From 5bd5f3bcd6d2cb375feb0756505691b551339716 Mon Sep 17 00:00:00 2001
From: zhangfeng <1603559716@qq.com>
Date: 星期五, 23 十二月 2022 08:55:23 +0800
Subject: [PATCH] Merge branch 'master' of https://sinanoaq.cn:8888/r/safePlatform-out into zf
---
equipment/equipment-rpc-provider/src/main/java/com/gkhy/safePlatform/equipment/rpc/provider/EquipmentRpcProvider.java | 239 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 239 insertions(+), 0 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
new file mode 100644
index 0000000..ca71dc0
--- /dev/null
+++ b/equipment/equipment-rpc-provider/src/main/java/com/gkhy/safePlatform/equipment/rpc/provider/EquipmentRpcProvider.java
@@ -0,0 +1,239 @@
+package com.gkhy.safePlatform.equipment.rpc.provider;
+
+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;
+import com.gkhy.safePlatform.equipment.model.dto.req.MaterialSpwReq;
+import com.gkhy.safePlatform.equipment.model.dto.resp.SafeMaterialClassifyDto;
+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.*;
+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;
+import org.springframework.util.CollectionUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@DubboService
+public class EquipmentRpcProvider implements EquipmentRpcAPi {
+ @Autowired
+ private MaterialClassifyService materialClassifyService;
+ @Autowired
+ private SafeMaterialDetailService safeMaterialDetailService;
+ @Autowired
+ private MaterialReceiveRecordsService materialReceiveRecordsService;
+
+
+ public ResultVO<List<SafeMaterialClassifyRPCRespDto>> getMaterialClassifyList(){
+ ResultVO<List<SafeMaterialClassifyRPCRespDto>> resultVO = new ResultVO(ResultCodes.OK);
+ List<SafeMaterialClassifyDto> list = materialClassifyService.list();
+ List<SafeMaterialClassifyRPCRespDto> rpcRespList = new ArrayList<>();
+ for (SafeMaterialClassifyDto classifyDto:list) {
+ SafeMaterialClassifyRPCRespDto classifyRPCRespDto = new SafeMaterialClassifyRPCRespDto();
+ classifyRPCRespDto.setId(classifyDto.getId());
+ classifyRPCRespDto.setParentId(classifyDto.getParentId());
+ classifyRPCRespDto.setMaterialClassifyName(classifyDto.getMaterialClassifyName());
+ List<SafeMaterialClassifyDto> childList = classifyDto.getChildList();
+ List<SafeMaterialClassifyRPCRespDto> childRPCList = new ArrayList<>();
+ for(SafeMaterialClassifyDto child:childList){
+ //临时限制一下
+ 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);
+
+ }
+ resultVO.setData(rpcRespList);
+ return resultVO;
+ }
+
+ @Override
+ public ResultVO<List<SafeMaterialBsClassifyRPCRespDto>> getTraceabilityClassifyList(List<Long> smallClassifyIds) {
+ ResultVO<List<SafeMaterialBsClassifyRPCRespDto>> resultVO = new ResultVO<>(ResultCodes.OK);
+ try {
+ List<SafeMaterialClassifyDO> list = materialClassifyService.getTraceabilityClassifyList(smallClassifyIds);
+ List<SafeMaterialBsClassifyRPCRespDto> classifyRPCRespDtoList= new ArrayList<>();
+ for(SafeMaterialClassifyDO classifyDO:list){
+ SafeMaterialBsClassifyRPCRespDto bsClassifyRPCRespDto = new SafeMaterialBsClassifyRPCRespDto();
+ BeanUtils.copyProperties(classifyDO,bsClassifyRPCRespDto);
+ classifyRPCRespDtoList.add(bsClassifyRPCRespDto);
+ }
+ resultVO.setData(classifyRPCRespDtoList);
+ }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;
+ }
+
+ public ResultVO<SafeMaterialBsClassifyRPCRespDto> getBigAndSmallClassifyInfo(Long smallClassifyId){
+ ResultVO<SafeMaterialBsClassifyRPCRespDto> resultVO = new ResultVO<>(ResultCodes.OK);
+ try {
+ SafeMaterialClassifyDO safeMaterialClassifyDO = materialClassifyService.getBigAndSmallClassifyInfo(smallClassifyId);
+ SafeMaterialBsClassifyRPCRespDto bsClassifyRPCRespDto = new SafeMaterialBsClassifyRPCRespDto();
+ if(null != safeMaterialClassifyDO){
+ BeanUtils.copyProperties(safeMaterialClassifyDO,bsClassifyRPCRespDto);
+ }
+ resultVO.setData(bsClassifyRPCRespDto);
+ }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;
+ }
+
+ @Override
+ public ResultVO<List<SafeMaterialClassifyRPCRespDto>> getClassifyListByIds(List<Long> ids) {
+ ResultVO<List<SafeMaterialClassifyRPCRespDto>> resultVO = new ResultVO<>(ResultCodes.OK);
+ try {
+ List<SafeMaterialClassifyDto> listBySmallClassify = materialClassifyService.getClassifyListByIds(ids);
+ List<SafeMaterialClassifyRPCRespDto> classifyRPCRespDtoList = new ArrayList<>();
+ for(SafeMaterialClassifyDto classifyDto:listBySmallClassify){
+ SafeMaterialClassifyRPCRespDto classifyRPCRespDto = new SafeMaterialClassifyRPCRespDto();
+ BeanUtils.copyProperties(classifyDto,classifyRPCRespDto);
+ classifyRPCRespDtoList.add(classifyRPCRespDto);
+ }
+ resultVO.setData(classifyRPCRespDtoList);
+ }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;
+ }
+
+ @Override
+ public ResultVO<List<SafeMaterialClassifyStockRPCRespDto>> getSmallClassifyStockByIds(List<Long> smallClassifyIds) {
+ ResultVO<List<SafeMaterialClassifyStockRPCRespDto>> resultVO = new ResultVO<>(ResultCodes.OK);
+ try {
+ List<SafeMaterialClassifyStockDto> smallClassifyStockList = safeMaterialDetailService.getSmallClassifyStockByIds(smallClassifyIds);
+ List<SafeMaterialClassifyStockRPCRespDto> classifyRPCRespDtoList = new ArrayList<>();
+ for(SafeMaterialClassifyStockDto classifyStockDto:smallClassifyStockList){
+ SafeMaterialClassifyStockRPCRespDto classifyRPCRespDto = new SafeMaterialClassifyStockRPCRespDto();
+ BeanUtils.copyProperties(classifyStockDto,classifyRPCRespDto);
+ classifyRPCRespDtoList.add(classifyRPCRespDto);
+ }
+ resultVO.setData(classifyRPCRespDtoList);
+ }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;
+ }
+
+ @Override
+ public ResultVO deliveryBatchSpw(MaterialSpwRPCReq req) {
+ ResultVO resultVO = new ResultVO<>(ResultCodes.OK);
+ MaterialSpwReq materialSpwReq = new MaterialSpwReq();
+ List<MaterialSpwDeliveryReq> list = new ArrayList<>();
+ List<MaterialSpwDeliveryRPCReq> deliveryRPCReqList = req.getDeliveryReqList();
+ if(!CollectionUtils.isEmpty(deliveryRPCReqList)){
+ for (MaterialSpwDeliveryRPCReq deliveryRPCReq:deliveryRPCReqList) {
+ MaterialSpwDeliveryReq deliveryReq = new MaterialSpwDeliveryReq();
+ BeanUtils.copyProperties(deliveryRPCReq,deliveryReq);
+ list.add(deliveryReq);
+ }
+ }
+ materialSpwReq.setClaimantId(req.getClaimantId());
+ materialSpwReq.setDeliveryReqList(list);
+
+ try {
+ safeMaterialDetailService.deliveryBatchSpw(materialSpwReq);
+ }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;
+ }
+
+ @Override
+ public ResultVO<List<SafeRfidMaterialDetailRPCRespDto>> getListByRfid(List<String> rfids) {
+ ResultVO resultVO = new ResultVO<>(ResultCodes.OK);
+ try {
+ List<SafeRfidMaterialDetailDto> listByRfids = safeMaterialDetailService.getListByRfids(rfids);
+ if(listByRfids.size()>0){
+ List<SafeRfidMaterialDetailRPCRespDto> safeRfidMaterialDetailRPCRespDtos = BeanCopyUtils.copyBeanList(listByRfids, SafeRfidMaterialDetailRPCRespDto.class);
+ resultVO.setData(safeRfidMaterialDetailRPCRespDtos);
+ }
+ }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;
+ }
+
+ @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