订单路由定时任务

Posted 2022-01-01 pxzbky

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：puxiaozhe
* 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);

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;