From 2c13954c3d7a3d7c73fe8dddc5e642a2c1c4929f Mon Sep 17 00:00:00 2001
From: hansha <bdqn_hansha@163.com>
Date: Fri, 19 Jul 2024 17:09:19 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=8E=A5=E5=8F=A3=E5=BC=82?=
 =?UTF-8?q?=E5=B8=B8=E4=BB=BB=E5=8A=A1=E7=8A=B6=E6=80=81=E4=B8=BA=E6=8E=A5?=
 =?UTF-8?q?=E6=94=B6=E5=A4=B1=E8=B4=A5=EF=BC=8C=E6=8A=A5=E9=94=99=E5=AD=98?=
 =?UTF-8?q?=E5=85=A5remark?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/da/dangan/timetask/TimeTask.java   | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

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