package cn.exrick.xboot.your.schedulings;
|
import cn.exrick.xboot.core.entity.User;
|
import cn.exrick.xboot.core.service.UserService;
|
import cn.exrick.xboot.your.entity.*;
|
import cn.exrick.xboot.your.service.*;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import org.elasticsearch.cluster.ClusterState;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.io.IOException;
|
import java.util.List;
|
//客户端首页数据统计
|
@Component
|
public class StatisticScheduleImpl {
|
|
@Autowired
|
private IUserStatisticService iUserStatisticService;
|
|
@Autowired
|
private UserService userService;
|
|
@Autowired
|
private IDrivingRecordService iDrivingRecordService;
|
|
@Autowired
|
private IOrderTaskService iOrderTaskService;
|
|
@Autowired
|
private IAreaService iAreaService;
|
|
@Autowired
|
private ICustomerService iCustomerService;
|
|
@Autowired
|
private IAlarmService iAlarmService;
|
|
@Autowired
|
private ICarService iCarService;
|
|
@Scheduled(cron="0 0 1 * * ?")//每晚凌晨1点执行
|
public void execute(){
|
List<User> all = userService.findAll();
|
for(User user:all){
|
Integer type2 = user.getType2();
|
if(type2!=null){
|
QueryWrapper<UserStatistic> wrapper = new QueryWrapper<>();
|
wrapper.eq("user_id",user.getId());
|
UserStatistic one = iUserStatisticService.getOne(wrapper);
|
if(one==null){
|
one = new UserStatistic();
|
one.setUserId(user.getId());
|
}
|
//司机
|
if(type2==0){
|
Integer max = iDrivingRecordService.maxByUserId(user.getId());
|
Integer min = iDrivingRecordService.minByUserId(user.getId());
|
if(max==null||min==null){
|
one.setSafeDriving(0);//安全驾驶里程
|
one.setDriving(0);//驾驶里程
|
}else{
|
if(max==min){
|
one.setSafeDriving(max);//安全驾驶里程
|
one.setDriving(max);//驾驶里程
|
}else{
|
one.setSafeDriving(max-min);//安全驾驶里程
|
one.setDriving(max-min);//驾驶里程
|
}
|
}
|
|
QueryWrapper<DrivingRecord> wrapper2 = new QueryWrapper<>();
|
wrapper2.eq("user_id",user.getId());
|
int count = iDrivingRecordService.count(wrapper2);
|
one.setOutCar(count);//出车次数
|
|
one.setLikes(iDrivingRecordService.sumLikeByUserId(user.getId()));//点赞数
|
|
QueryWrapper<Alarm> wrapper3 = new QueryWrapper<>();
|
wrapper3.eq("car_user_id",user.getId());
|
wrapper3.eq("type",1);
|
one.setFatigueDriving(iAlarmService.count(wrapper3));//疲劳驾驶
|
wrapper3.eq("type",3);
|
one.setNoBelt(iAlarmService.count(wrapper3));//不系安全带
|
wrapper3.eq("type",4);
|
one.setSmoking(iAlarmService.count(wrapper3));//抽烟
|
wrapper3.eq("type",2);
|
one.setPhone(iAlarmService.count(wrapper3));//接打电话
|
}
|
//配送员
|
if(type2==1){
|
QueryWrapper<OrderTask> wrapper2 = new QueryWrapper<>();
|
wrapper2.eq("user_id",user.getId());
|
wrapper2.ne("status",0);
|
int count = iOrderTaskService.count(wrapper2);
|
one.setSends(count);//配送次数
|
|
QueryWrapper<OrderTask> wrapper22 = new QueryWrapper<>();
|
wrapper22.eq("user_id",user.getId());
|
wrapper22.eq("status",1);
|
int count2 = iOrderTaskService.count(wrapper22);
|
one.setSends2(count2);//送达次数
|
|
// QueryWrapper<Area> wrapper3 = new QueryWrapper<>();
|
// wrapper3.eq("user_id",user.getId());
|
// Area area = iAreaService.getOne(wrapper3);
|
Area area = getArea(user.getId());
|
if(area!=null){
|
QueryWrapper<Customer> wrapper4 = new QueryWrapper<>();
|
wrapper4.eq("area_id",area.getId());
|
int count3 = iCustomerService.count(wrapper4);
|
one.setService(count3);//服务商户数
|
}
|
|
int i = iOrderTaskService.countLike();
|
one.setLikes(i);//点赞次数
|
int likeCount = iOrderTaskService.count();
|
if(likeCount==0){
|
one.setLikesRate(0);//点赞率
|
}else{
|
one.setLikesRate((i*100)/likeCount);//点赞率
|
}
|
|
QueryWrapper<Alarm> wrapper4 = new QueryWrapper<>();
|
wrapper4.eq("follow_user_id",user.getId());
|
wrapper4.eq("type",5);
|
one.setAbnormalOpen(iAlarmService.count(wrapper4));//异常开启
|
}
|
|
iUserStatisticService.saveOrUpdate(one);
|
}
|
|
}
|
|
}
|
|
public Area getArea(String userId){
|
QueryWrapper<Car> carQueryWrapper = new QueryWrapper<Car>();
|
carQueryWrapper.eq("follow_user_id",userId);
|
Car one = iCarService.getOne(carQueryWrapper);
|
if(one==null){
|
return null;
|
}else{
|
QueryWrapper<Area> wrapper = new QueryWrapper<Area>();
|
wrapper.eq("car_id",one.getId());
|
Area area = iAreaService.getOne(wrapper);
|
return area;
|
}
|
}
|
}
|
