任务节点
2019-07-15 09:49:50 0 举报
哈哈
作者其他创作
大纲/内容
推送到电商平台指定的接口地址或者指定的数据库中
当前运单的轨迹信息是不属于该平台或者合作方商户的。
平台指定接口推送失败,则将本队列写入一个延时生产轨迹队列
消费轨迹队列,判断当前轨迹队列运单号是否在当前订单信息(string)里面;即我们定义的扫描队列和订单信息的碰撞,代替连表查询。提高效率和性能
平台指定数据库推送失败,则记录异常日志,并且重新将本队列写入轨迹队列,进行下次推送
本脚本监控延时轨迹生产队列是否有数据,有的话,则补推消费该队列到平台指定的库或者接口
碰撞失败
生产队列由表中的根据最新时间决定,每次读取表中的10秒数据,分片写入队列,将最后的时间写入db文件,作为下一次读取的开始时间
碰撞成功
读取扫描表轨迹信息,放入轨迹队列(list)
当前运单的轨迹信息是属于该平台或者合作方商户的。
将当前轨迹队列,组装成电商平台需要的字段和文案格式的数组
shell脚本执行PHP脚本,一秒执行一次,无限循环,根据数据量酌情开启多个shell进程执行PHP脚本
推送成功,根据情况决定是否记录日志,如,新加的客户则需要记录日志,稳定下来以后则关闭日志
读取订单表信息,放入订单信息(string)
0 条评论
下一页
为你推荐
查看更多