package com.gk.firework.Service.ServiceImpl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gk.firework.Domain.Enterprise;
|
import com.gk.firework.Domain.Enum.HiddenDangerReportStatus;
|
import com.gk.firework.Domain.Exception.BusinessException;
|
import com.gk.firework.Domain.HiddenDangerReport;
|
import com.gk.firework.Domain.HiddenDangerReportDetail;
|
import com.gk.firework.Domain.UserInfo;
|
import com.gk.firework.Domain.Utils.FilterObject;
|
import com.gk.firework.Domain.Utils.Properties;
|
import com.gk.firework.Domain.Utils.StringUtils;
|
import com.gk.firework.Domain.Utils.UploadUtil;
|
import com.gk.firework.Domain.Vo.CheckReportVo;
|
import com.gk.firework.Domain.Vo.HiddenDangerTableRow;
|
import com.gk.firework.Mapper.HiddenDangerReportMapper;
|
import com.gk.firework.Service.EnterpriseService;
|
import com.gk.firework.Service.HiddenDangerReportDetailService;
|
import com.gk.firework.Service.HiddenDangerReportService;
|
import com.gk.firework.Service.UserService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.util.*;
|
|
@Service("hiddenDangerReportService")
|
public class HiddenDangerReportServiceImpl extends ServiceImpl<HiddenDangerReportMapper, HiddenDangerReport> implements HiddenDangerReportService {
|
|
@Autowired
|
private EnterpriseService enterpriseService;
|
@Autowired
|
private HiddenDangerReportDetailService hiddenDangerReportDetailService;
|
@Autowired
|
private HiddenDangerReportMapper hiddenDangerReportMapper;
|
@Autowired
|
private UserService userService;
|
|
|
|
/**
|
* @Description: 提交自检报告
|
* @date 2021/4/8 14:58
|
*/
|
@Override
|
@Transactional
|
public void addCheck(CheckReportVo checkReportVo, UserInfo user) {
|
|
//自检报告基本信息
|
HiddenDangerReport report = new HiddenDangerReport();
|
{
|
//自动生成code
|
report.setCode("SR"+System.currentTimeMillis());
|
report.setApplyperson(checkReportVo.getApplyperson());
|
report.setCreateby(user.getUsername());
|
report.setCreatetime(new Date());
|
report.setEnterpriseid(user.getId());
|
report.setEnterprisename(user.getUsername());
|
report.setStatus(HiddenDangerReportStatus.PENDING);
|
UserInfo userInfo = userService.getById(user.getId());
|
Enterprise enterprise = enterpriseService.getById(userInfo.getCompanyid());
|
assert enterprise != null;
|
report.setCycle(enterprise.getSelfrecordingcycle());
|
report.setEnterprisenumber(enterprise.getEnterprisenumber());
|
report.setMajornum(0);
|
report.setNormalnum(0);
|
report.setOverduenum(0);
|
report.setUndealnum(0);
|
report.setViewcount(0);
|
report.setTotalnum(0);
|
|
}
|
|
//新增自检已选选项
|
{
|
|
JSONArray jsonArray = JSONArray.parseArray(checkReportVo.getReport());
|
if (jsonArray != null) {
|
List<HiddenDangerTableRow> rows = jsonArray.toJavaList(HiddenDangerTableRow.class);
|
List<HiddenDangerReportDetail> adds;
|
if (rows != null && rows.size() > 0) {
|
adds = new ArrayList<>();
|
for (HiddenDangerTableRow row : rows) {
|
//合格
|
if (row.isQualified() && !row.isUnqualified()) {
|
HiddenDangerTableRow.Unqualified cu = row.getAnswer();
|
HiddenDangerReportDetail q = new HiddenDangerReportDetail();
|
q.setResultid(cu.getResultid());
|
q.setReportcode(report.getCode());
|
q.setValidflag(true);
|
q.setIsqualified(true);
|
q.setChecktypeid(row.getChecktypeid());
|
adds.add(q);
|
}
|
//不合格
|
if (row.isUnqualified() && !row.isQualified()) {
|
HiddenDangerTableRow.Unqualified cu = row.getAnswer();
|
//重大危险
|
if (cu.getLevel() == 2) {
|
report.setMajornum(report.getMajornum() + 1);
|
}else{
|
report.setNormalnum(report.getNormalnum() + 1);
|
}
|
//未处理完个数
|
if (cu.getRectifystatus() == 1) {
|
report.setUndealnum(report.getUndealnum() + 1);
|
}
|
|
HiddenDangerReportDetail uq = new HiddenDangerReportDetail();
|
uq.setChecktypeid(row.getChecktypeid());
|
uq.setResultid(cu.getResultid());
|
uq.setFindtime(cu.getFindtime());
|
uq.setLevel(cu.getLevel());
|
uq.setReportcode(report.getCode());
|
uq.setRectifyprincipal(cu.getRectifyprincipal());
|
uq.setMemo(cu.getMemo());
|
uq.setRectifycompletedate(cu.getRectifycompletedate());
|
uq.setRectifymeasure(cu.getRectifymeasure());
|
uq.setRectifydeadline(cu.getRectifydeadline());
|
uq.setRectifystatus(cu.getRectifystatus());
|
uq.setIsqualified(false);
|
uq.setValidflag(true);
|
uq.setUrl(cu.getUrl());
|
adds.add(uq);
|
|
}
|
}
|
|
if (adds.size() > 0) {
|
report.setTotalnum(adds.size());
|
hiddenDangerReportDetailService.saveBatch(adds);
|
}
|
|
}
|
|
}
|
|
|
|
|
}
|
//新增自检报告->执行
|
{
|
report.setValidflag(true);
|
this.save(report);
|
}
|
|
}
|
|
/**
|
* @Description: 报告统计分页
|
* @date 2021/4/8 18:31
|
*/
|
@Override
|
public IPage reportList(Page<HiddenDangerReport> page, Map filter,UserInfo user) {
|
|
UserInfo userInfo = userService.getById(user.getId());
|
|
Map<String, Object> params = new HashMap<>();
|
//监管部门（companyid = null）可视范围为已提交的，否则只能看自己提交的信息
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
params.put("committed", HiddenDangerReportStatus.COMMITTED);
|
// 过滤条件
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("cycle", filter.get("cycle"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("range", filter.get("range"));
|
List<HiddenDangerReport> list = hiddenDangerReportMapper.selectReportList(page, params);
|
if (list.size() > 0) {
|
for (HiddenDangerReport report : list) {
|
//过期并且未处理
|
report.setOverduenum(hiddenDangerReportDetailService.countOverdueByReportCode(report.getCode()));
|
}
|
}
|
return page.setRecords(list);
|
}
|
|
/**
|
* @Description: 根据Id获取单条自检报告
|
* @date 2021/4/8 18:38
|
*/
|
@Override
|
public List<HiddenDangerTableRow> getReport(String code) {
|
return hiddenDangerReportMapper.selectReport(code);
|
}
|
|
|
/**
|
* @Description: 修改报告
|
* @date 2021/4/9 10:09
|
*/
|
@Override
|
public void modReport(CheckReportVo checkReportVo, UserInfo user) {
|
|
HiddenDangerReport report = new HiddenDangerReport();
|
report.setId(checkReportVo.getReportid());
|
report.setApplyperson(checkReportVo.getApplyperson());
|
report.setMajornum(0);
|
report.setNormalnum(0);
|
report.setOverduenum(0);
|
report.setUndealnum(0);
|
report.setTotalnum(0);
|
|
|
JSONArray jsonArray = JSONArray.parseArray(checkReportVo.getReport());
|
if (jsonArray != null) {
|
List<HiddenDangerTableRow> rows = jsonArray.toJavaList(HiddenDangerTableRow.class);
|
List<HiddenDangerReportDetail> adds;
|
List<HiddenDangerReportDetail> upds2Unqualified;
|
List<HiddenDangerReportDetail> upds2Qualified;
|
List<HiddenDangerReportDetail> dels;
|
|
|
if (rows != null && rows.size() > 0) {
|
adds = new ArrayList<>();
|
upds2Unqualified = new ArrayList<>();
|
upds2Qualified = new ArrayList<>();
|
dels = new ArrayList<>();
|
for (HiddenDangerTableRow row : rows) {
|
//合格
|
HiddenDangerTableRow.Unqualified cu = row.getAnswer();
|
if (row.isQualified() && !row.isUnqualified()) {
|
HiddenDangerReportDetail q = new HiddenDangerReportDetail();
|
if (cu.getId() != null) {
|
q.setId(cu.getId());
|
q.setIsqualified(true);
|
q.setResultid(cu.getResultid());
|
upds2Qualified.add(q);
|
}else{
|
q.setResultid(cu.getResultid());
|
q.setReportcode(checkReportVo.getReportcode());
|
q.setValidflag(true);
|
q.setIsqualified(true);
|
q.setChecktypeid(row.getChecktypeid());
|
q.setReportcode(checkReportVo.getReportcode());
|
adds.add(q);
|
}
|
|
}
|
//不合格
|
if (row.isUnqualified() && !row.isQualified()) {
|
HiddenDangerReportDetail uq = new HiddenDangerReportDetail();
|
|
//重大危险
|
if (cu.getLevel() == 2) {
|
report.setMajornum(report.getMajornum() + 1);
|
}else{
|
report.setNormalnum(report.getNormalnum() + 1);
|
}
|
//未处理完个数
|
if (cu.getRectifystatus() == 1) {
|
report.setUndealnum(report.getUndealnum() + 1);
|
}
|
uq.setChecktypeid(row.getChecktypeid());
|
uq.setResultid(cu.getResultid());
|
uq.setFindtime(cu.getFindtime());
|
uq.setLevel(cu.getLevel());
|
uq.setReportcode(checkReportVo.getReportcode());
|
uq.setRectifyprincipal(cu.getRectifyprincipal());
|
uq.setMemo(cu.getMemo());
|
uq.setRectifystatus(cu.getRectifystatus());
|
uq.setLevel(cu.getLevel());
|
uq.setRectifycompletedate(cu.getRectifycompletedate());
|
uq.setRectifymeasure(cu.getRectifymeasure());
|
uq.setRectifydeadline(cu.getRectifydeadline());
|
uq.setUrl(cu.getUrl());
|
|
if (cu.getId() != null) {
|
uq.setId(cu.getId());
|
uq.setIsqualified(false);
|
upds2Unqualified.add(uq);
|
}else{
|
uq.setIsqualified(false);
|
uq.setValidflag(true);
|
adds.add(uq);
|
}
|
|
|
}
|
|
//删除数据
|
if (!row.isUnqualified() && !row.isQualified()) {
|
if (cu.getId() != null) {
|
HiddenDangerReportDetail deleteOne = new HiddenDangerReportDetail();
|
deleteOne.setId(cu.getId());
|
deleteOne.setValidflag(false);
|
dels.add(deleteOne);
|
}
|
}
|
}
|
|
|
|
|
if (adds.size() > 0) {
|
hiddenDangerReportDetailService.saveBatch(adds);
|
}
|
|
if (upds2Unqualified.size() > 0) {
|
hiddenDangerReportDetailService.updateBatchById(upds2Unqualified);
|
}
|
|
if (upds2Qualified.size() > 0) {
|
hiddenDangerReportDetailService.update2Qualified(upds2Qualified);
|
}
|
|
report.setTotalnum(adds.size() + upds2Unqualified.size() + upds2Qualified.size());
|
|
if (dels.size() > 0) {
|
hiddenDangerReportDetailService.updateBatchById(dels);
|
}
|
|
}
|
|
this.updateById(report);
|
|
}
|
|
|
}
|
|
/**
|
* @Description: 文件上传
|
* @date 2021/4/9 14:57
|
*/
|
@Override
|
public String upload(MultipartFile file) {
|
try {
|
String name = UploadUtil.uploadFile(file, Properties.transportCertificatePath);
|
return Properties.transportCertificate + name;
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new BusinessException("上传文件失败，请联系管理员");
|
}
|
}
|
|
/**
|
* @Description: 查看检查单子
|
* @date 2021/4/13 10:12
|
*/
|
@Override
|
public List<HiddenDangerTableRow> viewReport(String code) {
|
|
return hiddenDangerReportMapper.viewReport(code);
|
}
|
|
|
/**
|
* @Description: 提交单子，更新单子状态->已提交
|
* @date 2021/4/13 9:41
|
*/
|
@Override
|
public void commitReport(String code) {
|
hiddenDangerReportMapper.updateStatusByCode(HiddenDangerReportStatus.COMMITTED,code);
|
}
|
|
|
/**
|
* @Description: 修改检查
|
* @date 2021/4/13 10:12
|
*/
|
@Override
|
public void checkMod(CheckReportVo checkReportVo) {
|
HiddenDangerReport report = this.getById(checkReportVo.getReportid());
|
if (report.getStatus() == HiddenDangerReportStatus.COMMITTED) {
|
throw new BusinessException("已提交状态无法修改");
|
}
|
|
}
|
|
/**
|
* @Description: 重复提交判断
|
* @date 2021/4/13 10:10
|
*/
|
@Override
|
public void checkCommit(String code) {
|
HiddenDangerReport report = this.getReportByCode(code);
|
if (report.getStatus() == HiddenDangerReportStatus.COMMITTED) {
|
throw new BusinessException("不能重复提交");
|
}
|
}
|
|
/**
|
* @Description: 根据code获取单子的基本数据
|
* @date 2021/4/13 10:12
|
*/
|
@Override
|
public HiddenDangerReport getReportByCode(String code) {
|
return hiddenDangerReportMapper.getReportByCode(code);
|
}
|
|
|
|
/**
|
* @Description: 报告新增不能为空
|
* @date 2021/4/15 16:47
|
*/
|
@Override
|
public void checkAdd(CheckReportVo checkReportVo, UserInfo user) {
|
if (StringUtils.isBlank(user.getCompanynumber())) {
|
throw new BusinessException("没有权限新建");
|
}
|
|
if (StringUtils.isBlank(checkReportVo.getApplyperson())) {
|
throw new BusinessException("报告人不能为空");
|
}
|
}
|
|
/**
|
* @Description: 导出隐患自检目录
|
* @date 2021/4/19 16:39
|
*/
|
@Override
|
public List<Map> selectExportReport(Map filter, UserInfo user) {
|
|
UserInfo userInfo = userService.getById(user.getId());
|
|
Map<String, Object> params = new HashMap<>();
|
//监管部门（companyid = null）可视范围为已提交的，否则只能看自己提交的信息
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
params.put("committed", HiddenDangerReportStatus.COMMITTED);
|
// 过滤条件
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("cycle", filter.get("cycle"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("range", filter.get("range"));
|
|
List<Map> reports = hiddenDangerReportMapper.selectExportReport(params);
|
if (reports.size() > 0) {
|
for (Map report : reports) {
|
report.put("overduenum", hiddenDangerReportDetailService.countOverdueByReportCode((String) report.get("code")));
|
}
|
}
|
return reports;
|
}
|
}
|
