seafood/app/Http/Controllers/Admin/GoodsControl...

<?php
/**
 * Created by Sublime.
 * User: hao
 * Date: 19/08/30
 * Time: 上午11:20
 */
namespace App\Http\Controllers\Admin;

use App\Http\Controllers\Controller;
use App\Logs;
use App\Goods;
use App\GoodsSkus;
use App\Order;
use App\Oplog;
use App\Services\OssServices as oss;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

use PHPExcel_Reader_Excel2007;
use PHPExcel_Reader_Excel5;
use PHPExcel_Reader_CSV;

class GoodsController extends Controller
{
	public function index(Request $request){
        $page = (int)$request->input('page');
        $pageSize = 20;
        if($page<=0){
            $page = 1;
        }

        $offset = ($page-1) * $pageSize;
        $stime = $request->input('stime');
        $etime = $request->input('etime');
        $name = $request->input('name');

        $count = Goods::where(function($query) use($name, $stime, $etime){
            if($name) $query->where('name', 'like', $name.'%');
            if($stime) $query->where('createTime', '>=', $stime);
            if($etime) $query->where('createTime', '<=', $etime);
        })->where('is_del',0)->count();
        if ($count > 1) {
            // 总页数
            $pages = ceil($count/$pageSize);
        }else{
            // 总页数
            $pages = 1;
        }

        $result = Goods::where(function($query) use($name, $stime, $etime){
            if($name) $query->where('name', $name);
            if($stime) $query->where('createTime', '>=', $stime);
            if($etime) $query->where('createTime', '<=', $etime);
        })->where('is_del',0)->orderBy('id', 'desc')->offset($offset)->limit($pageSize)->get();
        $result = json_decode(json_encode($result),true);

        foreach($result as $k=>&$v){
            # 获取sku
            $skuList = GoodsSkus::where('goodsCode', $v['id'])->where('is_del', 0)->get();
            $v['sku_list'] = $skuList;            
        }

        return view('goods/index', ['result' =>$result,
            'page'              =>$page,
            'count'             =>$count,
            'pages'             =>$pages,          
            'stime'             =>$stime,
            'etime'             =>$etime,
            'name'           =>$name,
            ]);
    }

    /**
     * 添加商品
     * @return \Illuminate\View\View
     */
    public function create(Request $request)
    {
        return view('goods/create');
    }
    /**
     * 分组管理-进行添加操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function store(Request $request)
    {       
        $this->validate($request, [  
            'name'           => 'required',   
            'productCode'           => 'required',     
        ], [                                                              
            'name.required'           => '商品名不能为空',
            'productCode.required'           => '商品货号不能为空',                                                                        
        ]);
        //数据库-新增数据
        $goods = array();       
        $goods['name'] = trim($request->input('name')); 
        $goods['description'] = trim($request->input('description'));  //非必填
        $goods['eshopCode'] = '100|zjsc001'; 
        $goods['productCode'] = trim($request->input('productCode'));  
        /*$goods['propsName'] = $request->input('propsName');  
        $goods['price'] = $request->input('price');  
        $goods['Weight'] = $request->input('Weight');  
        $goods['volume'] = $request->input('volume');  */
        //图片上传 阿里云oss       
        if ($request->hasFile('img') && $request->file('img')->isValid()) {
            $file = $request->file('img');
            $ossClient=new oss();
            // 上传阿里云
            $file = $ossClient->upload($file->getClientOriginalExtension(), $file->getRealPath(), 'upload/seafoodPic'.date("Y-m-d",time()).'/'.date('His'));
            $img=$file['oss-request-url'];
            $goods['picUrl']=str_replace("kx-youhuiquan.oss-cn-beijing.aliyuncs.com","imgs.726p.com",$img);
        }
        //$goods['picUrl'] = $request->input('picUrl');  

