From a8a10ec2a3fe7d8db166413a92a34926fb178533 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期三, 29 四月 2026 19:59:17 +0800
Subject: [PATCH] 重发机制兼容
---
rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java | 101 +++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 78 insertions(+), 23 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
index 8a7d865..cbe2bd8 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
@@ -24,7 +24,6 @@
import com.vincent.rsf.server.manager.entity.*;
import com.vincent.rsf.server.manager.enums.*;
import com.vincent.rsf.server.manager.service.*;
-import com.vincent.rsf.server.manager.service.impl.MatnrServiceImpl;
import com.vincent.rsf.server.system.constant.DictTypeCode;
import com.vincent.rsf.server.system.constant.GlobalConfigCode;
import com.vincent.rsf.server.system.constant.SerialRuleCode;
@@ -69,7 +68,7 @@
@Autowired
private MatnrGroupService matnrGroupService;
@Autowired
- private MatnrServiceImpl matnrService;
+ private MatnrService matnrService;
@Autowired
private AsnOrderService asnOrderService;
@Autowired
@@ -122,6 +121,8 @@
private TaskItemService taskItemService;
@Autowired
private TaskService taskService;
+ @Autowired
+ private CusBarcodeSyncMatnrService cusBarcodeSyncMatnrService;
/**
* 浜戜粨鏀瑰崟/鍙栨秷鍓嶏細浠诲姟鏄庣粏宸插叧鑱旇鍗曟嵁涓斾富浠诲姟鏈�昏緫鍒犻櫎鍒欎笉鍏佽
@@ -165,6 +166,10 @@
return;
}
assertWkOrderExceStatusUnexecuted(order, "鍙栨秷");
+ }
+
+ private void syncMatnrFromCusItemSyncViewByConfig(List<SyncOrdersItem> orderItems, Long loginUserId) {
+ cusBarcodeSyncMatnrService.syncFromOrderItems(orderItems, loginUserId);
}
/**
@@ -260,16 +265,18 @@
public void syncMatnrs(List<BaseMatParms> matnrs) {
List<Matnr> syncMatnrs = new ArrayList<>();
if (!matnrs.isEmpty()) {
+ assertUniqueMatnrInSyncList(matnrs);
matnrs.forEach(matnr -> {
Matnr mat = new Matnr();
if (Objects.isNull(matnr.getMatnr())) {
throw new RuntimeException("鐗╂枡缂栫爜涓嶈兘涓虹┖锛侊紒");
}
BeanUtils.copyProperties(matnr, mat);
- mat.setCode(matnr.getMatnr()).setName(matnr.getMaktx());
+ mat.setCode(matnr.getMatnr()).setName(matnr.getMaktx())
+ .setBatch(matnrService.normalizeMatnrBatchValue(matnr.getBatch()));
if (!Objects.isNull(matnr.getGroupName())) {
MatnrGroup matnrGroup = matnrGroupService.getOne(new LambdaQueryWrapper<MatnrGroup>().eq(MatnrGroup::getName, matnr.getGroupName()), false);
- if (Objects.isNull(matnrGroup)) {
+ if (!Objects.isNull(matnrGroup)) {
mat.setGroupCode(matnrGroup.getCode()).setGroupId(matnrGroup.getId());
}
}
@@ -278,6 +285,21 @@
if (!matnrService.saveOrUpdateBatch(syncMatnrs)) {
throw new CoolException("鐗╂枡淇℃伅淇濆瓨鎴愬姛锛侊紒");
+ }
+ }
+ }
+
+ private void assertUniqueMatnrInSyncList(List<BaseMatParms> matnrs) {
+ Set<String> keys = new HashSet<>();
+ for (BaseMatParms p : matnrs) {
+ if (StringUtils.isBlank(p.getMatnr())) {
+ continue;
+ }
+ String key = p.getMatnr().trim() + "\u0000" + matnrService.normalizeMatnrBatchValue(p.getBatch());
+ if (!keys.add(key)) {
+ throw new CoolException("鍚屾鍒楄〃涓墿鏂欑紪鐮佷笌鎵规閲嶅锛�" + p.getMatnr().trim()
+ + (StringUtils.isNotBlank(matnrService.normalizeMatnrBatchValue(p.getBatch()))
+ ? " / " + matnrService.normalizeMatnrBatchValue(p.getBatch()) : ""));
}
}
}
@@ -323,7 +345,9 @@
public R syncLocsDetl(PageParam<Loc, BaseParam> pageParam, QueryWrapper<Loc> wrapper) {
Page<Object> page = new Page<>();
page.setCurrent(pageParam.getCurrent()).setSize(pageParam.getSize());
- IPage<LocStockDto> locStocks = locService.getLocDetls(page);
+ BaseParam bp = pageParam.getWhere();
+ Map<String, Object> conds = bp != null && bp.getMap() != null ? bp.getMap() : Collections.emptyMap();
+ IPage<LocStockDto> locStocks = locService.getLocDetls(page, conds);
return R.ok().add(locStocks);
}
@@ -499,6 +523,8 @@
}
}
}
+ // 鎸夐厤缃悓姝ョ墿鏂欎富鏁版嵁锛坣one 鏃朵笉褰卞搷閫氱煡妗ｅ啓鍏ヤ富娴佺▼锛�
+ syncMatnrFromCusItemSyncViewByConfig(syncOrder.getOrderItems(), loginUserId);
WkOrder wkOrder = new WkOrder();
String wkTypeInput = syncOrder.getWkType();
String typeCode = StringUtils.isBlank(wkTypeInput) ? null : orderWorkTypeService.getTypeByLabel(wkTypeInput);
@@ -525,10 +551,11 @@
.eq(WkOrder::getPoCode, syncOrder.getOrderInternalCode()));
if (!Objects.isNull(order)) {
assertWkOrderNoLinkedTask(order.getId());
- assertWkOrderExceStatusUnexecuted(order, "淇敼");
long pakinCount = waitPakinItemService.count(new LambdaQueryWrapper<WaitPakinItem>()
.eq(WaitPakinItem::getAsnId, order.getId()).eq(WaitPakinItem::getDeleted, 0));
if (pakinCount > 0) {
+ // 宸茬粍鎵樻椂浠嶆寜鍘熻鍒欓檺鍒讹細浠呮湭鎵ц鐘舵�佸彲鏀瑰崟
+ assertWkOrderExceStatusUnexecuted(order, "淇敼");
String changeSummary = computeWkOrderModifyChangeSummaryOrNull(order, syncOrder, resolvedOrderType, typeCode, true);
if (changeSummary == null) {
return "淇敼鏃犲彉鍖�";
@@ -543,7 +570,9 @@
if (changeSummary == null) {
return "淇敼鏃犲彉鍖�";
}
- updateOrderNoPakin(order, syncOrder, loginUserId);
+ // 鏈粍鎵樻椂鍏佽宸叉敹璐ф敼鍗曪紱鑷姩鏀惰揣鍦烘櫙涓嬪悓姝ヨ瀹屾垚鏁伴噺璺熻鍒掓暟閲忎竴鑷�
+ boolean alignQtyWithPlan = Objects.equals(order.getExceStatus(), AsnExceStatus.ASN_EXCE_STATUS_RECEIPT_DONE.val);
+ updateOrderNoPakin(order, syncOrder, loginUserId, alignQtyWithPlan);
if (isDirectWaitPakin()) {
syncReceiptAreaByOrder(order.getId());
}
@@ -857,7 +886,7 @@
/**
* 鏈粍鎵樺崟鎹殑淇敼锛氬湪鍘熷崟涓婃洿鏂颁富鍗�+鏄庣粏锛堟寜 lineId 鍖归厤锛夛紝淇濈暀 exceStatus銆乹ty銆亀orkQty锛岄伩鍏嶅垹鍗曢噸寤哄鑷村畾鏃朵换鍔″啀娆℃墽琛屻��
*/
- private void updateOrderNoPakin(WkOrder order, SyncOrderParams syncOrder, Long loginUserId) {
+ private void updateOrderNoPakin(WkOrder order, SyncOrderParams syncOrder, Long loginUserId, boolean alignQtyWithPlan) {
if (syncOrder.getOrderItems() == null || syncOrder.getOrderItems().isEmpty()) {
throw new CoolException("淇敼鏃舵槑缁嗕笉鑳戒负绌猴紒锛�");
}
@@ -897,7 +926,9 @@
SyncOrdersItem inc = incomingByLineId.get(lineId);
Double newAnfme = QuantityUtils.roundToScale(inc.getAnfme() != null ? inc.getAnfme() : existing.getAnfme());
existing.setAnfme(newAnfme);
- if (inc.getQty() != null) {
+ if (alignQtyWithPlan) {
+ existing.setQty(newAnfme);
+ } else if (inc.getQty() != null) {
existing.setQty(QuantityUtils.roundToScale(inc.getQty()));
} else {
Double curQty = existing.getQty() != null ? existing.getQty() : 0.0;
@@ -928,6 +959,9 @@
map.put("order_code", order.getCode());
map.put("matnrCode", e.getValue().getMatnr());
map.put("platItemId", e.getKey());
+ if (alignQtyWithPlan) {
+ map.put("qty", e.getValue().getAnfme());
+ }
if (!asnOrderItemService.fieldsSave(map, loginUserId)) {
throw new CoolException("鏄庣粏淇濆瓨澶辫触锛侊紒");
}
@@ -936,9 +970,13 @@
Double sum = QuantityUtils.roundToScale(asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, order.getId()))
.stream().mapToDouble(WkOrderItem::getAnfme).sum());
order.setAnfme(sum);
- List<WkOrderItem> afterItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, order.getId()));
- double qtySum = afterItems.stream().mapToDouble(oi -> oi.getQty() != null ? oi.getQty() : 0.0).sum();
- order.setQty(QuantityUtils.roundToScale(qtySum));
+ if (alignQtyWithPlan) {
+ order.setQty(sum);
+ } else {
+ List<WkOrderItem> afterItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, order.getId()));
+ double qtySum = afterItems.stream().mapToDouble(oi -> oi.getQty() != null ? oi.getQty() : 0.0).sum();
+ order.setQty(QuantityUtils.roundToScale(qtySum));
+ }
asnOrderService.updateById(order);
}
@@ -1310,7 +1348,7 @@
Integer operateType = baseMatParms.getOperateType();
// 3 绂佺敤 / 4 鍚敤锛氫粎鏇存柊鐘舵�侊紙status 1 姝ｅ父 0 鍐荤粨锛�
if (Integer.valueOf(3).equals(operateType) || Integer.valueOf(4).equals(operateType)) {
- Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getCode, baseMatParms.getMatnr()));
+ Matnr matnr = matnrService.getOneByCodeAndBatch(baseMatParms.getMatnr(), baseMatParms.getBatch());
if (matnr == null) {
throw new CoolException("鐗╂枡涓嶅瓨鍦紝鏃犳硶鎵ц绂佺敤/鍚敤锛侊紒");
}
@@ -1322,12 +1360,13 @@
return R.ok();
}
// 1 鏂板 / 2 淇敼 / 涓嶄紶锛氭湁鍒欐洿鏂般�佹棤鍒欐柊澧�
- Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getCode, baseMatParms.getMatnr()));
+ Matnr matnr = matnrService.getOneByCodeAndBatch(baseMatParms.getMatnr(), baseMatParms.getBatch());
if (Objects.isNull(matnr)) {
Matnr matnr1 = new Matnr();
BeanUtils.copyProperties(baseMatParms, matnr1);
matnr1.setCode(baseMatParms.getMatnr());
matnr1.setName(baseMatParms.getMaktx());
+ matnr1.setBatch(matnrService.normalizeMatnrBatchValue(baseMatParms.getBatch()));
if (!Objects.isNull(baseMatParms.getGroupName())) {
MatnrGroup matnrGroup = matnrGroupService.getOne(new LambdaQueryWrapper<MatnrGroup>()
.eq(MatnrGroup::getName, baseMatParms.getGroupName()));
@@ -1349,7 +1388,8 @@
matnr.setName(baseMatParms.getMaktx())
.setColor(baseMatParms.getColor())
.setModel(baseMatParms.getModel())
- .setSpec(baseMatParms.getSpec());
+ .setSpec(baseMatParms.getSpec())
+ .setBatch(matnrService.normalizeMatnrBatchValue(baseMatParms.getBatch()));
if (!matnrService.updateById(matnr)) {
throw new CoolException("鐗╂枡鏇存柊澶辫触锛侊紒");
@@ -1378,18 +1418,32 @@
if (!Cools.isEmpty(param.getPlanNo())) {
wrapper.eq(LocItem::getPlatWorkCode, param.getPlanNo());
}
+ // 浠撳簱銆佹枡绠辩爜鎸夊簱浣� id 浜ら泦杩囨护
+ List<Long> allowedLocIds = null;
if (!Cools.isEmpty(param.getWareHouseId())) {
Warehouse wh = warehouseService.getOne(new LambdaQueryWrapper<Warehouse>().eq(Warehouse::getCode, param.getWareHouseId()));
- if (wh != null) {
- List<Loc> locs = locService.list(new LambdaQueryWrapper<Loc>().eq(Loc::getWarehouseId, wh.getId()));
- if (!locs.isEmpty()) {
- wrapper.in(LocItem::getLocId, locs.stream().map(Loc::getId).collect(Collectors.toList()));
- } else {
- return R.ok().add(Collections.emptyList());
- }
- } else {
+ if (wh == null) {
return R.ok().add(Collections.emptyList());
}
+ List<Loc> locs = locService.list(new LambdaQueryWrapper<Loc>().eq(Loc::getWarehouseId, wh.getId()));
+ if (locs.isEmpty()) {
+ return R.ok().add(Collections.emptyList());
+ }
+ allowedLocIds = locs.stream().map(Loc::getId).collect(Collectors.toList());
+ }
+ if (!Cools.isEmpty(param.getBarcode())) {
+ LambdaQueryWrapper<Loc> lw = new LambdaQueryWrapper<Loc>().eq(Loc::getBarcode, param.getBarcode());
+ if (allowedLocIds != null) {
+ lw.in(Loc::getId, allowedLocIds);
+ }
+ List<Loc> locs = locService.list(lw);
+ if (locs.isEmpty()) {
+ return R.ok().add(Collections.emptyList());
+ }
+ allowedLocIds = locs.stream().map(Loc::getId).collect(Collectors.toList());
+ }
+ if (allowedLocIds != null) {
+ wrapper.in(LocItem::getLocId, allowedLocIds);
}
List<LocItem> list = locItemService.list(wrapper);
List<Map<String, Object>> result = new ArrayList<>();
@@ -1405,6 +1459,7 @@
row.put("wareHouseId", null);
row.put("wareHouseName", null);
}
+ row.put("barcode", loc != null ? loc.getBarcode() : null);
row.put("palletId", item.getTrackCode());
row.put("matNr", item.getMatnrCode());
row.put("makTx", item.getMaktx());
--
Gitblit v1.9.1