diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmRuleVo.java b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmRuleVo.java index a9321297..d59c93a9 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmRuleVo.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmRuleVo.java @@ -13,9 +13,4 @@ public class AlarmRuleVo extends QueryRequest implements Serializable { private String sourceType; private String sourceId; - - private Integer pageStart; - - // 标记:根据条件查询但不进行分页 - private String pageFlag; } diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmVo.java b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmVo.java index 439f0886..b0688d6e 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmVo.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/AlarmVo.java @@ -15,9 +15,4 @@ public class AlarmVo extends QueryRequest implements Serializable { private String startDate; private String endDate; - - private Integer pageStart; - - // 标记:根据条件查询但不进行分页 - private String pageFlag; } diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/NuclideAvgVo.java b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/NuclideAvgVo.java index a7059239..e7effb0b 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/NuclideAvgVo.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/NuclideAvgVo.java @@ -9,6 +9,4 @@ public class NuclideAvgVo extends QueryRequest { private String startDate; private String endDate; - - private int pageStart; } diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/SourceVo.java b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/SourceVo.java index 4954a484..e6df9421 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/SourceVo.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/bizVo/SourceVo.java @@ -14,6 +14,4 @@ public class SourceVo extends QueryRequest implements Serializable { private String startDate; private String endDate; - - private Integer pageStart; } diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/dto/EmailDto.java b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/dto/EmailDto.java index 999524e9..6f33a880 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/dto/EmailDto.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/modules/base/dto/EmailDto.java @@ -32,4 +32,8 @@ public class EmailDto implements Serializable { private String stoerCapacity; private boolean stoerRed; + + private String username; // 邮箱用户名 + + private Integer isQiye; // 是否企业邮箱 } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/controller/SysServerController.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/controller/SysServerController.java index b7fdafba..bd976ffe 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/controller/SysServerController.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/controller/SysServerController.java @@ -30,7 +30,7 @@ public class SysServerController { @GetMapping("findInfo") @ApiOperation(value = "服务器数据详情信息", notes = "服务器数据详情信息") - public Result findInfo(String id){ + public Result findInfo(@RequestParam String id){ return sysServerService.findInfo(id); } @@ -48,7 +48,7 @@ public class SysServerController { @DeleteMapping("deleteById") @ApiOperation(value = "删除服务器数据信息", notes = "删除服务器数据信息") - public Result deleteById(String id){ + public Result deleteById(@RequestParam String id){ return sysServerService.deleteById(id); } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmAnalysisNuclideAvgMapper.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmAnalysisNuclideAvgMapper.java index 0803fc99..86f5d4cb 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmAnalysisNuclideAvgMapper.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmAnalysisNuclideAvgMapper.java @@ -1,5 +1,6 @@ package org.jeecg.modules.mapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.jeecg.modules.base.dto.NuclideAvgDto; import org.jeecg.modules.base.entity.postgre.AlarmAnalysisNuclideAvg; import com.baomidou.mybatisplus.core.mapper.BaseMapper; @@ -9,5 +10,5 @@ import java.util.Map; public interface AlarmAnalysisNuclideAvgMapper extends BaseMapper { - List findPage(Map params); + Page findPage(Page page, Map params); } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmRuleMapper.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmRuleMapper.java index f7c9d10d..986d2dda 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmRuleMapper.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/AlarmRuleMapper.java @@ -1,6 +1,7 @@ package org.jeecg.modules.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.jeecg.modules.base.dto.AlarmRuleDto; import org.jeecg.modules.base.dto.AlarmRuleInfo; import org.jeecg.modules.base.entity.postgre.AlarmRule; @@ -10,7 +11,7 @@ import java.util.Map; public interface AlarmRuleMapper extends BaseMapper { - List findPage(Map params); + Page findPage(Page page, Map params); AlarmRuleInfo findInfo(String alarmRuleId); } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysDatabaseMapper.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysDatabaseMapper.java index 407b396b..c303229d 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysDatabaseMapper.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysDatabaseMapper.java @@ -1,6 +1,7 @@ package org.jeecg.modules.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; import org.jeecg.modules.base.dto.DBInfo; import org.jeecg.modules.base.dto.DatabaseDto; @@ -12,7 +13,7 @@ import java.util.Map; public interface SysDatabaseMapper extends BaseMapper { - List findAlarmHistory(Map params); + Page findAlarmHistory(Page page, Map params); - List findPage(Map params); + Page findPage(Page page, Map params); } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysServerMapper.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysServerMapper.java index 0a637959..d1580a6c 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysServerMapper.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/SysServerMapper.java @@ -1,6 +1,7 @@ package org.jeecg.modules.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.ibatis.annotations.Param; import org.jeecg.modules.base.dto.*; import org.jeecg.modules.base.entity.postgre.SysServer; @@ -11,11 +12,11 @@ import java.util.Map; public interface SysServerMapper extends BaseMapper { - List findAlarmHistory(Map params); + Page findAlarmHistory(Page page, Map params); - List findPage(Map params); + Page findPage(Page page, Map params); - List pageAll(String itemName); + Page pageAll(Page page, String itemName); - List alarmInfo(String sourceId); + Page alarmInfo(Page page, String sourceId); } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmAnalysisNuclideAvgMapper.xml b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmAnalysisNuclideAvgMapper.xml index c987e698..cc9db717 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmAnalysisNuclideAvgMapper.xml +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmAnalysisNuclideAvgMapper.xml @@ -17,16 +17,13 @@ FROM alarm_analysis_nuclide_avg - - cacl_date >= #{startDate} + + cacl_date >= #{params.startDate} - - AND cacl_date <= #{endDate} + + AND cacl_date <= #{params.endDate} ORDER BY cacl_date DESC - - LIMIT #{pageSize} OFFSET #{pageStart} - \ No newline at end of file diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmRuleMapper.xml b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmRuleMapper.xml index da9a1298..d2673545 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmRuleMapper.xml +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/mapper/xml/AlarmRuleMapper.xml @@ -1,7 +1,7 @@ - SELECT * FROM @@ -28,20 +28,17 @@ INNER JOIN alarm_contact_group g ON g.id = r.contact_id ) AS res - - enabled = #{enabled} + + enabled = #{params.enabled} - - AND source_type = #{sourceType} + + AND source_type = #{params.sourceType} - - AND source_id = #{sourceId} + + AND source_id = #{params.sourceId} ORDER BY enabled DESC, create_time DESC - - LIMIT #{pageSize} OFFSET #{pageStart} - \ No newline at end of file diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/InstanceSDK.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/InstanceSDK.java index a7dc67ea..db0de71b 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/InstanceSDK.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/InstanceSDK.java @@ -6,34 +6,40 @@ import com.netease.qiye.qiyeopenplatform.sdk.QiyeOpenPlatSDK; import com.netease.qiye.qiyeopenplatform.sdk.QiyeOpenPlatSDKConfig; import com.netease.qiye.qiyeopenplatform.sdk.dto.Q; import com.netease.qiye.qiyeopenplatform.sdk.dto.R; +import lombok.extern.slf4j.Slf4j; import org.jeecg.common.util.SpringContextUtils; import org.springframework.core.env.Environment; - +@Slf4j public class InstanceSDK { public static QiyeOpenPlatSDK getInstance() { - // 获取nacos armd.yaml配置文件中企业邮箱的相关配置信息 - Property property = Property.getInstance(); - String appId = property.getAppId(); - String orgOpenId = property.getOrgOpenId(); - String authCode = property.getAuthCode(); - String urlPrefix = property.getUrlPrefix(); - // 使用配置信息初始化配置类 - QiyeOpenPlatSDKConfig qiyeOpenPlatSDKConfig = QiyeOpenPlatSDKConfig.builder() - //应用ID - .appId(appId) - //企业OpenID - .orgOpenId(orgOpenId) - //服务地址信息 - .urlPrefix(urlPrefix) - .build(); - // 使用配置类创建SDK实例 - QiyeOpenPlatSDK qiyeOpenPlatSDK = new QiyeOpenPlatSDK("qiyeOpenPlatSDK", qiyeOpenPlatSDKConfig); - // 通过授权码登录 获取Token类并给SDK实例设置Token类 - R appLoginRespR = qiyeOpenPlatSDK.appLogin(authCode); - AppLoginResp appLoginResp = appLoginRespR.getDataBean(AppLoginResp.class); - qiyeOpenPlatSDK.getQiyeOpenPlatSDKConfig().setupToken(appLoginResp); - - return qiyeOpenPlatSDK; + QiyeOpenPlatSDK qiyeOpenPlatSDK = null; + try { + // 获取nacos armd.yaml配置文件中企业邮箱的相关配置信息 + Property property = Property.getInstance(); + String appId = property.getAppId(); + String orgOpenId = property.getOrgOpenId(); + String authCode = property.getAuthCode(); + String urlPrefix = property.getUrlPrefix(); + // 使用配置信息初始化配置类 + QiyeOpenPlatSDKConfig qiyeOpenPlatSDKConfig = QiyeOpenPlatSDKConfig.builder() + //应用ID + .appId(appId) + //企业OpenID + .orgOpenId(orgOpenId) + //服务地址信息 + .urlPrefix(urlPrefix) + .build(); + // 使用配置类创建SDK实例 + qiyeOpenPlatSDK = new QiyeOpenPlatSDK("qiyeOpenPlatSDK", qiyeOpenPlatSDKConfig); + // 通过授权码登录 获取Token类并给SDK实例设置Token类 + R appLoginRespR = qiyeOpenPlatSDK.appLogin(authCode); + AppLoginResp appLoginResp = appLoginRespR.getDataBean(AppLoginResp.class); + qiyeOpenPlatSDK.getQiyeOpenPlatSDKConfig().setupToken(appLoginResp); + return qiyeOpenPlatSDK; + }catch (Exception e){ + log.error("网易企业邮箱QiyeOpenPlatSDK登录失败: {}", e.getMessage()); + return null; + } } } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/RParam.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/RParam.java index 6798c5e1..9f0a4e94 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/RParam.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/qiyeEmail/base/RParam.java @@ -14,4 +14,13 @@ public class RParam { private String orgOpenId; // 必须 private Boolean showAliasDomain; // 必须 + + public RParam(String account_name, String domain) { + this.account_name = account_name; + this.domain = domain; + } + + public RParam() { + + } } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/ISysServerService.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/ISysServerService.java index 82e8d924..8f5c97f6 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/ISysServerService.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/ISysServerService.java @@ -12,17 +12,17 @@ import java.util.List; public interface ISysServerService extends IService { - Result findPage(QueryRequest query); + Result findPage(QueryRequest query); - Result findInfo(String id); + Result findInfo(String id); - Result create(SysServer sysServer); + Result create(SysServer sysServer); - Result update(SysServer sysServer); + Result update(SysServer sysServer); - Result deleteById(String id); + Result deleteById(String id); - Result findAlarmHistory(SourceVo sourceVo); + Result findAlarmHistory(SourceVo sourceVo); List listAll(); diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmAnalysisNuclideAvgServiceImpl.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmAnalysisNuclideAvgServiceImpl.java index 26498e43..d95ef555 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmAnalysisNuclideAvgServiceImpl.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmAnalysisNuclideAvgServiceImpl.java @@ -34,14 +34,9 @@ public class AlarmAnalysisNuclideAvgServiceImpl extends ServiceImpl findPage(NuclideAvgVo nuclideAvgVo) { Integer pageNo = nuclideAvgVo.getPageNo(); Integer pageSize = nuclideAvgVo.getPageSize(); - int pageStart = (pageNo - 1) * pageSize; - nuclideAvgVo.setPageStart(pageStart); Map params = BeanUtil.beanToMap(nuclideAvgVo); - List records = baseMapper.findPage(params); - params.put("pageFlag","noPage"); - int total = baseMapper.findPage(params).size(); - Page page = new Page<>(pageNo,pageSize,total); - page.setRecords(records); + Page page = new Page<>(pageNo, pageSize); + page = baseMapper.findPage(page, params); return page; } } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmRuleServiceImpl.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmRuleServiceImpl.java index 51432c3b..a29f93da 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmRuleServiceImpl.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/AlarmRuleServiceImpl.java @@ -58,17 +58,9 @@ public class AlarmRuleServiceImpl extends ServiceImpl findPage(AlarmRuleVo alarmRuleVo) { Integer pageNo = alarmRuleVo.getPageNo(); Integer pageSize = alarmRuleVo.getPageSize(); - Page page = new Page<>(pageNo,pageSize); - Integer pageStart = (pageNo - 1) * pageSize; - alarmRuleVo.setPageStart(pageStart); + Page page = new Page<>(pageNo, pageSize); Map params = BeanUtil.beanToMap(alarmRuleVo); - List alarmHistories = baseMapper.findPage(params); - // 当前页数据 - page.setRecords(alarmHistories); - // 获取数据总条数(经过查询条件过滤后的) - params.put("pageFlag","noPage"); - int total = baseMapper.findPage(params).size(); - page.setTotal(total); + page = baseMapper.findPage(page, params); return Result.OK(page); } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysDatabaseServiceImpl.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysDatabaseServiceImpl.java index ea45a67e..af4dd809 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysDatabaseServiceImpl.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysDatabaseServiceImpl.java @@ -53,10 +53,7 @@ public class SysDatabaseServiceImpl extends ServiceImpl findPage(QueryRequest query) { Integer pageNo = query.getPageNo(); Integer pageSize = query.getPageSize(); - Integer pageStart = (pageNo - 1) * pageSize; Map params = new HashMap<>(); - params.put("pageSize",pageSize); - params.put("pageStart",pageStart); DateTimeFormatter formatter = DateTimeFormatter .ofPattern(DateConstant.DATE); String date = LocalDate.now().format(formatter); @@ -64,7 +61,9 @@ public class SysDatabaseServiceImpl extends ServiceImpl databaseDtos = baseMapper.findPage(params); + Page page = new Page<>(pageNo, pageSize); + page = baseMapper.findPage(page, params); + List databaseDtos = page.getRecords(); List items = systemClient.getItems(DictConstant.DATASOURCE_TYPE); // 数据库类型Map key:类型值 value:类型名称 Map dataSourceMap = items.stream().collect(Collectors @@ -85,9 +84,6 @@ public class SysDatabaseServiceImpl extends ServiceImpl page = new Page<>(pageNo, pageSize, total); page.setRecords(databaseDtos); return Result.OK(page); } @@ -202,16 +198,9 @@ public class SysDatabaseServiceImpl extends ServiceImpl params = BeanUtil.beanToMap(sourceVo); - List alarmHistories = baseMapper.findAlarmHistory(params); - // 获取数据总条数(经过查询条件过滤后的) - params.put("pageFlag","noPage"); - int total = baseMapper.findAlarmHistory(params).size(); - Page page = new Page<>(pageNo,pageSize,total); - // 当前页数据 - page.setRecords(alarmHistories); + Page page = new Page<>(pageNo, pageSize); + page = baseMapper.findAlarmHistory(page, params); return Result.OK(page); } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysEmailLogServiceImpl.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysEmailLogServiceImpl.java index 3cff4b19..aa310d33 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysEmailLogServiceImpl.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysEmailLogServiceImpl.java @@ -101,15 +101,13 @@ public class SysEmailLogServiceImpl extends ServiceImpl i String emailStatus = RedisConstant.EMAIL_STATUS; String statusKey = prefixStatus + emailStatus; Map statusMap = redisUtil.hmget(statusKey); + // 查询是否有企业邮箱 + List hasQieye = emailDtos.stream().map(EmailDto::getIsQiye) + .filter(ObjectUtil::isNotNull).filter(isQiye -> Qiye.IS.getValue() == isQiye) + .collect(Collectors.toList()); + QiyeOpenPlatSDK platSDK = null; + // 如果emailDtos中存在企业邮箱 则提前登录为查询邮箱信息做准备 + if (CollUtil.isNotEmpty(hasQieye)) platSDK = InstanceSDK.getInstance(); + // 遍历emailDtos 完善每一个邮箱的详细配置信息 for (EmailDto emailDto : emailDtos) { String id = emailDto.getId(); + Integer isQiye = emailDto.getIsQiye(); + String capacity = "--"; + if (ObjectUtil.isNotNull(isQiye) && Qiye.IS.getValue() == isQiye){ + String username = emailDto.getUsername(); + String[] info = StrUtil.split(username, SymbolConstant.AT); + if (ArrayUtil.length(info) == 2 && ObjectUtil.isNotNull(platSDK)){ + String accountName = info[0]; + String domain = info[1]; + RParam param = new RParam(accountName, domain); + AccountInfo accountInfo = Account.getMailAccountInfo(platSDK, param); + Integer usedQuota = accountInfo.getUsedQuota(); + if (ObjectUtil.isNotNull(usedQuota)) + capacity = usedQuota + " MB"; + } + } Boolean online = (Boolean) statusMap.get(id); if (ObjectUtil.isNull(online)) online = false; - emailDto.setOnline(online).setStoerCapacity("100%").setStoerRed(true) + emailDto.setOnline(online).setStoerCapacity(capacity).setStoerRed(true) .setToday(todayMap.getOrDefault(id, 0)) .setYesterday(yestMap.getOrDefault(id, 0)) .setWeekly(weekMap.getOrDefault(id, 0)); @@ -264,13 +288,4 @@ public class SysEmailServiceImpl extends ServiceImpl i boolean contains = CollUtil.contains(domains, domain); return contains ? Qiye.IS.getValue() : Qiye.NOT.getValue(); } - - public static void main(String[] args) { - /*QiyeOpenPlatSDK platSDK = InstanceSDK.getInstance(); - RParam rParam = new RParam(); - rParam.setDomain("ndc.org.cn"); - rParam.setAccount_name("cnndc.rn.dr"); - System.out.println(MailBox.unreadMsg(platSDK, rParam));*/ - - } } diff --git a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysServerServiceImpl.java b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysServerServiceImpl.java index 66a0f351..8d1ad61b 100644 --- a/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysServerServiceImpl.java +++ b/jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysServerServiceImpl.java @@ -10,6 +10,7 @@ import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.api.QueryRequest; import org.jeecg.common.api.vo.Result; @@ -41,6 +42,7 @@ import java.util.*; import java.util.stream.Collectors; @Service("sysServerService") +@Slf4j public class SysServerServiceImpl extends ServiceImpl implements ISysServerService { @Autowired @@ -50,10 +52,7 @@ public class SysServerServiceImpl extends ServiceImpl findPage(QueryRequest query) { Integer pageNo = query.getPageNo(); Integer pageSize = query.getPageSize(); - Integer pageStart = (pageNo - 1) * pageSize; Map params = new HashMap<>(); - params.put("pageSize",pageSize); - params.put("pageStart",pageStart); DateTimeFormatter formatter = DateTimeFormatter .ofPattern(DateConstant.DATE); String date = LocalDate.now().format(formatter); @@ -61,10 +60,17 @@ public class SysServerServiceImpl extends ServiceImpl serverDtos = baseMapper.findPage(params); + Page page = new Page<>(pageNo, pageSize); + page = baseMapper.findPage(page, params); + List serverDtos = page.getRecords(); // 获取所有在线服务器信息 - List hosts = monitorAlarm.listOnApp(MonitorConstant.STATUS_ON, - MonitorConstant.SERVER_APP).getResult().getRecords(); + List hosts = new ArrayList<>(); + try { + hosts = monitorAlarm.listOnApp(MonitorConstant.STATUS_ON, + MonitorConstant.SERVER_APP).getResult().getRecords(); + }catch (Exception e){ + log.error("向运管系统查询Server监控项信息异常: {}", e.getMessage()); + } for (ServerDto serverDto : serverDtos) { int alarms = serverDto.getAlarms(); String hostIdS = serverDto.getHostId(); @@ -85,44 +91,27 @@ public class SysServerServiceImpl extends ServiceImpl noPage = baseMapper.findPage(params); - int alarms = noPage.stream().mapToInt(ServerDto::getAlarms).sum(); - // 获取记录总条数 - long total = noPage.size(); - Page page = new Page<>(pageNo, pageSize, total); + // int alarms = noPage.stream().mapToInt(ServerDto::getAlarms).sum(); page.setRecords(serverDtos); return Result.OK(page); } @Override public Result findInfo(String id) { - Result result = new Result(); - if (StringUtils.isBlank(id)){ - result.error500("id信息不能为空"); - } - //查询对应数据详情内容 - LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(SysServer::getId, id); - SysServer sysServer = this.baseMapper.selectOne(queryWrapper); - if (Objects.isNull(sysServer)){ - result.error500("查询数据不存在"); - return result; - } - result.setSuccess(true); - result.setResult(sysServer); - return result; + SysServer sysServer = getById(id); + if (ObjectUtil.isNull(sysServer)) + return Result.error(Prompt.DATA_NOT_EXITS); + return Result.OK(sysServer); } @Override @Transactional - public Result create(SysServer sysServer) { + public Result create(SysServer sysServer) { String name = sysServer.getName(); String ipAddress = sysServer.getIpAddress(); LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); @@ -142,7 +131,7 @@ public class SysServerServiceImpl extends ServiceImpl update(SysServer sysServer) { SysServer server = getById(sysServer.getId()); if (ObjectUtil.isNull(server)) return Result.error(Prompt.DATA_NOT_EXITS); @@ -168,15 +157,15 @@ public class SysServerServiceImpl extends ServiceImpl deleteById(String id) { + boolean success = removeById(id); + if(success) return Result.OK(Prompt.DELETE_SUCC); return Result.error(Prompt.DELETE_ERR); } @Override - public Result findAlarmHistory(SourceVo sourceVo) { + public Result findAlarmHistory(SourceVo sourceVo) { String startDate = sourceVo.getStartDate(); String endDate = sourceVo.getEndDate(); if (StrUtil.isNotBlank(startDate)) @@ -185,16 +174,9 @@ public class SysServerServiceImpl extends ServiceImpl params = BeanUtil.beanToMap(sourceVo); - List alarmHistories = baseMapper.findAlarmHistory(params); - // 获取数据总条数(经过查询条件过滤后的) - params.put("pageFlag","noPage"); - Integer total = baseMapper.findAlarmHistory(params).size(); - Page page = new Page<>(pageNo,pageSize,total); - // 当前页数据 - page.setRecords(alarmHistories); + Page page = new Page<>(pageNo, pageSize); + page = baseMapper.findAlarmHistory(page, params); return Result.OK(page); } @@ -218,12 +200,8 @@ public class SysServerServiceImpl extends ServiceImpl pageAll(QueryRequest query) { Integer pageNo = query.getPageNo(); Integer pageSize = query.getPageSize(); - List sourceDtos = baseMapper.pageAll(MonitorConstant.ITEM_CPUUSED); - - int total = sourceDtos.size(); - Page page = new Page<>(pageNo, pageSize, total); - List records = PageUtil.page(pageNo, pageSize, sourceDtos); - page.setRecords(records); + Page page = new Page<>(pageNo, pageSize); + page = baseMapper.pageAll(page, MonitorConstant.ITEM_CPUUSED); return page; } @@ -231,9 +209,8 @@ public class SysServerServiceImpl extends ServiceImpl wrapper = new LambdaQueryWrapper<>(); wrapper.eq(SysServer::getName,name); - String id = Optional.ofNullable(getOne(wrapper, false)) + return Optional.ofNullable(getOne(wrapper, false)) .orElse(new SysServer()).getId(); - return id; } @Override @@ -297,11 +274,8 @@ public class SysServerServiceImpl extends ServiceImpl details_AlarmInfo(String sourceId, Integer pageNo, Integer pageSize) { - List alarmInfos = baseMapper.alarmInfo(sourceId); - int total = alarmInfos.size(); - Page page = new Page<>(pageNo, pageSize, total); - List records = PageUtil.page(pageNo, pageSize, alarmInfos); - page.setRecords(records); + Page page = new Page<>(pageNo, pageSize); + page = baseMapper.alarmInfo(page, sourceId); return Result.OK(page); } }