订单费用处理添加头程费

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

@@ -47,7 +47,6 @@ public class OrderSyncJob extends PointJob {
                     try {
                         JobPointLogMapper mapper = SessionUtil.getSession().getMapper(JobPointLogMapper.class);
                         mapper.upsertSelective(jobPointLog);
-                        SessionUtil.getSession().commit();
                     } catch (Exception e) {
                         e.printStackTrace();
                         throw new RuntimeException("Mybatis操作DB失败", e);
@@ -142,6 +141,7 @@ public class OrderSyncJob extends PointJob {
 
                 //如果订单中存在百伦SKU, 去拿一些放在SKU里的信息
                 Map<String, BailunSkuStructure> bailunSkuInfoMap = new HashMap<>();
+                BigDecimal totalCostFirst = BigDecimal.ZERO;
                 if (omsResult.getBailunSku() != null && omsResult.getBailunSku().size() > 0) {
                     /*
                      * 遍历所有百伦SKU(omsResult.getBailunSku())
@@ -152,10 +152,7 @@ public class OrderSyncJob extends PointJob {
                     dcBaseOmsOrder.setQuantityBailunSku(bailunSkuCumulative.getTotalQuantity());
                     //拿仓库信息
                     DcBaseWarehouse dcBaseWarehouse = getDcBaseWarehouse(omsResult);
-                    //如果不是国内仓, 就需要去拿头程费
-                    if (dcBaseWarehouse != null && !dcBaseWarehouse.getHqType().equals(Constant.DOMESTIC_WAREHOUSE) && omsResult.getLogisticsItems() != null && omsResult.getLogisticsItems().size() > 0) {
-//                        getCostFirstFee(dcBaseOmsOrder,bailunSkuCumulative,omsResult.getLogisticsItems().get(0));
-                    }
+
                      //计算每个SKU采购价占总采购价比重(用于摊分SKU售价之类) 以及 每个SKU重量价占总重量的比重
                     for (BailunSku bailunSku : omsResult.getBailunSku()) {
                         BailunSkuStructure bailunSkuStructure = new BailunSkuStructure();
@@ -166,6 +163,9 @@ public class OrderSyncJob extends PointJob {
                         bailunSkuStructure.setSkuWeightRatio(bailunSkuCumulative.getTotalWeight().compareTo(BigDecimal.ZERO) ==1 ? bailunSkuStructure.getBailunSkuWeight().multiply(BigDecimal.valueOf(bailunSku.getBailunSkuQuantityOrdered())).divide(bailunSkuCumulative.getTotalWeight(), 3 ,BigDecimal.ROUND_HALF_EVEN) : BigDecimal.ONE);
                         bailunSkuStructure.setSkuQuantityOrderd(bailunSku.getBailunSkuQuantityOrdered() != null? bailunSku.getBailunSkuQuantityOrdered(): 0);
                         DcBaseOmsSku dcBaseOmsSku = new DcBaseOmsSku();
+                        /*
+                         * 赋值, 初始值避免null
+                         */
                         assignmentSkuInfo(omsResult, dcBaseOmsOrder, dcBaseOmsSku, bailunSku, dcBaseWarehouse,saleItemHashMap, isFbaFeeException);
                         if (PlatformType.FBA.value().equals(omsResult.getPlatformType().toUpperCase())) {
                             //FBA费用
@@ -175,6 +175,21 @@ public class OrderSyncJob extends PointJob {
                             dcBaseOmsSku.setBailunSkuQuantityShipped(bailunSku.getBailunSkuQuantityOrdered());
                             checkFbaFee(dcBaseOmsSku, isFbaFeeException);
                         }
+                        //如果不是国内仓, 就需要去拿头程费
+                        if (dcBaseWarehouse != null && !dcBaseWarehouse.getHqType().equals(Constant.DOMESTIC_WAREHOUSE)) {
+                            try {
+                                DcMidCostFirstMapper mapper = SessionUtil.getSession().getMapper(DcMidCostFirstMapper.class);
+                                DcMidCostFirst dcMidCostFirst = mapper.selectOneByExample(DcMidCostFirstExample.newAndCreateCriteria().andBailunSkuEqualTo(bailunSku.getBailunSku()).andWarehouseCodeEqualTo(dcBaseWarehouse.getWarehouseCode()).example());
+                                if (dcMidCostFirst != null) {
+                                    totalCostFirst = totalCostFirst.add(dcMidCostFirst.getCostFirst());
+                                    dcBaseOmsSku.setCostFirst(dcMidCostFirst.getCostFirst());
+                                }
+                            } catch (Exception e) {
+                                throw new RuntimeException("MYBATIS查头程费失败");
+                            } finally {
+                                SessionUtil.closeSession();
+                            }
+                        }
                         bailunSkuStructure.setDcBaseOmsSku(dcBaseOmsSku);
                         bailunSkuInfoMap.put(bailunSku.getBailunSku(), bailunSkuStructure);
                     }
@@ -269,8 +284,6 @@ public class OrderSyncJob extends PointJob {
                             BigDecimal skuAmountSalesRMB = (skuAmountSales.subtract(skuCostPromotion)).multiply(dcBaseOmsOrder.getSellerOrderExchangeRate()).setScale(3, RoundingMode.HALF_EVEN);
 
                             BigDecimal unitSkuAmountSalesRMB = BigDecimal.ZERO;
-                            //头程费
-                            BigDecimal skuCostFirstRMB = bailunSkuStructure.getSkuWeightRatio().multiply(dcBaseOmsOrder.getCostFirst()).setScale(3, RoundingMode.HALF_EVEN);
                             //FBA费-人民币
                             BigDecimal skuCostFbaFeeRMB = dcBaseOmsSku.getCostFbaFee().multiply(dcBaseOmsOrder.getSellerOrderExchangeRate()).setScale(3, RoundingMode.HALF_EVEN);
                             //百伦处理费
@@ -293,7 +306,6 @@ public class OrderSyncJob extends PointJob {
                                 dcBaseOmsSku.setCostPlatformFee(skuCostPlatformFee.divide(quantityOrderdDecimal, 3, RoundingMode.HALF_EVEN));
                                 dcBaseOmsSku.setCostHandlePlatform(dcBaseOmsSku.getCostHandlePlatform().divide(quantityOrderdDecimal, 3, RoundingMode.HALF_EVEN));
                                 dcBaseOmsSku.setCostFbaFee(dcBaseOmsSku.getCostFbaFee().divide(quantityOrderdDecimal, 3, RoundingMode.HALF_EVEN));
-                                dcBaseOmsSku.setCostFirst(skuCostFirstRMB.divide(quantityOrderdDecimal, 3, RoundingMode.HALF_EVEN));
                                 dcBaseOmsSku.setCostTail(dcBaseOmsSku.getCostTail().divide(quantityOrderdDecimal, 3, RoundingMode.HALF_EVEN));
                                 dcBaseOmsSku.setCostProduct(bailunSkuStructure.getBailunSkuUnitPrice());
                                 dcBaseOmsSku.setCostPromotion(skuCostPromotion.divide(quantityOrderdDecimal, 3, RoundingMode.HALF_EVEN));
@@ -339,11 +351,15 @@ public class OrderSyncJob extends PointJob {
                                 dcBaseOmsSku.setProfitRate(dcBaseOmsSku.getProfitTotal().divide(skuAmountSalesRMB, 5, RoundingMode.HALF_EVEN));
                             }
                             dcBaseOmsSku.setGmtModified(LocalDateTime.now());
+                            int i = omsSkuMapper.updateByExampleSelective(dcBaseOmsSku, DcBaseOmsSkuExample.newAndCreateCriteria().andBailunSkuEqualTo(dcBaseOmsSku.getBailunSku()).andOriginOrderIdEqualTo(dcBaseOmsSku.getOriginOrderId()).andBailunAccountIdEqualTo(dcBaseOmsSku.getBailunAccountId()).example());
+                            if (i == 0) {
                                 omsSkuMapper.insertSelective(dcBaseOmsSku);
                             }
                         }
+                    }
                     //预付款-预收金额-人民币
                     dcBaseOmsOrder.setAmountPrepaid(totalAmountPrepaid);
+                    dcBaseOmsOrder.setCostFirst(totalCostFirst);
                     /*
                      * OMS过来的详细费用不用动
                      * 这边处理新增了
@@ -370,8 +386,10 @@ public class OrderSyncJob extends PointJob {
                     }
                     dcBaseOmsOrder.setGmtModified(LocalDateTime.now());
                     DcBaseOmsOrderMapper omsOrderMapper = SessionUtil.getSession().getMapper(DcBaseOmsOrderMapper.class);
-                    omsOrderMapper.upsertSelective(dcBaseOmsOrder);
-                    SessionUtil.getSession().commit();
+                    int i = omsOrderMapper.updateByExampleSelective(dcBaseOmsOrder, DcBaseOmsOrderExample.newAndCreateCriteria().andOriginOrderIdEqualTo(dcBaseOmsOrder.getOriginOrderId()).andBailunAccountIdEqualTo(dcBaseOmsOrder.getBailunAccountId()).example());
+                    if (i == 0) {
+                        omsOrderMapper.insertSelective(dcBaseOmsOrder);
+                    }
                 } catch (Exception e) {
                     e.printStackTrace();
                     throw new RuntimeException("Mybatis操作DB失败", e);
@@ -508,8 +526,12 @@ public class OrderSyncJob extends PointJob {
             if (PlatformType.FBA.value().equals(omsResult.getPlatformType())) {
                 dcBaseWarehouse = baseWarehouseMapper.selectOneByExample(DcBaseWarehouseExample.newAndCreateCriteria().andBailunAccountIdEqualTo(omsResult.getSeller().getBailunAccountId()).example());
             } else if (omsResult.getBailunSku().size() > 0 && StringUtils.isNotBlank(omsResult.getBailunSku().get(0).getWarehouseCode())) {
+                if (omsResult.getLogisticsItems() != null && omsResult.getLogisticsItems().size() > 0 && omsResult.getLogisticsItems().get(0).getWarehouse() != null && omsResult.getLogisticsItems().get(0).getWarehouse().getWarehouseCode() != null) {
+                    dcBaseWarehouse = baseWarehouseMapper.selectOneByExample(DcBaseWarehouseExample.newAndCreateCriteria().andWarehouseCodeEqualTo(omsResult.getLogisticsItems().get(0).getWarehouse().getWarehouseCode()).example());
+                } else {
                     dcBaseWarehouse = baseWarehouseMapper.selectOneByExample(DcBaseWarehouseExample.newAndCreateCriteria().andWarehouseCodeEqualTo(omsResult.getBailunSku().get(0).getWarehouseCode()).example());
                 }
+            }
         } catch (Exception e) {
             e.printStackTrace();
             throw new RuntimeException("MYBATIS操作DB失败", e);
@@ -591,7 +613,6 @@ public class OrderSyncJob extends PointJob {
                             dcBaseOmsSku.setCostHandlePlatform(dcBaseOmsSku.getCostHandlePlatform() != null ? dcBaseOmsSku.getCostHandlePlatform().add(dcBaseOmsPick.getBailunSkuCostPackaging()) : dcBaseOmsPick.getBailunSkuCostPackaging());
                             dcBaseOmsSku.setCostTail(dcBaseOmsSku.getCostTail() != null ? dcBaseOmsSku.getCostTail().add(dcBaseOmsPick.getBailunSkuCostShipping()) : dcBaseOmsPick.getBailunSkuCostShipping());
                             mapper.upsertSelective(dcBaseOmsPick);
-                            SessionUtil.getSession().commit();
                         }
                     }
                 }
@@ -715,21 +736,6 @@ public class OrderSyncJob extends PointJob {
     }
 
 
-    /**
-     * 获取头程费
-     *
-     *
-     * @param dcBaseOmsOrder
-     * @param bailunSkuCumulative
-     * @param logisticsItem
-     * @throws Exception
-     */
-    public void getCostFirstFee(DcBaseOmsOrder dcBaseOmsOrder, BailunSkuCumulative bailunSkuCumulative, LogisticsItem logisticsItem) {
-        if (!StringUtils.isNotBlank(dcBaseOmsOrder.getReceiptCountry())) {
-            BigDecimal headPrices = CallBailunSystem.callCostFirstFee(dcBaseOmsOrder.getReceiptCountry(), bailunSkuCumulative.getMaxSkuLong(), bailunSkuCumulative.getMaxSkuWidth(), bailunSkuCumulative.getMaxSkuHight(), bailunSkuCumulative.getTotalWeight().divide(Constant.RATE_1000), logisticsItem.getLogisticsMethod().getLogisticsCode());
-            dcBaseOmsOrder.setCostFirst(headPrices);
-        }
-    }
 
 
     /**

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

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

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.bailuntec.mapper.DcMidCostFirstMapper">
+  <resultMap id="BaseResultMap" type="com.bailuntec.domain.entity.DcMidCostFirst">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    <id column="id" jdbcType="INTEGER" property="id" />
+    <result column="cost_first" jdbcType="DECIMAL" property="costFirst" />
+    <result column="bailun_sku" jdbcType="VARCHAR" property="bailunSku" />
+    <result column="warehouse_code" jdbcType="VARCHAR" property="warehouseCode" />
+  </resultMap>
+  <sql id="Example_Where_Clause">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    <where>
+      <foreach collection="oredCriteria" item="criteria" separator="or">
+        <if test="criteria.valid">
+          <trim prefix="(" prefixOverrides="and" suffix=")">
+            <foreach collection="criteria.criteria" item="criterion">
+              <choose>
+                <when test="criterion.noValue">
+                  and ${criterion.condition}
+                </when>
+                <when test="criterion.singleValue">
+                  and ${criterion.condition} #{criterion.value}
+                </when>
+                <when test="criterion.betweenValue">
+                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
+                </when>
+                <when test="criterion.listValue">
+                  and ${criterion.condition}
+                  <foreach close=")" collection="criterion.value" item="listItem" open="(" separator=",">
+                    #{listItem}
+                  </foreach>
+                </when>
+              </choose>
+            </foreach>
+          </trim>
+        </if>
+      </foreach>
+    </where>
+  </sql>
+  <sql id="Update_By_Example_Where_Clause">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    <where>
+      <foreach collection="example.oredCriteria" item="criteria" separator="or">
+        <if test="criteria.valid">
+          <trim prefix="(" prefixOverrides="and" suffix=")">
+            <foreach collection="criteria.criteria" item="criterion">
+              <choose>
+                <when test="criterion.noValue">
+                  and ${criterion.condition}
+                </when>
+                <when test="criterion.singleValue">
+                  and ${criterion.condition} #{criterion.value}
+                </when>
+                <when test="criterion.betweenValue">
+                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
+                </when>
+                <when test="criterion.listValue">
+                  and ${criterion.condition}
+                  <foreach close=")" collection="criterion.value" item="listItem" open="(" separator=",">
+                    #{listItem}
+                  </foreach>
+                </when>
+              </choose>
+            </foreach>
+          </trim>
+        </if>
+      </foreach>
+    </where>
+  </sql>
+  <sql id="Base_Column_List">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    id, cost_first, bailun_sku, warehouse_code
+  </sql>
+  <select id="selectByExample" parameterType="com.bailuntec.domain.example.DcMidCostFirstExample" resultMap="BaseResultMap">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    select
+    <if test="distinct">
+      distinct
+    </if>
+    <include refid="Base_Column_List" />
+    from dc_mid_cost_first
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+    <if test="orderByClause != null">
+      order by ${orderByClause}
+    </if>
+    <if test="rows != null">
+      <if test="offset != null">
+        limit ${offset}, ${rows}
+      </if>
+      <if test="offset == null">
+        limit ${rows}
+      </if>
+    </if>
+  </select>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    select 
+    <include refid="Base_Column_List" />
+    from dc_mid_cost_first
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    delete from dc_mid_cost_first
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <delete id="deleteByExample" parameterType="com.bailuntec.domain.example.DcMidCostFirstExample">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    delete from dc_mid_cost_first
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+  </delete>
+  <insert id="insert" parameterType="com.bailuntec.domain.entity.DcMidCostFirst">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    insert into dc_mid_cost_first (id, cost_first, bailun_sku, 
+      warehouse_code)
+    values (#{id,jdbcType=INTEGER}, #{costFirst,jdbcType=DECIMAL}, #{bailunSku,jdbcType=VARCHAR}, 
+      #{warehouseCode,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.bailuntec.domain.entity.DcMidCostFirst">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    insert into dc_mid_cost_first
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="costFirst != null">
+        cost_first,
+      </if>
+      <if test="bailunSku != null">
+        bailun_sku,
+      </if>
+      <if test="warehouseCode != null">
+        warehouse_code,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="costFirst != null">
+        #{costFirst,jdbcType=DECIMAL},
+      </if>
+      <if test="bailunSku != null">
+        #{bailunSku,jdbcType=VARCHAR},
+      </if>
+      <if test="warehouseCode != null">
+        #{warehouseCode,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <select id="countByExample" parameterType="com.bailuntec.domain.example.DcMidCostFirstExample" resultType="java.lang.Long">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    select count(*) from dc_mid_cost_first
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+  </select>
+  <update id="updateByExampleSelective" parameterType="map">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    update dc_mid_cost_first
+    <set>
+      <if test="record.id != null">
+        id = #{record.id,jdbcType=INTEGER},
+      </if>
+      <if test="record.costFirst != null">
+        cost_first = #{record.costFirst,jdbcType=DECIMAL},
+      </if>
+      <if test="record.bailunSku != null">
+        bailun_sku = #{record.bailunSku,jdbcType=VARCHAR},
+      </if>
+      <if test="record.warehouseCode != null">
+        warehouse_code = #{record.warehouseCode,jdbcType=VARCHAR},
+      </if>
+    </set>
+    <if test="_parameter != null">
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByExample" parameterType="map">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    update dc_mid_cost_first
+    set id = #{record.id,jdbcType=INTEGER},
+      cost_first = #{record.costFirst,jdbcType=DECIMAL},
+      bailun_sku = #{record.bailunSku,jdbcType=VARCHAR},
+      warehouse_code = #{record.warehouseCode,jdbcType=VARCHAR}
+    <if test="_parameter != null">
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByPrimaryKeySelective" parameterType="com.bailuntec.domain.entity.DcMidCostFirst">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    update dc_mid_cost_first
+    <set>
+      <if test="costFirst != null">
+        cost_first = #{costFirst,jdbcType=DECIMAL},
+      </if>
+      <if test="bailunSku != null">
+        bailun_sku = #{bailunSku,jdbcType=VARCHAR},
+      </if>
+      <if test="warehouseCode != null">
+        warehouse_code = #{warehouseCode,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.bailuntec.domain.entity.DcMidCostFirst">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+    -->
+    update dc_mid_cost_first
+    set cost_first = #{costFirst,jdbcType=DECIMAL},
+      bailun_sku = #{bailunSku,jdbcType=VARCHAR},
+      warehouse_code = #{warehouseCode,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <insert id="upsertSelective" parameterType="com.bailuntec.domain.entity.DcMidCostFirst">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+      @project https://github.com/itfsw/mybatis-generator-plugin
+    -->
+    insert into dc_mid_cost_first
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="costFirst != null">
+        cost_first,
+      </if>
+      <if test="bailunSku != null">
+        bailun_sku,
+      </if>
+      <if test="warehouseCode != null">
+        warehouse_code,
+      </if>
+    </trim>
+    values
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="costFirst != null">
+        #{costFirst,jdbcType=DECIMAL},
+      </if>
+      <if test="bailunSku != null">
+        #{bailunSku,jdbcType=VARCHAR},
+      </if>
+      <if test="warehouseCode != null">
+        #{warehouseCode,jdbcType=VARCHAR},
+      </if>
+    </trim>
+    on duplicate key update 
+    <trim suffixOverrides=",">
+      <if test="id != null">
+        id = #{id,jdbcType=INTEGER},
+      </if>
+      <if test="costFirst != null">
+        cost_first = #{costFirst,jdbcType=DECIMAL},
+      </if>
+      <if test="bailunSku != null">
+        bailun_sku = #{bailunSku,jdbcType=VARCHAR},
+      </if>
+      <if test="warehouseCode != null">
+        warehouse_code = #{warehouseCode,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <insert id="upsert" parameterType="com.bailuntec.domain.entity.DcMidCostFirst">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+      @project https://github.com/itfsw/mybatis-generator-plugin
+    -->
+    insert into dc_mid_cost_first
+    (id, cost_first, bailun_sku, warehouse_code)
+    values
+    (#{id,jdbcType=INTEGER}, #{costFirst,jdbcType=DECIMAL}, #{bailunSku,jdbcType=VARCHAR}, 
+      #{warehouseCode,jdbcType=VARCHAR})
+    on duplicate key update 
+    id = #{id,jdbcType=INTEGER}, 
+    cost_first = #{costFirst,jdbcType=DECIMAL}, 
+    bailun_sku = #{bailunSku,jdbcType=VARCHAR}, 
+    warehouse_code = #{warehouseCode,jdbcType=VARCHAR}
+  </insert>
+  <select id="selectOneByExample" parameterType="com.bailuntec.domain.example.DcMidCostFirstExample" resultMap="BaseResultMap">
+    <!--
+      WARNING - @mbg.generated
+      This element is automatically generated by MyBatis Generator, do not modify.
+      @project https://github.com/itfsw/mybatis-generator-plugin
+    -->
+    select
+    <include refid="Base_Column_List" />
+    from dc_mid_cost_first
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+    <if test="orderByClause != null">
+      order by ${orderByClause}
+    </if>
+    limit 1
+  </select>
+</mapper>
\ No newline at end of file