From 64994ed50bf27f21ec4a17c241f72bc333ed1afe Mon Sep 17 00:00:00 2001
From: Jacek Kowalski <Jacek@jacekk.info>
Date: Wed, 20 Feb 2019 09:00:24 +0000
Subject: [PATCH] Use transaction to add mapping to the DB
---
parse.php | 30 ++++++++++++++++--------------
1 files changed, 16 insertions(+), 14 deletions(-)
diff --git a/parse.php b/parse.php
index 432b3ef..f438ba6 100644
--- a/parse.php
+++ b/parse.php
@@ -52,33 +52,35 @@
$logger->info('Checking the data for correctness...');
$weight = count($mapping);
- $replace = 0;
- $ignore = 0;
+
+ $correct = 0;
+ $incorrect = 0;
+ $old = 0;
+ $maxWeight = 0;
foreach($mapping as $id => $vehicle) {
$dbVehicle = $db->getById($id);
if($dbVehicle) {
- if((int)substr($vehicle['num'], 2) != (int)$dbVehicle['num']) {
- if($weight > $dbVehicle['weight']) {
- $replace += 1;
- } else {
- $ignore += 1;
- }
+ $maxWeight = max($maxWeight, $dbVehicle['weight']);
+ if((int)substr($vehicle['num'], 2) == (int)$dbVehicle['num']) {
+ $correct += 1;
+ } else {
+ $incorrect += 1;
}
continue;
}
$dbVehicle = $db->getByNum($vehicle['num']);
if($dbVehicle && $dbVehicle['id'] != $id) {
- $replace += 1;
+ $old += 1;
}
}
- $logger->info('Weight: '.$weight.', ignore: '.$ignore.', replace: '.$replace);
+ $logger->info('Weight: '.$weight.', correct: '.$correct.', incorrect: '.$incorrect.', old: '.$old);
$previousMapping = NULL;
- if($ignore > 0 && $ignore >= $replace) {
+ if($incorrect > $correct && $maxWeight > $weight) {
throw new Exception('Ignoring result due to better data already present');
- } elseif($replace > 0) {
- $logger->warn('Replacing DB data with the mapping');
+ } elseif($old > $correct) {
+ $logger->warn('Replacing DB data with the new mapping');
$db->clear();
} else {
$previousMapping = @json_decode(@file_get_contents($source['result']), TRUE);
@@ -88,7 +90,7 @@
if(is_array($previousMapping)) {
$logger->info('Merging previous data with current mapping');
- $mapping = $previousMapping + $mapping;
+ $mapping = $mapping + $previousMapping;
ksort($mapping);
}
--
Gitblit v1.9.1