From c918f2e5ce42202cd9360a610e382a6a13831eba Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Sat, 12 Oct 2024 18:15:46 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E8=80=97=E6=9D=90=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../domain/TbConsStockCountQueryCriteria.java | 38 ++++++++++++++++++ .../repository/TbConsInfoFlowRepository.java | 39 +++++++++++++------ .../cons/rest/TbConsInfoFlowController.java | 7 ++-- .../cons/service/TbConsInfoFlowService.java | 5 ++- .../impl/TbConsInfoFlowServiceImpl.java | 18 +++++---- .../product/ProductStockCountRepository.java | 4 +- 6 files changed, 84 insertions(+), 27 deletions(-) create mode 100644 eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java new file mode 100644 index 00000000..195b4785 --- /dev/null +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java @@ -0,0 +1,38 @@ +package cn.ysk.cashier.cons.domain; + +import cn.ysk.cashier.dto.BaseQueryDto; +import lombok.Data; +import org.apache.commons.lang3.StringUtils; + +import java.util.List; + +@Data +public class TbConsStockCountQueryCriteria extends BaseQueryDto { + + private Integer consId; + + private String conName; + + private String conTypeId; + + private String column; + + private List bizCode; + + private Integer page = 0; + + private Integer size = 10; + + public void setConTypeId(String conTypeId) { + if (StringUtils.isNotBlank(conTypeId)) { + this.conTypeId = conTypeId; + } + } + + + public void setConName(String conName) { + if (StringUtils.isNotBlank(conName)) { + this.conName = conName; + } + } +} \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java index 90c0a8d6..b01546f5 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java @@ -1,25 +1,40 @@ package cn.ysk.cashier.cons.repository; import cn.ysk.cashier.cons.domain.TbConsInfoFlow; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.Pageable; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.JpaSpecificationExecutor; import org.springframework.data.jpa.repository.Query; -/** -* @website https://eladmin.vip -* @author admin -* @date 2024-06-22 -**/ +import java.util.Date; +import java.util.List; + public interface TbConsInfoFlowRepository extends JpaRepository, JpaSpecificationExecutor { - @Query(value = "SELECT\n" + - "\tp.`name` \n" + - "FROM\n" + - "\ttb_product_sku s\n" + - "\tLEFT JOIN tb_product p ON s.product_id = p.id \n" + - "WHERE\n" + - "\ts.id = ?1",nativeQuery = true) + @Query(value = "SELECT " + + "p.`name` " + + " FROM " + + "tb_product_sku s" + + " LEFT JOIN tb_product p ON s.product_id = p.id " + + " WHERE " + + "s.id = ?1",nativeQuery = true) String selectByPskId(Integer skuId); + @Query("SELECT flow FROM TbConsInfoFlow flow " + + "INNER JOIN TbConsInfo cons ON flow.consId = cons.id " + + "AND cons.shopId = :shopId " + + "AND (:consId IS NULL OR cons.id = :consId) " + + "AND (:conTypeId IS NULL OR cons.conTypeId = :conTypeId) " + + "AND (:conName IS NULL OR cons.conName LIKE %:conName%) " + + "where flow.shopId = :shopId " + + "AND flow.createTime > :startTime " + + "AND flow.createTime < :endTime " + + "AND flow.bizName IN :types " + + "ORDER BY flow.id DESC") + Page findByConsParam(Integer shopId, Integer consId, String conName, String conTypeId, List types, + Date startTime, Date endTime, Pageable pageable); + + } \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java index 97e62295..e29d6eab 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java @@ -1,10 +1,9 @@ package cn.ysk.cashier.cons.rest; import cn.ysk.cashier.annotation.Log; +import cn.ysk.cashier.cons.domain.TbConsStockCountQueryCriteria; import cn.ysk.cashier.cons.service.TbConsInfoFlowService; import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowDto; -import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowQueryCriteria; -import cn.ysk.cashier.dto.product.TbProductStockCountQueryCriteria; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; @@ -38,13 +37,13 @@ public class TbConsInfoFlowController { @PostMapping("/count") @ApiOperation("耗材库存统计") - public ResponseEntity stockCount(@RequestBody TbProductStockCountQueryCriteria criteria) throws ParseException { + public ResponseEntity stockCount(@RequestBody TbConsStockCountQueryCriteria criteria) throws ParseException { return new ResponseEntity<>(tbConsInfoFlowService.stockCount(criteria),HttpStatus.OK); } @PostMapping("/stock") @ApiOperation("耗材库存记录列表") - public ResponseEntity queryPage(@RequestBody TbConsInfoFlowQueryCriteria criteria){ + public ResponseEntity queryPage(@RequestBody TbConsStockCountQueryCriteria criteria){ return new ResponseEntity<>(tbConsInfoFlowService.queryPage(criteria),HttpStatus.OK); } diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java index 2c4d7b9b..72036654 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java @@ -1,6 +1,7 @@ package cn.ysk.cashier.cons.service; import cn.ysk.cashier.cons.domain.TbConsInfoFlow; +import cn.ysk.cashier.cons.domain.TbConsStockCountQueryCriteria; import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowDto; import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowQueryCriteria; import cn.ysk.cashier.dto.product.TbProductStockCountQueryCriteria; @@ -34,8 +35,8 @@ public interface TbConsInfoFlowService { */ List queryAll(TbConsInfoFlowQueryCriteria criteria); - Map queryPage(TbConsInfoFlowQueryCriteria criteria); - TbProductStockCountVo stockCount(TbProductStockCountQueryCriteria criteria) throws ParseException; + Map queryPage(TbConsStockCountQueryCriteria criteria); + TbProductStockCountVo stockCount(TbConsStockCountQueryCriteria criteria) throws ParseException; Map stockList(TbProductStockCountQueryCriteria criteria) throws ParseException; void frmLoss(TbConsInfoFlowDto resources); diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java index 4c30d2a4..93f2e3e7 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java @@ -3,6 +3,7 @@ package cn.ysk.cashier.cons.service.impl; import cn.hutool.core.bean.copier.CopyOptions; import cn.ysk.cashier.cons.domain.TbConsInfo; import cn.ysk.cashier.cons.domain.TbConsInfoFlow; +import cn.ysk.cashier.cons.domain.TbConsStockCountQueryCriteria; import cn.ysk.cashier.cons.repository.TbConsInfoFlowRepository; import cn.ysk.cashier.cons.repository.TbConsInfoRepository; import cn.ysk.cashier.cons.service.TbConsInfoFlowService; @@ -74,7 +75,7 @@ public class TbConsInfoFlowServiceImpl implements TbConsInfoFlowService { //入库stockInNumber; stockIn //出库stockOutNumber; stockout @Override - public Map queryPage(TbConsInfoFlowQueryCriteria criteria){ + public Map queryPage(TbConsStockCountQueryCriteria criteria){ if(StringUtils.isNotBlank(criteria.getColumn())){ switch (criteria.getColumn()){ case "addCountNumber": @@ -104,25 +105,28 @@ public class TbConsInfoFlowServiceImpl implements TbConsInfoFlowService { case "stockOutNumber": criteria.setBizCode(Collections.singletonList("stockout")); break; + default: + criteria.setBizCode(Arrays.asList("stockIn","cancelCart","init","stockIn","checkStockIn","stockOtherIn","cancelCart","createCart","stockout","checkStockOut","frmLoss")); + break; } } Sort sort = Sort.by(Sort.Direction.DESC, "id"); Pageable pageable = PageRequest.of(criteria.getPage(), criteria.getSize(), sort); - - Page page = tbConsInfoFlowRepository.findAll((root, criteriaQuery, criteriaBuilder) - -> QueryHelp.getPredicate(root,criteria,criteriaBuilder),pageable); + Page page = tbConsInfoFlowRepository.findByConsParam( + criteria.getShopId(), criteria.getConsId(), criteria.getConName(),criteria.getConTypeId(), + criteria.getBizCode(),criteria.getStartTime(),criteria.getEndTime(),pageable); return PageUtil.toPage(page); } @Override - public TbProductStockCountVo stockCount(TbProductStockCountQueryCriteria criteria) throws ParseException { + public TbProductStockCountVo stockCount(TbConsStockCountQueryCriteria criteria) throws ParseException { if (criteria.getStartTime() == null || criteria.getEndTime() == null) { criteria.setEndTime(new Date());// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); criteria.setStartTime(sdf.parse("2024-01-01"));//创建2024年1月1日的Date对象 } - return stockRepository.consStockCount(criteria.getShopId(), criteria.getProductName(), - criteria.getCategoryId(), criteria.getStartTime(), criteria.getEndTime()); + return stockRepository.consStockCount(criteria.getShopId(), criteria.getConsId(), criteria.getConName(), + criteria.getConTypeId(), criteria.getStartTime(), criteria.getEndTime()); } @Override diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java index 39c4e010..8d6c6aa4 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java @@ -152,14 +152,14 @@ public interface ProductStockCountRepository extends JpaRepository :startTime " + " AND flow.createTime < :endTime ") - TbProductStockCountVo consStockCount(Integer shopId, - String conName, + TbProductStockCountVo consStockCount(Integer shopId, Integer consId, String conName, String conTypeId, Date startTime, Date endTime); } From 527b5f059c6698d3dd144dc8aacf0e6549ffa000 Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Sat, 12 Oct 2024 18:15:46 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E8=80=97=E6=9D=90=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../domain/TbConsStockCountQueryCriteria.java | 38 ++++++++++++++++++ .../repository/TbConsInfoFlowRepository.java | 39 +++++++++++++------ .../cons/rest/TbConsInfoFlowController.java | 7 ++-- .../cons/service/TbConsInfoFlowService.java | 5 ++- .../impl/TbConsInfoFlowServiceImpl.java | 18 +++++---- .../product/ProductStockCountRepository.java | 4 +- 6 files changed, 84 insertions(+), 27 deletions(-) create mode 100644 eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java new file mode 100644 index 00000000..195b4785 --- /dev/null +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java @@ -0,0 +1,38 @@ +package cn.ysk.cashier.cons.domain; + +import cn.ysk.cashier.dto.BaseQueryDto; +import lombok.Data; +import org.apache.commons.lang3.StringUtils; + +import java.util.List; + +@Data +public class TbConsStockCountQueryCriteria extends BaseQueryDto { + + private Integer consId; + + private String conName; + + private String conTypeId; + + private String column; + + private List bizCode; + + private Integer page = 0; + + private Integer size = 10; + + public void setConTypeId(String conTypeId) { + if (StringUtils.isNotBlank(conTypeId)) { + this.conTypeId = conTypeId; + } + } + + + public void setConName(String conName) { + if (StringUtils.isNotBlank(conName)) { + this.conName = conName; + } + } +} \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java index 90c0a8d6..b01546f5 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java @@ -1,25 +1,40 @@ package cn.ysk.cashier.cons.repository; import cn.ysk.cashier.cons.domain.TbConsInfoFlow; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.Pageable; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.JpaSpecificationExecutor; import org.springframework.data.jpa.repository.Query; -/** -* @website https://eladmin.vip -* @author admin -* @date 2024-06-22 -**/ +import java.util.Date; +import java.util.List; + public interface TbConsInfoFlowRepository extends JpaRepository, JpaSpecificationExecutor { - @Query(value = "SELECT\n" + - "\tp.`name` \n" + - "FROM\n" + - "\ttb_product_sku s\n" + - "\tLEFT JOIN tb_product p ON s.product_id = p.id \n" + - "WHERE\n" + - "\ts.id = ?1",nativeQuery = true) + @Query(value = "SELECT " + + "p.`name` " + + " FROM " + + "tb_product_sku s" + + " LEFT JOIN tb_product p ON s.product_id = p.id " + + " WHERE " + + "s.id = ?1",nativeQuery = true) String selectByPskId(Integer skuId); + @Query("SELECT flow FROM TbConsInfoFlow flow " + + "INNER JOIN TbConsInfo cons ON flow.consId = cons.id " + + "AND cons.shopId = :shopId " + + "AND (:consId IS NULL OR cons.id = :consId) " + + "AND (:conTypeId IS NULL OR cons.conTypeId = :conTypeId) " + + "AND (:conName IS NULL OR cons.conName LIKE %:conName%) " + + "where flow.shopId = :shopId " + + "AND flow.createTime > :startTime " + + "AND flow.createTime < :endTime " + + "AND flow.bizName IN :types " + + "ORDER BY flow.id DESC") + Page findByConsParam(Integer shopId, Integer consId, String conName, String conTypeId, List types, + Date startTime, Date endTime, Pageable pageable); + + } \ No newline at end of file diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java index 97e62295..e29d6eab 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java @@ -1,10 +1,9 @@ package cn.ysk.cashier.cons.rest; import cn.ysk.cashier.annotation.Log; +import cn.ysk.cashier.cons.domain.TbConsStockCountQueryCriteria; import cn.ysk.cashier.cons.service.TbConsInfoFlowService; import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowDto; -import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowQueryCriteria; -import cn.ysk.cashier.dto.product.TbProductStockCountQueryCriteria; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; @@ -38,13 +37,13 @@ public class TbConsInfoFlowController { @PostMapping("/count") @ApiOperation("耗材库存统计") - public ResponseEntity stockCount(@RequestBody TbProductStockCountQueryCriteria criteria) throws ParseException { + public ResponseEntity stockCount(@RequestBody TbConsStockCountQueryCriteria criteria) throws ParseException { return new ResponseEntity<>(tbConsInfoFlowService.stockCount(criteria),HttpStatus.OK); } @PostMapping("/stock") @ApiOperation("耗材库存记录列表") - public ResponseEntity queryPage(@RequestBody TbConsInfoFlowQueryCriteria criteria){ + public ResponseEntity queryPage(@RequestBody TbConsStockCountQueryCriteria criteria){ return new ResponseEntity<>(tbConsInfoFlowService.queryPage(criteria),HttpStatus.OK); } diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java index 2c4d7b9b..72036654 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java @@ -1,6 +1,7 @@ package cn.ysk.cashier.cons.service; import cn.ysk.cashier.cons.domain.TbConsInfoFlow; +import cn.ysk.cashier.cons.domain.TbConsStockCountQueryCriteria; import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowDto; import cn.ysk.cashier.cons.service.dto.TbConsInfoFlowQueryCriteria; import cn.ysk.cashier.dto.product.TbProductStockCountQueryCriteria; @@ -34,8 +35,8 @@ public interface TbConsInfoFlowService { */ List queryAll(TbConsInfoFlowQueryCriteria criteria); - Map queryPage(TbConsInfoFlowQueryCriteria criteria); - TbProductStockCountVo stockCount(TbProductStockCountQueryCriteria criteria) throws ParseException; + Map queryPage(TbConsStockCountQueryCriteria criteria); + TbProductStockCountVo stockCount(TbConsStockCountQueryCriteria criteria) throws ParseException; Map stockList(TbProductStockCountQueryCriteria criteria) throws ParseException; void frmLoss(TbConsInfoFlowDto resources); diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java index 4c30d2a4..93f2e3e7 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java @@ -3,6 +3,7 @@ package cn.ysk.cashier.cons.service.impl; import cn.hutool.core.bean.copier.CopyOptions; import cn.ysk.cashier.cons.domain.TbConsInfo; import cn.ysk.cashier.cons.domain.TbConsInfoFlow; +import cn.ysk.cashier.cons.domain.TbConsStockCountQueryCriteria; import cn.ysk.cashier.cons.repository.TbConsInfoFlowRepository; import cn.ysk.cashier.cons.repository.TbConsInfoRepository; import cn.ysk.cashier.cons.service.TbConsInfoFlowService; @@ -74,7 +75,7 @@ public class TbConsInfoFlowServiceImpl implements TbConsInfoFlowService { //入库stockInNumber; stockIn //出库stockOutNumber; stockout @Override - public Map queryPage(TbConsInfoFlowQueryCriteria criteria){ + public Map queryPage(TbConsStockCountQueryCriteria criteria){ if(StringUtils.isNotBlank(criteria.getColumn())){ switch (criteria.getColumn()){ case "addCountNumber": @@ -104,25 +105,28 @@ public class TbConsInfoFlowServiceImpl implements TbConsInfoFlowService { case "stockOutNumber": criteria.setBizCode(Collections.singletonList("stockout")); break; + default: + criteria.setBizCode(Arrays.asList("stockIn","cancelCart","init","stockIn","checkStockIn","stockOtherIn","cancelCart","createCart","stockout","checkStockOut","frmLoss")); + break; } } Sort sort = Sort.by(Sort.Direction.DESC, "id"); Pageable pageable = PageRequest.of(criteria.getPage(), criteria.getSize(), sort); - - Page page = tbConsInfoFlowRepository.findAll((root, criteriaQuery, criteriaBuilder) - -> QueryHelp.getPredicate(root,criteria,criteriaBuilder),pageable); + Page page = tbConsInfoFlowRepository.findByConsParam( + criteria.getShopId(), criteria.getConsId(), criteria.getConName(),criteria.getConTypeId(), + criteria.getBizCode(),criteria.getStartTime(),criteria.getEndTime(),pageable); return PageUtil.toPage(page); } @Override - public TbProductStockCountVo stockCount(TbProductStockCountQueryCriteria criteria) throws ParseException { + public TbProductStockCountVo stockCount(TbConsStockCountQueryCriteria criteria) throws ParseException { if (criteria.getStartTime() == null || criteria.getEndTime() == null) { criteria.setEndTime(new Date());// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); criteria.setStartTime(sdf.parse("2024-01-01"));//创建2024年1月1日的Date对象 } - return stockRepository.consStockCount(criteria.getShopId(), criteria.getProductName(), - criteria.getCategoryId(), criteria.getStartTime(), criteria.getEndTime()); + return stockRepository.consStockCount(criteria.getShopId(), criteria.getConsId(), criteria.getConName(), + criteria.getConTypeId(), criteria.getStartTime(), criteria.getEndTime()); } @Override diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java index 39c4e010..8d6c6aa4 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java @@ -152,14 +152,14 @@ public interface ProductStockCountRepository extends JpaRepository :startTime " + " AND flow.createTime < :endTime ") - TbProductStockCountVo consStockCount(Integer shopId, - String conName, + TbProductStockCountVo consStockCount(Integer shopId, Integer consId, String conName, String conTypeId, Date startTime, Date endTime); } From f120867e3594deb67fd9413c94b8e9c4f0d56d73 Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Sat, 12 Oct 2024 18:26:54 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E8=80=97=E6=9D=90=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cons/domain/TbConsStockCountQueryCriteria.java | 8 +------- .../cashier/cons/repository/TbConsInfoFlowRepository.java | 2 +- .../ysk/cashier/cons/rest/TbConsInfoFlowController.java | 2 +- .../ysk/cashier/cons/service/TbConsInfoFlowService.java | 2 +- .../cons/service/impl/TbConsInfoFlowServiceImpl.java | 7 ++++++- .../repository/product/ProductStockCountRepository.java | 2 +- 6 files changed, 11 insertions(+), 12 deletions(-) diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java index 195b4785..7c2e24f5 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/domain/TbConsStockCountQueryCriteria.java @@ -13,7 +13,7 @@ public class TbConsStockCountQueryCriteria extends BaseQueryDto { private String conName; - private String conTypeId; + private Integer conTypeId; private String column; @@ -23,12 +23,6 @@ public class TbConsStockCountQueryCriteria extends BaseQueryDto { private Integer size = 10; - public void setConTypeId(String conTypeId) { - if (StringUtils.isNotBlank(conTypeId)) { - this.conTypeId = conTypeId; - } - } - public void setConName(String conName) { if (StringUtils.isNotBlank(conName)) { diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java index b01546f5..e8e77ffd 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java @@ -33,7 +33,7 @@ public interface TbConsInfoFlowRepository extends JpaRepository findByConsParam(Integer shopId, Integer consId, String conName, String conTypeId, List types, + Page findByConsParam(Integer shopId, Integer consId, String conName, Integer conTypeId, List types, Date startTime, Date endTime, Pageable pageable); diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java index e29d6eab..b555391f 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/rest/TbConsInfoFlowController.java @@ -43,7 +43,7 @@ public class TbConsInfoFlowController { @PostMapping("/stock") @ApiOperation("耗材库存记录列表") - public ResponseEntity queryPage(@RequestBody TbConsStockCountQueryCriteria criteria){ + public ResponseEntity queryPage(@RequestBody TbConsStockCountQueryCriteria criteria) throws ParseException { return new ResponseEntity<>(tbConsInfoFlowService.queryPage(criteria),HttpStatus.OK); } diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java index 72036654..a9e62631 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/TbConsInfoFlowService.java @@ -35,7 +35,7 @@ public interface TbConsInfoFlowService { */ List queryAll(TbConsInfoFlowQueryCriteria criteria); - Map queryPage(TbConsStockCountQueryCriteria criteria); + Map queryPage(TbConsStockCountQueryCriteria criteria) throws ParseException; TbProductStockCountVo stockCount(TbConsStockCountQueryCriteria criteria) throws ParseException; Map stockList(TbProductStockCountQueryCriteria criteria) throws ParseException; diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java index 93f2e3e7..56c45ecf 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoFlowServiceImpl.java @@ -75,7 +75,12 @@ public class TbConsInfoFlowServiceImpl implements TbConsInfoFlowService { //入库stockInNumber; stockIn //出库stockOutNumber; stockout @Override - public Map queryPage(TbConsStockCountQueryCriteria criteria){ + public Map queryPage(TbConsStockCountQueryCriteria criteria) throws ParseException { + if (criteria.getStartTime() == null || criteria.getEndTime() == null) { + criteria.setEndTime(new Date());// + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + criteria.setStartTime(sdf.parse("2024-01-01"));//创建2024年1月1日的Date对象 + } if(StringUtils.isNotBlank(criteria.getColumn())){ switch (criteria.getColumn()){ case "addCountNumber": diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java index 8d6c6aa4..883f3c72 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/ProductStockCountRepository.java @@ -160,6 +160,6 @@ public interface ProductStockCountRepository extends JpaRepository :startTime " + " AND flow.createTime < :endTime ") TbProductStockCountVo consStockCount(Integer shopId, Integer consId, String conName, - String conTypeId, Date startTime, Date endTime); + Integer conTypeId, Date startTime, Date endTime); } From cab483a7b9acffd709b0e72f9d9bcbdf624cf68d Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Mon, 14 Oct 2024 09:13:51 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E8=80=97=E6=9D=90=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ysk/cashier/cons/repository/TbConsInfoFlowRepository.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java index e8e77ffd..ad3991f2 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/repository/TbConsInfoFlowRepository.java @@ -31,7 +31,7 @@ public interface TbConsInfoFlowRepository extends JpaRepository :startTime " + "AND flow.createTime < :endTime " + - "AND flow.bizName IN :types " + + "AND flow.bizCode IN :types " + "ORDER BY flow.id DESC") Page findByConsParam(Integer shopId, Integer consId, String conName, Integer conTypeId, List types, Date startTime, Date endTime, Pageable pageable);