xingkong_admin/application/store/controller/Goods.php

<?php
namespace app\store\controller;
use app\common\library\PHPExcelService;
use library\Controller;
use think\cache\driver\Redis;
use think\Db;

/**
 * 售卖商品
 * Class Goods
 * @package app\store\controller
 */
class Goods extends Controller
{

    /**
     * 绑定数据表
     * @var string
     */
    protected $table = 'store_collection';
    protected $table2 = 'store_box';

    /**
     * 售卖商品列表
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function index()
    {
        checkCollectionState();
        $this->title = '售卖藏品管理';
        $query = $this->_query($this->table)->where('is_deleted',0)->like('name');
        $query->dateBetween('create_at')->whereIn('type','1,3')->order('id desc')->page();
    }

    /**
     * 数据列表处理
     * @auth true
     * @menu true
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    protected function _index_page_filter(&$data)
    {

        foreach ($data as &$v){
            $checksell = $this->checkSellTime($v['id']);
            if (!$checksell){
                $v['is_save'] = 0;
            }else{
                $v['is_save'] = 1;
            }
            $v['zz']=Db::table('hash')->where('goods_id',$v['id'])->count();
            $now_inventory = getCollectionInventory($v['id']);
            $v['now_inventory'] = $now_inventory<=0 ? 0 : $now_inventory;
            $v['shengyu'] = Db::name('hash')->where('goods_id',$v['id'])->where('status',0)->count();
        }

    }



    /**
     * 添加商品
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function add()
    {
        $this->title = '添加藏品';
        $this->_form($this->table, 'form');
    }


    /**
     * 编辑商品
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    function edit()
    {
        $this->title = '编辑商品';
        $id = $this->request->get('id');
        $checksell = $this->checkSellTime($id);
        //if (!$checksell)   $this->error('藏品已经开始抢购或已过期，无法修改');
        $this->_form($this->table, 'form');
    }





    /**
     * 表单数据处理
     * @auth true
     * @menu true
     * @param array $data
     */
    protected function _form_filter(&$data)
    {
        if($this->request->post()){
            if (isset($data['id']) || !empty($data['id'])){
                $checksell = $this->checkSellTime($data['id']);
                //if (!$checksell)   $this->error('藏品已经开始抢购或已过期，无法修改');
            }
            if ($data['cover'] == '') $this->error('请上传藏品图片');
            if ($data['price']<=0) $this->error('藏品价格错误');
            if ($data['auth_img'] == '') $this->error('请上传作者头像');
            if ($data['describe'] == '') $this->error('请上传商品描述');
            if ($data['buy_count']<1) $this->error('限购数量不能小于1');
            //if ($data['share_img'] == '') $this->error('请上传分享二维码');
            $data['date'] = date('Y-m-d',strtotime($data['sell_time']));
            if (isset($data['id'])){
                $buy_count = Db::name('store_order_info')
                    ->whereIn('status','1,3')
                    ->where('c_id',$data['id'])
                    ->count();
            }else{
                $buy_count = 0;
            }
            $data['now_inventory'] = $data['inventory']-$buy_count;
            $arr = explode('.',$data['detail_img']);
            $data['format'] = end($arr);
            //var_dump($data['is_pedestal']);exit();
        }else{
            if (!empty($data)){
                $data['covers'] = $data['cover'];
                $data['auth_imgs'] = $data['auth_img'];
                $data['describes'] = $data['describe'];
                $data['share_imgs'] = $data['share_img'];
            }
        }
    }

    /**
     * 处理成功回调
     */
    public function _form_result($result,$data){
        if ($result) {
            setCollectionInfoHash($result);
            $redis = new Redis();
            $count = Db::name($this->table)->where('id',$result)->value('now_inventory');
            $redis->set('collection_count_'.$result,$count);
            $this->success('操作成功',url('/#/store/goods/index'));
        }
    }


