| | |
| | | private final SqlSessionTemplate sqlSessionTemplate; |
| | | private final IApiMallMemberWalletService memberWalletService; |
| | | private final MallMoneyFlowMapper mallMoneyFlowMapper; |
| | | private final MallMqRecordMapper mallMqRecordMapper; |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | |
| | | |
| | | long end = System.currentTimeMillis(); |
| | | log.info("============订单:{},时间:{}===========",mallOrderInfo.getOrderNo(),(end - start)/1000); |
| | | MallMqRecord mallMqRecord = mallMqRecordMapper.selectByOrderId(orderId); |
| | | if(ObjectUtil.isNotEmpty(mallMqRecord)){ |
| | | mallMqRecord.setState(1); |
| | | mallMqRecordMapper.updateById(mallMqRecord); |
| | | } |
| | | } |
| | | |
| | | /** |
| | |
| | | if(CollUtil.isNotEmpty(mallMemberStars)){ |
| | | |
| | | List<Long> mallMemberStarIds = mallMemberStars.stream().map(MallMember::getId).collect(Collectors.toList()); |
| | | //排除掉本身 |
| | | mallMemberStarIds.remove(memberId); |
| | | //当前等级的总贡献点 |
| | | List<MallMemberWallet> mallMemberWallets = mallMemberWalletMapper.selectMemberWalletsByIds(mallMemberStarIds); |
| | | Integer starSum = mallMemberWallets.stream().mapToInt(MallMemberWallet::getStar).sum(); |