";
        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-WXT"; //默认一个公司
            $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. $name;
            Service_FtpMessageSendlist::add($aMessage);

            $sendApi = new Baoguandan($res);
            $result = $sendApi->send($path . $name);
            if(!$result){
                throw new Exception("发送文件到单一失败");
            }
            $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()
    {
        return true;
        $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()
    {
        $fetchPath = $this->getFentchConfig();
        $root ='/home/ftp/zh';
        $receivePath = $root.$fetchPath['baoguan']['receive']['path'];
//        $receivePath = 'E:/ftp/zh_baoguan/send/';
//        $dir = APPLICATION_PATH . '/../data/baoguandanreceive-tmp/';
        $dir = $receivePath.'/';
        $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 != '..' && !is_dir($dir . $baseName)) {
                $db = Common_Common::getAdapter();
                $localFile = $dir . $baseName;
                $zsDirFile = $moveDir . $baseName;
//                echo $zsDirFile;
//                echo PHP_EOL;
//                die();
                $db->beginTransaction();
                try {
                    $parseObj = new Api_Des_Receiving();
                    $result = $parseObj->parsebaoguandanProcess($localFile);
                    var_dump($result);
                    if ($result !== true) {
                        throw new \Exception("报文无法解析" . var_export($result, true));
                    }
                    $db->commit();
                    rename($localFile, $zsDirFile);
                    //$db->rollBack();
                } catch (\Exception $e) {
//                    echo $e;
                    $db->rollBack();
                    $failPath = dirname($dir) . '/receivefailse/';
                    if (!file_exists($failPath)) {
                        mkdir($failPath, 0777, true);
                    }
                    $failName = pathinfo($baseName, PATHINFO_FILENAME) . '.error';
                    rename($localFile, $failPath . $baseName);
                    file_put_contents($failPath . $failName, $e->__toString());
                    //rename($zsDirFile,$moveErrorDir.$baseName);
                    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 '报文无法解析';
        }
        //exit;
        if (isset($restArray['ResponseCode']) && isset($restArray['ErrorMessage']) && isset($restArray['ClientSeqNo'])) {
            $ClientSeqNo = $restArray['ClientSeqNo'];
            if(empty($ClientSeqNo)){
                return "报关单号为空";
            }
            $dmhInfo = Service_DesMessageHead::getByField($ClientSeqNo, 'dmh_no');
            //var_dump($dmhInfo);
            //exit;
            if (empty($dmhInfo)) {
                return '找不到对应报关单信息';
            }
            $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);
            return true;
        }
        if(isset($restArray['CUS_CIQ_NO']) && !empty($restArray['CUS_CIQ_NO'])){
            var_dump($restArray['CUS_CIQ_NO']);
            die();
            $dmhInfo = Service_DesMessageHead::getByField($restArray['CUS_CIQ_NO'], 'seq_no');
            if (empty($dmhInfo)) {
                return '找不到对应报关单信息';
            }
            $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' => $dmhInfo['des_status'],
                'user_id' => 0,
                'type' => '2',
                'file_path' => $zsDirFile
            );
            Service_DesMesssageLog::add($dmhLog);
            return true;

        }
        return false;
    }

}