| 
					
				 | 
			
			
				@@ -1,103 +1,83 @@ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import sys 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import codecs 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import traceback 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import requests 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import re 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import pandas as pd 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import random 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import urllib 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import json 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import gspread 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import datetime 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-from gspread_pandas import Spread, Client 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-from oauth2client.service_account import ServiceAccountCredentials 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import os 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import redis 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import time 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+import json 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import fire 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import dataset 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+import pymysql 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+pymysql.install_as_MySQLdb() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-def run_once(pport, dockername): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+def run_once(): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/seo?charset=utf8mb4') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    lst = [] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    cursor = db.query('select term, domain from seo.selected_kw where client not in ("毛怪","hhh")') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    for c in cursor: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        lst.append([c['term'], c['domain']]) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    #lst2=[['台灣仁本生命服務團隊','sctt.com.tw']] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    lst = ['倉儲管理 神助移動貨架', '倉儲管理 神助貨架', '倉儲 管理'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    # cursor = db.query('select term, domain from seo.selected_kw where client="仁本"') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    # for c in cursor: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     lst.append([c['term'], c['domain']]) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     obj = random.choice(lst) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    kw = obj[0] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    domain = obj[1] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    kw = obj 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    domain = 'jiatetea.tw' 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     print(kw, domain) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    db.close() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    intval = os.system(f'python3 general_clickbot_proxy.py get --kw="{kw}" --domain="{domain}" --port="{str(pport)}"') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    os.chdir('C:\/Users\/s1301\/PycharmProjects\/kw_tools\/INNNews') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    intval = os.system(f'python3 general_clickbot_local.py get --kw="{kw}" --domain="{domain}"') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     print('執行完成genetal_clickbot') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if intval == -1: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         print('-1') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         sys.exit() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    db.close() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-def run_specific(pport, dockername): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+def run_specific(): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/seo?charset=utf8mb4') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    # db_local = dataset.connect('mysql://root:jondae350@localhost/ig_tags') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     lst = [] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    cursor = db.query('select term, domain from seo.selected_kw where client="神助物流"') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    ####形象SEO#### 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    # cursor = db.query('select json from seo.seo_jobs where id between 810 and 830') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    # for c in cursor: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     js = json.loads(c['json']) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     prefix = js['prefix'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     postfix = js['postfix'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     domain = js['domain'][0] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     positive = js['positive'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     rnd = js['rnd'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     kw1 = random.choice(positive) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     kw2 = random.choice(rnd) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     kw = prefix + " " + kw1 + " " + kw2 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    #     print(kw, domain) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    ###形象SEO### 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    cursor = db.query('select term, domain from seo.selected_kw where client="極簡乳清"') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     for c in cursor: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         lst.append([c['term'], c['domain']]) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    db.close() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     obj = random.choice(lst) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    print('隨機',obj) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    #obj = ['貨架','gs-rack.com'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if obj[0]=='重型 架': 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        lst_1 = ['重型架 無軌式重型移動','重型架 無軌移動貨架','重型 架 神助物流'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        kw = random.choice(lst_1) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    elif obj[0]=='貨架': 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        lst_2=['貨架 無軌式重型移動','貨架 無軌式重型移動貨架','貨架 無軌移動貨架儲存方案'] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        kw = random.choice(lst_2) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    #elif obj[0]=='倉儲 設備': 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    #    kw = '倉儲 設備' 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    #    print(kw) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    else: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        lst_3=[] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        lst_3.append(obj[0]+' 神助物流') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        lst_3.append(obj[0]) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        kw = random.choice(lst_3) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    kw = obj[0] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     domain = obj[1] 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    print('執行的關鍵字',kw,domain) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    print(kw, domain) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    intval = os.system(f'python3 general_clickbot_proxy.py get --kw="{kw}" --domain="{domain}" --port="{str(pport)}"')     
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    print('執行完成神助genetal_clickbot') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    intval = os.system(f'python3 general_clickbot_local.py get --kw="{kw}" --domain="{domain}"') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    print('執行完成genetal_clickbot') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if intval == -1: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         print('-1') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         sys.exit() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    db.close() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+# run_specific() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+while True: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    # run_once() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    run_specific() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    time.sleep(random.randint(120, 150)) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-class JParams(object): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    def get(self, port=9222): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        while True: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            try: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                os.system('docker container restart tiny1') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                os.system('docker container restart tiny2') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                os.system('docker container restart tiny3') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                os.system('docker container restart tiny8') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                #os.system('docker container restart tiny10') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                time.sleep(1) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                run_once(9922, 'tiny1') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                run_once(9923, 'tiny2') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                run_once(9924, 'tiny3') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                #run_once(9930, 'tiny10')   
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                run_specific(9929, 'tiny8') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                time.sleep(20) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                break            
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            except: 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                os.system('docker container restart tiny8') 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                time.sleep(15) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-if __name__ == '__main__': 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    fire.Fire(JParams) 
			 |