<?php
namespace model\pro;
use \model;
use model\fanyi;
use \model\grid\lrtree;
/**
 * Class procate
 * @package model
 */
class cate extends model
{
    public $table = 'pro_cate';
    public $key = 'id';
    public $name = LG_NAME;
    public $order = LG_NAME;
	public $lrtree = null;
	public function __construct()
    {
		parent::__construct();
        $this->options = [
			'table'=>'pro_cate',
			'id'=>'id',
			'parent_id'=>'parent_id',
			'left'=>'left',
			'right'=>'right',
			'level'=>'level',
			'ismove'=>'ismove',
			'cn_name'=>'cn_name',
			'en_name'=>'en_name',
			'py_name'=>'py_name',
			'cat_zhuyi'=>'cat_zhuyi',
			'cat_pzbz'=>'cat_pzbz',
			'cat_zpsl'=>'cat_zpsl',
			'attaqty'=>'attaqty',
			'create_time'=>'create_time',
			'update_time'=>'update_time'
		];
        $this->attaqtys = [
			
		];
		$this->attaqtys2 = [
			
		];
		$this->lrtree = new lrtree($this->options);
	}


	public function attaqtysItems()
	{
		$attaqtysitems = [':'];
		foreach($this->attaqtys as $k=>$v)
		{
			$attaqtysitems[] = $k.':'.$v;
		}
		return implode(',', $attaqtysitems);
	}

	public function attaqtys2Items()
	{
		$attaqtys2items = [':'];
		foreach($this->attaqtys2 as $k=>$v)
		{
			$attaqtys2items[] = $k.':'.$v;
		}
		return implode(',', $attaqtys2items);	
	}

    /**
     * 保存参数示意图
     * @param $data
     * @param $config
     */
    public function save($data,$config)
    {
        $fileid = $data['file_id'];
        $data['param'] = json_decode($data['param'],true);
        $id = $data['param']['id'];
        $this->db->update($this->table,['photo_param' => $fileid],['id' => $id]);
    }

	function addCate($parent_id,$data)
	{
		$this->db->Begin();
		$ruleArr = $data['rule'];
		unset($data['rule']);
	
		$id = $this->lrtree->addNode($parent_id,$data);
		$rule =	new rule();
		$rule->saveCateRuleById($id,$ruleArr);
		$this->db->End();
		return $id;
	}

	function editCate($id,$parent_id,$data)
	{
		$this->db->Begin();
		$ruleArr = $data['rule'];
		unset($data['rule']);
		$result = $this->lrtree->editNodeByChangePid($id,$parent_id,$data);
		$rule =	new rule();
		$rule->saveCateRuleById($id,$ruleArr);
		$this->db->End();
		return $result;
	}

	
	function delCate($id)
	{
		$pid = $this->db->get('pro_cate', 'id', ['parent_id'=>$id]);
		if(!empty($pid)) exitJson('此分类有子类，请先删除子类');
		
		$pid = $this->db->get('pro', 'p_id', ['p_cate'=>$id]);
		if(!empty($pid)) exitJson('此小类有产品，请先删除产品');
		
		$this->db->Begin();

		$this->lrtree->deleteNode($id);
		//参数绑定
		$this->db->delete('part_param', ['ptpa_cate_id'=>$id]);
		//参数值
		$this->db->delete('pro_param_val', ['ppv_pc_id'=>$id]);
		$this->db->End();
		return [];
	}

	/**
	  * @method 获取中国车型的位置信息
	  * @author soul
	  */
	public function getCnModelFiled($cat_id = 0, $p_id = 0)
	{
		if(!empty($p_id))
		{
			$row = $this->db->get('pro(p)',['[><]pro_cate(cat)'=>['p.p_cate'=>'id']], ['cat.id', 'cat.cat_cnpos'], ['p.p_id'=>$p_id]);
		}
		else
		{
			$row = $this->db->get('pro_cate', ['id', 'cat_cnpos'], ['id'=>$cat_id]);
		}
		$fileds = [];
		if(!empty($row['cat_cnpos']))
		{
			$row['cat_cnpos'] = json_decode($row['cat_cnpos'], true);
			if(is_array($row['cat_cnpos'])) $fileds = array_column($row['cat_cnpos'], 'name', 'filed');
		}
		return $fileds;
	}


