Просмотр исходного кода

Merge branch 'master' into huangfamily

family 1 год назад
Родитель
Сommit
91e3dc6ea8

+ 48 - 6
app/common/repositories/store/order/StoreOrderRepository.php

@@ -982,7 +982,7 @@ class StoreOrderRepository extends BaseRepository
982
                             }
982
                             }
983
 
983
 
984
                         } else if (!empty($array_fzone_paytype['type'] == 'a1')) {
984
                         } else if (!empty($array_fzone_paytype['type'] == 'a1')) {
985
-                            //生活 VR支付
985
+                            //会员专区 VR支付
986
 
986
 
987
                             $user_data = Db::name("user")->where("uid", $uid)->find();
987
                             $user_data = Db::name("user")->where("uid", $uid)->find();
988
 
988
 
@@ -9363,6 +9363,13 @@ class StoreOrderRepository extends BaseRepository
9363
         //如果是会员专区就即刻到账
9363
         //如果是会员专区就即刻到账
9364
         $order_from_mer = Db::name('store_order')->where("order_id", $order_id)->find();
9364
         $order_from_mer = Db::name('store_order')->where("order_id", $order_id)->find();
9365
 
9365
 
9366
+        //查询支付方式
9367
+        $array_fzone_paytype = json_decode($order_from_mer['fzone_paytype'],true);
9368
+        $pay_type = 3;//默认是微信
9369
+        if($array_fzone_paytype['note'] != "现金"){
9370
+            $pay_type = 4;
9371
+        }
9372
+
9366
         $sm_status = 0;//储存当前用户是否有实名的状态
9373
         $sm_status = 0;//储存当前用户是否有实名的状态
9367
 
9374
 
9368
         if ($order_from_mer['mer_id'] == 496) {
9375
         if ($order_from_mer['mer_id'] == 496) {
@@ -9381,13 +9388,48 @@ class StoreOrderRepository extends BaseRepository
9381
 
9388
 
9382
                         $sm_status = 1;
9389
                         $sm_status = 1;
9383
                         $ds = 1;
9390
                         $ds = 1;
9384
-                        $order_from_mer = Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 1]);
9391
+                        Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 1]);
9392
+
9393
+                        //添加养老金到公证处日志
9394
+                        $ylj_data_log = [
9395
+                            'user_name' => $get_cer_datas['user_name'],
9396
+                            "mobile" => $get_cer_datas['mobile'],
9397
+                            "user_card" => $get_cer_datas['user_card'],//身份证
9398
+                            "pension" => $num,//养老金额度
9399
+                            "out_trade_no" => $order_from_mer['order_sn'],//订单号
9400
+                            "account_type" =>  $pay_type,//支付方式(3:微信,4:组合)
9401
+                            "order_type" => 2,//订单类型(2:)
9402
+                            "pay_time" => date('Y-m-d H:i:s'),
9403
+                            "create_time" => date('Y-m-d H:i:s'),
9404
+                            "update_time" => date('Y-m-d H:i:s'),
9405
+                            "uid" => $uid,
9406
+                        ];
9385
 
9407
 
9386
-                    } else {
9387
-                        $order_from_mer = Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 0]);
9388
-                    }
9389
-                }
9408
+                        Db::name('gzc_logs')->insert($ylj_data_log);
9409
+
9410
+                    } 
9411
+                }else {
9412
+                    Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 0]);
9413
+
9414
+                      //添加养老金到公证处日志
9415
+                    $ylj_data_log = [
9416
+                    //'user_name' => $get_cer_datas['user_name'],
9417
+                    //"mobile" => $get_cer_datas['mobile'],
9418
+                    //"user_card" => $get_cer_datas['user_card'],//身份证
9419
+                    "pension" => $num,//养老金额度
9420
+                    "out_trade_no" => $order_from_mer['order_sn'],//订单号
9421
+                    "account_type" =>  $pay_type,//支付方式(3:微信,4:组合)
9422
+                    "order_type" => 2,//订单类型(2:)
9423
+                    "pay_time" => date('Y-m-d H:i:s'),
9424
+                    "create_time" => date('Y-m-d H:i:s'),
9425
+                    "update_time" => date('Y-m-d H:i:s'),
9426
+                    "uid" => $uid,
9427
+
9428
+                    ];
9390
 
9429
 
9430
+                    Db::name('gzc_logs')->insert($ylj_data_log);
9431
+
9432
+                }
9391
 
9433
 
9392
             }
9434
             }
9393
 
9435
 

+ 16 - 18
app/controller/admin/gong/Goods.php

@@ -105,8 +105,6 @@ class Goods extends BaseController
105
     // 获取选品库中全部、已加入3号库、未加入3号库的数量
105
     // 获取选品库中全部、已加入3号库、未加入3号库的数量
106
     public function getStatusFilter()
106
     public function getStatusFilter()
107
     {
107
     {
108
-   
109
-   
110
         // 获取全部数据
108
         // 获取全部数据
111
         $allNum =  Db::name('douhuomall')->whereIn('status', [0, 1])->count();
109
         $allNum =  Db::name('douhuomall')->whereIn('status', [0, 1])->count();
112
         // 获取已加入3号库的数据
110
         // 获取已加入3号库的数据
@@ -116,21 +114,21 @@ class Goods extends BaseController
116
 
114
 
117
 
115
 
118
         $res = [
116
         $res = [
119
-            [
120
-                'type' => 0,
121
-                'title' => '全部',
122
-                'count' => $allNum
123
-            ],
124
-            [
125
-                'type' => 1,
126
-                'title' => '已加入3号库',
127
-                'count' => $joinNum
128
-            ],
129
-            [
130
-                'type' => 2,
131
-                'title' => '未加入3号库',
132
-                'count' => $notJoinNum
133
-            ]
117
+            // [
118
+            //     'type' => 0,
119
+            //     'title' => '全部',
120
+            //     'count' => $allNum
121
+            // ],
122
+            // [
123
+            //     'type' => 1,
124
+            //     'title' => '已加入3号库',
125
+            //     'count' => $joinNum
126
+            // ],
127
+            // [
128
+            //     'type' => 2,
129
+            //     'title' => '未加入3号库',
130
+            //     'count' => $notJoinNum
131
+            // ]
134
         ];
132
         ];
135
         return app('json')->success($res);
133
         return app('json')->success($res);
136
     }
134
     }
@@ -277,7 +275,7 @@ class Goods extends BaseController
277
                 'spu_id'=>$data['spu_id'],
275
                 'spu_id'=>$data['spu_id'],
278
                 'temp_id' => 105,
276
                 'temp_id' => 105,
279
                 'plate_mer_profit' => $data['mer_profit'],
277
                 'plate_mer_profit' => $data['mer_profit'],
280
-		'concession_pri' => $data['mer_profit'],
278
+		        'concession_pri' => $data['mer_profit'],
281
                 'yanglaojin_scale' => $yanglaojin_scale
279
                 'yanglaojin_scale' => $yanglaojin_scale
282
             ];
280
             ];
283
             $insert_id=Db::name('store_product')->insertGetId($product_insert_data);
281
             $insert_id=Db::name('store_product')->insertGetId($product_insert_data);

+ 8 - 1
app/controller/api/Auth.php

@@ -449,7 +449,7 @@ class Auth extends BaseController
449
         if (!$account)
449
         if (!$account)
450
             return app('json')->fail('请输入账号');
450
             return app('json')->fail('请输入账号');
451
         $user = $repository->accountByUser($this->request->param('phone'));
451
         $user = $repository->accountByUser($this->request->param('phone'));
