Skip to content

A
amos-boot-zx-biz
Commit b955c4ef authored by hezhuozhi's avatar hezhuozhi
Browse files
Options

27467 人大金仓数据库适配

parent d89e3d63
Hide whitespace changes
Inline Side-by-side
Showing with 343 additions and 331 deletions
amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/java/com/yeejoin/amos/boot/module/jxiop/api/dto/OverviewQuestionDto.java
View file @ b955c4ef
...@@ -13,8 +13,9 @@ public class OverviewQuestionDto { ...@@ -13,8 +13,9 @@ public class OverviewQuestionDto {
private String createDate; private String createDate;
@ApiModelProperty(value = "问题内容") @ApiModelProperty(value = "问题内容")
private String warningContent; private String content;
@ApiModelProperty(value = "问题内容")
private String content_;
@ApiModelProperty(value = "问题完成情况描述") @ApiModelProperty(value = "问题完成情况描述")
private String completionStatusDesc; private String completionStatusDesc;
......
amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/McbWarningServiceImpl.java
View file @ b955c4ef
...@@ -3,8 +3,6 @@ package com.yeejoin.amos.boot.module.jxiop.biz.service.impl; ...@@ -3,8 +3,6 @@ package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.yeejoin.amos.boot.module.jxiop.api.dto.OverviewQuestionDto; import com.yeejoin.amos.boot.module.jxiop.api.dto.OverviewQuestionDto;
import com.yeejoin.amos.boot.module.jxiop.api.dto.RectificationUnitClassifyTreeDto; import com.yeejoin.amos.boot.module.jxiop.api.dto.RectificationUnitClassifyTreeDto;
import com.yeejoin.amos.boot.module.jxiop.api.feign.McbWarningFeign; import com.yeejoin.amos.boot.module.jxiop.api.feign.McbWarningFeign;
...@@ -13,7 +11,6 @@ import com.yeejoin.amos.boot.module.jxiop.api.service.IPermissionService; ...@@ -13,7 +11,6 @@ import com.yeejoin.amos.boot.module.jxiop.api.service.IPermissionService;
import com.yeejoin.amos.boot.module.jxiop.biz.mcbwarningmapper.McbWarningMapper; import com.yeejoin.amos.boot.module.jxiop.biz.mcbwarningmapper.McbWarningMapper;
import com.yeejoin.amos.component.feign.model.FeignClientResult; import com.yeejoin.amos.component.feign.model.FeignClientResult;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.apache.ibatis.annotations.Param;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -26,332 +23,346 @@ import java.util.stream.Collectors; ...@@ -26,332 +23,346 @@ import java.util.stream.Collectors;
@Service @Service
public class McbWarningServiceImpl implements IMcbWarningService { public class McbWarningServiceImpl implements IMcbWarningService {
private final static org.slf4j.Logger log = LoggerFactory.getLogger(McbWarningServiceImpl.class); private final static org.slf4j.Logger log = LoggerFactory.getLogger(McbWarningServiceImpl.class);
@Autowired @Autowired
private McbWarningMapper mcbWarningMapper; private McbWarningMapper mcbWarningMapper;
@Autowired @Autowired
private IPermissionService permissionService; private IPermissionService permissionService;
@Autowired @Autowired
private McbWarningFeign mcbWarningFeign; private McbWarningFeign mcbWarningFeign;
/** /**
* 今日预警-预警总数 * 今日预警-预警总数
* *
* @param processingStatus 处理状态 * @param processingStatus 处理状态
* @return 总数信息 * @return 总数信息
*/ */
@Override @Override
public Map<String, Object> queryTodayCount(Integer processingStatus) { public Map<String, Object> queryTodayCount(Integer processingStatus) {
List<String> projectOrgCodes = this.getProjectOrgCodes(); List<String> projectOrgCodes = this.getProjectOrgCodes();
if (projectOrgCodes.isEmpty()) { if (projectOrgCodes.isEmpty()) {
projectOrgCodes.add("NULL"); projectOrgCodes.add("NULL");
} }
return mcbWarningMapper.queryTodayCount(projectOrgCodes, processingStatus); return mcbWarningMapper.queryTodayCount(projectOrgCodes, processingStatus);
} }
/** /**
* 近七日预警统计 * 近七日预警统计
* *
* @return 预警统计 * @return 预警统计
*/ */
@Override @Override
public List<Map<String, Object>> queryWeekCount() { public List<Map<String, Object>> queryWeekCount() {
List<String> projectOrgCodes = this.getProjectOrgCodes(); List<String> projectOrgCodes = this.getProjectOrgCodes();
if (projectOrgCodes.isEmpty()) { if (projectOrgCodes.isEmpty()) {
projectOrgCodes.add("NULL"); projectOrgCodes.add("NULL");
} }
return mcbWarningMapper.queryWeekCount(projectOrgCodes); return mcbWarningMapper.queryWeekCount(projectOrgCodes);
} }
/** /**
* 预警信息列表 * 预警信息列表
* *
* @param page 分页 * @param page 分页
* @param processingStatus 处理状态 * @param processingStatus 处理状态
* @return 预警信息列表 * @return 预警信息列表
*/ */
@Override @Override
public Page<Map<String, Object>> queryWarningPage(Page<Map<String, Object>> page, Integer processingStatus, public Page<Map<String, Object>> queryWarningPage(Page<Map<String, Object>> page, Integer processingStatus,
String eventLevel, String createDate,String startTime,String endTime, String warningSourceType,String objectName, String overView) { String eventLevel, String createDate, String startTime, String endTime, String warningSourceType, String objectName, String overView) {
List<String> projectOrgCodes = this.getProjectOrgCodes(); List<String> projectOrgCodes = this.getProjectOrgCodes();
long start = (page.getCurrent() - 1) * page.getSize(); long start = (page.getCurrent() - 1) * page.getSize();
long size = page.getSize(); long size = page.getSize();
if (projectOrgCodes.isEmpty()) { if (projectOrgCodes.isEmpty()) {
projectOrgCodes.add("NULL"); projectOrgCodes.add("NULL");
} }
List<Map<String, Object>> records = mcbWarningMapper.queryWarningList(start, size, projectOrgCodes, List<Map<String, Object>> records = mcbWarningMapper.queryWarningList(start, size, projectOrgCodes,
processingStatus, eventLevel, createDate,startTime,endTime, warningSourceType,objectName, overView); processingStatus, eventLevel, createDate, startTime, endTime, warningSourceType, objectName, overView);
Long total = mcbWarningMapper.queryWarningCount(projectOrgCodes, processingStatus, eventLevel, createDate,startTime,endTime, if (CollectionUtil.isNotEmpty(records)) {
warningSourceType,objectName, overView); for (Map<String, Object> record : records) {
page.setRecords(records); record.put("CONTENT", record.get("CONTENT_"));
page.setTotal(total); }
return page; }
} Long total = mcbWarningMapper.queryWarningCount(projectOrgCodes, processingStatus, eventLevel, createDate, startTime, endTime,
warningSourceType, objectName, overView);
@Override page.setRecords(records);
public Page<OverviewQuestionDto> overviewQuestionList(Integer current, Integer size, String startTime, String endTime) { page.setTotal(total);
List<String> projectOrgCodes = this.getProjectOrgCodes(); return page;
}
if(startTime!=null && startTime != "") { @Override
startTime+= " 00:00:00"; public Page<OverviewQuestionDto> overviewQuestionList(Integer current, Integer size, String startTime, String endTime) {
} List<String> projectOrgCodes = this.getProjectOrgCodes();
if(endTime!=null && endTime != "") {
endTime+= " 23:59:59"; if (startTime != null && startTime != "") {
} startTime += " 00:00:00";
}
List<OverviewQuestionDto> list = mcbWarningMapper.overviewQuestionList( (current -1) * size, size ,projectOrgCodes, startTime, endTime);
Integer total = mcbWarningMapper.overviewQuestionListTotal(projectOrgCodes, startTime, endTime); if (endTime != null && endTime != "") {
Page<OverviewQuestionDto> pagenew = new Page<>(); endTime += " 23:59:59";
pagenew.setCurrent(current); }
pagenew.setTotal(total);
pagenew.setSize(size); List<OverviewQuestionDto> list = mcbWarningMapper.overviewQuestionList((current - 1) * size, size, projectOrgCodes, startTime, endTime);
pagenew.setRecords(list); if (CollectionUtil.isNotEmpty(list)) {
for (OverviewQuestionDto overviewQuestionDto : list) {
return pagenew; overviewQuestionDto.setContent(overviewQuestionDto.getContent_());
} }
}
/** Integer total = mcbWarningMapper.overviewQuestionListTotal(projectOrgCodes, startTime, endTime);
* 预警信息总数 Page<OverviewQuestionDto> pagenew = new Page<>();
* pagenew.setCurrent(current);
* @param processingStatus 处理状态 pagenew.setTotal(total);
* @return 预警信息总数 pagenew.setSize(size);
*/ pagenew.setRecords(list);
@Override
public Long queryWarningCount(Integer processingStatus, String eventLevel, String createDate,String startTime,String endTime, return pagenew;
String warningSourceType,String objectName, String overView) { }
List<String> projectOrgCodes = this.getProjectOrgCodes();
if (projectOrgCodes.isEmpty()) { /**
projectOrgCodes.add("NULL"); * 预警信息总数
} *
return mcbWarningMapper.queryWarningCount(projectOrgCodes, processingStatus, eventLevel, createDate,startTime,endTime, * @param processingStatus 处理状态
warningSourceType,objectName,overView); * @return 预警信息总数
} */
@Override
/** public Long queryWarningCount(Integer processingStatus, String eventLevel, String createDate, String startTime, String endTime,
* 问题信息列表 String warningSourceType, String objectName, String overView) {
* List<String> projectOrgCodes = this.getProjectOrgCodes();
* @param page 分页 if (projectOrgCodes.isEmpty()) {
* @param completionStatus 完成状态 projectOrgCodes.add("NULL");
* @return 问题信息列表 }
*/ return mcbWarningMapper.queryWarningCount(projectOrgCodes, processingStatus, eventLevel, createDate, startTime, endTime,
@Override warningSourceType, objectName, overView);
public Page<Map<String, Object>> queryQuestionPage(Page<Map<String, Object>> page, Integer completionStatus, String startTime, String endTime) { }
List<String> projectOrgCodes = this.getProjectOrgCodes();
long start = page.getCurrent() - 1; /**
long offset = page.getSize() * page.getCurrent(); * 问题信息列表
if (projectOrgCodes.isEmpty()) { *
projectOrgCodes.add("NULL"); * @param page 分页
} * @param completionStatus 完成状态
List<Map<String, Object>> records = mcbWarningMapper.queryQuestionList(start, offset, projectOrgCodes, * @return 问题信息列表
completionStatus,startTime,endTime); */
Long total = mcbWarningMapper.queryQuestionCount(projectOrgCodes, completionStatus,startTime,endTime); @Override
page.setRecords(records); public Page<Map<String, Object>> queryQuestionPage(Page<Map<String, Object>> page, Integer completionStatus, String startTime, String endTime) {
page.setTotal(total); List<String> projectOrgCodes = this.getProjectOrgCodes();
return page; long start = page.getCurrent() - 1;
} long offset = page.getSize() * page.getCurrent();
if (projectOrgCodes.isEmpty()) {
/** projectOrgCodes.add("NULL");
* 问题信息列表 }
* List<Map<String, Object>> records = mcbWarningMapper.queryQuestionList(start, offset, projectOrgCodes,
* @param completionStatus 完成状态 completionStatus, startTime, endTime);
* @return 问题信息列表 if (CollectionUtil.isNotEmpty(records)) {
*/ for (Map<String, Object> record : records) {
@Override record.put("CONTENT", record.get("CONTENT_"));
public Long queryQuestionCount(Integer completionStatus, String startTime, String endTime) { }
List<String> projectOrgCodes = this.getProjectOrgCodes(); }
if (projectOrgCodes.isEmpty()) { Long total = mcbWarningMapper.queryQuestionCount(projectOrgCodes, completionStatus, startTime, endTime);
projectOrgCodes.add("NULL"); page.setRecords(records);
} page.setTotal(total);
return mcbWarningMapper.queryQuestionCount(projectOrgCodes, completionStatus,startTime,endTime); return page;
} }
/** /**
* 获取地图点位/路线 * 问题信息列表
* *
* @param province 省份 * @param completionStatus 完成状态
* @return 地图点位/路线 * @return 问题信息列表
*/ */
@Override @Override
public Object queryMapRoutes(String province) { public Long queryQuestionCount(Integer completionStatus, String startTime, String endTime) {
List<String> projectOrgCodes = this.getProjectOrgCodes(); List<String> projectOrgCodes = this.getProjectOrgCodes();
// TODO: 远程调用warning服务 if (projectOrgCodes.isEmpty()) {
return null; projectOrgCodes.add("NULL");
} }
return mcbWarningMapper.queryQuestionCount(projectOrgCodes, completionStatus, startTime, endTime);
/** }
* 任务详情分页列表
*/ /**
@Override * 获取地图点位/路线
public Page<Map<String, Object>> getTaskDetailPage(Map<String, Object> map) { *
map.put("projectOrgCodes", this.getProjectOrgCodes()); * @param province 省份
FeignClientResult<Page<Map<String, Object>>> page = mcbWarningFeign.getTaskDetailPage(map); * @return 地图点位/路线
return page.getResult(); */
} @Override
public Object queryMapRoutes(String province) {
/** List<String> projectOrgCodes = this.getProjectOrgCodes();
* 问题记录分页列表 // TODO: 远程调用warning服务
*/ return null;
@Override }
public Page<Map<String, Object>> getQuestionRecordPage(Map<String, Object> map) {
map.put("projectOrgCodes", this.getProjectOrgCodes()); /**
FeignClientResult<Page<Map<String, Object>>> page = mcbWarningFeign.getQuestionRecordPage(map); * 任务详情分页列表
return page.getResult(); */
} @Override
public Page<Map<String, Object>> getTaskDetailPage(Map<String, Object> map) {
public List<RectificationUnitClassifyTreeDto> treeToList(List<RectificationUnitClassifyTreeDto> source, map.put("projectOrgCodes", this.getProjectOrgCodes());
List<RectificationUnitClassifyTreeDto> object) { FeignClientResult<Page<Map<String, Object>>> page = mcbWarningFeign.getTaskDetailPage(map);
source.stream().forEach(v -> { return page.getResult();
RectificationUnitClassifyTreeDto t = new RectificationUnitClassifyTreeDto(); }
BeanUtils.copyProperties(v, t);
t.setChildren(new ArrayList()); /**
object.add(t); * 问题记录分页列表
// 判断该对象的getChildren()是否为空 */
if (!CollectionUtils.isEmpty(v.getChildren())) { @Override
treeToList(v.getChildren(), object); public Page<Map<String, Object>> getQuestionRecordPage(Map<String, Object> map) {
} map.put("projectOrgCodes", this.getProjectOrgCodes());
}); FeignClientResult<Page<Map<String, Object>>> page = mcbWarningFeign.getQuestionRecordPage(map);
return object; return page.getResult();
} }
/** public List<RectificationUnitClassifyTreeDto> treeToList(List<RectificationUnitClassifyTreeDto> source,
* 任务详情、问题记录左侧树 List<RectificationUnitClassifyTreeDto> object) {
* source.stream().forEach(v -> {
*/ RectificationUnitClassifyTreeDto t = new RectificationUnitClassifyTreeDto();
@Override BeanUtils.copyProperties(v, t);
public Object getWarnTree() { t.setChildren(new ArrayList());
FeignClientResult<List<RectificationUnitClassifyTreeDto>> allUnitList = mcbWarningFeign.getWarnTree(); object.add(t);
List<RectificationUnitClassifyTreeDto> res = allUnitList.getResult(); // 判断该对象的getChildren()是否为空
if (CollectionUtils.isEmpty(res)) { if (!CollectionUtils.isEmpty(v.getChildren())) {
return new ArrayList<>(); treeToList(v.getChildren(), object);
} }
List<RectificationUnitClassifyTreeDto> targetList = new ArrayList<>(); });
List<RectificationUnitClassifyTreeDto> tempList = treeToList(res, targetList); return object;
List<String> codes = permissionService.getCurrentUserAmosOrgCodes(); }
targetList = tempList.stream().filter(x -> {
if (CollectionUtil.isNotEmpty(codes)) { /**
for (String str : codes) { * 任务详情、问题记录左侧树
if (x.getCode().startsWith(str)) { *
return true; */
} @Override
} public Object getWarnTree() {
} FeignClientResult<List<RectificationUnitClassifyTreeDto>> allUnitList = mcbWarningFeign.getWarnTree();
return false; List<RectificationUnitClassifyTreeDto> res = allUnitList.getResult();
}).collect(Collectors.toList()); if (CollectionUtils.isEmpty(res)) {
List<RectificationUnitClassifyTreeDto> listDate = new ArrayList<>(); return new ArrayList<>();
if (!targetList.isEmpty()) { }
for (RectificationUnitClassifyTreeDto t : targetList) { List<RectificationUnitClassifyTreeDto> targetList = new ArrayList<>();
if (StringUtils.isBlank(t.getParentId()) || "0".equals(t.getParentId()) List<RectificationUnitClassifyTreeDto> tempList = treeToList(res, targetList);
|| codes.get(0).equals(t.getCode())) { List<String> codes = permissionService.getCurrentUserAmosOrgCodes();
t.setChildren(getChild(t, targetList)); targetList = tempList.stream().filter(x -> {
listDate.add(t); if (CollectionUtil.isNotEmpty(codes)) {
break; for (String str : codes) {
} if (x.getCode().startsWith(str)) {
} return true;
} }
return listDate; }
} }
return false;
private List<RectificationUnitClassifyTreeDto> getChild(RectificationUnitClassifyTreeDto dto, }).collect(Collectors.toList());
List<RectificationUnitClassifyTreeDto> listDto) { List<RectificationUnitClassifyTreeDto> listDate = new ArrayList<>();
return (List<RectificationUnitClassifyTreeDto>) listDto.stream() if (!targetList.isEmpty()) {
.filter(t -> t.getParentId().equals(dto.getSequenceNbr().toString())) for (RectificationUnitClassifyTreeDto t : targetList) {
.peek(m -> m.setChildren(getChild(m, listDto))).collect(Collectors.toList()); if (StringUtils.isBlank(t.getParentId()) || "0".equals(t.getParentId())
} || codes.get(0).equals(t.getCode())) {
t.setChildren(getChild(t, targetList));
/** listDate.add(t);
* 任务详情列表统计 break;
* }
*/ }
@Override }
public Object getTaskDetailStatistic(Map<String, Object> map) { return listDate;
List<String> projectOrgCodes = this.getProjectOrgCodes(); }
map.put("projectOrgCodes", projectOrgCodes);
FeignClientResult result = mcbWarningFeign.getTaskDetailStatistic(map); private List<RectificationUnitClassifyTreeDto> getChild(RectificationUnitClassifyTreeDto dto,
return result.getResult(); List<RectificationUnitClassifyTreeDto> listDto) {
} return (List<RectificationUnitClassifyTreeDto>) listDto.stream()
.filter(t -> t.getParentId().equals(dto.getSequenceNbr().toString()))
/** .peek(m -> m.setChildren(getChild(m, listDto))).collect(Collectors.toList());
* 问题记录列表统计 }
*
*/ /**
@Override * 任务详情列表统计
public Object getQuestionRecordStatistic(Map<String, Object> map) { *
List<String> projectOrgCodes = this.getProjectOrgCodes(); */
map.put("projectOrgCodes", this.getProjectOrgCodes()); @Override
FeignClientResult result = mcbWarningFeign.getQuestionRecordStatistic(map); public Object getTaskDetailStatistic(Map<String, Object> map) {
return result.getResult(); List<String> projectOrgCodes = this.getProjectOrgCodes();
} map.put("projectOrgCodes", projectOrgCodes);
FeignClientResult result = mcbWarningFeign.getTaskDetailStatistic(map);
/** return result.getResult();
* 问题记录列表统计 }
*
*/ /**
@Override * 问题记录列表统计
public Object getMapRouteInfoByCodes(String province) { *
List<String> projectOrgCodes = permissionService.getCurrentUserAmosOrgCodes(); */
if (projectOrgCodes.isEmpty()) { @Override
projectOrgCodes.add("NULL"); public Object getQuestionRecordStatistic(Map<String, Object> map) {
} List<String> projectOrgCodes = this.getProjectOrgCodes();
FeignClientResult<Object> result = mcbWarningFeign.getMapRouteInfoByCodes(province, projectOrgCodes, "like"); map.put("projectOrgCodes", this.getProjectOrgCodes());
return result.getResult(); FeignClientResult result = mcbWarningFeign.getQuestionRecordStatistic(map);
} return result.getResult();
}
@Override
public Object getLampListPageByCodes(String questionRectificationStatus, String warningSourceType, /**
String objectName, Page page) { * 问题记录列表统计
List<String> projectOrgCodes = permissionService.getCurrentUserAmosOrgCodes(); *
if (projectOrgCodes.isEmpty()) { */
projectOrgCodes.add("NULL"); @Override
} public Object getMapRouteInfoByCodes(String province) {
FeignClientResult<Object> result = mcbWarningFeign.getLampListPage(questionRectificationStatus, List<String> projectOrgCodes = permissionService.getCurrentUserAmosOrgCodes();
warningSourceType, objectName, projectOrgCodes, "like", page.getCurrent(), page.getSize()); if (projectOrgCodes.isEmpty()) {
return result.getResult(); projectOrgCodes.add("NULL");
} }
FeignClientResult<Object> result = mcbWarningFeign.getMapRouteInfoByCodes(province, projectOrgCodes, "like");
@Override return result.getResult();
public Object getLampListByCodes(String questionRectificationStatus, String warningSourceType, String objectName) { }
List<String> projectOrgCodes = permissionService.getCurrentUserAmosOrgCodes();
if (projectOrgCodes.isEmpty()) { @Override
projectOrgCodes.add("NULL"); public Object getLampListPageByCodes(String questionRectificationStatus, String warningSourceType,
} String objectName, Page page) {
FeignClientResult<Object> result = mcbWarningFeign.getLampList(questionRectificationStatus, warningSourceType, List<String> projectOrgCodes = permissionService.getCurrentUserAmosOrgCodes();
objectName, projectOrgCodes, "like"); if (projectOrgCodes.isEmpty()) {
return result.getResult(); projectOrgCodes.add("NULL");
} }
FeignClientResult<Object> result = mcbWarningFeign.getLampListPage(questionRectificationStatus,
/** warningSourceType, objectName, projectOrgCodes, "like", page.getCurrent(), page.getSize());
* 获取用户权限(此处使用projectOrgCode) return result.getResult();
* }
* @return gatewayIds
*/ @Override
private List<String> getProjectOrgCodes() { public Object getLampListByCodes(String questionRectificationStatus, String warningSourceType, String objectName) {
List<String> projectOrgCodes = permissionService.getCurrentUserProjectOrgCodes(); List<String> projectOrgCodes = permissionService.getCurrentUserAmosOrgCodes();
if (Objects.isNull(projectOrgCodes)) { if (projectOrgCodes.isEmpty()) {
projectOrgCodes = new ArrayList<>(); projectOrgCodes.add("NULL");
} }
log.info(JSON.toJSONString("当前用户转换获取的orgcode列表是 " + projectOrgCodes)); FeignClientResult<Object> result = mcbWarningFeign.getLampList(questionRectificationStatus, warningSourceType,
return projectOrgCodes; objectName, projectOrgCodes, "like");
} return result.getResult();
}
public List<Map<String, Object>> stationOverNum(String sourceAttribution){
return mcbWarningMapper.stationOverNum(sourceAttribution); /**
* 获取用户权限(此处使用projectOrgCode)
} *
* @return gatewayIds
*/
public Map<String,Object> stationOverTotal(String province, String sourceAttribution){ private List<String> getProjectOrgCodes() {
Map<String, Object> map = new HashMap<>(); List<String> projectOrgCodes = permissionService.getCurrentUserProjectOrgCodes();
map.put("dayNum",mcbWarningMapper.getDayTotal(province, sourceAttribution)); if (Objects.isNull(projectOrgCodes)) {
map.put("monNum",mcbWarningMapper.getMonthTotal(province, sourceAttribution)); projectOrgCodes = new ArrayList<>();
map.put("yearNum",mcbWarningMapper.getYearTotal(province, sourceAttribution)); }
return map; log.info(JSON.toJSONString("当前用户转换获取的orgcode列表是 " + projectOrgCodes));
} return projectOrgCodes;
}
public List<Map<String, Object>> stationOverNum(String sourceAttribution) {
return mcbWarningMapper.stationOverNum(sourceAttribution);
}
public Map<String, Object> stationOverTotal(String province, String sourceAttribution) {
Map<String, Object> map = new HashMap<>();
map.put("dayNum", mcbWarningMapper.getDayTotal(province, sourceAttribution));
map.put("monNum", mcbWarningMapper.getMonthTotal(province, sourceAttribution));
map.put("yearNum", mcbWarningMapper.getYearTotal(province, sourceAttribution));
return map;
}
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment