From 38aaf481e936881b79671548d122d27e10997a72 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期五, 12 十二月 2025 16:33:52 +0800
Subject: [PATCH] yys  库存分析

---
 src/main/java/com/ruoyi/production/service/impl/SalesLedgerSchedulingServiceImpl.java |  103 +++++++++++++++++++++++++++++++--------------------
 1 files changed, 62 insertions(+), 41 deletions(-)

diff --git a/src/main/java/com/ruoyi/production/service/impl/SalesLedgerSchedulingServiceImpl.java b/src/main/java/com/ruoyi/production/service/impl/SalesLedgerSchedulingServiceImpl.java
index 873bd1d..7c96246 100644
--- a/src/main/java/com/ruoyi/production/service/impl/SalesLedgerSchedulingServiceImpl.java
+++ b/src/main/java/com/ruoyi/production/service/impl/SalesLedgerSchedulingServiceImpl.java
@@ -25,6 +25,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
@@ -32,6 +33,7 @@
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -56,6 +58,11 @@
 
     @Override
     public IPage<SalesLedgerSchedulingDto> listPage(Page page, SalesLedgerSchedulingDto salesLedgerSchedulingDto) {
+        LoginUser loginUser = SecurityUtils.getLoginUser();
+        if(!"admin".equals(loginUser.getUsername())){
+            salesLedgerSchedulingDto.setProductionUserId(SecurityUtils.getLoginUser().getUser().getUserId());
+            salesLedgerSchedulingDto.setProductionUserName(SecurityUtils.getLoginUser().getUser().getNickName());
+        }
         IPage<SalesLedgerSchedulingDto> list = salesLedgerSchedulingMapper.listPage(page, salesLedgerSchedulingDto);
         if(list.getTotal() == 0){
             return list;
@@ -144,52 +151,60 @@
                 i++;
                 continue;
             }
-            // 鑾峰彇绌轰綑鐐掓満
-            String[] split = productionDispatchAddDto.getSpeculativeTradingName().split(",");
-            if(split != null && split.length == 0){
+            SysUser sysUser1 = sysUserMapper.selectUserById(productionDispatchAddDto.getProductionUserId() == null ? loginUser.getUser().getUserId() : productionDispatchAddDto.getSchedulingUserId());
+            if(sysUser1 == null){
                 i++;
                 continue;
             }
-            List<SpeculativeTradingInfo> speculativeTradingInfos = speculativeTradingInfoMapper.selectList(new LambdaQueryWrapper<SpeculativeTradingInfo>()
-                    .in(SpeculativeTradingInfo::getName, Arrays.asList(split))
-                    .orderByAsc(SpeculativeTradingInfo::getSort));
-            if(CollectionUtils.isEmpty(speculativeTradingInfos)){
-                i++;
-                continue;
-            }
-            AtomicReference<String> name = new AtomicReference<>("");  //闇�瑕佺粦瀹氱殑鐐掓満
-            //閫氳繃瑙勬牸鍨嬪彿鍜屾帓浜ф暟閲忚绠楁湰娆$敓浜т骇閲�
-            String[] split1 = productionDispatchAddDto.getSpecificationModel().split("\\*");
-            if(split1.length != 2){
-                i++;
-                continue;
-            }
-            // 鏈鐢熶骇浜ч噺
-            BigDecimal productionNum = new BigDecimal(split1[0])
-                    .multiply(new BigDecimal(split1[1]).multiply(productionDispatchAddDto.getSchedulingNum()));
-            // 澶氫釜鐐掓満鎯呭喌
-            if(speculativeTradingInfos.size() > 1){
-                for (SpeculativeTradingInfo speculativeTradingInfo : speculativeTradingInfos) {
-                    // 鑾峰彇璇ョ倰鏈烘鍦ㄦ帓浜ч噺
-                    BigDecimal schedulingNumBySpeculativeTradingName = getSchedulingNumBySpeculativeTradingName(speculativeTradingInfo.getName());
-                    // 濡傛灉璇ョ倰鏈烘�婚噺(鍗曚綅kg闇�瑕佷箻1000) - 姝e湪鎺掍骇閲� >=鏈鐢熶骇浜ч噺灏卞垎閰嶆鐐掓満
-                    if(speculativeTradingInfo.getWorkLoad().multiply(new BigDecimal(1000)).subtract(schedulingNumBySpeculativeTradingName).compareTo(productionNum) >= 0){
-                        name.set(speculativeTradingInfo.getName());
-                        break;
-                    }
-                }
-            }else{
-                // 鍗曚釜鐐掓満鎯呭喌
-                name.set(speculativeTradingInfos.get(0).getName());
-            }
-            if(name.get().isEmpty()){
-                i++;
-                continue;
-            }
+//            // 鑾峰彇绌轰綑鐐掓満
+//            String[] split = productionDispatchAddDto.getSpeculativeTradingName().split(",");
+//            if(split != null && split.length == 0){
+//                i++;
+//                continue;
+//            }
+//            List<SpeculativeTradingInfo> speculativeTradingInfos = speculativeTradingInfoMapper.selectList(new LambdaQueryWrapper<SpeculativeTradingInfo>()
+//                    .in(SpeculativeTradingInfo::getName, Arrays.asList(split))
+//                    .orderByAsc(SpeculativeTradingInfo::getSort));
+//            if(CollectionUtils.isEmpty(speculativeTradingInfos)){
+//                i++;
+//                continue;
+//            }
+//            AtomicReference<String> name = new AtomicReference<>("");  //闇�瑕佺粦瀹氱殑鐐掓満
+//            //閫氳繃瑙勬牸鍨嬪彿鍜屾帓浜ф暟閲忚绠楁湰娆$敓浜т骇閲�
+//            String[] split1 = productionDispatchAddDto.getSpecificationModel().split("\\*");
+//            if(split1.length != 2){
+//                i++;
+//                continue;
+//            }
+//            // 鏈鐢熶骇浜ч噺
+//            BigDecimal productionNum = new BigDecimal(split1[0])
+//                    .multiply(new BigDecimal(split1[1]).multiply(productionDispatchAddDto.getSchedulingNum()));
+//            // 澶氫釜鐐掓満鎯呭喌
+//            if(speculativeTradingInfos.size() > 1){
+//                for (SpeculativeTradingInfo speculativeTradingInfo : speculativeTradingInfos) {
+//                    // 鑾峰彇璇ョ倰鏈烘鍦ㄦ帓浜ч噺
+//                    BigDecimal schedulingNumBySpeculativeTradingName = getSchedulingNumBySpeculativeTradingName(speculativeTradingInfo.getName());
+//                    // 濡傛灉璇ョ倰鏈烘�婚噺(鍗曚綅kg闇�瑕佷箻1000) - 姝e湪鎺掍骇閲� >=鏈鐢熶骇浜ч噺灏卞垎閰嶆鐐掓満
+//                    if(speculativeTradingInfo.getWorkLoad().multiply(new BigDecimal(1000)).subtract(schedulingNumBySpeculativeTradingName).compareTo(productionNum) >= 0){
+//                        name.set(speculativeTradingInfo.getName());
+//                        break;
+//                    }
+//                }
+//            }else{
+//                // 鍗曚釜鐐掓満鎯呭喌
+//                name.set(speculativeTradingInfos.get(0).getName());
+//            }
+//            if(name.get().isEmpty()){
+//                i++;
+//                continue;
+//            }
             SalesLedgerScheduling salesLedgerScheduling = SalesLedgerScheduling.builder()
                     .salesLedgerId(productionDispatchAddDto.getSalesLedgerId())
                     .salesLedgerProductId(productionDispatchAddDto.getSalesLedgerProductId())
-                    .speculativeTradingName(name.get())
+//                    .speculativeTradingName(name.get())
+                    .productionUserId(sysUser1.getUserId())
+                    .productionUserName(sysUser1.getNickName())
+                    .productionLineId(productionDispatchAddDto.getLineId())
                     .schedulingUserId(sysUser.getUserId())
                     .schedulingUserName(sysUser.getNickName())
                     .schedulingNum(productionDispatchAddDto.getSchedulingNum())
@@ -242,7 +257,7 @@
         return new BigDecimal(totalNum.get()).multiply(new BigDecimal(100)).divide(lossNum, 2,RoundingMode.HALF_UP);
     }
 
-    private LossMapper lossMapper;
+    private final LossMapper lossMapper;
 
 
     /**
@@ -280,6 +295,10 @@
 
     @Override
     public IPage<SalesLedgerSchedulingProcessDto> listPageProcess(Page page, SalesLedgerSchedulingProcessDto salesLedgerSchedulingDto) {
+        LoginUser loginUser = SecurityUtils.getLoginUser();
+        if(!"admin".equals(loginUser.getUsername())){
+            salesLedgerSchedulingDto.setProductionUserId(loginUser.getUserId());
+        }
         IPage<SalesLedgerSchedulingProcessDto> list = salesLedgerSchedulingMapper.listPageProcess(page, salesLedgerSchedulingDto);
 //        Set<Long> collect = list.getRecords().stream().map(SalesLedgerSchedulingProcessDto::getId).collect(Collectors.toSet());
 //        if(CollectionUtils.isEmpty(collect)) return list;
@@ -337,6 +356,8 @@
             SalesLedgerWork.SalesLedgerWorkBuilder salesLedgerWorkBuilder = SalesLedgerWork.builder()
                     .salesLedgerSchedulingId(salesLedgerScheduling.getId())
                     .salesLedgerId(salesLedgerScheduling.getSalesLedgerId())
+                    .productionUserId(salesLedgerScheduling.getProductionUserId())
+                    .productionUserName(salesLedgerScheduling.getProductionUserName())
                     .remark(processSchedulingDto.getRemark())
                     .type(processSchedulingDto.getType())
                     .loss(processSchedulingDto.getLoss())

--
Gitblit v1.9.3