仓库sku库龄计算

data-base/base-sync-oms-order/src/main/java/com/bailuntec/job/OrderSyncJob.java

@@ -201,7 +201,7 @@ public class OrderSyncJob extends PointJob {
                                   DcBaseOmsSkuMapper dcBaseOmsSkuMapper = SessionUtil.getSession().getMapper(DcBaseOmsSkuMapper.class);
                                   BigDecimal FBAFee = dcBaseOmsSkuMapper.selectFBAFee(dcBaseOmsSku.getBailunSku(), dcBaseOmsSku.getWebsite(), dcBaseOmsSku.getPaidTime());
                                   dcBaseOmsSku.setCostFbaFee(FBAFee == null ? BigDecimal.valueOf(0) : FBAFee);
-                                  omsOrderFBAFee = omsOrderFBAFee.add(FBAFee);
+                                  omsOrderFBAFee = omsOrderFBAFee.add(dcBaseOmsSku.getCostFbaFee());
                               }
                             //FBA的发货数不用从配货单信息拿, FBA只要下单亚马逊就发货
                             dcBaseOmsSku.setBailunSkuQuantityShipped(bailunSkuObj.getBailunSkuQuantityOrdered());

data-common/src/main/java/com/bailuntec/domain/entity/DcBaseStockOut.java

+package com.bailuntec.domain.entity;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Data
+public class DcBaseStockOut {
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.id
+     *
+     * @mbg.generated
+     */
+    private Integer id;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.gmt_create
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtCreate;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.gmt_modified
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtModified;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.bailun_sku
+     *
+     * @mbg.generated
+     */
+    private String bailunSku;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.warehouse_code
+     *
+     * @mbg.generated
+     */
+    private String warehouseCode;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.warehouse_name
+     *
+     * @mbg.generated
+     */
+    private String warehouseName;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.quantity_stock
+     *
+     * @mbg.generated
+     */
+    private Integer quantityStock;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.stock_time
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime stockTime;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_out.has_transfer
+     *
+     * @mbg.generated
+     */
+    private Integer hasTransfer;
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_out
+     *
+     * @mbg.generated
+     */
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", gmtCreate=").append(gmtCreate);
+        sb.append(", gmtModified=").append(gmtModified);
+        sb.append(", bailunSku=").append(bailunSku);
+        sb.append(", warehouseCode=").append(warehouseCode);
+        sb.append(", warehouseName=").append(warehouseName);
+        sb.append(", quantityStock=").append(quantityStock);
+        sb.append(", stockTime=").append(stockTime);
+        sb.append(", hasTransfer=").append(hasTransfer);
+        sb.append("]");
+        return sb.toString();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_out
+     *
+     * @mbg.generated
+     */
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DcBaseStockOut other = (DcBaseStockOut) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getGmtCreate() == null ? other.getGmtCreate() == null : this.getGmtCreate().equals(other.getGmtCreate()))
+            && (this.getGmtModified() == null ? other.getGmtModified() == null : this.getGmtModified().equals(other.getGmtModified()))
+            && (this.getBailunSku() == null ? other.getBailunSku() == null : this.getBailunSku().equals(other.getBailunSku()))
+            && (this.getWarehouseCode() == null ? other.getWarehouseCode() == null : this.getWarehouseCode().equals(other.getWarehouseCode()))
+            && (this.getWarehouseName() == null ? other.getWarehouseName() == null : this.getWarehouseName().equals(other.getWarehouseName()))
+            && (this.getQuantityStock() == null ? other.getQuantityStock() == null : this.getQuantityStock().equals(other.getQuantityStock()))
+            && (this.getStockTime() == null ? other.getStockTime() == null : this.getStockTime().equals(other.getStockTime()))
+            && (this.getHasTransfer() == null ? other.getHasTransfer() == null : this.getHasTransfer().equals(other.getHasTransfer()));
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_out
+     *
+     * @mbg.generated
+     */
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getGmtCreate() == null) ? 0 : getGmtCreate().hashCode());
+        result = prime * result + ((getGmtModified() == null) ? 0 : getGmtModified().hashCode());
+        result = prime * result + ((getBailunSku() == null) ? 0 : getBailunSku().hashCode());
+        result = prime * result + ((getWarehouseCode() == null) ? 0 : getWarehouseCode().hashCode());
+        result = prime * result + ((getWarehouseName() == null) ? 0 : getWarehouseName().hashCode());
+        result = prime * result + ((getQuantityStock() == null) ? 0 : getQuantityStock().hashCode());
+        result = prime * result + ((getStockTime() == null) ? 0 : getStockTime().hashCode());
+        result = prime * result + ((getHasTransfer() == null) ? 0 : getHasTransfer().hashCode());
+        return result;
+    }
+}
\ No newline at end of file

