| | |
| | | monthEnd = DateTimeHelper.getCurrentMouthEnd(); |
| | | } |
| | | List<UserIntegralChanges> userIntegralChanges = this.baseMapper.selectList(new QueryWrapper<UserIntegralChanges>() |
| | | .eq("appUserId",userIdFormRedis ) |
| | | .between("insertTime",monthStart,monthEnd) |
| | | .eq("appUserId", userIdFormRedis) |
| | | .between("insertTime", monthStart, monthEnd) |
| | | .orderByDesc("insertTime")); |
| | | if (userIntegralChanges.size() > 0 ){ |
| | | if (userIntegralChanges.size() > 0) { |
| | | for (UserIntegralChanges userIntegralChange : userIntegralChanges) { |
| | | IntegralsData detail= new IntegralsData(); |
| | | switch (userIntegralChange.getType()){ |
| | | IntegralsData detail = new IntegralsData(); |
| | | switch (userIntegralChange.getType()) { |
| | | case 1: |
| | | detail.setConsumeAmount("+"+(userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeAmount("+" + (userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeName("赠送积分"); |
| | | detail.setDetailsType(2); |
| | | break; |
| | | case 2: |
| | | detail.setConsumeAmount(""+(userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeAmount("" + (userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeName("兑换商品"); |
| | | detail.setDetailsType(1); |
| | | break; |
| | | case 3: |
| | | detail.setConsumeAmount("+"+(userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeAmount("+" + (userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeName("完成课后练习"); |
| | | detail.setDetailsType(2); |
| | | break; |
| | | case 4: |
| | | detail.setConsumeAmount("+"+(userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeAmount("+" + (userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeTime(simpleDateFormat.format(userIntegralChange.getInsertTime())); |
| | | detail.setConsumeName("观看教学视频"); |
| | | detail.setDetailsType(2); |
| | | break; |
| | | case 5: |
| | | detail.setConsumeAmount(""+(userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeAmount("" + (userIntegralChange.getNewIntegral() - userIntegralChange.getOldIntegral())); |
| | | detail.setConsumeName("智慧球场开始游戏"); |
| | | detail.setDetailsType(1); |
| | | break; |
| | |
| | | detail.setConsumeTime(simpleDateFormat.format(userIntegralChange.getInsertTime())); |
| | | details.add(detail); |
| | | } |
| | | if (null != recordId){ |
| | | if (null != recordId) { |
| | | details = details.stream() |
| | | .filter(obj -> obj instanceof IntegralsData) |
| | | .filter(obj -> !Objects.equals(obj.getDetailsType(), recordId)) |
| | |
| | | |
| | | /** |
| | | * 保存用户积分变动 |
| | | * |
| | | * @param vo |
| | | * @throws Exception |
| | | */ |
| | |
| | | public List<ExchangeDetailsResponse> queryExchangeGoodsdetails(Integer userIdFormRedis, Integer useType, Integer goodType) { |
| | | List<ExchangeDetailsResponse> detailsResponses = new ArrayList<>(); |
| | | ExchangeDetailsVo integralExchangeDetails = mcClient.getIntegralExchangeDetails(userIdFormRedis); |
| | | if (ToolUtil.isNotEmpty(integralExchangeDetails.getDetailsResponses())){ |
| | | if (ToolUtil.isNotEmpty(integralExchangeDetails.getDetailsResponses())) { |
| | | detailsResponses = integralExchangeDetails.getDetailsResponses(); |
| | | if (ToolUtil.isNotEmpty(useType)){ |
| | | if (ToolUtil.isNotEmpty(useType)) { |
| | | detailsResponses = integralExchangeDetails.getDetailsResponses().stream() |
| | | .filter(response -> Objects.equals(response.getUseStatus(), useType)) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | if (ToolUtil.isNotEmpty(goodType)){ |
| | | if (ToolUtil.isNotEmpty(goodType)) { |
| | | detailsResponses = integralExchangeDetails.getDetailsResponses().stream() |
| | | .filter(response -> Objects.equals(response.getGoodType(), goodType)) |
| | | .collect(Collectors.toList()); |
| | |
| | | |
| | | @Override |
| | | public Page<UserIntegral> listAll(Page<UserIntegral> userIntegralPage, IntegralListQuery integralListQuery) { |
| | | String sTime =null; |
| | | String eTime =null; |
| | | if(ToolUtil.isNotEmpty(integralListQuery.getTime())){ |
| | | sTime = integralListQuery.getTime().split(" - ")[0]+" 00:00:00"; |
| | | eTime = integralListQuery.getTime().split(" - ")[1]+" 23:59:59"; |
| | | String sTime = null; |
| | | String eTime = null; |
| | | if (ToolUtil.isNotEmpty(integralListQuery.getTime())) { |
| | | sTime = integralListQuery.getTime().split(" - ")[0] + " 00:00:00"; |
| | | eTime = integralListQuery.getTime().split(" - ")[1] + " 23:59:59"; |
| | | } |
| | | Page<UserIntegral> userIntegrals = this.baseMapper.listAll(userIntegralPage, integralListQuery, sTime, eTime); |
| | | for (UserIntegral userIntegral : userIntegrals.getRecords()) { |
| | | if(userIntegral.getCategory()==1){ |
| | | userIntegral.setIntegral(userIntegral.getNewIntegral()-userIntegral.getOldIntegral()); |
| | | }else { |
| | | userIntegral.setIntegral(userIntegral.getOldIntegral()-userIntegral.getNewIntegral()); |
| | | if (userIntegral.getCategory() == 1) { |
| | | userIntegral.setIntegral(userIntegral.getNewIntegral() - userIntegral.getOldIntegral()); |
| | | } else { |
| | | userIntegral.setIntegral(userIntegral.getOldIntegral() - userIntegral.getNewIntegral()); |
| | | } |
| | | } |
| | | return userIntegrals; |
| | |
| | | ExchangeDetailsVo integralExchangeDetails = mcClient.getIntegralExchangeDetails(userIdFormRedis); |
| | | |
| | | |
| | | if (ToolUtil.isNotEmpty(integralExchangeDetails.getDetailsResponses())){ |
| | | if (ToolUtil.isNotEmpty(integralExchangeDetails.getDetailsResponses())) { |
| | | detailsResponses = integralExchangeDetails.getDetailsResponses(); |
| | | if (ToolUtil.isNotEmpty(useType)){ |
| | | if (ToolUtil.isNotEmpty(useType)) { |
| | | detailsResponses = detailsResponses.stream() |
| | | .filter(response -> Objects.equals(response.getUseStatus(), useType)) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | if (ToolUtil.isNotEmpty(goodType)){ |
| | | if (ToolUtil.isNotEmpty(goodType)) { |
| | | detailsResponses = detailsResponses.stream() |
| | | .filter(response -> Objects.equals(response.getGoodType(), goodType)) |
| | | .collect(Collectors.toList()); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | int totalItems = detailsResponses.size(); |
| | |
| | | } else { |
| | | detailsResponses.clear(); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | return detailsResponses; |