yueke/application/api/controller/Demo.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use Aws\Sns\SnsClient;
use Aws\Exception\AwsException;
/**
 * 示例接口
 */
class Demo extends Api
{

    //如果$noNeedLogin为空表示所有接口都需要登录才能请求
    //如果$noNeedRight为空表示所有接口都需要验证权限才能请求
    //如果接口已经设置无需登录,那也就无需鉴权了
    //
    // 无需登录的接口,*表示全部
    protected $noNeedLogin = ['*'];
    // 无需鉴权的接口,*表示全部
    protected $noNeedRight = ['*'];

    /**
     * 测试方法
     *
     * @ApiTitle    (测试名称)
     * @ApiSummary  (测试描述信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/demo/test/id/{id}/name/{name})
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="id", type="integer", required=true, description="会员ID")
     * @ApiParams   (name="name", type="string", required=true, description="用户名")
     * @ApiParams   (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturnParams   (name="data", type="object", sample="{'user_id':'int','user_name':'string','profile':{'email':'string','age':'integer'}}", description="扩展数据返回")
     * @ApiReturn   ({
         'code':'1',
         'msg':'返回成功'
        })
     */

    public function test1(){
        $SnSclient = new SnsClient([
            'profile' => 'default',
            'region' => 'us-east-1',
            'version' => '2010-03-31'
        ]);

        $subscription_token = 'arn:aws:sns:us-east-1:111122223333:MyTopic:123456-abcd-12ab-1234-12ba3dc1234a';
        $topic = 'arn:aws:sns:us-east-1:111122223333:MyTopic';

        try {
            $result = $SnSclient->confirmSubscription([
                'Token' => $subscription_token,
                'TopicArn' => $topic,
            ]);
            var_dump($result);
        } catch (AwsException $e) {
            // output error message if fails
            error_log($e->getMessage());
        }
    }

    public function test(){
        $out_trade_no = createUniqueNo('Test');
        $money = '1';
        $notifyurl = config('notify_cdnurl');
        $rs = $this->hitpay_payment($out_trade_no,$money,$notifyurl);
        dump($rs);

        //payorder 保存 $rs['id'] 为 payment_request_id
    }

    public function hitpay_payment($out_trade_no,$money,$notifyurl)
    {
        $return = [
            'status' => false,
            'msg'  => '',
            'url' => '',
            'id' => 0,
        ];

        $apiKey = config('hitpay.apikey');

        try {
            $hitPayClient = new \HitPay\Client($apiKey, true);

            $request = new \HitPay\Request\CreatePayment();

            $request->setAmount($money)
                    ->setCurrency('SGD')
                    ->setPaymentMethods(['paynow_online','card'])
                    ->setPurpose('Elin Dance Studio')
                    ->setWebhook($notifyurl)
                    ->setReferenceNumber($out_trade_no);

            $result = $hitPayClient->createPayment($request);

            $return['status'] = true;
            $return['url'] = $result->getUrl();
            $return['id']  = $result->getId();


            //print_r($result);

            /*$data = $hitPayClient->getPaymentStatus($result->getId());
            dump($data);
            dump($data->status);*/

            /*$data = $hitPayClient->deletePaymentRequest($data->getId());
            print_r($data);*/


        } catch (\Exception $e) {
            $return['msg'] = $e->getMessage();
        }

        return $return;
    }




}