<?php
namespace App\Http\Controllers\QuickApp\Order;
use App\Consts\ErrorConst;
use App\Libs\Utils;
use App\Modules\Activity\Models\Activity;
use App\Modules\SendOrder\Models\QappSendOrder;
use App\Modules\Statistic\Services\AdVisitStatService;
use App\Http\Controllers\QuickApp\BaseController;
use App\Modules\User\Models\User;
use Illuminate\Http\Request;
use App\Modules\Subscribe\Services\BookOrderService;
use App\Modules\Subscribe\Services\ChapterOrderService;
use App\Modules\Subscribe\Services\OrderService;
use App\Http\Controllers\QuickApp\Order\Transformers\BookOrderTransformer;
use App\Http\Controllers\QuickApp\Order\Transformers\ChapterOrderTransformer;
use App\Http\Controllers\QuickApp\Order\Transformers\ChargeListTransformer;
use App\Libs\Pay\PayFactory;
use Hashids;
use App\Modules\Product\Services\ProductService;
use App\Modules\Book\Services\BookConfigService;
use App\Modules\Book\Services\BookService;
use App\Modules\Channel\Services\PayTemplateService;
use App\Modules\Subscribe\Models\Order;
use App\Modules\Trade\Models\Order as TradeOrder;
use App\Modules\Trade\Pay\OrderArousePayFactory;
use App\Modules\Trade\Pay\OrderPaySuccess;
use App\Modules\Trade\Services\PayMerchantService;
use App\Modules\User\Services\ReadRecordService;
use EasyWeChat\Support\XML;
use App\Modules\User\Services\UserChargeService;
use App\Modules\User\Services\UserService;
class OrdersController extends BaseController
{
/**
* @apiDefine Order 订单
*/
/**
*
*/
private $chargeList;
public function exchangeList()
{
foreach ($this->chargeList as &$item) {
if (!$item->switch_to) continue;
$order = Order::where('uid', $this->uid)->where('status', 'PAID')->where('product_id', $item->id)->first();
if ($order) {
$change = ProductService::getProductSingle($item->switch_to);
$item->id = $change->id;
$item->price = $change->price;
$item->given = $change->given;
}
}
}
/**
* @apiVersion 1.0.0
* @apiDescription 充值列表
* @api {get} order/chargeList 充值列表
* @apiHeader {String} [Authorization] token
* @apiGroup Order
* @apiName chargeList
* @apiSuccess {int} code 状态码
* @apiSuccess {String} msg 信息
* @apiSuccess {object} data 结果集
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data: [
* {
* product_id: 1,
* price: "30.00元",
* vip: 0,
* intro: [
* {
* label: 3000,
* important: false
* },
* {
* label: "书币",
* important: true
* }
* ]
* },
* {
* product_id: 2,
* price: "50.00元",
* vip: 1,
* intro: [
* {
* label: 5000,
* important: false
* },
* {
* label: "1000+",
* important: true
* },
* {
* label: "书币",
* important: false
* }
* ]
* },
* {
* product_id: 5,
* price: "365.00元",
* vip: 0,
* intro: [
* {
* label: "年费VIP会员",
* important: true
* }
* ]
* }
* ]
* }
*/
public function chargeList(Request $request)
{
$bid = $request->input('bid', '');
$temp = $bid;
$template_id = PayTemplateService::getPayTemplate($this->distribution_channel_id);
// 获取派单id
$sendOrderId = 0;
//$sendOrderId = ReadRecordService::getSendOrderId($this->uid);
$sendOrderId = UserService::GetBindSendOrderId($this->uid);
if(env('NEW_CHARGE')){
//2022-4月中旬，启用新的获取模板方式
$res = UserChargeService::getTemplate($this->uid,$sendOrderId,$this->distribution_channel_id);
if ($res) {
return response()->success($res);
}
}
if ($sendOrderId) {
// 获取快应用账号
$qappSendOrder = QappSendOrder::getSendOrderById($sendOrderId);
$account = getProp($qappSendOrder, 'account');
// 注意！！！以后模板id加10000内的，不然可能会和渠道自定义的冲突
// 方夏青的派单使用，男频充值模板
// 30,50,100,200,499
if ($account === 'fangxq') {
$template_id = 10666;
}
// 黄宇辉的派单使用，男频充值模板
// 18首充,30,50,100,200,365
if (in_array($account, ['18668420256','huanghy1'])) {
$template_id = 9997;
}
// 蒋佳芯
// 30,50,100,200,499
if (in_array($account, ['jiangjx'])) {
$template_id = 10679;
}
// 杨子行
// 32,52,66,100,200,499
if (in_array($account, ['yangzh','yangzh2'])) {
$template_id = 9998;
}
// 32,52,100,200,365
if (in_array($account, ['hanyh', 'liwh', 'caicf', 'wangdd', 'zhangtt', 'hanyh2', 'hanyh33','zhangtt2','zhangtt33','zhangtt4'])) {
$template_id = 9999;
}
}
myLog('charge')->info('chargeList_1', ['uid' => $this->uid, 'bid' => $bid, 'template_id' => $template_id, 'sendOrderId' => $sendOrderId]);
$book_config = null;
if ($bid) {
$bid = Hashids::decode($bid)[0];
$book_config = BookConfigService::getBookById($bid);
}
if ($template_id == 2) { //模板2只有在长篇小说过来的用户才显示
//部分渠道需要2元模板不管哪个入口进来都展示
$exclude_channels = explode(',', env('PRICE_TWO_SHOW_ALL_CHANNEL'));
if (!in_array($this->distribution_channel_id, $exclude_channels)) {
if ($book_config) {
if ($book_config->charge_type == 'BOOK') $template_id = 1;
}
}
}
$res = ProductService::getChargeProduct($template_id);
if (!$res) {
return response()->error('WAP_SYS_ERROR');
}
$this->chargeList = $res;
$this->exchangeList();
//TODO 长篇小数才有模板2
$uid = $this->uid;
$is_first_recharge = OrderService::judgeUserFirstRecharge($uid);
myLog('charge')->info('chargeList_2', ['uid' => $this->uid, 'is_first_recharge' => $is_first_recharge, 'res' => $res]);
\Log::info('qappchargeList:uid:'.$uid.' send_order_id:'.$sendOrderId.' template_id:'.$template_id.' is_first_recharge:'.$is_first_recharge);
$data = [];
$appad = 0;
foreach ($res as $v) {
if ($template_id == 7 && $book_config && $book_config->charge_type == 'BOOK' && $v->price == 2) {
continue;
}
if ($template_id == 2 && $v->type == 'NEW_USER' && !$bid) {
//2元模版，直接进充值，不出现
continue;
}
if ($v->type == 'NEW_USER' && $is_first_recharge) {
if (
env('NO_NEW_USER_CHARGE') &&
in_array(
$this->distribution_channel_id,
explode(',', env('NO_NEW_USER_CHARGE'))
)
) {
continue;
}
$temp = [
'price' => (float)$v->price . '元',
'is_year_order' => 0,
'is_month_order' => 0,
'text' => sprintf('%s+%s书币', $v->price * 100, $v->given),
'today_special' => $v->is_default,
'first_charge' => true,
'save_text' => round($v->given / 100, 1) . '元',
'product_id' => $v->id,
];
$data[] = $temp;
} elseif ($v->type == 'YEAR_ORDER') {
if ($v->type == 'NEW_USER') {
continue;
}
$save_text = '年费vip会员';
$text = '全年免费看';
$temp = [
'price' => (int)$v->price . '元',
'is_year_order' => 1,
'is_month_order' => 0,
'text' => $text,
'today_special' => $v->is_default,
'first_charge' => false,
'save_text' => $save_text,
'product_id' => $v->id,
];
$data[] = $temp;
} else {
if ($v->type == 'NEW_USER') {
continue;
}
$save_text = '';
if ($v->given) {
$save_text = round($v->given / 100, 1) . '元';
$text = sprintf('%s+%s书币', $v->price * 100, $v->given);
} else {
$text = sprintf('%s书币', $v->price * 100);
}
$temp = [
'price' => (float)$v->price . '元',
'is_year_order' => 0,
'is_month_order' => 0,
'text' => $text,
'today_special' => $v->is_default,
'first_charge' => false,
'save_text' => $save_text,
'product_id' => $v->id,
];
$data[] = $temp;
}
}
return response()->success($data);
}
/**
* @apiVersion 1.0.0
* @apiDescription 单本消费记录
* @api {get} order/bookOrderList 单本消费记录
* @apiHeader {String} [Authorization] token
* @apiGroup Order
* @apiName bookOrderList
* @apiParam {String} [page_size] 分页大小
* @apiParam {String} [page] 页码
* @apiSuccess {int} code 状态码
* @apiSuccess {String} msg 信息
* @apiSuccess {object} data 结果集
* @apiSuccess {Int} uid uid
* @apiSuccess {Int} bid bid
* @apiSuccess {Int} book_name 书名
* @apiSuccess {Int} fee 钱
* @apiSuccess {String} created_at 时间
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data: list:[
* {
* uid: 4,
* bid: 1,
* book_name: "dfsedfertrwet",
* fee: 100,
* created_at: "2017-12-02 16:24:54"
* }
* ]
* meta: {
* total: 1,
* per_page: 15,
* current_page: 1,
* last_page: 1,
* next_page_url: "",
* prev_page_url: ""
* }
* }
* }
*/
public function bookOrderList(Request $request)
{
$page_size = $request->input('page_size', 15);
$book_order = BookOrderService::getRecord($this->uid, $page_size);
return response()->pagination(new BookOrderTransformer(), $book_order);
}
/**
* @apiVersion 1.0.0
* @apiDescription 章节消费记录
* @api {get} order/chapterOrderList 章节消费记录
* @apiHeader {String} [Authorization] token
* @apiGroup Order
* @apiName chapterOrderList
* @apiParam {String} [page_size] 分页大小
* @apiParam {String} [page] 页码
* @apiSuccess {int} code 状态码
* @apiSuccess {String} msg 信息
* @apiSuccess {object} data 结果集
* @apiSuccess {Int} uid uid
* @apiSuccess {Int} bid bid
* @apiSuccess {Int} cid cid
* @apiSuccess {Int} chapter_name 章节名
* @apiSuccess {Int} book_name 书名
* @apiSuccess {Int} fee 钱
* @apiSuccess {String} created_at 时间
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data: list:[
* {
* uid: 4,
* bid: 1,
* cid: 1,
* chapter_name: "sdfsd",
* book_name: "dfsedfertrwet",
* fee: 100,
* created_at: "2017-12-02 16:24:54"
* }
* ]
* meta: {
* total: 1,
* per_page: 15,
* current_page: 1,
* last_page: 1,
* next_page_url: "",
* prev_page_url: ""
* }
* }
*/
public function chapterOrderList(Request $request)
{
$chapter_model = new ChapterOrderService();
$page_size = $request->input('page_size', 15);
$chapter_order = $chapter_model->getByUid($this->uid, $page_size);
foreach ($chapter_order as $item) {
if ($item->fee == 0) {
$result = AdVisitStatService::getInfoV2($this->uid, $item->cid, ['UNLOCK', 'UNLOCK_2']);
$item->fee = '解锁';
}
}
return response()->pagination(new ChapterOrderTransformer(), $chapter_order);
}
/**
* @apiVersion 1.0.0
* @apiDescription 充值记录
* @api {get} order/chargeRecordLists 充值记录
* @apiParam {String} [token] token
* @apiHeader {String} [Authorization] token 两个token任选其一
* @apiGroup Order
* @apiName chargeRecordLists
* @apiParam {String} [page_size] 分页大小
* @apiParam {String} [page] 页码
* @apiSuccess {int} code 状态码
* @apiSuccess {String} msg 信息
* @apiSuccess {object} data 结果集
* @apiSuccess {String} data.price 价格
* @apiSuccess {String} data.status 状态
* @apiSuccess {String} data.trade_no 订单号
* @apiSuccess {String} data.created_at 时间
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data: {
* list: [
* {
* id: 134,
* price: "1.00",
* status: "PAID",
* trade_no: "201712021915481585670623626232",
* created_at: "2017-12-02 19:15:56"
* }
* ],
* meta: {
* total: 1,
* per_page: 15,
* current_page: 1,
* last_page: 1,
* next_page_url: "",
* prev_page_url: ""
* }
* }
* }
*/
public function chargeRecordLists(Request $request)
{
$page_size = $request->input('page_size', 15);
$res = OrderService::getSuccessOrderList($this->uid, $page_size);
return response()->pagination(new ChargeListTransformer(), $res);
}
private function getPayParams(Request $request)
{
$uid = $this->uid;
$product_id = $request->get('product_id', 0);
$send_order_id = $this->send_order_id;
if (!$product_id) {
return false;
}
$bid = $request->get('bid', 0);
if ($bid) {
$from_bid = BookService::decodeBidStatic($bid);
}else{
$from_bid = ReadRecordService::getSimpleFirstReadRecord($uid);
}
$trade_no = date("YmdHis") . hexdec(uniqid());
myLog('pay-order')->info('request', [
'params' => $request->all(),
'uid' => $uid,
'bid' => $bid,
'trade_no' => $trade_no
]);
$product_info = ProductService::getProductSingle($product_id);
if (!getProp($product_info, 'id')) {
return false;
}
$distribution_channel_id = $this->distribution_channel_id;
$price = $product_info->price * 100;
if (in_array($uid, explode(',', env('TEST_UID')))) {
$price = 1;
}
$from_type = 'QuickApp';
if ($product_info->type == 'YEAR_ORDER') {
$order_type = 'YEAR';
} elseif ($product_info->type == 'QUARTER') {
$order_type = 'QUARTER';
} elseif ($product_info->type == 'BOOK_ORDER') {
$order_type = 'BOOK';
} elseif ($product_info->type == 'TICKET_RECHARGE') {
$order_type = 'RECHARGE';
} else {
$order_type = '';
}
$create_ip = _getIp();
// 活动
$activity_token = $request->get('activity_token', '');
$activity_id = 0;
if ($activity_token) {
$activity = Activity::getActivityBuToken($activity_token);
$activity_id = (int)getProp($activity, 'id');
// 校验活动次数
$settingJson = getProp($activity, 'setting');
if ($settingJson) {
$setting = json_decode($settingJson, true);
$productInfos = getProp($setting, 'product_info', []);
$productInfo = collect($productInfos)->firstWhere('product_id', $product_id);
$limit = (int)getProp($productInfo, 'limit');
if ($limit > 0) {
// 查询用户通过该活动已经充值的次数
$paidNum = TradeOrder::getActivityOrderNum([
'uid' => $uid,
'begin_time' => getProp($activity, 'start_time'),
'end_time' => getProp($activity, 'end_time'),
'status' => 'PAID',
'product_id' => $product_id,
'activity_id' => $activity_id
]);
myLog('charge')->info('', compact('uid', 'product_id', 'activity', 'paidNum'));
// 活动充值次数限制
if ($paidNum >= $limit) {
Utils::throwError(ErrorConst::ACTIVITY_CHARGE_OUT_OF_LIMIT);
}
}
}
}
// 包名
$package = $request->header('x-package', '');
return compact(
'distribution_channel_id',
'uid',
'product_id',
'price',
'trade_no',
'create_ip',
'send_order_id',
'from_bid',
'from_type',
'order_type',
'activity_id',
'package'
);
}
/**
* @apiVersion 1.0.0
* @apiDescription 支付
* @api {get} goToPay 微信APP支付
* @apiGroup pay
* @apiName wxindex
* @apiParam {Int} product_id product_id
* @apiParam {Int} send_order_id send_order_id
* @apiParam {String} bid bid
* @apiHeader {String} [Authorization] token
* @apiSuccess {int} code 状态码
* @apiSuccess {String} msg 信息
* @apiSuccess {Object} data 信息
* @apiSuccess {Object} data.trade_no 订单号
* @apiSuccess {Object} data.appId 唤起支付的appId
* @apiSuccess {Object} data.mch_id 唤起支付的mch_id
* @apiSuccess {Object} data.nonce_str 唤起支付的nonce_str
* @apiSuccess {Object} data.prepay_id 唤起支付的prepay_id
* @apiSuccess {Object} data.sign 唤起支付的sign
* @apiSuccess {Object} data.trade_type 唤起支付trade_type
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data: {
*
* }
*/
function wxIndex(Request $request)
{
if ($params = $this->getPayParams($request)) {
$params['pay_merchant_id'] = $this->app_pay_merchat_id;
} else {
return response()->error('QAPP_PARAM_ERROR');
}
$app = OrderArousePayFactory::wx($this->uid);
// 微信支付参数
$params['trade_type'] = 'APP'; //交易类型
$result = $app->handle($params);
myLog('wxPay')->info('wxIndex', compact('params', 'result'));
if ($result) {
$result['trade_no'] = $params['trade_no'];
return response()->success($result);
} else {
return response()->error('APP_CREATE_WECHAT_ORDER_FAIL');
}
}
/**
* @apiVersion 1.0.0
* @apiDescription 微信H5支付
* @api {get} goToH5Pay 微信H5支付
* @apiGroup pay
* @apiName wxH5Index
* @apiParam {Int} product_id product_id
* @apiParam {Int} send_order_id send_order_id
* @apiParam {String} bid bid
* @apiHeader {String} [Authorization] token
* @apiSuccess {int} code 状态码
* @apiSuccess {String} msg 信息
* @apiSuccess {Object} data 信息
* @apiSuccess {Object} data.trade_no 订单号
* @apiSuccess {Object} data.appId 唤起支付的appId
* @apiSuccess {Object} data.mch_id 唤起支付的mch_id
* @apiSuccess {Object} data.nonce_str 唤起支付的nonce_str
* @apiSuccess {Object} data.prepay_id 唤起支付的prepay_id
* @apiSuccess {Object} data.sign 唤起支付的sign
* @apiSuccess {Object} data.trade_type 唤起支付trade_type
* @apiSuccess {Object} data.mweb_url 唤起支付mweb_url
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data: {
*
* }
*/
function wxH5Index(Request $request)
{
if ($params = $this->getPayParams($request)) {
$params['pay_merchant_id'] = $this->h5_pay_merchat_id;
} else {
return response()->error('QAPP_PARAM_ERROR');
}
$app = OrderArousePayFactory::wx($this->uid);
// 微信支付参数
$params['trade_type'] = 'MWEB'; //交易类型
$result = $app->handle($params);
myLog('wxPay')->info('wxH5Index', compact('params', 'result'));
if ($result) {
$result['trade_no'] = $params['trade_no'];
return response()->success($result);
} else {
return response()->error('APP_CREATE_WECHAT_ORDER_FAIL');
}
}
/**
* @apiVersion 1.0.0
* @apiDescription 支付宝APP支付
* @api {get} goToAliPay 支付宝APP支付
* @apiGroup pay
* @apiName aliIndex
* @apiParam {Int} product_id product_id
* @apiParam {Int} send_order_id send_order_id
* @apiParam {String} bid bid
* @apiHeader {String} [Authorization] token
* @apiSuccess {Object} data.order_info 唤起支付信息str
* @apiSuccess {Object} data.trade_no 订单号
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data:""
*
*/
public function aliIndex(Request $request)
{
myLog('aliPay')->info('aliIndex-request', [$request->all()]);
if ($params = $this->getPayParams($request)) {
myLog('aliPay')->info('aliIndex-request1', compact('params'));
$params['pay_merchant_id'] = $this->ali_pay_merchat_id;
$params['type'] = 'App';
myLog('aliPay')->info('aliIndex-request2', compact('params'));
} else {
return response()->error('QAPP_PARAM_ERROR');
}
$app = OrderArousePayFactory::ali($this->uid);
$order_info = $app->handle($params);
myLog('aliPay')->info('aliIndex', compact('params', 'order_info'));
return response()->success(['trade_no' => $params['trade_no'], 'order_info' => $order_info]);
}
/**
* @apiVersion 1.0.0
* @apiDescription 订单查询
* @api {get} checkOrder 订单查询
* @apiGroup pay
* @apiName checkOrder
* @apiParam {String} [token] token
* @apiHeader {String} [Authorization] token 两个token任选其一
* @apiParam {String} order order
* @apiSuccess {int} code 状态码
* @apiSuccess {String} msg 信息
* @apiSuccess {Object} data 信息
* @apiSuccessExample {json} Success-Response:
* HTTP/1.1 200 OK
* {
* code: 0,
* msg: "",
* data: {
*
* }
*/
public function checkOrder(Request $request)
{
$order = $request->input('order');
$order_info = OrderService::getByTradeNo($order);
if ($order_info && $order_info->status == 'PAID') {
return response()->success();
}else{
$result = $this->queryWechatPayResult($order);
if ($result){
return response()->success();
}
}
return response()->success($order);
}
/**
* 官方微信回调
*/
function wxback(Request $request)
{
$xml = XML::parse(strval($request->getContent()));
myLog('wxpay')->info($xml);
if (isset($xml['attach'])) {
$pay_merchant_id = (int)$xml['attach'];
$config = PayMerchantService::findPayConfig($pay_merchant_id);
$app = PayFactory::official($config);
$response = $app->notify()->handleNotify(function ($notify, $successful) {
if (!$successful) {
return 'fail';
}
if (OrderPaySuccess::handle($notify->out_trade_no, $notify->transaction_id)) {
return true;
} else {
return 'fail';
}
});
return $response;
} else {
return 'fail';
}
}
/**
* 支付宝支付回调
*/
function aliback(Request $request)
{
$param = $request->except('_url');
myLog('alipay')->info($param);
$trade_no = isset($param['out_trade_no']) ? $param['out_trade_no'] : '';
if ($trade_no) {
$order = Order::where('trade_no', $trade_no)->first();
$pay_merchant_id = $order ? $order->pay_merchant_id : 0;
$pay_merchant_id = $pay_merchant_id ? $pay_merchant_id : 140;
$config = PayMerchantService::findAliPayConfig($pay_merchant_id);
$app = PayFactory::aliPay($config);
if ($app->notify($param)) {
if (OrderPaySuccess::handle($param['out_trade_no'], $param['trade_no'])) {
return response('success');
} else {
return response('fail');
}
}
}
myLog('alipay')->info('sign fail');
return response('fail');
}
function wait(Request $request)
{
$param = $request->except('_url');
return view('pay.middleware')->with($param);
}
/**
* 根据用户获取付费列表
* @param Request $request [description]
* @return [type] [description]
*/
public function newChargeList(Request $request){
$this->distribution_channel_id;
$uid = $this->uid;
$send_order_id = $this->user_info->send_order_id;
$res = UserChargeService::getTemplate($this->uid,$send_order_id,$this->distribution_channel_id);
return response()->success($res);
}
/***
* 微信订单支付查询
* name: queryWechatPayResult
* @param mixed $order 订单号
* @return bool
* date 2022/07/29 11:11
*/
private function queryWechatPayResult($order = ""): bool
{
$config = PayMerchantService::findPayConfig($this->h5_pay_merchat_id);
$app = PayFactory::official($config);
$result = $app->query($order);
if ($result){
return true;
}
return false;
}
}