erp/core/CoreApp/controllers/Whlabeltransport.php

<?php defined('BASEPATH') OR exit('No direct script access allowed');
class Whlabeltransport extends Start_Controller {
	public function __construct(){
		parent::__construct();
		$this->load->_model('Model_whlabel','whlabel');
		$this->load->_model('Model_warehouse','warehouse');
		$this->load->_model('Model_excel','excel');
		$this->load->_model('Model_whlabeltransport','whlabeltransport');
		$this->load->_model('Model_logic_u9tools','logic_u9tools');
	}
	//定义方法的调用规则 获取URI第二段值
    public function _remap($arg,$arg_array)
    {
		if($arg == 'add')//添加
        {
             $this->_add();
        }
		else if($arg == 'edit')//修改
        {
             $this->_edit($arg_array);
        }
		else if($arg == 'del')//修改
        {
             $this->_del();
        }
		else if($arg == 'zj')//修改
        {
             $this->_zj();
        }
		else if($arg == 'list')//修改
        {
             $this->_list();
        }
		else if($arg == 'presetou')//修改
        {
             $this->_presetout($arg_array);
        }
		else if($arg == 'excel')
        {
             $this->_excel();
        }
		else if($arg == 'excelzh')
        {
             $this->_excelzh();//整合数据
        }
		else
		{
			 $this->_index();
		}
    }

