<?php
require_once ('config.php');
$flagFile = APPLICATION_PATH . '/../data/log/submitShipBatch.lock';
if (@file_exists($flagFile)) {
    echo 'Anather process is running.'."\r\n\r\n";
    echo $flagFile."\r\n";
    exit();
}
$link = fopen($flagFile, 'wb');
fclose($link);
define('RUNTIME', '[' . date('Y-m-d H:i:s') . '] ');
echo RUNTIME . "Starting.\r\n";

try {
	//$ftProcess = new Service_FtpReceiveProcess();
	$ftProcess = new Service_FtpMessageProcess();
	$sendList = Service_FtpMessageSendlist::getByCondition(array('fmt_code'=>'MCK', 'fml_status'=>1));
	foreach($sendList as $sendRow) {
		$affect = $ftProcess->updateSendMessage($sendRow);
		if(!$affect) {
			echo "创建出库报文失败[".$sendRow['refercence_no']."]\r\n";
			continue;
		}
		$result = $ftProcess->ftpSendMessage($sendRow['fml_id']);
		if(!$result) {
			echo "发送出库报文失败[".$sendRow['refercence_no']."]\r\n";
			continue;
		}
		//修改状态
		$aUpdate['fml_status'] = 2;
		$aUpdate['fml_update_time'] = date('Y-m-d H:i:s');
		Service_FtpMessageSendlist::update($aUpdate, $sendRow['fml_id']);
		echo "发送出库报文成功[".$sendRow['refercence_no']."]\r\n";
	}	
} catch (Exception $e) {
    @unlink($flagFile);
    echo '[' . date('Y-m-d H:i:s') . '] Fail Exception:' . $e->getMessage() ."\r\n";
}

echo "[" . date('Y-m-d H:i:s') . "] End run\r\n\r\n";
@unlink($flagFile);