三方定时拉取订单赠送养老金，积分，贡献值

app/common/repositories/store/order/StoreOrderRepository.php

@@ -3127,6 +3127,60 @@ class StoreOrderRepository extends BaseRepository
     }
 
 
+    public function yugu_rebate_gong_fu($order){
+
+        $order_sn = $order["order_sn"];
+        $tongji=Db::name("user_bill")->where("order_sn",$order_sn)->count();
+        if($tongji){
+            //第三方订单状态修改
+            try {
+                if(isset($order['table']) && !empty($order['table'])){
+                    $table = $order['table'];
+                    $bill_status = Db::name("$table")->where('order_sn',$order_sn) -> value('bill_status');
+                    if($bill_status == 2){
+                        Db::name("user_bill") -> where("order_sn",$order_sn) -> update(["status"=>-1]);
+                    }
+                }
+            }catch (Exception $exception){
+                Db::name("log")->insert(array('data'=>'第三方订单状态修改：'.$exception->getMessage()));//日志记录
+            }
+            return true;
+        }
+
+        $order_id = $order["order_id"];
+
+
+        /***************可以返的佣金*****************/
+        //商户养老金比例
+        $yanglao= systemConfig('yanglaojin_admin');
+        //平台若有养老金配置 则开始分配养老金
+        if ($yanglao){
+            //养老金
+//            $oldagefee=$this->decimal2($order["extension_one"]* $yanglao * 0.01);
+            //y养老金最新调整 =佣金的*50%*5%
+            $oldagefee=$this ->decimal2($order['total_price']*0.5*0.05);
+
+            //当前已扣会费总额
+//            $oldagefee = $oldagefee-$dues;
+            $mark = "消费获得养老金".$oldagefee;
+
+            //end会费
+            //sat存养老金
+            $title = "养老金 ";
+            $commission_type = 5;
+            if ($oldagefee >= 0.01) {
+                $this->add_bill($title, $oldagefee, $order["uid"], $mark, $commission_type, $order_sn, $order_id, $order["mer_id"], 0, 0, $order["type_shop"]);
+            }else {
+                Db::name('log')->insert(['data'=>'订单号：'.$order_sn.'付款额度较低或 商家、平台设置的返佣比例较低，养老金低于0.01无法入库 特此记录！']);
+            }
+            //end存养老金
+        }
+
+//
+    }
+
+
+
     public function yugu_rebate($order)
     {
 

app/common/repositories/user/UserThirdRepository.php

@@ -232,9 +232,9 @@ class UserThirdRepository extends BaseRepository
             ];
             return $order;
 //            var_dump($order,$pid);exit;
-//            $StoreOrderRepository = app()->make(StoreOrderRepository::class);
+            $StoreOrderRepository = app()->make(StoreOrderRepository::class);
 //            $StoreOrderRepository->yugu_rebate($order);
-//            $StoreOrderRepository->yugu_rebate_gong_fu($order);
+            $StoreOrderRepository->yugu_rebate_gong_fu($order);
 
 
 //            $money_hui = 0;
@@ -596,45 +596,67 @@ class UserThirdRepository extends BaseRepository
         return $data;
     }
     /**
-     * 预估积分
+     * 添加预估积分记录
      */
+
 //预估养老金
