lixu
/
tang_shan_task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

超标排放信息 

附图附件-自行监测布点图
污染物实际排放计算过程
台账管理情况表
main
hehongyu 2023-08-12 20:10:31 +08:00
parent 40070ca34d
commit d7ccc8a74c
25 changed files with 909 additions and 419 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
.idea/MyBatisCodeHelperDatasource.xml
View File

@ -63,6 +63,43 @@
<option name="insertMethodEnabled" value="false" />
<option name="insertSelectiveMethodEnabled" value="false" />
<option name="javaModelName" value="MAmProblemFi" />
<option name="moduleName" value="talroad-demo" />
<option name="selectByPrimaryKeyEnabled" value="false" />
<option name="sequenceColumn" value="" />
<option name="sequenceId" value="" />
<option name="updateByPrimaryKeySelectiveEnabled" value="false" />
<option name="updateByPrimaykeyEnabled" value="false" />
<option name="useActualColumnName" value="false" />
</TableGenerateConfig>
</value>
</entry>
<entry key="public:ods_permission_sharereportattachment_a">
<value>
<TableGenerateConfig>
<option name="deleteByPrimayKeyEnabled" value="false" />
<option name="generatedKey" value="" />
<option name="insertMethodEnabled" value="false" />
<option name="insertSelectiveMethodEnabled" value="false" />
<option name="javaModelName" value="OdsPermissionSharereportattachmentA" />
<option name="moduleName" value="talroad-demo" />
<option name="selectByPrimaryKeyEnabled" value="false" />
<option name="sequenceColumn" value="" />
<option name="sequenceId" value="" />
<option name="updateByPrimaryKeySelectiveEnabled" value="false" />
<option name="updateByPrimaykeyEnabled" value="false" />
<option name="useActualColumnName" value="false" />
</TableGenerateConfig>
</value>
</entry>
<entry key="public:ods_permission_sharereportledgerinfo_ledgerinfo_a">
<value>
<TableGenerateConfig>
<option name="deleteByPrimayKeyEnabled" value="false" />
<option name="generatedKey" value="" />
<option name="insertMethodEnabled" value="false" />
<option name="insertSelectiveMethodEnabled" value="false" />
<option name="javaModelName" value="OdsPermissionSharereportledgerinfoLedgerinfoA" />
<option name="moduleName" value="talroad-demo" />
<option name="selectByPrimaryKeyEnabled" value="false" />
<option name="sequenceColumn" value="" />
<option name="sequenceId" value="" />
@ -77,7 +114,6 @@
<option name="updateByPrimaryKeySelectiveEnabled" value="false" />
<option name="updateByPrimaykeyEnabled" value="false" />
<option name="useSwagger" value="true" />
<option name="userMybatisPlus" value="true" />
<option name="xmlMapperPackage" value="mapper.talroad" />
<option name="xmlMapperPath" value="$PROJECT_DIR$/szhpt-fixed-task/src/main/resources" />
</ProjectProfile>

7
.idea/dataSources.xml
View File

@ -8,5 +8,12 @@
<jdbc-url>jdbc:postgresql://10.0.200.170:5432/s_integrated_fixed_source?useUnicode=true&amp;characterEncoding=UTF-8&amp;allowMultiQueries=true&amp;serverTimezone=Asia/Shanghai</jdbc-url>
<working-dir>$ProjectFileDir$</working-dir>
</data-source>
<data-source source="LOCAL" name="PostgreSQL - postgres@39.100.149.153" uuid="ec83ab36-2f7f-4484-ba53-96f13bba69bd">
<driver-ref>postgresql</driver-ref>
<synchronize>true</synchronize>
<jdbc-driver>org.postgresql.Driver</jdbc-driver>
<jdbc-url>jdbc:postgresql://39.100.149.153:5432/postgres</jdbc-url>
<working-dir>$ProjectFileDir$</working-dir>
</data-source>
</component>
</project>

4
szhpt-fixed-task/src/main/java/cn/cecep/talroad/controller/callback/AmProblemFiCallbackController.java
View File

