package com.ld.igds.protocol.fzzy.analysis; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import com.ld.igds.common.CoreSerService; import com.ld.igds.constant.BizType; import com.ld.igds.io.notify.NotifyWebInvoker; import com.ld.igds.io.constant.OrderRespEnum; import com.ld.igds.models.DeviceSer; import com.ld.igds.protocol.fzzy.ServerUtils; import com.ld.igds.protocol.fzzy.dto.ReMessage; /** * 协议解析总入口 */ @Slf4j @Component(AnalysisService.BEAN_ID) public class AnalysisService { public static final String BEAN_ID = "fzzy.analysisService"; @Autowired private CoreSerService coreSerService; @Autowired private AnalysisGrain analysisGrain; @Autowired private AnalysisDevice analysisDevice; @Autowired private AnalysisGas analysisGas; @Autowired private AnalysisEs analysisEs; @Autowired private AnalysisSystem analysisSystem; @Autowired private AnalysisPest analysisPest; @Autowired private AnalysisN2 analysisN2; @Autowired private AnalysisTemp analysisTemp; @Autowired private AnalysisIot analysisIot; @Autowired private NotifyWebInvoker notifyWebInvoker; /** * 协议解析入口 * * @param message 返回信息 */ public void analysis(ReMessage message) { try { if (null == message) return; //登录解析 if (ServerUtils.FUNCTION_1001.equals(message.getFunctionId())) { analysisSystem.analysis1001(message); return; } String checkMsg = checkMsg(message); if (null != checkMsg) { log.warn("控制柜------>>>平台：当前组织编码={}，分机ID={}，报文信息-={}，响应吗返回不正确，无法进行解析," + checkMsg, message.getCompanyId(), message.getIedId(), message.getStrMsg()); notifyWebInvoker.notifyWeb(message.getCompanyId(), OrderRespEnum.MSG_ERROR, BizType.SYS, checkMsg); return; } DeviceSer ser = coreSerService.getCacheSer(message.getCompanyId(), message.getIedId()); if (null == ser) { log.warn("控制柜------>>>平台：当前组织编码={}，分机ID={}，系统没有获取到分机信息，报文无法进行解析", message.getCompanyId(), message.getIedId()); return; } //根据接口编号进行解析路由 switch (message.getFunctionId()) { case ServerUtils.FUNCTION_1003: analysisSystem.analysis1003(message, ser); break; case ServerUtils.FUNCTION_1004: analysisSystem.analysis1004(message, ser); break; case ServerUtils.FUNCTION_1005: analysisSystem.analysis1005(message, ser); break; case ServerUtils.FUNCTION_1006: analysisSystem.analysis1006(message, ser); break; case ServerUtils.FUNCTION_1007: analysisSystem.analysis1007(message, ser); break; case ServerUtils.FUNCTION_1008: analysisSystem.analysis1008(message, ser); break; case ServerUtils.FUNCTION_1009: analysisSystem.analysis1009(message, ser); break; case ServerUtils.FUNCTION_1010: analysisSystem.analysis1010(message, ser); break; case ServerUtils.FUNCTION_2101: analysisGrain.analysis2101(message, ser); break; case ServerUtils.FUNCTION_2102: analysisGrain.analysis2102(message, ser); break; case ServerUtils.FUNCTION_2201: analysisPest.analysis2201(message, ser); break; case ServerUtils.FUNCTION_2202: analysisPest.analysis2202(message, ser); break; case ServerUtils.FUNCTION_2203: analysisPest.analysis2203(message, ser); break; case ServerUtils.FUNCTION_2204: analysisPest.analysis2204(message, ser); break; case ServerUtils.FUNCTION_2301: analysisGas.analysis2301(message, ser); break; case ServerUtils.FUNCTION_2302: analysisGas.analysis2302(message, ser); break; case ServerUtils.FUNCTION_2303: analysisGas.analysis2303(message, ser); break; case ServerUtils.FUNCTION_2304: analysisGas.analysis2304(message, ser); break; case ServerUtils.FUNCTION_3101: analysisDevice.analysis3101(message, ser); break; case ServerUtils.FUNCTION_3102: analysisDevice.analysis3102(message, ser); break; case ServerUtils.FUNCTION_3103: analysisDevice.analysis3103(message, ser); break; case ServerUtils.FUNCTION_3201: analysisDevice.analysis3201(message, ser); break; case ServerUtils.FUNCTION_3301: analysisN2.analysis3301(message, ser); break; case ServerUtils.FUNCTION_3302: analysisN2.analysis3302(message, ser); break; case ServerUtils.FUNCTION_3303: analysisN2.analysis3303(message, ser); break; case ServerUtils.FUNCTION_3304: analysisN2.analysis3304(message, ser); break; case ServerUtils.FUNCTION_4001: analysisEs.analysis4001(message, ser); break; case ServerUtils.FUNCTION_5001: analysisTemp.analysis5001(message, ser); break; case ServerUtils.FUNCTION_5002: analysisTemp.analysis5002(message, ser); break; case ServerUtils.FUNCTION_6001: analysisIot.analysis6001(message, ser); break; default: break; } } catch (Exception e) { log.error("控制柜----->>>>平台：解析返回报文出现异常：" + e); e.printStackTrace(); } } public String checkMsg(ReMessage message) { if (StringUtils.isEmpty(message.getRespCode())) return null; if (ServerUtils.RESP_0000.equals(message.getRespCode())) return null; if (ServerUtils.RESP_1000.equals(message.getRespCode())) return "控制柜编号错误"; if (ServerUtils.RESP_1001.equals(message.getRespCode())) return "终端设备不在线"; if (ServerUtils.RESP_1010.equals(message.getRespCode())) return "控制柜授权到期"; if (ServerUtils.RESP_1011.equals(message.getRespCode())) return "授权码无效"; if (ServerUtils.RESP_1012.equals(message.getRespCode())) return "授权码已被使用"; if (ServerUtils.RESP_1013.equals(message.getRespCode())) return "授权码已过期"; if (ServerUtils.RESP_2000.equals(message.getRespCode())) return "签名验证失败"; if (ServerUtils.RESP_3000.equals(message.getRespCode())) return "通风模式不支持"; if (ServerUtils.RESP_4000.equals(message.getRespCode())) return "气调模式不支持"; if (ServerUtils.RESP_5000.equals(message.getRespCode())) return "控制柜当前为手动模式，拒绝远程操作"; if (ServerUtils.RESP_6000.equals(message.getRespCode())) return "采集执行失败"; if (ServerUtils.RESP_6001.equals(message.getRespCode())) return "粮情采集执行中"; if (ServerUtils.RESP_6002.equals(message.getRespCode())) return "气体采集执行中"; if (ServerUtils.RESP_6003.equals(message.getRespCode())) return "虫害采集执行中"; if (ServerUtils.RESP_9999.equals(message.getRespCode())) return "未知错误"; return null; } }