| | |
|---|
| | | if(CollUtil.isEmpty(mallMqRecords)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | DateTime dateTime = DateUtil.offsetMinute(new Date(), -5); |
|---|
| | | for(MallMqRecord mallMqRecord : mallMqRecords){ |
|---|
| | | if(DateUtil.compare(dateTime,mallMqRecord.getCreateTime()) <= 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Integer retryTimes = mallMqRecord.getRetryTimes(); |
|---|
| | | if(retryTimes <= 0){ |
|---|
| | | continue; |
|---|
| | |
|---|
| | | mallMqRecordMapper.updateById(mallMqRecord); |
|---|
| | | |
|---|
| | | Long orderId = mallMqRecord.getOrderId(); |
|---|
| | | agentProducer.sendPerkMoneyMsg(orderId); |
|---|
| | | if(mallMqRecord.getState() == 2){ |
|---|
| | | agentProducer.sendPerkMoneyMsg(orderId); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获取每日最大产生的凭证数量 |
|---|
| | | * 改成每日产出固定值 |
|---|
| | | */ |
|---|
| | | BigDecimal achieveDailyRelease = getAchieveDailyRelease(); |
|---|
| | | // BigDecimal achieveDailyRelease = getAchieveDailyRelease(); |
|---|
| | | DataDictionaryCustom achieveReleaseDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( |
|---|
| | | GreenScoreEnum.ACHIEVE_RELEASE.getType(), |
|---|
| | | GreenScoreEnum.ACHIEVE_RELEASE.getCode() |
|---|
| | | ); |
|---|
| | | BigDecimal achieveDailyRelease = new BigDecimal(achieveReleaseDic.getValue() == null ? "0" : achieveReleaseDic.getValue()); |
|---|
| | | if(achieveDailyRelease.compareTo(BigDecimal.ZERO) <= 0){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(achieveTotal.compareTo(achieveMax) < 0){ |
|---|
| | | BigDecimal divide = achieveTotal.divide(achieveMax, 2, BigDecimal.ROUND_DOWN); |
|---|
| | |
|---|
| | | mallScoreAchieveRelease.setReleaseNo(scoreNo); |
|---|
| | | mallScoreAchieveRelease.setVoucherExpect(achieveDailyRelease); |
|---|
| | | mallScoreAchieveRelease.setVoucherReal(achieveDailyReleaseReal); |
|---|
| | | mallScoreAchieveReleaseMapper.updateById(mallScoreAchieveRelease); |
|---|
| | | mallScoreAchieveReleaseMapper.insert(mallScoreAchieveRelease); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
