From 97304f6bb74875063755e53721d44b2f2a587cc5 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期六, 15 三月 2025 17:32:41 +0800
Subject: [PATCH] #修改 1. mybatis Map驼峰不转换问题修复 2. 字段修改导致接口显示问题修复

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java |  163 +++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 113 insertions(+), 50 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 956f040..527cf7b 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
@@ -1,5 +1,6 @@
 package com.vincent.rsf.server.api.service.impl;
 
+import com.alibaba.druid.sql.visitor.functions.If;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.vincent.rsf.framework.common.Cools;
 import com.vincent.rsf.framework.common.R;
@@ -12,19 +13,22 @@
 import com.vincent.rsf.server.common.config.ConfigProperties;
 import com.vincent.rsf.server.common.enums.WarehouseAreaType;
 import com.vincent.rsf.server.common.security.JwtSubject;
+import com.vincent.rsf.server.common.utils.CommonUtil;
 import com.vincent.rsf.server.common.utils.JwtUtil;
 import com.vincent.rsf.server.manager.entity.*;
 import com.vincent.rsf.server.manager.mapper.*;
 import com.vincent.rsf.server.manager.service.WarehouseAreasItemService;
 import com.vincent.rsf.server.manager.service.WarehouseAreasService;
 import com.vincent.rsf.server.system.constant.CodeRes;
+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.Tenant;
-import com.vincent.rsf.server.system.entity.User;
-import com.vincent.rsf.server.system.entity.UserLogin;
+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.mapper.UserMapper;
+import com.vincent.rsf.server.system.service.FieldsItemService;
+import com.vincent.rsf.server.system.service.FieldsService;
 import com.vincent.rsf.server.system.service.UserLoginService;
 import com.vincent.rsf.server.system.utils.SerialRuleUtils;
 import org.apache.tika.utils.StringUtils;
@@ -73,6 +77,11 @@
     private StockItemMapper stockItemMapper;
     @Resource
     private PurchaseItemMapper purchaseItemMapper;
