package com.matrix; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.RandomUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.matrix.core.pojo.AjaxResult; import com.matrix.core.tools.StringUtils; import com.matrix.system.activity.dao.ActivitySignAwardSetDao; import com.matrix.system.activity.dao.ActivitySignReceiveRecordDao; import com.matrix.system.activity.dao.ActivitySignRecordDao; import com.matrix.system.activity.dao.ActivitySignWriteoffDao; import com.matrix.system.activity.entity.ActivitySignAwardSet; import com.matrix.system.activity.entity.ActivitySignReceiveRecord; import com.matrix.system.activity.entity.ActivitySignRecord; import com.matrix.system.activity.entity.ActivitySignWriteoff; import com.matrix.system.common.constance.AppConstance; import com.matrix.system.hive.bean.SysVipInfo; import com.matrix.system.hive.dao.SysVipInfoDao; import com.matrix.system.score.entity.ScoreVipDetail; import com.matrix.system.score.service.ScoreVipDetailService; import com.matrix.system.shopXcx.api.dto.SeeAwardTextDto; import com.matrix.system.shopXcx.api.service.WxShopLogisticsQueryService; import com.matrix.system.shopXcx.api.tools.WxShopCouponUtil; import com.matrix.system.shopXcx.api.vo.ActivitySignAwardSetVo; import com.matrix.system.shopXcx.api.vo.LuckyDrawBasicInfoJsonVo; import com.matrix.system.shopXcx.api.vo.LuckyDrawSuccessVo; import com.matrix.system.shopXcx.api.vo.SeeAwardTextVo; import com.matrix.system.shopXcx.bean.*; import com.matrix.system.shopXcx.dao.*; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.RequestBody; import java.text.SimpleDateFormat; import java.util.*; @RunWith(SpringRunner.class) @SpringBootTest(classes = {ZqErpApplication.class},webEnvironment =SpringBootTest.WebEnvironment.RANDOM_PORT) public class FenxiaoSoreInitTest { @Autowired private ShopActivitiesDao shopActivitiesDao; @Autowired private ActivitySignAwardSetDao activitySignAwardSetDao; @Autowired private ActivitySignReceiveRecordDao activitySignReceiveRecordDao; @Autowired private ActivitySignWriteoffDao activitySignWriteoffDao; @Autowired private ActivitySignRecordDao activitySignRecordDao; @Autowired ShopDeliveryInfoDao shopDeliveryInfoDao; @Autowired private ShopLogisticsInfoDao shopLogisticsInfoDao; @Autowired private WxShopLogisticsQueryService wxShopLogisticsQueryService; @Autowired private ScoreVipDetailService scoreVipDetailService; @Autowired private ShopCouponDao shopCouponDao; @Autowired private WxShopCouponUtil wxShopCouponUtil; @Autowired private ShopCouponRecordDao shopCouponRecordDao; @Autowired SysVipInfoDao sysVipInfoDao; //获取奖品并索引+1 已领取+1 public synchronized ActivitySignAwardSet updateShopActivityAndAwardSet(Long actId){ //通过活动ID获取对应的活动 ShopActivities shopActivities = shopActivitiesDao.selectById(actId); String actContent = shopActivities.getActContent(); LuckyDrawBasicInfoJsonVo luckyDrawBasicInfoJsonVo = JSON.parseObject(actContent, LuckyDrawBasicInfoJsonVo.class); //中奖索引 Integer awrdLineIndex = luckyDrawBasicInfoJsonVo.getAwrdLineIndex(); //中奖序列 String awardLine = luckyDrawBasicInfoJsonVo.getAwardLine(); ActivitySignAwardSet activitySignAwardSet = null; if(awardLine.length() > 0) { String substring = awardLine.substring(1, awardLine.length() - 1); List awardList = StrUtil.splitTrim(substring, ","); if(awrdLineIndex < awardList.size()){ //中奖 Long awardId = Long.parseLong(awardList.get(awrdLineIndex + 1)); ActivitySignAwardSet activitySignAwardSetGet = activitySignAwardSetDao.selectById(awardId); //奖项库存数量 int awardInventoryCnt = activitySignAwardSetGet.getAwardInventoryCnt(); //已派发数量 int awardDistributeCnt = activitySignAwardSetGet.getAwardDistributeCnt(); if(awardDistributeCnt < awardInventoryCnt){ activitySignAwardSet = activitySignAwardSetGet; activitySignAwardSetGet.setAwardDistributeCnt(awardDistributeCnt +1); activitySignAwardSetDao.updateById(activitySignAwardSetGet); //将基本信息转换成JSON字符串存储到活动主表的act_content字段 luckyDrawBasicInfoJsonVo.setAwrdLineIndex(awrdLineIndex + 1); String json= JSON.toJSONString(luckyDrawBasicInfoJsonVo); shopActivities.setActContent(json); shopActivitiesDao.updateByModel(shopActivities); } } } return activitySignAwardSet; } @Test public void getLuckDraw(){ long actId = 85L; Long userId = 85L; Long companyId = 36L; SysVipInfo user = sysVipInfoDao.selectById(userId); /** * 活动是否存在 * 活动是否已经开始 * 免费抽奖还是积分抽奖 * 积分抽奖一次一次换 * 减少积分 * 是否中奖 * 中奖规则 * 奖品处理 * */ //活动是否存在 ShopActivities shopActivities = shopActivitiesDao.selectById(actId); if (ObjectUtil.isEmpty(shopActivities)) { // return AjaxResult.buildFailInstance("活动不存在"); } //活动是否已经开始 Integer actStatus = shopActivities.getActStatus(); if(ShopActivities.ACTSTATUS_STATUS_ING != actStatus) { //return AjaxResult.buildFailInstance("活动未开始"); } //获取今日抽奖总次数 String actContent = shopActivities.getActContent(); LuckyDrawBasicInfoJsonVo luckyDrawBasicInfoJsonVo = JSON.parseObject(actContent, LuckyDrawBasicInfoJsonVo.class); List activityRecords = activitySignRecordDao.selectListByActIdAndUserIdLikesignTime(actId,userId, DateUtil.date()); if(CollUtil.isNotEmpty(activityRecords)){ Integer wmkcjjh = luckyDrawBasicInfoJsonVo.getWmkcjjh(); Integer jfdhcs = luckyDrawBasicInfoJsonVo.getJfdhcs(); if(activityRecords.size() >= (wmkcjjh+jfdhcs)){ //return AjaxResult.buildFailInstance("明天再来抽奖吧"); } } //生成抽奖记录 ActivitySignRecord activitySignRecordAdd = new ActivitySignRecord(); activitySignRecordAdd.setCompanyId(companyId); activitySignRecordAdd.setCreateBy(user.getVipName()); activitySignRecordAdd.setCreateTime(DateUtil.date()); activitySignRecordAdd.setUpdateBy(user.getVipName()); activitySignRecordAdd.setUpdateTime(DateUtil.date()); activitySignRecordAdd.setActivityId(actId); activitySignRecordAdd.setSignTime(DateUtil.date()); activitySignRecordAdd.setUserId(userId); activitySignRecordDao.insert(activitySignRecordAdd); /** 获取中奖概率 中奖了获取奖品ID 没有中奖则获取谢谢参与的奖品ID 每个人最多中奖次数 */ List luckyDrawSuccessVos = new ArrayList<>(); //获取谢谢参与奖 QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("award_rule",ActivitySignAwardSet.AWARDRULE_NORMAL); queryWrapper.eq("company_id",companyId); queryWrapper.eq("activity_id",actId); ActivitySignAwardSet activitySignAwardSetNormal = activitySignAwardSetDao.selectOne(queryWrapper); //每个人最多中奖次数 Integer zzjcs = luckyDrawBasicInfoJsonVo.getZzjcs(); QueryWrapper queryWrapperActivitySignReceiveRecord = new QueryWrapper<>(); queryWrapperActivitySignReceiveRecord.eq("company_id", companyId); queryWrapperActivitySignReceiveRecord.eq("activity_id", actId); queryWrapperActivitySignReceiveRecord.eq("user_id", userId); queryWrapperActivitySignReceiveRecord.ne("award_id", activitySignAwardSetNormal.getId()); List activitySignReceiveRecordDone = activitySignReceiveRecordDao.selectList(queryWrapperActivitySignReceiveRecord); if(CollUtil.isNotEmpty(activitySignReceiveRecordDone)){ if(activitySignReceiveRecordDone.size() >= zzjcs){ //生成领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord(); activitySignReceiveRecord.setUserId(userId); activitySignReceiveRecord.setReceiveTime(DateUtil.date()); activitySignReceiveRecord.setAwardId(activitySignAwardSetNormal.getId()); activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE); activitySignReceiveRecord.setActivityId(actId); activitySignReceiveRecord.setCompanyId(companyId); activitySignReceiveRecord.setCreateBy(user.getVipName()); activitySignReceiveRecord.setCreateTime(new Date()); activitySignReceiveRecord.setUpdateBy(user.getVipName()); activitySignReceiveRecord.setUpdateTime(new Date()); activitySignReceiveRecordDao.insert(activitySignReceiveRecord); LuckyDrawSuccessVo luckyDrawSuccessVo = new LuckyDrawSuccessVo(); luckyDrawSuccessVo.setType(1); luckyDrawSuccessVo.setAwardName(activitySignAwardSetNormal.getAwardName()); luckyDrawSuccessVo.setAwardImg(activitySignAwardSetNormal.getIntroduceImg()); luckyDrawSuccessVos.add(luckyDrawSuccessVo); AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(""); ajaxResult.setData(luckyDrawSuccessVos); //return ajaxResult; } } //总中奖率 int zzjl = luckyDrawBasicInfoJsonVo.getZzjl(); int randomInt = RandomUtil.randomInt(1, 100); //不中奖的分界线 int failureScope = 0; if(failureScope >= randomInt){ //生成领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord(); activitySignReceiveRecord.setUserId(userId); activitySignReceiveRecord.setReceiveTime(DateUtil.date()); activitySignReceiveRecord.setAwardId(activitySignAwardSetNormal.getId()); activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE); activitySignReceiveRecord.setActivityId(actId); activitySignReceiveRecord.setCompanyId(companyId); activitySignReceiveRecord.setCreateBy(user.getVipName()); activitySignReceiveRecord.setCreateTime(new Date()); activitySignReceiveRecord.setUpdateBy(user.getVipName()); activitySignReceiveRecord.setUpdateTime(new Date()); activitySignReceiveRecordDao.insert(activitySignReceiveRecord); LuckyDrawSuccessVo luckyDrawSuccessVo = new LuckyDrawSuccessVo(); luckyDrawSuccessVo.setType(1); luckyDrawSuccessVo.setAwardName(activitySignAwardSetNormal.getAwardName()); luckyDrawSuccessVo.setAwardImg(activitySignAwardSetNormal.getIntroduceImg()); luckyDrawSuccessVos.add(luckyDrawSuccessVo); AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(""); ajaxResult.setData(luckyDrawSuccessVos); //return ajaxResult; } //中奖 if(failureScope < randomInt){ //获取奖品 ActivitySignAwardSet activitySignAwardSetCumulativeDay = updateShopActivityAndAwardSet(actId); if(ObjectUtil.isNotEmpty(activitySignAwardSetCumulativeDay)){ LuckyDrawSuccessVo luckyDrawSuccessVo = new LuckyDrawSuccessVo(); luckyDrawSuccessVo.setType(2); luckyDrawSuccessVo.setAwardType(activitySignAwardSetCumulativeDay.getAwardType()); luckyDrawSuccessVo.setAwardName(activitySignAwardSetCumulativeDay.getAwardName()); luckyDrawSuccessVo.setAwardImg(activitySignAwardSetCumulativeDay.getIntroduceImg()); luckyDrawSuccessVo.setAwardState(activitySignAwardSetCumulativeDay.getAwardState()); //新增奖品领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord(); activitySignReceiveRecord.setUserId(userId); activitySignReceiveRecord.setReceiveTime(DateUtil.date()); activitySignReceiveRecord.setAwardId(activitySignAwardSetCumulativeDay.getId()); activitySignReceiveRecord.setActivityId(actId); activitySignReceiveRecord.setCompanyId(companyId); activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE); activitySignReceiveRecord.setCreateBy(user.getVipName()); activitySignReceiveRecord.setCreateTime(new Date()); activitySignReceiveRecord.setUpdateBy(user.getVipName()); activitySignReceiveRecord.setUpdateTime(new Date()); /** * 奖项类型(1:自定义产品2:积分3:优惠券4:店铺商品) * * todo:4:店铺商品 */ //1:自定义产品 if(ActivitySignAwardSet.AWARDTYPE_CUSTOMIZE == activitySignAwardSetCumulativeDay.getAwardType()) { activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_ING); String randomString = StringUtils.getRandomString(8); activitySignReceiveRecord.setWriteOffCode(randomString); /** * 获取对应奖品的领取方式(兑奖方式(1:线下兑换2:物流配送3:客服兑换) */ luckyDrawSuccessVo.setWriteOffCode(randomString); luckyDrawSuccessVo.setAwardWay(activitySignAwardSetCumulativeDay.getAwardWay()); //2:物流配送 luckyDrawSuccessVo.setOperationTip(activitySignAwardSetCumulativeDay.getOperationTip()); //1:线下兑换 if(ActivitySignAwardSet.AWARDWAY_ONE == activitySignAwardSetCumulativeDay.getAwardWay()) { luckyDrawSuccessVo.setIntroduceTip(activitySignAwardSetCumulativeDay.getIntroduceTip()); luckyDrawSuccessVo.setPrizeAddress(activitySignAwardSetCumulativeDay.getPrizeAddress()); luckyDrawSuccessVo.setPrizeStartTime(activitySignAwardSetCumulativeDay.getPrizeStartTime()); luckyDrawSuccessVo.setPrizeEndTime(activitySignAwardSetCumulativeDay.getPrizeEndTime()); } //3:客服兑换 if(ActivitySignAwardSet.AWARDWAY_THREE == activitySignAwardSetCumulativeDay.getAwardWay()) { luckyDrawSuccessVo.setWechatImg(activitySignAwardSetCumulativeDay.getWechatImg()); luckyDrawSuccessVo.setPrizeStartTime(activitySignAwardSetCumulativeDay.getPrizeStartTime()); luckyDrawSuccessVo.setPrizeEndTime(activitySignAwardSetCumulativeDay.getPrizeEndTime()); } } //2:积分 if(ActivitySignAwardSet.AWARDTYPE_SCORE == activitySignAwardSetCumulativeDay.getAwardType()) { luckyDrawSuccessVo.setScoreCnt(activitySignAwardSetCumulativeDay.getScoreCnt()); } //3:优惠券 if(ActivitySignAwardSet.AWARDTYPE_COUPON == activitySignAwardSetCumulativeDay.getAwardType()) { luckyDrawSuccessVo.setCouponName(activitySignAwardSetCumulativeDay.getCouponName()); //获取优惠券 int couponId = Integer.parseInt(activitySignAwardSetCumulativeDay.getCouponId()); ShopCoupon shopCoupon = shopCouponDao.selectById(couponId); // 如果没有找到该优惠券 if (shopCoupon == null) { // return new AjaxResult(AjaxResult.STATUS_FAIL, "没有找到该优惠券!"); } // 如果优惠券有数量限制并且已经领完 if (shopCoupon.getMaxQuantity() >= 0 && (shopCoupon.getMaxQuantity() <= shopCoupon.getQuantityReceive())) { //return new AjaxResult(AjaxResult.STATUS_FAIL, "优惠券已领完!"); } boolean newPeople = wxShopCouponUtil.verifyIsNewPeople(userId); // 如果改券是新人专属且当前用户不是新人 if (AppConstance.COUPON_GET_LIMT_NEW.equals(shopCoupon.getGetLimit()) && !newPeople) { // return new AjaxResult(AjaxResult.STATUS_FAIL, "该优惠券为新人专享优惠券!"); } ShopCouponRecord insertRecord = new ShopCouponRecord(); insertRecord.setCreateBy(AppConstance.SYSTEM_USER); insertRecord.setUpdateBy(AppConstance.SYSTEM_USER); insertRecord.setCId(couponId); insertRecord.setUserId(userId); insertRecord.setIsUsing(2); int i = shopCouponRecordDao.insert(insertRecord); // 如果插入领取记录表失败 if (i < 0) { //return new AjaxResult(AjaxResult.STATUS_FAIL, "优惠券领取失败!"); } shopCoupon.setQuantityReceive(shopCoupon.getQuantityReceive() + 1); shopCouponDao.updateByModel(shopCoupon); } activitySignReceiveRecordDao.insert(activitySignReceiveRecord); //累计奖励积分,对应用户积分加减 if(ActivitySignAwardSet.AWARDTYPE_SCORE == activitySignAwardSetCumulativeDay.getAwardType()) { int awardType = activitySignAwardSetCumulativeDay.getAwardType(); if(ActivitySignAwardSet.AWARDTYPE_SCORE == awardType){ int scoreCnt = activitySignAwardSetCumulativeDay.getScoreCnt(); if(scoreCnt > 0){ scoreVipDetailService.addScore(userId,null,null,scoreCnt, activitySignReceiveRecord.getId(), ScoreVipDetail.SCORE_VIP_TYPE_JOIN_ACTIVE,"签到积分"); } } } //生成核销记录 if(ActivitySignAwardSet.AWARDTYPE_CUSTOMIZE == activitySignAwardSetCumulativeDay.getAwardType()) { ActivitySignWriteoff activitySignWriteoff = new ActivitySignWriteoff(); //线下兑换和客服兑换 if(ActivitySignAwardSet.AWARDWAY_ONE == activitySignAwardSetCumulativeDay.getAwardWay() || ActivitySignAwardSet.AWARDWAY_THREE == activitySignAwardSetCumulativeDay.getAwardWay()) { activitySignWriteoff.setWriteoffCode(activitySignReceiveRecord.getWriteOffCode()); } activitySignWriteoff.setActId(actId); activitySignWriteoff.setAwardId(activitySignAwardSetCumulativeDay.getId()); activitySignWriteoff.setWinTime(DateUtil.date()); if(ActivitySignAwardSet.AWARDWAY_TWO == activitySignAwardSetCumulativeDay.getAwardWay()) { activitySignWriteoff.setState(ActivitySignWriteoff.STATE_TWO); }else { activitySignWriteoff.setState(ActivitySignWriteoff.STATE_ONE); } activitySignWriteoff.setUserId(userId); activitySignWriteoff.setCompanyId(companyId); activitySignWriteoff.setReceiveId(activitySignReceiveRecord.getId()); activitySignWriteoff.setCreateBy(user.getVipName()); activitySignWriteoff.setCreateTime(new Date()); activitySignWriteoff.setUpdateBy(user.getVipName()); activitySignWriteoff.setUpdateTime(new Date()); activitySignWriteoffDao.insert(activitySignWriteoff); } luckyDrawSuccessVos.add(luckyDrawSuccessVo); }else{ //生成领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord(); activitySignReceiveRecord.setUserId(userId); activitySignReceiveRecord.setReceiveTime(DateUtil.date()); activitySignReceiveRecord.setAwardId(activitySignAwardSetNormal.getId()); activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE); activitySignReceiveRecord.setActivityId(actId); activitySignReceiveRecord.setCompanyId(companyId); activitySignReceiveRecord.setCreateBy(user.getVipName()); activitySignReceiveRecord.setCreateTime(new Date()); activitySignReceiveRecord.setUpdateBy(user.getVipName()); activitySignReceiveRecord.setUpdateTime(new Date()); activitySignReceiveRecordDao.insert(activitySignReceiveRecord); LuckyDrawSuccessVo luckyDrawSuccessVo = new LuckyDrawSuccessVo(); luckyDrawSuccessVo.setType(1); luckyDrawSuccessVo.setAwardName(activitySignAwardSetNormal.getAwardName()); luckyDrawSuccessVo.setAwardImg(activitySignAwardSetNormal.getIntroduceImg()); luckyDrawSuccessVos.add(luckyDrawSuccessVo); AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(""); ajaxResult.setData(luckyDrawSuccessVos); //return ajaxResult; } } AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(""); ajaxResult.setData(luckyDrawSuccessVos); //return ajaxResult; } @Test public void awardInsert() { //获取奖品的抽奖顺序 List activitySignAwardSetVos = new ArrayList<>(); ActivitySignAwardSetVo activitySignAwardSetVo1 = new ActivitySignAwardSetVo(); activitySignAwardSetVo1.setAwardInventoryCnt(10); activitySignAwardSetVo1.setId(1L); activitySignAwardSetVos.add(activitySignAwardSetVo1); ActivitySignAwardSetVo activitySignAwardSetVo2 = new ActivitySignAwardSetVo(); activitySignAwardSetVo2.setAwardInventoryCnt(10); activitySignAwardSetVo2.setId(2L); activitySignAwardSetVos.add(activitySignAwardSetVo2); ActivitySignAwardSetVo activitySignAwardSetVo3 = new ActivitySignAwardSetVo(); activitySignAwardSetVo3.setAwardInventoryCnt(2); activitySignAwardSetVo3.setId(3L); activitySignAwardSetVos.add(activitySignAwardSetVo3); ActivitySignAwardSetVo activitySignAwardSetVo4 = new ActivitySignAwardSetVo(); activitySignAwardSetVo4.setAwardInventoryCnt(1); activitySignAwardSetVo4.setId(4L); activitySignAwardSetVos.add(activitySignAwardSetVo4); //插入所有奖品后的集合 LinkedList awardIdFinalList = new LinkedList<>(); if(CollUtil.isNotEmpty(activitySignAwardSetVos)){ //总数 int maxCount = 0; HashMap integerStringHashMap = new HashMap<>(); for(ActivitySignAwardSetVo activitySignAwardSetVo : activitySignAwardSetVos){ //总共派发数量 int awardInventoryCnt = activitySignAwardSetVo.getAwardInventoryCnt(); integerStringHashMap.put(activitySignAwardSetVo.getId(),activitySignAwardSetVo); maxCount = maxCount + awardInventoryCnt; } HashMap sortHashMap = sortHashMap(integerStringHashMap,2); HashMap sortHashMapAec = sortHashMap(integerStringHashMap,1); //获取奖品最多的ID Long maxAwardIds = sortHashMap.keySet().stream().findFirst().get(); Long minAwardIds = sortHashMapAec.keySet().stream().findFirst().get(); //获取最大长度的奖品集合 List awardIdList = new LinkedList(); for(int i = 0; i< maxCount ; i++){ awardIdList.add(maxAwardIds); } Iterator> entries = sortHashMap.entrySet().iterator(); //插入奖品 while (entries.hasNext()) { Map.Entry entry = entries.next(); ActivitySignAwardSetVo activitySignAwardSetVo = entry.getValue(); int awardInventoryCnt = activitySignAwardSetVo.getAwardInventoryCnt(); Long awardIdNew = entry.getKey(); if(awardIdNew != maxAwardIds){ //分段之后的List List splitLists = getSplitList(awardInventoryCnt, awardIdList); for(int j = 0; j listInsert = getListInsert(maxAwardIds, awardIdNew, splitList); if(minAwardIds == awardIdNew){ awardIdFinalList.addAll(listInsert); } } } } } String awrdList = awardIdFinalList.toString(); String substring = awrdList.substring(1, awrdList.length() - 1); List strings = Arrays.asList(substring); System.out.println(strings); } //中间插入对应的奖品ID,如果和maxAwardIds相同,则索引+1 public static List getListInsert(Long awardOld,Long awardNew,List splitList){ //中间位置索引 LinkedList indexs = new LinkedList<>(); int groupFlag = splitList.size() % 2 == 0 ? (splitList.size() / 2) : (splitList.size() / 2 + 1); for(int j = groupFlag-1; j < splitList.size();j++){ if(splitList.get(j) == awardOld){ indexs.add(j); } } if(CollUtil.isNotEmpty(indexs)){ splitList.set(indexs.get(0),awardNew); }else{ splitList.add(groupFlag,awardNew); } return splitList; } //等份平分数组,最后剩余的添加到倒数第二个集合中 public static List> getSplitList(int splitNum, List list) { LinkedList> splitList = new LinkedList<>(); // groupFlag >= 1 int groupFlag = list.size() % splitNum == 0 ? (list.size() / splitNum) : (list.size() / splitNum); if(groupFlag * splitNum < list.size()){ for (int j = 1; j <= splitNum +1; j++) { if ((j * groupFlag) <= list.size() ) { splitList.add(list.subList(j * groupFlag - groupFlag, j * groupFlag)); } else if ((j * groupFlag) > list.size()) { splitList.add(list.subList(j * groupFlag - groupFlag, list.size())); } } }else if(groupFlag * splitNum > list.size()){ for (int j = 1; j < splitNum; j++) { if ((j * groupFlag) <= list.size() ) { splitList.add(list.subList(j * groupFlag - groupFlag, j * groupFlag)); } else if ((j * groupFlag) > list.size()) { splitList.add(list.subList(j * groupFlag - groupFlag, list.size())); } } }else{ for (int j = 1; j <= splitNum; j++) { if ((j * groupFlag) <= list.size() ) { splitList.add(list.subList(j * groupFlag - groupFlag, j * groupFlag)); } else if ((j * groupFlag) > list.size()) { splitList.add(list.subList(j * groupFlag - groupFlag, list.size())); } } } return splitList; } //对于奖品排序 1:升序进行排,2是倒序就是o2-o1 public static HashMap sortHashMap(HashMap map,int type) { // 首先拿到 map 的键值对集合 Set> entrySet = map.entrySet(); // 将 set 集合转为 List 集合,为什么,为了使用工具类的排序方法 List> list = new ArrayList>(entrySet); // 使用 Collections 集合工具类对 list 进行排序,排序规则使用匿名内部类来实现 Collections.sort(list, new Comparator>() { @Override public int compare(Map.Entry o1, Map.Entry o2) { if(type == 2){ //按照要求根据 升序进行排,如果是倒序就是o2-o1 return o2.getValue().getAwardInventoryCnt() - o1.getValue().getAwardInventoryCnt(); } return o1.getValue().getAwardInventoryCnt() - o2.getValue().getAwardInventoryCnt(); } }); //创建一个新的有序的 HashMap 子类的集合 LinkedHashMap linkedHashMap = new LinkedHashMap(); //将 List 中的数据存储在 LinkedHashMap 中 for (Map.Entry entry : list) { linkedHashMap.put(entry.getKey(), entry.getValue()); } //返回结果 return linkedHashMap; } /** * 获取当月的 天数 * */ public static int getCurrentMonthDay(Date date) { Date beginOfMonth = DateUtil.beginOfMonth(date); Date endOfMonth = DateUtil.endOfMonth(date); long betweenDay = DateUtil.between(beginOfMonth, endOfMonth, DateUnit.DAY); return Integer.parseInt(String.valueOf(betweenDay))+1; } /** * java 获取 获取某年某月 所有日期(yyyy-mm-dd格式字符串) * @param year * @param month * @return */ public static List getMonthFullDay(int year , int month){ SimpleDateFormat dateFormatYYYYMMDD = new SimpleDateFormat("yyyy-MM-dd"); List fullDayList = new ArrayList<>(32); // 获得当前日期对象 Calendar cal = Calendar.getInstance(); cal.clear();// 清除信息 cal.set(Calendar.YEAR, year); // 1月从0开始 cal.set(Calendar.MONTH, month-1 ); // 当月1号 cal.set(Calendar.DAY_OF_MONTH,1); int count = cal.getActualMaximum(Calendar.DAY_OF_MONTH); for (int j = 1; j <= count ; j++) { fullDayList.add(dateFormatYYYYMMDD.format(cal.getTime())); cal.add(Calendar.DAY_OF_MONTH,1); } return fullDayList; } // @Test // public void getinterger() { // Long userId = 30L; // Long companyId = 36L; // int size = activitySignReceiveRecordDao.getSignAwardReceiveCount(userId,companyId); // } // /** // * 获取累计签到天数 // * @param actId // * @param userId // * @param date // * @return // */ // public int getCumulativeDay(long actId, long userId,Date date, int i) { // ActivitySignRecord activitySignRecordOld = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,date); // if(ObjectUtil.isEmpty(activitySignRecordOld)) { // return i; // } // i++; // DateTime offsetDay = DateUtil.offsetDay(date, -i); // return getCumulativeDay(actId,userId,offsetDay,i); // } @Test public void clickSign() { long awardId = 10; Long userId = 30L; Long companyId = 36L; SeeAwardTextDto seeAwardTextDto = new SeeAwardTextDto(); seeAwardTextDto.setAwardId(awardId); seeAwardTextDto.setCompanyId(companyId); seeAwardTextDto.setUserId(userId); logisticsInsure(seeAwardTextDto); } public AjaxResult logisticsInsure(@RequestBody @Validated SeeAwardTextDto seeAwardTextDto) { SeeAwardTextVo seeAwardTextVO = activitySignReceiveRecordDao.selectSeeAwardTextVOById(seeAwardTextDto); if(ObjectUtil.isEmpty(seeAwardTextVO)){ return AjaxResult.buildFailInstance("奖品信息无法查看"); } long receiveId = seeAwardTextVO.getId(); //获取核销记录的ID ActivitySignWriteoff activitySignWriteoff = activitySignWriteoffDao.selectActivitySignWriteoffByUserIDAndReceiveId(seeAwardTextDto.getUserId(),receiveId); if(ObjectUtil.isNotEmpty(activitySignWriteoff)){ Integer logisticsId = activitySignWriteoff.getLogisticsId(); ShopDeliveryInfo shopDeliveryInfo = shopDeliveryInfoDao.selectById(logisticsId); if(ObjectUtil.isNotEmpty(shopDeliveryInfo)){ //查看物流信息 wxShopLogisticsQueryService.selectLogisticsInfo(shopDeliveryInfo); List shopLogisticsInfos = shopLogisticsInfoDao.selectByDelieryId(shopDeliveryInfo.getId()); seeAwardTextVO.setShopLogisticsInfos(shopLogisticsInfos); } } AjaxResult result=AjaxResult.buildSuccessInstance(seeAwardTextVO); return result; } /** * 获取累计签到天数 * @param actId * @param userId * @param date * @return */ public int getCumulativeDay(long actId, long userId,Date date, int i) { ActivitySignRecord activitySignRecordOld = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,date); if(ObjectUtil.isEmpty(activitySignRecordOld)) { return i; } i++; DateTime offsetDay = DateUtil.offsetDay(date, -i); return getCumulativeDay(actId,userId,offsetDay,i); } public void InitByCompanyId() { //对应的公司ID // long companyId = 36L; // initBusParameterSetting(companyId); // //initBusParameterFenxiaoSetting(companyId); } // /** // * 初始化默认积分规则设置 // */ // public void initBusParameterSetting(long companyId) { // List ruleSettings=new ArrayList<>(); // // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.VALID_PERIOD_POINTS, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.CREDIT_POINTS_CASH, companyId)); // // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.CASH_CONSUMPTION, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.PRINCIPAL_BALANCE_CONSUMPTION, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.BONUS_BALANCE_CONSUMPTION, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.PRINCIPAL_CONSUMPTION, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.GIVE_CONSUMPTION, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.REFERRALS_CONSUMPTION, companyId)); // // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.CASH_CONSUMPTION_SHOP, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.RESERVATION_SERVICE_SHOP, companyId)); // ruleSettings.add(addScoreRuleSetting(ScoreSettingConstant.EVALUATUIN_ORDER_SHOP, companyId)); // // busParameterSettingsDao.batchInsert(ruleSettings); // } // // /** // * 初始化默认分销规则设置 // */ // public void initBusParameterFenxiaoSetting(long companyId) { // List ruleSettings=new ArrayList<>(); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_SWITCH, companyId)); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_MODEL, companyId)); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_APPLY_WAY, companyId)); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_AUDIT_METHOD, companyId)); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_APPLY_CONDITION, companyId)); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_TG_PLAN, companyId)); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_TG_POSTER, companyId)); // ruleSettings.add(addScoreRuleSetting(FenxiaoSettingConstant.FX_ZGFY, companyId)); // busParameterSettingsDao.batchInsert(ruleSettings); // } // // private BusParameterSettings addScoreRuleSetting(String code,long companyId) { // BusParameterSettings busParameterSetting = new BusParameterSettings(); // busParameterSetting.setParamCode(code); // busParameterSetting.setCompanyId(companyId); // return busParameterSetting; // } }