diff --git a/mallinkBApi/src/main/java/com/iformall/controller/WxCouponOrderController.java b/mallinkBApi/src/main/java/com/iformall/controller/WxCouponOrderController.java index a3ca88f73..fc479a6a6 100644 --- a/mallinkBApi/src/main/java/com/iformall/controller/WxCouponOrderController.java +++ b/mallinkBApi/src/main/java/com/iformall/controller/WxCouponOrderController.java @@ -153,6 +153,13 @@ public class WxCouponOrderController extends BaseController { return wxCouponOrderService.listOnDateAsPageV2(getLoginBUser().getId(), startDate, endDate, pageNum, pageSize, true); } + @ApiOperation("核销流水统计接口") + @GetMapping("sumVerified") + public ResultData sumVerified(@RequestParam("startDate") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") Date startDate, + @RequestParam("endDate") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") Date endDate) { + return wxCouponOrderService.sumVerified(getLoginBUser(), startDate, endDate); + } + @ApiOperation("某日期交易总流水") @GetMapping("getUnverifiedAmountOnDate") @ApiImplicitParams({ diff --git a/mallinkBApi/src/main/java/com/iformall/controller/WxMicroPayController.java b/mallinkBApi/src/main/java/com/iformall/controller/WxMicroPayController.java index 9439d1864..6ae807016 100644 --- a/mallinkBApi/src/main/java/com/iformall/controller/WxMicroPayController.java +++ b/mallinkBApi/src/main/java/com/iformall/controller/WxMicroPayController.java @@ -276,6 +276,14 @@ public class WxMicroPayController extends BaseController { return wxOrderService.microPayListOnDateAsPageV2(getLoginBUser().getId(), EnumOrderType.MICROPAY.getCode(), startDate, endDate, pageNum, pageSize); } + @RedisCache + @ApiOperation("付款码支付交易流水分页列表接口") + @GetMapping("sumMicroPay") + public ResultData sumMicroPay(@RequestParam("startDate") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") Date startDate, + @RequestParam("endDate") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") Date endDate) { + return wxOrderService.sumMicroPay(getLoginBUser(), EnumOrderType.MICROPAY.getCode(), startDate, endDate); + } + @RedisCache @ApiOperation("付款码支付某日期交易总流水") @GetMapping("getMicroPayAmountOnDate") diff --git a/mallinkService/src/main/java/com/iformall/domain/vo/SumMicroPayVO.java b/mallinkService/src/main/java/com/iformall/domain/vo/SumMicroPayVO.java new file mode 100644 index 000000000..810b8532e --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/domain/vo/SumMicroPayVO.java @@ -0,0 +1,11 @@ +package com.iformall.domain.vo; + +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class SumMicroPayVO { + private BigDecimal amount; + private Integer total; +} diff --git a/mallinkService/src/main/java/com/iformall/domain/vo/SumVerifiedVO.java b/mallinkService/src/main/java/com/iformall/domain/vo/SumVerifiedVO.java new file mode 100644 index 000000000..e2a774c0f --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/domain/vo/SumVerifiedVO.java @@ -0,0 +1,11 @@ +package com.iformall.domain.vo; + +import lombok.Data; + +import java.math.BigDecimal; + +@Data +public class SumVerifiedVO { + private BigDecimal amount; + private Integer total; +} diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxCouponOrderMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxCouponOrderMapper.java index 35a51fff3..7b7fc5f98 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxCouponOrderMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxCouponOrderMapper.java @@ -112,4 +112,14 @@ public interface WxCouponOrderMapper extends CommonMapper { * @return */ List findVerifiedUserIds(@Param("tenantId")String tenantId, @Param("verifiedStartTime")Date verifiedStartTime, @Param("verifiedEndTime")Date verifiedEndTime); + + /** + * 统计核销记录总金额 + * @param tenantId + * @param merchantId + * @param startDate + * @param endDate + * @return {@link Integer} + */ + SumVerifiedVO sumVerified(@Param("tenantId") String tenantId, @Param("bMerchantId") Long merchantId, @Param("startDate") Date startDate, @Param("endDate") Date endDate); } diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java index 81a4796fc..75c521e40 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxOrderMapper.java @@ -69,4 +69,6 @@ public interface WxOrderMapper extends CommonMapper { void updateCUserId(WxOrder updateOrder); List getComposeOrderIds(WxOrder wxOrder); + + SumMicroPayVO sumMicroPay(Map dateMap); } diff --git a/mallinkService/src/main/java/com/iformall/service/WxCouponOrderService.java b/mallinkService/src/main/java/com/iformall/service/WxCouponOrderService.java index 1ae3add87..1fc33d994 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxCouponOrderService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxCouponOrderService.java @@ -240,6 +240,7 @@ public interface WxCouponOrderService { List findAvailCouponOrder(TenantEntity tenantEntity,Long cUserId,Long merchantId,Long posOrderId); PageInfo userTradeDetailList(WxMerchant wxMerchant,Date startTime,Date endTime,Integer pageIndex,Integer pageSize); - - + + + ResultData sumVerified(WxMerchantBUser bUser, Date startDate, Date endDate); } diff --git a/mallinkService/src/main/java/com/iformall/service/WxOrderService.java b/mallinkService/src/main/java/com/iformall/service/WxOrderService.java index 48216c1c7..c6962df95 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxOrderService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxOrderService.java @@ -286,4 +286,5 @@ public interface WxOrderService { ResultData handlerPushOrder(TenantEntity tenantEntity, Long composeOrderId, String batchExtParam, List goods); + ResultData sumMicroPay(WxMerchantBUser bUser, Integer type, Date startDate, Date endDate); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java index afca5e74a..c3b99da39 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponOrderServiceImpl.java @@ -326,8 +326,6 @@ public class WxCouponOrderServiceImpl implements WxCouponOrderService { if (isVerified) { PageInfo pageResult = findListOfVerifiedByDateForBUser(wxMerchant, wxMerchant.getId(), startDate, endDate, pageIndex, pageSize); resultMap.put("list", pageResult); - int amount = pageResult.getList() != null ? pageResult.getList().stream().mapToInt(WxCouponOrderBVo::getCouponPrice).sum() : 0; - resultMap.put("amount", amount); }else { resultMap.put("list", findListOfOrderedByDateForBUser(wxMerchant,wxMerchant.getId(),startDate,endDate,pageIndex,pageSize)); } @@ -3261,8 +3259,14 @@ public class WxCouponOrderServiceImpl implements WxCouponOrderService { retPageInfo.setList(couponOrderListToTradeDetailVoList(wxMerchant,pageInfo.getList())); return retPageInfo; } - - private List couponOrderListToTradeDetailVoList(TenantEntity tenantEntity,List couponOrderList) { + + @Override + public ResultData sumVerified(WxMerchantBUser bUser, Date startDate, Date endDate) { + SumVerifiedVO vo = wxCouponOrderMapper.sumVerified(bUser.getTenantId(), bUser.getMerchantId(), startDate, endDate); + return new ResultData(vo); + } + + private List couponOrderListToTradeDetailVoList(TenantEntity tenantEntity,List couponOrderList) { if (null == couponOrderList || couponOrderList.size() <=0 ) { return null; } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java index 9dd34a6db..2fb6034c7 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java @@ -333,8 +333,6 @@ public class WxOrderServiceImpl implements WxOrderService { } else { PageInfo pageResult = orderPayVoPageInfo(wxMerchantBUser, pageIndex, pageSize, dateMap); resultMap.put("list", pageResult); - int amount = pageResult.getList() != null ? pageResult.getList().stream().mapToInt(WxOrderPayVo::getPayment).sum() : 0; - resultMap.put("amount", amount); } return resultMap; } @@ -3922,6 +3920,27 @@ public class WxOrderServiceImpl implements WxOrderService { // } } + @Override + public ResultData sumMicroPay(WxMerchantBUser bUser, Integer type, Date startDate, Date endDate) { + Map dataMap = new HashMap(); + dataMap.put("startDate", startDate); + dataMap.put("endDate", endDate); + dataMap.put("merchantId", bUser.getMerchantId()); + dataMap.put("type", type); + dataMap.put("tenantId", bUser.getTenantId()); + dataMap.put("finalTenantId", bUser.getFinalTenantId()); + WxMerchantBUser merchantBUserQ = new WxMerchantBUser(); + merchantBUserQ.updateTenantInfo(bUser); + merchantBUserQ.setMerchantId(bUser.getMerchantId()); + List bUserIds = wxMerchantBUserMapper.findIdList(merchantBUserQ); + if (null == bUserIds || bUserIds.size() <= 0 ) { + throw new MallinkException(ErrorCode.MERCHANT_INFO_NOT_FOUND); + } + dataMap.put("bUserIds", bUserIds); + SumMicroPayVO vo = wxOrderMapper.sumMicroPay(dataMap); + return new ResultData(vo); + } + private Map> getBatchOrderMap(TenantEntity tenantEntity,List batchOrderIds){ WxOrder recordQ = new WxOrder(); recordQ.updateTenantInfo(tenantEntity); diff --git a/mallinkService/src/main/resources/mapper/WxCouponOrderMapper.xml b/mallinkService/src/main/resources/mapper/WxCouponOrderMapper.xml index 0fb95b902..c17d1b450 100644 --- a/mallinkService/src/main/resources/mapper/WxCouponOrderMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCouponOrderMapper.xml @@ -1181,5 +1181,20 @@ and update_date >= #{verifiedStartTime} and update_date <= #{verifiedEndTime} + \ No newline at end of file diff --git a/mallinkService/src/main/resources/mapper/WxOrderMapper.xml b/mallinkService/src/main/resources/mapper/WxOrderMapper.xml index d9e081624..32518fdb0 100644 --- a/mallinkService/src/main/resources/mapper/WxOrderMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxOrderMapper.xml @@ -1168,5 +1168,34 @@ - + +