Commit 37bc3c48 authored by suhuiguang's avatar suhuiguang

1.1.大屏-气瓶-右屏接口

parent d957a4a2
...@@ -196,14 +196,14 @@ public class AQZSDPStatisticsController { ...@@ -196,14 +196,14 @@ public class AQZSDPStatisticsController {
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(value = "大屏-安全追溯-右屏-按问题类型排名top 10") @ApiOperation(value = "大屏-安全追溯-右屏-当年主体单位问题排名(Top10)")
@PostMapping(value = "/issueCompanyTop") @PostMapping(value = "/issueCompanyTop")
public ResponseModel<List<Map<String, Object>>> issueCompanyTop(@RequestBody Map<String, Object> map) { public ResponseModel<List<Map<String, Object>>> issueCompanyTop(@Validated @RequestBody DPFilterParamDto dpFilterParamDto, BindingResult bindingResult) throws Exception {
Object regionCode = map.get("cityCode"); List<FieldError> fieldErrors = bindingResult.getFieldErrors();
if (ObjectUtils.isEmpty(regionCode)) { if (!fieldErrors.isEmpty()) {
regionCode = "610000"; throw new BadRequest(fieldErrors.get(0).getDefaultMessage());
} }
List<Map<String, Object>> result = statisticsService.issueCompanyTop(regionCode.toString()); List<Map<String, Object>> result = statisticsService.issueCompanyTop(dpFilterParamDto);
return ResponseHelper.buildResponse(result); return ResponseHelper.buildResponse(result);
} }
...@@ -221,12 +221,12 @@ public class AQZSDPStatisticsController { ...@@ -221,12 +221,12 @@ public class AQZSDPStatisticsController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(value = "大屏-安全追溯-右屏-当年下级区域问题闭环率排名") @ApiOperation(value = "大屏-安全追溯-右屏-当年下级区域问题闭环率排名")
@PostMapping(value = "/issueChildrenCityCountTop") @PostMapping(value = "/issueChildrenCityCountTop")
public ResponseModel<List<Map<String, Object>>> issueChildrenCityCountTop(@RequestBody Map<String, Object> map) throws Exception { public ResponseModel<List<Map<String, Object>>> issueChildrenCityCountTop(@Validated @RequestBody DPFilterParamDto dpFilterParamDto, BindingResult bindingResult) {
Object regionCode = map.get("cityCode"); List<FieldError> fieldErrors = bindingResult.getFieldErrors();
if (ObjectUtils.isEmpty(regionCode)) { if (!fieldErrors.isEmpty()) {
regionCode = "610000"; throw new BadRequest(fieldErrors.get(0).getDefaultMessage());
} }
List<Map<String, Object>> result = statisticsService.issueChildrenCityCountTop(regionCode.toString()); List<Map<String, Object>> result = statisticsService.issueChildrenCityCountTop(dpFilterParamDto);
return ResponseHelper.buildResponse(result); return ResponseHelper.buildResponse(result);
} }
......
...@@ -655,9 +655,9 @@ public class AQZSDPStatisticsServiceImpl { ...@@ -655,9 +655,9 @@ public class AQZSDPStatisticsServiceImpl {
return resultMap; return resultMap;
} }
public List<Map<String, Object>> issueCompanyTop(String cityCode) { public List<Map<String, Object>> issueCompanyTop(DPFilterParamDto dpFilterParamDto) {
List<Map<String, Object>> resultList = new ArrayList<>(); List<Map<String, Object>> resultList = new ArrayList<>();
String orgCode = stCommonService.getAndSetOrgCode(cityCode); String orgCode = stCommonService.getAndSetOrgCode(dpFilterParamDto.getCityCode());
if(orgCode == null){ if(orgCode == null){
return new ArrayList<>(); return new ArrayList<>();
} }
...@@ -674,12 +674,12 @@ public class AQZSDPStatisticsServiceImpl { ...@@ -674,12 +674,12 @@ public class AQZSDPStatisticsServiceImpl {
return resultList; return resultList;
} }
public List<Map<String, Object>> issueChildrenCityCountTop(String cityCode) { public List<Map<String, Object>> issueChildrenCityCountTop(DPFilterParamDto dpFilterParamDto) {
String orgCode = stCommonService.getAndSetOrgCode(cityCode); String orgCode = stCommonService.getAndSetOrgCode(dpFilterParamDto.getCityCode());
if(orgCode == null){ if(orgCode == null){
return new ArrayList<>(); return new ArrayList<>();
} }
List<RegionModel> regionModels = stCommonService.setRegionIfRootParentAndNoAccessIf3Level(cityCode); List<RegionModel> regionModels = stCommonService.setRegionIfRootParentAndNoAccessIf3Level(dpFilterParamDto.getCityCode());
List<Integer> regionCodeList = regionModels.stream().map(RegionModel::getRegionCode).collect(Collectors.toList()); List<Integer> regionCodeList = regionModels.stream().map(RegionModel::getRegionCode).collect(Collectors.toList());
List<Map<String, String>> orgCodeAndCompanyCodesByCompanyCodes = statisticsMapper.getOrgCodeAndCompanyCodesByCompanyCodes(regionCodeList); List<Map<String, String>> orgCodeAndCompanyCodesByCompanyCodes = statisticsMapper.getOrgCodeAndCompanyCodesByCompanyCodes(regionCodeList);
List<String> orgCodes = orgCodeAndCompanyCodesByCompanyCodes.stream().map(m -> m.get("orgCode")).collect(Collectors.toList()); List<String> orgCodes = orgCodeAndCompanyCodesByCompanyCodes.stream().map(m -> m.get("orgCode")).collect(Collectors.toList());
...@@ -710,17 +710,14 @@ public class AQZSDPStatisticsServiceImpl { ...@@ -710,17 +710,14 @@ public class AQZSDPStatisticsServiceImpl {
allIssuedataMap.forEach((k, v) -> { allIssuedataMap.forEach((k, v) -> {
if (k.startsWith(orgCodeAndCompanyCodesMap.get(regionModel.getRegionCode() + ""))) { if (k.startsWith(orgCodeAndCompanyCodesMap.get(regionModel.getRegionCode() + ""))) {
if (null != v) { if (null != v) {
allCount.addAndGet(Integer.valueOf(v + "")); allCount.addAndGet(Integer.parseInt(v + ""));
} }
} }
}); });
}
if (StringUtils.isNotBlank(orgCodeAndCompanyCodesMap.get(regionModel.getRegionCode() + ""))) {
endIssuedataMap.forEach((k, v) -> { endIssuedataMap.forEach((k, v) -> {
if (k.startsWith(orgCodeAndCompanyCodesMap.get(regionModel.getRegionCode() + ""))) { if (k.startsWith(orgCodeAndCompanyCodesMap.get(regionModel.getRegionCode() + ""))) {
if (null != v) { if (null != v) {
endCount.addAndGet(Integer.valueOf(v + "")); endCount.addAndGet(Integer.parseInt(v + ""));
} }
} }
}); });
...@@ -732,7 +729,8 @@ public class AQZSDPStatisticsServiceImpl { ...@@ -732,7 +729,8 @@ public class AQZSDPStatisticsServiceImpl {
} }
resultList.add(map); resultList.add(map);
} }
resultList.sort(Comparator.comparing(m -> Double.valueOf(m.get("rate") + ""), Comparator.reverseOrder())); resultList.sort(Comparator.comparingDouble(m -> Double.parseDouble(m.get("rate").toString())));
Collections.reverse(resultList);
for (int i = 0; i < resultList.size(); i++) { for (int i = 0; i < resultList.size(); i++) {
resultList.get(i).put("sequenceNbr", (i + 1) + ""); resultList.get(i).put("sequenceNbr", (i + 1) + "");
} }
......
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