|
@@ -193,9 +193,20 @@ func (self *ThreeWxUser) CopyWxUsers() error {
|
|
|
beego.BeeLogger.Warn("ThreeWxUser.CopyWxUsers() err[%s]", err)
|
|
beego.BeeLogger.Warn("ThreeWxUser.CopyWxUsers() err[%s]", err)
|
|
|
return err
|
|
return err
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ //更新invite_id丢失会员
|
|
|
|
|
+ sql = `
|
|
|
|
|
+ update wx_users set invite_id=1 where invite_id=0
|
|
|
|
|
+ `
|
|
|
|
|
+ _, err = o.Raw(sql).Exec()
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ beego.BeeLogger.Warn("ThreeWxUser.CopyWxUsers() update wx_users err[%s]", err)
|
|
|
|
|
+ return err
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
//迁移当前记录
|
|
//迁移当前记录
|
|
|
sql = `
|
|
sql = `
|
|
|
- insert into three_wx_users select * from wx_users
|
|
|
|
|
|
|
+ insert into three_wx_users (id,invite_id,intro_inner_no,intro_area) select id,invite_id,intro_inner_no,intro_area from wx_users
|
|
|
`
|
|
`
|
|
|
_, err = o.Raw(sql, self.Id).Exec()
|
|
_, err = o.Raw(sql, self.Id).Exec()
|
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -205,6 +216,23 @@ func (self *ThreeWxUser) CopyWxUsers() error {
|
|
|
return nil
|
|
return nil
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+//回写wx_users
|
|
|
|
|
+func (self *ThreeWxUser) CallBackWxUsers() error {
|
|
|
|
|
+ o := orm.NewOrm()
|
|
|
|
|
+
|
|
|
|
|
+ //更新invite_id丢失会员
|
|
|
|
|
+ sql := `
|
|
|
|
|
+ update wx_users a , three_wx_users b set a.intro_inner_no=b.intro_inner_no,a.intro_area=b.intro_area where a.id=b.id
|
|
|
|
|
+ `
|
|
|
|
|
+ _, err := o.Raw(sql).Exec()
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ beego.BeeLogger.Warn("ThreeWxUser.CallWxUsers() update wx_users err[%s]", err)
|
|
|
|
|
+ return err
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ return nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
//获取团队成员内部编号
|
|
//获取团队成员内部编号
|
|
|
func NewAvailableIntroArea(inviteRank int64) string {
|
|
func NewAvailableIntroArea(inviteRank int64) string {
|
|
|
//确定首字母
|
|
//确定首字母
|