|
|
<?php
namespace App\Service\v3\Implementations;
use App\Commons\Log;use App\Constants\v3\ErrorCode;use App\Constants\v3\LogLabel;use App\Constants\v3\OrderState;use App\Constants\v3\OrderType;use App\Constants\v3\Payment;use App\Exception\ErrorCodeException;use App\Model\v3\OrderMain;use App\Model\v3\User;use App\Service\v3\Interfaces\GoodsActivityServiceInterface;use App\Service\v3\Interfaces\PaymentServiceInterface;use EasyWeChat\Factory;use EasyWeChat\Kernel\Exceptions\InvalidConfigException;use EasyWeChat\Kernel\Support\Collection;use GuzzleHttp\Exception\GuzzleException;use Hyperf\DbConnection\Db;use Hyperf\Guzzle\CoroutineHandler;use Hyperf\Di\Annotation\Inject;use Psr\Http\Message\ResponseInterface;use function AlibabaCloud\Client\json;
class PaymentService implements PaymentServiceInterface{ /** * @Inject * @var Log */ protected $log;
public function do($globalOrderId, $money, $userId, $notifyUrl) {
try {
$config = config('wxpay'); $app = Factory::payment($config); $app['guzzle_handler'] = CoroutineHandler::class;
// 待支付的，未超时（15min，900sec）的订单
$orderMain = OrderMain::query() ->where(['state' => OrderState::UNPAID, 'global_order_id' => $globalOrderId, 'user_id' => $userId]) ->where('created_at', '>=', (time()-900)) ->first(); if (empty($orderMain)) { throw new ErrorCodeException(ErrorCode::ORDER_NOT_AVAILABLE, '[支付订单号]'.$globalOrderId); }
$payMoney = bcmul((string)$orderMain->money, 100, 0); if (env('APP_ENV') != 'prod' && $orderMain->type == OrderType::ONLINE) { $payMoney = 1; }
$user = User::select('openid')->find($userId); $result = $app->order->unify([ 'body' => '懒族生活', 'out_trade_no' => $orderMain->global_order_id, 'total_fee' => $payMoney, 'notify_url' => $notifyUrl, 'trade_type' => 'JSAPI', 'openid' => $user['openid'], ]);
if ($result['return_code'] == 'FAIL') { throw new ErrorCodeException(ErrorCode::PAYMENT_FAIL, '[支付失败]'.$result['return_msg']); }
// 返回支付参数给前端
$parameters = [ 'appId' => $result['appid'], 'timeStamp' => '' . time() . '', 'nonceStr' => uniqid(), 'package' => 'prepay_id=' . $result['prepay_id'], 'signType' => 'MD5' ];
$parameters['paySign'] = $this->signture($parameters, $config['key']); $parameters['order_main_id'] = $orderMain->global_order_id;
return $parameters;
} catch (\Exception $e) { $this->log->event(LogLabel::ORDER_PAYMENT_LOG, ['payment_do_exception_msg' => $e->getMessage()]); throw new ErrorCodeException(ErrorCode::PAYMENT_FAIL, '[支付失败]'.$e->getMessage()); } }
public function check() { // TODO: Implement check() method.
}
/** * 退款的整单，允许后台操作退款 * @param $globalOrderId * @param $userId * @return array|bool|Collection|object|ResponseInterface|string */ public function undo($globalOrderId, $userId) {
try{
$config = config('wxpay'); $app = Factory::payment($config); $app['guzzle_handler'] = CoroutineHandler::class;
// 已支付的，未退款的，使用微信支付的订单
$orderMain = OrderMain::query() ->whereIn('state', [OrderState::PAID, OrderState::DELIVERY, OrderState::COMPLETED, OrderState::EVALUATED, OrderState::REFUNDING]) ->where(['global_order_id' => $globalOrderId, 'user_id' => $userId, 'pay_type' => Payment::WECHAT,'refund_time'=>0]) ->first(); if (empty($orderMain)) { throw new ErrorCodeException(ErrorCode::ORDER_NOT_AVAILABLE, '[支付订单号]'.$globalOrderId); }
$result = $app->refund->byOutTradeNumber( $orderMain->global_order_id, $orderMain->global_order_id, bcmul($orderMain->money, 100, 0), bcmul($orderMain->money, 100, 0), [ 'refund_desc' => '订单退款', 'notify_url' => config('wechat.notify_url.refund'), ] ); if ($result['return_code'] == 'SUCCESS' && isset($result['result_code']) && $result['result_code'] == "SUCCESS") { return true; } else { throw new ErrorCodeException(ErrorCode::PAYMENT_FAIL,$result['err_code_des']); } } catch (\Exception $e) { $this->log->event(LogLabel::ORDER_PAYMENT_LOG, ['payment_do_exception_msg' => $e->getMessage()]); throw new ErrorCodeException(ErrorCode::PAYMENT_FAIL, '[退款失败]'.$e->getMessage()); }
}
/** * 企业付款到微信钱包 * @param $money * @param $tradeNo * @param $openId * @param $userName * @param string $desc * @param string $checkName * @throws GuzzleException */ public function payToWx($money, $tradeNo, $openId, $userName, $desc = '', $checkName = 'NO_CHECK') { $config = config('wxpay'); $app = Factory::payment($config); $app['guzzle_handler'] = CoroutineHandler::class;
$result = $app->transfer->toBalance([ 'partner_trade_no' => $tradeNo, // 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号)
'openid' => $openId, 'check_name' => $checkName, // NO_CHECK：不校验真实姓名, FORCE_CHECK：强校验真实姓名
're_user_name' => $userName, // 如果 check_name 设置为FORCE_CHECK，则必填用户真实姓名
'amount' => $money, // 企业付款金额，单位为分
'desc' => $desc, // 企业付款操作说明信息
]);
if ($result['return_code'] != 'SUCCESS') { $this->log->event(LogLabel::PAY_TO_WX_FAIL_LOG, [ 'exception_payToWx' => $result['return_msg'], 'result' => json_encode($result), 'desc' => $desc ]); throw new ErrorCodeException(ErrorCode::PAYMENT_FAIL, $result['return_msg']); }
if ($result['result_code'] != 'SUCCESS') { $this->log->event(LogLabel::PAY_TO_WX_FAIL_LOG, [ 'exception_payToWx' => $result['err_code_des'], 'result' => json_encode($result), 'desc' => $desc ]); throw new ErrorCodeException(ErrorCode::PAYMENT_FAIL, $result['err_code_des']); }
return true;
}
/** * 支付参数加签 * @param $parameters * @param $key * @return string */ private function signture($parameters, $key) { // 按字典序排序参数
ksort($parameters);
// http_query
$queryParams = $this->http_query($parameters);
// 加入KEY
$queryParams = $queryParams . "&key=" . $key;
// MD5加密
$queryParams = md5($queryParams);
// 字符转为大写
return strtoupper($queryParams); }
/** * 参数转为http query字串 * @param $parameters * @return string */ private function http_query($parameters) {
$http_query = []; foreach ($parameters as $key => $value) { $http_query[] = $key.'='.$value; }
return implode('&', $http_query); }}
|
