452 lines
17 KiB
PHP
452 lines
17 KiB
PHP
|
<?php
|
|||
|
|
/**
|
|||
|
|
* @link http://www.yiiframework.com/
|
|||
|
|
* @copyright Copyright (c) 2008 Yii Software LLC
|
|||
|
|
* @license http://www.yiiframework.com/license/
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
namespace yii\web;
|
|||
|
|
|
|||
|
|
use Yii;
|
|||
|
|
use yii\base\ErrorException;
|
|||
|
|
use yii\base\Exception;
|
|||
|
|
use yii\base\InlineAction;
|
|||
|
|
use yii\helpers\Url;
|
|||
|
|
use app\controllers\common\FuiouController;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Controller is the base class of web controllers.
|
|||
|
|
*
|
|||
|
|
* For more details and usage information on Controller, see the [guide article on controllers](guide:structure-controllers).
|
|||
|
|
*
|
|||
|
|
* @author Qiang Xue <qiang.xue@gmail.com>
|
|||
|
|
* @since 2.0
|
|||
|
|
*/
|
|||
|
|
class Controller extends \yii\base\Controller
|
|||
|
|
{
|
|||
|
|
/**
|
|||
|
|
* @var bool whether to enable CSRF validation for the actions in this controller.
|
|||
|
|
* CSRF validation is enabled only when both this property and [[\yii\web\Request::enableCsrfValidation]] are true.
|
|||
|
|
*/
|
|||
|
|
public $enableCsrfValidation = true;
|
|||
|
|
/**
|
|||
|
|
* @var array the parameters bound to the current action.
|
|||
|
|
*/
|
|||
|
|
public $actionParams = [];
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Renders a view in response to an AJAX request.
|
|||
|
|
*
|
|||
|
|
* This method is similar to [[renderPartial()]] except that it will inject into
|
|||
|
|
* the rendering result with JS/CSS scripts and files which are registered with the view.
|
|||
|
|
* For this reason, you should use this method instead of [[renderPartial()]] to render
|
|||
|
|
* a view to respond to an AJAX request.
|
|||
|
|
*
|
|||
|
|
* @param string $view the view name. Please refer to [[render()]] on how to specify a view name.
|
|||
|
|
* @param array $params the parameters (name-value pairs) that should be made available in the view.
|
|||
|
|
* @return string the rendering result.
|
|||
|
|
*/
|
|||
|
|
public function renderAjax($view, $params = [])
|
|||
|
|
{
|
|||
|
|
return $this->getView()->renderAjax($view, $params, $this);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Send data formatted as JSON.
|
|||
|
|
*
|
|||
|
|
* This method is a shortcut for sending data formatted as JSON. It will return
|
|||
|
|
* the [[Application::getResponse()|response]] application component after configuring
|
|||
|
|
* the [[Response::$format|format]] and setting the [[Response::$data|data]] that should
|
|||
|
|
* be formatted. A common usage will be:
|
|||
|
|
*
|
|||
|
|
* ```php
|
|||
|
|
* return $this->asJson($data);
|
|||
|
|
* ```
|
|||
|
|
*
|
|||
|
|
* @param mixed $data the data that should be formatted.
|
|||
|
|
* @return Response a response that is configured to send `$data` formatted as JSON.
|
|||
|
|
* @since 2.0.11
|
|||
|
|
* @see Response::$format
|
|||
|
|
* @see Response::FORMAT_JSON
|
|||
|
|
* @see JsonResponseFormatter
|
|||
|
|
*/
|
|||
|
|
public function asJson($data)
|
|||
|
|
{
|
|||
|
|
$this->response->format = Response::FORMAT_JSON;
|
|||
|
|
$this->response->data = $data;
|
|||
|
|
return $this->response;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Send data formatted as XML.
|
|||
|
|
*
|
|||
|
|
* This method is a shortcut for sending data formatted as XML. It will return
|
|||
|
|
* the [[Application::getResponse()|response]] application component after configuring
|
|||
|
|
* the [[Response::$format|format]] and setting the [[Response::$data|data]] that should
|
|||
|
|
* be formatted. A common usage will be:
|
|||
|
|
*
|
|||
|
|
* ```php
|
|||
|
|
* return $this->asXml($data);
|
|||
|
|
* ```
|
|||
|
|
*
|
|||
|
|
* @param mixed $data the data that should be formatted.
|
|||
|
|
* @return Response a response that is configured to send `$data` formatted as XML.
|
|||
|
|
* @since 2.0.11
|
|||
|
|
* @see Response::$format
|
|||
|
|
* @see Response::FORMAT_XML
|
|||
|
|
* @see XmlResponseFormatter
|
|||
|
|
*/
|
|||
|
|
public function asXml($data)
|
|||
|
|
{
|
|||
|
|
$this->response->format = Response::FORMAT_XML;
|
|||
|
|
$this->response->data = $data;
|
|||
|
|
return $this->response;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Binds the parameters to the action.
|
|||
|
|
* This method is invoked by [[\yii\base\Action]] when it begins to run with the given parameters.
|
|||
|
|
* This method will check the parameter names that the action requires and return
|
|||
|
|
* the provided parameters according to the requirement. If there is any missing parameter,
|
|||
|
|
* an exception will be thrown.
|
|||
|
|
* @param \yii\base\Action $action the action to be bound with parameters
|
|||
|
|
* @param array $params the parameters to be bound to the action
|
|||
|
|
* @return array the valid parameters that the action can run with.
|
|||
|
|
* @throws BadRequestHttpException if there are missing or invalid parameters.
|
|||
|
|
*/
|
|||
|
|
public function bindActionParams($action, $params)
|
|||
|
|
{
|
|||
|
|
if ($action instanceof InlineAction) {
|
|||
|
|
$method = new \ReflectionMethod($this, $action->actionMethod);
|
|||
|
|
} else {
|
|||
|
|
$method = new \ReflectionMethod($action, 'run');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$args = [];
|
|||
|
|
$missing = [];
|
|||
|
|
$actionParams = [];
|
|||
|
|
$requestedParams = [];
|
|||
|
|
foreach ($method->getParameters() as $param) {
|
|||
|
|
$name = $param->getName();
|
|||
|
|
if (array_key_exists($name, $params)) {
|
|||
|
|
$isValid = true;
|
|||
|
|
if ($param->isArray()) {
|
|||
|
|
$params[$name] = (array)$params[$name];
|
|||
|
|
} elseif (is_array($params[$name])) {
|
|||
|
|
$isValid = false;
|
|||
|
|
} elseif (
|
|||
|
|
PHP_VERSION_ID >= 70000 &&
|
|||
|
|
($type = $param->getType()) !== null &&
|
|||
|
|
$type->isBuiltin() &&
|
|||
|
|
($params[$name] !== null || !$type->allowsNull())
|
|||
|
|
) {
|
|||
|
|
$typeName = PHP_VERSION_ID >= 70100 ? $type->getName() : (string)$type;
|
|||
|
|
switch ($typeName) {
|
|||
|
|
case 'int':
|
|||
|
|
$params[$name] = filter_var($params[$name], FILTER_VALIDATE_INT, FILTER_NULL_ON_FAILURE);
|
|||
|
|
break;
|
|||
|
|
case 'float':
|
|||
|
|
$params[$name] = filter_var($params[$name], FILTER_VALIDATE_FLOAT, FILTER_NULL_ON_FAILURE);
|
|||
|
|
break;
|
|||
|
|
case 'bool':
|
|||
|
|
$params[$name] = filter_var($params[$name], FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
if ($params[$name] === null) {
|
|||
|
|
$isValid = false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (!$isValid) {
|
|||
|
|
throw new BadRequestHttpException(Yii::t('yii', 'Invalid data received for parameter "{param}".', [
|
|||
|
|
'param' => $name,
|
|||
|
|
]));
|
|||
|
|
}
|
|||
|
|
$args[] = $actionParams[$name] = $params[$name];
|
|||
|
|
unset($params[$name]);
|
|||
|
|
} elseif (PHP_VERSION_ID >= 70100 && ($type = $param->getType()) !== null && !$type->isBuiltin()) {
|
|||
|
|
try {
|
|||
|
|
$this->bindInjectedParams($type, $name, $args, $requestedParams);
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
throw new ServerErrorHttpException($e->getMessage(), 0, $e);
|
|||
|
|
}
|
|||
|
|
} elseif ($param->isDefaultValueAvailable()) {
|
|||
|
|
$args[] = $actionParams[$name] = $param->getDefaultValue();
|
|||
|
|
} else {
|
|||
|
|
$missing[] = $name;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (!empty($missing)) {
|
|||
|
|
throw new BadRequestHttpException(Yii::t('yii', 'Missing required parameters: {params}', [
|
|||
|
|
'params' => implode(', ', $missing),
|
|||
|
|
]));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$this->actionParams = $actionParams;
|
|||
|
|
|
|||
|
|
// We use a different array here, specifically one that doesn't contain service instances but descriptions instead.
|
|||
|
|
if (\Yii::$app->requestedParams === null) {
|
|||
|
|
\Yii::$app->requestedParams = array_merge($actionParams, $requestedParams);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $args;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* {@inheritdoc}
|
|||
|
|
*/
|
|||
|
|
public function beforeAction($action)
|
|||
|
|
{
|
|||
|
|
if (parent::beforeAction($action)) {
|
|||
|
|
if ($this->enableCsrfValidation && Yii::$app->getErrorHandler()->exception === null && !$this->request->validateCsrfToken()) {
|
|||
|
|
throw new BadRequestHttpException(Yii::t('yii', 'Unable to verify your data submission.'));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Redirects the browser to the specified URL.
|
|||
|
|
* This method is a shortcut to [[Response::redirect()]].
|
|||
|
|
*
|
|||
|
|
* You can use it in an action by returning the [[Response]] directly:
|
|||
|
|
*
|
|||
|
|
* ```php
|
|||
|
|
* // stop executing this action and redirect to login page
|
|||
|
|
* return $this->redirect(['login']);
|
|||
|
|
* ```
|
|||
|
|
*
|
|||
|
|
* @param string|array $url the URL to be redirected to. This can be in one of the following formats:
|
|||
|
|
*
|
|||
|
|
* - a string representing a URL (e.g. "http://example.com")
|
|||
|
|
* - a string representing a URL alias (e.g. "@example.com")
|
|||
|
|
* - an array in the format of `[$route, ...name-value pairs...]` (e.g. `['site/index', 'ref' => 1]`)
|
|||
|
|
* [[Url::to()]] will be used to convert the array into a URL.
|
|||
|
|
*
|
|||
|
|
* Any relative URL that starts with a single forward slash "/" will be converted
|
|||
|
|
* into an absolute one by prepending it with the host info of the current request.
|
|||
|
|
*
|
|||
|
|
* @param int $statusCode the HTTP status code. Defaults to 302.
|
|||
|
|
* See <https://tools.ietf.org/html/rfc2616#section-10>
|
|||
|
|
* for details about HTTP status code
|
|||
|
|
* @return Response the current response object
|
|||
|
|
*/
|
|||
|
|
public function redirect($url, $statusCode = 302)
|
|||
|
|
{
|
|||
|
|
// calling Url::to() here because Response::redirect() modifies route before calling Url::to()
|
|||
|
|
return $this->response->redirect(Url::to($url), $statusCode);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Redirects the browser to the home page.
|
|||
|
|
*
|
|||
|
|
* You can use this method in an action by returning the [[Response]] directly:
|
|||
|
|
*
|
|||
|
|
* ```php
|
|||
|
|
* // stop executing this action and redirect to home page
|
|||
|
|
* return $this->goHome();
|
|||
|
|
* ```
|
|||
|
|
*
|
|||
|
|
* @return Response the current response object
|
|||
|
|
*/
|
|||
|
|
public function goHome()
|
|||
|
|
{
|
|||
|
|
return $this->response->redirect(Yii::$app->getHomeUrl());
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Redirects the browser to the last visited page.
|
|||
|
|
*
|
|||
|
|
* You can use this method in an action by returning the [[Response]] directly:
|
|||
|
|
*
|
|||
|
|
* ```php
|
|||
|
|
* // stop executing this action and redirect to last visited page
|
|||
|
|
* return $this->goBack();
|
|||
|
|
* ```
|
|||
|
|
*
|
|||
|
|
* For this function to work you have to [[User::setReturnUrl()|set the return URL]] in appropriate places before.
|
|||
|
|
*
|
|||
|
|
* @param string|array $defaultUrl the default return URL in case it was not set previously.
|
|||
|
|
* If this is null and the return URL was not set previously, [[Application::homeUrl]] will be redirected to.
|
|||
|
|
* Please refer to [[User::setReturnUrl()]] on accepted format of the URL.
|
|||
|
|
* @return Response the current response object
|
|||
|
|
* @see User::getReturnUrl()
|
|||
|
|
*/
|
|||
|
|
public function goBack($defaultUrl = null)
|
|||
|
|
{
|
|||
|
|
return $this->response->redirect(Yii::$app->getUser()->getReturnUrl($defaultUrl));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Refreshes the current page.
|
|||
|
|
* This method is a shortcut to [[Response::refresh()]].
|
|||
|
|
*
|
|||
|
|
* You can use it in an action by returning the [[Response]] directly:
|
|||
|
|
*
|
|||
|
|
* ```php
|
|||
|
|
* // stop executing this action and refresh the current page
|
|||
|
|
* return $this->refresh();
|
|||
|
|
* ```
|
|||
|
|
*
|
|||
|
|
* @param string $anchor the anchor that should be appended to the redirection URL.
|
|||
|
|
* Defaults to empty. Make sure the anchor starts with '#' if you want to specify it.
|
|||
|
|
* @return Response the response object itself
|
|||
|
|
*/
|
|||
|
|
public function refresh($anchor = '')
|
|||
|
|
{
|
|||
|
|
return $this->response->redirect($this->request->getUrl() . $anchor);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function getPayChannel($storeId,$uniacid){
|
|||
|
|
$query_data = (new \yii\db\Query())
|
|||
|
|
->from('{{%ybwm_store_paychannel}}')
|
|||
|
|
->where(['store_id'=>$storeId,'apply_id'=>$uniacid,'is_del'=>0])
|
|||
|
|
->all();
|
|||
|
|
return $query_data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function payment2($uniacid,$outTradeNo,$auth_code,$money,$storeId=null,$payType = 1,$bind_data = []){
|
|||
|
|
switch ($payType) {
|
|||
|
|
case 1 : //富友支付
|
|||
|
|
return $this->fuiouPayment($uniacid,$outTradeNo,$auth_code,$money,$storeId,$bind_data);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//判断是否绑定支付通道
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @param $storeId 门店id
|
|||
|
|
* @param $uniacid 平台id
|
|||
|
|
* @param int $type 类型 1-收银台付款，2-小程序付款
|
|||
|
|
*/
|
|||
|
|
public function isBindPayChannel($storeId,$uniacid,$type = 1){
|
|||
|
|
$msg = '';
|
|||
|
|
switch ($type){
|
|||
|
|
case 2 :
|
|||
|
|
$msg = '支付异常，请联系门店人员！';
|
|||
|
|
break;
|
|||
|
|
case 1:
|
|||
|
|
default:
|
|||
|
|
$msg = '支付通道异常，请联系后台管理员！！';
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
$pay_channel_data = $this->getPayChannel($storeId,$uniacid);
|
|||
|
|
// if(!$pay_channel_data){
|
|||
|
|
// echo json_encode(['code'=>2,'msg'=>$msg]);die;
|
|||
|
|
// }
|
|||
|
|
// $channel_radio_arr = json_decode($pay_channel_data['channel_radio'],true);
|
|||
|
|
foreach ($pay_channel_data as $key=>$val){
|
|||
|
|
$pay_radio_num = $val['channel_radio'] >= 0 ? ($val['channel_radio'] * 100) : 0;
|
|||
|
|
$pay_channel_data[$key]['pay_radio'] = (int)$pay_radio_num;
|
|||
|
|
}
|
|||
|
|
$rand_data = $this->getRadioKey($pay_channel_data);
|
|||
|
|
if(!$rand_data){
|
|||
|
|
echo json_encode(['code'=>2,'msg'=>$msg]);die;
|
|||
|
|
}
|
|||
|
|
//获取支付渠道
|
|||
|
|
$channel_data = (new \yii\db\Query())
|
|||
|
|
->from('{{%ybwm_pay_channel}}')
|
|||
|
|
->where(['channel_id'=>$rand_data['channel_id']])
|
|||
|
|
->one();
|
|||
|
|
if(!$channel_data || $channel_data['status'] != 1){
|
|||
|
|
echo json_encode(['code'=>2,'msg'=>$msg]);die;
|
|||
|
|
}
|
|||
|
|
return $rand_data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function getRadioKey($radioDataList){
|
|||
|
|
$total = (int)array_sum(array_column($radioDataList,'pay_radio'));
|
|||
|
|
foreach($radioDataList as $key=>$value) {
|
|||
|
|
$randNumber = mt_rand(1,$total);
|
|||
|
|
if($randNumber <= $value['pay_radio']){
|
|||
|
|
$temp['bind_id'] = $value['id'];
|
|||
|
|
$temp['channel_id'] = $value['channel_id'];
|
|||
|
|
return $temp;
|
|||
|
|
break;
|
|||
|
|
}else{
|
|||
|
|
$total -= $value['pay_radio'];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
//富友支付-条码支付
|
|||
|
|
public function fuiouPayment($uniacid,$outTradeNo,$auth_code,$money,$storeId=null,$bind_data = []){
|
|||
|
|
// $money = 0.01;
|
|||
|
|
if(!isset($bind_data['channel_id']) || !isset($bind_data['bind_id'])) {
|
|||
|
|
echo json_encode(['code'=>2,'msg'=>'订单异常，请重新下单！！']);die;
|
|||
|
|
}
|
|||
|
|
$bind_channel_data = (new \yii\db\Query())
|
|||
|
|
->from('{{%ybwm_store_paychannel}}')
|
|||
|
|
->where(['id'=>$bind_data['bind_id'],'is_del'=>0,'store_id'=>$storeId])
|
|||
|
|
->one();
|
|||
|
|
|
|||
|
|
if(!$bind_channel_data || empty($bind_channel_data['private_key']) || empty($bind_channel_data['ins_num']) || empty($bind_channel_data['merchant_num'])){
|
|||
|
|
echo json_encode(['code'=>2,'msg'=>'支付通道信息缺失，请联系后台管理员配置！']);die;
|
|||
|
|
}
|
|||
|
|
$payType=1;
|
|||
|
|
$fuiou_config = Yii::$app->params['fuiou_config'];
|
|||
|
|
$ins_cd = $bind_channel_data['ins_num'];
|
|||
|
|
$mchnt_cd = $bind_channel_data['merchant_num'];
|
|||
|
|
$private_key = $bind_channel_data['private_key'];
|
|||
|
|
|
|||
|
|
$api_url = $fuiou_config['api_url'] ? $fuiou_config['api_url'] : '';
|
|||
|
|
$api_url = $api_url.'/micropay';
|
|||
|
|
$now_format_time = date('YmdHis', time());
|
|||
|
|
$order['version'] = "1.0";
|
|||
|
|
$order['ins_cd'] = $ins_cd;
|
|||
|
|
$order['mchnt_cd'] = $mchnt_cd;
|
|||
|
|
$order['term_id'] = "88888888";
|
|||
|
|
$order['random_str'] = $now_format_time;
|
|||
|
|
$order['sign'] = '';
|
|||
|
|
$order['order_type'] = $this->judgePayType($auth_code);
|
|||
|
|
$order['goods_des'] = $outTradeNo;
|
|||
|
|
$order['mchnt_order_no'] = $outTradeNo;
|
|||
|
|
$money=bcmul($money,100,0);
|
|||
|
|
$order['order_amt'] = $money;//IS_TEST ? 1 : $money;
|
|||
|
|
$order['term_ip'] = $_SERVER['REMOTE_ADDR'];
|
|||
|
|
$order['txn_begin_ts'] = $now_format_time;
|
|||
|
|
$order['auth_code'] = $auth_code;
|
|||
|
|
$order['reserved_terminal_info'] = '{"serial_num":"12345678901SN012"}';
|
|||
|
|
|
|||
|
|
//非必填
|
|||
|
|
$order['addn_inf'] = '';
|
|||
|
|
$order['curr_type'] = '';
|
|||
|
|
$order['goods_detail'] = '';
|
|||
|
|
$order['goods_tag'] = '';
|
|||
|
|
$order['sence'] = '';
|
|||
|
|
try {
|
|||
|
|
$fuiou_obj = new FuiouController();
|
|||
|
|
$fuioupay_res = $fuiou_obj->fuiouBarcodePay($order,$api_url,$private_key,$bind_data);
|
|||
|
|
}catch (\Exception $e){
|
|||
|
|
$message= $e->getMessage();
|
|||
|
|
$ISUSERPAYING = strpos($message,'USERPAYING');
|
|||
|
|
if($ISUSERPAYING){
|
|||
|
|
$data=[
|
|||
|
|
'code'=>'USERPAYING',
|
|||
|
|
'outTradeNo'=>$outTradeNo,
|
|||
|
|
'payModel'=>1
|
|||
|
|
];
|
|||
|
|
}else{
|
|||
|
|
$data=[
|
|||
|
|
'code'=>'ERROR',
|
|||
|
|
'outTradeNo'=>$outTradeNo,
|
|||
|
|
'payModel'=>1
|
|||
|
|
];
|
|||
|
|
}
|
|||
|
|
echo json_encode(['code'=> empty($ISUSERPAYING) ? 2:1,'msg'=>empty($ISUSERPAYING) ? $e->getMessage():'等待用户支付','data'=>$data]);die;
|
|||
|
|
}
|
|||
|
|
if(!$fuioupay_res){
|
|||
|
|
echo json_encode(['code'=>2,'msg'=>'订单异常,请重新下单']);die;
|
|||
|
|
}
|
|||
|
|
if($fuioupay_res){
|
|||
|
|
$payStatus=1;
|
|||
|
|
}
|
|||
|
|
return $payStatus;
|
|||
|
|
}
|
|||
|
|
}
|