From d3da07f30ac1e1ca9de4fdb079a967e7b7da3089 Mon Sep 17 00:00:00 2001 From: 李林 <z1292839451@163.com> Date: 星期日, 07 四月 2024 17:58:52 +0800 Subject: [PATCH] 系统调整 --- system-run/src/main/resources/application.yml | 2 +- data-server/src/main/java/com/yuanchu/mom/service/DataReportingService.java | 2 ++ data-server/src/main/java/com/yuanchu/mom/controller/DataReportingController.java | 10 ++++++++-- data-server/src/main/java/com/yuanchu/mom/mapper/DataReportingMapper.java | 2 ++ data-server/src/main/java/com/yuanchu/mom/service/impl/DataReportingServiceImpl.java | 35 +++++++++++++++++------------------ data-server/src/main/resources/mapper/DataReportingMapper.xml | 5 +++++ 6 files changed, 35 insertions(+), 21 deletions(-) diff --git a/data-server/src/main/java/com/yuanchu/mom/controller/DataReportingController.java b/data-server/src/main/java/com/yuanchu/mom/controller/DataReportingController.java index e6f7da5..edb24e5 100644 --- a/data-server/src/main/java/com/yuanchu/mom/controller/DataReportingController.java +++ b/data-server/src/main/java/com/yuanchu/mom/controller/DataReportingController.java @@ -211,9 +211,8 @@ break; } } - list.add(reporting); + if(reporting.getAccountConsumption().compareTo(BigDecimal.ZERO) > 0) list.add(reporting); } - deleteAllData(format); dataReportingService.addDataReporting(list, format, param); return Result.success(); } @@ -390,6 +389,13 @@ return Result.success(dataReportingService.selectDataReportingForCreateUserNames(time)); } + @ApiOperation(value = "鑾峰彇椤圭洰鏁版嵁缁熻鐨勯」鐩瓫閫夐」") + @PostMapping("/selectDataReportingForProduct") + @ValueAuth + public Result selectDataReportingForProduct(String time) { + return Result.success(dataReportingService.selectDataReportingForProduct(time)); + } + @ApiOperation(value = "鑾峰彇寰俊鍙峰垪琛�") @GetMapping("/selectVxs") @ValueAuth diff --git a/data-server/src/main/java/com/yuanchu/mom/mapper/DataReportingMapper.java b/data-server/src/main/java/com/yuanchu/mom/mapper/DataReportingMapper.java index 24bb6a1..b3ccf9a 100644 --- a/data-server/src/main/java/com/yuanchu/mom/mapper/DataReportingMapper.java +++ b/data-server/src/main/java/com/yuanchu/mom/mapper/DataReportingMapper.java @@ -44,6 +44,8 @@ IPage<DataComparisonDto> selectDataComparisonDtoPageList(Page page, DataComparisonDto dataComparisonDto); List<String> selectDataReportingForCreateUserNames(String time); + + List<String> selectDataReportingForProduct(String time); } diff --git a/data-server/src/main/java/com/yuanchu/mom/service/DataReportingService.java b/data-server/src/main/java/com/yuanchu/mom/service/DataReportingService.java index e21f8ef..69cc119 100644 --- a/data-server/src/main/java/com/yuanchu/mom/service/DataReportingService.java +++ b/data-server/src/main/java/com/yuanchu/mom/service/DataReportingService.java @@ -51,6 +51,8 @@ List<String> selectDataReportingForCreateUserNames(String time); + List<String> selectDataReportingForProduct(String time); + int updateVxCards(List<DataReporting> list); diff --git a/data-server/src/main/java/com/yuanchu/mom/service/impl/DataReportingServiceImpl.java b/data-server/src/main/java/com/yuanchu/mom/service/impl/DataReportingServiceImpl.java index 30ea641..29417ea 100644 --- a/data-server/src/main/java/com/yuanchu/mom/service/impl/DataReportingServiceImpl.java +++ b/data-server/src/main/java/com/yuanchu/mom/service/impl/DataReportingServiceImpl.java @@ -1,5 +1,6 @@ package com.yuanchu.mom.service.impl; +import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.core.io.file.FileReader; @@ -174,13 +175,7 @@ date = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); } else date = LocalDateTime.parse(date+"T00:00:00").plusDays(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); for (DataReporting dataReporting : list) { -// List<FansSubmit> fansSubmits = fansSubmitMapper.selectList(Wrappers.<FansSubmit>lambdaQuery().eq(FansSubmit::getProduct, dataReporting.getProduct()).eq(FansSubmit::getVx, param).select(FansSubmit::getFansAdd).like(FansSubmit::getCreateTime, date)); FinanceSubmit financeSubmit = financeSubmitMapper.selectOne(Wrappers.<FinanceSubmit>lambdaQuery().eq(FinanceSubmit::getCompany, dataReporting.getAgent()).eq(FinanceSubmit::getName, dataReporting.getName()).select(FinanceSubmit::getEmployeeRebate).like(FinanceSubmit::getCreateTime, date).orderByDesc(FinanceSubmit::getId).last("limit 1")); -// Integer sum = 0; -// for (FansSubmit fansSubmit : fansSubmits) { -// sum += fansSubmit.getFansAdd(); -// } -// dataReporting.setFansAdd(sum); if(ObjectUtil.isNotEmpty(financeSubmit)){ dataReporting.setAgentRebate(financeSubmit.getEmployeeRebate()); } @@ -211,27 +206,26 @@ dataReporting.setRemark(dataReporting.getConsumption().subtract(dataReporting.getRebateConsumption())); } catch (Exception e) { } -// dataReporting.setVxCard(param); -// if (ObjectUtil.isEmpty(one)) { dataReporting.setRegistrant(map.get("name")); dataReporting.setDepartment(map.get("department")); dataReporting.setCreateTime(LocalDateTime.parse(date2 + " " + new SimpleDateFormat("HH:mm:ss").format(new Date()), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); - dataReportingMapper.insert(dataReporting); -// } else { -// dataReporting.setId(one.getId()); -// dataReporting.setName(null); -// dataReportingMapper.updateById(dataReporting); -// } + DataReporting dataReporting1 = dataReportingMapper.selectOne(Wrappers.<DataReporting>lambdaQuery() + .eq(DataReporting::getName, dataReporting.getName()) + .eq(DataReporting::getAccountConsumption, dataReporting.getAccountConsumption()) + .eq(DataReporting::getShowNum, dataReporting.getShowNum()) + .eq(DataReporting::getClick, dataReporting.getClick())); + if(BeanUtil.isNotEmpty(dataReporting1)){ + dataReporting.setId(dataReporting1.getId()); + dataReportingMapper.updateById(dataReporting); + }else{ + dataReportingMapper.insert(dataReporting); + } } } @Transactional(rollbackFor = Exception.class) @Override public Integer delDataReporting(Integer id) { - /*List<FansSubmit> fansSubmits = fansSubmitMapper.selectList(Wrappers.<FansSubmit>lambdaQuery().eq(FansSubmit::getDataId, id).select(FansSubmit::getId)); - if(fansSubmits.size()>0)fansSubmitMapper.deleteBatchIds(fansSubmits); - List<FinanceSubmit> financeSubmits = financeSubmitMapper.selectList(Wrappers.<FinanceSubmit>lambdaQuery().eq(FinanceSubmit::getDataId, id).select(FinanceSubmit::getId)); - if(financeSubmits.size()>0)financeSubmitMapper.deleteBatchIds(financeSubmits);*/ return dataReportingMapper.deleteById(id); } @@ -412,6 +406,11 @@ } @Override + public List<String> selectDataReportingForProduct(String time) { + return dataReportingMapper.selectDataReportingForProduct(time.split(" ")[0]); + } + + @Override public int updateVxCards(List<DataReporting> list) { for (DataReporting reporting : list) { updateDataReporting(reporting); diff --git a/data-server/src/main/resources/mapper/DataReportingMapper.xml b/data-server/src/main/resources/mapper/DataReportingMapper.xml index 65a8d00..a1ed534 100644 --- a/data-server/src/main/resources/mapper/DataReportingMapper.xml +++ b/data-server/src/main/resources/mapper/DataReportingMapper.xml @@ -162,4 +162,9 @@ left join user u1 on dr.create_user = u1.id where dr.create_time like concat('%', #{time}, '%') </select> + + <select id="selectDataReportingForProduct" resultType="java.lang.String"> + select distinct product from data_reporting + where create_time like concat('%', #{time}, '%') + </select> </mapper> diff --git a/system-run/src/main/resources/application.yml b/system-run/src/main/resources/application.yml index e9ee9ae..a43a119 100644 --- a/system-run/src/main/resources/application.yml +++ b/system-run/src/main/resources/application.yml @@ -1,5 +1,5 @@ server: - port: 8001 + port: 8002 spring: profiles: active: dev -- Gitblit v1.9.3