zhuishuyun_quickapp/app/Http/Controllers/Wap/Order/OrdersController.php

<?php

namespace App\Http\Controllers\Wap\Order;

use App\Http\Controllers\Wap\BaseController;
use App\Modules\Channel\Services\ChannelService;
use App\Modules\Cpa\Services\AdvertiseUserQueueService;
use App\Modules\Cpa\Services\AdvertiseUsersService;
use App\Modules\OfficialAccount\Services\ForceSubscribeService;
use App\Modules\Statistic\Services\AdVisitStatService;
use App\Modules\Statistic\Services\DataAnalysisSelectUserService;
use App\Modules\User\Services\ForceSubscribeUserIService;
use App\Modules\User\Services\UserService;
use App\Modules\Book\Services\BookService;
use App\Modules\Channel\Services\PayTemplateService;
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\Wap\Order\Transformers\BookOrderTransformer;
use App\Http\Controllers\Wap\Order\Transformers\ChapterOrderTransformer;
use App\Http\Controllers\Wap\Order\Transformers\ChargeListTransformer;
use Redis;
use App\Modules\Product\Services\ProductService;
use App\Modules\Subscribe\Services\SubstituteOrderService;
use Hashids;
use DB;

class OrdersController extends BaseController
{
    /**
     * @apiDefine Order 订单
     */

    private $force_subscribe_info;
    /**
     * @apiVersion 1.0.0
     * @apiDescription 充值列表
     * @api {get} order/chargeList 充值列表
     * @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)
    {
        if (!$this->checkUid()) {
            return response()->error('WAP_NOT_LOGIN');
        }
        $res = ProductService::getChargeProduct();
        if (!$res->isEmpty()) {
            $data = [];

            /*if ($this->send_order_id) {
                try {
                    Redis::sadd('pay_page_uv' . $this->send_order_id, $this->uid);
                    Redis::sadd('pay_page_uv_send_order_ids', $this->send_order_id);
                } catch (\Exception $e) {
                }

            }*/