-    public static function yuguJifen($price, $user_id, $table, $table_id, $type_shop, $order_sn)
+    public static function yuguJifen($price,$user_id,$order_sn,$type_shop)
     {
         if (empty($user_id)) {
-            Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $table_id, 赠送积分, 不存在用户ID"]);
+            Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $order_sn, 赠送积分, 不存在用户ID"]);
             return false;
         }
         //查询用户是否已经存在该订单
         $user_sign_score_list = Db::name('user_sign_score')
             ->where('uid', $user_id)
-            ->where('order_type', $table)
-            ->where('order_id', $table_id)
+            ->where('order_type', $type_shop)
+            ->where('order_id', $order_sn)
             ->find();
         if (!empty($user_sign_score_list)) {
-            Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $table_id, 赠送积分, 订单已存在积分发放记录"]);
+            Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $order_sn, 赠送积分, 订单已存在积分发放记录"]);
             return false;
         }
-        Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $table_id, 赠送积分, $price"]);
+        Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $order_sn, 赠送积分, $price"]);
         Db::startTrans();
         try {
             //更新用户积分
             $user = Db::name('user')->where('uid', $user_id)->find();
-            $inc_score = $price;
+            $inc_score = decimal2($price*0.5);//pv=佣金的50%=积分=贡献值
             $user_score = $user['score'];
             $ins_data['uid'] = $user_id;
             $ins_data['reward_socre'] = $inc_score;
             $ins_data['addtime'] = time();
             $ins_data['status'] = -1;
-            $ins_data['order_type'] = $table;
-            $ins_data['order_id'] = $table_id;
+            $ins_data['order_type'] = $type_shop;
+            $ins_data['order_id'] = $order_sn;
             $ins_data['mark'] = "购买三方商品赠送积分";
             $ins_data['desc'] = '';
             $ins_data['surplus'] = $user_score + $inc_score;
             $ins_data['type'] = 1;
             $ins_data['pm'] = 1;
-            Db::name('user_sign_score')->insertGetId($ins_data);
-            Db::name('user')->where('uid', $user_id)->inc('score', $inc_score)->update();
+            $ins_data['source_type'] =3;
+
+
+            //更新贡献值
+            $gongxian_data['uid'] = $user_id;
+            $gongxian_data['number'] = $inc_score;
+            $gongxian_data['addtime'] = time();
+            $gongxian_data['status'] = -1;
+            $gongxian_data['order_type'] = $type_shop;
+            $gongxian_data['order_id'] = $order_sn;
+            $gongxian_data['mark'] = "购买三方商品赠送贡献值";
+            $gongxian_data['desc'] = '';
+            $gongxian_data['surplus'] = $user_score + $inc_score;
+            $gongxian_data['type'] = 1;
+            $gongxian_data['pm'] = 1;
+            $gongxian_data['source_type'] =3;
+
+            Db::name('user_sign_score')->insertGetId($ins_data);//添加积分记录
+            Db::name('user_sign_gongxian')->insertGetId($gongxian_data);//添加贡献记录
+
+//
+//            Db::name('user')->where('uid', $user_id)->inc('score', $inc_score)->update();
+//            Db::name('user')->where('uid', $user_id)->inc('contribute', $inc_score)->update();
             Db::commit();
 
 //            $now_score= Db::name('user')->where('uid',$user_id)->value('now_score_estimate');

app/controller/api/store/product/DaTaoKe.php

@@ -386,7 +386,7 @@ class DaTaoKe
                 'order_tb');
             //预估积分
             $orderThird->yuguJifen(
-                $localOrder['pay_amount'],
+                $localOrder['commission'],
                 $localOrder['uid'],
                 $localOrder['order_sn'],
                 5

app/controller/api/store/product/Jd.php

@@ -628,7 +628,7 @@ class Jd extends BaseController
                 'order_jd');
             //预估积分
             $orderThird->yuguJifen(
-                $order['price'],
+                $order['commission'],
                 $order['uid'],
                 $order['order_sn'],
                 6

app/controller/api/store/product/Jt.php

@@ -802,21 +802,19 @@ class Jt extends BaseController
             $yanglaojin = $yanglaojin_order['extension_one'] ?? 0;
             //预估积分
             $orderThird->yuguJifen(
-                $localOrder['price'] + $yanglaojin,
-                $localOrder['uid'],
-                'order_jd',
-                $localOrder['order_jd_id'],
-                $type_shop,
-                $localOrder['order_sn']
+                $order['commission'],
+                $order['uid'],
+                $order['order_sn'],
+                6
             );
             //直推奖处理
-            $orderThird->yuguZhitui(
-                $localOrder['commission'],
-                $localOrder['uid'],
-                $type_shop,
-                $localOrder['order_sn'],
-                $localOrder['order_jd_id']
-            );
+//            $orderThird->yuguZhitui(
+//                $localOrder['commission'],
+//                $localOrder['uid'],
+//                $type_shop,
+//                $localOrder['order_sn'],
+//                $localOrder['order_jd_id']
+//            );
         }
     }
 

app/controller/api/store/product/Su.php

@@ -759,10 +759,10 @@ class Su extends BaseController
                 3,
                 'order_su');
             //预估积分
-            $orderThird->yuguJifen($localOrder['pay_amount'],
-                $localOrder['uid'],
-                $localOrder['order_sn'],
-                $localOrder['bill_end_time'],
+            $orderThird->yuguJifen(
+                $order['commission'],
+                $order['uid'],
+                $order['order_sn'],
                 3
             );
         }

app/controller/api/store/product/Vip.php

@@ -880,7 +880,8 @@ class Vip extends BaseController
                     2,
                     'order_vip');
                 //预估积分
-                $orderThird->yuguJifen($localOrder['pay_amount'],
+                $orderThird->yuguJifen(
+                    $localOrder['commission'],
                     $localOrder['uid'],
                     $localOrder['order_sn'],
                     $localOrder['bill_end_time'],