From 256c59555e2a5dffdd6d127a519d4f0944b80e7f Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期三, 14 五月 2025 16:29:38 +0800
Subject: [PATCH] #物料表动态字段搜索

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java |   61 +++++++++++++++++++++++++-----
 1 files changed, 50 insertions(+), 11 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
index bf17cb3..5f955a8 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
@@ -2,7 +2,6 @@
 
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.vincent.rsf.framework.common.Cools;
 import com.vincent.rsf.framework.common.R;
 import com.vincent.rsf.framework.exception.CoolException;
@@ -22,12 +21,14 @@
 import com.vincent.rsf.server.manager.mapper.*;
 import com.vincent.rsf.server.manager.service.*;
 import com.vincent.rsf.server.system.constant.CodeRes;
+import com.vincent.rsf.server.system.constant.GlobalConfigCode;
 import com.vincent.rsf.server.system.constant.SerialRuleCode;
 import com.vincent.rsf.server.system.controller.param.LoginParam;
 import com.vincent.rsf.server.system.controller.result.LoginResult;
 import com.vincent.rsf.server.system.entity.*;
 import com.vincent.rsf.server.system.mapper.FieldsMapper;
 import com.vincent.rsf.server.system.mapper.TenantMapper;
+import com.vincent.rsf.server.system.service.ConfigService;
 import com.vincent.rsf.server.system.service.FieldsItemService;
 import com.vincent.rsf.server.system.service.UserLoginService;
 import com.vincent.rsf.server.system.service.UserService;
@@ -41,6 +42,8 @@
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -121,6 +124,8 @@
     private LocAreaMapper locAreaMapper;
     @Autowired
     private DeviceSiteMapper deviceSiteMapper;
+    @Autowired
+    private ConfigService configService;
 
     /**
      * @return
@@ -231,11 +236,15 @@
         }
         //TODO /**鏀惰揣鏁伴噺绱姞锛�1. 浼氬嚭瓒呮敹鎯呭喌 2. 浼氭湁鏀惰揣涓嶈冻鎯呭喌*/
         Double rcptedQty = asnOrder.getQty() + receiptQty;
-        asnOrder.setQty(rcptedQty).setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_EXCE_ING.val);
 
+        asnOrder.setQty(rcptedQty).setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_EXCE_ING.val);
         if (!asnOrderMapper.updateById(asnOrder)) {
             throw new CoolException("宸叉敹璐ф暟閲忎慨鏀瑰け璐ワ紒锛�");
         }