    /**
     * @auth true
     * @menu true
     * 商品上架
     */
    public function up()
    {
        $data = $this->request->post();
        checkCollectionState($data['id']);
        if (Db::name($this->table)->where('id',$data['id'])->update(['status'=>1])){
            setCollectionInfoHash($data['id']);
            $this->success('恭喜您，数据更新成功');
        }else{
            $this->error('数据更新失败');
        }
    }


    /**
     * @auth true
     * @menu true
     * 商品下架
     */
    public function down()
    {
        $data = $this->request->post();
        if (Db::name($this->table)->where('id',$data['id'])->update(['status'=>0])){
            setCollectionInfoHash($data['id']);
            $this->success('恭喜您，数据更新成功');
        }else{
            $this->error('数据更新失败');
        }
        //$this->_save($this->table, ['status' => '0']);
    }


    /**
     * @auth true
     * @menu true
     * 商品删除
     */
    public function del()
    {
        $data = $this->request->post();
        if (Db::name($this->table)->where('id',$data['id'])->update(['is_deleted'=>1])){
            setCollectionInfoHash($data['id']);
            $this->success('恭喜您，数据更新成功');
        }else{
            $this->error('数据更新失败');
        }
        //$this->_save($this->table, ['is_deleted' => '1']);
    }

//    public function _save_result($result){
//        if ($result){
//            setCollectionInfoHash($result);
//        }
//    }

    //判断是否已经抢购开始
    function checkSellTime($id){
        $sell_time = Db::name($this->table)->where('id',$id)->value('sell_time');
        $advance_minutes = getAdvanceMinutes();
        if ($advance_minutes>0){
            $sell_time = strtotime($sell_time)-($advance_minutes*60);
        }else{
            $sell_time = strtotime($sell_time);
        }
        if ($sell_time<=time()) return false;
        return true;
    }

