fix user relation

go/gopath/src/fohow.com/apps/controllers/cron_controller/three_user_relation.go

@@ -34,11 +34,24 @@ func threebUserRelation() {
 	//自公司账号自上而下递归更新
 	inviteList := user_model.GetInviteAllWxUsers(wxUserId, true)
 	UpdateClassThreeInner(inviteList, innerNo, wxUserId)
+
+	//回调更新wx_users
 	err = user_model.CallBackWxUsers()
 	if err != nil {
 		beego.BeeLogger.Error("UpdateClassThreeInner CallBackWxUsers err=[%s]", err)
 		return
 	}
+	//更新depart
+	departOneWxU := user_model.GetWxUserById(53, false)
+	departTwoWxU := user_model.GetWxUserById(13066, false)
+	if departOneWxU != nil && departTwoWxU != nil {
+		err = user_model.UpdateRelatedDepart(departOneWxU.IntroInnerNo, departTwoWxU.IntroInnerNo, departOneWxU.Depart, departTwoWxU.Depart)
+		if err != nil {
+			beego.BeeLogger.Error("UpdateClassThreeInner CallBackWxUsers err=[%s]", err)
+			return
+		}
+
+	}
 	//time.Sleep(time.Duration(300) * time.Second)
 }
 

go/gopath/src/fohow.com/apps/models/user_model/three_wx_user.go

@@ -204,6 +204,25 @@ func CopyWxUsers() error {
 		return err
 	}
 
+	//更新会员depart
+	sql = `
+		update wx_users set depart=1 where id=53
+	`
+	_, err = o.Raw(sql).Exec()
+	if err != nil {
+		beego.BeeLogger.Warn("ThreeWxUser.CopyWxUsers() update wx_users err[%s]", err)
+		return err
+	}
+
+	sql = `
+		update wx_users set depart=2 where id=13066
+	`
+	_, err = o.Raw(sql).Exec()
+	if err != nil {
+		beego.BeeLogger.Warn("ThreeWxUser.CopyWxUsers() update wx_users err[%s]", err)
+		return err
+	}
+
 	//迁移当前记录
 	sql = `
 		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 
@@ -232,6 +251,57 @@ func CallBackWxUsers() error {
 	return nil
 }
 
+//更新关联表depart
+func UpdateRelatedDepart(innerNo1, innerNo2 string, depart1, depart2 int64) error {
+	o := orm.NewOrm()
+	//更新1部会员
+
+	sql := fmt.Sprintf("update wx_users set depart=? where intro_inner_no like  %s", "'%"+innerNo1+"%'")
+	_, err := o.Raw(sql, depart1).Exec()
+	if err != nil {
+		beego.BeeLogger.Warn("ThreeWxUser.UpdateRelatedDepart() update wx_users err[%s]", err)
+		return err
+	}
+	//更新2部会员
+	sql1 := fmt.Sprintf("update wx_users set depart=? where intro_inner_no like  %s", "'%"+innerNo2+"%'")
+	_, err = o.Raw(sql1, depart2).Exec()
+	if err != nil {
+		beego.BeeLogger.Warn("ThreeWxUser.UpdateRelatedDepart() update wx_users err[%s]", err)
+		return err
+	}
+	//更新订单表
+	sql_or := `
+		update orders a , wx_users b set a.depart=b.depart where a.wx_user_id=b.id 
+	`
+	_, err = o.Raw(sql_or).Exec()
+	if err != nil {
+		beego.BeeLogger.Warn("ThreeWxUser.UpdateRelatedDepart() update wx_users err[%s]", err)
+		return err
+	}
+
+	//更新店长申请表
+	sql_shop := `
+		update shop_applications a , wx_users b set a.depart=b.depart where a.wx_user_id=b.id 
+	`
+	_, err = o.Raw(sql_shop).Exec()
+	if err != nil {
+		beego.BeeLogger.Warn("ThreeWxUser.UpdateRelatedDepart() update wx_users err[%s]", err)
+		return err
+	}
+
+	//更新充值提货券
+	sql_balance := `
+		update balance_orders a , wx_users b set a.depart=b.depart where a.wx_user_id=b.id 
+	`
+	_, err = o.Raw(sql_balance).Exec()
+	if err != nil {
+		beego.BeeLogger.Warn("ThreeWxUser.UpdateRelatedDepart() update wx_users err[%s]", err)
+		return err
+	}
+
+	return nil
+}
+
 //获取团队成员内部编号
 func NewAvailableIntroArea(inviteRank int64) string {
 	//确定首字母