Ntr

Administrator
1 parent cdd2c7b6
Showing 2 changed files with 13 additions and 16 deletions Show diff stats
common/modules/product/models/Import.php
console/controllers/ImportController.php
@@ -60,6 +60,11 @@ class Import extends Model {
     public function goPrices($from = 0, $limit = null) {
         set_time_limit(0);
         $new_products = $linked_products = 0;
+        if (file_exists(Yii::getAlias('@uploadDir/goPrices.lock'))) {
+            return 'Task already executed';
+        }
+        $ff = fopen(Yii::getAlias('@uploadDir/goPrices.lock'), 'w+');
+        fclose($ff);
  
         if ( !($handle = $this->getProductsFile('uploadFilePrices')) ) {
             $this->errors[] = 'File not found';
@@ -208,7 +213,7 @@ class Import extends Model {
         if ($result['end']) {
             unlink(Yii::getAlias('@uploadDir') .'/'. Yii::getAlias('@uploadFilePrices'));
         }
-
+        unlink(Yii::getAlias('@uploadDir/goPrices.lock'));
         return $result;
     }
  
@@ -216,6 +221,11 @@ class Import extends Model {
  
         set_time_limit(0);
         $new_products = $linked_products = 0;
+        if (file_exists(Yii::getAlias('@uploadDir/goProducts.lock'))) {
+            return 'Task already executed';
+        }
+        $ff = fopen(Yii::getAlias('@uploadDir/goProducts.lock'), 'w+');
+        fclose($ff);
  
         if ( !($handle = $this->getProductsFile('uploadFileProducts')) ) {
             $this->errors[] = 'File not found';
@@ -506,7 +516,7 @@ class Import extends Model {
         if ($result['end']) {
             unlink(Yii::getAlias('@uploadDir') .'/'. Yii::getAlias('@uploadFileProducts'));
         }
-
+        unlink(Yii::getAlias('@uploadDir/goProducts.lock'));
         return $result;
     }
  
@@ -50,28 +50,15 @@ class ImportController extends Controller {
     }
  
     public function actionProducts() {
-        if (file_exists(Yii::getAlias('@uploadDir/goProducts.lock'))) {
-            $this->errors[] = 'Task already executed';
-            return Controller::EXIT_CODE_ERROR;
-        }
-        $ff = fopen(Yii::getAlias('@uploadDir/goProducts.lock'), 'w+');
-        fclose($ff);
         $model = new Import();
         $model->goProducts(0, null);
-        unlink(Yii::getAlias('@uploadDir/goProducts.lock'));
         return Controller::EXIT_CODE_NORMAL;
     }
  
     public function actionPrices() {
-        if (file_exists(Yii::getAlias('@uploadDir/goPrices.lock'))) {
-            $this->stderr('Task already executed');
-            return Controller::EXIT_CODE_ERROR;
-        }
-        $ff = fopen(Yii::getAlias('@uploadDir/goPrices.lock'), 'w+');
-        fclose($ff);
+
         $model = new Import();
         $data = $model->goPrices(0, null);
-        unlink(Yii::getAlias('@uploadDir/goPrices.lock'));
         return Controller::EXIT_CODE_NORMAL;
     }