package service

import "kpt.notice/apiserver/model"

func (svc *Service) InsertUser(phone, openid string) (err error) {
	sql := `insert user (openid,phone) values(?,?) ON DUPLICATE KEY UPDATE phone=? `
	return svc.DB.Exec(sql, openid, phone, phone).Error
}

func (svc *Service) QueryOpenid(phones []string) (users []model.User, err error) {

	err = svc.DB.Where("phone in ?", phones).Find(&users).Error
	return
}