diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/pay/PayProductProcessor.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/pay/PayProductProcessor.java index 8d31f2ef4..564f3047a 100644 --- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/pay/PayProductProcessor.java +++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/pay/PayProductProcessor.java @@ -53,35 +53,49 @@ import static com.cf.imes.module.system.enums.ErrorCodeConstants.PRODUCT_PURCHAS */ public class PayProductProcessor { + // 当次订购的产品 private ProductsDO productsDO; + // 当次订购的定价规则 private ProductsDetailDO productsDetailDO; + // 组织产品的首次订购记录 private PurchaseRecordDO orgInitialPurchaseRecord; + // 当前组织资金信息 private OrganAmountDO organAmountDO; + // 组织id private Long organId; + // 支付配置 private ChenfengPayConfig payConfig; + // id生成规则配置 private MybatisIdProperties mybatisIdProperties; + // 标记本次订购是否首次 private boolean initialized = false; - private PreviouProductDelayRespVO previouProductDelayRespVO; + // 前序购买记录的延期记录 + private List delayRespVOList; + // 前序购买记录 private PurchaseRecordDO previousPurchaseRecord; + // 本地订购产品的开始时间 private LocalDate startTime = LocalDate.now(); + // 本地订购产品的月均单价 + private BigDecimal monthAverageAmount = BigDecimal.ZERO; + public PayProductProcessor(ProductsDO productsDO, ProductsDetailDO productsDetailDO, PurchaseRecordDO orgInitialPurchaseRecord, PreviouProductDelayRespVO previouProductDelayRespVO, OrganAmountDO organAmountDO, Long organId, ChenfengPayConfig payConfig, MybatisIdProperties mybatisIdProperties) { this.productsDO = productsDO; this.productsDetailDO = productsDetailDO; this.orgInitialPurchaseRecord = orgInitialPurchaseRecord; - this.previouProductDelayRespVO = previouProductDelayRespVO; if (ObjectUtil.isNotNull(previouProductDelayRespVO.getPreviouPurchaseRecord())) { + delayRespVOList = previouProductDelayRespVO.getDelayRespVOList(); previousPurchaseRecord = previouProductDelayRespVO.getPreviouPurchaseRecord(); // 如果有前置购买记录,那么新的开始时间是上一次订购的结束时间 startTime = previousPurchaseRecord.getEndTime(); @@ -105,6 +119,8 @@ public class PayProductProcessor { price = computePrice(orgInitialPurchaseRecord, productsDetailDO); } else { price = productsDetailDO.getCurrentPrice(); + // 首次订购计算月均单价 + monthAverageAmount = computeInitialProductPayMonthAverageAmount(price); // 首次购买记录是空,那么当前就是首次订购 initialized = true; } @@ -167,7 +183,7 @@ public class PayProductProcessor { .paymentMethod(PayProductChannelCodeEnum.BALANCE_ONLY.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .accountBalanceSpent(price) .isInvocing(InvoiceStatusEnum.INVOICABLE.getCode()) .initial(initialized) @@ -225,7 +241,7 @@ public class PayProductProcessor { .paymentMethod(PayProductChannelCodeEnum.BALANCE_ONLY.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .accountBalanceSpent(price) .isInvocing(InvoiceStatusEnum.INVOICABLE.getCode()) .initial(initialized) @@ -280,7 +296,7 @@ public class PayProductProcessor { .paymentMethod(PayProductChannelCodeEnum.BALANCE_ONLY.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .alipaySpent(price) .initial(initialized) .status(PurchaseRecordStatusEnum.ACTIVE.getStatus()) @@ -321,7 +337,7 @@ public class PayProductProcessor { .paymentMethod(PayProductChannelCodeEnum.BALANCE_ONLY.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .wechatSpent(price) .initial(initialized) .status(PurchaseRecordStatusEnum.ACTIVE.getStatus()) @@ -367,7 +383,7 @@ public class PayProductProcessor { .paymentMethod(PayProductChannelCodeEnum.BALANCE_AND_GIFT.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .isInvocing(InvoiceStatusEnum.INVOICABLE.getCode()) .initial(initialized) .status(PurchaseRecordStatusEnum.ACTIVE.getStatus()) @@ -445,7 +461,7 @@ public class PayProductProcessor { .paymentMethod(PayChannelCodeEnum.ALIPAY_PC.equals(payChannelCodeEnum) ? PayProductChannelCodeEnum.BALANCE_AND_GIFT_AND_ALIPAY.getCode() : PayProductChannelCodeEnum.BALANCE_AND_GIFT_AND_WECHAT.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .initial(initialized) .status(PurchaseRecordStatusEnum.ACTIVE.getStatus()) .build(); @@ -525,7 +541,7 @@ public class PayProductProcessor { .paymentMethod(PayChannelCodeEnum.ALIPAY_PC.equals(payChannelCodeEnum) ? PayProductChannelCodeEnum.GIFT_AND_ALIPAY.getCode() : PayProductChannelCodeEnum.GIFT_AND_WECHAT.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .initial(initialized) .status(PurchaseRecordStatusEnum.ACTIVE.getStatus()) .build(); @@ -607,7 +623,7 @@ public class PayProductProcessor { .paymentMethod(PayProductChannelCodeEnum.BALANCE_AND_GIFT.getCode()) .totalAmount(price) .originalAmount(productsDetailDO.getCurrentPrice()) - .monthAverageAmount(orgInitialPurchaseRecord.getMonthAverageAmount()) + .monthAverageAmount(monthAverageAmount) .initial(initialized) .status(PurchaseRecordStatusEnum.ACTIVE.getStatus()) .build(); @@ -718,7 +734,6 @@ public class PayProductProcessor { endTime = addTime(startTime, giftDuration, giftDurationUnit); } - List delayRespVOList = previouProductDelayRespVO.getDelayRespVOList(); if (CollUtil.isNotEmpty(delayRespVOList)) { // 根据延期列表计算新的结束时间 endTime = calculateDelayEndTime(startTime, endTime, delayRespVOList); @@ -793,7 +808,7 @@ public class PayProductProcessor { */ private BigDecimal computePrice(PurchaseRecordDO orgInitialPurchaseRecord, ProductsDetailDO productsDetailDO) { // 月均单价 - BigDecimal monthAverageAmount = orgInitialPurchaseRecord.getMonthAverageAmount(); + monthAverageAmount = orgInitialPurchaseRecord.getMonthAverageAmount(); // 定价规则的折扣 BigDecimal discount = productsDetailDO.getDiscount(); @@ -848,4 +863,18 @@ public class PayProductProcessor { return totalAmount; } + /** + * 计算首次订购的月均单价 + */ + private BigDecimal computeInitialProductPayMonthAverageAmount(BigDecimal price) { + Integer duration = productsDetailDO.getDuration(); + BigDecimal monthAverageAmount; + switch (ProductDurationUnitEnum.fromStatus(productsDetailDO.getDurationUnit())) { + case YEAR -> monthAverageAmount = price.divide(new BigDecimal(duration * 12), 2, RoundingMode.DOWN); + case MONTH -> monthAverageAmount = price.divide(new BigDecimal(duration), 2, RoundingMode.DOWN); + default -> throw new ServiceException(PRODUCTS_DETAIL_DURATION_UNIT_NOT_SUPPORT); + } + return monthAverageAmount; + } + } diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/permission/PermissionServiceImpl.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/permission/PermissionServiceImpl.java index 8dd021faa..c8de591ae 100644 --- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/permission/PermissionServiceImpl.java +++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/service/permission/PermissionServiceImpl.java @@ -19,7 +19,6 @@ import com.cf.imes.module.system.constants.permission.InternalRoleConstants; import com.cf.imes.module.system.controller.admin.permission.vo.permission.PermissionAssignRoleUserReqVO; import com.cf.imes.module.system.controller.admin.permission.vo.permission.PermissionAssignUserRoleReqVO; import com.cf.imes.module.system.dal.dataobject.oauth2.OAuth2AccessTokenDO; -import com.cf.imes.module.system.dal.dataobject.organ.OrganizationDO; import com.cf.imes.module.system.dal.dataobject.permission.MenuDO; import com.cf.imes.module.system.dal.dataobject.permission.RoleDO; import com.cf.imes.module.system.dal.dataobject.permission.RoleMenuDO; @@ -115,11 +114,11 @@ public class PermissionServiceImpl implements PermissionService { if (ObjectUtil.isNull(user)) { throw new ServiceException(ErrorCodeConstants.USER_NOT_EXISTS); } - OrganizationDO organizationDO = organService.validOrgan(user.getOrganId()); + organService.validOrgan(user.getOrganId()); // 情况一:遍历判断每个权限,如果有一满足,说明有权限 for (String permission : permissions) { - if (hasAnyPermission(roles, permission, organizationDO.getPackageId())) { + if (hasAnyPermission(roles, permission)) { return true; } } @@ -135,16 +134,13 @@ public class PermissionServiceImpl implements PermissionService { * @param permission 权限标识 * @return 是否拥有 */ - private boolean hasAnyPermission(List roles, String permission, Long packageId) { + private boolean hasAnyPermission(List roles, String permission) { List menuIds = menuService.getMenuIdListByPermissionFromCache(permission); // 采用严格模式,如果权限找不到对应的 Menu 的话,也认为没有权限 if (CollUtil.isEmpty(menuIds)) { return false; } - // 组织套餐下的菜单 - Set tenantPackageMenuIds = tenantPackageService.getTenantPackageMenuIds(packageId); - // 判断是否有权限 Set roleIds = convertSet(roles, RoleDO::getId); for (Long menuId : menuIds) { @@ -152,8 +148,7 @@ public class PermissionServiceImpl implements PermissionService { //Set menuRoleIds = getSelf().getMenuRoleIdListByMenuIdFromCache(menuId); Set menuRoleIds = getSelf().getMenuRoleIdListByMenuIdFromCache1(menuId); // 如果有交集,说明有权限 - // 角色下菜单id和组织套餐内菜单id必须同时满足 - if (CollUtil.containsAny(menuRoleIds, roleIds) && tenantPackageMenuIds.contains(menuId)) { + if (CollUtil.containsAny(menuRoleIds, roleIds)) { return true; } }