|
|
@ -45,11 +45,11 @@ public class RunReportAnalyseSchedule { |
|
|
|
if(Func.isNotEmpty(answerVOS)) { |
|
|
|
if(Func.isNotEmpty(answerVOS)) { |
|
|
|
AnswerVO answerVO = answerVOS.get(0); |
|
|
|
AnswerVO answerVO = answerVOS.get(0); |
|
|
|
if(answerVO.getRunning() == 0) { |
|
|
|
if(answerVO.getRunning() == 0) { |
|
|
|
log.info("运行月报分析结果为:" + answerVO.getAnswer()); |
|
|
|
log.info("运行月报分析结果为:" + JSON.toJSONString(answerVO)); |
|
|
|
JSONObject message = new JSONObject(); |
|
|
|
JSONObject message = new JSONObject(); |
|
|
|
message.put("stationCode", analyseObject.getString("stationCode")); |
|
|
|
message.put("stationCode", analyseObject.getString("stationCode")); |
|
|
|
message.put("month", analyseObject.getString("month")); |
|
|
|
message.put("month", analyseObject.getString("month")); |
|
|
|
message.put("result", answerVO.getAnswer()); |
|
|
|
message.put("result", JSONObject.parseObject(JSON.toJSONString(answerVO.getExtras()[0])).getString("data")); |
|
|
|
// 获取到问答答案,存入消息中
|
|
|
|
// 获取到问答答案,存入消息中
|
|
|
|
mqttSender.sendToMqtt(MqttTopicConstants.RUN_REPORT_ANALYSE_RESULT,JSON.toJSONString(message)); |
|
|
|
mqttSender.sendToMqtt(MqttTopicConstants.RUN_REPORT_ANALYSE_RESULT,JSON.toJSONString(message)); |
|
|
|
redisTemplate.opsForList().remove(RedisKeyConstants.RUN_REPORT_SESSION_ID,1,analyse); |
|
|
|
redisTemplate.opsForList().remove(RedisKeyConstants.RUN_REPORT_SESSION_ID,1,analyse); |
|
|
|