From 06f0fb09a61e16df895dc9feebea8ddd24d14db5 Mon Sep 17 00:00:00 2001 From: jyy <935090232@qq.com> Date: Tue, 20 Apr 2021 13:44:36 +0800 Subject: [PATCH] 修复微商城订单bug --- zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java | 275 +++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 248 insertions(+), 27 deletions(-) diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java index a9aa020..da861c3 100644 --- a/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java +++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java @@ -1,36 +1,43 @@ package com.matrix.system.shopXcx.api.action; 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.hive.bean.SysVipInfo; -import com.matrix.system.shopXcx.api.dto.ClickSignDTO; -import com.matrix.system.shopXcx.api.vo.ActivitySignAwardSetVo; -import com.matrix.system.shopXcx.api.vo.SignBasicInfoJsonVo; -import com.matrix.system.shopXcx.api.vo.SignBasicInfoVo; -import com.matrix.system.shopXcx.api.vo.SignSuccessVo; +import com.matrix.system.shopXcx.api.dto.SeeAwardTextDto; +import com.matrix.system.shopXcx.api.dto.SignAwardDto; +import com.matrix.system.shopXcx.api.vo.*; import com.matrix.system.shopXcx.bean.ShopActivities; import com.matrix.system.shopXcx.dao.ShopActivitiesDao; +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; @@ -52,6 +59,9 @@ private ActivitySignReceiveRecordDao activitySignReceiveRecordDao; @Autowired + private ActivitySignWriteoffDao activitySignWriteoffDao; + + @Autowired private ActivitySignRecordDao activitySignRecordDao; @ApiOperation(value = "获取签到基本信息", notes = "") @@ -66,7 +76,14 @@ 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()); @@ -74,24 +91,91 @@ String actContent = shopActivities.getActContent(); SignBasicInfoJsonVo signBasicInfoJsonVo = JSON.parseObject(actContent, SignBasicInfoJsonVo.class); signBasicInfoVo.setSignBasicInfoJsonVo(signBasicInfoJsonVo); - - List<ActivitySignAwardSetVo> activitySignAwardSetVos = activitySignAwardSetDao - .selectListByActIDAndCompanyId(actId,companyId,ActivitySignAwardSet.AWARDSTATE_WORK); - signBasicInfoVo.setActivitySignAwardSetVos(activitySignAwardSetVos); - //今日是否已经参与 - ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,DateUtil.today()); + List<ActivitySignAwardSetVo> 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); + signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_SIGN); }else { - signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_NOTSIGN); + signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_NOTSIGN); } - AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(""); + /** + * 默认获取当前月份 + * 获取当前月份的天数 + */ + List<ActivitySignRecordVo> activitySignRecordVos = new ArrayList<>(); + //获取当前月的第一天是星期几 + DateTime dateTime = DateUtil.beginOfMonth(DateUtil.date()); + int i = DateUtil.dayOfWeek(dateTime); + for(int j = 1;j<i;j++){ + ActivitySignRecordVo activitySignRecordVoNull = new ActivitySignRecordVo(); + activitySignRecordVos.add(activitySignRecordVoNull); + } + List<String> 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; } - - /** + /** + * java 获取 获取某年某月 所有日期(yyyy-mm-dd格式字符串) + * @param year + * @param month + * @return + */ + public List<String> getMonthFullDay(int year , int month){ + SimpleDateFormat dateFormatYYYYMMDD = new SimpleDateFormat("yyyy-MM-dd"); + List<String> 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; + } + + /** * 点击签到 * */ @@ -99,11 +183,12 @@ @ApiResponses({ @ApiResponse(code = 200, message = "ok", response = SignSuccessVo.class) }) - @PostMapping(value = "/clickSign") + + @GetMapping(value = "/clickSign/{actId}") + @ResponseBody @Transactional - public AjaxResult clickSign(@RequestBody ClickSignDTO clickSignDTO) { + public AjaxResult clickSign(@PathVariable("actId") long actId) { SysVipInfo user = redisUserLoginUtils.getLoginUser(SysVipInfo.class); - long actId = clickSignDTO.getActId(); Long userId = user.getId(); Long companyId = user.getCompanyId(); /** @@ -112,8 +197,10 @@ * 今日是否已经参与 * 新增签到记录表 * 判断累计连续签到天数是否+1 + * 是否已领取 * 查询是否有签到奖品 * 日常奖励和自定义奖品 + * 生成核销记录 */ //活动是否存在 ShopActivities shopActivities = shopActivitiesDao.selectById(actId); @@ -126,25 +213,28 @@ return AjaxResult.buildFailInstance("活动未开始"); } //今日是否已经参与 - ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,DateUtil.today()); + 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); - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - ActivitySignRecord activitySignRecordOld = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,sdf.format(offsetDay.getTime())); + 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); - Integer cumulativeDay = activitySignRecordOld.getCumulativeDay(); if(ObjectUtil.isEmpty(activitySignRecordOld)) { //新增签到记录表,累计连续签到天数是1 activitySignRecordAdd.setCumulativeDay(1); }else { + Integer cumulativeDay = activitySignRecordOld.getCumulativeDay(); //新增签到记录表,累计连续签到天数是否+1 activitySignRecordAdd.setCumulativeDay(cumulativeDay+1); } @@ -168,20 +258,40 @@ 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.setScoreCnt(activitySignAwardSetNormal.getScoreCnt()); signSuccessVo.setNormalAwardName(activitySignAwardSetNormal.getAwardName()); signSuccessVo.setNormalAwardImg(activitySignAwardSetNormal.getIntroduceImg()); } - + //获取当前累计天数 + int cumulativeDay = getCumulativeDay(actId, userId, date, 0); //自定义奖励 QueryWrapper<ActivitySignAwardSet> queryWrapperCumulativeDay = new QueryWrapper<>(); queryWrapperCumulativeDay.eq("award_rule",ActivitySignAwardSet.AWARDRULE_CUMULATIVEDAY); - queryWrapperCumulativeDay.eq("cumulative_day",activitySignRecordAdd.getCumulativeDay()); + queryWrapperCumulativeDay.eq("cumulative_day",cumulativeDay); queryWrapperCumulativeDay.eq("company_id",companyId); queryWrapperCumulativeDay.eq("activity_id",actId); ActivitySignAwardSet activitySignAwardSetCumulativeDay = activitySignAwardSetDao.selectOne(queryWrapperCumulativeDay); if(ObjectUtil.isNotEmpty(activitySignAwardSetCumulativeDay)) { + //是否已领取 + Long id = activitySignAwardSetCumulativeDay.getId(); + QueryWrapper<ActivitySignReceiveRecord> 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(signSuccessVo); + return ajaxResult; + } //新增奖品领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = new ActivitySignReceiveRecord(); activitySignReceiveRecord.setUserId(userId); @@ -190,6 +300,10 @@ 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:店铺商品) * @@ -231,14 +345,121 @@ signSuccessVo.setScoreCnt(activitySignAwardSetCumulativeDay.getScoreCnt()); } //3:优惠券 - if(ActivitySignAwardSet.AWARDTYPE_SCORE == activitySignAwardSetCumulativeDay.getAwardType()) { + if(ActivitySignAwardSet.AWARDTYPE_COUPON == activitySignAwardSetCumulativeDay.getAwardType()) { signSuccessVo.setCouponName(activitySignAwardSetCumulativeDay.getCouponName()); } activitySignReceiveRecordDao.insert(activitySignReceiveRecord); + //生成核销记录 + 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); + } } AjaxResult ajaxResult = AjaxResult.buildSuccessInstance("签到成功"); ajaxResult.setData(signSuccessVo); 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<SalesOrderVo> 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<SignAwardListVo> signAwardListVos = activitySignReceiveRecordDao.selectSignAwardList(page,signAwardDto); + AjaxResult result=AjaxResult.buildSuccessInstance(signAwardListVos.getRecords()); + 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); + AjaxResult result=AjaxResult.buildSuccessInstance(seeAwardTextVO); + return result; + } + + + + } -- Gitblit v1.9.1