From 604d00f67ddcf25a9d079ceddd1c668b2a4e5288 Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期五, 19 四月 2024 15:08:22 +0800 Subject: [PATCH] bug修复 --- ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TbBasicDataServiceImpl.java | 285 ++++++++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 234 insertions(+), 51 deletions(-) diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TbBasicDataServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TbBasicDataServiceImpl.java index a48fb28..5668a77 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TbBasicDataServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TbBasicDataServiceImpl.java @@ -1,5 +1,6 @@ package com.ruoyi.system.service.impl; +import cn.hutool.core.date.DateUtil; import com.alibaba.excel.EasyExcel; import com.alibaba.excel.ExcelWriter; import com.alibaba.excel.write.metadata.WriteSheet; @@ -15,6 +16,8 @@ import com.ruoyi.common.enums.BusinessType; import com.ruoyi.common.enums.CalculateTypeEnum; import com.ruoyi.common.enums.DataScreenConfigEnum; +import com.ruoyi.common.enums.FieldInputTypeEnum; +import com.ruoyi.common.enums.FieldTypeEnum; import com.ruoyi.common.enums.ReportingStatusEnum; import com.ruoyi.common.enums.ShowStatusEnum; import com.ruoyi.common.enums.UserTypeEnum; @@ -32,18 +35,17 @@ import com.ruoyi.system.domain.TbBasicDataConfigDetail; import com.ruoyi.system.domain.TbBasicDataField; import com.ruoyi.system.domain.TbDataScreenScore; -import com.ruoyi.system.domain.TbDept; import com.ruoyi.system.domain.TbField; import com.ruoyi.system.domain.TbOperLog; import com.ruoyi.system.domain.TbScore; import com.ruoyi.system.dto.BasicDataDTO; import com.ruoyi.system.dto.BasicDataFieldDTO; import com.ruoyi.system.dto.CalculateItemDTO; +import com.ruoyi.system.dto.update.BasicDataUpdDTO; import com.ruoyi.system.handler.CustomCellWriteHandler; import com.ruoyi.system.listener.BasicDataListener; import com.ruoyi.system.listener.HistoryDataListener; import com.ruoyi.system.mapper.TbBasicDataMapper; -import com.ruoyi.system.mapper.TbDeptMapper; import com.ruoyi.system.query.CurrentFieldsQuery; import com.ruoyi.system.query.ScoreCalculateQuery; import com.ruoyi.system.query.ScoreQuery; @@ -63,9 +65,11 @@ import com.ruoyi.system.vo.CurrentFieldsDetailVO; import com.ruoyi.system.vo.CurrentFieldsVO; import com.ruoyi.system.vo.DataScreenConfigVO; +import com.ruoyi.system.vo.FieldAndScoreDataVO; import com.ruoyi.system.vo.FieldsTreeVO; import com.ruoyi.system.vo.ScoreCalculateVO; import com.ruoyi.system.vo.ScoreVO; +import com.ruoyi.system.vo.TransferPaymentScaleVO; import java.io.IOException; import java.net.URLEncoder; import java.time.Instant; @@ -100,7 +104,6 @@ public class TbBasicDataServiceImpl extends ServiceImpl<TbBasicDataMapper, TbBasicData> implements TbBasicDataService { - private final TbDeptMapper tbDeptMapper; private final HttpServletResponse response; private final TbFieldService tbFieldService; private final TbBasicDataFieldService tbBasicDataFieldService; @@ -112,13 +115,14 @@ private final TbDataScreenScoreService tbDataScreenScoreService; private final TbDataScreenConfigService tbDataScreenConfigService; + public static void setFieldValues( List<FieldsTreeVO> fields, Map<Long, TbBasicDataField> fieldMap) { for (FieldsTreeVO field : fields) { TbBasicDataField tbBasicDataField = fieldMap.get(field.getId()); if (tbBasicDataField != null) { field.setValue( - FieldBuildUtil.formatNumberWithCommas(tbBasicDataField.getFieldValue())); + tbBasicDataField.getFieldValue()); } if (field.getChildren() != null && !field.getChildren().isEmpty()) { setFieldValues(field.getChildren(), fieldMap); @@ -132,35 +136,31 @@ String deptAreaCode = user.getAreaCode(); BasicDataReportingVO vo = new BasicDataReportingVO(); // 校验区划代码 - TbDept dept = - tbDeptMapper.selectOne( - Wrappers.<TbDept>lambdaQuery().eq(TbDept::getAreaCode, deptAreaCode)); + SysUser dept = + sysUserService.getOne( + Wrappers.<SysUser>lambdaQuery().eq(SysUser::getAreaCode, deptAreaCode)); if (Objects.isNull(dept)) { throw new ServiceException(String.format("区划代码%s不存在", deptAreaCode)); } Date date = new Date(); - Map<String, Date> quarterDate = DateUtils.getQuarterDate(date); - // 当前季度开始 - Date quarterStart = quarterDate.get("first"); - // 当前季度结束 - Date quarterEnd = quarterDate.get("last"); - // 判断当前时间是否在季度初1-15号 + Date quarterStart = DateUtil.beginOfQuarter(date); + Date quarterEnd = DateUtil.endOfQuarter(date); Instant instant = quarterStart.toInstant(); LocalDate quarterStartLocalDate = instant.atZone(ZoneId.systemDefault()).toLocalDate(); - LocalDate fifteenDaysLimit = quarterStartLocalDate.plusDays(15); + LocalDate fifteenDaysLimit = quarterStartLocalDate.plusDays(14); LocalDate now = LocalDate.now(); vo.setQuarter(DateUtils.getNowQuarter()); vo.setStatus(ReportingStatusEnum.UNFILLED); - // 如果当前时间不在规定范围内:季度初1-15号 - if (now.isBefore(quarterStartLocalDate) || now.isAfter(fifteenDaysLimit)) { + // 如果当前时间不在规定范围内:季度初1-15号 TODO + /* if (now.isBefore(quarterStartLocalDate) || now.isAfter(fifteenDaysLimit)) { return R.ok(vo, "请于季度初1-15号上传季度数据。"); - } + }*/ // 查询是否有当前季度的填报记录 TbBasicData basicData = this.getOne( Wrappers.<TbBasicData>lambdaQuery() .eq(TbBasicData::getDeptAreaCode, dept.getAreaCode()) - .between(TbBasicData::getCreateTime, quarterStart, quarterEnd)); + .between(TbBasicData::getReportingTime, quarterStart, quarterEnd)); // 查询需要填写的字段 List<TbField> list = tbFieldService.lambdaQuery().eq(TbField::getStatus, ShowStatusEnum.SHOW).list(); @@ -229,6 +229,7 @@ TbBasicData tbBasicData = BeanUtils.copyBean(dto, TbBasicData.class); if (basicDataOpt.isPresent()) { tbBasicData.setId(basicDataOpt.get().getId()); + tbBasicData.setDeptAreaCode(areaCode); this.updateById(tbBasicData); //查询该基础数据的动态字端 List<TbBasicDataField> originFields = tbBasicDataFieldService.lambdaQuery() @@ -244,15 +245,44 @@ this.save(tbBasicData); } // 保存基础数据动态字段数据 - List<TbBasicDataField> tbBasicDataFields = + List<TbBasicDataField> tbBasicDataFieldsOrg = BeanUtils.copyList(dto.getFields(), TbBasicDataField.class); - + List<TbBasicDataField> tbBasicDataFields = tbBasicDataFieldsOrg.stream() + .filter(item -> Objects.nonNull(item.getFieldValue())).collect( + Collectors.toList()); tbBasicDataFields.forEach( item -> { item.setBasicDataId(tbBasicData.getId()); TbField tbField = fieldMap.get(item.getFieldId()); if (Objects.nonNull(tbField)) { item.setFieldName(tbField.getFieldName()); + } + Integer numMax = tbField.getNumMax(); + Integer numMin = tbField.getNumMin(); + Integer textMaxNum = tbField.getTextMaxNum(); + Integer textMinNum = tbField.getTextMinNum(); + if (FieldTypeEnum.NUMBER.equals(tbField.getFieldType()) && Objects.nonNull( + numMax) && Objects.nonNull(numMin)) { + double fieldValue = Double.parseDouble(item.getFieldValue()); + if (fieldValue < numMin || fieldValue > numMax) { + throw new ServiceException( + String.format("字段%s的值不在范围%d-%d内", + tbField.getFieldName(), + numMin, numMax)); + } + } + if (FieldTypeEnum.TEXT.equals(tbField.getFieldType()) + && FieldInputTypeEnum.MANUAL_INPUT.equals( + tbField.getTextInputType()) + && Objects.nonNull( + textMaxNum) && Objects.nonNull(textMinNum)) { + String fieldValue = item.getFieldValue(); + if (fieldValue.length() < numMin || fieldValue.length() > numMax) { + throw new ServiceException( + String.format("字段%s的值的长度不在范围%d-%d内", + tbField.getFieldName(), + textMinNum, textMaxNum)); + } } }); // 添加固定字段 转移支付规模、当期GDP @@ -291,8 +321,10 @@ this.updateById(tbBasicData); } if (ReportingStatusEnum.FILLED.equals(tbBasicData.getStatus())) { - calculateScore(tbBasicData, tbBasicDataFields); - CompletableFuture.runAsync(() -> calculateScreenScore(tbBasicData, tbBasicDataFields)); + CompletableFuture.runAsync(() -> { + calculateScore(tbBasicData, tbBasicDataFields); + calculateScreenScore(tbBasicData, tbBasicDataFields); + }); } } @@ -314,9 +346,18 @@ } } - private void handleScoreCalculate(TbBasicData tbBasicData, DataScreenConfigVO riskLevel, + private void handleScoreCalculate(TbBasicData tbBasicData, DataScreenConfigVO vo, Map<Long, TbBasicDataField> basicDataFieldMap) { - List<CalculateItemDTO> scoreCalculateList = riskLevel.getScoreCalculateList(); + TbDataScreenScore tbDataScreenScore = tbDataScreenScoreService.lambdaQuery() + .eq(TbDataScreenScore::getBasicDataId, tbBasicData.getId()).eq( + TbDataScreenScore::getDataScreenConfigId, vo.getId()).one(); + if (Objects.isNull(tbDataScreenScore)) { + tbDataScreenScore = new TbDataScreenScore(); + tbDataScreenScore.setDataScreenConfigId(vo.getId()); + tbDataScreenScore.setBasicDataId(tbBasicData.getId()); + tbDataScreenScore.setDeptAreaCode(tbBasicData.getDeptAreaCode()); + } + List<CalculateItemDTO> scoreCalculateList = vo.getScoreCalculateList(); for (CalculateItemDTO item : scoreCalculateList) { if (item.getValueType().equals(ValueTypeEnum.FIELD)) { TbBasicDataField basicDataField = basicDataFieldMap.get( @@ -329,12 +370,24 @@ String calculateFormulaStr = scoreCalculateList.stream() .map(CalculateItemDTO::getContent).collect(Collectors.joining()); double score = CalculateUtil.calculate(calculateFormulaStr); - TbDataScreenScore tbDataScreenScore = new TbDataScreenScore(); - tbDataScreenScore.setDataScreenConfigId(riskLevel.getId()); - tbDataScreenScore.setDataScreenConfigId(riskLevel.getId()); - tbDataScreenScore.setDeptAreaCode(tbBasicData.getDeptAreaCode()); tbDataScreenScore.setScore(score); - tbDataScreenScoreService.save(tbDataScreenScore); + if (vo.getType().equals(DataScreenConfigEnum.DATA_INDICATORS)) { + List<CalculateItemDTO> rateCalculateList = vo.getRateCalculateList(); + for (CalculateItemDTO calculateItemDTO : rateCalculateList) { + if (calculateItemDTO.getValueType().equals(ValueTypeEnum.FIELD)) { + TbBasicDataField basicDataField = basicDataFieldMap.get( + Long.valueOf(calculateItemDTO.getContent())); + if (Objects.nonNull(basicDataField)) { + calculateItemDTO.setContent(basicDataField.getFieldValue()); + } + } + } + String calculateRateFormulaStr = rateCalculateList.stream() + .map(CalculateItemDTO::getContent).collect(Collectors.joining()); + double scoreRate = CalculateUtil.calculate(calculateRateFormulaStr); + tbDataScreenScore.setScoreRate(scoreRate); + } + tbDataScreenScoreService.saveOrUpdate(tbDataScreenScore); } private void saveExchangeLog(LoginUser loginUser, TbBasicData tbBasicData, @@ -389,10 +442,15 @@ private static void wrapOperLog(LoginUser loginUser, TbBasicData tbBasicData, String before, String after, List<TbOperLog> tbOperlogList, String fieldName) { + SysUser user = loginUser.getUser(); TbOperLog tbOperLog = new TbOperLog(); tbOperLog.setOperation(tbBasicData.getQuarter()); - tbOperLog.setStaffName(loginUser.getUser().getNickName()); - tbOperLog.setAreaName(loginUser.getUser().getAreaName()); + tbOperLog.setStaffName( + user.getUserType() == UserTypeEnum.PLATFORM ? user + .getUserName() + : user.getNickName()); + tbOperLog.setAreaName( + user.getUserType() == UserTypeEnum.PLATFORM ? "平台" : user.getAreaName()); tbOperLog.setFieldName(fieldName); tbOperLog.setBusinessType(BusinessType.UPDBASICDATA.ordinal()); tbOperLog.setBeforeEdit(before); @@ -402,6 +460,18 @@ @Override public void importBasicData(MultipartFile file) throws Exception { + Date date = new Date(); + Date quarterStart = DateUtil.beginOfQuarter(date); + Date quarterEnd = DateUtil.endOfQuarter(date); + // 判断当前时间是否在季度初1-15号 + Instant instant = quarterStart.toInstant(); + LocalDate quarterStartLocalDate = instant.atZone(ZoneId.systemDefault()).toLocalDate(); + LocalDate fifteenDaysLimit = quarterStartLocalDate.plusDays(14); + LocalDate now = LocalDate.now(); + //TODO + /* if (now.isBefore(quarterStartLocalDate) || now.isAfter(fifteenDaysLimit)) { + throw new ServiceException("请于季度初1-15号上传季度数据。"); + }*/ LoginUser loginUser = SecurityUtils.getLoginUser(); String areaCode = loginUser.getUser().getAreaCode(); EasyExcel.read( @@ -413,7 +483,7 @@ tbBasicDataFieldService, tbBasicDataConfigService, tbBasicDataConfigDetailService, - tbScoreService)) + tbScoreService, tbDataScreenScoreService, tbDataScreenConfigService)) .sheet() .doRead(); } @@ -491,7 +561,7 @@ if (CalculateTypeEnum.PERCENTAGE.equals( textAndPercentage.getCalculateType())) { for (Map.Entry<String, String> stringStringEntry : scoreMap.entrySet()) { - String[] split = stringStringEntry.getKey().split("-"); + String[] split = stringStringEntry.getKey().split("_"); double v = Double.parseDouble( textAndPercentageData.getFieldValue()); double min = Double.parseDouble(split[0]); @@ -516,17 +586,15 @@ Page<ScoreVO> page = new Page<>(query.getPageNum(), query.getPageSize()); SysUser user = SecurityUtils.getLoginUser().getUser(); String areaCode = user.getAreaCode(); - Map<String, Date> quarterDate = DateUtils.getQuarterDate(new Date()); - // 当前季度开始 - Date quarterStart = quarterDate.get("first"); - // 当前季度结束 - Date quarterEnd = quarterDate.get("last"); + Date date = new Date(); + Date quarterStart = DateUtil.beginOfQuarter(date); + Date quarterEnd = DateUtil.endOfQuarter(date); // 查询是否有当前季度的填报记录 TbBasicData basicData = this.getOne( Wrappers.<TbBasicData>lambdaQuery() .eq(TbBasicData::getDeptAreaCode, areaCode) - .between(TbBasicData::getCreateTime, quarterStart, quarterEnd)); + .between(TbBasicData::getReportingTime, quarterStart, quarterEnd)); if (Objects.isNull(basicData)) { return PageDTO.empty(page); } @@ -544,6 +612,7 @@ throw new ServiceException("非法参数"); } CurrentFieldsDetailVO vo = BeanUtils.copyBean(basicData, CurrentFieldsDetailVO.class); + vo.setId(basicData.getId()); // 查询用户信息 sysUserService .lambdaQuery() @@ -669,17 +738,18 @@ .collect(Collectors.toMap(SysUser::getAreaCode, e -> e)); Set<Long> basicDataIds = basicDataList.stream().map(TbBasicData::getId).collect(Collectors.toSet()); - Map<Long, TbBasicDataField> basicDataFieldMap = - tbBasicDataFieldService - .lambdaQuery() - .in(TbBasicDataField::getBasicDataId, basicDataIds) - .list() - .stream() - .collect(Collectors.toMap(TbBasicDataField::getFieldId, e -> e)); + + List<TbBasicDataField> tbBasicDataFieldList = tbBasicDataFieldService + .lambdaQuery() + .in(TbBasicDataField::getBasicDataId, basicDataIds) + .list(); // 值 List<Object> result = new ArrayList<>(); for (TbBasicData tbBasicData : basicDataList) { SysUser user = userMap.get(tbBasicData.getDeptAreaCode()); + Map<Long, TbBasicDataField> basicDataFieldMap = tbBasicDataFieldList.stream() + .filter(field -> field.getBasicDataId().equals(tbBasicData.getId())) + .collect(Collectors.toMap(TbBasicDataField::getFieldId, e -> e)); List<String> item = new ArrayList<>(); item.add(Objects.nonNull(user) ? user.getAreaName() : ""); item.add(tbBasicData.getQuarter()); @@ -689,8 +759,7 @@ TbBasicDataField tbBasicDataField = basicDataFieldMap.get(tbField.getId()); item.add( Objects.nonNull(tbBasicDataField) - ? FieldBuildUtil.formatNumberWithCommas( - tbBasicDataField.getFieldValue()) + ? tbBasicDataField.getFieldValue() : ""); } item.add(tbBasicData.getRemark()); @@ -797,8 +866,7 @@ TbBasicDataField tbBasicDataField = basicDataFieldMap.get(tbField.getId()); item.add( Objects.nonNull(tbBasicDataField) - ? FieldBuildUtil.formatNumberWithCommas( - tbBasicDataField.getFieldValue()) + ? tbBasicDataField.getFieldValue() : ""); } item.add(tbBasicData.getRemark()); @@ -830,7 +898,8 @@ tbBasicDataFieldService, tbBasicDataConfigService, tbBasicDataConfigDetailService, - tbScoreService, sysUserService, quarter)) + tbScoreService, sysUserService, quarter, tbDataScreenScoreService, + tbDataScreenConfigService)) .sheet() .doRead(); } @@ -972,4 +1041,118 @@ headTitles.add(Lists.newArrayList("备注")); return headTitles; } + + @Override + public Page<TransferPaymentScaleVO> transferPaymentScalePage(Page<TransferPaymentScaleVO> page, + String quarter) { + Page<TransferPaymentScaleVO> pageVO = baseMapper.transferPaymentScalePage( + page, quarter); + int rank = 1; + for (TransferPaymentScaleVO record : pageVO.getRecords()) { + record.setRank(rank++); + } + return pageVO; + } + + @Override + public List<FieldAndScoreDataVO> selectBasicDataFieldsConfig(String areaCode, + String nowQuarter) { + return baseMapper.selectBasicDataFieldsConfig(areaCode, nowQuarter); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void editBasicData(BasicDataUpdDTO dto) throws Exception { + LoginUser loginUser = SecurityUtils.getLoginUser(); + // 数据校验 + if (Objects.isNull(dto)) { + return; + } + //查询基础数据 + TbBasicData basicData = this.getById(dto.getId()); + if (Objects.isNull(basicData)) { + throw new ServiceException("非法参数"); + } + String nowQuarter = DateUtils.getNowQuarter(); + this.updateById(basicData); + //查询该基础数据的动态字端 + List<TbBasicDataField> originFields = tbBasicDataFieldService.lambdaQuery() + .eq(TbBasicDataField::getBasicDataId, basicData.getId()).list(); + Set<Long> fieldIdList = originFields.stream().map(TbBasicDataField::getFieldId) + .collect(Collectors.toSet()); + Map<Long, TbField> fieldMap = tbFieldService.lambdaQuery().in(TbField::getId, fieldIdList) + .list().stream().collect(Collectors.toMap(TbField::getId, e -> e)); + CompletableFuture.runAsync( + () -> saveExchangeLog(loginUser, basicData, originFields, + BeanUtils.copyBean(dto, BasicDataDTO.class), + fieldMap)); + TbBasicData tbBasicData = BeanUtils.copyBean(dto, TbBasicData.class); + + // 保存基础数据动态字段数据 + List<TbBasicDataField> tbBasicDataFields = + BeanUtils.copyList(dto.getFields(), TbBasicDataField.class); + + for (TbBasicDataField item : tbBasicDataFields) { + TbField tbField = fieldMap.get(item.getFieldId()); + Integer numMax = tbField.getNumMax(); + Integer numMin = tbField.getNumMin(); + Integer textMaxNum = tbField.getTextMaxNum(); + Integer textMinNum = tbField.getTextMinNum(); + if (FieldTypeEnum.NUMBER.equals(tbField.getFieldType()) && Objects.nonNull( + numMax) && Objects.nonNull(numMin)) { + double fieldValue = Double.parseDouble(item.getFieldValue()); + if (fieldValue < numMin || fieldValue > numMax) { + throw new ServiceException( + String.format("字段%s的值不在范围%d-%d内", tbField.getFieldName(), + numMin, numMax)); + } + } + if (FieldTypeEnum.TEXT.equals(tbField.getFieldType()) + && FieldInputTypeEnum.MANUAL_INPUT.equals(tbField.getTextInputType()) + && Objects.nonNull( + textMaxNum) && Objects.nonNull(textMinNum)) { + String fieldValue = item.getFieldValue(); + if (fieldValue.length() < numMin || fieldValue.length() > numMax) { + throw new ServiceException( + String.format("字段%s的值的长度不在范围%d-%d内", tbField.getFieldName(), + textMinNum, textMaxNum)); + } + } + } + tbBasicDataFields.forEach( + item -> { + item.setBasicDataId(tbBasicData.getId()); + TbField tbField = fieldMap.get(item.getFieldId()); + if (Objects.nonNull(tbField)) { + item.setFieldName(tbField.getFieldName()); + } + }); + // 添加固定字段 转移支付规模、当期GDP + TbBasicDataField transferPaymentScale = new TbBasicDataField(); + transferPaymentScale.setBasicDataId(tbBasicData.getId()); + transferPaymentScale.setFieldId(-1L); + transferPaymentScale.setFieldValue(tbBasicData.getTransferPaymentScale()); + tbBasicDataFields.add(transferPaymentScale); + TbBasicDataField currentGdp = new TbBasicDataField(); + currentGdp.setBasicDataId(tbBasicData.getId()); + currentGdp.setFieldId(-2L); + currentGdp.setFieldValue(tbBasicData.getCurrentGdp()); + tbBasicDataFields.add(currentGdp); + TbBasicDataField remark = new TbBasicDataField(); + remark.setBasicDataId(tbBasicData.getId()); + remark.setFieldId(-3L); + remark.setFieldValue(tbBasicData.getRemark()); + tbBasicDataFields.add(remark); + // 将该基础数据的动态字段数据全部删除 + tbBasicDataFieldService.remove( + Wrappers.<TbBasicDataField>lambdaQuery() + .eq(TbBasicDataField::getBasicDataId, tbBasicData.getId())); + tbBasicDataFieldService.saveBatch(tbBasicDataFields); + if (ReportingStatusEnum.FILLED.equals(tbBasicData.getStatus())) { + CompletableFuture.runAsync(() -> { + calculateScore(tbBasicData, tbBasicDataFields); + calculateScreenScore(tbBasicData, tbBasicDataFields); + }); + } + } } -- Gitblit v1.7.1