xianglian_test_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';

    /**
     * 售卖商品列表
     * @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)->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 = '编辑商品';
        $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('藏品已经开始抢购或已过期，无法修改');
                $goods_info = Db::name('store_collection')->find($data['id']);
                if($goods_info['issue_mode'] == 2 && strtotime($goods_info['apply_st']) <time()) $this->error('抽签报名开始无法修改');
                if($goods_info['inventory'] != $goods_info['now_inventory']) $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');
            $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();
                $blind_count = Db::name('store_blind_box')->where(['prize_id'=>$data['id'],'is_del'=>1,'status'=>1])->sum('num');
                $buy_count += $blind_count;
            }else{
                $buy_count = 0;
            }
            $data['now_inventory'] = $data['inventory']-$buy_count;
            $arr = explode('.',$data['detail_img']);
            $data['format'] = end($arr);
            if($data['issue_mode'] == 1){
                unset($data['apply_st']);
            }else{
                $data['apply_end']  = $data['sell_time'];
                $data['before_time']  = 0;
            }
            // 优先购处理
            $data['advance_info'] = (isset($data['advance_info']) && is_array($data['advance_info'])) ? join(',', $data['advance_info']) : '';
        }else{
            if (!empty($data)){
                $data['covers'] = $data['cover'];
                $data['auth_imgs'] = $data['auth_img'];
                $data['describes'] = $data['describe'];
                $data['share_imgs'] = $data['share_img'];
                $data['advance_info'] = explode(',', isset($data['advance_info']) ? $data['advance_info'] : '');
            }
            //查询会员等级
            $vipData = Db::name('store_vip')->where('is_del',0)->select();
            $this->assign('vipData',$vipData);
        }
    }

    /**
     * 处理成功回调
     */
    public function _form_result($result){
        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();
        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('数据更新失败');
        }
    }
    /**
     * @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('数据更新失败');
        }
    }

    //判断是否已经抢购开始
    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;
    }

    public function send(){
        if($this->request->post()){
            $data = $this->request->post();
            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();

            $redis = new Redis();
            $zhuzao_count = $redis->Llen('collectionHash_'.$data['id']);
            //var_dump($zhuzao_count,$redis->hGetAll('collectionHash_'.$data['id']));
            if ($zhuzao_count<$data['number']) $this->error('铸造的的数量不足，无法赠送');
            $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'],
                        'pro_info'=>json_encode($info,true),
                        'company'=>$company,
                        'company_hash'=>$company_hash ? $company_hash:'',
                        'company_hash_time'=>$company_hash_time ? $company_hash_time :'',
                        'ddcid'=>$tokenid,
                        'collectors_hash'=>$collectors_hash ? $collectors_hash :'',
                    ];
                    $array[] = $date;
                }
                Db::name('store_order_info')->insertAll($array);

                Db::commit();
            } catch (\Exception $e){
                Db::rollback();
                $this->error($e->getMessage());
                $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 add_first()
    {
        if($this->request->post()){
            $phone = input('post.phone');
            $c_id = input('post.c_id');
            $num = input('post.num');
            $member = Db::name('store_member')->where('phone',$phone)->find();
            if(!$member) $this->error('用户未注册');
            //查询是否已经导入
            $isAdd = Db::name('store_collection_first')->where(['phone'=>$phone,'c_id'=>$c_id])->count();
            if($isAdd) $this->error('已经添加');
            Db::name('store_collection_first')->insert(['uid'=>$member['id'],'phone'=>$phone,'num'=>$num,'c_id'=>$c_id]);
            $this->error('已经成功');
        }
        $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'],
                            'pro_info'=>json_encode($info,true),
                            'company'=>$company,
                            'company_hash'=>$company_hash ? $company_hash : '',
                            'company_hash_time'=>$company_hash_time,
                            'ddcid'=>$tokenid,
                            'collectors_hash'=>$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());
        }
    }


    /**
     * 导出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();
    }

    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 draw(){
        $id=$this->request->get('id');
        $this->title = '抽签明细';
        $where=  [];
        $where[] = ['d.coll_id','=',$id];
        $list = $this->_query('store_collection_draw')->field('d.*,u.name,u.phone,u.headimg')
            ->alias('d')->leftJoin('store_member u','u.id=d.user_id')->where($where)
            ->dateBetween('d.create_at')->order('d.id desc')
            ->page();
        $this->fetch();
    }


    /**
     * 下载文件到服务器
     * 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;
    }




    public function import_first_list(){
        $id=$this->request->get('id');
        $this->title = Db::name($this->table)->where('id',$id)->value('name').'--导入明细';
        $query = $this->_query('store_collection_first')->where('c_id',$id)->like('phone');
        $query->dateBetween('create_at')->order('id desc')->page();
        $this->fetch();
    }


    public function del_first()
    {
        $id = input('post.id');
        Db::name('store_collection_first')->where('id',$id)->delete();
        $this->success('删除成功');
    }


    /**
     * 批量导入优先购会员
     * @auth true
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function import_first()
    {
        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'];
        $path_arr  = explode('.',$import_path);
        $suffix = end($path_arr);
        if($suffix !='xlsx') $this->error('请上传 xlsx 格式文件');
        if (getConfigValue('storage_type')=='oss'){
            $save_dir = "./upload/excle/"; // 服务资源目录
            $filename = date('Ymd').time().".".$suffix; // 自定义名称
            $res = $this->getFile($url,$save_dir,$filename,1);
            $import_path = $_SERVER['DOCUMENT_ROOT'].'/upload/excle/'.$res;
        }

        $num = 1;
        try {
            $objReader =\PHPExcel_IOFactory::createReader('Excel2007');
            $objExcel = $objReader->load($import_path);
            $list = $objExcel->getActiveSheet()->toArray();
            $success = 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['num'] = $data['B'];
                        array_push($array,$a);
                    }
                }
            }


            $error = 0;
            $phone_error = array();
            foreach ($array as &$v){
                $member = Db::name('store_member')->where('phone',$v['phone'])->find();
                //查询是否已经导入
                $isAdd = Db::name('store_collection_first')->where(['phone'=>$v['phone'],'c_id'=>$c_id])->count();
                if (!$member || $isAdd>0 ){
                    $error = $error+1;
                    array_push($phone_error,$v['phone']);
                }else{
                    $array1 = [
                        'uid'=>$member['id'],
                        'c_id'=>$c_id,
                        'phone'=>$member['phone'],
                        'num'=>$v['num'],
                    ];

                    if (Db::name('store_collection_first')->insertGetId($array1)){
                        $success +=1;
                    }else{
                        $error = $error+1;
                        array_push($phone_error,$v['phone']);
                    }
                }
            }
            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());
        }
    }

}