item:剔除区域数据同步冗余

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/RiskSourceServiceImpl.java

@@ -24,7 +24,6 @@ import com.yeejoin.amos.fas.business.param.CommonPageInfoParam;
 import com.yeejoin.amos.fas.business.param.FmeaBindParam;
 import com.yeejoin.amos.fas.business.service.intfc.*;
 import com.yeejoin.amos.fas.business.service.model.ContingencyDeviceStatus;
-import com.yeejoin.amos.fas.business.util.DataSyncUtil;
 import com.yeejoin.amos.fas.business.util.DateUtils;
 import com.yeejoin.amos.fas.business.util.JexlUtil;
 import com.yeejoin.amos.fas.business.util.RpnUtils;
@@ -187,9 +186,6 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
     @Autowired
     private PlanDetailMapper planDetailMapper;
 
-    @Autowired
-    private DataSyncUtil dataSyncUtil;
-
     public static String cacheKeyForCanBeRunning() {
         return Redis.genKey(CacheType.ERASABLE.name(), "CONTINGENCYRUNING");
     }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/View3dServiceImpl.java

@@ -21,7 +21,6 @@ import com.yeejoin.amos.fas.business.feign.IDutyModeServer;
 import com.yeejoin.amos.fas.business.feign.RemoteSecurityService;
 import com.yeejoin.amos.fas.business.service.intfc.IDataRefreshService;
 import com.yeejoin.amos.fas.business.service.intfc.IView3dService;
-import com.yeejoin.amos.fas.business.util.DataSyncUtil;
 import com.yeejoin.amos.fas.business.vo.*;
 import com.yeejoin.amos.fas.common.enums.*;
 import com.yeejoin.amos.fas.core.common.request.CommonPageable;
@@ -99,9 +98,6 @@ public class View3dServiceImpl implements IView3dService {
     @Autowired
     private RemoteSecurityService remoteSecurityService;
 
-    @Autowired
-    private DataSyncUtil dataSyncUtil;
-
     @Override
     @Transactional(rollbackFor = Exception.class)
     public CommonResponse setPoint3dPosition(List<BindPointBo> pointBoList) {

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/util/DataSyncUtil.java

-package com.yeejoin.amos.fas.business.util;
-
-import com.yeejoin.amos.fas.business.action.mq.WebMqttComponent;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.stereotype.Component;
-
-/**
- * @ProjectName: YeeAmosFireAutoSysRoot
- * @Package: com.yeejoin.amos.fas.business.util
- * @ClassName: DataSyncUtil
- * @Author: Jianqiang Gao
- * @Description: 数据同步工具类
- * @Date: 2021/3/24 15:31
- * @Version: 1.0
- */
-@Component
-public class DataSyncUtil {
-
-    @Autowired
-    private RedisTemplate redisTemplate;
-
-    @Autowired
-    private WebMqttComponent webMqttComponent;
-
-    public void astDataSync(String topic, String message) {
-        redisTemplate.opsForValue().set(topic, message);
-        webMqttComponent.publish(topic.substring(0, topic.lastIndexOf("_")), message);
-    }
-
-}
\ No newline at end of file