+    @Resource
+    private FieldsMapper fieldsMapper;
+
+    @Autowired
+    private FieldsItemService fieldsItemService;
 
 
     /**
@@ -122,7 +131,7 @@
         if (StringUtils.isEmpty(barcode)) {
             return R.error("鏍囩鐮佷笉鑳戒负绌猴紒锛�");
         }
-        AsnOrderItem asnOrderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getBarcode, barcode));
+        List<AsnOrderItem> asnOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getBarcode, barcode));
         if (Objects.isNull(asnOrderItem)) {
             throw new CoolException("鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�");
         }
@@ -146,7 +155,14 @@
         if (Objects.isNull(params.getWhAreaId())) {
             throw new CoolException("搴撳尯鏍囪瘑涓嶈兘涓虹┖锛侊紒");
         }
-        WarehouseAreasItem areasItem = warehouseAreasItemService.getOne(new LambdaQueryWrapper<WarehouseAreasItem>().eq(WarehouseAreasItem::getAreaId, params.getWhAreaId()));
+
+        WarehouseAreas areasItem = warehouseAreasService.getOne(new LambdaQueryWrapper<WarehouseAreas>().eq(WarehouseAreas::getId, params.getWhAreaId()));
+        if (Objects.isNull(areasItem)) {
+            throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶅簱鍖轰笉瀛樺湪锛侊紒");
+        }
+        //鑾峰彇宸插惎鐢ㄧ殑鍔ㄦ�佹墿灞曞瓧
+        List<Fields> fields = fieldsMapper.selectList(new LambdaQueryWrapper<Fields>().eq(Fields::getFlagEnable, 1).eq(Fields::getStatus, 1));
+
         List<ReceiptDetlsDto> receipts = params.getReceipts();
         List<WarehouseAreasItem> allOrders =   new ArrayList<>();
         receipts.forEach(dto -> {
@@ -156,10 +172,10 @@
             }
             WarehouseAreasItem item = new WarehouseAreasItem();
             item.setBarcode(dto.getBarcode())
-                    .setAreaName(areasItem.getAreaName())
-                    .setAreaId(areasItem.getAreaId())
+                    .setAreaName(areasItem.getName())
+                    .setAreaId(areasItem.getId())
                     .setStockUnit(dto.getStockUnit())
-                    .setBatch(SerialRuleUtils.generateRuleCode("sys_receipt_batch", dto))
+                    .setBatch(SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto))
                     .setAnfme(dto.getReceiptQty())
                     .setSplrBtch(dto.getSplrBatch())
                     .setMatnrCode(matnr.getCode())
@@ -172,7 +188,35 @@
                     .setShipperId(matnr.getShipperId());
                     //TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲
 
+            if (!Objects.isNull(fields)) {
+                if (!Objects.isNull(dto.getExtendFields())) {
+                    //鑾峰彇16浣島uid
+                    String uuid16 = CommonUtil.randomUUID16();
+                    Map<String, Object> extendFields = dto.getExtendFields();
+                    //瀛楁闆嗗悎鐢虫槑
+                    List<FieldsItem> fieldsItems = new ArrayList<>();
+                    extendFields.keySet().forEach(key -> {
+                        fields.forEach(obj -> {
+                            //鍒ゆ柇key鍊间笌fields琛ㄥ瓧娈垫槸鍚︾浉鍚�
+                            if (obj.getFields().equals(key)) {
+                                FieldsItem fieldsItem = new FieldsItem();
+                                fieldsItem.setMatnrId(matnr.getId()).setFieldsId(obj.getId())
+                                        .setShiperId(matnr.getShipperId())
+                                        .setValue(extendFields.get(key).toString())
+                                        .setUuid(uuid16);
+                                fieldsItems.add(fieldsItem);
+                                //鍞竴鏍囪瘑鍏ュ簱
+                                item.setFieldsIndex(uuid16);
+                            }
+                        });
+                    });
+                    if (!fieldsItemService.saveBatch(fieldsItems)) {
+                        throw new CoolException("鎵╁睍瀛楁淇濆瓨澶辫触锛侊紒");
+                    }
+                }
+            }
             allOrders.add(item);
+
         });
 
         if (!warehouseAreasItemService.saveBatch(allOrders)) {
@@ -193,13 +237,9 @@
         if (Objects.isNull(params.getAsnCode())) {
             throw new CoolException("閫氱煡鍗曚笉鑳戒负绌猴紒锛�");
         }
-        if (Objects.isNull(params.getBarcode())) {
-            throw new CoolException("鐗╂枡缂栫爜涓嶈兘涓虹┖锛侊紒");
-        }
-
-        AsnOrderItem asnOrderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>()
+        List<AsnOrderItem> asnOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>()
                 .eq(AsnOrderItem::getAsnCode, params.getAsnCode())
-                .eq(AsnOrderItem::getBarcode, params.getBarcode()));
+                .eq(!Objects.isNull(params.getBarcode()) ,AsnOrderItem::getBarcode, params.getBarcode()));
 
         if (Objects.isNull(asnOrderItem)) {
             throw new CoolException("鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�");
@@ -233,47 +273,70 @@
     }
 
     /**
-     * 鑾峰彇ReceiptDetlsDto
+     * @author Ryan
+     * @description 鑾峰彇鎵�鏈夊惎鐢ㄥ姩鎬佸瓧娈�
+     * @param
+     * @return
+     * @time 2025/3/12 09:23
      */