452
-        //13231658486 周总
452
+        //13231658486 周总 张玉庭 13839803521 13083849831
453
         if($account != 15528079265){
453
         if($account != 15528079265){
454
             if (!$user)
454
             if (!$user)
455
                 return app('json')->fail('账号或密码错误');
455
                 return app('json')->fail('账号或密码错误');
@@ -742,6 +742,13 @@ class Auth extends BaseController
742
         //积分
742
         //积分
743
         $data['score']=set_price_rtrim($data['score']);
743
         $data['score']=set_price_rtrim($data['score']);
744
         //2025新增 贡献值,红包,京东,vr,复购金
744
         //2025新增 贡献值,红包,京东,vr,复购金
745
+
746
+        if( $user['user_group'] <= 2 ){
747
+            $data['contribute'] =  $user['contribute'] + $user['per_contribute'];
748
+        }else{
749
+            $data['contribute'] =  $user['contribute'];
750
+        }
751
+
745
         $date['contribute']=set_price_rtrim($data['contribute']);//贡献值
752
         $date['contribute']=set_price_rtrim($data['contribute']);//贡献值
746
         $data['repurchase_price']=set_price_rtrim($data['repurchase_price']);//复购余额
753
         $data['repurchase_price']=set_price_rtrim($data['repurchase_price']);//复购余额
747
         $data['jingdou']=set_price_rtrim($data['jingdou']);//京豆
754
         $data['jingdou']=set_price_rtrim($data['jingdou']);//京豆

+ 52 - 8
app/controller/api/Notify.php

@@ -1525,6 +1525,13 @@ class Notify
1525
         //如果是会员专区就即刻到账
1525
         //如果是会员专区就即刻到账
1526
         $order_from_mer = Db::name('store_order')->where("order_id",$order_id)->find();
1526
         $order_from_mer = Db::name('store_order')->where("order_id",$order_id)->find();
1527
 
1527
 
1528
+         //查询支付方式
1529
+         $array_fzone_paytype = json_decode($order_from_mer['fzone_paytype'],true);
1530
+         $pay_type = 3;//默认是微信
1531
+         if($array_fzone_paytype['note'] != "现金"){
1532
+             $pay_type = 4;
1533
+         }
1534
+
1528
         $sm_status = 0;//储存当前用户是否有实名的状态
1535
         $sm_status = 0;//储存当前用户是否有实名的状态
1529
 
1536
 
1530
         if($order_from_mer['mer_id'] == 496){
1537
         if($order_from_mer['mer_id'] == 496){
@@ -1536,18 +1543,55 @@ class Notify
1536
             //如果是会员区的养老金,查看是否有实名,如果实名就改变订单状态和user-bill的状态
1543
             //如果是会员区的养老金,查看是否有实名,如果实名就改变订单状态和user-bill的状态
1537
             if($comm_order_type == 5){
1544
             if($comm_order_type == 5){
1538
 
1545
 
1546
+              
1539
                 //当前用户是否有实名,然后改变user_bill和order_store的gzc状态
1547
                 //当前用户是否有实名,然后改变user_bill和order_store的gzc状态
1540
-                $get_cer_datas = Db::name('user_certification')->where("uid",$uid)->find();
1541
-                if(!empty($get_cer_datas)){
1542
-                    if(!empty($get_cer_datas['user_card'])){
1548
+                $get_cer_datas = Db::name('user_certification')->where("uid", $uid)->find();
1549
+                if (!empty($get_cer_datas)) {
1550
+                    if (!empty($get_cer_datas['user_card'])) {
1543
 
1551
 
1544
                         $sm_status = 1;
1552
                         $sm_status = 1;
1545
                         $ds = 1;
1553
                         $ds = 1;
1546
-                        $order_from_mer = Db::name('store_order')->where("order_id",$order_id)->update(['gzc'=>1]);
1547
-                       
1548
-                    }else{
1549
-                        $order_from_mer = Db::name('store_order')->where("order_id",$order_id)->update(['gzc'=>0]);
1550
-                    }
1554
+                        Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 1]);
1555
+
1556
+                        //添加养老金到公证处日志
1557
+                        $ylj_data_log = [
1558
+                            'user_name' => $get_cer_datas['user_name'],
1559
+                            "mobile" => $get_cer_datas['mobile'],
1560
+                            "user_card" => $get_cer_datas['user_card'],//身份证
1561
+                            "pension" => $num,//养老金额度
1562
+                            "out_trade_no" =>  $order_from_mer['order_sn'],//订单号
1563
+                            "account_type" =>  $pay_type,//支付方式(3:微信,4:组合)
1564
+                            "order_type" => 2,//订单类型(2:)
1565
+                            "pay_time" => date('Y-m-d H:i:s'),
1566
+                            "create_time" => date('Y-m-d H:i:s'),
1567
+                            "update_time" => date('Y-m-d H:i:s'),
1568
+                            "uid" => $uid,
1569
+                        ];
1570
+
1571
+                        Db::name('gzc_logs')->insert($ylj_data_log);
1572
+
1573
+                    } 
1574
+                }else {
1575
+                    Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 0]);
1576
+
1577
+                      //添加养老金到公证处日志
1578
+                    $ylj_data_log = [
1579
+                    //'user_name' => $get_cer_datas['user_name'],
1580
+                    //"mobile" => $get_cer_datas['mobile'],
1581
+                    //"user_card" => $get_cer_datas['user_card'],//身份证
1582
+                    "pension" => $num,//养老金额度
1583
+                    "out_trade_no" =>  $order_from_mer['order_sn'],//订单号
1584
+                    "account_type" =>  $pay_type,//支付方式(3:微信,4:组合)
1585
+                    "order_type" => 2,//订单类型(2:)
1586
+                    "pay_time" => date('Y-m-d H:i:s'),
1587
+                    "create_time" => date('Y-m-d H:i:s'),
1588
+                    "update_time" => date('Y-m-d H:i:s'),
1589
+                    "uid" => $uid,
1590
+
1591
+                    ];
1592
+
1593
+                    Db::name('gzc_logs')->insert($ylj_data_log);
1594
+
1551
                 }
1595
                 }
1552
 
1596
 
1553
                 
1597
                 

+ 243 - 4
app/controller/api/douhuomall/Take.php

@@ -2,18 +2,257 @@
2
 namespace app\controller\api\douhuomall;
2
 namespace app\controller\api\douhuomall;
3
 
3
 
4
 use app\traits\GongApiRequest;
4
 use app\traits\GongApiRequest;
5
+use think\Exception;
6
+use think\facade\Db;
7
+use think\facade\Log;
5
 
8
 
6
 class Take
9
 class Take
7
 {
10
 {
8
 
11
 
9
     use GongApiRequest;
12
     use GongApiRequest;
10
 
13
 
11
-    public function get(){
12
-        //spu_id列表
13
-        $spu_list = GongApiRequest::get_goods_list();
14
-        dump($spu_list);
14
+    public function get_goods_list(){
15
+        try {
16
+            set_time_limit(0);
17
+            $allData = [];
18
+            $page = 1;
19
+            $limit = 100;
20
+            $hasNextPage = true; // 是否有下一页的标志
21
+            while ($hasNextPage) {
22
+                $data = GongApiRequest::get_goods_list($page, $limit);
23
+                if (!$data) {
24
+                    break; // 如果请求失败,停止循环
25
+                }
26
+                $allData = array_merge($allData, $data['list']); // 数据在list键下
27
+                if (!count($data['list']) || count($data['list']) < $limit) {
28
+                    $hasNextPage = false; // 如果没有更多页面,停止循环
29
+                } else {
30
+                    $page++; // 增加页码数
31
+                }
32
+            }
15
 
33
 
34
+            $goods_id_list = [];
35
+            $spu_id_list = Db::name('douhuomall')->column('spu_id');
36
+         
37
+            // 同步到数据库
38
+            foreach ($allData as $key=>$value) {
39
+                sleep(1);
40
+                // if($key != 0) continue;
41
+                $goodsInfo = GongApiRequest::get_goods_info($value['goods_id']);
42
+                if(!$goodsInfo) continue;
43
+
44
+                //图片存放路径
45
+                $targetDir = public_path() . 'images/gong/'.$value['goods_id'].'/';
46
+
47
+                $this->deleteFilesInDirectory($targetDir);
48
+
49
+                //spuId_info商品详细信息处理
50
+                $goodsInfo['cover_url'] = $this->seveImg($value['goods_id'], $goodsInfo['main_img'], $targetDir);
51
+                $goodsInfo['spu_id'] = $goodsInfo['goods_id'];
52
+
53
+                $goodsInfo['detail'] = "";
54
+                $detail_img = $this->seveImg($value['goods_id'], $goodsInfo['detail_img'], $targetDir);
55
+                foreach($detail_img as $img_url){
56
+                    $img_url = "<img src='".$img_url."' />";
57
+                    $goodsInfo['detail'] = $goodsInfo['detail'].$img_url;
58
+                }
59
+
60
+                //sku信息处理
61
+                $skuInfo = $goodsInfo['sku_list'];
62
+                foreach ($skuInfo as $k=>$v) {
63
+                    $skuInfo[$k]['cost_price'] = bcadd($v['plat_price'], bcmul($v['plat_price'], 0.03, 2),2);//成本价格 原来进价的基础上加百分之3
64
+                    $skuInfo[$k]['market_price'] = bcadd($skuInfo[$k]['cost_price'], bcmul($skuInfo[$k]['cost_price'], 0.2, 2),2);//销售价格  售价在成本价格的基础上加百分20
65
+                    $skuInfo[$k]['profit'] = bcdiv($skuInfo[$k]['market_price'], $skuInfo[$k]['cost_price'], 2);
66
+                    $skuInfo[$k]['mer_profit'] = bcsub($skuInfo[$k]['market_price'], $skuInfo[$k]['cost_price'], 2);
67
+                    $skuInfo[$k]['yanglaojin'] = '0.00';
68
+                    if(count($v['attr'])){
69
+                        $skuInfo[$k]['attribute_json'] = $v['attr'];
70
+                    }else{
71
+                        $skuInfo[$k]['attribute_json'] = [['val'=> '默认', 'name'=> '默认']];
72
+                    }
73
+                }
74
+                unset($goodsInfo['sku_list']);
75
+
76
+                $seveData = [
77
+                    'spu_id' => $goodsInfo['spu_id'],
78
+                    'skuId_info' => $skuInfo,
79
+                    'sys_id' => '112',
80
+                    'goods_id' => $goodsInfo['goods_id'],
81
+                    'spuId_info' => $goodsInfo,
82
+                    'sku_id' => $skuInfo[0]['sku_id'] ? $skuInfo[0]['sku_id'] : 0,
83
+                    'status' => $goodsInfo['status'],
84
+                    'cate_ids' => $goodsInfo['cate_ids'],
85
+                    'title' => $goodsInfo['spu_name'],
86
+                    'cxb_cate_id' => 0,   
87
+                ];
88
+                $this->add($seveData);
89
+                $goods_id_list[] = $goodsInfo['spu_id'];
90
+            }
91
+
92
+            $goodsIds = array_diff($spu_id_list, $goods_id_list);
93
+            $this->remove($goodsIds);
94
+            return 'sussess';
95
+        } catch (Exception $e) {
96
+            Log::error('同步数据失败:' . $e->getMessage());
97
+            echo '供应链拉取数据:' . $e->getFile() . ':' . $e->getLine() . '【' . $e->getMessage() . '】';
98
+            return 'error';
99
+        }
100
+    }
101
+
102
+    public function seveImg($goods_id, $img_url, $targetDir)
103
+    {
104
+        if (is_array($img_url)){
105
+            $new_img_url = [];
106
+            foreach ($img_url as $value) {
107
+                $new_img_url[] = $this->seveImgUrl($goods_id, $value, $targetDir);
108
+            }
109
+        }else{  
110
+            $new_img_url = $this->seveImgUrl($goods_id, $img_url, $targetDir);
111
+        }
112
+        return $new_img_url;
113
+    }
114
+
115
+    public function seveImgUrl($goods_id, $remoteImageUrl, $targetDir)
116
+    {
117
+        // 目标路径(确保目录存在)
118
+        $targetDirTow = rand(1000, 10000). $this->upImgName(basename($remoteImageUrl));
119
+        $targetPath = $targetDir . $targetDirTow; // 使用basename获取文件名
120
+        
121
+        // 检查目标目录是否存在,如果不存在则创建
122
+        if (!is_dir($targetDir)) {
123
+            mkdir($targetDir, 0777, true); // 第二个参数是权限,第三个参数是递归创建
124
+        }
125
+        
126
+        // 获取远程图片内容
127
+        $imageContent = file_get_contents($remoteImageUrl);
128
+        
129
+        // 检查是否成功获取内容
130
+        if ($imageContent !== false) {
131
+            // 保存图片到指定路径
132
+            if (file_put_contents($targetPath, $imageContent)) {
133
+                $new_img_url = env('APP_URL').'/images/gong/'.$goods_id.'/'. $targetDirTow;
134
+                return $new_img_url;
135
+            } else {
136
+                echo "保存图片时发生错误。";
137
+                return $remoteImageUrl;
138
+            }
139
+        } else {
140
+            echo "无法获取远程图片内容。";
141
+            return $remoteImageUrl;
142
+        }
16
     }
143
     }
17
 
144
 
18
 
145
 
146
+    public function upImgName($filename)
147
+    {
148
+        $position = strpos($filename, '?');
149
+        if ($position !== false) {
150
+            $filename = substr($filename, 0, $position);
151
+        }
152
+        return $filename;
153
+    }
154
+
155
+    public function deleteFilesInDirectory($dir) {
156
+        if (!is_dir($dir)) return true;
157
+
158
+        // 打开目录
159
+        $files = scandir($dir);
160
+     
161
+        // 遍历目录中的所有文件
162
+        foreach ($files as $file) {
163
+            // 如果是文件(排除 . 和 ..)
164
+            if ($file !== '.' && $file !== '..') {
165
+                $filePath = $dir . '/' . $file;
166
+                // 删除文件
167
+                if (is_file($filePath)) {
168
+                    unlink($filePath);
169
+                }
170
+            }
171
+        }
172
+        return true;
173
+    }
174
+
175
+
176
+    public function add($data)
177
+    {
178
+        $findData = Db::name('douhuomall')->field('id,spu_id,status')->where('spu_id', $data['spu_id'])->find();
179
+        try {
180
+            $data['create_time'] = date('Y-m-d H:i:s');
181
+            $data['update_time'] = date('Y-m-d H:i:s');
182
+            $skuInfo = $this->arrSort($data['skuId_info'], 'cost_price', SORT_ASC);
183
+            $data['cost_price'] = isset($skuInfo[0]['cost_price']) ? $skuInfo[0]['cost_price'] : 0;
184
+            $data['market_price'] = isset($skuInfo[0]['market_price']) ? $skuInfo[0]['market_price'] : 0;
185
+            $data['ot_price'] = isset($skuInfo[0]['retail_price']) ? $skuInfo[0]['retail_price'] : 0;
186
+            $data['mer_profit'] = isset($skuInfo[0]['mer_profit']) ? $skuInfo[0]['mer_profit'] : 0;
187
+            $data['pension'] = isset($skuInfo[0]['yanglaojin']) ? $skuInfo[0]['yanglaojin'] : 0;
188
+            $data['profit'] = empty($data['cost_price']) || empty($data['market_price']) ? 0 : bcdiv($data['market_price'], $data['cost_price'], 2);
189
+            if (empty($findData)) {
190
+                $data['skuId_info'] = json_encode($data['skuId_info']);
191
+                $data['spuId_info'] = json_encode($data['spuId_info']);
192
+                Db::name('douhuomall')->insert($data);
193
+            } else {
194
+                Db::name('douhuomall')->where('spu_id', $findData['spu_id'])->update([
195
+                    'status' => $data['status'],
196
+                    'create_time' => date('Y-m-d H:i:s'),
197
+                    'update_time' => date('Y-m-d H:i:s'),
198
+                    'cost_price' => $data['cost_price'],
199
+                    'market_price' => $data['market_price'],
200
+                    'ot_price' => $data['ot_price'],
201
+                    'mer_profit' => $data['mer_profit'],
202
+                    'pension' => $data['pension'],
203
+                    'profit' => $data['profit'],
204
+                    'skuId_info' => json_encode($data['skuId_info']),
205
+                    'spuId_info' => json_encode($data['spuId_info']),
206
+                    'title' => $data['title'],
207
+                    'cate_ids' => $data['cate_ids'],
208
+                    'cxb_cate_id' => $data['cxb_cate_id']
209
+                ]);
210
+            }
211
+            return true;
212
+        } catch (Exception $e) {
213
+            echo '供应链产品添加:' . $e->getFile() . ':' . $e->getLine() . '【' . $e->getMessage() . '】';
214
+            return false;
215
+        }
216
+    }
217
+    
218
+
219
+    public function remove($goodsIds)
220
+    {
221
+        Db::startTrans();
222
+        try{
223
+            // 删除选品库对应的数据
224
+            Db::name('douhuomall')->whereIn('spu_id', $goodsIds)->update([
225
+                'status' => 3,
226
+                'update_time' => date('Y-m-d H:i:s')
227
+            ]);
228
+            // 删除商品管理对应的数据
229
+            Db::name('store_product')->whereIn('spu_id', $goodsIds)->update([
230
+                'is_del' => 1,
231
+                'is_show' => 0
232
+            ]);
233
+            Db::commit();
234
+            return true;
235
+        } catch (Exception $e) {
236
+            Db::rollback();
237
+            Log::channel("gong")->error('供应链取消商品失败:' . $e->getMessage());
238
+            return false;
239
+        }
240
+    }
241
+
242
+
243
+    /**
244
+     * 二维数组根据某个字段排序
245
+     * @param array $array 要排序的数组
246
+     * @param string $keys   要排序的键字段
247
+     * @param string $sort  排序类型  SORT_ASC     SORT_DESC
248
+     * @return array 排序后的数组
249
+     */
250
+    function arrSort($array, $keys, $sort = SORT_DESC) {
251
+        $keysValue = [];
252
+        foreach ($array as $k => $v) {
253
+            $keysValue[$k] = $v[$keys];
254
+        }
255
+        array_multisort($keysValue, $sort, $array);
256
+        return $array;
257
+    }
19
 }
258
 }

+ 47 - 83
app/controller/api/store/merchant/Taskorder.php

@@ -72,7 +72,7 @@ class Taskorder extends BaseController
72
     public function lst1()
72
     public function lst1()
73
     {
73
     {
74
 
74
 
75
-       
75
+       return;
76
    
76
    
77
         // $user_datas = Db::name("user")->select();//星级等级
77
         // $user_datas = Db::name("user")->select();//星级等级
78
         // foreach($user_datas as $k=>$v){
78
         // foreach($user_datas as $k=>$v){
@@ -89,76 +89,25 @@ class Taskorder extends BaseController
89
     
89
     
90
     //    var_dump($totalPv);return;    
90
     //    var_dump($totalPv);return;    
91
     
91
     
92
-         $ss = $this->getbig_samll_datas(222);
93
-         var_dump($ss);    return;
92
+        // $sf = $this->getStarLevel(221);
93
+ //var_dump($sf);
94
+         // $ss = $this->getbig_samll_datas(221);//222
95
+
96
+          //$ff = $this->getPerformanceOf(221);
97
+         // var_dump($ff);
98
+    //var_dump($ss);   
99
+          // return;
94
       
100
       
95
      
101
      
96
         // $store_product_datas = Db::name('old_user_of_goods_old')->select();
102
         // $store_product_datas = Db::name('old_user_of_goods_old')->select();
97
        
103
        
98
         //$week_record = 45500 + 1400 + 60000; //20250218
104
         //$week_record = 45500 + 1400 + 60000; //20250218
99
         //$week_record =23800 + 60000; //20250222
105
         //$week_record =23800 + 60000; //20250222
100
-        $week_record =64400; //20250301
101
-   
106
+       // $week_record = 64400; //20250301
107
+        $week_record = 10500 + 50000; //20250310
102
     //return;
108
     //return;
103
 
109
 
104
-       // $stock_comm = round($week_record * 0.05 ,2);
105
-     //var_dump($week_record);return;
106
-
107
-        // $team_small_big_amount = $this->getbig_samll_datas(17);//下标0是大部门,下标1是小部门
108
-        // var_dump($team_small_big_amount);return;
109
-
110
-
111
-        //获取股权分红的人
112
-       
113
-        // $GetAllUserPackNum = db::name("old_user_stock")->sum("pack");//计算所有用户的份数总和
114
-        
115
-        // $stockuserdatas = db::name("old_user_stock")->select();//获取所有用户
116
-       
117
-        // if(count($stockuserdatas) > 0){
118
-        //   $one_pack_comm_data = round($stock_comm / $GetAllUserPackNum,2);//获取每份的单佣金
119
-        
120
-        //     foreach ($stockuserdatas as &$v) {
121
-        //           $v['getcomm'] = $v['pack'] * $one_pack_comm_data;
122
-        //           $v['allgetcomm'] =  $v['allgetcomm'] + $v['getcomm'];
123
-        //           $v['update_time'] = time();
124
-                  
125
-        //           // 更新 user_stock 表中的记录
126
-        //           $res = db::name("old_user_stock")->where("id", $v['id'])->update([
127
-        //               'getcomm' => $v['getcomm'],
128
-        //               'allgetcomm' => $v['allgetcomm'],
129
-        //               'update_time' => $v['update_time']
130
-        //           ]);
131
-              
132
-        //           $res1 = Db::name("user")->where("id",$v['user_id'])->inc("total_amount_old",$v['getcomm'])->save();
133
-        //           $res2 = Db::name("user")->where("id",$v['user_id'])->inc("amount_old",$v['getcomm'])->save();
134
-                  
135
-        //        $res =true;
136
-        //           if($res){
137
-        //               $das = $this->change_user_log($v['user_id'],'amount_old',1,$v['getcomm'],"member_award_stock","股权分红入账"."-".$v['pack']);//释放佣金
138
-                    
139
-        //                 //入账星级分红记录表
140
-        //               $week_data = [];
141
-        //               $week_data['user_id'] =  $v['user_id'];
142
-        //               $week_data['user_star_id'] =  0;
143
-        //               $week_data['award_num'] =  0;
144
-        //               $week_data['award_num_sm'] =  0;
145
-        //               $week_data['remark'] =  "股权分红主动执行";
146
-        //               $week_data['week_record'] =  $week_record;
147
-        //               $week_data['all_amount'] =  $stock_comm;
148
-        //               $week_data['radio'] =  2;
149
-        //               $week_data['owner_bill'] =  0;  //总流水金额
150
-        //               $week_data['my_bill'] = 0;  //我的流水
151
-        //               $week_data['create_time'] = time();
152
-                      
153
-        
154
-        //               Db::name("old_user_weekaward")->insert($week_data);
155
-
156
-                         //$this->bill_user_log111111($v['user_id'],"股权分佣", $stock_comm,"股权明细入账");//股权分佣明细2.0系统
157
-        //           }
158
-                  
159
-        //     }
160
-        //   }
161
-        
110
+    
162
         //股权分红 end
111
         //股权分红 end
163
     
112
     
164
        
113
        
@@ -251,7 +200,7 @@ $sales_arr[2]['divider_people'] = array_values($intermediate);
251
       
200
       
252
       //移动指定ID_end
201
       //移动指定ID_end
253
    
202
    
254
-        // var_dump($sales_arr);die;
203
+         //var_dump($sales_arr);return;
255
       //$sales_arr获取分红的id和分红的比例 
204
       //$sales_arr获取分红的id和分红的比例 
256
 
205
 
257
 
206
 
@@ -334,21 +283,23 @@ $sales_arr[2]['divider_people'] = array_values($intermediate);
334
                $user_pv_small_num = $this->getpersamllcomm($v);//返回是数组,下标0是最小的值(业绩小的),下标1是最大的值(业绩大的)
283
                $user_pv_small_num = $this->getpersamllcomm($v);//返回是数组,下标0是最小的值(业绩小的),下标1是最大的值(业绩大的)
335
                $my_mix_money = round($amont * ($user_pv_small_num[0]/$small_ow_bill),2);
284
                $my_mix_money = round($amont * ($user_pv_small_num[0]/$small_ow_bill),2);
336
 
285
 
337
-               $userdatassss = db::name("old_user_jbp")->where("id",$v)->find();    
338
-               $datas_log = [
339
-        'note'=>"名称:".  $userdatassss['nick_name']  ." 用户:". $v . " 双联盟总业绩:" . $owner_bill ." 我的双区业绩:". $my_bill . " 小区总业绩:".$small_ow_bill." 我的业绩小的:" . $user_pv_small_num[0] . "  可分红佣金:" .$amont . "  可分红总佣金:" . $fs_money_nums . "  小区业绩可分红:" . $my_mix_money . " 大区业绩可分红:" .$my_weight_money,
340
-                'create_time'=>date('Y-m-d H:i:s')
341
-               ];
342
-               $con_data = Db::name('test_log')->insert($datas_log);   //数据存到2.0数据表中    
343
 
286
 
344
-        
345
-//die;
346
                # code...
287
                # code...
347
                $all_award = $my_weight_money + $my_mix_money; 
288
                $all_award = $my_weight_money + $my_mix_money; 
348
           
289
           
349
                //90%给佣金,10给复购金
290
                //90%给佣金,10给复购金
350
                $yj_90 = $all_award * 0.9;
291
                $yj_90 = $all_award * 0.9;
351
                $fg_10 = $all_award * 0.1;
292
                $fg_10 = $all_award * 0.1;
293
+
294
+
295
+               
296
+               $userdatassss = db::name("old_user_jbp")->where("id",$v)->find();    
297
+               $datas_log = [
298
+        'note'=>"名称:".  $userdatassss['nick_name']  ." 用户:". $v . " 双联盟总业绩:" . $owner_bill ." 我的双区业绩:". $my_bill . " 小区总业绩:".$small_ow_bill." 我的业绩小的:" . $user_pv_small_num[0] . "  可分红佣金:" .$amont . "  可分红总佣金:" . $fs_money_nums . "  小区业绩可分红:" . $my_mix_money . " 大区业绩可分红:" .$my_weight_money . " 实际分得:". $yj_90,
299
+                'create_time'=>date('Y-m-d H:i:s')
300
+               ];
301
+               $con_data = Db::name('test_log')->insert($datas_log);   //数据存到2.0数据表中    
302
+
352
                # code...
303
                # code...
353
                $res = Db::name("user")->where("uid",$v)->inc("total_amount_old",$yj_90)->save();
304
                $res = Db::name("user")->where("uid",$v)->inc("total_amount_old",$yj_90)->save();
354
 
305
 
@@ -379,7 +330,7 @@ $sales_arr[2]['divider_people'] = array_values($intermediate);
379
 
330
 
380
 
331
 
381
                   $this->bill_user_log111111($v,"合伙人分佣",$yj_90,"合伙人分佣明细入账",11);//联创分佣明细2.0系统
332
                   $this->bill_user_log111111($v,"合伙人分佣",$yj_90,"合伙人分佣明细入账",11);//联创分佣明细2.0系统
382
-                  $this->fugou_user_log($v,$fg_10,11,1,1);//复购金明细入账
333
+                  $this->fugou_user_log($v,$fg_10,16,1,1);//复购金明细入账
383
               //}
334
               //}
384
           }
335
           }
385
 
336
 
@@ -416,7 +367,7 @@ $sales_arr[2]['divider_people'] = array_values($intermediate);
416
             'number'=>$num,//数量
367
             'number'=>$num,//数量
417
             'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
368
             'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
418
             'mark'=>"复购金",//备注
369
             'mark'=>"复购金",//备注
419
-            'desc'=>"抽取佣金的10%作为复购金",//描述
370
+            'desc'=>"10%复购金",//描述
420
             'order_id'=>$order_id,//订单id
371
             'order_id'=>$order_id,//订单id
421
             'surplus'=>0,//剩余
372
             'surplus'=>0,//剩余
422
             'order_type'=>11,//关联订单ID
373
             'order_type'=>11,//关联订单ID
@@ -567,7 +518,7 @@ public function getWeekStartEnd()
567
 
518
 
568
 
519
 
569
           $person_money +=  $team_small_big_amount[1];
520
           $person_money +=  $team_small_big_amount[1];
570
-          $team_money += $team_small_big_amount[0];
521
+         $team_money += $team_small_big_amount[0];
571
     
522
     
572
         //end
523
         //end
573
 
524
 
@@ -1205,7 +1156,7 @@ public function getbig_samll_datas($user_id) {
1205
             //var_dump($result_small_team_arr);
1156
             //var_dump($result_small_team_arr);
1206
             //获取当前用户下面在2.0中的下级所有PV
1157
             //获取当前用户下面在2.0中的下级所有PV
1207
             $get_teams_per_pv = $this->getteampv($result_small_team_arr);
1158
             $get_teams_per_pv = $this->getteampv($result_small_team_arr);
1208
-           // var_dump($get_teams_per_pv);
1159
+           // var_dump("小区业绩:" . $get_teams_per_pv);
1209
             //获取当前用户在2.0中小区的业绩 end
1160
             //获取当前用户在2.0中小区的业绩 end
1210
 
1161
 
1211
         }else{
1162
         }else{
@@ -1247,15 +1198,28 @@ public function getbig_samll_datas($user_id) {
1247
         // $person_amount = 0;
1198
         // $person_amount = 0;
1248
 
1199
 
1249
         if($user_id < 611){
1200
         if($user_id < 611){
1250
-         
1251
-            //获取当前用户直属下级(查询在2.0中直接推荐人和伞下的业绩。并比对大小部门)
1252
-            //例子:17所有下面uid是speard_uid都是17的,和所有伞下的业绩。分出大小部门,加到1.0的大小部门中
1253
-            $b_s = $this->getparents_child_pv11($user_id,$get_teams_comm_pv, $get_teams_per_pv);
1201
+            //如果当前用户直推,在2.0没有下级就不用再调用这个方法了
1202
+            $getchild = db::name("user")->where("spread_uid",$user_id)->select();
1203
+
1204
+           
1205
+            if(count($getchild) > 0){
1206
+                //获取当前用户直属下级(查询在2.0中直接推荐人和伞下的业绩。并比对大小部门)
1207
+                //例子:17所有下面uid是speard_uid都是17的,和所有伞下的业绩。分出大小部门,加到1.0的大小部门中
1208
+                $b_s = $this->getparents_child_pv11($user_id,$get_teams_comm_pv, $get_teams_per_pv);
1209
+                
1210
+                //var_dump( $b_s);echo "yyyyyyyyyyyyy";
1211
+               
1212
+                    $get_teams_comm_pv = $b_s[0];
1213
+                    $get_teams_per_pv = $b_s[1];
1214
+           
1254
             
1215
             
1255
-            //var_dump( $b_s);echo "yyyyyyyyyyyyy";
1256
-            $get_teams_comm_pv = $b_s[0];
1257
-            $get_teams_per_pv = $b_s[1];
1216
+            }
1217
+         
1218
+         
1219
+        }
1258
 
1220
 
1221
+        if($user_id == 523){
1222
+            $get_teams_per_pv += 7000;
1259
         }
1223
         }
1260
 
1224
 
1261
    
1225
    

+ 10 - 8
app/controller/api/store/merchant/Taskorderguquan.php

@@ -32,7 +32,9 @@ class Taskorderguquan extends BaseController
32
 
32
 
33
         //$week_record = 23800 + 60000;//20250222
33
         //$week_record = 23800 + 60000;//20250222
34
 
34
 
35
-        $week_record = 64400;//20250303
35
+       // $week_record = 64400;//20250303
36
+
37
+        $week_record = 10500 + 50000; //20250310
36
 
38
 
37
         $stock_comm = round($week_record * 0.05 ,2);
39
         $stock_comm = round($week_record * 0.05 ,2);
38
 
40
 
@@ -61,11 +63,11 @@ class Taskorderguquan extends BaseController
61
                     'update_time' => $v['update_time']
63
                     'update_time' => $v['update_time']
62
                 ]);
64
                 ]);
