From fcaba6d5117778bd5c0f99494bd7fd1890bc6273 Mon Sep 17 00:00:00 2001 From: SongZhang <2064194730@qq.com> Date: Sat, 17 Aug 2024 16:52:29 +0800 Subject: [PATCH 1/4] =?UTF-8?q?1.=E5=95=86=E5=93=81=E4=B8=8D=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/ysk/cashier/repository/product/TbProductRepository.java | 3 +++ .../ysk/cashier/service/impl/productimpl/StockServiceImpl.java | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java index 8ec66a96..3c9bb447 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java @@ -66,4 +66,7 @@ public interface TbProductRepository extends JpaRepository, @Query(value = "select b.* from tb_product_sku as a left join tb_product as b on a.product_id=b.id where a.id=:skuId", nativeQuery = true) TbProduct selectBySkuId(@Param("skuId") Integer skuId); + @Query(value = "select * from tb_product_sku as a where a.id=:skuId", nativeQuery = true) + TbProduct selectById(@Param("skuId") Integer skuId); + } diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/StockServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/StockServiceImpl.java index 3f49b4c4..c6611709 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/StockServiceImpl.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/StockServiceImpl.java @@ -365,7 +365,7 @@ public class StockServiceImpl implements StockService { break; case "pauseSale": sqlQuery.append(" set is_pause_sale = ").append(updateValueVO.getUpdateValue()); - TbProduct product1 = tbProductRepository.selectBySkuId(Integer.valueOf(updateValueVO.getTargetId())); + TbProduct product1 = tbProductRepository.selectById(Integer.valueOf(updateValueVO.getTargetId())); // 推送微信操作消息 if (product1 != null) { wxMsgUtils.aboardOperationMsg(("0".equals(updateValueVO.getUpdateValue()) ? "关闭售罄: " : "开启售罄: ") + product1.getName(), Integer.valueOf(updateValueVO.getShopId())); From e8f9af93e867ba7fc91dc24f3d5d025f33496866 Mon Sep 17 00:00:00 2001 From: SongZhang <2064194730@qq.com> Date: Sat, 17 Aug 2024 16:57:51 +0800 Subject: [PATCH 2/4] =?UTF-8?q?1.=E5=95=86=E5=93=81=E4=B8=8D=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/ysk/cashier/repository/product/TbProductRepository.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java index 3c9bb447..b28da69f 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java @@ -66,7 +66,7 @@ public interface TbProductRepository extends JpaRepository, @Query(value = "select b.* from tb_product_sku as a left join tb_product as b on a.product_id=b.id where a.id=:skuId", nativeQuery = true) TbProduct selectBySkuId(@Param("skuId") Integer skuId); - @Query(value = "select * from tb_product_sku as a where a.id=:skuId", nativeQuery = true) + @Query(value = "select * from tb_product as a where a.id=:skuId", nativeQuery = true) TbProduct selectById(@Param("skuId") Integer skuId); } From e1499150f9cbf3ed7fae415040b0a468c83525be Mon Sep 17 00:00:00 2001 From: GYJ <1157756119@qq.com> Date: Sun, 18 Aug 2024 20:24:26 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=BA=93=E5=AD=98?= =?UTF-8?q?=E5=BC=80=E5=85=B3=E5=AF=BC=E8=87=B4=E6=95=B0=E6=8D=AE=E7=BC=BA?= =?UTF-8?q?=E5=A4=B1=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/TbConsInfoServiceImpl.java | 89 ++++++++++--------- 1 file changed, 49 insertions(+), 40 deletions(-) diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoServiceImpl.java index c40a90fc..dd13bf61 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoServiceImpl.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/cons/service/impl/TbConsInfoServiceImpl.java @@ -1,6 +1,7 @@ package cn.ysk.cashier.cons.service.impl; import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.StrUtil; import cn.ysk.cashier.cons.domain.*; import cn.ysk.cashier.cons.repository.TbConsInfoFlowRepository; import cn.ysk.cashier.cons.repository.TbConsInfoRepository; @@ -71,7 +72,6 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { private final TbProductStockOperateRepository tbProductStockOperateRepository; - @Override public Map queryAll(TbConsInfoQueryCriteria criteria, Pageable pageable) { Page page = tbConsInfoRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root, criteria, criteriaBuilder), pageable); @@ -81,9 +81,9 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { @Override public List queryAll(TbConsInfoQueryCriteria criteria) { - List list= tbConsInfoMapper.toDto(tbConsInfoRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root, criteria, criteriaBuilder))); - if(Objects.nonNull(list)&&list.size()>0){ - list.parallelStream().forEach(it->{ + List list = tbConsInfoMapper.toDto(tbConsInfoRepository.findAll((root, criteriaQuery, criteriaBuilder) -> QueryHelp.getPredicate(root, criteria, criteriaBuilder))); + if (Objects.nonNull(list) && list.size() > 0) { + list.parallelStream().forEach(it -> { it.setContypeCode(tbConsTypeRepository.findById(it.getConTypeId()).orElseGet(TbConsType::new).getConTypeCode()); }); } @@ -115,14 +115,14 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { // } - resource.setConCode(StringCodeUtil.getRandom(8,LETTER_CAPITAL_NUMBER)); + resource.setConCode(StringCodeUtil.getRandom(8, LETTER_CAPITAL_NUMBER)); resource.setConTypeName(tbConsType.getConTypeName()); resource.setLasterInStock(BigDecimal.ZERO); resource.setStockNumber(BigDecimal.ZERO); resource.setStatus("1"); resource.setStockConsume(BigDecimal.ZERO); resource.setCreateTime(new Timestamp(System.currentTimeMillis())); - resource=tbConsInfoRepository.save(resource); + resource = tbConsInfoRepository.save(resource); TbConsInfoFlow flow = new TbConsInfoFlow(); @@ -140,7 +140,6 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { tbConsInfoFlowRepository.save(flow); - } return tbConsInfoMapper.toDto(new TbConsInfo()); } @@ -155,12 +154,24 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { throw new Exception("耗材信息不存在"); } - tbConsInfo.setConName(resource.getConName()); - tbConsInfo.setPrice(resource.getPrice()); - tbConsInfo.setConUnit(resource.getConUnit()); - tbConsInfo.setConWarning(resource.getConWarning()); - tbConsInfo.setStatus(resource.getStatus()); - tbConsInfo.setIsCheck(resource.getIsCheck()); + if (StrUtil.isNotBlank(resource.getConName())) { + tbConsInfo.setConName(resource.getConName()); + } + if (resource.getPrice() != null) { + tbConsInfo.setPrice(resource.getPrice()); + } + if (StrUtil.isNotBlank(resource.getConUnit())) { + tbConsInfo.setConUnit(resource.getConUnit()); + } + if (resource.getConWarning() != null) { + tbConsInfo.setConWarning(resource.getConWarning()); + } + if (StrUtil.isNotBlank(resource.getStatus())) { + tbConsInfo.setStatus(resource.getStatus()); + } + if (StrUtil.isNotBlank(resource.getIsCheck())) { + tbConsInfo.setIsCheck(resource.getIsCheck()); + } tbConsInfo.setUpdateTime(new Timestamp(System.currentTimeMillis())); tbConsInfoRepository.save(tbConsInfo); @@ -184,9 +195,9 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { map.put("耗材名称", tbConsInfo.getConName()); map.put("耗材类型代码", tbConsInfo.getContypeCode()); map.put("单位", tbConsInfo.getConUnit()); - map.put("价格",tbConsInfo.getPrice()); - map.put("耗材预警值",tbConsInfo.getConWarning()); - map.put("库存",tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume())); + map.put("价格", tbConsInfo.getPrice()); + map.put("耗材预警值", tbConsInfo.getConWarning()); + map.put("库存", tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume())); list.add(map); } FileUtil.downloadExcel(list, response); @@ -195,7 +206,7 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { @Override @Transactional(rollbackFor = Exception.class) public void stockInOut(SuppFlow resources) throws Exception { - log.info("resources:{}",JSON.toJSONString(resources)); + log.info("resources:{}", JSON.toJSONString(resources)); if (Objects.isNull(resources)) { throw new Exception("参数错误"); } @@ -205,9 +216,9 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { throw new Exception("店铺信息不存在"); } - TbShopPurveyor purveyor=null; + TbShopPurveyor purveyor = null; TbProductStockOperate stockOperate = new TbProductStockOperate(); - if(Objects.nonNull(resources.getSupplierId())){ + if (Objects.nonNull(resources.getSupplierId())) { purveyor = tbShopPurveyorRepository.getById(resources.getSupplierId()); if (Objects.nonNull(purveyor)) { stockOperate.setPurveyorId(resources.getSupplierId().toString()); @@ -217,7 +228,7 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { stockOperate.setShopId(tbShopInfo.getId().toString()); stockOperate.setStockSnap(""); - stockOperate.setType(resources.getType().equals("in")?"cons_in":"cons_out"); + stockOperate.setType(resources.getType().equals("in") ? "cons_in" : "cons_out"); Map operatorSnapMap = new HashMap<>(); operatorSnapMap.put("name", tbShopInfo.getShopName()); operatorSnapMap.put("account", tbShopInfo.getAccount()); @@ -229,11 +240,11 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { stockOperate.setUpdatedAt(System.currentTimeMillis()); stockOperate.setStatus("normal"); - JSONArray array=new JSONArray(); + JSONArray array = new JSONArray(); for (SuppFlow.ConInfos conInfos : resources.getList()) { - JSONObject object=new JSONObject(); + JSONObject object = new JSONObject(); TbConsInfo info = tbConsInfoRepository.getById(conInfos.getConInfold()); if (Objects.isNull(info)) { @@ -247,19 +258,19 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { TbShopPurveyorTransact purveyorTransact = new TbShopPurveyorTransact(); purveyorTransact.setShopId(tbShopInfo.getId().toString()); - purveyorTransact.setPurveyorName(Objects.isNull(purveyor)?"":purveyor.getPurveyorName()); - purveyorTransact.setPurveyorId(Objects.isNull(purveyor)?"":purveyor.getId().toString()); + purveyorTransact.setPurveyorName(Objects.isNull(purveyor) ? "" : purveyor.getPurveyorName()); + purveyorTransact.setPurveyorId(Objects.isNull(purveyor) ? "" : purveyor.getId().toString()); purveyorTransact.setRemark(resources.getRemark()); purveyorTransact.setCreatedAt(System.currentTimeMillis()); purveyorTransact.setUpdatedAt(System.currentTimeMillis()); suppFlow.setConInfoId(info.getConTypeId()); suppFlow.setShopId(resources.getShopId()); - suppFlow.setSupplierId(Objects.isNull(resources.getSupplierId())?0: resources.getSupplierId()); + suppFlow.setSupplierId(Objects.isNull(resources.getSupplierId()) ? 0 : resources.getSupplierId()); suppFlow.setType(resources.getType()); suppFlow.setStockNumber(conInfos.getStockNumber()); - BigDecimal amount=info.getStockNumber().subtract(info.getStockConsume()); + BigDecimal amount = info.getStockNumber().subtract(info.getStockConsume()); if ("in".equals(resources.getType())) { @@ -279,19 +290,17 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { purveyorTransact.setWaitAmount((resources.getAccountsPayable().subtract(resources.getActualPayment()))); purveyorTransact.setType("cons_in"); - object.put("number",conInfos.getStockNumber()); - } else if("out".equals(resources.getType())) { + object.put("number", conInfos.getStockNumber()); + } else if ("out".equals(resources.getType())) { stockOperate.setSubType(-1); - if(conInfos.getStockNumber().compareTo(info.getStockNumber())>0){ + if (conInfos.getStockNumber().compareTo(info.getStockNumber()) > 0) { throw new BadRequestException("出库数量大于现有的库存数量"); } info.setStockNumber(info.getStockNumber().subtract(conInfos.getStockNumber())); - - suppFlow.setBalance(info.getStockNumber().subtract(info.getStockConsume()).subtract(conInfos.getStockNumber())); @@ -304,16 +313,16 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { purveyorTransact.setWaitAmount((resources.getAccountsPayable().subtract(resources.getActualPayment())).negate()); purveyorTransact.setType("cons_out"); - object.put("number",conInfos.getStockNumber()); - }else { + object.put("number", conInfos.getStockNumber()); + } else { throw new BadRequestException("错误操作类型"); } - object.put("stockNumber",amount); + object.put("stockNumber", amount); - object.put("name",info.getConName()); - object.put("unitName",info.getConUnit()); + object.put("name", info.getConName()); + object.put("unitName", info.getConUnit()); array.add(object); suppFlow.setPrice(conInfos.getPrice()); @@ -367,7 +376,7 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { XSSFSheet sheet = xssfWorkbook.getSheetAt(0); XSSFRow row = null; - List consInfos=new ArrayList<>(); + List consInfos = new ArrayList<>(); for (int i = 1; i < sheet.getPhysicalNumberOfRows(); i++) { row = sheet.getRow(i); if (row != null) { @@ -431,7 +440,7 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { TbConsInfo consInfo = tbConsInfoRepository.findByConCode(cell0.toString()); if (ObjectUtil.isEmpty(consInfo) || ObjectUtil.isNull(consInfo)) { consInfo = new TbConsInfo(); - consInfo.setConCode(StringCodeUtil.getRandom(8,LETTER_CAPITAL_NUMBER)); + consInfo.setConCode(StringCodeUtil.getRandom(8, LETTER_CAPITAL_NUMBER)); consInfo.setShopId(Integer.valueOf(shopId)); consInfo.setConTypeId(tbConsType.getId()); consInfo.setConTypeName(tbConsType.getConTypeName()); @@ -487,7 +496,7 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { } } else { TbConsInfo consInfo = new TbConsInfo(); - consInfo.setConCode(StringCodeUtil.getRandom(8,LETTER_CAPITAL_NUMBER)); + consInfo.setConCode(StringCodeUtil.getRandom(8, LETTER_CAPITAL_NUMBER)); consInfo.setShopId(Integer.valueOf(shopId)); consInfo.setConTypeId(tbConsType.getId()); consInfo.setConTypeName(tbConsType.getConTypeName()); @@ -523,7 +532,7 @@ public class TbConsInfoServiceImpl implements TbConsInfoService { } - public static void main(String[] args){ + public static void main(String[] args) { System.out.println(UUID.randomUUID().toString()); } From d7fe7cf40ab5b5bcccf17b97f0e8c44cd4a9893c Mon Sep 17 00:00:00 2001 From: yijiegong Date: Tue, 27 Aug 2024 15:59:43 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E5=A2=9E=E5=8A=A0userId=E5=8F=82=E6=95=B0=E7=AD=9B=E9=80=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/order/TbOrderInfoController.java | 1 - .../dto/order/TbOrderInfoQueryCriteria.java | 16 ++++++++++++++++ .../impl/order/TbOrderInfoServiceImpl.java | 9 ++++----- 3 files changed, 20 insertions(+), 6 deletions(-) diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java index 8c37a261..3fe11b9c 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/controller/order/TbOrderInfoController.java @@ -42,7 +42,6 @@ public class TbOrderInfoController { @PostMapping("/date") @ApiOperation("查询订单") - @AnonymousPostMapping public ResponseEntity queryTbOrderInfo(@RequestBody TbOrderInfoQueryCriteria criteria){ return new ResponseEntity<>(tbOrderInfoService.queryAllPage(criteria),HttpStatus.OK); } diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoQueryCriteria.java b/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoQueryCriteria.java index b5753431..453c829f 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoQueryCriteria.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/dto/order/TbOrderInfoQueryCriteria.java @@ -70,6 +70,8 @@ public class TbOrderInfoQueryCriteria{ @Query(type = Query.Type.BETWEEN) private List createdAt; + private Integer userId; + @Query private String tableName; @@ -79,4 +81,18 @@ public class TbOrderInfoQueryCriteria{ public void setProductName(String productName) { if(StringUtils.isNotBlank(productName)) this.productName = productName; } + + public Integer getPage() { + if (page == null) { + return 0; + } + return page; + } + + public Integer getPageSize() { + if (pageSize == null) { + return 10; + } + return pageSize; + } } diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java index e010e8c9..95c1a18e 100644 --- a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java +++ b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/order/TbOrderInfoServiceImpl.java @@ -108,6 +108,10 @@ public class TbOrderInfoServiceImpl implements TbOrderInfoService { predicate = criteriaBuilder.and(predicate, criteriaBuilder.notEqual(root.get("orderType"), "return")); } + if (criteria.getUserId() != null && criteria.getUserId() != 0) { + predicate = criteriaBuilder.and(predicate, criteriaBuilder.equal(root.get("userId"), criteria.getUserId())); + } + if (StringUtils.isNotBlank(criteria.getProductName())) { Date startTime, endTime; DateTime offsetMonth = cn.hutool.core.date.DateUtil.offsetMonth(new Date(), 3); @@ -120,11 +124,6 @@ public class TbOrderInfoServiceImpl implements TbOrderInfoService { startTime = new Date(startLong); endTime = new Date(endLong); - - // 如果开始时间小于三个月前，不查询 -// if (startTime.before(offsetMonth)) { -// throw new BadRequestException("查询时间范围不能超过三个月"); -// } } else { startTime = offsetMonth; endTime = new Date();