java_project
/
logisticsplatform-service
4
0
Fork 0
Code Issues Pull Requests Activity
Browse Source

feat(all): 增加报表查询时间验证和仓库权限

dist.1.3.0
zhaoqiaobo 10 months ago
parent
031313fa1b
commit
8dae7c6ef3
6 changed files with 152 additions and 96 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 29
      blade-service/logpm-report/src/main/java/com/logpm/report/controller/ReportBillLoadingController.java
  2. 15
      blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportBillLoadingAsyncService.java
  3. 77
      blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java
  4. 13
      blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportStockServiceImpl.java
  5. 41
      blade-service/logpm-report/src/main/java/com/logpm/report/util/CheckDataUtil.java
  6. 71
      blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportUtil.java

29
blade-service/logpm-report/src/main/java/com/logpm/report/controller/ReportBillLoadingController.java
Unescape View File

@ -1,12 +1,7 @@
package com.logpm.report.controller;
import cn.hutool.core.util.EnumUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import com.logpm.factorydata.enums.BrandEnums;
import org.springblade.common.constant.WorkNodeEnums;
import com.logpm.factorydata.util.FactoryDataMessageSender;
import com.logpm.factorydata.vo.NodePushMsg;
import com.logpm.report.query.BillDetailsQuery;
import com.logpm.report.query.BillLoadingTasksQuery;
import com.logpm.report.service.IReportBillLoadingAsyncService;
@ -17,15 +12,10 @@ import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletResponse;
import java.util.Date;
import java.util.List;
import java.util.Map;
/**
* 自提报表前端控制器
@ -41,25 +31,6 @@ public class ReportBillLoadingController {
private IReportBillLoadingAsyncService reportBillLoadingAsyncService;
private final FactoryDataMessageSender sender;
@PostMapping("/sendMessage")
@ApiOperation(value = "发送消息测试", notes = "发送消息测试")
public R<String> tasksPage(@RequestBody Map map) {
String node = (String) map.get("node");
WorkNodeEnums workNodeEnums = EnumUtil.fromString(WorkNodeEnums.class, node);
NodePushMsg build = NodePushMsg.builder()
.node(workNodeEnums)
.brand(BrandEnums.ZB)
.operatorTime(new Date())
.operator((String) map.get("operator"))
.address((String) map.get("address"))
.content((List<Object>) map.get("content"))
.build();
sender.sendNodeDataByBrand(build);
return R.data("成功");
}
@GetMapping("/tasks")
@ApiOperationSupport(order = 1)
@ApiOperation(value = "自提任务维度", notes = "自提任务维度")

15
blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportBillLoadingAsyncService.java
Unescape View File

@ -5,6 +5,7 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
import com.logpm.report.constant.ReportConstants;
import com.logpm.report.mapper.ReportBillLoadingMapper;
import com.logpm.report.query.BillDetailsQuery;
@ -14,6 +15,7 @@ import com.logpm.report.reader.BillLoadingTasksReader;
import com.logpm.report.service.IReportBillLoadingAsyncService;
import com.logpm.report.util.QueryUtil;
import com.logpm.report.util.ReportExcelUtil;
import com.logpm.report.util.ReportUtil;
import com.logpm.report.vo.BillLoadingDetailsVO;
import com.logpm.report.vo.BillLoadingTasksVO;
import lombok.AllArgsConstructor;
@ -48,12 +50,16 @@ public class ReportBillLoadingAsyncService implements IReportBillLoadingAsyncSer
private final BillLoadingDetailsReader billLoadingDetailsReader;
private final BillLoadingTasksReader billLoadingTasksReader;
private final IUserClient userClient;
private final IBasicdataWarehouseClient warehouseClient;
@Override
public IPage<BillLoadingTasksVO> tasksPage(BillLoadingTasksVO vo, BillLoadingTasksQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getCreatedTime(), query.getStartCreatedTime(), query.getEndCreatedTime(), "提货时间");
IPage<BillLoadingTasksVO> page = Condition.getPage(query);
QueryWrapper<BillLoadingTasksVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, BillLoadingTasksVO.class);
tasksCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouse(), query.getWarehouseRange(), queryWrapper, warehouseClient);
List<BillLoadingTasksVO> detailsPage = reportBillLoadingMapper.getTasksPage(page, queryWrapper);
return page.setRecords(detailsPage);
}
@ -74,17 +80,23 @@ public class ReportBillLoadingAsyncService implements IReportBillLoadingAsyncSer
@Override
public void exportTasks(HttpServletResponse response, BillLoadingTasksVO vo, BillLoadingTasksQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getCreatedTime(), query.getStartCreatedTime(), query.getEndCreatedTime(), "提货时间");
QueryWrapper<BillLoadingTasksVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, BillLoadingTasksVO.class);
tasksCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouse(), query.getWarehouseRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, billLoadingTasksReader, BillLoadingTasksVO.class, queryWrapper, "自提任务维度报表");
}
@Override
public IPage<BillLoadingDetailsVO> detailsPage(BillLoadingDetailsVO vo, BillDetailsQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getScanTime(), query.getStartScanTime(), query.getEndScanTime(), "提货扫描时间");
IPage<BillLoadingDetailsVO> page = Condition.getPage(query);
QueryWrapper<BillLoadingDetailsVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, BillLoadingDetailsVO.class);
// 自定义查询
detailsCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouse(), query.getWarehouseRange(), queryWrapper, warehouseClient);
List<BillLoadingDetailsVO> detailsPage = reportBillLoadingMapper.getDetailsPage(page, queryWrapper);
if (CollUtil.isNotEmpty(detailsPage)) {
// 组装数据批量去查询用户名称
@ -128,8 +140,11 @@ public class ReportBillLoadingAsyncService implements IReportBillLoadingAsyncSer
@Override
public void exportDetails(HttpServletResponse response, BillLoadingDetailsVO vo, BillDetailsQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getScanTime(), query.getStartScanTime(), query.getEndScanTime(), "提货扫描时间");
QueryWrapper<BillLoadingDetailsVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, BillLoadingDetailsVO.class);
detailsCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouse(), query.getWarehouseRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, billLoadingDetailsReader, BillLoadingDetailsVO.class, queryWrapper, "自提明细");
}
}

77
blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java
Unescape View File

@ -6,7 +6,6 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
import com.logpm.report.dto.DeliveryTrainLoadedScanDTO;
import com.logpm.report.mapper.ReportDeliverMapeer;
@ -19,22 +18,23 @@ import com.logpm.report.reader.DeliveryDetailReader;
import com.logpm.report.reader.DeliveryTrainReader;
import com.logpm.report.reader.StockOrderReader;
import com.logpm.report.service.ReportDeliverService;
import com.logpm.report.util.CheckDataUtil;
import com.logpm.report.util.QueryUtil;
import com.logpm.report.util.ReportExcelUtil;
import com.logpm.report.util.ReportUtil;
import com.logpm.report.vo.ReportCustomerVO;
import com.logpm.report.vo.ReportDetailVO;
import com.logpm.report.vo.ReportDevilerVO;
import com.logpm.report.vo.StockOrderVO;
import lombok.AllArgsConstructor;
import org.jetbrains.annotations.NotNull;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.support.Condition;
import org.springframework.stereotype.Service;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@ -49,6 +49,7 @@ import java.util.stream.Collectors;
@AllArgsConstructor
public class ReportDeliverServiceImpl implements ReportDeliverService {
private static final Logger log = LoggerFactory.getLogger(ReportDeliverServiceImpl.class);
private final ReportDeliverMapeer reportDeliverMapeer;
private final DeliveryTrainReader deliveryTrainReader;
private final DeliveryCustomerReader deliveryCustomerReader;
@ -59,7 +60,7 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
@Override
public IPage<ReportDevilerVO> deliveryTrainPage(ReportDevilerVO vo, ReportDevilerQuery query) {
// 校验时间
dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime());
ReportUtil.dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime(), "配送日期");
IPage<ReportDevilerVO> page = Condition.getPage(query);
QueryWrapper<ReportDevilerVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportDevilerVO.class);
// 自定义 sql 查询条件
@ -68,17 +69,15 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
// 1 如果用户页面选择了仓库，按选择的仓库查询。
// 2 用户页面没有选择仓库，但是切换了仓库，按切换的仓库查
// 3 用户没有选择仓库，也没有切换仓库，按用户当前所有仓查询
if (StrUtil.isEmpty(vo.getWarehouseName())) {
BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
if (ObjectUtil.isNotEmpty(myCurrentWarehouse)) {
queryWrapper.eq("warehouse_id", myCurrentWarehouse.getId());
} else {
List<BasicdataWarehouseEntity> warehouseEntities = warehouseClient.getMyWarehouseList();
queryWrapper.in("warehouse_id", warehouseEntities.stream().map(BasicdataWarehouseEntity::getId).collect(Collectors.toList()));
}
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
// 查询数据
List<ReportDevilerVO> deliveryTrainPage = reportDeliverMapeer.getDeliveryTrainPage(page, queryWrapper);
// 异步组装统计数据
asyncBuildDeliveryTrainPage(deliveryTrainPage);
return page.setRecords(deliveryTrainPage);
}
List<ReportDevilerVO> deliveryTrainPage = reportDeliverMapeer.getDeliveryTrainPage(page, queryWrapper);
private void asyncBuildDeliveryTrainPage(List<ReportDevilerVO> deliveryTrainPage) {
List<Long> ids = deliveryTrainPage.stream().map(ReportDevilerVO::getId).collect(Collectors.toList());
// 异步查询扫描装车和异常扫描装车数据
if (CollUtil.isNotEmpty(ids)) {
@ -93,12 +92,12 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
CompletableFuture<Void> allFutures = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));
allFutures.join();
} catch (Exception e) {
log.error("系统异常：{}", e);
}
}
return page.setRecords(deliveryTrainPage);
}
private @NotNull CompletableFuture<List<DeliveryTrainLoadedScanDTO>> getTrainLoadedScanInvnFuture(List<Long> idBatch, List<ReportDevilerVO> deliveryTrainPage) {
CompletableFuture<List<DeliveryTrainLoadedScanDTO>> future = CompletableFuture.supplyAsync(() ->
reportDeliverMapeer.getDeliveryTrainLoadSacnInvnByIds(idBatch));
@ -151,15 +150,6 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
return future;
}
private static void dateIsWithinOneMonth(String taskTime, Date startTaskTime, Date endTaskTime) {
if (ObjectUtil.isEmpty(taskTime)) {
boolean withinOneMonth = CheckDataUtil.isWithinOneMonth(startTaskTime, endTaskTime);
if (!withinOneMonth) {
throw new ServiceException("日期必选且日期只能选择一个月");
}
}
}
private void trainCustomQuery(ReportDevilerQuery query, QueryWrapper<ReportDevilerVO> queryWrapper) {
// 配送时间开始
QueryUtil.timeGe("task_time", query.getStartTaskTime(), queryWrapper);
@ -179,19 +169,26 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
@Override
public void exportTrain(HttpServletResponse response, ReportDevilerVO vo, ReportDevilerQuery query) {
dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime());
// 添加时间校验
ReportUtil.dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime(), "配送日期");
QueryWrapper<ReportDevilerVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportDevilerVO.class);
trainCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, deliveryTrainReader, ReportDevilerVO.class, queryWrapper, "配送车次维度报表");
}
@Override
public IPage<ReportCustomerVO> customerPage(ReportCustomerVO vo, ReportCustomerQuery query) {
// 添加时间校验
ReportUtil.dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime(), "配送日期");
// 构建前端查询参数
IPage<ReportCustomerVO> page = Condition.getPage(query);
QueryWrapper<ReportCustomerVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportCustomerVO.class);
// 自定义查询
customerCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
return page.setRecords(reportDeliverMapeer.getCustomerPage(page, queryWrapper));
}
@ -216,18 +213,26 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
@Override
public void exportCustomer(HttpServletResponse response, ReportCustomerVO vo, ReportCustomerQuery query) {
// 添加时间校验
ReportUtil.dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime(), "配送日期");
QueryWrapper<ReportCustomerVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportCustomerVO.class);
customerCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, deliveryCustomerReader, ReportCustomerVO.class, queryWrapper, "配送客户维度报表");
}
@Override
public IPage<ReportDetailVO> detailsPage(ReportDetailVO vo, DevilerDetailsQuery query) {
// 添加时间校验
ReportUtil.dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime(), "配送日期");
Integer current = query.getCurrent();
Integer size = query.getSize();
IPage<ReportDetailVO> page = Condition.getPage(query);
QueryWrapper<ReportDetailVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportDetailVO.class);
detailsCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
List<ReportDetailVO> detailsPage = reportDeliverMapeer.getDetailsPage(page, queryWrapper);
// 包件总数
long total = page.getTotal();
@ -273,16 +278,29 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
@Override
public void exportDetails(HttpServletResponse response, ReportDetailVO vo, DevilerDetailsQuery query) {
// 添加时间校验
ReportUtil.dateIsWithinOneMonth(vo.getTaskTime(), query.getStartTaskTime(), query.getEndTaskTime(), "配送日期");
QueryWrapper<ReportDetailVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportDetailVO.class);
detailsCustomQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, deliveryDetailReader, ReportDetailVO.class, queryWrapper, "配送明细报表");
}
@Override
public IPage<StockOrderVO> stockOrderPage(StockOrderVO vo, StockOrderQuery query) {
// 添加时间校验
if (ObjectUtil.isEmpty(vo.getWarehouseEntryTime())) {
boolean withinOneMonth = ReportUtil.isWithinOneMonth(query.getStartWarehouseEntryTime(), query.getEndWarehouseEntryTime());
if (!withinOneMonth) {
throw new ServiceException("入库时间必选且时间不超过一个月");
}
}
IPage<StockOrderVO> page = Condition.getPage(query);
QueryWrapper<StockOrderVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, StockOrderVO.class);
stockOrderQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouse(), query.getWarehouseRange(), queryWrapper, warehouseClient);
return page.setRecords(reportDeliverMapeer.getStockOrderPage(page, queryWrapper));
}
@ -304,8 +322,17 @@ public class ReportDeliverServiceImpl implements ReportDeliverService {
@Override
public void exportStockOrder(HttpServletResponse response, StockOrderVO vo, StockOrderQuery query) {
// 添加时间校验
if (ObjectUtil.isEmpty(vo.getWarehouseEntryTime())) {
boolean withinOneMonth = ReportUtil.isWithinOneMonth(query.getStartWarehouseEntryTime(), query.getEndWarehouseEntryTime());
if (!withinOneMonth) {
throw new ServiceException("入库时间必选且时间不超过一个月");
}
}
QueryWrapper<StockOrderVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, StockOrderVO.class);
stockOrderQuery(query, queryWrapper);
// 仓库权限
ReportUtil.buildReportWarehouseAuth(vo.getWarehouse(), query.getWarehouseRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, stockOrderReader, StockOrderVO.class, queryWrapper, "在库订单表");
}

13
blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportStockServiceImpl.java
Unescape View File

@ -5,6 +5,7 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
import com.logpm.report.mapper.ReportStockMapeer;
import com.logpm.report.query.StockDetailsQuery;
import com.logpm.report.query.StockInQuery;
@ -15,6 +16,7 @@ import com.logpm.report.reader.DeliveryStockReader;
import com.logpm.report.service.ReportStockService;
import com.logpm.report.util.QueryUtil;
import com.logpm.report.util.ReportExcelUtil;
import com.logpm.report.util.ReportUtil;
import com.logpm.report.vo.ReportInStockVO;
import com.logpm.report.vo.ReportOutStockVO;
import com.logpm.report.vo.StockDetailsVO;
@ -41,12 +43,14 @@ public class ReportStockServiceImpl implements ReportStockService {
private final DeliveryInStocksReader inStocksReader;
private final DeliveryOutStocksReader outStocksReader;
private final IDictBizClient dictBizClient;
private final IBasicdataWarehouseClient warehouseClient;
@Override
public IPage<StockDetailsVO> detailsPage(StockDetailsVO vo, StockDetailsQuery query) {
IPage<StockDetailsVO> page = Condition.getPage(query);
QueryWrapper<StockDetailsVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, StockDetailsVO.class);
detailsCustomQuery(query, queryWrapper);
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
return page.setRecords(reportStockMapeer.getDetailPage(page, queryWrapper));
}
@ -67,14 +71,17 @@ public class ReportStockServiceImpl implements ReportStockService {
public void exportDetails(HttpServletResponse response, StockDetailsVO vo, StockDetailsQuery query) {
QueryWrapper<StockDetailsVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, StockDetailsVO.class);
detailsCustomQuery(query, queryWrapper);
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, deliveryStockReader, StockDetailsVO.class, queryWrapper, "库存品表");
}
@Override
public IPage<ReportInStockVO> inStocks(ReportInStockVO vo, StockInQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getWarehousingTime(), query.getStartWarehousingTime(), query.getEndWarehousingTime(), "入库时间");
IPage<ReportInStockVO> page = Condition.getPage(query);
QueryWrapper<ReportInStockVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportInStockVO.class);
inStocksCustomQuery(query, queryWrapper);
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
List<ReportInStockVO> inStocks = reportStockMapeer.getInStocks(page, queryWrapper);
if (CollUtil.isNotEmpty(inStocks)) {
for (ReportInStockVO inStock : inStocks) {
@ -112,16 +119,20 @@ public class ReportStockServiceImpl implements ReportStockService {
@Override
public void exportInStocks(HttpServletResponse response, ReportInStockVO vo, StockInQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getWarehousingTime(), query.getStartWarehousingTime(), query.getEndWarehousingTime(), "入库时间");
QueryWrapper<ReportInStockVO> queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportInStockVO.class);
inStocksCustomQuery(query, queryWrapper);
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, inStocksReader, ReportInStockVO.class, queryWrapper, "库存入库表");
}
@Override
public IPage<ReportOutStockVO> outStocks(ReportOutStockVO vo, StockOutQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getCreateTime(), query.getStartCreateTime(), query.getEndCreateTime(), "出库时间");
IPage<ReportOutStockVO> page = Condition.getPage(query);
QueryWrapper queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportOutStockVO.class);
outStocksCustomQuery(query, queryWrapper);
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
return page.setRecords(reportStockMapeer.getOutStocks(page, queryWrapper));
}
@ -143,8 +154,10 @@ public class ReportStockServiceImpl implements ReportStockService {
@Override
public void exportOutStocks(HttpServletResponse response, ReportOutStockVO vo, StockOutQuery query) {
ReportUtil.dateIsWithinOneMonth(vo.getCreateTime(), query.getStartCreateTime(), query.getEndCreateTime(), "出库时间");
QueryWrapper queryWrapper = QueryUtil.buildQueryWrapper(vo, ReportOutStockVO.class);
outStocksCustomQuery(query, queryWrapper);
ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient);
new ReportExcelUtil().export(response, outStocksReader, ReportOutStockVO.class, queryWrapper, "库存出库表");
}

41
blade-service/logpm-report/src/main/java/com/logpm/report/util/CheckDataUtil.java
Unescape View File

@ -1,41 +0,0 @@
package com.logpm.report.util;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import java.util.Date;
/**
* 数据校验工具类
*
* @Author zqb
* @Date 2024/6/13
**/
public class CheckDataUtil {
/**
* 校验两个时间相差不超过 30 天
* 如果不跨月则返回 true
* 如果跨月则不超过 30 天
*
* @Param start 开始时间
* @Param end 解释时间
* @Return boolean
* @Author zqb 2024/6/13
**/
public static boolean isWithinOneMonth(Date start, Date end) {
// 检查输入是否为null
if (start == null || end == null) {
return false;
}
// 是否跨月，不跨越则直接返回true
if (DateUtil.year(start) == DateUtil.year(end) && DateUtil.month(start) == DateUtil.month(end)) {
return true;
}
// 跨越则判断两个日期是否相差超过30天
return DateUtil.between(start, end, DateUnit.DAY) <= 30;
}
}

