czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

同步数据 历史同步字段 回填

Browse Source
This commit is contained in:
wangw
2025-04-11 10:18:11 +08:00
parent 8124183eb0
commit 365824c140
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ShopSyncServiceImpl.java
View File

@@ -192,7 +192,7 @@ public class ShopSyncServiceImpl implements ShopSyncService {
public Map<Long, Long> syncUnit(Long sourceShopId, Long pointShopId, List<Map<String, Object>> mainMapList) {
Map<Long, Long> unitMap = new HashMap<>();
List<Long> pointShopUnits = new ArrayList<>();
List<ShopProdUnit> pointUnits = unitService.queryChain().select(ShopProdUnit::getSyncId)
List<ShopProdUnit> pointUnits = unitService.queryChain()
.eq(ShopProdUnit::getShopId, pointShopId)
.isNotNull(ShopProdUnit::getSyncId)
.list();
@@ -257,7 +257,7 @@ public class ShopSyncServiceImpl implements ShopSyncService {
public Map<Long, Long> syncSpec(Long sourceShopId, Long pointShopId, List<Map<String, Object>> mainMapList) {
Map<Long, Long> specMap = new HashMap<>();
List<Long> pointShopSpecs = new ArrayList<>();
List<ShopProdSpec> pointList = specService.queryChain().select(ShopProdSpec::getSyncId)
List<ShopProdSpec> pointList = specService.queryChain()
.eq(ShopProdSpec::getShopId, pointShopId)
.isNotNull(ShopProdSpec::getSyncId)
.list();
@@ -322,7 +322,7 @@ public class ShopSyncServiceImpl implements ShopSyncService {
public Map<Long, Long> syncCategory(Long sourceShopId, Long pointShopId, List<Map<String, Object>> mainMapList) {
Map<Long, Long> categoryMap = new HashMap<>();
List<Long> pointShopCateGory = new ArrayList<>();
List<ShopProdCategory> pointList = categoryService.queryChain().select(ShopProdCategory::getSyncId)
List<ShopProdCategory> pointList = categoryService.queryChain()
.eq(ShopProdCategory::getShopId, pointShopId)
.isNotNull(ShopProdCategory::getSyncId)
.list();