2024-06-24 11:52:30 +08:00
|
|
|
|
<?php
|
|
|
|
|
namespace app\server;
|
|
|
|
|
|
|
|
|
|
use app\model\Orders;
|
|
|
|
|
use support\Log;
|
|
|
|
|
use support\Redis;
|
|
|
|
|
|
|
|
|
|
class Meituan {
|
|
|
|
|
|
|
|
|
|
private $cookie = '';
|
|
|
|
|
private $gate = 'https://lvyou.meituan.com';
|
2024-07-28 16:50:38 +08:00
|
|
|
|
public $totalPage = 6;
|
2024-09-04 21:03:05 +08:00
|
|
|
|
public $os;
|
2024-09-20 10:39:29 +08:00
|
|
|
|
private $tryTimes = 0;
|
2024-06-24 11:52:30 +08:00
|
|
|
|
|
2024-09-04 21:03:05 +08:00
|
|
|
|
public function __construct($os = 1)
|
2024-06-24 11:52:30 +08:00
|
|
|
|
{
|
2024-09-04 21:03:05 +08:00
|
|
|
|
$this->os = $os;
|
2024-06-24 11:52:30 +08:00
|
|
|
|
$this->cookie = $this->_cookie();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public function login() {
|
2024-08-19 11:33:54 +08:00
|
|
|
|
|
2024-06-24 11:52:30 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public function voucher($check_sn) {
|
|
|
|
|
|
|
|
|
|
//https://lvyou.meituan.com/nib/trade/b/voucher/show?voucherCode=130949862550187&yodaReady=h5&csecplatform=4&csecversion=2.4.0
|
|
|
|
|
|
|
|
|
|
//https://lvyou.meituan.com/nib/trade/b/voucher/show?voucherCode=130949862550187&yodaReady=h5&csecplatform=4&csecversion=2.4.0
|
|
|
|
|
$res = $this->_curl('/nib/trade/b/voucher/show',[
|
|
|
|
|
'voucherCode' => $check_sn,
|
|
|
|
|
'yodaReady' => 'h5',
|
|
|
|
|
'csecplatform' => '4',
|
|
|
|
|
'csecversion' => '2.4.0'
|
|
|
|
|
]);
|
|
|
|
|
|
|
|
|
|
return $res;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public function get($page, $start = null, $end = null, $orderId = '') {
|
|
|
|
|
|
|
|
|
|
if(empty($start) || empty($end)) {
|
|
|
|
|
$start = date('Y-m-d 00:00:00');
|
|
|
|
|
$end = date('Y-m-d 23:59:59');
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$start = strtotime($start) * 1000;
|
|
|
|
|
$end = strtotime($end) * 1000 +999;
|
|
|
|
|
|
|
|
|
|
if($orderId) {
|
|
|
|
|
$start = $end = null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$params = [
|
|
|
|
|
'page' => $page,
|
2024-09-04 21:03:05 +08:00
|
|
|
|
'count' => 50,
|
2024-06-24 11:52:30 +08:00
|
|
|
|
'orderId' => $orderId,
|
|
|
|
|
'productId' => '',
|
|
|
|
|
'orderTimeTo' => $end ?? '',
|
|
|
|
|
'travelTimeTo' => '',
|
|
|
|
|
'orderTimeFrom' => $start ?? '',
|
|
|
|
|
'travelTimeFrom' => '',
|
|
|
|
|
'yodaReady' => '',
|
|
|
|
|
'h5' => '',
|
|
|
|
|
'csecplatform' => 4,
|
|
|
|
|
'csecversion' => '2.4.0',
|
|
|
|
|
];
|
|
|
|
|
|
|
|
|
|
$list = $this->_curl('/nib/trade/b/order/search/list', $params);
|
|
|
|
|
|
|
|
|
|
if(empty($list) || $list->code != 0) {
|
|
|
|
|
$list = $this->_curl('/nib/trade/b/order/search/list', $params);
|
|
|
|
|
|
|
|
|
|
if(empty($list) || $list->code != 0) {
|
|
|
|
|
throw new \Exception("美团拉单失败,Err:".json_encode($list));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$_list = [];
|
|
|
|
|
if($list && $list->code == 0 && $list->data && is_array($list->data->orderList)) {
|
|
|
|
|
foreach($list->data->orderList as $order) {
|
2024-09-05 10:55:45 +08:00
|
|
|
|
Log::info("美团 订单号:{$order->orderId} \n\n");
|
2024-06-24 11:52:30 +08:00
|
|
|
|
|
|
|
|
|
if(in_array($order->orderId, ['',''])) {
|
2024-09-05 10:55:45 +08:00
|
|
|
|
Log::info( "异常订单:". $order->orderId);
|
2024-06-24 11:52:30 +08:00
|
|
|
|
sleep(100);
|
|
|
|
|
}
|
2024-09-21 12:18:32 +08:00
|
|
|
|
// 过滤未付款订单
|
|
|
|
|
if ($order->orderStatus == 1) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
2024-06-24 11:52:30 +08:00
|
|
|
|
$item = new Orders();
|
2024-09-04 21:03:05 +08:00
|
|
|
|
$item->os = $this->os;
|
2024-06-24 11:52:30 +08:00
|
|
|
|
$item->sn = $order->orderId;
|
|
|
|
|
$item->product_id = $order->productId;
|
|
|
|
|
$item->product_name = $order->productName;
|
|
|
|
|
$item->category_id = $order->categoryId;
|
|
|
|
|
$item->create_at = $order->createTime;
|
|
|
|
|
$item->travel_date = $order->travelDate;
|
|
|
|
|
$item->mobile = $order->mobile;
|
|
|
|
|
$item->unit_price = $order->unitPrice;
|
|
|
|
|
$item->total_price = $order->totalPrice;
|
|
|
|
|
$item->actual_price = $order->actualPrice;
|
|
|
|
|
$item->quantity = $order->quantity;
|
|
|
|
|
$item->order_status = $order->orderStatus;
|
|
|
|
|
$item->refund_status = $order->refundStatus;
|
|
|
|
|
$item->category_desc = $order->categoryDesc;
|
2024-08-19 11:33:54 +08:00
|
|
|
|
$item->is_zhibo = $order->bizOrderChannel == 5 ? 1 : 0; // 是否直播(5-视频号,3-小程序)
|
2024-06-24 11:52:30 +08:00
|
|
|
|
$item->asset_price = $order->orderStatus == 4 ? $order->totalPrice: 0; //已核销订单,核销金额为订单金额
|
|
|
|
|
|
|
|
|
|
$_list[] = $item;
|
|
|
|
|
}
|
|
|
|
|
}
|
2024-08-19 11:33:54 +08:00
|
|
|
|
|
2024-06-24 11:52:30 +08:00
|
|
|
|
return $_list; //返回半成品
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public function _cookie($data = '') {
|
2024-09-04 21:03:05 +08:00
|
|
|
|
$key = sprintf('Meituan:cookie-%s', $this->os);
|
|
|
|
|
if($data) Redis::set($key, $data);
|
|
|
|
|
return Redis::get($key);
|
2024-06-24 11:52:30 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public function _curl($url, $params, $method = 'GET') {
|
|
|
|
|
|
2024-07-11 17:16:04 +08:00
|
|
|
|
// 请求次数统计
|
|
|
|
|
$key = sprintf("Meituan:ReqiestCount:%s", date('Y-m-d'));
|
|
|
|
|
$requestCount = Redis::incrBy($key, 1);
|
|
|
|
|
if ($requestCount == 1) {
|
|
|
|
|
Redis::expire($key, 604800); // 7天
|
|
|
|
|
}
|
|
|
|
|
|
2024-06-24 11:52:30 +08:00
|
|
|
|
$http = $this->gate.$url;
|
|
|
|
|
if($method == 'GET') {
|
|
|
|
|
$http = $http.'?'. http_build_query($params);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$ch = curl_init($http);
|
2024-08-19 11:33:54 +08:00
|
|
|
|
|
2024-06-24 11:52:30 +08:00
|
|
|
|
$header = [
|
|
|
|
|
'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36',
|
|
|
|
|
'Sec-Ch-Ua-Platform: "Windows"',
|
|
|
|
|
'Host: lvyou.meituan.com',
|
|
|
|
|
'Sec-Ch-Ua: "Google Chrome";v="123", "Not:A-Brand";v="8", "Chromium";v="123"',
|
|
|
|
|
'Accept-Language: zh-CN,zh;q=0.9'
|
|
|
|
|
];
|
|
|
|
|
|
|
|
|
|
curl_setopt($ch, CURLOPT_COOKIE, $this->_cookie());
|
|
|
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
|
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
|
|
|
|
|
if($method == 'POST') {
|
|
|
|
|
curl_setopt($ch, CURLOPT_POST, true);
|
|
|
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
|
|
|
|
|
}
|
|
|
|
|
|
2024-09-05 10:41:25 +08:00
|
|
|
|
$body = curl_exec($ch);
|
2024-09-10 09:41:07 +08:00
|
|
|
|
curl_close($ch);
|
|
|
|
|
$res = json_decode($body);
|
2024-09-10 09:43:28 +08:00
|
|
|
|
if (!isset($res->code) || $res->code != 0) {
|
2024-09-09 22:43:53 +08:00
|
|
|
|
Log::info('os:' . $this->os);
|
|
|
|
|
Log::info('http:' . $http);
|
|
|
|
|
Log::info('body:' . $body);
|
2024-09-20 10:39:29 +08:00
|
|
|
|
|
|
|
|
|
if ($this->tryTimes > 1) {
|
|
|
|
|
(new ThirdApiService())->weComNotice($this->os);
|
|
|
|
|
}
|
|
|
|
|
$this->tryTimes++;
|
2024-09-09 22:43:53 +08:00
|
|
|
|
}
|
2024-09-10 09:41:07 +08:00
|
|
|
|
return $res;
|
2024-06-24 11:52:30 +08:00
|
|
|
|
}
|
|
|
|
|
}
|