邮箱同步处理

ent/entity/user.go

@@ -280,7 +280,7 @@ func (u *User) UpdateInfo(mail string, phone string, name string, userId, deptId
 	if isAdmin {
 		ok := Mysql.ExecTx("修改员工", func(tx *sql.Tx) bool {
 			ok_1 := Mysql.UpdateOrDeleteBySqlByTx(tx, `update entniche_user set mail=?,phone=?,name=?,timestamp=? where id=? and ent_id=?`, mail, phone, name, NowFormat(Date_Full_Layout), userId, entId)
-			Mgo_Bidding.Update("ent_user", map[string]interface{}{"i_entid": entId, "i_userid": userId}, map[string]interface{}{
+			MQFW.Update("ent_user", map[string]interface{}{"i_entid": entId, "i_userid": userId}, map[string]interface{}{
 				"$set": map[string]interface{}{
 					"o_pushset.s_email": mail,
 				},
@@ -302,7 +302,7 @@ func (u *User) UpdateInfo(mail string, phone string, name string, userId, deptId
 	} else {
 		return Mysql.ExecTx("修改员工", func(tx *sql.Tx) bool {
 			ok_1 := Mysql.UpdateOrDeleteBySqlByTx(tx, `update entniche_user set mail=?,phone=?,name=?,timestamp=? where id=? and ent_id=?`, mail, phone, name, NowFormat(Date_Full_Layout), userId, entId)
-			Mgo_Bidding.Update("ent_user", map[string]interface{}{"i_entid": entId, "i_userid": userId}, map[string]interface{}{
+			MQFW.Update("ent_user", map[string]interface{}{"i_entid": entId, "i_userid": userId}, map[string]interface{}{
 				"$set": map[string]interface{}{
 					"o_pushset.s_email": mail,
 				},