From 0414ddb0b2b3a7199ae6181a770f97ac140dbd73 Mon Sep 17 00:00:00 2001
From: zhangf <1603559716@qq.com>
Date: 星期三, 08 五月 2024 16:46:22 +0800
Subject: [PATCH] spi统计

---
 emergency/emergency-rpc-provider/src/main/java/com/gkhy/safePlatform/emergency/rpc/provider/EmergencyRpcProvider.java |   23 +++++++++++++++++++++++
 1 files changed, 23 insertions(+), 0 deletions(-)

diff --git a/emergency/emergency-rpc-provider/src/main/java/com/gkhy/safePlatform/emergency/rpc/provider/EmergencyRpcProvider.java b/emergency/emergency-rpc-provider/src/main/java/com/gkhy/safePlatform/emergency/rpc/provider/EmergencyRpcProvider.java
index 52220f8..91dc006 100644
--- a/emergency/emergency-rpc-provider/src/main/java/com/gkhy/safePlatform/emergency/rpc/provider/EmergencyRpcProvider.java
+++ b/emergency/emergency-rpc-provider/src/main/java/com/gkhy/safePlatform/emergency/rpc/provider/EmergencyRpcProvider.java
@@ -27,6 +27,7 @@
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 @DubboService
 public class EmergencyRpcProvider implements EmergencyRpcAPi {
@@ -314,5 +315,27 @@
         return result;
     }
 
+    @Override
+    public ResultVO<List<EmergencySuppliesInfoRPCRespDTO>> getEmergencySupplies() {
+        ResultVO<List<EmergencySuppliesInfoRPCRespDTO>> result = new ResultVO<>(ResultCodes.OK);
+        try{
+            List<EmergencySuppliesInfoRespDTO> emergencySupplies = emergencySuppliesService.getEmergencySupplies();
+            List<EmergencySuppliesInfoRPCRespDTO> collect = emergencySupplies.stream().map(es -> {
+                EmergencySuppliesInfoRPCRespDTO emergencySuppliesInfoRPCRespDTO = new EmergencySuppliesInfoRPCRespDTO();
+                BeanUtils.copyProperties(es, emergencySuppliesInfoRPCRespDTO);
+                return emergencySuppliesInfoRPCRespDTO;
+            }).collect(Collectors.toList());
+            result.setData(collect);
+        }catch (EmergencyException e){
+            result.setCode(e.getCode());
+            result.setMsg(e.getMessage());
+        }catch (Exception e) {
+            e.printStackTrace();
+            result.setCode(EmergencyResultCodes.ERROR.getCode());
+            result.setMsg(EmergencyResultCodes.ERROR.getDesc());
+        }
+        return result;
+    }
+
 
 }

--
Gitblit v1.9.2