data-common/src/main/java/com/bailuntec/domain/entity/DcBaseStockRecord.java

+package com.bailuntec.domain.entity;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Data
+public class DcBaseStockRecord {
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.id
+     *
+     * @mbg.generated
+     */
+    private Integer id;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.gmt_create
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtCreate;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.gmt_modified
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtModified;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.bailun_sku
+     *
+     * @mbg.generated
+     */
+    private String bailunSku;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.warehouse_code
+     *
+     * @mbg.generated
+     */
+    private String warehouseCode;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.warehouse_name
+     *
+     * @mbg.generated
+     */
+    private String warehouseName;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.quantity_stock
+     *
+     * @mbg.generated
+     */
+    private Integer quantityStock;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.stock_time
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime stockTime;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_record.has_transfer
+     *
+     * @mbg.generated
+     */
+    private Integer hasTransfer;
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", gmtCreate=").append(gmtCreate);
+        sb.append(", gmtModified=").append(gmtModified);
+        sb.append(", bailunSku=").append(bailunSku);
+        sb.append(", warehouseCode=").append(warehouseCode);
+        sb.append(", warehouseName=").append(warehouseName);
+        sb.append(", quantityStock=").append(quantityStock);
+        sb.append(", stockTime=").append(stockTime);
+        sb.append(", hasTransfer=").append(hasTransfer);
+        sb.append("]");
+        return sb.toString();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DcBaseStockRecord other = (DcBaseStockRecord) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getGmtCreate() == null ? other.getGmtCreate() == null : this.getGmtCreate().equals(other.getGmtCreate()))
+            && (this.getGmtModified() == null ? other.getGmtModified() == null : this.getGmtModified().equals(other.getGmtModified()))
+            && (this.getBailunSku() == null ? other.getBailunSku() == null : this.getBailunSku().equals(other.getBailunSku()))
+            && (this.getWarehouseCode() == null ? other.getWarehouseCode() == null : this.getWarehouseCode().equals(other.getWarehouseCode()))
+            && (this.getWarehouseName() == null ? other.getWarehouseName() == null : this.getWarehouseName().equals(other.getWarehouseName()))
+            && (this.getQuantityStock() == null ? other.getQuantityStock() == null : this.getQuantityStock().equals(other.getQuantityStock()))
+            && (this.getStockTime() == null ? other.getStockTime() == null : this.getStockTime().equals(other.getStockTime()))
+            && (this.getHasTransfer() == null ? other.getHasTransfer() == null : this.getHasTransfer().equals(other.getHasTransfer()));
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getGmtCreate() == null) ? 0 : getGmtCreate().hashCode());
+        result = prime * result + ((getGmtModified() == null) ? 0 : getGmtModified().hashCode());
+        result = prime * result + ((getBailunSku() == null) ? 0 : getBailunSku().hashCode());
+        result = prime * result + ((getWarehouseCode() == null) ? 0 : getWarehouseCode().hashCode());
+        result = prime * result + ((getWarehouseName() == null) ? 0 : getWarehouseName().hashCode());
+        result = prime * result + ((getQuantityStock() == null) ? 0 : getQuantityStock().hashCode());
+        result = prime * result + ((getStockTime() == null) ? 0 : getStockTime().hashCode());
+        result = prime * result + ((getHasTransfer() == null) ? 0 : getHasTransfer().hashCode());
+        return result;
+    }
+}
\ No newline at end of file

data-common/src/main/java/com/bailuntec/domain/entity/DcMidStockDate.java