+
+        Config config = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.ALLOW_OVER_CHANGE));
+
+
         List<Map<String, Object>> receipts1 = (List<Map<String, Object>>) params.get("receipts");
         for (Map<String, Object> rcpt : receipts1) {
             if (null == rcpt || Objects.isNull(rcpt)) {
@@ -267,7 +276,27 @@
             if (Objects.isNull(dto.getReceiptQty()) || Double.compare(dto.getReceiptQty(), 0.0) == 0) {
                 throw new CoolException("鐗╂枡:" + dto.getMaktx() + "鏀惰揣鏁伴噺涓嶈兘涓洪浂锛侊紒");
             }
+
+            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+            try {
+                if (!Objects.isNull(dto.getProdTime())) {
+                    sdf.parse(dto.getProdTime());
+                }
+            } catch (ParseException e) {
+                throw new CoolException("璇疯緭鍏ユ纭殑鏃堕棿鏍煎紡锛侊紒");
+            }
+
             Double itemRcptQty = dto.getReceiptQty() + orderItem.getQty();
+            Boolean allowOver = false;
+            if (!Objects.isNull(config)) {
+                if (Boolean.parseBoolean(config.getVal())) {
+                    allowOver = true;
+                }
+            }
+            if (itemRcptQty.compareTo(orderItem.getAnfme()) > 0 && !allowOver) {
+                throw new CoolException("鏀惰揣鏁伴噺涓嶈兘澶т簬璁″垝鏁伴噺锛侊紒");
+            }
+
             orderItem.setQty(itemRcptQty)
 //                    .setSplrBatch(dto.getSplrBatch())
                     .setUpdateBy(loginUserId)
@@ -343,13 +372,21 @@
                 .setFieldsIndex(orderItem.getFieldsIndex())
                 .setShipperId(matnr.getShipperId());
         //TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲
-        WarehouseAreasItem serviceOne = warehouseAreasItemService.getOne(new LambdaQueryWrapper<WarehouseAreasItem>()
+
+        LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new LambdaQueryWrapper<WarehouseAreasItem>()
 //                .eq(WarehouseAreasItem::getAsnItemId, item.getAsnItemId())
                 .eq(WarehouseAreasItem::getMatnrCode, item.getMatnrCode())
                 .eq(!Cools.isEmpty(item.getFieldsIndex()), WarehouseAreasItem::getFieldsIndex, item.getFieldsIndex())
                 .eq(WarehouseAreasItem::getAsnCode, item.getAsnCode())
-                .eq(!Cools.isEmpty(item.getIsptResult()), WarehouseAreasItem::getIsptResult, item.getIsptResult())
-                .eq(StringUtils.isNotBlank(item.getSplrBatch()), WarehouseAreasItem::getSplrBatch, item.getSplrBatch()));
+                .eq(StringUtils.isNotBlank(item.getSplrBatch()), WarehouseAreasItem::getSplrBatch, item.getSplrBatch());
+        if (Objects.isNull(orderItem.getIsptResult())) {
+            queryWrapper.isNull(WarehouseAreasItem::getIsptResult);
+        } else {
+            queryWrapper.eq(WarehouseAreasItem::getIsptResult, orderItem.getIsptResult());
+        }
+
+        WarehouseAreasItem serviceOne = warehouseAreasItemService.getOne(queryWrapper);
+
         if (!Objects.isNull(serviceOne)) {
             item.setId(serviceOne.getId());
             item.setAnfme(item.getAnfme() + serviceOne.getAnfme());
@@ -612,15 +649,15 @@
                     .setId(isptItem.getId())
                     .setMatnrCode(isptItem.getMatnrCode())
                     .setMaktx(isptItem.getMaktx())
-                    .setDisQty(isptItem.getDisQty())
+//                    .setDisQty(isptItem.getDisQty())
                     .setDlyQty(isptItem.getDlyQty())
                     .setRcptQty(isptItem.getRcptQty())
                     .setIsptResult(isptItem.getIsptResult())
                     .setSplrBatch(isptItem.getSplrBatch())
                     .setSplrName(isptItem.getSplrName())
                     .setPicPath(isptItem.getPicPath())
-                    .setMemo(isptItem.getMemo())
-                    .setSafeQty(isptItem.getSafeQty());
+                    .setMemo(isptItem.getMemo());
+//                    .setSafeQty(isptItem.getSafeQty());
             dtos.add(objDto);
         });
         return R.ok(dtos);
@@ -630,16 +667,17 @@
      * 蹇�熻川妫�
      *
      * @param params
+     * @param loginUserId
      * @return
      */
     @Override
-    public R checkUpdate(List<QlyIsptItem> params) {
+    public R checkUpdate(List<QlyIsptItem> params, Long loginUserId) {
         if (Objects.isNull(params) || params.isEmpty()) {
             throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
         }
         IsptItemsParams itemsParams = new IsptItemsParams();
         itemsParams.setIsptItem(params).setType("0");
-        if (qlyIsptItemService.batchUpdate(itemsParams)) {
+        if (qlyIsptItemService.batchUpdate(itemsParams, loginUserId)) {
             return R.ok();
         } else {
             return R.error("淇濆瓨澶辫触锛侊紒");
@@ -694,7 +732,8 @@
         /**鑾峰彇骞冲簱璁㈠崟*/
         AsnOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>()
                 .eq(AsnOrder::getId, OrderId)
-                .eq(AsnOrder::getType, OrderType.ORDER_PLAT_IN.type));
+                        .eq(AsnOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type)
+                .eq(AsnOrder::getType, OrderType.ORDER_IN.type));
         if (Objects.isNull(order)) {
             throw new CoolException("闈炲钩搴撳崟鎹笉鍙墽琛屼汉宸ヤ笂鏋讹紒锛�");
         }

--
Gitblit v1.9.1