jiangzongtao
/
zhzf
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增首页、在线巡查、执法处罚统计、法治审核等接口

This commit is contained in:
renhao02 2025-03-07 17:33:36 +08:00
parent 133ef6a2de
commit 809aaae720
7 changed files with 1226 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server/src/main/java/com/aisino/iles/lawenforcement/service/ExampleService.java Normal file
View File

@ -0,0 +1,19 @@
package com.aisino.iles.lawenforcement.service;
import com.aisino.iles.lawenforcement.model.Example;
import com.aisino.iles.lawenforcement.repository.ExampleRepository;
import org.springframework.stereotype.Service;
@Service
public class ExampleService {
private final ExampleRepository exampleRepository;
public ExampleService(ExampleRepository exampleRepository) {
this.exampleRepository = exampleRepository;
}
public Example getExample() {
return exampleRepository.findAll().stream().findFirst().orElseGet(Example::new);
}
}

172
server/src/main/java/com/aisino/iles/lawenforcement/service/HikVisionService.java Normal file
View File

@ -0,0 +1,172 @@
package com.aisino.iles.lawenforcement.service;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.aisino.iles.lawenforcement.model.query.HikVisionQuery;
import com.hikvision.artemis.sdk.ArtemisHttpUtil;
import com.hikvision.artemis.sdk.config.ArtemisConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
@Slf4j
@Service
public class HikVisionService {
private void initHikInterfaceInfo() {
ArtemisConfig.host = "10.22.245.160:10443";
ArtemisConfig.appKey = "20976813";
ArtemisConfig.appSecret = "KCCXzxhyTFCelIg4SRIz";
}
public String getRegionsRoot(String treeCode) {
// 设置平台参数
initHikInterfaceInfo();
// 设置调用接口地址
Map<String, String> path = new HashMap<String, String>(2) {
{
put("https://", "/artemis/api/resource/v1/regions/root");
}
};
// 组装请求参数
JSONObject jsonBody = JSONUtil.createObj().putOpt("treeCode", treeCode);
String body = JSONUtil.toJsonStr(jsonBody);
// 设置参数提交方式
String contentType = "application/json";
// 调用接口
String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, contentType, null);
log.debug("获取根区域信息：{}", result);
return result;
}
public String getSubRegions(String parentIndexCode, String treeCode) {
// 设置平台参数
initHikInterfaceInfo();
// 设置调用接口地址
Map<String, String> path = new HashMap<String, String>(2) {
{
put("https://", "/artemis/api/resource/v1/regions/subRegions");
}
};
// 组装请求参数
JSONObject jsonBody = JSONUtil.createObj()
.putOpt("parentIndexCode", parentIndexCode)
.putOpt("treeCode", treeCode);
String body = JSONUtil.toJsonStr(jsonBody);
// 设置参数提交方式
String contentType = "application/json";
// 调用接口
String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, contentType, null);
log.debug("下一级区域信息：{}", result);
return result;
}
public String getRegionsCameras(HikVisionQuery hikVisionQuery) {
// 设置平台参数
initHikInterfaceInfo();
// 设置调用接口地址
Map<String, String> path = new HashMap<String, String>(2) {
{
put("https://", "/artemis/api/resource/v1/regions/regionIndexCode/cameras");
}
};
// 组装请求参数
JSONObject jsonBody = JSONUtil.createObj()
.putOpt("pageNo", hikVisionQuery.getPageNo())
.putOpt("pageSize", hikVisionQuery.getPageSize())
.putOpt("regionIndexCode", hikVisionQuery.getRegionIndexCode())
.putOpt("treeCode", hikVisionQuery.getTreeCode());
String body = JSONUtil.toJsonStr(jsonBody);
// 设置参数提交方式
String contentType = "application/json";
// 调用接口
String result;
result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, contentType, null);
log.debug("区域摄像头信息：{}", result);
return result;
}
public String getRegionsCamerasDetail(String cameraIndexCode) {
// 设置平台参数
initHikInterfaceInfo();
// 设置调用接口地址
Map<String, String> path = new HashMap<String, String>(2) {
{
put("https://", "/artemis/api/resource/v1/cameras/indexCode");
}
};
// 组装请求参数
JSONObject jsonBody = JSONUtil.createObj().putOpt("cameraIndexCode", cameraIndexCode);
String body = JSONUtil.toJsonStr(jsonBody);
// 设置参数提交方式
String contentType = "application/json";
// 调用接口
String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, contentType, null);
log.debug("摄像头详情信息：{}", result);
return result;
}
public String getCamerasPreview(HikVisionQuery hikVisionQuery) {
// 设置平台参数
initHikInterfaceInfo();
// 设置调用接口地址
Map<String, String> path = new HashMap<String, String>(2) {
{
put("https://", "/artemis/api/video/v1/cameras/previewURLs");
}
};
// 组装请求参数
JSONObject jsonBody = JSONUtil.createObj()
.putOpt("cameraIndexCode", hikVisionQuery.getCameraIndexCode())
.putOpt("streamType", hikVisionQuery.getStreamType())
.putOpt("protocol", hikVisionQuery.getProtocol())
.putOpt("transmode", hikVisionQuery.getTransMode());
String body = JSONUtil.toJsonStr(jsonBody);
// 设置参数提交方式
String contentType = "application/json";
log.debug("摄像头播放流请求参数：{}", jsonBody);
// 调用接口
String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, contentType, null);
log.debug("摄像头预览流信息：{}", result);
return result;
}
public String getCamerasPlayback(HikVisionQuery hikVisionQuery) {
// 设置平台参数
initHikInterfaceInfo();
// 设置调用接口地址
Map<String, String> path = new HashMap<String, String>(2) {
{
put("https://", "/artemis/api/video/v1/cameras/playbackURLs");
}
};
// 组装请求参数
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSXXX");
LocalDateTime s = hikVisionQuery.getFallBackTime()[0];
LocalDateTime e = hikVisionQuery.getFallBackTime()[1];
String beginTime = simpleDateFormat.format(Date.from(s.atZone(ZoneId.systemDefault()).toInstant()));
String endTime = simpleDateFormat.format(Date.from(e.atZone(ZoneId.systemDefault()).toInstant()));
JSONObject jsonBody = JSONUtil.createObj()
.putOpt("cameraIndexCode", hikVisionQuery.getCameraIndexCode())
.putOpt("protocol", hikVisionQuery.getProtocol())
.putOpt("transmode", hikVisionQuery.getTransMode())
.putOpt("beginTime", beginTime)
.putOpt("endTime", endTime);
String body = JSONUtil.toJsonStr(jsonBody);
// 设置参数提交方式
String contentType = "application/json";
log.debug("摄像头回放流请求参数：{}", jsonBody);
// 调用接口
String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, contentType, null);
log.debug("摄像头回放流信息：{}", result);
return result;
}
}

