From 0b3cdb1e0c2f495edb971c585bd6b4b0456bf93a Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期二, 14 四月 2026 14:55:34 +0800
Subject: [PATCH] 字段变更 增加类型
---
rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java | 32 +++++++++++++++++++++++++-------
1 files changed, 25 insertions(+), 7 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..db3b68b 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
@@ -260,16 +259,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 +279,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()) : ""));
}
}
}
@@ -1310,7 +1326,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 +1338,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 +1366,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("鐗╂枡鏇存柊澶辫触锛侊紒");
--
Gitblit v1.9.1