Browse Source

暂停订阅,自动取消订阅

lyhzzz 1 year ago
parent
commit
8821912db8

+ 1 - 1
src/main/java/com/fdkankan/ucenter/controller/IncrementController.java

@@ -83,7 +83,7 @@ public class IncrementController extends BaseController {
     }
 
     @GetMapping("/cancelSubscription/{incrementId}")
-    public Result cancelSubscription(@PathVariable Integer incrementId){
+    public Result cancelSubscription(@PathVariable Long incrementId){
         userIncrementService.cancelSubscription(incrementId);
         return Result.success();
     }

+ 6 - 0
src/main/java/com/fdkankan/ucenter/mq/consumer/AutoOrderConsumer.java

@@ -87,6 +87,12 @@ public class AutoOrderConsumer {
                 case "BILLING.SUBSCRIPTION.PAYMENT.FAILED" :     //订阅付款失败
                     autoOrderService.payError(incrementAutoOrder,order);
                     break;
+                case "BILLING.SUBSCRIPTION.SUSPENDED" :     //订阅暂停
+                    List<UserIncrement> userIncrementList = userIncrementService.getByAutoOrderSn(order.getSubscriptionId());
+                    for (UserIncrement userIncrement : userIncrementList) {
+                        userIncrementService.cancelSubscription(userIncrement.getId());
+                    }
+                    break;
                 default:
                     break;
             }

+ 1 - 1
src/main/java/com/fdkankan/ucenter/service/IIncrementAutoOrderService.java

@@ -31,7 +31,7 @@ public interface IIncrementAutoOrderService extends IService<IncrementAutoOrder>
 
     void setIncrementId(IncrementAutoOrder incrementAutoOrder, Long incrmentId);
 
-    void delByIncrementId(Integer incrementId);
+    void delByIncrementId(Long incrementId);
 
     IncrementAutoOrder getByOrderSn(String orderSn);
 }

+ 1 - 1
src/main/java/com/fdkankan/ucenter/service/IUserIncrementService.java

@@ -53,5 +53,5 @@ public interface IUserIncrementService extends IService<UserIncrement> {
 
     void cancelSubscriptions(UserIncrement increment);
 
-    void cancelSubscription(Integer incrementId);
+    void cancelSubscription(Long incrementId);
 }

+ 1 - 1
src/main/java/com/fdkankan/ucenter/service/impl/IncrementAutoOrderServiceImpl.java

@@ -117,7 +117,7 @@ public class IncrementAutoOrderServiceImpl extends ServiceImpl<IIncrementAutoOrd
     }
 
     @Override
-    public void delByIncrementId(Integer incrementId) {
+    public void delByIncrementId(Long incrementId) {
         LambdaUpdateWrapper<IncrementAutoOrder> wrapper = new LambdaUpdateWrapper<>();
         wrapper.eq(IncrementAutoOrder::getUserIncrementId,incrementId);
         this.remove(wrapper);

+ 1 - 1
src/main/java/com/fdkankan/ucenter/service/impl/UserIncrementServiceImpl.java

@@ -448,7 +448,7 @@ public class UserIncrementServiceImpl extends ServiceImpl<IUserIncrementMapper,
     IIncrementAutoOrderService incrementAutoOrderService;
 
     @Override
-    public void cancelSubscription(Integer incrementId) {
+    public void cancelSubscription(Long incrementId) {
         UserIncrement userIncrement = this.getById(incrementId);
         if(userIncrement == null){
             throw new BusinessException(ErrorCode.VALUE_NOT_EXIST);