添加手动回传 重新下发按钮

ruoyi-admin/src/main/java/com/ruoyi/job/controller/MydoJobController.java

@@ -113,4 +113,13 @@ public class MydoJobController extends BaseController
     {
         return toAjax(mydoJobService.deleteMydoJobByJobIds(jobIds));
     }
+
+
+    @PreAuthorize("@ss.hasPermi('job:mydoJob:manualCallback')")
+    @Log(title = "作业信息", businessType = BusinessType.UPDATE)
+    @GetMapping("/manualCallback/{jobId}")
+    public AjaxResult manualCallback(@PathVariable("jobId") String jobId)
+    {
+        return mydoJobService.manualCallback(jobId);
+    }
 }

ruoyi-admin/src/main/java/com/ruoyi/job/service/IMydoJobService.java

@@ -1,6 +1,8 @@
 package com.ruoyi.job.service;
 
 import java.util.List;
+
+import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.job.domain.MydoJob;
 
 /**
@@ -76,4 +78,6 @@ public interface IMydoJobService
     List<MydoJob> selectMydoJobFinishList(MydoJob mydoJob);
 
     MydoJob selectRunningMydoJobByExitList(List<String> strings);
+
+    AjaxResult manualCallback(String jobId);
 }

ruoyi-admin/src/main/java/com/ruoyi/job/service/impl/MydoJobServiceImpl.java

@@ -4,6 +4,8 @@ import java.util.HashMap;
 import java.util.List;
 
 import cn.hutool.core.convert.Convert;
+import cn.hutool.core.util.ObjUtil;
+import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.utils.DateUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -158,4 +160,17 @@ public class MydoJobServiceImpl implements IMydoJobService
     public MydoJob selectRunningMydoJobByExitList(List<String> exitList) {
         return mydoJobMapper.selectRunningMydoJobByExitList(exitList);
     }
+
+    @Override
+    public AjaxResult manualCallback(String jobId) {
+        MydoJob mydoJob = mydoJobMapper.selectMydoJobByJobId(jobId);
+        if (ObjUtil.isNull(mydoJob)){
+            return AjaxResult.warn("作业不存在");
+        }
+        boolean b = ddjTaskFinish(Convert.toLong(mydoJob.getTaskNo()), Convert.toInt(mydoJob.getRoadwayId()), 1);
+        if (b){
+            return AjaxResult.success("手动回调成功");
+        }
+        return AjaxResult.error("手动回调失败");
+    }
 }