Compare commits
5 Commits
36c8945201
...
4780f01f7d
| Author | SHA1 | Date |
|---|---|---|
|
|
4780f01f7d | |
|
|
2cd86c4d6a | |
|
|
adf1a57079 | |
|
|
b9b3120e20 | |
|
|
e310f16e58 |
|
|
@ -45,12 +45,17 @@ public class AutoCallTaskScheduled {
|
|||
|
||||
@EventListener(ApplicationReadyEvent.class)
|
||||
public void initialize() throws Exception {
|
||||
autoCallHelper.getToken();
|
||||
log.info("token1 {}", autoCallHelper.getToken());
|
||||
autoCallHelper.getToken();
|
||||
log.info("token2 {}", autoCallHelper.getToken());
|
||||
initialized.set(true);
|
||||
log.info("AutoCallTaskScheduled初始化完成");
|
||||
try {
|
||||
autoCallHelper.getToken();
|
||||
log.info("token1 {}", autoCallHelper.getToken());
|
||||
autoCallHelper.getToken();
|
||||
log.info("token2 {}", autoCallHelper.getToken());
|
||||
log.info("AutoCallTaskScheduled初始化完成");
|
||||
} catch (Exception ignore) {
|
||||
|
||||
} finally {
|
||||
initialized.set(true);
|
||||
}
|
||||
}
|
||||
|
||||
@Scheduled(cron = "*/3 * * * * ?")
|
||||
|
|
@ -125,6 +130,11 @@ public class AutoCallTaskScheduled {
|
|||
return;
|
||||
}
|
||||
for (AutoCallPerson person : personList) {
|
||||
AutoCallTask task = autoCallTaskService.getTaskMapper().selectById(taskId);
|
||||
if (task.getStatus() == AutoCallTask.STATUS_MANUAL_CLOSE || task.getStatus() == AutoCallTask.STATUS_CANCELLED) {
|
||||
autoCallTaskService.cancelPerson(person);
|
||||
continue;
|
||||
}
|
||||
while (person.getUploadedTimes() < 2) {
|
||||
if (AutoCallPerson.TAG_DONE.equals(person.getTag())) break;
|
||||
//do upload
|
||||
|
|
|
|||
|
|
@ -149,7 +149,7 @@ public class QXWarnController {
|
|||
/**
|
||||
* 气象预警-正在生效的预警信息
|
||||
*
|
||||
* @param dto
|
||||
* @param
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation(value = "气象预警-正在生效的预警信息")
|
||||
|
|
@ -435,7 +435,7 @@ public class QXWarnController {
|
|||
yearDto.setFilter(filter);
|
||||
String yearstr = HttpUtil.sendPost(getGroupWarning, JSON.toJSONString(yearDto));
|
||||
JSONObject yearjson = JSON.parseObject(yearstr);
|
||||
System.out.println("yearstr:" + yearjson);
|
||||
// System.out.println("yearstr:" + yearjson);
|
||||
if (yearjson != null && yearjson.getInteger("code") == HttpStatus.SC_OK) {
|
||||
List<WarningData> data = yearjson.getJSONArray("data").toJavaList(WarningData.class);
|
||||
//// return ResultJson.ok(getCount(data, publishUnit, warnSignalLevel, warnSignalType));
|
||||
|
|
|
|||
|
|
@ -73,7 +73,7 @@ public class AutoCallTaskService2 {
|
|||
task.setWarnCnnm("钟祥 ");
|
||||
taskMapper.insert(task);
|
||||
generatePerson(task);
|
||||
//
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
|
|
@ -89,21 +89,21 @@ public class AutoCallTaskService2 {
|
|||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
//
|
||||
warn = qxWarningMapper.selectOne(
|
||||
new QueryWrapper<QXWarning>()
|
||||
.orderByDesc("WARNID")
|
||||
.last("limit 1")
|
||||
);
|
||||
warn.setCtnm("荆州市");
|
||||
warn.setCnnm("枣阳 ");
|
||||
taskList = newTask(warn);
|
||||
task = taskList.get(0);
|
||||
task.setStatus(0);
|
||||
task.setCreateTm(new Date());
|
||||
task.setWarnCnnm("枣阳 ");
|
||||
taskMapper.insert(task);
|
||||
generatePerson(task);
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
// .last("limit 1")
|
||||
// );
|
||||
// warn.setCtnm("荆州市");
|
||||
// warn.setCnnm("枣阳 ");
|
||||
// taskList = newTask(warn);
|
||||
// task = taskList.get(0);
|
||||
// task.setStatus(0);
|
||||
// task.setCreateTm(new Date());
|
||||
// task.setWarnCnnm("枣阳 ");
|
||||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
//
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
|
|
@ -124,7 +124,7 @@ public class AutoCallTaskService2 {
|
|||
// .orderByDesc("WARNID")
|
||||
// .last("limit 1")
|
||||
// );
|
||||
|
||||
//
|
||||
// warn.setCtnm("荆州市");
|
||||
// warn.setCnnm("英山 ");
|
||||
// taskList = newTask(warn);
|
||||
|
|
@ -150,20 +150,20 @@ public class AutoCallTaskService2 {
|
|||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
// .last("limit 1")
|
||||
// );
|
||||
// warn.setCtnm("荆州市");
|
||||
// warn.setCnnm("阳新 ");
|
||||
// taskList = newTask(warn);
|
||||
// task = taskList.get(0);
|
||||
// task.setStatus(0);
|
||||
// task.setCreateTm(new Date());
|
||||
// task.setWarnCnnm("阳新 ");
|
||||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
warn = qxWarningMapper.selectOne(
|
||||
new QueryWrapper<QXWarning>()
|
||||
.orderByDesc("WARNID")
|
||||
.last("limit 1")
|
||||
);
|
||||
warn.setCtnm("荆州市");
|
||||
warn.setCnnm("阳新 ");
|
||||
taskList = newTask(warn);
|
||||
task = taskList.get(0);
|
||||
task.setStatus(0);
|
||||
task.setCreateTm(new Date());
|
||||
task.setWarnCnnm("阳新 ");
|
||||
taskMapper.insert(task);
|
||||
generatePerson(task);
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
|
|
@ -194,7 +194,7 @@ public class AutoCallTaskService2 {
|
|||
// task.setWarnCnnm("宜城 ");
|
||||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
//
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
|
|
@ -209,7 +209,7 @@ public class AutoCallTaskService2 {
|
|||
// task.setWarnCnnm("孝南 ");
|
||||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
//
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
|
|
@ -224,7 +224,7 @@ public class AutoCallTaskService2 {
|
|||
// task.setWarnCnnm("孝感 ");
|
||||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
//
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
|
|
@ -239,7 +239,7 @@ public class AutoCallTaskService2 {
|
|||
// task.setWarnCnnm("襄州 ");
|
||||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
//
|
||||
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
|
|
@ -285,7 +285,7 @@ public class AutoCallTaskService2 {
|
|||
// task.setWarnCnnm("秭归 ");
|
||||
// taskMapper.insert(task);
|
||||
// generatePerson(task);
|
||||
|
||||
//
|
||||
// warn = qxWarningMapper.selectOne(
|
||||
// new QueryWrapper<QXWarning>()
|
||||
// .orderByDesc("WARNID")
|
||||
|
|
|
|||
|
|
@ -90,7 +90,7 @@ public class HttpUtil {
|
|||
}
|
||||
jstr = sb.toString();
|
||||
|
||||
log.info("响应参数: " + jstr);
|
||||
// log.info("响应参数: " + jstr);
|
||||
|
||||
jstr = jsonFormat(jstr);
|
||||
|
||||
|
|
@ -169,7 +169,7 @@ public class HttpUtil {
|
|||
}
|
||||
jstr = sb.toString();
|
||||
|
||||
log.info("响应参数: " + jstr);
|
||||
// log.info("响应参数: " + jstr);
|
||||
|
||||
jstr = jsonFormat(jstr);
|
||||
|
||||
|
|
@ -243,7 +243,7 @@ public class HttpUtil {
|
|||
}
|
||||
jstr = sb.toString();
|
||||
|
||||
log.info("响应参数: " + jstr);
|
||||
// log.info("响应参数: " + jstr);
|
||||
|
||||
jstr = jsonFormat(jstr);
|
||||
|
||||
|
|
@ -317,7 +317,7 @@ public class HttpUtil {
|
|||
}
|
||||
jstr = sb.toString();
|
||||
|
||||
log.info("响应参数: " + jstr);
|
||||
// log.info("响应参数: " + jstr);
|
||||
|
||||
jstr = jsonFormat(jstr);
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue