418 lines
14 KiB
PHP
418 lines
14 KiB
PHP
<?php
|
||
|
||
namespace app\lib;
|
||
|
||
use app\util\Tools;
|
||
use app\util\ReturnCode;
|
||
use think\facade\Response;
|
||
use think\facade\Env;
|
||
use think\Exception;
|
||
use app\util\Aes;
|
||
use app\model\CebReportResult;
|
||
use think\facade\Log;
|
||
|
||
/**
|
||
* 光大银行系统接口
|
||
*/
|
||
class CEBApi
|
||
{
|
||
//光大银行接收询价结果接口
|
||
const ESZ004_API = '/webapi/Cebbank/ESZ004/returnESZ004Info';
|
||
const ESZ009_API = '/webapi/Cebbank/ESZ009/returnESZ009Info';
|
||
const ESZ011_API = '/webapi/Cebbank/ESZ011/returnESZ011Info';
|
||
const ESZ006_API = '/webapi/Cebbank/ESZ006/returnESZ006Info'; // 2.2.2 评估报告结果返回申请
|
||
|
||
//接收正式评估结果接口
|
||
const OFFICIAL_ESTIMATE_API = '/jkpt/pggsApi/estimate/receiveOff';
|
||
|
||
private $cebhost;
|
||
private $ftp_server = "";
|
||
private $ftp_port = 0;
|
||
private $ftp_user_name = "";
|
||
private $ftp_user_pass = "";
|
||
|
||
public function __construct(){
|
||
|
||
$this->ftp_server = Env::get('cebapi.ceb_ftp_host');
|
||
|
||
|
||
|
||
$key_env = Env::get('cebapi.KEY_ENV');
|
||
if ( $key_env == "TEST") {
|
||
$this->cebhost = Env::get('cebapi.ceb_test_host');
|
||
$this->ftp_port = Env::get('cebapi.ceb_test_ftp_port');
|
||
} else { // PROD
|
||
$this->cebhost = Env::get('cebapi.ceb_prop_host');
|
||
$this->ftp_port = Env::get('cebapi.ceb_prod_ftp_port');
|
||
}
|
||
|
||
$this->ftp_user_name = Env::get('cebapi.ftp_user_name');
|
||
$this->ftp_user_pass = Env::get('cebapi.ftp_user_pass');
|
||
}
|
||
|
||
public function getFileFromFtp($remotefile) {
|
||
$ret['code'] = 1;
|
||
$ret['data'] = "";
|
||
try
|
||
{
|
||
$sftp = new SFTPConnection($this->ftp_server, $this->ftp_port);
|
||
$sftp->login($this->ftp_user_name, $this->ftp_user_pass);
|
||
$fileData = $sftp->getFile( $remotefile);
|
||
$ret['data'] = $fileData;
|
||
return $ret;
|
||
}
|
||
catch (Exception $e)
|
||
{
|
||
$ret['code'] = -1;
|
||
$ret['data'] = $e->getMessage() ;
|
||
return $ret;
|
||
}
|
||
}
|
||
public function sendFileToFtp($localfile, $path, $remotefile) {
|
||
|
||
try
|
||
{
|
||
$sftp = new SFTPConnection($this->ftp_server, $this->ftp_port);
|
||
$sftp->login($this->ftp_user_name, $this->ftp_user_pass);
|
||
$sftp->uploadFile($localfile, $path, $remotefile);
|
||
Log::debug('upload to ftp:' . $remotefile);
|
||
}
|
||
catch (Exception $e)
|
||
{
|
||
echo $e->getMessage() . "\n";
|
||
return false;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
// 2.2.2 评估报告结果返回申请
|
||
public function getURLESZ006(){
|
||
return $this->cebhost . self::ESZ006_API;
|
||
}
|
||
|
||
public function getURLESZ004() {
|
||
return $this->cebhost . self::ESZ004_API;
|
||
}
|
||
|
||
public function getURLESZ011() {
|
||
return $this->cebhost . self::ESZ011_API;
|
||
}
|
||
public function getURLESZ009() {
|
||
return $this->cebhost . self::ESZ009_API;
|
||
}
|
||
|
||
public function sendInquiryResult($data) {
|
||
$url = $this->getURLESZ004();
|
||
$cebData['businessNo'] = $data['business_no'] ;
|
||
$cebData['companyCode'] = $data['company_code'] ;
|
||
$cebData['businessType'] = $data['business_type'] ;
|
||
if($data['business_type'] == "01") { //贷前询价
|
||
$cebData['unitPriceDetail'] = "0";
|
||
$cebData['guidedUnitPriceDetail'] = "0";
|
||
}else if ($data['business_type'] == "02"){ //贷中询价
|
||
$cebData['unitPriceDetail'] = $data['unitPriceDetail'];
|
||
$cebData['guidedUnitPriceDetail'] = $data['guidedUnitPriceDetail'];
|
||
}
|
||
$cebData['certificateNo'] = $data['certificate_no'] ;
|
||
$cebData['estimateDealNo'] = $data['estimate_deal_no'];
|
||
$cebData['totalPrice'] = $data['eva_total_value'] ;
|
||
$cebData['chargeAmt'] = $data['charge_amt'] ;
|
||
$cebData['guidedPrice'] = $data['guide_price'] ;
|
||
$cebData['netWorth'] = $data['eva_net_value'] ;
|
||
$cebData['evaluatorName'] = $data['evaluator_name'] ;
|
||
$cebData['telephoneNumber'] = $data['telephone_number'] ;
|
||
$cebData['estimateTime'] = $data['estimate_time'] ;
|
||
$cebData['status'] = $data['status'] ;
|
||
$cebData['field1'] = '' ;
|
||
$cebData['field2'] = '' ;
|
||
if(isset($data['reason'])) {
|
||
$cebData['field3'] = $data['reason'];
|
||
}else {
|
||
$cebData['field3'] = '';
|
||
}
|
||
return $this->sendToCEB($url,$cebData,"ESZ004");
|
||
}
|
||
|
||
public function sendReevaluateResult($data) {
|
||
$url = $this->getURLESZ011();
|
||
|
||
$cebData['businessNo'] = $data['businessNo'] ;
|
||
$cebData['companyCode'] = $data['companyCode'] ;
|
||
$cebData['estimateDealNo'] = $data['estimateDealNo'] ;
|
||
$cebData['reevaluatedFileName'] = $data['reevaluatedFileName'] ;
|
||
$cebData['reevaluatedFileEnd'] = $data['reevaluatedFileEnd'] ;
|
||
$cebData['reevaluatedFilePath'] = $data['reevaluatedFilePath'] ;
|
||
$cebData['status'] = $data['status'] ;
|
||
|
||
|
||
$cebData['estimateTime'] = $data['estimateTime'] ;
|
||
|
||
$cebData['field1'] = '' ;
|
||
$cebData['field2'] = '' ;
|
||
if(isset($data['reason'])) {
|
||
$cebData['field3'] = $data['reason'];
|
||
}else {
|
||
$cebData['field3'] = '';
|
||
}
|
||
|
||
return $this->sendToCEB($url,$cebData,"ESZ011");
|
||
}
|
||
/**
|
||
* ESZ006 预评估和正式报告回复 function
|
||
*
|
||
* @param [type] $data
|
||
* @return void
|
||
*/
|
||
public function sendReportResult($data) {
|
||
$url = $this->getURLESZ006();
|
||
$cebData['businessNo'] = $data['business_no'] ;
|
||
$cebData['companyCode'] = $data['company_code'] ;
|
||
$cebData['businessType'] = $data['business_type'] ;
|
||
$cebData['returnReportType'] = $data['return_report_type'] ;
|
||
$cebData['unitPrice'] = $data['eva_unit_price'] ;
|
||
$cebData['estimateDealNo'] = $data['estimate_deal_no']; //已有预估编号，不需要再加公司编码做前缀
|
||
$cebData['totalPrice'] = $data['eva_total_value'] ;
|
||
$cebData['totalTax'] = $data['total_tax'] ;
|
||
$cebData['detailTax'] = $data['detail_tax'];
|
||
$cebData['chargeAmt'] = $data['charge_amt'] ;
|
||
$cebData['guidedPrice'] = $data['guide_price'] ;
|
||
$cebData['netWorth'] = $data['eva_net_value'] ;
|
||
$cebData['estimateReportName'] = $data['estimate_report_name'] ;
|
||
$cebData['estimateReportEnd'] = $data['estimate_report_end'] ;
|
||
$cebData['estimateReportPath'] = $data['estimate_report_path'] ;
|
||
|
||
if( $data['business_type'] == CebReportResult::BUSINESS_TYPE_REPORT )
|
||
{
|
||
$cebData['mortgagor1'] = $data['mortgagor1'] ;
|
||
$cebData['mortgagor2'] = $data['mortgagor2'] ;
|
||
$cebData['mortgagor3'] = $data['mortgagor3'] ;
|
||
$cebData['mortgagor4'] = $data['mortgagor4'] ;
|
||
$cebData['mortgagor5'] = $data['mortgagor5'] ;
|
||
$cebData['mortgagor6'] = $data['mortgagor6'] ;
|
||
$cebData['field1'] = $data['field1'] ;
|
||
} else {
|
||
$cebData['mortgagor1'] = "" ;
|
||
$cebData['mortgagor2'] = "" ;
|
||
$cebData['mortgagor3'] = "" ;
|
||
$cebData['mortgagor4'] = "" ;
|
||
$cebData['mortgagor5'] = "" ;
|
||
$cebData['mortgagor6'] = "" ;
|
||
$cebData['field1'] = '';
|
||
}
|
||
|
||
|
||
|
||
$cebData['resultStatus'] = $data['result_status'] ;
|
||
$cebData['reason'] = $data['reason'] ;
|
||
|
||
$cebData['field2'] = '' ;
|
||
$cebData['field3'] = '' ;
|
||
$cebData['estimateTime'] = $data['estimate_time'] ;
|
||
|
||
|
||
|
||
return $this->sendToCEB($url,$cebData,"ESZ006");
|
||
}
|
||
|
||
|
||
|
||
public function sendCheckResult($data) {
|
||
$url = $this->getURLESZ009();
|
||
$cebData['businessNo'] = $data['business_no'] ;
|
||
$cebData['companyCode'] = $data['company_code'] ;
|
||
$cebData['estimateDealNo'] = $data['estimate_deal_no'];
|
||
$cebData['checkTotalPrice'] = $data['check_total_price'] ;
|
||
$cebData['checkNetWorth'] = $data['check_net_worth'] ;
|
||
$cebData['checkChargeAmt'] = $data['check_charge_amt'] ;
|
||
|
||
$cebData['checkTime'] = $data['check_time'] ;
|
||
$cebData['checkStatus'] = $data['check_status'] ;
|
||
$cebData['field1'] = '' ;
|
||
$cebData['field2'] = '' ;
|
||
if(isset($data['reason'])){
|
||
$cebData['field3'] = $data['reason'] ;
|
||
}else{
|
||
$cebData['field3'] = '' ;
|
||
}
|
||
|
||
|
||
return $this->sendToCEB($url,$cebData,"ESZ009");
|
||
}
|
||
|
||
/**
|
||
*发送给银行
|
||
*/
|
||
public function sendToCEB($url,$data,$tranCode) {
|
||
Log::debug("--------------------发送给光大银行-------------------");
|
||
Log::debug($url);
|
||
Log::debug($data);
|
||
//$arr_header['Content-Type'] = "application/json; charset=utf-8";
|
||
//$arr_header['Cebsz'] ="oemp";
|
||
//$arr_header['tranCode'] =$tranCode;
|
||
$arr_header = array(
|
||
"Content-Type: application/json; charset=utf-8",
|
||
"User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/111.0.0.0 Safari/537.36",
|
||
"Cebsz:oemp",
|
||
"tranCode:" . $tranCode . ""
|
||
);
|
||
|
||
$httpreturn = $this->http_post($url,$data,false,60,$arr_header);
|
||
Log::debug("------------------Http post 返回-------------");
|
||
try{
|
||
Log::debug($httpreturn);
|
||
}catch(Exception $e){
|
||
Log::warning($e->getMessage());
|
||
}
|
||
return $httpreturn;
|
||
}
|
||
|
||
public function responseToCEB($code,$msg,$data) {
|
||
$res['code'] = $code;
|
||
$res['message'] = $msg;
|
||
$res['data'] = $data;
|
||
|
||
$response = Response::create($res, 'json');
|
||
return $response;
|
||
}
|
||
|
||
|
||
/**
|
||
* GET 请求
|
||
* @param string $url
|
||
*/
|
||
public function http_get($url,$param,$arr_header=array()){
|
||
$oCurl = curl_init();
|
||
if (is_string($param)) {
|
||
$strPOST = $param;
|
||
} else {
|
||
$aPOST = array();
|
||
foreach ($param as $key => $val) {
|
||
$aPOST[] = $key . "=" . $val;
|
||
}
|
||
$strPOST = join("&", $aPOST);
|
||
}
|
||
$url = $url."?".$strPOST;
|
||
if (stripos($url, "https://") !== false) {
|
||
curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, false);
|
||
curl_setopt($oCurl, CURLOPT_SSL_VERIFYHOST, false);
|
||
curl_setopt($oCurl, CURLOPT_SSLVERSION, 1); //CURL_SSLVERSION_TLSv1
|
||
}
|
||
curl_setopt($oCurl, CURLOPT_URL, $url);
|
||
curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1);
|
||
if(!empty($arr_header)){
|
||
$arr_header[] = "Content-Type: application/json; charset=utf-8";
|
||
}
|
||
curl_setopt($oCurl, CURLOPT_HTTPHEADER, $arr_header);
|
||
|
||
$sContent = curl_exec($oCurl);
|
||
if (curl_errno($oCurl)){
|
||
throw new Exception(curl_error($oCurl),0);
|
||
}else{
|
||
$httpStatusCode = curl_getinfo($oCurl, CURLINFO_HTTP_CODE);
|
||
if (200 !== $httpStatusCode){
|
||
|
||
throw new Exception($arr_header[1],$httpStatusCode);
|
||
}
|
||
}
|
||
curl_close($oCurl);
|
||
return $sContent;
|
||
}
|
||
|
||
/**
|
||
* POST 请求
|
||
* @param string $url
|
||
* @param array $param
|
||
* @param boolean $post_file 是否文件上传
|
||
* @param boolean $timeout 超时时间，单位秒
|
||
* @param boolean $arr_header http请求头
|
||
* @return string content
|
||
*/
|
||
public function http_post($url, $param, $post_file = false, $timeout = 30,$arr_header=array()){
|
||
$ch = curl_init();
|
||
|
||
curl_setopt_array($ch, array(
|
||
// 不直接输出，返回到变量
|
||
CURLOPT_RETURNTRANSFER => true,
|
||
// 设置超时为60s，防止机器被大量超时请求卡死
|
||
CURLOPT_TIMEOUT => $timeout
|
||
));
|
||
// 支持POST请求
|
||
if (!empty($param)) {
|
||
curl_setopt_array($ch, array(
|
||
CURLOPT_POST => true,
|
||
// 设置POST参数
|
||
CURLOPT_POSTFIELDS => json_encode($param)
|
||
));
|
||
}
|
||
/*
|
||
if (is_string($param) || $post_file) {
|
||
$strPOST = $param;
|
||
} else {
|
||
$aPOST = array();
|
||
foreach ($param as $key => $val) {
|
||
$aPOST[] = $key . "=" . $val;
|
||
}
|
||
$strPOST = join("&", $aPOST);
|
||
}
|
||
*/
|
||
curl_setopt($ch, CURLOPT_URL, $url);
|
||
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, $arr_header);
|
||
|
||
$sContent = curl_exec($ch);
|
||
$aStatus = curl_getinfo($ch);
|
||
curl_close($ch);
|
||
|
||
if (intval($aStatus["http_code"]) == 200) {
|
||
return $sContent;
|
||
} else {
|
||
return $aStatus;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* DELETE 请求
|
||
* @param string $url
|
||
* @param array $param
|
||
* @param boolean $user_name AUTH账号
|
||
* @param boolean $password AUTH密码
|
||
* @return string content
|
||
*/
|
||
function http_delete($url,$param,$user_name,$password) {
|
||
$oCurl = curl_init();
|
||
|
||
if (is_string($param)) {
|
||
$strPOST = $param;
|
||
} else {
|
||
$aPOST = array();
|
||
foreach ($param as $key => $val) {
|
||
$aPOST[] = $key . "=" . $val;
|
||
}
|
||
$strPOST = join("&", $aPOST);
|
||
}
|
||
$url = $url."?".$strPOST;
|
||
|
||
curl_setopt($oCurl, CURLOPT_URL, $url);
|
||
curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1);
|
||
curl_setopt($oCurl, CURLOPT_CUSTOMREQUEST, 'DELETE');
|
||
|
||
//设置头
|
||
curl_setopt($oCurl, CURLOPT_USERPWD, "{$user_name}:{$password}");
|
||
curl_setopt($oCurl, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/57.0.2987.98 Safari/537.36');
|
||
|
||
curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, false);//SSL认证。
|
||
$sContent = curl_exec($oCurl);
|
||
$aStatus = curl_getinfo($oCurl);
|
||
|
||
curl_close($oCurl);
|
||
|
||
if (intval($aStatus["http_code"]) == 200) {
|
||
return $sContent;
|
||
} else {
|
||
return false;
|
||
}
|
||
}
|
||
|
||
|
||
}
|