feat:完善手机号修改

@@ -78,8 +78,8 @@ type ImportEmployeeData struct {
 
 
 // ChangePhoneData 修改手机号
 // ChangePhoneData 修改手机号
 type ChangePhoneData struct {
 type ChangePhoneData struct {
-	OldPhone string `json:"oldPhone"`
-	NewPhone string `json:"newPhone"`
+	OldPhone string `json:"old_phone"`
+	NewPhone string `json:"new_phone"`
 }
 }
 
 
 //SyncEmployeeService 同步用户数据
 //SyncEmployeeService 同步用户数据
@@ -150,7 +150,7 @@ func (service SyncEmployeeService) DoAction(action string, byteData []byte) erro
 	// case "batchRemove":
 	// case "batchRemove":
 	// 	//移动通讯录用户部门 暂时不需要
 	// 	//移动通讯录用户部门 暂时不需要
 	// 	return nil
 	// 	return nil
-	case "changePhone": // TODO 修改手机号
+	case "changePhoneAllCompany": // TODO 修改手机号
 		// 修改手机号
 		// 修改手机号
 		var (
 		var (
 			err  error
 			err  error
@@ -445,7 +445,7 @@ func (service SyncEmployeeService) updateUsersStatus(data ForbidAllowUserData) e
 	return err
 	return err
 }
 }
 
 
-// ChangePhone 修改手机号
+// ChangePhone TODO 修改手机号
 func (service SyncEmployeeService) changePhone(data ChangePhoneData) error {
 func (service SyncEmployeeService) changePhone(data ChangePhoneData) error {
 	var (
 	var (
 		transactionContext, _ = factory.CreateTransactionContext(nil)
 		transactionContext, _ = factory.CreateTransactionContext(nil)
@@ -457,15 +457,31 @@ func (service SyncEmployeeService) changePhone(data ChangePhoneData) error {
 	defer func() {
 	defer func() {
 		_ = transactionContext.RollbackTransaction()
 		_ = transactionContext.RollbackTransaction()
 	}()
 	}()
+
 	var uDao *dao.UsersDao
 	var uDao *dao.UsersDao
 	if uDao, err = factory.CreateUsersDao(map[string]interface{}{
 	if uDao, err = factory.CreateUsersDao(map[string]interface{}{
 		"transactionContext": transactionContext,
 		"transactionContext": transactionContext,
 	}); err != nil {
 	}); err != nil {
 		return lib.ThrowError(lib.INTERNAL_SERVER_ERROR, err.Error())
 		return lib.ThrowError(lib.INTERNAL_SERVER_ERROR, err.Error())
 	}
 	}
+
+	var pDao *dao.PartnerInfoDao
+	if pDao, err = factory.CreatePartnerInfoDao(map[string]interface{}{
+		"transactionContext": transactionContext,
+	}); err != nil {
+		return lib.ThrowError(lib.INTERNAL_SERVER_ERROR, err.Error())
+	}
+
+	// 更新高管手机号
 	if err = uDao.UpdateUserPhone(data.OldPhone, data.NewPhone); err != nil {
 	if err = uDao.UpdateUserPhone(data.OldPhone, data.NewPhone); err != nil {
 		return lib.ThrowError(lib.INTERNAL_SERVER_ERROR, err.Error())
 		return lib.ThrowError(lib.INTERNAL_SERVER_ERROR, err.Error())
 	}
 	}
+
+	// 更新合伙人手机号
+	if err = pDao.UpdatePartnerPhone(data.OldPhone, data.NewPhone); err != nil {
+		return lib.ThrowError(lib.INTERNAL_SERVER_ERROR, err.Error())
+	}
+
 	err = transactionContext.CommitTransaction()
 	err = transactionContext.CommitTransaction()
 	return err
 	return err
 }
 }

@@ -31,6 +31,17 @@ func (dao PartnerInfoDao) PartnerAccountExist(account string, companyId int64) (
 	return ok, err
 	return ok, err
 }
 }
 
 
+// UpdatePartnerPhone 更新合伙人手机号
+func (dao PartnerInfoDao) UpdatePartnerPhone(oldPhone string, newPhone string) error {
+	tx := dao.transactionContext.PgDd
+	m := &models.PartnerInfo{}
+	_, err := tx.Model(m).
+		Where("account=?", oldPhone).
+		Set("account=?", newPhone).
+		Update()
+	return err
+}
+
 func (dao PartnerInfoDao) UpdatePartnerStatus(ids []int64, companyId int64, status int) error {
 func (dao PartnerInfoDao) UpdatePartnerStatus(ids []int64, companyId int64, status int) error {
 	tx := dao.transactionContext.PgDd
 	tx := dao.transactionContext.PgDd
 	m := &models.PartnerInfo{}
 	m := &models.PartnerInfo{}

@@ -8,6 +8,8 @@ import (
 //外部调用,企业平台，总后台调用
 //外部调用,企业平台，总后台调用
 func init() {
 func init() {
 	nsPlatform := beego.NewNamespace("/platform",
 	nsPlatform := beego.NewNamespace("/platform",
+		// TODO 增加修改手机号动作
+		beego.NSRouter("/api/business/index", &controllers.SyncDataController{}, "Post:SyncData"),
 		//同步企业相关数据
 		//同步企业相关数据
 		beego.NSRouter("/action", &controllers.SyncDataController{}, "post:SyncData"),
 		beego.NSRouter("/action", &controllers.SyncDataController{}, "post:SyncData"),
 		//更换公司管理员
 		//更换公司管理员