|
|
|
@ -62,15 +62,15 @@ public class TimeTask {
|
|
|
|
public void getTaskResult() {
|
|
|
|
public void getTaskResult() {
|
|
|
|
String result = "";
|
|
|
|
String result = "";
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
String expired = DictUtils.getDictValue("task_time_out", "task_timeout");
|
|
|
|
DaTask param = new DaTask();
|
|
|
|
DaTask param = new DaTask();
|
|
|
|
param.setStatus("1"); //处理中
|
|
|
|
param.setStatus("1"); //处理中
|
|
|
|
//查询所有识别中的任务
|
|
|
|
//查询所有识别中的任务
|
|
|
|
List<DaTask> daTasks = daTaskService.selectDaTaskListByStatus(param);
|
|
|
|
List<DaTask> daTasks = daTaskService.selectDaTaskListByStatus(param);
|
|
|
|
if (daTasks != null && daTasks.size() > 0) {
|
|
|
|
if (daTasks != null && daTasks.size() > 0) {
|
|
|
|
for (DaTask datask : daTasks) {
|
|
|
|
for (DaTask datask : daTasks) {
|
|
|
|
//查看认识是否超时, 计算两个日期之间的差值(毫秒) 分钟-> / (1000 * 60)
|
|
|
|
//查看识别是否超时, 计算两个日期之间的差值(毫秒) 分钟-> / (1000 * 60)
|
|
|
|
long diff = (new Date().getTime() - datask.getSbStart().getTime()) / (1000 * 60);
|
|
|
|
long diff = (new Date().getTime() - datask.getSbStart().getTime()) / (1000 * 60);
|
|
|
|
String expired = DictUtils.getDictValue("task_time_out", "task_timeout");
|
|
|
|
|
|
|
|
if (diff > Long.parseLong(expired)) {
|
|
|
|
if (diff > Long.parseLong(expired)) {
|
|
|
|
datask.setStatus("3"); //设置状态任务超时
|
|
|
|
datask.setStatus("3"); //设置状态任务超时
|
|
|
|
daTaskService.updateDaTask(datask);
|
|
|
|
daTaskService.updateDaTask(datask);
|
|
|
|
@ -376,6 +376,7 @@ public class TimeTask {
|
|
|
|
* 定时任务,对等待中的任务进行提交(识别中任务<third_task_max值时)
|
|
|
|
* 定时任务,对等待中的任务进行提交(识别中任务<third_task_max值时)
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public void submitTask() {
|
|
|
|
public void submitTask() {
|
|
|
|
|
|
|
|
DaTask scTask = new DaTask();
|
|
|
|
String result = "";
|
|
|
|
String result = "";
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
//获取字典第三方任务最大数量
|
|
|
|
//获取字典第三方任务最大数量
|
|
|
|
@ -387,6 +388,7 @@ public class TimeTask {
|
|
|
|
List<DaTask> daTasks = daTaskService.selectDaTaskListByStatus(param);
|
|
|
|
List<DaTask> daTasks = daTaskService.selectDaTaskListByStatus(param);
|
|
|
|
if (daTasks != null && daTasks.size() > 0) {
|
|
|
|
if (daTasks != null && daTasks.size() > 0) {
|
|
|
|
for (DaTask daTask : daTasks) {
|
|
|
|
for (DaTask daTask : daTasks) {
|
|
|
|
|
|
|
|
scTask=daTask; //捕获异常的时候使用这个对象
|
|
|
|
DaTask sbz = new DaTask();
|
|
|
|
DaTask sbz = new DaTask();
|
|
|
|
sbz.setStatus("1"); //处理中
|
|
|
|
sbz.setStatus("1"); //处理中
|
|
|
|
//2.获取所有识别中的任务
|
|
|
|
//2.获取所有识别中的任务
|
|
|
|
@ -447,6 +449,9 @@ public class TimeTask {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
e.printStackTrace();
|
|
|
|
e.printStackTrace();
|
|
|
|
|
|
|
|
scTask.setStatus("0");
|
|
|
|
|
|
|
|
scTask.setRemark(e.getMessage()+",result:"+result);
|
|
|
|
|
|
|
|
daTaskService.updateDaTask(scTask);
|
|
|
|
System.out.println("upload_api接口:" + result);
|
|
|
|
System.out.println("upload_api接口:" + result);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|