forked from beauty-erp
zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxShopActivitiesSignAction.java
@@ -1,15 +1,38 @@ package com.matrix.system.shopXcx.api.action; import cn.hutool.core.date.DateTime; 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.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.entity.ActivitySignAwardSet; import com.matrix.system.activity.entity.ActivitySignReceiveRecord; import com.matrix.system.activity.entity.ActivitySignRecord; 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.bean.ShopActivities; import com.matrix.system.shopXcx.dao.ShopActivitiesDao; 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.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; @Api(tags = "签到活动接口类") @RestController @@ -22,20 +45,200 @@ @Autowired private RedisUserLoginUtils redisUserLoginUtils; @Autowired private ActivitySignAwardSetDao activitySignAwardSetDao; @Autowired private ActivitySignReceiveRecordDao activitySignReceiveRecordDao; @Autowired private ActivitySignRecordDao activitySignRecordDao; @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(); // shopActivitiesDao.selectOneByCompanyIdAndActTypeAndActStatus(); // BusParameterSettings busParameterSettings = busParameterSettingsDao.selectCompanyParamByCode(FenxiaoSettingConstant.FX_TG_PLAN, HostInterceptor.getCompanyId()); Long userId = loginUser.getId(); //获取签到活动的信息 SignBasicInfoVo signBasicInfoVo = new SignBasicInfoVo(); ShopActivities shopActivities = shopActivitiesDao.selectOneByCompanyIdAndActTypeAndActStatus(companyId,ShopActivities.ACTIVITIES_TYPE_SIGN,ShopActivities.ACTSTATUS_STATUS_ING); 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<ActivitySignAwardSetVo> activitySignAwardSetVos = activitySignAwardSetDao .selectListByActIDAndCompanyId(actId,companyId,ActivitySignAwardSet.AWARDSTATE_WORK); signBasicInfoVo.setActivitySignAwardSetVos(activitySignAwardSetVos); //今日是否已经参与 ActivitySignRecord activitySignRecord = activitySignRecordDao.selectOneByActIdAndUserIdLikesignTime(actId,userId,DateUtil.today()); if(ObjectUtil.isNotEmpty(activitySignRecord)) { signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_SIGN); }else { signBasicInfoVo.setJoinState(SignBasicInfoVo.JOINSTATE_NOTSIGN); } AjaxResult ajaxResult = AjaxResult.buildSuccessInstance(""); // ajaxResult.setData(busParameterSettings.getParamValue3()); ajaxResult.setData(signBasicInfoVo); return ajaxResult; } /** * 点击签到 * */ @ApiOperation(value = "点击签到", notes = "") @ApiResponses({ @ApiResponse(code = 200, message = "ok", response = SignSuccessVo.class) }) @PostMapping(value = "/clickSign") @Transactional public AjaxResult clickSign(@RequestBody ClickSignDTO clickSignDTO) { SysVipInfo user = redisUserLoginUtils.getLoginUser(SysVipInfo.class); long actId = clickSignDTO.getActId(); 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,DateUtil.today()); 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 activitySignRecordAdd = new ActivitySignRecord(); activitySignRecordAdd.setCompanyId(companyId); activitySignRecordAdd.setActivityId(actId); activitySignRecordAdd.setSignTime(date); activitySignRecordAdd.setUserId(userId); Integer cumulativeDay = activitySignRecordOld.getCumulativeDay(); if(ObjectUtil.isEmpty(activitySignRecordOld)) { //新增签到记录表,累计连续签到天数是1 activitySignRecordAdd.setCumulativeDay(1); }else { //新增签到记录表,累计连续签到天数是否+1 activitySignRecordAdd.setCumulativeDay(cumulativeDay+1); } activitySignRecordDao.insert(activitySignRecordAdd); /** * 查询是否有签到奖品 * 日常奖励和自定义奖品 */ SignSuccessVo signSuccessVo = new SignSuccessVo(); //日常奖励,新增奖品领取记录 QueryWrapper<ActivitySignAwardSet> 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); activitySignReceiveRecordDao.insert(activitySignReceiveRecord); signSuccessVo.setNormalAwardName(activitySignAwardSetNormal.getAwardName()); signSuccessVo.setNormalAwardImg(activitySignAwardSetNormal.getIntroduceImg()); } //自定义奖励 QueryWrapper<ActivitySignAwardSet> queryWrapperCumulativeDay = new QueryWrapper<>(); queryWrapperCumulativeDay.eq("award_rule",ActivitySignAwardSet.AWARDRULE_CUMULATIVEDAY); queryWrapperCumulativeDay.eq("cumulative_day",activitySignRecordAdd.getCumulativeDay()); queryWrapperCumulativeDay.eq("company_id",companyId); queryWrapperCumulativeDay.eq("activity_id",actId); ActivitySignAwardSet activitySignAwardSetCumulativeDay = activitySignAwardSetDao.selectOne(queryWrapperCumulativeDay); if(ObjectUtil.isNotEmpty(activitySignAwardSetCumulativeDay)) { //新增奖品领取记录 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); /** * 奖项类型（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.setAwardType(activitySignAwardSetCumulativeDay.getAwardType()); signSuccessVo.setAwardName(activitySignAwardSetCumulativeDay.getAwardName()); signSuccessVo.setAwardImg(activitySignAwardSetCumulativeDay.getIntroduceImg()); signSuccessVo.setAwardWay(activitySignAwardSetCumulativeDay.getAwardWay()); signSuccessVo.setAwardState(activitySignAwardSetCumulativeDay.getAwardState()); //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_SCORE == activitySignAwardSetCumulativeDay.getAwardType()) { signSuccessVo.setCouponName(activitySignAwardSetCumulativeDay.getCouponName()); } activitySignReceiveRecordDao.insert(activitySignReceiveRecord); } AjaxResult ajaxResult = AjaxResult.buildSuccessInstance("签到成功"); ajaxResult.setData(signSuccessVo); return ajaxResult; } }
