$matrixProductsIds = SalaryHelper::getMatrixProductsIds();
}
- if (!empty($result['checks']) && count($result['checks']) < 300) {
+ if (!empty($result['checks']) && count($result['checks']) < 1000) {
foreach ($result["checks"] as $arr) {
$check_id = $arr["id"];
private function insertDataSales($values, $tableName, $columns) {
$chunkValues = array_chunk($values, 1000);
- // Логирование общего количества значений и количества фрагментов
- file_put_contents(self::OUT_DIR . '/error_upload.txt', PHP_EOL . "Total values: " . count($values), FILE_APPEND);
- file_put_contents(self::OUT_DIR . '/error_upload.txt', PHP_EOL . "Total chunks: " . count($chunkValues), FILE_APPEND);
foreach ($chunkValues as $key => $rows) {
// Преобразование значений в $rows перед вставкой
}
}
-
- // Логирование текущего фрагмента перед попыткой вставки
- $jsonRows = json_encode($rows, JSON_UNESCAPED_UNICODE);
- file_put_contents(self::OUT_DIR . '/sales_upload.json', PHP_EOL . "Chunk $key: " . $jsonRows, FILE_APPEND);
try {
- file_put_contents(self::OUT_DIR . '/sales_upload2.json', PHP_EOL . "Inserting chunk $key", FILE_APPEND);
$transaction = \Yii::$app->db->beginTransaction();
Yii::$app->db->createCommand()->batchInsert($tableName, $columns, $rows)->execute();
$transaction->commit();
} catch (Exception $e) {
- // $transaction->rollBack();
+ $transaction->rollBack();
$errorString = substr($e->getMessage(), 0, 2000);
- // InfoLogService::setInfoLog(__FILE__, __LINE__, $tableName , 'error_id_25');
- // InfoLogService::setInfoLog(__FILE__, __LINE__, $errorString , 'error_id_25_22');
- // LogService::apiErrorLog(json_encode(["error_id" => 25, "error" => $errorString], JSON_UNESCAPED_UNICODE));
- file_put_contents(self::OUT_DIR . '/sales_upload3.json', PHP_EOL . "Error in chunk $key: " . $errorString, FILE_APPEND);
- file_put_contents(self::OUT_DIR . '/sales_upload3.json', PHP_EOL . "Failed chunk data: " . $jsonRows, FILE_APPEND);
+ InfoLogService::setInfoLog(__FILE__, __LINE__, $tableName , 'error_id_25');
+ InfoLogService::setInfoLog(__FILE__, __LINE__, $errorString , 'error_id_25_22');
+ LogService::apiErrorLog(json_encode(["error_id" => 25, "error" => $errorString], JSON_UNESCAPED_UNICODE));
+
}
}
}