|
|
|
@ -49,7 +49,7 @@ public class BasedataMontNestRunDataConsumerHandle implements IBasedataMontDataH |
|
|
|
BasedataMontNestRunData basedataMontNestrundata = iterator.next(); |
|
|
|
BasedataEqpBook basedataEqpbook = new BasedataEqpBook(); |
|
|
|
basedataEqpbook.setPatrolDeviceCode(basedataMontNestrundata.getNestCode()); |
|
|
|
List<BasedataEqpBook> basedataEqpBookList = this.basedataEqpBookService.selectBasedataEqpBookList(basedataEqpbook); |
|
|
|
List<BasedataEqpBook> basedataEqpBookList = basedataEqpBookService.selectBasedataEqpBookList(basedataEqpbook); |
|
|
|
if (!basedataEqpBookList.isEmpty()) { |
|
|
|
basedataMontNestrundata.setEqpBookId(basedataEqpBookList.get(0).getEqpBookId()); |
|
|
|
} |
|
|
|
@ -64,13 +64,12 @@ public class BasedataMontNestRunDataConsumerHandle implements IBasedataMontDataH |
|
|
|
} |
|
|
|
|
|
|
|
basedataMontNestrundata.setCreateTime(nowDate); |
|
|
|
this.basedataMontNestRunDataService.insertBasedataMontNestRunData(basedataMontNestrundata); |
|
|
|
basedataMontNestRunDataService.insertBasedataMontNestRunData(basedataMontNestrundata); |
|
|
|
basedataMontNestrundata.setCreateTime(null); |
|
|
|
} |
|
|
|
|
|
|
|
HashMap<String, ArrayList<BasedataMontNestRunData>> patrolDeviceDataMap = this.getPatrolDeviceData(list); |
|
|
|
HashMap<String, ArrayList<BasedataMontNestRunData>> patrolDeviceDataMap = getPatrolDeviceData(list); |
|
|
|
String sendCode = jsonObject.getString("SendCode"); |
|
|
|
|
|
|
|
for (String itemKey : patrolDeviceDataMap.keySet()) { |
|
|
|
JSONObject returnJsonObject = new JSONObject(); |
|
|
|
JSONObject montJsonObject = new JSONObject(); |
|
|
|
@ -82,8 +81,8 @@ public class BasedataMontNestRunDataConsumerHandle implements IBasedataMontDataH |
|
|
|
returnJsonObject.put("receiveTime", value_unit); |
|
|
|
returnJsonObject.put("event", "mont/montNestRunData"); |
|
|
|
String jsonString = JSON.toJSONString(returnJsonObject); |
|
|
|
this.redisService.setCacheObject("mont_nest_run_data:" + itemKey, returnJsonObject); |
|
|
|
this.parseMessage(jsonString); |
|
|
|
redisService.setCacheObject("mont_nest_run_data:" + itemKey, returnJsonObject); |
|
|
|
parseMessage(jsonString); |
|
|
|
System.out.println("发送机巢运行数据到websocket mont/montNestRunData:::" + jsonString); |
|
|
|
} |
|
|
|
|
|
|
|
@ -96,17 +95,16 @@ public class BasedataMontNestRunDataConsumerHandle implements IBasedataMontDataH |
|
|
|
|
|
|
|
private HashMap<String, ArrayList<BasedataMontNestRunData>> getPatrolDeviceData(List<BasedataMontNestRunData> list) { |
|
|
|
HashMap<String, ArrayList<BasedataMontNestRunData>> objectMap = new HashMap<>(); |
|
|
|
|
|
|
|
for (BasedataMontNestRunData montNestRunData : list) { |
|
|
|
String nest_code = montNestRunData.getNestCode(); |
|
|
|
ArrayList dataList; |
|
|
|
if (objectMap.containsKey(nest_code)) { |
|
|
|
dataList = objectMap.get(nest_code); |
|
|
|
String nestCode = montNestRunData.getNestCode(); |
|
|
|
ArrayList<BasedataMontNestRunData> dataList; |
|
|
|
if (objectMap.containsKey(nestCode)) { |
|
|
|
dataList = objectMap.get(nestCode); |
|
|
|
dataList.add(montNestRunData); |
|
|
|
} else { |
|
|
|
dataList = new ArrayList(); |
|
|
|
dataList = new ArrayList<>(); |
|
|
|
dataList.add(montNestRunData); |
|
|
|
objectMap.put(nest_code, dataList); |
|
|
|
objectMap.put(nestCode, dataList); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|