玫瑰

dating-agency-mall-sdk/src/main/java/com/qniao/dam/application/MallServerApplicationService.java

@@ -1,10 +1,7 @@
 package com.qniao.dam.application;
 
 import com.qniao.dam.application.request.*;
-import com.qniao.dam.application.response.ConsumeVirtualAccountVo;
-import com.qniao.dam.application.response.CostGiftSdkVo;
-import com.qniao.dam.application.response.UserCheckEnableRightBySdkVo;
-import com.qniao.dam.application.response.UserConsumeRightBySdkVo;
+import com.qniao.dam.application.response.*;
 import com.qniao.framework.annotation.IgnoreResponseAdvice;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -64,4 +61,8 @@ public interface MallServerApplicationService {
     @IgnoreResponseAdvice
     CostGiftSdkVo userCostChannelGiftBySdk(@RequestBody UserCostChannelGiftSdkDto dto);
 
+    @PostMapping("/user/check/one-on-one-rtc-consume/by/sdk")
+    @IgnoreResponseAdvice
+    CheckOneOnOneRtcConsumeSdkVo checkOneOnOneRtcConsumeBySdk(@RequestBody CheckOneOnOneRtcConsumeSdkDto dto);
+
 }

dating-agency-mall-sdk/src/main/java/com/qniao/dam/application/request/CheckOneOnOneRtcConsumeSdkDto.java

@@ -0,0 +1,14 @@
+package com.qniao.dam.application.request;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class CheckOneOnOneRtcConsumeSdkDto {
+
+    private Long userId;
+
+}

dating-agency-mall-sdk/src/main/java/com/qniao/dam/application/response/CheckOneOnOneRtcConsumeSdkVo.java

@@ -0,0 +1,14 @@
+package com.qniao.dam.application.response;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class CheckOneOnOneRtcConsumeSdkVo {
+
+    private Boolean flag;
+
+}

dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/virtualaccount/user/VirtualAccountUserCommandController.java

@@ -1,8 +1,10 @@
 package com.qniao.dam.api.command.virtualaccount.user;
 
+import com.qniao.dam.api.command.virtualaccount.user.request.CheckOneOnOneRtcConsumeDto;
 import com.qniao.dam.api.command.virtualaccount.user.request.UserConsumeVirtualAccountDto;
 import com.qniao.dam.api.command.virtualaccount.user.request.UserCostChannelGiftDto;
 import com.qniao.dam.api.command.virtualaccount.user.request.UserCostIMGiftDto;
+import com.qniao.dam.api.command.virtualaccount.user.response.CheckOneOnOneRtcConsumeVo;
 import com.qniao.dam.api.command.virtualaccount.user.response.CostGiftVo;
 import com.qniao.dam.api.command.virtualaccount.user.response.UserConsumeVirtualAccountVo;
 import com.qniao.dam.application.service.virtualaccount.VirtualAccountApplicationService;
