同步角色用户缓存

controllers/sys_admin.go

@@ -536,6 +536,10 @@ func (this *SysAdminController) Add() {
 		br.ErrMsg = "新增失败，Err:" + err.Error()
 		return
 	}
+
+	// 同步用户缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_USER_FROM_CRM, admin.AdminName)
+
 	//err = services.UpdateAdminResearchGroup(admin.AdminId, req.ResearchGroupIds)
 	err = services.UpdateResearcherTagGroup(admin.AdminId, req.ResearchGroupIds)
 	if err != nil {
@@ -761,6 +765,9 @@ func (this *SysAdminController) Edit() {
 		return
 	}
 
+	// 同步用户缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_USER_FROM_CRM, adminInfo.AdminName)
+
 	// 用户登出
 	logOutSystemUser(adminInfo.AdminId)
 
@@ -827,6 +834,9 @@ func (this *SysAdminController) EditEnabled() {
 		}
 	}
 
+	// 同步用户缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_USER_FROM_CRM, adminItem.AdminName)
+
 	//用户被禁用的情况下，需要将他对应的token给过期
 	if adminItem.Enabled == 1 && req.Enabled == 0 {
 		logOutSystemUser(adminItem.AdminId)
@@ -883,6 +893,9 @@ func (this *SysAdminController) Delete() {
 		return
 	}
 
+	// 同步用户缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_USER_FROM_CRM, adminInfo.AdminName)
+
 	// 删除手工数据关联用户
 	{
 		go data_manage.DeleteManualUser(req.AdminId)
@@ -1132,6 +1145,9 @@ func (this *SysAdminController) Move() {
 		}
 	}
 
+	// 同步用户缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_USER_FROM_CRM, adminInfo.AdminName)
+
 	// 清除系统用户列表缓存key
 	_ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN)
 	_ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN_ID)

controllers/sys_role.go

@@ -61,6 +61,10 @@ func (this *SysRoleController) Add() {
 		br.ErrMsg = "新增失败，Err:" + err.Error()
 		return
 	}
+
+	// 同步角色缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_ROLE_FROM_CRM, item.RoleName)
+
 	br.Ret = 200
 	br.Success = true
 	br.Msg = "新增成功"
@@ -112,6 +116,10 @@ func (this *SysRoleController) Edit() {
 		br.ErrMsg = "修改失败，Err:" + err.Error()
 		return
 	}
+
+	// 同步角色缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_ROLE_FROM_CRM, item.RoleName)
+
 	br.Ret = 200
 	br.Success = true
 	br.IsAddLog = true
@@ -141,12 +149,28 @@ func (this *SysRoleController) Delete() {
 		br.ErrMsg = "参数错误,GroupId 小于等于0 "
 		return
 	}
+
+	role, e := system.GetSysRoleById(req.RoleId)
+	if e != nil {
+		if err.Error() == utils.ErrNoRow() {
+			br.Msg = "角色不存在, 请刷新页面"
+			return
+		}
+		br.Msg = "删除失败"
+		br.ErrMsg = "获取角色信息失败, Err: " + e.Error()
+		return
+	}
+
 	err = system.DeleteSysRole(req.RoleId)
 	if err != nil {
 		br.Msg = "删除失败"
 		br.ErrMsg = "删除失败，Err:" + err.Error()
 		return
 	}
+
+	// 同步角色缓存
+	_ = utils.Rc.LPush(utils.CACHE_SYNC_SYS_ROLE_FROM_CRM, role.RoleName)
+
 	br.Ret = 200
 	br.Success = true
 	br.IsAddLog = true

utils/constants.go

@@ -289,6 +289,8 @@ const (
 	CACHE_KEY_DAYNEW_REFRESH          = "admin:day_new:refresh"               //每日资讯拉取企业微信聊天记录
 	CACHE_KEY_DAYNEW_TRANSLATE        = "admin:day_new:translate"             //每日资讯中翻英
 	CACHE_KEY_ADMIN_OPERATE_RECORD    = "HZ_ADMIN_CACHE_ADMIN_OPERATE_RECORD" //系统用户操作日志队列
+	CACHE_SYNC_SYS_USER_FROM_CRM      = "hz_crm_eta:crm_admin_sync"           // 同步用户的缓存队列key
+	CACHE_SYNC_SYS_ROLE_FROM_CRM      = "hz_crm_eta:crm_role_sync"            // 同步角色的缓存队列key
 )
 
 // 模板消息推送类型