|
@@ -1,14 +1,12 @@
|
|
package cn.kdan.cloud.pdf.office.payment.listener;
|
|
package cn.kdan.cloud.pdf.office.payment.listener;
|
|
|
|
|
|
-import cn.kdan.cloud.pdf.office.api.account.dto.UpdateUserForPaySuccessDTO;
|
|
|
|
|
|
+import cn.kdan.cloud.pdf.office.api.account.dto.UpdateUserForOrderDTO;
|
|
import cn.kdan.cloud.pdf.office.api.account.feign.UserApi;
|
|
import cn.kdan.cloud.pdf.office.api.account.feign.UserApi;
|
|
import cn.kdan.cloud.pdf.office.api.payment.vo.SubscriptionsVO;
|
|
import cn.kdan.cloud.pdf.office.api.payment.vo.SubscriptionsVO;
|
|
import cn.kdan.cloud.pdf.office.api.product.enums.PlatformEnum;
|
|
import cn.kdan.cloud.pdf.office.api.product.enums.PlatformEnum;
|
|
-import cn.kdan.cloud.pdf.office.api.product.feign.ProductApi;
|
|
|
|
import cn.kdan.cloud.pdf.office.common.constant.RabbitMqConstant;
|
|
import cn.kdan.cloud.pdf.office.common.constant.RabbitMqConstant;
|
|
import cn.kdan.cloud.pdf.office.common.enums.account.PDFOfficeUserStatusEnum;
|
|
import cn.kdan.cloud.pdf.office.common.enums.account.PDFOfficeUserStatusEnum;
|
|
import cn.kdan.cloud.pdf.office.common.utils.MyDateUtils;
|
|
import cn.kdan.cloud.pdf.office.common.utils.MyDateUtils;
|
|
-import cn.kdan.cloud.pdf.office.common.vo.UserInfoVO;
|
|
|
|
import cn.kdan.cloud.pdf.office.payment.service.OrdersService;
|
|
import cn.kdan.cloud.pdf.office.payment.service.OrdersService;
|
|
import cn.kdan.cloud.pdf.office.payment.service.SubscriptionsService;
|
|
import cn.kdan.cloud.pdf.office.payment.service.SubscriptionsService;
|
|
import com.rabbitmq.client.Channel;
|
|
import com.rabbitmq.client.Channel;
|
|
@@ -76,8 +74,8 @@ public class PaymentListener {
|
|
String validFlag = userApi.getById(subscription.getUserId()).getResult().getValidFlag();
|
|
String validFlag = userApi.getById(subscription.getUserId()).getResult().getValidFlag();
|
|
PDFOfficeUserStatusEnum userStatusEnum = PDFOfficeUserStatusEnum.getEnumByValue(validFlag);
|
|
PDFOfficeUserStatusEnum userStatusEnum = PDFOfficeUserStatusEnum.getEnumByValue(validFlag);
|
|
// TODO 修改用户状态
|
|
// TODO 修改用户状态
|
|
- UpdateUserForPaySuccessDTO paySuccessDTO = new UpdateUserForPaySuccessDTO();
|
|
|
|
- userApi.updateUserForPaySuccess(paySuccessDTO);
|
|
|
|
|
|
+ UpdateUserForOrderDTO paySuccessDTO = new UpdateUserForOrderDTO();
|
|
|
|
+ userApi.updateUserForOrder(paySuccessDTO);
|
|
}
|
|
}
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
log.info("订阅过期 处理成功 :{}", subscriptionId);
|
|
log.info("订阅过期 处理成功 :{}", subscriptionId);
|