Procházet zdrojové kódy

养老金调整,从pv5%到佣金的50%

hehaiqiang před 1 rokem
rodič
revize
dbc3612cf6

+ 2 - 2
app/common/repositories/store/order/StoreOrderRepository.php

@@ -3163,8 +3163,8 @@ class StoreOrderRepository extends BaseRepository
3163 3163
         //养老金
3164 3164
 //            $oldagefee=$this->decimal2($order["extension_one"]* $yanglao * 0.01);
3165 3165
 
3166
-        //y养老金最新调整 =佣金的*50%*5%
3167
-        $oldagefee=decimal2($order['total_price']*0.5*0.05);
3166
+        //y养老金最新调整 =佣金的*50%
3167
+        $oldagefee=decimal2($order['total_price']*0.5);
3168 3168
         log::info("++{$order['total_price']}+养老金===={$oldagefee}");
3169 3169
         //当前已扣会费总额
3170 3170
 //            $oldagefee = $oldagefee-$dues;

+ 4 - 1
app/common/repositories/store/product/ProductRepository.php

@@ -801,8 +801,11 @@ class ProductRepository extends BaseRepository
801 801
         $where = array_merge($where, $this->dao->productShow());
802 802
 
803 803
         //搜索记录
804
-        if ($userInfo && isset($where['keyword']) && !empty($where['keyword']))
804
+        if ($userInfo && isset($where['keyword']) && !empty($where['keyword'])){
805
+            log::info("======sousuojilu====");
805 806
             app()->make(UserVisitRepository::class)->searchProduct($userInfo['uid'], $where['keyword']);
807
+        }
808
+
806 809
 
807 810
         $query = $this->dao->search($merId, $where)->with(['merchant']);
808 811
         $query->with(['issetCoupon']);

+ 4 - 0
app/common/repositories/system/merchant/MerchantRepository.php

@@ -415,6 +415,10 @@ class MerchantRepository extends BaseRepository
415 415
     public function productList($merId, $where, $page, $limit, $userInfo,$type439=false)
