再加一个调.net写的web接口

data-mid/mid-stored-procedure/src/main/java/com/bailuntec/Application.java

@@ -4,9 +4,11 @@ import com.alibaba.druid.pool.DruidDataSource;
 import com.bailuntec.job.ProcSyncDataWareHouseJob;
 import com.bailuntec.job.SaveSkuWarehouseStockJob;
 import com.bailuntec.job.SkuWarehouseRedundancyJob;
+import com.bailuntec.job.SkuWarehouseSalesJob;
 import com.bailuntec.listener.ProcSyncDataWareHouseJobListener;
 import com.bailuntec.listener.SaveSkuWarehouseStockJobListener;
 import com.bailuntec.listener.SkuWarehouseRedundancyJobListener;
+import com.bailuntec.listener.SkuWarehouseSalesJobListener;
 import com.bailuntec.utils.PropertiesUtil;
 import com.dangdang.ddframe.job.config.JobCoreConfiguration;
 import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
@@ -32,6 +34,7 @@ public class Application {
         new JobScheduler(createRegistryCenter(), createJobConfiguration1(),createJobEventConfiguration(), new ProcSyncDataWareHouseJobListener()).init();
         new JobScheduler(createRegistryCenter(), createJobConfiguration2(),createJobEventConfiguration(), new SaveSkuWarehouseStockJobListener()).init();
         new JobScheduler(createRegistryCenter(), createJobConfiguration3(),createJobEventConfiguration(), new SkuWarehouseRedundancyJobListener()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration4(),createJobEventConfiguration(), new SkuWarehouseSalesJobListener()).init();
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
@@ -60,6 +63,13 @@ public class Application {
         return simpleJobRootConfig;
     }
 
+    private static LiteJobConfiguration createJobConfiguration4() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_NAME_SKUWAREHOUSESALES"), propertiesUtil.getPropertyAsString("JOB_CRON_SKUWAREHOUSESALES"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, SkuWarehouseSalesJob.class.getCanonicalName());
+        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
+        return simpleJobRootConfig;
+    }
+
     private static JobEventConfiguration createJobEventConfiguration() {
         JobEventConfiguration jobEventRdbConfig = new JobEventRdbConfiguration(setUpEventTraceDataSource());
         return jobEventRdbConfig;

data-mid/mid-stored-procedure/src/main/java/com/bailuntec/job/SkuWarehouseSalesJob.java

+package com.bailuntec.job;
+
+import com.bailuntec.mapper.DcBaseStockMapper;
+import com.bailuntec.utils.OkHttpUtil;
+import com.bailuntec.utils.PropertiesUtil;
+import com.bailuntec.utils.SessionUtil;
+import com.dangdang.ddframe.job.api.ShardingContext;
+import com.dangdang.ddframe.job.api.simple.SimpleJob;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+
+import java.io.IOException;
+
+@Slf4j
+public class SkuWarehouseSalesJob implements SimpleJob {
+    private OkHttpClient client = OkHttpUtil.getInstance();
+    private PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("const");
+    @Override
+    public void execute(ShardingContext shardingContext) {
+        RequestBody requestBody = RequestBody.create(null, new byte[]{});
+        Request request = new Request.Builder().url(propertiesUtil.getPropertyAsString("SKUWAREHOUSESALES_URL"))
+                .post(requestBody)
+                .addHeader("Content-Type", "application/json")
+                .build();
+        Response response = null;
+        try {
+            response = client.newCall(request).execute();
+        } catch (IOException e) {
+            throw new RuntimeException("调用SkuWarehouseSales接口失败", e);
+        } finally {
+            if (response != null) {
+                response.close();
+            }
+        }
+    }
+}

data-mid/mid-stored-procedure/src/main/java/com/bailuntec/listener/SkuWarehouseSalesJobListener.java

+package com.bailuntec.listener;
+
+import com.dangdang.ddframe.job.executor.ShardingContexts;
+import com.dangdang.ddframe.job.lite.api.listener.ElasticJobListener;
+
+public class SkuWarehouseSalesJobListener implements ElasticJobListener {
+    @Override
+    public void beforeJobExecuted(ShardingContexts shardingContexts) {
+
+    }
+
+    @Override
+    public void afterJobExecuted(ShardingContexts shardingContexts) {
+
+    }
+}

data-mid/mid-stored-procedure/src/main/resources/const.properties

-#SKUWAREHOUSEREDUNDANCY_URL=http://testdata.bailuntec.com/Api/SkuWarehouseRedundancy
 SKUWAREHOUSEREDUNDANCY_URL=http://10.0.6.16:8033/Api/SkuWarehouseRedundancy
+SKUWAREHOUSESALES_URL=http://10.0.6.16:8033/Api/SkuWarehouseSales 
\ No newline at end of file

data-mid/mid-stored-procedure/src/main/resources/job.properties

@@ -12,7 +12,9 @@ NAME_SPACE=data-center
 JOB_NAME_PROC_SYNC_DATAWAREHOUSE=mid-stored-procedure-proc-sync-datawarehouse
 JOB_NAME_SAVE_SKUWAREHOUSESTOCK=mid-stored-procedure-save-skuwarehousestock
 JOB_NAME_SKUWAREHOUSEREDUNDANCY=mid-stored-procedure-skuwarehouse-redundancy
+JOB_NAME_SKUWAREHOUSESALES=mid-stored-procedure-skuwarehousesales
 JOB_CRON_PROC_SYNC_DATAWAREHOUSE=0 0 3 * * ? * 
 JOB_CRON_SAVE_SKUWAREHOUSESTOCK=0 0 4 * * ? * 
 JOB_CRON_SKUWAREHOUSEREDUNDANCY=0 0 7 * * ? * 
+JOB_CRON_SKUWAREHOUSESALES=0 0 1 * * ? * 
 SHARDING_TOTAL_COUNT=1
\ No newline at end of file