From 902ec017c2c6b01bacc67a0a65fbb5a53a951c1e Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期二, 19 八月 2025 10:56:16 +0800
Subject: [PATCH] 企业信息同步
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/ReviseLogServiceImpl.java | 96 ++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 88 insertions(+), 8 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/ReviseLogServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/ReviseLogServiceImpl.java
index 3b03850..baf9048 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/ReviseLogServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/ReviseLogServiceImpl.java
@@ -1,12 +1,15 @@
package com.vincent.rsf.server.manager.service.impl;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.vincent.rsf.framework.common.R;
+import com.vincent.rsf.framework.exception.CoolException;
import com.vincent.rsf.server.manager.controller.params.ReviseLogParams;
-import com.vincent.rsf.server.manager.entity.LocRevise;
-import com.vincent.rsf.server.manager.entity.ReviseLogItem;
+import com.vincent.rsf.server.manager.entity.*;
+import com.vincent.rsf.server.manager.enums.CommonExceStatus;
+import com.vincent.rsf.server.manager.enums.OrderType;
import com.vincent.rsf.server.manager.mapper.ReviseLogMapper;
-import com.vincent.rsf.server.manager.entity.ReviseLog;
-import com.vincent.rsf.server.manager.service.LocReviseService;
-import com.vincent.rsf.server.manager.service.ReviseLogService;
+import com.vincent.rsf.server.manager.service.*;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -14,7 +17,9 @@
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
+import java.util.Map;
import java.util.Objects;
+import java.util.stream.Collectors;
@Service("reviseLogService")
public class ReviseLogServiceImpl extends ServiceImpl<ReviseLogMapper, ReviseLog> implements ReviseLogService {
@@ -24,6 +29,14 @@
@Autowired
private ReviseLogService reviseLogService;
+
+ @Autowired
+ private LocItemService locItemService;
+
+ @Autowired
+ private LocService locService;
+ @Autowired
+ private ReviseLogItemService reviseLogItemService;
/**
* 搴撳瓨璋冩暣鍗曟槑缁嗘坊鍔�
@@ -36,11 +49,11 @@
public List<ReviseLog> reviseLoc(ReviseLogParams revise, Long loginUserId) {
LocRevise locRevise = locReviseService.getById(revise.getReviseId());
if (Objects.isNull(locRevise)) {
- throw new RuntimeException("璋冩暣鍗曟嵁涓嶅瓨鍦紒锛�");
+ throw new CoolException("璋冩暣鍗曟嵁涓嶅瓨鍦紒锛�");
}
List<ReviseLog> items = revise.getItems();
if (items.isEmpty()) {
- throw new RuntimeException("璋冩暣鍗曟槑缁嗗弬鏁颁负绌猴紒锛�");
+ throw new CoolException("璋冩暣鍗曟槑缁嗗弬鏁颁负绌猴紒锛�");
}
items.forEach(item -> {
ReviseLog reviseLog = new ReviseLog();
@@ -51,9 +64,76 @@
.setUpdateBy(loginUserId)
.setReviseCode(locRevise.getCode()) ;
if (!reviseLogService.save(reviseLog)) {
- throw new RuntimeException("璋冩暣鍗曟槑缁嗕繚瀛樺け璐ワ紒锛�");
+ throw new CoolException("璋冩暣鍗曟槑缁嗕繚瀛樺け璐ワ紒锛�");
}
});
+ locRevise.setExceStatus(CommonExceStatus.COMMON_EXCE_STATUS_UN_EXCE.val);
+
+ if (!locReviseService.updateById(locRevise)) {
+ throw new CoolException("鐘舵�佹洿鏂板け璐ワ紒锛�");
+ }
return items;
}
+
+ /**
+ * @author Ryan
+ * @date 2025/8/18
+ * @description: 纭璋冩暣搴撳瓨
+ * @version 1.0
+ */
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public R complete(Long id, Long loginUserId) {
+ LocRevise revise = locReviseService.getById(id);
+ if (Objects.isNull(revise)) {
+ throw new CoolException("璋冩暣鍗曚笉瀛樺湪锛侊紒");
+ }
+ if (!revise.getExceStatus().equals(CommonExceStatus.COMMON_EXCE_STATUS_EXCE_ING.val)) {
+ throw new CoolException("鍗曟嵁鐘舵�佹湭鎵ц鎴栧凡瀹屾垚锛屾棤娉曟墽琛屽畬鎴愭搷浣滐紒锛�");
+ }
+ ReviseLog logs = reviseLogService.getOne(new LambdaQueryWrapper<ReviseLog>().eq(ReviseLog::getReviseId, revise.getId()));
+ if (Objects.isNull(logs)) {
+ throw new CoolException("搴撳瓨鏃ュ織涓嶅瓨鍦紒锛�");
+ }
+ List<ReviseLogItem> logItems = reviseLogItemService.list(new LambdaQueryWrapper<ReviseLogItem>().eq(ReviseLogItem::getReviseLogId, logs.getId()));
+ Map<Long, List<ReviseLogItem>> listMap = logItems.stream().collect(Collectors.groupingBy(ReviseLogItem::getLocId));
+ listMap.keySet().forEach(items -> {
+ Loc loc = locService.getById(items);
+ if (Objects.isNull(loc)) {
+ throw new CoolException("搴撲綅涓嶅瓨鍦紒锛�");
+ }
+ listMap.get(items).forEach(logItem -> {
+ LocItem one = locItemService.getOne(new LambdaQueryWrapper<LocItem>()
+ .eq(LocItem::getMatnrId, logItem.getMatnrId())
+ .eq(StringUtils.isNotBlank(logItem.getBatch()), LocItem::getBatch, logItem.getBatch())
+ .eq(StringUtils.isNotBlank(logItem.getFieldsIndex()), LocItem::getFieldsIndex, logItem.getFieldsIndex())
+ .eq(LocItem::getLocCode, logItem.getLocCode()));
+ if (Objects.isNull(one)) {
+ LocItem locDetl = new LocItem();
+ BeanUtils.copyProperties(logItem, locDetl);
+ locDetl.setLocId(loc.getId())
+ .setType(OrderType.ORDER_REVISE.type)
+ .setLocCode(loc.getCode())
+ .setAnfme(logItem.getReviseQty())
+ .setUpdateBy(loginUserId)
+ .setId(null)
+ .setCreateBy(loginUserId);
+ if (!locItemService.save(locDetl)) {
+ throw new CoolException("搴撳瓨鏄庣粏淇濆瓨澶辫触锛侊紒");
+ }
+ } else {
+ one.setAnfme(logItem.getReviseQty());
+ if (!locItemService.updateById(one)) {
+ throw new CoolException("搴撳瓨鏄庣粏淇敼澶辫触锛侊紒");
+ }
+ }
+ });
+ });
+
+ revise.setExceStatus(CommonExceStatus.COMMON_EXCE_STATUS_TASK_DONE.val);
+ if (!locReviseService.updateById(revise)) {
+ throw new CoolException("璋冩暣鍗曚慨鏀瑰け璐ワ紒锛�");
+ }
+ return R.ok();
+ }
}
--
Gitblit v1.9.1