1107需要变更

easydo-chengfa/src/main/java/easydo/technology/service/KafkaClient.java

@@ -3,6 +3,7 @@ package easydo.technology.service;
 import java.sql.Connection;
 import java.sql.ResultSet;
 import java.sql.Statement;
+import java.util.List;
 
 import javax.annotation.Resource;
 import javax.sql.DataSource;
@@ -41,7 +42,7 @@ public class KafkaClient {
     String purchasePath;
 
     @KafkaListener(topics = {"task_prod"}) // 在这里指定要监听的topic，可以监听多个
-    public void listenToMessage(String message) throws Exception{
+    public void listenToMessage(String message) throws Exception {
         JSONObject object = JSONObject.parseObject(message);
         String topic = object.getJSONObject("eventData").getString("topic");
         JSONObject taskSimpleInfo = object.getJSONObject("eventData").getJSONObject("taskSimpleInfo");
@@ -147,7 +148,22 @@ public class KafkaClient {
             }
 
         }
-
+        if (NULL_STATUS.equals(status)) {
+            sql = "select id from " + tableName + " where process_task_id = " + taskId;
+            ResultSet resultSet = statement.executeQuery(sql);
+            while (resultSet.next()) {
+                String id = resultSet.getString(1);
+                BusApprove busApprove = new BusApprove();
+                busApprove.setBusId(id);
+                busApprove.setBusType(tableName);
+                busApprove.setApproveStatus(ChengfaEnum.BUS_APPROVE_APPROVE_STATUS_DONE.getValue());
+                busApprove.setApproveResult(ChengfaEnum.BUS_APPROVE_APPROVE_RESULT_Y.getValue());
+                List<BusApprove> approveList = jdbcClient.getJdbcList(busApprove, connection);
+                for (BusApprove approveDone : approveList) {
+                    jdbcClient.jdbcRemoveById(approveDone, connection);
+                }
+            }
+        }
     }
 
     public void saveOAPurchaseInfo(String id, Connection connection) throws Exception {