query('update catalogs_config set value=value+1 where id=5'); $status = @$db->super_query('select value from catalogs_config where id=6',$db); if($status[0]['value'] ==1){ exit; } else { $db->query('update catalogs_config set value=1 where id=6'); sleep(300); } $d1 = @$db->super_query('select value from catalogs_config where id=5',$db); $num = $d1[0]['value']; } else{ exit; } $_SERVER['DOCUMENT_ROOT'] = realpath(dirname(__FILE__)); $tmpfname = $_SERVER['DOCUMENT_ROOT'] . "/cron/file_1_duble.csv"; $handle24 = fopen($tmpfname, "w"); //unlink($_SERVER['DOCUMENT_ROOT'] . "/tmp/noDB_mod.csv"); //$link = mysql_connect(DBHOST,DBNAME,DBPASS); //if(@$link) echo "ok"; //else echo "not"; //$fg = @fopen(dirname( __FILE__ )."/cron/file_1.csv","r"); //if(!@$fg) exit; //@fclose($fg); //exit; $rrrrrrrrrrrr = array(); $last_pid = ""; $ma = array(); $su = 0; $su2 = 0; $yy = @fopen(dirname ( __FILE__ )."/counter.txt","r+"); $su = trim(fread($yy,128)); fclose($yy); $fg = fopen(dirname( __FILE__ )."/cron/file_1.csv","r"); if(@$fg){ $cot = ""; while(!feof($fg)) $cot = $cot.fread($fg,512); @fclose($fg); } $cot = explode("\n",$cot); if(trim($su)<=0 && count($cot)>2){ $fg = @fopen(dirname ( __FILE__ )."/tmp/noDB_mod.csv","w+"); fclose($fg); } for($i=$su;$i"; $line = explode(";",$cot[$i]); if(trim($line[3])>0){ //$db->query("UPDATE `catalogs_modifications` SET `active` = '1' WHERE `code` = '".trim($line[0])."';"); } ///////////////////////////////////////////// Ïîèñê Ãîðîäà. Åñëè íåò, òî ñîçäàåì åãî. $row_city = @$db->super_query("SELECT * FROM `catalogs_cities` WHERE `name`='".trim($line[4])."' LIMIT 1;"); if(!@$row_city['id']){ @$db->query("INSERT INTO `catalogs_cities` (`name`) VALUES ('".trim($line[4])."');"); $row_city['id'] = $db->insert_id(); } echo "Ãîðîä:".$row_city['id']."
"; ///////////////////////////////////////////// Ïðîâåðêà ïðîäóêòà â ãîðîäàõ $protect = @$db->super_query("SELECT * FROM catalogs_keys_products_cities WHERE mod_code='".trim($line[0])."' LIMIT 1;"); $pr = @$db->super_query("SELECT * FROM catalogs_modifications WHERE code='".trim($line[0])."' LIMIT 1;"); ///////////////////////////////////////////// Îáíóëÿåì êîë-âî â ãîðîäàõ /* if($last_pid!=trim($pr['product_id'])){ $last_pid = trim($pr['product_id']); if(trim($pr['product_id'])!='') $db->query("DELETE FROM `catalogs_keys_products_cities` WHERE `product_id` = '".trim($pr['product_id'])."';"); } */ if($last_pid!=trim($line[0])){ $last_pid = trim($line[0]); if(trim($line[0])!='')$db->query("DELETE FROM `catalogs_keys_products_cities` WHERE `mod_code` = '".trim($line[0])."';"); } ///////////////////////////////////////////// if(!@$protect['product_id'] && @$pr['product_id']){ @$db->query("INSERT INTO `catalogs_keys_products_cities` (`product_id`,`mod_code`,`count`,`mktime`,`city_id`) VALUES ('".@$pr['product_id']."','".trim($line[0])."','".trim($line[3])."','".time()."','".$row_city['id']."');"); } echo "Ïðîäóêò ID:".$pr['product_id']."
"; ///////////////////////////////////////////// ///////////////////////////////////////////// Ïðîâåðêà òîâàðà íà ñóùåñòâîâàíèå è îáíîâëåíèå â ãîðîäå. $no_DB = 0; /* $product = $db->super_query("SELECT f1.product_id as in_city, f2.product_id as in_modification, f2.product_id as in_modification FROM catalogs_keys_products_cities f1 LEFT JOIN catalogs_modifications f2 ON f2.code='".trim($line[0])."' WHERE f1.mod_code='".trim($line[0])."' AND f1.city_id='".$row_city['id']."' LIMIT 1;"); */ $product = $db->super_query("SELECT f2.product_id as in_modification FROM catalogs_modifications f2 WHERE f2.code='".trim($line[0])."' LIMIT 1;"); $catalogs_keys_products_cities = $db->super_query("SELECT f1.product_id FROM catalogs_keys_products_cities f1 WHERE f1.product_id='".@$product['in_modification']."' and f1.mod_code='".trim($line[0])."' AND f1.city_id='".$row_city['id']."' LIMIT 1;"); if(!@$catalogs_keys_products_cities['product_id']){print'not city v keys
'; $db->query("INSERT INTO `catalogs_keys_products_cities` (`product_id`,`mod_code`,`count`,`mktime`,`city_id`) VALUES ('".@$pr['product_id']."','".trim($line[0])."','".trim($line[3])."','".time()."','".$row_city['id']."');"); print "INSERT INTO `catalogs_keys_products_cities` (`product_id`,`mod_code`,`count`,`mktime`,`city_id`) VALUES ('".@$pr['product_id']."','".trim($line[0])."','".trim($line[3])."','".time()."','".$row_city['id']."');
"; } //$product = $db->super_query("SELECT f2.product_id as in_modification, f2.product_id as in_modification FROM catalogs_modifications f2 //WHERE f2.code='".trim($line[0])."' LIMIT 1;"); echo "Øàã 3:".$product['in_modification']."
"; //if(@$product['in_modification'] && !@$product['in_city'] && trim($line[3])>0){ ////////$db->query("INSERT INTO `catalogs_keys_products_cities` (`product_id`,`mod_code`,`count`,`mktime`,`city_id`) VALUES ///////('".@$product['in_modification']."','".trim($line[0])."','".trim($line[3])."','".time()."','".$row_city['id']."');"); //}else if(@$product['in_modification']){ $db->query("UPDATE `catalogs_keys_products_cities` SET `count`='".trim($line[3])."' WHERE `product_id`='".@$product['in_modification']."' AND `mod_code`='".trim($line[0])."' AND `city_id`=".trim($row_city['id']).";"); print "UPDATE `catalogs_keys_products_cities` SET `count`='".trim($line[3])."' WHERE `product_id`='".@$product['in_modification']."' AND `mod_code`='".trim($line[0])."' AND `city_id`=".trim($row_city['id']).";
"; }elseif(!@$product['in_modification']) $no_DB = 1; ///////////////////////////////////////////// ///////////////////////////////////////////// Ðàáîòà ñ ìîäèôèêàöèÿìè if(@$product['in_modification'] && trim($line[0])!='') $row2 = $db->super_query("SELECT COUNT(*) as count FROM `catalogs_keys_products_cities` WHERE `count`>0 AND `product_id`='".@$product['in_modification']."' AND `mod_code` = '".trim($line[0])."';"); echo "Øàã 4:".$row2['count']."
"; if(trim($line[2])>0){$cine = trim($line[2]);$cine_last = trim($line[1]);$sale[] = 1;} else{$cine = trim($line[1]);$cine_last = 0;$sale[] = 0;} if(trim($line[3])<=0 && trim($line[0])!='' && $row2['count']<=0){ $db->query("UPDATE `catalogs_modifications` SET `active` = '0', `cine`=".$cine.", `cine_last`=".$cine_last." WHERE `code` = '".trim($line[0])."';"); }else if(trim($line[3])>0) $db->query("UPDATE `catalogs_modifications` SET `active` = '1', `cine`=".$cine.", `cine_last`=".$cine_last." WHERE `code` = '".trim($line[0])."';"); $p = $db->super_query("select COUNT(*) as count from catalogs_modifications where `active`>0 AND product_id='".$product['in_modification']."' and cine_last>0 GROUP BY cine"); $p2 = $db->super_query("select COUNT(*) as count from catalogs_modifications where `active`>0 AND product_id='".$product['in_modification']."'"); print "".$p['count'].''; $sale = ($p['count']>0 && $p['count']<$p2['count']) ? 1 : 0; $res1 = $db->query("UPDATE `catalogs_products` SET `sale`='".$sale."' WHERE `id`=".trim(@$product['in_modification'])." LIMIT 1;"); ///////////////////////////////////////////// ///////////////////////////////////////////// Âêëþ÷åíèå è âûêëþ÷åíèå ïðîäóêòà è ïîäñ÷åò åãî ìîäèôèêàöèé. if(@$product['in_modification']){ $row2 = $db->super_query("SELECT COUNT(*) as count FROM `catalogs_modifications` WHERE `active`>0 AND `product_id`=".@$product['in_modification'].";"); if(trim($row2['count']) <= 0) $db->query("UPDATE `catalogs_products` SET `count_modifications` = 0 WHERE `id` = '".@$product['in_modification']."';"); //else $db->query("UPDATE `catalogs_products` SET `count_modifications` = '".trim($row2['count'])."',`active` = '1' WHERE `id` = '".@$product['in_modification']."';"); else $db->query("UPDATE `catalogs_products` SET `count_modifications` = '".trim($row2['count'])."' WHERE `id` = '".@$product['in_modification']."';"); } ///////////////////////////////////////////// ///////////////////////////////////////////// Îáíîâëåíèå öåíû. $row_6 = $db->super_query("SELECT COUNT(*) as count FROM `catalogs_modifications` WHERE `active`>0 AND `product_id`='".@$product['in_modification']."'"); $row_7 = $db->super_query("SELECT COUNT(*) as count FROM `catalogs_modifications` WHERE `active`>0 AND `product_id`='".@$product['in_modification']."' Group by cine"); print'('.$row_7['count'].')'; if($row_7['count']==$row_6['count']){ }else{ $row_8 = $db->super_query("SELECT cine,cine_last FROM `catalogs_modifications` WHERE `active`>0 AND cine_last>0 AND `product_id`='".@$product['in_modification']."' Order by cine desc"); $line[1] = 0;//$row_8['cine_last']; $line[2] = $cine; print'['.$line[2].']'; } if(trim($line[3])>0){ if(trim($line[2])!="0.00" && @$product['in_modification'] && trim($line[1]) != "" && trim($line[2])!=''){ $res = $db->query("UPDATE `catalogs_products` SET `cine_last`=".trim($line[1]).", `cine`=".trim($line[2]).", update_cine=".$num." WHERE `id`=".trim(@$product['in_modification'])." LIMIT 1;"); } elseif(trim($line[1]) != "" && @$product['in_modification']) $res = $db->query("UPDATE `catalogs_products` SET `cine_last`='0' ,`cine`=".trim($line[1])." WHERE `id`=".trim(@$product['in_modification'])." LIMIT 1;"); if(@$res) echo "Çàïðîñ íà îáíîâëåíèå öåí âûïîëíåí. Êîä: ".@$product['in_modification']."
"; }else echo "Íå îáíîâëåííî, îòñóòñòâóåò òîâàð: ".@$product['in_modification']."
"; ///////////////////////////////////////////// fwrite($handle24,$cot[$i]."\r\n"); $product = array(); if($no_DB == 1){ if(!@$ma[trim($line[0])]){ $ma[trim($line[0])]="1"; $fg2 = @fopen(dirname ( __FILE__ )."/tmp/noDB_mod.csv","a"); fputs($fg2,implode(";",$line)); fclose($fg2); } } //if($su2>=1000) exit; $yy = @fopen(dirname ( __FILE__ )."/counter.txt","w+"); fputs($yy,$su); fclose($yy); $su++; $su2++; } $yy = @fopen(dirname ( __FILE__ )."/counter.txt","w+"); fputs($yy,"0"); fclose($yy); if($su==(count($cot)-1)){ @unlink(dirname( __FILE__ )."/cron/file_1.csv"); print "delete file"; } //$yyyyyyyyyyy = implode("",file("http://test9.artweb.com.ua/account/cron/report.php")); fclose($handle24); $db->query('update catalogs_config set value=0 where id=6'); ?>