package com.matrix.system.activity.service; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.matrix.core.constance.MatrixConstance; import com.matrix.core.pojo.AjaxResult; import com.matrix.core.tools.WebUtil; import com.matrix.system.activity.dao.ActivitySignAwardSetDao; import com.matrix.system.activity.dao.ActivitySignReceiveRecordDao; import com.matrix.system.activity.dao.ActivitySignWriteoffDao; import com.matrix.system.activity.dto.LogisticsSubmitDto; import com.matrix.system.activity.dto.SignWriteoffDto; import com.matrix.system.activity.dto.SignWriteoffListDto; import com.matrix.system.activity.dto.WriteoffCodeSubmitDto; import com.matrix.system.activity.entity.ActivitySignAwardSet; import com.matrix.system.activity.entity.ActivitySignReceiveRecord; import com.matrix.system.activity.entity.ActivitySignWriteoff; import com.matrix.system.activity.vo.LogisticsVo; import com.matrix.system.activity.vo.SignWriteoffListVo; import com.matrix.system.activity.vo.SignWriteoffVo; import com.matrix.system.activity.vo.ZjrVo; import com.matrix.system.common.bean.SysUsers; import com.matrix.system.common.bean.SystemDictionary; import com.matrix.system.common.constance.AppConstance; import com.matrix.system.common.dao.SystemDictionaryDao; import com.matrix.system.hive.action.util.QueryUtil; import com.matrix.system.hive.dao.SysVipInfoDao; import com.matrix.system.shopXcx.api.service.WxShopLogisticsQueryService; import com.matrix.system.shopXcx.bean.ShopActivities; import com.matrix.system.shopXcx.bean.ShopDeliveryInfo; import com.matrix.system.shopXcx.bean.ShopLogisticsInfo; import com.matrix.system.shopXcx.dao.ShopActivitiesDao; import com.matrix.system.shopXcx.dao.ShopDeliveryInfoDao; import com.matrix.system.shopXcx.dao.ShopLogisticsInfoDao; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.Date; import java.util.List; /** * @description 核销记录 * @author yourName * @date 2021-04-08 14:25 */ @Service public class ActivitySignWriteoffService extends ServiceImpl{ @Autowired ActivitySignWriteoffDao activitySignWriteoffDao; @Autowired ShopActivitiesDao shopActivitiesDao; @Autowired ActivitySignAwardSetDao activitySignAwardSetDao; @Autowired ActivitySignReceiveRecordDao activitySignReceiveRecordDao; @Autowired SysVipInfoDao sysVipInfoDao; @Autowired SystemDictionaryDao systemDictionaryDao; @Autowired ShopDeliveryInfoDao shopDeliveryInfoDao; @Autowired ShopLogisticsInfoDao shopLogisticsInfoDao; @Autowired private WxShopLogisticsQueryService wxShopLogisticsQueryService; public IPage findSignWriteoffList(Page page, SignWriteoffListDto signWriteoffListDto) { return activitySignWriteoffDao.findSignWriteoffList(page,signWriteoffListDto); } public AjaxResult findSignWriteoff(SignWriteoffDto signWriteoffDto) { //设置用户公司ID QueryUtil.setQueryLimitCom(signWriteoffDto); Long writeoffId = signWriteoffDto.getWriteoffId(); AjaxResult result= AjaxResult.buildSuccessInstance("成功"); //获取核销信息 SignWriteoffVo signWriteoffVo = new SignWriteoffVo(); ActivitySignWriteoff activitySignWriteoff = activitySignWriteoffDao.selectById(writeoffId); if(ObjectUtil.isNotEmpty(activitySignWriteoff)) { //获取奖品信息 ActivitySignAwardSet activitySignAwardSet = activitySignAwardSetDao.selectById(activitySignWriteoff.getAwardId()); signWriteoffVo.setJpmc(activitySignAwardSet.getAwardName()); signWriteoffVo.setJptp(activitySignAwardSet.getIntroduceImg()); signWriteoffVo.setSl(1); signWriteoffVo.setDjfs(activitySignAwardSet.getAwardWay()); //获取中奖人信息 ZjrVo zjrVo = activitySignWriteoffDao.selectUsernameByUserId(activitySignWriteoff.getUserId(),activitySignAwardSet.getId()); signWriteoffVo.setZjr(zjrVo.getZjr()); signWriteoffVo.setZjsj(zjrVo.getZjsj()); signWriteoffVo.setDjsj(activitySignWriteoff.getWriteoffTime()); signWriteoffVo.setState(activitySignWriteoff.getState()); //获取活动主表信息 ShopActivities shopActivities = shopActivitiesDao.selectById(activitySignWriteoff.getActId()); signWriteoffVo.setHdmc(shopActivities.getActName()); signWriteoffVo.setHdbh(shopActivities.getActCode()); //获取收货地址信息 int awardWay = activitySignAwardSet.getAwardWay(); if(ActivitySignAwardSet.AWARDWAY_TWO == awardWay) { ActivitySignWriteoff activitySignWriteoffLogistics = activitySignWriteoffDao.selectById(writeoffId); Long receiveId = activitySignWriteoffLogistics.getReceiveId(); ActivitySignReceiveRecord activitySignReceiveRecordLogistic = activitySignReceiveRecordDao.selectById(receiveId); signWriteoffVo.setConsignee(activitySignReceiveRecordLogistic.getConsignee()); signWriteoffVo.setConsigneePhone(activitySignReceiveRecordLogistic.getConsigneePhone()); signWriteoffVo.setConsigneeAddress(activitySignReceiveRecordLogistic.getConsigneeAddress()); //物流跟踪 Integer logisticsId = activitySignWriteoffLogistics.getLogisticsId(); ShopDeliveryInfo shopDeliveryInfo = shopDeliveryInfoDao.selectById(logisticsId); if(ObjectUtil.isNotEmpty(shopDeliveryInfo)){ signWriteoffVo.setLogisticsNum(shopDeliveryInfo.getWaybillNo()); signWriteoffVo.setLogisticsCompany(shopDeliveryInfo.getLogisticsCompany()); //查看物流信息 wxShopLogisticsQueryService.selectLogisticsInfo(shopDeliveryInfo); List shopLogisticsInfos = shopLogisticsInfoDao.selectByDelieryId(shopDeliveryInfo.getId()); if(CollUtil.isNotEmpty(shopLogisticsInfos)) { ArrayList logisticsVos = new ArrayList<>(); for(ShopLogisticsInfo shopLogistics : shopLogisticsInfos) { LogisticsVo logisticsVo = new LogisticsVo(); logisticsVo.setContent(shopLogistics.getDescribe()); logisticsVo.setTimestamp(shopLogistics.getLogisticsTime()); logisticsVos.add(logisticsVo); } signWriteoffVo.setActivities(logisticsVos); } } } } result.putInMap("signWriteoffVo", signWriteoffVo); return result; } @Transactional public AjaxResult writeoffCodeSubmit(WriteoffCodeSubmitDto writeoffCodeSubmitDto) { //设置用户公司ID QueryUtil.setQueryLimitCom(writeoffCodeSubmitDto); SysUsers sysUsers = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY); Long writeoffId = writeoffCodeSubmitDto.getWriteoffId(); String writeOffCode = writeoffCodeSubmitDto.getWriteOffCode(); /** * 验证核销码是不是匹配 * 只能核销一次 * 更新核销记录 * 更新领取记录 */ //验证核销码是不是匹配 ActivitySignWriteoff activitySignWriteoff = activitySignWriteoffDao.selectById(writeoffId); if(ActivitySignWriteoff.STATE_ONE != activitySignWriteoff.getState()){ return new AjaxResult(AjaxResult.STATUS_FAIL, "兑奖码已失效"); } if(ObjectUtil.isNotEmpty(activitySignWriteoff)) { String writeoffCodeReal = activitySignWriteoff.getWriteoffCode(); if(!writeoffCodeReal.equals(writeOffCode)) { return new AjaxResult(AjaxResult.STATUS_FAIL, "兑奖码无效"); } } //线下兑换失效 Long awardId = activitySignWriteoff.getAwardId(); ActivitySignAwardSet activitySignAwardSet = activitySignAwardSetDao.selectById(awardId); if(ActivitySignAwardSet.AWARDWAY_ONE == activitySignAwardSet.getAwardWay() || ActivitySignAwardSet.AWARDWAY_THREE == activitySignAwardSet.getAwardWay()){ Date prizeStartTime = activitySignAwardSet.getPrizeStartTime(); if(DateUtil.date().getTime() < prizeStartTime.getTime()){ return new AjaxResult(AjaxResult.STATUS_FAIL, "兑奖还没开始呢！"); } Date prizeEndTime = activitySignAwardSet.getPrizeEndTime(); if(DateUtil.date().getTime() > prizeEndTime.getTime()){ Long receiveId = activitySignWriteoff.getReceiveId(); ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(receiveId); if(ObjectUtil.isNotEmpty(activitySignReceiveRecord)){ activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_FIVE); } activitySignReceiveRecordDao.updateById(activitySignReceiveRecord); activitySignWriteoff.setState(ActivitySignWriteoff.STATE_FOUR); activitySignWriteoffDao.updateById(activitySignWriteoff); return new AjaxResult(AjaxResult.STATUS_FAIL, "已超出兑奖结束时间！"); } } //更新核销记录 activitySignWriteoff.setState(ActivitySignWriteoff.STATE_THREE); activitySignWriteoff.setWriteoffTime(new Date()); activitySignWriteoff.setWriteoffUser(sysUsers.getSuName()); activitySignWriteoff.setWriteoffUserid(sysUsers.getSuId()); activitySignWriteoffDao.updateById(activitySignWriteoff); //更新领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(activitySignWriteoff.getReceiveId()); activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_DONE); activitySignReceiveRecordDao.updateById(activitySignReceiveRecord); return new AjaxResult(AjaxResult.STATUS_SUCCESS, "核销成功"); } @Transactional public AjaxResult logisticsSubmit(LogisticsSubmitDto logisticsSubmitDto) { //设置用户公司ID QueryUtil.setQueryLimitCom(logisticsSubmitDto); SysUsers sysUsers = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY); Long writeoffId = logisticsSubmitDto.getWriteoffId(); /** * 更新领取记录表的收货信息和状态 * 更新核销记录表的状态和物流ID */ ActivitySignWriteoff activitySignWriteoff = activitySignWriteoffDao.selectById(writeoffId); //新增一条物流信息 ShopDeliveryInfo shopDeliveryInfo = new ShopDeliveryInfo(); Long receiveId = activitySignWriteoff.getReceiveId(); SystemDictionary systemDictionary = systemDictionaryDao.selectByCode(logisticsSubmitDto.getKdgs()); if (ObjectUtil.isEmpty(systemDictionary)) { return new AjaxResult(AjaxResult.STATUS_FAIL, "没有找到物流公司信息！"); } shopDeliveryInfo.setUserId(activitySignWriteoff.getUserId()); shopDeliveryInfo.setReceiveId(receiveId); shopDeliveryInfo.setReceiveAddress(logisticsSubmitDto.getShdz()); shopDeliveryInfo.setLogisticsCompany(systemDictionary.getName()); shopDeliveryInfo.setLogisticsCompanyCode(systemDictionary.getCode()); shopDeliveryInfo.setDeliveryWay("物流配送"); shopDeliveryInfo.setLogisticsStatus(AppConstance.LOGISTICS_STATUS_OF_RECEIVE); shopDeliveryInfo.setWaybillNo(logisticsSubmitDto.getKddh()); shopDeliveryInfo.setUpdateBy(sysUsers.getSuName()); shopDeliveryInfo.setCreateBy(sysUsers.getSuName()); shopDeliveryInfo.setDeliveryTime(new Date()); shopDeliveryInfoDao.insert(shopDeliveryInfo); //更新核销记录 activitySignWriteoff.setState(ActivitySignWriteoff.STATE_THREE); activitySignWriteoff.setWriteoffTime(new Date()); activitySignWriteoff.setWriteoffUser(sysUsers.getSuName()); activitySignWriteoff.setWriteoffUserid(sysUsers.getSuId()); activitySignWriteoff.setLogisticsId(shopDeliveryInfo.getId()); activitySignWriteoffDao.updateById(activitySignWriteoff); //更新领取记录 ActivitySignReceiveRecord activitySignReceiveRecord = activitySignReceiveRecordDao.selectById(receiveId); activitySignReceiveRecord.setState(ActivitySignReceiveRecord.STATE_FOUR); activitySignReceiveRecord.setConsignee(logisticsSubmitDto.getShr()); activitySignReceiveRecord.setConsigneeAddress(logisticsSubmitDto.getShdz()); activitySignReceiveRecord.setConsigneePhone(logisticsSubmitDto.getLxdh()); activitySignReceiveRecordDao.updateById(activitySignReceiveRecord); return new AjaxResult(AjaxResult.STATUS_SUCCESS, "发货成功"); } }