<?php

namespace admin\action;


use model\element;
use model\oe;
use model\pro\packing;
use \model\pro\pro;
use \model\pro\photo;
use \model\pro\master;
use model\pro\param;
use model\pro\synProPic;
use model\rcaApi;
use model\ypApi;
use model\ypRcaApi;
use model\pro\picTpl;
use model\import\uploadProPicZip;


class proAction  extends \action
{
    public $pro = null;

	public function __construct()
    {
		$this->pro = new pro();
	}


	function getSetstate()
	{
		foreach(\mvc::$cfg['PROSTATUS'] as $k=>$v){
			$data[] = ['key'=>$k, 'value'=>$v];
		}
		$this->successJson($data);
	}


	function total()
	{
		$this->successJson($this->pro->total());
	}

	function totalCommon($states)
	{
		$this->successJson($this->pro->totalCommon($states));
	}

    public function listView()
    {
		// dd('开发中');
        $req = \mvc::$req;
        if(!isset($req['from']))  $req['from'] = 'pro';
		$carmodel = new \model\carmodel();
		$pack = new \model\pro\packing();
		\view::set('proExpModelfields', $carmodel->proExpModelfields);
		\view::set('packFileds',[]);
		\view::set('from',$req['from']);
        \view::put('pro/list');
    }
    
    public function list()
    {
        $req = \mvc::$req;
		//前置条件
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
		if(isset($req['keys'])){
			$rules['keys'] = explode(',',$req['keys']);
		}
		if(isset($rules['findNulls']) && $rules['findNulls']){
			$rules['findNulls'] = json_decode(base64_decode($rules['findNulls']),true);
		}
		if(isset($req['coutype'])) $rules['coutype'] = $req['coutype'];
        $data = $this->pro->list($rules,$req['filters'], $req['page'], $req['rows'], $req['sidx'], $req['sord'],'p_comnum');
        $this->successJson($data);
    }
    
    //
    public function exportMQ(){
        error_reporting(E_ALL& ~E_NOTICE);
        set_time_limit(0);
        $mq = makeOne(\lib\mqRabbitMQ::class,'exportMQ',\mvc::$cfg['exportMQ']);
        echo "exportMQ runing.\r\n";
        $mq->receive(function($talk,$queue){
            sleep(1);
            $data = json_decode($talk->getBody(),true);
            $export = new \model\pro\export2();
            try {
                $queue->ack($talk->getDeliveryTag());
                if($export->export($data['msgId'],$data['count'],$data['filename'],$data['username'],$data['lgtag'],$data['type'],$data['options'],$data['rules'],$data['sql'],$data['pagesize'])){
                    //$queue->ack($talk->getDeliveryTag());
                }
            } catch (\Exception $e ) {
                makeOne(\model\message::class)->update($data['msgId'],['amsg_body'=>lg('失败').': '.$e->getMessage()]);
                //$queue->ack($talk->getDeliveryTag());
            }
            unset($export);
            return true;
        });
        echo "exportMQ exit.\r\n";
    }
    //监听队列
    public function export2($type,$options,$req)
    {
        ignore_user_abort(true);
		ini_set('memory_limit', \mvc::$cfg['export_memory_limit']);
		set_time_limit(\mvc::$cfg['export_time_limit']);
        //type:xlsx|xlsxzip|imgxlsx|imgzip
        $options = json_decode(base64_decode($options),true);
        parse_str(html_entity_decode($req), $req);
		//前置条件
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
			$options['numbers'] = $req['numbers'];
		}
		if(isset($req['keys'])){
			$rules['keys'] = explode(',',$req['keys']);
		}
        $pagesize = \p::fieldval('1100','export_limit');
        if(\p::isAdmin()) $pagesize = 2147483647;
        if($options['model']['hasmodel']){
            if($options['model']['modelCel']=='one'){
                $rules['modelsOne'] = 1;
            }else if($options['model']['modelCel']=='more'){
                $rules['modelsAll'] = 1;
            }else{
                $rules['modelsRows'] = 1;
            }
        }
        if(empty($pagesize)) $pagesize = \mvc::$cfg['export_record_limit'];
        if($options['oe']['qty']>200) $options['oe']['qty'] = 200;
        $options['fac'] = ($options['fac']!='') ? explode(',',$options['fac']) : [];
        
		$rules['getSQL'] = true;
        $sql = $this->pro->list($rules,$req['filters'], 1, $pagesize, '', '','p_cate,p_comnum');
        $sql = preg_replace('/ORDER(.*)/','',$sql);
        $sql = preg_replace('/SELECT(.*)FROM/','SELECT p.p_id,p_cate,p_pic,p_innum,p_comnum,p_state_main,p_sales_qty,p_vio FROM',$sql);
        $sql = str_replace('"','`',$sql);
        $sql = "SELECT * FROM (".$sql.") proAction GROUP BY p_id";
        
