package com.ruoyi.service.impl;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.common.utils.MapUtils;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.uuid.IdUtils;
|
import com.ruoyi.domain.ZTravelBase;
|
import com.ruoyi.domain.ZTravelPrice;
|
import com.ruoyi.domain.ZTravelPriceDetail;
|
import com.ruoyi.domain.dto.PriceDto;
|
import com.ruoyi.mapper.ZTravelPriceMapper;
|
import com.ruoyi.service.ZTravelBaseService;
|
import com.ruoyi.service.ZTravelPriceDetailService;
|
import com.ruoyi.service.ZTravelPriceService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author ojq
|
* @since 2023-03-14
|
*/
|
@Service
|
public class ZTravelPriceServiceImpl extends ServiceImpl<ZTravelPriceMapper, ZTravelPrice> implements ZTravelPriceService {
|
|
@Autowired
|
ZTravelPriceServiceImpl zTravelPriceService;
|
|
@Autowired
|
ZTravelPriceDetailService zTravelPriceDetailService;
|
|
@Autowired
|
ZTravelBaseService zTravelBaseService;
|
|
// private LambdaQueryWrapper<ZTravelPrice> uniqueCondition(ZTravelPrice zTravelPrice){
|
// LambdaQueryWrapper<ZTravelPrice> lqw = new LambdaQueryWrapper<>();
|
// lqw.eq(zTravelPrice.getMyId()!=null,ZTravelPrice::getMyId,zTravelPrice.getMyId())
|
// .eq(zTravelPrice.getStartTime()!=null,ZTravelPrice::getStartTime,zTravelPrice.getStartTime())
|
// .eq(zTravelPrice.getEndTime()!=null,ZTravelPrice::getEndTime,zTravelPrice.getEndTime())
|
// .eq(zTravelPrice.getTotalDay()!=null,ZTravelPrice::getTotalDay,zTravelPrice.getTotalDay())
|
// .eq(StringUtils.isNotEmpty(zTravelPrice.getTitle()),ZTravelPrice::getTitle,zTravelPrice.getTitle());
|
//// .eq(zTravelPrice.getEat()!=null,ZTravelPrice::getEat,zTravelPrice.getEat())
|
//// .eq(zTravelPrice.getStay()!=null,ZTravelPrice::getStay,zTravelPrice.getStay())
|
//// .eq(zTravelPrice.getTraffic()!=null,ZTravelPrice::getTraffic,zTravelPrice.getTraffic())
|
//// .eq(zTravelPrice.getShopping()!=null,ZTravelPrice::getShopping,zTravelPrice.getShopping());
|
// return lqw;
|
// }
|
|
private LambdaQueryWrapper<ZTravelPrice> buildCondition(ZTravelPrice zTravelPrice, Long userId) {
|
LambdaQueryWrapper<ZTravelPrice> lqw = new LambdaQueryWrapper<>();
|
lqw.eq(ZTravelPrice::getMyId, userId)
|
.eq(zTravelPrice.getTotalDay() != null, ZTravelPrice::getTotalDay, zTravelPrice.getTotalDay())
|
.like(StringUtils.isNotEmpty(zTravelPrice.getTitle()),ZTravelPrice::getTitle,zTravelPrice.getTitle())
|
.eq(zTravelPrice.getTotalCost()!=null,ZTravelPrice::getTotalCost,zTravelPrice.getTotalCost())
|
.le(zTravelPrice.getEnd() != null, ZTravelPrice::getEndTime, zTravelPrice.getEnd())
|
.ge(zTravelPrice.getStart() != null, ZTravelPrice::getStartTime, zTravelPrice.getStart())
|
.eq(zTravelPrice.getEat()!=null,ZTravelPrice::getEat,zTravelPrice.getEat())
|
.eq(zTravelPrice.getStay()!=null,ZTravelPrice::getStay,zTravelPrice.getStay())
|
.eq(zTravelPrice.getTraffic()!=null,ZTravelPrice::getTraffic,zTravelPrice.getTraffic())
|
.eq(zTravelPrice.getShopping()!=null,ZTravelPrice::getShopping,zTravelPrice.getShopping());
|
|
lqw.orderBy(true, true, ZTravelPrice::getStartTime);
|
return lqw;
|
}
|
|
/**
|
* 分页查找
|
*/
|
@Override
|
public AjaxResult selectDataList(ZTravelPrice zTravelPrice, Integer pageNum, Integer pageSize) {
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
Long userId = user.getUserId();
|
LambdaQueryWrapper<ZTravelPrice> lqw = buildCondition(zTravelPrice, userId);
|
|
Page<ZTravelPrice> pageBean = new Page<>(pageNum, pageSize);
|
Page<ZTravelPrice> pageResult = page(pageBean, lqw);
|
|
List<ZTravelPrice> priceList = pageResult.getRecords();//得到查询出来的数据
|
|
//查询费用详情
|
for (ZTravelPrice price : priceList) {
|
LambdaQueryWrapper<ZTravelPriceDetail> detailLqw = new LambdaQueryWrapper<>();
|
detailLqw.eq(ZTravelPriceDetail::getFeeId,price.getId());
|
List<ZTravelPriceDetail> detailList = zTravelPriceDetailService.list(detailLqw);
|
price.setDetailList(detailList);
|
}
|
|
HashMap<String, Object> data = MapUtils.getResult(pageResult, priceList);
|
return AjaxResult.success(data);
|
|
}
|
|
@Override
|
public List<ZTravelPrice> selectCondition(ZTravelPrice zTravelPrice) {
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
Long userId = user.getUserId();
|
LambdaQueryWrapper<ZTravelPrice> lqw = buildCondition(zTravelPrice, userId);
|
return list(lqw);
|
}
|
|
@Override
|
public List<ZTravelPrice> selectByIds(Long[] ids) {
|
List<ZTravelPrice> list = new ArrayList<>();
|
if (ids.length != 0)
|
list = listByIds(Arrays.asList(ids));
|
else
|
list = list();
|
return list;
|
}
|
|
|
@Override
|
@Transactional
|
public AjaxResult mySave(PriceDto priceDto) {
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
Long userId = user.getUserId();
|
|
List<ZTravelPriceDetail> detailList = priceDto.getDetailList();
|
|
//生成费用表id
|
String priceId = IdUtils.fastSimpleUUID();
|
|
//得到总天数
|
long count = detailList.stream().map(ZTravelPriceDetail::getHappenTime).distinct().count();
|
Integer totalDay = Math.toIntExact(count);
|
|
|
//先插入明细表
|
|
//collectList还没有添加每日金额字段
|
List<ZTravelPriceDetail> collectList = detailList.stream().peek((priceDetail) ->
|
{
|
priceDetail.setFeeId(priceId);
|
if (priceDetail.getEat() == null || priceDetail.getStay() == null || priceDetail.getTraffic() == null || priceDetail.getEntrance() == null || priceDetail.getShopping() == null) {
|
throw new RuntimeException("如果没有对应的费用，前端要传个0过来");
|
}
|
Double totalCost = priceDetail.getEat() + priceDetail.getStay() + priceDetail.getTraffic() + priceDetail.getEntrance() + priceDetail.getShopping();
|
priceDetail.setTotalCost(totalCost);
|
}).collect(Collectors.toList());
|
|
|
//按日期分组
|
Map<String, List<ZTravelPriceDetail>> groupByTimeMap = collectList.stream().collect(Collectors.groupingBy(ZTravelPriceDetail::getHappenTime));
|
|
//将每日金额字段的值也添加上
|
for (String key : groupByTimeMap.keySet()) {
|
List<ZTravelPriceDetail> groupByTimeList = groupByTimeMap.get(key);
|
Double dayTotalCost = 0d;
|
for (ZTravelPriceDetail detail : groupByTimeList) {
|
dayTotalCost += detail.getTotalCost();
|
}
|
|
for (ZTravelPriceDetail detail : groupByTimeList){
|
detail.setDayCost(dayTotalCost);
|
}
|
}
|
|
//开始插入费用详情数据
|
for (String key : groupByTimeMap.keySet()) {
|
List<ZTravelPriceDetail> dataList = groupByTimeMap.get(key);
|
for (ZTravelPriceDetail detail : dataList) {
|
zTravelPriceDetailService.save(detail);
|
}
|
}
|
|
|
//再插入费用记录统计表
|
|
//先得到各个详情费用的总和
|
Double eatTotal = 0d;
|
Double stayTotal = 0d;
|
Double trafficTotal = 0d;
|
Double entranceTotal = 0d;
|
Double shoppingTotal = 0d;
|
Double totalFee = 0d;
|
|
for (String key : groupByTimeMap.keySet()) {
|
List<ZTravelPriceDetail> dataList = groupByTimeMap.get(key);
|
for (ZTravelPriceDetail priceDetail : dataList) {
|
if (priceDetail.getEat() == null || priceDetail.getStay() == null || priceDetail.getTraffic() == null || priceDetail.getEntrance() == null || priceDetail.getShopping() == null) {
|
throw new RuntimeException("如果没有对应的费用，前端要传个0过来");
|
}
|
eatTotal+=priceDetail.getEat();
|
stayTotal+=priceDetail.getStay();
|
trafficTotal+=priceDetail.getTraffic();
|
entranceTotal+=priceDetail.getEntrance();
|
shoppingTotal+=priceDetail.getShopping();
|
totalFee+=priceDetail.getTotalCost();
|
}
|
}
|
|
ZTravelPrice zTravelPrice = new ZTravelPrice();
|
zTravelPrice.setId(priceId);
|
zTravelPrice.setStartTime(priceDto.getStartTime());
|
zTravelPrice.setEndTime(priceDto.getEndTime());
|
zTravelPrice.setTotalDay(totalDay);
|
zTravelPrice.setTitle(priceDto.getTitle());
|
zTravelPrice.setTableName(priceDto.getTableName());
|
zTravelPrice.setProperty(priceDto.getProperty());
|
zTravelPrice.setType(priceDto.getType());
|
zTravelPrice.setDestination(priceDto.getDestination());
|
zTravelPrice.setEat(eatTotal);
|
zTravelPrice.setStay(stayTotal);
|
zTravelPrice.setTraffic(trafficTotal);
|
zTravelPrice.setEntrance(entranceTotal);
|
zTravelPrice.setShopping(shoppingTotal);
|
zTravelPrice.setTotalCost(totalFee);
|
zTravelPrice.setMyId(userId);
|
|
//插入费用记录统计
|
zTravelPriceService.save(zTravelPrice);
|
|
return AjaxResult.success();
|
|
}
|
|
@Override
|
@Transactional
|
public AjaxResult myUpdate(PriceDto priceDto) {
|
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
Long userId = user.getUserId();
|
|
List<ZTravelPriceDetail> detailList = priceDto.getDetailList();
|
|
//先查数据库里面这一次费用所有的数据
|
LambdaQueryWrapper<ZTravelPriceDetail> lqw = new LambdaQueryWrapper<>();
|
lqw.eq(ZTravelPriceDetail::getFeeId,priceDto.getId());
|
List<ZTravelPriceDetail> selectDetailList = zTravelPriceDetailService.list(lqw);
|
|
//把传过来的数据中没有的id，在数据库中删掉
|
List<Long> detailIdList = detailList.stream().filter(priceDetail -> priceDetail.getId() != null).map(ZTravelPriceDetail::getId).collect(Collectors.toList());
|
List<Long> deleteIdList = selectDetailList.stream().filter(priceDetail -> !detailIdList.contains(priceDetail.getId())).map(ZTravelPriceDetail::getId).collect(Collectors.toList());
|
zTravelPriceDetailService.removeBatchByIds(deleteIdList);
|
|
|
//如果传过来的列表的数据里面没有id
|
List<ZTravelPriceDetail> addPriceDetail = detailList.stream().filter(priceDetail -> priceDetail.getId() == null || priceDetail.getId() == 0 ).collect(Collectors.toList());
|
addPriceDetail.forEach(priceDetail -> {
|
priceDetail.setFeeId(priceDto.getId());
|
});
|
|
//那就先增加到数据库中
|
zTravelPriceDetailService.saveBatch(addPriceDetail);
|
|
//得到总天数
|
long count = detailList.stream().map(ZTravelPriceDetail::getHappenTime).distinct().count();
|
Integer totalDay = Math.toIntExact(count);
|
|
List<ZTravelPriceDetail> collectList = detailList.stream().peek((priceDetail) ->
|
{
|
if (priceDetail.getEat() == null || priceDetail.getStay() == null || priceDetail.getTraffic() == null || priceDetail.getEntrance() == null || priceDetail.getShopping() == null) {
|
throw new RuntimeException("如果没有对应的费用，前端要传个0过来");
|
}
|
Double totalCost = priceDetail.getEat() + priceDetail.getStay() + priceDetail.getTraffic() + priceDetail.getEntrance() + priceDetail.getShopping();
|
priceDetail.setTotalCost(totalCost);
|
}).collect(Collectors.toList());
|
|
//按日期分组
|
Map<String, List<ZTravelPriceDetail>> groupByTimeMap = collectList.stream().collect(Collectors.groupingBy(ZTravelPriceDetail::getHappenTime));
|
|
//将每日金额字段的值也添加上
|
for (String key : groupByTimeMap.keySet()) {
|
List<ZTravelPriceDetail> groupByTimeList = groupByTimeMap.get(key);
|
Double dayTotalCost = 0d;
|
for (ZTravelPriceDetail detail : groupByTimeList) {
|
dayTotalCost += detail.getTotalCost();
|
}
|
|
for (ZTravelPriceDetail detail : groupByTimeList){
|
detail.setDayCost(dayTotalCost);
|
}
|
}
|
|
//开始修改费用详情数据
|
for (String key : groupByTimeMap.keySet()) {
|
List<ZTravelPriceDetail> dataList = groupByTimeMap.get(key);
|
for (ZTravelPriceDetail detail : dataList) {
|
zTravelPriceDetailService.updateById(detail);
|
}
|
}
|
|
//再修改费用记录统计表
|
|
//先得到各个详情费用的总和
|
Double eatTotal = 0d;
|
Double stayTotal = 0d;
|
Double trafficTotal = 0d;
|
Double entranceTotal = 0d;
|
Double shoppingTotal = 0d;
|
Double totalFee = 0d;
|
|
for (String key : groupByTimeMap.keySet()) {
|
List<ZTravelPriceDetail> dataList = groupByTimeMap.get(key);
|
for (ZTravelPriceDetail priceDetail : dataList) {
|
if (priceDetail.getEat() == null || priceDetail.getStay() == null || priceDetail.getTraffic() == null || priceDetail.getEntrance() == null || priceDetail.getShopping() == null) {
|
throw new RuntimeException("如果没有对应的费用，前端要传个0过来");
|
}
|
eatTotal+=priceDetail.getEat();
|
stayTotal+=priceDetail.getStay();
|
trafficTotal+=priceDetail.getTraffic();
|
entranceTotal+=priceDetail.getEntrance();
|
shoppingTotal+=priceDetail.getShopping();
|
totalFee+=priceDetail.getTotalCost();
|
}
|
}
|
|
ZTravelPrice zTravelPrice = new ZTravelPrice();
|
zTravelPrice.setId(priceDto.getId());
|
zTravelPrice.setStartTime(priceDto.getStartTime());
|
zTravelPrice.setEndTime(priceDto.getEndTime());
|
zTravelPrice.setTotalDay(totalDay);
|
zTravelPrice.setTitle(priceDto.getTitle());
|
zTravelPrice.setTableName(priceDto.getTableName());
|
zTravelPrice.setProperty(priceDto.getProperty());
|
zTravelPrice.setType(priceDto.getType());
|
zTravelPrice.setDestination(priceDto.getDestination());
|
zTravelPrice.setEat(eatTotal);
|
zTravelPrice.setStay(stayTotal);
|
zTravelPrice.setTraffic(trafficTotal);
|
zTravelPrice.setEntrance(entranceTotal);
|
zTravelPrice.setShopping(shoppingTotal);
|
zTravelPrice.setTotalCost(totalFee);
|
zTravelPrice.setMyId(userId);
|
|
//修改统计表
|
zTravelPriceService.updateById(zTravelPrice);
|
|
return AjaxResult.success();
|
|
|
}
|
|
@Override
|
@Transactional
|
public AjaxResult myRemove(String[] ids) {
|
|
for (String feeId : ids) {
|
//删除旅游经历
|
zTravelBaseService.remove(new LambdaQueryWrapper<ZTravelBase>().eq(ZTravelBase::getFeeId,feeId));
|
|
//删除费用详情
|
zTravelPriceDetailService.remove(new LambdaQueryWrapper<ZTravelPriceDetail>().eq(ZTravelPriceDetail::getFeeId,feeId));
|
|
//删除费用记录
|
zTravelPriceService.remove(new LambdaQueryWrapper<ZTravelPrice>().eq(ZTravelPrice::getId,feeId));
|
}
|
|
return AjaxResult.success();
|
|
}
|
|
// @Override
|
// public AjaxResult importExcel(MultipartFile file) {
|
//
|
// }
|
|
|
// @Override
|
// @Transactional
|
// public AjaxResult importExcel(MultipartFile file) {
|
//
|
// ExcelUtil<ZTravelPrice> util = new ExcelUtil<>(ZTravelPrice.class);
|
// List<ZTravelPrice> dataList = null;
|
// try {
|
// dataList = util.importExcel(file.getInputStream());
|
// } catch (Exception e) {
|
// throw new RuntimeException("没有按照规则导入数据");
|
// }
|
//
|
// assert dataList != null;
|
//
|
// for (ZTravelPrice zTravelPrice : dataList) {
|
// zTravelPriceService.mySave(zTravelPrice);
|
// }
|
//
|
// return AjaxResult.success();
|
//
|
// }
|
}
|
