";
//print_r($row);
//echo "
";die;
        $res = $export->save($row);
        if ($res === false){
            $this->error('发货失败');
        }
        $lager = new QcodeLarge();
        $lager->name($userinfo['company'].'_'.'qcode_large')->whereIn('_id',$lagerId)->update(['l_status'=>1]);

        $this->success('成功','',$file_dir);
    }
    /**
     * 表格数据处理
     * @param $bach_id
     * @param $large_str
     * @param $company
     * @param $large_num
     * @param $small_num
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function exportdata($bach_id,$large_str,$company,$large_num,$small_num)
    {
        $bach = new QcodeBach();
        $large = new QcodeLarge();
        $small = new QcodeSmall();
        $bachList = $bach->name($company . '_' . 'qcode_bach')->where('_id', $bach_id[0])->find();
        $data = [
            'supplier_name' => $bachList['supplier_name'],
            'supplier_no' => $bachList['supplier_code'],
            'matter_name' => $bachList['matter_name'],
            'matter_no' => $bachList['matter_no'],
            'manufacture_date' => date('Y/m/d',strtotime('20'.$bachList['manufacture_date'])),
            'print_date' => date('Y/m/d',strtotime('20'.$bachList['print_date'])),
            'box_num' => $large_num,
            'tray_num' => $bachList['tray_num'],
            'small_num' => $small_num,
            'l_reservation' => $bachList['l_reservation'],
            's_reservation' => $bachList['s_reservation'],
            'l_flow' => $bachList['l_flow'],
            's_flow' => $bachList['s_flow'],
            'l_weight' => 0,
            's_weight' => $bachList['s_weight']/1000,
            'code' => [],
        ];
        $large_id = explode(',', $large_str);
        foreach ($large_id as $k => $v) {
            $largeList = $large->name($company . '_' . 'qcode_large')->where('_id', $v)->find();
            $data['l_weight'] = $data['l_weight'] + (int)$largeList['l_weight']/100;
            $small_list = $small->name($company . '_' . 'qcode_small')->where('large_id', $v)->select();
            foreach ($small_list as $value) {
                $code = [
                    'large_code' => $largeList['code'],
                    'small_code' => $value['code'],
                ];
                array_push($data['code'],$code);
            }
        }
        return $data;
    }

    /**
     * 生成excel
     * @param $data
     * @return string
     * @throws Exception
     * @throws \PhpOffice\PhpSpreadsheet\Writer\Exception
     */
    public function exportExcel($data)
    {
        $objexcel = new Spreadsheet();
        $sheet = $objexcel->getActiveSheet();
        //设置全局单元格垂直居中
        $objexcel->getDefaultStyle()->getAlignment()->setVertical(Alignment::HORIZONTAL_CENTER);
        //设置全局单元格水平居中
        $objexcel->getDefaultStyle()->getAlignment()->setHorizontal(Alignment::HORIZONTAL_CENTER);
        //设置全局单元格自动换行
        $objexcel->getDefaultStyle()->getAlignment()->setWrapText(true);
        //设置单元格宽度
        $sheet->getDefaultColumnDimension()->setWidth(50);
        //设置表头
        $sheet->setCellValue('A1', '文件流水号');
        $sheet->setCellValue('A2', '订单号');
        $sheet->setCellValue('A3', '供应商');
        $sheet->setCellValue('A4', '供应商代码');
        $sheet->setCellValue('A5', '物料名称');
        $sheet->setCellValue('A6', '物料代码');
        $sheet->setCellValue('A7', '生产日期');
        $sheet->setCellValue('A8', '打码日期');
        $sheet->setCellValue('A9', '大件数量');
        $sheet->setCellValue('A10', '托盘小件数量');
        $sheet->setCellValue('A11', '小件总数量');
        $sheet->setCellValue('C3', '大件预留码');
        $sheet->setCellValue('C5', '小件预留码');
        $sheet->setCellValue('C7', '大件开始流水号');
        $sheet->setCellValue('C9', '小件开始流水号');
        $sheet->setCellValue('C11', '大件重量（Kg）');
        $sheet->setCellValue('C13', '小件重量（Kg）');
        $sheet->setCellValue('A15', '大件二维码');
        $sheet->setCellValue('B15', '大件条码（预留）');
        $sheet->setCellValue('C15', '小件二维码');
        $sheet->setCellValue('D15', '小件条码（预留）');
        //插入表格数据
        $sheet->getCell('B3')->setValue(isset($data['supplier_name'])?$data['supplier_name']:'');
        $sheet->getCell('B4')->setValue(isset($data['supplier_no'])?$data['supplier_no']:'');
        $sheet->getCell('B5')->setValue(isset($data['matter_name'])?$data['matter_name']:'');
        $sheet->getCell('B6')->setValue(isset($data['matter_no'])?$data['matter_no']:'');
        $sheet->getCell('B7')->setValue(isset($data['manufacture_date'])?$data['manufacture_date']:'');
        $sheet->getCell('B8')->setValue(isset($data['print_date'])?$data['print_date']:'');
        $sheet->getCell('B9')->setValue(isset($data['box_num'])?$data['box_num']:'');
        $sheet->getCell('B10')->setValue(isset($data['tray_num'])?$data['tray_num']:'');
        $sheet->getCell('B11')->setValue(isset($data['small_num'])?$data['small_num']:'');
        $sheet->getCell('C4')->setValue(isset($data['l_reservation'])?$data['l_reservation']:'');
        $sheet->getCell('C6')->setValue(isset($data['s_reservation'])?$data['s_reservation']:'');
        $sheet->getCell('C8')->setValue(isset($data['l_flow'])?$data['l_flow']:'');
        $sheet->getCell('C10')->setValue(isset($data['s_flow'])?$data['s_flow']:'');
        $sheet->getCell('C12')->setValue(isset($data['l_weight'])?$data['l_weight']:'');
        $sheet->getCell('C14')->setValue(isset($data['s_weight'])?$data['s_weight']:'');
        foreach ($data['code'] as $k=>$v){
            $m = $k+16;
            $sheet->getCell('A'.$m)->setValue(isset($v['large_code'])?$v['large_code']:'');
            $sheet->getCell('B'.$m)->setValue('');
            $sheet->getCell('C'.$m)->setValue(isset($v['small_code'])?$v['small_code']:'');
            $sheet->getCell('D'.$m)->setValue('');
        }
        //文件另存
        $filename = date('Ymd',time()).rand(100,999).'_'.$data['supplier_name'].'_'.str_replace('/','_',$data['matter_name']).'_'.$data['small_num'].'.xlsx';
//        $filename = iconv("utf-8","gb2312",$filename);
        header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
        header('Content-Disposition:attachment;filename='.$filename);
        header('Cache-Control: max-age=0');
        header("Content-Type:text/html;charset=utf-8");
        if(is_dir(ROOT_PATH.'public/uploads/export/') === false)
        {
            mkdir(ROOT_PATH.'public/uploads/export/',0777,true);
        }
        $writer = IOFactory::createWriter($objexcel, 'Xlsx');
        $writer->save(ROOT_PATH.'public/uploads/export/'.$filename);
        return 'uploads/export/'.$filename;
    }

    /**
     * 批次发货申请
     * @return string|\think\response\Json
     * @throws \think\Exception
     */
    public function apply()
    {
        $export = new QcodeExport();
        $this->request->filter(['strip_tags', 'trim']);
        if (false === $this->request->isAjax()) {
            return $this->view->fetch();
        }
        if ($this->request->request('keyField')) {
            return $this->selectpage();
        }
        // 接收参数
        $userInfo = Session::get('admin');
        $where = [
            'company_id' => $userInfo['company'],
            'delete_time'=> ''
        ];
        $filter = input('filter');
        $filter = json_decode($filter,true);
        //样品编号查询
        if (isset($filter['matter_name'])){
            $where['matter_no'] =$filter['matter_name'];
        }
        if (isset($filter['username'])){
            $where['username'] = $filter['username'];
        }
        if (isset($filter['status'])){
            $where['status'] = (int)$filter['status'];
        }
        if (isset($filter['create_time'])){
            $begin = substr($filter['create_time'],0,19);
            $end = substr($filter['create_time'],22);
            $begin = strtotime($begin);
            $end = strtotime($end);
            $where['create_time'] = ['between',[$begin,$end]];
        }
        $order = input('order');
        $offset = input('offset');
        $limit = input('limit');
        $total = $export->where($where)->count();
        $export_list = $export
            ->order('_id',$order)
            ->where($where)
            ->whereIn('status',[0,1])
            ->skip($offset)
            ->limit($limit)
            ->select();
        $list=[];
        foreach ($export_list as $k=>$v) {
            $list[$k]['id'] = substr(json_encode($v['_id']),9,-2);
            $list[$k]['matter_name'] = $v['matter_name'];
            $list[$k]['matter_no'] = $v['matter_no'];
            $list[$k]['username'] = $v['username'];
            $list[$k]['large_num'] = $v['large_num'];
            $list[$k]['small_num'] = $v['small_num'];
            $list[$k]['create_time'] = $v['create_time'];
            $list[$k]['file_dir'] = $v['file_dir'];
            $list[$k]['status'] = $v['status'];
        }
        $result = ['total'=>$total,'rows'=>$list];
        return json($result);
    }

    /**
     * 批次发货删除
     * @param $ids
     * @return void
     */
    public function apply_del($ids)
    {
        $export = new QcodeExport();
        $userinfo = Session::get('admin');
        $large = new QcodeLarge();
        if (empty($ids)){
            $this->error('请求错误');
        }
        $res = $export->where('_id',$ids)->update(['delete_time'=>date('Y-m-d H:i:s',time())]);
        if ($res === false){
            $this->error('删除失败');
        }
        $large_list = $export->where('_id',$ids)->find();
        $large_id = explode(',',$large_list['large_str']);
        foreach ($large_id as $v){
            $result = $large->name($userinfo['company'].'_'.'qcode_large')->where('_id',$v)->update(['l_status'=>0]);
            if ($result === 0){
                $this->error('删除失败');
            }
        }
        $this->success('成功');
    }

    /**
     * 司机弹窗
     * @param $ids
     * @return string
     * @throws \think\Exception
     */
    public function goods($ids)
    {
        $this->view->assign('ids',$ids);
        return $this->view->fetch();
    }

    /**
     * 批次发货提交
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function apply_add()
    {
        $goods = new QcodeGoods();
        $export = new QcodeExport();
        $userinfo = Session::get('admin');
        if ($this->request->isAjax() === false){
            $this->error('请求错误');
        }
        $ids = input('ids');
        $order_number = input('order_number');
        $deliveryman = input('deliveryman');
        $shr_phone = input('shr_phone');
        $plate_number = input('plate_number');
        $note = input('note');
        $id_list = [];
        if (strpos($ids,',') === false){
            $id_list[0] = $ids;
        }else{
            $id_list = explode(',',$ids);
        }
        $update_status = $export->where('company_id',$userinfo['company'])->whereIn('_id',$id_list)->update(['status'=>2]);
        if ($update_status){
            $export_list = $export->whereIn('_id',$id_list)->select();
            $daterq = date('ymd',time());

            $data = [
                'shdh' => substr($daterq,2,2).' '.substr($daterq,2,6).mt_rand(1000,9999),
                'order_number' => $order_number,
                'deliveryman' => $deliveryman,
                'shr_phone' => $shr_phone,
                'plate_number' => $plate_number,
                'shrq_date' => '',
                'supplier_name' => $export_list[0]['username'],
                'supplier_id' => $userinfo['id'],
                'user_id' => $userinfo['id'],
                'status' => 0,
                'export_id' => $ids,
                'create_time' => time(),
                'note' => $note,
                'company_id' => $userinfo['company'],
            ];
            $data['qrcode_add'] = $this->Qrcode($data['shdh']);
            $res = $goods->save($data);
            if ($res === false){
                $this->error('失败');
            }
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 生成二维码
     * @param $url
     * @return string
     */
    public function Qrcode($url)
    {
        $level=2;
        $size=5;
        Vendor('phpqrcode.phpqrcode');//加载生成二维码的核心类
        $errorCorrectionLevel =intval($level) ;//容错级别
        $matrixPointSize = intval($size);//生成图片大小
        //生成二维码图片
        $object = new \QRcode();
        //打开缓冲区
        ob_start();
        $object->png($url, false, $errorCorrectionLevel, $matrixPointSize, 2);
        //这里就是把生成的图片流从缓冲区保存到内存对象上，使用base64_encode变成编码字符串，通过json返回给页面。
        $imageString = base64_encode(ob_get_contents());
        //关闭缓冲区
        ob_end_clean();
        //把生成的base64字符串返回给前端
        return 'data:image/png;base64,'.$imageString;
    }

    /**
     * 发货单
     * @return string|\think\response\Json
     * @throws \think\Exception
     */
    public function dispatch()
    {
        $export = new QcodeGoods();
        $this->request->filter(['strip_tags', 'trim']);
        if (false === $this->request->isAjax()) {
            return $this->view->fetch();
        }
        if ($this->request->request('keyField')) {
            return $this->selectpage();
        }
        // 接收参数
        $userInfo = Session::get('admin');
        $where = [
            'company_id' => $userInfo['company'],
            'delete_time'=> ''
        ];
        $search = input('search');
        if (isset($search)){
            $where['order_number|supplier_name|status|plate_number|shdh|deliveryman'] = new \MongoDB\BSON\Regex($search);
        }
        $filter = input('filter');
        $filter = json_decode($filter,true);
        //订单编号查询
        if (isset($filter['order_number'])){
            $where['order_number'] =$filter['order_number'];
        }
        //所属公司查询
        if (isset($filter['supplier_name'])){
            $where['supplier_name'] = $filter['supplier_name'];
        }
        if (isset($filter['status'])){
            $where['status'] = (int)$filter['status'];
        }
        if (isset($filter['create_time'])){
            $begin = substr($filter['create_time'],0,19);
            $end = substr($filter['create_time'],22);
            $begin = strtotime($begin);
            $end = strtotime($end);
            $where['create_time'] = ['between',[$begin,$end]];
        }
        $order = input('order');
        $offset = input('offset');
        $limit = input('limit');
        $total = $export->where($where)->count();
        $export_list = $export
            ->order('_id',$order)
            ->where($where)
            ->whereIn('status',[0,1])
            ->skip($offset)
            ->limit($limit)
            ->select();
        $list=[];
        foreach ($export_list as $k=>$v) {
            $list[$k]['id'] = substr(json_encode($v['_id']),9,-2);
            $list[$k]['shdh'] = $v['shdh'];
            $list[$k]['order_number'] = $v['order_number'];
            $list[$k]['supplier_name'] = $v['supplier_name'];
            $list[$k]['deliveryman'] = $v['deliveryman'];
            $list[$k]['plate_number'] = $v['plate_number'];
            $list[$k]['create_time'] = $v['create_time'];
            $list[$k]['status'] = $v['status'];
        }
        $result = ['total'=>$total,'rows'=>$list];
        return json($result);
    }

    /**
     * 发货单打印
     * @return \think\response\Json|void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function printqrcode()
    {
        $goods = new QcodeGoods();
        $export = new QcodeExport();
        $large = new QcodeLarge();
        $userinfo = Session::get('admin');
        if ($this->request->isAjax() === false) {
            $this->error('请求错误');
        }
        $id = input('id');
        $good_list = $goods->where('_id',$id)->find();

        if ($good_list){
            if (strpos($good_list['export_id'],',') === false){
                $export_id[0] = $good_list['export_id'];
            }else{
                $export_id = explode(',',$good_list['export_id']);
            }
            $data = [];
            foreach ($export_id as $k=>$v){
                $data[$k] = $export->where('_id',$v)->find();
                $large_str = explode(',',$data[$k]['large_str']);
                $large_list = $large->name($userinfo['company'].'_'.'qcode_large')->whereIn('_id',$large_str)->select();
                $large_num = $large_weight = 0;
                foreach ($large_list as $value){
                    $large_num = $large_num + $value['l_num'];
                    $large_weight = $large_weight + $value['l_weight'];
                }
                $data[$k]['l_num'] = $large_num/10000;
                $data[$k]['l_weight'] = $large_weight;
            }
            $good_list['address'] = $userinfo['company_address'];
            $good_list['data'] = $data;
            $good_list['count'] = count($data);
            $good_list['shrq_date'] = substr($good_list['create_time'],0,10) ;
            if (empty($good_list['qrcode_add'])){
                $good_list['qrcode_add'] = $this->Qrcode($good_list['shdh']);
                $goods->where('_id',$id)->update(['qrcode_add'=>$good_list['qrcode_add']]);
            }
            if ($good_list['note'] == 'NULL'){
                $good_list['note'] = '';
            }

            return json(['code'=>1,'data'=>$good_list]);
        }
    }

    /**
     * 获取辅料名称
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function matterName()
    {
        $userinfo = Session::get('admin');
        $lager = new QcodeLarge();
        $bach = new QcodeBach();
        $bach_id = $lager->name($userinfo['company'].'_'.'qcode_large')->where('delete_time','')->column('bach_id');
        $matter_name = [];
        if (!empty($bach_id)){
            foreach ($bach_id as $v){
                $bach_list = $bach->name($userinfo['company'].'_'.'qcode_bach')->where('_id',$v)->find();
                $matter_name[$bach_list['matter_no']] = $bach_list['matter_name'];
            }
        }
        $matter_name = array_unique($matter_name);
        return json($matter_name);
    }

    /**
     * 发货单删除
     * @param $ids
     * @return void
     */
    public function dispatch_del($ids)
    {
        $goods = new QcodeGoods();
        $export = new QcodeExport();
        if (empty($ids)){
            $this->error('参数错误');
        }
        $res = $goods->where('_id',$ids)->update(['delete_time'=>date('Y-m-d H:i:s',time())]);
        if ($res === false){
            $this->error('删除失败');
        }
        $export_list = $goods->where('_id',$ids)->find();
        $export_id = explode(',',$export_list['export_id']);
        foreach ($export_id as $v){
            $result = $export->where('_id',$v)->update(['status'=>0]);
            if ($result === false){
                $this->error('删除失败');
            }
        }

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

    /**
     * 收货列表
     */
    public function receive()
    {
        //当前是否为关联查询
        $this->relationSearch = false;
        //设置过滤方法
        $this->request->filter(['strip_tags', 'trim']);
        if ($this->request->isAjax()) {
            //如果发送的来源是Selectpage，则转发到Selectpage
            if ($this->request->request('keyField')) {
                return $this->selectpage();
            }
            $where = [
                'delete_time'=> ''
            ];

            $req = input();
            $req['sort'] == 'id' ? $sort = '_id' : $sort = $req['sort'];
            $order = $req['order'];
            $offset = $req['offset'];
            $limit = $req['limit'];

            // 构造模糊查询条件
//            $regex = new MongoDB\BSON\Regex('.*abc.*', 'i');
//            $filter = ['field' => $regex];

            $filter = json_decode($req['filter'], true);
            if (isset($filter['status'])){
                $where['status'] = intval($filter['status']);
                unset($filter['status']);
            }
            if (isset($filter['create_time'])){
                $begin = substr($filter['create_time'],0,19);
                $end = substr($filter['create_time'],22);
                $begin = strtotime($begin);
                $end = strtotime($end);
                $where['create_time'] = ['between',[$begin,$end]];
                unset($filter['create_time']);
            }
            foreach ($filter as $k => $v){
                $where[$k] = new \MongoDB\BSON\Regex($v);
            }

            $goods = new QcodeGoods();
            $total = $goods->where($where)->count();
            $list = $goods->where($where)
                ->order($sort,$order)
                ->limit($limit)
                ->skip($offset)
                ->select();
            foreach ($list as $k=>$v) {
                $oid = $v['_id']->jsonSerialize();
                $list[$k]['id'] = $oid['$oid'];
            }

            $result = array("total" => $total, "rows" => $list);

            return json($result);
        }
        return $this->view->fetch();
    }

    /**
     * 扫码/输入收货
     */
    public function receive_add()
    {
        $req = $this->request->param();
        if(!isset($req['shdh']) || empty($req['shdh'])){
            $this->error('请输入送货单号');
        }
        $data = [
            'shdh'=>$req['shdh'],
            'delete_time'=>'',
        ];
        $goods = new QcodeGoods();
        $row = $goods->where($data)->find();
        if (!$row) $this->error('未查询到该单号');

        if ($row['status']==2) $this->error('该单号已收货');

        //收货---修改status为2
        $bool = $goods->where($data)->update(['status'=>2,'sync_flag'=>0]);
        if ($bool){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 取消收货
     */
    public function receive_del()
    {
        $req = $this->request->param();

        if(!isset($req['ids']) || empty($req['ids'])){
            $this->error('id不能为空');
        }
        $data = [
            '_id'=>$req['ids'],
            'delete_time'=>'',
        ];
        $goods = new QcodeGoods();

        //收货---修改status为2
        $bool = $goods->where($data)->update(['status'=>0,'sync_flag'=>0]);
        if ($bool){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }
}