错误消息未显示问题修改

src/main/java/com/neotel/smfcore/core/device/bean/StatusBean.java

@@ -9,6 +9,7 @@ import com.neotel.smfcore.core.storage.enums.DeviceType;
 import com.neotel.smfcore.core.system.service.po.AlarmInfo;
 import lombok.Data;
 import lombok.ToString;
+import lombok.extern.slf4j.Slf4j;
 
 import java.util.*;
 
@@ -22,6 +23,7 @@ import java.util.*;
  */
 @ToString
 @Data
+@Slf4j
 public class StatusBean {
 
     /// <summary>
@@ -133,10 +135,10 @@ public class StatusBean {
      */
     public  List<MsgInfo> msgList;
 
-    /**
-     * 消息合并
-     */
-    public List<MsgInfo> mergeMsgList;
+//    /**
+//     * 消息合并
+//     */
+//    public List<MsgInfo> mergeMsgList;
 
     /**
      * 料仓类型
@@ -685,12 +687,12 @@ public class StatusBean {
     }
 
     public String getShowMsg(Locale locale) {
-        if (ObjectUtil.isEmpty(this.mergeMsgList)) {
+        if (ObjectUtil.isEmpty(this.msgList)) {
             return "";
         }
         String returnMsg = "";
         for (MsgInfo msg :
-                mergeMsgList) {
+                msgList) {
             String mMsg = GetMsgStr(msg,locale);
             if (ObjectUtil.isEmpty(returnMsg)) {
                 returnMsg = mMsg;
@@ -729,43 +731,46 @@ public class StatusBean {
         return resultMap;
     }
 
-
-    public List<MsgInfo>  MsgDataProcess() {
-        List<MsgInfo> mergeMsgList = new ArrayList<>();
-        if (msgList != null && !msgList.isEmpty()) {
-            mergeMsgList.addAll(msgList);
-        }
-        if (ObjectUtil.isNotEmpty(msg)) {
-            //判断是否有换行
-            String[] msgArray = this.msg.split("\r\n");
-            if (msgArray.length > 0) {
-                for (String msg :
-                        msgArray) {
-                    if (ObjectUtil.isEmpty(msg)) {
-                        continue;
-                    }
-                    String msgType = MessageType.ERROR.name();
-                    if (msg.startsWith("A=")) {
-                        msgType = MessageType.ERROR.name();
-                        msg = msg.substring(2);
-                    } else if (msg.startsWith("I=")) {
-                        msgType = MessageType.INFO.name();
-                        msg = msg.substring(2);
-                    } else if (msg.startsWith("W=")) {
-                        msgType = MessageType.WARNING.name();
-                        msg = msg.substring(2);
-                    }
-
-                    if (msgArray.length == 1) {
-                        mergeMsgList.add(new MsgInfo(msg, msgType, msgEn, msgJp, msgCode, msgParam, "", "",""));
-                    } else {
-                        mergeMsgList.add(new MsgInfo(msg, msgType));
+    public List<MsgInfo> MsgDataProcess() {
+
+        try {
+            //消息格式处理
+            if (getMsgList() == null && ObjectUtil.isNotEmpty(msg)) {
+                msgList = new ArrayList<>();
+                //判断是否有换行
+                String[] msgArray = this.msg.split("\r\n");
+                if (msgArray.length > 0) {
+                    for (String msg :
+                            msgArray) {
+                        if (ObjectUtil.isEmpty(msg)) {
+                            continue;
+                        }
+                        String msgType = MessageType.ERROR.name();
+                        if (msg.startsWith("A=")) {
+                            msgType = MessageType.ERROR.name();
+                            msg = msg.substring(2);
+                        } else if (msg.startsWith("I=")) {
+                            msgType = MessageType.INFO.name();
+                            msg = msg.substring(2);
+                        } else if (msg.startsWith("W=")) {
+                            msgType = MessageType.WARNING.name();
+                            msg = msg.substring(2);
+                        }
+
+                        if (msgArray.length == 1) {
+                            msgList.add(new MsgInfo(msg, msgType, msgEn, msgJp, msgCode, msgParam, "", "",""));
+                        } else {
+                            msgList.add(new MsgInfo(msg, msgType));
+                        }
                     }
                 }
+            } else if (getMsgList() == null) {
+                msgList = new ArrayList<>();
             }
+        } catch (Exception e) {
+            log.error("" + getCid() + "MsgDataProcess  出錯:" + e.toString(), e);
         }
-        setMergeMsgList(mergeMsgList);
-        return mergeMsgList;
+        return msgList;
     }
 
     public void setRMsg(String msgKey, String[] msgParam, String message) {

src/main/java/com/neotel/smfcore/core/device/handler/impl/BaseDeviceHandler.java

@@ -925,7 +925,7 @@ public class BaseDeviceHandler implements IDeviceHandler {
         statusBean.setOp(statusBeanToSave.getOp());
         statusBean.setSeq(statusBeanToSave.getSeq());
         statusBean.setClientIp(statusBeanToSave.getClientIp());
-        statusBean.setMergeMsgList(statusBeanToSave.getMergeMsgList());
+        statusBean.setMsgList(statusBeanToSave.getMsgList());
 
         /**
          * 已解除的报警信息存到数据库中

src/main/java/com/neotel/smfcore/core/system/util/DevicesStatusUtil.java

@@ -204,7 +204,7 @@ public class DevicesStatusUtil {
         StatusBean statusBean = new StatusBean();
         statusBean.setCid(cid);
         statusBean.setTime(System.currentTimeMillis());
-        //statusBean.setMsgList(msgs);
+        statusBean.setMsgList(msgs);
         clientMsgs.put(cid, statusBean);
         return statusBean;
     }