话费功能模块调整

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

@@ -3,6 +3,7 @@
 namespace app\controller\api\store\service;
 
 use think\App;
+use think\facade\Db;
 use crmeb\basic\BaseController;
 
 class Huafei extends BaseController
@@ -12,8 +13,6 @@ class Huafei extends BaseController
 	public $secretKey = 'f154a106d56d804fcc640d9da4844b0c';
 	// 生产
 	public $gatewayUrl = "https://router.wikeyun.cn";
-	// 备用
-//	public $gatewayUrl = "https://router.wikeyun.cn/rest";
 
     public $format = "json";
     /** 是否打开入参check**/
@@ -26,17 +25,124 @@ class Huafei extends BaseController
         parent::__construct($app);
     }
 
+
+	//充值话费回调
+	public function notify(){
+		$param = $this->request->param();
+		Db::name('log')->insert(['data'=>'话费充值回调数据'.json_encode($param)]);
+
+		$order_no = $param['order_no'];
+		$order_number = $param['order_number'];
+		$updateData = [
+			'amount_price' => $param['amount'],
+			'fanli_price' => $param['fanli'],
+			'cost_price' => $param['cost_price'],
+			'arrived_amount'=> $param['arrived_amount'],
+			'status' => $param['status'],
+			'modify_time' => time(),
+		];
+		$ret = Db::name("order_huafei")->where("order_number", $order_number)->where("order_sn", $order_no)->update($updateData);
+		if($ret){
+			echo 'success';exit;
+		}else{
+			Db::name('log')->insert(['data'=>'话费充值回调数据处理失败']);
+			echo 'error';exit;
+		}
+	}
+
+
+
+
+	//充值话费面额
+	public function denomination(){
+		$data = [
+			['money'=>50, 'name'=>'50元'],
+			['money'=>100, 'name'=>'100元'],
+			['money'=>200, 'name'=>'200元'],
+		];
+		return app('json')->success('获取话费面额成功', $data);
+	}
+
+
     //充值话费推送
     public function recharge(){
+		$uid = $this->request->uid();
+		$params = $this->request->params(['phone', 'money']);
+		if(!$params['phone']) return app('json')->fail('请提交电话号码');
+		if(!$params['money']) return app('json')->fail('请提交充值金额');
+		//验证
+		$verify = $this->verify($params['phone'], $params['money']);
+		if($verify['code'] == '0000'){
+			//推送
+			$order_sn = time().$uid;
+			$push = $this->pushOrder($order_sn, $params['phone'], $params['money']);
+			if($push['code'] == '0000'){
+				//入库记录
+				$insertdata = [
+					'uid'=> $uid,
+					'mobile' => $params['phone'],
+					'commission'=> 0,
+					'commission_share'=> 0,
+					'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 verify($order_number, $money){
+		$request['mobile'] = $order_number;
+		$request['amount'] = $money;
+		$request['recharge_type'] = 1;
+		return $this->execute('/rest/Recharge/verify', $request);
+	}
+
+
+	//话费订单充值推送
+	public function pushOrder($order_sn, $phone, $money){
+		$request['store_id'] = '9189';
+		$request['order_no'] = $order_sn; 
+		$request['mobile'] = $phone;
+		$request['money'] = $money;
+		$request['recharge_type'] = 1;
+		$request['notify_url'] = 'https://api.gdjbp.com//api/huafei/notify';
+		return $this->execute('/rest/Recharge/PushOrder', $request);
+	}
+
+
+    //话费订单查询
+    public function query($order_number){
         $request['store_id'] = '9189';
-        $request['mobile'] = '18973958920';
-        $request['money'] = 100;
-        $request['recharge_type'] = 1;
-        $request['notify_url'] = 'https://api.gdjbp.com//api/huafei/notify';
-        $arr = $this->execute('/rest/Recharge/PushOrder', $request);
-        return app('json')->success('话费推送成功', $arr);
+		$request['order_number'] = $order_number;
+        return $this->execute('/rest/Recharge/query', $request);
     }
 
+
+	//话费订单取消
+	public function cancel($order_number){
+		$request['order_number'] = $order_number;
+		return $this->execute('/rest/Recharge/cancel', $request);
+	}
+
+
+
+
 	protected function generateSign($params){
 		ksort($params);
 		$stringToBeSigned = $this->secretKey;

route/api.php

@@ -1025,10 +1025,13 @@ Route::group('api/', function () {
 
     //话费充值
     Route::group('huafei', function () {
-        Route::get('recharge', '/recharge');
-        Route::get('notify', '/notify');
+        Route::post('denomination', '/denomination');
+        Route::post('recharge', '/recharge');
     })->prefix('api.store.service.Huafei');
 
+    //话费充值回调通知
+    Route::get('huafei/notify', 'api.store.service.Huafei/notify');
+
 
 
     //城市代码