fix user relation

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

@@ -33,16 +33,11 @@ func threebUserRelation() {
 	beego.BeeLogger.Warn("----------------end handle relation ")
 
 	//更新depart
-	/*departOneWxU := user_model.GetWxUserById(53, false)
+	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
-		}
-
-	}*/
+		user_model.UpdateRelatedDepart(departOneWxU.IntroInnerNo, departTwoWxU.IntroInnerNo, departOneWxU.Depart, departTwoWxU.Depart)
+	}
 	//time.Sleep(time.Duration(300) * time.Second)
 }
 

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

@@ -247,54 +247,35 @@ func CallBackWxUsers() {
 }
 
 //更新关联表depart
-func UpdateRelatedDepart(innerNo1, innerNo2 string, depart1, depart2 int64) error {
+func UpdateRelatedDepart(innerNo1, innerNo2 string, depart1, depart2 int64) {
 	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
-	}
+	o.Raw(sql, depart1).Exec()
+
 	//更新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
-	}
+	o.Raw(sql1, depart2).Exec()
+
 	//更新订单表
 	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
-	}
+	o.Raw(sql_or).Exec()
 
 	//更新店长申请表
 	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
-	}
+	o.Raw(sql_shop).Exec()
 
 	//更新充值提货券
 	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
-	}
+	o.Raw(sql_balance).Exec()
 
-	return nil
 }
 
 //获取团队成员内部编号