            foreach ($res as $v) {
                $intro = [];
                if ($v->given > 0 && $v->type == 'TICKET_RECHARGE') {
                    $intro = [
                        [
                            'label' => ($v->price * 100) . "+",
                            'important' => false,
                        ],
                        [
                            'label' => $v->given,
                            'important' => true,
                        ],
                        [
                            'label' => '书币',
                            'important' => false,
                        ]

                    ];
                    $intro2 = [
                        ['label' => '多送', 'important' => false],
                        ['label' => (int)($v->given / 100), 'important' => true],
                        ['label' => '元', 'important' => false],
                    ];
                    $v->vip = 0;
                }
                if ($v->given == 0 && $v->type == 'TICKET_RECHARGE') {
                    $intro = [
                        [
                            'label' => $v->price * 100,
                            'important' => false,
                        ],
                        [
                            'label' => '书币',
                            'important' => false,
                        ]
                    ];
                    $v->vip = 0;
                    $intro2 = [];
                }
                if ($v->given == 0 && $v->type == 'YEAR_ORDER') {
                    $intro = [
                        [
                            'label' => '年费VIP会员',
                            'important' => true,
                        ]
                    ];
                    $v->vip = 1;
                    $intro2 = [
                        ['label' => '每天1元,全年免费看', 'important' => false],
                    ];
                }
                $data[] = [
                    'product_id' => $v->id,
                    'price' => (int)$v->price . '元',
                    'vip' => $v->vip,
                    'intro' => $intro,
                    'intro2' => $intro2,
                    'is_default' => $v->is_default,

                ];
            }
            return response()->success($data);
        } else {
            return response()->error('WAP_SYS_ERROR');
        }
    }

    public function chargeList(Request $request)
    {
        if (!$this->checkUid()) {
            return response()->error('WAP_NOT_LOGIN');
        }
        /*if (env('OTHER_PAY_TEMPLATE') &&
            in_array($this->distribution_channel_id,
                explode(',', env('OTHER_PAY_TEMPLATE')))
        ) {
            $template_id = 3;
        } else {*/
        $bid = $request->input('bid', '');
        $temp = $bid;
        $template_id = PayTemplateService::getPayTemplate($this->distribution_channel_id);
        //}
        \Log::info('order:$template_id:' . $template_id);
        \Log::info('order:$distribution_channel_id:' . ($this->distribution_channel_id));

        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 ($bid) {
                    $bid = Hashids::decode($bid)[0];
                    \Log::info('order:$bid:' . $bid);
                    $book = BookService::getBookById($bid);
                    \Log::info('order:$$book:' . json_encode($book));
                    if ($book->size < 200000) {
                        $template_id = 1;
                    }
                } else {
                    $template_id = 1;
                }
            }
        }
        if($temp){
            $temp_bid = 0;
            try{
                $temp_bid =  Hashids::decode($temp)[0];
            }catch (\Exception $e){}

            $t = $this->recordFirstIntoPayPage($temp_bid);
            if ($t) {
                $template_id = $t;
            }
        }

        //男频站点 支付模板
        if( ($male_site_template = $this->maleSite($this->distribution_channel_id)) ){
            //\Log::info('$male_site_template is: '.$male_site_template);
            $template_id = $male_site_template;
        }

        if( ($compare_id = $this->templateCompare()) ){
            $template_id = $compare_id;
        }

        /*if( ($comparev2_id = $this->templateCompareV2()) ){
            $template_id = $comparev2_id;
        }*/

        \Log::info('recordFirstIntoPayPage:$template_id:' . $template_id);
        $res = ProductService::getChargeProduct($template_id);
        if (!$res) {
            return response()->error('WAP_SYS_ERROR');
        }

        /*if ($this->send_order_id) {
            try {
                Redis::sadd('pay_page_uv' . $this->send_order_id, $this->uid);
                Redis::sadd('pay_page_uv_send_order_ids', $this->send_order_id);
            } catch (\Exception $e) {
            }

        }*/
        //TODO 长篇小数才有模板2
        //$user = $this->_user_info;
        $uid = $this->uid;
        $is_first_recharge = OrderService::judgeUserFirstRecharge($uid);
        //yqLog('user')->info('user is ',['user'=>$user]);
        //yqLog('user')->info('user is ',['charge_count'=>$user->charge_count]);
        $data = [];
        $appad =0;
        if(in_array($this->distribution_channel_id,explode(',',env('ADS_OPEN_SITE')))){
            $appad = $this->appad();
            $my_bid = $bid;
            if($appad) {
                try{
                    AdvertiseUsersService::addAdAccessRec(['uid'=>$this->uid,
                        'bid'=>$my_bid,
                        'position'=>'RECHARGE',
                        'created_at'=>date('Y-m-d H:i:s'),
                        'updated_at'=>date('Y-m-d H:i:s'),
                        'remark'=>$request->url()
                    ]);
                }catch(\Exception $e){
                    \Log::error('insert into advertise_access_rec failded:'.$e->getMessage());
                }
            }
        }
        //\Log::info('ad-tu:uid:'.$uid.':'.$appad);
        foreach ($res as $v) {
            if($appad && $v->price == 100){
                //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,
                    'text' => sprintf('%s+%s书币', $v->price * 100, $v->given),
                    'first_charge' => true,
                    'today_special' => false,
                    'save_text' => round($v->given / 100, 1) . '元',
                    'product_id' => $v->id,
                    'show_free_ads'=>$appad
                ];
                $data[] = $temp;
            } elseif ($v->type == 'YEAR_ORDER') {
                if ($v->type == 'NEW_USER') {
                    continue;
                }
                $save_text = '年费vip会员';
                $text = '每天1元，全年免费看';
                $temp = [
                    'price' => (int)$v->price . '元',
                    'is_year_order' => 1,
                    'text' => $text,
                    'first_charge' => false,
                    'today_special' => false,
                    'save_text' => $save_text,
                    'product_id' => $v->id,
                    'show_free_ads'=>$appad
                ];
                $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,
                    'text' => $text,
                    'first_charge' => false,
                    'today_special' => $v->is_default == 1 ? true : false,
                    'save_text' => $save_text,
                    'product_id' => $v->id,
                    'show_free_ads'=>$appad
                ];
                $data[] = $temp;
            }
        }
        return response()->success($data);
    }


    public function substitutePayChargeList(Request $request)
    {
        $default = $request->get('product_id');
        if (!$this->checkUid()) {
            return response()->error('WAP_NOT_LOGIN');
        }
        $su = $request->get('su');
        $res = ProductService::getChargeProduct();
        if (!$res) {
            return response()->error('WAP_SYS_ERROR');
        }
        $is_can_allow_pay = 1;
        if ($su) {
            $su_user = UserService::getById($su);
            $now_user = $this->_user_info;
            if ($now_user && $su_user && $su_user->openid == $now_user->openid) {
                $is_can_allow_pay = 0;
            }
        }
        SubstituteOrderService::substitutePageUvPv($this->uid, $this->distribution_channel_id);
        $data = [];
        foreach ($res as $v) {
            if ($v->type == 'YEAR_ORDER') {
                $temp = [
                    'price' => (int)$v->price . '元',
                    'text' => '年费VIP会员',
                    'first_charge' => false,
                    'today_special' => $v->is_default == 1 ? true : false,
                    'save_text' => '全年免费',
                    'product_id' => $v->id,
                    'default' => false,
                    'is_vip' => 1,
                    'is_can_allow_pay' => $is_can_allow_pay
                ];
                if ($default) {
                    if ($default == $v->id) {
                        $temp['default'] = true;
                    }
                } else {
                    $temp['default'] = $v->is_default == 1 ? true : false;
                }
                $data[] = $temp;

            } else {
                $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' => (int)$v->price . '元',
                    'text' => $text,
                    'first_charge' => false,
                    'today_special' => $v->is_default == 1 ? true : false,
                    'save_text' => $save_text,
                    'product_id' => $v->id,
                    'default' => false,
                    'is_vip' => 0,
                    'is_can_allow_pay' => $is_can_allow_pay
                ];
                if ($default) {
                    if ($default == $v->id) {
                        $temp['default'] = true;
                    }
                } else {
                    $temp['default'] = $v->is_default == 1 ? true : false;
                }

                $data[] = $temp;
            }
        }
        return response()->success($data);
    }

    /**
     * @apiVersion 1.0.0
     * @apiDescription 单本消费记录
     * @api {get} order/bookOrderList 单本消费记录
     * @apiGroup Order
     * @apiName bookOrderList
     * @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)
    {
        if (!$this->checkUid()) {
            return response()->error('WAP_NOT_LOGIN');
        }
        $page_size = $request->input('page_size', 15);
        $book_order = BookOrderService::getRecord($this->uid, $page_size);
        //$book_order = BookOrder::where('uid', $this->uid)->select('bid', 'uid', 'book_name', 'created_at', 'fee')->paginate($page_size);

        return response()->pagination(new BookOrderTransformer(), $book_order);
    }


    /**
     * @apiVersion 1.0.0
     * @apiDescription 章节消费记录
     * @api {get} order/chapterOrderList 章节消费记录
     * @apiGroup Order
     * @apiName chapterOrderList
     * @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)
    {
        if (!$this->checkUid()) {
            return response()->error('WAP_NOT_LOGIN');
        }
        $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']);
                if($result) $item->fee = '解锁';
            }
        }
        return response()->pagination(new ChapterOrderTransformer(), $chapter_order);
    }


    /**
     * @apiVersion 1.0.0
     * @apiDescription 充值记录
     * @api {get} order/chargeRecordLists 充值记录
     * @apiGroup Order
     * @apiName chargeRecordLists
     * @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::getOrderList($this->uid, $page_size);
        return response()->pagination(new ChargeListTransformer(), $res);
    }

    //订单是否成功
    public function isSuccess(Request $request)
    {
        $order = $request->input('order');
        $order_info = OrderService::getByTradeNo($order);
        if ($order_info && $order_info->status == 'PAID') {
            return response()->success();
        }
        return response()->error('WAP_SYS_ERROR');
    }

    public function substitutePay(Request $request)
    {
        if (!$this->checkUid()) {
            return response()->error('WAP_NOT_LOGIN');
        }
        $product_id = $request->get('product_id');
        SubstituteOrderService::substituteButtonUvPv($this->uid, $this->distribution_channel_id);
        $user = $this->_user_info;
        $data = [
            'head_img' => '',
            'nickname' => $user->nickname
        ];
        //$help_pay_page_channel_id = env('HELP_PAY_PAGE_CHANNEL_ID', 123);
        $help_pay_page_channel_id = $this->distribution_channel_id;
        $url_format = '%s://site%s.%s.com/helppay?%s';
        $param = [];
        $param['su'] = $this->uid;
        if ($product_id) {
            $param['product_id'] = $product_id;
        }

        $help_pay_page = sprintf(
            $url_format,
            env('PROTOCOL'),
            encodeDistributionChannelId($help_pay_page_channel_id),
            env('CUSTOM_HOST'),
            http_build_query($param)
        );
        $data['help_pay_page'] = $help_pay_page;
        return response()->success($data);
    }

    private function recordFirstIntoPayPage($bid)
    {
        $start_time = env('RECORD_FIRST_VISIT_PAY_PAGE_TIME');
        $template_id = 0;
        if (in_array($this->distribution_channel_id,[123,211])  && $start_time && $this->uid) {
            $user = $this->_user_info;
            if (strtotime($user->created_at) > $start_time) {
                $old = DB::table('user_first_visit_pay_page')->where('uid', $this->uid)->select('uid', 'template_type')->first();
                if ($old) {
                    $template_id = $old->template_type;
                    if($template_id) return $template_id;
                }
                if ($bid && $bid == 1148) {
                    $template_id = $this->uid % 2 == 0 ? 2 : 1;
                    if (empty($old)) {
                        try {
                            DB::table('user_first_visit_pay_page')->insert([
                                'uid' => $this->uid,
                                'template_type' => $template_id,
                                'created_at' => date('Y-m-d H:i:s'),
                                'updated_at' => date('Y-m-d H:i:s')
                            ]);
                        } catch (\Exception $e) {
                        }
                    }
                }
            }
        }
        return $template_id;
    }

    private function templateCompare(){
        //if(!in_array($this->distribution_channel_id,[2,14,211,155,4427,4488,256,691,146,255,722,4364,5,202,318,4237,266,196,273,4236,148,8,4241,160,271,4053,123,4334,4487,4593,695,4025,4426,4174])){
        /*$start_time = env('TEMPLATE_COMPARE_START_TIME_3',0);
        if(!$start_time){
            return 0;
        }*/
        if(!in_array($this->distribution_channel_id,[14,123,211,5,8,160,4236,4237,4241,374,243,244,245,320,321,324,337,338,538,539,751,752,753,754,4331,4384,4578,4580,4768,4769,4778,130,163,164,165,166,4126])){
            return 0;
        }

        //$user = $this->_user_info;
        /*if(strtotime($user->created_at) < $start_time){
            return 0;
        }*/
        $template_id = 0;
        $user = DataAnalysisSelectUserService::getByUidAndType($this->uid,'TEMPLATE_COMPARE_V3');
        if($user){
            $template_id = $user->attach;
        }

        return $template_id;
    }


    private function templateCompareV2(){
        $start_time = env('TEMPLATE_COMPARE_START_TIME',0);
        if(!$start_time){
            return 0;
        }

        if(!in_array($this->distribution_channel_id,[2,146 ,155 ,255 ,256 ,691 ,722 ,4364 ,695 ,4174 ,4025 ,4593 ,4426 ,4742 ,4053 ,4334 ,4487])){
            return 0;
        }
        $user = $this->_user_info;
        if(strtotime($user->created_at) < $start_time){
            return 0;
        }

        $user = DataAnalysisSelectUserService::getByUidAndType($this->uid,'TEMPLATE_COMPAREV2');
        if($user){
            $template_id = $user->attach;
        }else{
            $template_id = $this->uid % 2 == 0? 1:6;
            DataAnalysisSelectUserService::create(
                $this->uid,
                $this->distribution_channel_id,
                'TEMPLATE_COMPAREV2',
                -1, $template_id);
        }

        return $template_id;
    }

    private function maleSite($distribution_channel_id){
        $info = ChannelService::getChannelCompanyInfo($distribution_channel_id);
        //\Log::info('maleSite info is:');
        //\Log::info($info);
        if($info && isset($info->fans_gender)){
            if($info->fans_gender == 1){
                return 1;
            }
        }
        return 0;
    }

    private function appad(){
        if($this->force_subscribe_info){
            $force_subscribe_info = $this->force_subscribe_info;
        }else{
            $force_subscribe_info = $this->force_subscribe_info = ForceSubscribeService::forceSubscribeUsersByUid(['uid' => $this->uid]);
        }
        if(!$force_subscribe_info){
            return 0;
        }
        $force_sub_user_by_openid = ForceSubscribeUserIService::getForceSubscribeByUidOpenid($this->uid);
        if($force_sub_user_by_openid){
            $force_subscribe_info = $force_sub_user_by_openid;
        }
        if($force_subscribe_info->subscribe_time &&
            (time()-strtotime($force_subscribe_info->subscribe_time) >=3*86400)
            && !OrderService::isPaidUser($this->uid) &&
            !AdvertiseUserQueueService::getUserAdvertise($this->uid) &&
            in_array($this->distribution_channel_id,explode(',',env('ADS_OPEN_SITE')))
        ){
            return 1;
        }
        return 0;
    }
}