路由规则

src/main/java/com/zjty/autotest/mq/TestTask.java

@@ -218,12 +218,16 @@ public class TestTask {
                     testReport.setOutReport(out);
 
                     testReportService.update(testReport);
-                    autoResultSetService.updateByid(id);
+                    autoResultSetService.updateByid(id,1);
                     WebSocketServer.sendInfo("1,"+id,"sjq110");
+                    return;
                 }
+                autoResultSetService.updateByid(id,3);
+                WebSocketServer.sendInfo("2,"+id,"sjq110");
             } catch (Exception e) {
                 e.printStackTrace();
                 try {
+                    autoResultSetService.updateByid(id,3);
                     WebSocketServer.sendInfo("2,"+id,"sjq110");
                 } catch (IOException e1) {
                     e1.printStackTrace();

src/main/java/com/zjty/autotest/service/AutoResultSetService.java

@@ -24,7 +24,7 @@ public interface AutoResultSetService {
      * @param id
      * @return
      */
-    ResponseResult updateByid(String id);
+    ResponseResult updateByid(String id,Integer status);
     /**
      * 新增
      */

src/main/java/com/zjty/autotest/service/impl/AutoResultSetServiceImpl.java

@@ -27,10 +27,7 @@ import javax.persistence.criteria.CriteriaBuilder;
 import javax.persistence.criteria.CriteriaQuery;
 import javax.persistence.criteria.Predicate;
 import javax.persistence.criteria.Root;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 @Service
 public class AutoResultSetServiceImpl implements AutoResultSetService {
@@ -84,9 +81,13 @@ public class AutoResultSetServiceImpl implements AutoResultSetService {
     }
 
     @Override
-    public ResponseResult updateByid(String id) {
-        int i = autoResultSetDao.updateStatus(id);
-        if(i==1){
+    public ResponseResult updateByid(String id,Integer status) {
+        Optional<AutoResultSet> optional = autoResultSetDao.findById(id);
+        if(optional.isPresent()){
+            AutoResultSet autoResultSet = optional.get();
+            autoResultSet.setStatus(status);
+            autoResultSet.setUpdateTime(new Date());
+            autoResultSetDao.save(autoResultSet);
             return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
         }
         return ResponseResult.errorResult(AppHttpCodeEnum.UPDATE_ERROR);