    /**
     * 赠送商品
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function send(){
        if($this->request->post()){
            $data = $this->request->post();
            $data["mid"]=Db::name("store_member")->where(["phone"=>$data["phone"],"status"=>1,"is_deleted"=>0])->value("id");
            if (!isset($data['mid']) || $data['mid']==''){
                $this->error('请选择有效用户');
            }
            $inventory = Db::name($this->table)->where('id',$data['id'])->value('inventory');
            $info = Db::name($this->table)->where('id',$data['id'])->find();
            $com = true;
            Db::startTrans();
            try {
                $array = [];
                for ($i=0;$i<$data['number'];$i++){
                    //获取排名
                    $rank = getRanking($data['id'])+1;
                    $tag = getTag($data['id'],$rank,$inventory);
                    saveRanking($data['id']);
                    $company = '江苏栩贝文化有限公司';
                    $hash = getCompanyHash($data['id']);
                    $company_hash = $hash['hash'];
                    $company_hash_time = $hash['create_at'];
                    $tokenid = $hash['tokenid'];
                    Db::name('hash')->where('hash',$hash['hash'])->update(['status'=>1]);
                    $collectors_hash = '';
                    $date = [
                        'order_no'=>get_order_sn(),
                        'tag'=>$tag,
                        'mid'=>$data['mid'],
                        'c_id'=>$data['id'],
                        'name'=>$info['name'],
                        'cover'=>$info['cover'],
                        'type'=>$info['type'],
                        'pro_info'=>json_encode($info,true),
                        'company'=>$company,
                        'company_hash'=>$company_hash,
                        'company_hash_time'=>$company_hash_time,
                        'ddcid'=>$tokenid,
                        'collectors_hash'=>$collectors_hash,
                        'collectors_hash_time'=>''
                    ];
                    $array[] = $date;
                }
                Db::name('store_order_info')->insertAll($array);
                Db::commit();
            } catch (\Exception $e){
                Db::rollback();
                $com = false;
            }
            if ($com){
                //减掉库存
                loseCollectionInventory($data['id'],$data['number']);
                $this->success('赠送成功');
            }else{
                $this->error('赠送失败');
            }
        }else{
            $id=$this->request->get('id');
            $this->assign('id',$id);
            // $user = Db::name('store_member')->where('is_deleted',0)->field('id,name,phone')->select();
            // $this->assign('user',$user);
            $this->fetch();

        }
    }


    public function hash(){

        if($this->request->post()){
            $id = $this->request->post('id');
            $number = $this->request->post('number');

            if ($number<=0){
                $this->error('数量错误');
            }
            if (Db::name('store_collection')->where('id',$id)->setInc('casting_num',$number)){
                $redis = new Redis();
                $redis->Incrby('castingHash_'.$id,$number);
                $this->success('增加成功，正在铸造中');
            }
            $this->error('增加失败，请稍后重试');

        }else{

            $id=$this->request->get('id');
            $this->assign('id',$id);
            $this->fetch();

        }

    }



    /**
     * 批量赠送
     * @auth true
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function import()
    {
        list($msec, $sec) = explode(' ', microtime());
        $msectime = (float)sprintf('%.0f', (floatval($msec) + floatval($sec)) * 1000);  //毫秒值
        $get = $this->request->get();
        $import_path = $_SERVER['DOCUMENT_ROOT'].'/'.$get['path'];
        $url = $get['url'];
        $c_id = $get['c_id'];
        if (getConfigValue('storage_type')=='oss'){
            $save_dir = "./upload/excle/"; // 服务资源目录
            $filename = date('Ymd').time().".xlsx"; // 自定义名称
            $res = $this->getFile($url,$save_dir,$filename,1);
            $import_path = $_SERVER['DOCUMENT_ROOT'].'/upload/excle/'.$res;
        }

        $info = getCollectionInfoHash($c_id);
        $num = 1;
        try {
            $objReader =\PHPExcel_IOFactory::createReader('Excel2007');
            $objExcel = $objReader->load($import_path);
            $list = $objExcel->getActiveSheet()->toArray();
            $success = 0;
            $number = 0;
            $array = array();
            foreach ($list as $k=>$v){
                if($k>$num-1){
                    if(array_filter($v)){
                        $data=[];
                        foreach ($v as $kk=>$vv){
                            $data[IntToChr($kk)]=trim($vv);
                        }
                        $a['phone'] = $data['A'];
                        $a['number'] = $data['B'];
                        array_push($array,$a);
                        $number = $number+$data['B'];
                    }
                }
            }

            $redis = new Redis();
            $zhuzao_count = $redis->Llen('collectionHash_'.$c_id);
            if ($zhuzao_count<$number){
                $this->error('铸造的的数量不足，无法赠送',[],3);
            }
            $error = 0;
            $phone_error = array();
            foreach ($array as &$v){
                $member = Db::name('store_member')->where('phone',$v['phone'])->find();
                if (!$member){
                    $error = $error+1;
                    array_push($phone_error,$v['phone']);
                }else{
                    $array1 = [];
                    for ($i=0;$i<$v['number'];$i++){
                        //获取排名
                        $rank = getRanking($c_id)+1;
                        $tag = getTag($c_id,$rank,$info['inventory']);
                        saveRanking($c_id);
                        $company = '江苏栩贝文化有限公司';
                        $hash = getCompanyHash($c_id);
                        $company_hash = $hash['hash'];
                        $company_hash_time = $hash['create_at'];
                        $tokenid = $hash['tokenid'];
                        Db::name('hash')->where('hash',$hash['hash'])->update(['status'=>1]);
                        $collectors_hash = '';
                        $date = [
                            'order_no'=>get_order_sn(),
                            'tag'=>$tag,
                            'mid'=>$member['id'],
                            'c_id'=>$c_id,
                            'name'=>$info['name'],
                            'cover'=>$info['cover'],
                            'type'=>$info['type'],
                            'pro_info'=>json_encode($info,true),
                            'company'=>$company,
                            'company_hash'=>$company_hash,
                            'company_hash_time'=>$company_hash_time,
                            'ddcid'=>$tokenid,
                            'collectors_hash'=>$collectors_hash,
                            'collectors_hash_time'=>''
                        ];
                        $array1[] = $date;
                    }
                    if (Db::name('store_order_info')->insertAll($array1)){
                        loseCollectionInventory($c_id,$v['number']);
                        $success +=1;
                    }else{
                        $error = $error+1;
                    }
                }
            }
            if ($error<1){
                $this->success('成功');
            }else{
                $this->error('失败',['error'=>$error,'success'=>$success,'phone_error'=>$phone_error],2);
            }

        } catch (\think\exception\ValidateException $e) {
            $this->error($e->getMessage());
        }
    }



  /**
     * 批量赠送vip
     * @auth true
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function import2()
    {
        list($msec, $sec) = explode(' ', microtime());
        $msectime = (float)sprintf('%.0f', (floatval($msec) + floatval($sec)) * 1000);  //毫秒值
        $get = $this->request->get();
        $import_path = $_SERVER['DOCUMENT_ROOT'].'/'.$get['path'];
        $url = $get['url'];
        $c_id = $get['c_id'];
        if (getConfigValue('storage_type')=='oss'){
            $save_dir = "./upload/excle2/"; // 服务资源目录
            $filename = date('Ymd').time().".xlsx"; // 自定义名称
            $res = $this->getFile($url,$save_dir,$filename,1);
            $import_path = $_SERVER['DOCUMENT_ROOT'].'/upload/excle2/'.$res;
        }
        $num = 1;
        try {
            $objReader =\PHPExcel_IOFactory::createReader('Excel2007');
            $objExcel = $objReader->load($import_path);
            $list = $objExcel->getActiveSheet()->toArray();
            $success = 0;
            $number = 0;
            $array = array();
            foreach ($list as $k=>$v){
                if($k>$num-1){
                    if(array_filter($v)){
                        $data=[];
                        foreach ($v as $kk=>$vv){
                            $data[IntToChr($kk)]=trim($vv);
                        }
                        $a['phone'] = $data['A'];
                        array_push($array,$a);
                    }
                }
            }
            $error = 0;
            $phone_error = array();
            $array_data=array();
            foreach ($array as &$v){
                $member = Db::name('store_member')->where('phone',$v['phone'])->value("id");
                // $store_collection_tree=Db::name("store_collection")->where(["id"=>$c_id])->value("tree");
                // if($store_collection_tree && strpos($store_collection_tree,"|".$member."|")!==false){
                //     break;
                // }
                if(!$member){
                    $error = $error+1;
                    array_push($phone_error,$v['phone']);
                }else{
                    $success +=1;
                    array_push($array_data,$member);
                }
            }
            if($success){
                $store_collection_tree=Db::name("store_collection")->where(["id"=>$c_id])->value("tree");
                $tree=implode("|",$array_data);
                if($store_collection_tree){
                     Db::name("store_collection")->where(["id"=>$c_id])->update(["tree"=>$store_collection_tree.$tree."|"]);
                }else{
                     Db::name("store_collection")->where(["id"=>$c_id])->update(["tree"=>"|".$tree."|"]);
                }

            }
            if ($error<1){
                $this->success('成功');
            }else{
                $this->error('失败',['error'=>$error,'success'=>$success,'phone_error'=>$phone_error],2);
            }
        } catch (\think\exception\ValidateException $e) {
            $this->error($e->getMessage());
        }
    }

    /**
     * 导出EXCL
     * @remark 根据WHERE条件导出EXCL
     * @param array $post 查询条件所需值
     * @return array
     */
    public function get_excl()
    {
        set_time_limit(300);

        $list = json_decode($this->request->get('phone'),true);

        $export = [];
        if (is_array($list)) {
            foreach ($list as $index => $item) {
                $export[] = [
                    $item
                ];
            }
        }
        PHPExcelService::setExcelHeader(['手机号'])
            ->setExcelTile('错误手机号', '错误手机号', '手机号', time())
            ->setExcelContent($export)
            ->ExcelSave();

    }



