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-12 16:18:07 +08:00
parent f07a5b8f67
commit 55a25e0cdb
1 changed files with 4 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -226,7 +226,8 @@ public class ShopSyncServiceImpl implements ShopSyncService {
unitService.updateById(unit, false); unitService.updateById(unit, false);
unitMap.put(unit.getSyncId(), unit.getId()); unitMap.put(unit.getSyncId(), unit.getId());
} }
}; }
;
buildNotice(mainMapList, "单位同步", pointShopUnits.size(), null, null); buildNotice(mainMapList, "单位同步", pointShopUnits.size(), null, null);
buildNotice(mainMapList, "单位新增", unitMap.size() - pointShopUnits.size(), null, null); buildNotice(mainMapList, "单位新增", unitMap.size() - pointShopUnits.size(), null, null);
log.info("单位同步,源{}个,已有{}个,同步{}个", list.size(), pointShopUnits.size(), unitMap.size() - pointShopUnits.size()); log.info("单位同步,源{}个,已有{}个,同步{}个", list.size(), pointShopUnits.size(), unitMap.size() - pointShopUnits.size());
@@ -1101,8 +1102,8 @@ public class ShopSyncServiceImpl implements ShopSyncService {
} }
public void syncConsPro(Long sourceShopId, Long pointShopId, Map<Long, Long> consMap, Map<Long, Long> proMap) { public void syncConsPro(Long sourceShopId, Long pointShopId, Map<Long, Long> consMap, Map<Long, Long> proMap) {
prodConsRelationService.remove(QueryWrapper.create().eq(ProdConsRelation::getShopId, pointShopId));
List<ProdConsRelation> list = prodConsRelationService.queryChain().eq(ProdConsRelation::getShopId, sourceShopId).list(); List<ProdConsRelation> list = prodConsRelationService.queryChain().eq(ProdConsRelation::getShopId, sourceShopId).list();
List<ProdConsRelation> upList = new ArrayList<>();
List<ProdConsRelation> addList = new ArrayList<>(); List<ProdConsRelation> addList = new ArrayList<>();
for (ProdConsRelation prodConsRelation : list) { for (ProdConsRelation prodConsRelation : list) {
prodConsRelation.setShopId(pointShopId); prodConsRelation.setShopId(pointShopId);
@@ -1112,24 +1113,11 @@ public class ShopSyncServiceImpl implements ShopSyncService {
log.info("关联关系同步失败 商品ID:{}或耗材ID:{}不存在", prodConsRelation.getProductId(), prodConsRelation.getConsInfoId()); log.info("关联关系同步失败 商品ID:{}或耗材ID:{}不存在", prodConsRelation.getProductId(), prodConsRelation.getConsInfoId());
continue; continue;
} }
ProdConsRelation oldRelation = prodConsRelationService.queryChain() addList.add(prodConsRelation);
.eq(ProdConsRelation::getShopId, pointShopId)
.eq(ProdConsRelation::getProductId, prodConsRelation.getProductId())
.eq(ProdConsRelation::getConsInfoId, prodConsRelation.getConsInfoId()).one();
if (oldRelation == null) {
addList.add(prodConsRelation);
} else {
if (oldRelation.getSurplusStock().compareTo(prodConsRelation.getSurplusStock()) != 0) {
upList.add(prodConsRelation);
}
}
} }
if (CollUtil.isNotEmpty(addList)) { if (CollUtil.isNotEmpty(addList)) {
prodConsRelationService.saveBatch(addList, 100); prodConsRelationService.saveBatch(addList, 100);
} }
if (CollUtil.isNotEmpty(upList)) {
prodConsRelationService.updateBatch(addList, 100);
}
log.info("耗材与商品关联关系,同步{}个", list.size()); log.info("耗材与商品关联关系,同步{}个", list.size());
} }