数字预案绑定资源删除信息同步

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/mapper/EquipmentSpecificMapper.java

@@ -8,6 +8,7 @@ import com.yeejoin.amos.fas.business.vo.EquipmentSpecificVo;
 import com.yeejoin.amos.fas.dao.entity.EquipmentSpecific;
 import com.yeejoin.amos.fas.dao.entity.FmeaEquipmentPoint;
 import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
 
 import java.util.List;
 import java.util.Map;
@@ -18,6 +19,7 @@ import java.util.Map;
  * @author zjw
  * @date 2020-11-04
  */
+@Repository
 public interface EquipmentSpecificMapper extends BaseMapper<EquipmentSpecificVo> {
 
     Long saveBatch(List<FmeaEquipmentPoint> list);

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

@@ -576,9 +576,9 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
             emqKeeper.getMqttClient().subscribe(DELETE_SYNC_PLAN_RULE, (s, mqttMessage) -> {
                 byte[] payload = mqttMessage.getPayload();
                 try {
-                    List<String> ids = (List<String>) ClazzUtils.deserializableObject(payload);
+                    String[] ids = new String(payload).split(",");
                     if (!ValidationUtil.isEmpty(ids)) {
-                        planRuleMapper.logicDeleteByRuleIdList(ids);
+                        planRuleMapper.logicDeleteByRuleIdList(Arrays.asList(ids));
                     }
                 } catch (Exception e) {
                     logger.error("预案规则删除同步出错", e);