|
|
@@ -304,24 +304,6 @@ public class DspCallbackServiceImpl implements IDspCallbackService { |
|
|
|
Boolean result = this.saveAccidentData(thirstyQuestionFiles); |
|
|
|
log.info("预警数据入库完成,result={}",result); |
|
|
|
|
|
|
|
log.info("进入调小程序接口推送消息"); |
|
|
|
//获取第一个问题,调小程序接口通知 |
|
|
|
InspectionFile inspectionFile = thirstyQuestionFiles.get(0); |
|
|
|
if(ObjectUtil.isNotNull(inspectionFile)){ |
|
|
|
//发送类 |
|
|
|
WxRequest request = new WxRequest(); |
|
|
|
request.setInspectionId(inspectionId); |
|
|
|
request.setQuestionId(inspectionFile.getId()); |
|
|
|
request.setCreateTime(inspectionFile.getCreateTime().toString()); |
|
|
|
request.setInspectionName(inspectionFile.getFileName()); |
|
|
|
request.setQuestionDesc(inspectionFile.getQuestionDesc()); |
|
|
|
String url = CommonConfig.minprogramUrl + SystemConstant.MESSAGE_PUSH; |
|
|
|
//发送请求 |
|
|
|
JsonResult jsonResult = doPost(url, request); |
|
|
|
if(jsonResult.getCode() != 0){ |
|
|
|
log.info("消息推送失败,jsonResult={}",jsonResult.toString()); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
//释放通道 |
|
|
|
if (4 == inspection.getAnalyseStatus() || 5 == inspection.getAnalyseStatus() || 6 == inspection.getAnalyseStatus()) { |