支付成功后推送话费订单

app/controller/api/Notify.php

@@ -4,6 +4,7 @@ namespace app\controller\api;
 use AdaPaySdk\AdapayTools;
 use app\common\repositories\store\order\StoreRefundOrderRepository;
 use app\controller\api\merchant\sxy\Access;
+use app\controller\api\store\service\Huafei;
 use think\facade\Db;
 use think\facade\Log;
 use think\facade\Request;
@@ -54,6 +55,13 @@ class Notify
                             }catch (\Exception $e) {
                                 Db::name('log')->insert(['data'=>'话费充值支付回调错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
                             }
+                            //话费充值支付成功推送
+                            try{
+                                $Huafei = new Huafei();
+                                $Huafei->pushHf($order_data['uid'], $order_data['order_no'], $order_data['mobile'], $order_data['pay_price']);
+                            }catch (\Exception $e) {
+                                Db::name('log')->insert(['data'=>'话费充值支付回调推送订单错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
+                            }
                             break;
                         case 'pay':
                             //商城集合订单

app/controller/api/store/service/Huafei.php

@@ -20,12 +20,6 @@ class Huafei extends BaseController
     protected $apiVersion = "1.0";
 
 
-    public function __construct(App $app)
-    {
-        parent::__construct($app);
-    }
-
-
 	//充值话费回调
 	public function notify(){
 		$param = $this->request->param();
@@ -106,38 +100,42 @@ class Huafei extends BaseController
 			}else{
 				return app('json')->fail('创建话费充值预支付订单失败');
 			}
-
-			//推送订单
-			// $push = $this->pushOrder($order_sn, $params['phone'], $params['money']);
-			// if($push['code'] == '0000'){
-			// 	//入库记录
-			// 	$insertdata = [
-			// 		'uid'=> $uid,
-			// 		'mobile' => $params['phone'],
-			// 		'commission'=> 0,
-			// 		'commission_share'=> 0.04,
-			// 		'order_number' => $push['data']['order_number'],
-			// 		'order_sn' => $order_sn,
-			// 		'amount_price' => $push['data']['amount'],
-			// 		'fanli_price' => $push['data']['fanli'],
-			// 		'cost_price' => $push['data']['cost_price'],
-			// 		'pay_money' => $params['money'],
-			// 		'status' => 0,
-			// 		'create_time' => time(),
-			// 		'finish_time' => time(),
-			// 		'modify_time' => time(),
-			// 	];
-			// 	Db::name('order_huafei')->insert($insertdata);
-			// 	return app('json')->success('话费推送成功', $push);
-			// }else{
-			// 	return app('json')->fail($push['msg']);
-			// }
 		}else{
 			return app('json')->fail($verify['msg']);
 		}
     }
 
 
+	//话费充值推送
+	public function pushHf($uid, $order_sn, $phone, $money){
+		//推送订单
+		$push = $this->pushOrder($order_sn, $phone, $money);
+		if($push['code'] == '0000'){
+			//入库记录
+			$insertdata = [
+				'uid'=> $uid,
+				'mobile' => $phone,
+				'commission'=> 0,
+				'commission_share'=> 0.04,
+				'order_number' => $push['data']['order_number'],
+				'order_sn' => $order_sn,
+				'amount_price' => $push['data']['amount'],
+				'fanli_price' => $push['data']['fanli'],
+				'cost_price' => $push['data']['cost_price'],
+				'pay_money' => $money,
+				'status' => 0,
+				'create_time' => time(),
+				'finish_time' => time(),
+				'modify_time' => time(),
+			];
+			Db::name('order_huafei')->insert($insertdata);
+			return $push;
+		}else{
+			return false;
+		}
+	}
+
+
 
 	//话费充值记录
 	public function record(){