订单路由定时任务

爱被打了一巴掌 2021-10-18 16:20 269阅读 0赞

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;  
\}

转载于:https://www.cnblogs.com/pxzbky/p/10995019.html