0,
'response' => $response,
);
if (curl_errno($curl)) {
$ack['response'] = curl_error($curl);
}
elseif (200 === (int) $httpCode) {
$ack['status'] = 1;
}
curl_close($curl);
return $ack;
}
// 密钥、令牌
$appSecret = '76EC82BCE17F93667477774A4CBF0BB5';
$appToken = 'F00FD5D2-1CD7-42AB-0274-F58907795BA2';
$sendPath = '/home/webcode/export/wms/data/DZKA';
$apiUrl = 'http://119.145.38.246:11111/gateway.php';
$action = 'send';
$maxSize = 50; // 每次推送报文数量
echo '[', date('Y-m-d H:i:s'), '] Start', "\r\n";
$dirHandler = @opendir($sendPath);
if (FALSE === $dirHandler) {
echo '报文目录无法读取', "\r\n";
}
else {
$success = 0;
$responseBody = '';
while ((FALSE !== $fileName = readdir($dirHandler))) {
if ('.' !== $fileName && '..' !== $fileName && is_file($sendPath . '/' . $fileName)) {
$responseBody .= '';
$responseBody .= '' . $fileName . '';
$responseBody .= '' . base64_encode(file_get_contents($sendPath . '/' . $fileName)) . '';
$responseBody .= '';
++$success;
}
if ($success >= $maxSize) {
$operationTime = date('Y-m-d H:i:s');
$request = '';
$request .= '';
$request .= '' . $appToken . '';
$request .= '' . $operationTime . '';
$request .= '' . $action . '';
$request .= '' . strtoupper(md5($operationTime . $appSecret . $action . $operationTime)) . '';
$request .= '' . $responseBody . '';
$request .= '';
$ack = curlExecute($apiUrl, base64_encode($request));
if (1 === $ack['status']) {
$response = base64_decode($ack['response']);
$xmlObj = @simplexml_load_string($response);
if (FALSE !== $xmlObj) {
$responseCode = isset($xmlObj->code) ? (int) $xmlObj->code : '';
$responseMessage = isset($xmlObj->message) ? $xmlObj->message : '';
if (isset($xmlObj->code) && 100 === (int) $xmlObj->code) { // 数据推送成功删除报文
if (isset($xmlObj->fileSet)) {
foreach ($xmlObj->fileSet->file as $file) {
$fileName = isset($file->name) ? trim($file->name) : '';
if ('' !== $fileName && is_file($sendPath . '/' . $fileName)) {
@unlink($sendPath . '/' . $fileName);
}
}
}
}
echo sprintf('[%s] %s', $responseCode, $responseMessage), "\r\n";
}
else {
echo '发送客户端响应XML内容无法解析1：', $ack['response'], "\r\n";
}
}
$success = 0;
$responseBody = '';
}
}
if ($success) { // 还有残留继续推送
$operationTime = date('Y-m-d H:i:s');
$request = '';
$request .= '';
$request .= '' . $appToken . '';
$request .= '' . $operationTime . '';
$request .= '' . $action . '';
$request .= '' . strtoupper(md5($operationTime . $appSecret . $action . $operationTime)) . '';
$request .= '' . $responseBody . '';
$request .= '';
$ack = curlExecute($apiUrl, base64_encode($request));
var_dump($ack);
if (1 === $ack['status']) {
$response = base64_decode($ack['response']);
$xmlObj = @simplexml_load_string($response);
if (FALSE !== $xmlObj) {
$responseCode = isset($xmlObj->code) ? (int) $xmlObj->code : '';
$responseMessage = isset($xmlObj->message) ? $xmlObj->message : '';
if (isset($xmlObj->code) && 100 === (int) $xmlObj->code) { // 数据推送成功删除报文
if (isset($xmlObj->fileSet)) {
foreach ($xmlObj->fileSet->file as $file) {
$fileName = isset($file->name) ? trim($file->name) : '';
if ('' !== $fileName && is_file($sendPath . '/' . $fileName)) {
@unlink($sendPath . '/' . $fileName);
}
}
}
}
echo sprintf('[%s] %s', $responseCode, $responseMessage), "\r\n";
}
else {
echo '发送客户端响应XML内容无法解析2：', $ack['response'], "\r\n";
}
}
}
closedir($dirHandler);
}
echo '[', date('Y-m-d H:i:s'), '] End', "\r\n";
@unlink($flag);