        $filename = date('ymdHis');
        $msg = [
        	'amsg_title'=> lg('自由导出').','.lg('序号').': '.$filename,
        	'amsg_body'=> lg('排队中'),
        	'amsg_send_mail'=>0,
			'amsg_send_sms'=> 0
        ];
        $msgId = makeOne(\model\message::class)->send([getOpuser()],$msg);
        $export = makeOne(\model\pro\export2::class);
        $count = $export->count($sql);
        $backJson = ['mq'=>false];
        $newRules['models'] = $rules['models'];
        $newRules['modelFields'] = $rules['modelFields'];
        $newRules['modelDisplayFields'] = $rules['modelDisplayFields'];
        $newRules['modelPos'] = $options['modelPos'];
        if($count>2000){
            //加入队列
            if($msgId){
                $mq = makeOne(\lib\mqRabbitMQ::class,'exportMQ',\mvc::$cfg['exportMQ']);
                $mq->send(json_encode([
                    'msgId'=>$msgId,
                    'count'=>$count,
                    'filename'=>$filename,
                    'username'=>getOpuser(),
                    'lgtag'=>cateName(),
                    'type'=>$type,
                    'options'=>$options,
                    'rules'=>$newRules,
                    'sql'=>$sql,
                    'pagesize'=>$pagesize
                ]));
            }
            $mq->close();
            $backJson = ['mq'=>true];
            (new \model\user)->toLog('导出','自由导出(队列)'.', 共 '. $count . '条, '.$sql,$count);
        }else{
            $export->export($msgId,$count,$filename,getOpuser(),cateName(),$type,$options,$newRules,$sql,$pagesize);
            (new \model\user)->toLog('导出','自由导出'.', 共 '. $count . '条, '.$sql,$count);
        }
        $this->successJson($backJson);
    }
    
    public function export($type,$options,$req)
    {
		ini_set('memory_limit', \mvc::$cfg['export_memory_limit']);
		set_time_limit(\mvc::$cfg['export_time_limit']);
        //type:xlsx|xlsxzip|imgxlsx|imgzip
        $options = json_decode(base64_decode($options),true);
        parse_str(html_entity_decode($req), $req);
		//前置条件
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
			$options['numbers'] = $req['numbers'];
		}
		if(isset($req['keys'])){
			$rules['keys'] = explode(',',$req['keys']);
		}
        $pagesize = \p::fieldval('1100','export_limit');
        if(\p::isAdmin()) $pagesize = 2147483647;
        if($options['model']['hasmodel']){
            if($options['model']['modelCel']=='one'){
                $rules['modelsOne'] = 1;
            }else if($options['model']['modelCel']=='more'){
                $rules['modelsAll'] = 1;
            }else{
                $rules['modelsRows'] = 1;
            }
        }
        //dd($rules);
        if(empty($pagesize)) $pagesize = \mvc::$cfg['export_record_limit'];
        $data = $this->pro->list($rules,$req['filters'], 1, $pagesize, '', '','p_cate,p_comnum');
        //dd($data);
        if(empty($data['rows'])) exit(lg('无数据'));
        
        if($options['oe']['qty']>200) $options['oe']['qty'] = 200;
        $options['fac'] = ($options['fac']!='') ? explode(',',$options['fac']) : [];
        (new \model\user)->toLog('导出','自由导出(1)'.', 共 '. count($data['rows']) . '条, ');
        $export = makeOne(\model\pro\export::class,$options,$data['rows']);
        if($type=='xlsx'){
            $export->imgxlsx($options,false);
        }else if($type=='xlsxzip'){
            $export->zip($options);
        }else if($type=='imgxlsx'){
            $export->imgxlsx($options,true);
        }else if($type=='imgzip'){
            $export->imgzip($options);
        }
    }


	/**
	  * @method 编码库
	  * @author soul
	  */
	public function exportState($url,$query,$fields,$keyField,$keys,$searchoptions,$pwcode='',$page=1,$pagesize=2147483647,$callback=null)
	{
		ini_set('memory_limit', \mvc::$cfg['export_memory_limit']);
		set_time_limit(\mvc::$cfg['export_time_limit']);
		$bigDataPageSize = 65535;
		$excelType = 'binary'; //binary | xml ,默认 binary
		
		$dir = str_replace('\\','/',__DIR__);
		preg_match('/(\w+)\/action/i',str_replace('\\','/',__DIR__),$m);
		$path_info = '/'. explode($m[1].'/',$url)[1];
		
        $fields = html_entity_decode($fields);
        $arr1 = explode(',',$fields);
        $fields = [];
        foreach($arr1 as $k=>$v){
            $arr2 = explode('=>',$v);
            $fields[$arr2[0]] = $arr2[1];
        }
        parse_str(html_entity_decode($query), $post);
        /*
        if(!\p::isAdmin() && !in_array($url,\mvc::$cfg['export_record_max_urls'])){
           $pagesize = \mvc::$cfg['export_record_limit'];
            if($pwcode!=''){
                $pagesize = \p::fieldval($pwcode,'export_limit');
            }
        }
        if(empty($pagesize)) $pagesize = \mvc::$cfg['export_record_limit'];*/
        $post['page'] = 1;
        $post['rows'] = $pagesize;
        list($class,$method,$uri_params,$req,$reqUriValues) = \mvc::parseurl($path_info);
		if($req){
		    foreach ($req as $k=>$v){
		        $post[$k] = $v;
		    }
		}
		\mvc::$req = [];
		if(strpos($url,'?')){
		    parse_str(html_entity_decode(explode('?',$url)[1]), \mvc::$req);
		}
		$_hasJsonFields = [];
        if(!empty($post['_hasJsonFields'])){
    		$_hasJsonFields = explode(',',$post['_hasJsonFields']);
        }
	    foreach ($post as $k=>$v){
	        if(in_array($k,$_hasJsonFields)) $v = json_decode(urldecode(base64_decode($v)), true);
	        \mvc::$req[$k] = $v;
	    }	
	    
        $req = \mvc::$req;
		//前置条件
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
		if(isset($req['keys'])){
			$rules['keys'] = explode(',',$req['keys']);
		}
		if(isset($rules['findNulls']) && $rules['findNulls']){
			$rules['findNulls'] = json_decode(base64_decode($rules['findNulls']),true);
		}
		$rules['getDoneSQL'] = true;
        $sql = $this->pro->list($rules,$req['filters'], $req['page'], $req['rows'], $req['sidx'], $req['sord'],'p_comnum');
        $fields = "p.*";
        /*
        $fields .= ",   (
                        select 
                          mpro.`p_comnum` 
                        from 
                          p_code 
                          JOIN pro mpro ON pc_merge_p_id = mpro.`p_id` 
                        where 
                          pc_p_id = p.p_id 
                        limit 
                          1
                      ) AS `merge_outnum`";
        $fields .= ",   (
                        select 
                          mpro.`p_innum` 
                        from 
                          p_code 
                          JOIN pro mpro ON pc_merge_p_id = mpro.`p_id` 
                        where 
                          pc_p_id = p.p_id 
                        limit 
                          1
                      ) AS `merge_innum`";
        */
	    $join = "\r\n ";
	    $sql = preg_replace('/SELECT\s.*\s+FROM/is',"SELECT ".$fields." FROM",$sql);
	    //$sql = preg_replace('/\sAS\s`p`(.*)\sWHERE/is','AS `p` "\\1"'.$join." WHERE",$sql);
	    $pro = new \model\pro\pro();
	    $db = $pro->getDb();
        //$rows  = $db->query($sql)->fetchAll(\PDO::FETCH_ASSOC);
        $data = [];
        
        $cateRows = $db->select('pro_cate',['id'=>['parent_id',cateName()]]);
        $tRows = $db->query("SELECT from_id,pc_p_id to_id,pc_outnum,pc_innum FROM p_code
JOIN (SELECT pc_p_id from_id,pc_merge_p_id FROM p_code WHERE pc_merge_p_id>0) t1 ON t1.pc_merge_p_id = pc_p_id
WHERE pc_p_id>0")->fetchAll(\PDO::FETCH_ASSOC);
        $mergeRows = [];                        
        foreach($tRows as $tRow){
            $mergeRows[$tRow['from_id']] = $tRow;
        }       
        unset($tRows);
        $header = [
            lg('主状态'),
            lg('产品线'),
            lg('小类')
        ];

        if(\p::fieldhas('1D00','outnum')) $header[] = lg('FREAY型号');
        if(\p::fieldhas('1D00','innum')) $header[] = lg('内部编码');
        if(\p::fieldhas('1D00','merge_outnum')) $header[] = lg('合并后型号');
        if(\p::fieldhas('1D00','merge_innum')) $header[] = lg('合并后内部编码');
        
        $cacheDir = \mvc::$cfg['dir']['cache'].'/'.date('Ym');
	    mkdirs($cacheDir);
        $tempfile = $cacheDir.'/'.getOpuser().guid().'.xlsx';
        include(\mvc::$cfg['mvcDir'].'/lib/excel/excelInterface.php');
        include(\mvc::$cfg['mvcDir'].'/lib/excel/excel.php');
        include(\mvc::$cfg['mvcDir'].'/lib/excel/excelBase.php');
        include(\mvc::$cfg['mvcDir'].'/lib/excel/excelXlsx.php');
        
        $excel = new \lib\excel\excel('xlsx');
        $excel->setDirFile($tempfile);
        //$excel = new \lib\exportXlsxDll($cacheDir,$tempfile);
        $excel->header();
        $excel->bookBegin();
        $excel->sheetBegin(lg('基本资料'),$header);
        
        //foreach($rows as $k=>$row){
        
        $db->useBuff(false);
        $res = $db->query($sql);
        while($row = $res->fetch(\PDO::FETCH_ASSOC)){
            //$row = $pro->formatRow($row);
            $pid = $row['p_id'];
            if(isset($cateRows[$row['p_cate']])){
                $cateName = $cateRows[$row['p_cate']][cateName()];
                $bigCateName = $cateRows[$cateRows[$row['p_cate']]['parent_id']][cateName()];
            }else{
                $cateName = '';
                $bigCateName = '';
            }
            if($mergeRows[$pid]){
                $row['merge_outnum'] = $mergeRows[$pid]['pc_outnum'];
                $row['merge_innum'] = $mergeRows[$pid]['pc_innum'];
            }
            $item = [
                'p_state_main'=>$row['p_state_main'],
                //'p_bigcate'=>$row['langs']['p_bigcate'][LG],
                //'p_cate'=>$row['langs']['p_cate'][LG],
                'p_bigcate'=>$bigCateName,
                'p_cate'=>$cateName
            ];
            if(\p::fieldhas('1D00','outnum')) $item['p_comnum'] =$row['p_comnum'];
            if(\p::fieldhas('1D00','innum')) $item['p_innum'] =$row['p_innum'];
            if(\p::fieldhas('1D00','merge_outnum')) $item['merge_outnum'] =$row['merge_outnum'];
            if(\p::fieldhas('1D00','merge_innum')) $item['merge_innum'] =$row['merge_innum'];
            
            $excel->append($item);
    	    unset($rows[$k]);
        }
        $excel->sheetEnd();
        $excel->bookEnd();
	    //readfile($tempfile);
        //ob_end_flush();
        //unlink($tempfile);
        //exit();
	}

	public function codeList()
	{	
		$req = \mvc::$req;
		\view::set('allPos',$this->pro->allPos);
		\view::put();
	}
	/**
	  * @method 编码库
	  * @author soul
	  */
	public function getCodeList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		if($req['coutype']) $rules['coutype'] = $req['coutype'];
		if(isset($req['numbers'])){
			$rules['numbers'] = arryNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
		if(isset($rules['findNulls']) && $rules['findNulls']){
			$rules['findNulls'] = json_decode(base64_decode($rules['findNulls']),true);
		}
        $data = $this->pro->getCodeList($req, $rules);
        $this->successJson($data);
	}

	/**
	  * @method 编辑编码库
	  * @param  id  int  [必填] pn_id
	  * @param  field  string  [必填] 字段
	  * @author soul
	  */
	public function setCodeCell()
	{
		$req = \mvc::$req;
		$result = '';
		if(!empty($req['id']) && preg_match('/^\d+$/', $req['id']))
		{
			$setArr = [
				$req['field']=>$req[$req['field']]
			];
			$result = $this->pro->setCodeCell($req['id'], $setArr);
		}
		echo $result;
	}

	public function setCnNosale()
	{
		$req = \mvc::$req;
		$data = $this->pro->setCnNosale($req['ids'], $req['val']);
		$this->successJson($data);
	}

	public function setCodeCate()
	{
		$req = \mvc::$req;
		$data = $this->pro->setCodeCate($req['ids'], $req['pc_cate']);
		$this->successJson($data);
	}

	/**
	  * @method 删除编码库
	  * @param  ids  string  [必填] pc_id  多个逗号分隔
	  * @author soul
	  */
	public function delCode()
	{
		$req = \mvc::$req;
		$data = $this->pro->delCode(explode(',', $req['ids']));
		$this->successJson($data);
	}

	/**
	  * @method 变更主状态
	  * @param  ids  string  [必填] pc_id  多个逗号分隔
	  * @author soul
	  */
	public function changeStateMain()
	{
		$req = \mvc::$req;
		$data = $this->pro->changeStateMain(explode(',', $req['ids']), $req);
		$this->successJson($data);
	}


	/**
	  * @method 生成编码
	  * @param  ids  string  [必填] pc_id  多个逗号分隔
	  * @author soul
	  */
	public function buildCode()
	{
		$req = \mvc::$req;
		$data = $this->pro->buildCode(explode(',', $req['ids']), $req['auto'], $req['pcr_id']);
		$this->successJson($data);
	}


	/**
	  * @method 审核编码
	  * @param  ids  string  [必填] pc_id  多个逗号分隔
	  * @author soul
	  */
	public function checkCode()
	{
		$req = \mvc::$req;
		$data = $this->pro->checkCode(explode(',', $req['ids']));
		$this->successJson($data);
	}



	//取附件
    public function attaqtyList()
    {
        $req = \mvc::$req;
		//前置条件
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
        $data = $this->pro->list($rules,$req['filters'], $req['page'], $req['rows'], $req['sidx'], $req['sord'],'p_comnum');
		if(!empty($data)){
			foreach($data['rows'] as &$row){
				$attaRow = $this->pro->getAttaqtyByPid($row['p_id']);
				if(!empty($attaRow)){
					foreach($attaRow as $field=>$value){
						$regi = substr($field,strrpos($field, '_')+1);
						if($regi!='' && is_numeric($regi)){
							$row['pa_'.$regi] = $value;
						}
					}
				}//$data['rows']
			}
		}
        $this->successJson($data);
    }

    public function detail($p_id,$outnum='')
    {
        if($p_id){
            $item = $this->pro->getRowByKey($p_id);
        }else if($outnum){
            $item = $this->pro->getRowByFieldValue('p_comnum_format',formatNum($outnum));
            $p_id = $item['p_id'];
        }
		
        \view::set('item',$item);
		\view::put('pro/detail');
    }

    public function getNumberByPid($num)
    {
        $num = $this->pro->getPidByNumber($num);
        $this->successJson($num);
    }

    public function getPidByNumber($num)
    {
        $pid = $this->pro->getPidByNumber($num);
        $this->successJson(['pid'=>$pid]);
    }

    public function getRowByNumber($num)
    {
        $pid = $this->pro->getPidByNumber($num);
		if($pid){
			$data = $this->pro->getRowByKey($pid);
			if(!empty($data))
				$this->successJson($this->pro->formatRow($data));
		}
		$this->successJson(0);
    }

	public function chkProIdByAny()
	{
		$this->successJson($this->pro->chkProIdByAny(\mvc::$req));
	}

    public function base($p_id)
    {
		$req = \mvc::$req;
		$item = $this->pro->getDetail($p_id);
        \view::set('item',$item);
		\view::set('allPos', $this->pro->allPos);
		\view::set('req',$req);
		\view::put('pro/base/form');
    }

    public function pic($p_id)
    {
        $item = $this->pro->formatRow($p_id);
        \view::set('item',$item);
		\view::put('pro/pic');
    }

    public function pack()
    {
		$req = \mvc::$req;
		$p_id = $req['p_id'];
		$area = $req['area'];
        $pack = new packing();
		$packArea = $pack->getProPackArea($p_id);
		if(empty($area)) $area = $packArea[0]['id'];
        $item = $pack->getProPackOld($p_id, $area);

        \view::set('item',$item);
        \view::set('p_id',$p_id);
        \view::set('area',$area);
        \view::set('hasArea',$hasArea);
        \view::set('packArea', $packArea);
        \view::set('packFileds',$pack->packFileds);

		\view::put('pro/pack');
    }

    public function getPackFiledAndArea()
    {
		$req = \mvc::$req;
        $pack = new packing();
		$data = ['packFileds'=>$pack->packFileds, 'packArea'=>$pack->packArea];
		$this->successJson($data);
    }
    
    public function bom($p_id)
    {
        $proRow = $this->pro->getRowByKey($p_id);
        \view::set('proRow',$proRow);
		\view::put('pro/bom');
    }
    
    public function order()
    {
		\view::put();
    }
    
    public function base_order($p_id)
    {
        $proRow = $this->pro->getRowByKey($p_id);
        \view::set('proRow',$proRow);
		\view::put();
    }
    
    public function base_sample($p_id)
    {
        if(empty($p_id)){
		    exitJson(lg('参数错误'));
		}else{
            $proRow = $this->pro->getRowByKey($p_id);
            \view::set('proRow',$proRow);
    		\view::put();
		}
    }
    
    public function getOrder()
    {
        $req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
        $data = (makeOne(\model\bi\bi::class))->getOrder($rules,$req['filters'], $req['page'], $req['rows'], $req['sidx'], $req['sord']);
		$this->successJson($data);
    }

	public function saveBase()
	{
		$req = \mvc::$req;
        $key = $req['p_id'];
		$result = $this->pro->saveCodeBase($key,$req);
		$this->successJson($result);
	}

    public function baseEdit()
    {
        $req = \mvc::$req;
        $key = $req['p_id'];
        $link_tags = $req['link_tags'];
        unset($req['link_tags']);
        if($key==0){
            $result = $this->pro->baseAdd($req,$link_tags);
        }else{
            $result = $this->pro->baseEdit($key,$req,$link_tags);
        }
        $this->successJson($result);
    }

	//取父零件
    public function getFather($p_id)
    {
        $data = $this->pro->getFather($p_id);
        $this->successJson($data);
    }

	//取子零件
    public function getSon($p_id)
    {
        $data = $this->pro->getSon($p_id);
        $this->successJson($data);
    }

	//添加父零件
    public function addFather($p_id,$father_p_id)
    {
		if($p_id == $father_p_id){
			$this->msgJson(lg('自己不能添加自己'));
		}
		if($this->pro->hasSon($p_id,$father_p_id)){
			$this->msgJson(lg('执行失败, 此型号已存在于子零件中'));
		}
		$data = [
			'pf_father_pid' => $father_p_id,
			'pf_son_pid' => $p_id,
		];
        $this->pro->addFatherSon($data);
        $this->successJson(lg('执行成功'));
    }

	//添加子零件
    public function addSon($p_id,$son_p_id)
    {
		if($p_id == $son_p_id){
			$this->msgJson(lg('自己不能添加自己'));
		}
		if($this->pro->hasFather($p_id,$son_p_id)){
			$this->msgJson(lg('执行失败, 此型号已存在于父零件中'));
		}
		$data = [
			'pf_father_pid' => $p_id,
			'pf_son_pid' => $son_p_id,
		];
        $this->pro->addFatherSon($data);
        $this->successJson(lg('执行成功'));
    }

	//删父或子零件
    public function deleteSon($p_id)
    {
        $data = $this->pro->deleteSon($p_id,\mvc::$req['ids']);
        $this->successJson($data);
    }

    //编码测试
    public function testProCodeCreate($plmseq,$innum)
    {
        $codeRule = new \model\pro\codeRule();
        $data = $codeRule->createCode($plmseq,$innum);
        $this->successJson($data);
    }



	/**
	 * 通过属性集合住创建产品CODE
	 * @param  s_cate  int  [必填] 小类
	 * @param  s_procode_ext  string  [必填] 扩展类型
	 * @param  s_usa_make  string  [选填] 大品牌
	 * @param  s_procode_a  string  [选填]
	 * @param  s_procode_b  string  [选填]
	 * @param  s_procode_c  string  [选填]
	 * @param  innum string [必填] 内部编码
	 * @author soul
	 */
	public function createCodeByValues()
    {
		$req = \mvc::$req;
        $codeRule = new \model\pro\codeRule();
        $data = $codeRule->createCodeByValues($req,$req['innum']);
		$this->successJson($data);
    }



    public function editCell()
    {
		$req = \mvc::$req;
        $id = $req['id'];
        $oper = $req['oper'];
        $field = $req['field'];
		if(isset($req['value']))
			$value = $req['value'];
 		else
			$value = $req[$field];
        if($oper=='edit'){
            $result = $this->pro->setValue($id,$field,$value);
        }
    }

    public function editCellAttaqty()
    {
		$req = \mvc::$req;
        $id = $req['id'];
        $oper = $req['oper'];
        $field = $req['field'];
		if(isset($req['value']))
			$value = $req['value'];
 		else
			$value = $req[$field];
        if($oper=='edit'){
            $result = $this->pro->setAttaqty($id,$field,$value);
        }
    }



	/**
	  * @method 新增产品
	  * @param  p_cate  int  [必填] 小类
	  * @param  p_innum  string  [必填] 内部编码
	  * @param  nums  array  [必填] 自动生成的编码
	  * @author soul
	  */
	public function addNewProduct()
	{
		$req = \mvc::$req;
		$autonums = [];
		foreach($req['nums'] as $fac=>$nv)
		{
			if($fac == 'OUTNUM'){
				$row = json_decode($nv['old'], true);
				$row['num'] = $nv['num'];
				$autonums[$fac] = $row;
			}else{
				foreach($nv as $nkk=>$nvv)
				{
					$row = json_decode($nvv['old'], true);
					$row['num'] = $nvv['num'];
					$autonums[$fac][] = $row;
				}
			}
		}
		$baseArr = [
			'p_cate'=>$req['p_cate'],
			'p_innum'=>$req['p_innum']
		];
		$othArr = [
			'autonums'=>$autonums
		];
		$data = $this->pro->addProductBySelf($baseArr, $othArr);
		$this->successJson($data);
	}

	/**
	  * @method 号码自动完成
	  * @param  type string  [选填] outnum[默认] innum  oth:非gsp品牌号  all:不限制
	  * @param  num string  [必填] 号码
	  * @author soul
	  */
	public function autocomNum()
	{
		$req = \mvc::$req;
		$data = $this->pro->autocomNum($req);
		$this->successJson($data);
	}

	
	public function autoCate()
	{
		$req = \mvc::$req;
		$data = $this->pro->autoCate($req);
		$this->successJson($data);
	}

	
	/**
	  * @method 导入中心
	  */
	  public function import()
	  {
		  \view::put();
	  }

	
	/**
	  * @method 产品比较
	  * @param  pids string  [选填] 产品ID，逗号分隔
	  * @param  nums string  [选填] FREAY型号，逗号分隔
	  * @author soul
	  */
	public function compare()
	{
		$req = \mvc::$req;
		$maxItem = 20;
		$req['maxItem'] = $maxItem;
		if(!empty($req['pids']))
		{
			$pids = [];
			foreach(explode(',', $req['pids']) as $k=>$v)
			{
				$t = explode('-', $v);
				$pids[] = (int) $t[0];
			}
			$req['pids'] = implode(',', $pids);
		}
		$dataArr = $this->pro->getCompare($req);

		list($numUnikeyArr,$numCount)= $this->compareData($dataArr['items'],'nums');
		list($cnModelsUnikeyArr,$cnModelsCount) = $this->compareData($dataArr['items'],'cnmodels');
		list($modelsUnikeyArr,$modelsCount)  = $this->compareData($dataArr['items'],'models');
	
		\view::set('itemCount', count($dataArr['items']));
		\view::set('numCount', $numCount);
		\view::set('cnModelsCount', $cnModelsCount);
		\view::set('modelsCount', $modelsCount);
		\view::set('numUnikeyArr', $numUnikeyArr);
		\view::set('cnModelsUnikeyArr', $cnModelsUnikeyArr);
		\view::set('modelsUnikeyArr', $modelsUnikeyArr);
		\view::set('ip_test_edi_runtime', gethostbyname("test.edi-runtime.jdl.cn")); //test.edi-runtime.jdl.cn
		\view::set('ip_edi_runtime', gethostbyname("edi-runtime.jdl.cn")); //test.edi-runtime.jdl.cn
		\view::set('maxItem', $maxItem);
		\view::set('maxInput', 6);
		\view::set('nums', $req['nums']);
		\view::set('itemArr', $dataArr['items']);
		\view::set('paraArr', $dataArr['para']);
		\view::set('dataArr', $dataArr);
		\view::set('req', $req);
		\view::put();
	}

	protected function compareData($dataArr,$type)
	{
		if(!in_array($type,['nums','models','cnmodels'])) return [];
		$hasCount = 0;
		$unikeyArr = [];
		foreach($dataArr as $k=>$v){
			if(!empty($v[$type])){
				$hasCount++;
				foreach($v[$type] as $kk=> $vv){
					$unikeyArr[$vv['unikey']]['keys'][$k] = $kk;
					$unikeyArr[$vv['unikey']]['count']++;
					$unikeyArr[$vv['unikey']]['unikey'] = $vv['unikey'];
				}
				unset($vv);
			}
		}
		if($unikeyArr){
			$sort = [];
			foreach($unikeyArr as $k=>$v){
				$sort['count'][$k] = $v['count'];
				$sort['unikey'][$k] = $v['unikey'];
			}
			array_multisort($sort['count'], SORT_DESC, $sort['unikey'], SORT_ASC, $unikeyArr);
		}

		return [array_values($unikeyArr),$hasCount];
	}

	public function addMerge()
	{
	   $req = \mvc::$req;
	   $data = $this->pro->addMerge($req['pch_p_id_from'], $req['pch_p_id_to']);
	   $this->successJson($data);
	}

	public function getMergeList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
        $data = $this->pro->getMergeList($req, $rules);
        $this->successJson($data);
	}

	public function getMergeEndList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
        $data = $this->pro->getMergeEndList($req, $rules);
        $this->successJson($data);
	}

	public function getExchageAllList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
        $data = $this->pro->getExchageAllList($req, $rules);
        $this->successJson($data);
	}

	public function delMerge()
	{
		$req = \mvc::$req;
		$data = $this->pro->delMerge(explode(',', $req['ids']));
		$this->successJson($data);
	}

	public function checkMerge()
	{
		$req = \mvc::$req;
		$data = $this->pro->checkMerge(explode(',', $req['ids']), $req);
		$this->successJson($data);
	}

	public function rollbackMerge()
	{
		$req = \mvc::$req;
		$data = $this->pro->rollbackMerge($req['id'], $req);
		$this->successJson($data);
	}
	

	/**
	  * @method 选择器
	  * @param  sql    string  [sql+db] base64:xxxxxx select brand_name name, brand_id id, brand_initial letter from m_cn_model group by brand_id order by brand_initial
	  * @param  db    string  [sql+db] 选择sql时必填
	  * @param  table  string  [选填] factory | make
	  * @param  style  string  [选填] 选择模式 anychk:多选  空(默认):单选
	  * @param  letter  int  [选填] 是否启用字母选择  1(默认)|-1
	  * @param  liwidth  int  [选填] 每个名称宽度 默认 150
	  * @param  data  string  [选填] base64:W3sibmFtZSI6Ilx1NTAzYyIsImlkIjoiMTIzIn0seyJuYW1lIjoiXHU1MDNjMiIsImlkIjoiNDU2In1d  base64_encode(json_encode([["name"=>"值", "id"=>"123"], ["name"=>"值2", "id"=>"456"]]))
	  * @author soul
		传sql   pro/select?db=main&sql=select+brand_name+name%2C+brand_id+id%2C+brand_initial+letter+from+m_cn_model+group+by+brand_id+order+by+brand_initial&style=anychk&callback=onSelectUser&letter=1
        传sql base64 /pro/select?sql=base64:xxxxxx
		model/pro/pro/getSelect配置  pro/select?table=cnmakesql&callback=onSelectUser&letter=1
	  */
    public function select()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		$style = !empty($req['style']) && $req['style'] == 'anychk'? 'anychk': '';
        if(substr($req['sql'],0,7)=='base64:'){
            $req['sql'] = base64_decode(substr($req['sql'],7));
        }
		if(!empty($req['sql']) && stripos($req['sql'], 'select') === 0 && !empty(\mvc::$cfg['db'][$req['db']]))
		{
			$req['sql'] = strtr($req['sql'], ['insert'=>'###','update'=>'###','delete'=>'###', 'drop'=>'###', 'truncate'=>'###', 'alert'=>'###']);
			$this->sdb = new \lib\db(\mvc::$cfg['db'][$req['db']]);
			$dataArr = $this->sdb->query($req['sql'])->fetchAll(\PDO::FETCH_ASSOC);
		}
		else if(!empty($req['data']))
		{
			$raw = substr($req['data'],7);
			$raw = str_replace(' ', '+', $raw);
			$raw = rawurldecode($raw);
			$dataArr = json_decode(base64_decode($raw), true);
		}
		else
		{
			if($req['table']=='brand'&&$req['pwcode']){
				$proBrands = \p::areas($req['pwcode']);
				if(!\p::isAdmin() && $proBrands){
					if(!isset($rules['pb_id'])){
						$rules['pb_id'] = explode(',',$proBrands);
					}
				}
			}

			$dataArr = $this->pro->getSelect($req['table'], $rules);
		}
		$letterArr = [];
		if($req['letter'] != -1)
		{
			$sort = ['seq'=>[], 'letter'=>[], 'name'=>[]];
			$cnInitialLetter = include(\mvc::$cfg['mvcDir'].'/lib/cnInitialLetter.php');
			foreach($dataArr as &$v)
			{
				if(isset($v['letter']))
				{
					$v['letter'] = substr($v['letter'], 0, 1);
				}
				else if(preg_match('/^[0-9a-zA-Z]/', $v['name'], $match))
				{
					$v['letter'] = $match[0];
				}
				else
				{
					$first = mb_substr($v['name'], 0, 1);
					if(!empty($cnInitialLetter[$first])){
						$py = $cnInitialLetter[$first];
					}else{
						$py = pinyinFirst($first);
					}
					$v['letter'] = substr($py, 0, 1);
				}
				$v['letter'] = strtoupper($v['letter']);
				$sort['seq'][] = isset($v['seq'])? $v['seq']: 0;
				$sort['letter'][] = $v['letter'];
				$sort['name'][] = $v['name'];
				$letterArr[] = $v['letter'];
			}
			array_multisort($sort['seq'], SORT_DESC,$sort['letter'], SORT_ASC, $sort['name'], SORT_ASC, $dataArr);
			$letterArr = array_unique($letterArr);
			sort($letterArr);
		}
		\view::set('letterArr', $letterArr);
		\view::set('dataArr', $dataArr);
		\view::set('style', $style);
		\view::set('req', $req);
		\view::set('id',$id);
		\view::put();
    }
	
    /**
    * @method 区域&本地码 审核
    * @param string $ids 
    */
    public function codeAreaNumberCheck2($ids)
    {
        if($ids!=''){
            $res = (new \model\pro\codeRule())->codeAreaNumberCheck2($ids,true);
            $this->successJson($res);
        }
        $this->msgJson(lg('未知错误'));
    }
	
    /**
    * @method 区域&本地码 删除
    * @param string $ids 
    */
    public function codeAreaNumberDeleteRows($ids)
    {
        if($ids!=''){
            $res = (new \model\pro\codeRule())->codeAreaNumberDeleteRows($ids);
            $this->successJson();
        }
        $this->msgJson(lg('未知错误'));
    }
    
    
	
    /**
    * @method 生成条码
    * @param string $ids 
    */
    public function buildBarCode($ids)
    {
        if($ids!=''){
            $res = (new \model\pro\codeRule())->buildBarCode($ids);
            if($res){
                $this->successJson([$res]);
            }
        }
        $this->msgJson(lg('生成条码出现错误,请检测企业编码可使用次数'));
    }


	public function getPlmParamByInnum($innum)
	{
	    $io = new \model\io();
        $data = $io->plmParam($innum);
		$this->successJson($data);
	}

	public function getBomByInnum()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		if(empty($rules['innum']) || empty($rules['cid']))
		    return $this->successJson([]);;
		//随机生成演示数据
		$innum = $rules['innum'];

		$seed = abs(crc32($innum));

		$rowCount = ($seed % 5) + 1;
		
		$data = [];
		
		for ($i = 0; $i < $rowCount; $i++) {
		
			$rowSeed = $seed + $i;
			
			$qty = ($rowSeed % 10) + 1;
			
			$partSuffix = strtoupper(substr(md5($innum . $i), 0, 4));
			
			$data[] = [
				'MAKTX' => $innum,
				'IMAKT_' . LANG => 'PART-' . $partSuffix, 
				'MENGE' => $qty 
			];
		}
		
		$this->successJson($data);
	}


	//报表
	public function master()
	{
		$req = \mvc::$req;
		$master = new master();
		$mainkey = $req['mainkey'];
		$scof = [];
		$selftscof = [];
		if($mainkey == 'self'){
			$selftscof = $master->getSelfReport();
			\view::set('selftscof', $selftscof);
		}else{
			$scof = \mvc::$cfg['master'][$mainkey];	
			\view::set('scof', $scof);
		}
		\view::set('mainkey', $mainkey);
		\view::put();
	}

	public function exeMaster()
	{
		$req = \mvc::$req;
		$master = new master();
		$master->export($req['mainkey'], explode(',', $req['skey']), $req);
		$this->successJson([]);
	}

	function delMasterTpl()
	{
		$req = \mvc::$req;
		$master = new master();
		$master->delMasterTpl(explode(',', $req['ids']));
		$this->successJson([]);
	}

	//监听队列
    public function exeMasterSelf($options,$req)
    {
        ignore_user_abort(true);
		ini_set('memory_limit', \mvc::$cfg['export_memory_limit']);
		set_time_limit(\mvc::$cfg['export_time_limit']);
        //type:xlsx|xlsxzip|imgxlsx|imgzip
        $options = json_decode(base64_decode($options),true);
        parse_str(html_entity_decode($req), $req);
		//前置条件
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
			$options['numbers'] = $req['numbers'];
		}
		if(isset($req['keys'])){
			$rules['keys'] = explode(',',$req['keys']);
		}
        $pagesize = 2147483647;
        if($options['model']['hasmodel']){
            if($options['model']['modelCel']=='one'){
                $rules['modelsOne'] = 1;
            }else if($options['model']['modelCel']=='more'){
                $rules['modelsAll'] = 1;
            }else{
                $rules['modelsRows'] = 1;
            }
        }
        if($options['oe']['qty']>200) $options['oe']['qty'] = 200;
        $options['fac'] = ($options['fac']!='') ? explode(',',$options['fac']) : [];
		$rules['getSQL'] = true;
        $sql = $this->pro->list($rules,$req['filters'], 1, $pagesize, '', '','');
        $fields = "p.p_id";
	    $join = "\r\n ";
	    $sql = preg_replace('/SELECT\s.*\s+FROM/is',"SELECT ".$fields." FROM",$sql);
		$master = new master();
		if($options['act'] == 'reporttpl'){
			$data = ['mr_name'=>$options['mr_name'], 'mr_mt_id'=>(int)$options['mtids'], 'mr_sql'=>$sql];
			$master->setReportTpl($data);
			$this->successJson([]);
		}else if($options['act'] == 'export'){
			$master = new master();
			$master->export('self', '', ['sql'=>$sql, 'mtids'=>$options['mtids']]);
			$this->successJson([]);
		}
	}

	public function masAttaqtyList()
	{
		$req = \mvc::$req;
		//前置条件
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = formatNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
        $data = $this->pro->list($rules,$req['filters'], $req['page'], $req['rows'], $req['sidx'], $req['sord'],'p_comnum');
		if(!empty($data)){
			foreach($data['rows'] as &$row){
				$attaRow = $this->pro->getMasAttaqtyByPid($row['p_id']);
				if(!empty($attaRow)){
					foreach($attaRow as $field=>$value){
						$regi = substr($field,strrpos($field, '_')+1);
						if($regi!='' && is_numeric($regi)){
							$row['pa_'.$regi] = $value;
						}
					}
				}//$data['rows']
			}
		}
        $this->successJson($data);
	}

	public function editCellMasAttaqty()
    {
		$req = \mvc::$req;
        $id = $req['id'];
        $oper = $req['oper'];
        $field = $req['field'];
		if(isset($req['value']))
			$value = $req['value'];
 		else
			$value = $req[$field];
        if($oper=='edit'){
            $result = $this->pro->setMasAttaqty($id,$field,$value);
        }
    }
	
	//审核零件库到商品库
	public function chkPoeToPro()
	{
		$req = \mvc::$req;
		$data = $this->pro->getBuildProByOeInfo($req['oe_id']);
		\view::set('data', $data);
		\view::put();
	}


	public function getBatchBuildProByOeInfo()
	{
		$req = \mvc::$req;
		$data = $this->pro->getBatchBuildProByOeInfo($req['oe_id']);
		$this->successJson($data);
	}

	public function buildProByOe()
	{
		$req = \mvc::$req;
		$data = $this->pro->buildProByOe($req['oe_id'], $req, $req['p_id'],true);
		$this->successJson($data);
	}

	public function getProRelOe()
	{
		$req = \mvc::$req;
		$data = [];
		$data = $this->pro->getProRelOe($req['pid'],$req);
		$this->successJson($data);
	}

	/**
	 * @method 关联产品
	 * @author zhengweihua 
	 * @copyright 2024-12-04
	 */
	public function relpro()
	{	
		$req = \mvc::$req;
		\view::set('req',$req);
		\view::put();
	}

	/**
	 * @method 保存产品包装
	 * @author zhengweihua 
	 * @copyright 2024-12-05
	 */
	public function saveProPack()
	{
		$req = \mvc::$req;
        $key = $req['pp_p_id'];
		$result = $this->pro->saveProPack($key,$req);
		$this->successJson($result);
	}


	public function getPackList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = arryNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
        $data = $this->pro->getPackList($req, $rules);
        $this->successJson($data);
	}


	public function delPack()
	{
		$req = \mvc::$req;
        $data = $this->pro->delPack(\mvc::$req['ids']);
        $this->successJson($data);
	}

	/**
	 * @param  string $elename
	 * @method 产品相关属性的删除
	 * @author zhengweihua 
	 * @copyright 2024-12-10
	 */
	public function deleteElementRows($elename='')
    {
        $req = \mvc::$req;
		$elename = ($elename!='') ? $elename : \mvc::$req['elename'];
		$elecfg = require(\mvc::$cfg['projectDir'].'/element/'.$elename.'.php');
        $pro =  new pro();
        if($pro->deleteElementRows($elecfg,$req['ids'])){
            $this->successJson(lg('删除完成'));
        }
    }

	/**
	 * @param  string $elename
	 * @method 产品相关属性的编辑
	 * @author zhengweihua 
	 * @copyright 2024-12-11
	 */
	public function editElementCell($elename='')
	{
		$req = \mvc::$req;
        $id = $req['id'];
        $oper = $req['oper'];
        $field = $req['field'];
		if(isset($req['value']))
			$value = $req['value'];
 		else
			$value = $req[$field];

		$elename = ($elename!='') ? $elename : \mvc::$req['elename'];
		$elecfg = require(\mvc::$cfg['projectDir'].'/element/'.$elename.'.php');
		$elementModel = new element($elecfg);

		$pro =  new pro();

        if($oper=='edit' && !empty($field)){
			if(isset($elecfg['uniqueFields']) && !empty($elecfg['uniqueFields']) && in_array($field,  $elecfg['uniqueFields'])){
				if($elementModel->hasUnique($id,$field,$value)){
                    exit(lg("重复的记录,保存失败"));
				}
			}
            if($value!='' && $elecfg['fields'][$field]['unique'] && !$elecfg['fields'][$field]['key']){
                if($elementModel->hasWithOut($field,$value,$id)){
                   exit(sprintf("重复的 [ %s ] 在 [ %s ] 中",$value,$elecfg['fields'][$field][LG_NAME]));
                }
            }
            $pro->editElementCell($elecfg,$id,$field,$value);
        }else{
			$this->errorJson(500);
		}
	}

	/**
	 * @method 根据号码获取对应配件分类
	 * @author zhengweihua 
	 * @copyright 2024-12-17
	 */
	public function getNumParts()
	{	
		$req = \mvc::$req;
		if(!$req['number']) exitJson(-1,'参数错误');
		$ypApi = new ypApi();
		$chkres = $ypApi->Get('tcd/getNumParts',$req);
		$data = $chkres['status']? $chkres['data']: [];
		\view::set('data',$data);
		\view::put();
	}

	/**
	 * 格式化参考参数
	 */
	public function formatPara()
	{
		$req = \mvc::$req;
		$p_id = $req['p_id'];
		
		$pro = new pro();
		$detail = $this->pro->getDetail($p_id);
	
		if($detail['p_para'])
		{
			$ret = $pro->formatParaFromTcd($detail['p_cate'],$detail['p_para'],$p_id);

			$pro->setProParaAndPos($p_id,$ret);
		}
		
		$this->successJson("操作成功");
	}

	/**
	 * 检测状态并删除选项
	 */
	public function deleteRowsByChk($elename='')
	{
		$req = \mvc::$req;
		$elename = ($elename!='') ? $elename : \mvc::$req['elename'];
		$pro = new pro();
		$data = $pro->deleteRowsByChk($elename,$req['ids']);
		$this->successJson($data);
	}

	public function seachAllNum()
	{
		$req = \mvc::$req;
		$nums = splitNums($req['num'], $req['splitval']);
		$datas = [];
		if($req['showtype'] == 'merge'){
			//合并模式
			foreach($nums as $numstr){
				$tnum = explode(':', $numstr);
				if(count($tnum) == 1) $tnum = ['', $tnum[0]];
				$number = $tnum[1]; $factory = $tnum[0];
				$pro = new pro();
				$chkres = $pro->seachAllNum($number, $factory, $req);
				$unikey = md5(serialize(['oe_ids'=>array_column($chkres['poe'], 'oe_id')]));
				$typeArr = ['pro'=>'p_id', 'super'=>'sup_id', 'work'=>'wdlist_id', 'poe'=>'oe_id', 'tb_brands'=>'tb_id', 'oe_nums'=>'','company'=>'','resource'=>'','ypresource'=>''];
				foreach($typeArr as $type=>$unifield){
					if(empty($chkres[$type])){
						$datas[$unikey][$type] = [];
						continue;
					}
					foreach($chkres[$type] as $vv){
						if($type == 'poe'){
							$datas[$unikey]['num_by'][] = ['number'=>$vv['on_number'], 'factory'=>$vv['pf_name_s']];
						}
						if($unifield){
							$datas[$unikey][$type][$vv[$unifield]] = $vv;
						}else{
							$datas[$unikey][$type][] = $vv;
						}
					}
					if(empty($unifield) && $datas[$unikey][$type]) $datas[$unikey][$type] = multiArrayUnique($datas[$unikey][$type]);
				}
				$datas[$unikey]['num_org'][] = ['number'=>$number, 'factory'=>$factory];
			}
			$datas = array_values($datas);
		}else{
			foreach($nums as $numstr){
				$tnum = explode(':', $numstr);
				if(count($tnum) == 1) $tnum = ['', $tnum[0]];
				$number = $tnum[1]; $factory = $tnum[0];
				$pro = new pro();
				$chkres = $pro->seachAllNum($number, $factory);
				$chkres['num_org'] = [['number'=>$number, 'factory'=>$factory]];
				$chkres['num_by'] = [];
				if($chkres['poe']){
					foreach($chkres['poe'] as $vv){
						$chkres['num_by'][] = ['number'=>$vv['on_number'], 'factory'=>$vv['pf_name_s']];
					}
				}
				$datas[] = $chkres;
			}
		}

		\view::set('datas', $datas);
		\view::set('rownum', $req['rownum']);
		$html = \view::fetch();

		$this->successJson(['html'=>$html]);
	}


	public function seachEpcNum()
	{
		$req = \mvc::$req;
		$nums = splitNums($req['num'], $req['splitval']);
		$datas = [];
		foreach($nums as $numstr){
			$tnum = explode(':', $numstr);
			if(count($tnum) == 1) $tnum = ['', $tnum[0]];
			$number = $tnum[1]; $factory = $tnum[0];
			$pro = new pro();
			$chkres = $pro->seachEpcNum($number);
			$chkres['num_org'] = [['number'=>$number, 'factory'=>$factory]];
			$datas[] = $chkres;
		}
		\view::set('datas', $datas);
		\view::set('rownum', $req['rownum']);
		$html = \view::fetch();

		$this->successJson(['html'=>$html]);
	}

	/**
	 * @method 获取品牌标签key value
	 * @author zhengweihua 
	 * @copyright 2025-01-09
	 */
	public function getTagBrandAllKv()
	{
		$req = \mvc::$req;
        $pro = new pro();
        $rows = $pro->getDb()->select('tag_brand',['tb_id','tb_'.LG_NAME],['ORDER'=>raw('tb_seq,CONVERT(tb_'.LG_NAME.' USING gbk)')]);
        $data = [];
        $regi=0;
		$firstkey = isset($req['firstkey'])? $req['firstkey']: 0;
        if(isset($req['hasFirst']) && $req['hasFirst']){
            $data[0] = ['key'=>$firstkey, 'value'=>'' ];
            $regi = 1;
        }
        foreach($rows as $k=>$v){
            $data[$k+$regi]=[ 'key'=>$v['tb_id'], 'value' => $v['tb_'.LG_NAME] ];
        }
       $this->successJson($data);
	}

	/**
	 * @method 产品供应商
	 * @author zhengweihua 
	 * @copyright 2025-01-09
	 */
	public function listSupplier()
	{
		$req = \mvc::$req;
		\view::set('req',$req);
		\view::put();
	}
	/**
	 * @method OE供应商列表
	 */
	public function getListSupplier()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		$pro = new pro();
        $data = $pro->getListSupplier($req, $rules);
        $this->successJson($data);
	}


	function itemImg(){
		$req = \mvc::$req;
		$pro = new pro();
		//$pro->getItemImg();
		\view::set('req',$req);
		\view::put();
	}

	/**
	 * @method 图片相关
	 * @author zhengweihua 
	 * @copyright 2025-01-14
	 */
	public function listPic()
	{
		$req = \mvc::$req;

		$pro = new pro();
		$data = $pro->getDetail($req['p_id']);
		\view::set('data',$data);
		\view::set('req',$req);
		\view::put();
	}

	/**
	 * @method 获取图片列表
	 * @author zhengweihua 
	 * @copyright 2025-01-14
	 */
	public function getListPic()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		$pro = new pro();
        $data = $pro->getListPic($req, $rules);
        $this->successJson($data);
	}

	/**
	 * @method 单元格编辑
	 * @author zhengweihua 
	 * @copyright 2025-01-14
	 */
	public function setOePicCell()
	{
		$req = \mvc::$req;
		
		$pro = new pro();
		$data = $pro->setOePicCell($req);
		
	}

	public function searchPic()
	{
		$req = \mvc::$req;
		$data = [];
		$searchArr = [];
		if($req['p_id']){
			$pro = new pro();
			$res = $pro->getListPic(['pid'=>$req['p_id'],'type'=>'img']);
			$data = $res['rows'];
		}
		\view::set('data',$data);
		if($req['number']){
			$oe = new oe();
			$res = $oe->searchPic($req['number']);
			$searchArr = $res['data'];
		}
		\view::set('searchArr',$searchArr);
	
		\view::set('req',$req);
		\view::put();
	}

	/**
	 * @method 设置主图
	 * @author zhengweihua 
	 * @copyright 2025-01-14
	 */
	public function setProMainPic()
	{
		$req = \mvc::$req;
		if(!$req['fileid']||!$req['pid']||!$req['type']) return $this->exitJson(-1,lg('参数错误'));
		$pro = new pro();
		$data = $pro->setProMainPic($req['fileid'],$req['pid'],$req['type']);
		$this->successJson($data);
	}

	public function setPicSup()
	{
		$req = \mvc::$req;
		if(!$req['fileid']||!$req['pid']||!$req['sup_id']) return $this->exitJson(-1,lg('参数错误'));
		$pro = new pro();
		$fileids = array_values(explode(',',$req['fileid']));
		$data = $pro->setPicLineSup($req['pid'],$req['sup_id'],$fileids);
		$this->successJson($data);
	}

	public function delProPic()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->delProPic($req);
		$this->successJson($data);	
	}

	/**
	 * @method 将选择的图片设置为零件图
	 * @author zhengweihua 
	 * @copyright 2025-01-15
	 */
	public function setProPicByFile()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->setProPicByFile($req);
		$this->successJson($data);
	}

	/**
	 * @method 设置零件图为主图
	 * @author zhengweihua 
	 * @copyright 2025-01-15
	 */
	public function setImgToMain()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->setImgToMain($req);
		$this->successJson($data);
	}

	public function getNumParams()
	{
		$req = \mvc::$req;
		if(!$req['number']) exitJson(-1,'参数错误');
		$ypApi = new ypApi();
		$postData = ['number'=>$req['number'],'factory'=>$req['factory'],'ganame'=>$req['ganame']];
		$chkres = $ypApi->Get('tcd/chkOneNumBase',[],$postData);
		$data = $chkres['status']? $chkres['data']: [];
		$this->successJson($data);
	}

	/**
	 * @method 设置主OE
	 * @author zhengweihua 
	 * @copyright 2025-03-06
	 */
	public function setOeMain()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->setOeMain($req['pn_id']);
		$this->successJson($data);
	}

	public function setDevelopNo()
	{
		$req = \mvc::$req;
		\view::set('req',$req);
		\view::put();
	}

	public function proLink()
	{
		$req = \mvc::$req;
		\view::set('req',$req);
		\view::put();
	}

	public function getListProLink()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = explode(',', $req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
		$pro = new pro();
        $data = $pro->getListProLink($req['p_id'], $req,$rules);
        $this->successJson($data);
	}


	public function getInnum()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->getAllInnum($req);
		$this->successJson($data);
	}

	public function doExcel()
	{
		set_time_limit(0);
		set_time_limit(\mvc::$cfg['bigtable_memory_limit']);
		$req = \mvc::$req;
		$synProPic = new synProPic();
		//excle文件目录
		if($req['path'])
		{
			$path = $req['path'];
		}else{
			$path = \mvc::$cfg['dir']['files'].'/pro.xlsx';
		}
		
		$data = $synProPic->savePicToExcel($path);
		$this->successJson($data);
	}


	/**
	 * @method 品牌商品
	 * @author zhengweihua 
	 * @copyright 2025-06-18
	 */
	public function pbProExt()
	{
		$req = \mvc::$req;
		
		$pro = new pro();
		$list = $pro->getProPbList();
		foreach ($list as $key => $val) {
			$arr[] = [
				'name' =>$val['pb_name'],
                'src' =>  \mvc::$cfg['domain'].'/pro/pbProList?pb_id='.$val['pb_id']
			];
		}
		\view::set('arr',$arr);
		\view::set('req',$req);
		\view::put();
	}

	/**
	 * @method 品牌商品页面
	 * @author zhengweihua 
	 * @copyright 2025-06-19
	 */
	public function pbProList()
	{
		$req = \mvc::$req;
		\view::set('req',$req);
		\view::set('allPos',$this->pro->allPos);
		\view::put();
	}

	public function getPbProList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = arryNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
		if(isset($rules['findNulls']) && $rules['findNulls']){
			$rules['findNulls'] = json_decode(base64_decode($rules['findNulls']),true);
		}
		if(isset($req['pb_id']) && $req['pb_id']){
			$rules['proBrand'] = $req['pb_id'];
		}
		
		$pro = new pro();
		$data = $pro->getCodeList($req, $rules);
		$this->successJson($data);
	}

	/**
	 * @method 事业部商品列表
	 * @author zhengweihua 
	 * @copyright 2025-06-19
	 */
	public function compProExt()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$list = $pro->getPlcComList();
		foreach ($list as $key => $val) {
			$arr[] = [
				'name' =>$val['com_name'],
                'src' =>  \mvc::$cfg['domain'].'/pro/compProList?com_id='.$val['com_id']
			];
		}
		\view::set('arr',$arr);
		\view::set('req',$req);
		\view::put();
	}
	/**
	 * @method 事业部商品
	 * @author zhengweihua 
	 * @copyright 2025-06-18
	 */
	public function compProList()
	{
		$req = \mvc::$req;
		
		\view::set('req',$req);
		\view::put();
	}

	/**
	 * @method 获取事业部商品
	 * @author zhengweihua 
	 * @copyright 2025-06-19
	 */
	public function getCompProList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		if(isset($req['numbers'])){
			$rules['numbers'] = arryNums($req['numbers']);
			$rules['numlike'] = empty($req['numlike']) ? 0 : $req['numlike'];
		}
		if(isset($rules['findNulls']) && $rules['findNulls']){
			$rules['findNulls'] = json_decode(base64_decode($rules['findNulls']),true);
		}
		$pro = new pro();
		$data = $pro->compProList($req, $rules);
		$this->successJson($data);
	}

	public function linkcomp()
	{
		$req = \mvc::$req;
		
		\view::set('req',$req);
		\view::put();
	}

	/**
	 * @method 事业部相关信息
	 */
	public function getLinkcompList()
	{
		$req = \mvc::$req;
		$rules = $this->urlRulesToWhere($req);
		$pro = new pro();
        $data = $pro->compProList($req, $rules);
        $this->successJson($data);
	}	

	/**
	 * @method 关联事业部信息详情
	 * @author zhengweihua 
	 * @copyright 2025-06-21
	 */
	public function compLinkDetail()
	{
		$req = \mvc::$req;	
		$pro = new pro();
        $data = $pro->compLinkDetail($req['plc_id']);
		\view::set('item',$data);
		\view::put();
	}

	/**
	 * @method 资源库
	 * @author zhengweihua 
	 * @copyright 2025-06-27
	 */
	public function sourceSearch()
	{
		$req = \mvc::$req;
		if($req['nums'] && !is_array($req['nums'])){
			$req['nums'] = explode("\r\n", strtr($req['nums'], [','=>"\r\n"]));
		}
		\view::set('req',$req);
		\view::put();	
	}


	public function sourceSearchList()
	{	
		$req = \mvc::$req;
		if(!$req['num'] && !$req['keyword']) $this->successJson([]);
		$rcaApi = new rcaApi();
		
		if($req['type']=='num')
		{
			$numArr = splitNums($req['num'], $req['splitval']);
			$dataArr  = array_unique($numArr);
			$data = $rcaApi->getSourceSearch($dataArr);
			\view::set('datas', $data);
			$html = \view::fetch();
		}elseif ($req['type']=='keyword') {
			$data = $rcaApi->getFactorySearch($req['keyword']);
			\view::set('datas', $data);
			\view::set('from', 'rca');
			$html = \view::fetch('pro.factorySearchList');
		}
	
		\view::set('rownum', $req['rownum']);
		$this->successJson(['html'=>$html]);
	}

	public function getResourcesUrlById()
	{
		$req = \mvc::$req;
		if(!$req['id']) $this->successJson([]);
		$rcaApi = new rcaApi();
		$data = $rcaApi->getResourcesUrlById($req['id']);
		$this->successJson($data);
	}


	/**
	 * @method 资源库
	 * @author zhengweihua 
	 * @copyright 2025-06-27
	 */
	public function sourceSearchYp()
	{
		$req = \mvc::$req;
		if($req['nums'] && !is_array($req['nums'])){
			$req['nums'] = explode("\r\n", strtr($req['nums'], [','=>"\r\n"]));
		}
		\view::set('req',$req);
		\view::put();	
	}


	/**
	 * @method
	 * @author zhengweihua 
	 * @copyright 2025-07-21
	 */
	public function sourceSearchYpList()
	{
		$req = \mvc::$req;
		if(!$req['num'] && !$req['keyword']) $this->successJson([]);

		$ypRcaApi = new ypRcaApi();
		if($req['type']=='num')
		{
			$numArr = splitNums($req['num'], $req['splitval']);
			$dataArr  = array_unique($numArr);
			$data = $ypRcaApi->getSourceSearch($dataArr);
			\view::set('datas', $data);
			$html = \view::fetch();
		}elseif ($req['type']=='keyword') {
			$data = $ypRcaApi->getFactorySearch($req['keyword']);
			\view::set('datas', $data);
			\view::set('from', 'yp');
			$html = \view::fetch('pro.factorySearchList');
		}
		\view::set('rownum', $req['rownum']);
		$this->successJson(['html'=>$html]);	
	}
	
	/**
	 * @method 工厂详情(宜配)
	 * @author zhengweihua 
	 * @copyright 2025-07-21
	 */
	public function factoryYpDetail()
	{
		$req = \mvc::$req;
		if(!$req['id']) $this->exitJson(-1,'参数错误');
		
		$ypRcaApi = new ypRcaApi();
		$res = $ypRcaApi->Get('resourcefactory/get',[],['id'=>$req['id']]);
		
		\view::set('dataArr', $res['data']);
		\view::put();
	}

	/**
	 * @method 删除发动机字段的重复数据
	 * @author zhengweihua 
	 * @copyright 2025-07-21
	 */
	public function removeEngineDuplicates()
	{
		set_time_limit(0);
		ini_set('memory_limit', \mvc::$cfg['bigtable_memory_limit']);
		$pro = new pro();
		$data = $pro->removeEngineDuplicates();
		$this->successJson($data);
	}

	public function checkIsFgioBrand()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->checkIsFgioBrand($req['p_id']);
		$this->successJson($data);
	}

	public function getOeItem()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->getOeItemByPid($req);
		$this->successJson($data);
	}

	/**
	 * @method 变更所属零件
	 * @author zhengweihua 
	 * @copyright 2025-10-20
	 */
	public function changeProOe()
	{
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->changeProOe($req);
		$this->successJson($data);
	}


	/**
	 * @method 批量上传图片
	 * @author zhengweihua 
	 * @copyright 2026-02-10
	 */
	public function batchUploadPic()
	{
		\view::put();
	}

	/**
	 * @method 处理批量上传图片
	 * @author zhengweihua 
	 * @copyright 2026-02-10
	 */
	public function batchUploadProPic()
	{
		$req = \mvc::$req;
		$filesArray = $req['filesArray'] ?? [];
		$pid = $req['pid'] ?? 0;

		if (empty($filesArray)) {
			$this->msgJson(lg('没有待处理的文件'));
		}

		$successCount = 0;
		$errorCount = 0;
		$results = [];

		foreach ($filesArray as $file) {
			$uploadProPicZip = new uploadProPicZip();
			$result = $uploadProPicZip->uploadSingleFileToOSS(
				$file['temp_path'],
				$file['original_name'],
				$file['pic_style'],
				$file['p_id']
			);

			if ($result['success']) {
				$successCount++;
				$results[] = [
					'filename' => $file['original_name'],
					'status' => 'success',
					'fileid' => $result['data']['fileid']
				];
			} else {
				$errorCount++;
				$results[] = [
					'filename' => $file['original_name'],
					'status' => 'error',
					'error' => $result['error']
				];
			}
		}
		$this->successJson([
			'total' => count($filesArray),
			'success' => $successCount,
			'error' => $errorCount,
			'results' => $results
		]);
	}

	/**
	 * 清理临时目录
	 */
	public function cleanupTempDir()
	{
		$req = \mvc::$req;
		$tempDir = $req['temp_dir'] ?? '';

		if (empty($tempDir) || !is_dir($tempDir)) {
			$this->successJson(['success' => true]);
		}

		try {
		
			//清理临时目录
			$uploadModel = make(\model\import\uploadProPicZip::class);
			$uploadModel->removeDir($tempDir);

			$this->successJson(['success' => true]);
		} catch (Exception $e) {
			$this->errorJson(500, $e->getMessage());
		}
	}

	/**
	 * @method 海报模板
	 * @author hongzhang
	 * @copyright 2026-02-10
	 */
	public function picTpl()
	{
		$req = \mvc::$req;
		\view::put('pro/pic/picTpl');
	}
	/**
	 * @method 获取模板列表
	 * @author hongzhang
	 * @copyright 2026-02-10
	 */
	public function getPicTplList()
	{
		$req = \mvc::$req;
		$picTpl = new picTpl();
		$data = $picTpl->getList($req);
		$this->successJson($data);
	}
	/**
	 * @method 新增模板界面
	 * @author hongzhang
	 * @copyright 2026-02-10
	 */
	public function addPicTpl()
	{
		$req = \mvc::$req;
		$ptl_id = $req['id']??'';
		// 判断是更新还是新增
		$update = $req['update']??'';
		$text_cfg = [];
		$logo_cfg = [];
		$watermark_cfg = [];
		$qrcode_cfg = [];
		$background_cfg = [];
		$template_cfg = [];
		$ptl_lang = '';
		$ptl_name = '';
		$ptl_pb_id = '';
		$ptl_test_info = [];
		$hasTestProInfo = false;
		$picTpl = new picTpl();
		// 获取模板详情
		if($ptl_id){
			$detail = $picTpl->getTplCfg($ptl_id);
			$ptl_lang = $detail['ptl_lang'];
			$ptl_name = $detail['ptl_name'];
			$ptl_pb_id = $detail['ptl_pb_id'];
			$ptl_cfg = $detail['ptl_cfg'];
			$ptl_cfg = json_decode($ptl_cfg,true);
			foreach($ptl_cfg as $item){
				if($item['type']=='text'){
					$text_cfg[] = $item;
				}elseif($item['type']=='logo'){
					$logo_cfg = $item;
					$logo_cfg['val'] = \mvc::$cfg['path']['files'].'/pictpl/logo/'.$logo_cfg['val'];
				}elseif($item['type']=='watermark'){
					$watermark_cfg = $item;
					$watermark_cfg['val'] = \mvc::$cfg['path']['files'].'/pictpl/watermark/'.$watermark_cfg['val'];
				}elseif($item['type']=='qrcode'){
					$qrcode_cfg = $item;
					$qrcode_cfg['val'] = $qrcode_cfg['val'];
				}elseif($item['type']=='background'){
					$background_cfg = $item;
					if($background_cfg['mode']=='image' && !empty($background_cfg['val'])){
						$background_cfg['val'] = \mvc::$cfg['path']['files'].'/pictpl/bg/'.$background_cfg['val'];
					}
				}elseif($item['type']=='template'){
					$template_cfg = $item;
				}elseif($item['type']=='testProInfo'){
					$hasTestProInfo = true;
					$testProOInfo = $item;
				}
			}
			\view::set('ptl_id',$ptl_id);

			if($hasTestProInfo){
				$ptl_test_info = $picTpl->getProInfoByBrand($ptl_pb_id,$ptl_lang,$testProOInfo['p_id']);
			}else{
				$ptl_test_info = $picTpl->getProInfoByBrand($ptl_pb_id,$ptl_lang);
			}
		}else{
			$ptl_test_info = $picTpl->getProInfoByBrand();
		}
		\view::set('update',$update);
		\view::set('text_cfg',$text_cfg);
		\view::set('logo_cfg',$logo_cfg);
		\view::set('watermark_cfg',$watermark_cfg);
		\view::set('qrcode_cfg',$qrcode_cfg);
		\view::set('background_cfg',$background_cfg);
		\view::set('template_cfg',$template_cfg);
		\view::set('ptl_lang',$ptl_lang);
		\view::set('ptl_name',$ptl_name);
		\view::set('ptl_pb_id',$ptl_pb_id);
		\view::set('ptl_test_info',$ptl_test_info);
		$logoList = [];
		$watermarkList = [];
		$bgList = [];
		$logoDir = \mvc::$cfg['dir']['files'].'/pictpl/logo';
		$watermarkDir = \mvc::$cfg['dir']['files'].'/pictpl/watermark';
		$bgDir = \mvc::$cfg['dir']['files'].'/pictpl/bg';
		$logoBaseUrl = \mvc::$cfg['path']['files'].'/pictpl/logo';
		$watermarkBaseUrl = \mvc::$cfg['path']['files'].'/pictpl/watermark';
		$bgBaseUrl = \mvc::$cfg['path']['files'].'/pictpl/bg';
		$allowExt = ['jpg','jpeg','png','gif','bmp','webp'];
		// 获取语言列表
		$langList = \mvc::$cfg['LANGS'];
		// 获取pro_brand表中的品牌列表
		$proBrand = new picTpl();
		$brandList = $proBrand->getProBrandList('G500');
		// 读取logo目录下的文件
		if (is_dir($logoDir)) {
			$files = scandir($logoDir);
			foreach ($files as $file) {
				if ($file === '.' || $file === '..') {
					continue;
				}
				$full = $logoDir.'/'.$file;
				if (!is_file($full)) {
					continue;
				}
				$ext = strtolower(pathinfo($file, PATHINFO_EXTENSION));
				if (!in_array($ext, $allowExt, true)) {
					continue;
				}
				$logoList[] = ['name'=>$file,'url'=>$logoBaseUrl.'/'.$file];
			}
		}
		// 读取水印目录下的文件
		if (is_dir($watermarkDir)) {
			$files = scandir($watermarkDir);
			foreach ($files as $file) {
				if ($file === '.' || $file === '..') {
					continue;
				}
				$full = $watermarkDir.'/'.$file;
				if (!is_file($full)) {
					continue;
				}
				$ext = strtolower(pathinfo($file, PATHINFO_EXTENSION));
				if (!in_array($ext, $allowExt, true)) {
					continue;
				}
				$watermarkList[] = ['name'=>$file,'url'=>$watermarkBaseUrl.'/'.$file];
			}
		}

		// 读取背景图目录下的文件
		if (is_dir($bgDir)) {
			$files = scandir($bgDir);
			foreach ($files as $file) {
				if ($file === '.' || $file === '..') {
					continue;
				}
				$full = $bgDir.'/'.$file;
				if (!is_file($full)) {
					continue;
				}
				$ext = strtolower(pathinfo($file, PATHINFO_EXTENSION));
				if (!in_array($ext, $allowExt, true)) {
					continue;
				}
				$bgList[] = ['name'=>$file,'url'=>$bgBaseUrl.'/'.$file];
			}
		}
		\view::set('langList',$langList);
		\view::set('pbList',$brandList);
		\view::set('logoList',$logoList);
		\view::set('watermarkList',$watermarkList);
		\view::set('bgList',$bgList);
		\view::put('pro/pic/addPicTpl');
	}
	/**
	 * @method 海报模板选择不同品牌时随机给一个商品信息
	 * @author hongzhang
	 * @copyright 2026-02-25
	 */
	public function getProInfoByBrand()
	{
		$req = \mvc::$req;
		$pb_id = $req['pb_id'];
		$lang = $req['langue'];
		// 改变语言的情况下，不改变现有的testProOInfo的其他值
		$p_id = $req['p_id'];
		$p_innum = $req['p_innum'];
		if(!$pb_id){
			$this->errorJson('未知品牌');
		}
		$proBrand = new picTpl();
		$proInfo = $proBrand->getProInfoByBrand($pb_id,$lang,$p_id,$p_innum);
		if(!$proInfo){
			$this->errorJson('该品牌下暂无商品');
		}
		$this->successJson($proInfo);
	}

	/**
	 * @method 海报模板预览图AI抠图
	 * @author hongzhang
	 * @copyright 2026-04-14
	 */
	public function getTplMattingImage()
	{
		$req = \mvc::$req;
		$source = $req['source'] ?? '';
		if (!$source) {
			$this->errorJson(-1, '图片地址不能为空');
		}
		if (empty(\mvc::$cfg['aiimg']['automatting'])) {
			$this->successJson(['image' => $source]);
		}
		// 图可丽的 mattingByUrl 需要公网可访问地址，模板图常为内网地址；
		// 这里统一先转为 base64，强制走上传文件通道(matting2)以避免回源失败。
		$sourceForMatting = $source;
		if (stripos($source, 'http') === 0) {
			$imgData = false;
			// 优先把 outfiles URL 映射到本地 files 目录读取，避免网络回源失败
			$outfilesUrl = rtrim(\mvc::$cfg['urls']['outfiles'] ?? '', '/');
			if ($outfilesUrl && stripos($source, $outfilesUrl . '/') === 0) {
				$relativePath = ltrim(substr($source, strlen($outfilesUrl)), '/');
				$relativePath = str_replace('/', DIRECTORY_SEPARATOR, $relativePath);
				$localPath = rtrim(\mvc::$cfg['dir']['files'], '\\/') . DIRECTORY_SEPARATOR . $relativePath;
				if (is_file($localPath)) {
					$imgData = @file_get_contents($localPath);
				}
			}
			if ($imgData !== false && strlen($imgData) > 0) {
				$mimeType = 'image/jpeg';
				$finfo = @finfo_open(FILEINFO_MIME_TYPE);
				if ($finfo) {
					$detectedType = @finfo_buffer($finfo, $imgData);
					@finfo_close($finfo);
					if ($detectedType && stripos($detectedType, 'image/') === 0) {
						$mimeType = $detectedType;
					}
				}
				$sourceForMatting = 'data:' . $mimeType . ';base64,' . base64_encode($imgData);
			} else {
				// 无法映射本地文件时直接回退原图，避免继续触发 mattingByUrl 报错
				$this->successJson(['image' => $source]);
			}
		}
		$aiImage = new aiImage();
		$imageData = $aiImage->matting([
			'source' => $sourceForMatting
		]);
		if (!$imageData) {
			$this->errorJson(-1, 'AI抠图处理失败');
		}
		$this->successJson(['image' => $imageData]);
	}
	/**
	 * @method 新模板入库
	 * @author hongzhang
	 * @copyright 2026-02-10
	 */
	public function savePicTpl()
	{
		$req = \mvc::$req;
		$picTpl = new picTpl();
		$data = $picTpl->add($req);
		if(!$data['status']){
			$this->errorJson(-1,$data['msg']);
		}
		$this->successJson($data);
	}
	/**
	 * @method 更新模板
	 * @author hongzhang
	 * @copyright 2026-02-10
	 */
	public function updatePicTpl()
	{
		$req = \mvc::$req;
		$id = $req['id'];
		$data = $req['data'];
		if(!$id){
			$this->errorJson('未知模板');
		}
		$picTpl = new picTpl();
		$data = $picTpl->update($id,$req);
		$this->successJson($data);
	}

	/**
	 * @method 删除模板
	 * @author hongzhang
	 * @copyright 2026-02-10
	 */
	public function delPicTpl()
	{
		$req = \mvc::$req;
		$idArr = [];
		if($req['ids']){
			$idArr = explode(',',$req['ids']);
		}
		$picTpl = new picTpl();
		$data = $picTpl->del($idArr);
		$this->successJson($data);
	}

	/**
	 * @method 应用模板界面
	 * @author hongzhang
	 * @copyright 2026-02-11
	 */
	public function setPicTpl()
	{
		$req = \mvc::$req;
		$pic_fileid = $req['id'];
		// 获取商品信息
		$picTpl = new picTpl();
		$tplShowInfo = $picTpl->getTplInfo($pic_fileid);
		\view::set('tplShowInfo',$tplShowInfo);
		// 获取模板信息
		$tplList = $picTpl->getListSimple();
		\view::set('tplList',$tplList);
		\view::set('pic_fileid',$pic_fileid);
		\view::put('pro/pic/setPicTpl');
	}

	/**
	 * @method 图片绑定模板
	 * @author hongzhang
	 * @copyright 2026-02-11
	 */
	public function bindPicTpl()
	{
		$req = \mvc::$req;
		$p_id = $req['p_id'];
		$pic_fileid = $req['pic_fileid'];
		$tpl_id = $req['tpl_id'];
		// 绑定模板
		$picTpl = new picTpl();
		$data = $picTpl->bindTpl($p_id,$pic_fileid,$tpl_id);
		$this->successJson($data);
	}

	/**
	 * @method 图片模板单元格编辑
	 * @author hongzhang
	 * @copyright 2026-02-11
	 */
	public function editPicTplCell()
	{
		$req = \mvc::$req;
		$picTpl = new picTpl();
		$picTpl->updateCell($req);
		echo json_encode(['msg'=>'']);
		exit;
	}

	/**
	 * @method 创建品牌商品
	 * @author hongzhang
	 * @copyright 2026-04-22
	 */
	public function createBrandPro(){
		$req = \mvc::$req;
		$p_ids = explode(',',$req['p_id']);
		$p_pb_id = $req['p_pb_id'];
		$pro = new pro();
		$data = [];
		foreach($p_ids as $p_id){
			$data[] = $pro->copyPro($p_pb_id,$p_id);
		}
		$this->successJson(implode(',',$data));
	}

	/**
	 * @method 获取品牌列表(除集团品牌)
	 * @author hongzhang
	 * @copyright 2026-02-28
	 */
	public function getProPbList(){
		$pro = new pro();
		$list = $pro->getAllSubProPbList();
		$data = [];
		foreach($list as $item){
			$data[] = ['key'=>$item['pb_id'],'value'=>$item['pb_name']];
		}
		$this->successJson($data);
	}

	/**
	 * @method 根据产品id获取其汽车品牌
	 * @author hongzhang
	 * @copyright 2026-02-28
	 */
	public function getComnumTbList(){
		$req = \mvc::$req;
		$p_id = $req['p_id'];
		$pro = new pro();
		// 先根据产品id回溯到集团一级的层面
 		$list = $pro->getProTbList($p_id);
		$data = [];
		foreach($list as $item){
			$data[] = ['key'=>$item['tb_id'],'value'=>$item['tb_name']];
		}
		$this->successJson($data);
	}

	/**
	 * @method 获取事业部列表
	 * @author hongzhang
	 * @copyright 2026-02-28
	 */
	public function getCompanyList(){
		$pro = new pro();
		$list = $pro->getCompanyList();
		$data = [];
		foreach($list as $item){
			$data[] = ['key'=>$item['com_id'],'value'=>$item['com_name']];
		}
		$this->successJson($data);
	}

	/**
	 * @method 品牌物料添加事业部
	 * @author hongzhang
	 * @copyright 2026-03-02
	 */
	public function addCompanyToPro(){
		$req = \mvc::$req;
		$p_id = $req['p_id'];
		$com_ids = explode(',',$req['com_id']);
		if(!$com_ids){
			$this->errorJson('请选择事业部');
		}
		$pro = new pro();
		$data = $pro->addCompanyToPro($p_id,$com_ids);
		$this->successJson($data);
	}

	/**
	 * @method 更新事业部商品
	 * @author hongzhang
	 * @copyright 2026-03-03
	 */
	public function saveCompPro(){
		$req = \mvc::$req;
		$pro = new pro();
		$data = $pro->updateCompPro($req);
		$this->successJson($data);
	}

	/**
	 * @method 删除事业部商品
	 * @author hongzhang
	 * @copyright 2026-03-03
	 */
	public function deleteCompanyToPro(){
		$req = \mvc::$req;
		$ids = $req['ids'];
		if(!$ids){
			$this->errorJson('请选择事业部');
		}
		$pro = new pro();
		$data = $pro->deleteCompanyToPro($ids);
		$this->successJson($data);
	}

	/**
	 * @method 比较修改值，返回需要同步的字段
	 * @author hongzhang
	 * @copyright 2026-03-03
	 */
	public function compareAsync(){
		$req = \mvc::$req;
		// 需要同步到事业部物料的字段
		$asyncToCompPro = ['p_state_main','p_chassis','p_model_year','p_engine','p_cc'];
		// 需要同步到商品物料的字段
		$asyncToPro = ['p_state_main','p_chassis','p_model_year','p_engine','p_cc','p_standard_name','p_unit','p_state_remark','p_iskit','p_fuel_type'];
		foreach(\mvc::$cfg['LANGS'] as $lk=>$lv){
			$asyncToCompPro[] = 'p_'.$lv['field'];
			$asyncToCompPro[] = 'p_model_'.$lv['field'];
			$asyncToPro[] = 'p_'.$lv['field'];
			$asyncToPro[] = 'p_model_'.$lv['field'];
			$asyncToPro[] = 'p_des_'.$lv['field'];
		}
		$pro = new pro();
		$data = $pro->compareAsync($req,$asyncToCompPro,$asyncToPro);
		$this->successJson($data);
	}
}