469 lines
18 KiB
PHP
469 lines
18 KiB
PHP
<?php
|
||
|
||
namespace addons\wdsxh\library;
|
||
|
||
use app\admin\model\wdsxh\Config;
|
||
use app\admin\model\wdsxh\mall\Order;
|
||
use EasyWeChat\Factory;
|
||
use think\Exception;
|
||
use think\Log;
|
||
use GuzzleHttp\Client;
|
||
use GuzzleHttp\Psr7\Request;
|
||
use GuzzleHttp\Pool;
|
||
use GuzzleHttp\Exception\ClientException;
|
||
|
||
/**
|
||
* 微信处理类
|
||
*/
|
||
class Wxapp
|
||
{
|
||
public static function wxappInit($type = 0)
|
||
{
|
||
try {
|
||
$site = (new \app\admin\model\wdsxh\Config())->where('id',1)->find();
|
||
|
||
if ($type == 1) {
|
||
if (empty($site['mch_id'])) {
|
||
throw new \think\Exception('微信支付商户号未配置');
|
||
}
|
||
if (empty($site['key'])) {
|
||
throw new \think\Exception('微信支付秘钥未配置');
|
||
}
|
||
}
|
||
$appid = trim($site['applet_appid']);
|
||
$secret = trim($site['applet_secret']);
|
||
if ($type == 2) {
|
||
$appid = trim($site['wananchi_appid']);
|
||
$secret = trim($site['wananchi_secret']);
|
||
}
|
||
|
||
$config = [
|
||
'app_id' => $appid,
|
||
'secret' => $secret,
|
||
'mch_id' => empty($site['mch_id']) ? '' : trim($site['mch_id']),
|
||
'key' => empty($site['key']) ? '' : trim($site['key']),
|
||
'cert_path' => empty($site['cert_path']) ? '' : ROOT_PATH . 'public' . trim($site['cert_path']),
|
||
'key_path' => empty($site['key_path']) ? '' : ROOT_PATH . 'public' . trim($site['key_path']),
|
||
'notify_url' => '',
|
||
'response_type' => 'array',
|
||
'log' => [
|
||
'level' => 'debug',
|
||
'file' => RUNTIME_PATH . 'wechat.log',
|
||
],
|
||
];
|
||
if ($type == 0) {
|
||
return Factory::miniProgram($config);
|
||
} else {
|
||
return Factory::payment($config);
|
||
}
|
||
} catch (Exception $e) {
|
||
die($e->getMessage());
|
||
}
|
||
}
|
||
|
||
public static function getApp()
|
||
{
|
||
return self::wxappInit();
|
||
}
|
||
|
||
public static function getPay()
|
||
{
|
||
return self::wxappInit(1);
|
||
}
|
||
|
||
public static function getPayWxofficial()
|
||
{
|
||
return self::wxappInit(2);
|
||
}
|
||
|
||
public static function wxlogin($code)
|
||
{
|
||
return self::getApp()->auth->session($code);
|
||
}
|
||
|
||
public static function unify($body, $sn, $money, $openid, $notify_url)
|
||
{
|
||
$pay = self::getPay();
|
||
$result = $pay->order->unify([
|
||
'body' => $body,
|
||
'out_trade_no' => $sn,
|
||
'total_fee' => $money * 100,
|
||
'notify_url' => $notify_url,
|
||
'trade_type' => 'JSAPI',
|
||
'openid' => $openid,
|
||
]);
|
||
if ($result && $result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS' && isset($result['prepay_id'])) {
|
||
return $pay->jssdk->bridgeConfig($result['prepay_id'], false);
|
||
} else {
|
||
Log::record([
|
||
'body' => $body,
|
||
'out_trade_no' => $sn,
|
||
'total_fee' => $money * 100,
|
||
'notify_url' => $notify_url,
|
||
'trade_type' => 'JSAPI',
|
||
'openid' => $openid,
|
||
], 'info');
|
||
Log::record($result, 'info');
|
||
throw new \think\Exception(isset($result['return_msg']) ? $result['return_msg'] : '统一下单发生错误');
|
||
}
|
||
}
|
||
|
||
public static function unify_wxofficial($body, $sn, $money, $openid, $notify_url)
|
||
{
|
||
$pay = self::getPayWxofficial();
|
||
$result = $pay->order->unify([
|
||
'body' => $body,
|
||
'out_trade_no' => $sn,
|
||
'total_fee' => $money * 100,
|
||
'notify_url' => $notify_url,
|
||
'trade_type' => 'JSAPI',
|
||
'openid' => $openid,
|
||
]);
|
||
|
||
if ($result && $result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS' && isset($result['prepay_id'])) {
|
||
return $pay->jssdk->bridgeConfig($result['prepay_id'], false);
|
||
} else {
|
||
Log::record([
|
||
'body' => $body,
|
||
'out_trade_no' => $sn,
|
||
'total_fee' => $money * 100,
|
||
'notify_url' => $notify_url,
|
||
'trade_type' => 'JSAPI',
|
||
'openid' => $openid,
|
||
], 'info');
|
||
Log::record($result, 'info');
|
||
throw new \think\Exception(isset($result['err_code_des']) ? $result['err_code_des'] : '统一下单发生错误');
|
||
}
|
||
}
|
||
|
||
public static function weixinunify($body, $sn, $money, $openid, $notify_url)
|
||
{
|
||
$pay = self::getPay();
|
||
$result = $pay->order->unify([
|
||
'body' => $body,
|
||
'out_trade_no' => $sn,
|
||
'total_fee' => $money * 100,
|
||
'notify_url' => $notify_url,
|
||
'trade_type' => 'MWEB',
|
||
'openid' => $openid,
|
||
]);
|
||
p($result);
|
||
if ($result && $result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS' && isset($result['prepay_id'])) {
|
||
return $pay->jssdk->bridgeConfig($result['prepay_id'], false);
|
||
} else {
|
||
Log::record([
|
||
'body' => $body,
|
||
'out_trade_no' => $sn,
|
||
'total_fee' => $money * 100,
|
||
'notify_url' => $notify_url,
|
||
'trade_type' => 'JSAPI',
|
||
'openid' => $openid,
|
||
], 'info');
|
||
Log::record($result, 'info');
|
||
throw new \think\Exception(isset($result['return_msg']) ? $result['return_msg'] : '统一下单发生错误');
|
||
}
|
||
}
|
||
|
||
/*
|
||
* 退款操作
|
||
*/
|
||
public static function payRefund($number, $refundNumber, $refundFee, $config = null)
|
||
{
|
||
$pay = self::getPay();
|
||
try {
|
||
$result = $pay->refund->byOutTradeNumber($number, $refundNumber, intval($refundFee * 100), intval($refundFee * 100), $config ? $config : [
|
||
'refund_desc' => '支付后退款',
|
||
]);
|
||
} catch (\Exception $e) {
|
||
die($e->getMessage());
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
public static function phone($code, $iv, $encryptedData)
|
||
{
|
||
$app = self::getApp();
|
||
$openid = $app->auth->session($code);
|
||
if (empty($openid['openid']) || empty($openid['session_key'])) {
|
||
throw new \think\Exception('小程序登录失败');
|
||
}
|
||
return $app->encryptor->decryptData($openid['session_key'], $iv, $encryptedData);
|
||
}
|
||
|
||
public static function getQrcode($path)
|
||
{
|
||
$app = self::getApp();
|
||
$response = $app->app_code->get($path, array('width' => 280, 'is_hyaline' => true));
|
||
//$response = $app->app_code->getQrCode($path,280);
|
||
if ($response instanceof \EasyWeChat\Kernel\Http\StreamResponse) {
|
||
$savePath = ROOT_PATH . 'public' . DS . 'uploads'.DS.'wdsxh'.DS.'qrcode' . DS;
|
||
if (!is_dir($savePath)) {
|
||
mkdir($savePath, 0777, true);
|
||
}
|
||
$filename = time() . mt_rand(1000, 9999) . '.png';
|
||
$response->saveAs($savePath, $filename);
|
||
return $savePath . $filename;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
public static function subscribeMessage($template_id, $openid, $page, $data)
|
||
{
|
||
if(empty($template_id) || empty($openid) || empty($data)){
|
||
return false;
|
||
}
|
||
$app = self::getApp();
|
||
$accessToken = $app->access_token;
|
||
$token = $accessToken->getToken(true);
|
||
$url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token={$token['access_token']}";
|
||
$content = [
|
||
'template_id' => trim($template_id),
|
||
'touser' => '',
|
||
'page' => trim($page),
|
||
'data' => $data,
|
||
];
|
||
//$response=$app->subscribe_message->send($data);
|
||
$client = new Client();
|
||
$openids = [];
|
||
if (is_string($openid)) {
|
||
$openids[] = $openid;
|
||
} elseif (is_array($openid)) {
|
||
$openids = $openid;
|
||
} else {
|
||
throw new Exception('openid类型错误');
|
||
}
|
||
try {
|
||
$requests = function ($total) use ($client, $url, $content, $openids) {
|
||
foreach ($openids as $row) {
|
||
$content['touser'] = $row;
|
||
yield function () use ($client, $url, $content) {
|
||
$options = [
|
||
'headers' => ['Content-Type' => 'application/json'],
|
||
'body' => json_encode($content)
|
||
];
|
||
return $client->postAsync($url, $options);
|
||
};
|
||
}
|
||
};
|
||
$res = [];
|
||
$pool = new Pool($client, $requests(count($openids)), [
|
||
'concurrency' => count($openids),
|
||
'fulfilled' => function ($response, $index) use (&$res) {
|
||
$res[$index] = json_decode($response->getBody()->getContents(), true);
|
||
},
|
||
'rejected' => function ($reason, $index) use (&$res) {
|
||
$res[$index] = $reason;
|
||
},
|
||
]);
|
||
$promise = $pool->promise();
|
||
$promise->wait();
|
||
} catch (Exception $e) {
|
||
throw new Exception($e->getMessage());
|
||
} catch (ClientException $e) {
|
||
throw new Exception($e->getMessage());
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
public static function uniformSend($openid, $mp_template_msg)
|
||
{
|
||
$app = self::getApp();
|
||
$accessToken = $app->access_token;
|
||
$token = $accessToken->getToken();
|
||
$url = 'https://api.weixin.qq.com/cgi-bin/message/wxopen/template/uniform_send?access_token=' . $token['access_token'];
|
||
$data = [
|
||
'touser' => $openid,
|
||
'mp_template_msg' => $mp_template_msg
|
||
];
|
||
$response = self::httpPost($url, $data);
|
||
|
||
}
|
||
|
||
private static function httpPost($url, $data)
|
||
{
|
||
$curlPost = json_encode($data);
|
||
$curl = curl_init();
|
||
curl_setopt($curl, CURLOPT_URL, $url);
|
||
curl_setopt($curl, CURLOPT_HEADER, false);
|
||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
|
||
curl_setopt($curl, CURLOPT_NOBODY, true);
|
||
curl_setopt($curl, CURLOPT_POST, true);
|
||
curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
|
||
$return_str = curl_exec($curl);
|
||
curl_close($curl);
|
||
return $return_str;
|
||
}
|
||
|
||
public static function checkSecurityText($openId,$content)
|
||
{
|
||
$app = self::getApp();
|
||
$accessToken = $app->access_token;
|
||
$token = $accessToken->getToken();
|
||
$url = "https://api.weixin.qq.com/wxa/msg_sec_check?access_token=".$token['access_token'];
|
||
$data = [
|
||
'openid' => $openId,
|
||
'scene' => 2,
|
||
'version' => 2,
|
||
'content' => $content,
|
||
];
|
||
$response = self::httpPostCheckText($url, $data);
|
||
|
||
$result = json_decode($response,true);
|
||
if ($result['errcode'] != 0) {
|
||
if ($result['errcode'] == 40001) {
|
||
$token = $accessToken->getToken(true);
|
||
$url = "https://api.weixin.qq.com/wxa/msg_sec_check?access_token=".$token['access_token'];
|
||
$fileType = mb_detect_encoding($content, array('UTF-8','GBK','LATIN1','BIG5'));
|
||
if($fileType != 'UTF-8') {
|
||
$content = mb_convert_encoding($content ,'utf-8', $fileType);
|
||
}
|
||
$data = [
|
||
'openid' => $openId,
|
||
'scene' => 2,
|
||
'version' => 2,
|
||
'content' => $content,
|
||
];
|
||
$response = self::httpPostCheckText($url, $data);
|
||
$result = json_decode($response,true);
|
||
}
|
||
return $result;
|
||
}
|
||
if (isset($result['errcode']) && $result['errcode'] == 0 && isset($result['result']) && $result['result']['suggest']=='pass') {
|
||
return 1;
|
||
} else {
|
||
return 2;
|
||
}
|
||
}
|
||
|
||
private static function httpPostCheckText($url, $data)
|
||
{
|
||
$curlPost = json_encode($data, JSON_UNESCAPED_UNICODE);
|
||
$curl = curl_init();
|
||
curl_setopt($curl, CURLOPT_URL, $url);
|
||
curl_setopt($curl, CURLOPT_HEADER, false);
|
||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
|
||
curl_setopt($curl, CURLOPT_NOBODY, true);
|
||
curl_setopt($curl, CURLOPT_POST, true);
|
||
curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
|
||
$return_str = curl_exec($curl);
|
||
curl_close($curl);
|
||
return $return_str;
|
||
}
|
||
|
||
//订单发货
|
||
//$order_number_type = 订单单号类型，用于确认需要上传详情的订单。枚举值1，使用下单商户号和商户侧单号；枚举值2，使用微信支付单号
|
||
//transaction_id = 原支付交易对应的微信订单号
|
||
//delivery_mode = 发货模式，发货模式枚举值：1、UNIFIED_DELIVERY（统一发货）2、SPLIT_DELIVERY（分拆发货） 示例值: UNIFIED_DELIVERY
|
||
//logistics_type = 物流模式，发货方式枚举值：1、实体物流配送采用快递公司进行实体物流配送形式 2、同城配送 3、虚拟商品，虚拟商品，例如话费充值，点卡等，无实体配送形式 4、用户自提
|
||
//tracking_no = 物流单号，物流快递发货时必填，示例值: 323244567777 字符字节限制: [1, 128]
|
||
//express_company = 物流公司编码，快递公司ID，参见「查询物流公司编码列表」，物流快递发货时必填， 示例值: DHL 字符字节限制: [1, 128]
|
||
//item_desc = 商品信息，例如：微信红包抱枕*1个，限120个字以内
|
||
//consignor_contact = 寄件人联系方式，寄件人联系方式，采用掩码传输，最后4位数字不能打掩码 示例值: `189****1234, 021-****1234, ****1234, 0**2-***1234, 0**2-******23-10, ****123-8008` 值限制: 0 ≤ value ≤ 1024
|
||
//upload_time = 上传时间，用于标识请求的先后顺序 示例值: `2022-12-15T13:29:35.120+08:00`
|
||
//openid = 用户标识，用户在小程序appid下的唯一标识。 下单前需获取到用户的Openid 示例值: oUpF8uMuAJO_M2pxb1Q9zNjWeS6o 字符字节限制: [1, 128]
|
||
public static function upload_shipping_info($order_number_type,$transaction_id,$delivery_mode,$logistics_type,$tracking_no,$express_company,$item_desc,$consignor_contact,$openid)
|
||
{
|
||
$app = self::getApp();
|
||
$accessToken = $app->access_token;
|
||
$token = $accessToken->getToken();
|
||
$url = 'https://api.weixin.qq.com/wxa/sec/order/upload_shipping_info?access_token='.$token['access_token'];
|
||
$data = [
|
||
'order_key' => [
|
||
'order_number_type' => $order_number_type,
|
||
'transaction_id' => $transaction_id,
|
||
],
|
||
'delivery_mode' => $delivery_mode,
|
||
'logistics_type' => $logistics_type,
|
||
'shipping_list' => [
|
||
[
|
||
'tracking_no' => $tracking_no,
|
||
'express_company' => $express_company,
|
||
'item_desc' => $item_desc,
|
||
'contact' => [
|
||
'consignor_contact' => '+86-'.$consignor_contact,
|
||
],
|
||
],
|
||
],
|
||
'upload_time' => date('Y-m-d',time()).'T'.date('h:i:s',time()).'.120+08:00',
|
||
'payer' => [
|
||
'openid' => $openid,
|
||
],
|
||
];
|
||
Log::record($data,'delivery_data');
|
||
$response = self::httpPosts($url, $data);
|
||
$response = json_decode($response, true);
|
||
if ($response['errcode'] == 0){
|
||
$data = [
|
||
'code' => $response['errcode'],
|
||
'errmsg' => $response['errmsg'],
|
||
];;
|
||
return $data;
|
||
}else{
|
||
$data = [
|
||
'code' => $response['errcode'],
|
||
'errmsg' => $response['errmsg'],
|
||
];
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
|
||
|
||
|
||
public static function get_order($transaction_id)
|
||
{
|
||
$app = self::getApp();
|
||
$accessToken = $app->access_token;
|
||
$token = $accessToken->getToken();
|
||
$url = 'https://api.weixin.qq.com/wxa/sec/order/get_order?access_token='.$token['access_token'];
|
||
$data = [
|
||
'transaction_id' => $transaction_id,
|
||
"merchant_id"=> (new Config())->where('id',1)->value('mch_id'),
|
||
"merchant_trade_no"=> (new Order())->where('trade_no',$transaction_id)->value('order_no'),
|
||
];
|
||
Log::record($data,'get_order');
|
||
$response = self::httpPosts($url, $data);
|
||
$response = json_decode($response, true);
|
||
if ($response['errcode'] == 0){
|
||
$data = [
|
||
'code' => $response['errcode'],
|
||
'errmsg' => $response['errmsg'],
|
||
'order'=>isset($response['order']) ? $response['order'] : [],
|
||
];;
|
||
return $data;
|
||
}else{
|
||
$data = [
|
||
'code' => $response['errcode'],
|
||
'errmsg' => $response['errmsg'],
|
||
];
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
private static function httpPosts($url, $data)
|
||
{
|
||
$curlPost = json_encode($data, JSON_UNESCAPED_UNICODE); // 确保以 UTF-8 编码发送数据
|
||
$curl = curl_init();
|
||
curl_setopt($curl, CURLOPT_URL, $url);
|
||
curl_setopt($curl, CURLOPT_HEADER, false);
|
||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 允许获取返回内容
|
||
curl_setopt($curl, CURLOPT_POST, true);
|
||
curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
|
||
|
||
// 设置 HTTP 头信息，确保是 UTF-8 编码
|
||
curl_setopt($curl, CURLOPT_HTTPHEADER, [
|
||
'Content-Type: application/json; charset=UTF-8',
|
||
]);
|
||
$return_str = curl_exec($curl);
|
||
// 错误检查
|
||
if(curl_errno($curl)) {
|
||
// 错误处理
|
||
echo 'Curl error: ' . curl_error($curl);
|
||
}
|
||
curl_close($curl);
|
||
// 返回响应结果
|
||
return $return_str;
|
||
}
|
||
|
||
}
|