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