From dda268997ca8f8a364f7c19b45d7a43a50a98efe Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期二, 25 十月 2022 18:00:11 +0800
Subject: [PATCH] changes

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/ErrorMsgService.java |  126 ++++++++++++++++++++++--------------------
 1 files changed, 66 insertions(+), 60 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ErrorMsgService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ErrorMsgService.java
index f138605..f124b6f 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ErrorMsgService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ErrorMsgService.java
@@ -3,16 +3,13 @@
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.sandu.common.domain.CommonPage;
-import com.sandu.common.execption.BusinessException;
 import com.sandu.common.object.BaseConditionVO;
 import com.sandu.ximon.admin.dto.ErrorMsgDto;
-import com.sandu.ximon.admin.utils.ListPagingUtils;
 import com.sandu.ximon.dao.bo.C3ReportErrorBo;
 import com.sandu.ximon.dao.bo.LightReportErrorBo;
 import com.sandu.ximon.dao.domain.C3mCharging;
 import com.sandu.ximon.dao.domain.Light;
 import lombok.AllArgsConstructor;
-import org.apache.commons.lang.StringUtils;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -34,67 +31,76 @@
     private final C3ChargingService c3ChargingService;
 
 
-    public CommonPage listMsg(BaseConditionVO baseConditionVO, String type) {
-        if (StringUtils.isEmpty(type)) {
-            throw new BusinessException("璁惧鏁呴殰绫诲瀷涓嶈兘涓虹┖锛�");
-        }
-        CommonPage commonPage = null;
-        switch (type) {
-            case "鍗曠伅鏁呴殰":
-                //鍗曠伅鏁呴殰鏁版嵁
-                commonPage = lightReportErrorService.queryErrorCode(baseConditionVO);
-                if (!commonPage.getList().isEmpty()) {
-                    for (LightReportErrorBo lightReportError : (List<LightReportErrorBo>) commonPage.getList()) {
-                        ErrorMsgDto errorMsgDto = new ErrorMsgDto();
-                        errorMsgDto.setMac(lightReportError.getDeviceCode());
-                        errorMsgDto.setErrorCode(lightReportError.getErrorCode());
-                        errorMsgDto.setErrorDesc(lightReportError.getErrorMsg());
-                        errorMsgDto.setErrorTime(lightReportError.getCreateTime());
-                        errorMsgDto.setDeviceType(1);
-                        Light one = lightService.getOne(Wrappers.lambdaQuery(Light.class).eq(Light::getDeviceCode, lightReportError.getDeviceCode()));
-                        if (one != null) {
-                            errorMsgDto.setDeviceJson(JSON.toJSONString(one));
-                        }
-                    }
+    /**
+     * 鍗曠伅
+     *
+     * @param baseConditionVO
+     * @return
+     */
+    public CommonPage lightListMsg(BaseConditionVO baseConditionVO) {
+        List<ErrorMsgDto> errorMsgDtoList = new ArrayList<>();
+        //鍗曠伅鏁呴殰鏁版嵁
+        CommonPage commonPage = lightReportErrorService.queryErrorCode(baseConditionVO);
+        if (!commonPage.getList().isEmpty()) {
+            for (LightReportErrorBo lightReportError : (List<LightReportErrorBo>) commonPage.getList()) {
+                ErrorMsgDto errorMsgDto = new ErrorMsgDto();
+                errorMsgDto.setMac(lightReportError.getDeviceCode());
+                errorMsgDto.setErrorCode(lightReportError.getErrorCode());
+                errorMsgDto.setErrorDesc(lightReportError.getErrorMsg());
+                errorMsgDto.setErrorTime(lightReportError.getCreateTime());
+                errorMsgDto.setDeviceType(1);
+                Light one = lightService.getOne(Wrappers.lambdaQuery(Light.class).eq(Light::getDeviceCode, lightReportError.getDeviceCode()));
+                System.out.println(lightReportError.getDeviceCode() + " ---code ");
+                if (one != null) {
+                    errorMsgDto.setDeviceJson(JSON.toJSONString(one));
+                } else {
+                    errorMsgDto.setDeviceJson("绯荤粺鏈壘鍒拌澶囨暟鎹�");
                 }
-                break;
-            case "鍏呯數妗╂晠闅�":
-                //鍏呯數妗╂晠闅滄暟鎹�
-                List<C3ReportErrorBo> c3ReportErrorBos = c3mReportErrorService.listReportError(baseConditionVO);
-                if (!c3ReportErrorBos.isEmpty()) {
-                    List<C3ReportErrorBo> list = c3ReportErrorBos;
-                    list.forEach(c3ReportError -> {
-                        ErrorMsgDto errorMsgDto = new ErrorMsgDto();
-                        errorMsgDto.setMac(c3ReportError.getC3Mac());
-                        errorMsgDto.setErrorDesc(c3ReportError.getErrorMsg());
-                        errorMsgDto.setErrorTime(c3ReportError.getCreateTime());
-                        errorMsgDto.setDeviceType(3);
-                        C3mCharging one = c3ChargingService.getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3ReportError.getC3Mac()));
-                        if (one != null) {
-                            errorMsgDto.setDeviceJson(JSON.toJSONString(one));
-                        }
-                    });
-                    commonPage = new CommonPage();
-                    commonPage.setList(c3ReportErrorBos);
-                }
-
-                break;
-            case "澶ф皵鏁呴殰":
-                //澶ф皵鏁呴殰鏁版嵁  todo 鏆傛棤
-
-                break;
-            default:
-                throw new BusinessException("绫诲瀷涓嶆纭紝璇风‘璁わ紒");
+                errorMsgDtoList.add(errorMsgDto);
+            }
         }
-//
-//
-//        //瀵筫rrorMsgDtos鎸夊垱寤烘椂闂村�掑彊
-//        errorMsgDtos.sort((a, b) -> b.getErrorTime().compareTo(a.getErrorTime()));
-//        //鎵嬪姩鍒嗛〉  baseConditionVO.getPageNo() 褰撳墠椤� baseConditionVO.getPageSize() 姣忛〉鏉℃暟
-////        return errorMsgDtos.subList((baseConditionVO.getPageNo() - 1) * baseConditionVO.getPageSize(), baseConditionVO.getPageNo() * baseConditionVO.getPageSize());
-//        ListPagingUtils.pages(errorMsgDtos, baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+        commonPage.setList(errorMsgDtoList);
         return commonPage;
     }
 
+    /**
+     * 鍏呯數妗�
+     *
+     * @param baseConditionVO
+     * @return
+     */
+    public List<ErrorMsgDto> C3ListMsg(BaseConditionVO baseConditionVO) {
+        List<ErrorMsgDto> errorMsgDtoList = new ArrayList<>();
+        //鍏呯數妗╂晠闅滄暟鎹�
+        List<C3ReportErrorBo> c3ReportErrorBos = c3mReportErrorService.listReportError(baseConditionVO);
+        if (!c3ReportErrorBos.isEmpty()) {
+            List<C3ReportErrorBo> list = c3ReportErrorBos;
+            list.forEach(c3ReportError -> {
+                ErrorMsgDto errorMsgDto = new ErrorMsgDto();
+                errorMsgDto.setMac(c3ReportError.getC3Mac());
+                errorMsgDto.setErrorDesc(c3ReportError.getErrorMsg());
+                errorMsgDto.setErrorTime(c3ReportError.getCreateTime());
+                errorMsgDto.setDeviceType(3);
+                C3mCharging one = c3ChargingService.getOne(Wrappers.lambdaQuery(C3mCharging.class).eq(C3mCharging::getC3Mac, c3ReportError.getC3Mac()));
+                if (one != null) {
+                    errorMsgDto.setDeviceJson(JSON.toJSONString(one));
+                }else {
+                    errorMsgDto.setDeviceJson("绯荤粺鏈壘鍒拌澶囨暟鎹�");
+                }
+                errorMsgDtoList.add(errorMsgDto);
+            });
+        }
+        return errorMsgDtoList;
+    }
+
+    /**
+     * 澶ф皵
+     *
+     * @param baseConditionVO
+     * @return
+     */
+    public List<ErrorMsgDto> atmosphereListMsg(BaseConditionVO baseConditionVO) {
+        return new ArrayList<>();
+    }
 
 }

--
Gitblit v1.9.3