| | |
| | | package cn.exrick.xboot.your.schedulings; |
| | | import cn.exrick.xboot.your.entity.*; |
| | | import cn.exrick.xboot.your.service.*; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | |
| | | private ICustomerService iCustomerService; |
| | | |
| | | @Autowired |
| | | private ICarService iCarService; |
| | | |
| | | @Autowired |
| | | private ICustomerReceiveService iCustomerReceiveService; |
| | | |
| | | @Scheduled(cron="0 30 23 * * ?")//每晚凌晨1点执行 |
| | | //@Scheduled(cron="0 22 11 * * ?")//每晚凌晨1点执行 |
| | | public void execute(){ |
| | | System.out.println("开始处理订单"); |
| | | QueryWrapper<OrderTaskOriginal> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.between("create_time",dateStringFormat(new Date()),dateStringFormat2(new Date())); |
| | | List<OrderTaskOriginal> list = iOrderTaskOriginalService.list(); |
| | | List<OrderTaskOriginal> list = iOrderTaskOriginalService.list(queryWrapper); |
| | | |
| | | for(OrderTaskOriginal original:list){ |
| | | OrderTask orderTask = new OrderTask(); |
| | | orderTask.setCode(original.getCode()); |
| | | orderTask.setAreaId(getArea(original.getAreaName())); |
| | | Area area = getArea(original.getAreaName()); |
| | | orderTask.setAreaId(area.getId()); |
| | | orderTask.setCarId(area.getCarId()); |
| | | orderTask.setAreaSectionId(getAreaSection(orderTask.getAreaId(),original.getAreaSection())); |
| | | orderTask.setCustomerId(getCustomer(original.getCustomerCode(),original.getCustomerName(),original.getCustomerPhone(),original.getLinker(),orderTask.getAreaId(),orderTask.getAreaSectionId())); |
| | | orderTask.setEndDate(original.getPacketDate()); |
| | | orderTask.setSendDate(original.getSendDate()); |
| | | orderTask.setOrderDate(original.getOrderDate()); |
| | | orderTask.setSeq(original.getSeq()); |
| | | if(original.getSeq()!=null){ |
| | | orderTask.setSeq(original.getSeq()); |
| | | }else{ |
| | | orderTask.setSeq(999); |
| | | } |
| | | |
| | | orderTask.setNum(original.getNum()); |
| | | orderTask.setCarId(orderTask.getAreaId()); |
| | | |
| | | iOrderTaskService.saveOrUpdate(orderTask); |
| | | |
| | | updateCustomerRecive(orderTask.getCustomerId(),original.getLinker(),original.getCustomerPhone()); |
| | | |
| | | QueryWrapper<OrderDetailOriginal> wrapper = new QueryWrapper<>(); |
| | | wrapper.between("create_time",dateStringFormat(new Date()),dateStringFormat2(new Date())); |
| | | wrapper.eq("orderId",original.getId()); |
| | | // wrapper.between("create_time",dateStringFormat(new Date()),dateStringFormat2(new Date())); |
| | | wrapper.eq("order_id",original.getId()); |
| | | List<OrderDetailOriginal> list1 = iOrderDetailOriginalService.list(wrapper); |
| | | for(OrderDetailOriginal o:list1){ |
| | | OrderDetail orderDetail = new OrderDetail(); |
| | |
| | | } |
| | | |
| | | } |
| | | System.out.println("处理订单结束"); |
| | | |
| | | } |
| | | |
| | |
| | | return one.getId(); |
| | | } |
| | | |
| | | public String getArea(String name){ |
| | | public Area getArea(String name){ |
| | | QueryWrapper<Area> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.eq("name",name); |
| | | Area one = iAreaService.getOne(queryWrapper); |
| | |
| | | Area area = new Area(); |
| | | area.setName(name); |
| | | iAreaService.saveOrUpdate(area); |
| | | return area.getId(); |
| | | return area; |
| | | } |
| | | return one.getId(); |
| | | return one; |
| | | } |
| | | |
| | | public String getAreaSection(String areaId,String name){ |
| | |
| | | |
| | | public String getCarId(String areaId){ |
| | | Area area = iAreaService.getById(areaId); |
| | | String userId = area.getUserId(); |
| | | if(StrUtil.isNotEmpty(userId)){ |
| | | QueryWrapper<Car> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.eq("follow_user_id",userId); |
| | | Car one = iCarService.getOne(queryWrapper); |
| | | return one.getId(); |
| | | }else{ |
| | | return null; |
| | | } |
| | | return area.getCarId(); |
| | | // String userId = area.getUserId(); |
| | | // if(StrUtil.isNotEmpty(userId)){ |
| | | // QueryWrapper<Car> queryWrapper = new QueryWrapper<>(); |
| | | // queryWrapper.eq("follow_user_id",userId); |
| | | // Car one = iCarService.getOne(queryWrapper); |
| | | // return one.getId(); |
| | | // }else{ |
| | | // return null; |
| | | // } |
| | | //return iAreaService.getCarId(areaId); |
| | | } |
| | | |
| | | public String dateStringFormat(Date strDate) { |