const OUT_DIR =
// __DIR__ . "/../json";
- "/www/api2/json";
+ "/var/www/erp24/api2/json";
// "/var/www/www-root/data/www/api.bazacvetov24.ru/data/json";
public function actionRequest() {
return $this->asJson(['error' => ['code' => 400, 'message' => 'result empty']]);
}
- $requestId = '';
+ $requestIdText = '';
if (!empty($result["request_id"])) {
- $requestId = $result["request_id"];
+ $requestIdText = $result["request_id"];
$fl = "request_id_" . $result["request_id"];
} else {
$fl = time();
}
- file_put_contents(self::OUT_DIR . '/error_upload.txt',
- PHP_EOL . "requestId: " . $requestId, FILE_APPEND);
//InfoLogService::setInfoLog(__FILE__, __LINE__, 'upload_' . $fl . '.json' , 'info_id_25_1');
file_put_contents(self::OUT_DIR . '/upload_' . $fl . '.json', PHP_EOL . $request);
}
$mess["result"] = true;
$checks_dell = "";
- $request_id = time();
- file_put_contents(self::OUT_DIR . '/error_upload.txt',
- PHP_EOL . "request_id: " . $request_id, FILE_APPEND);
+ $requestId = time();
if (array_key_exists("request_id", $result) && !empty($result["request_id"])) {
- $request_id = $result["request_id"];
+ $requestId = $result["request_id"];
}
$type_price = "Розничная цена";
- file_put_contents(self::OUT_DIR . '/error_upload.txt',
- PHP_EOL . "request_id 2: " . $request_id, FILE_APPEND);
- if (!empty($request_id)) {
- $apiCron = ApiCron::find()->select(['json_post'])->where(['request_id' => $request_id])->one();
+
+ if (!empty($requestId)) {
+ $apiCron = ApiCron::find()->select(['json_post'])->where(['request_id' => $requestId])->one();
if ($apiCron) {
$jsn = json_decode($apiCron->json_post, true, 512, JSON_UNESCAPED_UNICODE);
$start_time = $jsn["checks"]["start_time"] ?? date('Y-m-d 00:00:00', time() - 3 * 86400);
$end_time = $jsn["checks"]["end_time"] ?? date('Y-m-d 00:00:00', time());
$checks_dell = $jsn["checks_dell"] ?? "";
$type_price = $jsn["prices"]["type_price"] ?? "Розничная цена";
- file_put_contents(self::OUT_DIR . '/error_upload.txt',
- PHP_EOL . "start_time: " . $start_time, FILE_APPEND);
+
ApiCron::updateAll(['status' => 1, 'date_up' => date('Y-m-d H:i:s')],
- ['and', ['status' => 0], ['request_id' => $request_id]]);
+ ['and', ['status' => 0], ['request_id' => $requestId]]);
- file_put_contents(self::OUT_DIR . '/request_api_cron.txt', PHP_EOL . date("d.m.Y H:i:s", time()) . "request_id=$request_id $start_time - $end_time ", FILE_APPEND);
+ file_put_contents(self::OUT_DIR . '/request_api_cron.txt', PHP_EOL . date("d.m.Y H:i:s", time()) . "request_id=$requestId $start_time - $end_time ", FILE_APPEND);
}
}
}
}
- file_put_contents(self::OUT_DIR . '/error_upload.txt',
- PHP_EOL . $update , FILE_APPEND);
-
- if (!empty($result['write_offs'])) {
+ if (!empty($result['write_offs'])) {
if (!empty($start_time) and !empty($end_time)) {
if ($update) {
WriteOffs::deleteAll(['and', ['>=', 'date', $start_time], ['<=', 'date', $end_time]]);
}
// SalesUpdate::updateAll(['operation' => 'Удален'], ['and', ['>=', 'date', $start_time], ['<=', 'date', $end_time]]);
- file_put_contents(self::OUT_DIR . '/check_dell.txt', PHP_EOL . date("d.m.Y H:i:s",time()). " regquest_id=$request_id Удаление $start_time - $end_time ", FILE_APPEND);
+ file_put_contents(self::OUT_DIR . '/check_dell.txt', PHP_EOL . date("d.m.Y H:i:s",time()). " regquest_id=$requestId Удаление $start_time - $end_time ", FILE_APPEND);
}
$matrixProductsIds = [];
if (!empty($result['checks'])) {
$matrixProductsIds = SalaryHelper::getMatrixProductsIds();
}
- file_put_contents(self::OUT_DIR . '/error_upload.txt',
- PHP_EOL . count($result['checks']) , FILE_APPEND);
- if (!empty($result['checks']) && count($result['checks']) < 200) {
- file_put_contents(self::OUT_DIR . '/error_upload.txt',
- PHP_EOL . "if" , FILE_APPEND);
+ if (!empty($result['checks']) && count($result['checks']) < 1000) {
+
foreach ($result["checks"] as $arr) {
$check_id = $arr["id"];
} catch (Exception $e) {
file_put_contents(self::OUT_DIR . '/log_error.txt', PHP_EOL . date("d.m.Y H:i:s",time()). $e->getMessage() . " " . $e->getLine(), FILE_APPEND);
} finally {
- LogService::apiDataLogs(1, json_encode($mess, JSON_UNESCAPED_UNICODE), $requestId);
+ LogService::apiDataLogs(1, json_encode($mess, JSON_UNESCAPED_UNICODE), $requestIdText);
}
return $this->asJson(['response' => true]);
$chunkValues = array_chunk($values, 1000);
foreach ($chunkValues as $key => $rows) {
- // Преобразование значений в $rows перед вставкой
- // foreach ($rows as &$row) {
- // if (isset($row['held'])) {
- // Приведение значений к булевому типу
- // $row['held'] = (bool)$row['held'];
- // }
- // }
try {
$transaction = \Yii::$app->db->beginTransaction();