    /**
     *  删除参数示意图
     * @param $id
     * @param $photoParam
     * @return false|\PDOStatement
     */
    public function deleteImage($id,$photoParam)
    {
        return $this->db->update($this->table,['photo_param' => ''],['id' => $id]);
    }

    public function list($where='',$page=0,$pagesize=0,$sidx='',$sord='asc',$orderby='')
    {
        if($where){
            $where = $this->filter2medoo($where);
        }
        $arr = $this->lrtree->list($where, $page, $pagesize, $sidx, $sord);
		foreach($arr['rows'] as &$row)
		{
			$row['captions']['attaqty'] = isset($this->attaqtys[$row['attaqty']])? $this->attaqtys[$row['attaqty']]: '';
			$row['captions']['cat_model_fileds'] = $this->getSmallFiledsName($row);
		}
		return $arr;
    }

	function list2($rules, $where='',$page=0,$pagesize=0,$sidx='',$sord='asc',$orderby=''){
	    $page=1;
	    $pagesize = 1000;
	    $orderby='level,parent_id,en_name';
	    
        $table = $this->table.'(c)';
        $this->fields = ['c.*'];
        $this->join = [];
		$this->joinWhere = [];
		$this->group = [];
        $where = $this->filter2medoo($where,function(&$field,&$op,&$data){
            if($field=='en_name' || $field=='cn_name'|| $field=='py_name'){
                $op = 'eq';
                $field = 'id';
                $data = $this->likeAndChilds($data,true);
				if(empty($data)) $data = 0;
            }
			if($field=='cat_model_fileds' || $field=='cat_cnpos')
			{
				if($data == 1)
				{
					$op = 'not';
					$data = '{}';
				}
				else if($data == 0)
				{
					$data = '{}';
				}
			}
			if($field == 'oe_counts'){
				$temp = [
					'eq'=>'=',
					'le'=>'<=',
					'lt'=>'<',
					'gt'=>'>',
					'ge'=>'>='
				];
				$opr = $temp[$op];
				$op = 'RAW_'.$field;
				$data = raw(sprintf("id in (SELECT `cate1`.`id` FROM`pro_cate` AS `cate1` 
				LEFT JOIN `pro_cate` AS `cate2` ON `cate1`.`id` = `cate2`.`parent_id`
				LEFT JOIN `pro_cate` AS `cate3` ON `cate2`.`id` = `cate3`.`parent_id`
				LEFT JOIN `oe_item` AS `oe` ON `cate1`.`id` = `oe`.`oe_cate_id` OR `cate2`.`id` = `oe`.`oe_cate_id` OR `cate3`.`id` = `oe`.`oe_cate_id` 
				GROUP BY  `cate1`.`id` HAVING COUNT(oe.oe_id) %s %d)",$opr,$data));
			}

			if($field == 'pro_counts'){
				$temp = [
					'eq'=>'=',
					'le'=>'<=',
					'lt'=>'<',
					'gt'=>'>',
					'ge'=>'>='
				];
				$opr = $temp[$op];
				$op = 'RAW_'.$field;
				$data = raw(sprintf("id in (SELECT `cate1`.`id` FROM`pro_cate` AS `cate1` 
				LEFT JOIN `pro_cate` AS `cate2` ON `cate1`.`id` = `cate2`.`parent_id`
				LEFT JOIN `pro_cate` AS `cate3` ON `cate2`.`id` = `cate3`.`parent_id`
				LEFT JOIN `pro` AS `p` ON `cate1`.`id` = `p`.`p_cate` OR `cate2`.`id` = `p`.`p_cate` OR `cate3`.`id` = `p`.`p_cate` 
				GROUP BY  `cate1`.`id` HAVING COUNT(p.p_id) %s %d)",$opr,$data));
			}

			
        });
		if($where==null) $where = [];
		
		
		$pwids = \p::cates($rules['pwcode']);
		if(!\p::isAdmin() && $pwids != ''){
			$where['id'] = $this->getParentIds($pwids,true);
		}
		
		if(!empty($this->joinWhere)){
			$where = array_merge($where, $this->joinWhere);
		}

		if(!empty($this->group)){
			$where = array_merge($where, $this->group);
		}
        $where = $this->listWhere($where,$page,$pagesize,$sidx,$sord,$orderby);

		if($page>0 && $pagesize>0){
            if(empty($this->join)){
                $pages = $this->paging($table,$where,$page,$pagesize);
            }else{
                $pages = $this->paging($table,$this->join,'*',$where,$page,$pagesize);
            }
			$where["LIMIT"] = [$pages['limit'],$pagesize];
		}
        if(empty($this->join)){
            $rows = $this->db->select($table,$this->fields,$where);
        }else{
            $rows = $this->db->select($table,$this->join,$this->fields,$where);
        }
		//查零件总数量
		$oeCntSql = sprintf("SELECT cate_id,SUM(product_count) AS product_count FROM (
			SELECT cate1.id AS cate_id,COUNT(oe.oe_id) AS product_count
			FROM pro_cate AS cate1
			LEFT JOIN oe_item AS oe ON cate1.id = oe.oe_cate_id
			GROUP BY cate1.id
			UNION ALL
			SELECT cate1.id AS cate_id,COUNT(oe.oe_id) AS product_count
			FROM pro_cate AS cate1
			LEFT JOIN pro_cate AS cate2 ON cate1.id = cate2.parent_id
			LEFT JOIN oe_item AS oe ON cate2.id = oe.oe_cate_id
			GROUP BY cate1.id
			UNION ALL
			SELECT cate1.id AS cate_id,COUNT(oe.oe_id) AS product_count
			FROM pro_cate AS cate1
			LEFT JOIN pro_cate AS cate2 ON cate1.id = cate2.parent_id
			LEFT JOIN pro_cate AS cate3 ON cate2.id = cate3.parent_id
			LEFT JOIN oe_item AS oe ON cate3.id = oe.oe_cate_id
			GROUP BY cate1.id) AS subquery GROUP BY cate_id ORDER BY cate_id");
		$st = $this->db->query($oeCntSql);
		$oeCntRows = $st->fetchAll();
		$oeCntRows = array_column($oeCntRows,'product_count','cate_id');
		//查商品总数量
		$proCntSql = sprintf("SELECT cate_id,SUM(product_count) AS product_count FROM (
		SELECT cate1.id AS cate_id,COUNT(p.p_id) AS product_count
		FROM pro_cate AS cate1
		LEFT JOIN pro AS p ON cate1.id = p.p_cate
		GROUP BY cate1.id
		UNION ALL
		SELECT cate1.id AS cate_id,COUNT(p.p_id) AS product_count
		FROM pro_cate AS cate1
		LEFT JOIN pro_cate AS cate2 ON cate1.id = cate2.parent_id
		LEFT JOIN pro AS p ON cate2.id = p.p_cate
		GROUP BY cate1.id
		UNION ALL
		SELECT cate1.id AS cate_id,COUNT(p.p_id) AS product_count
		FROM pro_cate AS cate1
		LEFT JOIN pro_cate AS cate2 ON cate1.id = cate2.parent_id
		LEFT JOIN pro_cate AS cate3 ON cate2.id = cate3.parent_id
		LEFT JOIN pro AS p ON cate3.id = p.p_cate
		GROUP BY cate1.id) AS subquery GROUP BY cate_id ORDER BY cate_id");

		$st = $this->db->query($proCntSql);
		$proCntRows = $st->fetchAll();
		$proCntRows = array_column($proCntRows,'product_count','cate_id');
		//查pb_id=1的编码
		$prlArr = $this->db->select('pro_rule_link',['prl_code_a','prl_val_id'],['prl_type'=>'cate','prl_pb_id'=>1]);
		$prlArr = array_column($prlArr,'prl_code_a','prl_val_id');

		$sortRows = [];
        $this->treeSortRows($rows,$sortRows);
        
        foreach($rows as $row){
            $sortRows[] = $row; //遗留
        }
		
        foreach($sortRows as $k=>&$row){
			$t = json_decode($row['cat_cnpos'], true);
			if(!is_array($t)) $t = [];
			$row['oe_counts'] = $oeCntRows[$row['id']]?:'';
			$row['pro_counts'] = $proCntRows[$row['id']]?:'';
			$row['captions']['cat_cnpos'] = implode(',', array_column($t, 'name'));
			$row['captions']['attaqty'] = isset($this->attaqtys[$row['attaqty']])? $this->attaqtys[$row['attaqty']]: '';
            //叶子节点
            if($row['right']-$row['left']==1){
                $row['leaf'] = true;
            }else{
                $row['leaf'] = false;
            }
			$row['tcd_name'] = trim($row['tcd_name'], ';');
			$row['prl_code_a'] = $prlArr[$row['id']] ?? '';
        }
		unset($row);
        
		$data = [
			'page'=> $page,
			'total'=> $pages['total'],
			'records' => $pages['records'],
			'rows' => $sortRows
		];
		return $data;
	}
	function listOppo($rules, $where='',$page=0,$pagesize=0,$sidx='',$sord='asc',$orderby=''){
	    $page=1;
	    $pagesize = 1000;
	    $orderby='level,parent_id,en_name';
	    
        $table = $this->table.'(c)';
        $this->fields = ['*'];
        $this->join['[>]oppo_pro_cate'] = ['c.id'=>'opc_id'];
		$this->joinWhere = [];
		$this->group = [];
        $where = $this->filter2medoo($where,function(&$field,&$op,&$data){
            if($field=='en_name' || $field=='cn_name' || $field=='py_name'){
                $op = 'eq';
                $field = 'id';
                $data = $this->likeAndChilds($data,true);
				if(empty($data)) $data = 0;
            }
			if($field=='cat_model_fileds' || $field=='cat_cnpos')
			{
				if($data == 1)
				{
					$op = 'not';
					$data = '{}';
				}
				else if($data == 0)
				{
					$data = '{}';
				}
			}
        });
		if($where==null) $where = [];
		if(!empty($rules['pwcode']))
		{
			$pwids = \p::cates($rules['pwcode']);
			if($pwids != ''){
				$where['id'] = $this->getParentIds($pwids,true);
			}
		}
		if(!empty($this->joinWhere)){
			$where = array_merge($where, $this->joinWhere);
		}

		if(!empty($this->group)){
			$where = array_merge($where, $this->group);
		}
        $where = $this->listWhere($where,$page,$pagesize,$sidx,$sord,$orderby);

		if($page>0 && $pagesize>0){
            if(empty($this->join)){
                $pages = $this->paging($table,$where,$page,$pagesize);
            }else{
                $pages = $this->paging($table,$this->join,'*',$where,$page,$pagesize);
            }
			$where["LIMIT"] = [$pages['limit'],$pagesize];
		}
        if(empty($this->join)){
            $rows = $this->db->select($table,$this->fields,$where);
        }else{
            $rows = $this->db->select($table,$this->join,$this->fields,$where);
        }
		//dd($this->db->last());
		
		$sortRows = [];
        $this->treeSortRows($rows,$sortRows);
        
        foreach($rows as $row){
            $sortRows[] = $row; //遗留
        }
		
        foreach($sortRows as $k=>&$row){
			$t = json_decode($row['cat_model_fileds'], true);
			if(!is_array($t)) $t = [];
			$row['captions']['cat_model_fileds'] = implode(',', $t);

			$t = json_decode($row['cat_cnpos'], true);
			if(!is_array($t)) $t = [];
			$row['captions']['cat_cnpos'] = implode(',', array_column($t, 'name'));

            //叶子节点
            if($row['right']-$row['left']==1){
                $row['leaf'] = true;
            }else{
                $row['leaf'] = false;
            }
        }
        
		$data = [
			'page'=> $page,
			'total'=> $pages['total'],
			'records' => $pages['records'],
			'rows' => $sortRows
		];
		return $data;
	}
	
	function treeSortRows(&$rows,&$sortRows,$parent=0)
	{
	    foreach($rows as $k=>$row){
	        if($row['parent_id']==$parent){
	            $sortRows[] = $row;
	            unset($rows[$k]);
	            $this->treeSortRows($rows,$sortRows,$row['id']);
	        }
	    }
	}

	/*模糊摸查名称*/
    public function like($value){
        $value = trim($value);
        $where = ['OR'=>[
                    'cn_name[~]'=>$value,
                    'en_name[~]'=>$value,
                    'keyword[~]'=>$value
                    ]
                 ];
        $rows = $this->db->select($this->table,"id",$where);
        $rows = array_unique($rows);
        if(count($rows)==1) $rows = $rows[0];
        return $rows;
    }

	/*精确查名称*/
    public function eqname($value, $pcate = '', $isend = 1){
        $value = trim($value);
        $pcate = trim($pcate);
		if(!empty($pcate))
		{
			$join = ["[>]pro_cate(pcat)" => ["cat.parent_id" => "id"]];
			$where = [
			'AND #'=>[
					'OR #1'=>[
						'pcat.cn_name'=>$pcate,
						'pcat.en_name'=>$pcate,
						'pcat.py_name'=>$pcate,
					],
					'OR #2'=>[
						'cat.cn_name'=>$value,
						'cat.en_name'=>$value,
						'cat.py_name'=>$value,
						'cat.cat_as[~]'=>','.$value.',',
						// 'tcd_name[~]'=>';'.$value.';',
					],
				]
			];
			if($isend) $where['cat.right'] = raw('`cat`.`left`+1');
			return $this->db->get('pro_cate(cat)', $join,"cat.id",$where);
		}
		else
		{
			$where = [
				'AND #'=>[
					'OR'=>[
						'cn_name'=>$value,
						'en_name'=>$value,
						'py_name'=>$value,
						'cat_as[~]'=>','.$value.',',
						// 'tcd_name[~]'=>';'.$value.';',
					]
				]
			 ];
		    if($isend) $where['right'] = raw('`left`+1');
			return $this->db->get($this->table,"id",$where);
		}
    }
	
	//仅通过TCD名称匹配品名，可能返回多个
	public function eqnameByTcd($value, $pcate = '', $isend = 1){
        $value = trim($value);
        $pcate = trim($pcate);
		if(!empty($pcate))
		{
			$join = ["[>]pro_cate(pcat)" => ["cat.parent_id" => "id"]];
			$where = [
			'AND #'=>[
					'OR #1'=>[
						'pcat.cn_name'=>$pcate,
						'pcat.en_name'=>$pcate,
						'pcat.py_name'=>$pcate,
					],
					'OR #2'=>[
						'tcd_name[~]'=>';'.$value.';',
					],
				]
			];
			if($isend) $where['cat.right'] = raw('`cat`.`left`+1');
			return $this->db->select('pro_cate(cat)', $join,"cat.id",$where);
		}
		else
		{
			$where = [
				'AND #'=>[
					'OR'=>[
						'tcd_name[~]'=>';'.$value.';',
					]
				]
			 ];
		    if($isend) $where['right'] = raw('`left`+1');
			return $this->db->select($this->table,"id",$where);
		}
    }

    public function getCate($id){
        return $this->db->get($this->table,'*', ['id'=>$id]);
    }

	/*模糊摸查别名*/
    public function likeAs($value){
        $value = trim($value);
        $where = ['as[~]'=>$value];
        $rows = $this->db->select($this->table,"id",$where);
        $rows = array_unique($rows);
        if(count($rows)==1) $rows = $rows[0];
        return $rows;
    }

	/*模糊摸查名称，并返回所有子节点*/
    public function likeAndChilds($value,$hasSelf=false){
        $value = trim($value);
        $where = ['OR'=>[
                    'cn_name[~]'=>$value,
                    'en_name[~]'=>$value,
                    'py_name[~]'=>$value,
					'sp_name[~]'=>$value,
					'al_name[~]'=>$value,
                    ]
                 ];
        $ids = $this->db->select($this->table,"id",$where);
        $ids = array_unique($ids);
		$rows=[];
		if($ids){
			if($rows = $this->db->select($this->table,"id",['OR'=>['id'=>$ids,'parent_id'=>$ids]])){
    			$rows = array_unique($rows);
			}
			if($rows && $rows = $this->db->select($this->table,"id",['OR'=>['id'=>$ids,'parent_id'=>$rows]])){
    			$rows = array_unique($rows);
			}
		}
        if(count($rows)==1) $rows = $rows[0];
        return $rows;
    }

	/*模糊摸查名称，并返回所有父节点*/
    public function getParentIds($ids,$hasSelf=false){
        if(is_string($ids)) $ids = explode(',',$ids);
        $frows = $this->db->select($this->table,['left','right'],['id'=>$ids]);
		
        $arrAnd = [];
        $opLeft  = $hasSelf ? 'left[<=]' : 'left[<]';
        $opRight = $hasSelf ? 'right[>=]' : 'right[>]';
        foreach ($frows as $fk=>$frow){
            $arrAnd['AND #'.$fk] = [$opLeft=>$frow['left'],$opRight=>$frow['right']];
        }
        $where['OR'] = $arrAnd;
        $arrIds = $this->db->select($this->table,'id',$where);
        return $arrIds;
    }


	public function searchPart($word,$isbigCate=false,$limit=10000, $pwids = '',$pcate = '')
	{
		$word = trim($word);
		$data = [];
		if($word!=''){
			$fields = ['c.id', 'c.cn_name', 'c.en_name', 'c.py_name'];
			$where['OR'] =[
				'c.keyword[~]'=>$word,
				'c.cn_name[~]'=>$word,
				'c.en_name[~]'=>$word,
				'c.py_name[~]'=>$word,
				'c.al_name[~]'=>$word
			];
			$where['LIMIT'] = $limit;
			if(!empty($pcate)){
				$where['RAW_pids'] = raw(sprintf(" c.parent_id in (select id from pro_cate where cn_name ='%s' or en_name='%s' or py_name = '%s')",$pcate,$pcate,$pcate));
			}
		    if($isbigCate){
		        $where['RAW'] = raw("c.`right`-c.`left`>1");
				if(!empty($pwids))
					$where['RAW_ids'] = raw(" c.id in (select parent_id from pro_cate where id in (".$pwids."))");
		    }else{
		        $where['RAW'] = raw("c.`right`-c.`left`=1");
				if(!empty($pwids))
					$where['c.id'] = explode(',', $pwids);
		        $fields = array_merge($fields,[
		            'big.id(pid)', 'big.cn_name(pcn_name)', 'big.en_name(pen_name)', 'big.py_name(ppy_name)'
		        ]);
    			$join = [
    				"[><]pro_cate(big)" => ["c.parent_id" => "id"]
    			];
		    }
		    if(!$join){
		        $join = $fields; $fields = $where; $where = null;
		    }
			
			$data = $this->db->select('pro_cate(c)', $join, $fields, $where);
		}else if($isbigCate){
		    $where['RAW'] = raw("`right`-`left`>1");
			if(!empty($pwids))
				$where['RAW_ids'] = raw(" id in (select parent_id from pro_cate where id in (".$pwids."))");
			$data = $this->getAll($where);
		}else{
			if(!empty($pwids))
				$where['RAW_ids'] = raw(" id in (".$pwids.")");
			if(!empty($pcate)){
				$where['RAW_pids'] = raw(sprintf(" parent_id in (select id from pro_cate where cn_name ='%s' or en_name='%s' or py_name = '%s')",$pcate,$pcate,$pcate));
			}
			$data = $this->getAll($where);
		}
		return $data;
	}

	/**
	  * @method 复制属性
	  * @param  $from_cate  int  [必填] 
	  * @param  $to_cate  string  [必填] 逗号分隔
	  * @param  $fileds  string  [必填] cat_model_fileds,cat_zhuyi...
	  * @author soul
	  */
    function copyFileds($from_cate, $to_cate, $fileds)
	{
		$canSetFiled = ['cat_model_fileds', 'cat_zhuyi', 'cat_pzbz', 'cat_zpsl'];
		$setfiles = [];
		foreach(explode(',', $fileds) as $fk)
		{
			if(in_array($fk, $canSetFiled)) $setfiles[] = $fk;
		}
		if(empty($setfiles)) exitJson('参数异常');

		$fromArr = $this->db->get('pro_cate', $setfiles, ['id'=>$from_cate]);
		if(empty($fromArr)) exitJson('数据不存在');
		$this->db->update('pro_cate', $fromArr, ['id'=>explode(',', $to_cate)]);
		return [];
    }
    
	/**
	  * @method 取二级产品线,通过指定ID
	  * @param  $ids  array 
	  */
    function getBigCatesByIds($ids=[])
	{
	    $where = [];
	    if(!empty($ids)){
	       $where['OR']['parent_id'] = $ids; 
	       $where['OR']['id'] = $ids; 
	    }
	    $where['RAW'] = raw("`right`-`left`>1");
	    
		$rows = $this->db->select('pro_cate', '*', $where);
		$data = [];
		foreach ($rows as $row){
            $hasWhere['left[>]'] = $row['left']*1;
            $hasWhere['right[<]'] = $row['right']*1;
            $hasWhere['RAW'] = raw("`right`-`left`>1");
		    if(!$this->db->has('pro_cate',$hasWhere)){
		        $data[] = $row;
		    }
		}
		return $data;
    }
    
	/**
	  * @method 取二级产品线,通过小类
	  * @param  $cates  array 
	  */
    function getBigCatesByCates($cates)
	{
        $where['id'] = $cates; 
		$rows = $this->db->select('pro_cate', ['parent_id'], $where);
		$parent_ids = [];
		foreach ($rows as $row){
            $parent_ids[] = $row['parent_id'];
		}
		return $this->db->select('pro_cate', '*', ['id'=>$parent_ids]);
    }
    
	/**
	  * @method 通过产品线,取所有小类
	  * @param  $cates  array 
	  */
    function getCatesByBigCates($ids)
	{
		return $this->db->select('pro_cate', ['id','cn_name','en_name','py_name'], ['parent_id'=>$ids]);
    }

	//获取小类的竞品统计信息
	function cleanGaTj($cat_id)
	{
		$data = [];
		$row = $this->db->get('pro_cate', ['id','cn_name','en_name','py_name', 'tcd_name'], ['id'=>$cat_id]);
		if(!empty($row))
		$names = [];
		if(!empty($row['tcd_name'])){
			$names[] = $row['tcd_name'];
		}else{
			if(!empty($row['cn_name'])) $names[] = $row['cn_name'];
			if(!empty($row['en_name'])) $names[] = $row['en_name'];
			if(!empty($row['py_name'])) $names[] = $row['py_name'];
		}
		if(!empty($names)){
			$ypApi = new \model\ypApi();
			$res = $ypApi->Get('tcd/cleanGaTj', ['ganame'=>implode(';', $names)]);
			$data = $res['data'];
		}
		return $data;
	}

	function canMoveSubtree($id,$parent_id,$limitLevel=3)
	{
		if(!$id && !$parent_id) return ['status'=>true,'msg'=>''];
		$maxLevel =0;
		if(!$id){
			$curNode['level'] =0;
		}else{
			
			// 获取子树的当前层级
			$curNode = $this->db->get('pro_cate','*',['id'=>$id]);
			$left = $curNode['left']*1;
			$right = $curNode['right']*1;
			$oldparent = $curNode['parent_id']*1;
			if ($oldparent == $parent_id) {
				return ['status' => true, 'msg' => ''];
			}
			// 计算子树的最大层级
			$maxLevel =$this->db->max('pro_cate','level',[
				'left'."[>=]" => $left,
				'right'."[<=]" => $right,
			]);
		}
		
		$newParent = $this->db->get('pro_cate','*',['id'=>$parent_id]);
		// 检查新层级是否超过3级
		$newMaxLevel = $newParent['level'] + ($maxLevel - $curNode['level']) + 1;
		if ($newMaxLevel > $limitLevel) {
			return ['status'=>false,'msg'=>'系统只支持'.$limitLevel.'级小类，请选择另一个小类来添加'];
		}
	
		return ['status'=>true,'msg'=>''];
	}

	/**
	 * @param  int $cat_id
	 * @param  Array $param
	 * @method 将参数转换到参数表
	 * @author zhengweihua 
	 * @copyright 2025-01-08
	 */
	function formatParam($cat_id,$param)
	{	
		$rows = $this->db->select('part_param', ['ptpa_id','cn_name','en_name','py_name','tcd_name', 'ptpa_type','ptpa_unit','ptpa_decimal'], ['ptpa_cate_id'=>$cat_id]);
		$array = array_column($rows, null, 'cn_name');
		$fanyi = new fanyi();
		$this->db->Begin();
		foreach ($param as $key => $val) {
			if(!isset($array[$val['cn_name']])){
				$type = !$val['unit']?'string':'double';
				$py_name = $fanyi->translate($val['cn_name'],'zh','ru');
				$addData = [
					'ptpa_cate_id'           => $cat_id,
					'cn_name'         => trim($val['cn_name']),
					'en_name'         => trim($val['name']),
					'py_name'         => $py_name['dst']?trim($py_name['dst']):trim($val['name']),
					'tcd_name'         => trim($val['cn_name']),
					'ptpa_type'            => $type,
					'ptpa_length'          => 50,
					'ptpa_decimal'         => $type == 'double'?2:0,
					'ptpa_unit'            => trim($val['unit']) ?: '',
					'ptpa_is_edit'         => 1,
					'update_time'          => date('Y-m-d H:i:s'),
					'create_time'          => date('Y-m-d H:i:s'),
				];
				$this->db->insert('part_param', $addData);
			}elseif (isset($array[$val['cn_name']])) {
				$tcdNameArr = explode(';',$array[$val['cn_name']]['tcd_name']);
				$tcdNameArr = array_filter($tcdNameArr);
				if(!in_array($val['cn_name'],$tcdNameArr)){
					$tcdNameArr[] = $val['cn_name'];
					$this->db->update('part_param', ['tcd_name' => implode(';',$tcdNameArr)], ['ptpa_id' => $array[$val['cn_name']]['ptpa_id']]);
				}
			}
		}
		$this->db->End();
		return [];
	}


	function getCatesByCfg($cfg)
	{	
		$where = [$cfg['field'].'[!]'=>0];
		if($cfg['condition']){
			$where = array_merge($where, $cfg['condition']);
		}
		$rows = $this->db->select($cfg['table'],$cfg['field'],$where);
		return array_unique($rows);
	}

	 // 返回所有类型id
	function getAllIds()
	{
		$rows = $this->db->select('pro_cate','id',[]);
		return $rows;
	}
}