| | |
| | | import com.doumee.dao.business.web.response.BikeLogDTO; |
| | | import com.doumee.dao.business.web.response.MemberRidesDTO; |
| | | import com.doumee.dao.business.web.response.MemberRidesDetailResponse; |
| | | import com.doumee.dao.system.SystemDictDataMapper; |
| | | import com.doumee.dao.system.model.SystemDictData; |
| | | import com.doumee.service.business.DeviceService; |
| | | import com.doumee.service.business.GoodsorderService; |
| | | import com.doumee.service.business.MemberRidesService; |
| | | import com.doumee.service.system.SystemDictDataService; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.shiro.SecurityUtils; |
| | |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * 用户骑行记录表Service实现 |
| | |
| | | @Autowired |
| | | private GoodsorderService goodsorderService; |
| | | |
| | | |
| | | |
| | | @Autowired |
| | | private SystemDictDataMapper systemDictDataMapper; |
| | | |
| | | @Override |
| | | public String create(MemberRides memberRides) { |
| | |
| | | |
| | | MPJLambdaWrapper<MemberRides> queryWrapper = new MPJLambdaWrapper<>(); |
| | | queryWrapper.leftJoin(BaseParam.class,BaseParam::getId,MemberRides::getParamId); |
| | | queryWrapper.eq(MemberRides::getMemberId, id); |
| | | queryWrapper.eq(MemberRides::getId, id); |
| | | queryWrapper.selectAll(MemberRides.class); |
| | | queryWrapper.selectAs(BaseParam::getName,MemberRidesDTO::getBikeType) ; |
| | | queryWrapper.last("limit 1"); |
| | |
| | | queryWrapper.le(model.getRentDateEnd()!=null, MemberRides::getRentDate,model.getRentDateEnd()); |
| | | queryWrapper.eq(model.getCloseStatus()!=null,MemberRides::getCloseStatus, model.getCloseStatus()); |
| | | queryWrapper.eq(model.getGoodsorderId()!=null,MemberRides::getOrdreId, model.getGoodsorderId()); |
| | | queryWrapper.selectAs(Member::getOpenid,MemberRidesDTO::getOpenid) |
| | | queryWrapper |
| | | .selectAs(MemberRides::getId,MemberRidesDTO::getId) |
| | | .selectAs(Member::getOpenid,MemberRidesDTO::getOpenid) |
| | | .selectAs(MemberRides::getBikeCode,MemberRidesDTO::getBikeCode) |
| | | .selectAs(MemberRides::getCloseStatus,MemberRidesDTO::getCloseStatus) |
| | | .selectAs(MemberRides::getStatus,MemberRidesDTO::getStatus) |
| | | .selectAs(BaseParam::getName,MemberRidesDTO::getBikeType) |
| | | .selectAs(MemberRides::getDuration,MemberRidesDTO::getDuration) |
| | | .selectAs(MemberRides::getRentDate,MemberRidesDTO::getRentDate) |
| | | .selectAs(MemberRides::getRentLockId,MemberRidesDTO::getRentLockId) |
| | | .selectAs(MemberRides::getRentSiteId,MemberRidesDTO::getRentSiteId) |
| | | .selectAs(MemberRides::getBackDate,MemberRidesDTO::getBackDate); |
| | | return queryWrapper; |
| | | } |
| | |
| | | @Override |
| | | public void updateDuration(MemberRides memberRides){ |
| | | LoginUserInfo user =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(StringUtils.isBlank(memberRides.getMemberId()) |
| | | if(StringUtils.isBlank(memberRides.getId()) |
| | | ||StringUtils.isBlank(memberRides.getBackReason()) |
| | | || memberRides.getDuration() == null){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = {BusinessException.class,Exception.class}) |
| | | public void forceBack(MemberRides memberRides){ |
| | | public void forceBack(MemberRides memberRides){ |
| | | LoginUserInfo user =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | if(StringUtils.isBlank(memberRides.getMemberId()) |
| | | ||StringUtils.isBlank(memberRides.getBackReason())){ |
| | | if(StringUtils.isBlank(memberRides.getBackReason())){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST); |
| | | } |
| | | MemberRides model = findJoinById(memberRides.getId()); |
| | |
| | | if(Constants.formatIntegerNum(model.getStatus()) != Constants.MEMBER_RIDES_STATUS.RIDES_RUNNING.getKey() ){ |
| | | throw new BusinessException( ResponseStatus.NOT_ALLOWED.getCode(),"对不起,只能针对未还车辆进行强制还车操作!" ); |
| | | } |
| | | QueryWrapper<SystemDictData> wrapper = new QueryWrapper<>(); |
| | | wrapper.lambda() |
| | | .eq(SystemDictData::getLabel, Arrays.asList(Constants.FORCE_BACK_SITE,Constants.FORCE_BACK_LOCK)); |
| | | List<SystemDictData> systemDictData = systemDictDataMapper.selectList(wrapper); |
| | | Map<String, SystemDictData> collect = systemDictData.stream().collect(Collectors.toMap(s -> s.getLabel(), s -> s)); |
| | | |
| | | MemberRides update = new MemberRides(); |
| | | update.setId(model.getId()); |
| | | update.setEditDate(new Date()); |
| | |
| | | update.setBackReason(memberRides.getBackReason()); |
| | | update.setBackUserid(user.getId()); |
| | | update.setBackType(Constants.ONE); |
| | | update.setStatus(Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey()); |
| | | update.setBackSiteId(collect.get(Constants.FORCE_BACK_SITE).getCode()); |
| | | update.setBackLockId(collect.get(Constants.FORCE_BACK_LOCK).getCode()); |
| | | //计算骑行计费时长 |
| | | update.setDuration(DateUtil.betweenMin(model.getRentDate(), update.getBackDate())); |
| | | memberRidesMapper.updateById(update); |