# coding=utf-8
import time
import os
from apscheduler.schedulers.blocking import BlockingScheduler

from selenium import webdriver
import json
import time
import requests
from urllib.parse import urlencode
file = 'cookies.json'
reply_msg=''
logfile = 'log.log'
# 打开网址
def open_url(url,driver):
 driver.get(url)
 driver.delete_all_cookies()
 driver.implicitly_wait(5)
 driver.maximize_window()


# 向浏览器添加保存的cookies
def add_cookies(driver):
 fp = open(file, 'r')
 cookies = json.load(fp)
 fp.close()
 for cookie in cookies:
 driver.add_cookie(cookie)

def save_cookies(driver):
 cookies = driver.get_cookies()
 fp = open(file, 'w')
 jsonCookies = json.dumps(cookies)
 # 登录完成后,将cookie保存到本地文件
 with open(file, 'w') as f:
 f.write(jsonCookies)
 fp.close()

 # 关闭浏览器
def run(driver):
 global f_list
 global reply_msg
 driver.get("https://mp.toutiao.com/profile_v3/weitoutiao")
 time.sleep(3)
 articUrl = driver.find_element_by_xpath("//a[@class='src-pages-content-components-post-item-item-body-index-content'][1]").get_attribute("href")
 if articUrl not in f_list:
 send_reply(driver,articUrl,reply_msg)
 add_log(articUrl)
 print("reply Ok")
 else:
 print("now not flush")
def send_reply(driver,articUrl,reply_msg):
 driver.get(articUrl)
 driver.find_element_by_xpath("//textarea").click()
 time.sleep(1)
 driver.find_element_by_xpath("//textarea").send_keys(reply_msg)
 time.sleep(1)
 driver.find_element_by_xpath("//div[@class='c-submit']").click()

# open()
def add_log(logUrl):
 global f_list
 if logUrl not in f_list:
 f_list.append(logUrl)
 with open(logfile,"a+",encoding='utf-8') as log:
 log.write(logUrl+'\n')


if __name__ == '__main__':
 f_list = []
 with open("msg.txt","r+",encoding='utf-8') as msg:
 reply_msg = msg.read()
 try:
 with open(logfile,"r+",encoding='utf-8') as log:
 texts = log.readlines()
 for t in texts:
 f_list.append(t[:-1])
 except:
 open(logfile, "w+", encoding='utf-8').close()


 #进入进程

 # '''
 driver = webdriver.Firefox()
 open_url("https://www.toutiao.com", driver)
 time.sleep(3)
 # 添加cookies后刷新界面,实现免密登录
 add_cookies(driver)
 driver.refresh()
 key = input("请输入")
 if key == 'start':
 print("start")
 # save_cookies(driver)

 run(driver)

 # '''

 scheduler = BlockingScheduler()
 scheduler.add_job(run,'interval',seconds=90,args=[driver])
 scheduler.start()
 driver.close()