63
 
65
 
64
-               Db::name("user")->where("uid",$v['user_id'])->inc("brokerage_price", $yj_90)->save();
65
-               $res1 = Db::name("user")->where("uid",$v['user_id'])->inc("total_amount_old", $yj_90)->save();
66
-               $res2 = Db::name("user")->where("uid",$v['user_id'])->inc("amount_old", $yj_90)->save();
66
+              Db::name("user")->where("uid",$v['user_id'])->inc("brokerage_price", $yj_90)->save();
67
+              $res1 = Db::name("user")->where("uid",$v['user_id'])->inc("total_amount_old", $yj_90)->save();
68
+              $res2 = Db::name("user")->where("uid",$v['user_id'])->inc("amount_old", $yj_90)->save();
67
 
69
 
68
-               $res3 = Db::name("user")->where("uid",$v['user_id'])->inc("fugou", $fg_10)->save();
70
+              $res3 = Db::name("user")->where("uid",$v['user_id'])->inc("fugou", $fg_10)->save();
69
 
71
 
70
                 $res =true;
72
                 $res =true;
71
                 if($res){
73
                 if($res){
@@ -77,7 +79,7 @@ class Taskorderguquan extends BaseController
77
                     $week_data['user_star_id'] =  0;
79
                     $week_data['user_star_id'] =  0;
78
                     $week_data['award_num'] =  0;
80
                     $week_data['award_num'] =  0;
79
                     $week_data['award_num_sm'] =  0;
81
                     $week_data['award_num_sm'] =  0;
80
-                    $week_data['remark'] =  "股权分红主动执行";
82
+                    $week_data['remark'] =  "股权分红主动执行" . $yj_90;
81
                     $week_data['week_record'] =  $week_record;
83
                     $week_data['week_record'] =  $week_record;
82
                     $week_data['all_amount'] =  $stock_comm;
84
                     $week_data['all_amount'] =  $stock_comm;
83
                     $week_data['radio'] =  2;
85
                     $week_data['radio'] =  2;
@@ -99,7 +101,7 @@ class Taskorderguquan extends BaseController
99
 
101
 
100
                     $this->bill_user_log111111($v['user_id'],"股权分佣",  $yj_90,"股权明细入账",13);//股权分佣明细2.0系统
102
                     $this->bill_user_log111111($v['user_id'],"股权分佣",  $yj_90,"股权明细入账",13);//股权分佣明细2.0系统
101
 
103
 
102
-                    $this->fugou_user_log($v['user_id'],$fg_10,11,1,1);//复购金明细入账
104
+                    $this->fugou_user_log($v['user_id'],$fg_10,16,1,1);//复购金明细入账
103
                 }
105
                 }
