# 更新

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

+package com.bailuntec.mapper;
+
+import com.bailuntec.domain.entity.DcReportProfitAnalysis;
+import com.bailuntec.domain.example.DcReportProfitAnalysisExample;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+public interface DcReportProfitAnalysisMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    long countByExample(DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int deleteByExample(DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int deleteByPrimaryKey(Integer id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int insert(DcReportProfitAnalysis record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int insertSelective(DcReportProfitAnalysis record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    DcReportProfitAnalysis selectOneByExample(DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    DcReportProfitAnalysis selectOneByExampleWithBLOBs(DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    List<DcReportProfitAnalysis> selectByExampleWithBLOBs(DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    List<DcReportProfitAnalysis> selectByExample(DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    DcReportProfitAnalysis selectByPrimaryKey(Integer id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int updateByExampleSelective(@Param("record") DcReportProfitAnalysis record, @Param("example") DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int updateByExampleWithBLOBs(@Param("record") DcReportProfitAnalysis record, @Param("example") DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int updateByExample(@Param("record") DcReportProfitAnalysis record, @Param("example") DcReportProfitAnalysisExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeySelective(DcReportProfitAnalysis record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeyWithBLOBs(DcReportProfitAnalysis record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKey(DcReportProfitAnalysis record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    int upsert(DcReportProfitAnalysis record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    int upsertSelective(DcReportProfitAnalysis record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_report_profit_analysis
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    int upsertWithBLOBs(DcReportProfitAnalysis record);
+}
\ No newline at end of file

data-common/src/main/resources/init.properties

-table-name=dc_auto_turnover_air
+table-name=dc_report_profit_analysis

data-show/show-auto-turnover/src/main/resources/job.properties

@@ -13,9 +13,9 @@ NAME_SPACE=data-center
 #JOB_NAME_WEEK=show-auto-turnover-week
 #JOB_NAME_WEEK=0 0 10 ? * MON
 
-JOB_NAME=show-auto-turnover78
-#JOB_CRON=0 0 3 * * ?
-JOB_CRON=0 30 15 * * ?
+JOB_NAME=show-auto-turnover79
+JOB_CRON=0 0 3 * * ?
+#JOB_CRON=0 30 15 * * ?
 
 SHARDING_TOTAL_COUNT=8
 JOB_NAME_NE_NORMAL=show-auto-turnover-ne-normal

data-show/show-auto-turnover/src/test/java/AutoTurnoverTest.java

@@ -4,13 +4,11 @@ import com.alibaba.excel.context.AnalysisContext;
 import com.alibaba.excel.event.AnalysisEventListener;
 import com.alibaba.fastjson.JSON;
 import com.bailuntec.domain.constant.CommonConstant;
-import com.bailuntec.domain.entity.DcBaseQueue;
-import com.bailuntec.domain.entity.DcBaseStock;
-import com.bailuntec.domain.entity.JobPointLog;
-import com.bailuntec.domain.entity.SalesDayConfig;
+import com.bailuntec.domain.entity.*;
 import com.bailuntec.domain.example.DcAutoTurnoverExample;
 import com.bailuntec.domain.example.DcBaseStockExample;
 import com.bailuntec.domain.example.DcMidTransitExample;
+import com.bailuntec.domain.example.DcReportProfitAnalysisExample;
 import com.bailuntec.excel.DcAutoTurnoverExcel;
 import com.bailuntec.excel.ExcelListener;
 import com.bailuntec.job.AutoTurnoverJob;
@@ -33,7 +31,6 @@ import org.springframework.transaction.annotation.Transactional;
 import java.io.Serializable;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
-import java.time.LocalTime;
 import java.time.Period;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
@@ -259,8 +256,8 @@ public class AutoTurnoverTest {
     public void testXX2() {
         DcBaseStock dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class)
                 .selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
-                        .andBailunSkuEqualTo("942967401")
-                        .andWarehouseCodeEqualTo("GZBLWH")
+                        .andBailunSkuEqualTo("944766402")
+                        .andWarehouseCodeEqualTo("ESFBABLEM")
                         .example());
         try {
             AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
@@ -282,13 +279,14 @@ public class AutoTurnoverTest {
     public void testQueue() {
         DcBaseStockMapper dcBaseStockMapper = SessionUtil.getSession().getMapper(DcBaseStockMapper.class);
         DcBaseQueueMapper dcBaseQueueMapper = SessionUtil.getSession().getMapper(DcBaseQueueMapper.class);
+        DcReportProfitAnalysisMapper dcReportProfitAnalysisMapper = SessionUtil.getSession().getMapper(DcReportProfitAnalysisMapper.class);
+        List<DcReportProfitAnalysis> dcReportProfitAnalysisList = dcReportProfitAnalysisMapper.selectByExample(DcReportProfitAnalysisExample.newAndCreateCriteria().example());
 
-        List<DcBaseStock> dcBaseStockList = dcBaseStockMapper.selectNew(LocalDateTime.of(LocalDate.now().minusDays(2), LocalTime.MIN));
-        dcBaseStockList.forEach(dcBaseStock -> {
+        dcReportProfitAnalysisList.forEach(dcReportProfitAnalysis -> {
             DcBaseQueue dcBaseQueue = new DcBaseQueue();
             QueueConsumerJob.BaseQueueMessage message = new QueueConsumerJob.BaseQueueMessage();
-            message.setBailunSku(dcBaseStock.getBailunSku());
-            message.setWarehouseCode(dcBaseStock.getWarehouseCode());
+            message.setBailunSku(dcReportProfitAnalysis.getBailunSku());
+            message.setWarehouseCode(dcReportProfitAnalysis.getWarehouseCode());
 
             dcBaseQueue.setMessage(JSON.toJSONString(message));
             dcBaseQueue.setType("10");