<?php
|
|
namespace app\api\controller;
|
|
use app\common\controller\Api;
|
use think\Log;
|
use app\api\logic\taoke\device\Zhetaoke as LogicZhetaoke;
|
use app\api\logic\order\TbOrder as LogicTbOrder;
|
|
/**
|
* 同步淘宝订单
|
*/
|
class AnsyTaobaoOrder extends Api
|
{
|
|
protected $noNeedLogin = '*';
|
protected $noNeedRight = '*';
|
|
protected $max_page = 50; //最大执行页数
|
|
protected $page_size = 100; //每页获取数据
|
|
|
|
public function __construct()
|
{
|
$key = request()->param('key','');
|
if(empty($key)) fault('访问受限');
|
if($key != config('site.pas_key'))fault('访问密钥错误，访问受限');
|
}
|
|
/**
|
* 同步订单近20分钟内的订单
|
*
|
* @return void
|
*/
|
public function syncOrder()
|
{
|
$time_str = date("Y-m-d H:i:s");
|
echo "---------".$time_str."同步开始-------------";
|
$query_type = request()->param('query_type','');
|
if(empty($query_type)){
|
mylog('系统提示','查询类型不能为空',"errorInfo");
|
fault('查询类型不能为空');
|
}
|
$LogicZhetaoke = new LogicZhetaoke();
|
$end_time = date("Y-m-d H:i:s",time()); //当前时间
|
$start_time = date("Y-m-d H:i:s",time()-20*60);//默认前20分钟
|
/**测试 */
|
// $start_time = "2022-06-20 23:50:00";
|
// $end_time = "2022-06-20 23:59:59";
|
$position_index = "";
|
$error_flag = false;
|
$error = "";
|
$LogicTbOrder = new LogicTbOrder();
|
for($i=1;$i<=$this->max_page;$i++){
|
$res = $LogicZhetaoke->synchronizeOrder($query_type,$start_time,$end_time,2,$position_index,$i,$this->page_size,0);
|
if(!$res['status']){
|
$error_flag = true;
|
$error = $res['info'];
|
break;
|
}else{
|
if($res['total'] == 0)break;
|
$position_index = $res['position_index'];
|
$order_list = $res['list'];
|
if(!empty($order_list)){
|
foreach($order_list as $order){
|
$result = $LogicTbOrder->fanliOrder($order);
|
if(!$result['status']){
|
mylog('订单更新错误',$result['info'],"errorInfo");
|
}
|
}
|
}
|
if(!$res['has_next'])break;
|
}
|
}
|
if($error_flag){
|
mylog('同步错误',$error,"errorInfo");
|
fault('同步错误--'.$error);
|
}
|
echo "---------".$time_str."同步完成-------------";
|
}
|
|
|
|
/**
|
* 同步订单拆分
|
*
|
* @return void
|
*/
|
public function orderCommission()
|
{
|
$time_str = date("Y-m-d H:i:s");
|
echo "---------".$time_str."同步拆分开始-------------";
|
$LogicTbOrder = new LogicTbOrder();
|
$result = $LogicTbOrder->chaifenOrder();
|
if(!$result)fault('同步拆分错误--'.$result['info']);
|
echo "---------".$time_str."同步拆分完成-------------";
|
}
|
|
|
/**
|
* 同步近x天的订单
|
*
|
* @return void
|
*/
|
public function synchronizeDayOrder()
|
{
|
$day = request()->param('day','');
|
$time_type = request()->param('time_type','now');
|
if($time_type == "now"){
|
if(empty($day)) fault('只限近90天数据');
|
if($day > 90) fault('只限近90天数据');
|
}
|
$tk_status = request()->param('tk_status','');
|
$query_type = request()->param('query_type','');
|
if(empty($query_type))fault('查询类型不能为空');
|
$interval = request()->param('interval',20); //时间间隔
|
if($interval > 100)fault('最大时间间隔100');
|
$order_scene = request()->param('order_scene',2);
|
$LogicZhetaoke = new LogicZhetaoke();
|
if($time_type == 'last_month'){
|
$time = strtotime('-1 month');
|
$start_time = date('Y-m-d H:i:s',mktime(0,0,0,date('m',$time),01,date('Y',$time))); //上个月的开始时间
|
$now_time = mktime(23,59,59,date('m',$time),date('t',$time),date('Y',$time));
|
}else{
|
$start_time = date("Y-m-d 00:00:00", strtotime("-".($day-1)." day"));
|
$now_time = time();
|
}
|
$error_flag = false;
|
$error = "";
|
$LogicTbOrder = new LogicTbOrder();
|
for($j=strtotime($start_time);$j<=$now_time;$j+=$interval*60){
|
$begain_time = date("Y-m-d H:i:s",$j);
|
$end_time = date("Y-m-d H:i:s",$j+$interval*60);
|
$position_index = "";
|
for($i=1;$i<=$this->max_page;$i++){
|
$res = $LogicZhetaoke->synchronizeOrder($query_type,$begain_time,$end_time,$order_scene,$position_index,$i,$this->page_size,0,$tk_status);
|
if(!$res['status']){
|
$error_flag = true;
|
$error = $res['info'];
|
break;
|
}else{
|
if($res['total'] == 0)break;
|
$position_index = $res['position_index'];
|
$order_list = $res['list'];
|
if(!empty($order_list)){
|
foreach($order_list as $order){
|
$result = $LogicTbOrder->fanliOrder($order);
|
if(!$result['status']){
|
mylog('订单更新错误',$result['info'],"errorInfo");
|
}
|
}
|
}
|
if(!$res['has_next'])break;
|
}
|
}
|
}
|
if($error_flag){
|
mylog('同步错误',$error,"errorInfo");
|
fault('同步错误--'.$error);
|
}
|
echo "同步成功";
|
|
}
|
|
}
|
