package com.doumee.service.business.impl;
|
|
import com.doumee.core.constants.Constants;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.MemberRidesMapper;
|
import com.doumee.dao.business.join.MemberRidesJoinMapper;
|
import com.doumee.dao.business.model.BaseParam;
|
import com.doumee.dao.business.model.Goodsorder;
|
import com.doumee.dao.business.model.Member;
|
import com.doumee.dao.business.model.MemberRides;
|
import com.doumee.dao.business.web.response.BikeLogDTO;
|
import com.doumee.dao.business.web.response.MemberRidesDTO;
|
import com.doumee.dao.business.web.response.MemberRidesQuery;
|
import com.doumee.service.business.MemberRidesService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 用户骑行记录表Service实现
|
* @author 江蹄蹄
|
* @date 2023/09/27 18:06
|
*/
|
@Service
|
public class MemberRidesServiceImpl implements MemberRidesService {
|
|
@Autowired
|
private MemberRidesMapper memberRidesMapper;
|
|
|
@Autowired
|
private MemberRidesJoinMapper memberRidesJoinMapper;
|
|
@Override
|
public String create(MemberRides memberRides) {
|
memberRidesMapper.insert(memberRides);
|
return memberRides.getId();
|
}
|
|
@Override
|
public void deleteById(String id) {
|
memberRidesMapper.deleteById(id);
|
}
|
|
@Override
|
public void delete(MemberRides memberRides) {
|
UpdateWrapper<MemberRides> deleteWrapper = new UpdateWrapper<>(memberRides);
|
memberRidesMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<String> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
memberRidesMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
public void updateById(MemberRides memberRides) {
|
memberRidesMapper.updateById(memberRides);
|
}
|
|
@Override
|
public void updateByIdInBatch(List<MemberRides> memberRidess) {
|
if (CollectionUtils.isEmpty(memberRidess)) {
|
return;
|
}
|
for (MemberRides memberRides: memberRidess) {
|
this.updateById(memberRides);
|
}
|
}
|
|
@Override
|
public MemberRides findById(String id) {
|
return memberRidesMapper.selectById(id);
|
}
|
|
@Override
|
public MemberRides findOne(MemberRides memberRides) {
|
QueryWrapper<MemberRides> wrapper = new QueryWrapper<>(memberRides);
|
return memberRidesMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<MemberRides> findList(MemberRides memberRides) {
|
QueryWrapper<MemberRides> wrapper = new QueryWrapper<>(memberRides);
|
return memberRidesMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<MemberRidesDTO> findPage(PageWrap<MemberRidesQuery> pageWrap) {
|
IPage<MemberRides> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<MemberRides> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
queryWrapper.orderByDesc(MemberRides::getCreateDate);
|
queryWrapper.leftJoin(Member.class,Member::getId,MemberRides::getMemberId)
|
.leftJoin(BaseParam.class,BaseParam::getId,MemberRides::getParamId)
|
.leftJoin(Goodsorder.class,Goodsorder::getId,MemberRides::getOrdreId)
|
.eq(BaseParam::getType, Constants.THREE)
|
.like(StringUtils.isNotBlank(pageWrap.getModel().getOpenid()),Member::getOpenid,pageWrap.getModel().getOpenid())
|
.like(StringUtils.isNotBlank(pageWrap.getModel().getBikeCode()),MemberRides::getBikeCode,pageWrap.getModel().getBikeCode())
|
.between((Objects.nonNull(pageWrap.getModel().getRentDateStart())&&Objects.nonNull(pageWrap.getModel().getRentDateEnd())),
|
MemberRides::getRentDate,
|
pageWrap.getModel().getRentDateStart(),pageWrap.getModel().getRentDateEnd());
|
if (Objects.nonNull(pageWrap.getModel().getStatus())
|
&& Constants.GOODSORDER_STATUS.CLOSE.getKey().equals(pageWrap.getModel().getStatus())){
|
queryWrapper.eq(Goodsorder::getStatus,pageWrap.getModel().getStatus());
|
}else if (Objects.nonNull(pageWrap.getModel().getStatus())
|
&& !Constants.GOODSORDER_STATUS.CLOSE.getKey().equals(pageWrap.getModel().getStatus())){
|
queryWrapper.ne(Goodsorder::getStatus,pageWrap.getModel().getStatus());
|
}
|
queryWrapper.selectAs(Member::getOpenid,MemberRidesDTO::getOpenid)
|
.selectAs(MemberRides::getBikeCode,MemberRidesDTO::getBikeCode)
|
.selectAs(Goodsorder::getStatus,MemberRidesDTO::getStatus)
|
.selectAs(BaseParam::getName,MemberRidesDTO::getBikeType)
|
.selectAs(MemberRides::getDuration,MemberRidesDTO::getDuration)
|
.selectAs(MemberRides::getRentDate,MemberRidesDTO::getRentDate)
|
.selectAs(MemberRides::getBackDate,MemberRidesDTO::getBackDate);
|
IPage<MemberRidesDTO> memberRidesDTOIPage = memberRidesJoinMapper.selectJoinPage(page, MemberRidesDTO.class, queryWrapper);
|
if (!CollectionUtils.isEmpty(memberRidesDTOIPage.getRecords())){
|
memberRidesDTOIPage.getRecords().forEach(s->{
|
if (Objects.nonNull(s.getBackDate())){
|
s.setRideTime(DateUtil.betweenMin(s.getRentDate(),s.getBackDate()));
|
}
|
});
|
}
|
return PageData.from(memberRidesDTOIPage);
|
}
|
|
@Override
|
public long count(MemberRides memberRides) {
|
QueryWrapper<MemberRides> wrapper = new QueryWrapper<>(memberRides);
|
return memberRidesMapper.selectCount(wrapper);
|
}
|
|
@Override
|
public PageData<BikeLogDTO> findBikeLog(PageWrap<MemberRidesQuery> pageWrap) {
|
|
IPage<MemberRides> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<MemberRides> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
queryWrapper.orderByDesc(MemberRides::getCreateDate);
|
queryWrapper.leftJoin(Member.class,Member::getId,MemberRides::getMemberId)
|
.leftJoin(BaseParam.class,BaseParam::getId,MemberRides::getParamId)
|
.eq(BaseParam::getType, Constants.THREE)
|
.like(StringUtils.isNotBlank(pageWrap.getModel().getOpenid()),Member::getOpenid,pageWrap.getModel().getOpenid())
|
.like(StringUtils.isNotBlank(pageWrap.getModel().getBikeCode()),MemberRides::getBikeCode,pageWrap.getModel().getBikeCode())
|
.between((Objects.nonNull(pageWrap.getModel().getRentDateStart())&&Objects.nonNull(pageWrap.getModel().getRentDateEnd())),
|
MemberRides::getRentDate,
|
pageWrap.getModel().getRentDateStart(),pageWrap.getModel().getRentDateEnd());
|
if (Objects.nonNull(pageWrap.getModel().getHasBack())
|
&& pageWrap.getModel().getHasBack()){
|
queryWrapper.isNotNull(MemberRides::getBackDate);
|
}else if (Objects.nonNull(pageWrap.getModel().getStatus())
|
&& !pageWrap.getModel().getHasBack()){
|
queryWrapper.isNull(MemberRides::getBackDate);
|
}
|
queryWrapper.orderByDesc(MemberRides::getCreateDate);
|
queryWrapper.leftJoin("locks rl on rl.id = t.rent_lock_id and rl.site_id = t.rent_site_id")
|
.leftJoin("sites rs on rs.id = rl.site_id")
|
.leftJoin("locks bl on bl.id = t.rent_lock_id and bl.site_id = t.rent_site_id")
|
.leftJoin("sites bs on bs.id = rl.site_id");
|
queryWrapper.selectAs(Member::getOpenid,BikeLogDTO::getOpenid)
|
.selectAs(MemberRides::getBikeCode,BikeLogDTO::getBikeCode)
|
.selectAs(BaseParam::getName,BikeLogDTO::getBikeType)
|
.selectAs(MemberRides::getRentDate,BikeLogDTO::getRentDate)
|
.selectAs(MemberRides::getBackDate,BikeLogDTO::getBackDate)
|
.select("rs.Name as rentSiteName, rl.name as rentLockName")
|
.select("bs.Name as backSiteName, bl.name as backLockName");
|
|
IPage<BikeLogDTO> bikeLogDTOIPage = memberRidesJoinMapper.selectJoinPage(page, BikeLogDTO.class, queryWrapper);
|
if (!CollectionUtils.isEmpty(bikeLogDTOIPage.getRecords())){
|
bikeLogDTOIPage.getRecords().forEach(s->{
|
if (Objects.nonNull(s.getBackDate())){
|
s.setRideTime(DateUtil.betweenMin(s.getRentDate(),s.getBackDate()));
|
}
|
});
|
}
|
return PageData.from(bikeLogDTOIPage);
|
}
|
}
|
