errorCode为空 不上抛

src/main/java/com/neotel/smfcore/custom/lizhen/kafka/service/KafkaService.java

@@ -130,6 +130,10 @@ public class KafkaService {
 
                 if (msgList != null && !msgList.isEmpty()) {
                     for (Map<String, String> map : msgList) {
+                        String errorCode = map.get("errorCode");
+                        if (StringUtils.isEmpty(errorCode)){
+                            continue;
+                        }
                         status.setErrorCode(map.get("errorCode"));
                         status.setErrorMsg(map.get("msg"));
                         status.setCurrentStatus("3");
@@ -331,10 +335,15 @@ public class KafkaService {
 
                 if (equipMsgList != null && !equipMsgList.isEmpty()) {
                     for (EquipMsg equipMsg : equipMsgList) {
+                        //如果errorCode为空,就不抛送
+                        String errorCode = equipMsg.getErrorCode();
+                        if (StringUtils.isEmpty(errorCode)){
+                            continue;
+                        }
                         MachineStatus machineStatus = new MachineStatus();
                         String dateStr = DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss.SSS");
                         machineStatus.setOccurrenceTime(dateStr);
-                        machineStatus.setMachineID(StorageExportConfig.getMachineId(module));
+                        machineStatus.setMachineID(module);
                         machineStatus.setTopicType(KafkaConfig.MACHINESTATUS_TOPIC);
                         machineStatus.setCurrentStatus(3+"");
                         machineStatus.setErrorCode(equipMsg.getErrorCode());