fix(quartz): 1.增加超时重试机制2.数据条数不统一时删除拉取到的数据

cy

2023-10-11 f17a48a0e3d7531b240a89755e7b7e7e2248ccb2

 src/main/java/com/integrated/zyyt/service/ZyytService.java

@@ -263,7 +263,7 @@
                        continue;
                    }
                    List<YyztTShkdrb> yyztTShkdrbs = stationInfoList.subList(fromIndex, toIndex);
                    try {

                        List<Object[]> insertShkdrbList = new ArrayList<>();
                        yyztTShkdrbs.forEach(item -> {
                            insertShkdrbList.add(new Object[]{
@@ -317,17 +317,11 @@
                                    batchNo});
                        });
                        jdbcTemplate.batchUpdate(batchInsertSql, insertShkdrbList);
                    } catch (Exception e) {
                        log.error(e.getMessage());
                        //手工回滚异常
//                        TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
                        stationInfoService.updateRecord(recordId, 1, 0L, e.getMessage());
                        return;
                    }
                }
            }
        } catch (Exception e) {
            log.error(e.getMessage());
            jdbcTemplate.update(delSql);
            stationInfoService.updateRecord(recordId, 1, 0L, e.getMessage());
            return;
        }
@@ -430,6 +424,7 @@
                        log.error(e.getMessage());
                        //手工回滚异常
//                        TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
                        jdbcTemplate.update(delSql);
                        stationInfoService.updateRecord(recordId, 1, 0L, e.getMessage());
                        return;
                    }