@ -6,7 +6,7 @@ import cn.cecep.talroad.domain.AmProblemFiProcess;
import cn.cecep.talroad.service.IAmProblemFiService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.junit.jupiter.api.Disabled;
//import org.junit.jupiter.api.Disabled;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
@ -37,7 +37,7 @@ public class AmProblemFiCallbackController extends BasesController {
@ApiOperation(value = "审核结果回调")
@PostMapping(value = "/audit/result")
@Disabled
// @Disabled
public AjaxResults auditResult(@RequestBody @Validated AmProblemFiProcess param) {
amProblemFiService.auditResult(param);
return AjaxResults.success();

4
szhpt-fixed-task/src/main/java/cn/cecep/talroad/controller/effective/ERmStationExceedController.java
View File

@ -14,7 +14,7 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.junit.jupiter.api.Disabled;
//import org.junit.jupiter.api.Disabled;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.web.bind.annotation.GetMapping;
@ -51,7 +51,7 @@ public class ERmStationExceedController {
@GetMapping("/selectInfo")
@ApiOperation("查询站点信息--弃用，使用接口 POST station/detail/air/{id}")
@Disabled("使用cn.cecep.talroad.controller.TCodStationController.airStationDetail")
// @Disabled("使用cn.cecep.talroad.controller.TCodStationController.airStationDetail")
public AjaxResults<ERmStationHour> selectInfo(@RequestParam(name = "stationCode") String stationCode) {
QueryWrapper<ERmStationHour> ew = new QueryWrapper<>();
ew.eq(ERmStationHour.COL_STATION_CODE, stationCode);

98
szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/ExcessiveEmissionsService.java
View File

@ -1,15 +1,30 @@
package cn.cecep.talroad.data.analyse.task.execute.report.specifications.audit;
import cn.cecep.talroad.domain.AmProblemFi;
import cn.cecep.talroad.domain.BMainActionReports;
import cn.cecep.talroad.domain.PcOutlet;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditRecord;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditResult;
import cn.cecep.talroad.domain.analysis.SRaSelfMonitoringData;
import cn.cecep.talroad.enums.EmlTypeEnums;
import cn.cecep.talroad.enums.ProblemTypeEnum;
import cn.cecep.talroad.mapper.AmProblemFiMapper;
import cn.cecep.talroad.mapper.BMainActionReportsMapper;
import cn.cecep.talroad.mapper.PcOutletMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditRecordMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditResultMapper;
import cn.cecep.talroad.mapper.analysis.SRaSelfMonitoringDataMapper;
import cn.cecep.talroad.util.DateUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.*;
import java.util.stream.Collectors;
/**
* @author hehongyu
@ -26,6 +41,17 @@ public class ExcessiveEmissionsService {
@Autowired
private BMainActionReportsMapper actionReportsMapper;
@Autowired
private SRaSelfMonitoringDataMapper monitoringDataMapper;
@Autowired
private AmProblemFiMapper problemFiMapper;
@Autowired
private SRaActionReportsAuditRecordMapper recordMapper;
@Autowired
private PcOutletMapper outletMapper;
public void execute(List<String> reportIds){
LambdaQueryWrapper<BMainActionReports> queryWrapper = new QueryWrapper<BMainActionReports>().lambda()
@ -35,9 +61,75 @@ public class ExcessiveEmissionsService {
String factoryId = bMainActionReport.getFactoryId();
String reportsType = bMainActionReport.getReportsType();//EmlTypeEnums
//根据 企业id 加 报告周期 查询到对应报警信息表 是否有超标信息
//按照报表审核类型的时间 为 查询数据开始的时间
Calendar startCalendar = Calendar.getInstance();
Calendar endCalendar = Calendar.getInstance();
if (EmlTypeEnums.YEAR.getCode().equals(reportsType)) {
//去年 开始的数据 到今年的数据
startCalendar.setTime(DateUtil.parseTime(startCalendar.get(Calendar.YEAR) - 1 + "-01-01 00:00:00"));
endCalendar.setTime(DateUtil.parseTime(endCalendar.get(Calendar.YEAR) + "-01-01 00:00:00"));
}else if (EmlTypeEnums.QUARTER.getCode().equals(reportsType)) {
//获取上季度的数据 此处获取到当前季度开始的日期 手动去-3月 上季度结束日期 就是本季度开始
startCalendar.setTime(DateUtil.getQuarterStart(new Date()));
startCalendar.set(Calendar.MONTH,startCalendar.get(Calendar.MONTH) - 3);
endCalendar.setTime(DateUtil.getQuarterStart(new Date()));
}else if (EmlTypeEnums.MONTH.getCode().equals(reportsType)) {
//上月开始 到 这月结束的数据
startCalendar.set(Calendar.DAY_OF_MONTH,0);
DateUtil.setTimeZero(startCalendar);
endCalendar.set(Calendar.DAY_OF_MONTH,1);
DateUtil.setTimeZero(endCalendar);
startCalendar.set(Calendar.MONTH,startCalendar.get(Calendar.MONTH) - 1);
}
Date endTime = endCalendar.getTime();
Date startTime = startCalendar.getTime();
//直接查询企业下 所有超标的站点和 污染物 然后去 执行报告进行匹配
LambdaQueryWrapper<AmProblemFi> problemFiLambdaQueryWrapper = new QueryWrapper<AmProblemFi>().lambda()
.eq(AmProblemFi::getFactoryId, factoryId)
.eq(AmProblemFi::getProblemType, ProblemTypeEnum.CONCENTRATION_EXCEEDED_TYPE.getCode())
.between(AmProblemFi::getAnalyseTime, startTime, endTime);
List<AmProblemFi> mAmProblemFis = problemFiMapper.selectList(problemFiLambdaQueryWrapper);
if (CollectionUtil.isEmpty(mAmProblemFis)){
log.warn("超标排放信息 无报警信息！bMainActionReport:{}", JSON.toJSONString(bMainActionReport));
continue;
}
for (AmProblemFi mAmProblemFi : mAmProblemFis) {
LambdaQueryWrapper<SRaSelfMonitoringData> dataLambdaQueryWrapper = new QueryWrapper<SRaSelfMonitoringData>().lambda()
.eq(SRaSelfMonitoringData::getFactoryId, mAmProblemFi.getFactoryId())
.eq(SRaSelfMonitoringData::getMonitorId, mAmProblemFi.getStationId())
//现有的报警内容中有污染物名称 直接根据污染物名称进行查询
.eq(SRaSelfMonitoringData::getPollutantsName, mAmProblemFi.getParamName())
.between(SRaSelfMonitoringData::getMonitorTime, startTime, endTime);
List<SRaSelfMonitoringData> sRaSelfMonitoringData = monitoringDataMapper.selectList(dataLambdaQueryWrapper);
//如果有该企业有报警信息 但是根据报警信息中的站点和污染物没有查询到实际数据 则认为是不规范
if (CollectionUtil.isEmpty(sRaSelfMonitoringData)){
//转换一下排口id 和 code 将 排口编号 输出到提示内容里面
PcOutlet pcOutlet = outletMapper.selectOne(new QueryWrapper<PcOutlet>().lambda().select(PcOutlet::getOutletCode).eq(PcOutlet::getId, mAmProblemFi.getStationId()));
//报告id 排口编号 污染物名称
updateReportAuditData(bMainActionReport.getId(),pcOutlet.getOutletCode(),mAmProblemFi.getParamName());
}
}
}
}
public void updateReportAuditData(String problemReportId,String outletCode, String pollutantsName){
LambdaQueryWrapper<SRaActionReportsAuditRecord> recordQueryWrapper = new QueryWrapper<SRaActionReportsAuditRecord>()
.lambda()
.select(SRaActionReportsAuditRecord::getId,SRaActionReportsAuditRecord::getReportId)
.eq(SRaActionReportsAuditRecord::getReportId, problemReportId);
List<SRaActionReportsAuditRecord> sRaActionReportsAuditRecords = recordMapper.selectList(recordQueryWrapper);
if (CollectionUtil.isEmpty(sRaActionReportsAuditRecords)){
log.warn("执行报告审核记录不存在！");
return;
}
List<String> recordIds = sRaActionReportsAuditRecords.stream().map(SRaActionReportsAuditRecord::getId).collect(Collectors.toList());
LambdaQueryWrapper<SRaActionReportsAuditResult> queryWrapper = new QueryWrapper<SRaActionReportsAuditResult>().lambda().in(SRaActionReportsAuditResult::getRecordId, recordIds);
List<SRaActionReportsAuditResult> sRaActionReportsAuditResults = mapper.selectList(queryWrapper);
if (CollectionUtil.isEmpty(sRaActionReportsAuditResults)){
log.warn("执行报告规范性审核结果记录不存在！");
return;
}
sRaActionReportsAuditResults.forEach(data -> data.setAttachment("“"+outletCode+"”“"+pollutantsName+"”在执行周期内有超标排放信息，但是此表未填报。"));
mapper.batchUpdate(sRaActionReportsAuditResults);
}
}

54
szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/LedgerManagementStatusTableService.java
View File

@ -1,9 +1,21 @@
package cn.cecep.talroad.data.analyse.task.execute.report.specifications.audit;
import cn.cecep.talroad.domain.OdsPermissionSharereportledgerinfoLedgerinfoA;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditRecord;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditResult;
import cn.cecep.talroad.mapper.OdsPermissionSharereportledgerinfoLedgerinfoAMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditRecordMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditResultMapper;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @author hehongyu
@ -13,9 +25,51 @@ import java.util.List;
@Slf4j
@Service
public class LedgerManagementStatusTableService {
@Autowired
private SRaActionReportsAuditResultMapper mapper;
@Autowired
private SRaActionReportsAuditRecordMapper recordMapper;
@Autowired
private OdsPermissionSharereportledgerinfoLedgerinfoAMapper sharereportattachmentAMapper;
public void execute(List<String> reportIds){
LambdaQueryWrapper<SRaActionReportsAuditRecord> recordQueryWrapper = new QueryWrapper<SRaActionReportsAuditRecord>()
.lambda()
.select(SRaActionReportsAuditRecord::getId,SRaActionReportsAuditRecord::getReportId)
.in(SRaActionReportsAuditRecord::getReportId, reportIds);
List<SRaActionReportsAuditRecord> sRaActionReportsAuditRecords = recordMapper.selectList(recordQueryWrapper);
if (CollectionUtil.isEmpty(sRaActionReportsAuditRecords)){
log.warn("执行报告审核记录不存在！");
return;
}
//报告id 和 报告记录id映射
Map<String, String> reportIdMap = sRaActionReportsAuditRecords.stream().collect(Collectors.toMap(SRaActionReportsAuditRecord::getId, SRaActionReportsAuditRecord::getReportId));
List<String> recordIds = sRaActionReportsAuditRecords.stream().map(SRaActionReportsAuditRecord::getId).collect(Collectors.toList());
LambdaQueryWrapper<SRaActionReportsAuditResult> queryWrapper = new QueryWrapper<SRaActionReportsAuditResult>().lambda().in(SRaActionReportsAuditResult::getRecordId, recordIds);
List<SRaActionReportsAuditResult> sRaActionReportsAuditResults = mapper.selectList(queryWrapper);
if (CollectionUtil.isEmpty(sRaActionReportsAuditResults)){
log.warn("执行报告规范性审核结果记录不存在！");
return;
}
//未填“是否完整”则不完整
LambdaQueryWrapper<OdsPermissionSharereportledgerinfoLedgerinfoA> fileQueryWrapper = new QueryWrapper<OdsPermissionSharereportledgerinfoLedgerinfoA>()
.lambda().in(OdsPermissionSharereportledgerinfoLedgerinfoA::getReportid, reportIds);
List<OdsPermissionSharereportledgerinfoLedgerinfoA> odsPermissionSharereportattachmentAS = sharereportattachmentAMapper.selectList(fileQueryWrapper);
//过滤未填“是否完整”则不完整 报表id
List<String> notFileReportIds = odsPermissionSharereportattachmentAS.stream()
.filter(data -> !"Y".equals(data.getWhethercomplete()))
.map(OdsPermissionSharereportledgerinfoLedgerinfoA::getReportid)
.collect(Collectors.toList());
sRaActionReportsAuditResults.stream().filter(data -> {
String reportId = reportIdMap.get(data.getRecordId());
if (reportId == null){
return false;
}
return notFileReportIds.contains(reportId);
}).forEach(data -> data.setAttachment("台账管理情况表填报不完整"));
mapper.batchUpdate(sRaActionReportsAuditResults);
}
}

61
szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/PollutantEmissionsCalculationProcessService.java
View File

@ -1,9 +1,22 @@
package cn.cecep.talroad.data.analyse.task.execute.report.specifications.audit;
import cn.cecep.talroad.domain.OdsPermissionSharereportattachmentA;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditRecord;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditResult;
import cn.cecep.talroad.mapper.OdsPermissionSharereportattachmentAMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditRecordMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditResultMapper;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @author hehongyu
@ -14,8 +27,54 @@ import java.util.List;
@Service
public class PollutantEmissionsCalculationProcessService {
public void execute(List<String> reportIds){
@Autowired
private SRaActionReportsAuditResultMapper mapper;
@Autowired
private SRaActionReportsAuditRecordMapper recordMapper;
@Autowired
private OdsPermissionSharereportattachmentAMapper sharereportattachmentAMapper;
public void execute(List<String> reportIds){
LambdaQueryWrapper<SRaActionReportsAuditRecord> recordQueryWrapper = new QueryWrapper<SRaActionReportsAuditRecord>()
.lambda()
.select(SRaActionReportsAuditRecord::getId,SRaActionReportsAuditRecord::getReportId)
.in(SRaActionReportsAuditRecord::getReportId, reportIds);
List<SRaActionReportsAuditRecord> sRaActionReportsAuditRecords = recordMapper.selectList(recordQueryWrapper);
if (CollectionUtil.isEmpty(sRaActionReportsAuditRecords)){
log.warn("执行报告审核记录不存在！");
return;
}
//报告id 和 报告记录id映射
Map<String, String> reportIdMap = sRaActionReportsAuditRecords.stream().collect(Collectors.toMap(SRaActionReportsAuditRecord::getId, SRaActionReportsAuditRecord::getReportId));
List<String> recordIds = sRaActionReportsAuditRecords.stream().map(SRaActionReportsAuditRecord::getId).collect(Collectors.toList());
LambdaQueryWrapper<SRaActionReportsAuditResult> queryWrapper = new QueryWrapper<SRaActionReportsAuditResult>().lambda().in(SRaActionReportsAuditResult::getRecordId, recordIds);
List<SRaActionReportsAuditResult> sRaActionReportsAuditResults = mapper.selectList(queryWrapper);
if (CollectionUtil.isEmpty(sRaActionReportsAuditResults)){
log.warn("执行报告规范性审核结果记录不存在！");
return;
}
//污染物实际排放计算过程 未上传 则为不规范
LambdaQueryWrapper<OdsPermissionSharereportattachmentA> fileQueryWrapper = new QueryWrapper<OdsPermissionSharereportattachmentA>()
.lambda().in(OdsPermissionSharereportattachmentA::getReportid, reportIds)
.like(OdsPermissionSharereportattachmentA::getFilename,"实际排放计算过程");
List<OdsPermissionSharereportattachmentA> odsPermissionSharereportattachmentAS = sharereportattachmentAMapper.selectList(fileQueryWrapper);
//过滤没有附件的 报表id
List<Long> notFileReportIds = odsPermissionSharereportattachmentAS.stream().filter(data -> StringUtils.isBlank(data.getFastdfsid()))
.map(OdsPermissionSharereportattachmentA::getReportid)
.collect(Collectors.toList());
sRaActionReportsAuditResults
.stream().filter(data -> {
String reportId = reportIdMap.get(data.getRecordId());
if (reportId == null){
return false;
}
return notFileReportIds.contains(reportId);
}).forEach(data -> data.setAttachment("未上报自行监测布点图"));
mapper.batchUpdate(sRaActionReportsAuditResults);
}
}

31
szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/specifications/audit/SelfMonitoringLayoutMapService.java
View File

@ -1,7 +1,9 @@
package cn.cecep.talroad.data.analyse.task.execute.report.specifications.audit;
import cn.cecep.talroad.domain.OdsPermissionSharereportattachmentA;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditRecord;
import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditResult;
import cn.cecep.talroad.mapper.OdsPermissionSharereportattachmentAMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditRecordMapper;
import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditResultMapper;
import cn.hutool.core.collection.CollectionUtil;
@ -13,6 +15,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
@ -30,6 +33,9 @@ public class SelfMonitoringLayoutMapService {
@Autowired
private SRaActionReportsAuditRecordMapper recordMapper;
@Autowired
private OdsPermissionSharereportattachmentAMapper sharereportattachmentAMapper;
public void execute(List<String> reportIds){
LambdaQueryWrapper<SRaActionReportsAuditRecord> recordQueryWrapper = new QueryWrapper<SRaActionReportsAuditRecord>()
.lambda()
@ -40,6 +46,9 @@ public class SelfMonitoringLayoutMapService {
log.warn("执行报告审核记录不存在！");
return;
}
//报告id 和 报告记录id映射
Map<String, String> reportIdMap = sRaActionReportsAuditRecords.stream().collect(Collectors.toMap(SRaActionReportsAuditRecord::getId, SRaActionReportsAuditRecord::getReportId));
List<String> recordIds = sRaActionReportsAuditRecords.stream().map(SRaActionReportsAuditRecord::getId).collect(Collectors.toList());
LambdaQueryWrapper<SRaActionReportsAuditResult> queryWrapper = new QueryWrapper<SRaActionReportsAuditResult>().lambda().in(SRaActionReportsAuditResult::getRecordId, recordIds);
List<SRaActionReportsAuditResult> sRaActionReportsAuditResults = mapper.selectList(queryWrapper);
@ -47,10 +56,24 @@ public class SelfMonitoringLayoutMapService {
log.warn("执行报告规范性审核结果记录不存在！");
return;
}
//TODO 自行监测布点图 未上传 则为不规范
List<SRaActionReportsAuditResult> updateList = sRaActionReportsAuditResults.stream().filter(data -> StringUtils.isBlank(data.getAttachment())).collect(Collectors.toList());
updateList.forEach(data -> data.setAttachment("未上报自行监测布点图"));
mapper.batchUpdate(updateList);
//自行监测布点图 未上传 则为不规范
LambdaQueryWrapper<OdsPermissionSharereportattachmentA> fileQueryWrapper = new QueryWrapper<OdsPermissionSharereportattachmentA>()
.lambda().in(OdsPermissionSharereportattachmentA::getReportid, reportIds)
.eq(OdsPermissionSharereportattachmentA::getFiletype,"file3");
List<OdsPermissionSharereportattachmentA> odsPermissionSharereportattachmentAS = sharereportattachmentAMapper.selectList(fileQueryWrapper);
//过滤没有附件的 报表id
List<Long> notFileReportIds = odsPermissionSharereportattachmentAS.stream().filter(data -> StringUtils.isBlank(data.getFastdfsid()))
.map(OdsPermissionSharereportattachmentA::getReportid)
.collect(Collectors.toList());
sRaActionReportsAuditResults
.stream().filter(data -> {
String reportId = reportIdMap.get(data.getRecordId());
if (reportId == null){
return false;
}
return notFileReportIds.contains(reportId);
}).forEach(data -> data.setAttachment("未上报自行监测布点图"));
mapper.batchUpdate(sRaActionReportsAuditResults);
}
}

46
szhpt-fixed-task/src/main/java/cn/cecep/talroad/domain/OdsPermissionSharereportattachmentA.java 100644
View File

@ -0,0 +1,46 @@
package cn.cecep.talroad.domain;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* @description: TODO
* @author hehongyu
* @date 2023/8/12 18:33
*/
/**
* 执行报告-获取附件信息
*/
@ApiModel(description="执行报告-获取附件信息")
@Data
@AllArgsConstructor
@NoArgsConstructor
public class OdsPermissionSharereportattachmentA implements Serializable {
@ApiModelProperty(value="")
private Long reportid;
@ApiModelProperty(value="")
private Long fileid;
@ApiModelProperty(value="")
private String filename;
@ApiModelProperty(value="")
private String filesize;
@ApiModelProperty(value="")
private String filetype;
@ApiModelProperty(value="")
private String remark;
@ApiModelProperty(value="")
private String fastdfsid;
private static final long serialVersionUID = 1L;
}

43
szhpt-fixed-task/src/main/java/cn/cecep/talroad/domain/OdsPermissionSharereportledgerinfoLedgerinfoA.java 100644
View File

@ -0,0 +1,43 @@
package cn.cecep.talroad.domain;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* @description: TODO
* @author hehongyu
* @date 2023/8/12 18:34
*/
/**
* 执行报告-台账管理情况
*/
@ApiModel(description="执行报告-台账管理情况")
@Data
@AllArgsConstructor
@NoArgsConstructor
public class OdsPermissionSharereportledgerinfoLedgerinfoA implements Serializable {
@ApiModelProperty(value="")
private String reportid;
@ApiModelProperty(value="")
private String summary;
@ApiModelProperty(value="")
private String ledgerrecordname;
@ApiModelProperty(value="")
private String whethercomplete;
@ApiModelProperty(value="")
private String description;
@ApiModelProperty(value="")
private String reporttime;
private static final long serialVersionUID = 1L;
}

9
szhpt-fixed-task/src/main/java/cn/cecep/talroad/enums/EmlTypeEnums.java
View File

@ -22,4 +22,13 @@ public enum EmlTypeEnums {
private final String code;
private final String name;
private final String simple;
public static EmlTypeEnums getEnumByCode(String type){
for (EmlTypeEnums value : values()) {
if (value.getCode().equals(type)){
return value;
}
}
return null;
}
}

29
szhpt-fixed-task/src/main/java/cn/cecep/talroad/enums/LabelFactoryEnum.java
View File

@ -75,6 +75,15 @@ public enum LabelFactoryEnum {
this.enumName=enumName;
}
public static LabelFactoryEnum getByCode(String code) {
for (LabelFactoryEnum value : values()) {
if (value.enumId.equals(code)) {
return value;
}
}
return null;
}
public String getEnumId() {
return enumId;
}
@ -84,19 +93,19 @@ public enum LabelFactoryEnum {
}
public PcLabelFactory pcLabelFactory(String id, Map<String, PcLabel> pcLabelsMap, String value, String useing, PcLabelFactory pcLabelFactory){
pcLabelFactory=new PcLabelFactory();
pcLabelFactory.setFactoryId(id);
pcLabelFactory.setLabelId(pcLabelsMap.get(enumId).getId());
pcLabelFactory.setLabelValue(value);
pcLabelFactory.setLableUseing(useing);
pcLabelFactory=new PcLabelFactory();
pcLabelFactory.setFactoryId(id);
pcLabelFactory.setLabelId(pcLabelsMap.get(enumId).getId());
pcLabelFactory.setLabelValue(value);
pcLabelFactory.setLableUseing(useing);
return pcLabelFactory;
}
public PcLabelFactory pcLabelFactoryPollutant(String id, Map<String, PcLabel> pcLabelsMap, String value, String useing, PcLabelFactory pcLabelFactory){
pcLabelFactory=new PcLabelFactory();
pcLabelFactory.setFactoryId(id);
pcLabelFactory.setLabelId(pcLabelsMap.get(enumId).getId());
pcLabelFactory.setLabelValue(value);
pcLabelFactory.setLableUseing(useing);
pcLabelFactory=new PcLabelFactory();
pcLabelFactory.setFactoryId(id);
pcLabelFactory.setLabelId(pcLabelsMap.get(enumId).getId());
pcLabelFactory.setLabelValue(value);
pcLabelFactory.setLableUseing(useing);
return pcLabelFactory;
}

1
szhpt-fixed-task/src/main/java/cn/cecep/talroad/enums/ProblemTypeEnum.java
View File

@ -30,6 +30,7 @@ public enum ProblemTypeEnum {
//TODO 待确认该枚举是否正确
POLLUTION_CONTROL_EXCEEDED("0040020112","污染源管控超标"),
FREQUENCY_MEASUREMENT("006005","手工监测频次不满足许可证要求"),
CONCENTRATION_EXCEEDED_TYPE("003002","浓度超标类型"),
;

14
szhpt-fixed-task/src/main/java/cn/cecep/talroad/mapper/OdsPermissionSharereportattachmentAMapper.java 100644
View File

@ -0,0 +1,14 @@
package cn.cecep.talroad.mapper;
import cn.cecep.talroad.domain.OdsPermissionSharereportattachmentA;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* @description: TODO
* @author hehongyu
* @date 2023/8/12 18:33
*/
@Mapper
public interface OdsPermissionSharereportattachmentAMapper extends BaseMapper<OdsPermissionSharereportattachmentA> {
}

14
szhpt-fixed-task/src/main/java/cn/cecep/talroad/mapper/OdsPermissionSharereportledgerinfoLedgerinfoAMapper.java 100644
View File

@ -0,0 +1,14 @@
package cn.cecep.talroad.mapper;
import cn.cecep.talroad.domain.OdsPermissionSharereportledgerinfoLedgerinfoA;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* @description: TODO
* @author hehongyu
* @date 2023/8/12 18:34
*/
@Mapper
public interface OdsPermissionSharereportledgerinfoLedgerinfoAMapper extends BaseMapper<OdsPermissionSharereportledgerinfoLedgerinfoA> {
}

12
szhpt-fixed-task/src/main/java/cn/cecep/talroad/service/impl/AppVersionAddressManagementServiceImpl.java
View File

@ -4,13 +4,9 @@ import cn.cecep.talroad.common.core.utils.StringUtils;
import cn.cecep.talroad.domain.AppVersionAddressManagement;
import cn.cecep.talroad.mapper.AppVersionAddressManagementMapper;
import cn.cecep.talroad.service.IAppVersionAddressManagementService;
import cn.cecep.talroad.util.QrCodeUtils;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
/**
* @Description: app版本管理表
@ -58,8 +54,8 @@ public class AppVersionAddressManagementServiceImpl extends ServiceImpl<AppVersi
if (StringUtils.isEmpty(logUrl)) {
logUrl = versionAddress.getLogImgUrl();
}
String encode = QrCodeUtils.createQrCodeBase64Encode(url, StrUtil.isNotEmpty(logUrl)? FileUtil.file(logUrl): null, true);
return BASE64_CODE_PREFIX + encode;
return null;
// String encode = QrCodeUtils.createQrCodeBase64Encode(url, StrUtil.isNotEmpty(logUrl)? FileUtil.file(logUrl): null, true);
// return BASE64_CODE_PREFIX + encode;
}
}

15
szhpt-fixed-task/src/main/java/cn/cecep/talroad/service/impl/analysis/BasDeviceStatusServiceImpl.java
View File

@ -1,20 +1,21 @@
package cn.cecep.talroad.service.impl.analysis;
import cn.cecep.talroad.common.core.text.UUID;
import cn.cecep.talroad.common.core.utils.DateUtils;
import cn.cecep.talroad.common.core.utils.StringUtils;
import cn.cecep.talroad.domain.BasDevice;
import cn.cecep.talroad.mapper.BasDeviceMapper;
import cn.cecep.talroad.service.analysis.IBasDeviceStatusService;
import cn.cecep.talroad.service.strategy.StrategyFactory;
import cn.cecep.talroad.util.MsgProducer;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import java.text.ParseException;
import java.util.List;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.text.ParseException;
import java.util.Date;
import java.util.List;
//import cn.cecep.talroad.util.MsgProducer;
/**
* @Auther: cjh
@ -31,8 +32,8 @@ public class BasDeviceStatusServiceImpl implements IBasDeviceStatusService {
private BasDeviceMapper deviceMapper;
@Autowired
private StrategyFactory strategyFactory;
@Autowired
private MsgProducer msgProducer;
// @Autowired
// private MsgProducer msgProducer;
@Override
public void doCheckDeviceStatus(String industry, String deviceType) {
@ -56,7 +57,7 @@ public class BasDeviceStatusServiceImpl implements IBasDeviceStatusService {
if (deviceList != null && deviceList.size() > 0) {
// 查询设备类型的参数配置
deviceList.forEach(d -> {
msgProducer.sendYieldStatisticMsg(UUID.randomUUID().toString(),d.getDeviceId());
// msgProducer.sendYieldStatisticMsg(UUID.randomUUID().toString(),d.getDeviceId());
});
}
}

49
szhpt-fixed-task/src/main/java/cn/cecep/talroad/util/DateUtil.java
View File

@ -1,6 +1,7 @@
package cn.cecep.talroad.util;
import cn.cecep.talroad.enums.EmlTypeEnums;
import com.alibaba.nacos.common.utils.DateFormatUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateUtils;
@ -870,4 +871,52 @@ public class DateUtil {
}
return dayAgo;
}
/**
* 获取日期所对的季度开始日期
* @param date
* @return
*/
public static Date getQuarterStart(Date date) {
Calendar calendar = Calendar.getInstance();
calendar.setTime(date);
int month = calendar.get(Calendar.MONTH) + 1;
int quarter = (month - 1) / 3 + 1;
int year = calendar.get(Calendar.YEAR);
int quarterStartMonth = (quarter - 1) * 3 + 1;
int quarterEndMonth = quarter * 3 + 1;
Calendar quarterStart = Calendar.getInstance();
quarterStart.set(year, quarterStartMonth - 1, 1);
return quarterStart.getTime();
}
/**
* 获取日期所对的季度结束日期
* @param date
* @return
*/
public static Date getQuarterEnd(Date date){
Calendar calendar = Calendar.getInstance();
calendar.setTime(date);
int month = calendar.get(Calendar.MONTH) + 1;
int quarter = (month - 1) / 3 + 1;
int year = calendar.get(Calendar.YEAR);
int quarterStartMonth = (quarter - 1) * 3 + 1;
int quarterEndMonth = quarter * 3 + 1;
Calendar quarterEnd = Calendar.getInstance();
quarterEnd.set(year, quarterEndMonth - 2, 1);
quarterEnd.add(Calendar.DATE, -1);
return quarterEnd.getTime();
}
/**
* 时间至0
*/
public static Calendar setTimeZero(Calendar calendar){
calendar.set(Calendar.HOUR_OF_DAY,0);
calendar.set(Calendar.MILLISECOND,0);
calendar.set(Calendar.MINUTE,0);
calendar.set(Calendar.SECOND,0);
return calendar;
}
}

106
szhpt-fixed-task/src/main/java/cn/cecep/talroad/util/MsgProducer.java
View File

@ -1,53 +1,53 @@
package cn.cecep.talroad.util;
import cn.cecep.talroad.config.ExchangeConfig;
import cn.cecep.talroad.config.RabbitmqConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @Auther: cjh
* @Date: 2022-05-07 15:27
* @Class: MsgProducer
* @Deseription:
* @Version V1.0
*/
@Slf4j
@Component
public class MsgProducer implements RabbitTemplate.ConfirmCallback {
@Autowired
private RabbitTemplate rabbitTemplate;
/**
* 发送消息-定时判断设备停限产状态
*
* @param uuid
* @param message 消息
*/
public void sendStatusMsg(String uuid, Object message) {
rabbitTemplate.setConfirmCallback(this);
CorrelationData correlationId = new CorrelationData(uuid);
rabbitTemplate.convertAndSend(ExchangeConfig.DIRECT_EXCHANGE, RabbitmqConfig.ROUTE_KEY_STATUS,message, correlationId);
}
/**
* 发送探查消息
* @param uuid
* @param message
*/
public void sendYieldStatisticMsg(String uuid, Object message) {
rabbitTemplate.setConfirmCallback(this);
CorrelationData correlationId = new CorrelationData(uuid);
rabbitTemplate.convertAndSend(ExchangeConfig.DIRECT_EXCHANGE, RabbitmqConfig.ROUTE_KEY_YIELD,message, correlationId);
}
@Override
public void confirm(CorrelationData correlationData, boolean b, String s) {
log.info("消息推送交换机状态{},消息ID{}",b,correlationData.getId());
}
}
//package cn.cecep.talroad.util;
//
//import cn.cecep.talroad.config.ExchangeConfig;
//import cn.cecep.talroad.config.RabbitmqConfig;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.connection.CorrelationData;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
///**
// * @Auther: cjh
// * @Date: 2022-05-07 15:27
// * @Class: MsgProducer
// * @Deseription:
// * @Version V1.0
// */
//@Slf4j
//@Component
//public class MsgProducer implements RabbitTemplate.ConfirmCallback {
//
//
// @Autowired
// private RabbitTemplate rabbitTemplate;
//
// /**
// * 发送消息-定时判断设备停限产状态
// *
// * @param uuid
// * @param message 消息
// */
// public void sendStatusMsg(String uuid, Object message) {
// rabbitTemplate.setConfirmCallback(this);
// CorrelationData correlationId = new CorrelationData(uuid);
// rabbitTemplate.convertAndSend(ExchangeConfig.DIRECT_EXCHANGE, RabbitmqConfig.ROUTE_KEY_STATUS,message, correlationId);
// }
//
// /**
// * 发送探查消息
// * @param uuid
// * @param message
// */
// public void sendYieldStatisticMsg(String uuid, Object message) {
// rabbitTemplate.setConfirmCallback(this);
// CorrelationData correlationId = new CorrelationData(uuid);
// rabbitTemplate.convertAndSend(ExchangeConfig.DIRECT_EXCHANGE, RabbitmqConfig.ROUTE_KEY_YIELD,message, correlationId);
// }
//
// @Override
// public void confirm(CorrelationData correlationData, boolean b, String s) {
// log.info("消息推送交换机状态{},消息ID{}",b,correlationData.getId());
// }
//}

458
szhpt-fixed-task/src/main/java/cn/cecep/talroad/util/QrCodeUtils.java
View File

@ -1,229 +1,229 @@
package cn.cecep.talroad.util;
import com.google.zxing.BarcodeFormat;
import com.google.zxing.EncodeHintType;
import com.google.zxing.MultiFormatWriter;
import com.google.zxing.WriterException;
import com.google.zxing.common.BitMatrix;
import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
import org.springframework.web.client.RestTemplate;
import javax.imageio.ImageIO;
import java.awt.*;
import java.awt.geom.RoundRectangle2D;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.util.*;
/**
* @Description：二维码工具类
* @PACKAGE_NAME: cn.cecep.talroad.utils
* @date 2021-12-21 11:10*/
public class QrCodeUtils {
private static final int BLACK = 0xFF000000;
private static final int WHITE = 0xFFFFFFFF;
private static final String CHARSET = "utf-8";
private static final String FORMAT_NAME = "JPG";
// 二维码尺寸
private static final int QRCODE_SIZE = 300;
// LOGO宽度
private static final int WIDTH = 60;
// LOGO高度
private static final int HEIGHT = 60;
private static RestTemplate restTemplate = new RestTemplate();
/**
* 生成二维码
* 经过base64编码
*
* @param url
* @return
*/
public static BufferedImage createQrCode(String url) throws WriterException {
Map<EncodeHintType, String> hints = new HashMap<EncodeHintType, String>(4);
hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
BitMatrix bitMatrix = new MultiFormatWriter().encode(url, BarcodeFormat.QR_CODE, 500, 500, hints);
return toBufferedImage(bitMatrix);
}
/**
* 生成二维码
* 经过base64编码
*
* @param url
* @return
*/
public static String createQrCodeBase64(String url) {
String base64String = "";
try {
Map<EncodeHintType, String> hints = new HashMap<EncodeHintType, String>(4);
hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
BitMatrix bitMatrix = new MultiFormatWriter().encode(url, BarcodeFormat.QR_CODE, 400, 400, hints);
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
BufferedImage bufferedImage = toBufferedImage(bitMatrix);
ImageIO.write(bufferedImage, "jpg", outputStream);
Base64.Encoder encoder = Base64.getEncoder();
base64String = encoder.encodeToString(outputStream.toByteArray());
} catch (Exception e) {
e.printStackTrace();
}
//return "data:image/jpg;base64," + base64String;
return base64String;
}
private static BufferedImage toBufferedImage(BitMatrix matrix) {
int width = matrix.getWidth();
int height = matrix.getHeight();
BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
for (int x = 0; x < width; x++) {
for (int y = 0; y < height; y++) {
image.setRGB(x, y, matrix.get(x, y) ? BLACK : WHITE);
}
}
return image;
}
/**
* 生成二维码(内嵌LOGO)
* author zhangpeizhi
* @param content 内容
* @param logoFile LOGO文件
* @param needCompress 是否压缩LOGO
* @throws Exception
*/
public static String createQrCodeBase64Encode(String content, File logoFile,
boolean needCompress) throws Exception {
BufferedImage image = createImage(content, logoFile,
needCompress);
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
ImageIO.write(image, "jpg", outputStream);
Base64.Encoder encoder = Base64.getEncoder();
String base64String = encoder.encodeToString(outputStream.toByteArray());
return base64String;
}
/**
* 生成二维码(内嵌LOGO)
*
* @param content 内容
* @param logoFile LOGO文件
* @param destPath 存放目录
* @param needCompress 是否压缩LOGO
* @throws Exception
*/
public static String encode(String content, File logoFile, String destPath,
boolean needCompress) throws Exception {
BufferedImage image = createImage(content, logoFile,
needCompress);
mkdirs(destPath);
String file = new Random().nextInt(99999999) + ".jpg";
ImageIO.write(image, FORMAT_NAME, new File(destPath + "/" + file));
return file;
}
private static BufferedImage createImage(String content, File logoFile,
boolean needCompress) throws Exception {
Hashtable<EncodeHintType, Object> hints = new Hashtable<EncodeHintType, Object>();
hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.H);
hints.put(EncodeHintType.CHARACTER_SET, CHARSET);
hints.put(EncodeHintType.MARGIN, 1);
BitMatrix bitMatrix = new MultiFormatWriter().encode(content,
BarcodeFormat.QR_CODE, QRCODE_SIZE, QRCODE_SIZE, hints);
int width = bitMatrix.getWidth();
int height = bitMatrix.getHeight();
BufferedImage image = new BufferedImage(width, height,
BufferedImage.TYPE_INT_RGB);
for (int x = 0; x < width; x++) {
for (int y = 0; y < height; y++) {
image.setRGB(x, y, bitMatrix.get(x, y) ? 0xFF000000
: 0xFFFFFFFF);
}
}
if (CmUtil.isEmpty(logoFile)) {
return image;
}
// 插入图片
insertImage(image, logoFile, needCompress);
return image;
}
/**
* 当文件夹不存在时，mkdirs会自动创建多层目录，区别于mkdir．(mkdir如果父目录不存在则会抛出异常)
*
* @param destPath 存放目录
* @date 2013-12-11 上午10:16:36
*/
public static void mkdirs(String destPath) {
File file = new File(destPath);
//当文件夹不存在时，mkdirs会自动创建多层目录，区别于mkdir．(mkdir如果父目录不存在则会抛出异常)
if (!file.exists() && !file.isDirectory()) {
file.mkdirs();
}
}
public static class CmUtil{
public static boolean isEmpty(File file){
if (null == file || 0 == file.length() || !file.exists()) return true;
return false;
}
}
/**
* 插入LOGO
*
* @param source 二维码图片
* @param logoFile LOGO图片文件
* @param needCompress 是否压缩
* @throws Exception
*/
private static void insertImage(BufferedImage source, File logoFile,
boolean needCompress) throws Exception {
if (!logoFile.exists()) {
System.err.println("" + logoFile + " 该文件不存在！");
return;
}
Image src = ImageIO.read(logoFile);
int width = src.getWidth(null);
int height = src.getHeight(null);
// 压缩LOGO
if (needCompress) {
if (width > WIDTH) {
width = WIDTH;
}
if (height > HEIGHT) {
height = HEIGHT;
}
Image image = src.getScaledInstance(width, height,
Image.SCALE_SMOOTH);
BufferedImage tag = new BufferedImage(width, height,
BufferedImage.TYPE_INT_RGB);
Graphics g = tag.getGraphics();
// 绘制缩小后的图
g.drawImage(image, 0, 0, null);
g.dispose();
src = image;
}
// 插入LOGO
Graphics2D graph = source.createGraphics();
int x = (QRCODE_SIZE - width) / 2;
int y = (QRCODE_SIZE - height) / 2;
graph.drawImage(src, x, y, width, height, null);
Shape shape = new RoundRectangle2D.Float(x, y, width, width, 6, 6);
graph.setStroke(new BasicStroke(3f));
graph.draw(shape);
graph.dispose();
}
}
//package cn.cecep.talroad.util;
//
//import com.google.zxing.BarcodeFormat;
//import com.google.zxing.EncodeHintType;
//import com.google.zxing.MultiFormatWriter;
//import com.google.zxing.WriterException;
//import com.google.zxing.common.BitMatrix;
//import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
//import org.springframework.web.client.RestTemplate;
//
//import javax.imageio.ImageIO;
//import java.awt.*;
//import java.awt.geom.RoundRectangle2D;
//import java.awt.image.BufferedImage;
//import java.io.ByteArrayOutputStream;
//import java.io.File;
//import java.util.*;
//
///**
// * @Description：二维码工具类
// * @PACKAGE_NAME: cn.cecep.talroad.utils
// * @date 2021-12-21 11:10*/
//public class QrCodeUtils {
//
// private static final int BLACK = 0xFF000000;
// private static final int WHITE = 0xFFFFFFFF;
// private static final String CHARSET = "utf-8";
// private static final String FORMAT_NAME = "JPG";
// // 二维码尺寸
// private static final int QRCODE_SIZE = 300;
// // LOGO宽度
// private static final int WIDTH = 60;
// // LOGO高度
// private static final int HEIGHT = 60;
//
// private static RestTemplate restTemplate = new RestTemplate();
//
//
// /**
// * 生成二维码
// * 经过base64编码
// *
// * @param url
// * @return
// */
// public static BufferedImage createQrCode(String url) throws WriterException {
// Map<EncodeHintType, String> hints = new HashMap<EncodeHintType, String>(4);
// hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
// BitMatrix bitMatrix = new MultiFormatWriter().encode(url, BarcodeFormat.QR_CODE, 500, 500, hints);
//
// return toBufferedImage(bitMatrix);
// }
//
// /**
// * 生成二维码
// * 经过base64编码
// *
// * @param url
// * @return
// */
// public static String createQrCodeBase64(String url) {
// String base64String = "";
// try {
// Map<EncodeHintType, String> hints = new HashMap<EncodeHintType, String>(4);
// hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
// BitMatrix bitMatrix = new MultiFormatWriter().encode(url, BarcodeFormat.QR_CODE, 400, 400, hints);
// ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
//
// BufferedImage bufferedImage = toBufferedImage(bitMatrix);
// ImageIO.write(bufferedImage, "jpg", outputStream);
// Base64.Encoder encoder = Base64.getEncoder();
// base64String = encoder.encodeToString(outputStream.toByteArray());
// } catch (Exception e) {
// e.printStackTrace();
// }
// //return "data:image/jpg;base64," + base64String;
// return base64String;
// }
//
// private static BufferedImage toBufferedImage(BitMatrix matrix) {
// int width = matrix.getWidth();
// int height = matrix.getHeight();
// BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
// for (int x = 0; x < width; x++) {
// for (int y = 0; y < height; y++) {
// image.setRGB(x, y, matrix.get(x, y) ? BLACK : WHITE);
// }
// }
// return image;
// }
//
// /**
// * 生成二维码(内嵌LOGO)
// * author zhangpeizhi
// * @param content 内容
// * @param logoFile LOGO文件
// * @param needCompress 是否压缩LOGO
// * @throws Exception
// */
// public static String createQrCodeBase64Encode(String content, File logoFile,
// boolean needCompress) throws Exception {
// BufferedImage image = createImage(content, logoFile,
// needCompress);
//
// ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
//
// ImageIO.write(image, "jpg", outputStream);
// Base64.Encoder encoder = Base64.getEncoder();
// String base64String = encoder.encodeToString(outputStream.toByteArray());
//
// return base64String;
// }
//
//
// /**
// * 生成二维码(内嵌LOGO)
// *
// * @param content 内容
// * @param logoFile LOGO文件
// * @param destPath 存放目录
// * @param needCompress 是否压缩LOGO
// * @throws Exception
// */
// public static String encode(String content, File logoFile, String destPath,
// boolean needCompress) throws Exception {
// BufferedImage image = createImage(content, logoFile,
// needCompress);
// mkdirs(destPath);
// String file = new Random().nextInt(99999999) + ".jpg";
// ImageIO.write(image, FORMAT_NAME, new File(destPath + "/" + file));
// return file;
// }
//
// private static BufferedImage createImage(String content, File logoFile,
// boolean needCompress) throws Exception {
// Hashtable<EncodeHintType, Object> hints = new Hashtable<EncodeHintType, Object>();
// hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.H);
// hints.put(EncodeHintType.CHARACTER_SET, CHARSET);
// hints.put(EncodeHintType.MARGIN, 1);
// BitMatrix bitMatrix = new MultiFormatWriter().encode(content,
// BarcodeFormat.QR_CODE, QRCODE_SIZE, QRCODE_SIZE, hints);
// int width = bitMatrix.getWidth();
// int height = bitMatrix.getHeight();
// BufferedImage image = new BufferedImage(width, height,
// BufferedImage.TYPE_INT_RGB);
// for (int x = 0; x < width; x++) {
// for (int y = 0; y < height; y++) {
// image.setRGB(x, y, bitMatrix.get(x, y) ? 0xFF000000
// : 0xFFFFFFFF);
// }
// }
// if (CmUtil.isEmpty(logoFile)) {
// return image;
// }
// // 插入图片
// insertImage(image, logoFile, needCompress);
// return image;
// }
//
// /**
// * 当文件夹不存在时，mkdirs会自动创建多层目录，区别于mkdir．(mkdir如果父目录不存在则会抛出异常)
// *
// * @param destPath 存放目录
// * @date 2013-12-11 上午10:16:36
// */
// public static void mkdirs(String destPath) {
// File file = new File(destPath);
// //当文件夹不存在时，mkdirs会自动创建多层目录，区别于mkdir．(mkdir如果父目录不存在则会抛出异常)
// if (!file.exists() && !file.isDirectory()) {
// file.mkdirs();
// }
// }
//
// public static class CmUtil{
// public static boolean isEmpty(File file){
// if (null == file || 0 == file.length() || !file.exists()) return true;
// return false;
// }
// }
//
//
// /**
// * 插入LOGO
// *
// * @param source 二维码图片
// * @param logoFile LOGO图片文件
// * @param needCompress 是否压缩
// * @throws Exception
// */
// private static void insertImage(BufferedImage source, File logoFile,
// boolean needCompress) throws Exception {
//
// if (!logoFile.exists()) {
// System.err.println("" + logoFile + " 该文件不存在！");
// return;
// }
// Image src = ImageIO.read(logoFile);
// int width = src.getWidth(null);
// int height = src.getHeight(null);
// // 压缩LOGO
// if (needCompress) {
// if (width > WIDTH) {
// width = WIDTH;
// }
// if (height > HEIGHT) {
// height = HEIGHT;
// }
// Image image = src.getScaledInstance(width, height,
// Image.SCALE_SMOOTH);
// BufferedImage tag = new BufferedImage(width, height,
// BufferedImage.TYPE_INT_RGB);
// Graphics g = tag.getGraphics();
// // 绘制缩小后的图
// g.drawImage(image, 0, 0, null);
// g.dispose();
// src = image;
// }
// // 插入LOGO
// Graphics2D graph = source.createGraphics();
// int x = (QRCODE_SIZE - width) / 2;
// int y = (QRCODE_SIZE - height) / 2;
// graph.drawImage(src, x, y, width, height, null);
// Shape shape = new RoundRectangle2D.Float(x, y, width, width, 6, 6);
// graph.setStroke(new BasicStroke(3f));
// graph.draw(shape);
// graph.dispose();
// }
//
//}

92
szhpt-fixed-task/src/main/java/cn/cecep/talroad/util/StatusConsumer.java
View File

@ -1,48 +1,48 @@
package cn.cecep.talroad.util;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
import org.springframework.stereotype.Component;
/**
* @Auther: cjh
* @Date: 2023-04-17 11:02
* @Class: MsgReceiver
* @Deseription: 停限产状态消息消费
* @Version V1.0
*/
@Slf4j
@Component
public class StatusConsumer implements ChannelAwareMessageListener {
@Override
//@RabbitListener(queues = "status-queue")
public void onMessage(Message message, Channel channel) throws Exception {
// try {
// String deviceId = new String(message.getBody());
// BasDevice d = deviceMapper.selectById(deviceId);
// PcFactory p = pcFactoryMapper.selectPcFactoryById(d.getFactoryId());
//package cn.cecep.talroad.util;
//
// QueryWrapper<BasDeviceParam> paramWrapper = new QueryWrapper<>();
// paramWrapper.eq("industry", d.getIndustry());
// paramWrapper.eq("device_id", d.getDeviceId());
// paramWrapper.eq("device_type",d.getType());
// List<BasDeviceParam> paramList = basDeviceParamMapper.selectList(paramWrapper);
// //拼接策略服务名称
// String strategyName = StringUtils.upperCase(d.getIndustry() + d.getType());
// //执行策略，处理设备状态
// strategyFactory.getByName(strategyName).doCheckProcess(p, d, paramList);
//import com.rabbitmq.client.Channel;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
//import org.springframework.stereotype.Component;
//
// } catch (Exception e) {
// log.error("MsgReceiver.onMessage##失败:" + e.getMessage());
// } finally {
// //ACK 手动签收消息，告诉对方消息签收成功,唯一标识ID
// Long deliverTag = message.getMessageProperties().getDeliveryTag();
// channel.basicAck(deliverTag, false);
// }
}
}
///**
// * @Auther: cjh
// * @Date: 2023-04-17 11:02
// * @Class: MsgReceiver
// * @Deseription: 停限产状态消息消费
// * @Version V1.0
// */
//@Slf4j
//@Component
//public class StatusConsumer implements ChannelAwareMessageListener {
//
//
// @Override
// //@RabbitListener(queues = "status-queue")
// public void onMessage(Message message, Channel channel) throws Exception {
//// try {
//// String deviceId = new String(message.getBody());
//// BasDevice d = deviceMapper.selectById(deviceId);
//// PcFactory p = pcFactoryMapper.selectPcFactoryById(d.getFactoryId());
////
//// QueryWrapper<BasDeviceParam> paramWrapper = new QueryWrapper<>();
//// paramWrapper.eq("industry", d.getIndustry());
//// paramWrapper.eq("device_id", d.getDeviceId());
//// paramWrapper.eq("device_type",d.getType());
//// List<BasDeviceParam> paramList = basDeviceParamMapper.selectList(paramWrapper);
//// //拼接策略服务名称
//// String strategyName = StringUtils.upperCase(d.getIndustry() + d.getType());
//// //执行策略，处理设备状态
//// strategyFactory.getByName(strategyName).doCheckProcess(p, d, paramList);
////
//// } catch (Exception e) {
//// log.error("MsgReceiver.onMessage##失败:" + e.getMessage());
//// } finally {
//// //ACK 手动签收消息，告诉对方消息签收成功,唯一标识ID
//// Long deliverTag = message.getMessageProperties().getDeliveryTag();
//// channel.basicAck(deliverTag, false);
//// }
// }
//}

104
szhpt-fixed-task/src/main/java/cn/cecep/talroad/util/YieldConsumer.java
View File

@ -1,52 +1,52 @@
package cn.cecep.talroad.util;
import cn.cecep.talroad.common.core.utils.StringUtils;
import cn.cecep.talroad.service.IBasDeviceService;
import cn.cecep.talroad.service.strategy.StrategyFactory;
import cn.cecep.talroad.vo.FactoryDeviceVo;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @Auther: cjh
* @Date: 2023-04-17 11:02
* @Class: MsgReceiver
* @Deseription: 产量统计消息消费
* @Version V1.0
*/
@Slf4j
@Component
public class YieldConsumer implements ChannelAwareMessageListener {
@Autowired
private IBasDeviceService basDeviceService;
@Autowired
private StrategyFactory strategyFactory;
@Override
@RabbitListener(queues = "yield-queue")
public void onMessage(Message message, Channel channel) throws Exception {
String deviceId = new String(message.getBody());
try {
FactoryDeviceVo vo = basDeviceService.selectFactoryDeviceVoByDeviceId(deviceId);
//拼接策略服务名称
String strategyName = StringUtils.upperCase(vo.getIndustry() + vo.getDeviceType() + vo.getDeviceType());
log.info("开始消费者-产量统计-行业："+vo.getIndustry()+",设备类型:"+vo.getDeviceType());
//执行策略，处理设备状态
strategyFactory.getByName(strategyName).doCheckProcessYield(vo);
} catch (Exception e) {
log.error("MsgReceiver.onMessage##设备ID:"+ deviceId+"##异常信息:"+ e.getMessage());
} finally {
//ACK 手动签收消息，告诉对方消息签收成功,唯一标识ID
Long deliverTag = message.getMessageProperties().getDeliveryTag();
channel.basicAck(deliverTag, false);
}
}
}
//package cn.cecep.talroad.util;
//
//import cn.cecep.talroad.common.core.utils.StringUtils;
//import cn.cecep.talroad.service.IBasDeviceService;
//import cn.cecep.talroad.service.strategy.StrategyFactory;
//import cn.cecep.talroad.vo.FactoryDeviceVo;
//import com.rabbitmq.client.Channel;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
///**
// * @Auther: cjh
// * @Date: 2023-04-17 11:02
// * @Class: MsgReceiver
// * @Deseription: 产量统计消息消费
// * @Version V1.0
// */
//@Slf4j
//@Component
//public class YieldConsumer implements ChannelAwareMessageListener {
//
// @Autowired
// private IBasDeviceService basDeviceService;
// @Autowired
// private StrategyFactory strategyFactory;
//
// @Override
// @RabbitListener(queues = "yield-queue")
// public void onMessage(Message message, Channel channel) throws Exception {
// String deviceId = new String(message.getBody());
// try {
// FactoryDeviceVo vo = basDeviceService.selectFactoryDeviceVoByDeviceId(deviceId);
//
// //拼接策略服务名称
// String strategyName = StringUtils.upperCase(vo.getIndustry() + vo.getDeviceType() + vo.getDeviceType());
// log.info("开始消费者-产量统计-行业："+vo.getIndustry()+",设备类型:"+vo.getDeviceType());
// //执行策略，处理设备状态
// strategyFactory.getByName(strategyName).doCheckProcessYield(vo);
//
// } catch (Exception e) {
// log.error("MsgReceiver.onMessage##设备ID:"+ deviceId+"##异常信息:"+ e.getMessage());
// } finally {
// //ACK 手动签收消息，告诉对方消息签收成功,唯一标识ID
// Long deliverTag = message.getMessageProperties().getDeliveryTag();
// channel.basicAck(deliverTag, false);
// }
// }
//}

2
szhpt-fixed-task/src/main/resources/application.yaml
View File

@ -45,7 +45,7 @@ spring:
# 主库数据源
master:
driver-class-name: org.postgresql.Driver
url: jdbc:postgresql://39.100.149.153:5432/public?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
url: jdbc:postgresql://39.100.149.153:5432/postgres?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
username: postgres
password: abc@123@...
# ods:

19
szhpt-fixed-task/src/main/resources/mapper/talroad/OdsPermissionSharereportattachmentAMapper.xml 100644
View File

@ -0,0 +1,19 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.cecep.talroad.mapper.OdsPermissionSharereportattachmentAMapper">
<resultMap id="BaseResultMap" type="cn.cecep.talroad.domain.OdsPermissionSharereportattachmentA">
<!--@mbg.generated-->
<!--@Table ods_permission_sharereportattachment_a-->
<result column="reportId" jdbcType="BIGINT" property="reportid" />
<result column="fileId" jdbcType="BIGINT" property="fileid" />
<result column="fileName" jdbcType="VARCHAR" property="filename" />
<result column="fileSize" jdbcType="VARCHAR" property="filesize" />
<result column="fileType" jdbcType="VARCHAR" property="filetype" />
<result column="remark" jdbcType="VARCHAR" property="remark" />
<result column="fastdfsId" jdbcType="VARCHAR" property="fastdfsid" />
</resultMap>
<sql id="Base_Column_List">
<!--@mbg.generated-->
reportId, fileId, fileName, fileSize, fileType, remark, fastdfsId
</sql>
</mapper>

18
szhpt-fixed-task/src/main/resources/mapper/talroad/OdsPermissionSharereportledgerinfoLedgerinfoAMapper.xml 100644
View File

@ -0,0 +1,18 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.cecep.talroad.mapper.OdsPermissionSharereportledgerinfoLedgerinfoAMapper">
<resultMap id="BaseResultMap" type="cn.cecep.talroad.domain.OdsPermissionSharereportledgerinfoLedgerinfoA">
<!--@mbg.generated-->
<!--@Table ods_permission_sharereportledgerinfo_ledgerinfo_a-->
<result column="reportId" jdbcType="VARCHAR" property="reportid" />
<result column="summary" jdbcType="VARCHAR" property="summary" />
<result column="ledgerRecordName" jdbcType="VARCHAR" property="ledgerrecordname" />
<result column="whetherComplete" jdbcType="VARCHAR" property="whethercomplete" />
<result column="description" jdbcType="VARCHAR" property="description" />
<result column="reportTime" jdbcType="VARCHAR" property="reporttime" />
</resultMap>
<sql id="Base_Column_List">
<!--@mbg.generated-->
reportId, summary, ledgerRecordName, whetherComplete, description, reportTime
</sql>
</mapper>