订单增加平台SKU维度处理, 并对配货SKU重量按配货单出库重量摊分

data-base/base-sync-oms-order/src/main/java/com/bailuntec/mapper/DcBaseOmsPlatformSkuMapper.java

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

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

@@ -9,7 +9,7 @@ EVENT_RDB_STORAGE_USERNAME=root
 EVENT_RDB_STORAGE_PASSWORD=#7kfnymAM$Y9-Ntf
 ZOOKEEPER_SERVER=172.31.255.120:2181
 NAME_SPACE=data-center
-#JOB_NAME=base-sync-oms-order-coroutine
-JOB_NAME=base-sync-oms-order
+JOB_NAME=base-sync-oms-order-coroutine
+#JOB_NAME=base-sync-oms-order
 JOB_CRON=0/1 * * * * ? *
 SHARDING_TOTAL_COUNT=1
\ No newline at end of file

data-base/base-sync-oms-order/src/test/java/OmsOrderTest.java

@@ -78,7 +78,7 @@ public class OmsOrderTest {
         LinkedHashMap<String, String> map = new LinkedHashMap<>(4);
         map.put("pageIndex", "1");
         map.put("pageCount", "100");
-        map.put("OriginOrderNo", "171-0246982-9581102");
+        map.put("OriginOrderNo", "203-5274222-9279548");
         Request request = new Request.Builder()
                 .get()
                 .url(OkHttpUtil.attachHttpGetParams("http://oms.bailuntec.com/apiV2/bailunOrder/getBailunOrders", map))