接口完善

master
litao 3 years ago
parent a3a93896f5
commit 343ce02b6e
  1. 1
      src/main/java/org/springblade/modules/business/controller/ReportController.java
  2. 11
      src/main/java/org/springblade/modules/business/entity/DataEntity.java
  3. 3
      src/main/java/org/springblade/modules/business/service/ILargeScreenService.java
  4. 32
      src/main/java/org/springblade/modules/business/service/impl/LargeScreenServiceImpl.java

@ -41,6 +41,7 @@ import java.util.Date;
@TenantDS @TenantDS
@RestController @RestController
@RequestMapping(CommonConstant.APPLICATION_NAME_BUSINESS + "/report") @RequestMapping(CommonConstant.APPLICATION_NAME_BUSINESS + "/report")
//@RequestMapping("/report")
@AllArgsConstructor @AllArgsConstructor
@ApiSort(1) @ApiSort(1)
@Api(value = "统计报表", tags = "统计报表接口") @Api(value = "统计报表", tags = "统计报表接口")

@ -0,0 +1,11 @@
package org.springblade.modules.business.entity;
import lombok.Data;
@Data
public class DataEntity {
private String name;
private Integer num;
}

@ -19,6 +19,7 @@ package org.springblade.modules.business.service;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springblade.modules.business.entity.Appeal; import org.springblade.modules.business.entity.Appeal;
import org.springblade.modules.business.entity.DataEntity;
import java.text.ParseException; import java.text.ParseException;
import java.util.Date; import java.util.Date;
@ -48,7 +49,7 @@ public interface ILargeScreenService {
Map<String, Object> getImmediateCountByLoc(Integer timeFrame, String startTime, String endTime) throws ParseException; Map<String, Object> getImmediateCountByLoc(Integer timeFrame, String startTime, String endTime) throws ParseException;
Map<String, Map<String, Object>> getAppealHot(); Map<String, List<DataEntity>> getAppealHot();
IPage<Appeal> getImmediateList(String streetId, IPage<Appeal> page); IPage<Appeal> getImmediateList(String streetId, IPage<Appeal> page);
} }

@ -24,6 +24,7 @@ import org.apache.commons.lang3.StringUtils;
import org.springblade.common.cache.DictBizCache; import org.springblade.common.cache.DictBizCache;
import org.springblade.modules.business.entity.Appeal; import org.springblade.modules.business.entity.Appeal;
import org.springblade.modules.business.entity.AppealVisitor; import org.springblade.modules.business.entity.AppealVisitor;
import org.springblade.modules.business.entity.DataEntity;
import org.springblade.modules.business.service.IAppealService; import org.springblade.modules.business.service.IAppealService;
import org.springblade.modules.business.service.IAppealVisitorService; import org.springblade.modules.business.service.IAppealVisitorService;
import org.springblade.modules.business.service.ILargeScreenService; import org.springblade.modules.business.service.ILargeScreenService;
@ -315,6 +316,7 @@ public class LargeScreenServiceImpl implements ILargeScreenService {
wrapper.select(Appeal::getId, Appeal::getFirstRegTime, Appeal::getDisputeName); wrapper.select(Appeal::getId, Appeal::getFirstRegTime, Appeal::getDisputeName);
wrapper.eq(Appeal::getStreetId, streetId); wrapper.eq(Appeal::getStreetId, streetId);
wrapper.eq(Appeal::getSkipGrant, 1); wrapper.eq(Appeal::getSkipGrant, 1);
wrapper.orderByDesc(Appeal::getCreateTime);
IPage<Appeal> iPage = appealService.page(page, wrapper); IPage<Appeal> iPage = appealService.page(page, wrapper);
// 给每条数据赋值来访人姓名 // 给每条数据赋值来访人姓名
@ -333,8 +335,8 @@ public class LargeScreenServiceImpl implements ILargeScreenService {
} }
@Override @Override
public Map<String, Map<String, Object>> getAppealHot() { public Map<String, List<DataEntity>> getAppealHot() {
Map<String, Map<String, Object>> map = new HashMap(); Map<String, List<DataEntity>> map = new HashMap();
// 化解成功状态数组 // 化解成功状态数组
List<Integer> state = new ArrayList<>(); List<Integer> state = new ArrayList<>();
state.add(2); state.add(2);
@ -352,23 +354,33 @@ public class LargeScreenServiceImpl implements ILargeScreenService {
Map<String, List<Appeal>> street = appeals.stream().collect(Collectors.groupingBy(Appeal::getStreet)); Map<String, List<Appeal>> street = appeals.stream().collect(Collectors.groupingBy(Appeal::getStreet));
Set<String> names = street.keySet(); Set<String> names = street.keySet();
// 街道对应的数量 // 封装到数据对象
Map<String, Object> streetMap = new HashMap<>(); List<DataEntity> strees = new ArrayList<>();
for (String name : names) { for (String name : names) {
streetMap.put(name, street.get(name).size()); DataEntity entity = new DataEntity();
entity.setName(name);
entity.setNum(street.get(name).size());
strees.add(entity);
} }
map.put("street", streetMap); // 倒序
List<DataEntity> streeList = strees.stream().sorted(Comparator.comparing(DataEntity::getNum).reversed()).collect(Collectors.toList());
map.put("street", streeList);
// 根据部门分组 // 根据部门分组
Map<String, List<Appeal>> town = appeals.stream().collect(Collectors.groupingBy(Appeal::getName)); Map<String, List<Appeal>> town = appeals.stream().collect(Collectors.groupingBy(Appeal::getName));
Set<String> depts = town.keySet(); Set<String> depts = town.keySet();
// 部门对应的数量 // 封装到数据对象
Map<String, Object> townMap = new HashMap<>(); List<DataEntity> towns = new ArrayList<>();
for (String name : depts) { for (String name : depts) {
townMap.put(name, town.get(name).size()); DataEntity entity = new DataEntity();
entity.setName(name);
entity.setNum(town.get(name).size());
towns.add(entity);
} }
map.put("town", townMap); // 倒序
List<DataEntity> townList = towns.stream().sorted(Comparator.comparing(DataEntity::getNum).reversed()).collect(Collectors.toList());
map.put("town", townList);
return map; return map;
} }

Loading…
Cancel
Save