From d015cc0b48ca51a2b93b6c60c91dc352a104b1e7 Mon Sep 17 00:00:00 2001
From: kongzy <kongzy>
Date: 星期一, 23 九月 2024 10:41:50 +0800
Subject: [PATCH] 删除密码加密
---
incident-manage/incident-manage-rpc-provider/src/main/java/com/gkhy/safePlatform/incidentManage/rpc/provider/IncidentManageRpcProvider.java | 202 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 201 insertions(+), 1 deletions(-)
diff --git a/incident-manage/incident-manage-rpc-provider/src/main/java/com/gkhy/safePlatform/incidentManage/rpc/provider/IncidentManageRpcProvider.java b/incident-manage/incident-manage-rpc-provider/src/main/java/com/gkhy/safePlatform/incidentManage/rpc/provider/IncidentManageRpcProvider.java
index 1a1bd5e..39c1f2e 100644
--- a/incident-manage/incident-manage-rpc-provider/src/main/java/com/gkhy/safePlatform/incidentManage/rpc/provider/IncidentManageRpcProvider.java
+++ b/incident-manage/incident-manage-rpc-provider/src/main/java/com/gkhy/safePlatform/incidentManage/rpc/provider/IncidentManageRpcProvider.java
@@ -1,14 +1,25 @@
package com.gkhy.safePlatform.incidentManage.rpc.provider;
+import com.gkhy.safePlatform.commons.enums.ResultCodes;
+import com.gkhy.safePlatform.commons.exception.BusinessException;
+import com.gkhy.safePlatform.commons.utils.BeanCopyUtils;
+import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
+import com.gkhy.safePlatform.incidentManage.enums.AccidentResultCodes;
+import com.gkhy.safePlatform.incidentManage.exception.AccidentException;
+import com.gkhy.safePlatform.incidentManage.model.dto.resp.*;
+import com.gkhy.safePlatform.incidentManage.query.IncidentManageCountQuery;
import com.gkhy.safePlatform.incidentManage.rpc.api.IncidentManageRpcAPi;
import com.gkhy.safePlatform.incidentManage.rpc.api.model.dto.req.IncidentManageCountRPCReq;
-import com.gkhy.safePlatform.incidentManage.rpc.api.model.dto.resp.IncidentManageRPCResp;
+import com.gkhy.safePlatform.incidentManage.rpc.api.model.dto.resp.*;
import com.gkhy.safePlatform.incidentManage.service.AccidentCountService;
+import org.apache.commons.collections.CollectionUtils;
import org.apache.dubbo.config.annotation.DubboService;
+import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
+import java.util.ArrayList;
import java.util.List;
@DubboService
@@ -26,4 +37,193 @@
public SearchResultVO<List<IncidentManageRPCResp>> getCountByDeptIds(IncidentManageCountRPCReq query) {
return accidentCountService.getCountByDeptIds(query);
}
+
+ @Override
+ public ResultVO<StatisticsDepLevelMonthAccidentRPCRespDTO> getAccidentCountByDeptIdAndMonth(IncidentManageCountRPCReq query) {
+ ResultVO<StatisticsDepLevelMonthAccidentRPCRespDTO> result = new ResultVO<>(ResultCodes.OK);
+ IncidentManageCountQuery countQuery = new IncidentManageCountQuery();
+ countQuery.setDeptId(query.getDeptId());
+ countQuery.setYear(query.getYear());
+ countQuery.setMonth(query.getMonth());
+ try{
+ StatisticsDepLevelMonthAccidentRespDTO accidentRespDTO = accidentCountService.getCountByDeptIdAndMonth(countQuery);
+ StatisticsDepLevelMonthAccidentRPCRespDTO accidentRPCRespDTO = new StatisticsDepLevelMonthAccidentRPCRespDTO();
+ accidentRPCRespDTO.setMonth(accidentRespDTO.getMonth());
+ accidentRPCRespDTO.setDepLevel(accidentRespDTO.getDepLevel());
+ List<AccidentLevelResultCountRespDTO> accidentLevelList = accidentRespDTO.getAccidentLevelList();
+ if(!CollectionUtils.isEmpty(accidentLevelList)){
+ List<AccidentLevelResultCountRPCRespDTO> resultCountRPCRespDTOList = BeanCopyUtils.copyBeanList(accidentLevelList, AccidentLevelResultCountRPCRespDTO.class);
+ accidentRPCRespDTO.setAccidentLevelList(resultCountRPCRespDTOList);
+ }
+ result.setData(accidentRPCRespDTO);
+ }catch (AccidentException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (Exception e) {
+ result.setCode(AccidentResultCodes.ERROR.getCode());
+ result.setMsg(AccidentResultCodes.ERROR.getDesc());
+ }
+ return result;
+ }
+
+ @Override
+ public ResultVO<StatisticsDeptLevelYearAccidentRPCRespDTO> getAccidentCountByDeptIdAndYear(IncidentManageCountRPCReq query) {
+ ResultVO<StatisticsDeptLevelYearAccidentRPCRespDTO> result = new ResultVO<>(ResultCodes.OK);
+ IncidentManageCountQuery countQuery = new IncidentManageCountQuery();
+ countQuery.setDeptId(query.getDeptId());
+ countQuery.setYear(query.getYear());
+ countQuery.setMonth(query.getMonth());
+ try{
+ StatisticsDeptLevelYearAccidentRespDTO accidentRespDTO = accidentCountService.getCountByDeptIdAndYear(countQuery);
+ StatisticsDeptLevelYearAccidentRPCRespDTO accidentRPCRespDTO = new StatisticsDeptLevelYearAccidentRPCRespDTO();
+ accidentRPCRespDTO.setYear(accidentRespDTO.getYear());
+ accidentRPCRespDTO.setDepLevel(accidentRespDTO.getDepLevel());
+ List<StatisticsDepLevelMonthAccidentRespDTO> monthList = accidentRespDTO.getMonthList();
+ List<StatisticsDepLevelMonthAccidentRPCRespDTO> monthAccidentRPCRespDTOList = new ArrayList<>();
+ if(!CollectionUtils.isEmpty(monthList)){
+ for(StatisticsDepLevelMonthAccidentRespDTO monthAccidentRespDTO : monthList){
+ StatisticsDepLevelMonthAccidentRPCRespDTO monthAccidentRPCRespDTO = new StatisticsDepLevelMonthAccidentRPCRespDTO();
+ monthAccidentRPCRespDTO.setMonth(monthAccidentRespDTO.getMonth());
+ monthAccidentRPCRespDTO.setDepLevel(monthAccidentRespDTO.getDepLevel());
+ List<AccidentLevelResultCountRespDTO> accidentLevelList = monthAccidentRespDTO.getAccidentLevelList();
+ if(!CollectionUtils.isEmpty(accidentLevelList)){
+ List<AccidentLevelResultCountRPCRespDTO> resultCountRPCRespDTOList = BeanCopyUtils.copyBeanList(accidentLevelList, AccidentLevelResultCountRPCRespDTO.class);
+ monthAccidentRPCRespDTO.setAccidentLevelList(resultCountRPCRespDTOList);
+ }
+ monthAccidentRPCRespDTOList.add(monthAccidentRPCRespDTO);
+ }
+ }
+ accidentRPCRespDTO.setMonthList(monthAccidentRPCRespDTOList);
+ result.setData(accidentRPCRespDTO);
+ }catch (AccidentException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (Exception e) {
+ result.setCode(AccidentResultCodes.ERROR.getCode());
+ result.setMsg(AccidentResultCodes.ERROR.getDesc());
+ }
+ return result;
+ }
+
+ @Override
+ public ResultVO<List<StatisticsDepLevelMonthAccidentRPCRespDTO>> getAccidentCountByDeptIdsAndMonth(IncidentManageCountRPCReq query) {
+ ResultVO<List<StatisticsDepLevelMonthAccidentRPCRespDTO>> result = new ResultVO<>(ResultCodes.OK);
+ IncidentManageCountQuery countQuery = new IncidentManageCountQuery();
+ countQuery.setDeptId(query.getDeptId());
+ countQuery.setYear(query.getYear());
+ countQuery.setMonth(query.getMonth());
+ try{
+ List<StatisticsDepLevelMonthAccidentRespDTO> accidentRespDTOList = accidentCountService.getCountByDeptIdsAndMonth(countQuery);
+ List<StatisticsDepLevelMonthAccidentRPCRespDTO> accidentRPCRespDTOList = new ArrayList<>();
+ for(StatisticsDepLevelMonthAccidentRespDTO accidentRespDTO:accidentRespDTOList){
+ StatisticsDepLevelMonthAccidentRPCRespDTO accidentRPCRespDTO = new StatisticsDepLevelMonthAccidentRPCRespDTO();
+ accidentRPCRespDTO.setMonth(accidentRespDTO.getMonth());
+ accidentRPCRespDTO.setDepLevel(accidentRespDTO.getDepLevel());
+ List<AccidentLevelResultCountRespDTO> accidentLevelList = accidentRespDTO.getAccidentLevelList();
+ if(!CollectionUtils.isEmpty(accidentLevelList)){
+ List<AccidentLevelResultCountRPCRespDTO> resultCountRPCRespDTOList = BeanCopyUtils.copyBeanList(accidentLevelList, AccidentLevelResultCountRPCRespDTO.class);
+ accidentRPCRespDTO.setAccidentLevelList(resultCountRPCRespDTOList);
+ }
+ accidentRPCRespDTOList.add(accidentRPCRespDTO);
+ }
+ result.setData(accidentRPCRespDTOList);
+ }catch (AccidentException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (Exception e) {
+ result.setCode(AccidentResultCodes.ERROR.getCode());
+ result.setMsg(AccidentResultCodes.ERROR.getDesc());
+ }
+ return result;
+ }
+
+ @Override
+ public ResultVO<List<StatisticsDeptLevelYearAccidentRPCRespDTO>> getAccidentCountByDeptIdsAndYear(IncidentManageCountRPCReq query) {
+ ResultVO<List<StatisticsDeptLevelYearAccidentRPCRespDTO>> result = new ResultVO<>(ResultCodes.OK);
+ IncidentManageCountQuery countQuery = new IncidentManageCountQuery();
+ countQuery.setDeptId(query.getDeptId());
+ countQuery.setYear(query.getYear());
+ countQuery.setMonth(query.getMonth());
+ try{
+ List<StatisticsDeptLevelYearAccidentRespDTO> yearAccidentRespDTOList = accidentCountService.getCountByDeptIdsAndYear(countQuery);
+ List<StatisticsDeptLevelYearAccidentRPCRespDTO> accidentRPCRespDTOList = new ArrayList<>();
+ for(StatisticsDeptLevelYearAccidentRespDTO yearAccidentRespDTO:yearAccidentRespDTOList){
+ StatisticsDeptLevelYearAccidentRPCRespDTO yearAccidentRPCRespDTO = new StatisticsDeptLevelYearAccidentRPCRespDTO();
+ yearAccidentRPCRespDTO.setYear(yearAccidentRespDTO.getYear());
+ yearAccidentRPCRespDTO.setDepLevel(yearAccidentRespDTO.getDepLevel());
+ List<StatisticsDepLevelMonthAccidentRespDTO> monthList = yearAccidentRespDTO.getMonthList();
+ List<StatisticsDepLevelMonthAccidentRPCRespDTO> monthAccidentRPCRespDTOList = new ArrayList<>();
+ if(!CollectionUtils.isEmpty(monthList)){
+ for(StatisticsDepLevelMonthAccidentRespDTO monthAccidentRespDTO:monthList){
+ StatisticsDepLevelMonthAccidentRPCRespDTO monthAccidentRPCRespDTO = new StatisticsDepLevelMonthAccidentRPCRespDTO();
+ monthAccidentRPCRespDTO.setMonth(monthAccidentRespDTO.getMonth());
+ monthAccidentRPCRespDTO.setDepLevel(monthAccidentRespDTO.getDepLevel());
+ List<AccidentLevelResultCountRespDTO> accidentLevelList = monthAccidentRespDTO.getAccidentLevelList();
+ if (!CollectionUtils.isEmpty(accidentLevelList)) {
+ List<AccidentLevelResultCountRPCRespDTO> resultCountRPCRespDTOList = BeanCopyUtils.copyBeanList(accidentLevelList, AccidentLevelResultCountRPCRespDTO.class);
+ monthAccidentRPCRespDTO.setAccidentLevelList(resultCountRPCRespDTOList);
+ }
+ monthAccidentRPCRespDTOList.add(monthAccidentRPCRespDTO);
+ }
+ }
+ accidentRPCRespDTOList.add(yearAccidentRPCRespDTO);
+
+ }
+ result.setData(accidentRPCRespDTOList);
+ }catch (AccidentException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (Exception e) {
+ result.setCode(AccidentResultCodes.ERROR.getCode());
+ result.setMsg(AccidentResultCodes.ERROR.getDesc());
+ }
+ return result;
+ }
+
+ @Override
+ public ResultVO<List<IncidentStatisticCountRPCRespDTO>> getAccidentCountByGradeAndTime(IncidentManageCountRPCReq query){
+ ResultVO<List<IncidentStatisticCountRPCRespDTO>> result = new ResultVO<>(ResultCodes.OK);
+ try{
+ List<AccidentStatisticDTO> countByAccidentGradeList = accidentCountService.getCountByAccidentGrade(query.getYear(), query.getMonth());
+
+ List<IncidentStatisticCountRPCRespDTO> statisticCountRPCRespDTOList = new ArrayList<>();
+ for(AccidentStatisticDTO accidentStatisticDTO:countByAccidentGradeList){
+ IncidentStatisticCountRPCRespDTO accidentRPCRespDTO = new IncidentStatisticCountRPCRespDTO();
+ accidentRPCRespDTO.setAccidentGrade(accidentStatisticDTO.getAccidentGrade());
+ accidentRPCRespDTO.setCount(accidentStatisticDTO.getCount());
+ statisticCountRPCRespDTOList.add(accidentRPCRespDTO);
+ }
+ result.setData(statisticCountRPCRespDTOList);
+ }catch (AccidentException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (BusinessException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (Exception e) {
+ result.setCode(AccidentResultCodes.ERROR.getCode());
+ result.setMsg(AccidentResultCodes.ERROR.getDesc());
+ }
+ return result;
+ }
+ @Override
+ public ResultVO<AccidentCountByGradeRPCRespDTO> getSpiAccidentCountByGradeAndTime(IncidentManageCountRPCReq query){
+ ResultVO<AccidentCountByGradeRPCRespDTO> result = new ResultVO<>(ResultCodes.OK);
+ try{
+ AccidentCountByGradeRespDTO accidentCountByGradeRespDTO = accidentCountService.getSpiAccidentCountByAccidentGrade(query.getYear(), query.getMonth());
+ AccidentCountByGradeRPCRespDTO accidentRPCRespDTO = new AccidentCountByGradeRPCRespDTO();
+ BeanUtils.copyProperties(accidentCountByGradeRespDTO, accidentRPCRespDTO);
+ result.setData(accidentRPCRespDTO);
+ }catch (AccidentException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (BusinessException e){
+ result.setCode(e.getCode());
+ result.setMsg(e.getMessage());
+ }catch (Exception e) {
+ result.setCode(AccidentResultCodes.ERROR.getCode());
+ result.setMsg(AccidentResultCodes.ERROR.getDesc());
+ }
+ return result;
+ }
}
--
Gitblit v1.9.2