From 0dda0878101c086c176c5ceb8b5311ebfc517c43 Mon Sep 17 00:00:00 2001
From: Yen <yen1130@qq.com>
Date: Tue, 23 Jul 2024 14:23:15 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E8=A1=A5=E5=85=85=E5=AE=A2=E6=88=B7?=
 =?UTF-8?q?=E7=89=B9=E6=AE=8A=E4=BB=B7=E5=88=A0=E9=99=A4=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E6=97=B6=E6=9B=B4=E6=96=B0=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/GoodsCustomerPriceService.java    |  8 +++++-
 .../impl/GoodsCustomerPriceServiceImpl.java   | 26 ++++++++++++++-----
 .../modules/tbs/common/TbsSeeYonConst.java    |  1 +
 3 files changed, 28 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/qs/serve/modules/goods/service/GoodsCustomerPriceService.java b/src/main/java/com/qs/serve/modules/goods/service/GoodsCustomerPriceService.java
index de540086..b558970c 100644
--- a/src/main/java/com/qs/serve/modules/goods/service/GoodsCustomerPriceService.java
+++ b/src/main/java/com/qs/serve/modules/goods/service/GoodsCustomerPriceService.java
@@ -29,10 +29,16 @@ public interface GoodsCustomerPriceService extends IService<GoodsCustomerPrice>
     List<GoodsCustomerPrice> getBySupplierCodeAndCode(String supplierCode, List<String> skuCode);
 
     /**
-     * 同步客户特殊价
+     * 同步客户特殊价()
      */
     void syncCustomerPrice();
 
+    void syncCustomerPrice(String dictKey,String dictTitle,String url);
+
+    /**
+     * 刷新客户所有的商品特殊价
+     * @param cusCode
+     */
     void syncCustomerPrice(String cusCode);
 
 }
diff --git a/src/main/java/com/qs/serve/modules/goods/service/impl/GoodsCustomerPriceServiceImpl.java b/src/main/java/com/qs/serve/modules/goods/service/impl/GoodsCustomerPriceServiceImpl.java
index c23e3a7e..188dec22 100644
--- a/src/main/java/com/qs/serve/modules/goods/service/impl/GoodsCustomerPriceServiceImpl.java
+++ b/src/main/java/com/qs/serve/modules/goods/service/impl/GoodsCustomerPriceServiceImpl.java
@@ -157,18 +157,18 @@ public class GoodsCustomerPriceServiceImpl extends ServiceImpl<GoodsCustomerPric
     }
 
     @Override
-    public void syncCustomerPrice() {
-        final String DICT_KEY = "sync-customer-price-max-id";
+    public void syncCustomerPrice(String dictKey,String dictTitle,String url) {
+        final String DICT_KEY = dictKey;
         SysDictData dictData = sysDictDataMapper
                 .selectOne(new LambdaQueryWrapper<SysDictData>()
-                .eq(SysDictData::getGroupKey,DICT_KEY));
+                        .eq(SysDictData::getGroupKey,DICT_KEY));
         Long maxId = 0L;
         if(dictData!=null&&dictData.getKeyVal()!=null){
             maxId = Long.parseLong(dictData.getKeyVal());
         }
         List<InventoryCusPrice> allCusPriceList = new ArrayList<>();
 
-        R<String> res = seeYonRequestBaseService.postBase(TbsSeeYonConst.ERP_CUS_INV_LAST_UPD+"/"+maxId,null,"查询最近更新的客户特殊价");
+        R<String> res = seeYonRequestBaseService.postBase(url+"/"+maxId,null,"查询最近更新的客户特殊价");
         if(res.getStatus().equals(200)){
             allCusPriceList = JsonUtil.jsonToList(res.getData(), InventoryCusPrice.class);
         }
@@ -195,9 +195,9 @@ public class GoodsCustomerPriceServiceImpl extends ServiceImpl<GoodsCustomerPric
                 dictData.setDictId(0L);
                 dictData.setGroupKey(DICT_KEY);
                 dictData.setKeyVal(maxId+"");
-                dictData.setLabel("同步客户特殊价最大值ID");
+                dictData.setLabel(dictTitle);
                 dictData.setSort(0);
-                dictData.setRemark("同步客户特殊价最大值ID");
+                dictData.setRemark(dictTitle);
                 sysDictDataMapper.insert(dictData);
             }else {
                 dictData.setKeyVal(maxId+"");
@@ -206,6 +206,20 @@ public class GoodsCustomerPriceServiceImpl extends ServiceImpl<GoodsCustomerPric
         }
     }
 
+    @Override
+    public void syncCustomerPrice() {
+        // 客户特殊价，新增和更新的触发器
+        String dictKey = "sync-customer-price-max-id";
+        String url = TbsSeeYonConst.ERP_CUS_INV_LAST_UPD;
+        String title = "同步客户特殊价最大值ID";
+        this.syncCustomerPrice(dictKey,title,url);
+        // 客户特殊价，删除的触发器
+        String dictKey2 = "sync-customer-price-del-max-id";
+        String url2 = TbsSeeYonConst.ERP_CUS_INV_LAST_DEL;
+        String title2 = "同步客户特殊价最大值ID(PriceJustify_DeleteLog)";
+        this.syncCustomerPrice(dictKey2,title2,url2);
+    }
+
     @Override
     public void syncCustomerPrice(String cusCode) {
        this.flushSupplierSkuPrices(cusCode);
diff --git a/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java b/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java
index 3a7c150d..4db087a9 100644
--- a/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java
+++ b/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java
@@ -109,6 +109,7 @@ public interface TbsSeeYonConst {
     String ERP_CUS_INV_PRICE = "/erp/inventory/invPrices";
     String ERP_CUS_INV_PRICE_CUS = "/erp/inventory/invPricesByCusCode?cusCode=";
     String ERP_CUS_INV_LAST_UPD = "/erp/inventory/lastUpdateCusInvPrices";
+    String ERP_CUS_INV_LAST_DEL = "/erp/inventory/lastDeleteCusInvPrices";
     String ERP_CUS_INV_STAND = "/erp/inventory/standList";
     String ERP_CUS_INV_SYNC_PRICE = "/erp/inventory/syncPrice";
     String ERP_CUS_INV_SPECIAL = "/erp/inventory/specialSyncCrm";