@@ -40,4 +42,11 @@ public class VirtualAccountUserCommandController {
     public CostGiftVo userCostChannelGiftBySdk(@RequestBody UserCostChannelGiftDto dto) {
         return virtualAccountApplicationService.costChannelGift(dto);
     }
+
+    @PostMapping("/check/one-on-one-rtc-consume/by/sdk")
+    @IgnoreResponseAdvice
+    public CheckOneOnOneRtcConsumeVo checkOneOnOneRtcConsumeBySdk(@RequestBody CheckOneOnOneRtcConsumeDto dto) {
+        return virtualAccountApplicationService.checkOneOnOneRtcConsume(dto.getUserId(), dto.getRtcChannelType());
+    }
+
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/virtualaccount/user/request/CheckOneOnOneRtcConsumeDto.java

@@ -0,0 +1,13 @@
+package com.qniao.dam.api.command.virtualaccount.user.request;
+
+import com.qniao.daca.domian.aggregate.rtcchannel.constant.RtcChannelTypeEnum;
+import lombok.Data;
+
+@Data
+public class CheckOneOnOneRtcConsumeDto {
+
+    private Long userId;
+
+    private RtcChannelTypeEnum rtcChannelType;
+
+}

dating-agency-mall-server/src/main/java/com/qniao/dam/api/command/virtualaccount/user/response/CheckOneOnOneRtcConsumeVo.java

@@ -0,0 +1,10 @@
+package com.qniao.dam.api.command.virtualaccount.user.response;
+
+import lombok.Data;
+
+@Data
+public class CheckOneOnOneRtcConsumeVo {
+
+    private Boolean flag = false;
+
+}

dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/virtualaccount/VirtualAccountApplicationService.java

@@ -1,10 +1,13 @@
 package com.qniao.dam.application.service.virtualaccount;
 
+import com.qniao.daca.domian.aggregate.rtcchannel.constant.RtcChannelTypeEnum;
 import com.qniao.dam.api.command.virtualaccount.user.request.UserConsumeVirtualAccountDto;
 import com.qniao.dam.api.command.virtualaccount.user.request.UserCostChannelGiftDto;
 import com.qniao.dam.api.command.virtualaccount.user.request.UserCostIMGiftDto;
+import com.qniao.dam.api.command.virtualaccount.user.response.CheckOneOnOneRtcConsumeVo;
 import com.qniao.dam.api.command.virtualaccount.user.response.CostGiftVo;
 import com.qniao.dam.api.command.virtualaccount.user.response.UserConsumeVirtualAccountVo;
+import com.qniao.dam.api.query.product.user.response.UserGetProductByCategoryVo;
 import com.qniao.dam.domain.aggregate.order.entity.Order;
 import com.qniao.dam.domain.aggregate.order.entity.OrderItem;
 import com.qniao.dam.domain.aggregate.product.entity.Product;
@@ -21,6 +24,7 @@ import com.qniao.dam.domain.service.virtualaccount.CostGiftRewardDomainService;
 import com.qniao.dam.domian.aggregate.order.constant.OrderBelongingEnum;
 import com.qniao.dam.domian.aggregate.order.constant.OrderStatusEnum;
 import com.qniao.dam.domian.aggregate.order.constant.OrderTypeEnum;
+import com.qniao.dam.domian.aggregate.product.constant.ProductSubCategoryEnum;
 import com.qniao.dam.domian.aggregate.productspec.constant.ProductSpecTermNameEnum;
 import com.qniao.dam.domian.aggregate.virtualaccount.constant.VirtualAccountTradeTypeEnum;
 import com.qniao.dam.domian.aggregate.walletaccount.constant.IdentityTypeEnum;
@@ -346,4 +350,22 @@ public class VirtualAccountApplicationService extends BaseApplicationService {
             virtualAccountAggregate.edit(virtualAccount);
         }
     }
+
+    public CheckOneOnOneRtcConsumeVo checkOneOnOneRtcConsume(Long userId,
+                                                             RtcChannelTypeEnum rtcChannelType) {
+        CheckOneOnOneRtcConsumeVo vo = new CheckOneOnOneRtcConsumeVo();
+        UserGetProductByCategoryVo productSpec = null;
+        if (RtcChannelTypeEnum.ONE_ON_ONE_VOICE.equals(rtcChannelType)) {
+            //一对一语音
+            productSpec = productQueryService.getProductByCategory(ProductSubCategoryEnum.CHAT_VOICE_FEE.getValue());
+        } else if (RtcChannelTypeEnum.ONE_ON_ONE_VIDEO.equals(rtcChannelType)) {
+            //一对一视频
+            productSpec = productQueryService.getProductByCategory(ProductSubCategoryEnum.CHAT_VIDEO_FEE.getValue());
+        }
+        VirtualAccount virtualAccount = virtualAccountQueryService.queryBy(userId);
+        if (virtualAccount != null && virtualAccount.getBalance() >= productSpec.getUnitSellingPrice().intValue()) {
+            vo.setFlag(true);
+        }
+        return vo;
+    }
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/query/product/ProductQueryService.java

@@ -50,4 +50,5 @@ public interface ProductQueryService {
     List<UserGiftProductVo> listGiftProduct();
 
     UserGetProductByCategoryVo getProductByCategory(Integer subCategory);
+
 }