446
server/src/main/java/com/aisino/iles/lawenforcement/service/HomePageService.java Normal file
View File

@ -0,0 +1,446 @@
package com.aisino.iles.lawenforcement.service;
import com.aisino.iles.common.util.PageableHelper;
import com.aisino.iles.common.util.StringUtils;
import com.aisino.iles.lawenforcement.model.*;
import com.aisino.iles.lawenforcement.model.dto.*;
import com.aisino.iles.lawenforcement.model.enums.FlowNode;
import com.aisino.iles.lawenforcement.model.query.CaseQuery;
import com.aisino.iles.lawenforcement.model.query.DocumentQuery;
import com.aisino.iles.lawenforcement.model.query.EnforceCheckQuery;
import com.aisino.iles.lawenforcement.repository.*;
import com.smartlx.sso.client.model.RemoteUserInfo;
import jakarta.persistence.criteria.CriteriaBuilder;
import jakarta.persistence.criteria.Join;
import jakarta.persistence.criteria.JoinType;
import jakarta.persistence.criteria.Predicate;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.Page;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;
import java.time.temporal.TemporalAdjusters;
import java.util.*;
import java.util.stream.Collectors;
@Service
@Slf4j
public class HomePageService {
private final EnforcementInfoRepository enforcementInfoRepository;
private final EnforceCheckRepository enforceCheckRepo;
private final DocumentRepository documentRepository;
private final HomePageRepository homePageRepository;
private final AgencyRepository agencyRepo;
private final CaseRepository caseRepository;
public HomePageService(DocumentRepository documentRepository,
EnforcementInfoRepository enforcementInfoRepository,
EnforceCheckRepository enforceCheckRepo,
HomePageRepository homePageRepository,
AgencyRepository agencyRepo,
CaseRepository caseRepository) {
this.enforcementInfoRepository = enforcementInfoRepository;
this.documentRepository = documentRepository;
this.enforceCheckRepo = enforceCheckRepo;
this.homePageRepository = homePageRepository;
this.agencyRepo = agencyRepo;
this.caseRepository = caseRepository;
}
public Map<String, Long> getstatCount(RemoteUserInfo user) {
Long qys;
Long ajs;
Long zfxxs;
Long wss;
Long jcs;
Long cls;
Agency currentAgency = agencyRepo.findByAgencyCode(user.getGajgjgdm()).orElseThrow(() -> new RuntimeException("当前用户机构数据错误，请检查！"));
if (currentAgency.getAgencyLevel() == 3) {
qys = homePageRepository.getqysByDistrict(currentAgency.getAgencyCode());
ajs = homePageRepository.getajsByDistrict(currentAgency.getAgencyCode());
zfxxs = homePageRepository.getZfxxsByDistrict(currentAgency.getAgencyCode());
wss = homePageRepository.getWssByDistrict(currentAgency.getAgencyCode());
jcs = homePageRepository.getjcsByDistrict(currentAgency.getAgencyCode());
cls = homePageRepository.getclsByDistrict(currentAgency.getAgencyCode());
} else {
qys = homePageRepository.getqys(StringUtils.trimEven0(user.getGajgjgdm()) + "%");
ajs = homePageRepository.getajs();
zfxxs = enforcementInfoRepository.count();
wss = documentRepository.countByStatus(Document.DocumentStatus.done);
jcs = homePageRepository.getjcs();
cls = homePageRepository.getcls();
}
Map<String, Long> res = new HashMap<>();
res.put("qys", qys);
res.put("ajs", ajs);
res.put("zfxxs", zfxxs);
res.put("wss", wss);
res.put("jcs", jcs);
res.put("cls", cls);
return res;
}
public Map<String, Long> getdla(RemoteUserInfo user) {
Agency currentAgency = agencyRepo.findByAgencyCode(user.getGajgjgdm()).orElseThrow(() -> new RuntimeException("当前用户机构数据错误，请检查！"));
Long dlas;
if (currentAgency.getAgencyLevel() == 3) {
dlas = homePageRepository.getdlaByDistrict(currentAgency.getAgencyCode());
} else {
dlas = homePageRepository.getdla();
}
Map<String, Long> res = new HashMap<>();
res.put("dla", dlas);
return res;
}
public List<Map<String, Object>> countCurrentNodeCode(RemoteUserInfo user) {
Agency currentAgency = agencyRepo.findByAgencyCode(user.getGajgjgdm()).orElseThrow(() -> new RuntimeException("当前用户机构数据错误，请检查！"));
if (currentAgency.getAgencyLevel() == 3)
return homePageRepository.countCurrentNodeCodeByDistrict(currentAgency.getAgencyCode());
else
return homePageRepository.countCurrentNodeCode();
}
/**
* 提供平台大屏接口
*
* @return 当月文书数
*/
public Long getDocumentNumForPlatform() {
LocalDateTime firstDayOfMonth = LocalDate.now().with(TemporalAdjusters.firstDayOfMonth()).atTime(LocalTime.MIN);
LocalDateTime lastDayOfMonth = LocalDate.now().with(TemporalAdjusters.lastDayOfMonth()).atTime(LocalTime.MAX);
return homePageRepository.getDocumentNumForPlatform(firstDayOfMonth, lastDayOfMonth);
}
/**
* 提供平台大屏接口查询当月案卷数量
*
* @return 当月案卷数量
*/
public Long getDossiersNumForPlatform() {
LocalDateTime firstDayOfMonth = LocalDate.now().with(TemporalAdjusters.firstDayOfMonth()).atTime(LocalTime.MIN);
LocalDateTime lastDayOfMonth = LocalDate.now().with(TemporalAdjusters.lastDayOfMonth()).atTime(LocalTime.MAX);
return homePageRepository.getDossiersNumForPlatform(firstDayOfMonth, lastDayOfMonth);
}
/**
* 查询当月受理、调查、决定、执行数量
*
* @return 查询当月受理、调查、决定、执行数量
*/
public HomePageDto getCaseNodeNumForPlatform() {
LocalDateTime firstDayOfMonth = LocalDate.now().with(TemporalAdjusters.firstDayOfMonth()).atTime(LocalTime.MIN);
LocalDateTime lastDayOfMonth = LocalDate.now().with(TemporalAdjusters.lastDayOfMonth()).atTime(LocalTime.MAX);
HomePageDto dto = new HomePageDto();
dto.setSlNum(homePageRepository.getSlNum(firstDayOfMonth, lastDayOfMonth));
dto.setDcNum(homePageRepository.getdcNum(firstDayOfMonth, lastDayOfMonth));
dto.setJdNum(homePageRepository.getjdNum(firstDayOfMonth, lastDayOfMonth));
dto.setZxNum(homePageRepository.getzxNum(firstDayOfMonth, lastDayOfMonth));
return dto;
}
@Transactional(readOnly = true)
public Page<HomePageDetailDto> getDocumentForPlatformDetail(DocumentQuery query) {
LocalDateTime firstDayOfMonth = LocalDate.now().with(TemporalAdjusters.firstDayOfMonth()).atTime(LocalTime.MIN);
LocalDateTime lastDayOfMonth = LocalDate.now().with(TemporalAdjusters.lastDayOfMonth()).atTime(LocalTime.MAX);
query.setDocumentDate(new LocalDateTime[]{firstDayOfMonth, lastDayOfMonth});
return documentRepository.findAll(buildQuery(query), PageableHelper.buildPageRequest(query.page(), query.pageSize(), query.sort(), query.dir())).map(this::getDocumentInfo);
}
private Specification<Document> buildQuery(DocumentQuery query) {
return Specification.where((root, q, criteriaBuilder) -> {
List<Predicate> predicates = new ArrayList<>();
predicates.add(criteriaBuilder.equal(root.get(Document_.status), Document.DocumentStatus.done));
Optional.ofNullable(query.getDocumentDate()).filter(f -> f.length == 2).map(f -> {
List<Predicate> timePredicates = new ArrayList<>();
Optional.ofNullable(f[0]).map(from -> criteriaBuilder.greaterThanOrEqualTo(root.get(Document_.documentDate), from)).ifPresent(timePredicates::add);
Optional.ofNullable(f[1]).map(to -> criteriaBuilder.lessThanOrEqualTo(root.get(Document_.documentDate), to)).ifPresent(timePredicates::add);
return timePredicates;
}).ifPresent(predicates::addAll);
return criteriaBuilder.and(predicates.toArray(new Predicate[0]));
});
}
private HomePageDetailDto getDocumentInfo(Document c) {
HomePageDetailDto dto = new HomePageDetailDto();
dto.setCaseId(c.getCaseId());
dto.setCaseName(c.getCaseInfo().getCaseName());
dto.setCaseNum(c.getCaseInfo().getCaseNum());
dto.setCaseCause(c.getCaseInfo().getCaseCause());
dto.setDocumentCode(c.getDocumentCode());
dto.setDocumentName(c.getDocumentName());
dto.setDocumentDate(c.getDocumentDate());
return dto;
}
@Transactional(readOnly = true)
public Page<HomePageDetailDto> gettDossiersNumForPlatformDetail(CaseQuery query) {
LocalDate firstDayOfMonth = LocalDate.now().with(TemporalAdjusters.firstDayOfMonth());
LocalDate lastDayOfMonth = LocalDate.now().with(TemporalAdjusters.lastDayOfMonth());
query.setFillingDate(new LocalDate[]{firstDayOfMonth, lastDayOfMonth});
return caseRepository.findAll(buildCondiction(query), PageableHelper.buildPageRequest(query.page(), query.pageSize(), query.sort(), query.dir())).map(this::getdtoInfo);
}
private Specification<Case> buildCondiction(CaseQuery query) {
return Specification.where((root, q, criteriaBuilder) -> {
List<Predicate> predicates = new ArrayList<>();
predicates.add(criteriaBuilder.isNotNull(root.get(Case_.filePath)));
Optional.ofNullable(query.getFillingDate()).filter(f -> f.length == 2).map(f -> {
List<Predicate> timePredicates = new ArrayList<>();
Optional.ofNullable(f[0]).map(from -> criteriaBuilder.greaterThanOrEqualTo(root.get("fillingDate"), from)).ifPresent(timePredicates::add);
Optional.ofNullable(f[1]).map(to -> criteriaBuilder.lessThanOrEqualTo(root.get("fillingDate"), to)).ifPresent(timePredicates::add);
return timePredicates;
}).ifPresent(predicates::addAll);
return criteriaBuilder.and(predicates.toArray(new Predicate[0]));
});
}
private HomePageDetailDto getdtoInfo(Case c) {
HomePageDetailDto dto = new HomePageDetailDto();
dto.setCaseId(c.getCaseId());
dto.setCaseName(c.getCaseName());
dto.setCaseNum(c.getCaseNum());
dto.setCaseCause(c.getCaseCause());
dto.setFillingDate(c.getFillingDate());
dto.setCaseClosingDate(c.getCaseClosingDate());
dto.setUnitName(c.getEnforcementInfo().getEnterprise().getUnitName());
dto.setUnifiedSocialCode(c.getEnforcementInfo().getEnterprise().getUnifiedSocialCode());
return dto;
}
private Specification<Case> buildSpec(CaseQuery query) {
return Specification.where((root, q, criteriaBuilder) -> {
List<Predicate> predicates = new ArrayList<>();
Join<Case, EnforcementInfo> enforcementInfoCaseRoot = root.join("enforcementInfo", JoinType.LEFT);
predicates.add(criteriaBuilder.equal((enforcementInfoCaseRoot.get(EnforcementInfo_.fillingFlag)), "1"));
Optional.ofNullable(query.getFlowNodes()).ifPresent(o -> {
CriteriaBuilder.In<FlowNode> nods = criteriaBuilder.in(enforcementInfoCaseRoot.get(EnforcementInfo_.currentNodeCode));
for (FlowNode flowNode : o) {
nods.value(flowNode);
}
predicates.add(nods);
});
Optional.ofNullable(query.getFillingDate()).filter(f -> f.length == 2).map(f -> {
List<Predicate> timePredicates = new ArrayList<>();
Optional.ofNullable(f[0]).map(from -> criteriaBuilder.greaterThanOrEqualTo(root.get("fillingDate"), from)).ifPresent(timePredicates::add);
Optional.ofNullable(f[1]).map(to -> criteriaBuilder.lessThanOrEqualTo(root.get("fillingDate"), to)).ifPresent(timePredicates::add);
return timePredicates;
}).ifPresent(predicates::addAll);
return criteriaBuilder.and(predicates.toArray(new Predicate[0]));
});
}
@Transactional(readOnly = true)
public Page<HomePageDetailDto> getCaseNodeNumForPlatformDetail(CaseQuery query) {
String conditionlike = query.getConditionlike();
if ("sl".equals(conditionlike)) {
query.setFlowNodes(new FlowNode[]{FlowNode.filed, FlowNode.investigating, FlowNode.investigation_done, FlowNode.analyze_judge, FlowNode.reviewing_failed, FlowNode.reviewing_done, FlowNode.brainstorm, FlowNode.closed, FlowNode.done});
} else if ("dc".equals(conditionlike)) {
query.setFlowNodes(new FlowNode[]{FlowNode.investigating, FlowNode.investigation_done, FlowNode.analyze_judge, FlowNode.reviewing_failed, FlowNode.reviewing_done, FlowNode.brainstorm, FlowNode.closed, FlowNode.done});
} else if ("la".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.filed, FlowNode.investigating, FlowNode.investigation_done, FlowNode.analyze_judge, FlowNode.inform, FlowNode.hearing, FlowNode.decided, FlowNode.execute, FlowNode.closed, FlowNode.done});
else if ("dcqz".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.investigation_done, FlowNode.analyze_judge, FlowNode.inform, FlowNode.hearing, FlowNode.decided, FlowNode.execute, FlowNode.closed, FlowNode.done});
else if ("sls".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.analyze_judge, FlowNode.inform, FlowNode.hearing, FlowNode.decided, FlowNode.execute, FlowNode.closed, FlowNode.done});
else if ("gz".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.inform, FlowNode.hearing, FlowNode.decided, FlowNode.execute, FlowNode.closed, FlowNode.done});
else if ("tz".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.hearing, FlowNode.decided, FlowNode.execute, FlowNode.closed, FlowNode.done});
else if ("zx".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.decided, FlowNode.execute, FlowNode.closed, FlowNode.done});
else if ("jd".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.execute, FlowNode.closed, FlowNode.done});
else if ("ja".equals(conditionlike))
query.setFlowNodes(new FlowNode[]{FlowNode.closed, FlowNode.done});
return caseRepository.findAll(buildSpec(query), PageableHelper.buildPageRequest(query.page(), query.pageSize(), query.sort(), query.dir())).map(this::getdtoInfo);
}
/**
* 执法趋势统计
*
* @return 统计结果
*/
public Map<String, Object> zfqstj(EnforceCheckQuery query) {
Map<String, Object> result = new LinkedHashMap<>();
LocalDateTime[] times = query.getCreateTime();
if (null != times && times.length == 2) {
LocalDate now = times[1].toLocalDate();
LocalDate start = times[0].toLocalDate();
DateTimeFormatter ym = DateTimeFormatter.ofPattern("yyyy-MM");
List<String> pastMonths = new ArrayList<>();
LocalDate current = start.withDayOfMonth(1);
LocalDate end = now.with(TemporalAdjusters.lastDayOfMonth());
while (!current.isAfter(end)) {
pastMonths.add(current.format(ym));
current = current.plusMonths(1);
}
List<EnforceCheckDto> dtos = enforceCheckRepo.checkGroupByMonth(start, end);
Map<String, Long> zfjcMap = dtos.stream()
.collect(Collectors.toMap(dto -> formatMonth(dto.getDateStr()), EnforceCheckDto::getNum));
List<Long> zfjc = pastMonths.stream()
.map(month -> zfjcMap.getOrDefault(month, 0L))
.toList();
List<EnforceCheckDto> caseDtos = caseRepository.caseGroupByMonth(start, end);
Map<String, Long> zflaMap = caseDtos.stream()
.collect(Collectors.toMap(dto -> formatMonth(dto.getDateStr()), EnforceCheckDto::getNum));
List<Long> zfla = pastMonths.stream()
.map(month -> zflaMap.getOrDefault(month, 0L))
.toList();
List<String> keys = List.of("执法检查", "执法立案");
result.put("legend", keys);
result.put("xAxis", pastMonths);
result.put("执法检查", zfjc);
result.put("执法立案", zfla);
}
return result;
}
private String formatMonth(String dateStr) {
if (dateStr == null || dateStr.isEmpty())
return dateStr;
String[] parts = dateStr.split("-");
if (parts.length != 2)
return dateStr;
try {
int year = Integer.parseInt(parts[0]);
int month = Integer.parseInt(parts[1]);
return String.format("%d-%02d", year, month);
} catch (NumberFormatException e) {
return dateStr;
}
}
/**
* 行政执法案件进度一览表
*
* @return 列表
*/
public List<DocumentDto> ajjdlb(EnforceCheckQuery query) {
LocalDateTime[] times = query.getCreateTime();
LocalDate start = times[0].toLocalDate();
LocalDate end = times[1].toLocalDate().with(TemporalAdjusters.lastDayOfMonth());
List<DocumentDto> list = documentRepository.getList(start.atStartOfDay(), end.atTime(23, 59, 59));
List<String> documentOrder = Arrays.asList(
"现场检查记录",
"立案审批表",
"案件调查终结报告",
"行政执法决定法制审核意见书",
"行政处罚告知书",
"听证会报告书",
"行政处罚集体讨论记录",
"行政处罚决定书",
"结案审批表"
);
List<DocumentDto> res = new ArrayList<>();
if (!list.isEmpty()) {
Map<String, List<DocumentDto>> map = list.stream().filter(o -> documentOrder.contains(o.getDocumentName())).collect(Collectors.groupingBy(DocumentDto::getCaseId));
map.keySet().forEach(key -> {
List<DocumentDto> dtos = map.get(key);
DocumentDto dto = new DocumentDto();
List<DocumentDto.DocumentList> ls = new ArrayList<>();
for (int i = 0; i < documentOrder.size(); i++) {
String column = "";
if (0 == i) column = "检查";
else if (1 == i) column = "立案";
else if (2 == i) column = "调查终结";
else if (3 == i) column = "审理";
else if (4 == i) column = "告知";
else if (5 == i) column = "申辩与听证";
else if (6 == i) column = "执行";
else if (7 == i) column = "决定";
else column = "结案";
String k = documentOrder.get(i);
DocumentDto.DocumentList dto1 = new DocumentDto.DocumentList();
dto1.setDocumentName(k);
if (dtos.stream().noneMatch(o -> k.equals(o.getDocumentName()))) {
dto1.setStatusTxt("未开始");
dto1.setDocumentDate(null);
} else {
List<DocumentDto> dtoList = dtos.stream().filter(o -> k.equals(o.getDocumentName())).toList();
Optional<DocumentDto> dtoOptional;
if (dtoList.size() > 1)
dtoOptional = dtoList.stream().filter(o -> Document.DocumentStatus.done.equals(o.getStatus())).findFirst();
else
dtoOptional = dtoList.stream().findFirst();
dtoOptional.ifPresent(o -> {
if (null == o.getDocumentDate())
dto1.setStatusTxt("未开始");
if (StringUtils.isEmpty(dto1.getStatusTxt())) {
if (Document.DocumentStatus.afoot.equals(o.getStatus())) {
if (ls.stream().anyMatch(oo -> "未开始".equals(oo.getStatusTxt()))
|| ls.stream().anyMatch(oo -> "进行中".equals(oo.getStatusTxt())))
dto1.setStatusTxt("未开始");
else dto1.setStatusTxt("进行中");
} else if (Document.DocumentStatus.done.equals(o.getStatus())) {
if (ls.stream().anyMatch(oo -> "未开始".equals(oo.getStatusTxt()))
|| ls.stream().anyMatch(oo -> "进行中".equals(oo.getStatusTxt())))
dto1.setStatusTxt("未开始");
else dto1.setStatusTxt("已完成");
}
}
dto1.setDocumentName(o.getDocumentName());
dto1.setDocumentDate(o.getDocumentDate());
});
}
if ("未开始".equals(dto1.getStatusTxt()))
dto1.setDocumentDate(null);
dto1.setColumn(column);
ls.add(dto1);
}
dto.setCaseName(dtos.get(0).getCaseName());
dto.setCaseId(dtos.get(0).getCaseId());
ls.sort(Comparator.comparingInt(o -> {
int index = documentOrder.indexOf(o.getDocumentName());
return index == -1 ? Integer.MAX_VALUE : index;
}));
dto.setList(ls);
res.add(dto);
});
}
return res;
}
/**
* 节点案件数量
*
* @param query 查询参数
* @return 节点案件数量
*/
public NodeCaseNumDto getNodeCaseNum(CaseQuery query) {
// filed-立案
// investigation_done-完成调查取证
// analyze_judge-审理
// inform-告知
// hearing-陈述申辩或听证
// execute-执行
// decided-决定
// closed-结案
return homePageRepository.getNodeCaseNum();
}
public Map<String, Long> ajtj(EnforceCheckQuery query, RemoteUserInfo user) {
Agency currentAgency = agencyRepo.findByAgencyCode(user.getGajgjgdm()).orElseThrow(() -> new RuntimeException("当前用户机构数据错误，请检查！"));
String code = StringUtils.trimEven0(currentAgency.getAgencyCode()) + "%";
Long ajs = homePageRepository.getajsByAgencyCode(code);
Map<String, Long> res = new HashMap<>();
res.put("ajs", ajs);
return res;
}
}

