同步社区配置

controllers/sys_admin.go

@@ -8,6 +8,7 @@ import (
 	"eta/eta_api/models/data_manage"
 	"eta/eta_api/models/system"
 	"eta/eta_api/services"
+	"eta/eta_api/services/eta_forum"
 	etaTrialService "eta/eta_api/services/eta_trial"
 	"eta/eta_api/utils"
 	"fmt"
@@ -581,7 +582,7 @@ func (this *SysAdminController) Add() {
 
 	// 新增弘则联系人
 	//go services.AddHzCompanyUser(admin.Mobile, admin.RealName, this.SysUser.AdminId, this.SysUser.RealName)
-
+	go eta_forum.AdminSave(admin.AdminId)
 	br.Ret = 200
 	br.Success = true
 	br.Msg = "新增成功"
@@ -798,6 +799,7 @@ func (this *SysAdminController) Edit() {
 		}()
 	}
 
+	go eta_forum.AdminSave(adminInfo.AdminId)
 	br.Ret = 200
 	br.Success = true
 	br.IsAddLog = true
@@ -880,6 +882,7 @@ func (this *SysAdminController) EditEnabled() {
 		br.ErrMsg = "操作失败，Err:" + err.Error()
 		return
 	}
+	go eta_forum.AdminSave(adminItem.AdminId)
 	br.Ret = 200
 	br.Success = true
 	br.IsAddLog = true
@@ -949,7 +952,7 @@ func (this *SysAdminController) Delete() {
 			_, _ = etaTrialService.RemoveEtaTrialUser(r)
 		}()
 	}
-
+	go eta_forum.AdminDelete(adminInfo.AdminName)
 	br.Ret = 200
 	br.Success = true
 	br.IsAddLog = true

services/eta_forum/eta_forum_hub.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"eta/eta_api/models/data_manage"
 	"eta/eta_api/models/data_manage/chart_theme"
+	"eta/eta_api/models/system"
 	"eta/eta_api/utils"
 	"fmt"
 )
@@ -370,3 +371,73 @@ func DeleteChart(chartInfoId int) (err error, errMsg string) {
 
 	return
 }
+
+type AdminSaveReq struct {
+	*system.Admin
+	BusinessCode string `description:"商家编码"`
+}
+
+// 上传管理员信息
+func AdminSave(adminId int) (err error) {
+	if utils.BusinessCode == "" || (utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeDebug && utils.BusinessCode != utils.BusinessCodeSandbox) {
+		return
+	}
+	//查询用户信息
+	adminInfo, err := system.GetSysAdminById(adminId)
+	if err != nil {
+		if err.Error() == utils.ErrNoRow() {
+			err = fmt.Errorf("用户不存在")
+			return
+		}
+		err = fmt.Errorf("获取用户信息失败,Err:" + err.Error())
+		return
+	}
+	var req AdminSaveReq
+	req.Admin = adminInfo
+	req.BusinessCode = utils.BusinessCode
+	reqJson, err := json.Marshal(req)
+	if err != nil {
+		err = fmt.Errorf("参数解析异常,Err:" + err.Error())
+		return
+	}
+	respItem, err := AdminSaveLib(string(reqJson))
+	if err != nil {
+		err = fmt.Errorf("上传管理员信息失败,Err:" + err.Error())
+		return
+	}
+	if respItem.Ret != 200 {
+		err = fmt.Errorf("上传管理员信息失败,Err:%v,errMsg:%v", respItem.Msg, respItem.ErrMsg)
+		return
+	}
+	return
+}
+
+type AdminDeleteReq struct {
+	AdminName    string
+	BusinessCode string `description:"商家编码"`
+}
+
+// 上传管理员信息
+func AdminDelete(adminName string) (err error) {
+	if utils.BusinessCode == "" || (utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeDebug && utils.BusinessCode != utils.BusinessCodeSandbox) {
+		return
+	}
+	var req AdminDeleteReq
+	req.AdminName = adminName
+	req.BusinessCode = utils.BusinessCode
+	reqJson, err := json.Marshal(req)
+	if err != nil {
+		err = fmt.Errorf("参数解析异常,Err:" + err.Error())
+		return
+	}
+	respItem, err := AdminDeleteLib(string(reqJson))
+	if err != nil {
+		err = fmt.Errorf("删除管理员信息失败,Err:" + err.Error())
+		return
+	}
+	if respItem.Ret != 200 {
+		err = fmt.Errorf("删除管理员信息失败,Err:%v,errMsg:%v", respItem.Msg, respItem.ErrMsg)
+		return
+	}
+	return
+}

services/eta_forum/eta_forum_hub_lib.go

@@ -40,6 +40,26 @@ func ChartDeleteLib(req string) (resp *models.BaseResponse, err error) {
 	return
 }
 
+// AdminSaveLib 上传管理员信息
+func AdminSaveLib(req string) (resp *models.BaseResponse, err error) {
+	_, resultByte, err := post(req, "/v1/admin/save")
+	err = json.Unmarshal(resultByte, &resp)
+	if err != nil {
+		return
+	}
+	return
+}
+
+// AdminDeleteLib 删除管理员信息
+func AdminDeleteLib(req string) (resp *models.BaseResponse, err error) {
+	_, resultByte, err := post(req, "/v1/admin/delete")
+	err = json.Unmarshal(resultByte, &resp)
+	if err != nil {
+		return
+	}
+	return
+}
+
 // post
 func post(paramStr string, urlStr string) (resp *models.BaseResponse, result []byte, err error) {
 	if utils.ETA_FORUM_HUB_URL == "" {