计算头程费时,如果SKU-仓库找不到, 就取一个公共的均值

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

@@ -267,10 +267,11 @@ public class OrderSyncJob extends PointJob {
                             if (dcBaseWarehouse != null && !dcBaseWarehouse.getHqType().equals(Constant.DOMESTIC_WAREHOUSE) && dcBaseOmsSku.getBailunSkuQuantityShipped() > 0) {
                                 DcMidCostFirstMapper mapper = SessionUtil.getSession().getMapper(DcMidCostFirstMapper.class);
                                 DcMidCostFirst dcMidCostFirst = mapper.selectOneByExample(DcMidCostFirstExample.newAndCreateCriteria().andBailunSkuEqualTo(dcBaseOmsSku.getBailunSku()).andWarehouseCodeEqualTo(dcBaseWarehouse.getWarehouseCode()).example());
-                                if (dcMidCostFirst != null) {
-                                    dcBaseOmsSku.setCostFirst(dcMidCostFirst.getCostFirst());
-                                    totalCostFirst = totalCostFirst.add(dcMidCostFirst.getCostFirst().multiply(BigDecimal.valueOf(dcBaseOmsSku.getBailunSkuQuantityShipped())));
+                                if (dcMidCostFirst == null) {
+                                    dcMidCostFirst = mapper.selectOneByExample(DcMidCostFirstExample.newAndCreateCriteria().andBailunSkuEqualTo(CommonConstant.COMMON_SKU_WAREHOUSE_COST_FIRST).andWarehouseCodeEqualTo(CommonConstant.COMMON_SKU_WAREHOUSE_COST_FIRST).example());
                                 }
+                                dcBaseOmsSku.setCostFirst(dcMidCostFirst.getCostFirst());
+                                totalCostFirst = totalCostFirst.add(dcMidCostFirst.getCostFirst().multiply(BigDecimal.valueOf(dcBaseOmsSku.getBailunSkuQuantityShipped())));
                             }
                             //下单数大于发货数, 判定为预收费-人民币
                             if (dcBaseOmsSku.getBailunSkuQuantityOrdered() != null && dcBaseOmsSku.getBailunSkuQuantityOrdered() > dcBaseOmsSku.getBailunSkuQuantityShipped()) {

data-common/src/main/java/com/bailuntec/domain/constant/CommonConstant.java

@@ -24,4 +24,5 @@ public interface CommonConstant {
 //    String SKU_URL = "http://api.sku.bailuntec.com/api/ApiCenter/SetData";
     String SKU_URL = "http://10.0.6.13:8001/api/ApiCenter/SetData";
     BigDecimal BIGDECIMAL_TWO = BigDecimal.valueOf(2);
+    String COMMON_SKU_WAREHOUSE_COST_FIRST = "";
 }

data-mid/mid-calculate-cost-first/src/main/java/com/bailuntec/listener/CalculateCostFirstListener.java

@@ -47,6 +47,15 @@ public class CalculateCostFirstListener implements ElasticJobListener {
                 }
                 index++;
             } while (index < skuWarehouseTotalPage);
+            MidCostFirst midCostFirst = dcMidCostFirstOrderMapper.sumQuantityAndCost();
+            DcMidCostFirst dcMidCostFirst = new DcMidCostFirst();
+            dcMidCostFirst.setBailunSku(CommonConstant.COMMON_SKU_WAREHOUSE_COST_FIRST);
+            dcMidCostFirst.setWarehouseCode(CommonConstant.COMMON_SKU_WAREHOUSE_COST_FIRST);
+            dcMidCostFirst.setCostFirst(midCostFirst.getTotalCostFirst().divide(BigDecimal.valueOf(midCostFirst.getTotalCount()), 3, RoundingMode.HALF_EVEN));
+            int i = dcMidCostFirsMapper.updateByExampleSelective(dcMidCostFirst,DcMidCostFirstExample.newAndCreateCriteria().andBailunSkuEqualTo(midCostFirst.getBailunSku()).andWarehouseCodeEqualTo(midCostFirst.getWarehouseCode()).example());
+            if (i == 0) {
+                dcMidCostFirsMapper.insertSelective(dcMidCostFirst);
+            }
         } catch (Exception e) {
             throw new RuntimeException("在计算头程费到DcMidCostFirst时失败");
         } finally {

data-mid/mid-calculate-cost-first/src/main/java/com/bailuntec/mapper/DcMidCostFirstOrderMapper.java

@@ -126,4 +126,6 @@ public interface DcMidCostFirstOrderMapper {
     int countSkuWarehouse();
 
     List<MidCostFirst> listSkuWarehouse(@Param("v1") int v1, @Param("v2") int v2);
+
+    MidCostFirst sumQuantityAndCost();
 }
\ No newline at end of file

data-mid/mid-calculate-cost-first/src/main/java/com/bailuntec/mapper/DcMidCostFirstOrderMapper.xml

@@ -460,4 +460,7 @@
   <select id="listSkuWarehouse" resultType="com.bailuntec.domain.pojo.MidCostFirst">
         SELECT bailun_sku,warehouse_code,sum(cost_first) as total_cost_first,sum(quantity) as total_count FROM  dc_mid_cost_first_order GROUP BY bailun_sku,warehouse_code order by id asc limit #{v1}, #{v2}
   </select>
+  <select id="sumQuantityAndCost" resultType="com.bailuntec.domain.pojo.MidCostFirst">
+        SELECT sum(cost_first) as total_cost_first,sum(quantity) as total_count FROM  dc_mid_cost_first_order
+  </select>
 </mapper>
\ No newline at end of file