基础配置

dating-agency-mall-entity/src/main/java/com/qniao/dam/domain/aggregate/rightconsumerel/entity/RightConsumeRel.java

@@ -1,16 +1,31 @@
 package com.qniao.dam.domain.aggregate.rightconsumerel.entity;
 
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.qniao.dam.domian.aggregate.right.constant.RightTypeEnum;
 import com.qniao.domain.Entity;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
+import java.time.LocalDate;
+
 @Data
 @EqualsAndHashCode(callSuper = true)
 @TableName("da_right_consume_rel")
 public class RightConsumeRel extends Entity<RightConsumeRel> {
 
+    @ApiModelProperty("用户标识")
+    private Long userId;
+
+    @ApiModelProperty("征婚资料标识")
+    private Long miId;
+
+    @ApiModelProperty("消费日期")
+    private LocalDate consumeDate;
+
+    @ApiModelProperty("权益类型")
+    private RightTypeEnum type;
+
     @ApiModelProperty("权益标识")
     private Long rightId;
 
@@ -20,8 +35,12 @@ public class RightConsumeRel extends Entity<RightConsumeRel> {
     @ApiModelProperty("状态")
     private Boolean enable;
 
-    public static RightConsumeRel build(Long rightId, Long associatedId) {
+    public static RightConsumeRel build(Long userId, Long miId, RightTypeEnum type, Long rightId, Long associatedId) {
         RightConsumeRel rightConsumeRel = new RightConsumeRel();
+        rightConsumeRel.setUserId(userId);
+        rightConsumeRel.setMiId(miId);
+        rightConsumeRel.setConsumeDate(LocalDate.now());
+        rightConsumeRel.setType(type);
         rightConsumeRel.setRightId(rightId);
         rightConsumeRel.setAssociatedId(associatedId);
         rightConsumeRel.setEnable(true);

dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/right/RightApplicationService.java

@@ -152,9 +152,6 @@ public class RightApplicationService {
         }
     }
 
-    /**
-     * todo 检查今日使用次数
-     */
     public UserConsumeRightBySdkVo consumeRight(UserConsumeRightBySdkDto dto) {
         UserConsumeRightBySdkVo vo = new UserConsumeRightBySdkVo();
         try {
@@ -164,6 +161,7 @@ public class RightApplicationService {
                     if (rightQueryService.checkEnable(right)) {
                         executeConsumeRight(right, dto.getAssociatedId());
                         vo.setFlag(true);
+                        break;
                     }
                 }
             }
@@ -194,8 +192,9 @@ public class RightApplicationService {
         if (!rightQueryService.checkEnable(right)) {
             right.setEnable(false);
         }
+        right.setUpdateRightTermList(right.getRightTermList());
         //组装权益消费关联实体
-        RightConsumeRel rightConsumeRel = RightConsumeRel.build(right.getId(), associatedId);
+        RightConsumeRel rightConsumeRel = RightConsumeRel.build(right.getUserId(), right.getMiId(), right.getType(), right.getId(), associatedId);
         consumeRightDomainService.handle(right, rightConsumeRel);
     }
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/query/right/impl/RightQueryServiceImpl.java

@@ -13,6 +13,7 @@ import com.qniao.dam.domian.aggregate.right.constant.RightUnitEnum;
 import com.qniao.dam.infrastructure.persistent.dao.domain.RightDao;
 import com.qniao.dam.infrastructure.persistent.dao.domain.RightTermDao;
 import com.qniao.dam.query.right.RightQueryService;
+import com.qniao.dam.query.rightconsumerel.RightConsumeRelQueryService;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -33,6 +34,8 @@ public class RightQueryServiceImpl implements RightQueryService {
     private RightTermDao rightTermDao;
     @Resource
     private RightRepository rightRepository;
+    @Resource
+    private RightConsumeRelQueryService rightConsumeRelQueryService;
 
     @Override
     public List<UserListRightByCustomerVo> listRightByCustomer(UserListRightByCustomerQueryParam queryParam) {
@@ -46,6 +49,8 @@ public class RightQueryServiceImpl implements RightQueryService {
                 List<Right> rightList = allRightMap.get(rightType);
                 if (CollUtil.isNotEmpty(rightList)) {
                     UserListRightByCustomerVo customerVo = transformCustomerRight(rightType, rightList);
+                    //统计使用次数
+                    customerVo.setDailyUseCount(rightConsumeRelQueryService.countDailyUseBy(queryParam.getUserId(), queryParam.getMiId(), rightType));
                     customerVolist.add(customerVo);
                 }
             }

dating-agency-mall-server/src/main/java/com/qniao/dam/query/rightconsumerel/RightConsumeRelQueryService.java

@@ -0,0 +1,7 @@
+package com.qniao.dam.query.rightconsumerel;
+
+import com.qniao.dam.domian.aggregate.right.constant.RightTypeEnum;
+
+public interface RightConsumeRelQueryService {
+    Integer countDailyUseBy(Long userId, Long miId, RightTypeEnum rightType);
+}

dating-agency-mall-server/src/main/java/com/qniao/dam/query/rightconsumerel/impl/RightConsumeRelQueryServiceImpl.java

@@ -0,0 +1,29 @@
+package com.qniao.dam.query.rightconsumerel.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.qniao.dam.domain.aggregate.rightconsumerel.entity.RightConsumeRel;
+import com.qniao.dam.domian.aggregate.right.constant.RightTypeEnum;
+import com.qniao.dam.infrastructure.persistent.dao.domain.RightConsumeRelDao;
+import com.qniao.dam.query.rightconsumerel.RightConsumeRelQueryService;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Mono;
+
+import javax.annotation.Resource;
+import java.time.LocalDate;
+
+@Service
+public class RightConsumeRelQueryServiceImpl implements RightConsumeRelQueryService {
+
+    @Resource
+    private RightConsumeRelDao rightConsumeRelDao;
+
+    @Override
+    public Integer countDailyUseBy(Long userId, Long miId, RightTypeEnum rightType) {
+        return rightConsumeRelDao.selectCount(new LambdaQueryWrapper<RightConsumeRel>()
+                .eq(RightConsumeRel::getUserId, userId)
+                .eq(RightConsumeRel::getMiId, miId)
+                .eq(RightConsumeRel::getType, rightType)
+                .eq(RightConsumeRel::getConsumeDate, LocalDate.now())
+                .eq(RightConsumeRel::getEnable, true));
+    }
+}