";
        print_r($data);
        exit;*/
        return $data;
    }

    /**
     * Note:生成xml
     * User: Yao
     * Date: 2019/12/24
     * Time: 13:35
     * @param $data
     */
    protected function toXml($data){
        $xml = Common_ArrayToXml::convert($data,array(
            'rootElementName'=>'DecMessage',
            '_attributes'=>array(
                'xmlns'=>'http://www.chinaport.gov.cn/dec',
                'Version'=>'4.8'
            ),

        ),
            true,
            'UTF-8',
            '1.0',
            [
                'formatOutput' => true,
                'encoding'=>'UTF-8'
            ]
        );
        return $xml;
    }
    /**
     * @todo 获取file的名称
     */
    public function getFile(){
        return $this->file;
    }
    /**
     * @todo 报关单发送
     */
    public function sendbaoguandan($id){
        $return = array(
            'state'=>0,
            'message'=>'faise',
        );
        try{
            $xml = $this->getXmlById($id);

            $path = APPLICATION_PATH . '/../data/baoguan/baoguandan/' . date('Ymd') . '/';
            if (!is_dir($path)) {
                mkdir($path, 0777, true);
            }
            $name = "baoguandan." . time() . "." . $id . ".xml";
            file_put_contents($path . $name, $xml);

            $company_code = "ZH"; //默认一个公司
            $res = [];
            if($this->desHead['bpedbh_id']>0){
                $bgpdh = Service_BgPriEntryDataDetailBodyHead::getByField($this->desHead['bpedbh_id'],'bpedbh_id');
                if(!empty($bgpdh)){
                    $bgpreData = Service_BgPriEntryData::getByField($bgpdh['bped_id'],'bped_id');
                    if (!empty($bgpreData)) {
                        $company_code = $bgpreData['company_code'];
                    }
                }
            }
            if($company_code!=''){
                $bgCompany = Service_BgCompany::getByField($company_code, 'company_code');
                if (!empty($bgCompany)) {
                    $resourceRow = json_decode($bgCompany['config_value'], true);
                    if (!empty($resourceRow)) {
                        $res = $resourceRow['baoguan']['send'];
                    }
                }
            }


            $aMessage['fmt_code'] = 'baoguandan';
            $aMessage['fmt_type'] = 'baoguandan';
            $aMessage['refercence_no'] = $this->desHead['dmh_no'];
            $aMessage['fml_status'] = 2;
            $aMessage['fml_add_time'] = date('Y-m-d H:i:s');
            $aMessage['company_code'] = $company_code;
            $aMessage['fml_path'] = $path;
            Service_FtpMessageSendlist::add($aMessage);

            $sendApi = new Baoguandan($res);
            $result = $sendApi->send($xml);
            $return['state'] = 1;
            $return['message'] = "发送成功";
            $this->result = $return;
            return true;
        }catch (Exception $e){
            $return['message'] = $e->getMessage();
            $this->result = $return;
            return false;
        }
        $filename = $path."/".$id."_".date("ymdhis",time()).".xml";
        file_put_contents($filename,$xml);
        $sendinfo = $this->getSendConfig();
        //var_dump($sendinfo);
        $config = $sendinfo['config'];
        $param['host'] = $config['host'];
        $param['port'] = $config['port'];
        $param['tube'] = $config['tube'];
        $obj = new Service_Pheanstalk($param);
        $sendName = basename($filename);
        $message = file_get_contents($filename);
        $this->file = $filename;
        if ($obj->putMessage($message, $sendName)) {
            $result = true;
        } else {
            $result = false;
        }
        return $result;
    }
    public function getResult(){
        return $this->result;
    }
    /**
     * @todo 报关单接收回执
     */
    public function receivingbaoguandan(){
        $dir = $path = APPLICATION_PATH."/../data/baoguandanreceive/";
        $path = $path.date("Y/m",time());
        if(!file_exists($path)){
            mkdir($path,0777,true);
        }
        $sendinfo = $this->getFentchConfig();
        $config = $sendinfo['config'];
        $param['host'] = $config['host'];
        $param['port'] = $config['port'];
        $param['tube'] = $config['tube'];
        //print_r($param);
        //exit;
        $stalk = new Pheanstalk($param['host'], $param['port']);
        //$stalk = new Service_Pheanstalk($param);
        //var_dump($stalk);
        //exit;
        if(!is_dir($dir)){
            mkdir($dir,0777,true);
        }
        $moveDir = APPLICATION_PATH . '/../data/baoguandanreceive-tmp/';
        if(!is_dir($moveDir)){
            mkdir($moveDir,0777,true);
        }
        try {
            $number = 5000;
            while ($number > 0) {
                $tube = $param['tube'];
                //$tube = 'baoguandanfetch';
                $job = $stalk->watchOnly($tube)->reserve(4);
                if (!$job) {
                    return false;
                }
                //echo "
";
                $xml = $job->getData();
                //var_dump($data);
                //exit;
                //$xml = json_decode($data,true);
                //$filename = $data['name'];
                //$xml = $data['xml'];
                $filename = time().uniqid().rand(1000,9999).'.xml';

                if($xml!=''&&$filename!=''){
                    $localFile = $dir.$filename;
                    if(file_put_contents($localFile,$xml,FILE_APPEND)){
                        rename($localFile, $moveDir . basename($localFile));
                        $stalk->delete($job);
                    };
                }
                $number--;
            }
        } catch (Exception $exception) {
            echo $exception->getMessage() . "\n";
            return false;
        }
    }
    /**
     * @todo 报关单解析回执
     */
    public function parsebaoguandan(){
        $dir = APPLICATION_PATH . '/../data/baoguandanreceive-tmp/';
        $moveDir =   APPLICATION_PATH . '/../data/baoguandanreceive/' . date('Ymd') . '/';
        $moveErrorDir = APPLICATION_PATH . '/../data/baoguandanreceive-error/';
        if(!is_dir($moveErrorDir)){
            mkdir($moveErrorDir,0777,true);
        }
        if(!is_dir($moveDir)){
            mkdir($moveDir,0777,true);
        }
        $dirSource = opendir($dir);
        while($baseName = readdir($dirSource)){
            if($baseName!='.' && $baseName!='..'){
                $db = Common_Common::getAdapter();
                $localFile=$dir.$baseName;
                $zsDirFile = $moveDir.$baseName;
                //var_dump($localFile);
                //var_dump($zsDirFile);
                //exit;
                rename($localFile,$zsDirFile);
                $db->beginTransaction();
                try {
                    $parseObj = new Api_Des_Receiving();
                    $parseObj->parsebaoguandanProcess($zsDirFile);
                    $db->commit();
                    //$db->rollBack();
                }catch (Exception $e){
                    $db->rollBack();
                    //rename($zsDirFile,$moveErrorDir.$baseName);
                    echo $e;
                    echo $baseName;
                }
            }
        }
        closedir($dirSource);
    }
    /**
     * @todo 解析报关单
     */
    public function parsebaoguandanProcess($zsDirFile){
        //$zsDirFile = "E:/mycode/kjqinguan/kjqinguan/trunk/data/baoguan-tmp/Failed_24_20211211003_2021121316144490707289.xml";
        $fileContent = file_get_contents($zsDirFile);
        $restArray = Common_Common::simpleXmlToArray($fileContent);
        if (!is_array($restArray)) {
            return $result['message'] = '报文无法解析';
        }
        //exit;
        if(isset($restArray['ResponseCode'])&&isset($restArray['ErrorMessage'])&&isset($restArray['ClientSeqNo'])){
            $ClientSeqNo = $restArray['ClientSeqNo'];
            $dmhInfo = Service_DesMessageHead::getByField($ClientSeqNo,'dmh_no');
            //var_dump($dmhInfo);
            //exit;
            if(!empty($dmhInfo)){
                $state_to = 1;
                //写日志
                if($restArray['ResponseCode']=='0'){
                    //接收成功
                    $desRow = array(
                        'seq_no'=>$restArray['SeqNo'],
                        'des_status'=>2,
                        'update_time'=>date("Y-m-d H:i:s",time())
                    );
                    Service_DesMessageHead::update($desRow,$dmhInfo['dmh_id'],'dmh_id');
                    $state_to =2;
                }
                //写日志
                $dmhLog = array(
                    'note'=>"接收报关单回执:".$fileContent,
                    'add_time'=>date("Y-m-d H:i:s",time()),
                    'dmh_id'=>$dmhInfo['dmh_id'],
                    'state_from'=>$dmhInfo['des_status'],
                    'state_to'=>$state_to,
                    'user_id'=>0,
                    'type'=>'2',
                    'file_path'=>$zsDirFile
                );
                Service_DesMesssageLog::add($dmhLog);
            }
        }
    }

}