appId映射修改

yangys

2024-10-24 16f093ea132a823e255f446c225ce6b63fdb9eeb

 collect/src/main/java/com/qianwen/mdc/collect/config/MqttConfig.java

@@ -24,7 +24,6 @@
import com.alibaba.fastjson.JSONObject;
import com.qianwen.mdc.collect.service.DeviceStateFixPointService;
import com.qianwen.mdc.collect.service.IOTMqttReceiveService;
import com.qianwen.mdc.collect.service.WorkstationAppMappingService;
import com.qianwen.mdc.collect.service.WorkstationDatapointsService;
import com.qianwen.mdc.collect.service.feedback.WorkstationFeedbackService;

@@ -48,8 +47,6 @@
    private DeviceStateFixPointService stateFixPointService;
   @Autowired
    private WorkstationFeedbackService workstationFeedbackService;
   @Autowired
    private WorkstationAppMappingService workstationAppMappingService;
   
   @Autowired
    private WorkstationDatapointsService dpService;
@@ -134,11 +131,10 @@
           }else if(WORKSTATION_DATAPOINT_CHANGED_TOPIC.equals(topic)) {
              String payload = (String)message.getPayload();
              logger.info("工位appId映射变化消息={}",payload);
              workstationAppMappingService.saveToCache();
              //workstationAppMappingService.saveToCache();
              //清除该工位的数据点缓存
              JSONObject payloadObj = JSONObject.parseObject(payload);
              //payloadObj.getLong("workstationId");
        		
              dpService.datapointsCacheEvict(payloadObj.getString("appId"));
           } else {//订阅了几个topic就会接收到几个，其他的不会进来
              logger.warn("topic={},msg={},无对应的处理器",topic,message.getPayload());