root / sleep · 提交

转到一个项目

作者 董瑞恩
提交 8b400579ea88bbc7debd79ff2348a0ef8403c3cd 1 个父辈 5e9cf442
1 个管道 的构建 通过 耗费 1 秒

cost

内嵌 并排对比
正在显示 2 个修改的文件 包含 293 行增加 和 1 行删除
... ... @@ -10,14 +10,26 @@ namespace app\portal\controller;
use cmf\controller\HomeBaseController;
use EasyWeChat\Foundation\Application;
use think\Db;
use wxapp\pay\WeixinPay;
/**
* @title 用户相关接口
* @description 用户相关接口
* @group 用户相关接口
*/
class UsersController extends HomeBaseController{
protected $options;
function _initialize()
{
parent::_initialize();
$this->options = [
'app_id' => config('wechat_config.app_id'),
'secret' => config('wechat_config.secret'),
'payment' => config('wechat_config.payment'),
];
}
/**
* @title 状态验证
* @description 开锁前判断是否有未支付订单与是否提交押金
... ... @@ -54,6 +66,8 @@ class UsersController extends HomeBaseController{
* @method GET
*
* @param name:users_id type:String require:1 default:无 other: desc:用户id
*
*
*/
public function isUse(){
$users_id=$this->request->param('users_id');
... ... @@ -65,6 +79,119 @@ class UsersController extends HomeBaseController{
}
}
/**
* @title 用户交纳押金
* @description 交纳押金
* @author 董瑞恩
* @url /portal/users/payDeposit
* @method GET
*
* @param name:users_id type:String require:1 default:无 other: desc:用户id
*
* @return data:下单返回值
*/
public function payDeposit(){
$users_id=$this->request->param('users_id');
$users=Db::name('users')->where('users_id',$users_id)->find();
$openId=$users['open_id'];
$order_no = cmf_get_order_sn();
$body="押金-支付";
$price=300*100;//数据库查询
$notify_url=url('users/notify','','',true);//回调地址
$wxPay=new WeixinPay($openId,$order_no,$body,$price,$notify_url);
$data=$wxPay->pay();
if (isset($data['package'])){
try{
Db::name('users')->where(['users_id'=>$users_id])->update(['deposit_order_no'=>$order_no]);
}catch (\Exception $exception){
}
$this->apiResponse(200,'下单成功',$data);//微信支付下单成功，返回调用支付的参数
}
}
//支付回调接口
public function notify(){
$param = $this->request->param();
if ($param == null) {
$param = file_get_contents("php://input");
if ($param == null) {
$param = $GLOBALS['HTTP_RAW_POST_DATA'];
}
}
$wxPay=new WeixinPay();
$data = $wxPay->xmlToArray($param);
$Sign = $data['sign'];
//支付成功回调后变更订单状态
$mySign = $wxPay->getSign($data);
$order_no = $data['out_trade_no'];
if ($Sign===$mySign && $data['return_code'] == 'SUCCESS') {
$data=[
'is_deposit' => 1,
'deposit' => $data['total_fee'],
];
try{
Db::name('order')->where(['order_no'=>$order_no])->update($data);
}catch (\Exception $exception){
$this->apiResponse(301,'error：'.$exception->getMessage());
}
return "<xml>
<return_code><![CDATA[SUCCESS]]></return_code>
<return_msg><![CDATA[OK]]></return_msg>
</xml>";
}
}
/**
* @title 用户退回押金
* @description 用户退回押金
* @author 董瑞恩
* @url /portal/users/refundDeposit
* @method GET
*
* @param name:users_id type:String require:1 default:无 other: desc:用户id
*
* @return result:退款接口返回值
*/
public function refundDeposit(){
$users_id=$this->request->param('users_id');
$users=Db::name('users')->where('users_id',$users_id)->find();
$orderNo=$users['deposit_order_no'];//需要退款的订单
$price=$users['deposit'];
Db::startTrans();
try{
Db::name('users')->where('users_id',$users_id)->update(['is_deposit'=>0,'deposit'=>null,'deposit_order_no'=>null]);
}catch (\Exception $exception){
$this->apiResponse(301,'数据库修改失败');
}
$app= new Application($this->options);
$payment = $app->payment;
//使用商户订单号退款 PS.其他形式参考文档
$refundNo =cmf_get_order_sn();//退款单号
$result = $payment->refund($orderNo, $refundNo, $price); // 总金额 100， 退款 80，refundFee可选（为空时全额退款）
if ($result['return_code']==='SUCCESS' && $result['result_code']==='SUCCESS'){
Db::commit();
}else{
Db::rollback();
}
return json_decode($result,true);
}
/**
* 退款结果回调
*/
public function refundNotify() {
$app = new Application($this->options);
$response = $app->payment->handleRefundNotify(function ($message, $reqInfo) {
cache('message',$message);
cache('reqInfo',$reqInfo);
// 其中 $message['req_info'] 获取到的是加密信息
// $reqInfo 为 message['req_info'] 解密后的信息
// 你的业务逻辑...
return true; // 返回 true 告诉微信“我已处理完成”
// 或返回错误原因 $fail('参数格式校验错误');
});
$response->send();
}
}
\ No newline at end of file
... ...
<?php
/**
* Created by PhpStorm.
* User: ruidiudiu
* Date: 2018/10/16
* Time: 16:34
*/
namespace wxapp\pay;
const APICLIENT_CERT=EXTEND_PATH."wxapp/pay/cert/apiclient_cert.pem";
const APICLIENT_KEY=EXTEND_PATH."wxapp/pay/cert/apiclient_key.pem";
class WecharGetCash{
protected $appid;//商户账号
protected $mch_id;//商户号
protected $key;
protected $partner_trade_no;//商户订单号
protected $openid;
protected $check_name;//校验用户姓名选项 NO_CHECK：不校验真实姓名 FORCE_CHECK：强校验真实姓名
protected $amount;//金额
protected $desc;//企业付款备注
protected $spbill_create_ip;//Ip地址:该IP同在商户平台设置的IP白名单中的IP没有关联，该IP可传用户端或者服务端的IP。
function __construct($openid,$partner_trade_no,$desc,$amount) {
$this->appid = config('wechat_config.app_id');
$this->mch_id = config('wechat_config.payment')['merchant_id'];
$this->key = config('wechat_config.payment')['key'];
$this->partner_trade_no = $partner_trade_no;//商户订单号
$this->openid = $openid;
$this->check_name = "NO_CHECK";
$this->amount = $amount*100;//金额
$this->desc = $desc;//企业付款备注
$this->spbill_create_ip = "114.215.223.17";//Ip地址
}
public function getCash() {
//提现接口
$return = $this->enterprisePayment();
return $return;
}
//企业付款接口
private function enterprisePayment() {
$url = 'https://api.mch.weixin.qq.com/mmpaymkttransfers/promotion/transfers';
$parameters = array(
'mch_appid' => $this->appid,
'mchid' => $this->mch_id,
'nonce_str' => $this->createNoncestr(),
'partner_trade_no' => $this->partner_trade_no,
'openid' => $this->openid,
'check_name' => $this->check_name,
'amount' => $this->amount,
'desc' => $this->desc,
'spbill_create_ip' => $this->spbill_create_ip
);
//签名
$parameters['sign'] = $this->getSign($parameters);
$xmlData = $this->arrayToXml($parameters);
$return = $this->xmlToArray($this->postXmlCurl($xmlData, $url, 60));
return $return;
}
private static function postXmlCurl($xml, $url, $second = 30)
{
$ch = curl_init();
//设置超时
curl_setopt($ch, CURLOPT_TIMEOUT, $second);
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE); //严格校验
//第一种方法，cert 与 key 分别属于两个.pem文件
//默认格式为PEM，可以注释
curl_setopt($ch,CURLOPT_SSLCERT,APICLIENT_CERT);
curl_setopt($ch,CURLOPT_SSLKEY,APICLIENT_KEY);
//设置header
curl_setopt($ch, CURLOPT_HEADER, FALSE);
//要求结果为字符串且输出到屏幕上
curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
//post提交方式
curl_setopt($ch, CURLOPT_POST, TRUE);
curl_setopt($ch, CURLOPT_POSTFIELDS, $xml);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 20);
curl_setopt($ch, CURLOPT_TIMEOUT, 40);
set_time_limit(0);
//运行curl
$data = curl_exec($ch);
//返回结果
if ($data) {
curl_close($ch);
return $data;
} else {
$error = curl_errno($ch);
curl_close($ch);
throw new ErrorException("curl出错，错误码:$error");
}
}
//数组转换成xml
private function arrayToXml($arr) {
$xml = "<root>";
foreach ($arr as $key => $val) {
if (is_array($val)) {
$xml .= "<" . $key . ">" . $this->arrayToXml($val) . "</" . $key . ">";
} else {
$xml .= "<" . $key . ">" . $val . "</" . $key . ">";
}
}
$xml .= "</root>";
return $xml;
}
//xml转换成数组
public function xmlToArray($xml) {
//禁止引用外部xml实体
libxml_disable_entity_loader(true);
$xmlstring = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
$val = json_decode(json_encode($xmlstring), true);
return $val;
}
//作用：产生随机字符串，不长于32位
private function createNoncestr($length = 32) {
$chars = "abcdefghijklmnopqrstuvwxyz0123456789";
$str = "";
for ($i = 0; $i < $length; $i++) {
$str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1);
}
return $str;
}
//作用：生成签名
public function getSign($Obj) {
foreach ($Obj as $k => $v) {
$Parameters[$k] = $v;
}
//签名步骤一：按字典序排序参数
ksort($Parameters);
$String = $this->formatBizQueryParaMap($Parameters, false);
//签名步骤二：在string后加入KEY
$String = $String . "&key=" . $this->key;
//签名步骤三：MD5加密
$String = md5($String);
//签名步骤四：所有字符转为大写
$result_ = strtoupper($String);
return $result_;
}
///作用：格式化参数，签名过程需要使用
private function formatBizQueryParaMap($paraMap, $urlencode) {
$buff = "";
ksort($paraMap);
foreach ($paraMap as $k => $v) {
if(null != $v && "null" != $v && "sign" != $k) {
if ($urlencode) {
$v = urlencode($v);
}
$buff .= $k . "=" . $v . "&";
}
}
$reqPar='';
if (strlen($buff) > 0) {
$reqPar = substr($buff, 0, strlen($buff) - 1);
}
return $reqPar;
}
}
\ No newline at end of file
... ...