zooeytsai 3 éve
szülő
commit
a7c6276185
1 módosított fájl, 18 hozzáadás és 11 törlés
  1. 18 11
      SEO/run_ranking_day.py

+ 18 - 11
SEO/run_ranking_day.py

@@ -5,7 +5,8 @@ import time
 import fire
 import dataset
 from random import randint
-
+import pymysql
+pymysql.install_as_MySQLdb()
 
 def run_once(pport, dockername):
     db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/seo?charset=utf8mb4')
@@ -16,16 +17,23 @@ def run_once(pport, dockername):
         lst.append([c['term'], c['domain']])
 
     cur = db.query('select * from seo.google_rank order by id  desc limit 1')
+    count_row = db.query('select count(*) from seo.google_rank where CAST(dt AS DATE) = CAST( curdate() AS DATE)')
     for c in cur:
         kw = c['keyword']
-        
+    for c in count_row:
+        now_day_len = c['count(*)']
+        print(now_day_len)
+    if now_day_len == 0:
+        print('首位')
+        intval = os.system(
+            f'python3 ranking_day.py get --kw="清原 中央" --domain="taroboba-yuan.com" --port="{str(pport)}"')
+    
     for i in lst:
         if i[0] == kw:
-            id = lst.index(i[0])
-            intval = os.system(f'python3 ranking_day.py get --kw="{lst[id+1]}" --domain="{i[id+1]}" --port="{str(pport)}"')
-    
+            id = lst.index(i)
+            intval = os.system(f'python3 ranking_day.py get --kw="{lst[id+1][0]}" --domain="{lst[id+1][1]}" --port="{str(pport)}"')
+
         print('執行ranking_day.py')
-        time.sleep(randint(180,190))
         if intval == -1:
             print('-1')
             sys.exit()
@@ -39,14 +47,13 @@ class JParams(object):
                 os.system('docker container restart tiny9')
                 time.sleep(1)
                 run_once(9928,'tiny9')
-                
                 time.sleep(20)
-            
+                break
             except:
-                os.system('docker container restart tiny4')
+                os.system('docker container restart tiny9')
                 time.sleep(15)
 
 
-if __name__ == '__main__':
-    fire.Fire(JParams)
+# if __name__ == '__main__':
+#     run_once()