szcollect_admin2/application/store/controller/Goods.php

<?php
namespace app\store\controller;
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')->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'])->where('success',1)->count();

            $hash = Db::name('hash2')->where('goods_id',$v['id'])->find();
            if ($hash){
                if ($hash['success']==1){
                    $v['is_hash'] = 2;
                }else{
                    $v['is_hash'] = 3;
                }
            }else{
                $redis = new Redis();
                $count = $redis->get('castingHash_'.$v['id']);
                if ($count && $count>0){
                    $v['is_hash'] = 3;
                }else{
                    $v['is_hash'] = 1;
                }

            }
        }
    }



    /**
     * 添加商品
     * @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['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')->where('c_id',$data['id'])->count();
            }else{
                $buy_count = 0;
            }

            $data['now_inventory'] = $data['inventory']-$buy_count;
        }else{
            if (!empty($data)){
                $data['covers'] = $data['cover'];
                $data['auth_imgs'] = $data['auth_img'];
                $data['describes'] = $data['describe'];
                $data['share_imgs'] = $data['share_img'];

                $hash = Db::name('hash2')->where('goods_id',$data['id'])->find();
                if ($hash){
                    if ($hash['success']==1){
                        $data['is_hash'] = 2;
                    }else{
                        $data['is_hash'] = 3;
                    }
                }else{
                    $data['is_hash'] = 1;
                }
            }
        }
    }

    /**
     * 处理成功回调
     */
    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();
        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;
    }


    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();

            $zhuzao_count = Db::name('hash2')
                ->where('goods_id',$data['id'])
                ->where('success',1)
                ->count();
            if (!$zhuzao_count){
                $this->error('hash未铸造，无法赠送');
            }
//            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'];
//                    $ddcid = Db::name('hash')->where('hash',$hash['hash'])->value('ddcid');
//                    $company_hash_time = $hash['create_at'] ? $hash['create_at'] : date('Y-m-d H:i:s');
//                    Db::name('hash')->where('hash',$hash['hash'])->update(['status'=>1]);
                    $company_hash = Db::name('hash2')->where('goods_id',$data['id'])->where('success',1)->field('hash,ddcid')->find();
                    $company_hash_time = date('Y-m-d H:i:s');
                    $collectors_hash = '';
                    $date = [
                        'order_no'=>get_order_sn(),
                        'tag'=>$tag,
                        'mid'=>$data['mid'],
                        'c_id'=>$data['id'],
                        'pro_info'=>json_encode($info,true),
                        'company'=>$company,
                        'company_hash'=>$company_hash['hash'],
                        'company_hash_time'=>$company_hash_time,
                        'ddcid'=>$company_hash['ddcid'],
                        'collectors_hash'=>$collectors_hash,
                        'collectors_hash_time'=>'',
                        'type'=>2
                    ];
                    $array[] = $date;
                }
                Db::name('store_order_info')->insertAll($array);

                //减少数据库库存
                Db::name($this->table)->where('id',$data['id'])->setDec('now_inventory',$data['number']);

                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')->where('is_auth',1)->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('增加失败，请稍后重试');









            Db::name('store_collection')->where('id',$id)->setInc('casting_num',$number);
            $goods=Db::table('store_collection')->where('id',$this->request->post('id'))->find();

            if($number){

                $url2='http://192.144.219.204:8083/ddc/getNonce';
                $nonce=$this->curlRequest($url2);
                $result=json_decode($nonce,true);
                if(isset($result['code'])){
                    $this->error($result['msg']);
                }
                for ($i=1;$i<=$number;$i++){
                    $address='0x8583c53ca3759f0893cb6c156b682e8fef22ed95';
                    $str=$goods['id'].'-'.rand(1000000,9999999);
                  //  $url='http://192.144.219.204:8083/ddc/createHash?address='.$address.'&ddcURI='.$str;
                    $nonce = $nonce + 1;
                    $url='http://192.144.219.204:8083/ddc/createHash?address='.$address.'&ddcURI='.$str.'&nonce='.$nonce;
                    $res=$this->curlRequest($url);
                    $result=json_decode($res,true);
                    if($result['code']){
                        $this->error($result['msg']);
                    }
                    $data['goods_id']=$id;
                    $data['hash']=$res;
                    $data['status']=0;
                    $redis = new Redis();

                    if (Db::table('hash')->insert($data)){
                        //存入reids list
                        $redis_data = ['hash'=>$res,'create_at'=>date('Y-m-d H:i:s')];
                        $redis->rPush('collectionHash_'.$id,json_encode($redis_data));
                    }

                }
            }else{
                $this->error('请填写正确的铸造数量');
            }

            $this->success('铸造成功',url('/#/store/goods/index'));


        }else{

            $id=$this->request->get('id');
            $this->assign('id',$id);
            $vo = Db::name('store_collection')->where('id',$id)->field('inventory')->find();
            $this->assign('vo',$vo);
            $this->fetch();

        }

    }


    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)->where('success',1);
        $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;
    }


}