作者 钟来

明牛协议解析完成

  1 +### 启动说明
  2 +1、启动时依赖canal。
  3 +2、先启动canal,再启动lh-alarm。
  4 +3、canal启动时要先删除 conf/example/meta.dat,这样是为了解决mysql日志文件起始点丢失的问题。
@@ -130,15 +130,28 @@ public class DeviceCommandListenServiceImpl implements DeviceCommandServiceFacto @@ -130,15 +130,28 @@ public class DeviceCommandListenServiceImpl implements DeviceCommandServiceFacto
130 */ 130 */
131 private String reverseKey(String number, String dataIdentifier) 131 private String reverseKey(String number, String dataIdentifier)
132 { 132 {
133 - String[] arr = number.split("_");  
134 - if (arr.length < 3) {  
135 - return null; 133 + String area = "A"; // A
  134 + String mappedNumber = "0"; // 09
  135 + String index = "0"; // 1
  136 + String probe = null; // 探头编号(如果有)
  137 +
  138 + if("0".equals(number))
  139 + {
  140 + area = "A";
  141 + mappedNumber = "0";
  142 + index = "0";
  143 + }else{
  144 + String[] arr = number.split("_");
  145 + if (arr.length < 3) {
  146 + return null;
  147 + }
  148 +
  149 + area = arr[0]; // A
  150 + mappedNumber = arr[1]; // 09
  151 + index = arr[2]; // 1
  152 + probe = arr.length > 3 ? arr[3] : null; // 探头编号(如果有)
136 } 153 }
137 154
138 - String area = arr[0]; // A  
139 - String mappedNumber = arr[1]; // 09  
140 - String index = arr[2]; // 1  
141 - String probe = arr.length > 3 ? arr[3] : null; // 探头编号(如果有)  
142 155
143 // 反向查找设备类型(identifier) 156 // 反向查找设备类型(identifier)
144 String identifier = getIdentifierByMappedNumber(mappedNumber); 157 String identifier = getIdentifierByMappedNumber(mappedNumber);
@@ -29,7 +29,7 @@ mqtt: @@ -29,7 +29,7 @@ mqtt:
29 client: 29 client:
30 #客户端操作时间 30 #客户端操作时间
31 operationTime: 10 31 operationTime: 10
32 - productids: 39,40 32 + productids: 40
33 33
34 #rocketmq配置信息 34 #rocketmq配置信息
35 rocketmq: 35 rocketmq: