fix: 同步缓存

controllers/sys_admin.go

@@ -493,10 +493,12 @@ func (this *SysAdminController) Add() {
 	}
 
 	// 同步用户缓存
-	var syncData system.SyncAdminData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.AdminName = admin.AdminName
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncAdminData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.AdminName = admin.AdminName
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	}
 
 	err = services.UpdateResearcherTagGroup(admin.AdminId, req.ResearchGroupIds)
 	if err != nil {
@@ -695,10 +697,12 @@ func (this *SysAdminController) Edit() {
 	}
 
 	// 同步用户缓存
-	var syncData system.SyncAdminData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.AdminName = adminInfo.AdminName
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncAdminData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.AdminName = adminInfo.AdminName
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	}
 
 	// 用户登出
 	logOutSystemUser(adminInfo.AdminId)
@@ -767,10 +771,12 @@ func (this *SysAdminController) EditEnabled() {
 	}
 
 	// 同步用户缓存
-	var syncData system.SyncAdminData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.AdminName = adminItem.AdminName
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncAdminData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.AdminName = adminItem.AdminName
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	}
 
 	//用户被禁用的情况下，需要将他对应的token给过期
 	if adminItem.Enabled == 1 && req.Enabled == 0 {
@@ -829,10 +835,12 @@ func (this *SysAdminController) Delete() {
 	}
 
 	// 同步用户缓存
-	var syncData system.SyncAdminData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.AdminName = adminInfo.AdminName
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncAdminData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.AdminName = adminInfo.AdminName
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	}
 
 	// 删除手工数据关联用户
 	{
@@ -1070,10 +1078,12 @@ func (this *SysAdminController) Move() {
 	}
 
 	// 同步用户缓存
-	var syncData system.SyncAdminData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.AdminName = adminInfo.AdminName
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncAdminData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.AdminName = adminInfo.AdminName
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	}
 
 	// 清除系统用户列表缓存key
 	_ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN)
@@ -1155,10 +1165,12 @@ func (this *SysAdminController) ResetPass() {
 	}
 
 	// 同步用户缓存
-	var syncData system.SyncAdminData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.AdminName = adminInfo.AdminName
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncAdminData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.AdminName = adminInfo.AdminName
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ADMIN, syncData)
+	}
 
 	// 清除系统用户列表缓存key
 	_ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN)

controllers/sys_department.go

@@ -56,10 +56,12 @@ func (this *SysDepartmentController) Add() {
 	}
 
 	// 同步部门缓存
-	var syncData system.SyncDepartmentData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.DepartmentId = int(departmentId)
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_DEPARTMENT, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncDepartmentData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.DepartmentId = int(departmentId)
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_DEPARTMENT, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true
@@ -113,10 +115,12 @@ func (this *SysDepartmentController) Edit() {
 	}
 
 	// 同步部门缓存
-	var syncData system.SyncDepartmentData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.DepartmentId = req.DepartmentId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_DEPARTMENT, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncDepartmentData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.DepartmentId = req.DepartmentId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_DEPARTMENT, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true
@@ -154,10 +158,12 @@ func (this *SysDepartmentController) Delete() {
 	}
 
 	// 同步部门缓存
-	var syncData system.SyncDepartmentData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.DepartmentId = req.DepartmentId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_DEPARTMENT, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncDepartmentData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.DepartmentId = req.DepartmentId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_DEPARTMENT, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true

controllers/sys_group.go

@@ -62,10 +62,12 @@ func (this *SysGroupController) Add() {
 			}
 
 			// 同步分组缓存
-			var syncData system.SyncGroupData
-			syncData.Source = utils.SOURCE_ETA_FLAG
-			syncData.GroupId = int(groupId)
-			_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+			if utils.BusinessCode == utils.BusinessCodeRelease {
+				var syncData system.SyncGroupData
+				syncData.Source = utils.SOURCE_ETA_FLAG
+				syncData.GroupId = int(groupId)
+				_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+			}
 		}
 	}
 	br.Ret = 200
@@ -120,10 +122,12 @@ func (this *SysGroupController) Edit() {
 	}
 
 	// 同步分组缓存
