xialei пре 1 година
родитељ
комит
31eac7c0bf
1 измењених фајлова са 626 додато и 0 уклоњено
  1. 626 0
      app/traits/GongApiRequestBefen.php

+ 626 - 0
app/traits/GongApiRequestBefen.php

@@ -0,0 +1,626 @@
1
+<?php
2
+
3
+
4
+namespace app\traits;
5
+
6
+use think\facade\Cache;
7
+use think\facade\Db;
8
+use think\facade\Log;
9
+
10
+trait GongApiRequestBefen
11
+{
12
+    //接口文档:https://kdocs.cn/l/cov4HdLPYVgV
13
+    private static $path = 'https://www.douhuomall.com';
14
+//    private static $app_id = 'YS112May13bb673b251a';
15
+//    private static $app_secret = '38971362a8965c9135cb147d53e52706';
16
+//    private static $mobile = '13911251783';
17
+    private static $app_id = 'YS3a8ab661406e47bb86';
18
+    private static $app_secret = '41d8b8e1dd9a454a1abc4534297e33c3';
19
+    private static $mobile = '17855366921';
20
+
21
+    public static function get_access_token(){
22
+        $url = '/api/noAuth/access_token';
23
+        $time = time();
24
+        $body = [
25
+            'app_id' => self::$app_id,
26
+            'sign' => self::getSign($time),
27
+            'mobile' => self::$mobile,
28
+            'timestamp' => $time
29
+        ];
30
+        $res = self::curl_post(self::$path.$url,$body);
31
+        if($res['error_code'] == 0){
32
+            Cache::set('gong_access_token', $res['result']['access_token'], 23*60*60);// 将取到的token存入redis方便下次使用
33
+            return $res['result']['access_token'];
34
+        }
35
+        return false;
36
+    }
37
+
38
+    public static function access_token(){
39
+        $gong_access_token = Cache::get('gong_access_token');
40
+        $url = '/api/category/get_list';
41
+        $body = ['access_token' => $gong_access_token];
42
+        $res = self::curl_post(self::$path.$url,$body);
43
+        if(!$gong_access_token || ($res['error_code'] == 1001)){
44
+            Cache::delete('gong_access_token');
45
+            $gong_access_token = self::get_access_token();
46
+        }
47
+        return $gong_access_token;
48
+    }
49
+
50
+    //分类
51
+    public static function get_category(){
52
+        $url = '/api/category/get_list';
53
+        $body = [
54
+            'access_token' => self::access_token(),
55
+        ];
56
+        $res = self::curl_post(self::$path.$url,$body);
57
+        if($res['error_code'] == 1002 && $res['error_msg'] == '会话不存在'){
58
+            return 1002;
59
+        }
60
+        if($res['error_code'] == 0){
61
+            return $res['result'];
62
+        }
63
+        return false;
64
+    }
65
+
66
+    /**
67
+     * 商品列表
68
+     * @param int $page 页数
69
+     * @param int $limit 每页数量
70
+     * @return array|boolean
71
+     * @author lin
72
+     * @created 2022年5月19日11:31:59
73
+     */
74
+    public static function get_goods_list($page=1,$limit=50){
75
+        $url = '/api/goods/get_spuid_list';
76
+        $body = [
77
+            'access_token' => self::access_token(),
78
+            'page' => $page,
79
+            'limit' => $limit
80
+        ];
81
+        $res = self::curl_post(self::$path.$url,$body);
82
+        if($res['error_code'] == 0){
83
+            return $res['result'];
84
+        }
85
+        return false;
86
+    }
87
+
88
+    /**
89
+     * 商品详情
90
+     * @param array $spu_id 商品spu_id
91
+     * @return array|boolean
92
+     * @author lin
93
+     * @created 2022年5月19日11:31:59
94
+     */
95
+    public static function get_goods_info($spu_id){
96
+        $url = '/api/goods/get_spuId_info';
97
+        $body = [
98
+            'access_token' => self::access_token(),
99
+            'spu_id' => $spu_id,
100
+        ];
101
+        $res = self::curl_post(self::$path.$url,$body);
102
+        if ($res['error_code'] == 2001) {
103
+            return $res;
104
+        }
105
+        if($res['error_code'] == 0){
106
+            return $res['result'];
107
+        }
108
+        return false;
109
+    }
110
+
111
+    /**
112
+     * 商品规格
113
+     * @param array $spu_id 商品spu_id
114
+     * @return array|boolean
115
+     * @author lin
116
+     * @created 2022年5月19日11:31:59
117
+     */
118
+    public static function get_sku($spu_id){
119
+        $url = '/api/goods/get_skuId_info';
120
+        $body = [
121
+            'access_token' => self::access_token(),
122
+            'spu_id' => $spu_id
123
+        ];
124
+        $res = self::curl_post(self::$path.$url,$body);
125
+        if($res['error_code'] == 0){
126
+            return $res['result'];
127
+        }
128
+        return false;
129
+    }
130
+
131
+    /**
132
+     * 商品价格
133
+     * @param string $sku_id 商品skuid,[‘984783’,’984784’]
134
+     * @return array|boolean
135
+     * @author lin
136
+     * @created 2022年5月19日11:31:59
137
+     */
138
+    public static function get_price($sku_id){
139
+        $url = '/api/goods/sell_price';
140
+        $body = [
141
+            'access_token' => self::access_token(),
142
+            'skuid' => $sku_id
143
+        ];
144
+        $res = self::curl_post(self::$path.$url,$body);
145
+        if($res['error_code'] == 0){
146
+            return $res['result'];
147
+        }
148
+        return false;
149
+    }
150
+
151
+    /**
152
+     * 商品是否有货
153
+     * @param int $sku_id 商品sku_id
154
+     * @param int $address_id 地址id(区id或者接到id)
155
+     * @param int $goods_num 商品数量
156
+     * @return array|boolean
157
+     * @author lin
158
+     * @created 2022年5月19日11:31:59
159
+     */
160
+    public static function stock($sku_id,$address_id,$goods_num){
161
+        $url = '/api/goods/stock';
162
+        $body = [
163
+            'access_token' => self::access_token(),
164
+            'sku_id' => $sku_id,
165
+            'address_id' => $address_id,
166
+            'goods_num' => $goods_num
167
+        ];
168
+        $res = self::curl_post(self::$path.$url,$body);
169
+        if($res['error_code'] == 0){
170
+            return $res['result'];
171
+        }
172
+        return false;
173
+    }
174
+
175
+    /**
176
+     * 查询商品上下架
177
+     * @param string $spu_id 商品spu_id
178
+     * @return array|boolean
179
+     * @author lin
180
+     * @created 2022年5月19日11:46:54
181
+     * */
182
+    public static function goods_status($spu_id){
183
+        $url = '/api/goods/status';
184
+        $body = [
185
+            'access_token' => self::access_token(),
186
+            'spu_id' => $spu_id
187
+        ];
188
+        $res = self::curl_post(self::$path.$url,$body);
189
+        if($res['error_code'] == 0){
190
+            return $res['result'];
191
+        }
192
+        return false;
193
+    }
194
+
195
+    /**
196
+     * 查询商品库存
197
+     * @param string $sku_list 商品sku和数量[{"sku_id":123123,"num":1},{"sku_id":123124,"num":1}]
198
+     * @param int $address_id 地址id(区id或街道id)
199
+     * @return array|boolean
200
+     * @author lin
201
+     * @created 2022年5月19日11:46:54
202
+     */
203
+    public static function sku_stock(string $sku_list, int $address_id){
204
+        $url = '/api/goods/find_sku_stock';
205
+        $body = [
206
+            'access_token' => self::access_token(),
207
+            'sku_list' => $sku_list,
208
+            'address_id' => $address_id,
209
+        ];
210
+        $res = self::curl_post(self::$path.$url,$body);
211
+        if($res['error_code'] == 0){
212
+            return $res['result'];
213
+        }
214
+        return false;
215
+    }
216
+
217
+    /**
218
+     * 运费查询(下单前调用,确定可售)
219
+     * @param string $address_id 地址id
220
+     * @param array $sku_id sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
221
+     * @return array|boolean
222
+     * @author lin
223
+     * @created 2022年5月19日11:46:54
224
+     */
225
+    public static function freight(string $address_id, array $sku_id){
226
+        $url = '/api/order/freight';
227
+        $body = [
228
+            'access_token' => self::access_token(),
229
+            'address_id' => $address_id,
230
+            'sku_list' => $sku_id
231
+        ];
232
+        $res = self::curl_post(self::$path.$url,$body);
233
+        if($res['error_code'] == 0){
234
+            return $res['result'];
235
+        }
236
+        return false;
237
+    }
238
+
239
+    /**
240
+     * 正式下单
241
+     * @param string $address_id 地址id
242
+     * @param array $sku_id sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
243
+     * @param string $address 详细地址
244
+     * @param string $third_order 订单id
245
+     * @param string $other 备注
246
+     * @param string $receiver 收货人
247
+     * @param string $receiver_phone 收货人手机号
248
+     * @return array|boolean
249
+     * @author lin
250
+     * @created 2022年5月19日13:22:09
251
+     */
252
+    public static function submit(string $address_id, array $sku_id, string $address, string $third_order, string $other, string $receiver, string $receiver_phone){
253
+        $url = '/api/order/submit';
254
+        $body = [
255
+            'access_token' => self::access_token(),
256
+            'address_id' => $address_id,
257
+            'sku_list' => $sku_id,
258
+            'address' => $address,
259
+            'third_order' => $third_order,
260
+            'other' => $other,
261
+            'receiver' => $receiver,
262
+            'receiver_phone' => $receiver_phone
263
+        ];
264
+//        Db::name('log')->insert(['data'=>'供应链发货-------2:']);
265
+        $res = self::curl_post(self::$path.$url,$body);
266
+        return $res;
267
+    }
268
+
269
+    /**
270
+     * 手动发货
271
+     * @param string $out_order_no 订单编号
272
+     * @param string $logistics_number 物流单号
273
+     * @param string $logistics_company 物流名称
274
+     * @return string|boolean 订单状态值 0失败 1待付款 2待发货 3待收货 4已完成 5已取消 6售后中 7售后完成8拒收
275
+     * @author lin
276
+     * @created 2022年5月19日11:46:54
277
+     */
278
+    public static function order_send(string $out_order_no, string $logistics_company, string $logistics_number){
279
+        $url = '/api/order/send';
280
+        $body = [
281
+            'access_token' => self::access_token(),
282
+            'out_order_no' => $out_order_no,
283
+            'logistics_number' => $logistics_number,
284
+            'logistics_company' => $logistics_company
285
+        ];
286
+        $res = self::curl_post(self::$path.$url,$body);
287
+        if($res['error_code'] == 0){
288
+            return $res['result'];
289
+        }
290
+        return false;
291
+    }
292
+
293
+    /**
294
+     * 查询订单状态
295
+     * @param string $out_order_no 订单编号
296
+     * @return string|boolean 订单状态值 0失败 1待付款 2待发货 3待收货 4已完成 5已取消 6售后中 7售后完成8拒收
297
+     * @author lin
298
+     * @created 2022年5月19日11:46:54
299
+     */
300
+    public static function order_status(string $out_order_no){
301
+        $url = '/api/order/status';
302
+        $body = [
303
+            'access_token' => self::access_token(),
304
+            'out_order_no' => $out_order_no,
305
+        ];
306
+        $res = self::curl_post(self::$path.$url,$body);
307
+        if($res['error_code'] == 0){
308
+            return $res['result'];
309
+        }
310
+        return false;
311
+    }
312
+
313
+    /**
314
+     * 查询订单详情
315
+     * @param string $out_order_no 订单编号
316
+     * @return array|boolean
317
+     * @author lin
318
+     * @created 2022年5月19日11:46:54
319
+     */
320
+    public static function order_details(string $out_order_no){
321
+        $url = '/api/order/details';
322
+        $body = [
323
+            'access_token' => self::access_token(),
324
+            'out_order_no' => $out_order_no,
325
+        ];
326
+        $res = self::curl_post(self::$path.$url,$body);
327
+        if($res['error_code'] == 0){
328
+            return $res['result'];
329
+        }
330
+        return false;
331
+    }
332
+
333
+    /**
334
+     * 查询配送信息
335
+     * @param string $out_order_no 订单编号
336
+     * @return array|boolean
337
+     * @author lin
338
+     * @created 2022年5月19日11:46:54
339
+     */
340
+    public static function order_track(string $out_order_no){
341
+        $url = '/api/order/track';
342
+        $body = [
343
+            'access_token' => self::access_token(),
344
+            'out_order_no' => $out_order_no,
345
+        ];
346
+        $res = self::curl_post(self::$path.$url,$body);
347
+        if($res['error_code'] == 0){
348
+            return $res['result'];
349
+        }
350
+        return false;
351
+    }
352
+
353
+
354
+    /**
355
+     * 确认收货
356
+     * @param string $out_order_no 订单编号
357
+     * @return array|boolean
358
+     * @author lin
359
+     * @created 2022年5月19日11:46:54
360
+     */
361
+    public static function confirm_received(string $out_order_no){
362
+        $url = '/api/order/confirm_received';
363
+        $body = [
364
+            'access_token' => self::access_token(),
365
+            'out_order_no' => $out_order_no,
366
+        ];
367
+        $res = self::curl_post(self::$path.$url,$body);
368
+        if($res['error_code'] == 0){
369
+            return $res['result'];
370
+        }
371
+        return false;
372
+    }
373
+
374
+    /**
375
+     * 查询商品是否可售后属性
376
+     * @param string $out_order_no 订单编号
377
+     * @return array|boolean
378
+     * @author lin
379
+     * @created 2022年5月19日11:46:54
380
+     */
381
+    public static function after_is_can(string $out_order_no){
382
+        $url = '/api/after/is_can   ';
383
+        $body = [
384
+            'access_token' => self::access_token(),
385
+            'out_order_no' => $out_order_no,
386
+        ];
387
+        $res = self::curl_post(self::$path.$url,$body);
388
+        if($res['error_code'] == 0){
389
+            return $res['result'];
390
+        }
391
+        return false;
392
+    }
393
+
394
+    /**
395
+     * 申请售后
396
+     * @param string $out_order_no 订单编号
397
+     * @param string $customer_expect 1-退货。2-换货
398
+     * @param string $question_desc 申请理由
399
+     * @param array $sku_list 多商品规格
400
+     * @param string $img 退货图片json['',''],链接
401
+     * @return array|boolean
402
+     * @author lin
403
+     * @created 2022年5月19日11:46:54
404
+     */
405
+    public static function after_create_apply(string $out_order_no, string $customer_expect, string $question_desc, array $sku_list, string $img){
406
+        $url = '/api/after/create_apply';
407
+        $body = [
408
+            'access_token'  => self::access_token(),
409
+            'plat_order_no' => $out_order_no,
410
+            'after_type'    => $customer_expect,
411
+            'explain'       => $question_desc,
412
+            'sku_list'      => $sku_list,
413
+            'img'           => $img
414
+        ];
415
+        $res = self::curl_post(self::$path.$url,$body);
416
+        return $res;
417
+    }
418
+
419
+    /**
420
+     * 申请售后
421
+     * @param string $order_goods_id 订单商品id
422
+     * @param string $out_order_no 系统订单号
423
+     * @param string $after_type 1=未收货退款,2=退货退款,3=换货补发,4=不退货仅退款
424
+     * @param string $explain 售后原因
425
+     * @param string $after_num 售后数量
426
+     * @return array|boolean
427
+     * @author lin
428
+     * @created 2022年5月19日11:46:54
429
+     */
430
+    public static function apply_after_sales(string $order_goods_id,string $out_order_no, string $after_type, string $explain, string $after_num){
431
+        $url = '/api/After/applyAfterSales';
432
+        $body = [
433
+            'access_token'   => self::access_token(),
434
+            'order_goods_id' => $order_goods_id,
435
+            'after_type'     => $after_type,
436
+            'after_num'      => $after_num,
437
+            'explain'        => $explain,
438
+            'plat_order_no'  => $out_order_no,
439
+        ];
440
+        $res = self::curl_post(self::$path.$url,$body);
441
+        return $res;
442
+    }
443
+
444
+
445
+    /**
446
+     * 查询订单是否可售后
447
+     * @param string $out_order_no 系统订单号
448
+     * @return mixed|string
449
+     */
450
+    public static function is_can_after(string $out_order_no){
451
+        $url = '/api/After/isCanAfter';
452
+        $body = [
453
+            'access_token'   => self::access_token(),
454
+            'order_goods_id' => '',
455
+            'plat_order_no'  => $out_order_no,
456
+        ];
457
+        $res = self::curl_post(self::$path.$url,$body);
458
+        return $res;
459
+    }
460
+
461
+    /**
462
+     * 售后订单状态
463
+     * @param string $after_sn 售后订单号
464
+     * @return array|boolean
465
+     */
466
+    public static function after_status_new(string $after_sn){
467
+        $url = '/api/after/afterStatus';
468
+        $body = [
469
+            'access_token' => self::access_token(),
470
+            'plat_after_no' => $after_sn
471
+        ];
472
+        return self::curl_post(self::$path.$url,$body);
473
+
474
+    }
475
+
476
+    /**
477
+     * 售后订单状态
478
+     * @param string $after_sn 售后订单号
479
+     * @return array|boolean
480
+     */
481
+    public static function after_status(string $after_sn){
482
+        $url = '/api/after/status';
483
+        $body = [
484
+            'access_token' => self::access_token(),
485
+            'after_sn' => $after_sn
486
+        ];
487
+        return self::curl_post(self::$path.$url,$body);
488
+
489
+    }
490
+
491
+    /**
492
+     * 退换货发货信息
493
+     * @param string $after_sn 售后订单编号。申请售后接口返回
494
+     * @param string $logistics_company 1-退货。2-换货
495
+     * @param string $logistics_number 申请理由
496
+     * @return string|boolean
497
+     * @author lin
498
+     * @created 2022年5月19日13:40:52
499
+     */
500
+    public static function after_update_send_info(string $after_sn, string $logistics_number, string $logistics_company){
501
+        $url = '/api/after/update_send_info';
502
+        $body = [
503
+            'access_token' => self::access_token(),
504
+            'after_sn' => $after_sn,
505
+            'logistics_company' => $logistics_company,
506
+            'logistics_number' => $logistics_number
507
+        ];
508
+        $res = self::curl_post(self::$path.$url,$body);
509
+        if($res['error_code'] == 0){
510
+            return $res['result'];
511
+        }
512
+        return false;
513
+    }
514
+
515
+    /**
516
+     * 取消申请售后
517
+     * @param string $after_sn 售后订单编号。申请售后接口返回
518
+     * @param string $out_order_no 订单编号
519
+     * @return string|boolean
520
+     * @author lin
521
+     * @created 2022年5月19日13:40:52
522
+     */
523
+    public static function after_cancel_apply(string $after_sn, string $out_order_no){
524
+        $url = '/api/after/cancel_apply';
525
+        $body = [
526
+            'access_token' => self::access_token(),
527
+            'after_sn' => $after_sn,
528
+            'out_order_no' => $out_order_no
529
+        ];
530
+        $res = self::curl_post(self::$path.$url,$body);
531
+        if($res['error_code'] == 0){
532
+            return $res['result'];
533
+        }
534
+        return false;
535
+    }
536
+
537
+    /**
538
+     * 获取地区
539
+     * @param string $code 地区代码,为空查询省级信息,否则查询code的下级
540
+     * @return string|boolean
541
+     * @author lin
542
+     * @created 2022年5月19日13:40:52
543
+     */
544
+    public static function get_region_code(string $code = null){
545
+        $url = '/api/regions/get_region_code';
546
+        $body = [
547
+            'access_token' => self::access_token(),
548
+        ];
549
+        if($code != null) $body['code'] = $code;
550
+        $res = self::curl_post(self::$path.$url,$body);
551
+        if($res['error_code'] == 0){
552
+            return $res['result'];
553
+        }
554
+        return false;
555
+    }
556
+
557
+    /**
558
+     * 获取消息池消息
559
+     * @param int $type 1-订单状态变动, 2-商品详情, 3-sku价格, 4-商品删除, 5-规格状态变更, 6-规格删除, 7-规格详情, 8-商品状态变更
560
+     * @return  array|boolean
561
+     * @author lin
562
+     * @created 2022年5月19日13:55:07
563
+     */
564
+    public static function MessagePool(int $type){
565
+        $url = '/api/MessagePool/get';
566
+        $body = [
567
+            'access_token' => self::access_token(),
568
+            'type' => $type,
569
+        ];
570
+        $res = self::curl_post(self::$path.$url,$body);
571
+        if($res['error_code'] == 0){
572
+            return $res['result'];
573
+        }
574
+        return false;
575
+    }
576
+
577
+    public static function getSign($time){
578
+        //按照以下顺序将字符串拼接起来 app_id+mobile+timestamp+app_secret 再用md5加密
579
+        return md5(self::$app_id.self::$mobile.$time.self::$app_secret);
580
+    }
581
+
582
+    //通过curl发送post请求带body传参
583
+    public static function curl_post($url, $postFields = null, $header = array())
584
+    {
585
+
586
+//        Db::name('log')->insert(['data'=>'供应链发货-------3:']);
587
+        if ($url != 'https://www.douhuomall.com/api/category/get_list') {
588
+            Db::name("log")->insert(array('data' => '供应链【' . $url . '】body:' . json_encode($postFields)));//日志记录
589
+        }
590
+        $curl = curl_init();
591
+        //设置抓取的url
592
+        curl_setopt($curl, CURLOPT_URL, $url);
593
+        curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST");
594
+        curl_setopt($curl, CURLOPT_TIMEOUT, 30);
595
+        curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($postFields));
596
+//        curl_setopt($curl, CURLOPT_TIMEOUT_MS, 500);
597
+        curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
598
+//        curl_setopt($curl, CURLOPT_HEADER, 1);
599
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
600
+        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
601
+        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
602
+        //执行命令
603
+        $data = curl_exec($curl);
604
+        if(is_null(json_decode($data))){
605
+            $data = strstr($data,'{');
606
+        }
607
+        if ($url != 'https://www.douhuomall.com/api/category/get_list'){
608
+            log::info('供应链【'.$url.'】body:'.json_encode($postFields,JSON_UNESCAPED_UNICODE));
609
+            log::info('供应链【'.$url.'】headerArray:'.json_encode($header,JSON_UNESCAPED_UNICODE));
610
+            log::info('供应链【'.$url.'】data:'.$data);
611
+//            Db::name("log")->insert(array('data'=>'供应链【'.$url.'】body:'.json_encode($postFields)));//日志记录
612
+//            Db::name("log")->insert(array('data'=>'供应链【'.$url.'】headerArray:'.json_encode($header)));//日志记录
613
+//            Db::name("log")->insert(array('data'=>'供应链【'.$url.'】data:'.$data));//日志记录
614
+//            dump($data);
615
+        }
616
+        // 显示错误信息
617
+        if (curl_error($curl)) {
618
+            return curl_error($curl);
619
+        } else {
620
+            curl_close($curl);
621
+            return json_decode($data, true);
622
+        }
623
+    }
624
+
625
+
626
+}