From f7d2f20365467a834188edd35c464d9fb9349214 Mon Sep 17 00:00:00 2001
From: zhangfeng <1603559716@qq.com>
Date: 星期五, 23 十二月 2022 08:53:43 +0800
Subject: [PATCH] 安全物资和设备管理调整v2

---
 equipment/equipment-rpc-provider/src/main/java/com/gkhy/safePlatform/equipment/rpc/provider/EquipmentRpcProvider.java |   57 ++++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 48 insertions(+), 9 deletions(-)

diff --git a/equipment/equipment-rpc-provider/src/main/java/com/gkhy/safePlatform/equipment/rpc/provider/EquipmentRpcProvider.java b/equipment/equipment-rpc-provider/src/main/java/com/gkhy/safePlatform/equipment/rpc/provider/EquipmentRpcProvider.java
index b5cbfb2..ca71dc0 100644
--- a/equipment/equipment-rpc-provider/src/main/java/com/gkhy/safePlatform/equipment/rpc/provider/EquipmentRpcProvider.java
+++ b/equipment/equipment-rpc-provider/src/main/java/com/gkhy/safePlatform/equipment/rpc/provider/EquipmentRpcProvider.java
@@ -3,6 +3,8 @@
 import com.gkhy.safePlatform.commons.enums.ResultCodes;
 import com.gkhy.safePlatform.commons.utils.BeanCopyUtils;
 import com.gkhy.safePlatform.commons.vo.ResultVO;
+import com.gkhy.safePlatform.equipment.entity.MaterialReceiveRecordsBO;
+import com.gkhy.safePlatform.equipment.entity.MaterialReceiveRecordsDO;
 import com.gkhy.safePlatform.equipment.entity.SafeMaterialClassifyDO;
 import com.gkhy.safePlatform.equipment.excepiton.EquipmentException;
 import com.gkhy.safePlatform.equipment.model.dto.req.MaterialSpwDeliveryReq;
@@ -11,14 +13,14 @@
 import com.gkhy.safePlatform.equipment.model.dto.resp.SafeMaterialClassifyStockDto;
 import com.gkhy.safePlatform.equipment.model.dto.resp.SafeRfidMaterialDetailDto;
 import com.gkhy.safePlatform.equipment.rpc.api.EquipmentRpcAPi;
+import com.gkhy.safePlatform.equipment.rpc.api.model.dto.req.MaterialReceiveRecordsRPCReq;
 import com.gkhy.safePlatform.equipment.rpc.api.model.dto.req.MaterialSpwDeliveryRPCReq;
 import com.gkhy.safePlatform.equipment.rpc.api.model.dto.req.MaterialSpwRPCReq;
-import com.gkhy.safePlatform.equipment.rpc.api.model.dto.resp.SafeMaterialBsClassifyRPCRespDto;
-import com.gkhy.safePlatform.equipment.rpc.api.model.dto.resp.SafeMaterialClassifyRPCRespDto;
-import com.gkhy.safePlatform.equipment.rpc.api.model.dto.resp.SafeMaterialClassifyStockRPCRespDto;
-import com.gkhy.safePlatform.equipment.rpc.api.model.dto.resp.SafeRfidMaterialDetailRPCRespDto;
+import com.gkhy.safePlatform.equipment.rpc.api.model.dto.resp.*;
 import com.gkhy.safePlatform.equipment.service.MaterialClassifyService;
+import com.gkhy.safePlatform.equipment.service.MaterialReceiveRecordsService;
 import com.gkhy.safePlatform.equipment.service.SafeMaterialDetailService;
+import com.gkhy.safePlatform.equipment.service.impl.MaterialReceiveRecordsServiceImpl;
 import org.apache.dubbo.config.annotation.DubboService;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -33,6 +35,8 @@
     private MaterialClassifyService materialClassifyService;
     @Autowired
     private SafeMaterialDetailService safeMaterialDetailService;
+    @Autowired
+    private MaterialReceiveRecordsService materialReceiveRecordsService;
 
 
     public ResultVO<List<SafeMaterialClassifyRPCRespDto>> getMaterialClassifyList(){
@@ -47,11 +51,17 @@
             List<SafeMaterialClassifyDto> childList = classifyDto.getChildList();
             List<SafeMaterialClassifyRPCRespDto> childRPCList = new ArrayList<>();
             for(SafeMaterialClassifyDto child:childList){
-                SafeMaterialClassifyRPCRespDto childRPCRespDto = new SafeMaterialClassifyRPCRespDto();
-                childRPCRespDto.setId(child.getId());
-                childRPCRespDto.setParentId(child.getParentId());
-                childRPCRespDto.setMaterialClassifyName(child.getMaterialClassifyName());
-                childRPCList.add(childRPCRespDto);
+                //临时限制一下
+                if(child.getConsumable() == 1){
+                    SafeMaterialClassifyRPCRespDto childRPCRespDto = new SafeMaterialClassifyRPCRespDto();
+                    childRPCRespDto.setId(child.getId());
+                    childRPCRespDto.setParentId(child.getParentId());
+                    childRPCRespDto.setMaterialClassifyName(child.getMaterialClassifyName());
+                    childRPCRespDto.setConsumable(child.getConsumable());
+                    childRPCRespDto.setConsumableName(child.getConsumableName());
+                    childRPCList.add(childRPCRespDto);
+                }
+
             }
             classifyRPCRespDto.setChildList(childRPCList);
             rpcRespList.add(classifyRPCRespDto);
@@ -197,4 +207,33 @@
         }
         return resultVO;
     }
+
+    @Override
+    public ResultVO<List<MaterialReceiveRecordsRPCRespDto>> getMaterialReceiveRecords(MaterialReceiveRecordsRPCReq req) {
+        ResultVO resultVO = new ResultVO<>(ResultCodes.OK);
+        MaterialReceiveRecordsBO  materialReceiveRecordsBO = new MaterialReceiveRecordsBO();
+        if(null != req){
+            BeanUtils.copyProperties(req,materialReceiveRecordsBO);
+        }
+        try {
+            List<MaterialReceiveRecordsDO> list = materialReceiveRecordsService.getReceiveRecordsByReceiveUids(materialReceiveRecordsBO);
+            List<MaterialReceiveRecordsRPCRespDto> materialReceiveRecordsRPCRespDtos = new ArrayList<>();
+            if(list.size()>0){
+                for(MaterialReceiveRecordsDO recordsDO:list){
+                    MaterialReceiveRecordsRPCRespDto receiveRecordsRPCRespDto = new MaterialReceiveRecordsRPCRespDto();
+                    BeanUtils.copyProperties(recordsDO,receiveRecordsRPCRespDto);
+                    materialReceiveRecordsRPCRespDtos.add(receiveRecordsRPCRespDto);
+                }
+                resultVO.setData(materialReceiveRecordsRPCRespDtos);
+            }
+        }catch (EquipmentException e){
+            resultVO.setCode(e.getCode());
+            resultVO.setMsg(e.getMessage());
+        }catch (Exception e){
+            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
+            resultVO.setCode(ResultCodes.SERVER_ERROR.getDesc());
+
+        }
+        return resultVO;
+    }
 }

--
Gitblit v1.9.2