From 3af951146aabb69d7857daf11a4bdef21c7ef77e Mon Sep 17 00:00:00 2001
From: value <z1292839451@163.com>
Date: 星期三, 22 五月 2024 09:54:29 +0800
Subject: [PATCH] 功能调整
---
data-server/src/main/java/com/yuanchu/mom/service/impl/DataReportingServiceImpl.java | 76 ++++++++++++++++++++++++--------------
1 files changed, 48 insertions(+), 28 deletions(-)
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..6f27469 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;
@@ -22,6 +23,7 @@
import com.yuanchu.mom.dto.DataReportingPageDto;
import com.yuanchu.mom.dto.ProductCountDto;
import com.yuanchu.mom.dto.RegistrantCountDto;
+import com.yuanchu.mom.mapper.AuthMapper;
import com.yuanchu.mom.mapper.FansSubmitMapper;
import com.yuanchu.mom.mapper.FinanceSubmitMapper;
import com.yuanchu.mom.pojo.DataReporting;
@@ -83,11 +85,18 @@
@Resource
private FinanceSubmitMapper financeSubmitMapper;
+ @Resource
+ private AuthMapper authMapper;
+
@Override
public Map<String, Object> selectDataReportingList(IPage<DataReportingPageDto> page, DataReportingPageDto dataReportingPageDto) {
Map<String, Object> map = new HashMap<>();
Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("selectDataReportingList");
- if (map1.get("look") == 1) dataReportingPageDto.setCreateUser(map1.get("userId"));
+ if (map1.get("look") == 1) dataReportingPageDto.setUpdateUser(map1.get("userId"));
+ Integer power = authMapper.isPower(map1.get("userId"), "dataReportingPower");
+ if (power == 1) {
+ dataReportingPageDto.setDepartment(dataReportingMapper.getUserDepartmentById(map1.get("userId")));
+ }
map.put("head", PrintChina.printChina(DataReportingPageDto.class));
map.put("body", dataReportingMapper.selectDataReportingDtoPageList(page, QueryWrappers.queryWrappers(dataReportingPageDto)));
return map;
@@ -128,7 +137,11 @@
for (FansSubmit fansSubmit : fansSubmits) {
sum += fansSubmit.getFansAdd();
}
- dataReporting2.setFansAdd(sum);
+ if (dataReporting.getFansAdd() != null || dataReporting.getFansAdd() != 0) {
+ dataReporting2.setFansAdd(dataReporting.getFansAdd());
+ } else {
+ dataReporting2.setFansAdd(sum);
+ }
return dataReportingMapper.updateById(dataReporting2);
}
@@ -147,8 +160,13 @@
Map<String, Object> map = new HashMap<>();
map.put("head", PrintChina.printChina(RegistrantCountDto.class));
Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("selectRegistrantCountDtoPageList");
- if (map1.get("look") == 1) registrantCountDto.setCreateUser(map1.get("userId"));
- map.put("body", dataReportingMapper.selectRegistrantCountDtoPageList(page, QueryWrappers.queryWrappers(registrantCountDto)));
+ if (map1.get("look") == 1) {
+ String name = dataReportingMapper.getUserNameById(map1.get("userId"));
+ registrantCountDto.setName2(name);
+ }
+ String department = dataReportingMapper.getUserDepartmentById(map1.get("userId"));
+ registrantCountDto.setDepartment(department);
+ map.put("body", dataReportingMapper.selectRegistrantCountDtoPageList(page, QueryWrappers.queryWrappers(registrantCountDto), registrantCountDto.getStartTime(), registrantCountDto.getEndTime()));
return map;
}
@@ -169,19 +187,14 @@
int userId = Integer.parseInt(JSONUtil.parseObj(new Jwt().readJWT(ServletUtils.getRequest().getHeader("token")).get("data")).get("id") + "");
Map<String, String> map = dataReportingMapper.selectUser(userId);
String date2 = date;
- if(date == null) {
+ if (date == null) {
date2 = fansSubmitService.getYesterday();
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"));
+ } 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)){
+ if (ObjectUtil.isNotEmpty(financeSubmit)) {
dataReporting.setAgentRebate(financeSubmit.getEmployeeRebate());
}
if (dataReporting.getName() == null || dataReporting.getName().equals(""))
@@ -211,27 +224,27 @@
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())
+ .last("limit 1"));
+ 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);
}
@@ -324,6 +337,7 @@
@Override
public String downFansSubmitFile(IPage<FansSubmit> page, FansSubmit fansSubmit) {
+ fansSubmit.setCreateTime(fansSubmit.getCreateTime().plusDays(1));
Map<String, Object> map = fansSubmitService.selectFansSubmitList(page, fansSubmit);
String time = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy_MM_dd_HH_mm_ss"));
String name = "绮変笣涓婃姤" + time + ".csv";
@@ -331,7 +345,7 @@
CsvWriter writer = CsvUtil.getWriter(path, CharsetUtil.CHARSET_GBK);
writer.write(new String[]{"瀵煎嚭鏃堕棿锛�" + time});
writer.write(new String[]{});
- writer.write(new String[]{"鏃堕棿鑼冨洿锛�" + fansSubmit.getCreateTime().format(DateTimeFormatter.ofPattern("yyyyMMdd"))});
+ writer.write(new String[]{"鏃堕棿鑼冨洿锛�" + fansSubmit.getCreateTime().minusDays(1).format(DateTimeFormatter.ofPattern("yyyyMMdd"))});
writer.write(new String[]{});
writer.write(new String[]{});
List<Map<String, String>> head = JSON.parseObject(JSON.toJSONString(map.get("head")), List.class);
@@ -353,14 +367,15 @@
@Override
public String downFinanceSubmitFile(IPage<FinanceSubmit> page, FinanceSubmit financeSubmit) {
+ financeSubmit.setCreateTime(financeSubmit.getCreateTime().plusDays(1));
Map<String, Object> map = financeSubmitService.selectFinanceSubmitList(page, financeSubmit);
- String time = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy_MM_dd_HH_mm_ss"));
+ String time = LocalDateTime.now().minusDays(1).format(DateTimeFormatter.ofPattern("yyyy_MM_dd_HH_mm_ss"));
String name = "璐㈠姟涓婃姤" + time + ".csv";
String path = outPath + name;
CsvWriter writer = CsvUtil.getWriter(path, CharsetUtil.CHARSET_GBK);
writer.write(new String[]{"瀵煎嚭鏃堕棿锛�" + time});
writer.write(new String[]{});
- writer.write(new String[]{"鏃堕棿鑼冨洿锛�" + financeSubmit.getCreateTime().format(DateTimeFormatter.ofPattern("yyyyMMdd"))});
+ writer.write(new String[]{"鏃堕棿鑼冨洿锛�" + financeSubmit.getCreateTime().minusDays(1).format(DateTimeFormatter.ofPattern("yyyyMMdd"))});
writer.write(new String[]{});
writer.write(new String[]{});
List<Map<String, String>> head = JSON.parseObject(JSON.toJSONString(map.get("head")), List.class);
@@ -412,6 +427,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);
--
Gitblit v1.9.3