416 416
     {
417 417
         log::info("========j进入prodctList");
418
+        log::info($merId);
419
+        log::info( $where);
420
+//        log::info($userInfo);
421
+        log::info($type439);
418 422
         $list=app()->make(ProductRepository::class)->getApiSearch($merId, $where, $page, $limit, $userInfo,$type439);
419 423
         $arr=[];
420 424
         foreach ($list["list"] as $v){

+ 7 - 2
app/controller/api/store/merchant/Merchant.php

@@ -87,7 +87,7 @@ class Merchant extends BaseController
87 87
     }
88 88
     public function productTypeList()
89 89
     {
90
-        $params= $this->request->params(['type','pageNum','pageSize']);
90
+        $params= $this->request->params(['type','mer_cate_id','pageNum','pageSize']);
91 91
         $name=$params['type'];
92 92
 
93 93
         $domain = $this->request->domain();
@@ -97,7 +97,7 @@ class Merchant extends BaseController
97 97
             $id=486;
98 98
         }else if($name=='jingpin'){
99 99
             $id=439;
100
-            $type439=false;
100
+//            $type439=false;
101 101
         }else if($name=='jifen'){
102 102
             $id=148;
103 103
         }else if($name=='gongchang'){
@@ -120,6 +120,11 @@ class Merchant extends BaseController
120 120
         $where['is_used'] = 1;
121 121
         $where['product_type'] = 0;
122 122
         $where['is_hide'] = 0;
123
+        log::info("====={$params['mer_cate_id']}===");
124
+        if($params['mer_cate_id']){
125
+            $where['cate_id'] =$params['mer_cate_id'];
126
+        }
127
+
123 128
         return app('json')->success($this->repository->productList($id,$where, $page, $limit,$this->userInfo,$type439));
124 129
     }
125 130
 

+ 2 - 2
app/controller/api/store/product/Jd.php

@@ -192,8 +192,8 @@ class Jd extends BaseController
192 192
         foreach ($list as $value) {
193 193
             $json = json_decode($value['json'], true);
194 194
             $json['pension'] = $json['pension']??'0';
195
-            $json['pv'] = $json['pension']*0.5;
196
-            $json['yanglaojin'] = $json['pv']*0.05;
195
+            $json['pv'] = $json['pension'];
196
+            $json['yanglaojin'] = $json['pension'];
197 197
 
198 198
             // $json['shopName'] = "";
199 199
             // $json['monthSales'] = "0";

+ 8 - 6
app/controller/api/store/product/Jt.php

@@ -267,12 +267,14 @@ class Jt extends BaseController
267 267
     {
268 268
 //        $formatList = [];
269 269
         foreach ($goodsList as $value) {
270
+            log::info("京推推定时返回数据");
271
+            log::info($value);
270 272
             $finalPrice = $value['final_price']; //商品最终价格(使用优惠券后的商品最终价格)
271 273
             $commissionRate = $value['commissionShare'];  //京推推商品佣金比率
272 274
             $commissionMoney = sprintf('%.2f', ($finalPrice * $commissionRate / 100)); // 商品最终价格 * 京推推商品佣金比率 /100 =最终佣金
273 275
 
274
-            $pv=$commissionMoney* 0.5;  //PV
275
-            $yanglaojin=$pv*0.05; //新的养老金
276
+            $pv=$commissionMoney*0.5;  //PV
277
+            $yanglaojin=$pv; //新的养老金
276 278
 
277 279
             
278 280
             //养老金
@@ -298,7 +300,7 @@ class Jt extends BaseController
298 300
                 'yanglaojin'=>$yanglaojin,
299 301
 
300 302
 
301
-                'commission' => $yanglaojin,//养老金
303
+                'commission' => $commissionMoney,//佣金金额
302 304
                 'commission_rate' => $commissionRate,
303 305
                 // 'sales' => $value['inOrderCount30Days'],
304 306
                 'coupon_money' => $couponMoney,//优惠券相关信息
@@ -330,7 +332,7 @@ class Jt extends BaseController
330 332
 
331 333
             Db::name("third_party_goods") -> insert([
332 334
                 'json'=>json_encode($formatList,JSON_UNESCAPED_UNICODE),
333
-                'pension'=>$yanglaojin,
335
+                'pension'=>$commissionMoney,
334 336
                 'type'=>2,                
335 337
                 'cid'=>$cid //一级分类
336 338
             ]);  //20250110 增加cid字段,json中增加 shopName,monthSales by Conner
@@ -529,11 +531,11 @@ class Jt extends BaseController
529 531
             $finalPrice = sprintf('%.2f', $finalPrice);
530 532
             $commissionRate = $detail['commissionInfo']['commissionShare'];
531 533
             //目前京东联盟等级只返回90%的收益,后续调整0.9即可
532
-            $commissionMoney = sprintf('%.2f', ($finalPrice * $commissionRate * 0.9 / 100));
534
+            $commissionMoney = sprintf('%.2f', ($finalPrice * $commissionRate / 100));
533 535
 
534 536
             $commission=$commissionMoney; //佣金(预估)
535 537
             $pv=$commission* 0.5;  //PV
536
-            $yanglaojin=$pv*0.05; //新的养老金
538
+            $yanglaojin=$pv; //新的养老金
537 539
 
538 540
             $gongxian=$pv; //新的养老金
539 541
             $jifen=$pv; //新的养老金

+ 7 - 3
app/controller/api/store/product/Su.php

@@ -170,7 +170,7 @@ class Su extends BaseController
170 170
                     
171 171
                     $commission=$goods['commodityInfo']['commodityPrice'] * $goods['commodityInfo']['rate'] / 100; //佣金
172 172
                     $pv=round($commission* 0.5,2);  //PV
173
-                    $yanglaojin=round($pv*0.05,2); //新的养老金
173
+                    $yanglaojin=$pv; //新的养老金
174 174
 
175 175
 
176 176
                     // if($yanglaojin < 0.1) {
@@ -217,7 +217,7 @@ class Su extends BaseController
217 217
                     Db::name("third_party_goods")->insert([
218 218
                         'json' => json_encode($goods, JSON_UNESCAPED_UNICODE),
219 219
                         'type' => 4,
220
-                        'pension' => $yanglaojin,
220
+                        'pension' => $commission,
221 221
                         'cid'=>$cid //一级分类
222 222
                     ]);
223 223
                     
@@ -524,8 +524,12 @@ class Su extends BaseController
524 524
 
525 525
 
526 526
         $commission=$result['wapPrePayCommission'] ; //佣金(预估)
527
+//        $commission=$result['commodityInfo']['commodityPrice'] * $result['commodityInfo']['rate'] / 100; //佣金
528
+        log::info("===========commission=====$commission=============");
529
+        log::info("===========res==================");
530
+        log::info($result);
527 531
         $pv=$commission* 0.5;  //PV
528
-        $yanglaojin=$pv*0.05; //新的养老金
532
+        $yanglaojin=$pv; //新的养老金
529 533
 
530 534
         $gongxian=$pv; //新的养老金
531 535
         $jifen=$pv; //新的养老金

+ 16 - 10
app/controller/api/store/product/TaoKe.php

@@ -191,8 +191,13 @@ class TaoKe extends BaseController
191 191
         $goodsList = [];
192 192
 
193 193
         // Log::info($goodsResult);
194
-        
194
+
195
+
196
+
197
+
195 198
         foreach ($goodsResult as $goods) {
199
+
200
+            log::info("=======min_normal_price====={$goods['min_normal_price']}==============");
196 201
             //var_dump($goods);
197 202
             $min_normal_price = sprintf('%.2f', $goods['min_normal_price'] / 100);
198 203
             $groupPrice = sprintf('%.2f', $goods['min_group_price'] / 100);
@@ -201,14 +206,15 @@ class TaoKe extends BaseController
201 206
             //佣金比例,千分比
202 207
             $commissionRate = $goods['promotion_rate'];
203 208
 
204
-            $commission = sprintf('%.2f', (($groupPrice * $commissionRate) / 1000));  //佣金
209
+            log::info("=======min_normal_price====={$groupPrice}==========={$commissionRate}===");
210
+            $commission = sprintf('%.2f', (($groupPrice * $commissionRate) /1000));  //佣金
205 211
             //将佣金根据用户等级转成积分
206 212
             //$userCommissionIntegral = getCommission($userLevel, $commission);
207 213
 
208
-            // $yanglaojin = app()->make(ProductRepository::class)->yanglaojin(0, $commission);
214
+//             $yanglaojin = app()->make(ProductRepository::class)->yanglaojin(0, $commission);
209 215
 
210
-            $pv=$commission* 0.5;  //PV
211
-            $yanglaojin=$pv*0.05; //新的养老金
216
+            $pv=sprintf('%.2f',$commission* 0.5);  //PV
217
+            $yanglaojin=$pv; //新的养老金
212 218
             Log::info("养老金:".$yanglaojin);
213 219
             // if($yanglaojin < 0.1) {
214 220
             //     continue;
@@ -235,8 +241,8 @@ class TaoKe extends BaseController
235 241
                     //'desc' => $goods['goods_desc'],
236 242
                     'coupon_money' => $couponMoney,
237 243
                     //'market_price' => $groupPrice,
238
-                    'market_price' => set_price_rtrim(sprintf('%.2f', $groupPrice - $couponMoney)),
239
-                    'price' => set_price_rtrim(sprintf('%.2f', $min_normal_price - $couponMoney)),
244
+                    'market_price' => set_price_rtrim(sprintf('%.2f', $min_normal_price - $couponMoney)),
245
+                    'price' => set_price_rtrim(sprintf('%.2f', $groupPrice - $couponMoney)),
240 246
     
241 247
                     'shopName'=>$goods['mall_name'], //店铺名称
242 248
                     'monthSales'=>$goods['sales_tip']>0?$goods['sales_tip']:mt_rand(100,10000) //月销量
@@ -413,12 +419,12 @@ class TaoKe extends BaseController
413 419
         if (empty($detail)) {//不能请求到数据将结果返回
414 420
             return ['code' => 0, 'data' => $result];
415 421
         }
416
-        $commission = ($detail['min_group_price'] * $detail['promotion_rate']) / 1000 / 100;
422
+        $commission = sprintf('%.2f',($detail['min_group_price'] * $detail['promotion_rate']) / 1000 / 100);
417 423
         // $detail['yanglao'] = app()->make(ProductRepository::class)
418 424
         //     ->thirdYanglaojin(0, sprintf('%.2f', $commission));
419 425
         
420
-            $pv=$commission* 0.5;  //PV
421
-            $yanglaojin=$pv*0.05; //新的养老金
426
+            $pv=sprintf('%.2f', $commission *0.5);  //PV
427
+            $yanglaojin=$pv; //新的养老金
422 428
         
423 429
         $gongxian=$pv;
424 430
         $jifen=$pv;

+ 3 - 3
app/controller/api/store/product/Vip.php

@@ -171,7 +171,7 @@ class Vip extends BaseController
171 171
                     $commission = $goods['commission'];
172 172
 
173 173
                     $pv=$commission* 0.5;  //PV
174
-                    $yanglaojin=$pv*0.05; //新的养老金
174
+                    $yanglaojin=$pv; //新的养老金
175 175
 
176 176
 
177 177
                     // $yanglaojin = app()->make(ProductRepository::class)->yanglaojin(0, $commission);
@@ -212,7 +212,7 @@ class Vip extends BaseController
212 212
                     Db::name("third_party_goods")->insert([
213 213
                         'json' => json_encode($goods, JSON_UNESCAPED_UNICODE),
214 214
                         'type' => 5,
215
-                        'pension' => $yanglaojin,
215
+                        'pension' => $commission,
216 216
                         'cid'=>$cid //一级分类
217 217
                     ]);
218 218
 
@@ -534,7 +534,7 @@ class Vip extends BaseController
534 534
 
535 535
         $commission=$result['result'][0]['vipPrice'] * $result['result'][0]['commissionRate'] / 100 ; //佣金(预估)
536 536
         $pv=$commission* 0.5;  //PV
537
-        $yanglaojin=$pv*0.05; //新的养老金
537
+        $yanglaojin=$pv; //新的养老金
538 538
 
539 539
         $gongxian=$pv; //新的养老金
540 540
         $jifen=$pv; //新的养老金

+ 243 - 35
app/controller/api/user/User.php

@@ -219,11 +219,13 @@ class User extends BaseController
219 219
     //贡献值
220 220
 
221 221
     public function  gongxian_info(){
222
-        log::info("============hongbao");
222
+        log::info("============gongxianinfo");
223 223
         $user = $this->request->userInfo();
224 224
         if($user->uid>0){
225
+
226
+//            $dateObj=DB::name('user_sign_hongbao')->where('uid', $user->uid)->select();
225 227
             //已经入账贡献值
226
-            $data['total_source']=$user->gongxian;
228
+            $data['total_source']=$user->contribute;
227 229
             //为生贡献值
228 230
             $data['no_total_source']=Db::name('user_sign_gongxian')->where('status', -1)->where('uid', $user->uid)->sum('number');;
229 231
             log::info("====spread_info_yhc=={$data['total_source']}======={$data['no_total_source']}");
@@ -242,14 +244,14 @@ class User extends BaseController
242 244
 
243 245
         if ($pm==0){
244 246
 
245
-            $data = DB::name('user_sign_gongxian')->where($where)->where('pm', 1)->field('id,mark,number,pm,addtime,order_id')->page($page, $limit)->order("id desc")->select();
246
-        }
247
-        if($pm==1){
248
-            $data = DB::name('user_sign_gongxian')->where($where)->where('pm', 2)->field('id,mark,number,pm,addtime,order_id')->page($page, $limit)->order("id desc")->select();
249
-
247
+            $data = DB::name('user_sign_gongxian')->where($where)->where('status', 1)->field('id,mark,number,addtime,order_id')->page($page, $limit)->order("id desc")->select();
250 248
         }
249
+//        if($pm==1){
250
+//            $data = DB::name('user_sign_gongxian')->where($where)->where('pm', 2)->field('id,mark,number,pm,addtime,order_id')->page($page, $limit)->order("id desc")->select();
251
+//
252
+//        }
251 253
         if($pm==2){
252
-            $data = DB::name('user_sign_gongxian')->where($where)->where('status', -1)->field('id,mark,number,pm,addtime,order_id')->page($page, $limit)->order("id desc")->select();
254
+            $data = DB::name('user_sign_gongxian')->where($where)->where('status', -1)->field('id,mark,number,addtime,order_id')->page($page, $limit)->order("id desc")->select();
253 255
 
254 256
         }
255 257
         log::info("=======date==={$data}");
@@ -1488,41 +1490,247 @@ class User extends BaseController
1488 1490
         return app("json")->fail("未绑定");
1489 1491
     }
1490 1492
 
1493
+//    /*
1494
+//     * 养老金统计
1495
+//     * */
1496
+//    public function get_yanglao_statistics()
1497
+//    {
1498
+//        $uid = $this->request->uid();
1499
+//        //线下数量
1500
+//        // 查询未结算
1501
+//
1502
+//        $gzc_order_list = Db::name('gzc_logs')->where('uid', $uid)->column('out_trade_no');
1503
+//
1504
+//        $onlineYanglaoUserBill = Db::name('user_bill')->where('commission_type', 5)->whereNotIn('order_sn',$gzc_order_list)->where('status', 0)->where('uid', $uid)->sum('number');
1505
+//        $onlineYanglaoGzc = Db::name('gzc_logs')->where('success', 0)->where('uid', $uid)->sum('pension');
1506
+//        $clearYanglao = Db::name('gzc_logs')->where('success', 1)->where('uid', $uid)->sum('pension');
1507
+//
1508
+//        $userInfo = Db::name('UserCertification')->where('uid', $uid)->field('user_name,user_card')->find();
1509
+//        $res = GzcApiRequest::checkAmount($userInfo);
1510
+//        $gzc = $res['extendData']['amount'] * 0.01;
1511
+//        // PCPC-中信公证处
1512
+//        $data['all_gzc'] = set_price_rtrim(sprintf("%01.2f", $gzc));
1513
+//        // 总养老金
1514
+//        $data['all_yanglao'] = set_price_rtrim($onlineYanglaoUserBill + $onlineYanglaoGzc + $clearYanglao + $gzc);
1515
+//        // 平台养老金
1516
+//        $data['all_yanglao_yhc'] = set_price_rtrim($onlineYanglaoUserBill + $onlineYanglaoGzc + $clearYanglao);
1517
+//        // 未结算养老金=预估养老金,不能包含进入公证处未成功的记录(这部分是已结算的)
1518
+//        $data['all_yanglao_yugu'] = set_price_rtrim(round($onlineYanglaoUserBill, 2));
1519
+//        // 已结算养老金 已入账
1520
+//        $data['all_yanglao_clear'] = set_price_rtrim(round($onlineYanglaoGzc+$clearYanglao, 2));
1521
+//        // 已入账养老金
1522
+//        $data['all_yanglao_in'] = set_price_rtrim(round($clearYanglao, 2));
1523
+//        // 平台未入账养老金
1524
+//        $data['all_yanglao_nclear'] = set_price_rtrim(round($onlineYanglaoGzc + $onlineYanglaoUserBill, 2));
1525
+//        // 待发起
1526
+//        $data['all_yanglao_wait'] = set_price_rtrim(round($onlineYanglaoGzc, 2));
1527
+//
1528
+//        return app("json")->success("查询成功", $data);
1529
+//    }
1530
+
1491 1531
     /*
1492
-     * 养老金统计
1493
-     * */
1532
+        * 养老金统计
1533
+        * */
1494 1534
     public function get_yanglao_statistics()
1495 1535
     {
1496 1536
         $uid = $this->request->uid();
1497 1537
         //线下数量
1498
-        // 查询未结算
1538
+        $offLine = \think\facade\Db::name('order_merchant')->where('uid', $uid)->where('status', 1)->field('pension yanglao')->select()->toArray();
1539
+        $data['offLine'] = array(
1540
+            'num' => count($offLine),
1541
+            'yanglao' => round($this->num($offLine, 'yanglao'), 2)
1542
+        );
1543
+        $offLinewhere=['uid'=>$uid,'status'=>'1','commission_type' => '5','source'=>1,'type_shop'=>0];
1544
+        if($this->source=='yhc' && $this->merId){
1545
+            $offLinewhere['mer_id']=$this->merId;
1546
+        }
1547
+        $offLine= \think\facade\Db::name('user_bill')->where($offLinewhere)->select()->toArray();
1548
+        $data['offLine'] = array(
1549
+            'num' => count($offLine),
1550
+            'yanglao' => round($this->num($offLine, 'number'), 2)
1551
+        );
1552
+//        $offLinewhere=['uid'=>$uid,'status'=>'1','commission_type' => '5','source'=>0,'type_shop'=>0];
1553
+//        $offLine= \think\facade\Db::name('user_bill')->where($offLinewhere)->select()->toArray();
1554
+//        $data['offLine'] = array(
1555
+//            'num' => count($offLine),
1556
+//            'yanglao' => round($this->num($offLine, 'number'), 2)
1557
+//        );
1558
+        //线上已确认收货
1559
+//        $onLine = \think\facade\Db::name('store_order')->where('uid', $uid)->where('paid', 1)->where('status', 'in', '2,3')->select()
1560
+//            ->each(function ($item) {
1561
+//                //查询养老金金额
1562
+//                $UserBillRepository = app()->make(UserBillRepository::class);
1563
+//                $bill = $UserBillRepository->getWhere(['uid' => $item['uid'], 'link_id' => $item['order_id'], 'order_sn' => $item['order_sn'], 'title' => '养老金']);
1564
+//                $pension = $bill->number ?? 0;
1565
+//                $item['yanglao'] = $pension;
1566
+//                return $item;
1567
+//            })
1568
+//            ->toArray();
1569
+
1570
+        $onLinewhere=['uid'=>$uid,'status'=>'1','commission_type' => '5','source'=>0,'type_shop'=>0];
1571
+        if($this->source=='yhc' && $this->merId){
1572
+            $onLinewhere['mer_id']=$this->merId;
1573
+        }
1574
+        $onLine= \think\facade\Db::name('user_bill')->where($onLinewhere)->select()->toArray();
1575
+        $data['onLine'] = array(
1576
+            'num' => count($onLine),
1577
+            'yanglao' => round($this->num($onLine, 'number'), 2)
1578
+        );
1579
+        //线上未确认收货
1580
+//        $onLine = \think\facade\Db::name('store_order')->where('uid', $uid)->where('paid', 1)->where('status', 'in', '0,1')->select()
1581
+//            ->each(function ($item) {
1582
+//                //查询养老金金额
1583
+//                $UserBillRepository = app()->make(UserBillRepository::class);
1584
+//                $bill = $UserBillRepository->getWhere(['uid' => $item['uid'], 'link_id' => $item['order_id'], 'order_sn' => $item['order_sn'], 'title' => '养老金']);
1585
+//                $pension = $bill->number ?? 0;
1586
+//                $item['yanglao'] = $pension;
1587
+//                return $item;
1588
+//            })
1589
+//            ->toArray();
1590
+        $onLine_take_nowhere=['uid'=>$uid,'status'=>'0','commission_type' => '5','source'=>0,'type_shop'=>0];
1591
+        if($this->source=='yhc' && $this->merId){
1592
+            $onLine_take_nowhere['mer_id']=$this->merId;
1593
+        }
1594
+        $onLine_take_no=\think\facade\Db::name('user_bill')->where($onLine_take_nowhere)->select()->toArray();
1595
+        $data['onLine_take_no'] = array(
1596
+            'num' => count($onLine_take_no),
1597
+            'yanglao' => round($this->num($onLine_take_no, 'number'), 2)
1598
+        );
1599
+        if($this->source=='yhc' && $this->merId){
1600
+            $data['all_num'] = $data['offLine']['num'] +$data['onLine_take_no']['num'] + $data['onLine']['num'];
1601
+            $data['all_yanglao_yhc'] = set_price_rtrim(round($data['offLine']['yanglao']+$data['onLine']['yanglao'] + $data['onLine_take_no']['yanglao'] , 2));//总养老金
1602
+            $data['all_yanglao_a'] = set_price_rtrim(round($data['offLine']['yanglao'] + $data['onLine']['yanglao'], 2));//已结算养老金
1603
+            $data['all_yanglao_yugu'] = set_price_rtrim(round($data['all_yanglao_yhc']-$data['all_yanglao_a'],2));//预估养老金
1499 1604
 
1500
-        $gzc_order_list = Db::name('gzc_logs')->where('uid', $uid)->column('out_trade_no');
1605
+            $userInfo = Db::name('UserCertification') -> where('uid',$uid) -> field('user_name,user_card') -> find();
1606
+            $res = GzcApiRequest::checkAmount($userInfo);
1607
+            $data['all_gzc']=set_price_rtrim(sprintf("%01.2f", $res['extendData']['amount'] * 0.01));
1608
+            $data['all_yanglao']=set_price_rtrim( $data['all_yanglao_yhc'] + $data['all_gzc']);
1501 1609
 
1502
-        $onlineYanglaoUserBill = Db::name('user_bill')->where('commission_type', 5)->whereNotIn('order_sn',$gzc_order_list)->where('status', 0)->where('uid', $uid)->sum('number');
1503
-        $onlineYanglaoGzc = Db::name('gzc_logs')->where('success', 0)->where('uid', $uid)->sum('pension');
1504
-        $clearYanglao = Db::name('gzc_logs')->where('success', 1)->where('uid', $uid)->sum('pension');
1610
+            return app("json")->success("查询成功", $data);
1611
+        }
1505 1612
 
1506
-        $userInfo = Db::name('UserCertification')->where('uid', $uid)->field('user_name,user_card')->find();
1507
-        $res = GzcApiRequest::checkAmount($userInfo);
1508
-        $gzc = $res['extendData']['amount'] * 0.01;
1509
-        // PCPC-中信公证处
1510
-        $data['all_gzc'] = set_price_rtrim(sprintf("%01.2f", $gzc));
1511
-        // 总养老金
1512
-        $data['all_yanglao'] = set_price_rtrim($onlineYanglaoUserBill + $onlineYanglaoGzc + $clearYanglao + $gzc);
1513
-        // 平台养老金
1514
-        $data['all_yanglao_yhc'] = set_price_rtrim($onlineYanglaoUserBill + $onlineYanglaoGzc + $clearYanglao);
1515
-        // 未结算养老金=预估养老金,不能包含进入公证处未成功的记录(这部分是已结算的)
1516
-        $data['all_yanglao_yugu'] = set_price_rtrim(round($onlineYanglaoUserBill, 2));
1517
-        // 已结算养老金 已入账
1518
-        $data['all_yanglao_clear'] = set_price_rtrim(round($onlineYanglaoGzc+$clearYanglao, 2));
1519
-        // 已入账养老金
1520
-        $data['all_yanglao_in'] = set_price_rtrim(round($clearYanglao, 2));
1521
-        // 平台未入账养老金
1522
-        $data['all_yanglao_nclear'] = set_price_rtrim(round($onlineYanglaoGzc + $onlineYanglaoUserBill, 2));
1523
-        // 待发起
1524
-        $data['all_yanglao_wait'] = set_price_rtrim(round($onlineYanglaoGzc, 2));
1613
+        //淘宝
1614
+        $tb_a = 0;
1615
+        $tb_where=['uid'=>$uid,'commission_type' => '5','source'=>0,'type_shop'=>5];
1616
+        $tb = \think\facade\Db::name('user_bill')->where('uid', $uid)->where($tb_where)->where('status','<>','-1')->select()->each(function ($value) use (&$tb_a) {
1617
+            $value['yanglao'] = 0;
1618
+            $value['yanglao'] = $value['number'];
1619
+            $value['yanglao_a'] = 0;
1620
+            if ($value['status'] == 1) {
1621
+                $value['yanglao_a'] = $value['yanglao'];
1622
+                $tb_a++;
1623
+            }
1624
+            return $value;
1625
+        })->toArray();
1626
+        $data['tb'] = array(
1627
+            'num' => count($tb),
1628
+            'num_a' => $tb_a,
1629
+            'yanglao' => round($this->num($tb, 'yanglao'), 2),
1630
+            'yanglao_a' => round($this->num($tb, 'yanglao_a'), 2),
1631
+        );
1632
+        //京东
1633
+        $jd_a = 0;
1634
+        $jd_where=['uid'=>$uid,'commission_type' => '5','source'=>0,'type_shop'=>6];
1635
+        $jd = \think\facade\Db::name('user_bill')->where('uid', $uid)->where($jd_where)->where('status','<>','-1')->select()->each(function ($value) use (&$jd_a) {
1636
+            $value['yanglao'] = 0;
1637
+            $value['yanglao'] = $value['number'];
1638
+            $value['yanglao_a'] = 0;
1639
+            if ($value['status'] == 1) {
1640
+                $value['yanglao_a'] = $value['yanglao'];
1641
+                $jd_a++;
1642
+            }
1643
+            return $value;
1644
+        })->toArray();
1645
+        $data['jd'] = array(
1646
+            'num' => count($jd),
1647
+            'num_a' => $jd_a,
1648
+            'yanglao' => round($this->num($jd, 'yanglao'), 2),
1649
+            'yanglao_a' => round($this->num($jd, 'yanglao_a'), 2),
1650
+        );
1651
+        //苏宁
1652
+        $su_a = 0;
1653
+        $su_where=['uid'=>$uid,'commission_type' => '5','source'=>0,'type_shop'=>3];
1654
+        $su = \think\facade\Db::name('user_bill')->where('uid', $uid)->where($su_where)->where('status','<>','-1')->select()->each(function ($value) use (&$su_a) {
1655
+            $value['yanglao'] = 0;
1656
+            $value['yanglao'] = $value['number'];
1657
+            $value['yanglao_a'] = 0;
1658
+            if ($value['status'] == 1) {
1659
+                $value['yanglao_a'] = $value['yanglao'];
1660
+                $su_a++;
1661
+            }
1662
+            return $value;
1663
+        })->toArray();
1664
+        $data['su'] = array(
1665
+            'num' => count($su),
1666
+            'num_a' => $su_a,
1667
+            'yanglao' => round($this->num($su, 'yanglao'), 2),
1668
+            'yanglao_a' => round($this->num($su, 'yanglao_a'), 2),
1669
+        );
1670
+        //拼多多
1671
+        $pdd_a = 0;
1672
+        $pdd_where=['uid'=>$uid,'commission_type' => '5','source'=>0,'type_shop'=>1];
1673
+        $pdd = \think\facade\Db::name('user_bill')->where('uid', $uid)->where($pdd_where)->where('status','<>','-1')->select()->each(function ($value) use (&$pdd_a) {
1674
+            $value['yanglao'] = 0;
1675
+            $value['yanglao'] = $value['number'];
1676
+            $value['yanglao_a'] = 0;
1677
+            if ($value['status'] == 1) {
1678
+                $value['yanglao_a'] = $value['yanglao'];
1679
+                $pdd_a++;
1680
+            }
1681
+            return $value;
1682
+        })->toArray();
1683
+        $data['pdd'] = array(
1684
+            'num' => count($pdd),
1685
+            'num_a' => $pdd_a,
1686
+            'yanglao' => round($this->num($pdd, 'yanglao'), 2),
1687
+            'yanglao_a' => round($this->num($pdd, 'yanglao_a'), 2),
1688
+        );
1689
+        //唯品会
1690
+        $vip_a = 0;
1691
+        $vip_where=['uid'=>$uid,'commission_type' => '5','source'=>0,'type_shop'=>2];
1692
+        $vip = \think\facade\Db::name('user_bill')->where($vip_where)->where('uid', $uid)->where('status','<>','-1')->select()->each(function ($value) use (&$vip_a) {
1693
+            $value['yanglao'] = 0;
1694
+            $value['yanglao'] = $value['number'];
1695
+            $value['yanglao_a'] = 0;
1696
+            if ($value['status'] == 1) {
1697
+                $value['yanglao_a'] = $value['yanglao'];
1698
+                $vip_a++;
1699
+            }
1700
+            return $value;
1701
+        })->toArray();
1702
+        $data['vip'] = array(
1703
+            'num' => count($vip),
1704
+            'num_a' => $vip_a,
1705
+            'yanglao' => round($this->num($vip, 'yanglao'), 2),
1706
+            'yanglao_a' => round($this->num($vip, 'yanglao_a'), 2),
1707
+        );
1708
+        // 抖音
1709
+        $dy_a = 0;
1710
+        $dy_where=['uid'=>$uid,'commission_type' => '5','source'=>0,'type_shop'=>9];
1711
+        $dy = \think\facade\Db::name('user_bill')->where('uid', $uid)->where($dy_where)->where('status','<>','-1')->select()->each(function ($value) use (&$dy_a) {
1712
+            $value['yanglao'] = 0;
1713
+            $value['yanglao'] = $value['number'];
1714
+            $value['yanglao_a'] = 0;
1715
+            if ($value['status'] == 1) {
1716
+                $value['yanglao_a'] = $value['yanglao'];
1717
+                $dy_a++;
1718
+            }
1719
+            return $value;
1720
+        })->toArray();
1721
+        $data['dy'] = array(
1722
+            'num' => count($dy),
1723
+            'num_a' => $dy_a,
1724
+            'yanglao' => round($this->num($dy, 'yanglao'), 2),
1725
+            'yanglao_a' => round($this->num($dy, 'yanglao_a'), 2),
1726
+        );
1525 1727
 
1728
+        $data['all_num'] = $data['offLine']['num'] +$data['onLine_take_no']['num'] + $data['onLine']['num'] + $data['tb']['num'] + $data['jd']['num'] + $data['su']['num'] + $data['pdd']['num'] + $data['vip']['num'] + $data['dy']['num'];
1729
+        $data['all_yanglao'] = round($data['offLine']['yanglao']+$data['onLine']['yanglao'] + $data['onLine_take_no']['yanglao'] + $data['tb']['yanglao'] + $data['jd']['yanglao'] + $data['su']['yanglao'] + $data['pdd']['yanglao'] + $data['vip']['yanglao'] + $data['dy']['yanglao'], 2);
1730
+        $data['all_yanglao_a'] = round($data['offLine']['yanglao'] + $data['onLine']['yanglao'] + $data['tb']['yanglao_a'] + $data['jd']['yanglao_a'] + $data['su']['yanglao_a'] + $data['pdd']['yanglao_a'] + $data['vip']['yanglao_a'] + $data['dy']['yanglao_a'], 2);
1731
+        $data['third_party_num']=['all_num'=>$data['tb']['num']+$data['jd']['num']+$data['su']['num']+ $data['pdd']['num'] + $data['vip']['num']+ $data['dy']['num']];
1732
+        $data['third_party_num_a']=['all_num_a'=>$data['tb']['num_a']+$data['jd']['num_a']+$data['su']['num_a']+ $data['pdd']['num_a'] + $data['vip']['num_a']+ $data['dy']['num_a']];
1733
+        $data['third_party_num_n']=['all_num_n'=>$data['third_party_num']['all_num']-$data['third_party_num_a']['all_num_a']];
1526 1734
         return app("json")->success("查询成功", $data);
1527 1735
     }
1528 1736
 
@@ -1608,7 +1816,7 @@ class User extends BaseController
1608 1816
     //20220712版签到
1609 1817
     public function new_sign()
1610 1818
     {
1611
-        return app('json')->fail('不允许签到');
1819
+//        return app('json')->fail('不允许签到');
1612 1820
         $uid = $this->request->uid();//签到用户
1613 1821
         $user = Db::name('user')->where('uid', $uid)->field("spread_uid,first_sign")->find();//上级用户
1614 1822
 

+ 2 - 2
route/api.php

@@ -300,8 +300,8 @@ Route::group('api/', function () {
300 300
 
301 301
             Route::get('hongbao_info','User/hongbao_list');//红包
302 302
             Route::get('hongbao_list','User/hongbao_list');//红包记录
303
-            Route::get('gongxian_info','User/hongbao_list');//贡献
304
-            Route::get('gongxian_list','User/hongbao_list');//贡献记录
303
+            Route::get('gongxian_info','User/gongxian_info');//贡献
304
+            Route::get('gongxian_list','User/gongxian_list');//贡献记录
305 305
             Route::get('fugou_info','User/fugou_list');//复购金
306 306
             Route::get('fugou_list','User/fugou_list');//复购金记录
307 307
             Route::get('jingdou_info','User/jingdou_list');//京豆