|
|
|
@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollUtil; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
|
import com.qniao.dam.application.service.right.RightApplicationService; |
|
|
|
import com.qniao.dam.domain.aggregate.right.valueobj.RightAcquireRecord; |
|
|
|
import com.qniao.dam.domian.aggregate.right.constant.RightAcquireEnum; |
|
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.MarriageInformationDao; |
|
|
|
import com.qniao.dam.infrastructure.persistent.dao.domain.RightAcquireRecordDao; |
|
|
|
import com.qniao.das.domian.aggregate.marriageinformation.MarriageInformation; |
|
|
|
@ -52,6 +53,9 @@ public class AcquireGiftRightTask { |
|
|
|
for (MarriageInformation marriageInformation : list) { |
|
|
|
//判断资料是否领取过免费权益 |
|
|
|
if (rightAcquireRecordDao.selectCount(new LambdaQueryWrapper<RightAcquireRecord>() |
|
|
|
.eq(RightAcquireRecord::getUserId, marriageInformation.getUserId()) |
|
|
|
.eq(RightAcquireRecord::getMiId, marriageInformation.getId()) |
|
|
|
.eq(RightAcquireRecord::getAcquireType, RightAcquireEnum.GIFT) |
|
|
|
.ge(RightAcquireRecord::getCreateTime, startTime) |
|
|
|
.le(RightAcquireRecord::getCreateTime, endTime)) == 0) { |
|
|
|
rightApplicationService.acquireNewMIRight(marriageInformation.getUserId(), marriageInformation.getId()); |
|
|
|
|