|
|
@@ -148,22 +148,6 @@ 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 {
|