        $res = DB::table('goods')->insertGetId($goods); 
        if($res){
            //卖家云必要参数拼接转化
            $mjArr = $goods;
            $mjArr['outerCode'] = $res;

            //sku
            $sku = $request->input('sku');
            if(!empty($sku)){
                foreach($sku as $key=>$item){
                    $sku_data = explode('@@', $item);
                    $sku_insert_data = $mjArr['skuList'][$key] = ['skuProductCode'=>'DCY-001', 'propsName'=>$sku_data[0], 'price'=>$sku_data[1], 'createTime'=>date('Y-m-d H:i:s'), 'modifyTime'=>date('Y-m-d H:i:s')];
                    $sku_insert_data['goodsCode'] = $res;
                    $sku_insert_data['eshopCode'] = '100|zjsc001';

                    $sku_ids = DB::table('goods_skus')->insertGetId($sku_insert_data);

                    $mjArr['skuList'][$key]['outerCode'] = $sku_ids;
                }
            }

            //对接卖家云
            $mj = Order::mjGoodsAdd($mjArr);
            /* 同步卖家云商品code等信息 */
var_dump($mj);exit;
            /* end */
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');
            $context = "新增商品数据";
            $type = 0; 
            $tables = 'goods,goods_skus';
            $data_id = $res;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);

        } 
      
        return redirect('/admin/goods/index')->with('info', '添加成功'); 
       
    }

    /**
     * 分组管理-编辑分组界面
     * @param $id
     * @return \Illuminate\View\View
     */
    public function edit($id,Request $request)
    {
        
        $data = Goods::where('id', $id)->first();
        $sku =  GoodsSkus::where('goodsCode', $id)->where('is_del', 0)->get();
        return view('goods/edit', [         
            'goods' => $data,
            'sku_list' => $sku,
            'id' => $id,
        ]);

    }

    /**
     * 分组管理-进行编辑操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function update(Request $request)
    {    
        $id = (int)$request->input('id');
        $this->validate($request, [  
            'id'             => 'required',
            'name'           => 'required',   
            'productCode'           => 'required',     
        ], [       
            'id'             => '非法操作',                                                       
            'name.required'           => '商品名不能为空',
            'productCode.required'           => '商品货号不能为空',                                                                        
        ]);

        $del_sku_ids = trim($request->input('del_sku_ids'),',');
        $sku = $request->input('sku');
        //数据库-修改数据
        $goods = array();       
        $goods['name'] = trim($request->input('name')); 
        $goods['description'] = trim($request->input('description'));  //非必填
        $goods['productCode'] = trim($request->input('productCode'));  
        //图片上传 阿里云oss       
        if ($request->hasFile('img') && $request->file('img')->isValid()) {
            $file = $request->file('img');
            $ossClient=new oss();
            // 上传阿里云
            $file = $ossClient->upload($file->getClientOriginalExtension(), $file->getRealPath(), 'upload/seafoodPic'.date("Y-m-d",time()).'/'.date('His'));
            $img=$file['oss-request-url'];
            $goods['picUrl']=str_replace("kx-youhuiquan.oss-cn-beijing.aliyuncs.com","imgs.726p.com",$img);
        } 

        $res = DB::table('goods')->where('id', $id)->update($goods); 
        if($res){
            //卖家云必要参数拼接转化
            $mjArr = $goods;
            $mjArr['outerCode'] = $id;
            //$mj = Order::mjGoodsUpdate($mjArr);
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');
            $context = "修改商品数据";
            $type = 0; 
            $tables = 'goods,goods_skus';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);

        }elseif( empty($del_sku_ids) && empty($sku) ){
            return redirect('/admin/goods/index')->with('info', '未做任何修改');
        } 

        if(!empty($sku)){
            $mjSkuArr = array();
            foreach($sku as $key=>$item){
                $sku_data = explode('@@', $item);
                $sku_insert_data = $mjSkuArr['skus'][$key] = ['goodsCode'=>$id,'eshopCode'=>'100|zjsc001','propsName'=>$sku_data[0], 'price'=>$sku_data[1], 'createTime'=>date('Y-m-d H:i:s'), 'modifyTime'=>date('Y-m-d H:i:s')];

                $sku_ids = DB::table('goods_skus')->insertGetId($sku_insert_data);

                $mjSkuArr['skus'][$key]['outerCode'] = $sku_ids;
            }
            //$mj_sku = Order::mjSkuAdd($mjSkuArr);
        }
        if(!empty($del_sku_ids)){
            $del_sku_ids = explode(',', $del_sku_ids);
            $del_res = GoodsSkus::whereIn('id', $del_sku_ids)->update(['is_del'=>1]);
        }

        //对接卖家云
        //$mj = Order::mjGoodsAdd($mjArr);
        /* 同步卖家云商品code等信息 */

        /* end */
      
        return redirect('/admin/goods/index')->with('info', '更新成功');       
    }

    /**
     * 分组管理-进行删除操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function delete($id)
    {
        $goods = Goods::find($id);
        $goods->is_del = 1;
        if ($goods ->save()){
            #记录操作日志
            $self_id = session('admin_id');
            $self_name = session('real_name');            
            $context = "删除商品";
            $type = 0; 
            $tables = 'goods';
            $data_id = $id;
            Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
            exit('1');
        }
        exit('0');
    }

    /**
     * 搜索商品
     */
    public function searchSkus(Request $request){
        $name = trim($request->input('name'));
        $result = Goods::select('gs.id as sku_id', 'goods.id as goods_id', 'goods.name', 'gs.propsName', 'gs.price')->leftJoin('goods_skus as gs', 'gs.goodsCode', '=', 'goods.id')->where('goods.name', 'like', '%'.$name.'%')->where('goods.is_del', 0)->where('gs.is_del', 0)->orderBy('goods.id', 'desc')->get();
        $result = json_decode(json_encode($result), true);

        if(empty($result)) exit('0');
        exit(json_encode($result));
    }

}