订单路由定时任务

package com.sf.XWFS.task;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.sf.XWFS.domain.OrderDO;
import com.sf.XWFS.service.OrderService;
import com.sf.XWFS.service.YHOrderService;
import com.sf.XWFS.util.CSIMUtil;
import com.sf.erui.util.StringUtil;
import io.jsonwebtoken.lang.Collections;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.*;

/**
 * author：80003756-蔡俊华
 * date：2019-5-13
 * desc：订单路由定时任务
 */
@Component
public class OrderSendStateTask {

    private Logger logger = LoggerFactory.getLogger(OrderSendStateTask.class);
    //redis缓存注入
    //@Autowired
    //private RedisTemplate redisTemplate;

    //@Autowired
    private OrderService orderService;



    private YHOrderService yhOrderService;
    /**
     * 从丰桥拉取路由状态
     * 每隔12小时执行一次
     */
    @Scheduled(cron="0 0 0/12 * * ?")
    public void pullSendState() {
        logger.info("start -----> 开始从丰桥拉取路由状态 ");

        orderService = (OrderService)ApplicationContextUtil.getBean("orderServiceImpl");
        yhOrderService = (YHOrderService)ApplicationContextUtil.getBean("YHOrderServiceImpl");

        long start = System.currentTimeMillis();
        int pageSize = 100;//条数
        int pageStart = 0;//偏移量
        int maxTimes = 50;//最多查询次数 50*100为5000条数据
        int queryTimes = 0;
        boolean isStop = false;
        HashMap<String,Object> param = new HashMap<String,Object>();
        try {
            //查询50次，一共5000条
            param.put("pageSize", pageSize);
            param.put("orderBy", "create_tm asc");//排序
            param.put("is_cancel", "0");//未作废
            param.put("mailnoNotNull","1");//运单号不为空
            param.put("send_state_nq","已收件");//未收件
            param.put("submit_state","1");//已提交

            while( queryTimes ++ <= maxTimes){
                param.put("pageStart", pageStart);
                try{
                    List<Map<String, Object>> orderList =orderService.selectOrder(param);
                    if(Collections.isEmpty(orderList)){
                        logger.info("第"+queryTimes+"次查询到数据为空");
                        break;
                    }
                    logger.info("第"+queryTimes+"次查询到记录："+orderList.size());
                    if(orderList.size()<100){
                        isStop = true;
                    }
                    //获取路由状态
                    queryState(filter(orderList));

                }catch(Exception ex){
                    isStop = true;
                    logger.error("", ex);
                }
                //已经没有需要更新路由的数据
                if(isStop){
                    break;
                }
                //翻页
                pageStart +=pageSize;
            }

        } catch (Exception ex) {

            logger.error("从丰桥拉取路由异常", ex);
        } finally {
            logger.info("end -----> 从丰桥拉取路由状态结束,耗时：" + (System.currentTimeMillis() - start) + "ms");
        }
    }

    private void queryState(List<Map<String, Object>> orderList){
        try{
            int start =0;
            boolean isStop = false;
            String trackingType = "1";//用运单号查询
            JSONArray result = new JSONArray();
            while(!isStop){
                try{
                    //运单号多个逗号隔开
                    StringBuilder tracking_number = new StringBuilder();
                    //每次取十条
                    for(int i=0;i <10; i++){
                        if(start >= orderList.size()){
                            isStop = true;
                            break;
                        }
                        Map<String,Object> order = orderList.get(start ++);
                        tracking_number.append(order.get("mailno")+",");
                    }
                    JSONArray route = CSIMUtil.RouteServiceBySys(trackingType,tracking_number.substring(0,tracking_number.length()-1));
                    //----
/*                    JSONObject jsonb = new JSONObject();
                    jsonb.put("mailno", "873YUADSFH11197773DL0982");

                    jsonb.put("opcode", "8000");
                    route.add(jsonb);
                    JSONObject jsonb2 = new JSONObject();
                    jsonb2.put("mailno", "873YUADSFH11197773DL098");

                    jsonb2.put("opcode", "70");
                    route.add(jsonb2);*/
                    //--
                    logger.info("丰桥返回:"+route.toString());
                    result.addAll(route);
                }catch(Exception ex){
                    logger.error("查询丰桥路由异常",ex );
                }
                if(result.size()>=30){//30条更新一次数据库
                    //更新数据状态
                    updateDatabase(result);
                    result.clear();
                }
            }
            if(result.size()>0){//更新一次数据库
                //更新数据状态
                updateDatabase(result);
            }

        }catch(Exception ex){
            logger.error("查询丰桥路由异常",ex );
        }
    }