71
blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportUtil.java
Unescape View File

@ -0,0 +1,71 @@
package com.logpm.report.util;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
import org.springblade.core.log.exception.ServiceException;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
/**
* 报表工具类
*
* @Author zqb
* @Date 2024/6/13
**/
public class ReportUtil {
/**
* 校验两个时间相差不超过 30 天
* 如果不跨月则返回 true
* 如果跨月则不超过 30 天
*
* @Param start 开始时间
* @Param end 解释时间
* @Return boolean
* @Author zqb 2024/6/13
**/
public static boolean isWithinOneMonth(Date start, Date end) {
// 检查输入是否为null
if (start == null || end == null) {
return false;
}
// 是否跨月，不跨越则直接返回true
if (DateUtil.year(start) == DateUtil.year(end) && DateUtil.month(start) == DateUtil.month(end)) {
return true;
}
// 跨越则判断两个日期是否相差超过30天
return DateUtil.between(start, end, DateUnit.DAY) <= 30;
}
public static void buildReportWarehouseAuth(String warehouseName, String warehouseNameRange,
QueryWrapper queryWrapper, IBasicdataWarehouseClient warehouseClient) {
if (StrUtil.isEmpty(warehouseName) && StrUtil.isEmpty(warehouseNameRange)) {
BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
if (ObjectUtil.isNotEmpty(myCurrentWarehouse)) {
queryWrapper.eq("warehouse_id", myCurrentWarehouse.getId());
} else {
List<BasicdataWarehouseEntity> warehouseEntities = warehouseClient.getMyWarehouseList();
queryWrapper.in("warehouse_id", warehouseEntities.stream().map(BasicdataWarehouseEntity::getId).collect(Collectors.toList()));
}
}
}
public static void dateIsWithinOneMonth(String taskTime, Date startTaskTime, Date endTaskTime, String title) {
if (ObjectUtil.isEmpty(taskTime)) {
boolean withinOneMonth = isWithinOneMonth(startTaskTime, endTaskTime);
if (!withinOneMonth) {
throw new ServiceException(title + "必选且时间不超过一个月");
}
}
}
}
Write Preview
Loading…
Cancel
Save