Commit e66e90f0 by yinyong

另一版本CRM退款

parent 093d6bab
...@@ -38,8 +38,8 @@ public class CrmRefundSyncJob extends PointJob { ...@@ -38,8 +38,8 @@ public class CrmRefundSyncJob extends PointJob {
@Override @Override
public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) { public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
HashMap<String, String> map = new HashMap<>(4); HashMap<String, String> map = new HashMap<>(4);
map.put("r_btime", jobPointLog.getStartTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT))); map.put("btime", jobPointLog.getStartTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT)));
map.put("r_etime", jobPointLog.getEndTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT))); map.put("etime", jobPointLog.getEndTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT)));
map.put("rows", jobPointLog.getPageSize().toString()); map.put("rows", jobPointLog.getPageSize().toString());
Integer totalPage = 0; Integer totalPage = 0;
do { do {
......
...@@ -8,8 +8,9 @@ EVENT_RDB_STORAGE_USERNAME=root ...@@ -8,8 +8,9 @@ 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-refund
JOB_NAME=base-sync-crm-refund-update
JOB_CRON=0 0 0/1 * * ? * JOB_CRON=0 0 0/1 * * ? *
JOB_LINK_NAME=base-link-crm-refund JOB_LINK_NAME=base-link-crm-refund-update
JOB_LINK_CRON=0 0 0/2 * * ? * JOB_LINK_CRON=0 0 0/2 * * ? *
SHARDING_TOTAL_COUNT=1 SHARDING_TOTAL_COUNT=1
\ No newline at end of file
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