fix 同步值班客服、群发客服key

netflix-common/src/main/java/com/cyksj/common/constant/Constant.java

@@ -146,6 +146,8 @@ public interface Constant {
 
 	String CORP_SERVICE_FOLLOWS_KEY = "corp_service_follows_key";
 
+	String CORP_SERVICE_GROUPS_RELATION_FOLLOWS_KEY = "corp_service_groups_relation_follows_key";
+
 	String NEW_USER_WELFARE_KEY = "new_user_welfare_key";
 
 	/**

netflix-service/src/main/java/com/cyksj/service/sys/impl/SysCorpFollowServiceImpl.java

@@ -1,5 +1,6 @@
 package com.cyksj.service.sys.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -21,6 +22,7 @@ import org.springframework.stereotype.Service;
 
 import java.util.List;
 import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.stream.Collectors;
 
 /**
  * 项目名: yhlxj
@@ -69,6 +71,35 @@ public class SysCorpFollowServiceImpl extends ServiceImpl<SysCorpFollowMapper, S
 			//更新客服图片
 			updateCorpFollowImg(sysCorpFollowRelate, req.getName());
 		}
+		//同步企业客服key
+		syncSysCorpUserKey();
+	}
+
+	private void syncSysCorpUserKey() {
+		//客服群发key
+		SysConfig corpSendMsg = sysConfigMapper.selectOne(Wrappers.lambdaQuery(SysConfig.class)
+				.eq(SysConfig::getSysKey, Constant.CORP_SERVICE_FOLLOWS_KEY).last("limit 1"));
+
+		//客服跟进续费key
+		SysConfig corpDutyServices = sysConfigMapper.selectOne(Wrappers.lambdaQuery(SysConfig.class)
+				.eq(SysConfig::getSysKey, Constant.CORP_SERVICE_GROUPS_RELATION_FOLLOWS_KEY).last("limit 1"));
+
+		//获取目前可用值班客服
+		List<SysCorpFollowRelate> sysCorpFollowRelates = sysCorpFollowRelateMapper.selectList(Wrappers.lambdaQuery(SysCorpFollowRelate.class)
+				.eq(SysCorpFollowRelate::getStatus, 1)
+				.eq(SysCorpFollowRelate::getDeleted, 1));
+		List<String> followIds = sysCorpFollowRelates.stream().map(SysCorpFollowRelate::getFollowId).collect(Collectors.toList());
+		if (CollUtil.isNotEmpty(followIds)) {
+			try {
+				String followIdsStr = Jsons.toJson(followIds);
+				corpSendMsg.setSysValue(followIdsStr);
+				sysConfigMapper.updateById(corpSendMsg);
+
+				corpDutyServices.setSysValue(followIdsStr);
+				sysConfigMapper.updateById(corpDutyServices);
+			} catch (Exception e) {
+			}
+		}
 	}
 
 	@Override