jiankangtv/application/api/controller/Notify.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use wxpay;
use addons\epay\library\Service;

/**
 * 支付回调
 */
class Notify extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    // 支付回调
    public function notify() {
//        require_once($_SERVER['DOCUMENT_ROOT'] . "/Plugins/WxPay/WxPay.php");
        $wxPay = new wxpay\WxPay();
        //验证是否是微信发送
        $flag = $wxPay->WxPayNotifyCheck();
//        error_log(print_r($flag, 1), 3, 'post.txt');

//        LL($flag,'./log1.txt');
        //验证成功
        if ($flag['status']) {
            if ($flag['data']['return_code'] == 'SUCCESS' && $flag['data']['result_code'] == 'SUCCESS') {
                $total_fee = trim($flag['data']['total_fee']) / 100; //支付的金额, 单位:分转成元
                $order_sn = trim($flag['data']['out_trade_no']);//商家订单号

                $PayResult = Db::name('rechar_order');
                $where['order_no'] = $order_sn;
                $order_info = $PayResult->where($where)->find();
                if ($order_info['money'] != $total_fee) {
                    $r_arr['return_code'] = 'FAIL';
                    $r_arr['return_msg'] = '回调失败';
                    echo $wxPay->arrayToXml($r_arr);
                    die;
                }
                if ($order_info['status'] == 1) {
                    $r_arr['return_code'] = 'SUCCESS';
                    $r_arr['return_msg'] = '回调成功';
                    echo $wxPay->arrayToXml($r_arr);
                    die;
                }

                //构建支付订单处理结果信息
                $_data['transaction_id'] = trim($flag['data']['transaction_id']); //微信交易凭证
                $_data['status'] = 1;
                $_data['updatetime'] = time();

                //支付订单类型
                if ($order_info['purpose'] == 1) {
                    //查询订单
                    $active_order = Db::name('game_people')->find($order_info['relation_id']);
                    //开启事务
                    Db::startTrans();
                    //修改报名状态
                    $active_order_rs = Db::name('game_people')->where(['id' => $order_info['relation_id'], 'status' => 0])->setField(['status' => 1, 'updatetime' => time()]);

                    //活动标题
                    $active_title = Db::name('game')->where(['id' => $active_order['game_id']])->value('name');
                    //发送消息
                    $data = [
                        'user_id' => $order_info['user_id'],
                        'type' => 1,
                        'title' => '比赛通知',
                        'content' => '您已成功报名' . $active_title . '比赛',
                        'createtime' => time()
                    ];
                    $sys_rs = Db::name('sys_msg')->insertGetId($data);

                    if ($active_order_rs && $sys_rs) {
                        Db::commit();
                    } else {
                        Db::rollback();
                        $_data['pay_status'] = 1; //回调状态: 1=支付订单回调失败,2=充值回调失败,3=开通会员回调失败
                    }
                }

                $PayResult->where($where)->setField($_data);

                $r_arr['return_code'] = 'SUCCESS';
                $r_arr['return_msg'] = '回调成功';
                echo $wxPay->arrayToXml($r_arr);
                die;
            }
        }
        $r_arr['return_code'] = 'FAIL';
        $r_arr['return_msg'] = '回调失败';
        echo $wxPay->arrayToXml($r_arr);
        file_put_contents('wx_pay_error_logs.txt', date('Y-m-d H:i:s').'支付失败！'.json_encode($flag), FILE_APPEND);
        die;
    }

    /**
     * 支付回调
     */
    public function notify1() {
        $paytype = $this->request->param('paytype');
        $pay = Service::checkNotify($paytype);
//        Log::record("=======================", 'info');
//        Log::record("pay:", 'info');
//        Log::record($pay, 'info');
//        Log::record("=======================", 'info');
        if (!$pay) {
            echo '签名错误';
            return;
        }
        $data = $pay->verify();
        $time = time();
        try {
            $payamount = $paytype == 'alipay' ? $data['total_amount'] : $data['total_fee'] / 100;
            $out_trade_no = $data['out_trade_no'];
            Db::startTrans();
            try{
                $orderModel = new \app\common\model\RecharOrder();
                $userModel = new \app\common\model\User();
                $orderInfo = $orderModel->where(["order_no"=>$out_trade_no])->find();
                $userInfo = $userModel->where(["id"=>$orderInfo["user_id"]])->find();
                $res1 = false;
                $res2 = false;
                $res3 = false;
                if($orderInfo['status'] == 0) {
                    // 修改订单状态
                    $res1 = $orderModel->update(["status"=>1,"updatetime"=>$time],["order_no"=>$out_trade_no, 'status' => 0]);
                    // 充值后
                    switch($orderInfo['purpose']) {
                        case 1:
                            // 修改用户为已缴纳认证费
                            $userInfo->recharge_auth = 1;
                            $res2 = $userInfo->save();
                            $res3 = true;
                            break;
                        case 2:
                            // 添加有眼缘记录--单次付费
                            $data = [];
                            $data['user_id'] = $userInfo->id;
                            $data['fate_user_id'] = $orderInfo->fate_user_id;
                            if(!\app\common\model\UserFate::where($data)->find()) {
                                $data['createtime'] = $time;
                                $res2 = \app\common\model\UserFate::insert($data);
                            } else {
                                $res2 = true;
                            }

                            // 返利
                            $preuser_id = $userInfo->pre_user_id;
                            if($userInfo->vip_duetime < $time) {
                                $memo = '用户充值获得收益！';
                                $profit = $payamount * config('site.userProfitRate') * 0.01;
                            } else {
                                $memo = '会员充值获得收益！';
                                $profit = $payamount * config('site.vipProfitRate') * 0.01;
                            }
                            if($profit>=0.01 && $preuser_id > 0) {
                                $res3 = \app\common\model\User::profit($profit,$preuser_id,$memo);
                            } else {
                                $res3 = true;
                            }

                            break;
                        case 3:
                            // 获取vip配置信息
                            $vip_config_id = $orderInfo['vip_config_id'];
                            $vipConfigInfo = \app\admin\model\vip\Config::where(['id'=>$vip_config_id])->find();
                            // 计算vip到期时间
                            if($userInfo->vip_duetime < $time) {
                                $duetime = strtotime ( '+'.intval($vipConfigInfo['time']).' month' );
                            } else {
                                $duetime = strtotime ( '+'.intval($vipConfigInfo['time']).' month',$userInfo->vip_duetime);
                            }
                            // 修改用户为vip
                            if($userInfo->vip_duetime <= time()) {
                                $userInfo->view_count = $vipConfigInfo->give_times; // 今日剩余次数
                                $userInfo->view_date = date('Y-m-d'); // 次数最后更新日期
                            }
                            $userInfo->vip_duetime = $duetime;
                            $res2 = $userInfo->save();
                            // 添加查看次数
                            $data = [];
                            $data['user_id'] = $userInfo->id;
                            $data['end_date'] = date("Y-m-d",$duetime);
                            $data['times'] = $vipConfigInfo->give_times;
                            $data['createtime'] = time();
                            $res3 = \app\common\model\GiveFateLog::insert($data);
                            break;
                        case 4:
                            // 获取钻石配置信息
                            $vip_config_id = $orderInfo['vip_config_id'];
                            $vipConfigInfo = Db::name('diamond')->where(['id'=>$vip_config_id])->find();
                            //修改用户钻石余额
                            $diamond = $userInfo['diamond'] + $vipConfigInfo['number'];
                            $res2 = Db::name('user')->where(['id' => $userInfo['id'], 'diamond' => $userInfo['diamond']])->setField('diamond', $diamond);
                            // 添加钻石明细
                            $diamond_log = Db::name('user_diamond_log')->where(['user_id' => $userInfo['id']])->order('id', 'desc')->find();
                            if (!$diamond_log && $userInfo['diamond'] > 0) {
                                $res3 = false;
                                break;
                            }
                            if ($diamond_log && $diamond_log['after'] != $userInfo['diamond']) {
                                $res3 = false;
                                break;
                            }
                            $data = [];
                            $data['user_id'] = $userInfo['id'];
                            $data['diamond'] = $vipConfigInfo['number'];
                            $data['before'] = $userInfo['diamond'];
                            $data['after'] = $diamond;
                            $data['memo'] = '充值';
                            $data['createtime'] = time();

                            $res3 = Db::name('user_diamond_log')->insertGetId($data);
                            break;
                    }
                }


                if($res1 && $res2 !== false && $res3) {
                    Db::commit();
                } else {
                    Db::rollback();
                }
            }catch (ValidateException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (Exception $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }

            //你可以在此编写订单逻辑
        } catch (Exception $e) {
        }
        echo $pay->success();
    }

    //自动取消超时未支付的活动订单
    public function cancelorder() {
        set_time_limit(0);

        $where = array(
            'status' => 0,
            'createtime' => ['lt', time() - 1920], //32分钟之前
        );
        $active_order = Db::name('active_order');
        $list = $active_order->where($where)->limit(200)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }


        $active_people = Db::name('active_people');
        $active_people_modify = Db::name('active_people_modify');
        $active = Db::name('active');

        foreach ($list as &$v) {
            //开启事务
            Db::startTrans();
            //修改订单信息
            $rs = $active_order->where(['id' => $v['id'], 'status' => 0])->setField('status', 3);
            if (!$rs) {
                Db::rollback();
                continue;
            }
            //修改活动人员
            $rt = $active_people->where(['order_id' => $v['id'], 'status' => 0])->setField(['status' => 3, 'modifystatus' => 0]);
            if (!$rt) {
                Db::rollback();
                continue;
            }
            //修改活动人员修改记录
            $res = $active_people_modify->where(['order_id' => $v['id'], 'status' => 0])->setField('status', 2);
            if ($res === false) {
                Db::rollback();
                continue;
            }
            //减少活动已报名人数
            $active_info = $active->find($v['active_id']);
            $currentperson = $active_info['currentperson'] - $v['number'];
            $active_rs = $active->where(['id' => $v['active_id'], 'currentperson' => $active_info['currentperson']])->setField('currentperson', $currentperson);
            if (!$active_rs) {
                Db::rollback();
                continue;
            }

            Db::commit();
        }

        echo 'wan bi';
        die;
    }

    //消息推送 我报名参加活动的前一天会提前推送消息，时间 地点 及一些提醒
    public function sysmsg() {
        set_time_limit(0);

        $where = array(
            'starttime' => ['elt', time() + 86400], //活动开始前一天
            'msgstatus' => 0,
            'status' => ['neq', 3]
        );

        $active = Db::name('active');
        $list = $active->where($where)->limit(200)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $active_order = Db::name('active_order');
        $sys_msg = Db::name('sys_msg'); //系统消息

        $data['type'] = 1;
        $data['title'] = '活动通知';
        $data['createtime'] = time();
        foreach ($list as &$v) {
            //修改活动消息通知状态
            $active->where(['id' => $v['id']])->setField('msgstatus', 1);
            //发送通知
            $data['content'] = '您报名的' . $v['title'] . '活动即将开始，请规划好您的时间。活动集合时间：' . date('Y-m-d H:i', $v['collectiontime']) . '，活动集合地点：' . $v['collectionplace'];
            //查询报名用户id
            $user_ids = $active_order->where(['active_id' => $v['id'], 'status' => 1])->column('user_id');
            if ($user_ids) {
                foreach ($user_ids as &$va) {
                    $data['user_id'] = $va;
                    $sys_msg->insertGetId($data);
                }
            }
        }

        echo 'wan bi';
        die;
    }

    //每年1月1重置免费次数
    public function resetfreenumber() {
        set_time_limit(0);
        //每年开始时间
        $time = strtotime(date('Y-1-1 0:0:0', time()));

        $where = array(
            'freenumbertime' => ['lt', $time]
        );

        $user = Db::name('user');
        $list = $user->where($where)->limit(200)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $vip = Db::name('vip');
        foreach ($list as &$v) {
            $free = $vip->find($v['growthlevel']);
            $user->where(['id' => $v['id'], 'freenumber' => $v['freenumber']])->setField(['freenumber' => $free['free'], 'freenumbertime' => time()]);
        }

        echo 'wan bi';
        die;
    }
    
    //自动结束已完成订单
    public function finishorder() {
        set_time_limit(0);

        $where = array(
            'status' => 1,
            'endtime' => ['lt', time()]
        );

        $active = Db::name('active');
        $list = $active->where($where)->limit(100)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $active_order = Db::name('active_order');
        $active_people = Db::name('active_people');
        $active_people_modify = Db::name('active_people_modify');
        $active_refund = Db::name('active_refund');

        foreach ($list as &$v) {
            //开启事务
            Db::startTrans();
            //活动结束
            $active_rs = $active->where(['id' => $v['id'], 'status' => 1])->setField(['status' => 2, 'updatetime' => time()]);
            if (!$active_rs) {
                Db::rollback();
                continue;
            }
            //修改活动订单状态
            $order_rs = $active_order->where(['active_id' => $v['id'], 'status' => 1])->setField(['status' => 2, 'updatetime' => time()]);
            if ($order_rs === false) {
                Db::rollback();
                continue;
            }
            //修改活动人员状态
            $people_rs = $active_people->where(['active_id' => $v['id'], 'status' => 1])->setField(['status' => 2, 'modifystatus' => 0, 'updatetime' => time()]);
            if ($people_rs === false) {
                Db::rollback();
                continue;
            }
            //修改活动人员信息修改表
            $people_modify_rs = $active_people_modify->where(['active_id' => $v['id'], 'status' => 0])->setField(['status' => 2, 'updatetime' => time()]);
            if ($people_modify_rs === false) {
                Db::rollback();
                continue;
            }
            //修改活动申请取消表
            $refund_rs = $active_refund->where(['active_id' => $v['id'], 'status' => 0])->setField(['status' => 2, 'updatetime' => time()]);
            if ($refund_rs === false) {
                Db::rollback();
                continue;
            }

            Db::commit();
        }

        echo 'wan bi';
        die;
    }
    
    //自动取消未成行订单
    public function cancelminpeopleorder() {
        set_time_limit(0);

        $where = array(
            'status' => 0,
            'signupendtime' => ['lt', time()]
        );

        $active = Db::name('active');
        $list = $active->where($where)->limit(100)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $active_order = Db::name('active_order');
        $active_people = Db::name('active_people');
        $active_people_modify = Db::name('active_people_modify');
        $active_refund = Db::name('active_refund');
        $user_coupon = Db::name('user_coupon'); //用户优惠券表
        $sys_msg = Db::name('sys_msg'); //消息通知

        foreach ($list as &$v) {
            //开启事务
            Db::startTrans();
            //活动结束
            $active_rs = $active->where(['id' => $v['id'], 'status' => 0])->setField(['status' => 3, 'updatetime' => time()]);
            if (!$active_rs) {
                Db::rollback();
                continue;
            }
            //修改活动人员状态
            $people_rs = $active_people->where(['active_id' => $v['id'], 'status' => 1])->setField(['status' => 3, 'modifystatus' => 0, 'updatetime' => time()]);
            if ($people_rs === false) {
                Db::rollback();
                continue;
            }
            //修改活动人员信息修改表
            $people_modify_rs = $active_people_modify->where(['active_id' => $v['id'], 'status' => 0])->setField(['status' => 2, 'updatetime' => time()]);
            if ($people_modify_rs === false) {
                Db::rollback();
                continue;
            }
            //修改活动申请取消表
            $refund_rs = $active_refund->where(['active_id' => $v['id'], 'status' => 0])->setField(['status' => 2, 'updatetime' => time()]);
            if ($refund_rs === false) {
                Db::rollback();
                continue;
            }
            //查询活动订单
            $active_order_list = $active_order->where(['active_id' => $v['id'], 'status' => 1])->select();
            if ($active_order_list) {
                //活动订单修改信息
                $order_data['status'] = 3; //状态:0=待付款,1=待出行,2=已完成,3=已取消
                $order_data['updatetime'] = time();

                foreach ($active_order_list as &$vv) {
                    //退还支付金额
                    if ($vv['price'] > 0) {
                        $order_data['refundstatus'] = 1; //退款状态:0=无需退款,1=退款成功,2=退款失败
                        $order_data['refundprice'] = $vv['price'];//退款金额
                        $order_data['refundtime'] = time();

                        if ($vv['paytype'] == 0) {
                            //余额支付, 退回余额
                            $rs = create_log($vv['price'], '活动取消返还', $vv['user_id'], 3, $vv['id']);
                            if ($rs != 1) {
                                $order_data['refundstatus'] = 2;
                            }
                        } elseif ($vv['paytype'] == 1) {
                            //微信支付, 退回微信
                            //扣除用户成长值
                            $paygrowth = (int)config('site.paygrowth'); //每消费1元赠送成长值数量, 1元=?成长值
                            $balance = floor($paygrowth * $vv['price']);
                            if ($balance > 0) {
                                $paygrowth_rs = create_growth_log(-$balance, '活动取消扣除', $vv['user_id'], 4, $vv['id']);
                            }
                            //退款单号
                            $order_data['refund_no'] = $vv['order_sn'];
                            //调用微信退款
                            $wxData['transaction_id'] = $vv['transaction_id'];
                            $wxData['out_refund_no'] = $order_data['refund_no'];
                            $wxData['total_fee'] = (int)($vv['price'] * 100);//1 微信支付 单位为分
                            $wxData['refund_fee'] = (int)($vv['price'] * 100);//1 微信支付 单位为分
                            $wxData['refund_desc'] = '活动取消返还';
//                                            require_once("Plugins/WxPay/WxPay.php");
                            $wxPay = new wxpay\WxPay(config('wxchatpay'));
                            $back = $wxPay->WxPayRefund($wxData);
                            if($back['return_code'] != 'SUCCESS' || $back['result_code'] != 'SUCCESS') {
                                $order_data['refundstatus'] = 2;
                            }
                        }
                    }
                    //修改活动订单状态
                    $order_rs = $active_order->where(['id' => $vv['id'], 'status' => 1])->setField($order_data);
                    if ($order_rs === false) {
                        Db::rollback();
                        continue;
                    }
                    //上级优惠券设为过期
                    $user_coupon->where(['active_id' => $vv['id'], 'status' => 0])->setField('endtime', time() - 1);
                    //发送消息
                    $data = [
                        'user_id' => $vv['user_id'],
                        'type' => 1,
                        'title' => '活动通知',
                        'content' => '您报名的' . $v['title'] . '活动已取消',
                        'createtime' => time()
                    ];
                    $sys_msg->insertGetId($data);
                }
            }

            Db::commit();
        }

        echo 'wan bi';
        die;
    }

    //自动上架活动
    public function showactive() {
        set_time_limit(0);

        $time = time();
        $where = array(
            'showstatus' => 0,
            'is_autoshow' => 1,
            'showtime' => ['elt', $time]
        );

        $active = Db::name('active');
        $list = $active->where($where)->limit(200)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        foreach ($list as &$v) {
            $active->where(['id' => $v['id'], 'showstatus' => 0])->setField(['showstatus' => 1]);
        }

        echo 'wan bi';
        die;
    }

    //视频转码
    public function transcode() {
        set_time_limit(0);

        $where = array(
            'transcode_status' => 0
        );

        $hu_video = Db::name('video');
        $list = $hu_video->where($where)->limit(50)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $url = 'http://api.trans.gitv.tv/upload';
        $data['cp_id'] = config('cp_id');
        $data['media_type'] = 'mp4';
        foreach ($list as &$v) {
            $data['uri'] = urlencode(config('upload.cdnurl') . $v['videofile']);
            $data['file_name'] = urlencode($v['title']);

            $request_url = $url . '?' . http_build_query($data);
            $rs = file_get_contents($request_url);
            if (!$rs) {
                continue;
            }
            $rs = json_decode($rs);
            if ($rs['code'] == 'A000000') {
                $hu_video->where(['id' => $v['id'], 'transcode_status' => 0])->setField(['transcode_status' => 1, 'task_id' => $rs['task_id']]);
            }
        }

        echo 'wan bi';
        die;
    }

    //视频转码回执
    public function transcodecallback() {
        $cp_id = input('cp_id', 0, 'intval');
        $file_url = input('file_url', '', 'trim');
        $task_id = input('task_id', '', 'trim');

        if ($cp_id != config('cp_id')) {
            $this->error('错误1');
        }
        $info = Db::name('video')->where(['task_id' => $task_id])->find();
        if (!$info) {
            $this->error('错误2');
        }
        if ($info['transcode_status'] != 1) {
            $this->success('已完成');
        }

        $file_url = urldecode($file_url);
        $rs = Db::name('video')->where(['id' => $info['id'], 'transcode_status' => 1])->setField(['transcode_status' => 2, 'file_url' => $file_url]);
        if (!$rs) {
            $this->error('失败');
        }

        $this->success('成功');
    }

    //视频注入
    public function inject() {
        set_time_limit(0);

        $where = array(
            'transcode_status' => 2,
            'inject_status' => 0
        );

        $hu_video = Db::name('video');
        $list = $hu_video->where($where)->limit(50)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $url = 'http://api.gs.gitv.tv/upload';
        $data['cp_id'] = config('cp_id');
        $data['bit_id'] = 5;
        $data['file_type'] = 'm3u8';
        foreach ($list as &$v) {
            $data['album_id'] = (string)$v['id'];
            $data['video_id'] = (string)$v['id'];
            $data['uri'] = $v['file_url'];

            $rs = httpRequest($url, 'POST', $data);
            if (!$rs) {
                continue;
            }
            $rs = json_decode($rs);
            if ($rs['code'] == 'A000000') {
                $hu_video->where(['id' => $v['id'], 'inject_status' => 0])->setField(['inject_status' => 1]);
            }
        }

        echo 'wan bi';
        die;
    }

    //视频注入回执
    public function injectcallback() {
        $cp_id = input('cp_id', 0, 'intval');
        $album_id = input('album_id', '', 'trim'); //专辑 ID
        $video_id = input('video_id', '', 'trim'); //剧集 ID
        $code = input('code', '', 'trim'); //状态码

        if ($cp_id != config('cp_id')) {
            $this->error('错误1');
        }
        $info = Db::name('video')->where(['id' => $video_id])->find();
        if (!$info) {
            $this->error('错误2');
        }
        if ($info['inject_status'] != 1) {
            $this->success('已完成');
        }

        if ($code == 'A000000') {
            $inject_status = 2;
        } else {
            $inject_status = 3;
        }

        $rs = Db::name('video')->where(['id' => $info['id'], 'inject_status' => 1])->setField(['inject_status' => $inject_status]);
        if (!$rs) {
            $this->error('失败');
        }

        $this->success('成功');
    }

    //视频注入结果查询
    public function injectquery() {
        set_time_limit(0);

        $time = strtotime(date('Y-m-d', time()));
        $where = array(
            'inject_status' => 1,
//            'updatetime' => ['egt', $time]
        );

        $hu_video = Db::name('video');
//        $list = $hu_video->where($where)->count('id');
        $list = $hu_video->where($where)->limit(50)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        /*$starttime = date('Ymd000000', time());
        $endtime = date('Ymd235959', time());
//        $url = 'http://'.config('inject_ip').':'.config('inject_port').'/injectResult/v1/queryAdd?cspId=' . config('cspid') . '&startTime='.$starttime.'&endTime='.$endtime;
        $url = 'http://jscp.agency.gitv.tv/injectResult/v1/queryAdd?cspId=' . config('cspid') . '&startTime='.$starttime.'&endTime='.$endtime;
        $header = [
            'Content-Type: application/json'
        ];
        $rs = httpRequest($url, 'POST', [], $header);
        if (!$rs) {
            echo 'cuo wu1';
            die;
        }

        $list = json_decode($rs, true);
        if ($list['code'] != 'A000000') {
            echo 'cuo wu2';
            die;
        }
        foreach ($list['data'] as &$v) {
            if ($v['taskStatus'] == 2) {
                $hu_video->where(['id' => $v['cpTvId'], 'inject_status' => 1])->setField(['inject_status' => 2]);
            }
        }*/

        $header = [
            'Content-Type: application/json'
        ];

        //生成ftp文件
        $content = [
            'cpPrvdName' => '健康e家',
            'cpPrvCode' => '41000144',
            'cpPrvType' => '1006',
            'ChnName' => '健康',
            'ChnCode' => '1000020',
            'actors' => '无',
            'directors' => '无',
            'contentYear' => date('Y'),
            'tags' => '',
            'contentTime' => date('Y-m-d H:i:s'),
            'formatType' => '超清'
        ];
        //增量接口
        $insert_url = 'http://test.meta.unso.gitv.tv/sendMeta';
        $method = 'POST';

        foreach ($list as &$v) {
            //查询华为注入结果
            $url = 'http://jscp.agency.gitv.tv/injectResult/v1/queryTv?cspId=' . config('cspid') . '&cpAlbumId=' . $v['id'] . '&cpTvId=' .  $v['id'];
            $rs = httpRequest($url, 'GET', [], $header);
            if (!$rs) {
                continue;
            }
            $rs = json_decode($rs, true);
            if ($rs['code'] != 'A000000') {
                continue;
            }
            $data = $rs['data'][0];
            if ($data['taskStatus'] == 2) {
                /*//生成ftp文件
                $content['contentId'] = $v['movieid'];
                $content['extraContentID'] = $v['movieid'];
                $content['content'] = $v['title'];
                $content['intent'] = [
                    'action' => 'com.huxiu.heh.tv.ui.splash.SplashActivity',
                    'package' => 'com.huxiu.heh.tv',
                    'component' => [
                        'pkg' => 'com.huxiu.heh.tv',
                        'cls' => 'com.huxiu.heh.tv.ui.splash.SplashActivity'
                    ],
                    'extras' => [
//                        'cmd' => '',
//                        'from' => '',
//                        'media_id' => ''
                        'type_id' => $v['video_type_id'],
                        'id' => $v['id']
                    ]
                ];
                $content['isEffective'] = $v['status'];
                $content['pic'] = one_domain_image($v['image']);
                $content['isPaid'] = $v['is_pay'];

                $content = json_encode($content, 320);
                $filename = 'shipin_'.date('Ymd').'_'.date('His').'_increment'.'.json';
                error_log(print_r($content, 1) . PHP_EOL, 3, './jiankang/' . $filename);
                //调用增量注入接口

                $postfields = [
                    'priKey' => config('cspid'),
                    'data' => [$content]
                ];
                $rt = httpRequest($insert_url, $method, $postfields, $header);
                if (!$rt) {
                    continue;
                }
                $rt = json_decode($rt, true);
                if ($rt['code'] != 'A000000') {
                    continue;
                }*/

                //查询中兴注入结果
                $url2 = 'http://jscp.agency.gitv.tv/injectResult/v1/queryTv?cspId=' . config('cspid_zx') . '&cpAlbumId=' . $v['id'] . '&cpTvId=' .  $v['id'];
                $rs2 = httpRequest($url2, 'GET', [], $header);
                if (!$rs2) {
                    continue;
                }
                $rs2 = json_decode($rs2, true);
                if ($rs2['code'] != 'A000000') {
                    continue;
                }
                $data2 = $rs2['data'][0];
                if ($data2['taskStatus'] == 2) {
                    $hu_video->where(['id' => $v['id'], 'inject_status' => 1])->setField(['inject_status' => 2, 'seriesid' => $data['seriesId'], 'programid' => $data['programId'], 'movieid' => $data['movieId']]);
                } elseif ($data2['taskStatus'] == -1 || $data2['taskStatus'] == -3 || $data2['taskStatus'] == -4) {
                    $hu_video->where(['id' => $v['id'], 'inject_status' => 1])->setField(['inject_status' => 3, 'seriesid' => $data['seriesId'], 'programid' => $data['programId'], 'movieid' => $data['movieId']]);
                }
            } elseif ($data['taskStatus'] == -1 || $data['taskStatus'] == -3 || $data['taskStatus'] == -4) {
                $hu_video->where(['id' => $v['id'], 'inject_status' => 1])->setField(['inject_status' => 3, 'seriesid' => $data['seriesId'], 'programid' => $data['programId'], 'movieid' => $data['movieId']]);
            }
        }

        echo 'wan bi';
        die;
    }

    //视频统一搜索生成ftp文件
    public function videosearch() {
        set_time_limit(0);

//        $time = strtotime(date('Y-m-d', time()));
        $where = array(
            'inject_status' => 2,
            'search_status' => 0,
//            'updatetime' => ['egt', $time]
        );

        $hu_video = Db::name('video');
        $list = $hu_video->where($where)->limit(50)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $header = [
            'Content-Type: application/json'
        ];

        //生成ftp文件
        $data_content = [
            'cpPrvdName' => '健康e家',
            'cpPrvCode' => '41000144',
            'cpPrvType' => '1006',
            'ChnName' => '健康',
            'ChnCode' => '1000020',
            'actors' => '无',
            'directors' => '无',
            'contentYear' => date('Y'),
            'tags' => '',
            'contentTime' => date('Y-m-d H:i:s'),
            'formatType' => '超清'
        ];
        //增量接口
        $insert_url = 'http://test.meta.unso.gitv.tv/sendMeta';
        $method = 'POST';

        foreach ($list as &$v) {
            //生成ftp文件
            $content = $data_content;
            $content['contentId'] = $v['movieid'];
            $content['extraContentID'] = $v['movieid'];
            $content['content'] = $v['title'];
            $intent = json_encode([
                'action' => 'com.huxiu.heh.tv.ui.splash.SplashActivity',
                'package' => 'com.huxiu.heh.tv',
                'component' => [
                    'pkg' => 'com.huxiu.heh.tv',
                    'cls' => 'com.huxiu.heh.tv.ui.splash.SplashActivity'
                ],
                'extras' => [
//                        'cmd' => '',
//                        'from' => '',
//                        'media_id' => ''
                    'type_id' => $v['video_type_id'],
                    'id' => $v['id']
                ]
            ], 320);
            $content['intent'] = "$intent";
            $content['isEffective'] = $v['status'];
            $content['pic'] = one_domain_image($v['image']);
            $content['isPaid'] = $v['is_pay'];

            $content = json_encode($content, 320);
            $filename = 'shipin_'.date('Ymd').'_'.date('His').'_increment'.'.json';
            error_log(print_r($content, 1) . PHP_EOL, 3, './jiankang/' . $filename);
            //调用增量注入接口

            /*$postfields = [
                'priKey' => config('cspid'),
                'data' => [$content]
            ];
            $rt = httpRequest($insert_url, $method, $postfields, $header);
            if (!$rt) {
                continue;
            }
            $rt = json_decode($rt, true);
            if ($rt['code'] != 'A000000') {
                continue;
            }*/
            $hu_video->where(['id' => $v['id'], 'search_status' => 0])->setField(['search_status' => 1]);
        }

        echo 'wan bi';
        die;
    }
    
    //订购关系同步地址
    public function ordersync() {
        $data = file_get_contents('php://input');
        file_put_contents('chen_tui.txt', $data, FILE_APPEND);
        if (!$data) {
            $this->error('参数缺失');
        }

        $jsonxml = json_encode(simplexml_load_string($data, 'SimpleXMLElement', LIBXML_NOCDATA));
        $data = json_decode($jsonxml, true);
        if (!$data) {
            $this->error('参数缺失');
        }
        $phoneNumber = $data['orderRelationSyncRequest']['phoneNumber']; //手机号
        $apppId = $data['orderRelationSyncRequest']['apppId']; //订购的HDC业务产品编码

        if ($apppId != config('product_code')) {
            echo 'meiyou';
            exit;
        }

        //用户增值产品包当前订购快照
        $content = [
            'UserID' => $phoneNumber,
            'prod_code' => $apppId,
            'prod_name' => '月包会员',
            'eff_time' => date('Y-m-d H:i:s', time()),
            'exp_time' => date('Y-m-d H:i:s', time() + 30 * 86400),
            'price' => 2900
        ];

        $content = join(json_decode('"\u0001"', true), $content);
        $filename = date('Ymd').'_'.config('data_cp_id').'_userefforderdata_1.dat';
        $check_filename = date('Ymd').'_'.config('data_cp_id').'_userefforderdata_1.chk';

        error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
        error_log('', 3, './dashuju/' . $check_filename);
        $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_userefforderdata.finish';
        error_log('', 3, './dashuju/' . $finish_filename);

        //用户增值产品包订购行为数据
        $user_id = Db::name('user')->where(['mobile' => $phoneNumber])->value('id');
        $order_info = Db::name('rechar_order')->where(['user_id' => $user_id, 'purpose' => 3, 'pay_type' => 'zhuowang', 'status' => 1])->order('id desc')->find();

        $content = [
            'orderid' => $order_info['order_no'],
            'order_time' => date('Y-m-d H:i:s', time()),
            'order_type' => 1,
            'UserID' => $phoneNumber,
            'prod_code' => $apppId,
            'prod_name' => '月包会员',
            'eff_time' => date('Y-m-d H:i:s', time()),
            'exp_time' => date('Y-m-d H:i:s', time() + 30 * 86400),
            'csource' => 99,
            'trace_id' => '',
            'price' => 2900,
            'paytype' => 0,
            'cpid' => config('data_cp_id'),
            'albumid' => '',
            'albumname' => ''
        ];

        $content = join(json_decode('"\u0001"', true), $content);
        $filename = date('Ymd').'_'.config('data_cp_id').'_userorderdata_1.dat';
        $check_filename = date('Ymd').'_'.config('data_cp_id').'_userorderdata_1.chk';

        error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
        error_log('', 3, './dashuju/' . $check_filename);
        $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_userorderdata.finish';
        error_log('', 3, './dashuju/' . $finish_filename);
    }

    //(补漏)视频注入中兴
    public function injectzx() {
        set_time_limit(0);

        $hu_video = Db::name('video');
        $list = $hu_video->where(['id' => 107])->limit(50)->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $cspid = config('cspid_zx');
        $url = 'http://jscp.agency.gitv.tv/epgDataSync/v1/' . $cspid . '/';

        foreach ($list as &$params) {
            //内容同步
            $videofile = $params['videofile'];
            $videofile = explode('/', $videofile);
            $video_url = $videofile[3];
            $data = [
//                        'cspId' => $cspid,
                'cpAlbumId' => $params['id'],
                'albumName' => $params['title'],
                'tvSets' => 1,
                'updateToSet' => 1,
                'isPurchase' => $params['is_pay'],
                'isEffective' => $params['status'],
                'isOnline' => $params['status'],
                'albumTypes' => '健康',
                'picBox' => config('upload.cdnurl') . $params['image'],
                'albumUpdateTime' => date('YmdHis', time()),
                'albumCreateTime' => date('YmdHis', time()),
                'tvlist' => [
                    [
                        'cpAlbumId' => $params['id'],
                        'cpTvId' => $params['id'],
                        'tvName' => $params['title'],
                        'tvIsEffective' => $params['status'],
                        'tvIsOnline' => $params['status'],
                        'isPurchase' => $params['is_pay'],
                        'playOrder' => 1,
                        'tvUrl' => 'ftp://'.config('ftp_user').':'.config('ftp_pwd').'@'.config('ftp_ip').':'.config('ftp_port').'/inject/'.$video_url
                    ]
                ]
            ];

            $data = json_encode($data, 320);
            $header = [
                'Content-Type: application/json'
            ];
            $rs = httpRequest($url, 'POST', $data, $header);
            if ($rs) {
                $rs = json_decode($rs, true);
                if ($rs['code'] != 'A000000') {
                    continue;
                }
            }
        }

        echo 'wan bi';
        die;
    }

    //(补漏)删除注入中兴视频
    public function delinjectzx() {
        set_time_limit(0);

        $hu_video = Db::name('video');
        $list = $hu_video->where(['id' => 107])->limit(1)->order('id')->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        $cspid = config('cspid_zx');
        $url = 'http://jscp.agency.gitv.tv/epgDeleteSync/v1/' . $cspid . '/';

        foreach ($list as &$params) {
            //内容同步
            $videofile = $params['videofile'];
            $videofile = explode('/', $videofile);
            $video_url = $videofile[3];

            $data = [
//            'cspId' => $cspid,
                'cpAlbumId' => $params['id'],
                'albumName' => $params['title'],
                'tvSets' => 1,
                'updateToSet' => 1,
                'isPurchase' => $params['is_pay'],
                'isEffective' => 0,
                'isOnline' => 2,
                'albumTypes' => '健康',
                'picBox' => config('upload.cdnurl') . $params['image'],
                'albumUpdateTime' => date('YmdHis', time()),
//                'albumCreateTime' => date('YmdHis', time()),
                'tvlist' => [
                    [
                        'cpAlbumId' => $params['id'],
                        'cpTvId' => $params['id'],
                        'tvName' => $params['title'],
                        'tvIsEffective' => 0,
                        'tvIsOnline' => 2,
                        'isPurchase' => $params['is_pay'],
                        'playOrder' => 1,
                        'tvUrl' => 'ftp://'.config('ftp_user').':'.config('ftp_pwd').'@'.config('ftp_ip').':'.config('ftp_port').'/inject/'.$video_url
                    ]
                ]
            ];
            $data = json_encode($data, 320);
            $header = [
                'Content-Type: application/json'
            ];
            $rs = httpRequest($url, 'POST', $data, $header);
            if ($rs) {
                $rs = json_decode($rs, true);
                if ($rs['code'] != 'A000000') {
                    continue;
                }
            }
        }

        echo 'wan bi';
        die;
    }

    //媒资数据专辑粒度
    public function mediadataalbum() {
        $hu_video = Db::name('video');
        $list = $hu_video->where(['inject_status' => 2, 'mediaalbum_status' => 0])->order('id')->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        foreach ($list as $key => &$param) {
            $content = [
                'Updatetype' => 1,
                'cpid' =>  config('data_cp_id'),
                'channelid' => '1000035',
                'albumid' => $param['id'],
                'albumname' => $param['title'],
                'albumnum' => 1,
                'tag' => '',
                'onlinetime' => '',
                'bref' => '',
                'onebref' => '',
                'cornersign' => $param['is_pay'],
                'director' => '',
                'actor' => '',
                'year' => '',
                'area' => '',
                'language' => '',
                'score' => '',
                'picurl' => config('upload.cdnurl') . $param['image'],
                'picurl_v' => '',
                'gotourl' => json_encode([
                    'action' => 'com.huxiu.heh.tv.ui.splash.SplashActivity',
                    'package' => 'com.huxiu.heh.tv',
                    'component' => [
                        'pkg' => 'com.huxiu.heh.tv',
                        'cls' => 'com.huxiu.heh.tv.ui.splash.SplashActivity'
                    ],
                    'extras' => [
//                        'cmd' => '',
//                        'from' => '',
//                        'media_id' => ''
                        'type_id' => $param['video_type_id'],
                        'id' => $param['id']
                    ]
                ], 320),
                'is_politics' => '',
                'second_type' => ''
            ];

            $content = join(json_decode('"\u0001"', true), $content);
            $filename = date('Ymd').'_'.config('data_cp_id').'_albumsdata_1.dat';
            $check_filename = date('Ymd').'_'.config('data_cp_id').'_albumsdata_1.chk';

            error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
            error_log('', 3, './dashuju/' . $check_filename);

            if ($key == count($list) - 1) {
                $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_albumsdata.finish';
                error_log('', 3, './dashuju/' . $finish_filename);
            }

            $hu_video->where(['id' => $param['id'], 'mediaalbum_status' => 0])->setField('mediaalbum_status', 1);
        }

        echo 'wan bi';
    }

    //媒资数据节目/内容粒度
    public function mediadatavideo() {
        $hu_video = Db::name('video');
        $list = $hu_video->where(['inject_status' => 2, 'mediavideo_status' => 0])->order('id')->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        foreach ($list as $key => &$param) {
            $content = [
                'Updatetype' => 1,
                'cpid' =>  config('data_cp_id'),
                'channelid' => '1000035',
                'albumid' => $param['id'],
                'albumname' => $param['title'],
                'videoid' => $param['id'],
                'videoname' => $param['title'],
                'videonum' => 1,
                'Contenttype' => 1,
                'duration' => '',
                'quality' => ''
            ];

            $content = join(json_decode('"\u0001"', true), $content);
            $filename = date('Ymd').'_'.config('data_cp_id').'_videosdata_1.dat';
            $check_filename = date('Ymd').'_'.config('data_cp_id').'_videosdata_1.chk';

            error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
            error_log('', 3, './dashuju/' . $check_filename);

            if ($key == count($list) - 1) {
                $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_videosdata.finish';
                error_log('', 3, './dashuju/' . $finish_filename);
            }

            $hu_video->where(['id' => $param['id'], 'mediavideo_status' => 0])->setField('mediavideo_status', 1);
        }
    }

    //产品包
    public function product() {
        $content = [
            'prod_code' => config('product_code'),
            'prod_name' => '月包会员',
            'prod_type' => 0,
            'cpid' => config('data_cp_id')
        ];

        $content = join(json_decode('"\u0001"', true), $content);
        $filename = date('Ymd').'_'.config('data_cp_id').'_productsdata_1.dat';
        $check_filename = date('Ymd').'_'.config('data_cp_id').'_productsdata_1.chk';

        error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
        error_log('', 3, './dashuju/' . $check_filename);
        $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_productsdata.finish';
        error_log('', 3, './dashuju/' . $finish_filename);

        //连接ftp
        $host = config('data_ftp_ip');
        $port = config('data_ftp_port');
        $username = config('data_ftp_user');
        $password = config('data_ftp_pwd');
        $conn = ftp_connect($host, $port) or die("Could not connect");
        //登录
        ftp_login($conn,$username,$password);
        //开启被动模式
        ftp_pasv($conn, true);
        //利用ftp创建目录
        /*$path = "home/2021-12-08";
        $this->make_directory($conn,$path);
        //利用ftp选择进入目录
        ftp_chdir($conn,$path);*/
        //开始上传  ftp_put(ftp链接,服务器地址,本地地址,上传模式);
        if(ftp_put($conn,$filename,'./dashuju/' . $filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$check_filename,'./dashuju/' . $check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$finish_filename,'./dashuju/' . $finish_filename,FTP_BINARY)){
            //上传成功
        }
        ftp_close($conn);
        //注意上传端的ftp权限设置

        echo 'wanbi';
    }

    //产品包和媒资所属关系
    public function productmediarelation() {
        $hu_video = Db::name('video');
        $list = $hu_video->where(['inject_status' => 2, 'productmedia_status' => 0])->order('id')->select();

        if (!$list) {
            echo 'mei shu ju';
            die;
        }

        foreach ($list as $key => &$param) {
            $content = [
                'Updatetype' => 1,
                'prod_code' => config('product_code'),
                'cpid' =>  config('data_cp_id'),
                'albumid' => $param['id']
            ];

            $content = join(json_decode('"\u0001"', true), $content);
            $filename = date('Ymd').'_'.config('data_cp_id').'_productalbumdata_1.dat';
            $check_filename = date('Ymd').'_'.config('data_cp_id').'_productalbumdata_1.chk';

            error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
            error_log('', 3, './dashuju/' . $check_filename);

            if ($key == count($list) - 1) {
                $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_productalbumdata.finish';
                error_log('', 3, './dashuju/' . $finish_filename);
            }

            $hu_video->where(['id' => $param['id'], 'productmedia_status' => 0])->setField('productmedia_status', 1);
        }
    }

    //用户观看行为数据文件上传到卓望ftp(每小时第10分钟提供)
    public function uploadpayftp() {
        set_time_limit(0);
        $host = config('pay_ftp_ip');
        $port = config('pay_ftp_port');
        $username = config('pay_ftp_user');
        $password = config('pay_ftp_pwd');

        $filename = date('YmdH', time() - 3600).'_'.config('cp_id').'_userviewdata_1.dat';
        $check_filename = date('YmdH', time() - 3600).'_'.config('cp_id').'_userviewdata_1.chk';

        //判断文件是否存在, 不存在则创建
        if (!file_exists('./dashuju/' . $filename)) {
            @touch('./dashuju/' . $filename);
        }
        if (!file_exists('./dashuju/' . $check_filename)) {
            @touch('./dashuju/' . $check_filename);
        }

        //连接ftp
        $conn = ftp_connect($host, $port) or die("Could not connect");
        //登录
        ftp_login($conn,$username,$password);
        //开启被动模式
        ftp_pasv($conn, true);
        //利用ftp创建目录
        /*$path = "home/2021-12-08";
        $this->make_directory($conn,$path);
        //利用ftp选择进入目录
        ftp_chdir($conn,$path);*/
        //开始上传  ftp_put(ftp链接,服务器地址,本地地址,上传模式);
        if(ftp_put($conn,$filename,'./dashuju/' . $filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$check_filename,'./dashuju/' . $check_filename,FTP_BINARY)){
            //上传成功
        }
        ftp_close($conn);
        //注意上传端的ftp权限设置

        echo 'wanbi';
    }

    //大数据文件上传到大数据ftp(每天一点提供)
    public function uploaddataftp() {
        set_time_limit(0);
        $host = config('data_ftp_ip');
        $port = config('data_ftp_port');
        $username = config('data_ftp_user');
        $password = config('data_ftp_pwd');

        $time = date('Ymd', time() - 86400);

        // 专辑粒度媒资
        $albumsdata_filename = $time.'_'.config('data_cp_id').'_albumsdata_1.dat';
        $albumsdata_check_filename = $time.'_'.config('data_cp_id').'_albumsdata_1.chk';
        $albumsdata_finish_filename = $time.'_'.config('data_cp_id').'_albumsdata_1.finish';
        // 节目/内容粒度媒资
        $videosdata_filename = $time.'_'.config('data_cp_id').'_videosdata_1.dat';
        $videosdata_check_filename = $time.'_'.config('data_cp_id').'_videosdata_1.chk';
        $videosdata_finish_filename = $time.'_'.config('data_cp_id').'_videosdata_1.finish';
        //  产品包和媒资所属关系
        $productalbumdata_filename = $time.'_'.config('data_cp_id').'_productalbumdata_1.dat';
        $productalbumdata_check_filename = $time.'_'.config('data_cp_id').'_productalbumdata_1.chk';
        $productalbumdata_finish_filename = $time.'_'.config('data_cp_id').'_productalbumdata_1.finish';
        //  用户增值产品包当前订购快照
        $userefforderdata_filename = $time.'_'.config('data_cp_id').'_userefforderdata_1.dat';
        $userefforderdata_check_filename = $time.'_'.config('data_cp_id').'_userefforderdata_1.chk';
        $userefforderdata_finish_filename = $time.'_'.config('data_cp_id').'_userefforderdata_1.finish';
        //  用户增值产品包订购行为
        $userorderdata_filename = $time.'_'.config('data_cp_id').'_userorderdata_1.dat';
        $userorderdata_check_filename = $time.'_'.config('data_cp_id').'_userorderdata_1.chk';
        $userorderdata_finish_filename = $time.'_'.config('data_cp_id').'_userorderdata_1.finish';
        //  用户观看行为
        $userplaydata_filename = $time.'_'.config('data_cp_id').'_userplaydata_1.dat';
        $userplaydata_check_filename = $time.'_'.config('data_cp_id').'_userplaydata_1.chk';
        $userplaydata_finish_filename = $time.'_'.config('data_cp_id').'_userplaydata_1.finish';
        //  用户收藏行为
        $userfavdata_filename = $time.'_'.config('data_cp_id').'_userfavdata_1.dat';
        $userfavdata_check_filename = $time.'_'.config('data_cp_id').'_userfavdata_1.chk';
        $userfavdata_finish_filename = $time.'_'.config('data_cp_id').'_userfavdata_1.finish';

        //判断文件是否存在, 不存在则创建
        if (!file_exists('./dashuju/' . $albumsdata_filename)) {
            @touch('./dashuju/' . $albumsdata_filename);
        }
        if (!file_exists('./dashuju/' . $albumsdata_check_filename)) {
            @touch('./dashuju/' . $albumsdata_check_filename);
        }
        if (!file_exists('./dashuju/' . $albumsdata_finish_filename)) {
            @touch('./dashuju/' . $albumsdata_finish_filename);
        }
        if (!file_exists('./dashuju/' . $videosdata_filename)) {
            @touch('./dashuju/' . $videosdata_filename);
        }
        if (!file_exists('./dashuju/' . $videosdata_check_filename)) {
            @touch('./dashuju/' . $videosdata_check_filename);
        }
        if (!file_exists('./dashuju/' . $videosdata_finish_filename)) {
            @touch('./dashuju/' . $videosdata_finish_filename);
        }
        if (!file_exists('./dashuju/' . $productalbumdata_filename)) {
            @touch('./dashuju/' . $productalbumdata_filename);
        }
        if (!file_exists('./dashuju/' . $productalbumdata_check_filename)) {
            @touch('./dashuju/' . $productalbumdata_check_filename);
        }
        if (!file_exists('./dashuju/' . $productalbumdata_finish_filename)) {
            @touch('./dashuju/' . $productalbumdata_finish_filename);
        }
        if (!file_exists('./dashuju/' . $userefforderdata_filename)) {
            @touch('./dashuju/' . $userefforderdata_filename);
        }
        if (!file_exists('./dashuju/' . $userefforderdata_check_filename)) {
            @touch('./dashuju/' . $userefforderdata_check_filename);
        }
        if (!file_exists('./dashuju/' . $userefforderdata_finish_filename)) {
            @touch('./dashuju/' . $userefforderdata_finish_filename);
        }
        if (!file_exists('./dashuju/' . $userorderdata_filename)) {
            @touch('./dashuju/' . $userorderdata_filename);
        }
        if (!file_exists('./dashuju/' . $userorderdata_check_filename)) {
            @touch('./dashuju/' . $userorderdata_check_filename);
        }
        if (!file_exists('./dashuju/' . $userorderdata_finish_filename)) {
            @touch('./dashuju/' . $userorderdata_finish_filename);
        }
        if (!file_exists('./dashuju/' . $userplaydata_filename)) {
            @touch('./dashuju/' . $userplaydata_filename);
        }
        if (!file_exists('./dashuju/' . $userplaydata_check_filename)) {
            @touch('./dashuju/' . $userplaydata_check_filename);
        }
        if (!file_exists('./dashuju/' . $userplaydata_finish_filename)) {
            @touch('./dashuju/' . $userplaydata_finish_filename);
        }
        if (!file_exists('./dashuju/' . $userfavdata_filename)) {
            @touch('./dashuju/' . $userfavdata_filename);
        }
        if (!file_exists('./dashuju/' . $userfavdata_check_filename)) {
            @touch('./dashuju/' . $userfavdata_check_filename);
        }
        if (!file_exists('./dashuju/' . $userfavdata_finish_filename)) {
            @touch('./dashuju/' . $userfavdata_finish_filename);
        }

        //连接ftp
        $conn = ftp_connect($host, $port) or die("Could not connect");
        //登录
        ftp_login($conn,$username,$password);
        //开启被动模式
        ftp_pasv($conn, true);
        //利用ftp创建目录
        /*$path = "home/2021-12-08";
        $this->make_directory($conn,$path);
        //利用ftp选择进入目录
        ftp_chdir($conn,$path);*/
        //开始上传  ftp_put(ftp链接,服务器地址,本地地址,上传模式);
        if(ftp_put($conn,$albumsdata_filename,'./dashuju/' . $albumsdata_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$albumsdata_check_filename,'./dashuju/' . $albumsdata_check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$albumsdata_finish_filename,'./dashuju/' . $albumsdata_finish_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$videosdata_filename,'./dashuju/' . $videosdata_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$videosdata_check_filename,'./dashuju/' . $videosdata_check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$videosdata_finish_filename,'./dashuju/' . $videosdata_finish_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$productalbumdata_filename,'./dashuju/' . $productalbumdata_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$productalbumdata_check_filename,'./dashuju/' . $productalbumdata_check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$productalbumdata_finish_filename,'./dashuju/' . $productalbumdata_finish_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userefforderdata_filename,'./dashuju/' . $userefforderdata_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userefforderdata_check_filename,'./dashuju/' . $userefforderdata_check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userefforderdata_finish_filename,'./dashuju/' . $userefforderdata_finish_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userorderdata_filename,'./dashuju/' . $userorderdata_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userorderdata_check_filename,'./dashuju/' . $userorderdata_check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userorderdata_finish_filename,'./dashuju/' . $userorderdata_finish_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userplaydata_filename,'./dashuju/' . $userplaydata_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userplaydata_check_filename,'./dashuju/' . $userplaydata_check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userplaydata_finish_filename,'./dashuju/' . $userplaydata_finish_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userfavdata_filename,'./dashuju/' . $userfavdata_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userfavdata_check_filename,'./dashuju/' . $userfavdata_check_filename,FTP_BINARY)){
            //上传成功
        }
        if(ftp_put($conn,$userfavdata_finish_filename,'./dashuju/' . $userfavdata_finish_filename,FTP_BINARY)){
            //上传成功
        }

        ftp_close($conn);
        //注意上传端的ftp权限设置

        echo 'wanbi';
    }

    public function make_directory($ftp_stream, $dir){
        // if directory already exists or can be immediately created return true
        if ($this->ftp_is_dir($ftp_stream, $dir) || @ftp_mkdir($ftp_stream, $dir)) return true;
        // otherwise recursively try to make the directory
        if (!$this->make_directory($ftp_stream, dirname($dir))) return false;
        // final step to create the directory
        return ftp_mkdir($ftp_stream, $dir);
    }

    public function ftp_is_dir($ftp_stream, $dir){
        // get current directory
        $original_directory = ftp_pwd($ftp_stream);
        // test if you can change directory to $dir
        // suppress errors in case $dir is not a file or not a directory
        if ( @ftp_chdir( $ftp_stream, $dir ) ) {
            // If it is a directory, then change the directory back to the original directory
            ftp_chdir( $ftp_stream, $original_directory );
            return true;
        } else {
            return false;
        }
    }
}