Dockerfile+url配置

data-base/base-sync-finance-fee/Dockerfile

+FROM maven:3.6.0-alpine
+
+RUN apk add ca-certificates && \
+    apk add tzdata && \
+    ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && \
+    echo "Asia/Shanghai" > /etc/timezone
+
+# make source folder
+RUN mkdir -p /usr/app
+WORKDIR /usr/app
+# install maven dependency packages (keep in image)
+
+COPY data-parent /usr/app/data-parent
+COPY data-common /usr/app/data-common
+COPY data-base /usr/app/data-base
+COPY data-mid /usr/app/data-mid
+COPY data-show /usr/app/data-show
+
+RUN cd /usr/app/data-parent && mvn -T 1C install  -pl ../data-base/base-sync-cashier -am
+
+#指定容器启动程序及参数   <ENTRYPOINT> "<CMD>"
+EXPOSE 8080
+ENTRYPOINT ["java","-Xms30m","-Xmx80m","-jar","/usr/app/data-base/base-sync-finance-fee/target/base-sync-finance-fee-1.0-SNAPSHOT.jar"]
\ No newline at end of file

data-base/base-sync-finance-fee/src/main/java/com/bailuntec/Application.java

@@ -2,6 +2,7 @@ package com.bailuntec;
 
 import com.alibaba.druid.pool.DruidDataSource;
 import com.bailuntec.job.FeeJob;
+import com.bailuntec.job.LogisticsJob;
 import com.bailuntec.utils.PropertiesUtil;
 import com.dangdang.ddframe.job.config.JobCoreConfiguration;
 import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
@@ -24,6 +25,7 @@ public class Application {
     private static final String EVENT_RDB_STORAGE_PASSWORD = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_PASSWORD");
     public static void main(String[] args) {
         new JobScheduler(createRegistryCenter(), createJobConfiguration(),createJobEventConfiguration()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration1(),createJobEventConfiguration()).init();
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
@@ -39,6 +41,13 @@ public class Application {
         return simpleJobRootConfig;
     }
 
+    private static LiteJobConfiguration createJobConfiguration1() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("LOGISTICS_JOB_NAME"), propertiesUtil.getPropertyAsString("LOGISTICS_JOB_CRON"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, LogisticsJob.class.getCanonicalName());
+        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
+        return simpleJobRootConfig;
+    }
+
     private static JobEventConfiguration createJobEventConfiguration() {
         JobEventConfiguration jobEventRdbConfig = new JobEventRdbConfiguration(setUpEventTraceDataSource());
         return jobEventRdbConfig;

data-base/base-sync-finance-fee/src/main/java/com/bailuntec/domain/LogisticsInfo.java

+package com.bailuntec.domain;
+
+import com.bailuntec.domain.entity.DcBaseFinanceLogistics;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class LogisticsInfo {
+    private List<DcBaseFinanceLogistics> data;
+    private boolean success;
+}

data-base/base-sync-finance-fee/src/main/java/com/bailuntec/job/LogisticsJob.java

+package com.bailuntec.job;
+
+import com.alibaba.fastjson.JSON;
+import com.bailuntec.domain.LogisticsInfo;
+import com.bailuntec.domain.constant.CommonConstant;
+import com.bailuntec.domain.entity.DcBaseFinanceLogistics;
+import com.bailuntec.domain.entity.JobPointLog;
+import com.bailuntec.mapper.DcBaseFinanceLogisticsMapper;
+import com.bailuntec.support.PointJob;
+import com.bailuntec.utils.OkHttpUtil;
+import com.bailuntec.utils.PropertiesUtil;
+import com.bailuntec.utils.SessionUtil;
+import com.dangdang.ddframe.job.api.ShardingContext;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import org.apache.commons.lang3.StringUtils;
+
+import java.io.IOException;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.LinkedHashMap;
+import java.util.List;
+
+@Slf4j
+public class LogisticsJob extends PointJob {
+
+    private OkHttpClient okHttpClient = OkHttpUtil.getInstance();
+    private PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("const");
+
+    @Override
+    public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
+        LinkedHashMap<String, String> map = new LinkedHashMap<>(4);
+        map.put("startDate", DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(jobPointLog.getStartTime().minusHours(3l)));
+        map.put("endDate", DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(jobPointLog.getEndTime()));
+            Response response = null;
+            String palResultStr = null;
+            try {
+                Request request = new Request.Builder()
+                        .get()
+                        .url(OkHttpUtil.attachHttpGetParams(propertiesUtil.getPropertyAsString("LOGISTICS_URL"), map))
+                        .addHeader("Content-Type", "application/json")
+                        .build();
+                response = okHttpClient.newCall(request).execute();
+                palResultStr = response.body().string();
+            } catch (IOException e) {
+                throw new RuntimeException(map + "请求物流接口同步百伦接口失败" + response, e);
+            } finally {
+                if (response != null) {
+                    response.close();
+                }
+            }
+            if (StringUtils.isNoneBlank(palResultStr)) {
+                LogisticsInfo logisticsInfo = JSON.parseObject(palResultStr, LogisticsInfo.class);
+                if (logisticsInfo != null && logisticsInfo.isSuccess() && logisticsInfo.getData().size() > 0) {
+                    List<DcBaseFinanceLogistics> logisticsList = logisticsInfo.getData();
+                    for(DcBaseFinanceLogistics dcBaseFinanceLogistics : logisticsList) {
+                        try {
+                            DcBaseFinanceLogisticsMapper dcBaseFinanceLogisticsMapper = SessionUtil.getSession().getMapper(DcBaseFinanceLogisticsMapper.class);
+                            dcBaseFinanceLogisticsMapper.upsertSelective(dcBaseFinanceLogistics);
+                        } catch (Exception e) {
+                            throw new RuntimeException("MyBatis 操作失败!");
+                        }finally {
+                            SessionUtil.closeSession();
+                        }
+                    }
+                } else {
+                    log.warn("请求结果：" + palResultStr + "请求参数：" + map.toString());
+                }
+            } else {
+                throw new RuntimeException("调用物流接口同步百伦流水失败, 响应为null, 请求参数" + map.toString());
+            }
+        jobPointLog.setStartTime(jobPointLog.getEndTime());
+        jobPointLog.setEndTime(jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()).isAfter(LocalDateTime.now()) ? LocalDateTime.now() : jobPointLog.getEndTime().plusDays(jobPointLog.getIntervalTime()));
+
+    }
+}

data-base/base-sync-finance-fee/src/main/resources/const.properties

-FEE_URL=http://127.0.0.1:8085//logistic/fee/cost/api/getCostList
+FEE_URL=http://api.fee.bailuntec.com/fee/api/cost/api/getCostList
+LOGISTICS_URL=http://yisanyong.xyz:8085/logistic/fee/cost/api/logisticsCostList
 

data-base/base-sync-finance-fee/src/main/resources/job.properties

@@ -11,4 +11,6 @@ ZOOKEEPER_SERVER=172.31.255.120:2181
 NAME_SPACE=data-center
 JOB_NAME=base-sync-finance-fee
 JOB_CRON=0/1 * * * * ? *
+LOGISTICS_JOB_NAME=base-sync-logistics
+LOGISTICS_JOB_CRON=0 0 0 1,15 * ? *
 SHARDING_TOTAL_COUNT=1
\ No newline at end of file