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';
$receivePath = '/home/webcode/export/wms/data/DZKA_R';
$apiUrl = 'http://119.145.38.246:11111/gateway.php';
$action = 'receive';
$loopCount = 0;
echo '[', date('Y-m-d H:i:s'), '] Start', "\r\n";
while (TRUE) {
$operationTime = date('Y-m-d H:i:s');
$request = '';
$request .= '';
$request .= '' . $appToken . '';
$request .= '' . $operationTime . '';
$request .= '' . $action . '';
$request .= '' . strtoupper(md5($operationTime . $appSecret . $action . $operationTime)) . '';
$request .= '';
$ack = curlExecute($apiUrl, base64_encode($request));
if (1 === $ack['status']) {
$response = base64_decode($ack['response']);
$success = array();
$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) : '';
$fileContent = isset($file->content) ? trim($file->content) : '';
if ('' === $fileName || '' === $fileContent) {
continue ;
}
if (FALSE !== file_put_contents($receivePath . '/' . $fileName, base64_decode($fileContent), LOCK_EX)) {
umask(0);
chmod($receivePath . '/' . $fileName, 0777);
$success[$fileName] = 1;
}
}
}
if (!empty($success)) { // 回执接收成功，通知删除回执报文
$requestBody = '';
foreach ($success as $name => $tag) {
$requestBody .= '' . $name . '';
}
$request = '';
$request .= '';
$request .= '' . $appToken . '';
$request .= '' . $operationTime . '';
$request .= 'clear';
$request .= '' . strtoupper(md5($operationTime . $appSecret . 'clear' . $operationTime)) . '';
$request .= '' . $requestBody . '';
$request .= '';
$clearAck = curlExecute($apiUrl, base64_encode($request)); // 对执行返回结果可不做分析
}
}
echo sprintf('[%s] %s', $responseCode, $responseMessage), "\r\n";
if (111 === $responseCode) { // 没有回执需要回传则跳出循环
break ;
}
}
else {
echo '发送客户端响应XML内容无法解析：', $ack['response'], "\r\n";
break ;
}
}
else {
break ;
}
++$loopCount;
if ($loopCount > 10001) { // 循环次数太多，不科学，暂时中断
break ;
}
}
echo '[', date('Y-m-d H:i:s'), '] End', "\r\n";
@unlink($flag);