+package com.bailuntec.domain.entity;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Data
+public class DcMidStockDate {
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.id
+     *
+     * @mbg.generated
+     */
+    private Integer id;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.gmt_create
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtCreate;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.gmt_modified
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtModified;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.bailun_sku
+     *
+     * @mbg.generated
+     */
+    private String bailunSku;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.warehouse_code
+     *
+     * @mbg.generated
+     */
+    private String warehouseCode;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.warehouse_name
+     *
+     * @mbg.generated
+     */
+    private String warehouseName;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.quantity_stock
+     *
+     * @mbg.generated
+     */
+    private Integer quantityStock;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.stock_time
+     *
+     * @mbg.generated
+     */
+    private LocalDate stockTime;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.unit_price
+     *
+     * @mbg.generated
+     */
+    private BigDecimal unitPrice;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.has_transfer
+     *
+     * @mbg.generated
+     */
+    private Integer hasTransfer;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_mid_stock_date.report_date
+     *
+     * @mbg.generated
+     */
+    private LocalDate reportDate;
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_mid_stock_date
+     *
+     * @mbg.generated
+     */
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", id=").append(id);
+        sb.append(", gmtCreate=").append(gmtCreate);
+        sb.append(", gmtModified=").append(gmtModified);
+        sb.append(", bailunSku=").append(bailunSku);
+        sb.append(", warehouseCode=").append(warehouseCode);
+        sb.append(", warehouseName=").append(warehouseName);
+        sb.append(", quantityStock=").append(quantityStock);
+        sb.append(", stockTime=").append(stockTime);
+        sb.append(", unitPrice=").append(unitPrice);
+        sb.append(", hasTransfer=").append(hasTransfer);
+        sb.append(", reportDate=").append(reportDate);
+        sb.append("]");
+        return sb.toString();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_mid_stock_date
+     *
+     * @mbg.generated
+     */
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DcMidStockDate other = (DcMidStockDate) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getGmtCreate() == null ? other.getGmtCreate() == null : this.getGmtCreate().equals(other.getGmtCreate()))
+            && (this.getGmtModified() == null ? other.getGmtModified() == null : this.getGmtModified().equals(other.getGmtModified()))
+            && (this.getBailunSku() == null ? other.getBailunSku() == null : this.getBailunSku().equals(other.getBailunSku()))
+            && (this.getWarehouseCode() == null ? other.getWarehouseCode() == null : this.getWarehouseCode().equals(other.getWarehouseCode()))
+            && (this.getWarehouseName() == null ? other.getWarehouseName() == null : this.getWarehouseName().equals(other.getWarehouseName()))
+            && (this.getQuantityStock() == null ? other.getQuantityStock() == null : this.getQuantityStock().equals(other.getQuantityStock()))
+            && (this.getStockTime() == null ? other.getStockTime() == null : this.getStockTime().equals(other.getStockTime()))
+            && (this.getUnitPrice() == null ? other.getUnitPrice() == null : this.getUnitPrice().equals(other.getUnitPrice()))
+            && (this.getHasTransfer() == null ? other.getHasTransfer() == null : this.getHasTransfer().equals(other.getHasTransfer()))
+            && (this.getReportDate() == null ? other.getReportDate() == null : this.getReportDate().equals(other.getReportDate()));
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_mid_stock_date
+     *
+     * @mbg.generated
+     */
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getGmtCreate() == null) ? 0 : getGmtCreate().hashCode());
+        result = prime * result + ((getGmtModified() == null) ? 0 : getGmtModified().hashCode());
+        result = prime * result + ((getBailunSku() == null) ? 0 : getBailunSku().hashCode());
+        result = prime * result + ((getWarehouseCode() == null) ? 0 : getWarehouseCode().hashCode());
+        result = prime * result + ((getWarehouseName() == null) ? 0 : getWarehouseName().hashCode());
+        result = prime * result + ((getQuantityStock() == null) ? 0 : getQuantityStock().hashCode());
+        result = prime * result + ((getStockTime() == null) ? 0 : getStockTime().hashCode());
+        result = prime * result + ((getUnitPrice() == null) ? 0 : getUnitPrice().hashCode());
+        result = prime * result + ((getHasTransfer() == null) ? 0 : getHasTransfer().hashCode());
+        result = prime * result + ((getReportDate() == null) ? 0 : getReportDate().hashCode());
+        return result;
+    }
+}
\ No newline at end of file

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

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

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

