订单路由定时任务

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：订单路由定时任务 */@Componentpublic 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;    }}