package cn.exrick.xboot.your.schedulings;
import cn.exrick.xboot.your.entity.Area;
import cn.exrick.xboot.your.entity.AreaSection;
import cn.exrick.xboot.your.entity.Customer;
import cn.exrick.xboot.your.entity.OrderTask;
import cn.exrick.xboot.your.service.IAreaSectionService;
import cn.exrick.xboot.your.service.IAreaService;
import cn.exrick.xboot.your.service.ICustomerService;
import cn.exrick.xboot.your.service.IOrderTaskService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
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.ArrayList;
import java.util.List;
//大屏配送分析
@Component
public class StatisticPc2ScheduleImpl {
@Autowired
private IAreaService iAreaService;
@Autowired
private IAreaSectionService iAreaSectionService;
@Autowired
private ICustomerService iCustomerService;
@Autowired
private IOrderTaskService iOrderTaskService;
@Scheduled(cron="0 0 * * * ?")//每小时执行一次
public void execute(){
List list = iAreaService.list();
for(Area area:list){
QueryWrapper wrapper = new QueryWrapper<>();
wrapper.eq("area_id",area.getId());
int count = iCustomerService.count(wrapper);
area.setCustomerSum(count);
iAreaService.saveOrUpdate(area);
}
List list2 = iAreaSectionService.list();
for(AreaSection areaSection:list2){
String id = areaSection.getId();
QueryWrapper wrapper = new QueryWrapper<>();
wrapper.eq("area_section_id",id);
int count = iCustomerService.count(wrapper);
areaSection.setCustomerNum(count);
List orderTasks = iOrderTaskService.sumTime(id);
int sum = 0;
List listTime = new ArrayList<>();
for(OrderTask orderTask:orderTasks){
sum+=orderTask.getTime();
listTime.add(orderTask.getTime());
}
}
}
}