573 lines
16 KiB
PHP
573 lines
16 KiB
PHP
<?php
|
||
|
||
namespace app\channel\service\system;
|
||
use app\channel\service\KamiService;
|
||
use app\merchant\service\MerchantService;
|
||
use app\merchant\service\OrderService;
|
||
use dever\Log;
|
||
use think\facade\Db;
|
||
|
||
/**
|
||
* 骏网接口--汇元重构版本--无换卡逻辑
|
||
* Class HyJk
|
||
*
|
||
* @package app\channel\service
|
||
*/
|
||
class HyJk2 extends Core
|
||
{
|
||
# 这几个可以后台设置
|
||
protected $host = '';
|
||
protected $mid = '';
|
||
protected $token = '';
|
||
protected $api = '';
|
||
protected $aeskey = '';
|
||
|
||
# 通用卡，只需后台设置卡种
|
||
public function cardbuy($param)
|
||
{
|
||
$check = array
|
||
(
|
||
'num' => 'product_num',
|
||
);
|
||
|
||
$this->api = 'UCard/UCardFetchSubmit.aspx';
|
||
return $this->submit($param, $check);
|
||
}
|
||
|
||
|
||
# 提单接口
|
||
private function submit($param, $check)
|
||
{
|
||
$param = $this->param($param, $check);
|
||
if (is_string($param) || (is_array($param) && $param['status'] == 1)) {
|
||
return $param;
|
||
}
|
||
|
||
|
||
$request = $param['detail'];
|
||
$request['agent_id'] = $this->mid;
|
||
$request['bill_id'] = $param['order'];
|
||
$request['bill_time'] = date('YmdHis');
|
||
$request['card_kind']= $this->getGid($param['cash']);
|
||
$request['product_code'] = $this->GoodId($param['cash']);
|
||
$request['time_stamp'] = date('YmdHis');
|
||
|
||
$request['sign'] = $this->_sign($request, array('agent_id', 'bill_id', 'bill_time', 'product_code', 'product_num', 'card_kind','time_stamp'));
|
||
$url = $this->host . $this->api;
|
||
|
||
|
||
|
||
|
||
$KamiService = KamiService::instance();
|
||
$kami_group_id = $this->product['cid'].'00'.$this->product['service_id'];
|
||
|
||
#通过后台其他参数确定参与换卡
|
||
|
||
# Secondary_sales_type二次销售类型1为全部支持二销，2为部分支持二销
|
||
|
||
$channel_other_data = $this->channel['other_data'];
|
||
$channel_other_data_array = json_decode($channel_other_data, true);
|
||
$randomKami = null;
|
||
if(is_array($channel_other_data_array) && isset($channel_other_data_array['Secondary_sales_type'])){
|
||
$m_id = $this->data['merchant'];
|
||
|
||
|
||
if($channel_other_data_array['Secondary_sales_type'] == 1) {
|
||
|
||
// var_dump($m_id);die;
|
||
|
||
$randomKami = $KamiService->getData($param['cash'],$m_id, 1, true, false, $kami_group_id);
|
||
|
||
if(!$randomKami){
|
||
$randomKami = $KamiService->getData($param['cash'],$m_id, 1, true, false, '100'.$this->product['service_id']);
|
||
}
|
||
}elseif($channel_other_data_array['Secondary_sales_type'] == 2){
|
||
$Secondary_sales= $channel_other_data_array['Secondary_sales'] ?? false;
|
||
if($Secondary_sales && in_array($this->product['service_id'], $Secondary_sales)){
|
||
$randomKami = $KamiService->getData($param['cash'],$m_id, 1, true, false, $kami_group_id);
|
||
if(!$randomKami){
|
||
$randomKami = $KamiService->getData($param['cash'],$m_id, 1, true, false, '100'.$this->product['service_id']);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
if ($randomKami) {
|
||
|
||
#解锁卡密
|
||
$cards = [
|
||
'cardno' => $randomKami['cnum'],
|
||
'cardpwd' => $randomKami['cpwd'],
|
||
];
|
||
$unlocks = $this->UnLockCards($cards, $param['cash']);
|
||
if($unlocks == 'ok'){
|
||
$randomKami_data = [
|
||
'is_kami' =>1,
|
||
];
|
||
|
||
$msg = 'yescard';
|
||
$randomKami_data['kami'] = array
|
||
(
|
||
'cardno'=>$randomKami['cnum'],
|
||
'cardpwd'=>$randomKami['cpwd'],
|
||
'expired'=>$randomKami['expire_time'],
|
||
'value'=>$randomKami['value'],
|
||
);
|
||
$response = [
|
||
'msg' => $msg,
|
||
'data' => $randomKami_data,
|
||
'array' => $randomKami_data,
|
||
];
|
||
}else{
|
||
#解锁失败
|
||
$data = array();
|
||
$data['cnum'] = $randomKami['cnum'];
|
||
$data['cpwd'] = $randomKami['cpwd'];
|
||
$data['value'] = $randomKami['value'];
|
||
$KamiService->db()->where($data)->update(['status'=>0,'use_info'=>'解锁失败，请核验']);
|
||
// var_dump(223);die;
|
||
$response = $this->curl('get', $url, $request);
|
||
$response = $this->response($response);
|
||
}
|
||
|
||
|
||
|
||
|
||
} else {
|
||
// var_dump(223);die;
|
||
$response = $this->curl('get', $url, $request);
|
||
$response = $this->response($response);
|
||
}
|
||
|
||
$channel_order_id = '';
|
||
if (isset($response['array']['jnet_bill_no'])) {
|
||
$channel_order_id = $response['array']['jnet_bill_no'];
|
||
}
|
||
|
||
if(isset($param['account'])){
|
||
|
||
}elseif(isset($response['kami']['cardno']) ){
|
||
$param['account'] = $response['kami']['cardno'];
|
||
}else{
|
||
$param['account'] = $request['card_kind'];
|
||
}
|
||
|
||
$this->create($param['order'], $channel_order_id, $param['merchant_order'], $param['cash'], $url, $request, $response, 1, $param['account']);
|
||
return $response['msg'];
|
||
}
|
||
|
||
#获取固定的产品编码
|
||
private function GoodId($cash)
|
||
{
|
||
|
||
$goodId = [
|
||
'10' => 'AAJWVVXKYK010FV',
|
||
'15' => 'AAJWVVXKYK015FV',
|
||
'20' => 'AAJWVVXKYK020FV',
|
||
'30' => 'AAJWVVXKYK030FV',
|
||
'50' => 'AAJWVVXKYK050FV',
|
||
'100' => 'AAJWVVXKYK100FV',
|
||
'120' => 'AAJWVVXKYK120FV',
|
||
'200' => 'AAJWVVXKYK200FV',
|
||
'500' => 'AAJWVVXKYK500FV',
|
||
'1000' => 'AAJWVVXKYK1K0FV'
|
||
];
|
||
return $goodId[$cash] ?? '';
|
||
|
||
}
|
||
|
||
|
||
|
||
# 数据响应格式处理
|
||
|
||
private function _sign($request, $param)
|
||
{
|
||
$signature_string = '';
|
||
foreach ($param as $k => $v) {
|
||
|
||
$signature_string .= $v . '=' . $request[$v] . '&';
|
||
|
||
}
|
||
|
||
$signature_string = substr($signature_string, 0, -1);
|
||
|
||
$signature_string .= '|||'.$this->token;
|
||
|
||
return md5($signature_string);
|
||
}
|
||
|
||
public function response($data)
|
||
{
|
||
$data = iconv('GBK', 'UTF-8', $data);
|
||
// $data = $this->charsetToUTF8($data);
|
||
$log['type'] = 'response';
|
||
$log['data'] = $data;
|
||
$log['config'] = $this->data;
|
||
$this->log($log);
|
||
|
||
$pairs = explode('&', $data);
|
||
|
||
$array = [];
|
||
foreach ($pairs as $pair) {
|
||
// 分割键和值
|
||
list($key, $value) = explode('=', $pair);
|
||
// 解码键和值
|
||
$array[urldecode($key)] = urldecode($value);
|
||
}
|
||
|
||
|
||
if (!$array) {
|
||
$msg = 'error';
|
||
} elseif (isset($array['ret_code']) && $array['ret_code'] == '0' || $array['ret_code'] == '999') {
|
||
# 正确
|
||
if(isset($array['card_no_data'])){
|
||
|
||
$msg = 'yescard';
|
||
$kami = $this->decrypt_3des($array['card_no_data']);
|
||
|
||
$kami = explode(',', $kami);
|
||
$array['kami'] = array
|
||
(
|
||
'cardno' => $kami[0],
|
||
'cardpwd' => $kami[1],
|
||
'expired' => $kami[2],
|
||
'value' => $array['par_price'],
|
||
);
|
||
|
||
}else{
|
||
$msg = 'ok';
|
||
}
|
||
|
||
} else {
|
||
# 错误
|
||
$msg = $array['ret_msg'] ?? 'error';
|
||
}
|
||
|
||
|
||
return array
|
||
(
|
||
'msg' => $msg,
|
||
'data' => $array,
|
||
'array' => $array,
|
||
);
|
||
}
|
||
|
||
public function decrypt_3des($encrypted_string,$aeskey = ''){
|
||
|
||
$cipher = "des-ede3"; // 3des-ebc 使用的是des-ede3算法
|
||
$mode = "ebc"; // 工作模式为ebc
|
||
|
||
$iv = ""; // EBC模式不需要IV，留空即可
|
||
$json = $this->channel['describe'];
|
||
$array = $this->json_decode($json);
|
||
if(!$aeskey){
|
||
if(isset($array['aeskey'])){
|
||
$this->aeskey = $array['aeskey'];
|
||
}
|
||
}else{
|
||
$this->aeskey = $aeskey;
|
||
}
|
||
|
||
return openssl_decrypt(hex2bin($encrypted_string), $cipher, $this->aeskey, $options=OPENSSL_RAW_DATA, $iv); // 输出解密后的字符串
|
||
}
|
||
|
||
#换卡查询接口
|
||
|
||
|
||
# 查询接口
|
||
|
||
public function lockCard($order)
|
||
{
|
||
|
||
$lockCard = $this->lockCards($order,'首次锁定');
|
||
// var_dump($lockCard);die;
|
||
|
||
|
||
|
||
|
||
if($lockCard == 'ok'){
|
||
|
||
$KamiService = KamiService::instance();
|
||
|
||
$response = $this->json_decode($order['response']);
|
||
$cardno = $response['kami']['cardno'];
|
||
$cardpwd = $response['kami']['cardpwd'];
|
||
$expired = $response['kami']['expired'];
|
||
$value = $response['kami']['value'];
|
||
$where['id'] = $order['pid'];
|
||
$where['status'] = 1;
|
||
$channel_product = Db::name('channel_product')->where($where)->find();
|
||
$service_id = $channel_product['service_id'];
|
||
$kami_group_id = $order['cid'].'00'.$service_id;
|
||
|
||
|
||
$upkami = $KamiService->upKami($cardno, $cardpwd, $value, $expired,$kami_group_id,$order['mid']);
|
||
|
||
|
||
|
||
|
||
|
||
if($upkami){
|
||
return 'ok';
|
||
}else{
|
||
$KamiService->db()->where(['cnum'=>$cardno,'cpwd'=>$cardpwd,'value'=>$value])->update(['use'=>1,'use_mid'=>$order['mid']]);
|
||
$logss['type'] = 'Restorage';
|
||
$logss['data'] = [
|
||
'cardno'=>$cardno,
|
||
'cpwd'=>$cardpwd,
|
||
'value'=>$value,
|
||
'order_id'=>$order['order_id'],
|
||
];
|
||
Log::write('kami', 'Secondary_sales', $logss);
|
||
|
||
return 'old_ok';
|
||
}
|
||
|
||
}else{
|
||
return 'error';
|
||
}
|
||
|
||
|
||
|
||
|
||
}
|
||
|
||
public function UnlockCard($order,$desc = '')
|
||
{
|
||
return $this->lockCards($order,'解锁',2);
|
||
|
||
}
|
||
|
||
public function lockCards($order,$desc = '',$lock_type = 1)
|
||
{
|
||
$request = [
|
||
'agent_id' => $this->mid,
|
||
'card_from_type' => 0,
|
||
'lock_type' => $lock_type,
|
||
'lock_amt_fen'=>$order['cash']*100,
|
||
|
||
];
|
||
|
||
$response = $this->json_decode($order['response']);
|
||
if(empty($response['kami'])){
|
||
return '未找到卡密';
|
||
}
|
||
$kami_data = $response['kami']['cardno'].'='. $response['kami']['cardpwd'];
|
||
|
||
|
||
|
||
|
||
$request['card_data'] = $this->aes_encrypt($kami_data);
|
||
|
||
|
||
$request['card_style'] = 1;
|
||
if($desc){
|
||
$request['desc'] = $desc;
|
||
}
|
||
|
||
$request['time_stamp'] = date('YmdHis');
|
||
$request['sign'] = $this->_sign($request, array('agent_id', 'card_data', 'card_style', 'lock_amt_fen', 'lock_type', 'time_stamp'));
|
||
$url = $this->host.'UCard/UCardJPointLock.aspx';
|
||
$response = http_get($url,$request);
|
||
// var_dump($request);die;
|
||
|
||
$response = iconv('GBK', 'UTF-8', $response);
|
||
// var_dump($response);die;
|
||
|
||
$pairs = explode('&', $response);
|
||
|
||
$array = [];
|
||
//
|
||
foreach ($pairs as $pair) {
|
||
// 分割键和值
|
||
list($key, $value) = explode('=', $pair);
|
||
// 解码键和值
|
||
$array[urldecode($key)] = urldecode($value);
|
||
}
|
||
|
||
if (!$array) {
|
||
|
||
$msg = 'error';
|
||
} elseif (isset($array['ret_code']) && $array['ret_code'] == '0' ) {
|
||
# 正确
|
||
if ((isset($array['total_amt_fen']) && ($array['total_amt_fen'] == $array['current_lock_amt_fen']) && $array['total_amt_fen'] == $request['lock_amt_fen']))$msg = 'ok';
|
||
else $msg = '金额错误';
|
||
|
||
|
||
|
||
} elseif(isset($array['ret_msg']) && $array['ret_code'] == '1' && $array['ret_msg'] == '该卡已被锁定' && ($array['total_amt_fen'] == $array['current_lock_amt_fen']) ) {
|
||
$msg = 'old_ok';
|
||
|
||
}else{
|
||
# 错误
|
||
$msg = $array['ret_msg'] ?? 'error';
|
||
|
||
}
|
||
|
||
return $msg;
|
||
|
||
|
||
}
|
||
|
||
# 提交数据
|
||
|
||
public function UnLockCards($cards,$cash){
|
||
$request = [
|
||
'agent_id' => $this->mid,
|
||
'card_from_type' => 0,
|
||
'lock_type' => 2,
|
||
'lock_amt_fen'=>$cash*100,
|
||
|
||
];
|
||
|
||
|
||
$kami_data = $cards['cardno'].'='. $cards['cardpwd'];
|
||
|
||
|
||
|
||
$request['card_data'] = $this->aes_encrypt($kami_data);
|
||
|
||
$request['card_style'] = 1;
|
||
|
||
$request['desc'] = '二销解锁';
|
||
|
||
|
||
$request['time_stamp'] = date('YmdHis');
|
||
$request['sign'] = $this->_sign($request, array('agent_id', 'card_data', 'card_style', 'lock_amt_fen', 'lock_type', 'time_stamp'));
|
||
$url = $this->host.'UCard/UCardJPointLock.aspx';
|
||
$response = http_get($url,$request);
|
||
|
||
$response = iconv('GBK', 'UTF-8', $response);
|
||
|
||
Log::write('kami', 'test_unlock_jc', $request);
|
||
Log::write('kami', 'test_unlock_jc', $response);
|
||
$pairs = explode('&', $response);
|
||
|
||
$array = [];
|
||
//
|
||
foreach ($pairs as $pair) {
|
||
// 分割键和值
|
||
list($key, $value) = explode('=', $pair);
|
||
// 解码键和值
|
||
$array[urldecode($key)] = urldecode($value);
|
||
}
|
||
|
||
if (!$array) {
|
||
|
||
$msg = 'error';
|
||
} elseif (isset($array['ret_code']) && $array['ret_code'] == '0' ) {
|
||
if ((isset($array['total_amt_fen']) && ($array['total_amt_fen'] == $array['current_lock_amt_fen']) && $array['total_amt_fen'] == $request['lock_amt_fen']))$msg = 'ok';
|
||
else $msg = '金额错误';
|
||
|
||
|
||
|
||
} else{
|
||
# 错误
|
||
$msg = $array['ret_msg'] ?? 'error';
|
||
|
||
}
|
||
|
||
return $msg;
|
||
|
||
|
||
|
||
}
|
||
|
||
private function aes_encrypt($data,$aeskey = '') {
|
||
|
||
$data = iconv('UTF-8', 'GBK', $data);
|
||
|
||
$json = $this->channel['describe'];
|
||
$array = $this->json_decode($json);
|
||
if(!$aeskey){
|
||
if(isset($array['aeskey'])){
|
||
$this->aeskey = $array['aeskey'];
|
||
}
|
||
}else{
|
||
$this->aeskey = $aeskey;
|
||
}
|
||
|
||
|
||
$encrypted = openssl_encrypt($data, 'des-ede3', $this->aeskey , OPENSSL_RAW_DATA);
|
||
|
||
return base64_encode($encrypted);
|
||
}
|
||
|
||
|
||
public function query($order)
|
||
{
|
||
$orderRequest = json_decode($order['request'], true);
|
||
$request['agent_id'] = $this->mid;
|
||
$request['bill_id'] = $order['order_id'];
|
||
$request['time_stamp'] =date('YmdHis');
|
||
|
||
$request['sign'] = $this->_sign($request, array('agent_id', 'bill_id', 'time_stamp'));
|
||
$url = $this->host . 'UCard/UCardFetchQuery.aspx';
|
||
$response = $this->curl('get', $url, $request);
|
||
$response = iconv('GBK', 'UTF-8', $response);
|
||
|
||
$log['type'] = 'query_response';
|
||
$log['data'] = $response;
|
||
$log['config'] = $this->data;
|
||
$this->log($log);
|
||
$pairs = explode('&', $response);
|
||
$array = [];
|
||
foreach ($pairs as $pair) {
|
||
// 分割键和值
|
||
list($key, $value) = explode('=', $pair);
|
||
// 解码键和值
|
||
$array[urldecode($key)] = urldecode($value);
|
||
}
|
||
|
||
|
||
|
||
$result = array();
|
||
// $result['status'] = 4;
|
||
if (isset($array['ret_code']) && $array['ret_code'] == '0') {
|
||
if(isset($array['card_no_data'])){
|
||
$kami = $this->decrypt_3des($array['card_no_data']);
|
||
$kami = explode(',', $kami);
|
||
$kamidata = [
|
||
'cardno' => $kami[0],
|
||
'cardpwd' => $kami[1],
|
||
'expired' => $kami[2],
|
||
|
||
];
|
||
|
||
$this->upOrderResponse($kamidata,$order['merchant_order_id'],$order['response']);
|
||
$result['status'] = 7;
|
||
$result['kami'] = $kamidata;
|
||
}else{
|
||
$result['status'] = 4;
|
||
}
|
||
|
||
} else{
|
||
$result['status'] = 3;
|
||
}
|
||
|
||
if (isset($array['jnet_bill_no']) && $array['jnet_bill_no']) {
|
||
# 流水号
|
||
// $result['status'] = 3;
|
||
//$data['s_nubmer'] = $result['s_nubmer'] = $data['result']['code'];
|
||
}
|
||
|
||
|
||
|
||
return $result;
|
||
|
||
}
|
||
|
||
public function upOrderResponse($kami,$merchant_order_id,$orderResponse)
|
||
{
|
||
$orderService = OrderService::instance();
|
||
|
||
$response = json_decode($orderResponse,true);
|
||
$response['kami'] = $kami;
|
||
$data = ['response' => json_encode($response)];
|
||
|
||
$orderService->db()->where(array('merchant_order_id' => $merchant_order_id))->update($data);
|
||
}
|
||
|
||
|
||
} |