+package com.bailuntec.mapper;
+
+import com.bailuntec.domain.entity.DcBaseOmsPick;
+import com.bailuntec.domain.entity.DcBaseStockRecord;
+import com.bailuntec.domain.entity.JobPointLog;
+import com.bailuntec.domain.example.DcBaseStockRecordExample;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface DcBaseStockRecordMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    long countByExample(DcBaseStockRecordExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int deleteByExample(DcBaseStockRecordExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int deleteByPrimaryKey(Integer id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int insert(DcBaseStockRecord record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int insertSelective(DcBaseStockRecord record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    DcBaseStockRecord selectOneByExample(DcBaseStockRecordExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    List<DcBaseStockRecord> selectByExample(DcBaseStockRecordExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    DcBaseStockRecord selectByPrimaryKey(Integer id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int updateByExampleSelective(@Param("record") DcBaseStockRecord record, @Param("example") DcBaseStockRecordExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int updateByExample(@Param("record") DcBaseStockRecord record, @Param("example") DcBaseStockRecordExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeySelective(DcBaseStockRecord record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKey(DcBaseStockRecord record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    int upsert(DcBaseStockRecord record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_record
+     *
+     * @mbg.generated
+     * @project https://github.com/itfsw/mybatis-generator-plugin
+     */
+    int upsertSelective(DcBaseStockRecord record);
+
+    /**
+     * 根据仓库、sku，入库时间升序查询入库sku记录
+     * @param bailunSku
+     * @param warehouseCode
+     * @return
+     */
+    List<DcBaseStockRecord> selectByStockTime(@Param("bailunSku")String bailunSku, @Param("warehouseCode")String warehouseCode);
+
+    List<DcBaseStockRecord> selectPageByGroup(JobPointLog jobPointLog);
+
+    /**
+     *  根据仓库、sku分组计算入库数量
+     * @param jobPointLog
+     * @return
+     */
+    Integer selectCountByGroup(JobPointLog jobPointLog);
+
+    List<DcBaseOmsPick> selectListByPage(JobPointLog jobPointLog);
+
+    Integer selectOrderPickCount(JobPointLog jobPointLog);
+}
\ No newline at end of file

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

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

data-mid/mid-duration-stock/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>data-mid</artifactId>
+        <groupId>com.bailuntec</groupId>
+        <version>1.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>mid-duration-stock</artifactId>
+
+    <dependencies>
+
+
+        <dependency>
+            <groupId>com.bailuntec</groupId>
+            <artifactId>data-common</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>RELEASE</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+            </plugin>
+            <plugin>
+                <artifactId>maven-assembly-plugin</artifactId>
+                <version>3.1.0</version>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <mainClass>com.bailuntec.Application</mainClass>
+                        </manifest>
+                    </archive>
+                    <descriptorRefs>
+                        <descriptorRef>jar-with-dependencies</descriptorRef>
+                    </descriptorRefs>
+                    <appendAssemblyId>false</appendAssemblyId>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>make-assembly</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>single</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <includes>
+                    <include>**/*.xml</include>
+                    <include>**/*.properties</include>
+                </includes>
+                <!--默认是true-->
+                <filtering>true</filtering>
+            </resource>
+            <resource>
+                <directory>src/main/java</directory>
+                <includes>
+                    <include>**/*.xml</include>
+                    <include>**/*.properties</include>
+                </includes>
+            </resource>
+        </resources>
+    </build>
+</project>

data-mid/mid-duration-stock/src/main/java/Application.java

+import com.alibaba.druid.pool.DruidDataSource;
+import com.bailuntec.job.SyncWarehouseStockJob;
+import com.bailuntec.utils.PropertiesUtil;
+import com.dangdang.ddframe.job.config.JobCoreConfiguration;
+import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
+import com.dangdang.ddframe.job.event.JobEventConfiguration;
+import com.dangdang.ddframe.job.event.rdb.JobEventRdbConfiguration;
+import com.dangdang.ddframe.job.lite.api.JobScheduler;
+import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
+import com.dangdang.ddframe.job.reg.base.CoordinatorRegistryCenter;
+import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
+import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
+import lombok.extern.slf4j.Slf4j;
+
+import javax.sql.DataSource;
+
+@Slf4j
+public class Application {
+
+
+    private static PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("job");
+    private static final String EVENT_RDB_STORAGE_DRIVER = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_DRIVER");
+    private static final String EVENT_RDB_STORAGE_URL = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_URL");
+    private static final String EVENT_RDB_STORAGE_USERNAME = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_USERNAME");
+    private static final String EVENT_RDB_STORAGE_PASSWORD = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_PASSWORD");
+    public static void main(String[] args) {
+        new JobScheduler(createRegistryCenter(), createJobConfiguration1()).init();
+    }
+
+    private static CoordinatorRegistryCenter createRegistryCenter() {
+        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration(propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"), propertiesUtil.getPropertyAsString("NAME_SPACE")));
+        regCenter.init();
+        return regCenter;
+    }
+
+    private static LiteJobConfiguration createJobConfiguration1() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_NAME_BALE"), propertiesUtil.getPropertyAsString("JOB_CRON_BALE"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, SyncWarehouseStockJob.class.getCanonicalName());
+        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
+        return simpleJobRootConfig;
+    }
+
+    private static JobEventConfiguration createJobEventConfiguration() {
+        JobEventConfiguration jobEventRdbConfig = new JobEventRdbConfiguration(setUpEventTraceDataSource());
+        return jobEventRdbConfig;
+    }
+
+    private static DataSource setUpEventTraceDataSource() {
+        DruidDataSource result = new DruidDataSource();
+        result.setDriverClassName(EVENT_RDB_STORAGE_DRIVER);
+        result.setUrl(EVENT_RDB_STORAGE_URL);
+        result.setUsername(EVENT_RDB_STORAGE_USERNAME);
+        result.setPassword(EVENT_RDB_STORAGE_PASSWORD);
+        return result;
+    }
+
+}

data-mid/mid-duration-stock/src/main/java/com/bailuntec/domain/dto/PurchaseDetailDTO.java

+package com.bailuntec.domain.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+@Data
+public class PurchaseDetailDTO {
+    @JSONField(name = "parentid")
+    private Integer parentId;
+    @JSONField(name = "CreateTime")
+    private Date createdTime;
+    @JSONField(name = "no")
+    private String commonId;
+    @JSONField(name = "skuname")
+    private String skuName;
+    @JSONField(name = "skucode")
+    private String bailunSku;
+    @JSONField(name = "purchaseno")
+    private String purchaseId;
+    @JSONField(name = "warehousecode")
+    private String warehouseCode;
+    @JSONField(name = "warehousename")
+    private String warehouseName;
+    @JSONField(name = "status")
+    private String status;
+    @JSONField(name = "arrivaldate")
+    private Date arrivaldate;
+    @JSONField(name = "UpdateTime")
+    private Date updatedTime;
+    @JSONField(name = "count")
+    private Integer count;
+    @JSONField(name = "isallot")
+    private Integer hasTransfer;
+    @JSONField(name = "qccount")
+    private Integer qualifiedCount;
+    @JSONField(name = "transporttype")
+    private Integer transportType;
+    @JSONField(name = "suretime")
+    private Date suretime;
+    @JSONField(name = "lastpaytime")
+    private Date lastpaytime;
+    @JSONField(name = "paytype")
+    private Integer payType;
+    @JSONField(name = "supplierid")//采购系统接口中,supplierid是采购系统自创的供应商id
+    private Integer deliverId;
+    @JSONField(name = "suppliername")
+    private String supplierName;
+    @JSONField(name = "payprice")
+    private BigDecimal price;
+    @JSONField(name = "buystatus")
+    private Integer buyStatus;
+    @JSONField(name = "deliverid")//采购系统接口中,deliverid是skuMS的供应商id
+    private Integer supplierId;
+    @JSONField(name = "skudelstatus")//采购系统接口中,deliverid是skuMS的供应商id
+    private Integer hasDelete;
+
+
+}

data-mid/mid-duration-stock/src/main/java/com/bailuntec/domain/dto/TransferDetailsPOJO.java

+package com.bailuntec.domain.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class TransferDetailsPOJO {
+    private Integer pageRow;
+
+    private Integer pageCount;
+
+    private Integer currentPage;
+
+    private List<TransferStreamPOJO> data;
+
+}

data-mid/mid-duration-stock/src/main/java/com/bailuntec/domain/dto/TransferStreamPOJO.java

+package com.bailuntec.domain.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.google.gson.annotations.JsonAdapter;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Data
+public class TransferStreamPOJO {
+
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.bailun_sku
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "sku")
+       private String bailunSku;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.transfer_order_id
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "orderCode")
+       private String transferOrderId;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.transfer_order_id
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "scheduleCode")
+       private String transferPlanOrderId;
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.warehouse_code
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "targetWareCode")
+       private String warehouseCode;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.warehouse_name
+        *
+        * @mbg.generated
+        */
+       private String warehouseName;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.status
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "state")
+       private String status;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.create_time
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "creationTime")
+       private LocalDateTime createTime;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.create_time
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "updateTime")
+       private LocalDateTime updateTime;
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.create_time
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "expectArrivalTime")
+       private LocalDateTime estimatedArrivalTime;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.count
+        *
+        * @mbg.generated
+        */
+       private Integer count;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.sku_title
+        *
+        * @mbg.generated
+        */
+       private String skuTitle;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.transfer_key
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "id")
+       private Integer transferKey;
+
+       /**
+        *
+        * This field was generated by MyBatis Generator.
+        * This field corresponds to the database column dc_base_transfer_bale.deleted
+        *
+        * @mbg.generated
+        */
+       @JSONField(name = "isDeleted")
+       private Boolean deleted;
+
+       @JSONField(name = "sourceWareNo")
+       private String fromWarehouseCode;
+}

data-mid/mid-duration-stock/src/main/java/com/bailuntec/job/CalculateStockRecordJob.java

+package com.bailuntec.job;
+
+import com.bailuntec.domain.entity.DcBaseSku;
+import com.bailuntec.domain.entity.DcBaseStockRecord;
+import com.bailuntec.domain.entity.DcMidStockDate;
+import com.bailuntec.domain.entity.JobPointLog;
+import com.bailuntec.domain.example.DcBaseSkuExample;
+import com.bailuntec.mapper.DcBaseSkuMapper;
+import com.bailuntec.mapper.DcBaseStockOutMapper;
+import com.bailuntec.mapper.DcBaseStockRecordMapper;
+import com.bailuntec.mapper.DcMidStockDateMapper;
+import com.bailuntec.support.PointJob;
+import com.bailuntec.utils.SessionUtil;
+import com.dangdang.ddframe.job.api.ShardingContext;
+import lombok.extern.slf4j.Slf4j;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Slf4j
+public class CalculateStockRecordJob extends PointJob {
+
+
+    @Override
+    public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
+
+        jobPointLog.setPageIndex(jobPointLog.getPageIndex() == 0 ? 1 : jobPointLog.getPageIndex());
+        Integer pickSize = 0;
+        try {
+            // 根据仓库、sku分组分页查询sku数量
+            DcBaseStockRecordMapper dcBaseStockRecordMapper = SessionUtil.getSession().getMapper(DcBaseStockRecordMapper.class);
+            pickSize = dcBaseStockRecordMapper.selectCountByGroup(jobPointLog);
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new RuntimeException("MYbatis操作DB失败", e);
+        } finally {
+            SessionUtil.closeSession();
+        }
+        Integer pageSize = pickSize % jobPointLog.getPageSize() == 0 ? pickSize/jobPointLog.getPageSize() : pickSize/jobPointLog.getPageSize() + 1;
+
+        LocalDateTime localDateTime = LocalDateTime.now();
+
+        do{
+            // 根据仓库、sku分组分页查询sku
+            DcBaseStockRecordMapper dcBaseStockRecordMapper = SessionUtil.getSession().getMapper(DcBaseStockRecordMapper.class);
+            List<DcBaseStockRecord> dcBaseStockRecordList = dcBaseStockRecordMapper.selectPageByGroup(jobPointLog);
+
+            for(DcBaseStockRecord dcBaseStockRecord : dcBaseStockRecordList) {
+
+                // 根据仓库、sku计算出库数量
+                DcBaseStockOutMapper dcBaseStockOutMapper = SessionUtil.getSession().getMapper(DcBaseStockOutMapper.class);
+                Integer stockOut = dcBaseStockOutMapper.selectCount(dcBaseStockRecord.getBailunSku(), dcBaseStockRecord.getWarehouseCode());
+
+                // 根据仓库、sku，入库时间升序查询入库sku记录
+                DcBaseStockRecordMapper midDcBaseStockRecordMapper = SessionUtil.getSession().getMapper(DcBaseStockRecordMapper.class);
+                List<DcBaseStockRecord> baseStockRecordList = midDcBaseStockRecordMapper.selectByStockTime(dcBaseStockRecord.getBailunSku(), dcBaseStockRecord.getWarehouseCode());
+                Integer quantityStock = 0;
+                boolean firstMatch = true;
+                for(DcBaseStockRecord midDcBaseStockRecord : baseStockRecordList) {
+                    quantityStock = quantityStock + midDcBaseStockRecord.getQuantityStock();
+                    if(quantityStock > stockOut) {
+                        DcMidStockDate dcMidStockDate = new DcMidStockDate();
+                        DcBaseSkuMapper dcBaseSkuMapper = SessionUtil.getSession().getMapper(DcBaseSkuMapper.class);
+                        DcBaseSku dcBaseSku = dcBaseSkuMapper.selectOneByExample(DcBaseSkuExample.newAndCreateCriteria().andBailunSkuEqualTo(midDcBaseStockRecord.getBailunSku()).andCompanyIdEqualTo(1).example());
+                        if(dcBaseSku != null) {
+                         dcMidStockDate.setUnitPrice(dcBaseSku.getUnitPrice());
+                        }
+                        dcMidStockDate.setBailunSku(midDcBaseStockRecord.getBailunSku());
+                        dcMidStockDate.setWarehouseCode(midDcBaseStockRecord.getWarehouseCode());
+                        dcMidStockDate.setWarehouseName(midDcBaseStockRecord.getWarehouseName());
+                        dcMidStockDate.setGmtCreate(midDcBaseStockRecord.getGmtCreate());
+                        dcMidStockDate.setGmtModified(midDcBaseStockRecord.getGmtModified());
+                        dcMidStockDate.setStockTime(midDcBaseStockRecord.getStockTime().toLocalDate());
+                        dcMidStockDate.setGmtModified(localDateTime);
+                        if(firstMatch) {
+                            dcMidStockDate.setQuantityStock(quantityStock - stockOut);
+                        }else{
+                            dcMidStockDate.setQuantityStock(midDcBaseStockRecord.getQuantityStock());
+                        }
+                       // dcMidStockDate.setHasTransfer(midDcBaseStockRecord.getHasTransfer());
+                        dcMidStockDate.setReportDate(localDateTime.toLocalDate());
+                        try {
+                            DcMidStockDateMapper dcMidStockDateMapper = SessionUtil.getSession().getMapper(DcMidStockDateMapper.class);
+                            dcMidStockDateMapper.upsertSelective(dcMidStockDate);
+                            firstMatch = false;
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                            throw new RuntimeException("MYbatis操作DB失败", e);
+                        } finally {
+                            SessionUtil.closeSession();
+                        }
+                    }
+                }
+            }
+            jobPointLog.setPageIndex(jobPointLog.getPageIndex() + 1);
+        }while(jobPointLog.getPageIndex() <= pageSize);
+    }
+}

data-mid/mid-duration-stock/src/test/java/com/bailuntec/ApplicationTest.java

+package com.bailuntec;
+
+import com.bailuntec.domain.entity.DcBaseStock;
+import com.bailuntec.domain.entity.DcBaseStockRecord;
+import com.bailuntec.domain.entity.JobPointLog;
+import com.bailuntec.domain.example.DcBaseStockExample;
+import com.bailuntec.domain.example.DcBaseStockRecordExample;
+import com.bailuntec.job.CalculateStockRecordJob;
+import com.bailuntec.job.SyncWarehouseStockJob;
+import com.bailuntec.mapper.DcBaseStockMapper;
+import com.bailuntec.mapper.DcBaseStockRecordMapper;
+import com.bailuntec.utils.SessionUtil;
+import org.junit.jupiter.api.Test;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class ApplicationTest {
+
+    @Test
+    public void syncStock() {
+        DcBaseStockMapper dcBaseStockMapper = SessionUtil.getSession().getMapper(DcBaseStockMapper.class);
+        List<DcBaseStock>  dcBaseStockList = dcBaseStockMapper.selectByExample(DcBaseStockExample.newAndCreateCriteria().andUpdateTimeLessThan(LocalDateTime.of(2019, 9, 10, 00, 00, 00)).example());
+        for(DcBaseStock dcBaseStock : dcBaseStockList) {
+            try {
+                DcBaseStockRecord dcBaseStockRecord = new DcBaseStockRecord();
+                dcBaseStockRecord.setStockTime(dcBaseStock.getUpdateTime());
+                dcBaseStockRecord.setBailunSku(dcBaseStock.getBailunSku());
+                dcBaseStockRecord.setWarehouseCode(dcBaseStock.getWarehouseCode());
+                dcBaseStockRecord.setQuantityStock(dcBaseStock.getUsableStock());
+                DcBaseStockRecordMapper mapper = SessionUtil.getSession().getMapper(DcBaseStockRecordMapper.class);
+                int i = mapper.updateByExampleSelective(dcBaseStockRecord, DcBaseStockRecordExample.newAndCreateCriteria().andBailunSkuEqualTo(dcBaseStockRecord.getBailunSku()).andWarehouseCodeEqualTo(dcBaseStockRecord.getWarehouseCode()).andStockTimeEqualTo(dcBaseStockRecord.getStockTime()).example());
+                if (i == 0) {
+                    mapper.insertSelective(dcBaseStockRecord);
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+                throw new RuntimeException("MYbatis操作DB失败", e);
+            } finally {
+                SessionUtil.closeSession();
+            }
+        }
+    }
+
+    @Test
+    public void syncPurchaseDetail() {
+        SyncWarehouseStockJob syncWarehouseStockJob = new SyncWarehouseStockJob();
+        JobPointLog jobPointLog = new JobPointLog();
+        jobPointLog.setStartTime(LocalDateTime.of(2019, 01, 01 , 00, 00, 00));
+        jobPointLog.setEndTime(LocalDateTime.of(2019, 9, 03 , 00, 00, 00));
+        jobPointLog.setPageIndex(0);
+        jobPointLog.setPageSize(100);
+        jobPointLog.setType(5);
+        jobPointLog.setIntervalTime(1);
+        jobPointLog.setJobName("syncPurchaseDetail");
+        syncWarehouseStockJob.syncPurchaseDetail(null, jobPointLog);
+    }
+
+    @Test
+    public void syncTransferInbound() {
+        SyncWarehouseStockJob syncWarehouseStockJob = new SyncWarehouseStockJob();
+        JobPointLog jobPointLog = new JobPointLog();
+        jobPointLog.setStartTime(LocalDateTime.of(2019, 01, 01 , 00, 00, 00));
+        jobPointLog.setEndTime(LocalDateTime.of(2019, 9, 03 , 00, 00, 00));
+        jobPointLog.setPageIndex(0);
+        jobPointLog.setPageSize(100);
+        jobPointLog.setType(5);
+        jobPointLog.setIntervalTime(1);
+        jobPointLog.setJobName("syncPurchaseDetail");
+        syncWarehouseStockJob.syncTransferInbound(null, jobPointLog);
+    }
+
+    @Test
+    public void syncOrderPick() {
+        SyncWarehouseStockJob syncWarehouseStockJob = new SyncWarehouseStockJob();
+        JobPointLog jobPointLog = new JobPointLog();
+        jobPointLog.setStartTime(LocalDateTime.of(2019, 01, 01 , 00, 00, 00));
+        jobPointLog.setEndTime(LocalDateTime.of(2019, 9, 03 , 00, 00, 00));
+        jobPointLog.setPageIndex(1);
+        jobPointLog.setPageSize(100);
+        jobPointLog.setType(5);
+        jobPointLog.setIntervalTime(1);
+        jobPointLog.setJobName("syncPurchaseDetail");
+        syncWarehouseStockJob.syncOrderPick(null, jobPointLog);
+    }
+
+    @Test
+    public void calculateDutation() {
+        CalculateStockRecordJob calculateStockRecordJob = new CalculateStockRecordJob();
+        JobPointLog jobPointLog = new JobPointLog();
+        jobPointLog.setStartTime(LocalDateTime.of(2019, 07, 01 , 00, 00, 00));
+        jobPointLog.setEndTime(LocalDateTime.of(2019, 9, 02 , 00, 00, 00));
+        jobPointLog.setPageIndex(1);
+        jobPointLog.setPageSize(100);
+        jobPointLog.setType(5);
+        jobPointLog.setIntervalTime(1);
+        jobPointLog.setJobName("syncPurchaseDetail");
+        calculateStockRecordJob.executeJob(null, jobPointLog);
+    }
+}

data-mid/pom.xml

@@ -15,6 +15,7 @@
         <module>mid-daily-stock</module>
         <module>mid-auto-turnover-prepare</module>
         <module>mid-calculate-cost-first</module>
+        <module>mid-duration-stock</module>
     </modules>
 
     <parent>