58自动发帖神器软件，58同城发帖脚本插件，python发布模块

import os
import time
import random
import requests
from selenium import webdriver
from selenium.webdriver.common.by import By
from selenium.webdriver.common.keys import Keys
from selenium.webdriver.chrome.options import Options
from selenium.webdriver.support.ui import WebDriverWait
from selenium.webdriver.support import expected_conditions as EC
from datetime import datetime
import json
import logging
from logging.handlers import RotatingFileHandler
import schedule
import threading
import queue

class FiveEightPoster:
    def __init__(self, config_file='config.json'):
        self.setup_logging()
        self.logger = logging.getLogger('58Poster')
        self.config = self.load_config(config_file)
        self.post_queue = queue.Queue()
        self.driver = None
        self.is_running = False
        self.setup_driver()
        self.login()

    def setup_logging(self):
        handler = RotatingFileHandler(
            '58_poster.log',
            maxBytes=1024*1024*5,
            backupCount=5
        )
        formatter = logging.Formatter(
            '%(asctime)s - %(name)s - %(levelname)s - %(message)s'
        )
        handler.setFormatter(formatter)
        logging.basicConfig(level=logging.INFO, handlers=[handler])

    def load_config(self, config_file):
        try:
            with open(config_file, 'r', encoding='utf-8') as f:
                return json.load(f)
        except Exception as e:
            self.logger.error(f"Config load error: {str(e)}")
            raise

    def setup_driver(self):
        chrome_options = Options()
        if self.config.get('headless', False):
            chrome_options.add_argument('--headless')
        chrome_options.add_argument('--disable-gpu')
        chrome_options.add_argument('--no-sandbox')
        chrome_options.add_argument('--window-size=1920,1080')
        chrome_options.add_argument('--user-agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36')
        
        self.driver = webdriver.Chrome(
            executable_path=self.config.get('chrome_driver_path', 'chromedriver'),
            options=chrome_options
        )
        self.driver.implicitly_wait(10)

    def login(self):
        try:
            self.driver.get('https://passport.58.com/login')
            time.sleep(3)
            
            # 切换账号密码登录
            pwd_login = WebDriverWait(self.driver, 10).until(
                EC.element_to_be_clickable((By.XPATH, '//div[@class="login-tab login-tab-pwd"]'))
            )
            pwd_login.click()
            
            # 输入账号密码
            username = WebDriverWait(self.driver, 10).until(
                EC.presence_of_element_located((By.XPATH, '//input[@id="username"]'))
            )
            password = self.driver.find_element(By.XPATH, '//input[@id="password"]')
            
            username.send_keys(self.config['username'])
            password.send_keys(self.config['password'])
            
            # 点击登录
            submit = self.driver.find_element(By.XPATH, '//button[@id="submitBtn"]')
            submit.click()
            
            # 等待登录成功
            WebDriverWait(self.driver, 30).until(
                EC.presence_of_element_located((By.XPATH, '//a[contains(@class,"user-name")]'))
            )
            self.logger.info("Login successful")
            return True
        except Exception as e:
            self.logger.error(f"Login failed: {str(e)}")
            return False

    def create_post(self, post_data):
        try:
            self.driver.get('https://post.58.com/')
            time.sleep(3)
            
            # 选择分类
            category = WebDriverWait(self.driver, 10).until(
                EC.element_to_be_clickable((By.XPATH, f'//div[contains(text(),"{post_data["category"]}")]'))
            )
            category.click()
            time.sleep(1)
            
            # 填写标题
            title = self.driver.find_element(By.XPATH, '//input[@id="title"]')
            title.send_keys(post_data['title'])
            
            # 填写内容
            content = self.driver.find_element(By.XPATH, '//textarea[@id="content"]')
            content.send_keys(post_data['content'])
            
            # 设置价格
            if 'price' in post_data:
                price = self.driver.find_element(By.XPATH, '//input[@id="price"]')
                price.send_keys(str(post_data['price']))
            
            # 设置地区
            if 'region' in post_data:
                region = self.driver.find_element(By.XPATH, '//input[@id="region"]')
                region.send_keys(post_data['region'])
                time.sleep(1)
                region.send_keys(Keys.ENTER)
            
            # 上传图片
            if 'images' in post_data:
                for img_path in post_data['images']:
                    upload = self.driver.find_element(By.XPATH, '//input[@type="file"]')
                    upload.send_keys(os.path.abspath(img_path))
                    time.sleep(2)
            
            # 提交发布
            submit = self.driver.find_element(By.XPATH, '//button[@id="submitBtn"]')
            submit.click()
            
            # 验证发布成功
            WebDriverWait(self.driver, 30).until(
                EC.presence_of_element_located((By.XPATH, '//div[contains(text(),"发布成功")]'))
            )
            self.logger.info(f"Post published: {post_data['title']}")
            return True
        except Exception as e:
            self.logger.error(f"Post failed: {str(e)}")
            return False

    def start_scheduler(self):
        schedule.every().day.at("09:00").do(self.run_daily_posts)
        schedule.every().day.at("14:00").do(self.run_daily_posts)
        schedule.every().day.at("19:00").do(self.run_daily_posts)
        
        while self.is_running:
            schedule.run_pending()
            time.sleep(1)

    def run_daily_posts(self):
        for post in self.config['daily_posts']:
            self.create_post(post)
            time.sleep(random.randint(30, 120))

    def start(self):
        self.is_running = True
        scheduler_thread = threading.Thread(target=self.start_scheduler)
        scheduler_thread.start()

    def stop(self):
        self.is_running = False
        if self.driver:
            self.driver.quit()

if __name__ == "__main__":
    poster = FiveEightPoster()
    try:
        poster.start()
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        poster.stop()

        {
    "username": "your_username",
    "password": "your_password",
    "chrome_driver_path": "/path/to/chromedriver",
    "headless": false,
    "daily_posts": [
        {
            "category": "二手手机",
            "title": "出售iPhone 15 Pro Max 256G 国行",
            "content": "自用iPhone 15 Pro Max 256G，国行在保，无拆无修，全套包装配件齐全。",
            "price": 6999,
            "region": "北京",
            "images": ["phone1.jpg", "phone2.jpg"]
        },
        {
            "category": "租房",
            "title": "朝阳区精装一居室出租",
            "content": "朝阳区地铁旁精装一居室，家电齐全，拎包入住，房东直租无中介费。",
            "price": 6500,
            "region": "北京"
        }
    ]
}