package com.zy.asrs.task;
|
|
import cn.hutool.core.date.DateUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.zy.asrs.entity.AgvWrkMast;
|
import com.zy.asrs.mapper.AgvBasMapper;
|
import com.zy.asrs.service.AgvWrkMastService;
|
import com.zy.asrs.task.core.WrkMastConfig;
|
import com.zy.common.utils.HttpHandler;
|
import com.zy.system.entity.Config;
|
import com.zy.system.service.ConfigService;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.io.IOException;
|
import java.util.*;
|
|
/**
|
* Created by vincent on 2020/7/7
|
*/
|
@Component
|
public class AgvWrkMastWarnScheduler {
|
|
private static final Logger log = LoggerFactory.getLogger(AgvWrkMastWarnScheduler.class);
|
|
|
@Autowired
|
private AgvWrkMastService agvWrkMastService;
|
|
|
@Autowired
|
private ConfigService configService;
|
|
@Autowired
|
private AgvBasMapper agvBasMapper;
|
|
|
@Scheduled(fixedDelay = 600000)
|
public void report() {
|
Date date = new Date();
|
Map<Long, Integer> timeConfig = new HashMap<>();
|
Config url = configService.selectOne(new EntityWrapper<Config>().eq("code", "WRKMAST_WARN_REPORT_URL"));
|
Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "WRKMAST_WARN_CONFIG"));
|
if (url != null && url.getValue() != null && config != null && config.getValue() != null) {
|
List<WrkMastConfig> wrkMastConfigs = JSONArray.parseArray(config.getValue(), WrkMastConfig.class);
|
EntityWrapper<AgvWrkMast> wrapper = new EntityWrapper<>();
|
for (WrkMastConfig wrkMastConfig : wrkMastConfigs) {
|
wrapper.eq("wrk_sts", wrkMastConfig.getSts()).le("modi_time", DateUtil.offsetHour(date, -wrkMastConfig.getHours()));
|
if (!wrkMastConfigs.get(wrkMastConfigs.size() - 1).equals(wrkMastConfig)) {
|
wrapper.orNew();
|
}
|
timeConfig.put(wrkMastConfig.getSts(), wrkMastConfig.getReport());
|
}
|
List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(wrapper);
|
StringBuffer buffer;
|
for (AgvWrkMast agvWrkMast : agvWrkMasts) {
|
Date errorTime = agvWrkMast.getErrorTime();
|
if (errorTime == null) {
|
errorTime = agvWrkMast.getModiTime();
|
}
|
if (DateUtil.offsetMinute(date, -timeConfig.get(agvWrkMast.getWrkSts())).after(errorTime)) {
|
buffer = new StringBuffer();
|
buffer.append("[" + agvWrkMast.getWrkNo() + "]工作号,状态：" + agvWrkMast.getWrkSts$() + "\n");
|
buffer.append("最后一次更新时间:" + DateUtil.formatDateTime(agvWrkMast.getModiTime()) + "\n");
|
HashMap<String, Object> param = new HashMap<>();
|
HashMap<String, Object> data = new HashMap<>();
|
data.put("content", buffer.toString());
|
param.put("msgtype", "text");
|
param.put("text", data);
|
|
log.info("发送报警信息：{}", JSON.toJSONString(param));
|
String response = null;
|
try {
|
response = new HttpHandler.Builder().setUri(url.getValue()).setJson(JSON.toJSONString(param)).setHttps(true).build().doPost();
|
} catch (IOException e) {
|
//continue;
|
}
|
JSONObject jsonObject = JSON.parseObject(response);
|
if (jsonObject != null && jsonObject.get("errmsg").equals("ok")) {
|
agvWrkMast.setErrorTime(date);
|
agvWrkMastService.updateById(agvWrkMast);
|
} else {
|
agvWrkMast.setErrorTime(date);
|
agvWrkMastService.updateById(agvWrkMast);
|
log.error("发送失败，错误信息：{}", jsonObject == null ? "空" : jsonObject.get("errmsg"));
|
}
|
}
|
}
|
}
|
}
|
|
|
public static void main(String[] args) {
|
List<WrkMastConfig> list = new ArrayList<>();
|
WrkMastConfig wrkMastConfig = new WrkMastConfig();
|
wrkMastConfig.setSts(205L);
|
wrkMastConfig.setHours(480);
|
wrkMastConfig.setReport(120);
|
list.add(wrkMastConfig);
|
wrkMastConfig = new WrkMastConfig();
|
wrkMastConfig.setSts(204L);
|
wrkMastConfig.setHours(24);
|
wrkMastConfig.setReport(60);
|
list.add(wrkMastConfig);
|
wrkMastConfig = new WrkMastConfig();
|
wrkMastConfig.setSts(203L);
|
wrkMastConfig.setHours(24);
|
wrkMastConfig.setReport(60);
|
list.add(wrkMastConfig);
|
wrkMastConfig = new WrkMastConfig();
|
wrkMastConfig.setSts(202L);
|
wrkMastConfig.setHours(24);
|
wrkMastConfig.setReport(60);
|
list.add(wrkMastConfig);
|
System.out.println(JSON.toJSONString(list));
|
}
|
|
}
|