38
server/src/main/java/com/aisino/iles/lawenforcement/service/InsEnterprseService.java Normal file
View File

@ -0,0 +1,38 @@
package com.aisino.iles.lawenforcement.service;
import com.aisino.iles.lawenforcement.model.Enterprise;
import com.aisino.iles.lawenforcement.model.InsEnterprse;
import com.aisino.iles.lawenforcement.model.dto.InsEnterprseDto;
import com.aisino.iles.lawenforcement.repository.InsEnterprseRepository;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
/**
* 在线巡查企业信息服务类
*/
@Service
public class InsEnterprseService {
private final InsEnterprseRepository insEnterprseRepository;
public InsEnterprseService(InsEnterprseRepository insEnterprseRepository) {
this.insEnterprseRepository = insEnterprseRepository;
}
@Transactional
public void saveEnterprise(InsEnterprseDto insEnterprseDto) {
insEnterprseDto.getEnterpriseIds().forEach(id -> {
InsEnterprse insEnterprse = new InsEnterprse();
insEnterprse.setValidStartTime(insEnterprseDto.getValidStartTime());
insEnterprse.setValidEndTime(insEnterprseDto.getValidEndTime());
insEnterprse.setCreateUserId(insEnterprseDto.getCreateUserId());
insEnterprse.setCreateUserName(insEnterprseDto.getCreateUserName());
insEnterprse.setCreateTime(insEnterprseDto.getCreateTime());
Enterprise enterprise = new Enterprise();
enterprise.setEnterpriseId(id);
insEnterprse.setEnterprise(enterprise);
insEnterprseRepository.save(insEnterprse);
});
}
}

