1

application/api_broker/controller/Amercement.php

@@ -133,5 +133,62 @@ class Amercement extends Basic
 
     }
 
+    public function getPayStatusByCurl()
+    {
+        $params = $this->params;
+        /*    $params = array(
+                "trade_no"        => "12323123123",//赵坤返回的fc开头的no
+            );*/
+        $checkResult = $this->validate($params, "AmercementValidate.getPayStatusByCurl");
+        if (true !== $checkResult) {
+            return $this->response("101", $checkResult);
+        }
+        $arr["oritranflow"] = $params["trade_no"];
+
+        $data          = json_encode($arr);
+        $curl          = new \app\chat\utils\CurlUtil();
+        $curl->headers = [
+            "Accept"       => "application/json",
+            "Content-Type" => "application/json;charset=utf-8",
+        ];
+        $curl->options = [
+            "CURLOPT_SSL_VERIFYPEER" => 0,
+            "CURLOPT_SSL_VERIFYHOST" => 2,
+        ];
+        $url           = $this->buildSendUrl();
+        $response      = $curl->post($url, $data);
+        $result        = jsondecode($response, true);
+        if ($result && $result["code"] == 0) {
+            $status = 0;
+            $is_success = $result["data"]["oritranstatus"];
+            if ($is_success == "01") {
+                $status = 1;
+            }elseif ($is_success == "02"){
+                $status = 3;
+            }else{
+                $status = 2;
+            }
+            $remark =  $result["data"]["orirespmsg"];
+            $is_ok = $this->s_amercement->updatePayAmercement($params["trade_no"],$status,$remark);
+            if($is_ok > 0){
+                return $this->response("200","success",["status"=>$status,",remark"=>$remark]);
+            }else{
+                return $this->response("101","查询异常请稍后再试");
+            }
+        } else {
+            return $this->response("101", $result["msg"]);
+        }
+    }
+
+    /**
+     * 请求api
+     * @return string
+     */
+    private function buildSendUrl()
+    {
+        return "http://120.55.43.9/api/pay/trans_result";
+
+    }
+
 
 }
\ No newline at end of file

application/api_broker/validate/AmercementValidate.php

@@ -74,5 +74,6 @@ class AmercementValidate extends Validate
         'addAmercement'     => ['type', 'money', 'agent_id', 'remarks'],
         'getAmercementList' => ['agent_id', 'status', 'amercement_type'],
         'savePayAmercement' => ['amercement_id', 'trade_no', 'pay_type', 'pay_money', 'pay_time'],
+        'getPayStatusByCurl' => [ 'trade_no'],
     ];
 }

application/index/service/AmercementService.php

@@ -627,7 +627,7 @@ class AmercementService
         $amercementPayModel     = new OAmercementPayModel();
         $where["amercement_id"] = $amercement_id;
         $where["status"]        = 0;
-        $payInfo1                = $amercementPayModel->getAmercementPayInfo($where, "id,status,trade_no");
+        $payInfo1               = $amercementPayModel->getAmercementPayInfo($where, "id,status,trade_no");
         if ($payInfo1) {
             return ["code" => '101', "msg" => "订单已支付"];
         }
@@ -635,9 +635,9 @@ class AmercementService
         $where["trade_no"]      = $trade_no;
         $payInfo2               = $amercementPayModel->getAmercementPayInfo($where, "id,status,trade_no");
 
-         if ($payInfo2) {
+        if ($payInfo2) {
             return ["code" => '101', "msg" => "订单等待支付中"];
-        }else {
+        } else {
             $arr["amercement_id"] = $amercement_id;
             $arr["trade_no"]      = $trade_no;
             $arr["pay_type"]      = $pay_type;
@@ -646,8 +646,14 @@ class AmercementService
             $id                   = $amercementPayModel->saveAmercementPay($arr);
             return ["code" => '200', ["id" => $id]];
         }
+    }
 
-
+    public function updatePayAmercement($trade_no, $status, $remark)
+    {
+        $amercementPayModel = new OAmercementPayModel();
+        $update["status"]   = $status;
+        $update["remark"]   = $remark;
+        return $amercementPayModel->updateAmercementPayData($trade_no, $update);
     }
 
 

application/model/OAmercementPayModel.php

@@ -42,37 +42,6 @@ class OAmercementPayModel extends Model
         return $result;
     }
 
-    public function getAmercementList($params, $field, $page_no, $page_size)
-    {
-        $result = $this->db_
-            ->field($field)
-            ->where($params)
-            ->limit($page_size)
-            ->page($page_no)
-            ->order('id desc')
-            ->select();
-        return $result;
-    }
-
-    public function getAmercementTotal($params, $field)
-    {
-        $result = $this->db_
-            ->field($field)
-            ->where($params)
-            ->count();
-        return $result;
-    }
-
-    public function getAmercementListExcel($params, $field)
-    {
-        $result = $this->db_
-            ->field($field)
-            ->where($params)
-            ->order('id desc')
-            ->select();
-        return $result;
-    }
-
 
     /**更新数据
      * @param $params
@@ -80,11 +49,18 @@ class OAmercementPayModel extends Model
      * @throws \think\Exception
      * @throws \think\exception\PDOException
      */
-    public function updateAmercementData($params)
+    public function updateAmercementPayData($trade_no, $params)
     {
-        $return  = $this->db_->update($params);
-        // big_log($this->getLastSql());
-        return $return;
+        $params["update_time"] = date("Y-m-d H:i:s", time());
+        Db::startTrans();
+        try {
+            $this->db_->where('trade_no', $trade_no)->update($params);
+            Db::commit();
+            return 1;
+        } catch (\Exception $e) {
+            Db::rollback();
+            return 0;
+        }
     }
 
 }

application/route.php

@@ -1099,10 +1099,11 @@ Route::group('broker', [
     'subletList'          => ['api_broker/Sublet/subletList', ['method' => 'GET']],//委托转铺列表
     'getUserLookShopList' => ['api_broker/Shop/getUserLookShopList', ['method' => 'GET']],//获取客户浏览商铺数据
 
-    'addAmercement'     => ['api_broker/Amercement/addAmercement', ['method' => 'GET|POST']],
-    'getAmercementType' => ['api_broker/Amercement/getAmercementType', ['method' => 'GET|POST']],
-    'getAmercementList' => ['api_broker/Amercement/getAmercementList', ['method' => 'GET|POST']],
-    'savePayAmercement' => ['api_broker/Amercement/savePayAmercement', ['method' => 'GET|POST']],
+    'addAmercement'      => ['api_broker/Amercement/addAmercement', ['method' => 'GET|POST']],
+    'getAmercementType'  => ['api_broker/Amercement/getAmercementType', ['method' => 'GET|POST']],
+    'getAmercementList'  => ['api_broker/Amercement/getAmercementList', ['method' => 'GET|POST']],
+    'savePayAmercement'  => ['api_broker/Amercement/savePayAmercement', ['method' => 'GET|POST']],
+    'getPayStatusByCurl' => ['api_broker/Amercement/getPayStatusByCurl', ['method' => 'GET|POST']],
 
 ]);