104
             }
106
             }
105
         }
107
         }
@@ -121,7 +123,7 @@ class Taskorderguquan extends BaseController
121
             'number'=>$num,//数量
123
             'number'=>$num,//数量
122
             'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
124
             'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
123
             'mark'=>"复购金",//备注
125
             'mark'=>"复购金",//备注
124
-            'desc'=>"抽取佣金的10%作为复购金",//描述
126
+            'desc'=>"10%作为复购金",//描述
125
             'order_id'=>$order_id,//订单id
127
             'order_id'=>$order_id,//订单id
126
             'surplus'=>0,//剩余
128
             'surplus'=>0,//剩余
127
             'order_type'=>11,//关联订单ID
129
             'order_type'=>11,//关联订单ID

+ 6 - 4
app/controller/api/store/merchant/Taskorderlianc.php

@@ -299,7 +299,9 @@ class Taskorderlianc extends BaseController
299
 
299
 
300
        // $week_record = 45500 + 1400 + 60000;
300
        // $week_record = 45500 + 1400 + 60000;
301
         //$week_record = 23800 +60000;
301
         //$week_record = 23800 +60000;
302
-        $week_record = 64400;//20250303
302
+       // $week_record = 64400;//20250303
303
+
304
+        $week_record = 10500 + 50000; //20250310
303
 