-	var syncData system.SyncGroupData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.GroupId = req.GroupId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncGroupData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.GroupId = req.GroupId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true
@@ -167,10 +171,12 @@ func (this *SysGroupController) Delete() {
 	}
 
 	// 同步分组缓存
-	var syncData system.SyncGroupData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.GroupId = req.GroupId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncGroupData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.GroupId = req.GroupId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true
@@ -244,11 +250,13 @@ func (this *SysGroupController) SetSort() {
 			}
 
 			// 同步分组缓存
-			for _, g := range updateArr {
-				var syncData system.SyncGroupData
-				syncData.Source = utils.SOURCE_ETA_FLAG
-				syncData.GroupId = g.GroupId
-				_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+			if utils.BusinessCode == utils.BusinessCodeRelease {
+				for _, g := range updateArr {
+					var syncData system.SyncGroupData
+					syncData.Source = utils.SOURCE_ETA_FLAG
+					syncData.GroupId = g.GroupId
+					_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+				}
 			}
 		}
 	}

controllers/sys_role.go

@@ -2,12 +2,12 @@ package controllers
 
 import (
 	"encoding/json"
-	"fmt"
-	"github.com/rdlucklib/rdluck_tools/paging"
 	"eta/eta_api/models"
 	"eta/eta_api/models/system"
 	"eta/eta_api/services"
 	"eta/eta_api/utils"
+	"fmt"
+	"github.com/rdlucklib/rdluck_tools/paging"
 	"strconv"
 	"strings"
 	"time"
@@ -63,10 +63,12 @@ func (this *SysRoleController) Add() {
 	}
 
 	// 同步角色缓存
-	var syncData system.SyncRoleData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.RoleId = int(roleId)
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ROLE, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncRoleData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.RoleId = int(roleId)
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ROLE, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true
@@ -121,10 +123,12 @@ func (this *SysRoleController) Edit() {
 	}
 
 	// 同步角色缓存
-	var syncData system.SyncRoleData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.RoleId = item.RoleId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ROLE, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncRoleData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.RoleId = item.RoleId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ROLE, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true
@@ -175,10 +179,12 @@ func (this *SysRoleController) Delete() {
 	}
 
 	// 同步角色缓存
-	var syncData system.SyncRoleData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.RoleId = role.RoleId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_ROLE, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncRoleData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.RoleId = role.RoleId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_ROLE, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true

controllers/sys_team.go

@@ -63,10 +63,12 @@ func (this *SysTeamController) Add() {
 			}
 
 			// 同步分组缓存
-			var syncData system.SyncGroupData
-			syncData.Source = utils.SOURCE_ETA_FLAG
-			syncData.GroupId = int(groupId)
-			_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+			if utils.BusinessCode == utils.BusinessCodeRelease {
+				var syncData system.SyncGroupData
+				syncData.Source = utils.SOURCE_ETA_FLAG
+				syncData.GroupId = int(groupId)
+				_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+			}
 		}
 	}
 	br.Ret = 200
@@ -121,10 +123,12 @@ func (this *SysTeamController) Edit() {
 	}
 
 	// 同步分组缓存
-	var syncData system.SyncGroupData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.GroupId = item.GroupId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncGroupData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.GroupId = item.GroupId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true
@@ -168,10 +172,12 @@ func (this *SysTeamController) Delete() {
 	}
 
 	// 同步分组缓存
-	var syncData system.SyncGroupData
-	syncData.Source = utils.SOURCE_ETA_FLAG
-	syncData.GroupId = req.TeamId
-	_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	if utils.BusinessCode == utils.BusinessCodeRelease {
+		var syncData system.SyncGroupData
+		syncData.Source = utils.SOURCE_ETA_FLAG
+		syncData.GroupId = req.TeamId
+		_ = utils.Rc.LPush(utils.CACHE_SYNC_GROUP, syncData)
+	}
 
 	br.Ret = 200
 	br.Success = true

utils/constants.go

@@ -289,7 +289,6 @@ const (
 
 // 系统来源
 const (
-	SOURCE_CRM_FLAG = 1
 	SOURCE_ETA_FLAG = 2
 )