数据中心-半成品每日库存

data-base/base-sync-semi-order/src/main/java/com/bailuntec/Application.java

@@ -2,6 +2,7 @@ package com.bailuntec;
 
 import com.alibaba.druid.pool.DruidDataSource;
 import com.bailuntec.job.SemiOrderSyncJob;
+import com.bailuntec.job.SemiStockProdDailySyncJob;
 import com.bailuntec.job.SemiStockProdSyncJob;
 import com.bailuntec.job.SemiStockReportSyncJob;
 import com.bailuntec.listener.SemiOrderSyncJobListener;
@@ -30,6 +31,7 @@ public class Application {
         new JobScheduler(createRegistryCenter(), createJobConfiguration(),createJobEventConfiguration(), new SemiOrderSyncJobListener()).init();
         new JobScheduler(createRegistryCenter(), createJobConfiguration1(), createJobEventConfiguration()).init();
         new JobScheduler(createRegistryCenter(), createJobConfiguration2(), createJobEventConfiguration()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration3(), createJobEventConfiguration()).init();
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
@@ -59,6 +61,13 @@ public class Application {
         return simpleJobRootConfig;
     }
 
+    private static LiteJobConfiguration createJobConfiguration3() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_STOCK_PROD_DAILY_NAME"), propertiesUtil.getPropertyAsString("JOB_STOCK_PROD_DAILY_CRON"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, SemiStockProdDailySyncJob.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-semi-order/src/main/java/com/bailuntec/job/SemiStockProdDailySyncJob.java

+package com.bailuntec.job;
+
+
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
+import com.bailuntec.domain.entity.DcSemiStockProd;
+import com.bailuntec.domain.entity.JobPointLog;
+import com.bailuntec.domain.pojo.SemiStockReportInfo;
+import com.bailuntec.mapper.DcSemiStockProdMapper;
+import com.bailuntec.mapper.JobPointLogMapper;
+import com.bailuntec.support.PointJob;
+import com.bailuntec.utils.ExceptionUtil;
+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.util.LinkedHashMap;
+import java.util.List;
+
+@Slf4j
+public class SemiStockProdDailySyncJob extends PointJob {
+
+    @Override
+    public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
+        DcSemiStockProdMapper mapper = SessionUtil.getSession().getMapper(DcSemiStockProdMapper.class);
+        mapper.insertDaily();
+    }
+}

data-base/base-sync-semi-order/src/main/resources/job.properties

@@ -15,4 +15,6 @@ JOB_STOCK_NAME=base_sync_semi_stock
 JOB_STOCK_CRON=0/10 * * * * ? *
 JOB_STOCK_PROD_NAME=base-sync-semi-prod
 JOB_STOCK_PROD_CRON=0/10 * * * * ? *
+JOB_STOCK_PROD_DAILY_NAME=base-sync-semi-prod-daily
+JOB_STOCK_PROD_DAILY_CRON=0 0 0 * * ? *
 SHARDING_TOTAL_COUNT=1
\ No newline at end of file

data-common/src/main/java/com/bailuntec/mapper/DcSemiStockProdMapper.java

@@ -121,4 +121,6 @@ public interface DcSemiStockProdMapper {
      * @project https://github.com/itfsw/mybatis-generator-plugin
      */
     int upsertSelective(DcSemiStockProd record);
+
+    int insertDaily();
 }
\ No newline at end of file

data-common/src/main/java/com/bailuntec/mapper/DcSemiStockProdMapper.xml

@@ -559,4 +559,17 @@
     </if>
     limit 1
   </select>
+
+  <insert id="insertDaily">
+insert into dc_semi_stock_prod_daily (material_id, warehouse_id,
+      jit_prod_stock, plan_prod_stock, warehouse_name,
+      material_code, material_name, material_category,
+      new_price, gmt_create, gmt_modify, record_time
+      )
+      select material_id, warehouse_id,
+      jit_prod_stock, plan_prod_stock, warehouse_name,
+      material_code, material_name, material_category,
+      new_price, gmt_create, gmt_modify, DATE_SUB( CURDATE( ), INTERVAL 1 DAY )
+      from dc_semi_stock_prod
+  </insert>
 </mapper>
\ No newline at end of file