305
 
304
         $originator_award = round(($week_record * 0.05),2);
306
         $originator_award = round(($week_record * 0.05),2);
305
 
307
 
@@ -382,7 +384,7 @@ class Taskorderlianc extends BaseController
382
                     $week_data['user_id'] =  $v;
384
                     $week_data['user_id'] =  $v;
383
                     $week_data['user_lianc_id'] =  $value['id'];
385
                     $week_data['user_lianc_id'] =  $value['id'];
384
                     $week_data['money'] =  $yj_90;
386
                     $week_data['money'] =  $yj_90;
385
-                    $week_data['remark'] =  "联创分红入账主动执行";
387
+                    $week_data['remark'] =  "联创分红入账主动执行" . $yj_90;
386
                     $week_data['all_record'] =  $originator_award;
388
                     $week_data['all_record'] =  $originator_award;
387
                     $week_data['all_amount'] =  $distribution_money;
389
                     $week_data['all_amount'] =  $distribution_money;
388
                     $week_data['create_time'] = time();
390
                     $week_data['create_time'] = time();
@@ -396,7 +398,7 @@ class Taskorderlianc extends BaseController
396
                     Db::name('test_log')->insert($datas_log);   //数据存到2.0数据表中
398
                     Db::name('test_log')->insert($datas_log);   //数据存到2.0数据表中
397
                     $this->bill_user_log111111($v,"联创分佣", $yj_90,"联创明细入账",12);//股权分佣明细2.0系统
399
                     $this->bill_user_log111111($v,"联创分佣", $yj_90,"联创明细入账",12);//股权分佣明细2.0系统
398
                     
400
                     
399
-                    $this->fugou_user_log($v,$fg_10,11,1,1);//复购金明细入账
401
+                    $this->fugou_user_log($v,$fg_10,16,1,1);//复购金明细入账
400
 
402
 
