package com.matrix.system.shopXcx.api.action; 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 com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.matrix.component.redis.RedisUserLoginUtils; 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.score.entity.ScoreVipDetail; import com.matrix.system.score.service.ScoreVipDetailService; import com.matrix.system.shopXcx.api.dto.SeeAwardTextDto; import com.matrix.system.shopXcx.api.dto.SignAwardDto; import com.matrix.system.shopXcx.api.service.WxShopLogisticsQueryService; import com.matrix.system.shopXcx.api.tools.WxShopCouponUtil; import com.matrix.system.shopXcx.api.vo.*; import com.matrix.system.shopXcx.bean.*; import com.matrix.system.shopXcx.dao.*; import com.matrix.system.shopXcx.vo.SalesOrderVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiResponse; import io.swagger.annotations.ApiResponses; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.List; @Api(tags = "签到活动接口类") @RestController @RequestMapping(value = "/wxapi/sign") public class WxShopActivitiesSignAction { @Autowired private ShopActivitiesDao shopActivitiesDao; @Autowired private RedisUserLoginUtils redisUserLoginUtils; @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 ShopReceiveAddressDao shopReceiveAddressDao; @Autowired private WxShopLogisticsQueryService wxShopLogisticsQueryService; @Autowired private ScoreVipDetailService scoreVipDetailService; @Autowired private ShopCouponDao shopCouponDao; @Autowired private WxShopCouponUtil wxShopCouponUtil; @Autowired private ShopCouponRecordDao shopCouponRecordDao; @ApiOperation(value = "获取签到基本信息", notes = "") @ApiResponses({ @ApiResponse(code = 200, message = "ok", response = SignBasicInfoVo.class) }) @GetMapping(value = "/getSignBasicInfo") public AjaxResult getSignBasicInfo() { //获取登录人信息 SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class); Long companyId = loginUser.getCompanyId(); Long userId = loginUser.getId(); //获取签到活动的信息 SignBasicInfoVo signBasicInfoVo = new SignBasicInfoVo(); AjaxResult ajaxResult = new AjaxResult(); ShopActivities shopActivities = shopActivitiesDao.selectOneByCompanyIdAndActTypeAndActStatus(companyId,ShopActivities.ACTIVITIES_TYPE_SIGN,ShopActivities.ACTSTATUS_STATUS_ING); if(ObjectUtil.isEmpty(shopActivities)){ ajaxResult = AjaxResult.buildFailInstance("活动还没有开始"); ajaxResult.setData(signBasicInfoVo); return ajaxResult; } Long actId = shopActivities.getId(); signBasicInfoVo.setActName(shopActivities.getActName()); signBasicInfoVo.setActCode(shopActivities.getActCode()); signBasicInfoVo.setId(shopActivities.getId()); String actContent = shopActivities.getActContent(); SignBasicInfoJsonVo signBasicInfoJsonVo = JSON.parseObject(actContent, SignBasicInfoJsonVo.class); signBasicInfoVo.setSignBasicInfoJsonVo(signBasicInfoJsonVo); List activitySignAwardSetVos = activitySignAwardSetDao .selectListByActIDAndCompanyId(actId,companyId,ActivitySignAwardSet.AWARDSTATE_WORK); signBasicInfoVo.setActivitySignAwardSetVos(activitySignAwardSetVos); //今日是否已经参与 ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,new Date()); if(ObjectUtil.isNotEmpty(activitySignRecord)) { signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_SIGN); }else { signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_NOTSIGN); } /** * 默认获取当前月份 * 获取当前月份的天数 */ List activitySignRecordVos = new ArrayList<>(); //获取当前月的第一天是星期几 DateTime dateTime = DateUtil.beginOfMonth(DateUtil.date()); int i = DateUtil.dayOfWeek(dateTime); for(int j = 1;j monthFullDays = getMonthFullDay(DateUtil.year(DateUtil.date()), DateUtil.month(DateUtil.date()) + 1); for(String monthFullDay : monthFullDays){ ActivitySignRecordVo activitySignRecordVo = new ActivitySignRecordVo(); activitySignRecordVo.setSignTime(monthFullDay); activitySignRecordVo.setActivityId(actId); activitySignRecordVo.setCompanyId(companyId); //对应日期是否已签到 Date date = DateUtil.parse(monthFullDay); ActivitySignRecord activitySignRecordDone = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,date); if(ObjectUtil.isNotEmpty(activitySignRecordDone)){ activitySignRecordVo.setState(1); }else{ activitySignRecordVo.setState(2); } activitySignRecordVos.add(activitySignRecordVo); } signBasicInfoVo.setActivitySignRecords(activitySignRecordVos); //累计签到日期 int cumulativeDay = getCumulativeDay(actId, userId, DateUtil.date(), 0); signBasicInfoVo.setActAumulativeDay(cumulativeDay); ajaxResult = AjaxResult.buildSuccessInstance(""); ajaxResult.setData(signBasicInfoVo); return ajaxResult; } /** * 查看历史签到记录 * * @param * @return */ @ApiOperation(value = "查看历史签到记录", notes = "") @GetMapping(value = "getSignRecord/{actId}/{month}") @ResponseBody public AjaxResult getSignRecord(@PathVariable("actId") long actId,@PathVariable("month") String dateStr) { //获取登录人信息 SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class); Long companyId = loginUser.getCompanyId(); Long userId = loginUser.getId(); Date date = DateUtil.parse(dateStr); /** * 默认获取当前月份 * 获取当前月份的天数 */ List activitySignRecordVos = new ArrayList<>(); //获取当前月的第一天是星期几 DateTime dateTime = DateUtil.beginOfMonth(date); int i = DateUtil.dayOfWeek(dateTime); for(int j = 1;j monthFullDays = getMonthFullDay(DateUtil.year(dateTime), DateUtil.month(dateTime) + 1); for(String monthFullDay : monthFullDays){ ActivitySignRecordVo activitySignRecordVo = new ActivitySignRecordVo(); activitySignRecordVo.setSignTime(monthFullDay); activitySignRecordVo.setActivityId(actId); activitySignRecordVo.setCompanyId(companyId); //对应日期是否已签到 Date dateSign = DateUtil.parse(monthFullDay); ActivitySignRecord activitySignRecordDone = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,dateSign); if(ObjectUtil.isNotEmpty(activitySignRecordDone)){ activitySignRecordVo.setState(1); }else{ activitySignRecordVo.setState(2); } activitySignRecordVos.add(activitySignRecordVo); } AjaxResult ajaxResult = new AjaxResult(); ajaxResult = AjaxResult.buildSuccessInstance(""); ajaxResult.setData(activitySignRecordVos); return ajaxResult; } /** * java 获取 获取某年某月 所有日期（yyyy-mm-dd格式字符串） * @param year * @param month * @return */ public 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; } /** * 获取当月的 天数 * */ 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; } /** * 点击签到 * */ @ApiOperation(value = "点击签到", notes = "") @ApiResponses({ @ApiResponse(code = 200, message = "ok", response = SignSuccessVo.class) }) @GetMapping(value = "/clickSign/{actId}") @ResponseBody @Transactional public AjaxResult clickSign(@PathVariable("actId") long actId) { SysVipInfo user = redisUserLoginUtils.getLoginUser(SysVipInfo.class); Long userId = user.getId(); Long companyId = user.getCompanyId(); /** * 活动是否存在 * 活动是否已经开始 * 今日是否已经参与 * 新增签到记录表 * 判断累计连续签到天数是否+1 * 是否已领取 * 查询是否有签到奖品 * 日常奖励和自定义奖品 * 生成核销记录 */ //活动是否存在 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("活动未开始"); } //今日是否已经参与 ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,new Date()); if (ObjectUtil.isNotEmpty(activitySignRecord)) { return AjaxResult.buildFailInstance("今日用户已经签到成功"); } //前一天是否签到 Date date = new Date(); DateTime offsetDay = DateUtil.offsetDay(date, -1); ActivitySignRecord activitySignRecordOld = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,offsetDay); ActivitySignRecord activitySignRecordAdd = new ActivitySignRecord(); activitySignRecordAdd.setCompanyId(companyId); activitySignRecordAdd.setCreateBy(user.getVipName()); activitySignRecordAdd.setCreateTime(new Date()); activitySignRecordAdd.setUpdateBy(user.getVipName()); activitySignRecordAdd.setUpdateTime(new Date()); activitySignRecordAdd.setActivityId(actId); activitySignRecordAdd.setSignTime(date); activitySignRecordAdd.setUserId(userId); if(ObjectUtil.isEmpty(activitySignRecordOld)) { //新增签到记录表,累计连续签到天数是1 activitySignRecordAdd.setCumulativeDay(1); }else { Integer cumulativeDay = activitySignRecordOld.getCumulativeDay(); //新增签到记录表,累计连续签到天数是否+1 activitySignRecordAdd.setCumulativeDay(cumulativeDay+1); } activitySignRecordDao.insert(activitySignRecordAdd); /** * 查询是否有签到奖品 * 日常奖励和自定义奖品 */ List signSuccessVos = 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); if(ObjectUtil.isNotEmpty(activitySignAwardSetNormal)) { ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord(); activitySignReceiveRecord.setUserId(userId); activitySignReceiveRecord.setReceiveTime(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); SignSuccessVo signSuccessVo = new SignSuccessVo(); signSuccessVo.setType(1); signSuccessVo.setScoreCnt(activitySignAwardSetNormal.getScoreCnt()); signSuccessVo.setAwardName(activitySignAwardSetNormal.getAwardName()); signSuccessVo.setAwardImg(activitySignAwardSetNormal.getIntroduceImg()); signSuccessVos.add(signSuccessVo); //日常奖励积分，对应用户积分加减 int awardType = activitySignAwardSetNormal.getAwardType(); if(ActivitySignAwardSet.AWARDTYPE_SCORE == awardType){ int scoreCnt = activitySignAwardSetNormal.getScoreCnt(); if(scoreCnt > 0){ scoreVipDetailService.addScore(userId,null,null,scoreCnt, activitySignReceiveRecord.getId(), ScoreVipDetail.SCORE_VIP_TYPE_JOIN_ACTIVE,"签到积分"); } } //获取优惠券 if(ActivitySignAwardSet.AWARDTYPE_COUPON == awardType){ //获取优惠券 int couponId = Integer.parseInt(activitySignAwardSetNormal.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); } } //获取当前累计天数 int cumulativeDay = getCumulativeDay(actId, userId, date, 0); //自定义奖励 QueryWrapper queryWrapperCumulativeDay = new QueryWrapper<>(); queryWrapperCumulativeDay.eq("award_rule",ActivitySignAwardSet.AWARDRULE_CUMULATIVEDAY); queryWrapperCumulativeDay.eq("cumulative_day",cumulativeDay); queryWrapperCumulativeDay.eq("company_id",companyId); queryWrapperCumulativeDay.eq("activity_id",actId); // ActivitySignAwardSet activitySignAwardSetCumulativeDay = activitySignAwardSetDao.selectOne(queryWrapperCumulativeDay); List activitySignAwardSetCumulativeDays = activitySignAwardSetDao.selectList(queryWrapperCumulativeDay); if(CollUtil.isNotEmpty(activitySignAwardSetCumulativeDays)){ for(ActivitySignAwardSet activitySignAwardSetCumulativeDay : activitySignAwardSetCumulativeDays){ if(ObjectUtil.isNotEmpty(activitySignAwardSetCumulativeDay)) { //是否已领取 Long id = activitySignAwardSetCumulativeDay.getId(); QueryWrapper queryWrapperActivitySignReceiveRecord = new QueryWrapper<>(); queryWrapperActivitySignReceiveRecord.eq("award_id", id); queryWrapperActivitySignReceiveRecord.eq("company_id", companyId); queryWrapperActivitySignReceiveRecord.eq("activity_id", actId); queryWrapperActivitySignReceiveRecord.eq("user_id", userId); ActivitySignReceiveRecord activitySignReceiveRecordDone = activitySignReceiveRecordDao.selectOne(queryWrapperActivitySignReceiveRecord); if (ObjectUtil.isNotEmpty(activitySignReceiveRecordDone)) { String awardNameCumulativeDay = activitySignAwardSetCumulativeDay.getAwardName(); AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(awardNameCumulativeDay+"已经领取过了"); ajaxResult.setData(signSuccessVos); return ajaxResult; } SignSuccessVo signSuccessVo = new SignSuccessVo(); signSuccessVo.setType(2); signSuccessVo.setAwardType(activitySignAwardSetCumulativeDay.getAwardType()); signSuccessVo.setAwardName(activitySignAwardSetCumulativeDay.getAwardName()); signSuccessVo.setAwardImg(activitySignAwardSetCumulativeDay.getIntroduceImg()); signSuccessVo.setAwardState(activitySignAwardSetCumulativeDay.getAwardState()); //新增奖品领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord(); activitySignReceiveRecord.setUserId(userId); activitySignReceiveRecord.setReceiveTime(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：客服兑换） */ signSuccessVo.setWriteOffCode(randomString); signSuccessVo.setAwardWay(activitySignAwardSetCumulativeDay.getAwardWay()); //2：物流配送 signSuccessVo.setOperationTip(activitySignAwardSetCumulativeDay.getOperationTip()); //1：线下兑换 if(ActivitySignAwardSet.AWARDWAY_ONE == activitySignAwardSetCumulativeDay.getAwardWay()) { signSuccessVo.setIntroduceTip(activitySignAwardSetCumulativeDay.getIntroduceTip()); signSuccessVo.setPrizeAddress(activitySignAwardSetCumulativeDay.getPrizeAddress()); signSuccessVo.setPrizeStartTime(activitySignAwardSetCumulativeDay.getPrizeStartTime()); signSuccessVo.setPrizeEndTime(activitySignAwardSetCumulativeDay.getPrizeEndTime()); } //3：客服兑换 if(ActivitySignAwardSet.AWARDWAY_THREE == activitySignAwardSetCumulativeDay.getAwardWay()) { signSuccessVo.setWechatImg(activitySignAwardSetCumulativeDay.getWechatImg()); signSuccessVo.setPrizeStartTime(activitySignAwardSetCumulativeDay.getPrizeStartTime()); signSuccessVo.setPrizeEndTime(activitySignAwardSetCumulativeDay.getPrizeEndTime()); } } //2：积分 if(ActivitySignAwardSet.AWARDTYPE_SCORE == activitySignAwardSetCumulativeDay.getAwardType()) { signSuccessVo.setScoreCnt(activitySignAwardSetCumulativeDay.getScoreCnt()); } //3：优惠券 if(ActivitySignAwardSet.AWARDTYPE_COUPON == activitySignAwardSetCumulativeDay.getAwardType()) { signSuccessVo.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(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); } signSuccessVos.add(signSuccessVo); } } } AjaxResult ajaxResult = AjaxResult.buildSuccessInstance("签到成功"); ajaxResult.setData(signSuccessVos); return ajaxResult; } /** * 获取累计签到天数 * @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); } /** * 获取累计的签到奖品 * * @return */ @ApiOperation(value = "获取累计的签到奖品", notes = "") @PostMapping(value = "/getSignAwardList") @ApiResponses({ @ApiResponse(code = 200, message = "ok", response = SignAwardListVo.class) }) public AjaxResult getSignAwardList(@RequestBody @Validated SignAwardDto signAwardDto) { SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class); Page page=new Page<>(signAwardDto.getPageNum(),signAwardDto.getPageSize()); if(StringUtils.isBlank(signAwardDto.getSort())){ signAwardDto.setSort("create_time"); signAwardDto.setOrder("desc"); } signAwardDto.setUserId(loginUser.getId()); signAwardDto.setCompanyId(loginUser.getCompanyId()); IPage signAwardListVos = activitySignReceiveRecordDao.selectSignAwardList(page,signAwardDto); AjaxResult result=AjaxResult.buildSuccessInstance(signAwardListVos); return result; } /** * 查看劵码 * * @return */ @ApiOperation(value = "查看劵码", notes = "") @PostMapping(value = "/seeAwardText") @ApiResponses({ @ApiResponse(code = 200, message = "ok", response = SeeAwardTextVo.class) }) public AjaxResult seeAwardText(@RequestBody @Validated SeeAwardTextDto seeAwardTextDto) { SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class); seeAwardTextDto.setUserId(loginUser.getId()); seeAwardTextDto.setCompanyId(loginUser.getCompanyId()); SeeAwardTextVo seeAwardTextVO = activitySignReceiveRecordDao.selectSeeAwardTextVOById(seeAwardTextDto); AjaxResult result=AjaxResult.buildSuccessInstance(seeAwardTextVO); return result; } /** * 物流配送信息查看 * * @return */ @ApiOperation(value = "物流配送信息查看", notes = "") @PostMapping(value = "/logisticsInsure") @ApiResponses({ @ApiResponse(code = 200, message = "ok", response = SeeAwardTextVo.class) }) public AjaxResult logisticsInsure(@RequestBody @Validated SeeAwardTextDto seeAwardTextDto) { SysVipInfo loginUser = redisUserLoginUtils.getLoginUser(SysVipInfo.class); seeAwardTextDto.setUserId(loginUser.getId()); seeAwardTextDto.setCompanyId(loginUser.getCompanyId()); SeeAwardTextVo seeAwardTextVO = activitySignReceiveRecordDao.selectSeeAwardTextVOById(seeAwardTextDto); if(ObjectUtil.isEmpty(seeAwardTextVO)){ return AjaxResult.buildFailInstance("奖品无法查看物流配送信息"); } long receiveId = seeAwardTextVO.getId(); //获取核销记录的ID ActivitySignWriteoff activitySignWriteoff = activitySignWriteoffDao.selectActivitySignWriteoffByUserIDAndReceiveId(loginUser.getId(),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 * @return */ @ApiOperation(value = "物流配送收货地址保存", notes = "") @GetMapping(value = "logisticsInsureAddress/{addressId}/{receiveId}") @ResponseBody public AjaxResult logisticsInsureAddress(@PathVariable("addressId") int addressId,@PathVariable("receiveId") long receiveId) { ShopReceiveAddress shopReceiveAddress = shopReceiveAddressDao.selectById(addressId); if(ObjectUtil.isEmpty(shopReceiveAddress)){ return AjaxResult.buildFailInstance("收货地址无效"); } ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(receiveId); //该奖品不是待领取状态 if (ActivitySignReceiveRecord.STATE_DONE == activitySignReceiveRecord.getState() || ActivitySignReceiveRecord.STATE_FOUR == activitySignReceiveRecord.getState() || ActivitySignReceiveRecord.STATE_FIVE == activitySignReceiveRecord.getState()) { return AjaxResult.buildFailInstance("无法修改收货信息"); } activitySignReceiveRecord.setConsigneeAddress(shopReceiveAddress.getAddrRegion()+"-"+shopReceiveAddress.getAddrDetailaddr()+"-"+shopReceiveAddress.getDormitory()); activitySignReceiveRecord.setConsignee(shopReceiveAddress.getAddrLiaisonman()); activitySignReceiveRecord.setConsigneePhone(shopReceiveAddress.getAddrTelephone()); activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_THREE); activitySignReceiveRecordDao.updateById(activitySignReceiveRecord); return new AjaxResult(AjaxResult.STATUS_SUCCESS, "设置成功！"); } /** * 物流配送确认收货 * * @param * @return */ @ApiOperation(value = "物流配送确认收货", notes = "") @GetMapping(value = "logisticsInsureById/{receiveId}") @ResponseBody public AjaxResult logisticsInsureById(@PathVariable("receiveId") long receiveId) { ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(receiveId); //如果不是待收货状态 if (ActivitySignReceiveRecord.STATE_FOUR != activitySignReceiveRecord.getState()) { return AjaxResult.buildFailInstance("该奖品不是待收货状态"); } activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE); activitySignReceiveRecordDao.updateById(activitySignReceiveRecord); return new AjaxResult(AjaxResult.STATUS_SUCCESS, "收货成功！"); } }