90
server/src/main/java/com/aisino/iles/lawenforcement/service/LawEnfPenaltyStatService.java Normal file
View File

@ -0,0 +1,90 @@
package com.aisino.iles.lawenforcement.service;
import com.aisino.iles.common.util.Constants;
import com.aisino.iles.lawenforcement.model.Agency;
import com.aisino.iles.lawenforcement.model.EnforcementInfoHistory;
import com.aisino.iles.lawenforcement.model.OnlinePatrol;
import com.aisino.iles.lawenforcement.model.query.CaseQuery;
import com.aisino.iles.lawenforcement.model.query.LawEnfPenaltyStatQuery;
import com.aisino.iles.lawenforcement.repository.AgencyRepository;
import com.aisino.iles.lawenforcement.repository.LawEnfPenaltyStatRepository;
import com.aisino.iles.lawenforcement.repository.impl.StatisticCustomRepositoryImpl;
import com.smartlx.sso.client.model.RemoteUserInfo;
import org.springframework.data.domain.Page;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;
import java.util.Optional;
/**
* 执法处罚统计服务类
*/
@Service
public class LawEnfPenaltyStatService {
private final LawEnfPenaltyStatRepository lawEnfPenaltyStatRepository;
private final AgencyRepository agencyRepo;
private final StatisticCustomRepositoryImpl customRepository;
public LawEnfPenaltyStatService(LawEnfPenaltyStatRepository lawEnfPenaltyStatRepository,AgencyRepository agencyRepo,StatisticCustomRepositoryImpl customRepository) {
this.lawEnfPenaltyStatRepository = lawEnfPenaltyStatRepository;
this.agencyRepo = agencyRepo;
this.customRepository = customRepository;
}
/**
* 查询执法处罚统计列表
*
* @param lawEnfPenaltyStatQuery
* @return 执法处罚统计列表
*/
public List<Map<String, Object>> getLawEnfPenaltyStat(LawEnfPenaltyStatQuery lawEnfPenaltyStatQuery, RemoteUserInfo user) {
Agency currentAgency = agencyRepo.findByAgencyCode(user.getGajgjgdm()).orElseThrow(() -> new RuntimeException("当前用户机构数据错误，请检查！"));
LocalDateTime startTime = Optional.ofNullable(lawEnfPenaltyStatQuery.getStatisticsTime()).map(list -> list[0]).orElse(LocalDateTime.now().minusMonths(1));
LocalDateTime endTime = Optional.ofNullable(lawEnfPenaltyStatQuery.getStatisticsTime()).map(list -> list[1]).orElse(LocalDateTime.now());
if(currentAgency.getAgencyLevel()==2)
return lawEnfPenaltyStatRepository.getLawEnfPenaltyStat(startTime, endTime);
else
return lawEnfPenaltyStatRepository.getLawEnfPenaltyStatByDistrict(currentAgency.getAgencyCode(), startTime, endTime);
}
@Transactional(readOnly = true)
public Page<OnlinePatrol> getPagexccsDetail(LawEnfPenaltyStatQuery query, RemoteUserInfo user) {
LocalDateTime startTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[0]).orElse(LocalDateTime.now().minusMonths(1));
LocalDateTime endTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[1]).orElse(LocalDateTime.now());
return customRepository.fxczfXCDetail(query.page(), query.pageSize(), query.sort(), query.dir(), query.getAgencyCode(), startTime,endTime);
}
@Transactional(readOnly = true)
public Page<OnlinePatrol> getPagefxczffxwtDetail(LawEnfPenaltyStatQuery query, RemoteUserInfo user) {
LocalDateTime startTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[0]).orElse(LocalDateTime.now().minusMonths(1));
LocalDateTime endTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[1]).orElse(LocalDateTime.now());
return customRepository.fxczffxwtDetail(query.page(), query.pageSize(), query.sort(), query.dir(), query.getAgencyCode(), startTime,endTime);
}
@Transactional(readOnly = true)
public Page<OnlinePatrol> getPagefxczfjjwtDetail(LawEnfPenaltyStatQuery query, RemoteUserInfo user) {
LocalDateTime startTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[0]).orElse(LocalDateTime.now().minusMonths(1));
LocalDateTime endTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[1]).orElse(LocalDateTime.now());
return customRepository.fxczfjjwtDetail(query.page(), query.pageSize(), query.sort(), query.dir(), query.getAgencyCode(), startTime,endTime);
}
@Transactional(readOnly = true)
public Page<OnlinePatrol> getPagefxczflasDetail(LawEnfPenaltyStatQuery query, RemoteUserInfo user) {
LocalDateTime startTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[0]).orElse(LocalDateTime.now().minusMonths(1));
LocalDateTime endTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[1]).orElse(LocalDateTime.now());
return customRepository.fxczflasDetail(query.page(), query.pageSize(), query.sort(), query.dir(), query.getAgencyCode(), startTime,endTime);
}
@Transactional(readOnly = true)
public Page<OnlinePatrol> getPagefxczfcfsDetail(LawEnfPenaltyStatQuery query, RemoteUserInfo user) {
LocalDateTime startTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[0]).orElse(LocalDateTime.now().minusMonths(1));
LocalDateTime endTime = Optional.ofNullable(query.getStatisticsTime()).map(list -> list[1]).orElse(LocalDateTime.now());
return customRepository.fxczfcfsDetail(query.page(), query.pageSize(), query.sort(), query.dir(), query.getAgencyCode(), startTime,endTime);
}
}