-    private R getAsnOrderItem(AsnOrderItem asnOrderItem) {
-        ReceiptDetlsDto detlsDto = new ReceiptDetlsDto();
+    @Override
+    public List<Fields> getDynamicFields() {
+        return fieldsMapper.selectList(new LambdaQueryWrapper<Fields>().eq(Fields::getFlagEnable, 1).eq(Fields::getStatus, 1));
+    }
 
-        detlsDto.setAsnCode(asnOrderItem.getAsnCode())
-                .setMatnk(asnOrderItem.getMatnk())
-                .setBarcode(asnOrderItem.getBarcode())
-                .setPoCode(asnOrderItem.getPoCode())
-                .setPurQty(asnOrderItem.getAnfme())
-                .setSplrBatch(asnOrderItem.getSplrBatch());
+    /**
+     * 鑾峰彇ReceiptDetlsDtos
+     */
+    private R getAsnOrderItem(List<AsnOrderItem> items) {
+        List<ReceiptDetlsDto> detlsDtos = new ArrayList<>();
+        items.forEach(asnOrderItem -> {
+            ReceiptDetlsDto detlsDto = new ReceiptDetlsDto();
 
-        Matnr matnr = matnrMapper.selectById(asnOrderItem.getMatnrId());
-        if (Objects.isNull(matnr)) {
-            throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶇墿鏂欎笉瀛樺湪锛侊紒");
-        }
-        //SET 鐗╂枡鏈�澶у瓨鏀炬暟閲�
-        detlsDto.setMaxQty(matnr.getMaxQty())
-                .setMatnrId(matnr.getId())
-                .setStockUnit(matnr.getStockUnit());
-        QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>()
-                .eq(QlyInspect::getAsnItemId, asnOrderItem.getId()).eq(QlyInspect::getPoItemId, asnOrderItem.getPoDetlId()));
-        //set 璐ㄦ缁撴灉
-        detlsDto.setInspect(inspect.getStatus$());
-        //鑾峰彇褰撳墠搴撳瓨淇℃伅
-        StockItem stockItem = stockItemMapper.selectOne(new LambdaQueryWrapper<StockItem>()
-                .eq(StockItem::getAsnItemId, asnOrderItem.getId())
-                .eq(StockItem::getMatnrId, asnOrderItem.getMatnrId()));
-        //SET 褰撳墠搴撳瓨鏁伴噺
-        if (Objects.isNull(stockItem)) {
-            detlsDto.setStockQty(0.0);
-        } else {
-            detlsDto.setStockQty(stockItem.getQty() + stockItem.getWorkQty());
-        }
+            detlsDto.setAsnCode(asnOrderItem.getAsnCode())
+                    .setMaktx(asnOrderItem.getMaktx())
+                    .setBarcode(asnOrderItem.getBarcode())
+                    .setPoCode(asnOrderItem.getPoCode())
+                    .setPurQty(asnOrderItem.getAnfme())
+                    .setSplrBatch(asnOrderItem.getSplrBatch());
 
-        //鑾峰彇閲囪喘鍗曟槑缁嗕俊鎭�
-        PurchaseItem purchaseItem = purchaseItemMapper.selectOne(new LambdaQueryWrapper<PurchaseItem>().eq(PurchaseItem::getId, asnOrderItem.getPoDetlId()));
-        //SET 骞冲彴琛屽彿
-        detlsDto.setPlatformId(purchaseItem.getPlatItemId());
+            Matnr matnr = matnrMapper.selectById(asnOrderItem.getMatnrId());
+            if (Objects.isNull(matnr)) {
+                throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶇墿鏂欎笉瀛樺湪锛侊紒");
+            }
+            //SET 鐗╂枡鏈�澶у瓨鏀炬暟閲�
+            detlsDto.setMaxQty(matnr.getMaxQty())
+                    .setMatnrId(matnr.getId())
+                    .setStockUnit(matnr.getStockUnit());
+            QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>()
+                    .eq(QlyInspect::getAsnItemId, asnOrderItem.getId()));
+            if (!Objects.isNull(inspect)) {
+                //set 璐ㄦ缁撴灉
+                detlsDto.setInspect(inspect.getStatus$());
+            }
+            //鑾峰彇褰撳墠搴撳瓨淇℃伅
+            StockItem stockItem = stockItemMapper.selectOne(new LambdaQueryWrapper<StockItem>()
+                    .eq(StockItem::getAsnItemId, asnOrderItem.getId())
+                    .eq(StockItem::getMatnrId, asnOrderItem.getMatnrId()));
+            //SET 褰撳墠搴撳瓨鏁伴噺
+            if (Objects.isNull(stockItem)) {
+                detlsDto.setStockQty(0.0);
+            } else {
+                detlsDto.setStockQty(stockItem.getQty() + stockItem.getWorkQty());
+            }
 
-        return R.ok(detlsDto);
+            if (!Objects.isNull(asnOrderItem.getPoDetlId())) {
+                //鑾峰彇閲囪喘鍗曟槑缁嗕俊鎭�
+                PurchaseItem purchaseItem = purchaseItemMapper.selectOne(new LambdaQueryWrapper<PurchaseItem>().eq(PurchaseItem::getId, asnOrderItem.getPoDetlId()));
+                if (Objects.isNull(purchaseItem)) {
+                    //SET 骞冲彴琛屽彿
+                    detlsDto.setPlatformId(purchaseItem.getPlatItemId());
+                }
+            }
+
+            detlsDtos.add(detlsDto);
+        });
+
+        return R.ok(detlsDtos);
     }
 
 

--
Gitblit v1.9.1