Compare commits

..

2 Commits

33 changed files with 229 additions and 374 deletions

View File

@ -1,4 +1,4 @@
<!doctype html><html lang="zh"><head data-built-info="@cqsjjb/scripts@2.0.0-alpha-1 Env/production (2026/7/28 16:48:49) App/fireCheck"><meta charset="UTF-8"/><meta name="renderer" content="webkit"/><meta http-equiv="X-UA-Compatible" content="IE=edge,Chrome=1"/><meta name="viewport" content="width=device-width,minimum-scale=1,maximum-scale=1,user-scalable=no,viewport-fit=cover"><meta charset="UTF-8" name="referrer" content="strict-origin-when-cross-origin"/><title>秦港安全监管平台</title><script>(function () {
<!doctype html><html lang="zh"><head data-built-info="@cqsjjb/scripts@2.0.0-alpha-1 Env/production (2026/6/15 17:02:37) App/fireCheck"><meta charset="UTF-8"/><meta name="renderer" content="webkit"/><meta http-equiv="X-UA-Compatible" content="IE=edge,Chrome=1"/><meta name="viewport" content="width=device-width,minimum-scale=1,maximum-scale=1,user-scalable=no,viewport-fit=cover"><title>秦港安全监管平台</title><script>(function () {
const APP_ENV = {
antd: {
'ant-prefix': 'micro-temp',
@ -20,4 +20,4 @@
redirect: '',
FRAMEWORK: APP_ENV.antd
};
})();</script><script defer="defer" src="/fireCheck/static/js/201.9d4d48ed85dbd20c30f6.js"></script><script defer="defer" src="/fireCheck/static/js/514.cbbdb1f566e234e3ebed.js"></script><script defer="defer" src="/fireCheck/static/js/main.e0c5ce72dc8c82f0bb1b.js"></script><link href="/fireCheck/static/css/main.4351c3e506121e95b980.css" rel="stylesheet"></head><body><noscript>此网页需要开启JavaScript功能。</noscript><div id="root" style="width: 100%; height: 100%; position: relative;overflow-y: auto"></div><script type="text/javascript">/* @cqsjjb/script 输出当前应用基本信息、构建时间 */console.log("%c@cqsjjb/scripts@2.0.0-alpha-1 Env/production (2026/7/28 16:48:49) App/fireCheck Version/main Java/<branch-name>", "color: #1890ff; border-radius: 2px; padding: 0 4px; border: 1px solid #1890ff; background: #f9fcff")</script></body></html>
})();</script><script defer="defer" src="/fireCheck/static/js/201.a64808ef21f0f31301fd.js"></script><script defer="defer" src="/fireCheck/static/js/514.df5c4abca1ad6efc80a4.js"></script><script defer="defer" src="/fireCheck/static/js/main.8fead917278fdc3194ac.js"></script><link href="/fireCheck/static/css/main.4351c3e506121e95b980.css" rel="stylesheet"></head><body><noscript>此网页需要开启JavaScript功能。</noscript><div id="root" style="width: 100%; height: 100%; position: relative;overflow-y: auto"></div><script type="text/javascript">/* @cqsjjb/script 输出当前应用基本信息、构建时间 */console.log("%c@cqsjjb/scripts@2.0.0-alpha-1 Env/production (2026/6/15 17:02:37) App/fireCheck Version/main Java/<branch-name>", "color: #1890ff; border-radius: 2px; padding: 0 4px; border: 1px solid #1890ff; background: #f9fcff")</script></body></html>

View File

@ -1 +1 @@
module.exports={javaGit:"<git-url>",javaGitName:"<git-name>",environment:{development:{javaGitBranch:"<branch-name>",API_HOST:"https://gbs-gateway.qhdsafety.com"},production:{javaGitBranch:"<branch-name>",API_HOST:""}},appIdentifier:"fireCheck",contextInject:{appKey:"",fileUrl:""},windowInject:{title:"微应用模板",links:[],element:{root:{id:"root"}},scripts:[]},server:{port:"8088",host:"127.0.0.1",open:!0},framework:{antd:{"ant-prefix":"micro-temp",fontFamily:"PingFangSC-Regular",colorPrimary:"#1677ff",borderRadius:2}},webpackConfig:{htmlWebpackPluginOption:{inject:!0}}};
module.exports={javaGit:"<git-url>",javaGitName:"<git-name>",environment:{development:{javaGitBranch:"<branch-name>",API_HOST:"https://gbs-gateway.qhdsafety.com"},production:{javaGitBranch:"<branch-name>",API_HOST:""}},appIdentifier:"fireCheck",contextInject:{appKey:"",fileUrl:"https://jpfz.qhdsafety.com/gbsFileTest/"},windowInject:{title:"微应用模板",links:[],element:{root:{id:"root"}},scripts:[]},server:{port:"8088",host:"127.0.0.1",open:!0},framework:{antd:{"ant-prefix":"micro-temp",fontFamily:"PingFangSC-Regular",colorPrimary:"#1677ff",borderRadius:2}},webpackConfig:{htmlWebpackPluginOption:{inject:!0}}};

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

View File

@ -0,0 +1,215 @@
package com.zcloud.fire.check.facade;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.cola.dto.MultiResponse;
import com.alibaba.cola.dto.SingleResponse;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.jjb.saas.message.client.message.facede.MessageFacade;
import com.jjb.saas.message.client.message.request.MessageSendCmd;
import com.jjb.saas.message.client.message.request.MessageTargetCmd;
import com.zcloud.fire.check.domain.config.MessageConfig;
import com.zcloud.fire.check.persistence.dataobject.FireCheckListDO;
import com.zcloud.fire.check.persistence.dataobject.FireCheckListUserDO;
import com.zcloud.fire.check.persistence.dataobject.UserDO;
import com.zcloud.fire.check.persistence.mapper.FireCheckListMapper;
import com.zcloud.fire.check.persistence.mapper.FireCheckListUserMapper;
import com.zcloud.fire.check.persistence.repository.UserRepository;
import com.zcloud.gbscommon.utils.UuidUtil;
import com.zcloud.gbscommon.zloudfirecheck.facade.ZcloudFireCheckFacade;
import com.zcloud.gbscommon.zloudfirecheck.request.FireCheckQry;
import com.zcloud.gbscommon.zloudfirecheck.response.FireCheckListByUserCO;
import com.zcloud.gbscommon.zloudfirecheck.response.FireCheckWorkChangeCmd;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@DubboService
@AllArgsConstructor
@Slf4j
public class ZcloudFireCheckFacadeImpl implements ZcloudFireCheckFacade {
@Resource
private final FireCheckListMapper fireCheckListMapper;
@Resource
private final FireCheckListUserMapper fireCheckListUserMapper;
@Resource
private final UserRepository userRepository;
@DubboReference
private MessageFacade messageFacade;
@Resource
private final MessageConfig messageConfig;
@Override
public MultiResponse<FireCheckListByUserCO> listManagerByUserId(FireCheckQry fireCheckQry) {
if (fireCheckQry == null || fireCheckQry.getUserId() == null || fireCheckQry.getCorpinfoId() == null) {
return MultiResponse.of(Collections.emptyList());
}
QueryWrapper<FireCheckListUserDO> listUserQueryWrapper = new QueryWrapper<>();
listUserQueryWrapper.eq("user_id", fireCheckQry.getUserId());
listUserQueryWrapper.eq("corpinfo_id", fireCheckQry.getCorpinfoId());
List<FireCheckListUserDO> fireCheckListUserList = fireCheckListUserMapper.selectList(listUserQueryWrapper);
if (CollUtil.isEmpty(fireCheckListUserList)) {
return MultiResponse.of(Collections.emptyList());
}
Set<String> fireCheckIdSet = fireCheckListUserList.stream()
.map(FireCheckListUserDO::getFireCheckId)
.filter(StringUtils::isNotEmpty)
.collect(Collectors.toSet());
if (CollUtil.isEmpty(fireCheckIdSet)) {
return MultiResponse.of(Collections.emptyList());
}
QueryWrapper<FireCheckListDO> listQueryWrapper = new QueryWrapper<>();
listQueryWrapper.in("fire_check_id", fireCheckIdSet);
listQueryWrapper.eq("corpinfo_id", fireCheckQry.getCorpinfoId());
List<FireCheckListDO> fireCheckListList = fireCheckListMapper.selectList(listQueryWrapper);
if (CollUtil.isEmpty(fireCheckListList)) {
return MultiResponse.of(Collections.emptyList());
}
List<FireCheckListByUserCO> result = fireCheckListList.stream()
.map(this::buildFireCheckListByUserCO)
.collect(Collectors.toList());
return MultiResponse.of(result);
}
@Override
@Transactional(rollbackFor = Exception.class)
public SingleResponse updateRiskWorkChange(FireCheckWorkChangeCmd fireCheckWorkChangeCmd) {
if (fireCheckWorkChangeCmd == null
|| StringUtils.isEmpty(fireCheckWorkChangeCmd.getFireCheckId())
|| fireCheckWorkChangeCmd.getOldUserId() == null
|| fireCheckWorkChangeCmd.getUserId() == null) {
return SingleResponse.buildFailure("PARAM_ERROR", "交接参数不完整");
}
QueryWrapper<FireCheckListUserDO> listUserQueryWrapper = new QueryWrapper<>();
listUserQueryWrapper.eq("fire_check_id", fireCheckWorkChangeCmd.getFireCheckId());
listUserQueryWrapper.eq("user_id", fireCheckWorkChangeCmd.getOldUserId());
List<FireCheckListUserDO> fireCheckListUserList = fireCheckListUserMapper.selectList(listUserQueryWrapper);
if (CollUtil.isEmpty(fireCheckListUserList)) {
return SingleResponse.buildFailure("DATA_NOT_FOUND", "未查询到待交接的消防检查工作");
}
QueryWrapper<FireCheckListUserDO> existsQueryWrapper = new QueryWrapper<>();
existsQueryWrapper.eq("fire_check_id", fireCheckWorkChangeCmd.getFireCheckId());
existsQueryWrapper.eq("user_id", fireCheckWorkChangeCmd.getUserId());
Long existsCount = fireCheckListUserMapper.selectCount(existsQueryWrapper);
if (existsCount != null && existsCount > 0) {
return SingleResponse.buildFailure("DATA_EXISTS", "新责任人已存在于该消防检查工作中");
}
UserDO newUser = getNewUser(fireCheckWorkChangeCmd.getUserId());
for (FireCheckListUserDO fireCheckListUserDO : fireCheckListUserList) {
fireCheckListUserDO.setUserId(fireCheckWorkChangeCmd.getUserId());
fireCheckListUserDO.setDepartmentId(resolveDepartmentId(fireCheckWorkChangeCmd, newUser));
fireCheckListUserDO.setCorpinfoId(resolveCorpinfoId(fireCheckWorkChangeCmd, newUser));
fireCheckListUserMapper.updateById(fireCheckListUserDO);
}
FireCheckListDO fireCheckListDO = getFireCheckList(fireCheckWorkChangeCmd.getFireCheckId());
sendWorkChangeMessage(fireCheckWorkChangeCmd, fireCheckListDO);
return SingleResponse.buildSuccess();
}
private FireCheckListByUserCO buildFireCheckListByUserCO(FireCheckListDO fireCheckListDO) {
FireCheckListByUserCO result = new FireCheckListByUserCO();
result.setFireCheckId(fireCheckListDO.getFireCheckId());
result.setWorkProject("消防检查");
result.setWorkContent(buildWorkContent(fireCheckListDO));
return result;
}
private String buildWorkContent(FireCheckListDO fireCheckListDO) {
if (fireCheckListDO == null) {
return "";
}
if (StringUtils.isNotEmpty(fireCheckListDO.getFireCheckName())
&& StringUtils.isNotEmpty(fireCheckListDO.getFireCheckTypeName())) {
return fireCheckListDO.getFireCheckName() + "" + fireCheckListDO.getFireCheckTypeName() + "";
}
if (StringUtils.isNotEmpty(fireCheckListDO.getFireCheckName())) {
return fireCheckListDO.getFireCheckName();
}
return StringUtils.defaultString(fireCheckListDO.getFireCheckTypeName());
}
private UserDO getNewUser(Long userId) {
List<UserDO> userList = userRepository.getListById(Collections.singletonList(userId));
if (CollUtil.isEmpty(userList)) {
return null;
}
return userList.get(0);
}
private Long resolveDepartmentId(FireCheckWorkChangeCmd fireCheckWorkChangeCmd, UserDO newUser) {
if (fireCheckWorkChangeCmd.getDeptId() != null) {
return fireCheckWorkChangeCmd.getDeptId();
}
if (newUser != null) {
return newUser.getDepartmentId();
}
return null;
}
private Long resolveCorpinfoId(FireCheckWorkChangeCmd fireCheckWorkChangeCmd, UserDO newUser) {
if (fireCheckWorkChangeCmd.getCorpId() != null) {
return fireCheckWorkChangeCmd.getCorpId();
}
if (newUser != null) {
return newUser.getCorpinfoId();
}
return null;
}
private FireCheckListDO getFireCheckList(String fireCheckId) {
QueryWrapper<FireCheckListDO> listQueryWrapper = new QueryWrapper<>();
listQueryWrapper.eq("fire_check_id", fireCheckId);
return fireCheckListMapper.selectOne(listQueryWrapper);
}
private void sendWorkChangeMessage(FireCheckWorkChangeCmd fireCheckWorkChangeCmd, FireCheckListDO fireCheckListDO) {
try {
MessageSendCmd messageSendCmd = new MessageSendCmd();
messageSendCmd.setBusinessId(UuidUtil.get32UUID());
MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
messageTargetCmd.setUserId(fireCheckWorkChangeCmd.getUserId());
messageSendCmd.setTargetCmd(messageTargetCmd);
messageSendCmd.setSourceCode(messageConfig.getFireCheckPending());
messageSendCmd.setNeedTokenEnum(false);
messageSendCmd.setParams(buildSendParams(fireCheckWorkChangeCmd, fireCheckListDO));
log.info("消防检查工作交接发送消息参数:{}", JSONUtil.toJsonStr(messageSendCmd));
SingleResponse<Boolean> response = messageFacade.send(messageSendCmd);
log.info("消防检查工作交接发送消息结果:{}", JSONUtil.toJsonStr(response));
if (response == null || !response.isSuccess() || !Boolean.TRUE.equals(response.getData())) {
log.warn("消防检查工作交接消息发送未成功, fireCheckId:{}, userId:{}", fireCheckWorkChangeCmd.getFireCheckId(), fireCheckWorkChangeCmd.getUserId());
}
} catch (Exception e) {
log.error("消防检查工作交接发送消息失败", e);
}
}
private Map<String, Object> buildSendParams(FireCheckWorkChangeCmd fireCheckWorkChangeCmd, FireCheckListDO fireCheckListDO) {
String fireCheckName = fireCheckListDO == null ? "" : StringUtils.defaultString(fireCheckListDO.getFireCheckName());
String fireCheckTypeName = fireCheckListDO == null ? "" : StringUtils.defaultString(fireCheckListDO.getFireCheckTypeName());
return Stream.of(
new Object[]{"FirefightinglistName", fireCheckName},
new Object[]{"checkPeriod", fireCheckTypeName},
new Object[]{"oldUserId", fireCheckWorkChangeCmd.getOldUserId()},
new Object[]{"newUserId", fireCheckWorkChangeCmd.getUserId()},
new Object[]{"newUserName", StringUtils.defaultString(fireCheckWorkChangeCmd.getUserName())},
new Object[]{"workProject", "消防检查"},
new Object[]{"workContent", buildWorkContent(fireCheckListDO)}
)
.filter(item -> Objects.nonNull(item[1]))
.collect(Collectors.toMap(item -> String.valueOf(item[0]), item -> item[1], (left, right) -> right));
}
}

View File

@ -10,7 +10,6 @@ import com.jjb.saas.framework.auth.utils.AuthContext;
import com.zcloud.fire.check.api.FireCheckListServiceI;
import com.zcloud.fire.check.dto.*;
import com.zcloud.fire.check.dto.clientobject.FireCheckListCO;
import com.zcloud.fire.check.dto.clientobject.FireCheckListScreenCO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
@ -99,12 +98,5 @@ public class FireCheckListController {
public PageResponse<FireCheckListCO> mainCheckListRecordList(@RequestBody FireCheckListRecordPageQry qry) {
return fireCheckListService.checkListRecordList(qry);
}
@ApiOperation("可视化大屏-消防点检列表")
@PostMapping("/screen/list")
public PageResponse<FireCheckListScreenCO> screenList(@RequestBody(required = false) FireCheckListScreenQry qry) {
return fireCheckListService.screenList(qry);
}
}

View File

@ -5,10 +5,11 @@ import com.alibaba.cola.dto.MultiResponse;
import com.alibaba.cola.dto.PageResponse;
import com.alibaba.cola.dto.Response;
import com.alibaba.cola.dto.SingleResponse;
import com.jjb.saas.framework.auth.model.SSOUser;
import com.jjb.saas.framework.auth.utils.AuthContext;
import com.zcloud.fire.check.api.FirePointServiceI;
import com.zcloud.fire.check.dto.*;
import com.zcloud.fire.check.dto.clientobject.FirePointCO;
import com.zcloud.fire.check.dto.clientobject.FirePointDeviceCO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
@ -17,6 +18,7 @@ import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
/**
* web-adapter
@ -50,8 +52,6 @@ public class FirePointController {
return firePointService.listPage(qry);
}
@ApiOperation("根据消防区域获取消防点位所有")
@GetMapping("/listByFireRegionId/{fireRegionId}")
public MultiResponse<FirePointCO> listByFireRegionId(@PathVariable("fireRegionId") String fireRegionId) {
@ -96,10 +96,5 @@ public class FirePointController {
firePointService.exportFirePointPage(ids,httpServletResponse);
}
@ApiOperation("可视化大屏-消防点位设备列表")
@PostMapping("/deviceList")
public PageResponse<FirePointDeviceCO> deviceList(@RequestBody FirePointDeviceQry qry) {
return firePointService.listDevice(qry);
}
}

View File

@ -76,41 +76,6 @@ public class FireCheckListQueryExe {
private MessageFacade messageFacade;
private MessageConfig messageConfig;
public PageResponse<FireCheckListScreenCO> screenList(FireCheckListScreenQry qry) {
if (qry == null) {
qry = new FireCheckListScreenQry();
}
Map<String, Object> params = PageQueryHelper.toHashMap(qry);
PageResponse<FireCheckListDO> pageResponse = fireCheckListRepository.screenList(params);
List<FireCheckListScreenCO> result = new ArrayList<>();
for (FireCheckListDO item : pageResponse.getData()) {
FireCheckListScreenCO co = new FireCheckListScreenCO();
BeanUtils.copyProperties(item, co);
Long checkCycleCount = parseLong(item.getCheckCycleCount());
co.setCheckCycleCount(checkCycleCount);
FireCheckListE info = new FireCheckListE();
info.getCheckRecordPeriod(item.getFireCheckType(), LocalDateTime.now());
co.setCheckStartTime(info.getPeriodStart());
co.setCheckEndTime(info.getPeriodEnd());
if (checkCycleCount > 0) {
co.setCheckStatus(2);
co.setCheckStatusName("已检查");
} else {
co.setCheckStatus(1);
co.setCheckStatusName("未检查");
}
result.add(co);
}
return PageResponse.of(result, pageResponse.getTotalCount(), pageResponse.getPageSize(), pageResponse.getPageIndex());
}
private Long parseLong(String value) {
if (StringUtils.isEmpty(value)) {
return 0L;
}
return Long.valueOf(value);
}
/**
*
*

View File

@ -1,20 +1,16 @@
package com.zcloud.fire.check.command.query;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.cola.dto.MultiResponse;
import com.alibaba.cola.dto.PageResponse;
import com.alibaba.nacos.api.config.annotation.NacosValue;
import com.zcloud.fire.check.command.convertor.FirePointCoConvertor;
import com.zcloud.fire.check.domain.enums.CorpTypeEnum;
import com.zcloud.fire.check.domain.config.PointConfig;
import com.zcloud.fire.check.domain.model.FirePointE;
import com.zcloud.fire.check.dto.FirePointDeviceQry;
import com.zcloud.fire.check.dto.FirePointPageQry;
import com.zcloud.fire.check.dto.clientobject.FirePointCO;
import com.zcloud.fire.check.dto.clientobject.FirePointDeviceCO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDeviceCountDO;
import com.zcloud.fire.check.dto.clientobject.FireRegionCO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDO;
import com.zcloud.fire.check.persistence.repository.FireCheckRecordPointRepository;
import com.zcloud.fire.check.persistence.repository.FireDeviceRepository;
@ -133,26 +129,5 @@ public class FirePointQueryExe {
List<FirePointCO> examCenterCOS = firePointCoConvertor.converDOsToCOs(pageResponse);
return MultiResponse.of(examCenterCOS);
}
public PageResponse<FirePointDeviceCO> listDevice(FirePointDeviceQry qry) {
Map<String, Object> params = PageQueryHelper.toHashMap(qry);
if (ObjectUtil.isNotEmpty(params.get("enterpriseType"))) {
List<Integer> enterpriseType = CorpTypeEnum.getCodesByEnterpriseType((Integer) params.get("enterpriseType"));
if (CollUtil.isNotEmpty(enterpriseType)) {
params.put("type", enterpriseType);
}
}
List<Integer> inType = (List<Integer>) params.get("inType");
if (CollUtil.isNotEmpty(inType)) {
params.put("type", inType);
}
PageResponse<FirePointDeviceCountDO> pageResponse = firePointRepository.listDevice(params);
List<FirePointDeviceCO> list = pageResponse.getData().stream().map(item -> {
FirePointDeviceCO co = new FirePointDeviceCO();
BeanUtils.copyProperties(item, co);
return co;
}).collect(Collectors.toList());
return PageResponse.of(list, pageResponse.getTotalCount(), pageResponse.getPageSize(), pageResponse.getPageIndex());
}
}

View File

@ -29,11 +29,6 @@ public class FireCheckListServiceImpl implements FireCheckListServiceI {
private final FireCheckListRemoveExe fireCheckListRemoveExe;
private final FireCheckListQueryExe fireCheckListQueryExe;
@Override
public PageResponse<FireCheckListScreenCO> screenList(FireCheckListScreenQry qry) {
return fireCheckListQueryExe.screenList(qry);
}
@Override
public PageResponse<FireCheckListCO> listPage(FireCheckListPageQry qry) {
return fireCheckListQueryExe.execute(qry);

View File

@ -9,12 +9,10 @@ import com.zcloud.fire.check.command.FirePointRemoveExe;
import com.zcloud.fire.check.command.FirePointUpdateExe;
import com.zcloud.fire.check.command.query.FirePointQueryExe;
import com.zcloud.fire.check.dto.FirePointAddCmd;
import com.zcloud.fire.check.dto.FirePointDeviceQry;
import com.zcloud.fire.check.dto.FirePointPageQry;
import com.zcloud.fire.check.dto.FirePointUpdateCmd;
import com.zcloud.fire.check.dto.FirePointUpdateDepartmentCmd;
import com.zcloud.fire.check.dto.clientobject.FirePointCO;
import com.zcloud.fire.check.dto.clientobject.FirePointDeviceCO;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
@ -81,10 +79,5 @@ public class FirePointServiceImpl implements FirePointServiceI {
return firePointQueryExe.listByFireRegionId(fireRegionId);
}
@Override
public PageResponse<FirePointDeviceCO> listDevice(FirePointDeviceQry qry) {
return firePointQueryExe.listDevice(qry);
}
}

View File

@ -15,8 +15,6 @@ import java.util.Map;
* @Date 2025-11-28 10:32:09
*/
public interface FireCheckListServiceI {
PageResponse<FireCheckListScreenCO> screenList(FireCheckListScreenQry qry);
PageResponse<FireCheckListCO> listPage(FireCheckListPageQry qry);
SingleResponse<FireCheckListCO> add(FireCheckListAddCmd cmd);

View File

@ -4,12 +4,10 @@ import com.alibaba.cola.dto.MultiResponse;
import com.alibaba.cola.dto.PageResponse;
import com.alibaba.cola.dto.SingleResponse;
import com.zcloud.fire.check.dto.FirePointAddCmd;
import com.zcloud.fire.check.dto.FirePointDeviceQry;
import com.zcloud.fire.check.dto.FirePointPageQry;
import com.zcloud.fire.check.dto.FirePointUpdateCmd;
import com.zcloud.fire.check.dto.FirePointUpdateDepartmentCmd;
import com.zcloud.fire.check.dto.clientobject.FirePointCO;
import com.zcloud.fire.check.dto.clientobject.FirePointDeviceCO;
import javax.servlet.http.HttpServletResponse;
@ -37,7 +35,5 @@ public interface FirePointServiceI {
void exportFirePointPage(Long[] ids, HttpServletResponse httpServletResponse);
MultiResponse<FirePointCO> listByFireRegionId(String fireRegionId);
PageResponse<FirePointDeviceCO> listDevice(FirePointDeviceQry qry);
}

View File

@ -1,18 +0,0 @@
package com.zcloud.fire.check.dto;
import com.alibaba.cola.dto.PageQuery;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
*
*/
@Data
public class FireCheckListScreenQry extends PageQuery {
@ApiModelProperty(value = "企业id", name = "corpinfoId")
private Long corpinfoId;
@ApiModelProperty(value = "港区1:秦皇岛港区,2:秦皇岛东,3:秦皇岛西", name = "portArea")
private Integer portArea;
}

View File

@ -1,32 +0,0 @@
package com.zcloud.fire.check.dto;
import com.alibaba.cola.dto.PageQuery;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
/**
*
*/
@Data
public class FirePointDeviceQry extends PageQuery {
@ApiModelProperty(value = "企业id", name = "corpinfoId")
private Long corpinfoId;
@ApiModelProperty(value = "港区1:秦皇岛港区,2:秦皇岛东,3:秦皇岛西", name = "portArea")
private Integer portArea;
@ApiModelProperty(value = "消防设备类型", name = "fireDeviceType")
private String fireDeviceType;
@ApiModelProperty(value = "关键字", name = "vagueKey")
private String vagueKey;
@ApiModelProperty(value = "企业类型列表", name = "inType")
private List<Integer> inType;
@ApiModelProperty(value = "企业类型1监管 2企业 3相关方", name = "enterpriseType")
private Integer enterpriseType;
}

View File

@ -1,73 +0,0 @@
package com.zcloud.fire.check.dto.clientobject;
import com.alibaba.cola.dto.ClientObject;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.time.LocalDateTime;
/**
*
*/
@Data
public class FireCheckListScreenCO extends ClientObject {
@ApiModelProperty(value = "主键")
private Long id;
@ApiModelProperty(value = "业务主键id")
private String fireCheckId;
@ApiModelProperty(value = "企业id")
private Long corpinfoId;
@ApiModelProperty(value = "消防点检表名字")
private String fireCheckName;
@ApiModelProperty(value = "消防点检表类型")
private String fireCheckType;
@ApiModelProperty(value = "消防点检表类型名称")
private String fireCheckTypeName;
@ApiModelProperty(value = "启用状态0:启用,1:禁用")
private Integer state;
@ApiModelProperty(value = "检查照片上传方式1:相机拍照,2:相册获取")
private Integer photoUploadMethod;
@ApiModelProperty(value = "负责人,逗号分隔")
private String userName;
@ApiModelProperty(value = "点位数")
private Long firePointCount;
@ApiModelProperty(value = "检查状态1:未检查,2:已检查")
private Integer checkStatus;
@ApiModelProperty(value = "检查状态名称")
private String checkStatusName;
@ApiModelProperty(value = "周期内检查次数")
private Long checkCycleCount;
@ApiModelProperty(value = "周期开始时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime checkStartTime;
@ApiModelProperty(value = "周期结束时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime checkEndTime;
@ApiModelProperty(value = "创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime createTime;
@ApiModelProperty(value = "更新时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime updateTime;
}

View File

@ -1,20 +0,0 @@
package com.zcloud.fire.check.dto.clientobject;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
*
*/
@Data
public class FirePointDeviceCO extends FirePointCO {
@ApiModelProperty(value = "消防设备类型")
private String fireDeviceType;
@ApiModelProperty(value = "消防设备类型名称")
private String fireDeviceTypeName;
@ApiModelProperty(value = "数量")
private Long deviceCount;
}

View File

@ -52,9 +52,6 @@ public class CorpInfoDO extends BaseDO {
@ApiModelProperty(value = "所属区域")
private String companyArea;
@ApiModelProperty(value = "港区1:秦皇岛港区,2:秦皇岛东,3:秦皇岛西")
private Integer portArea;
//规模
@ApiModelProperty(value = "规模")
private String scale;

View File

@ -70,14 +70,6 @@ public class FireCheckListDO extends BaseDO {
@TableField(exist = false)
private String checkCycleCount;
@ApiModelProperty(value = "点位数")
@TableField(exist = false)
private Long firePointCount;
@ApiModelProperty(value = "港区")
@TableField(exist = false)
private Integer portArea;
public FireCheckListDO(String fireCheckId) {
this.fireCheckId = fireCheckId;
}

View File

@ -1,16 +0,0 @@
package com.zcloud.fire.check.persistence.dataobject;
import lombok.Data;
/**
*
*/
@Data
public class FirePointDeviceCountDO extends FirePointDO {
private String fireDeviceType;
private String fireDeviceTypeName;
private Long deviceCount;
}

View File

@ -28,8 +28,6 @@ import java.util.Map;
})
public interface FireCheckListMapper extends BaseMapper<FireCheckListDO> {
IPage<FireCheckListDO> screenList(IPage<FireCheckListDO> iPage, Map<String, Object> params, DateTimeE dateTimeE);
FireCheckListDO getInfoById(Long id);
IPage<FireCheckListDO> listPage(IPage<FireCheckListDO> iPage, Map<String, Object> params, String menuPerms);

View File

@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.jjb.saas.framework.datascope.annotation.DataScope;
import com.jjb.saas.framework.datascope.annotation.DataScopes;
import com.zcloud.fire.check.persistence.dataobject.DataStatisticDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDeviceCountDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointStatisticDO;
import org.apache.ibatis.annotations.Mapper;
@ -36,7 +35,5 @@ public interface FirePointMapper extends BaseMapper<FirePointDO> {
List<DataStatisticDO> countByCorpinfoIds(List<Long> corpinfoIds);
Long getFirePointCount(Map<String, Object> params);
IPage<FirePointDeviceCountDO> listDevice(IPage<FirePointDeviceCountDO> iPage, Map<String, Object> params);
}

View File

@ -18,8 +18,6 @@ import java.util.Map;
* @Date 2025-11-28 10:32:09
*/
public interface FireCheckListRepository extends BaseRepository<FireCheckListDO> {
PageResponse<FireCheckListDO> screenList(Map<String, Object> params);
PageResponse<FireCheckListDO> listPage(Map<String, Object> params);
FireCheckListDO getInfoById(Long id);

View File

@ -3,7 +3,6 @@ package com.zcloud.fire.check.persistence.repository;
import com.alibaba.cola.dto.PageResponse;
import com.jjb.saas.framework.repository.repo.BaseRepository;
import com.zcloud.fire.check.persistence.dataobject.DataStatisticDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDeviceCountDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDO;
import javax.validation.constraints.NotEmpty;
@ -41,6 +40,5 @@ public interface FirePointRepository extends BaseRepository<FirePointDO> {
List<DataStatisticDO> countByCorpinfoIds(List<Long> corpinfoIds);
FirePointDO getInfoByCode(@NotEmpty(message = "消防点位编码不能为空") String firePointCode);
PageResponse<FirePointDeviceCountDO> listDevice(Map<String, Object> params);
}

View File

@ -39,15 +39,6 @@ public class FireCheckListRepositoryImpl extends BaseRepositoryImpl<FireCheckLis
private final FireCheckListMapper fireCheckListMapper;
private final CorpInfoRepository corpInfoRepository;
@Override
public PageResponse<FireCheckListDO> screenList(Map<String, Object> params) {
IPage<FireCheckListDO> iPage = new Query<FireCheckListDO>().getPage(params);
FireCheckListE fireCheckListE = new FireCheckListE();
DateTimeE dateTimeE = fireCheckListE.getCheckRecordInterval(null);
IPage<FireCheckListDO> result = fireCheckListMapper.screenList(iPage, params, dateTimeE);
return PageHelper.pageToResponse(result, result.getRecords());
}
@Override
public PageResponse<FireCheckListDO> listPage(Map<String, Object> params) {
IPage<FireCheckListDO> iPage = new Query<FireCheckListDO>().getPage(params);

View File

@ -11,7 +11,6 @@ import com.zcloud.fire.check.domain.enums.FireRegionStateEnum;
import com.zcloud.fire.check.domain.enums.MenuEnum;
import com.zcloud.fire.check.domain.enums.UserTypeEnum;
import com.zcloud.fire.check.persistence.dataobject.DataStatisticDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDeviceCountDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointDO;
import com.zcloud.fire.check.persistence.dataobject.FirePointStatisticDO;
import com.zcloud.fire.check.persistence.dataobject.FireRegionDO;
@ -137,12 +136,5 @@ public class FirePointRepositoryImpl extends BaseRepositoryImpl<FirePointMapper,
public List<DataStatisticDO> countByCorpinfoIds(List<Long> corpinfoIds) {
return firePointMapper.countByCorpinfoIds(corpinfoIds);
}
@Override
public PageResponse<FirePointDeviceCountDO> listDevice(Map<String, Object> params) {
IPage<FirePointDeviceCountDO> iPage = new Query<FirePointDeviceCountDO>().getPage(params);
IPage<FirePointDeviceCountDO> result = firePointMapper.listDevice(iPage, params);
return PageHelper.pageToResponse(result, result.getRecords());
}
}

View File

@ -3,43 +3,6 @@
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zcloud.fire.check.persistence.mapper.FireCheckListMapper">
<select id="screenList" resultType="com.zcloud.fire.check.persistence.dataobject.FireCheckListDO">
select
cl.*,
ci.port_area as portArea,
GROUP_CONCAT(DISTINCT u.name) AS userName,
COUNT(DISTINCT cli.fire_point_id) AS firePointCount,
COUNT(DISTINCT cr.id) AS checkCycleCount
from fire_check_list cl
left join corp_info ci on cl.corpinfo_id = ci.id and ci.delete_enum = 'FALSE'
left join fire_check_list_user fclu on cl.fire_check_id = fclu.fire_check_id and fclu.delete_enum = 'FALSE'
left join user u on fclu.user_id = u.id and u.delete_enum = 'FALSE'
left join fire_check_list_item cli on cl.fire_check_id = cli.fire_check_id and cli.delete_enum = 'FALSE'
left join fire_check_record cr on cl.fire_check_id = cr.fire_check_id
and cr.delete_enum = 'FALSE'
and cr.finished_flag = 1
and (
(cl.fire_check_type = 'fireCheckPeriod0001' and cr.check_time <![CDATA[>=]]> #{dateTimeE.dayStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.dayEndTime})
or (cl.fire_check_type = 'fireCheckPeriod0002' and cr.check_time <![CDATA[>=]]> #{dateTimeE.weeklyStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.weeklyEndTime})
or (cl.fire_check_type = 'fireCheckPeriod0003' and cr.check_time <![CDATA[>=]]> #{dateTimeE.tenDaysStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.tenDaysEndTime})
or (cl.fire_check_type = 'FireCheckPeriod0004' and cr.check_time <![CDATA[>=]]> #{dateTimeE.monthlyStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.monthlyEndTime})
or (cl.fire_check_type = 'fireCheckPeriod0005' and cr.check_time <![CDATA[>=]]> #{dateTimeE.quarterlyStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.quarterlyEndTime})
or (cl.fire_check_type = 'fireCheckPeriod0006' and cr.check_time <![CDATA[>=]]> #{dateTimeE.yearlyStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.yearlyEndTime})
or (cl.fire_check_type = 'fireCheckPeriod0007' and cr.check_time <![CDATA[>=]]> #{dateTimeE.halfYearStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.halfYearEndTime})
or (cl.fire_check_type = 'fireCheckPeriod0008' and cr.check_time <![CDATA[>=]]> #{dateTimeE.halfMonthStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.halfMonthEndTime})
or (cl.fire_check_type = 'fireCheckPeriod0009' and cr.check_time <![CDATA[>=]]> #{dateTimeE.weeklyStartTime} and cr.check_time <![CDATA[<=]]> #{dateTimeE.weeklyEndTime})
)
where cl.delete_enum = 'FALSE' and cl.state = 0
<if test="params.corpinfoId != null">
and cl.corpinfo_id = #{params.corpinfoId}
</if>
<if test="params.portArea != null">
and ci.port_area = #{params.portArea}
</if>
group by cl.fire_check_id
order by cl.create_time desc
</select>
<select id="getInfoById" resultType="com.zcloud.fire.check.persistence.dataobject.FireCheckListDO">
select cl.*,
fclu.department_id as departmentId ,
@ -62,7 +25,7 @@
d.name AS departmentName,
GROUP_CONCAT(DISTINCT u.name) AS userName
FROM fire_check_list cl
LEFT JOIN fire_check_list_user fclu on cl.fire_check_id = fclu.fire_check_id and fclu.delete_enum='FALSE'
LEFT JOIN fire_check_list_user fclu on cl.fire_check_id = fclu.fire_check_id
LEFT JOIN department d ON fclu.department_id = d.id AND d.delete_enum = 'FALSE'
LEFT JOIN user u ON fclu.user_id = u.id AND u.delete_enum = 'FALSE'
WHERE cl.delete_enum = 'FALSE'

View File

@ -101,41 +101,5 @@
and c.use_flag = 1
and p.delete_enum = 'FALSE'
</select>
<select id="listDevice" resultType="com.zcloud.fire.check.persistence.dataobject.FirePointDeviceCountDO">
select
p.*,
d.fire_device_type as fireDeviceType,
d.fire_device_type_name as fireDeviceTypeName,
count(d.fire_device_id) as deviceCount
from fire_point p
inner join fire_device d on d.fire_point_id = p.fire_point_id and d.delete_enum = 'FALSE'
left join corp_info c on p.corpinfo_id = c.id and c.delete_enum = 'FALSE'
where p.delete_enum = 'FALSE'
<if test="params.corpinfoId != null">
and p.corpinfo_id = #{params.corpinfoId}
</if>
<if test="params.portArea != null">
and c.port_area = #{params.portArea}
</if>
<if test="params.fireDeviceType != null and params.fireDeviceType != ''">
and d.fire_device_type = #{params.fireDeviceType}
</if>
<if test="params.vagueKey != null and params.vagueKey != ''">
and (
p.fire_point_name like concat('%', #{params.vagueKey}, '%')
or p.fire_point_code like concat('%', #{params.vagueKey}, '%')
or d.fire_device_code like concat('%', #{params.vagueKey}, '%')
or d.fire_device_type_name like concat('%', #{params.vagueKey}, '%')
)
</if>
<if test="params.inType != null and !params.inType.isEmpty()">
and c.type in
<foreach collection="params.inType" item="item" open="(" close=")" separator=",">
#{item}
</foreach>
</if>
group by p.id, d.fire_device_type, d.fire_device_type_name
order by p.fire_point_name asc, d.fire_device_type_name asc
</select>
</mapper>