220
server/src/main/java/com/aisino/iles/lawenforcement/service/LegalReviewService.java Normal file
View File

@ -0,0 +1,220 @@
package com.aisino.iles.lawenforcement.service;
import com.aisino.iles.common.util.PageableHelper;
import com.aisino.iles.common.util.StringUtils;
import com.aisino.iles.core.exception.BusinessError;
import com.aisino.iles.core.repository.DictItemRepo;
import com.aisino.iles.lawenforcement.event.DataChangeAction;
import com.aisino.iles.lawenforcement.event.aop.PublishDataChange;
import com.aisino.iles.lawenforcement.model.*;
import com.aisino.iles.lawenforcement.model.dto.LegalReviewDto;
import com.aisino.iles.lawenforcement.model.enums.FlowNode;
import com.aisino.iles.lawenforcement.model.query.EnforcementInfoQuery;
import com.aisino.iles.lawenforcement.repository.*;
import jakarta.persistence.criteria.Predicate;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.Page;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
/**
* 法制审核及执法监督服务类
*/
@Service
@Slf4j
public class LegalReviewService {
private final EnforcementInfoRepository enforcementInfoRepository;
private final OfficerRepository officerRepository;
private final ExamineReportRepository examineReportRepository;
private final EnforceCheckRepository enforceCheckRepository;
private final CheckItemRepository checkItemRepository;
private final CaseRepository caseRepository;
private final DictItemRepo dictItemRepo;
public LegalReviewService(EnforcementInfoRepository enforcementInfoRepository,
OfficerRepository officerRepository,
ExamineReportRepository examineReportRepository,
EnforceCheckRepository enforceCheckRepository,
CheckItemRepository checkItemRepository,
CaseRepository caseRepository,
DictItemRepo dictItemRepo) {
this.enforcementInfoRepository = enforcementInfoRepository;
this.officerRepository = officerRepository;
this.examineReportRepository = examineReportRepository;
this.enforceCheckRepository = enforceCheckRepository;
this.checkItemRepository = checkItemRepository;
this.caseRepository = caseRepository;
this.dictItemRepo = dictItemRepo;
}
/**
* 分页查询执法信息
*
* @param query@return 分页执法信息
*/
@Transactional(readOnly = true)
public Page<EnforcementInfo> findEnforcementInfosPage(EnforcementInfoQuery query) {
return enforcementInfoRepository
.findAll(buildSpecification(query), PageableHelper.buildPageRequest(query.page(), query.pageSize(), query.sort(), query.dir()))
.map(this::handleResult);
}
private Specification<EnforcementInfo> buildSpecification(EnforcementInfoQuery query) {
return Specification.where((root, criteriaQuery, criteriaBuilder) -> {
List<Predicate> predicates = new ArrayList<>();
List<Predicate> orPredicates = new ArrayList<>();
orPredicates.add(criteriaBuilder.equal(root.get("currentNodeCode"), FlowNode.analyze_judge));
orPredicates.add(criteriaBuilder.equal(root.get("currentNodeCode"), FlowNode.reviewing_failed));
predicates.add(criteriaBuilder.or(orPredicates.toArray(new Predicate[0])));
Optional.ofNullable(query.getAgencyCode()).ifPresent(o -> predicates.add(criteriaBuilder.like(root.get("agency").get("agencyCode"), StringUtils.trimEven0(o) + "%")));
Optional.ofNullable(query.getUnitName()).ifPresent(o -> predicates.add(criteriaBuilder.like(root.get("enterprise").get("unitName"), "%" + o + "%")));
Optional.ofNullable(query.getCurrentNodeCode()).filter(StringUtils::isNotEmpty).ifPresent(o -> predicates.add(criteriaBuilder.equal(root.get(EnforcementInfo_.currentNodeCode), FlowNode.fromString(o))));
Optional.ofNullable(query.getStartTime()).ifPresent(o -> predicates.add(criteriaBuilder.greaterThanOrEqualTo(root.get("createTime"), o)));
Optional.ofNullable(query.getEndTime()).ifPresent(o -> predicates.add(criteriaBuilder.lessThanOrEqualTo(root.get("createTime"), o)));
return criteriaBuilder.and(predicates.toArray(new Predicate[0]));
});
}
private EnforcementInfo handleResult(EnforcementInfo enforcementInfoDto) {
Optional.ofNullable(enforcementInfoDto.getEnterprise()).ifPresent(enterprise -> enterprise.getUnitName());
Optional.ofNullable(enforcementInfoDto.getAgency()).ifPresent(agency -> agency.getAgencyName());
return enforcementInfoDto;
}
/**
* 根据ID查询执法信息
*
* @param enforcementId 执法信息ID
* @return 执法信息
*/
@Transactional(readOnly = true)
public Optional<EnforcementInfo> findEnforcementInfoById(String enforcementId) {
return enforcementInfoRepository.findById(enforcementId).map(enforcementInfo -> {
// 机构信息
Optional.ofNullable(enforcementInfo.getAgency()).ifPresent(agency -> agency.getAgencyName());
// 企业信息
Optional.ofNullable(enforcementInfo.getEnterprise()).ifPresent(enterprise -> enterprise.getUnitName());
// 检查记录信息
List<EnforceCheck> enforceChecks = enforceCheckRepository.findByEnforcementId(enforcementInfo.getEnforcementId());
enforceChecks.forEach(enforceCheck -> {
String officerIds = enforceCheck.getOfficerIds();
if (StringUtils.isNotEmpty(officerIds)) {
List<Officer> officerList = new ArrayList<>();
Arrays.stream(officerIds.split(",")).forEach(id -> officerRepository.findById(id).ifPresent(officerList::add));
enforceCheck.setOfficerList(officerList);
}
String checkStatusMsg = "1".equals(enforceCheck.getCheckStatus()) ? "待检查" : "已检查";
enforceCheck.setCheckStatusMsg(checkStatusMsg);
dictItemRepo.findByDictDictCodeAndValue("dm_cljg", enforceCheck.getCheckResult()).ifPresent(o -> enforceCheck.setCheckResultMsg(o.getDisplay()));
});
// 排序
enforceChecks.stream().sorted((a, b) -> b.getCreateTime().compareTo(a.getCreateTime())).collect(Collectors.toList());
enforcementInfo.setEnforceChecks(enforceChecks);
// 检查项信息
if (enforceChecks.size() > 0 && StringUtils.isNotEmpty(enforceChecks.get(0).getCheckItemIds())) {
enforcementInfo.setCheckItems(checkItemRepository.findByItemIdIn(enforceChecks.get(0).getCheckItemIds().split(",")));
}
return enforcementInfo;
});
}
/**
* 根据ID查询执法信息
*
* @param enforcementId 执法信息ID
* @return 执法信息
*/
@Transactional(readOnly = true)
public Optional<EnforcementInfo> findLegalReviewInfoById(String enforcementId) {
return enforcementInfoRepository.findById(enforcementId).map(enforcementInfo -> {
// 机构信息
Optional.ofNullable(enforcementInfo.getAgency()).ifPresent(agency -> agency.getAgencyName());
// 案件信息
caseRepository.findByEnforcementInfoEnforcementId(enforcementInfo.getEnforcementId()).ifPresent(caseInfo -> enforcementInfo.setCaseInfo(caseInfo));
// 检查记录信息
List<EnforceCheck> enforceChecks = enforceCheckRepository.findByEnforcementId(enforcementInfo.getEnforcementId());
enforceChecks.forEach(enforceCheck -> {
String officerIds = enforceCheck.getOfficerIds();
if (StringUtils.isNotEmpty(officerIds)) {
List<Officer> officerList = new ArrayList<>();
Arrays.stream(officerIds.split(",")).forEach(id -> officerRepository.findById(id).ifPresent(officerList::add));
enforceCheck.setOfficerList(officerList);
}
String checkStatusMsg = "1".equals(enforceCheck.getCheckStatus()) ? "待检查" : "已检查";
enforceCheck.setCheckStatusMsg(checkStatusMsg);
dictItemRepo.findByDictDictCodeAndValue("dm_cljg", enforceCheck.getCheckResult()).ifPresent(o -> enforceCheck.setCheckResultMsg(o.getDisplay()));
});
// 排序
enforceChecks.stream().sorted((a, b) -> b.getCreateTime().compareTo(a.getCreateTime())).collect(Collectors.toList());
enforcementInfo.setEnforceChecks(enforceChecks);
// 检查项信息
if (enforceChecks.size() > 0 && StringUtils.isNotEmpty(enforceChecks.get(0).getCheckItemIds()))
enforcementInfo.setCheckItems(checkItemRepository.findByItemIdIn(enforceChecks.get(0).getCheckItemIds().split(",")));
return enforcementInfo;
});
}
/**
* 法治审核信息
*
* @param legalReviewDto 法治审核信息
* @return 更新后的执法信息
*/
@Transactional
@PublishDataChange(action = DataChangeAction.SAVE)
public EnforcementInfo saveLegalReviewInfo(LegalReviewDto legalReviewDto) {
EnforcementInfo enforcementInfo = enforcementInfoRepository.findById(legalReviewDto.getEnforcementId())
.orElseThrow(() -> new BusinessError("未找到指定的执法信息：" + legalReviewDto.getEnforcementId()));
if ("1".equals(legalReviewDto.getIsRegister()) ) {
enforcementInfo.setCurrentNodeCode(FlowNode.reviewing_done);
enforcementInfo.setCurrentNode("法治审核完成");
enforcementInfo.setAuditType(legalReviewDto.getAuditType());
} else {
enforcementInfo.setCurrentNodeCode(FlowNode.reviewing_failed);
enforcementInfo.setCurrentNode("法治审核未通过");
}
enforcementInfo.setAuditComment(legalReviewDto.getAuditComment());
enforcementInfo.setAuditAgencyName(legalReviewDto.getAuditAgencyName());
enforcementInfo.setAuditAgencyCode(legalReviewDto.getAuditAgencyCode());
enforcementInfo.setAuditUserId(legalReviewDto.getAuditUserId());
enforcementInfo.setAuditUserName(legalReviewDto.getAuditUserName());
enforcementInfo.setAuditTime(legalReviewDto.getAuditTime());
// AOP切面会拦截此返回值并发布事件
return enforcementInfo;
}
/**
* 保存调查报告
*
* @param examineReport 调查报告
* @return 保存后的执法信息
*/
@Transactional
public ExamineReport saveEnforcementInfo(ExamineReport examineReport) {
Optional<EnforcementInfo> optionalEnforcementInfo = enforcementInfoRepository.findById(examineReport.getEnforcementId());
if (optionalEnforcementInfo.isPresent()) {
EnforcementInfo enforcementInfo = optionalEnforcementInfo.get();
examineReport.setEnforcementId(enforcementInfo.getEnforcementId());
//examineReport.setUserId(enforcementInfo);
examineReport.setExamineReportTime(LocalDateTime.now());
examineReportRepository.save(examineReport);
enforcementInfo.setExamineReport(examineReport);
enforcementInfoRepository.save(enforcementInfo);
return examineReport;
} else {
throw new BusinessError("无查询结果不能导出");
}
}
}