	//管理
	public function _index()
	{
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['page']))  
		{
		    $page = $this->input->post('page',true);
		    $perpage = $this->input->post('perpage',true);
			$warehouse = $this->input->post('warehouse',true);
			$sku = $this->input->post('sku',true);
			$text = $this->input->post('text',true);
			$cz = $this->input->post('cz',true);
			$xztime = $this->input->post('xztime',true);
			$timetk = $this->input->post('timetk',true);
			$timetj = $this->input->post('timetj',true);
			$timetk = strtotime($timetk);
			$timetj = strtotime($timetj);
			$where = "1=1 ";
			if($warehouse)
            {
                $where  .= " and warehouse = '$warehouse'";
            }
			if($sku)
            {
                $where  .= " and sku = '$sku'";
            }
			if($text)
            {
                $where  .= " and text like '%$text%'";
            }
			if($cz != '')
            {
                $where  .= " and cz = '$cz'";
            }
			if($timetk && $timetj)
            {
                $where  .= " and ".$xztime." > '$timetk' and ".$xztime." < '$timetj'";
            }
            //数据排序
            $order_str = $xztime." desc";
            if(empty($page))
		    {
                $start = 0;
		    	$perpage = 1;
            }
		    else
		    {
                $start = ($page - 1)*$perpage;
            }
            $info_list = $this->whlabeltransport->find_all($where,'id,warehouse,sku,title,num,enter,stime,time,text,cz',$order_str,$start,$perpage);
			foreach ($info_list as $key=>$value) 
		    {
				$warehouse = $this->warehouse->read($value['warehouse']);
				$info_list[$key]['warehouse'] = $warehouse['title'];
				$info_list[$key]['enter'] = date('Y-m-d H:i:s',$value['enter']);
				$info_list[$key]['stime'] = date('Y-m-d',$value['stime']);
				if($value['time'] > 0)
				{
				    $info_list[$key]['time'] = date('Y-m-d H:i:s',$value['time']);
				}
				else
				{
					$info_list[$key]['time'] = "<p class='wc'><p>";
				}
				if($value['cz'] == '0')
				{
					$info_list[$key]['cz'] = "<p class='cz'><span class='ztwc' data-id='".$value['id']."'>点击完成</span><p>";
				}
				else if($value['cz'] == '1')
				{
					$info_list[$key]['cz'] = "<p class='cz'><font>已完成</font><p>";
				}
		    }
		    $total = $this->whlabeltransport->find_count($where);
		    $pagenum = ceil($total/$perpage);
		    $over = $total-($start+$perpage);
		    $rows = array('total'=>$total,'over'=>$over,'pagenum'=>$pagenum,'rows'=>($info_list));
		    echo json_encode($rows);exit;
		}
		$this->_Template('whlabeltransport',$this->data);
	}
	//添加
	public function _add()
	{
		$dir = '/data/excel/'.date('Ymd',time()).'/';
		$config['upload_path'] = '.'.$dir ;
		$config['file_name'] = date('Ymd_His_',time()).rand(1000,9999);
        $config['allowed_types'] = 'xls|xlsx|csv';
        $config['max_size'] = 10240;
		$this->load->library('upload', $config);
		$this->upload->initialize($config);
        if ($this->upload->do_upload('userfile'))
        {
			$full_path = $dir.$this->upload->data('file_name');
			$fileName = '.' . $full_path;
            if (!file_exists($fileName)) 
			{
				echo json_encode(array('msg'=>"上传失败，请重试",'success'=>false));exit;
            }
			else
			{
				libxml_use_internal_errors(true);
				require_once "./data/excel/PHPExcel/IOFactory.php";
				$phpExcel = PHPExcel_IOFactory::load($fileName);// 载入当前文件
				$phpExcel->setActiveSheetIndex(0);// 设置为默认表
				$sheetCount = $phpExcel->getSheetCount();// 获取表格数量
				$row = $phpExcel->getActiveSheet()->getHighestRow();// 获取行数
				$column = $phpExcel->getActiveSheet()->getHighestColumn();// 获取列数
				++$column;//如果列数大于26行
				$list = array();
				for ($i = 2; $i <= $row; $i++) // 行数循环
				{
					$data = array();
                    for ($c = 'A'; $c != $column; $c++)  // 列数循环
	                {
						$data[] = $phpExcel->getActiveSheet()->getCell($c . $i)->getValue();
                    }
					$list[] = $data;
                }
			}
			$i = 0;$j = 0;$ed = array();
			$order_no = "ZT".date("yMdHis");
		    foreach ($list as $key=>$value)
		    {
				$time = time();
				if($value['0'] == "")
				{
					continue;
				}
				$warehouse = $this->warehouse->get_title($value['0']);
				//$d = $this->whlabel->get_sku($value['1']);//针对各个仓库
				if($value['2'] =='' || $value['2'] < 1)
				{
					continue;
				}
				$d = $this->whlabel->get_warehousesku(5,$value['1']);//针对各个仓库
				if(!$d)//如果没有这个SKU
				{
					$ed[] = array($value['1'].'-库存中不存在此SKU');
					$j++;
					continue;
				}
				if(!isset($warehouse['id']))
				{
					$ed[] = array($value['1'].'-仓库名错误！');
					$j++;
					continue;
				}
				if($value['3'] == '')
				{
					$ed[] = array($value['1'].'-没有填写预达日期！');
					$j++;
					continue;
				}
				$post['sku'] = $value['1'];
				$post['num'] = $value['2'];//数量
				$post['stime'] = strtotime($value['3']);//预计到达日期
				$post['text'] = $value['4'];//备注
				$post['enter'] = $time;//添加时间
				$post['shop'] = $d['shop'];
				$post['warehouse'] = $warehouse['id'];
				$post['purchase'] = $d['purchase'];
				$post['title'] = $d['title'];
				$post['number'] = $d['number'];
				$post['features'] = $d['features'];
				$post['retreatwarehouse'] = $d['retreatwarehouse'];
				$post['order_no'] = $order_no;
				$post['u9_tb'] = 0;
				$this->whlabeltransport->insert($post);
			}
			if($j > 0)
			{
				$tt = date('Ymd',time());
				$title = '导入错误信息-'.$tt;
        		$titlename = "<table border=1><tr><td>错误详情</td></tr></table>";
				$tail = "\n";
        		$filename = $title.".xls";
        		$ecl = $this->excel->get_fz3($ed,$titlename,$filename,$tail);
				$dir = '/data/excel/'.$time.'/';
				$file_name = 'error_'.$time.rand(1000,9999);
				if(!is_dir('.'.$dir))mkdir('.'.$dir,0777);
				$myfile = fopen(".".$dir.$file_name.".xls", "w") or die();
				fwrite($myfile,$ecl);
				fclose($myfile);
				$error = $dir.$file_name.'.xls';
				echo json_encode(array('msg'=>'导入成功，'.$j.'条异常，','error'=>$error,'success'=>true));exit;
			}
			else
			{
				echo json_encode(array('msg'=>'导入成功!','error'=>1,'success'=>true));exit;
			}
		}
	}
	//修改
	public function _edit($arg_array)
	{
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['id']))
		{
			$id = $this->input->post('id',true);
			$data = $this->whlabeltransport->read($id);
			if($data['cz'] == '1')
			{
				echo json_encode(array('msg'=>'已完成的数据无法修改！','success'=>false));exit;
			}
			$post['num'] = $this->input->post('num',true);
			$post['text'] = $this->input->post('text',true);
			$stime = $this->input->post('stime',true);
			$post['stime'] = strtotime($stime);
			$post['edit'] = time();
			if($this->whlabeltransport->save($post,$id))
        	{
         		echo json_encode(array('msg'=>'修改成功','success'=>true));exit;
       	 	}
       		else
        	{
           		echo json_encode(array('msg'=>'修改失败，请重试','success'=>false));exit;
        	}
		}
		$arg_array = $arg_array[0];
		$whlabeltransport = $this->whlabeltransport->read($arg_array);
		$this->data['whlabeltransport'] = $whlabeltransport;
		$this->_Template('whlabeltransport_edit',$this->data);
	}
	
	public function _zj()
	{
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['id']))
		{
			$id = $this->input->post('id',true);
			$data = $this->whlabeltransport->read($id);
			if($data['cz'] == '0')
			{
				$list = array();$num = "";$title = "";$features = "";
				$order = $this->input->post('order',true);
				$shop = $this->input->post('shop',true);
				$label['shop'] = $data['shop'];
				$label['sku'] = $data['sku'];
				$label['warehouse'] = $data['warehouse'];
				$label['purchase'] = $data['purchase'];
				$label['retreatwarehouse'] = $data['retreatwarehouse'];
				$label['state'] = 0;
				$time = time();
				$label['title'] = $data['title'];
				$label['number'] = $data['number'];
				$label['features'] = $data['features'];
				$label['enter'] = $time;
				$label['time'] = $time;//操作时间
				if($label['warehouse'] == '5')
				{
					$yza = $this->whlabel->find_all("sku =  '".$label['sku']."' and warehouse = '".$label['warehouse']."'",'*','id desc');
					if($yza)
					{
						if($label['features'] != $yza[0]['features'])
						{
							echo json_encode(array('msg'=>'此SKU的产品信息和现有不一致！- 1','success'=>false));exit;
						}
					}
					/**
					$yzb = $this->whlabel->find_all("features =  '".$label['features']."' and warehouse = '".$label['warehouse']."'",'*','id desc');
					if($yzb)
					{
						if($label['sku'] != $yzb[0]['sku'])
						{
							echo json_encode(array('msg'=>'此产品信息的SKU和现有不一致！ - 2','success'=>false));exit;
						}
					}
					**/
				}
				$this->db->trans_begin();
				for($i=0;$i<$data['num'];$i++)
			    {
					$label['label'] = time().rand(100,999).$i;//产品标签 辨别各个产品，暂不使用
					$label['cs'] = $id;//前期增加这个是在途库存添加的数据
					$label['rktype'] = 1;
				    $this->whlabel->insert($label);
			    }
				$this->whlabeltransport->save(array('time'=>$time,'cz'=>1),$data['id']);
				if ($this->db->trans_status() === TRUE)
        		{
					$this->db->trans_commit();
					echo json_encode(array('msg'=>'入库成功！','id'=>$id,'time'=>date('Y-m-d H:i:s',$time),'success'=>true));exit;
				}
				else
				{
					$this->db->trans_rollback();
					echo json_encode(array('msg'=>'入库失败，请重试！','success'=>false));exit;
				}
			}
			else
		    {
			    echo json_encode(array('msg'=>'错误！已操作入库','success'=>false));exit;
		    }
		}
	}
	//导出模板
	public function _presetout()
	{
		if(isset($_GET['excel']))  
		{
			$where = "sku != 'Preset'";
            //数据排序
            $order_str = "id desc";
            if(empty($page))
		    {
                $start = 0;
		    	$perpage = 1;
            }
		    else
		    {
                $start = ($page - 1)*$perpage;
            }
			$warehouse = $this->input->get('warehouse',true);
			if($warehouse)
			{
				$where .= " and warehouse = '".$warehouse."'";
			}
            //取得信息列表
            $info_list = $this->whlabel->find_pc($where,'warehouse,sku','*');
			$rows = array();$list = array();
			foreach ($info_list as $value) 
		    {
				$warehouse = $this->warehouse->read($value['warehouse']);
				$number = $value['number'];$ftime = time()-15*24*3600;
				$list[] = array($warehouse['title'],$value['sku'],'0','','');
		    }
            $title = "在途模板"; 
            $titlename = "<table border=1>
            <tr align='center'>
			<td>仓库</td>
			<td>SKU</td>
            <td>数量</td>
            <td>预达日期(格式：2022-01-01)</td>
			<td>备注</td>
            </tr>
            </table>"; 
            $filename = $title.".xls";
			$tail = "";
            $this->excel->get_fz2($list,$titlename,$filename,$tail);
	    }
	}
	
	public function _excel()
	{
		if(isset($_GET['excel']))  
		{
			$warehouse = $this->input->get('warehouse',true);
			$sku = $this->input->get('sku',true);
			$cz = $this->input->get('cz',true);
			$text = $this->input->post('text',true);
			$xztime = $this->input->get('xztime',true);
			$timetk = $this->input->get('timetk',true);
			$timetj = $this->input->get('timetj',true);
			$timetk = strtotime($timetk);
			$timetj = strtotime($timetj);
			$where = "1=1 ";
			if($warehouse)
            {
                $where  .= " and warehouse = '$warehouse'";
            }
			if($sku)
            {
                $where  .= " and sku = '$sku'";
            }
			if($text)
            {
                $where  .= " and text like '%$text%'";
            }
			if($cz != '')
            {
                $where  .= " and cz = '$cz'";
            }
			if($timetk && $timetj)
            {
                $where  .= " and ".$xztime." > '$timetk' and ".$xztime." < '$timetj'";
            }
            //数据排序
            $order_str = $xztime." desc";
            //取得信息列表
           $info_list = $this->whlabeltransport->find_all($where,'warehouse,sku,title,num,enter,stime,time,text,features');


		   //转化为用友的编码 不为空在执行 为空了啥都不说了
		   if(!empty($info_list)){
				$info_list = $this->logic_u9tools->getU9bm($info_list,'features');
		   }

		   $final_list = [];
		   $warehouse_list = $this->warehouse->find_all("1=1",'id,title');
		   
		   $warehouse_list = array_column($warehouse_list,'title','id');
		   foreach($info_list as $key=>$value){
			 $final_list[$key] = [
				'warehouse'=>isset($warehouse_list[$value['warehouse']])?$warehouse_list[$value['warehouse']]:"",
				"sku"=>$value['sku'],
				'title'=>$value['title'],
				'jm'=>$value['jm'],
				'num'=>$value['num'],
				'enter'=>date('Y-m-d H:i:s',$value['enter']),
				'stime'=>date('Y-m-d',$value['stime']),
				'time'=>(($value['time'] > 0))?date('Y-m-d H:i:s',$value['time']):"<p class='wc'><p>",
				'text'=>$value['text']
			 ];
		    }
		 
			// foreach ($info_list as $key=>$value) 
		    // {
			// 	$warehouse = $this->warehouse->read($value['warehouse']);
			// 	$info_list[$key]['warehouse'] = $warehouse['title'];
			// 	$info_list[$key]['enter'] = date('Y-m-d H:i:s',$value['enter']);
			// 	$info_list[$key]['stime'] = date('Y-m-d',$value['stime']);
			// 	if($value['time'] > 0)
			// 	{
			// 	    $info_list[$key]['time'] = date('Y-m-d H:i:s',$value['time']);
			// 	}
			// 	else
			// 	{
			// 		$info_list[$key]['time'] = "<p class='wc'><p>";
			// 	}
		    // }
		
            $title = "在途数据".date('Y-m-d',time()); 
            $titlename = "<table border=1>
            <tr align='center'>
			<td>仓库</td>
			<td>SKU</td>
			<td>名称</td>
			<td>料号</td>
            <td>数量</td>
			<td>添加日期</td>
			<td>预达日期</td>
            <td>完成日期</td>
			<td>备注</td>
            </tr>
            </table>"; 
            $filename = $title.".xls";
			$tail = "";
            $this->excel->get_fz2($final_list,$titlename,$filename,$tail);
	    }
	}
	
	public function _excelzh()
	{
		if(isset($_GET['excel']))  
		{
			$warehouse = $this->input->get('warehouse',true);
			$sku = $this->input->get('sku',true);
			$cz = $this->input->get('cz',true);
			$text = $this->input->post('text',true);
			$xztime = $this->input->get('xztime',true);
			$timetk = $this->input->get('timetk',true);
			$timetj = $this->input->get('timetj',true);
			$timetk = strtotime($timetk);
			$timetj = strtotime($timetj);
			$where = "time = '0' ";
			if($warehouse)
            {
                $where  .= " and warehouse = '$warehouse'";
            }
			if($sku)
            {
                $where  .= " and sku = '$sku'";
            }
			if($text)
            {
                $where  .= " and text like '%$text%'";
            }
			if($cz != '')
            {
                $where  .= " and cz = '$cz'";
            }
			if($timetk && $timetj)
            {
                $where  .= " and ".$xztime." > '$timetk' and ".$xztime." < '$timetj'";
            }
            //数据排序
            $order_str = $xztime." desc";
            //取得信息列表
			$zh = array();
           $info_list = $this->whlabeltransport->find_all($where,'warehouse,sku,title,num,features,enter,stime,text');
		 //转化为用友的编码 不为空在执行 为空了啥都不说了
		   if(!empty($info_list)){
				$info_list = $this->logic_u9tools->getU9bm($info_list,'features');
		   }

		   $final_list = [];
		   $warehouse_list = $this->warehouse->find_all("1=1",'id,title');

		   
		   $warehouse_list = array_column($warehouse_list,'title','id');
		   foreach($info_list as $key=>$value){
			 $final_list[$key] = [
				'warehouse'=>$value['warehouse'],
				"sku"=>$value['sku'],
				'title'=>$value['title'],
				'jm'=>$value['jm'],
				'num'=>$value['num'],
				'features'=>$value['features'],
				'enter'=>date('Y-m-d H:i:s',$value['enter']),
				'stime'=>date('Y-m-d',$value['stime']),
				'text'=>$value['text']
			 ];
		    }

			foreach ($final_list as $v) 
		    {
				$c = $this->whlabel->find_count('state = 0 and warehouse = "'.$v['warehouse'].'" and features = "'.$v['features'].'"');
				// $warehouse = $this->warehouse->read($v['warehouse']);
				// $v['warehouse'] = $warehouse['title'];
				// $v['enter'] = date('Y-m-d H:i:s',$v['enter']);
				// $v['stime'] = date('Y-m-d',$v['stime']);
				$v['warehouse'] = isset($warehouse_list[$value['warehouse']])?$warehouse_list[$value['warehouse']]:"";
				if(isset($zh[$v['features']]))
				{
					$zh[$v['features']]['num'] += $v['num'];
				}
				else
				{
					$zh[$v['features']] = $v;
				}
				$zh[$v['features']]['features'] = $c;
		    }

            $title = "在途数据".date('Y-m-d',time()); 
            $titlename = "<table border=1>
            <tr align='center'>
			<td>仓库</td>
			<td>SKU</td>
			<td>名称</td>
			<td>料号</td>
            <td>在途数量</td>
			<td>库存数量</td>
			<td>添加在途日期</td>
			<td>预达日期</td>
			<td>备注</td>
            </tr>
            </table>"; 
            $filename = $title.".xls";
			$tail = "";
            $this->excel->get_fz2($zh,$titlename,$filename,$tail);
	    }
	}
	
	//批量完成
	public function _list()
	{
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['s']))  
		{
			$cw = '';$i = 0;
            $id_arr = $this->input->post('s');
            $id_arr =  explode(',',$id_arr);
            if(!$id_arr)
            {
                echo json_encode(array('msg'=>'参数错误！','success'=>false));exit;
            }
            //循环删除记录
            foreach ($id_arr as $v) 
		    {
			    $id = $v;
			    $data = $this->whlabeltransport->read($id);
			    if($data['cz'] == '0')
			    {
				    $list = array();$num = "";$title = "";$features = "";
				    $order = $this->input->post('order',true);
				    $shop = $this->input->post('shop',true);
				    $label['shop'] = $data['shop'];
				    $label['sku'] = $data['sku'];
				    $label['warehouse'] = $data['warehouse'];
				    $label['purchase'] = $data['purchase'];
				    $label['retreatwarehouse'] = $data['retreatwarehouse'];
				    $label['state'] = 0;
				    $time = time();
				    $label['title'] = $data['title'];
				    $label['number'] = $data['number'];
				    $label['features'] = $data['features'];
				    $label['enter'] = $time;
				    $label['time'] = $time;//操作时间
				    if($label['warehouse'] == '5')
				    {
					    $yza = $this->whlabel->find_all("sku =  '".$label['sku']."' and warehouse = '".$label['warehouse']."'");
					    if($yza)
					    {
						    if($label['features'] != $yza[0]['features'])
						    {
							    echo json_encode(array('msg'=>'此SKU的产品信息和现有不一致！','success'=>false));exit;
						    }
					    }
					    $yzb = $this->whlabel->find_all("features =  '".$label['features']."' and warehouse = '".$label['warehouse']."'");
					    if($yzb)
					    {
						    if($label['sku'] != $yzb[0]['sku'])
						    {
							    echo json_encode(array('msg'=>'此产品信息的SKU和现有不一致！','success'=>false));exit;
						    }
					    }
				    }
				    $this->db->trans_begin();
				    for($i=0;$i<$data['num'];$i++)
			        {
					    $label['label'] = time().rand(100,999).$i;//产品标签 辨别各个产品，暂不使用
					    $label['cs'] = 1;//前期增加这个是在途库存添加的数据
						$label['rktype'] = 1;
				        $this->whlabel->insert($label);
			        }
				    $this->whlabeltransport->save(array('time'=>$time,'cz'=>1),$data['id']);
				    if ($this->db->trans_status() === TRUE)
        		    {
					    $this->db->trans_commit();
						$i++;
				    }
				    else
				    {
					    $this->db->trans_rollback();
					    $cw .= $data['sku'].' | ';
				    }
			    }
            }
			if(count($id_arr) == $i)
			{
				echo json_encode(array('msg'=>'入库成功！','success'=>true));exit;
			}
			else
			{
				echo json_encode(array('msg'=>'有入库失败数据：'.$cw,'success'=>false));exit;
			}
		}
    }
	
	//删除
	public function _del()
	{
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['s']))  
		{
            $id_arr = $this->input->post('s');
            $id_arr =  explode(',',$id_arr);
            if(!$id_arr)
            {
                echo json_encode(array('msg'=>'参数错误！','success'=>false));exit;
            }
            //循环删除记录
            foreach ($id_arr as $v) 
		    {
				$data = $this->whlabeltransport->read($v);
				if($data['cz'] == '0')
				{
                    $this->whlabeltransport->remove($v);
				}
				else
				{
					echo json_encode(array('msg'=>'有已完成数据！无法继续删除','success'=>false));exit;
				}
            }
            echo json_encode(array('del'=>$id_arr,'msg'=>'删除记录成功！','success'=>true));
		}
    }
}