最新版本

wang-hao-jie

2022-03-23 7005c13237516d5dd965afb1b3c5aa734a01a661

 xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/schedulings/OrderSynScheduleImpl.java

@@ -7,6 +7,7 @@
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@@ -38,15 +39,20 @@
    @Autowired
    private ICustomerReceiveService iCustomerReceiveService;

    @Autowired
    private IOrderLogService iOrderLogService;

    @Scheduled(cron="0 30 23 * * ?")//每晚凌晨1点执行
    //@Scheduled(cron="0 22 11 * * ?")//每晚凌晨1点执行
    //@Scheduled(cron="0 11 15 * * ?")//每晚凌晨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(queryWrapper);

        int sumNum = 0;
        for(OrderTaskOriginal original:list){
            try {
            OrderTask orderTask = new OrderTask();
            orderTask.setCode(original.getCode());
            Area area = getArea(original.getAreaName());
@@ -64,24 +70,34 @@
            }

            orderTask.setNum(original.getNum());
                sumNum+=original.getNum();

            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("order_id",original.getId());
            List<OrderDetailOriginal> list1 = iOrderDetailOriginalService.list(wrapper);

                List<OrderDetail> detailList = new ArrayList<>();
            for(OrderDetailOriginal o:list1){
                OrderDetail orderDetail = new OrderDetail();
                orderDetail.setNum(o.getNum());
                orderDetail.setOrderId(orderTask.getId());
                orderDetail.setProduct(o.getProductName());
                iOrderDetailService.saveOrUpdate(orderDetail);
                    detailList.add(orderDetail);
            }
                iOrderDetailService.saveBatch(detailList);
            }catch (Exception e){

        }
        }

        OrderLog orderLog = new OrderLog();
        orderLog.setNum(sumNum);
        orderLog.setType(0);
        iOrderLogService.save(orderLog);
        System.out.println("处理订单结束");

    }
@@ -90,9 +106,9 @@
        QueryWrapper<CustomerReceive> wrapper = new QueryWrapper<>();
        wrapper.eq("customer_id",customerId);
        wrapper.eq("name",linker);
        CustomerReceive one = iCustomerReceiveService.getOne(wrapper);
        if(one==null){
            one = new CustomerReceive();
        List<CustomerReceive> list = iCustomerReceiveService.list(wrapper);
        if(list.size()==0){
            CustomerReceive one = new CustomerReceive();
            one.setCustomerId(customerId);
            one.setFstatus(0);
            one.setStatus(1);