同步FBA库存时,将共享库存分配到一个仓库上.

data-base/base-sync-stock-wms/src/main/java/com/bailuntec/listener/FbaStockListener.java

@@ -9,8 +9,10 @@ public class FbaStockListener implements ElasticJobListener {
 
     }
 
+
     @Override
     public void afterJobExecuted(ShardingContexts shardingContexts) {
 
+
     }
 }

data-base/base-sync-stock-wms/src/main/java/com/bailuntec/mapper/DcBaseStockConfigFbaMapper.java

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

data-base/base-sync-stock-wms/src/test/java/DailyStockTest.java

@@ -22,7 +22,7 @@ public class DailyStockTest {
         FbaStockJob fbaStockJob = new FbaStockJob();
         JobPointLog jobPointLog = new JobPointLog();
         jobPointLog.setPageIndex(1);
-        jobPointLog.setPageSize(10000);
+        jobPointLog.setPageSize(1000);
         fbaStockJob.executeJob(null,jobPointLog);
     }
 

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

+package com.bailuntec.domain.entity;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Data
+public class DcBaseStockConfigFba {
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_config_fba.id
+     *
+     * @mbg.generated
+     */
+    private Integer id;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_config_fba.platform_sku
+     *
+     * @mbg.generated
+     */
+    private String platformSku;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_config_fba.warehouse_code
+     *
+     * @mbg.generated
+     */
+    private String warehouseCode;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_config_fba.warehouse_name
+     *
+     * @mbg.generated
+     */
+    private String warehouseName;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_config_fba.gmt_create
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtCreate;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_config_fba.gmt_modified
+     *
+     * @mbg.generated
+     */
+    private LocalDateTime gmtModified;
+
+    /**
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column dc_base_stock_config_fba.bl_operator
+     *
+     * @mbg.generated
+     */
+    private String blOperator;
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_config_fba
+     *
+     * @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(", platformSku=").append(platformSku);
+        sb.append(", warehouseCode=").append(warehouseCode);
+        sb.append(", warehouseName=").append(warehouseName);
+        sb.append(", gmtCreate=").append(gmtCreate);
+        sb.append(", gmtModified=").append(gmtModified);
+        sb.append(", blOperator=").append(blOperator);
+        sb.append("]");
+        return sb.toString();
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_config_fba
+     *
+     * @mbg.generated
+     */
+    @Override
+    public boolean equals(Object that) {
+        if (this == that) {
+            return true;
+        }
+        if (that == null) {
+            return false;
+        }
+        if (getClass() != that.getClass()) {
+            return false;
+        }
+        DcBaseStockConfigFba other = (DcBaseStockConfigFba) that;
+        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
+            && (this.getPlatformSku() == null ? other.getPlatformSku() == null : this.getPlatformSku().equals(other.getPlatformSku()))
+            && (this.getWarehouseCode() == null ? other.getWarehouseCode() == null : this.getWarehouseCode().equals(other.getWarehouseCode()))
+            && (this.getWarehouseName() == null ? other.getWarehouseName() == null : this.getWarehouseName().equals(other.getWarehouseName()))
+            && (this.getGmtCreate() == null ? other.getGmtCreate() == null : this.getGmtCreate().equals(other.getGmtCreate()))
+            && (this.getGmtModified() == null ? other.getGmtModified() == null : this.getGmtModified().equals(other.getGmtModified()))
+            && (this.getBlOperator() == null ? other.getBlOperator() == null : this.getBlOperator().equals(other.getBlOperator()));
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table dc_base_stock_config_fba
+     *
+     * @mbg.generated
+     */
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
+        result = prime * result + ((getPlatformSku() == null) ? 0 : getPlatformSku().hashCode());
+        result = prime * result + ((getWarehouseCode() == null) ? 0 : getWarehouseCode().hashCode());
+        result = prime * result + ((getWarehouseName() == null) ? 0 : getWarehouseName().hashCode());
+        result = prime * result + ((getGmtCreate() == null) ? 0 : getGmtCreate().hashCode());
+        result = prime * result + ((getGmtModified() == null) ? 0 : getGmtModified().hashCode());
+        result = prime * result + ((getBlOperator() == null) ? 0 : getBlOperator().hashCode());
+        return result;
+    }
+}
\ No newline at end of file

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

@@ -5,6 +5,7 @@ import lombok.Data;
 import java.time.LocalDateTime;
 
 @Data
+
 public class DcBaseStockFba {
     /**
      *

mybatis-generator/pom.xml

@@ -12,7 +12,7 @@
     <dependency>
         <groupId>com.itfsw</groupId>
         <artifactId>mybatis-generator-plugin</artifactId>
-        <version>1.2.12</version>
+        <version>1.2.20</version>
     </dependency>
 
     <!-- https://mvnrepository.com/artifact/org.mybatis.generator/mybatis-generator-maven-plugin -->

mybatis-generator/src/main/resources/init.properties

-table-name=dc_base_sku
+table-name=dc_base_stock_config_fba