Commit 4979811c by huluobin

bug fix

parent 29c5a8af
...@@ -8,7 +8,7 @@ EVENT_RDB_STORAGE_USERNAME=root ...@@ -8,7 +8,7 @@ EVENT_RDB_STORAGE_USERNAME=root
EVENT_RDB_STORAGE_PASSWORD=#7kfnymAM$Y9-Ntf EVENT_RDB_STORAGE_PASSWORD=#7kfnymAM$Y9-Ntf
ZOOKEEPER_SERVER=172.31.255.120:2181 ZOOKEEPER_SERVER=172.31.255.120:2181
NAME_SPACE=data-center NAME_SPACE=data-center
JOB_NAME=base-sync-crm-refund JOB_NAME=base-sync-crm-refun3
#JOB_NAME=base-sync-crm-refund-update #JOB_NAME=base-sync-crm-refund-update
JOB_CRON=0/1 * * * * ? JOB_CRON=0/1 * * * * ?
JOB_LINK_NAME=base-link-crm-refund JOB_LINK_NAME=base-link-crm-refund
......
...@@ -107,8 +107,8 @@ public class EbayFinanceAdSyncJobTest { ...@@ -107,8 +107,8 @@ public class EbayFinanceAdSyncJobTest {
public void testThreadPool2() { public void testThreadPool2() {
EbayFinanceAdSyncJob ebayFinanceAdSyncJob = new EbayFinanceAdSyncJob(); EbayFinanceAdSyncJob ebayFinanceAdSyncJob = new EbayFinanceAdSyncJob();
LocalDateTime start = LocalDateTime.of(2020, 12, 23, 0, 0); LocalDateTime start = LocalDateTime.of(2020, 12, 27, 0, 0);
LocalDateTime end = LocalDateTime.of(2020, 12, 25, 0, 0); LocalDateTime end = LocalDateTime.of(2020, 12, 29, 0, 0);
List<LocalDateTime> localDateTimeList = Stream.iterate(start, List<LocalDateTime> localDateTimeList = Stream.iterate(start,
localDateTime -> localDateTime.plusDays(1)) localDateTime -> localDateTime.plusDays(1))
......
...@@ -5,8 +5,8 @@ ...@@ -5,8 +5,8 @@
<configuration> <configuration>
<!--<properties resource="db-tj.properties"/>--> <!--<properties resource="db-tj.properties"/>-->
<!-- <properties resource="db-dev.properties"/>--> <properties resource="db-dev.properties"/>
<properties resource="db-prod.properties"/> <!-- <properties resource="db-prod.properties"/>-->
<settings> <settings>
<setting name="mapUnderscoreToCamelCase" value="true"/> <setting name="mapUnderscoreToCamelCase" value="true"/>
</settings> </settings>
......
...@@ -134,6 +134,10 @@ public class AutoTurnoverJob extends PointJob { ...@@ -134,6 +134,10 @@ public class AutoTurnoverJob extends PointJob {
try { try {
String queryTime = DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()); String queryTime = DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now());
dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class).selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
.andBailunSkuEqualTo(dcBaseStock.getBailunSku())
.andWarehouseCodeEqualTo(dcBaseStock.getWarehouseCode())
.example());
this.autoTurnoverFromStock(queryTime, dcBaseStock); this.autoTurnoverFromStock(queryTime, dcBaseStock);
} catch (Exception e) { } catch (Exception e) {
//错误记录到日志表, 任务跑完了再跑一次错误SKU //错误记录到日志表, 任务跑完了再跑一次错误SKU
...@@ -146,6 +150,8 @@ public class AutoTurnoverJob extends PointJob { ...@@ -146,6 +150,8 @@ public class AutoTurnoverJob extends PointJob {
} finally { } finally {
SessionUtil.closeSession(); SessionUtil.closeSession();
} }
} finally {
SessionUtil.closeSession();
} }
}); });
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment