value
2024-04-27 06f256c166529b0c333171f76fd49eec4b66afe3
data-server/src/main/java/com/yuanchu/mom/controller/DataReportingController.java
@@ -6,6 +6,8 @@
import cn.hutool.core.text.csv.CsvReader;
import cn.hutool.core.text.csv.CsvRow;
import cn.hutool.core.text.csv.CsvUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yuanchu.mom.annotation.ValueAuth;
@@ -30,6 +32,9 @@
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
@RequestMapping("/dataReporting")
@@ -72,7 +77,7 @@
        return Result.success(dataReportingService.selectProductCountDtoPageList(page, productCountDto));
    }
    @ApiOperation(value = "获取登记人汇总列表")
    @ApiOperation(value = "获取员工数据统计列表")
    @PostMapping("/selectRegistrantCountDtoPageList")
    public Result selectRegistrantCountDtoPageList(@RequestBody Map<String, Object> data) {
        Page page = JSON.parseObject(JSON.toJSONString(data.get("page")), Page.class);
@@ -85,7 +90,17 @@
    public Result selectFansSubmitList(@RequestBody Map<String, Object> data) {
        Page page = JSON.parseObject(JSON.toJSONString(data.get("page")), Page.class);
        FansSubmit fansSubmit = JSON.parseObject(JSON.toJSONString(data.get("entity")), FansSubmit.class);
        if (ObjectUtil.isNotEmpty(fansSubmit.getCreateTime())){
            fansSubmit.setCreateTime(fansSubmit.getCreateTime().plusDays(1));
        }
        return Result.success(fansSubmitService.selectFansSubmitList(page, fansSubmit));
    }
    @ApiOperation(value = "获取进粉上报总数")
    @PostMapping("/countFansSubmitList")
    @ValueAuth
    public Result countFansSubmitList(@RequestBody FansSubmit fansSubmit) {
        return Result.success(fansSubmitService.countFansSubmitList(fansSubmit));
    }
    @ApiOperation(value = "删除进粉上报列表")
@@ -111,6 +126,9 @@
    public Result selectFinanceSubmitList(@RequestBody Map<String, Object> data) {
        Page page = JSON.parseObject(JSON.toJSONString(data.get("page")), Page.class);
        FinanceSubmit financeSubmit = JSON.parseObject(JSON.toJSONString(data.get("entity")), FinanceSubmit.class);
        if (ObjectUtil.isNotEmpty(financeSubmit.getCreateTime())){
            financeSubmit.setCreateTime(financeSubmit.getCreateTime().plusDays(1));
        }
        return Result.success(financeSubmitService.selectFinanceSubmitList(page, financeSubmit));
    }
@@ -200,7 +218,7 @@
                        break;
                }
            }
            list.add(reporting);
            if(reporting.getAccountConsumption().compareTo(BigDecimal.ZERO) > 0) list.add(reporting);
        }
        dataReportingService.addDataReporting(list, format, param);
        return Result.success();
@@ -376,6 +394,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
@@ -389,4 +414,25 @@
        List<DataReporting> list = JSON.parseArray(str, DataReporting.class);
        return Result.success(dataReportingService.updateVxCards(list));
    }
    @ApiOperation(value = "一键删除所有进粉上报的数据")
    @PostMapping("/deleteAllFans")
    public Result deleteAllFans(String date) {
        fansSubmitService.deleteAllFans(date);
        return Result.success();
    }
    @ApiOperation(value = "一键删除所有财务上报的数据")
    @PostMapping("/deleteAllFinance")
    public Result deleteAllFinance(String date) {
        financeSubmitService.deleteAllFinance(date);
        return Result.success();
    }
    @ApiOperation(value = "数据上报主管权限")
    @GetMapping("/dataReportingPower")
    public Result dataReportingPower() {
        return Result.success();
    }
}