    /**
     * 奖品管理
     * @remark 根据WHERE条件导出EXCL
     * @param array $post 查询条件所需值
     * @return array
     */
    public function prize_list(){
        $id=$this->request->get('id');
        $this->c_id = $id;
        $this->title = '奖品列表';
        $query = $this->_query($this->table2)->where('coll_id',$id)->where('is_del',1);
        $query->like('name');
        $query->order('id desc')->page();
    }

    /**
     * 数据列表处理
     * @auth true
     * @menu true
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    protected function _prize_list_page_filter(&$data)
    {
        foreach ($data as &$v){
            if ($v['is_prize']==1){
                $v['info'] = Db::name('store_collection')
                    ->where('id',$v['prize'])
                    ->field('id,name,cover,now_inventory,status')
                    ->find();
                $v['info']['now_inventory'] = getCollectionInventory($v['prize']);
            }
        }
        //dump($data);die();
    }


    /**
     * 添加奖品
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function add_prize()
    {
        $id=$this->request->get('c_id');
        $this->c_id = $id;
        $this->title = '添加奖品';
        if($this->request->post()){
            if (Db::name($this->table2)->insert($this->request->post())){
                $this->success('添加成功');
            }
            $this->error('添加失败');
        }else{
            $prize = Db::name('store_collection')
                ->where('type',4)
                ->where('is_deleted',0)
                ->where('status',1)
                ->field('id,name')
                ->select();
            $this->prize = $prize;
            $this->_form($this->table, 'add_prize');
        }
    }

    /**
     * 添加奖品
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function edit_prize()
    {
        $cid=$this->request->get('c_id');
        $this->c_id = $cid;
        $this->title = '编辑奖品';
        if($this->request->post()){
            $post = $this->request->post();
            $post['update_at'] = date('Y-m-d H:i:s');
            if (Db::name($this->table2)->where('id',$post['id'])->update($post)){
                $this->success('编辑成功');
            }
            $this->error('编辑失败');
        }else{
            $id = $this->request->get('id');
            $this->vo = Db::name($this->table2)->where('id',$id)->find();
            $prize = Db::name('store_collection')
                ->where('type',4)
                ->where('is_deleted',0)
                ->where('status',1)
                ->field('id,name')
                ->select();
            $this->prize = $prize;
            $this->_form($this->table, 'add_prize');
        }




    }


    /**
     * 禁用
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function forbid2()
    {
        $this->_save($this->table2, ['status' => '0']);
    }

    /**
     * 启用
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function enable2()
    {
        $this->_save($this->table2, ['status' => 1]);
    }

    /**
     * 删除
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function del2()
    {
        $this->_save($this->table2, ['is_del' => 0]);
    }








    public function detail(){
        $id=$this->request->get('id');
        $this->title = Db::name($this->table)->where('id',$id)->value('name').'--铸造明细';
        $query = $this->_query('hash')->where('goods_id',$id);
        $query->dateBetween('create_at')->order('id desc')->page();
        $this->fetch();
    }


    public function curlRequest($url, $headers = [], $body = [], $method = "GET")
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);//设置请求头
        curl_setopt($ch, CURLOPT_POSTFIELDS, $body);//设置请求体
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method); //定义请求类型
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_HTTP_VERSION, 'CURL_HTTP_VERSION_1_1');
        $output = curl_exec($ch);
        curl_close($ch);
        return $output;
    }




    /**
     * 下载文件到服务器
     * addtime 2020年8月28日 18:38:43
     */
    function getFile($url, $save_dir = '', $filename = '', $type = 0)
    {
        if (trim($url) == '') {
            return false;
        }
        if (trim($save_dir) == '') {
            $save_dir = './';
        }
        if (0 !== strrpos($save_dir, '/')) {
            $save_dir.= '/';
        }
        //创建保存目录
        if (!file_exists($save_dir) && !mkdir($save_dir, 0777, true)) {
            return false;
        }
        //获取远程文件所采用的方法
        if ($type) {
            $ch = curl_init();
            $timeout = 5;
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
            $content = curl_exec($ch);
            curl_close($ch);
        } else {
            ob_start();
            readfile($url);
            $content = ob_get_contents();
            ob_end_clean();
        }
        $size = strlen($content);
        //文件大小
        $fp2 = @fopen($save_dir . $filename, 'a');
        fwrite($fp2, $content);
        fclose($fp2);
        unset($content, $url);
        return $filename;
    }

}