| | |
| | | public String addBatch(MemberCouponAddDTO memberCoupon){ |
| | | checkAddBatchParamValid(memberCoupon); |
| | | |
| | | int num = 0; |
| | | List<Coupon> couponList = getCouponListByParam(memberCoupon); |
| | | List<Member> memberList = getMemberListByParam(memberCoupon); |
| | | List<MemberCoupon> addList = new ArrayList<>(); |
| | |
| | | //挨个送 |
| | | addList.add(initMemberCouponByParam(coupon,member,loginUserInfo,now)); |
| | | } |
| | | num++; |
| | | } |
| | | index++; |
| | | } |
| | | |
| | | |
| | | if(addList.size()>0){ |
| | | //批量插入数据 |
| | | memberCouponMapper.insert(addList); |
| | | } |
| | | return "操作成功,成功人员数量:"+num+",共发放优惠券数量:"+addList.size(); |
| | | return "操作成功,成功人员数量:"+memberList.size()+",共发放优惠券数量:"+addList.size(); |
| | | |
| | | } |
| | | |
| | |
| | | insert.setMemberId(member.getId()); |
| | | insert.setShopId(coupon.getShopId()); |
| | | insert.setType(coupon.getType()); |
| | | insert.setCouponType(coupon.getType()); |
| | | insert.setLimitPrice(coupon.getLimitPrice()); |
| | | insert.setPrice(coupon.getPrice()); |
| | | if(Constants.equalsObject(coupon.getUseType(),Constants.ZERO)){ |
| | |
| | | if(list == null || list.size()==0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,未查询到有效优惠券数据,请刷新页面重试!"); |
| | | } |
| | | |
| | | return list; |
| | | } |
| | | |
| | | private void checkAddBatchParamValid(MemberCouponAddDTO memberCoupon) { |
| | | if(memberCoupon.getAddType() == null || memberCoupon.getAddCouponList()==null || memberCoupon.getAddCouponList().size()==0){ |
| | | if(memberCoupon.getAddType() == null |
| | | || memberCoupon.getAddCouponList()==null |
| | | || memberCoupon.getAddCouponList().size()==0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | if(Constants.equalsObject(memberCoupon.getAddType(),Constants.ZERO)){ |
| | |
| | | if( StringUtils.isBlank(memberCoupon.getAddMemberPhones())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | String[] ss =memberCoupon.getAddMemberPhones().split("\n"); |
| | | String[] ss =memberCoupon.getAddMemberPhones().replace(" ","").split("\n"); |
| | | if(ss == null ||ss.length==0){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | |
| | | MPJLambdaWrapper<MemberCoupon> queryWrapper = new MPJLambdaWrapper<>(); |
| | | Utils.MP.blankToNull(pageWrap.getModel()); |
| | | queryWrapper.selectAll(MemberCoupon.class); |
| | | queryWrapper.selectAs(Member::getPhone,MemberCoupon::getMemberPhone); |
| | | queryWrapper.selectAs(Member::getNickname,MemberCoupon::getNikeName); |
| | | queryWrapper.selectAs(Goodsorder::getCode,MemberCoupon::getOrderCode); |
| | | queryWrapper.selectAs(Goodsorder::getCouponPrice,MemberCoupon::getCouponPrice);//优惠金额 |
| | |
| | | IPage<MemberCoupon> result = memberCouponJoinMapper.selectJoinPage(page, MemberCoupon.class, queryWrapper); |
| | | if(result!=null && result.getRecords()!=null){ |
| | | for(MemberCoupon model :result.getRecords()){ |
| | | model.setNikeName(StringUtils.defaultString(model.getNikeName(),"")+" "+StringUtils.defaultString(model.getMemberPhone(),"")); |
| | | if(Constants.equalsInteger(model.getStatus(),Constants.ZERO) |
| | | && model.getEndDate()!=null |
| | | && model.getEndDate().before(new Date())){ |