package com.project.report.service.impl;
|
|
import com.project.common.core.domain.entity.SysDept;
|
import com.project.common.core.domain.entity.SysDictData;
|
import com.project.common.core.domain.entity.SysUser;
|
import com.project.common.vo.KeyVal;
|
import com.project.enforce.domain.EnforceOrder;
|
import com.project.enforce.service.IEnforceComplaintLogService;
|
import com.project.enforce.service.IEnforceOrderService;
|
import com.project.report.domain.bo.query.ReportQueryBo;
|
import com.project.report.mapper.ReportMapper;
|
import com.project.report.service.IReportService;
|
import com.project.system.domain.SysCompany;
|
import com.project.system.domain.SysDoc;
|
import com.project.system.service.*;
|
import lombok.RequiredArgsConstructor;
|
import org.jetbrains.annotations.NotNull;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
/**
|
* 功能描述：
|
*
|
* @author ZQN
|
* @version 1.0
|
*/
|
|
@Service
|
@RequiredArgsConstructor
|
public class ReportServiceImpl implements IReportService
|
{
|
private final ISysCompanyService companyService;
|
private final ISysDeptService deptService;
|
private final ISysUserService userService;
|
private final ISysDocService docService;
|
private final ISysDictDataService dictDataService;
|
private final IEnforceOrderService orderService;
|
private final IEnforceComplaintLogService complaintLogService;
|
private final ReportMapper reportMapper;
|
|
|
private final String[] months = {"1","2","3","4","5","6","7","8","9","10","11","12"};
|
private final String[] complaintStatus = {"-1","0","1","2"};
|
|
@Override//汇总
|
public Map<String, Object> getTotalInfo()
|
{
|
int companyNum = companyService.count(companyService.lq()
|
.eq(SysCompany::getCompanyStatus, 0)
|
.eq(SysCompany::getCheckStatus, 2)
|
);
|
int enforceCompanyNum = orderService.getDistinctCompanyNum();
|
int enforceDeptNum = deptService.count(deptService.lq().eq(SysDept::getParentId,100));
|
int enforceUserNum = userService.count(userService.lq()
|
.ne(SysUser::getUserType,"02")
|
.ne(SysUser::getUserName,"admin")
|
.eq(SysUser::getStatus,"0")
|
);
|
int enforceOrderNum = orderService.count();
|
int enforceOrderCheckedNum = orderService.count(orderService.lq().ge(EnforceOrder::getCheckStatus,2));
|
int enforceOrderCompleteNum = orderService.count(orderService.lq().eq(EnforceOrder::getOrderStatus,4));
|
int complaintNum = complaintLogService.count();
|
int docNum = docService.count(docService.lq().eq(SysDoc::getDocStatus,0));
|
Map<String, Object> result = new HashMap<>(7);
|
result.put("companyNum", companyNum); //企业数
|
result.put("enforceCompanyNum", enforceCompanyNum);//被执法企业数
|
result.put("enforceDeptNum", enforceDeptNum);//执法单位
|
result.put("enforceUserNum", enforceUserNum);//执法人员
|
result.put("enforceOrderNum", enforceOrderNum);//执法单总数
|
result.put("enforceOrderCheckedNum", enforceOrderCheckedNum);//已审批执法单数
|
result.put("enforceOrderCompleteNum", enforceOrderCompleteNum);//执法单完成数
|
result.put("complaintNum", complaintNum);//投诉数
|
result.put("docNum", docNum);//政策数
|
return result;
|
}
|
|
@Override//执法单位执法次数月度分布
|
public List<KeyVal> getMonthCount(ReportQueryBo bo)
|
{
|
List<KeyVal> list = reportMapper.getMonthCount(bo);
|
return getKeyVal(list, months);
|
}
|
|
@Override//执法单位执法次数部门分布
|
public List<KeyVal> getDeptCount(ReportQueryBo bo)
|
{
|
List<KeyVal> list = reportMapper.getDeptCount(bo);
|
Map<String, Object> resultMap = list.stream().collect(Collectors.toMap(KeyVal::getK,KeyVal::getV));
|
List<SysDept> deptList = deptService.list(deptService.lq().eq(SysDept::getParentId, 100));
|
return deptList.stream().map(e -> {
|
KeyVal keyVal;
|
if (resultMap.get(e.getDeptId().toString()) == null) {
|
keyVal = new KeyVal(e.getDeptName(), 0);
|
} else {
|
keyVal = new KeyVal(e.getDeptName(), resultMap.get(e.getDeptId().toString()));
|
}
|
return keyVal;
|
}).collect(Collectors.toList());
|
}
|
|
@Override//企业被执法次数分布
|
public List<KeyVal> getCompanyCount(ReportQueryBo bo)
|
{
|
return reportMapper.getCompanyCount(bo);
|
}
|
|
@Override//执法类型
|
public List<KeyVal> getEnforceTypeCount(ReportQueryBo bo)
|
{
|
List<KeyVal> list = reportMapper.getEnforceTypeCount(bo);
|
Map<String, Object> resultMap = list.stream().collect(Collectors.toMap(KeyVal::getK, KeyVal::getV));
|
List<SysDictData> dictDataList = dictDataService.list(dictDataService.lq().eq(SysDictData::getDictType,"enforce_type"));
|
return getKeyVal(resultMap, dictDataList);
|
}
|
|
|
@Override//投诉处理状态
|
public List<KeyVal> getComplaintStatusCount(ReportQueryBo bo)
|
{
|
List<KeyVal> list = reportMapper.getComplaintStatusCount(bo);
|
return getKeyVal(list, complaintStatus);
|
}
|
|
|
@Override//投诉类型
|
public List<KeyVal> getComplaintTypeCount(ReportQueryBo bo)
|
{
|
List<KeyVal> list = reportMapper.getComplaintTypeCount(bo);
|
Map<String, Object> resultMap = list.stream().collect(Collectors.toMap(KeyVal::getK, KeyVal::getV));
|
List<SysDictData> dictDataList = dictDataService.list(dictDataService.lq().eq(SysDictData::getDictType,"complaint_type"));
|
return getKeyVal(resultMap, dictDataList);
|
}
|
|
|
//-----------------------------------------------------------------------------
|
|
/**
|
* 通过数组获取返回数据
|
* @param list 结果
|
* @param array 数组
|
* @return 结果
|
*/
|
@NotNull
|
private List<KeyVal> getKeyVal(List<KeyVal> list, String[] array)
|
{
|
Map<String, Object> resultMap = list.stream().collect(Collectors.toMap(KeyVal::getK,KeyVal::getV));
|
return Arrays.stream(array).map(e -> {
|
KeyVal keyVal;
|
if (resultMap.get(e) == null) {
|
keyVal = new KeyVal(e, 0);
|
} else {
|
keyVal = new KeyVal(e, resultMap.get(e));
|
}
|
return keyVal;
|
}).collect(Collectors.toList());
|
}
|
|
/**
|
* 通过字典获取返回数据
|
* @param resultMap 结果
|
* @param dictDataList 字典
|
* @return 结果
|
*/
|
@NotNull
|
private List<KeyVal> getKeyVal(Map<String, Object> resultMap, List<SysDictData> dictDataList)
|
{
|
return dictDataList.stream().map(e -> {
|
KeyVal keyVal;
|
if (resultMap.get(e.getDictCode().toString()) == null) {
|
keyVal = new KeyVal(e.getDictLabel(), 0);
|
} else {
|
keyVal = new KeyVal(e.getDictLabel(), resultMap.get(e.getDictCode().toString()));
|
}
|
return keyVal;
|
}).collect(Collectors.toList());
|
}
|
}
|