241
server/src/main/java/com/aisino/iles/lawenforcement/service/MessageService.java Normal file
View File

@ -0,0 +1,241 @@
package com.aisino.iles.lawenforcement.service;
import com.aisino.iles.core.exception.BusinessError;
import com.aisino.iles.lawenforcement.model.Message;
import com.aisino.iles.lawenforcement.model.Message.MessageStatus;
import com.aisino.iles.lawenforcement.model.MessageReceiver;
import com.aisino.iles.lawenforcement.model.dto.message.MessageDto.MessageCountResponse;
import com.aisino.iles.lawenforcement.model.dto.message.MessageDto.MessageResponse;
import com.aisino.iles.lawenforcement.model.dto.message.MessageDto.SendMessageRequest;
import com.aisino.iles.lawenforcement.repository.MessageReceiverRepository;
import com.aisino.iles.lawenforcement.repository.MessageRepository;
import com.smartlx.sso.client.model.RemoteUserInfo;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
/**
* 消息服务
* 提供消息的发送、查询、状态更新等功能
*/
@Service
@Slf4j
@RequiredArgsConstructor
public class MessageService {
private final MessageRepository messageRepository;
private final MessageReceiverRepository messageReceiverRepository;
/**
* 发送消息
*
* @param request 发送消息请求
* @param user 当前用户
* @return 消息ID
*/
@Transactional
public String sendMessage(SendMessageRequest request, RemoteUserInfo user) {
// 获取当前用户ID
String currentUserId = user.getYhwybs();
// 检查是否存在相同业务键的消息（用于去重）
if (request.getBusinessKey() != null && !request.getBusinessKey().isEmpty()) {
Optional<Message> existingMessage = messageRepository.findByBusinessKey(request.getBusinessKey());
if (existingMessage.isPresent()) {
log.info("消息已存在，业务键: {}", request.getBusinessKey());
return existingMessage.get().getId();
}
}
// 创建新消息
Message message = new Message();
message.setTitle(request.getTitle());
message.setContent(request.getContent());
message.setSenderId(currentUserId);
message.setRouteUrl(request.getRouteUrl());
message.setRouteParams(request.getRouteParams());
message.setBusinessKey(request.getBusinessKey());
// 添加接收者
for (String receiverId : request.getReceiverIds()) {
message.addReceiver(receiverId);
}
// 保存消息
messageRepository.save(message);
log.info("消息发送成功，ID: {}, 接收者数量: {}", message.getId(), request.getReceiverIds().size());
return message.getId();
}
/**
* 获取当前用户的消息列表
*
* @param status 消息状态过滤（可选）
* @param pageable 分页参数
* @param user 当前用户
* @return 消息列表（分页）
*/
@Transactional(readOnly = true)
public Page<MessageResponse> getUserMessages(MessageStatus status, Pageable pageable, RemoteUserInfo user) {
String currentUserId = user.getYhwybs();
Page<MessageReceiver> receivers;
if (status != null) {
// 如果指定了状态，则按该状态查询
receivers = messageReceiverRepository.findByReceiverIdAndStatusIn(
currentUserId, Arrays.asList(status), pageable);
} else {
// 否则，查询所有未删除的消息（未读和已读）
receivers = messageReceiverRepository.findByReceiverIdAndStatusIn(
currentUserId, Arrays.asList(MessageStatus.UNREAD, MessageStatus.READ), pageable);
}
return receivers.map(messageReceiver -> {
messageReceiver.setUser(user);
return convertToMessageResponse(messageReceiver);
});
}
/**
* 获取消息详情
*
* @param messageId 消息ID
* @param user 当前用户
* @return 消息详情
* @throws BusinessError 如果消息不存在或当前用户无权访问
*/
@Transactional(readOnly = true)
public MessageResponse getMessageById(String messageId, RemoteUserInfo user) {
String currentUserId = user.getYhwybs();
MessageReceiver receiver = messageReceiverRepository.findByReceiverIdAndMessageId(currentUserId, messageId)
.orElseThrow(() -> new BusinessError("消息不存在或无权访问"));
receiver.setUser(user);
return convertToMessageResponse(receiver);
}
/**
* 更新消息状态
*
* @param messageId 消息ID
* @param status 新状态
* @param user 当前用户
* @throws BusinessError 如果消息不存在或当前用户无权访问
*/
@Transactional
public void updateMessageStatus(String messageId, MessageStatus status, RemoteUserInfo user) {
String currentUserId = user.getYhwybs();
MessageReceiver receiver = messageReceiverRepository.findByReceiverIdAndMessageId(currentUserId, messageId)
.orElseThrow(() -> new BusinessError("消息不存在或无权访问"));
if (status == MessageStatus.READ) {
receiver.markAsRead();
} else if (status == MessageStatus.DELETED) {
receiver.markAsDeleted();
}
messageReceiverRepository.save(receiver);
log.info("消息状态已更新，ID: {}, 新状态: {}", messageId, status);
}
/**
* 删除消息（逻辑删除）
*
* @param messageId 消息ID
* @param user 当前用户
* @throws RuntimeException 如果消息不存在或当前用户无权访问
*/
@Transactional
public void deleteMessage(String messageId, RemoteUserInfo user) {
updateMessageStatus(messageId, MessageStatus.DELETED, user);
}
/**
* 批量删除消息（逻辑删除）
*
* @param messageIds 消息ID列表
* @param user 当前用户
*/
@Transactional
public void deleteMessagesForCurrentUser(List<String> messageIds, RemoteUserInfo user) {
String currentUserId = user.getYhwybs();
List<MessageReceiver> receivers = messageReceiverRepository.findByReceiverIdAndMessageIdIn(currentUserId, messageIds);
if (receivers.isEmpty()) {
log.warn("没有找到任何属于用户 {} 的消息，消息ID: {}", currentUserId, messageIds);
return;
}
for (MessageReceiver receiver : receivers) {
receiver.setStatus(MessageStatus.DELETED);
}
messageReceiverRepository.saveAll(receivers);
log.info("用户 {} 成功删除了 {} 条消息", currentUserId, receivers.size());
}
/**
* 获取当前用户的未读消息数
*
* @return 未读消息数量
*/
@Transactional(readOnly = true)
public MessageCountResponse getUnreadMessageCount(RemoteUserInfo user) {
String currentUserId = user.getYhwybs();
long count = messageReceiverRepository.countByReceiverIdAndStatus(currentUserId, MessageStatus.UNREAD);
MessageCountResponse response = new MessageCountResponse();
response.setUnreadCount(count);
return response;
}
/**
* 检查消息是否重复
*
* @param businessKey 业务键
* @return 是否存在相同业务键的消息
*/
@Transactional(readOnly = true)
public boolean checkDuplicateMessage(String businessKey) {
if (businessKey == null || businessKey.isEmpty()) {
return false;
}
return messageRepository.existsByBusinessKey(businessKey);
}
/**
* 将MessageReceiver转换为MessageResponse
*
* @param receiver 消息接收记录
* @return 消息响应DTO
*/
private MessageResponse convertToMessageResponse(MessageReceiver receiver) {
Message message = receiver.getMessage();
MessageResponse response = new MessageResponse();
response.setId(message.getId());
response.setTitle(message.getTitle());
response.setContent(message.getContent());
response.setSenderId(message.getSenderId());
response.setSenderName(receiver.getUser().getXm()); // 假设有方法获取用户名
response.setSenderAgencyName(receiver.getUser().getGajgmc());
response.setStatus(receiver.getStatus());
response.setCreateTime(message.getCreateTime());
response.setReadTime(receiver.getReadTime());
response.setRouteUrl(message.getRouteUrl());
response.setRouteParams(message.getRouteParams());
return response;
}
}