    /**
     * 更新到数据库
     * @param route
     */
    private void updateDatabase(JSONArray route){
        try{
            if(route == null ||route.size()==0){
                return;
            }
            Map<String, List<OrderDO>> map = new HashMap<String, List<OrderDO>>() ;
            List<OrderDO> list = new ArrayList<OrderDO>();

            route.forEach(jsonObj ->{
                JSONObject json  = (JSONObject)jsonObj;
                if(json.get("error") != null){
                    return;
                }
                String sendState = "";
                String mailno = json.getString("mailno");
                String opcode = json.getString("opcode");

                switch (opcode) {
                    case "50":
                        sendState = "已收件";
                        break;
                    case "80":
                        sendState = "派送成功";
                        break;
                    case "8000":
                        sendState = "派送成功";
                        break;
                    case "33":
                        sendState = "派送失败";
                        break;
                    case "70":
                        sendState = "派送失败";
                        break;
                    default:
                        sendState = "运输中";
                        break;
                }
                OrderDO order = new OrderDO();
                order.setMailno(mailno);
                order.setSendState(sendState);
                list.add(order);
            });
            map.put("list",list);
            Integer rest = orderService.batchUpdateRoute(map);
            logger.info("成功更新路由到数据库："+rest);
            //更新数据到远航
            new Thread(()->updateRoutToYH(list)).start();

        }catch(Exception ex){
            logger.error("更新路由异常",ex );
        }


    }


    //更新数据到远航
    private void updateRoutToYH(List<OrderDO> list){
         try{
             SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
             String dateStr = sf.format(new Date());

             List<Map<String,Object>> param = new ArrayList<Map<String,Object>>();
             list.forEach(orderDO -> {
                 Map<String,Object> map = new HashMap<String,Object>();
                 map.put("mailno",orderDO.getMailno());
                 map.put("send_state",orderDO.getSendState());
                 map.put("hcsj",dateStr);
                 param.add(map);
             });
             //推送路由
             Integer rest = yhOrderService.updateYHOrderRoute(param);
             logger.info("路由推送成功："+rest);
             //更新数据库
             Map<String, List<OrderDO>> map = new HashMap<String, List<OrderDO>>();
             map.put("list", list);
             rest = orderService.batchUpdateBack(map,dateStr);
             logger.info("更新回传时间成功："+rest);

         }catch(Exception ex){
             logger.error("更新路由到远航异常", ex);
         }
    }

    /**
     * 派送失败超过10天不再查询路由
     * @param datalist
     * @return
     */
    public List<Map<String, Object>> filter(List<Map<String, Object>> datalist){
        for(Iterator<Map<String,Object>> it = datalist.iterator(); it.hasNext();){
            Map<String, Object> map = it.next();
            if(map.get("send_state")!=null && map.get("send_state").equals("派送失败")){
                  if(map.get("first_time_route") == null){
                      continue;
                  }
                  Date first_time_route = (Date)map.get("first_time_route");
                  Date now = new Date();
                  long ms = now.getTime()-first_time_route.getTime();
                  int days = (int) (ms/(1000*60*60*24));
                  if(days >=10){
                      it.remove();;
                  }
            }
        }
        return datalist;
    }

}