erp/core/CoreApp/controllers/Commodity.php

<?php defined('BASEPATH') OR exit('No direct script access allowed');
class Commodity extends Start_Controller {
	public function __construct(){
		parent::__construct();
		$this->load->library('session');
		$this->load->_model('Model_commodity','commodity');
		$this->load->_model('Model_commodityread','commodityread');
		$this->load->_model('Model_shop','shop');
		$this->load->_model('Model_apismt','apismt');
		$this->load->_model('Model_typeclass','typeclass');
		$this->load->_model('Model_commodityread_del','commodityreaddel');
	}
	//定义方法的调用规则 获取URI第二段值
    public function _remap($arg,$arg_array)
    {
		if($arg == 'aeorder')//同步
        {
             $this->_aeorder();
        }
		else if($arg == 'edit')//修改
        {
             $this->_edit($arg_array);
        }
		else if($arg == 'batchedit')//批量修改
        {
             $this->_batchedit();
        }
		else if($arg == 'skuedit')//修改
        {
             $this->_skuedit($arg_array);
        }
		else
		{
			 $this->_index();
		}
    }

	//管理
	public function _index()
	{
		$dt = 0;
		if(isset($_SESSION['api']))
		{
			$user = $this->user->get_api($_SESSION['api']);
			$usp = $user;
		    $fgshop = "";$sid = "";
		    $usersp = explode('|',trim($user['shop'],'|'));
			foreach ($usersp as $value) 
		    {
				$fgshop .= " shop = ".$value." or";
				$sid .= " id = ".$value." or";
			}
		}
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['page']))
		{
		    $page = $this->input->post('page',true);
		    $perpage = $this->input->post('perpage',true);
			$shop = $this->input->post('shop',true);
			$productid = $this->input->post('productid',true);
			$title = $this->input->post('title',true);
			$type = $this->input->post('type',true);
			$code = $this->input->post('code',true);
			$skuid = $this->input->post('skuid',true);
			$category = $this->input->post('category',true);
			$categorytypeclass =  $this->typeclass->get_titleclassid($category,16);
			$where = "1=1 and (".rtrim($fgshop,'or').")";
			if($shop)
            {
                $where  .= " and shop = '$shop'";
            }
			if($productid)
            {
                $where  .= " and productid = '$productid'";
            }
			if($title)
            {
				$where  .= " and title like '%$title%'";
            }
			if($type)
            {
                $where  .= " and type = '$type'";
            }
			if($category)
            {
                $where  .= " and category like '%".$categorytypeclass['id']."%'";
            }
			if($code)
            {
				$u = $this->commodityread->get_sku($code);
				$u = $u['productid'];
                $where  .= " and productid = '$u'";
            }
			if($skuid)
            {
				$u = $this->commodityread->get_skuid($skuid);
				$u = $u['productid'];
                $where  .= " and productid = '$u'";
            }
            //数据排序
            $order_str = "time desc";
            if(empty($page))
		    {
                $start = 0;
		    	$perpage = 1;
            }
		    else
		    {
                $start = ($page - 1)*$perpage;
            }
            //取得信息列表
            $info_list = $this->commodity->find_all($where,'id,shop,productid,img,title,category,time',$order_str,$start,$perpage);
			 //格式化数据
            foreach ($info_list as $key=>$v) 
		    {
				$shop = $this->shop->read($v['shop']);
				$info_list[$key]['shop'] = $shop['shopname'];
				$info_list[$key]['img'] = "<img src='".$v['img']."' style='height:55px' />";
				$category = '';
				if($v['category'])
				{
				    $v['category'] = explode(',',trim($v['category'],','));
				    foreach ($v['category'] as $vv) 
		            {
				        $typeclass = $this->typeclass->read($vv);
					    $category .= "<p>".$typeclass['title']."</p>";
				    }
				    $info_list[$key]['category'] = $category;
				}
				else
				{
					$info_list[$key]['category'] = '';
				}
				$info_list[$key]['time'] = "<p><a href='http://posting.aliexpress.com/wsproduct/edit_wholesale_product.htm?product_id=".$v['productid']."' target='_blank'>编辑</a></p><p><a href='http://www.aliexpress.com/item/".$v['productid'].".html' target='_blank'>浏览</a></p>";
				
            }
		    $total = $this->commodity->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;
		}
		$wlshop = $this->shop->find_all('1=1 and '.rtrim($sid,'or'));
		$this->data['wlshop'] = $wlshop;
		$this->_Template('commodity',$this->data);
	}
	//修改
	public function _edit($arg_array)
	{
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['id']))
		{
			$id = $this->input->post('id',true);
			$category = $this->input->post('category',true);
			$data = $this->input->post('data');
			if($data)
			{
			    $data = explode('|',rtrim($data,'|'));
			    foreach ($data as $v) 
		        {
				    $d = explode('@',$v);
				    $this->commodityread->save(array('sku'=>$d[1]),$d[0]);
			    }
			}
			if($this->commodity->save(array('category'=>','.$category),$id))
        	{
         		echo json_encode(array('msg'=>'操作成功','success'=>true));exit;
       	 	}
       		else
        	{
           		echo json_encode(array('msg'=>'操作失败，请重试','success'=>false));exit;
        	}
		}
		$arg_array = $arg_array[0];
		$commodity = $this->commodity->read($arg_array);
		$this->data['commodity'] = $commodity;
		$sku = $this->commodityread->find_all('productid = '.$commodity['productid']);
		$this->data['sku'] = $sku;
		$this->_Template('commodity_edit',$this->data);
	}
	
	public function _batchedit_b()//老系统形式，保留，不用
	{
		$dictionaries = $this->typeclass->find_all('ae!= "" and (classid=13 or classid=22 or classid=8 or classid=15 or classid=27 or classid=25 or classid=26 or classid=18 or classid=14 or classid=9 or classid=12 or classid=10 or classid=6)'); //产品人发类型颜色
		$dtc = array();$ctd = array();
		foreach ($dictionaries as $v) 
		{
			if(stripos($v['spare'],'|') !== false)//如果有多个值
			{
				$v['spare'] = explode('|',$v['spare']);
				foreach ($v['spare'] as $vs)
		        {
					$dtc[strtolower($vs)] = array('classid'=>$v['classid'],'title'=>$v['title'],'id'=>$v['id']);
				}
			}
			else
			{
				$dtc[strtolower($v['spare'])] = array('classid'=>$v['classid'],'title'=>$v['title'],'id'=>$v['id']);
			}
			$ctd[$v['id']] = $v['title'];
		}
		$ctd[126] = 'Hair Weaving';
		$ctd[127] = 'Closure';
		$ctd[128] = 'Wigs';
		$ctd[130] = 'Clip-in Full Head';
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['id']))
		{
			$id = $this->input->post('id',true);
			$ndata = $this->input->post('data',true);
			$id = explode(',',rtrim($id,','));
			$data = explode('-',rtrim($ndata,'-'));
			$rows = array();
			foreach ($id as $val) 
		    {
				//a:颜色 b:密度 c:头路设计
			    $u = $this->commodityread->read($val);
				$u['codeid'] = strtolower($u['codeid']);
				$u['codeid'] = str_replace(array('stretched length','inches','& '),array('length','',''),$u['codeid']);
				$sku = explode(';',rtrim($u['codeid'],';'));
				$codeid = array();$whlabel = ''; $fpdata = '';
				foreach ($sku as $v)
		        {
					$va = explode(':',$v);
					$codeid[$va[0]] = $va[1];
				}
				$num = '';$ti = '';$tit = '';$error = '';$i = 1;
				foreach ($data as $k=>$v) 
		        {
					if($v == 'a')
					{
						if(isset($codeid['color']) && isset($dtc[$codeid['color']]))
						{
						    $num .= $dtc[$codeid['color']]['id'].'-';
							$ti .= $dtc[$codeid['color']]['title'].' ';
						}
						else
						{
							$num .= '57-';
							$ti .= 'Natural Black ';
						}
					}
					else if($v == 'b')
					{
						if(isset($codeid['density']) && isset($dtc[$codeid['density']]))
						{
						    $num .= $dtc[$codeid['density']]['id'].'-';
							$ti .= $dtc[$codeid['density']]['title'].' ';
						}
						else
						{
							$num .= '71-';
							$ti .= '150% ';
						}
					}
					else if($v == 'c')
					{
						if(isset($codeid['part design']) && isset($dtc[$codeid['part design']]))
						{
						    $num .= $dtc[$codeid['part design']]['id'].'-';
							$ti .= $dtc[$codeid['part design']]['title'].' ';
						}
						else
						{
							$num .= '75-';
							$ti .= 'Free Part ';
						}
					}
					else
					{
						if($i == 2)
						{
							$num .= $v.'-id-';
						}
						else
						{
							$num .= $v.'-';
						}
						$ti .= $ctd[$v].' ';
					}
					$i++;
			    }
				if(stripos($codeid['length'],'closure') !== false && stripos($ndata,'127') !== false)
				{
					$v = preg_replace(array('/([\s\S]*)closure/','/([\s\S]*)closure\s/'),array('',''),$codeid['length']);
					$v = preg_replace('/([\s]*)/','',$v);
					$fpdata = $dtc[$v]['id'].',-'.str_replace('id-','',$num).'|'.$ti.$v.'inch |1|0.00|0.00|'.$v.'|0.00|0.00;';
					$tit = '<p>'.$ti.$v.'inch</p>';
					$whlabel = '|'.str_replace(array('-','id'),array('',$dtc[$v]['id']),$num).'-1';
				}
				else
				{
				    $codeid['length'] = explode(' ',$codeid['length']);
				    foreach ($codeid['length'] as $v) 
		            {
					    if(is_numeric($v))
					    {
					    	$fpdata .= $dtc[$v]['id'].',-'.str_replace('id-','',$num).'|'.$ti.$v.'inch |1|0.00|0.00|'.$v.'|0.00|0.00;';
						    $tit .= '<p>'.$ti.$v.'inch</p>';
						    $whlabel .= '|'.str_replace(array('-','id'),array('',$dtc[$v]['id']),$num).'-1';
					    }
					    else
					    {
					    	break;
					    }
				    }
				}
				$fa = '';$wl = '';
				$u['fpdata'] = explode(';',rtrim($u['fpdata'],';'));
				$u['whlabel'] = explode('|',trim($u['whlabel'],'|'));
				for($i=0;$i<count($u['fpdata']);$i++) 
		        {
					if(stripos($u['fpdata'][$i],$data[0]) === false)
					{
						if($u['fpdata'][$i] != '')
						{
						    $fa .= $u['fpdata'][$i].';';
							$te = explode('|',$u['fpdata'][$i]);
						    $tit .= '<p>'.$te[1].'</p>';
						}
					}
					if(stripos($u['whlabel'][$i],$data[0]) === false)
					{
						if($u['whlabel'][$i] != '')
						{
						    $wl .= '|'.$u['whlabel'][$i];
						}
					}
				}
				$this->commodityread->save(array('fpdata'=>$fa.$fpdata,'whlabel'=>$wl.$whlabel.'|'),$val);
				$rows[] = array('id'=>$val,'title'=>$tit);
            }
			echo json_encode(array('rows'=>$rows,'success'=>true));exit;
		}
	}
	public function _skuedit($arg_array)
	{
		$post = $this->input->post(NULL, TRUE);
		if(isset($post['id']))
		{
			$id = $this->input->post('id',true);
			$post['fpdata'] = $this->input->post('fpdata',true);
			$post['whlabel'] = $this->input->post('whlabel',true);
			if($this->commodityread->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];$fpdata = array();
		$commodityread = $this->commodityread->read($arg_array);
		if(stripos($commodityread['fpdata'],';') !== false)
		{
		    $fpdata = explode(';',rtrim($commodityread['fpdata'],';'));
		    foreach ($fpdata as $k=>$v) 
		    {
			    $fpdata[$k] = explode('|',$v);
            }
		}
		$this->data['fpdata'] = $fpdata;
		$this->data['commodityread'] = $commodityread;
		$this->_Template('commodityread_edit',$this->data);
	}
	
	//获取
	public function _aeorder()
	{
		$sid = '';
		if(isset($_SESSION['api']))
		{
			$user = $this->user->get_api($_SESSION['api']);
		    $user = explode('|',trim($user['shop'],'|'));
			foreach ($user as $value) 
		    {
				$sid .= " id = '$value' or";
			}
			$sid = " and (".rtrim($sid,'or').")";
		}
		$post = $this->input->post(NULL, TRUE);
		if($sid)  
		{
			$shop = $this->shop->find_all("code != '' and type = '270'".$sid);//获取店铺信息
			foreach ($shop as $value)
		    {
				$res = array();
				for($x=1;$x<5;$x++)
				{
				    $resi = $this->apismt->get_commoditylist($x,100,$value['code']);//获取商品列表
					if($resi)
					{
				        $res += $resi;
					}
				}
				if($res)
				{
				        $yzpid = $this->commodity->find_all('shop = '.$value['id']);
						foreach ($yzpid as $v)
		        	    {
							if($v['productid'] == '' || $v['productid'] == '0')
							{
								$this->commodity->remove($v['id']);
								continue;
							}
							if(!isset($res[$v['productid']]))
							{
								$this->commodity->save(array('type'=>'offline'),$v['id']);
							}
						}
						foreach ($res as $v)
		        	    {
						    $productid = $this->commodity->get_productid($v);
						    //if(!$productid)
							//{
								@$read = $this->apismt->get_commodityread($v,$value['code']);
								if(is_array($read))
								{
									@$cid = $this->apismt->get_commoditysku($read['cid'],$value['code']);
								}
								else
								{
									continue;
								}
								//处理结束
								if(isset($cid[0]))
								{
									// 处理 $cid
									$cc = array();
									foreach ($cid as $c)
		        	            	{
										$names = json_decode($c['names'],true);
										$cc[$c['id']] = $names['en'];
										if(!isset($c['values']))
										{
											continue;
										}
										if(isset($c['values']['aeop_attr_value_dto'][0]))
										{
									 	   foreach ($c['values']['aeop_attr_value_dto'] as $cv)
		        	                 	   {
											   if(isset($read['gg'][$cv['id']]))//如果有自定义
											   {
												   $cc[$cv['id']] = $read['gg'][$cv['id']];
											   }
											   else
											   {
											       $cnames = json_decode($cv['names'],true);
											       $cc[$cv['id']] = $cnames['en'];
											   }
									    	}
										}
										else
										{
											$cnames = json_decode($c['values']['aeop_attr_value_dto']['names'],true);
											$cc[$c['values']['aeop_attr_value_dto']['id']] = $cnames['en'];
										}
									}
									$read['title'] = ($read['title'])?$read['title']:'';
									if(!$productid)
									{
									    //处理结束
							            $this->commodity->insert(array('shop'=>$value['id'],'productid'=>$v,'title'=>$read['title'],'img'=>$read['img'],'type'=>$read['type'],'time'=>time()));
									}
									else
									{
										$this->commodity->save(array('shop'=>$value['id'],'productid'=>$read['productid'],'title'=>$read['title'],'img'=>$read['img'],'type'=>$read['type']),$productid['id']);
									}
									$this->_aeordersku($read['sku'],$value['id'],$v,$cc);
								}
						    //}
					    }
				}
				else
				{
					continue;
				}
			}
			echo json_encode(array('msg'=>'同步完成!','success'=>true));exit;
		}
	}
	public function _aeordersku($sku,$shop,$productid,$cc)
	{
		$yzsku = $this->commodityread->find_all("productid = '$productid'");
		foreach ($yzsku as $v)
		{
			$s = 0;
			if(!isset($sku[$v['skuid']]))
			{
				$skuid = explode(';',$v['skuid']);
				if(count($skuid) < 2)
				{
					$this->commodityreaddel->insert($v);
					$this->commodityread->remove($v['id']);//asd
					continue;
				}
				else
				{
					$skuidarray = $this->_qpl($skuid);
					foreach ($skuidarray as $skuv)
		            {
						if(isset($sku[$skuv]))
						{
							$this->commodityread->save(array('skuid'=>$skuv),$v['id']);
							$s++;
							break 1;
						}
					}
				}
				if($s < 1)
				{
				    $this->commodityreaddel->insert($v);
				    $this->commodityread->remove($v['id']);//asd
				}
			}
		}
		foreach ($sku as $v)
	    {
			$read = $this->commodityread->get_productid($productid,$v['skuid']);
			if(isset($read['productid']))
			{
				$cd = explode(';',$v['skuid']);$cod = '';
				foreach ($cd as $vv)
	            {
					$cv = explode(':',$vv);
					$cod .=$cc[$cv[0]].":".$cc[$cv[1]].";";
				}
				$this->commodityread->save(array('shop'=>$shop,'productid'=>$productid,'codeid'=>$cod,'skuid'=>$v['skuid'],'code'=>$v['code'],'time'=>time()),$read['id']);
			}
			else
			{
				$cd = explode(';',$v['skuid']);$cod = '';
				foreach ($cd as $vv)
	            {
					$cv = explode(':',$vv);
					$cod .=$cc[$cv[0]].":".$cc[$cv[1]].";";
				}
				$this->commodityread->insert(array('shop'=>$shop,'productid'=>$productid,'codeid'=>$cod,'skuid'=>$v['skuid'],'code'=>$v['code'],'time'=>time()));
			}
		}
	}
	
	public function _qpl($source)//全排列
	{
		$qpl = array();
		sort($source); //保证初始数组是有序的
		$last = count($source) - 1; //$source尾部元素下标
		$x = $last;
		$count = 1; //组合个数统计
		$qpl[implode(';', $source)] = implode(';', $source); //输出第一种组合
		while (true) 
		{
		    $y = $x--; //相邻的两个元素
		    if ($source[$x] < $source[$y])//如果前一个元素的值小于后一个元素的值
			{ 
		        $z = $last;
		        while ($source[$x] > $source[$z]) //从尾部开始，找到第一个大于 $x 元素的值
				{
					$z--;
				}
				/* 交换 $x 和 $z 元素的值 */
                list($source[$x], $source[$z]) = array($source[$z], $source[$x]);
                /* 将 $y 之后的元素全部逆向排列 */
                for ($i = $last; $i > $y; $i--, $y++) 
				{
					list($source[$i], $source[$y]) = array($source[$y], $source[$i]);
				}
				$qpl[implode(';', $source)] = implode(';', $source); //输出组合
				$x = $last;
				$count++;
			}
			if ($x == 0)//全部组合完毕
			{
			    break;
			}
		}
        return $qpl;
	}
	
	public function _skudelhf($a)//commodityread 同步删除的恢复
	{
		$this->db->trans_begin();
		$qbpid = array();
		$a = $this->commodityread->find_all("time > '1653613200'");
		foreach ($a as $v)
	    {
		   $qbpid[$v['productid']] = $v['productid'];
	    }
		foreach ($qbpid as $valer)
	    {
	       $del = $this->commodityreaddel->find_all("productid = '".$valer."' and sku != ''",'*','id asc');
		   if($del)
		   {
	           foreach ($del as $val)
	           {
		           $skuid = explode(';',$val['skuid']);
				   if(count($skuid) < 2)
				   {
					   continue;
				   }
		           $skuidarray = $this->_qpl($skuid);
		           $red = $this->commodityread->find_all("productid = '".$val['productid']."' and sku = ''");
		           foreach ($red as $v)
	               {
					   if(isset($skuidarray[$v['skuid']]))
			           {
						   $this->commodityread->save(array('sku'=>$val['sku']),$v['id']);
			           }
		           }
	           }
		   }
	    }
	   if ($this->db->trans_status() === TRUE)
        {
			$this->db->trans_commit();
			echo 1;
		}
		else
		{
			$this->db->trans_rollback();
			echo 2;
		}
	}
}