401
                 }else {
403
                 }else {
402
                     // ..
404
                     // ..
@@ -420,7 +422,7 @@ class Taskorderlianc extends BaseController
420
                 'number'=>$num,//数量
422
                 'number'=>$num,//数量
421
                 'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
423
                 'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
422
                 'mark'=>"复购金",//备注
424
                 'mark'=>"复购金",//备注
423
-                'desc'=>"抽取佣金的10%作为复购金",//描述
425
+                'desc'=>"10%作为复购金",//描述
424
                 'order_id'=>$order_id,//订单id
426
                 'order_id'=>$order_id,//订单id
425
                 'surplus'=>0,//剩余
427
                 'surplus'=>0,//剩余
426
                 'order_type'=>11,//关联订单ID
428
                 'order_type'=>11,//关联订单ID

+ 32 - 14
app/controller/api/user/User.php

@@ -254,10 +254,18 @@ class User extends BaseController
254
             
254
             
255
            // $getteamscon = $this->getPerformance($user->uid);
255
            // $getteamscon = $this->getPerformance($user->uid);
256
 
256
 
257
-            $getcon = $this->getPerformance_getcon( $user->uid);
257
+            //$getcon = $this->getPerformance_getcon( $user->uid);
258
+
259
+            $team_userinfo_old_jbp22 = $this->getPerformance22($user->uid);
258
 
260
 
259
             //我的团队贡献值
261
             //我的团队贡献值
260
-            $data['team_gongxian_num'] = $getcon['common_nums_pv'] + $getcon['person_nums_pv'];
262
+            if( $con['user_group'] <= 2 ){
263
+                $data['team_gongxian_num'] =  $team_userinfo_old_jbp22['person_nums_pv'] - $con['per_contribute'];
264
+            }else{
265
+                $data['team_gongxian_num'] = $team_userinfo_old_jbp22['person_nums_pv'];
266
+            }
267
+
268
+           
261
 
269
 
262
             //为生贡献值
270
             //为生贡献值
263
             $data['no_total_source']=Db::name('user_sign_gongxian')->where('status', -1)->where('uid', $user->uid)->sum('number');
271
             $data['no_total_source']=Db::name('user_sign_gongxian')->where('status', -1)->where('uid', $user->uid)->sum('number');
@@ -1406,17 +1414,27 @@ class User extends BaseController
1406
 
1414
 
1407
 
1415
 
1408
         if($teamid == 592){
1416
         if($teamid == 592){
1409
-             $teamid = 454;//593
1417
+             $teamid = 17;//593
1418
+
1419
+//            // $ss=  $this->userupdates($teamid);
1420
+//            // var_dump($ss);
1421
+
1422
+ //$team_userinfo_old_jbp22 = $this->getPerformance22(17);
1423
+
1424
+ //$datas_jbp = Db::name('user')->where("status",1)->select();
1425
+
1426
+ //var_dump( $team_userinfo_old_jbp22['person_nums_pv']);
1427
+
1428
+// foreach($datas_jbp as $k=>$v){
1429
+//     $team_userinfo_old_jbp22 = $this->getPerformance22($v['uid']);
1430
+//     var_dump("id:" . $v['uid'] . "  用户:" . $v['nickname'] . "    小部门贡献值 :" .  $team_userinfo_old_jbp22['person_nums_pv']);
1431
+// }
1410
 
1432
 
1411
-           // $ss=  $this->userupdates($teamid);
1412
-           // var_dump($ss);
1413
-    $team_userinfo_old_jbp22 = $this->getPerformance22($teamid);
1414
- var_dump( $team_userinfo_old_jbp22);
1415
  return;
1433
  return;
1416
-                $team_userinfo_old_jbp1 = $this->getPerformance($teamid);
1434
+//                 $team_userinfo_old_jbp1 = $this->getPerformance($teamid);
1417
 
1435
 
1418
-           //return;
1419
-              var_dump($team_userinfo_old_jbp1);return;
1436
+//            //return;
1437
+//               var_dump($team_userinfo_old_jbp1);return;
1420
         }
1438
         }
1421
 
1439
 
1422
 
1440
 
@@ -1437,7 +1455,7 @@ class User extends BaseController
1437
         ];
1455
         ];
1438
 
1456
 
1439
         // 如果在旧系统中有数据
1457
         // 如果在旧系统中有数据
1440
-       //if (!empty($datas_jbp)) {
1458
+     
1441
             $team_userinfo_old_jbp1 = $this->getPerformance($teamid);
1459
             $team_userinfo_old_jbp1 = $this->getPerformance($teamid);
1442
             $tes = $this->teamPeople($teamid, $type); // 1:团队, 2:个人
1460
             $tes = $this->teamPeople($teamid, $type); // 1:团队, 2:个人
1443
 
1461
 
@@ -1494,7 +1512,7 @@ class User extends BaseController
1494
             $data['common_nums'] = $team_userinfo_old_jbp1['person_nums'];
1512
             $data['common_nums'] = $team_userinfo_old_jbp1['person_nums'];
1495
             $data['common_nums_pv'] = max($team_userinfo_old_jbp1['common_nums_pv'], $team_userinfo_old_jbp1['person_nums_pv']);
1513
             $data['common_nums_pv'] = max($team_userinfo_old_jbp1['common_nums_pv'], $team_userinfo_old_jbp1['person_nums_pv']);
1496
             $data['person_nums_pv'] = min($team_userinfo_old_jbp1['common_nums_pv'], $team_userinfo_old_jbp1['person_nums_pv']);
1514
             $data['person_nums_pv'] = min($team_userinfo_old_jbp1['common_nums_pv'], $team_userinfo_old_jbp1['person_nums_pv']);
1497
-       // }
1515
+      
1498
 return app("json")->success($data);
1516
 return app("json")->success($data);
1499
 // // 查询当前会员旗下的会员数据(分页)
1517
 // // 查询当前会员旗下的会员数据(分页)
1500
 //         [$page, $limit] = $this->getPage();
1518
 //         [$page, $limit] = $this->getPage();
@@ -3944,7 +3962,7 @@ return app("json")->success($data);
3944
 
3962
 
3945
         $team_amount = 0;
3963
         $team_amount = 0;
3946
         $person_amount = 0;
3964
         $person_amount = 0;
3947
-        $user_id = 454; //598 523 536
3965
+       // $user_id = 17; //598 523 536
3948
         
3966
         
3949
         $result_big_team_arr = [];
3967
         $result_big_team_arr = [];
3950
         $get_teams_comm_datas = [];//在2.0中获取父级下面的所有团队数据
3968
         $get_teams_comm_datas = [];//在2.0中获取父级下面的所有团队数据
@@ -4079,7 +4097,7 @@ return app("json")->success($data);
4079
            // $get_teams_per_pv = $this->getteampv($result_small_team_arr);
4097
            // $get_teams_per_pv = $this->getteampv($result_small_team_arr);
4080
            $t_pv = $this->getteampv($result_small_team_arr);
4098
            $t_pv = $this->getteampv($result_small_team_arr);
4081
            $get_teams_per_pv =$t_pv['totalPv'];
4099
            $get_teams_per_pv =$t_pv['totalPv'];
4082
-            //var_dump(  $get_teams_per_pv);
4100
+           //var_dump(  $get_teams_per_pv);
4083
           
4101
           
4084
        
4102
        
4085
         
4103
         

+ 1 - 1
app/controller/merchant/gong/Goods.php

@@ -275,7 +275,7 @@ class Goods extends BaseController
275
                 'spu_id'=>$data['spu_id'],
275
                 'spu_id'=>$data['spu_id'],
276
                 'temp_id' => 105,
276
                 'temp_id' => 105,
277
                 'plate_mer_profit' => $data['mer_profit'],
277
                 'plate_mer_profit' => $data['mer_profit'],
278
-		'concession_pri' => $data['mer_profit'],
278
+		        'concession_pri' => $data['mer_profit'],
279
                 'yanglaojin_scale' => $yanglaojin_scale
279
                 'yanglaojin_scale' => $yanglaojin_scale
280
             ];
280
             ];
281
             $insert_id=Db::name('store_product')->insertGetId($product_insert_data);
281
             $insert_id=Db::name('store_product')->insertGetId($product_insert_data);

+ 69 - 44
app/traits/GongApiRequest.php

@@ -19,7 +19,7 @@ trait GongApiRequest
19
     private static $mobile = '17855366921';
19
     private static $mobile = '17855366921';
20
 
20
 
