订单调整

src/main/java/com/qs/serve/modules/goods/mapper/GoodsSkuMapper.java

@@ -15,6 +15,9 @@ import java.util.List;
  */
 public interface GoodsSkuMapper extends BaseMapper<GoodsSku> {
 
+
+    List<String> getBelongStringList();
+
     /**
      * 查询vo
      * @param goodsSku

src/main/java/com/qs/serve/modules/goods/service/GoodsSkuService.java

@@ -15,6 +15,8 @@ import java.util.List;
  */
 public interface GoodsSkuService extends IService<GoodsSku> {
 
+    List<String> getBelongPlace();
+
     GoodsSku getByCode(String code);
 
     List<GoodsSku> getByCodes(List<String> codes);

src/main/java/com/qs/serve/modules/goods/service/GoodsSpuService.java

@@ -36,7 +36,15 @@ public interface GoodsSpuService extends IService<GoodsSpu> {
 
     GoodSkuBatchResult editTasteBo(GoodsSpuTasteBo tasteProduct);
 
-    List<OmsSpuToSkuKey> getSpuToSkuInfo(String book, List<String> skuCodes);
+    List<GoodsSpu> selectListBySpuCodes(List<String> spuCodes);
+
+    /**
+     *
+     * @param placeName
+     * @param spuCodes
+     * @return
+     */
+    List<OmsSpuToSkuKey> getSpuToSkuInfo(String placeName, List<String> spuCodes);
 
 }
 

src/main/java/com/qs/serve/modules/goods/service/impl/GoodsSkuServiceImpl.java

@@ -44,6 +44,11 @@ public class GoodsSkuServiceImpl extends ServiceImpl<GoodsSkuMapper,GoodsSku> im
     private GoodsSpecValueService goodsSpecValueService;
     private SeeYonRequestBaseService seeYonRequestBaseService;
 
+    @Override
+    public List<String> getBelongPlace() {
+        return null;
+    }
+
     @Override
     public GoodsSku getByCode(String code) {
         LambdaQueryWrapper<GoodsSku> lqw = new LambdaQueryWrapper<>();

src/main/java/com/qs/serve/modules/goods/service/impl/GoodsSpuServiceImpl.java

@@ -27,6 +27,7 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * spu 服务实现类
@@ -253,20 +254,64 @@ public class GoodsSpuServiceImpl extends ServiceImpl<GoodsSpuMapper,GoodsSpu> im
         return skuBatchResult;
     }
 
+
+    @Override
+    public List<GoodsSpu> selectListBySpuCodes(List<String> spuCodes) {
+
+        return null;
+    }
+
     /**
      * 根据账套，获取spu对应的sku
-     * @param book 账套
-     * @param skuCodes 嘉士利的SKU-CODE
+     * @param placeName 账套
+     * @param spuCodes 嘉士利的SKU-CODE
      * @return 嘉士利的invCode
      */
     @Override
-    public List<OmsSpuToSkuKey> getSpuToSkuInfo(String book, List<String> skuCodes){
-        Map<String,Object> params = new HashMap<>();
-        params.put("book",book);
-        params.put("skuCode",skuCodes);
-        String apiUrl = projectApisProperties.getSpuToSku();
-        String response = HttpUtil.doPost(apiUrl, JsonUtil.objectToJson(params),null);
-        return JsonUtil.jsonToList(response,OmsSpuToSkuKey.class);
+    public List<OmsSpuToSkuKey> getSpuToSkuInfo(String placeName, List<String> spuCodes){
+
+        //取消调用远程接口
+//        Map<String,Object> params = new HashMap<>();
+//        params.put("book",book);
+//        params.put("skuCode",skuCodes);
+//        String apiUrl = projectApisProperties.getSpuToSku();
+//        String response = HttpUtil.doPost(apiUrl, JsonUtil.objectToJson(params),null);
+//        return JsonUtil.jsonToList(response,OmsSpuToSkuKey.class);
+
+        if(spuCodes.size()<1){
+            return new ArrayList<>();
+        }
+
+        List<GoodsSpu> spuList = this.selectListBySpuCodes(spuCodes);
+
+        if(spuList.size()<1){
+            return new ArrayList<>();
+        }
+
+        List<Long> spuIds = spuList.stream().map(GoodsSpu::getId).collect(Collectors.toList());
+
+        LambdaQueryWrapper<GoodsSku> skuLqw = new LambdaQueryWrapper<>();
+        skuLqw.eq(GoodsSku::getBelong,placeName);
+        skuLqw.in(GoodsSku::getSpuId,spuIds);
+        List<GoodsSku> goodsSkus = goodsSkuService.list(skuLqw);
+
+        List<OmsSpuToSkuKey> skuKeys = new ArrayList<>();
+        for (GoodsSku sku : goodsSkus) {
+            GoodsSpu currSpu = null;
+            for (GoodsSpu goodsSpu : spuList) {
+                if(sku.getSpuId().equals(goodsSpu.getId())){
+                    currSpu = goodsSpu;
+                    break;
+                }
+            }
+            OmsSpuToSkuKey skuKey = new OmsSpuToSkuKey();
+            skuKey.setSkuCode(currSpu.getSpuCode());
+            skuKey.setInvCode(sku.getSkuCode());
+            skuKey.setWeight(sku.getWeight().toString());
+            skuKey.setVolume(sku.getVolume().toString());
+            skuKeys.add(skuKey);
+        }
+        return skuKeys;
     }
 
     /**

src/main/java/com/qs/serve/modules/pay/entity/PayPayment.java

@@ -154,8 +154,10 @@ public class PayPayment implements Serializable {
     @JsonProperty
     private String delFlag;
 
+    //private Integer syncActFlag;
+
     /** 同步标识 */
-    private Integer syncActFlag;
+    private Integer syncCostFlag;
 
 }
 

src/main/java/com/qs/serve/modules/tbs/controller/TbsCostTodoController.java

@@ -62,6 +62,16 @@ public class TbsCostTodoController {
     public R<List<TbsCostTodo>> getList(TbsCostTodo param){
         LambdaQueryWrapper<TbsCostTodo> lqw = new LambdaQueryWrapper<>(param);
         List<TbsCostTodo> list = tbsCostTodoService.list(lqw);
+        for (TbsCostTodo tbsCostTodo : list) {
+            if(tbsCostTodo.getAttachIds()!=null&&tbsCostTodo.getAttachIds().length>0){
+                List list2 = attachService.listByIds(Arrays.asList(tbsCostTodo.getAttachIds()));
+                tbsCostTodo.setAttachList(list2);
+            }
+            if(tbsCostTodo.getAttachIds2()!=null&&tbsCostTodo.getAttachIds2().length>0){
+                List list2 = attachService.listByIds(Arrays.asList(tbsCostTodo.getAttachIds2()));
+                tbsCostTodo.setAttachList2(list2);
+            }
+        }
         return R.ok(list);
     }
 

src/main/java/com/qs/serve/modules/tbs/entity/TbsCostApply.java

@@ -81,6 +81,7 @@ public class TbsCostApply implements Serializable {
      * 1-已通过：代表这个案子的所有活动都已经核销完成；
      * 2-核销中：代表这个案子的某些活动在核销中；
      * 3-被拒绝；代表这个案子里面的所有活动金额都被释放了
+     * 4-部分核销，部分已核销，还有未完成部分
      */
     private Integer checkState;
 
@@ -221,6 +222,12 @@ public class TbsCostApply implements Serializable {
     private String extUserCode;
     private String extUserName;
 
+    /** 支付状态： 0->未支付；1->部分支付；2->已支付 */
+    private Integer payStatus;
+
+    /** 验收状态： 0->未验收；1-验收中；2-部分验收；3完成 */
+    private Integer agreeCheckStatus;
+
     @TableField(exist = false)
     private String affairId;
 

src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyServiceImpl.java

@@ -1113,6 +1113,8 @@ public class TbsCostApplyServiceImpl extends ServiceImpl<TbsCostApplyMapper,TbsC
             }
         }
         boolean isAllCancel = true;
+        boolean someActChecked = false;
+        boolean someActNotChecked = false;
         for (TbsActivity activity : activityList) {
             boolean itemCancel = activity.getReleaseFlag().equals(1)
                     && activity.getReleaseAmount()!=null
@@ -1121,13 +1123,22 @@ public class TbsCostApplyServiceImpl extends ServiceImpl<TbsCostApplyMapper,TbsC
                 isAllCancel = false;
                 break;
             }
+            if(activity.getActivityState().equals(TbsActivityState.STATE_1_Finished)){
+                someActChecked = true;
+            }
+            if(!activity.getActivityState().equals(TbsActivityState.STATE_1_Finished)){
+                someActNotChecked = true;
+            }
         }
+        boolean isChecked = someActChecked&&someActNotChecked;
 
         TbsCostApply costApply = new TbsCostApply();
         costApply.setId(costApplyId);
         costApply.setChargeState(TbsCostApplyState.State_3_finished.getCode());
         if(isAllCancel){
             costApply.setCheckState(3);
+        }else if (isChecked){
+            costApply.setCheckState(4);
         }else {
             costApply.setCheckState(1);
         }

src/main/java/com/qs/serve/modules/third/PortalGoodsController.java

@@ -6,6 +6,7 @@ import com.qs.serve.modules.goods.entity.GoodsSpu;
 import com.qs.serve.modules.goods.service.GoodsSkuService;
 import com.qs.serve.modules.goods.service.GoodsSpuService;
 import com.qs.serve.modules.oms.entity.dto.OmsSpuToSkuKey;
+import com.qs.serve.modules.third.entity.GoodsToSkuParam;
 import com.qs.serve.modules.third.entity.param.SkuToGetSpuParam;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -50,4 +51,24 @@ public class PortalGoodsController {
         return rs;
     }
 
+    /**
+     * 通过invCode获取spuCode
+     * @param param
+     * @return
+     */
+    @PostMapping("matchInvCode")
+    public List<OmsSpuToSkuKey> matchInvCode(@RequestBody GoodsToSkuParam param){
+        return goodsSpuService.getSpuToSkuInfo(param.getPlaceName(), param.getSpuCodes());
+    }
+
+    /**
+     * 通过invCode获取spuCode
+     * @return
+     */
+    @PostMapping("belongPlace")
+    public List<?> getSpuBySku(){
+        return goodsSkuService.getBelongPlace();
+    }
+
+
 }

src/main/java/com/qs/serve/modules/third/entity/GoodsToSkuParam.java

@@ -0,0 +1,17 @@
+package com.qs.serve.modules.third.entity;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author YenHex
+ * @since 2023/11/6
+ */
+@Data
+public class GoodsToSkuParam {
+
+    String placeName;
+    List<String> spuCodes;
+
+}

src/main/resources/mapper/goods/GoodsSkuMapper.xml

@@ -161,4 +161,8 @@
             </foreach>
     </select>
 
+    <select id="getBelongStringList" resultType="java.lang.String">
+        SELECT `belong` FROM `goods_sku` where `belong` is not null GROUP BY `belong`
+    </select>
+
 </mapper>