|
package com.by4cloud.platform.processing.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.by4cloud.platform.processing.entity.TransitAvgSch;
|
import com.by4cloud.platform.processing.mapper.TransitAvgSchMapper;
|
import com.by4cloud.platform.processing.service.TransitAvgSchService;
|
import com.by4cloud.platform.yunxiao.entity.Ponderation;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* 运输平均时间
|
*
|
* @author zzl
|
* @date 2025-10-17 16:04:39
|
*/
|
@Service
|
public class TransitAvgSchServiceImpl extends ServiceImpl<TransitAvgSchMapper, TransitAvgSch> implements TransitAvgSchService {
|
|
// private PonderationService ponderationService;
|
// private LoadUnloadAvgTimeMapper loadUnloadAvgTimeMapper;
|
//
|
// @Override
|
// public void getTransitAvgSch(Date startDate, Date endDate) {
|
// loadUnloadAvgTimeMapper.setGroupConcatMaxLen();
|
// //筛选磅单记录
|
// List<Ponderation> ponderationList = ponderationService.list(new QueryWrapper<Ponderation>()
|
// .select("customer_address_id","comp_id","vehicle_no",
|
// "DATE_FORMAT(out_time, '%Y-%m-%d') AS out_time",
|
// "COUNT(id) AS count1",
|
// "GROUP_CONCAT(DATE_FORMAT(create_time, '%Y-%m-%d %H:%i:%s') SEPARATOR ',') AS start_date",
|
// "GROUP_CONCAT(DATE_FORMAT(out_time, '%Y-%m-%d %H:%i:%s') SEPARATOR ',') AS real_ids")
|
// .ge("out_time", startDate)
|
// .le("out_time", endDate)
|
// .eq("del_flag",0)
|
// .ne("isbl",1)
|
// .isNull("is_empty")
|
// .eq("ponderation_type","外销")
|
// .orderByDesc("out_time")
|
// .groupBy("customer_address_id,comp_id,vehicle_no,DATE_FORMAT(out_time, '%Y-%m-%d')")
|
// .having("COUNT(id) >= 2"));
|
// List<TransitAvgSch> transitAvgSches = new ArrayList<>();
|
// //循环获取每天的最短时间、最长时间、平均值
|
// ponderationList.forEach(e -> {
|
// TransitAvgSch transitAvgSch = new TransitAvgSch();
|
// transitAvgSch.setCustomerAddressId(e.getCustomerAddressId());
|
// transitAvgSch.setTransitType(1);
|
// transitAvgSch.setCompId(e.getCompId());
|
// transitAvgSch.setSaleType(e.getPonderationType());
|
// transitAvgSch.setIds(e.getRealIds());
|
// int[] stats = AvgTimeUtils.compareTimes(e.getStartDate(),e.getRealIds());
|
// //设置最短时间、最长时间、平均值
|
// transitAvgSch.setMinTime(stats[0]);
|
// transitAvgSch.setMaxTime(stats[1]);
|
// transitAvgSch.setDay(e.getOutTime());
|
// transitAvgSches.add(transitAvgSch);
|
// });
|
// List<TransitAvgSch> saveTransitAvgSches = new ArrayList<>();
|
// transitAvgSches.stream().collect(Collectors.groupingBy(e -> e.getCompId())).forEach((compId, list) -> {
|
// list.stream().collect(Collectors.groupingBy(e -> e.getCustomerAddressId())).forEach((customerAddressId, list1) -> {
|
// TransitAvgSch transitAvgSch = new TransitAvgSch();
|
// transitAvgSch.setFyCompId(compId);
|
// transitAvgSch.setFyCompName(list1.get(0).getCompName());
|
// transitAvgSch.setCustomerAddressId(customerAddressId);
|
// transitAvgSch.setCustomerAddressName(list1.get(0).getCustomerAddressName());
|
// transitAvgSch.setTransitType(1);
|
// transitAvgSch.setSaleType(list1.get(0).getSaleType());
|
// List<Integer> avgTimes = new ArrayList<>();
|
// list1.forEach(e -> {
|
// avgTimes.add(e.getMinTime());
|
// avgTimes.add(e.getMaxTime());
|
// });
|
// //转换为数组
|
// //过滤极值
|
// List<Integer> resultList = AvgTimeUtils.filterByIQR(avgTimes);
|
// int[] avgTimesArray = resultList.stream().mapToInt(Integer::intValue).toArray();
|
// int[] stats = AvgTimeUtils.calculateStats(avgTimesArray);
|
// transitAvgSch.setMinTime(stats[0]);
|
// transitAvgSch.setAvgTime(stats[2]);
|
// saveTransitAvgSches.add(transitAvgSch);
|
// });
|
// });
|
// saveBatch(saveTransitAvgSches);
|
// }
|
//
|
// @Override
|
// public void getNxTransitAvgSch(Date startDate, Date endDate) {
|
// loadUnloadAvgTimeMapper.setGroupConcatMaxLen();
|
// //筛选磅单记录
|
// List<Ponderation> ponderationList = ponderationService.list(new QueryWrapper<Ponderation>()
|
// .select("from_comp_id","to_comp_id","vehicle_no",
|
// "DATE_FORMAT(out_time, '%Y-%m-%d') AS out_time",
|
// "COUNT(id) AS count1",
|
// "GROUP_CONCAT(DATE_FORMAT(create_time, '%Y-%m-%d %H:%i:%s') SEPARATOR ',') AS start_date",
|
// "GROUP_CONCAT(DATE_FORMAT(out_time, '%Y-%m-%d %H:%i:%s') SEPARATOR ',') AS real_ids")
|
// .ge("out_time", startDate)
|
// .le("out_time", endDate)
|
// .eq("del_flag",0)
|
// .ne("isbl",1)
|
// .isNull("is_empty")
|
// .eq("ponderation_type","内销")
|
// .orderByDesc("out_time")
|
// .groupBy("from_comp_id,to_comp_id,vehicle_no,DATE_FORMAT(out_time, '%Y-%m-%d')")
|
// .having("COUNT(id) >= 2"));
|
// List<TransitAvgSch> transitAvgSches = new ArrayList<>();
|
// //循环获取每天的最短时间、最长时间、平均值
|
// ponderationList.forEach(e -> {
|
// TransitAvgSch transitAvgSch = new TransitAvgSch();
|
// transitAvgSch.setToCompId(e.getToCompId());
|
// transitAvgSch.setToCompName(e.getToCompName());
|
// transitAvgSch.setTransitType(1);
|
// transitAvgSch.setCompId(e.getFromCompId());
|
// transitAvgSch.setSaleType(e.getPonderationType());
|
// transitAvgSch.setIds(e.getRealIds());
|
// int[] stats = AvgTimeUtils.compareTimes(e.getStartDate(),e.getRealIds());
|
// //设置最短时间、最长时间、平均值
|
// transitAvgSch.setMinTime(stats[0]);
|
// transitAvgSch.setMaxTime(stats[1]);
|
// transitAvgSch.setDay(e.getOutTime());
|
// transitAvgSches.add(transitAvgSch);
|
// });
|
// List<TransitAvgSch> saveTransitAvgSches = new ArrayList<>();
|
// transitAvgSches.stream().collect(Collectors.groupingBy(e -> e.getCompId())).forEach((compId, list) -> {
|
// list.stream().collect(Collectors.groupingBy(e -> e.getToCompId())).forEach((toCompId, list1) -> {
|
// TransitAvgSch transitAvgSch = new TransitAvgSch();
|
// transitAvgSch.setFyCompId(compId);
|
// transitAvgSch.setFyCompName(list1.get(0).getCompName());
|
// transitAvgSch.setToCompId(toCompId);
|
// transitAvgSch.setToCompName(list1.get(0).getToCompName());
|
// transitAvgSch.setTransitType(1);
|
// transitAvgSch.setSaleType(list1.get(0).getSaleType());
|
// List<Integer> avgTimes = new ArrayList<>();
|
// list1.forEach(e -> {
|
// avgTimes.add(e.getMinTime());
|
// avgTimes.add(e.getMaxTime());
|
// });
|
// //转换为数组
|
// //过滤极值
|
// List<Integer> resultList = AvgTimeUtils.filterByIQR(avgTimes);
|
// int[] avgTimesArray = resultList.stream().mapToInt(Integer::intValue).toArray();
|
// int[] stats = AvgTimeUtils.calculateStats(avgTimesArray);
|
// transitAvgSch.setMinTime(stats[0]);
|
// transitAvgSch.setAvgTime(stats[2]);
|
// saveTransitAvgSches.add(transitAvgSch);
|
// });
|
// });
|
// saveBatch(saveTransitAvgSches);
|
// }
|
|
}
|