21
     public static function get_access_token(){
21
     public static function get_access_token(){
22
-        $url = '/api/noAuth/access_token';
22
+        $url = '/api_v2/noAuth/getAccessToken';
23
         $time = time();
23
         $time = time();
24
         $body = [
24
         $body = [
25
             'app_id' => self::$app_id,
25
             'app_id' => self::$app_id,
@@ -37,7 +37,7 @@ trait GongApiRequest
37
 
37
 
38
     public static function access_token(){
38
     public static function access_token(){
39
         $gong_access_token = Cache::get('gong_access_token');
39
         $gong_access_token = Cache::get('gong_access_token');
40
-        $url = '/api/category/get_list';
40
+        $url = '/api_v2/Goods/getGoodsList';
41
         $body = ['access_token' => $gong_access_token];
41
         $body = ['access_token' => $gong_access_token];
42
         $res = self::curl_post(self::$path.$url,$body);
42
         $res = self::curl_post(self::$path.$url,$body);
43
         if(!$gong_access_token || ($res['error_code'] == 1001)){
43
         if(!$gong_access_token || ($res['error_code'] == 1001)){
@@ -47,7 +47,7 @@ trait GongApiRequest
47
         return $gong_access_token;
47
         return $gong_access_token;
48
     }
48
     }
49
 
49
 
50
-    //分类
50
+    //分类(未更改)
51
     public static function get_category(){
51
     public static function get_category(){
52
         $url = '/api/category/get_list';
52
         $url = '/api/category/get_list';
53
         $body = [
53
         $body = [
@@ -72,7 +72,7 @@ trait GongApiRequest
72
      * @created 2022年5月19日11:31:59
72
      * @created 2022年5月19日11:31:59
73
      */
73
      */
74
     public static function get_goods_list($page=1,$limit=50){
74
     public static function get_goods_list($page=1,$limit=50){
75
-        $url = '/api/goods/get_spuid_list';
75
+        $url = '/api_v2/Goods/getGoodsList';
76
         $body = [
76
         $body = [
77
             'access_token' => self::access_token(),
77
             'access_token' => self::access_token(),
78
             'page' => $page,
78
             'page' => $page,
@@ -87,16 +87,16 @@ trait GongApiRequest
87
 
87
 
88
     /**
88
     /**
89
      * 商品详情
89
      * 商品详情
90
-     * @param array $spu_id 商品spu_id
90
+     * @param array $goods_id 商品goods_id
91
      * @return array|boolean
91
      * @return array|boolean
92
      * @author lin
92
      * @author lin
93
      * @created 2022年5月19日11:31:59
93
      * @created 2022年5月19日11:31:59
94
      */
94
      */
95
-    public static function get_goods_info($spu_id){
96
-        $url = '/api/goods/get_spuId_info';
95
+    public static function get_goods_info($goods_id){
96
+        $url = '/api_v2/Goods/getGoodsDetail';
97
         $body = [
97
         $body = [
98
             'access_token' => self::access_token(),
98
             'access_token' => self::access_token(),
99
-            'spu_id' => $spu_id,
99
+            'goods_id' => $goods_id,
100
         ];
100
         ];
101
         $res = self::curl_post(self::$path.$url,$body);
101
         $res = self::curl_post(self::$path.$url,$body);
102
         if ($res['error_code'] == 2001) {
102
         if ($res['error_code'] == 2001) {
@@ -108,18 +108,42 @@ trait GongApiRequest
108
         return false;
108
         return false;
109
     }
109
     }
110
 
110
 
111
+
112
+
113
+    /**
114
+     * 规格详情
115
+     * @param array $sku_id 商品sku_id
116
+     * @return array|boolean
117
+     * @author lin
118
+     * @created 2022年5月19日11:31:59
119
+     */
120
+    public static function get_sku_detail($sku_id){
121
+        $url = '/api_v2/Goods/getSkuDetail';
122
+        $body = [
123
+            'access_token' => self::access_token(),
124
+            'sku_id' => $sku_id,
125
+        ];
126
+        $res = self::curl_post(self::$path.$url,$body);
127
+        echo json_encode($res);
128
+        if($res['error_code'] == 0){
129
+            return $res['result'];
130
+        }
131
+        return false;
132
+    }
133
+
134
+
111
     /**
135
     /**
112
      * 商品规格
136
      * 商品规格
113
-     * @param array $spu_id 商品spu_id
137
+     * @param array $sku_sn 商品sku_sn
114
      * @return array|boolean
138
      * @return array|boolean
115
      * @author lin
139
      * @author lin
116
      * @created 2022年5月19日11:31:59
140
      * @created 2022年5月19日11:31:59
117
      */
141
      */
118
-    public static function get_sku($spu_id){
119
-        $url = '/api/goods/get_skuId_info';
142
+    public static function get_sku($sku_sn){
143
+        $url = '/api/Goods/getSkuDetail';
120
         $body = [
144
         $body = [
121
             'access_token' => self::access_token(),
145
             'access_token' => self::access_token(),
122
-            'spu_id' => $spu_id
146
+            'sku_sn' => $sku_sn
123
         ];
147
         ];
124
         $res = self::curl_post(self::$path.$url,$body);
148
         $res = self::curl_post(self::$path.$url,$body);
125
         if($res['error_code'] == 0){
149
         if($res['error_code'] == 0){
@@ -127,9 +151,10 @@ trait GongApiRequest
127
         }
151
         }
128
         return false;
152
         return false;
129
     }
153
     }
154
+    
130
 
155
 
131
     /**
156
     /**
132
-     * 商品价格
157
+     * 商品价格(未更改)
133
      * @param string $sku_id 商品skuid,[‘984783’,’984784’]
158
      * @param string $sku_id 商品skuid,[‘984783’,’984784’]
134
      * @return array|boolean
159
      * @return array|boolean
135
      * @author lin
160
      * @author lin
@@ -149,7 +174,7 @@ trait GongApiRequest
149
     }
174
     }
150
 
175
 
151
     /**
176
     /**
152
-     * 商品是否有货
177
+     * 商品是否有货(未更改)
153
      * @param int $sku_id 商品sku_id
178
      * @param int $sku_id 商品sku_id
154
      * @param int $address_id 地址id(区id或者接到id)
179
      * @param int $address_id 地址id(区id或者接到id)
155
      * @param int $goods_num 商品数量
180
      * @param int $goods_num 商品数量
@@ -173,7 +198,7 @@ trait GongApiRequest
173
     }
198
     }
174
 
199
 
175
     /**
200
     /**
176
-     * 查询商品上下架
201
+     * 查询商品上下架(未更改)
177
      * @param string $spu_id 商品spu_id
202
      * @param string $spu_id 商品spu_id
178
      * @return array|boolean
203
      * @return array|boolean
179
      * @author lin
204
      * @author lin
@@ -201,7 +226,7 @@ trait GongApiRequest
201
      * @created 2022年5月19日11:46:54
226
      * @created 2022年5月19日11:46:54
202
      */
227
      */
203
     public static function sku_stock(string $sku_list, int $address_id){
228
     public static function sku_stock(string $sku_list, int $address_id){
204
-        $url = '/api/goods/find_sku_stock';
229
+        $url = '/api_v2/Goods/stock';
205
         $body = [
230
         $body = [
206
             'access_token' => self::access_token(),
231
             'access_token' => self::access_token(),
207
             'sku_list' => $sku_list,
232
             'sku_list' => $sku_list,
@@ -215,19 +240,19 @@ trait GongApiRequest
215
     }
240
     }
216
 
241
 
217
     /**
242
     /**
218
-     * 运费查询(下单前调用,确定可售)
243
+     * 运费查询(下单前调用,确定可售) (未对接)
219
      * @param string $address_id 地址id
244
      * @param string $address_id 地址id
220
-     * @param array $sku_id sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
245
+     * @param array $sku_list sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
221
      * @return array|boolean
246
      * @return array|boolean
222
      * @author lin
247
      * @author lin
223
      * @created 2022年5月19日11:46:54
248
      * @created 2022年5月19日11:46:54
224
      */
249
      */
225
-    public static function freight(string $address_id, array $sku_id){
226
-        $url = '/api/order/freight';
250
+    public static function freight(string $address_id, array $sku_list){
251
+        $url = '/api_v2/order/getFreightPrice';
227
         $body = [
252
         $body = [
228
             'access_token' => self::access_token(),
253
             'access_token' => self::access_token(),
229
             'address_id' => $address_id,
254
             'address_id' => $address_id,
230
-            'sku_list' => $sku_id
255
+            'sku_list' => $sku_list
231
         ];
256
         ];
232
         $res = self::curl_post(self::$path.$url,$body);
257
         $res = self::curl_post(self::$path.$url,$body);
233
         if($res['error_code'] == 0){
258
         if($res['error_code'] == 0){
@@ -239,7 +264,7 @@ trait GongApiRequest
239
     /**
264
     /**
240
      * 正式下单
265
      * 正式下单
241
      * @param string $address_id 地址id
266
      * @param string $address_id 地址id
242
-     * @param array $sku_id sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
267
+     * @param array $sku_list sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
243
      * @param string $address 详细地址
268
      * @param string $address 详细地址
244
      * @param string $third_order 订单id
269
      * @param string $third_order 订单id
245
      * @param string $other 备注
270
      * @param string $other 备注
@@ -249,17 +274,17 @@ trait GongApiRequest
249
      * @author lin
274
      * @author lin
250
      * @created 2022年5月19日13:22:09
275
      * @created 2022年5月19日13:22:09
251
      */
276
      */
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';
277
+    public static function submit(string $address_id, array $sku_list, string $address, string $third_order, string $other, string $receiver, string $receiver_phone){
278
+        $url = '/api_v2/order/submit';
254
         $body = [
279
         $body = [
255
             'access_token' => self::access_token(),
280
             'access_token' => self::access_token(),
256
             'address_id' => $address_id,
281
             'address_id' => $address_id,
257
-            'sku_list' => $sku_id,
282
+            'sku_list' => $sku_list,
283
+            'receiver' => $receiver,
284
+            'receiver_phone' => $receiver_phone,
258
             'address' => $address,
285
             'address' => $address,
259
-            'third_order' => $third_order,
260
             'other' => $other,
286
             'other' => $other,
261
-            'receiver' => $receiver,
262
-            'receiver_phone' => $receiver_phone
287
+            'third_order' => $third_order
263
         ];
288
         ];
264
 //        Db::name('log')->insert(['data'=>'供应链发货-------2:']);
289
 //        Db::name('log')->insert(['data'=>'供应链发货-------2:']);
265
         $res = self::curl_post(self::$path.$url,$body);
290
         $res = self::curl_post(self::$path.$url,$body);
@@ -267,7 +292,7 @@ trait GongApiRequest
267
     }
292
     }
268
 
293
 
269
     /**
294
     /**
270
-     * 手动发货
295
+     * 手动发货(未对接)
271
      * @param string $out_order_no 订单编号
296
      * @param string $out_order_no 订单编号
272
      * @param string $logistics_number 物流单号
297
      * @param string $logistics_number 物流单号
273
      * @param string $logistics_company 物流名称
298
      * @param string $logistics_company 物流名称
@@ -291,7 +316,7 @@ trait GongApiRequest
291
     }
316
     }
292
 
317
 
293
     /**
318
     /**
294
-     * 查询订单状态
319
+     * 查询订单状态(未对接)
295
      * @param string $out_order_no 订单编号
320
      * @param string $out_order_no 订单编号
296
      * @return string|boolean 订单状态值 0失败 1待付款 2待发货 3待收货 4已完成 5已取消 6售后中 7售后完成8拒收
321
      * @return string|boolean 订单状态值 0失败 1待付款 2待发货 3待收货 4已完成 5已取消 6售后中 7售后完成8拒收
297
      * @author lin
322
      * @author lin
@@ -318,7 +343,7 @@ trait GongApiRequest
318
      * @created 2022年5月19日11:46:54
343
      * @created 2022年5月19日11:46:54
319
      */
344
      */
320
     public static function order_details(string $out_order_no){
345
     public static function order_details(string $out_order_no){
321
-        $url = '/api/order/details';
346
+        $url = '/api_v2/order/getOrderDetail';
322
         $body = [
347
         $body = [
323
             'access_token' => self::access_token(),
348
             'access_token' => self::access_token(),
324
             'out_order_no' => $out_order_no,
349
             'out_order_no' => $out_order_no,
@@ -338,7 +363,7 @@ trait GongApiRequest
338
      * @created 2022年5月19日11:46:54
363
      * @created 2022年5月19日11:46:54
339
      */
364
      */
340
     public static function order_track(string $out_order_no){
365
     public static function order_track(string $out_order_no){
341
-        $url = '/api/order/track';
366
+        $url = '/api_v2/order/track';
342
         $body = [
367
         $body = [
343
             'access_token' => self::access_token(),
368
             'access_token' => self::access_token(),
344
             'out_order_no' => $out_order_no,
369
             'out_order_no' => $out_order_no,
@@ -352,7 +377,7 @@ trait GongApiRequest
352
 
377
 
353
 
378
 
354
     /**
379
     /**
355
-     * 确认收货
380
+     * 确认收货(未对接)
356
      * @param string $out_order_no 订单编号
381
      * @param string $out_order_no 订单编号
357
      * @return array|boolean
382
      * @return array|boolean
358
      * @author lin
383
      * @author lin
@@ -372,14 +397,14 @@ trait GongApiRequest
372
     }
397
     }
373
 
398
 
374
     /**
399
     /**
375
-     * 查询商品是否可售后属性
400
+     * 查询商品是否可售后属性(未对接)
376
      * @param string $out_order_no 订单编号
401
      * @param string $out_order_no 订单编号
377
      * @return array|boolean
402
      * @return array|boolean
378
      * @author lin
403
      * @author lin
379
      * @created 2022年5月19日11:46:54
404
      * @created 2022年5月19日11:46:54
380
      */
405
      */
381
     public static function after_is_can(string $out_order_no){
406
     public static function after_is_can(string $out_order_no){
382
-        $url = '/api/after/is_can   ';
407
+        $url = '/api/after/is_can';
383
         $body = [
408
         $body = [
384
             'access_token' => self::access_token(),
409
             'access_token' => self::access_token(),
385
             'out_order_no' => $out_order_no,
410
             'out_order_no' => $out_order_no,
@@ -392,7 +417,7 @@ trait GongApiRequest
392
     }
417
     }
393
 
418
 
394
     /**
419
     /**
395
-     * 申请售后
420
+     * 申请售后(未对接)
396
      * @param string $out_order_no 订单编号
421
      * @param string $out_order_no 订单编号
397
      * @param string $customer_expect 1-退货。2-换货
422
      * @param string $customer_expect 1-退货。2-换货
398
      * @param string $question_desc 申请理由
423
      * @param string $question_desc 申请理由
@@ -417,7 +442,7 @@ trait GongApiRequest
417
     }
442
     }
418
 
443
 
419
     /**
444
     /**
420
-     * 申请售后
445
+     * 申请售后(未对接)
421
      * @param string $order_goods_id 订单商品id
446
      * @param string $order_goods_id 订单商品id
422
      * @param string $out_order_no 系统订单号
447
      * @param string $out_order_no 系统订单号
423
      * @param string $after_type 1=未收货退款,2=退货退款,3=换货补发,4=不退货仅退款
448
      * @param string $after_type 1=未收货退款,2=退货退款,3=换货补发,4=不退货仅退款
@@ -443,7 +468,7 @@ trait GongApiRequest
443
 
468
 
444
 
469
 
445
     /**
470
     /**
446
-     * 查询订单是否可售后
471
+     * 查询订单是否可售后(未对接)
447
      * @param string $out_order_no 系统订单号
472
      * @param string $out_order_no 系统订单号
448
      * @return mixed|string
473
      * @return mixed|string
449
      */
474
      */
@@ -459,7 +484,7 @@ trait GongApiRequest
459
     }
484
     }
460
 
485
 
461
     /**
486
     /**
462
-     * 售后订单状态
487
+     * 售后订单状态(未对接)
463
      * @param string $after_sn 售后订单号
488
      * @param string $after_sn 售后订单号
464
      * @return array|boolean
489
      * @return array|boolean
465
      */
490
      */
@@ -474,7 +499,7 @@ trait GongApiRequest
474
     }
499
     }
475
 
500
 
476
     /**
501
     /**
477
-     * 售后订单状态
502
+     * 售后订单状态(未对接)
478
      * @param string $after_sn 售后订单号
503
      * @param string $after_sn 售后订单号
479
      * @return array|boolean
504
      * @return array|boolean
480
      */
505
      */
@@ -489,7 +514,7 @@ trait GongApiRequest
489
     }
514
     }
490
 
515
 
491
     /**
516
     /**
492
-     * 退换货发货信息
517
+     * 退换货发货信息(未对接)
493
      * @param string $after_sn 售后订单编号。申请售后接口返回
518
      * @param string $after_sn 售后订单编号。申请售后接口返回
494
      * @param string $logistics_company 1-退货。2-换货
519
      * @param string $logistics_company 1-退货。2-换货
495
      * @param string $logistics_number 申请理由
520
      * @param string $logistics_number 申请理由
@@ -513,7 +538,7 @@ trait GongApiRequest
513
     }
538
     }
514
 
539
 
515
     /**
540
     /**
516
-     * 取消申请售后
541
+     * 取消申请售后(未对接)
517
      * @param string $after_sn 售后订单编号。申请售后接口返回
542
      * @param string $after_sn 售后订单编号。申请售后接口返回
518
      * @param string $out_order_no 订单编号
543
      * @param string $out_order_no 订单编号
519
      * @return string|boolean
544
      * @return string|boolean
@@ -535,7 +560,7 @@ trait GongApiRequest
535
     }
560
     }
536
 
561
 
537
     /**
562
     /**
538
-     * 获取地区
563
+     * 获取地区(未对接)
539
      * @param string $code 地区代码,为空查询省级信息,否则查询code的下级
564
      * @param string $code 地区代码,为空查询省级信息,否则查询code的下级
540
      * @return string|boolean
565
      * @return string|boolean
541
      * @author lin
566
      * @author lin
@@ -555,7 +580,7 @@ trait GongApiRequest
555
     }
580
     }
556
 
581
 
557
     /**
582
     /**
558
-     * 获取消息池消息
583
+     * 获取消息池消息(未对接)
559
      * @param int $type 1-订单状态变动, 2-商品详情, 3-sku价格, 4-商品删除, 5-规格状态变更, 6-规格删除, 7-规格详情, 8-商品状态变更
584
      * @param int $type 1-订单状态变动, 2-商品详情, 3-sku价格, 4-商品删除, 5-规格状态变更, 6-规格删除, 7-规格详情, 8-商品状态变更
560
      * @return  array|boolean
585
      * @return  array|boolean
561
      * @author lin
586
      * @author lin

+ 2 - 0
route/api.php

@@ -1210,6 +1210,8 @@ Route::group('api/', function () {
1210
     Route::get('close_seckill','api.warehouse.Product/close_seckill');//每小时 执行关闭秒杀任务
1210
     Route::get('close_seckill','api.warehouse.Product/close_seckill');//每小时 执行关闭秒杀任务
1211
     Route::post('send_order/:id','api.douhuomall.Order/send_order');//测试下单 供应链
1211
     Route::post('send_order/:id','api.douhuomall.Order/send_order');//测试下单 供应链
1212
 
1212
 
1213
+    Route::get('get_goods_list','api.douhuomall.Take/get_goods_list');//测试拉去唯微宝商品
1214
+
1213
     Route::get('pay_demo', 'api.merchant.sxy.Access/pay_demo');
1215
     Route::get('pay_demo', 'api.merchant.sxy.Access/pay_demo');
1214
 
1216
 
1215
     Route::get('refund_test', 'api.store.order.StoreOrder/refund_test');//首信易测试订单退款
1217
     Route::get('refund_test', 'api.store.order.StoreOrder/refund_test');//首信易测试订单退款