eta_api/models/wx_user.go

package models

import (
	"eta_gn/eta_api/global"
	"time"
)

type WxUser struct {
	UserId              int64     `gorm:"column:user_id;primaryKey;type:bigint" orm:"column(user_id);pk" gorm:"primaryKey"  description:"用户ID"`
	Mobile              string    `gorm:"column:mobile;type:varchar(255)" orm:"column(mobile)" description:"手机号"`
	Email               string    `gorm:"column:email;type:varchar(255)" orm:"column(email)" description:"邮箱"`
	CompanyId           int       `gorm:"column:company_id;type:int" orm:"column(company_id)" description:"公司ID"`
	RealName            string    `gorm:"column:real_name;type:varchar(255)" orm:"column(real_name)" description:"姓名"`
	NickName            string    `gorm:"column:nick_name;type:varchar(255)" orm:"column(nick_name)" description:"昵称"`
	CreatedTime         time.Time `gorm:"column:created_time;type:datetime" orm:"column(created_time)" description:"创建时间"`
	MobileTwo           string    `gorm:"column:mobile_two;type:varchar(255)" orm:"column(mobile_two)" description:"备用手机号"`
	BusinessCardUrl     string    `gorm:"column:business_card_url;type:varchar(255)" orm:"column(business_card_url)" description:"名片"`
	IsMaker             int       `gorm:"column:is_maker;type:int" orm:"column(is_maker)" description:"是否决策人，1:是，0:否"`
	Position            string    `gorm:"column:position;type:varchar(255)" orm:"column(position)" description:"职位"`
	Sex                 int       `gorm:"column:sex;type:int" orm:"column(sex)" description:"普通用户性别，1为男性，2为女性"`
	DepartmentName      string    `gorm:"column:department_name;type:varchar(255)" orm:"column(department_name)" description:"联系人部门"`
	RegisterTime        time.Time `gorm:"column:register_time;type:datetime" orm:"column(register_time)" description:"注册时间"`
	RegisterPlatform    int       `gorm:"column:register_platform;type:int" orm:"column(register_platform)" description:"注册平台"`
	Remark              string    `gorm:"column:remark;type:varchar(255)" orm:"column(remark)" description:"备注"`
	CountryCode         string    `gorm:"column:country_code;type:varchar(255)" orm:"column(country_code)" description:"区号，86、852、886等"`
	OutboundMobile      string    `gorm:"column:outbound_mobile;type:varchar(255)" orm:"column(outbound_mobile)" description:"外呼手机号"`
	OutboundCountryCode string    `gorm:"column:outbound_country_code;type:varchar(255)" orm:"column(outbound_country_code)" description:"外呼手机号区号，86、852、886等"`
	LastUpdatedTime     time.Time `gorm:"column:last_updated_time;type:datetime" orm:"column(last_updated_time)" description:"最近一次更新时间"`
	IsDeal              int       `gorm:"column:is_deal;type:int" orm:"column(is_deal)" description:"是否标记处理 0-未处理 1-已处理"`
	OpenId              string    `gorm:"column:open_id;type:varchar(255)" orm:"column(open_id)" description:"微信openid"`
	Headimgurl          string    `gorm:"column:headimgurl;type:varchar(255)" orm:"column(headimgurl)" description:"用户头像"`
	UserLabel           string    `gorm:"column:user_label;type:varchar(255)" orm:"column(user_label)" description:"查研观向用户标签"`
}

func GetWxUserByMobile(mobile string) (item *WxUser, err error) {
	//o := orm.NewOrmUsingDB("weekly")
	sql := `SELECT * FROM wx_user WHERE mobile = ? LIMIT 1`
	//err = o.Raw(sql, mobile).QueryRow(&item)
	err = global.DmSQL["weekly"].Raw(sql, mobile).First(&item).Error
	return
}

// Update 更新wxUser信息
func (wxUser *WxUser) Update(cols []string) (err error) {
	//o := orm.NewOrmUsingDB("weekly")
	//_, err = o.Update(wxUser, cols...)
	err = global.DmSQL["weekly"].Select(cols).Updates(wxUser).Error
	return
}

// GetWxUserByCompanyIdAndMobile 根据客户ID及手机号获取用户
func GetWxUserByCompanyIdAndMobile(companyId int, mobile string) (item *WxUser, err error) {
	//o := orm.NewOrmUsingDB("weekly")
	sql := ` SELECT * FROM wx_user WHERE company_id = ? AND mobile = ? LIMIT 1 `
	//err = o.Raw(sql, companyId, mobile).QueryRow(&item)
	err = global.DmSQL["weekly"].Raw(sql, companyId, mobile).First(&item).Error
	return
}

// DeleteWxUserAndRecordByUserId 删除用户及第三方信息
func DeleteWxUserAndRecordByUserId(userId int) (err error) {
	//o := orm.NewOrmUsingDB("weekly")
	//to, err := o.Begin()
	to := global.DmSQL["weekly"].Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	// 删除wx_user
	userSql := ` DELETE FROM wx_user WHERE user_id = ? LIMIT 1 `
	//_, err = to.Raw(userSql, userId).Exec()
	err = to.Exec(userSql, userId).Error
	// 删除user_record
	if err == nil {
		recordSql := ` DELETE FROM user_record WHERE user_id = ? `
		//_, err = to.Raw(recordSql, userId).Exec()
		err = to.Exec(recordSql, userId).Error
	}

	return
}