MT/mt1/mt_auto_scrape .py

import requests
import base64
import cv2
import uiautomator2 as u2
import time
import subprocess
import re
import random
import datetime
import json
from aip import AipOcr
from apscheduler.schedulers.blocking import BlockingScheduler
# from db_mysql import mysqlClient
import threading
from collections import deque
import numpy as np
import secrets
import os
import math
import schedule

# import pyperclip


from config import Config
from logger import setup_logger
import logging
from contextlib import contextmanager
from typing import Dict, Any

# from database import MySQLClient

# 配置日志
# logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')

setup_logger("mt_spider")          # 初始化日志

class SpiderMonitor(threading.Thread):
    """全局弹窗监控线程（增强版）"""
    def __init__(self, spider_instance):
        super().__init__(daemon=True)
        self.spider = spider_instance
        self.running = True
        self.pausing = threading.Event()          # 主线程同步事件
        self.last_verification_time = 0
        self.verification_count = 0
        self.MAX_VERIFICATION_RETRY = 10
        self.recent_clicks = deque(maxlen=10)  # 防重复点击
        self.logger = logging.getLogger("SpiderMonitor")

        # 可配置化弹窗规则
        self.popup_rules = {
            "simple": [
                ('//*[@text="确定"]', "点击确定"),
                ('//*[@text="允许"]', "点击允许"),
                ('//*[@text="关闭"]', "点击关闭"),
                ('//*[@resource-id="com.sankuai.meituan:id/close"]', "关闭按钮"),
                ('//*[@resource-id="com.sankuai.meituan:id/address_center_location_close"]', "关闭按钮"),
                ('//*[@resource-id="com.sankuai.meituan:id/location_close"]', "关闭按钮"),
            ],  
            "verification": [
                '//*[contains(@text, "验证")]',
                '//*[contains(@text, "滑块")]',
                '//*[contains(@text, "依次点击")]',
                '//*[contains(@text, "请点击")]',
                '//*[contains(@text, "拖动滑块刚")]',  #这个需要拖动滑块至最右边，然后再截图
                '//*[contains(@text, "请输入图片中的内容")]',
                '//*[contains(@text, "用最短线连接")]',
                '//*[contains(@text, "请按语序依次点击")]',
                '//*[contains(@text, "请向右滑动滑块")]',
                '//*[contains(@text, "请拖动下方滑块完成拼图")]',
                '//*[contains(@resource-id, "captcha")]'
            ]
        }

    def run(self):
        while self.running:
            try:
                handled = self.check_and_handle_popup()
                time.sleep(2 if handled else 1)
            except Exception as e:
                self.logger.exception("监控线程异常: %s", e)
                time.sleep(3)

    def _is_recent_click(self, xpath):
        """防止重复点击同一个弹窗"""
        key = f"{xpath}_{int(time.time())}"
        if key in self.recent_clicks:
            return True
        self.recent_clicks.append(key)
        return False

    def check_and_handle_popup(self):
        d = self.spider.d

        # 1. 处理简单弹窗
        for xpath, desc in self.popup_rules["simple"]:
            if d.xpath(xpath).exists and not self._is_recent_click(xpath):
                self.logger.info("检测到弹窗: %s", desc)
                d.xpath(xpath).click()
                return True

        # 2. 处理验证码弹窗
        for xpath in self.popup_rules["verification"]:
            if d.xpath(xpath).exists:
                now = time.time()
                if now - self.last_verification_time < 30:
                    return False  # 30秒内不重复触发

                self.last_verification_time = now
                self.verification_count += 1
                self.logger.warning("验证码弹窗触发，等待人工处理...")

                if self.verification_count > self.MAX_VERIFICATION_RETRY:
                    self.logger.error("验证码重试超限，终止任务")
                    self.spider.stop_all()
                    return True
                
                self.pausing.set()   # 通知主线程暂停
                d.toast.show("需要人工处理验证码", 120)

                # 等待人工处理
                start = time.time()
                # while time.time() - start < 120*60:
                #     if not d.xpath(xpath).exists:
                #         self.logger.info("验证码已处理")
                #         d.toast.show("验证完成", 2)
                #         self.pausing.clear()      # 放行主线程
                #         return True
                #     time.sleep(5)
                while True:
                    if not d.xpath(xpath).exists:
                        self.logger.info("验证码已处理")
                        d.toast.show("验证完成", 2)
                        self.pausing.clear()      # 放行主线程
                        return True
                    time.sleep(5)


                self.logger.warning("验证码超时，重启APP")
                self.spider.restart_app()
                return True

        # 3. 处理广告弹窗（点击右上角）
        if d.xpath('//*[contains(@text, "广告")]').exists:
            w, h = d.info['displayWidth'], d.info['displayHeight']
            d.click(w - 50, 50)
            self.logger.info("关闭广告弹窗")
            return True

        return False

    def stop(self):
        self.running = False


def get_access_token():
    AppKey = "tRK2RhyItCSh6BzyT4CNVXQa"
    AppSrcret = "TDgKiPo94i2mOM1sDqOuDnlcK1bG66jh"
    token_url = 'https://aip.baidubce.com/oauth/2.0/token'
    url = f"{token_url}?grant_type=client_credentials&client_id={AppKey}&client_secret={AppSrcret}"

    payload = ""
    headers = {
        'Content-Type': 'application/json',
        'Accept': 'application/json'
    }

    response = requests.request("POST", url, headers=headers, data=payload)

    try:
        return response.json()['access_token']
    except:
        return None
    
def get_mysql():
    """
    建立并返回一个到数据库的连接对象
    """
    import pymysql
    return pymysql.connect(
        host = Config.DB_HOST,        #"localhost",  # 修改后的主机
        port = Config.DB_PORT,        #3306,  # 添加端口号
        user = Config.DB_USER,        #'root', # 修改后的用户名
        password = Config.DB_PASSWORD,  # 修改后的密码
        db = Config.DB_NAME,     #"drug_data",  # 修改后的数据库名
        charset='utf8mb4'
    )

class MT:
    def __init__(self, key):
        # self.package_name = 'com.sankuai.meituan'
        self.package_name = Config.PACKAGE_NAME
        self.access_token = get_access_token()
        self.city2province = self.get_city_info()
        self.APP_ID = '116857964'
        self.API_KEY = '1gAzACJOAr7BeILKqkqPOETh'
        self.SECRET_KEY = 'ZNArANb9GwJYgLKg4EfYhukKBfPdl1n3'
        self.client = AipOcr(self.APP_ID, self.API_KEY, self.SECRET_KEY)
        # host = Config.DB_HOST #"localhost"
        # user = Config.DB_USER #"root"
        # password = Config.DB_PASSWORD #"dfwy2025"
        # database = Config.DB_NAME #"drug_data"
        # port = Config.DB_PORT#3306
        # print(f'数据库配置:host:{host},user:{user},password:{password},database:{database},port:{port}')
        
        self.table_name = Config.DB_TABLE #"mt_drug"
        self.shop_table_name = Config.DB_SHOP_TABLE
        # print(f'数据库表名:table_name:{self.table_name},shop_table_name:{self.shop_table_name}')
        # self.mysql_client = mysqlClient(host, user, password, database, port)

        self.loggerMT = logging.getLogger()

        self.search_key = key  # 参苓健脾胃颗粒  舒肝颗粒 清肺化痰丸 香砂平胃颗粒
        self.unrelated_data = 0  # 无关数据数量
        self.shop_data_num  = 0  # 店铺数据数量

    def stop_app(self):
        self.d.app_stop(self.package_name)
        time.sleep(5)

    def start_app(self):
        self.d.app_start(self.package_name)
        time.sleep(5)

    def restart_app(self):
        """
        重启app
        :return:
        """
        self.stop_app()
        self.start_app()

    @staticmethod
    def get_sleep_time():
        # return random.randint(5, 8)
        return random.randint(1, 3)

    @staticmethod
    def get_current_date():
        return datetime.datetime.now().strftime('%Y/%m/%d')

    @staticmethod
    def get_city_info():
        """
        获取所有的省市数据
        :return:
        """
        file_path = '../kailin_city.json'
        with open(file_path, 'r', encoding='utf-8') as f:
            data = json.load(f)
        province = {province_one["id"]: province_one for province_one in data['province']}
        city2province = dict()
        city = data['city']
        for city_one in city:
            name = city_one['name']
            pid = city_one['pid']
            if len(str(pid)) > 2:
                pid = int(re.match('^\d{2}', str(pid)).group())
            city2province[name] = province[pid]['name']
        return city2province


    def get_shop_name(self):
        """
        获取店铺名
        :return:
        """
        
        try:
            shop_name = self.d.xpath(
                '//android.widget.ScrollView/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.widget.FrameLayout[1]/android.widget.TextView').text
            print(f'获取到店铺名:{shop_name}')
            return shop_name
        except:
            try:
                shop_name = self.d.xpath(
                    '//android.widget.ScrollView/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()-1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.widget.FrameLayout[1]/android.widget.TextView').text
                print(f'获取到店铺名2:{shop_name}')
                return shop_name
            except Exception as e:
                #点击店铺曲获取店铺名称
                print("点击店铺进入后获取店铺名称")
                self.enter_shop()
                shop_xpath = '//*[@resource-id="com.sankuai.meituan:id/layout_header_view"]/android.widget.FrameLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[1]//android.widget.FrameLayout[2]/android.widget.FrameLayout[1]/android.widget.TextView'
                if self.d.xpath(shop_xpath).exists:
                    shop_name = self.d.xpath(shop_xpath).text
                    self.swipe_back(1)
                    return shop_name
                else:
                    print(f'获取店铺名出错:{e}')
                    return None

    def get_qualification_number(self):
        """
        获取资质编号
        :return:
        """
        try:
            qualification_number_str = self.d.xpath(
                '//*[@resource-id="com.sankuai.meituan:id/mil_container"]/android.webkit.WebView[1]/android.webkit.WebView[1]/android.view.View[1]/android.view.View[1]/android.widget.TextView[2]').text

            qualification_number = qualification_number_str.strip('资质编号：').strip()
            return qualification_number
        except:
            return None
        
    def get_shop_address(self):
        try:
            xpath = '//*[@resource-id="com.sankuai.meituan:id/wm_sc_drug_shop_content_mrn_container_id_2"]/android.widget.FrameLayout[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.TextView'
            if self.d.xpath(xpath).exists:
                shop_address = self.d.xpath(xpath).text
                print(f'111-获取到店铺地址:{shop_address}')
                if '发货时间' in shop_address:
                    print(f'店铺地址包含发货时间，再次获取店铺地址')
                    xpath2 = '//*[@resource-id="com.sankuai.meituan:id/wm_sc_drug_shop_content_mrn_container_id_2"]/android.widget.FrameLayout[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.TextView'
                    if self.d.xpath(xpath2).exists:
                        shop_address = self.d.xpath(xpath2).text
                        print(f'222-获取到店铺地址:{shop_address}')
                    else:
                        print(f'222-xpath2获取店铺地址失败')
            else:
                shop_address = ''
            print(f'333-获取到店铺地址:{shop_address}')
            return shop_address
        except:
            print(f'获取店铺地址出错-get_shop_address')
            return None

    def enter_detail(self):
        self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/recycler"]/android.widget.FrameLayout[1]').click()
        time.sleep(self.get_sleep_time())

    def save_to_database(self, data):
        print(f'保存数据到数据库:{data}')
        # 连接数据库
        conn = get_mysql()
        # 创建游标对象
        cur = conn.cursor()

        # add_sql = "insert into delete_friend_table(delete_user_name,delete_user_id,delete_content,delete_time) value(%s,%s,%s,%s)"
        add_sql = f"""
            INSERT INTO {self.table_name} 
            (product, min_price, manufacture_date, expiry_date, shop, business_license_company, province, city, manufacturer, specification, approval_number, product_link, scrape_date, scrape_province, availability, credit_code, platform, search_key) 
            VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
        """
        # cur.execute(add_sql, (data['product'], data['min_price'], data['manufacture_date'], data['expiry_date'], data['shop'], data['business_license_company'],data['province'], data['city'], data['manufacturer'], data['specification'], data['approval_number'], data['product_link'], self.get_current_date(), data['scrape_province'], data['availability'], data['credit_code'], data['platform']))
        cur.execute(add_sql, (data['product'], data['min_price'], data['manufacture_date'], data['expiry_date'], data['shop'], data['business_license_company'],data['province'], data['city'], data['manufacturer'], data['specification'], data['approval_number'], data['product_link'], data['scrape_date'], data['scrape_province'], data['availability'], data['credit_code'], data['platform'], data['search_key']))
        conn.commit()  # 提交数据

        #self.mysql_client.insert(self.table_name, data)
        print(f"存入数据库成功")

    def save_shop_info_to_database(self, data):
        print(f'保存店铺数据到数据库:{data}')
        # 连接数据库
        conn = get_mysql()
        # 创建游标对象
        cur = conn.cursor()

        add_sql = f"""
            INSERT INTO {self.shop_table_name} 
            (shop, contact_address, qualification_number, business_license_company, business_license_address, scrape_date, platform) 
            VALUES (%s, %s, %s, %s, %s, %s, %s)
        """

        cur.execute(add_sql, (data['shop'], data['contact_address'], data['qualification_number'], data['business_license_company'], data['business_license_address'], data['scrape_date'], data['platform']))
        conn.commit()  # 提交数据

        #self.mysql_client.insert(self.shop_table_name, data)
        print(f'存入店铺信息到数据库成功')

    def swipe_up(self):
        """
        上滑
        :return:
        """
        screen_width = self.d.info['displayWidth']
        screen_height = self.d.info['displayHeight']
        duration_rate = random.uniform(0, 0.3)
        self.d.swipe(screen_width // 2, screen_height - 100, screen_width // 2, 100, duration=duration_rate)
        no = random.uniform(0, 1)
        if no > 0.85:
            # 有的时候卡着 再稍微往上滑一点点
            self.d.swipe_ext("up", 0.1)
            time.sleep(self.get_sleep_time())

    def swipe_back(self, no):
        """
        返回
        :param no: 回退次数
        :return:
        """
        for idx in range(no):
            self.d.press('back')
            time.sleep(self.get_sleep_time())

    def drug_price(self):
        """
        获取药品价格
        :return:
        """
        try:
            price_str = self.d.xpath('//*[starts-with(@text,"¥")]').text
            price = float(re.search('[\d\.]+', price_str).group())
            print(f'获取到价格:{price}')
            return price
        except Exception as e:
            print(f'提取价格出错-->{e}')
            return None

    def restart_uiautomator_services(self, device_id):
        """
        重启atx的uiautomator 服务
        :param device_id:
        :return:
        """
        stop_uiautomator_services = f'adb -s {device_id} shell /data/local/tmp/atx-agent server -d --stop'
        start_uiautomator_services = f'adb -s {device_id} shell /data/local/tmp/atx-agent server -d'
        # result = subprocess.run(stop_uiautomator_services, capture_output=True, text=True, shell=True)
        # print(result.stdout)
        subprocess.run(stop_uiautomator_services, capture_output=True, text=True, shell=True)
        time.sleep(self.get_sleep_time())
        subprocess.run(start_uiautomator_services, capture_output=True, text=True, shell=True)
        time.sleep(self.get_sleep_time())

    def connect_devices(self, device_id):
        """
        连接设备
        :return:
        """
        try:
            self.d = u2.connect_usb(device_id)
            # 设置隐形等待时间
            # self.d.implicitly_wait(5)
            self.restart_uiautomator_services(device_id)
            print(f'连接到设备:{device_id}')
        except Exception as e:
            print(f'{device_id} 连接错误: {e}')
            raise Exception(e)

    def get_ocr_res(self, img):
        try:
            #img地址
            print(f'开始识别图片:{img}')
            request_url = "https://aip.baidubce.com/rest/2.0/ocr/v1/business_license"
            # 二进制方式打开图片文件
            f = open(img, 'rb')
            img = base64.b64encode(f.read())
            params = {"image": img}
            # access_token = get_access_token()
            request_url = request_url + "?access_token=" + self.access_token
            headers = {'content-type': 'application/x-www-form-urlencoded'}
            response = requests.post(request_url, data=params, headers=headers)
            if response:
                res = response.json()
                new_dic = dict()
                for ite in res['words_result'].keys():
                    new_dic[ite] = res['words_result'][ite]['words']
                print('资质数据信息', new_dic)
                return new_dic
            else:
                return None
        except:
            return None
        
    def remove_watermark(self, img_path):
        """
        图片去水印(将水印部分变成白色背景)并将数据转化为二进制数据
        :param img_path: 图片路径
        :return: 二进制图片数据
        """
        img = cv2.imdecode(np.fromfile(img_path, dtype=np.uint8), -1)
        endswith = os.path.splitext(img_path)[1]
        new = np.clip(1.4057577998008846 * img - 38.33089999653017, 0, 255).astype(np.uint8)
        _, img_binary = cv2.imencode(endswith, new)
        return img_binary
    
    def get_ocr_res_image(self, img):
        try:
            image = self.remove_watermark(img)
            # image_file = open(img,'wb')
            # image_file.write(image)
            # res_image = self.client.basicAccurate(image)  # 高精度
            res_image = self.client.basicGeneral(image)
            # print(f'百度api返回结果:{res_image}')
            # print(res_image.get('words_result', ''))
            # new_dic = dict()
            data = res_image.get('words_result', '')
            print(f'百度api返回结果:{data}')

            # full_text = ';'.join(item['words'] for item in data)
            # address = ''
            # for item in data:
            #     if '企业注册号' in item['words']:
            #         print('come in 111')
            #         reg_number = item['words'].split('：', 1)[1].strip()
            #     elif '企业名称' in item['words']:
            #         print('come in 222')
            #         company_name = item['words'].split('：', 1)[1].strip()
            #     elif '所：' in item['words']:
            #         print('come in 333')
            #         address = item['words'].split('：', 1)[1].strip()

            # # 输出结果
            # print("企业注册号:", reg_number)
            # print("企业名称:", company_name)
            # print("住所:", address)
            return data
        except:
            return None    

    def screenshot_the_business_license(self, qualification_number):
        screenshot_path = 'screenshot1.png'
        self.d.screenshot(screenshot_path)
        img = cv2.imread(screenshot_path)
        # 指定裁剪区域 (left, top, right, bottom)
        left = 0
        top = 480
        right = 720
        bottom = 1420
        cropped_img = img[top:bottom, left:right]
        if qualification_number:
            cropped_screenshot_path = 'D:\\work\\dfwy_spider\\drug_data\\mt\\screenshot\\' + qualification_number + '.png'
        else:
            cropped_screenshot_path = 'cropped_screenshot.png'
        cv2.imwrite(cropped_screenshot_path, cropped_img)
        return cropped_screenshot_path
    
    def screenshot_instruction(self):
        # 获取当前时间
        current_time = datetime.datetime.now()

        # 格式化为时分秒
        time_str = current_time.strftime("%H-%M-%S")

        # 生成随机的 8 位字符串
        random_str = secrets.token_hex(4)  # 生成 4 个字节的随机字符串，转换为 8 位十六进制字符串

        print(time_str)
        screenshot_path = 'instructionscreenshot1-' + time_str + '-' + random_str  + '.png'
        self.d.screenshot(screenshot_path)

        return screenshot_path

    #获取商品title
    def get_title(self):
        # try:
        #     title = self.d.xpath(
        #         '//android.widget.ScrollView/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView').text
        # except:
        #     title = self.d.xpath(
        #         '//android.widget.ScrollView/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.TextView').text
        
        # title = self.d.xpath('//*[contains(@text, "舒肝颗粒")]').text
        def _inner():
            
            temp_search_key = self.search_key
            if "999" in self.search_key:
                if self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                    temp_search_key = self.search_key.replace("999皮炎平", "")
                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                    temp_search_key = self.search_key.replace("999必无忧", "")
                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                    temp_search_key = self.search_key.replace("999必无忧", "")
                elif self.search_key == '999速复康布洛芬缓释胶囊':
                    temp_search_key = self.search_key.replace("999速复康", "")
                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                    temp_search_key = self.search_key.replace("999选平", "")
                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                    temp_search_key = self.search_key.replace("999皮炎平", "")
                else:
                    temp_search_key = self.search_key.replace("999", "")
            else:
                if self.search_key == '史达功右美沙芬愈创甘油醚糖浆120':
                    temp_search_key = self.search_key.replace("史达功", "")
                    temp_search_key = temp_search_key.replace("120", "")
                elif self.search_key == '三九胃泰养胃舒颗粒8袋':
                    temp_search_key = self.search_key.replace("三九胃泰", "")
                    temp_search_key = temp_search_key.replace("8袋", "")
                elif self.search_key == '今维多赐多康牌蛋白粉':
                    temp_search_key = self.search_key.replace("今维多", "")
                elif self.search_key == '佳美舒阿奇霉素肠溶胶囊4':
                    temp_search_key = self.search_key.replace("佳美舒", "")
                    temp_search_key = temp_search_key.replace("4", "")
                elif self.search_key == '三九胃泰颗粒20g*10':
                    temp_search_key = self.search_key.replace("20g*10", "")
                elif self.search_key == '三九胃泰颗粒20g*6袋':
                    temp_search_key = self.search_key.replace("20g*6袋", "")
                elif self.search_key == '顺峰康王酮康他索乳膏':
                    temp_search_key = self.search_key.replace("顺峰康王", "")


            
            if self.search_key == '999糠酸莫米松凝胶15':
                temp_search_key = temp_search_key.replace("15", "")
            elif self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                temp_search_key = temp_search_key.replace("30", "")
            elif self.search_key == '999复方金银花颗粒10g':
                temp_search_key = temp_search_key.replace("10g", "")
            elif self.search_key == '999复方板蓝根颗粒15g*15袋/盒':
                temp_search_key = temp_search_key.replace("15g*15袋/盒", "")
            elif self.search_key == '999复方氨酚烷胺胶囊6粒':
                temp_search_key = temp_search_key.replace("6粒", "")
            elif self.search_key == '999可调式生理性海水鼻腔喷雾50':
                temp_search_key = temp_search_key.replace("50", "")
            elif self.search_key == '999止泻利颗粒15g*8':
                temp_search_key = temp_search_key.replace("15g*8", "")
            elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                temp_search_key = temp_search_key.replace("30", "")
            elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                temp_search_key = temp_search_key.replace("15g", "")
            elif self.search_key == '999复方苦参肠炎康片12片':
                temp_search_key = temp_search_key.replace("12片", "")
            elif self.search_key == '999强力枇杷露16袋':
                temp_search_key = temp_search_key.replace("16袋", "")
            elif self.search_key == '999三蛇胆川贝膏138':
                temp_search_key = temp_search_key.replace("138", "")
            elif self.search_key == '999强力枇杷露120ml':
                temp_search_key = temp_search_key.replace("120ml", "")
            elif self.search_key == '999强力枇杷露150ml':
                temp_search_key = temp_search_key.replace("150ml", "")
            elif self.search_key == '999抗病毒口服液10ml*10':
                temp_search_key = temp_search_key.replace("10ml*10", "")
            elif self.search_key == '999抗病毒口服液10ml*12':
                temp_search_key = temp_search_key.replace("10ml*12", "")
            elif self.search_key == '999糠酸莫米松乳膏10g支':
                temp_search_key = temp_search_key.replace("10g支", "")
            elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                temp_search_key = temp_search_key.replace("20g", "")
            elif self.search_key == '999感冒清热颗粒(无糖)6g':
                temp_search_key = temp_search_key.replace("(无糖)6g", "")
            elif self.search_key == '999壮骨关节丸6g*20':
                temp_search_key = temp_search_key.replace("6g*20", "")
            elif self.search_key == '999正天丸6g*15':
                temp_search_key = temp_search_key.replace("6g*15", "")
            elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                temp_search_key = temp_search_key.replace("20", "")
            elif self.search_key == '999糠酸莫米松凝胶10':
                temp_search_key = temp_search_key.replace("10", "")
            elif self.search_key == '999板蓝根颗粒10g*20':
                temp_search_key = temp_search_key.replace("10g*20", "")
            elif self.search_key == '999复方氨酚烷胺胶囊10粒':
                temp_search_key = temp_search_key.replace("10粒", "")
            elif self.search_key == '999复方氨酚烷胺胶囊12粒':
                temp_search_key = temp_search_key.replace("12粒", "")
            elif self.search_key == '999咽炎片0.26g*12片*2板':
                temp_search_key = temp_search_key.replace("0.26g*12片*2板", "")
            elif self.search_key == '999小儿止咳糖浆120':
                temp_search_key = temp_search_key.replace("120", "")
            elif self.search_key == '999小儿止咳糖浆225':
                temp_search_key = temp_search_key.replace("225", "")
            elif self.search_key == '999小儿感冒颗粒6g*10':
                temp_search_key = temp_search_key.replace("6g*10", "")
            elif self.search_key == '999小儿感冒颗粒6g*24':
                temp_search_key = temp_search_key.replace("6g*24", "")
            elif self.search_key == '999小儿氨酚黄那敏颗粒6g*10袋':
                temp_search_key = temp_search_key.replace("6g*10袋", "")
            elif self.search_key == '999小儿氨酚黄那敏颗粒6g*20袋':
                temp_search_key = temp_search_key.replace("6g*20袋", "")
            elif self.search_key == '999小儿咽扁颗粒8g*10袋':
                temp_search_key = temp_search_key.replace("8g*10袋", "")
            elif self.search_key == '999小儿感冒宁颗粒2.5g*10袋':
                temp_search_key = temp_search_key.replace("2.5g*10袋", "")
            elif self.search_key == '999感冒清热颗粒12g*18':
                temp_search_key = temp_search_key.replace("12g*18", "")







            # elif self.search_key == '三九胃泰颗粒':
            #     self.search_key = '三九胃泰' #兼容三九胃泰 温胃舒颗粒

            print(f'获取商品title时的搜索关键字:{temp_search_key}')

            # title = self.d.xpath(f'//*[contains(@text, "{self.search_key}")]').text

            #初始化
            drugs_name = ''
            specifications = ''
            title = ''

            #循环的获取title为了有时间来处理人机验证
            for m in range(1, 6000) :
                if self.d.xpath(f'//*[contains(@text, "{temp_search_key}")]').exists:
                    title = self.safe_exec(
                        lambda: self.d.xpath(f'//*[contains(@text, "{temp_search_key}")]').text
                    )
                    print(f"第{m}次获取title成功")
                    break
                else:
                    time.sleep(3)
                    # return drugs_name, specifications

            

            # drugs_name = ''
            # specifications = ''

            # try:
            #     title_xpath   = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView'
            #     title_xpath_2 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView'
            #     if self.d.xpath(title_xpath).exists:
            #         title =  self.d.xpath(title_xpath).text
            #         print(f"title_xpath获取的title={title}")
            #         if temp_search_key not in title:
            #             return drugs_name, specifications
            #     elif self.d.xpath(title_xpath_2).exists:                    
            #         title =  self.d.xpath(title_xpath_2).text
            #         print(f"title_xpath_2获取的title={title}")
            #         if temp_search_key not in title:
            #             return drugs_name, specifications
            #     else:
            #         print('title_xpath不存在,请确认')
            #         return drugs_name, specifications

            #     # title = self.d.xpath(f'//*[contains(@text, "{temp_search_key}")]').text            
            # except Exception as e:
            #     print(f"发生异常: {e}")
            #     return drugs_name, specifications

            #奇怪：有的时候title取出来的记过第一位会多一个0
            # title = self.safe_exec(self.d.xpath(f'//*[contains(@text, "{self.search_key}")]').text)

            # title = self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView').text
            title = title[1:] if title.startswith('0') else title

            print(f'获取到药品标题:{title}')
            # 从里面匹配出药品名和规格
            # drugs_name
            # specifications
            # match = re.search(r'([^\d]+)([\d\D]+)', title)

            if self.search_key == '999赐多康大豆':
                return title, '1罐'

            if self.search_key == "999感冒清热颗粒" :
                match = re.search(r'(\[[^\]]+\])(.+?)(\d+.*)', title)
            else:
                match = re.match(r'(\[[^\]]+\])(.*?)\s*((?:\d+\S*|\(.+))$', title)

            
                

            if match:
                #drugs_name = match.group(1).strip() + match.group(2).strip()
                drugs_name = title
                specifications = match.group(3).strip()
                print("药品名:", drugs_name)
                print("规格:", specifications)
                # print('完整药名:', drugs_name + specifications)
                return drugs_name, specifications
            else:
                if title == '999抗病毒口服液10ml*12' or title == '999抗病毒口服液':
                    drugs_name = title
                    specifications = '10ml*12支/盒'
                    return drugs_name, specifications
                elif title == '999抗病毒口服液10ml*10':
                    drugs_name = title
                    specifications = '10ml*10支/盒'
                    return drugs_name, specifications
                elif title == '999小柴胡颗粒':
                    drugs_name = title
                    specifications = '10g*9袋/盒'
                    return drugs_name, specifications
                elif title == '999养胃舒颗粒':
                    drugs_name = title
                    specifications = '10g*6袋/盒'
                    return drugs_name, specifications
                elif title == '三九胃泰胶囊':
                    drugs_name = title
                    specifications = '0.5g*24粒/盒'
                    return drugs_name, specifications
                elif title == '999补脾益肠丸':
                    drugs_name = title
                    specifications = '6g*15袋/盒'
                    return drugs_name, specifications
                elif title == '999复方感冒灵颗粒':
                    drugs_name = title
                    specifications = '14g*9袋/盒'
                    return drugs_name, specifications
                else:
                    print("没有匹配到预期格式")
                    drugs_name = title
                    specifications = ''
                    return drugs_name, specifications
         # 用 safe_exec 包装内部逻辑，确保验证码阻塞
        return self.safe_exec(_inner)
    def enter_shop(self):
        """
        进店，方便提取资质环境
        :return:
        """
        # self.d.xpath('//*[@text="进店"]').click()
        self.d.xpath('//*[@text="店铺"]').click()
        time.sleep(self.get_sleep_time())

    def enter_shoper(self):
        """
        进入商家
        :return:
        """
        is_shoper_exists = 0
        for i in range(10):
            if self.d.xpath('//*[@text="商家"]').exists:
                print(f'第{i}次商家存在')
                is_shoper_exists = 1
                break
            else:
                print(f'第{i}次商家不存在')
                time.sleep(self.get_sleep_time())
        if is_shoper_exists == 1:
            self.d.xpath('//*[@text="商家"]').click()
            time.sleep(self.get_sleep_time())
            return True
        else:
            return False

    #点击查看商家资质
    def scan_shoper_license(self):
        exist_shoper = 0
        for i in range(10):
            if self.d.xpath('//*[@text="查看商家资质"]').exists:
                print(f'第{i}次查看商家资质存在')
                exist_shoper = 1
                break
            else:
                print(f'第{i}次查看商家资质不存在')
                time.sleep(self.get_sleep_time())

        if exist_shoper == 1:
            self.d.xpath('//*[@text="查看商家资质"]').click()
            time.sleep(self.get_sleep_time())
        else:
            self.swipe_back(1)

    #验证商品的信息是否在数据库中已存在
    def data_is_exists(self, data):
        """
        检查指定数据是否已存在于数据库表中（仅检查存在性）
    
        参数:
            data: 包含查询条件的字典，键为列名，值为条件值
    
        返回:
            True: 数据存在
            False: 数据不存在
            None: 检查过程中出错
        """
        # dup_data = {'product': product, 'min_price': min_price, 'shop': shop, 'scrape_date': scrape_date,
        #             'platform': '美团'}
        
         # 1. 验证必要字段
        required_keys = ['product', 'min_price', 'shop', 'scrape_date', 'platform']
        if not all(key in data for key in required_keys):
            missing = [key for key in required_keys if key not in data]
            logging.error(f"缺少必要字段: {', '.join(missing)}")
            return None
        
        try:
            # 连接数据库
            conn = get_mysql()

            # 创建游标对象
            cur = conn.cursor()

            # query_sql = f"SELECT * FROM {self.table_name} WHERE product = '{data['product']}' AND min_price = '{data['min_price']}' AND shop = '{data['shop']}' AND scrape_date = '{data['scrape_date']}' AND platform = '{data['platform']}'"

            # cur.execute(query_sql)

            query_sql = """
                SELECT * FROM {} 
                WHERE product = %s 
                AND min_price = %s 
                AND shop = %s 
                AND scrape_date = %s 
                AND platform = %s
            """.format(self.table_name)

            cur.execute(query_sql, (
                data['product'],
                data['min_price'],
                data['shop'],
                data['scrape_date'],
                data['platform']
            ))

            result = cur.fetchone()

            return bool(result)  # 如果存在返回True，否则False
        except Exception as e:
            print(f"MySQL 错误: {str(e)}")
        
    #验证店铺信息是否在数据库中已存在
    def shop_is_exists_database(self, shop):
        try:
            # 连接数据库
            conn = get_mysql()

            # 创建游标对象
            cur = conn.cursor()
            query_sql = """
                SELECT * FROM {} 
                WHERE  shop = %s 
            """.format(self.shop_table_name)

            cur.execute(query_sql, (
                shop
            ))

            result = cur.fetchone()

            return bool(result)  # 如果存在返回True，否则False
        except Exception as e:
            print(f"MySQL 错误: {str(e)}")


    def wait_if_verifying(self, monitor, timeout=120):
        """验证码处理期间阻塞主线程"""
        start = time.time()
        while monitor.pausing.is_set() and time.time() - start < timeout:
            time.sleep(1)

    # def safe_xpath(self, xpath, timeout=10):
    #     """线程安全 xpath 查找"""
    #     self.wait_if_verifying(self.monitor)
    #     return self.d.xpath(xpath).wait(timeout=timeout)
    
    def wait_for_ready(self, monitor, timeout=86400):
        """进入每一页前都先等验证码"""
        start = time.time()
        while monitor.pausing.is_set() and time.time() - start < timeout:
            time.sleep(1)

        # 额外保险：如果验证码突然在这一秒才弹，再主动扫一次
        monitor.check_and_handle_popup()

    def safe_list(self, xpath, monitor):
        """线程安全地拿商品列表"""
        self.wait_for_ready(monitor)
        return self.d.xpath(xpath).all()
    
    def safe_exec(self, func, *args, **kwargs):
        """
        万能安全壳：执行 func 前检查验证码，
        若监控线程已置位 pausing，则一直阻塞直到放行。
        """
        while self.monitor.pausing.is_set():
            time.sleep(1)
        # 执行真正逻辑
        return func(*args, **kwargs)
    
    def get_next_data(self, data, target):
        for i, item in enumerate(data):
            if item['words'] == target:
                if i + 1 < len(data):
                    return data[i + 1]['words']
        return None
    
    def delete_instruction_screenshot(self, screenshot_path):
        # 删除截图文件
        try:
            os.remove(screenshot_path)
            print(f"截图文件已删除：{screenshot_path}")
        except FileNotFoundError:
            print(f"文件未找到，无法删除：{screenshot_path}")
        except Exception as e:
            print(f"删除文件时出错：{e}")
        
    '''
    def get_instructions_data(self):
        """
        确定有说明书之后，提取所有的说明书数据
        :return:
        """
        self.d.xpath('//*[@text="说明"]').click()
        # time.sleep(random.randint(3, 5))
        time.sleep(0.5)
        self.d.xpath('//*[@text="查看详细说明"]').click()
        # time.sleep(random.randint(3, 5))
        time.sleep(0.5)
        self.d.xpath('//*[@text="加载更多"]').click_exists()
        loop_page = 5
        # new_list = list()
        new_list = []
        for i in range(loop_page):
            self.d.xpath('//*[@text="加载更多"]').click_exists()
            time.sleep(0.2)
            if i == 0:
                self.d.swipe(200, 1000, 200, 300, 0.4)
            else:
                self.d.swipe(200, 1000, 200, 62)
            time.sleep(0.2) 
            if self.d.xpath('//*[@text="加载更多"]').exists:
                self.d.xpath('//*[@text="加载更多"]').click()
                time.sleep(0.2)
            all_tt = self.d.xpath(
                '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup').all()

            for idx in range(1, len(all_tt) + 1):
                all_tt1 = self.d.xpath(
                    f'//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[{idx}]//android.widget.TextView').all()
                # print(f'当前说明书列表数据:{all_tt1}')
                for tt in all_tt1:
                    if tt.text and tt.text != '展开全文':
                        new_list.append(tt.text)
            if i == 0:
                height = 938
            else:
                drug_box = self.d.xpath(
                    '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]').info
                bounds = drug_box['bounds']
                height = bounds['bottom'] - bounds['top']
            if height < 938:
                # print('说明书翻页到底部')
                break



        # 展开全文
        new_list = [item for item in new_list if item != '展开全文']
        print(f'当前说明书列表数据:{new_list}')
        # expiry_date_index = next(idx for idx, i in enumerate(new_list) if i == '有效期')
        # manufacturer_index = next(idx for idx, i in enumerate(new_list) if i == '生产单位')
        # approval_number_index = next(idx for idx, i in enumerate(new_list) if i == '批准文号')
        # res_data = {
        #     "有效期": new_list[expiry_date_index + 1],
        #     "生产单位": new_list[manufacturer_index + 1],
        #     "批准文号": new_list[approval_number_index + 1]
        # }

        res_data = {
            "有效期":   (new_list[new_list.index("有效期") + 1])   if "有效期"   in new_list and new_list.index("有效期") + 1   < len(new_list) else "",
            "生产单位": (new_list[new_list.index("生产单位") + 1]) if "生产单位" in new_list and new_list.index("生产单位") + 1 < len(new_list) else "",
            "批准文号": (new_list[new_list.index("批准文号") + 1]) if "批准文号" in new_list and new_list.index("批准文号") + 1 < len(new_list) else ""
}

        print(f'当前说明书字典数据:{res_data}')
        return res_data
    '''
 
    '''
    def get_instructions_data(self):
        """
        确定有说明书之后，提取所有的说明书数据
        :return:
        """
        self.d.xpath('//*[@text="说明"]').click()
        # time.sleep(random.randint(3, 5))
        time.sleep(0.5)
        self.d.xpath('//*[@text="查看详细说明"]').click()
        # time.sleep(random.randint(3, 5))
        time.sleep(0.5)

        # 1) 先向上滑动一次，触发“加载更多”出现
        self.d.swipe(200, 1000, 200, 300, 0.4)
        time.sleep(0.3)

        # 2) 再进入“出现就点”的循环
        while self.d.xpath('//*[@text="加载更多"]').click_exists(timeout=1):
            time.sleep(0.2)
            self.d.swipe(200, 1000, 200, 300, 0.4)
            # self.d.swipe(200, 1000, 200, 62)
            time.sleep(0.2)

        
        # 一次性获取所有文本
        texts = [
            node.text.strip()
            # for node in self.d.xpath('//android.widget.TextView').all()
            for node in self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]//android.widget.TextView').all()
            if node.text and node.text.strip() and node.text != '加载更多'
        ]
        print(f'当前说明书列表数据:{texts}')

        # 提取关键字段
        def safe_get(key):
            # try:
            #     idx = texts.index(key)
            #     return texts[idx + 1] if idx + 1 < len(texts) else ""
            # except ValueError:
            #     return ""
            try:
                idx = next(i for i, text in enumerate(texts) if text == key)
                return texts[idx + 1] if idx + 1 < len(texts) else ""
            except StopIteration:
                return ""

        res_data = {
            "有效期": safe_get("有效期"),
            "生产单位": safe_get("生产单位"),
            "批准文号": safe_get("批准文号")
        }

        print(f'当前说明书字典数据:{res_data}')
        return res_data
    '''
    
    '''
    def get_instructions_data(self):
        """
        说明书键值对采集：连续两个 TextView 为一对，精确提取
        """
        # 1. 进入说明书
        self.d(text="说明").click()
        time.sleep(0.5)
        self.d(text="查看详细说明").click()
        time.sleep(0.5)
        # self.d(text="加载更多").click_exists(timeout=0.5)

        # 2. 找到说明书最外层 ScrollView（页面主体）
        scroll_view = self.d(resourceId="com.sankuai.meituan:id/container") .child(className="android.widget.ScrollView")
        count = scroll_view.count
        print(f"找到的 ScrollView 数量: {count}")
        if not scroll_view.exists:
            return {"有效期": "", "生产单位": "", "批准文号": ""}

        # 3. 在 ScrollView 内再定位真正包含键值对的容器
        #    绝大多数美团说明书页面对应的是 ScrollView > ViewGroup > 若干 TextView
        kv_container = scroll_view.child(className="android.view.ViewGroup")
        if not kv_container.exists:
            kv_container = scroll_view  # 降级：直接对 ScrollView 取子孙 TextView

        # 4. 滑动到底并收集所有 TextView（保留顺序）
        all_texts = []
        max_swipe = 5
        last_length = 0

        for _ in range(max_swipe):
            texts = kv_container.child(className="android.widget.TextView")
            #获取texts中的文本
            print(f'当前说明书列表数据:{texts}')
            current_texts = []
            self.loggerMT.info(f'说明书111')
            for tv in texts:
                try:
                    txt = tv.get_text().strip()
                    # txt = tv.info['text'].strip()
                except Exception:
                    continue
                if txt and txt != "展开全文":
                    current_texts.append(txt)
            self.loggerMT.info(f'说明书222')
            print(f'当前说明书列表数据:{current_texts}')
            # 去重
            if current_texts:
                current_texts = [t for t in current_texts if t not in all_texts]
                all_texts.extend(current_texts)

            # 判断是否到底
            # if not scroll_view.info.get("scrollable"):
            #     break
            
            # 判断是否到底
            if len(all_texts) == last_length:
                break
            last_length = len(all_texts)

            # self.d.swipe_ext("up", scale=0.7)
            #向上滑动一次
            self.d.swipe(200, 1000, 200, 300, 0.2)
            time.sleep(0.2)
            if self.d.xpath('//*[@text="加载更多"]').exists:
                self.d.xpath('//*[@text="加载更多"]').click()

        # 5. 成对解析
        res_data = {"有效期": "", "生产单位": "", "批准文号": ""}
        for i in range(len(all_texts) - 1):
            key = all_texts[i]
            val = all_texts[i + 1]
            if key in res_data:
                res_data[key] = val

        print(f'说明书文本共 {len(all_texts)} 条，提取结果: {res_data}')
        # time.sleep(1000000)
        return res_data
    '''    

    def get_instructions_data(self):
        """
        确定有说明书之后，提取所有的说明书数据
        :return:
        """
        self.d.xpath('//*[@text="说明"]').click()
        # time.sleep(random.randint(3, 5))
        time.sleep(0.5)
        if self.d.xpath('//*[@text="查看详细说明"]').exists:
            self.d.xpath('//*[@text="查看详细说明"]').click()
        else:
            for i in range(8):
                if self.d.xpath('//*[@text="查看全部"]').exists:
                    print('开始点击查看全部')
                    break
                self.d.swipe_ext('down', 0.3)
                time.sleep(1)               
                if self.d.xpath('//*[@text="查看全部"]').exists:
                    print('开始点击查看全部2')
                    break

            if self.d.xpath('//*[@text="查看全部"]').exists:
                self.d.xpath('//*[@text="查看全部"]').click()
            else:
                res_data = {
                    "有效期":   '',
                    "生产单位": '',
                    "批准文号": ''
                } 
                self.loggerMT.info('获取到的说明书信息为空。') 
                return res_data 
        # time.sleep(random.randint(3, 5))
        time.sleep(0.5)
        # self.d.xpath('//*[@text="加载更多"]').click_exists()
        # loop_page = 5
        # new_list = list()
        # new_list = []

        for ii in range(8):
            if self.d.xpath('//*[@text="加载更多"]').exists:
                self.d.xpath('//*[@text="加载更多"]').click()
                time.sleep(0.2)
                break
            else:
                self.d.swipe(200, 1000, 200, 300, 0.3)
        
        for iii in range(10):
                if self.d.xpath('//*[@text="生产单位"]').exists and self.d.xpath('//*[@text="批准文号"]').exists:
                    break
                else:
                    self.d.swipe(200, 1300, 200, 300, 0.3)
        
        instruction_path = self.screenshot_instruction()

        print(f"instruction_path= {instruction_path}")
        time.sleep(2)

        ocr_res = self.get_ocr_res_image(instruction_path)
        # print(f'ocr_res:{ocr_res}')

        if ocr_res:
            # 获取有效期的下一个数据
            validity = self.get_next_data(ocr_res, '有效期')
            # 获取批准文号的下一个数据
            approval_number = self.get_next_data(ocr_res, '批准文号')
            # 获取生产单位的下一个数据
            manufacturer = self.get_next_data(ocr_res, '生产单位')
        else:
            validity = ''
            approval_number = ''
            manufacturer = ''

        # print("有效期:", validity)
        # print("批准文号:", approval_number)
        # print("生产单位:", manufacturer)

        res_data = {
            "有效期":   validity,
            "生产单位": manufacturer,
            "批准文号": approval_number
        }   

        print(f"res_data={res_data}")

        time.sleep(1)    
        self.delete_instruction_screenshot(instruction_path)

        return res_data



    
    def has_instructions(self):
        """
        是否有说明书
        :return:
        """
        # 没有说明书的无法采集具体数据
        time.sleep(self.get_sleep_time())
        is_has_instructions = False
        for i in range(8):
            if self.d.xpath('//*[@text="说明"]').exists:
                print(f"第{i}次有说明书1")
                is_has_instructions = True
                break
            self.d.swipe_ext('down', 0.3)
            time.sleep(1)
            # detail_info = self.d.xpath(
            #     '//android.widget.ScrollView/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[6]').info
            # bounds = detail_info['bounds']
            # height = bounds['bottom'] - bounds['top']
            # if self.d.xpath('//*[@text="进店"]').exists and height > 100:
            if self.d.xpath('//*[@text="说明"]').exists:
                is_has_instructions = True
                print(f"第{i}次有说明书2")
                break


        # is_has_instructions = self.d.xpath('//*[@text="说明"]').exists
        return is_has_instructions

    def has_shop(self):
        """
        是否有进店按钮
        :return:
        """
        # self.d.swipe_ext('up', 0.1)
        time.sleep(self.get_sleep_time())
        is_has_enter_shop = self.d.xpath('//*[@text="进店"]').exists
        return is_has_enter_shop

    #获取商品对应的店铺信息
    def get_license_info_ex(self):
        # self.enter_shop()
        self.safe_exec(self.enter_shop)
        # self.enter_shoper()
        result = self.safe_exec(self.enter_shoper)

        if result == False:
            license_info_data = {'contact_address': '', 'qualification_number': '', 'business_license_company': '', 'business_license_address': ''}
            return license_info_data
            


        for i in range(10):
            if self.d.xpath('//*[@text="查看商家资质"]').exists:
                print(f"第{i}次有商家资质")
                break
            else:
                print(f"第{i}次没有商家资质")
                time.sleep(self.get_sleep_time())


        #获取地址
        # contact_address = self.get_shop_address()
        contact_address = self.safe_exec(self.get_shop_address)
        # time.sleep(50000)
        ###
        # self.scan_shoper_license()
        self.safe_exec(self.scan_shoper_license)
        # 获取资质编码
        # qualification_number = self.get_qualification_number()
        qualification_number = self.safe_exec(self.get_qualification_number)

        #qualification_number 不为None继续下一步

        

        if qualification_number:

            #营业执照公司名称
            business_license_company = ''

            #营业执照地址
            business_license_address = ''

            self.d.click(0.603, 0.27)

            time.sleep(self.get_sleep_time())
            cropped_screenshot_path = self.screenshot_the_business_license(qualification_number)

            print(f'cropped_screenshot_path:{cropped_screenshot_path}')
            # if qualification_number:
            #     cropped_screenshot_path = 'D:\\work\\dfwy_spider\\drug_data\\mt\\screenshot\\' + qualification_number + '.png'
            # else:
            #     cropped_screenshot_path = 'cropped_screenshot.png'

            # ocr_res = self.get_ocr_res('cropped_screenshot.png')
            ocr_res = self.get_ocr_res(cropped_screenshot_path)
            print(f'ocr_res:{ocr_res}')
            #获取ocr_res 中的地址、单位名称
            if ocr_res:
                if '单位名称' in ocr_res.keys():
                    business_license_company = ocr_res['单位名称']
                
                if '地址' in ocr_res.keys():
                    business_license_address = ocr_res['地址']
                
            license_info_data = {'contact_address': contact_address, 'qualification_number': qualification_number, 'business_license_company': business_license_company, 'business_license_address': business_license_address}
        else:
            license_info_data = {'contact_address': contact_address, 'qualification_number': '', 'business_license_company': '', 'business_license_address': ''}
        return license_info_data

    """暂不用该功能
    def get_license_info(self):
        self.enter_shop()
        self.enter_shoper()
        self.scan_shoper_license()
        # 获取资质编码
        qualification_number = self.get_qualification_number()
        if qualification_number:
            table_license_info = self.get_table_license_info(qualification_number)
            if table_license_info:
                return {
                    '单位名称': table_license_info[0],
                    '地址': table_license_info[1],
                    '社会信用代码': table_license_info[2]
                }
            else:
                # operate_no = random.randint(0, 1)
                self.d.click(0.603, 0.27)
                # if operate_no == 0:
                #     self.d.xpath('//*[@text="营业执照"]').click()
                # else:
                #     self.d.click(0.603, 0.27)
                time.sleep(self.get_sleep_time())
                self.screenshot_the_business_license()
                ocr_res = self.get_ocr_res('cropped_screenshot.png')
                return ocr_res
        # operate_no = random.randint(0, 1)
        self.d.click(0.603, 0.27)
        # if operate_no == 0:
        #     self.d.xpath('//*[@text="营业执照"]').click()
        # else:
        #     self.d.click(0.603, 0.27)
        time.sleep(self.get_sleep_time())
        self.screenshot_the_business_license()
        ocr_res = self.get_ocr_res('cropped_screenshot.png')
        return ocr_res
        """
    def distinct_target(self):

        result = False    

        position_xpath = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]'
        position_xpath2 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]'    

        is_position = self.d.xpath(position_xpath).exists
        is_position2 = self.d.xpath(position_xpath2).exists

        xpath = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
        xpath2 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
        xpath3 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
        xpath4 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
        is_position5 = self.d.xpath(xpath).exists
        is_position6 = self.d.xpath(xpath2).exists
        is_position7 = self.d.xpath(xpath3).exists
        is_position8 = self.d.xpath(xpath4).exists
        
        # print(f"is_position = {is_position}")
        # print(f"is_position2 = {is_position2}")

        if is_position or is_position2 or is_position5 or is_position6 or is_position7 or is_position8:
            result = True

        return result
        # return is_position

    def enter_target_page(self):
        self.d.xpath('//*[@content-desc="看病买药"]').click()
        time.sleep(self.get_sleep_time())
        self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/vf_search_carousel_text"]').click()
        time.sleep(self.get_sleep_time())
        self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]').click()
        time.sleep(self.get_sleep_time())
        self.d.send_keys(self.search_key, clear=True)
        time.sleep(self.get_sleep_time())
        self.d.xpath('//*[@text="搜索"]').click()
        time.sleep(self.get_sleep_time())



        # content_frame = self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]').exists
        # print(content_frame)

        # position_xpath1 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]'
        # position_xpath2 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]'    
        # if self.d.xpath(position_xpath1).exists:
        #     print("position_xpath1 exist")
        # elif self.d.xpath(position_xpath2).exists:
        #     print("position_xpath2 exist")
        # else:
        #     print("position_xpath not exist")

        # time.sleep(10000)


        #增加点击快递送
        self.click_express_send()        
        time.sleep(self.get_sleep_time())

    
    def click_express_send(self):

        # xpath= '//*[@resource-id="com.sankuai.meituan:id/container"]//android.widget.HorizontalScrollView[last()]'

        slide_xpath = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]'
        slide_xpath2= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]'
        slide_xpath3= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]'
        slide_xpath4= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]'


        for i in range (1,3):
            if self.d.xpath(slide_xpath).exists:
                bounds = self.d.xpath(slide_xpath).info['bounds']
                top = bounds['top']
                bottom = bounds['bottom'] 
                print(f'top={top}')
                print(f'bottom={bottom}')

                y = (top + bottom) // 2
                print(f'y={y}')
                self.loggerMT.info('开始滑动1')
                self.d.swipe(500, y, 100, y, 0.5)
                time.sleep(self.get_sleep_time())
                break
            elif self.d.xpath(slide_xpath2).exists:
                bounds = self.d.xpath(slide_xpath2).info['bounds']
                top = bounds['top']
                bottom = bounds['bottom'] 
                print(f'top={top}')
                print(f'bottom={bottom}')

                y = (top + bottom) // 2
                print(f'y={y}')
                self.loggerMT.info('开始滑动2')
                self.d.swipe(500, y, 100, y, 0.5)
                time.sleep(self.get_sleep_time())
                break
            elif self.d.xpath(slide_xpath3).exists:
                bounds = self.d.xpath(slide_xpath3).info['bounds']
                top = bounds['top']
                bottom = bounds['bottom'] 
                print(f'top={top}')
                print(f'bottom={bottom}')

                y = (top + bottom) // 2
                print(f'y={y}')
                self.loggerMT.info('开始滑动3')
                self.d.swipe(500, y, 100, y, 0.5)
                time.sleep(self.get_sleep_time())
                break
            elif self.d.xpath(slide_xpath4).exists:
                bounds = self.d.xpath(slide_xpath4).info['bounds']
                top = bounds['top']
                bottom = bounds['bottom'] 
                print(f'top={top}')
                print(f'bottom={bottom}')

                y = (top + bottom) // 2
                print(f'y={y}')
                self.loggerMT.info('开始滑动4')
                self.d.swipe(500, y, 100, y, 0.5)
                time.sleep(self.get_sleep_time())
                break

        max_retry = 5        # 最多尝试次数
        for idx in range(1, max_retry + 1):
            # xpath= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()-1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]'
            xpath= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
            xpath2= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
            xpath3= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
            xpath4 = '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[2]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
            # print(f"xpath:{xpath}")
            # scroll_view = self.d(resourceId="com.sankuai.meituan:id/container") .child(className="android.widget.HorizontalScrollView")
            if self.d.xpath(xpath).exists:
                self.d.xpath(xpath).click()
                # time.sleep(self.get_sleep_time())
                print(f"第{idx}次点击xpath快递送成功")
                time.sleep(self.get_sleep_time())
                break
            elif self.d.xpath(xpath2).exists:
                self.d.xpath(xpath2).click()
                # time.sleep(self.get_sleep_time())
                print(f"第{idx}次点击xpath2快递送成功")
                time.sleep(self.get_sleep_time())
                break
            elif self.d.xpath(xpath3).exists:
                self.d.xpath(xpath3).click()
                # time.sleep(self.get_sleep_time())
                print(f"第{idx}次点击xpath3快递送成功")
                time.sleep(self.get_sleep_time())
                break
            elif self.d.xpath(xpath4).exists:
                self.d.xpath(xpath4).click()
                # time.sleep(self.get_sleep_time())
                print(f"第{idx}次点击xpath4快递送成功")
                time.sleep(self.get_sleep_time())
                break
            else:
                print(f"第{idx}次点击xpath或xpath2或xpath3快递送都失败")
                time.sleep(self.get_sleep_time())
                # xpath2= '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.support.v7.widget.RecyclerView[1]/android.widget.FrameLayout[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.HorizontalScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[last()]'
                # if self.d.xpath(xpath2).exists:
                #     self.d.xpath(xpath2).click()
                #     print(f"第{idx}次点击xpath2快递送成功")
                #     time.sleep(self.get_sleep_time())
                #     break
                

        


    """暂不用该功能
    def get_table_license_info(self, qualification_number):
        try:
            sql = f'select business_license_company,city,credit_code from mt_drug  where credit_code = "{qualification_number}"'
            self.mysql_client.cur.execute(sql)
            res = self.mysql_client.cur.fetchone()
            return res
        except:
            return None
     """
    
    # def get_clipboard(self):
    #     """通过ADB获取Android手机剪贴板内容"""
    #     try:
    #         result = subprocess.run(
    #             ["adb", "shell", "am", "broadcast", "-a", "clipper.get"],
    #             capture_output=True,
    #             text=True,
    #             timeout=5
    #         )
    #         print(f"获取剪贴板结果: {result.stdout}")
    #         # 解析返回信息中的剪贴板内容
    #         for line in result.stdout.splitlines():
    #             if "data=" in line:
    #                 return line.split("data=")[1].strip()
    #         return ""
    #     except Exception as e:
    #         print("获取剪贴板失败:", e)
    #         return ""
        
    # def get_clipboard(self):
    #     """读取 Android 剪贴板（系统自带命令）"""
    #     try:
    #         text = subprocess.check_output(
    #             ["adb", "shell", "cmd", "clipboard", "get"],
    #             text=True, timeout=5, stderr=subprocess.STDOUT
    #         ).strip()
    #         print(f"获取剪贴板结果: {text}")
    #         return text if text else ""
    #     except Exception as e:
    #         print("获取剪贴板失败:", e)
    #         return ""
    def get_clipboard(self):
        time.sleep(1)  
        self.loggerMT.info(f"Clipboard content:{self.d.clipboard}")  # 打印调试信息
        clipboard_content = self.d.clipboard
        if clipboard_content is None:
            return ''
        return clipboard_content.strip()


        # return self.d.clipboard.strip()
    
    def clear_clipboard(self):
        self.d.set_clipboard("", "text/plain")
        
    # def clear_clipboard(self):
    #     """清空手机剪贴板：写入空字符串（subprocess 版）"""
    #     try:
    #         subprocess.run(
    #             ["adb", "shell", "am", "broadcast", "-a", "clipper.set", "-e", "text", " "],
    #             check=True,
    #             capture_output=True,
    #             text=True,
    #             timeout=5
    #         )
    #     except subprocess.CalledProcessError as e:
    #         print("ADB 清空失败:", e.stderr)
        
    # def clear_clipboard():
    #     """清空手机剪贴板：写入空字符串"""
    #     try:
    #         adb_shell(["shell", "am", "broadcast", "-a", "clipper.set", "-e", "text", ""])
    #     except subprocess.CalledProcessError as e:
    #         print("ADB 清空失败:", e.output)
    
    #获取一个商品的数据、商品对应的店铺的数据

    def get_product_link(self):
        product_link = ''

        # 两种可能的“···”按钮
        dots_xpaths = [
            '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]',
            '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]',
            '//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]'
        ]

        max_retry = 5        # 最多尝试次数
        for idx in range(1, max_retry + 1):
            if product_link:              # 已经拿到则退出
                break

            for xp in dots_xpaths:
                if self.d.xpath(xp).exists:
                    print(f'{idx}-进入分享点点点')
                    self.loggerMT.info(f'{idx}-进入分享点点点')
                    # #先清空剪贴板的内容
                    # self.clear_clipboard()
                    # print("清空剪贴板内容成功。")

                    self.d.xpath(xp).click()
                    time.sleep(0.2)
                    self.d.xpath('//*[@text="分享商品"]').click_exists()
                    time.sleep(0.2)

                    link_xpath = '//*[@text="复制链接"]'
                    if self.d.xpath(link_xpath).exists:
                        self.d.xpath(link_xpath).click()    
                        time.sleep(1)
                        product_link = self.get_clipboard()
                        time.sleep(0.5)
                        print(f'{idx}-商品链接:{product_link}')
                        self.loggerMT.info(f'{idx}-商品链接:{product_link}')
                        break                       # 找到并执行后跳出内层循环
                    else:
                        print(f'{idx}-商品链接:{product_link}')
                        self.loggerMT.info(f'{idx}-商品链接:{product_link}')
                        product_link = ''

                    # self.d.xpath('//*[@text="复制链接"]').click_exists()
                    # time.sleep(1)

                    # product_link = self.get_clipboard()
                    # time.sleep(0.5)
                    # print(f'{idx}-商品链接:{product_link}')
                    # self.loggerMT.info(f'{idx}-商品链接:{product_link}')
                    # break                       # 找到并执行后跳出内层循环

        if not product_link and idx < max_retry:
            time.sleep(0.5)               # 最后一次不需要再等待 
        
        return product_link


    def integrate_data(self):

        #测试说明书详情：
        # instructions_info = self.safe_exec(self.get_instructions_data)
        # time.sleep(1000000)

        #测试店铺信息
        # license_info = self.safe_exec(self.get_license_info_ex)
        # time.sleep(1000000)

        #测试定位地址

    

        #获取链接开始
        #self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ScrollView[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView').text
        #1、点击页面的... 先判断元素是否存在
        '''
        if self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:
            print('1-进入分享点点点111')
            self.loggerMT.info('1-进入分享点点点111')            
            self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').click()
            #点击分享商品
            # if self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:

            time.sleep(0.2)
            self.d.xpath('//*[@text="分享商品"]').click_exists()
            time.sleep(0.2)
            self.d.xpath('//*[@text="复制链接"]').click_exists()
            time.sleep(1)

            #获取剪切板的数据
            product_link = self.get_clipboard()
            time.sleep(0.5)
            print(f'1-商品链接:{product_link}')
            self.loggerMT.info(f'1-商品链接:{product_link}')
            #清空剪切板
            # self.clear_clipboard()

            # if self.d.xpath('//*[@text="加载更多"]').click_exists():
            #     self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').click()
            #     if self.d.xpath('//android.support.v7.widget.RecyclerView/android.view.ViewGroup[3]/android.widget.ImageView[1]').exists:
            #         self.d.xpath('//android.support.v7.widget.RecyclerView/android.view.ViewGroup[3]/android.widget.ImageView[1]').click()
            #         #获取剪切板的数据
            #         product_link = self.get_clipboard()
            #         time.sleep(0.5)
            #         print(f'商品链接:{product_link}')
            #         #清空剪切板
            #         self.clear_clipboard()
            # else:
            #     print('未找到分享按钮111')
        elif self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:
            print('1-进入分享点点点222')
            self.loggerMT.info('1-进入分享点点点222')
            self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').click()

            time.sleep(0.2)
            self.d.xpath('//*[@text="分享商品"]').click_exists()
            time.sleep(0.2)
            self.d.xpath('//*[@text="复制链接"]').click_exists()
            time.sleep(1)

            #获取剪切板的数据
            product_link = self.get_clipboard()
            time.sleep(0.5)
            print(f'1-商品链接:{product_link}')
            self.loggerMT.info(f'1-商品链接:{product_link}')

        #如果为获取到product_link 则等待0.5秒再获取
        if not product_link:
            time.sleep(0.5)
            if self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:
                print('2-进入分享点点点111')
                self.loggerMT.info('2-进入分享点点点111')            
                self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').click()
                #点击分享商品
                # if self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:

                time.sleep(0.2)
                self.d.xpath('//*[@text="分享商品"]').click_exists()
                time.sleep(0.2)
                self.d.xpath('//*[@text="复制链接"]').click_exists()
                time.sleep(1)

                #获取剪切板的数据
                product_link = self.get_clipboard()
                time.sleep(0.5)
                print(f'2-商品链接:{product_link}')
                self.loggerMT.info(f'2-商品链接:{product_link}')
            elif self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:
                print('2-进入分享点点点222')
                self.loggerMT.info('2-进入分享点点点222')
                self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').click()

                time.sleep(0.2)
                self.d.xpath('//*[@text="分享商品"]').click_exists()
                time.sleep(0.2)
                self.d.xpath('//*[@text="复制链接"]').click_exists()
                time.sleep(1)

                #获取剪切板的数据
                product_link = self.get_clipboard()
                time.sleep(0.5)
                print(f'2-商品链接:{product_link}')
                self.loggerMT.info(f'2-商品链接:{product_link}')
        
        #如果为获取到product_link 则等待0.5秒再获取
        if not product_link:
            time.sleep(0.5)
            if self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:
                print('3-进入分享点点点111')
                self.loggerMT.info('3-进入分享点点点111')            
                self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').click()
                #点击分享商品
                # if self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[3]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:

                time.sleep(0.2)
                self.d.xpath('//*[@text="分享商品"]').click_exists()
                time.sleep(0.2)
                self.d.xpath('//*[@text="复制链接"]').click_exists()
                time.sleep(1)

                #获取剪切板的数据
                product_link = self.get_clipboard()
                time.sleep(0.5)
                print(f'3-商品链接:{product_link}')
                self.loggerMT.info(f'3-商品链接:{product_link}')
            elif self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').exists:
                print('3-进入分享点点点222')
                self.loggerMT.info('3-进入分享点点点222')
                self.d.xpath('//*[@resource-id="com.sankuai.meituan:id/container"]/android.widget.FrameLayout[1]/android.widget.RelativeLayout[1]/android.widget.FrameLayout[1]/android.widget.LinearLayout[1]/android.widget.FrameLayout[1]/android.widget.FrameLayout[3]/android.widget.FrameLayout[1]/android.view.ViewGroup[3]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.ImageView[1]').click()

                time.sleep(0.2)
                self.d.xpath('//*[@text="分享商品"]').click_exists()
                time.sleep(0.2)
                self.d.xpath('//*[@text="复制链接"]').click_exists()
                time.sleep(1)

                #获取剪切板的数据
                product_link = self.get_clipboard()
                time.sleep(0.5)
                print(f'3-商品链接:{product_link}')
                self.loggerMT.info(f'3-商品链接:{product_link}')
            '''
        #获取链接结束


        """
        整合数据
        :return:
        """
        # title_info = self.get_title()  # 药品，规格
        # title_info = self.safe_exec(self.get_title) # 药品，规格
        product, specifications = self.safe_exec(self.get_title) # 药品，规格
        if product:
            # product, specifications = title_info

            #如果关键字包含999 则 product必须包含999 和 999后面的那段字符串 ps 999感冒灵颗粒必须包含："999"和"感冒灵颗粒"
            if '999' in self.search_key:
                if self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                    temp_search_key = self.search_key.replace('999皮炎平', '')
                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                    temp_search_key = self.search_key.replace('999必无忧', '')    
                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                    temp_search_key = self.search_key.replace('999必无忧', '') 
                elif self.search_key ==  '999速复康布洛芬缓释胶囊':
                    temp_search_key = self.search_key.replace('999速复康', '')  
                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                    temp_search_key = self.search_key.replace('999选平', '')     
                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                    temp_search_key = self.search_key.replace('999皮炎平', '')                                                           
                else:
                    temp_search_key = self.search_key.replace('999', '')

                if self.search_key == '999糠酸莫米松凝胶15':
                    temp_search_key = temp_search_key.replace('15', '')
                elif self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                    temp_search_key = temp_search_key.replace('30', '')
                elif self.search_key == '999抗病毒口服液10ml*6支/盒':
                    temp_search_key = temp_search_key.replace("10ml*6支/盒", "")
                elif self.search_key == '999复方金银花颗粒10g':
                    temp_search_key = temp_search_key.replace("10g", "")
                elif self.search_key == '999复方板蓝根颗粒15g*15袋/盒':
                    temp_search_key = temp_search_key.replace("15g*15袋/盒", "")
                elif self.search_key == '999复方氨酚烷胺胶囊6粒':
                    temp_search_key = temp_search_key.replace("6粒", "")
                elif self.search_key == '999可调式生理性海水鼻腔喷雾50':
                    temp_search_key = temp_search_key.replace("50", "")
                elif self.search_key == '999止泻利颗粒15g*8':
                    temp_search_key = temp_search_key.replace("15g*8", "")
                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                    temp_search_key = temp_search_key.replace("30", "")
                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                    temp_search_key = temp_search_key.replace("15g", "")
                elif self.search_key == '999复方苦参肠炎康片12片':
                    temp_search_key = temp_search_key.replace("12片", "")
                elif self.search_key == '999强力枇杷露16袋':
                    temp_search_key = temp_search_key.replace("16袋", "")
                elif self.search_key == '999三蛇胆川贝膏138':
                    temp_search_key = temp_search_key.replace("138", "")
                elif self.search_key == '999抗病毒口服液10ml*12':
                    temp_search_key = temp_search_key.replace("10ml*12", "")            
                elif self.search_key == '999抗病毒口服液10ml*10':
                    temp_search_key = temp_search_key.replace("10ml*10", "")
                elif self.search_key == '999强力枇杷露120ml':
                    temp_search_key = temp_search_key.replace("120ml", "")
                elif self.search_key == '999强力枇杷露150ml':
                    temp_search_key = temp_search_key.replace("150ml", "")
                elif self.search_key == '999糠酸莫米松乳膏10g支':
                    temp_search_key = temp_search_key.replace("10g支", "")
                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                    temp_search_key = temp_search_key.replace("20g", "")
                elif self.search_key == '999感冒清热颗粒(无糖)6g':
                    temp_search_key = temp_search_key.replace("(无糖)6g", "")
                elif self.search_key == '999壮骨关节丸6g*20':
                    temp_search_key = temp_search_key.replace("6g*20", "")
                elif self.search_key == '999正天丸6g*15':
                    temp_search_key = temp_search_key.replace("6g*15", "")
                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                    temp_search_key = temp_search_key.replace("20", "")
                elif self.search_key == '999糠酸莫米松凝胶10':
                    temp_search_key = temp_search_key.replace("10", "")
                elif self.search_key == '999板蓝根颗粒10g*20':
                    temp_search_key = temp_search_key.replace("10g*20", "")
                elif self.search_key == '999复方氨酚烷胺胶囊10粒':
                    temp_search_key = temp_search_key.replace("10粒", "")
                elif self.search_key == '999复方氨酚烷胺胶囊12粒':
                    temp_search_key = temp_search_key.replace("12粒", "")
                elif self.search_key == '999咽炎片0.26g*12片*2板':
                    temp_search_key = temp_search_key.replace("0.26g*12片*2板", "")
                elif self.search_key == '999小儿止咳糖浆120':
                    temp_search_key = temp_search_key.replace("120", "")
                elif self.search_key == '999小儿止咳糖浆225':
                    temp_search_key = temp_search_key.replace("225", "")
                elif self.search_key == '999小儿感冒颗粒6g*10':
                    temp_search_key = temp_search_key.replace("6g*10", "")
                elif self.search_key == '999小儿感冒颗粒6g*24':
                    temp_search_key = temp_search_key.replace("6g*24", "")
                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*10袋':
                    temp_search_key = temp_search_key.replace("6g*10袋", "")
                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*20袋':
                    temp_search_key = temp_search_key.replace("6g*20袋", "")
                elif self.search_key == '999小儿咽扁颗粒8g*10袋':
                    temp_search_key = temp_search_key.replace("8g*10袋", "")
                elif self.search_key == '999小儿感冒宁颗粒2.5g*10袋':
                    temp_search_key = temp_search_key.replace("2.5g*10袋", "")
                elif self.search_key == '999感冒清热颗粒12g*18':
                    temp_search_key = temp_search_key.replace("12g*18", "")



                

                if '999' not in product or temp_search_key not in product:
                    self.swipe_back(1)
                    self.unrelated_data += 1
                    return
            else:
                if self.search_key == '史达功右美沙芬愈创甘油醚糖浆120':
                    temp_search_key = self.search_key.replace('史达功', '')
                    temp_search_key = temp_search_key.replace('120', '')
                    if '史达功' not in product or temp_search_key not in product:
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return
                elif self.search_key == '三九胃泰养胃舒颗粒8袋':
                    temp_search_key = self.search_key.replace('三九胃泰', '')
                    temp_search_key = temp_search_key.replace('8袋', '')
                    if '三九胃泰' not in product or temp_search_key not in product:
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return
                elif self.search_key == '今维多赐多康牌蛋白粉':
                    temp_search_key = self.search_key.replace('今维多', '')                
                    if '今维多' not in product or temp_search_key not in product:
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return
                elif self.search_key == '佳美舒阿奇霉素肠溶胶囊4':
                    temp_search_key = self.search_key.replace('佳美舒', '')
                    temp_search_key = temp_search_key.replace('4', '')
                    if '佳美舒' not in product or temp_search_key not in product:
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return
                elif self.search_key == '三九胃泰颗粒20g*10':
                    temp_search_key = self.search_key.replace('20g*10', '')   
                    if  temp_search_key not in product:
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return 
                elif self.search_key == '三九胃泰颗粒20g*6袋':
                    temp_search_key = self.search_key.replace('20g*6袋', '')   
                    if  temp_search_key not in product:
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return  
                elif self.search_key == '顺峰康王酮康他索乳膏':
                    temp_search_key = self.search_key.replace('顺峰康王', '')
                    if '顺峰康王' not in product or temp_search_key not in product:
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return


                    
                else:
                    if self.search_key not in product.replace(' ', ''):
                        self.swipe_back(1)
                        self.unrelated_data += 1
                        return
                
            
            # if self.search_key not in product.replace(' ', ''):
            #     self.swipe_back(1)
            #     self.unrelated_data += 1
            #     return
        else:
            self.swipe_back(1)
            return
        min_price = self.drug_price()  # 最低价格

        # 商品链接
        product_link = self.get_product_link()
        #判断是否有自营的文本，有的话不需要获取店铺的信息

        if self.d.xpath('//*[@text="自营"]').exists:
            shop = "美团自营大药房（快递电商）"
            # 爬取日期
            scrape_date = self.get_current_date()
            # scrape_date = "2025-07-18"
            dup_data = {'product': product, 'min_price': min_price, 'shop': shop, 'scrape_date': scrape_date,
                    'platform': '美团'}
            print(f'当前数据:{dup_data}')
            if self.data_is_exists(dup_data):
                print('存在相同数据不入库')
                self.swipe_back(1)
                return
        else:
            for i in range(8):
                if self.d.xpath('//*[@text="进店"]').exists:
                    print('开始获取店铺名1')
                    break
                self.d.swipe_ext('up', 0.3)
                time.sleep(1)
                # detail_info = self.d.xpath(
                #     '//android.widget.ScrollView/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[6]').info
                # bounds = detail_info['bounds']
                # height = bounds['bottom'] - bounds['top']
                # if self.d.xpath('//*[@text="进店"]').exists and height > 100:
                if self.d.xpath('//*[@text="进店"]').exists:
                    print('开始获取店铺名2')
                    break
            shop = self.get_shop_name()
            # 爬取日期
            scrape_date = self.get_current_date()
            # scrape_date = "2025-07-18"
            dup_data = {'product': product, 'min_price': min_price, 'shop': shop, 'scrape_date': scrape_date,
                    'platform': '美团'}
            print(f'当前数据:{dup_data}')


            #获取店铺信息开始
            
            #暂时不获取店铺信息 start
            
            is_has_enter_shop = self.has_shop()

            #需要判断shop是否已经在数据库中存在，如果存在，则不再进入店铺，直接进入下一个商品
            shop_is_exists = self.shop_is_exists_database(shop)
               
            #存在进店 并且店铺的名称不包含美团官方的字样
            print(f"已采集{self.shop_data_num}家店铺数据")
            if is_has_enter_shop and '美团官方' not in shop and '美团自营' not in shop and not shop_is_exists and self.shop_data_num < 500:

                # license_info = self.get_license_info_ex()
                license_info = self.safe_exec(self.get_license_info_ex)
                contact_address = license_info['contact_address']
                qualification_number = license_info['qualification_number']
                business_license_company = license_info['business_license_company']
                business_license_address = license_info['business_license_address']

                save_shop_data = {
                    'shop': shop,
                    'contact_address': contact_address,
                    'qualification_number': qualification_number,
                    'scrape_date': scrape_date,
                    'business_license_company':business_license_company,
                    'business_license_address':business_license_address,
                    'platform': '美团'
                }

                self.save_shop_info_to_database(save_shop_data)
                self.shop_data_num += 1 # 店铺数据数量+1
                
                self.swipe_back(2)
            else:
                print('不采集店铺信息')
                
                    

            #获取店铺信息结束
            
            #暂时不获取店铺信息 end
            

            if self.data_is_exists(dup_data):
                print('存在相同数据不入库')
                self.swipe_back(1)
                return
            
            if not shop:
                print('未获取到店铺名：开始回退')
                self.swipe_back(1)
                return
            if not shop or '自营' in shop:
                self.swipe_back(1)
                return
            time.sleep(self.get_sleep_time())
           

            

        
       
        # 生产日期为空
        manufacture_date = ''

        # 执政信息
        # if is_has_enter_shop:
        #     license_info = self.get_license_info()
        #     business_license_company = license_info["单位名称"]
        #     credit_code = license_info['社会信用代码']
        #     city_str = license_info['地址']
        #     # 先把省份啥的替换掉
        #     city_sub_str = re.sub(r'[u4e00-\u9fa5]+省', '', city_str)
        #     try:
        #         city = re.search(r'[\u4e00-\u9fa5]+?(市|区|县)', city_sub_str).group(0)
        #     except:
        #         city = city_sub_str
        #     try:
        #         province = self.city2province[city]
        #     except:
        #         province = ''
        #     self.swipe_back(2)
        # else:
        #     business_license_company = ''
        #     credit_code = ''
        #     city = ''
        #     province = ''
        business_license_company = ''
        credit_code = ''
        city = ''
        province = ''
        expiry_date = ''
        manufacturer = ''
        approval_number = ''
        #暂时不获取说明书信息 start
        
        #是否存在说明书
        # is_has_instructions = self.has_instructions()

        #有的药品没有说明书，直接默认
        if self.search_key == '今维多赐多康牌蛋白粉':
            expiry_date = '18个月'
            manufacturer = '华润圣海健康科技有限公司'
            approval_number = '食健备G202437001992'
        elif self.search_key == '佳美舒阿奇霉素肠溶胶囊4':
            expiry_date = '24个月'
            manufacturer = '浙江华润三九众益制药有限公司'
            approval_number = '国药准字H20090152'
        elif self.search_key == '999可调式生理性海水鼻腔喷雾50':
            expiry_date = '3年'
            manufacturer = '江苏萨瑞斯医疗科技有限公司'
            approval_number = '苏械注准20212140025'
        elif self.search_key == '999蒲地蓝消炎片':
            expiry_date = '24个月'
            manufacturer = '特一药业集团股份有限公司'
            approval_number = '国药准字Z20063596'
        elif self.search_key == '999养胃舒颗粒':
            expiry_date = '36个月'
            manufacturer = '合肥华润神鹿药业有限公司'
            approval_number = '国药准字Z34020289'
        elif self.search_key == '999糠酸莫米松凝胶15':
            expiry_date = '36个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字H20080010'
        elif self.search_key == '999黄芪精':
            expiry_date = '36个月'
            manufacturer = '台州南峰药业有限公司'
            approval_number = '国药准字Z33020783'
        elif self.search_key == '999复方感冒灵颗粒':
            expiry_date = '24个月'
            manufacturer = '华润三九（郴州）制药有限公司'
            approval_number = '国药准字Z43020334'
        elif self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
            expiry_date = '36个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字H20074155'
        elif self.search_key == '史达功右美沙芬愈创甘油醚糖浆120':
            expiry_date = '暂定24个月，具体有效期以实物说明书为准'
            manufacturer = '史达德药业（北京）有限公司'
            approval_number = '国药准字H11021837'
        elif self.search_key == '999速复康布洛芬缓释胶囊':
            expiry_date = '24个月'
            manufacturer = '北京红林制药有限公司'
            approval_number = '国药准字H20074172'
        elif self.search_key == '999复方板蓝根颗粒15g*15袋/盒':
            expiry_date = '24个月'
            manufacturer = '重庆科瑞东和制药有限责任公司'
            approval_number = '国药准字Z50020420'
        elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
            expiry_date = '24个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字H20073954'
        elif self.search_key == '999维生素C咀嚼片':
            expiry_date = '24个月'
            manufacturer = '甘肃成纪生物药业有限公司'
            approval_number = '国药准字H62021166'
        elif self.search_key == '999强力枇杷露120ml':
            expiry_date = '36个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字Z36021533'
        elif self.search_key == '999强力枇杷露150ml':
            expiry_date = '36个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字Z36021533'
        elif self.search_key == '999抗病毒口服液10ml*10' or self.search_key == '999抗病毒口服液10ml*12':
            expiry_date = '24个月'
            manufacturer = '杭州华润老桐君药业有限公司'
            approval_number = '国药准字Z33020518'
        elif self.search_key == '999精氨酸布洛芬颗粒':
            expiry_date = '暂定36个月'
            manufacturer = '华润三九（唐山）药业有限公司'
            approval_number = '国药准字H20070139'
        elif self.search_key == '999糠酸莫米松乳膏10g支':
            expiry_date = '36个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字H20074090'
        elif self.search_key == '999选平硝酸咪康唑乳膏20g':
            expiry_date = '24个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字H20074079'
        elif self.search_key == '999感冒清热颗粒(无糖)6g':
            expiry_date = '36个月'
            manufacturer = '合肥华润神鹿药业有限公司'
            approval_number = '国药准字Z20055023'
        elif self.search_key == '999银菊清咽颗粒':
            expiry_date = '30个月'
            manufacturer = '合肥华润神鹿药业有限公司'
            approval_number = '国药准字Z20026680'
        elif self.search_key == '999阿奇霉素片':
            expiry_date = '48个月'
            manufacturer = '浙江华润三九众益制药有限公司'
            approval_number = '国药准字H20084458'
        elif self.search_key == '999补脾益肠丸':
            expiry_date = '24个月'
            manufacturer = '惠州市九惠制药股份有限公司'
            approval_number = '国药准字Z44023376'
        elif self.search_key == '999壮骨关节丸6g*20':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z44023377'
        elif self.search_key == '999壮骨关节胶囊':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z20080055'
        elif self.search_key == '999正天丸6g*15':
            expiry_date = '30个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z44020711'
        elif self.search_key == '999正天胶囊':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z20010142'
        elif self.search_key == '三九胃泰胶囊':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z44020704'
        elif self.search_key == '三九胃泰颗粒20g*10':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z44020705'
        elif self.search_key == '999感冒灵颗粒':
            expiry_date = '24个月'
            manufacturer = '华润三九（枣庄）药业有限公司'
            approval_number = '国药准字Z44021940'
        elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
            expiry_date = '36个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字H44024170'
        elif self.search_key == '三九胃泰颗粒20g*6袋':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z44020705'
        elif self.search_key == '顺峰康王酮康他索乳膏':
            expiry_date = '24个月'
            manufacturer = '广东华润顺峰药业有限公司'
            approval_number = '国药准字H10980204'
        elif self.search_key == '999糠酸莫米松凝胶10':
            expiry_date = '36个月'
            manufacturer = '华润三九（南昌）药业有限公司'
            approval_number = '国药准字H20080010'
        elif self.search_key == '999板蓝根颗粒10g*20':
            expiry_date = '36个月'
            manufacturer = '广东恒诚制药股份有限公司'
            approval_number = '国药准字Z44021520'
        elif self.search_key == '999复方氨酚烷胺胶囊' or self.search_key == '999复方氨酚烷胺胶囊12粒' or self.search_key == '999复方氨酚烷胺胶囊10粒' or self.search_key == '999复方氨酚烷胺胶囊6粒' :
            expiry_date = '36个月'
            manufacturer = '华润三九（唐山）药业有限公司'
            approval_number = '国药准字H13021912'
        elif self.search_key == '999咽炎片0.26g*12片*2板':
            expiry_date = '24个月'
            manufacturer = '华润三九（黄石）药业有限公司'
            approval_number = '国药准字Z42021062'
        elif self.search_key == '999小儿止咳糖浆120' or self.search_key == '999小儿止咳糖浆225':
            expiry_date = '24个月'
            manufacturer = '华润三九（雅安）药业有限公司'
            approval_number = '国药准字Z51020675'
        elif self.search_key == '999小儿感冒颗粒6g*10' or self.search_key == '999小儿感冒颗粒6g*24':
            expiry_date = '36个月'
            manufacturer = '华润三九（枣庄）药业有限公司'
            approval_number = '国药准字Z37021392'
        elif self.search_key == '999小儿氨酚黄那敏颗粒6g*10袋' or self.search_key == '999小儿氨酚黄那敏颗粒6g*20袋':
            expiry_date = '36个月'
            manufacturer = '华润三九（黄石）药业有限公司'
            approval_number = '国药准字H42022510'
        elif self.search_key == '999感冒灵胶囊':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z44021939'
        elif self.search_key == '999小儿咽扁颗粒8g*10袋':
            expiry_date = '24个月'
            manufacturer = '华润三九（黄石）药业有限公司'
            approval_number = '国药准字Z42021105'
        elif self.search_key == '999小儿感冒宁颗粒2.5g*10袋':
            expiry_date = '18个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z20100067'
        elif self.search_key == '999感冒清热颗粒12g*18':
            expiry_date = '36个月'
            manufacturer = '山东新大陆制药有限公司'
            approval_number = '国药准字Z37020066'
        elif self.search_key == '999小柴胡颗粒':
            expiry_date = '24个月'
            manufacturer = '华润三九医药股份有限公司'
            approval_number = '国药准字Z44020709'
            

        else:
            is_has_instructions = self.safe_exec(self.has_instructions)
            # 说明书等信息
            if is_has_instructions:
                print('开始获取说明书信息')
                # instructions_info = self.get_instructions_data()
                instructions_info = self.safe_exec(self.get_instructions_data)
                if instructions_info['有效期'] is not None:
                    expiry_date = instructions_info['有效期'].strip('。')
                if instructions_info['生产单位'] is not None:
                    manufacturer = instructions_info['生产单位'].strip('。')
                if instructions_info['批准文号'] is not None:
                    approval_number = instructions_info['批准文号'].strip('。')
            else:
                # 没有说明书不入库
                print('没有获取到说明书信息')
                self.swipe_back(1)
                return
            
            
        
        #暂时不获取说明书信息 end
        self.unrelated_data = 0
       
        # 爬取省份
        scrape_province = '广东'  # 这里先默认广东
        # 是否有货
        availability = ''
        save_data = {
            'product': product,
            'min_price': min_price,
            'manufacture_date': manufacture_date,
            'expiry_date': expiry_date,
            'shop': shop,
            'business_license_company': business_license_company,
            'province': province,
            'city': city,
            'manufacturer': manufacturer,
            'specification': specifications,
            'approval_number': approval_number,
            'product_link': product_link,
            'scrape_date': scrape_date,
            'scrape_province': scrape_province,
            'availability': availability,
            'credit_code': credit_code,
            'platform': '美团',
            'search_key': self.search_key,
        }
        self.save_to_database(save_data)
        # time.sleep(100000)
        time.sleep(self.get_sleep_time())
        if self.distinct_target():
            print('已到达搜索列表页')
        else:
            for i in range(1):
                print('在详情页')
                self.swipe_back(1)
                time.sleep(self.get_sleep_time())
                # 最外部有个定位按钮
                if self.distinct_target():
                    break
    
    #主函数                
    def main(self, device_id, start_page, end_page, retry_count=0):
        MAX_RETRY = 3  # 最大重试次数
        spider_no = 0
        self.connect_devices(device_id)
        time.sleep(self.get_sleep_time())
        self.d.toast.show("测试toast", 20)
        # 启动全局弹窗监控
        self.monitor = SpiderMonitor(self)
        self.monitor.start()
        try:
            # 重新开启美团应用
            self.restart_app()
            # 搜索关键字
            self.enter_target_page()
            # print('开始滑动')
            # self.d.drag(300, 1400, 300, 400, 1)
            # time.sleep(100000)
            for idx in range(300):
                print(f'第{idx + 1}页')
                if spider_no > 30:
                    time.sleep(60)
                    spider_no = 0
                print('目前无关数据量: ', self.unrelated_data)

                # 检查是否需要暂停（验证码过多）
                if self.monitor.verification_count >= self.monitor.MAX_VERIFICATION_RETRY:
                    print("频繁遇到验证码，暂停程序")
                    self.d.toast("请处理验证码后点击继续", 30)
                    # 等待用户点击屏幕继续
                    self.d.click(0, 0)  # 无效点击，等待用户操作
                    self.monitor.verification_count = 0

                # if self.unrelated_data > 10:
                #     # 连续超过5个不达标的数据则停止采集
                #     break
                    
                # 线程安全获取商品列表
                # drug_lis = self.d.xpath('//android.support.v7.widget.RecyclerView/android.widget.FrameLayout').all()
                # drug_lis = self.safe_list('//android.support.v7.widget.RecyclerView/android.widget.FrameLayout', self.monitor)
                
                while True:
                    if self.d.xpath('//android.support.v7.widget.RecyclerView/android.widget.FrameLayout').exists:
                        break
                    time.sleep(1)

                drug_lis = self.safe_exec(self.d.xpath('//android.support.v7.widget.RecyclerView/android.widget.FrameLayout').all)
                lis_len = len(drug_lis)
                print(f'当前页面共有{lis_len}个商品')
                for idxx,drug_one in  enumerate(drug_lis,start = 1):
                    bounds = drug_one.info['bounds']
                    top = bounds['top']
                    bottom = bounds['bottom']
                    # height = bottom - top
                    print(f'当前商品bottom:{bottom}')
                    print(f'当前商品top:{top}')
                    # if  304 <= top and bottom <= 1475:  # 默认高度241的才行
                    if  304 <= top and bottom <= 1475:  # 默认高度241的才行 1559
                        # print('目标-->', drug_one.info)
                        # drug_one.click()
                        #获取当前元素中的属性来判断是否要点击进入采集
                        print(f"这页的第几个商品:{idxx}")
                        product_title = ''
                        price     = ''
                        shop_name     = ''

                        #商品名称的xpath
                        product_tittle_xpath = f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView'
                        product_tittle_xpath2 = f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView'
                        if self.d.xpath(product_tittle_xpath).exists:
                            product_title = self.d.xpath(product_tittle_xpath).text
                            product_title = product_title[1:] if product_title.startswith('0') else product_title
                            print(f"product_tittle_xpath列表当前商品名称:{product_title}")

                            if '999' in self.search_key:
                                if self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                                    temp_search_key = self.search_key.replace('999皮炎平', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                                    temp_search_key = self.search_key.replace('999必无忧', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                                    temp_search_key = self.search_key.replace('999必无忧', '')
                                elif self.search_key == '999速复康布洛芬缓释胶囊':
                                    temp_search_key = self.search_key.replace('999速复康', '')
                                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                                    temp_search_key = self.search_key.replace('999选平', '')
                                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                                    temp_search_key = self.search_key.replace('999皮炎平', '')
                                else:
                                    temp_search_key = self.search_key.replace('999', '')

                                if self.search_key == '999糠酸莫米松凝胶15':
                                    temp_search_key = temp_search_key.replace('15', '')
                                elif self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                                    temp_search_key = temp_search_key.replace('30', '')
                                elif self.search_key == '999复方金银花颗粒10g':
                                    temp_search_key = temp_search_key.replace('10g', '')
                                elif self.search_key == '999复方板蓝根颗粒15g*15袋/盒':
                                    temp_search_key = temp_search_key.replace('15g*15袋/盒', '')
                                elif self.search_key == '999复方氨酚烷胺胶囊6粒':
                                    temp_search_key = temp_search_key.replace('6粒', '')
                                elif self.search_key == '999可调式生理性海水鼻腔喷雾50':
                                    temp_search_key = temp_search_key.replace('50', '')
                                elif self.search_key == '999止泻利颗粒15g*8':
                                    temp_search_key = temp_search_key.replace('15g*8', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                                    temp_search_key = temp_search_key.replace('30', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                                    temp_search_key = temp_search_key.replace('15g', '')
                                elif self.search_key == '999复方苦参肠炎康片12片':
                                    temp_search_key = temp_search_key.replace("12片", "")
                                elif self.search_key == '999强力枇杷露16袋':
                                    temp_search_key = temp_search_key.replace("16袋", "")
                                elif self.search_key == '999三蛇胆川贝膏138':
                                    temp_search_key = temp_search_key.replace("138", "")
                                elif self.search_key == '999抗病毒口服液10ml*12':
                                    temp_search_key = temp_search_key.replace("10ml*12", "")
                                elif self.search_key == '999抗病毒口服液10ml*10':
                                    temp_search_key = temp_search_key.replace("10ml*10", "")
                                elif self.search_key == '999强力枇杷露120ml':
                                    temp_search_key = temp_search_key.replace("120ml", "")
                                elif self.search_key == '999强力枇杷露150ml':
                                    temp_search_key = temp_search_key.replace("150ml", "")
                                elif self.search_key == '999糠酸莫米松乳膏10g支':
                                    temp_search_key = temp_search_key.replace("10g支", "")
                                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                                    temp_search_key = temp_search_key.replace("20g", "")
                                elif self.search_key == '999感冒清热颗粒(无糖)6g':
                                    temp_search_key = temp_search_key.replace("(无糖)6g", "")
                                elif self.search_key == '999壮骨关节丸6g*20':
                                    temp_search_key = temp_search_key.replace("6g*20", "")
                                elif self.search_key == '999正天丸6g*15':
                                    temp_search_key = temp_search_key.replace("6g*15", "")
                                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                                    temp_search_key = temp_search_key.replace("20", "")
                                elif self.search_key == '999糠酸莫米松凝胶10':
                                    temp_search_key = temp_search_key.replace("10", "")
                                elif self.search_key == '999板蓝根颗粒10g*20':
                                    temp_search_key = temp_search_key.replace("10g*20", "")
                                elif self.search_key == '999复方氨酚烷胺胶囊10粒':
                                    temp_search_key = temp_search_key.replace("10粒", "")
                                elif self.search_key == '999复方氨酚烷胺胶囊12粒':
                                    temp_search_key = temp_search_key.replace("12粒", "")
                                elif self.search_key == '999咽炎片0.26g*12片*2板':
                                    temp_search_key = temp_search_key.replace("0.26g*12片*2板", "")
                                elif self.search_key == '999小儿止咳糖浆120':
                                    temp_search_key = temp_search_key.replace("120", "")
                                elif self.search_key == '999小儿止咳糖浆225':
                                    temp_search_key = temp_search_key.replace("225", "")
                                elif self.search_key == '999小儿感冒颗粒6g*10':
                                    temp_search_key = temp_search_key.replace("6g*10", "")
                                elif self.search_key == '999小儿感冒颗粒6g*24':
                                    temp_search_key = temp_search_key.replace("6g*24", "")
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*10袋':
                                    temp_search_key = temp_search_key.replace("6g*10袋", "")
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*20袋':
                                    temp_search_key = temp_search_key.replace("6g*20袋", "")
                                elif self.search_key == '999小儿咽扁颗粒8g*10袋':
                                    temp_search_key = temp_search_key.replace("8g*10袋", "")
                                elif self.search_key == '999小儿感冒宁颗粒2.5g*10袋':
                                    temp_search_key = temp_search_key.replace("2.5g*10袋", "")
                                elif self.search_key == '999感冒清热颗粒12g*18':
                                    temp_search_key = temp_search_key.replace("12g*18", "")


                                
                                
                                if self.search_key == '999抗病毒口服液':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10ml*12' not in product_title and '10ml*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*12和10ml*10品规")
                                        continue
                                elif self.search_key == '999抗病毒口服液10ml*12':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10ml*12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*12品规")
                                        continue
                                elif self.search_key == '999抗病毒口服液10ml*10':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10ml*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*10品规")
                                        continue
                                elif self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '30' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含30品规")
                                        continue
                                elif self.search_key == '999复方感冒灵颗粒':
                                     if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                     elif '14g*15' not in product_title and '14g*9' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含14g*15 和 14g*9品规")
                                        continue
                                elif self.search_key == '999养胃舒颗粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10g*6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g*6品规")
                                        continue
                                elif self.search_key == '999糠酸莫米松凝胶15':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15品规")
                                        continue  
                                elif self.search_key == '999复方金银花颗粒10g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10g' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g品规")
                                        continue 
                                elif self.search_key == '999复方板蓝根颗粒15g*15袋/盒': 
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '15g*15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15g*15品规")
                                        continue 
                                elif self.search_key == '999复方氨酚烷胺胶囊6粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6品规")
                                        continue 
                                elif self.search_key == '999可调式生理性海水鼻腔喷雾50':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '50' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含50品规")
                                        continue 
                                elif self.search_key == '999止泻利颗粒15g*8':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '15g*8' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15g*8品规")
                                        continue 
                                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '30' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含30品规")
                                        continue 
                                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15品规")
                                        continue 
                                elif self.search_key == '999复方苦参肠炎康片12片':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含12品规")
                                        continue
                                elif self.search_key == '999强力枇杷露16袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '16' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含16品规")
                                        continue
                                elif self.search_key == '999三蛇胆川贝膏138':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '138' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含16品规")
                                        continue
                                elif self.search_key == '999速复康布洛芬缓释胶囊':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                elif self.search_key == '999维生素C咀嚼片':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '80' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含80品规")                                        
                                elif self.search_key == '999精氨酸布洛芬颗粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '9' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含9品规")
                                        continue
                                elif self.search_key == '999强力枇杷露120ml':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '120' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含120品规")
                                        continue
                                elif self.search_key == '999强力枇杷露150ml':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '150' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含120品规")
                                        continue
                                elif self.search_key == '999糠酸莫米松乳膏10g支':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10品规")
                                        continue
                                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20品规")
                                        continue
                                elif self.search_key == '999感冒清热颗粒(无糖)6g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6品规")
                                        continue
                                elif self.search_key == '999阿奇霉素片':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '0.25g*6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含0.25g*6品规")
                                        continue                                
                                elif self.search_key == '999补脾益肠丸':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*15品规")
                                        continue
                                elif self.search_key == '999壮骨关节丸6g*20':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*20品规")
                                        continue
                                elif self.search_key == '999正天丸6g*15':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*15品规")
                                        continue
                                elif self.search_key == '999感冒灵颗粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10g*9' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g*9品规")
                                        continue
                                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20品规")
                                        continue
                                elif self.search_key == '999糠酸莫米松凝胶10':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10品规")
                                        continue
                                elif self.search_key == '999板蓝根颗粒10g*20':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10g*20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g*20品规")
                                        continue
                                elif self.search_key == '999复方氨酚烷胺胶囊10粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10品规")
                                        continue
                                elif self.search_key == '999复方氨酚烷胺胶囊12粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含12品规")
                                        continue   
                                elif  self.search_key == '999复方氨酚烷胺胶囊':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue      
                                elif self.search_key == '999咽炎片0.26g*12片*2板':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '0.26g*12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含0.26g*12品规")
                                        continue   
                                elif self.search_key == '999小儿止咳糖浆120':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '120' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含120品规")
                                        continue   
                                elif self.search_key == '999小儿止咳糖浆225':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '225' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含225品规")
                                        continue   
                                elif self.search_key == '999小儿感冒颗粒6g*10':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*10品规")
                                        continue   
                                elif self.search_key == '999小儿感冒颗粒6g*24':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*24' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*24品规")
                                        continue  
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*10袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*10品规")
                                        continue  
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*20袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*20品规")
                                        continue  
                                elif self.search_key == '999感冒灵胶囊':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '0.5g*12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含0.5g*12品规")
                                        continue
                                elif self.search_key == '999小儿咽扁颗粒8g*10袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '8g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含8g*10品规")
                                        continue
                                elif self.search_key == '999小儿感冒宁颗粒2.5g*10袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '2.5g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含2.5g*10品规")
                                        continue
                                elif self.search_key == '999感冒清热颗粒12g*18':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '12g*18' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含12g*18品规")
                                        continue
                                elif self.search_key == '999藿香正气合剂':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10ml*6' not in product_title and '10ml*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*6 和 10ml*10品规")
                                        continue


                                else:
                                    if '999' not in product_title or temp_search_key not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue

                            else:
                                if self.search_key == '史达功右美沙芬愈创甘油醚糖浆120':
                                    temp_search_key = self.search_key.replace('史达功', '')
                                    temp_search_key = temp_search_key.replace('120', '')
                                    if '史达功' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '120' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含120品规")
                                        continue  
                                elif self.search_key == '三九胃泰养胃舒颗粒8袋':
                                    temp_search_key = self.search_key.replace('三九胃泰', '')
                                    temp_search_key = temp_search_key.replace('8袋', '')
                                    if '三九胃泰' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '8' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含8品规")
                                        continue  
                                elif self.search_key == '今维多赐多康牌蛋白粉':
                                    temp_search_key = self.search_key.replace('今维多', '')                            
                                    if '今维多' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                elif self.search_key == '佳美舒阿奇霉素肠溶胶囊4':
                                    temp_search_key = self.search_key.replace('佳美舒', '')
                                    temp_search_key = temp_search_key.replace('4', '')
                                    if '佳美舒' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '4' not in product_title and '8' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含4和或8品规")
                                        continue
                                elif self.search_key == '三九胃泰颗粒20g*10':
                                    temp_search_key = self.search_key.replace('20g*10', '')
                                    if  temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20g*10品规")
                                        continue  
                                elif self.search_key == '三九胃泰颗粒20g*6袋':
                                    temp_search_key = self.search_key.replace('20g*6袋', '')
                                    if  temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20g*6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20g*6品规")
                                        continue  
                                elif self.search_key == '顺峰康王酮康他索乳膏':
                                    temp_search_key = self.search_key.replace('顺峰康王', '')                                    
                                    if '顺峰康王' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue



                                else:
                                    if self.search_key not in product_title.replace(' ', ''):
                                        continue
                        elif self.d.xpath(product_tittle_xpath2).exists:
                            product_title = self.d.xpath(product_tittle_xpath2).text
                            product_title = product_title[1:] if product_title.startswith('0') else product_title
                            print(f"product_tittle_xpath2列表当前商品名称:{product_title}")

                            
                            if '999' in self.search_key:
                                if self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                                    temp_search_key = self.search_key.replace('999皮炎平', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                                    temp_search_key = self.search_key.replace('999必无忧', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                                    temp_search_key = self.search_key.replace('999必无忧', '')
                                elif self.search_key == '999速复康布洛芬缓释胶囊':
                                    temp_search_key = self.search_key.replace('999速复康', '')
                                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                                    temp_search_key = self.search_key.replace('999选平', '')
                                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                                    temp_search_key = self.search_key.replace('999皮炎平', '')
                                else:
                                    temp_search_key = self.search_key.replace('999', '')

                                if self.search_key == '999糠酸莫米松凝胶15':
                                    temp_search_key = temp_search_key.replace('15', '')
                                elif self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                                    temp_search_key = temp_search_key.replace('30', '')
                                elif self.search_key == '999复方金银花颗粒10g':
                                    temp_search_key = temp_search_key.replace('10g', '')
                                elif self.search_key == '999复方板蓝根颗粒15g*15袋/盒':
                                    temp_search_key = temp_search_key.replace('15g*15袋/盒', '')
                                elif self.search_key == '999复方氨酚烷胺胶囊6粒':
                                    temp_search_key = temp_search_key.replace('6粒', '')
                                elif self.search_key == '999可调式生理性海水鼻腔喷雾50':
                                    temp_search_key = temp_search_key.replace('50', '')
                                elif self.search_key == '999止泻利颗粒15g*8':
                                    temp_search_key = temp_search_key.replace('15g*8', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                                    temp_search_key = temp_search_key.replace('30', '')
                                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                                    temp_search_key = temp_search_key.replace('15g', '')
                                elif self.search_key == '999复方苦参肠炎康片12片':
                                    temp_search_key = temp_search_key.replace("12片", "")
                                elif self.search_key == '999强力枇杷露16袋':
                                    temp_search_key = temp_search_key.replace("16袋", "")
                                elif self.search_key == '999三蛇胆川贝膏138':
                                    temp_search_key = temp_search_key.replace("138", "")
                                elif self.search_key == '999抗病毒口服液10ml*12':
                                    temp_search_key = temp_search_key.replace("10ml*12", "")
                                elif self.search_key == '999抗病毒口服液10ml*10':
                                    temp_search_key = temp_search_key.replace("10ml*10", "")
                                elif self.search_key == '999强力枇杷露120ml':
                                    temp_search_key = temp_search_key.replace("120ml", "")
                                elif self.search_key == '999强力枇杷露150ml':
                                    temp_search_key = temp_search_key.replace("150ml", "")
                                elif self.search_key == '999糠酸莫米松乳膏10g支':
                                    temp_search_key = temp_search_key.replace("10g支", "")
                                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                                    temp_search_key = temp_search_key.replace("20g", "")
                                elif self.search_key == '999感冒清热颗粒(无糖)6g':
                                    temp_search_key = temp_search_key.replace("(无糖)6g", "")
                                elif self.search_key == '999壮骨关节丸6g*20':
                                    temp_search_key = temp_search_key.replace("6g*20", "")
                                elif self.search_key == '999正天丸6g*15':
                                    temp_search_key = temp_search_key.replace("6g*15", "")
                                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                                    temp_search_key = temp_search_key.replace("20", "")
                                elif self.search_key == '999糠酸莫米松凝胶10':
                                    temp_search_key = temp_search_key.replace("10", "")
                                elif self.search_key == '999板蓝根颗粒10g*20':
                                    temp_search_key = temp_search_key.replace("10g*20", "")
                                elif self.search_key == '999复方氨酚烷胺胶囊10粒':
                                    temp_search_key = temp_search_key.replace("10粒", "")
                                elif self.search_key == '999复方氨酚烷胺胶囊12粒':
                                    temp_search_key = temp_search_key.replace("12粒", "")
                                elif self.search_key == '999咽炎片0.26g*12片*2板':
                                    temp_search_key = temp_search_key.replace("0.26g*12片*2板", "")
                                elif self.search_key == '999小儿止咳糖浆120':
                                    temp_search_key = temp_search_key.replace("120", "")
                                elif self.search_key == '999小儿止咳糖浆225':
                                    temp_search_key = temp_search_key.replace("225", "")
                                elif self.search_key == '999小儿感冒颗粒6g*10':
                                    temp_search_key = temp_search_key.replace("6g*10", "")
                                elif self.search_key == '999小儿感冒颗粒6g*24':
                                    temp_search_key = temp_search_key.replace("6g*24", "")
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*10袋':
                                    temp_search_key = temp_search_key.replace("6g*10袋", "")
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*20袋':
                                    temp_search_key = temp_search_key.replace("6g*20袋", "")
                                elif self.search_key == '999小儿咽扁颗粒8g*10袋':
                                    temp_search_key = temp_search_key.replace("8g*10袋", "")
                                elif self.search_key == '999小儿感冒宁颗粒2.5g*10袋':
                                    temp_search_key = temp_search_key.replace("2.5g*10袋", "")
                                elif self.search_key == '999感冒清热颗粒12g*18':
                                    temp_search_key = temp_search_key.replace("12g*18", "")

                                

                                if self.search_key == '999抗病毒口服液':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '10ml*12' not in product_title and '10ml*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*12和10ml*10品规")
                                        continue
                                elif self.search_key == '999抗病毒口服液10ml*12':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '10ml*12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*12品规")
                                        continue
                                elif self.search_key == '999抗病毒口服液10ml*10':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10ml*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*10品规")
                                        continue
                                elif self.search_key == '999皮炎平曲安奈德益康唑乳膏30':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '30' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含30品规")
                                        continue
                                elif self.search_key == '999复方感冒灵颗粒':
                                     if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                     elif '14g*15' not in product_title and '14g*9' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含14g*15 和 14g*9品规")
                                        continue
                                elif self.search_key == '999养胃舒颗粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '10g*6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g*6品规")
                                        continue   
                                elif self.search_key == '999糠酸莫米松凝胶15':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15品规")
                                        continue
                                elif self.search_key == '999复方金银花颗粒10g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '10g' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g品规")
                                        continue
                                elif self.search_key == '999复方板蓝根颗粒15g*15袋/盒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '15g*15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15g*15品规")
                                        continue
                                elif self.search_key == '999复方氨酚烷胺胶囊6粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6品规")
                                        continue
                                elif self.search_key == '999可调式生理性海水鼻腔喷雾50':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '50' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含50品规")
                                        continue
                                elif self.search_key == '999止泻利颗粒15g*8':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '15g*8' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15g*8品规")
                                        continue
                                elif self.search_key == '999必无忧盐酸特比萘芬喷雾剂30':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '30' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含30品规")
                                        continue
                                elif self.search_key == '999必无忧盐酸特比萘芬乳膏15g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含15品规")
                                        continue
                                elif self.search_key == '999复方苦参肠炎康片12片':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含12品规")
                                        continue
                                elif self.search_key == '999强力枇杷露16袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '16' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含16品规")
                                        continue
                                elif self.search_key == '999三蛇胆川贝膏138':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                    elif '138' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含138品规")     
                                elif self.search_key == '999速复康布洛芬缓释胶囊':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                elif self.search_key == '999维生素C咀嚼片':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '80' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含80品规")
                                        continue
                                elif self.search_key == '999精氨酸布洛芬颗粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '9' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含9品规")
                                        continue
                                elif self.search_key == '999强力枇杷露120ml':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '120' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含120品规")
                                        continue    
                                elif self.search_key == '999强力枇杷露150ml':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '150' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含150品规")
                                        continue  
                                elif self.search_key == '999糠酸莫米松乳膏10g支':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10品规")
                                        continue  
                                elif self.search_key == '999选平硝酸咪康唑乳膏20g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20品规")
                                        continue  
                                elif self.search_key == '999感冒清热颗粒(无糖)6g':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6品规")
                                        continue  
                                elif self.search_key == '999阿奇霉素片':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '0.25g*6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含0.25g*6品规")
                                        continue
                                elif self.search_key == '999补脾益肠丸':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*15品规")
                                        continue
                                elif self.search_key == '999壮骨关节丸6g*20':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*20品规")
                                        continue
                                elif self.search_key == '999正天丸6g*15':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*15' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*15品规")
                                        continue
                                elif self.search_key == '999感冒灵颗粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10g*9' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g*9品规")
                                        continue
                                elif self.search_key == '999皮炎平复方醋酸地塞米松乳膏20':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20品规")
                                        continue
                                elif self.search_key == '999糠酸莫米松凝胶10':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10品规")
                                        continue
                                elif self.search_key == '999板蓝根颗粒10g*20':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10g*20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10g*20品规")
                                        continue
                                elif self.search_key == '999复方氨酚烷胺胶囊10粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10品规")
                                        continue
                                elif self.search_key == '999复方氨酚烷胺胶囊12粒':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含12品规")
                                        continue
                                elif  self.search_key == '999复方氨酚烷胺胶囊':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue  
                                elif self.search_key == '999咽炎片0.26g*12片*2板':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '0.26g*12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含0.26g*12品规")
                                        continue
                                elif self.search_key == '999小儿止咳糖浆120':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '120' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含120品规")
                                        continue     
                                elif self.search_key == '999小儿止咳糖浆225':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '225' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含225品规")
                                        continue   
                                elif self.search_key == '999小儿感冒颗粒6g*10':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*10品规")
                                        continue      
                                elif self.search_key == '999小儿感冒颗粒6g*24':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*24' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*24品规")
                                        continue  
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*10袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*10品规")
                                        continue  
                                elif self.search_key == '999小儿氨酚黄那敏颗粒6g*20袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '6g*20' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含6g*20品规")
                                        continue    
                                elif self.search_key == '999感冒灵胶囊':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '0.5g*12' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含0.5g*12品规")
                                        continue  
                                elif self.search_key == '999小儿咽扁颗粒8g*10袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '8g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含8g*10品规")
                                        continue 
                                elif self.search_key == '999小儿感冒宁颗粒2.5g*10袋':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '2.5g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含2.5g*10品规")
                                        continue 
                                elif self.search_key == '999感冒清热颗粒12g*18':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '12g*18' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含12g*18品规")
                                        continue
                                elif self.search_key == '999藿香正气合剂':
                                    if '999' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '10ml*6' not in product_title and '10ml*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含10ml*6 和 10ml*10品规")
                                        continue

                                else:
                                    if '999' not in product_title or temp_search_key not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                        continue
                                # if '999' not in product_title or temp_search_key not in product_title:
                                #     print(f"当前商品名称:{product_title} 不包含关键字:{self.search_key}")
                                #     continue
                            else:
                                if self.search_key == '史达功右美沙芬愈创甘油醚糖浆120':
                                    temp_search_key = self.search_key.replace('史达功', '')
                                    temp_search_key = temp_search_key.replace('120', '')
                                    if '史达功' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '120' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含120品规")
                                        continue  
                                elif self.search_key == '三九胃泰养胃舒颗粒8袋':
                                    temp_search_key = self.search_key.replace('三九胃泰', '')
                                    temp_search_key = temp_search_key.replace('8袋', '')
                                    if '三九胃泰' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '8' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含8品规")
                                        continue 
                                elif self.search_key == '今维多赐多康牌蛋白粉':
                                    temp_search_key = self.search_key.replace('今维多', '')                            
                                    if '今维多' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                elif self.search_key == '佳美舒阿奇霉素肠溶胶囊4':
                                    temp_search_key = self.search_key.replace('佳美舒', '')
                                    temp_search_key = temp_search_key.replace('4', '')
                                    if '佳美舒' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '4' not in product_title and '8' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含4和或8品规")
                                        continue
                                elif self.search_key == '三九胃泰颗粒20g*10':
                                    temp_search_key = self.search_key.replace('20g*10', '')
                                    if  temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20g*10' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20g*10品规")
                                        continue 
                                elif self.search_key == '三九胃泰颗粒20g*6袋':
                                    temp_search_key = self.search_key.replace('20g*6袋', '')
                                    if  temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                    elif '20g*6' not in product_title:
                                        print(f"当前商品名称:{product_title} 不包含20g*6品规")
                                        continue 
                                elif self.search_key == '顺峰康王酮康他索乳膏':
                                    temp_search_key = self.search_key.replace('顺峰康王', '')                                    
                                    if '顺峰康王' not in product_title or temp_search_key not in product_title :
                                        print(f"当前商品名称:{product_title} 不包含关键字:{temp_search_key}")
                                        continue
                                else:
                                    if self.search_key not in product_title.replace(' ', ''):
                                        continue
                        else:
                            print(f"列表当前商品名称不存在")
                        #价格
                        price_xpath = f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView'
                        price_xpath3 = f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView'
                        if self.d.xpath(price_xpath).exists:
                            price_str = self.d.xpath(price_xpath).text
                            print(f"price_xpath列表当前商品价格:{price_str}")
                            if price_str:
                                price = float(re.search('[\d\.]+', price_str).group())
                        elif self.d.xpath(price_xpath3).exists:
                            price_str = self.d.xpath(price_xpath3).text
                            print(f"price_xpath3列表当前商品价格:{price_str}")
                            if price_str:
                                price = float(re.search('[\d\.]+', price_str).group())
                        else:
                            price_xpath2 = f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.widget.FrameLayout[1]/android.widget.TextView'
                            if self.d.xpath(price_xpath2).exists:
                                price_str = self.d.xpath(price_xpath2).text
                                print(f"price_xpath2列表当前商品价格:{price_str}")
                                if price_str:
                                    price = float(re.search('[\d\.]+', price_str).group())
                            else:
                                print(f"列表当前商品价格不存在")
                        # price_str = self.d.xpath(f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]//*[starts-with(@text,"¥")]').text
                        
                        print(f'列表获取到价格:{price}')

                        #店铺名称的xpath
                        shop_name_xpath = f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.FrameLayout[last()]/android.widget.TextView[1]'
                        shop_name_xpath2 = f'//android.support.v7.widget.RecyclerView/android.widget.FrameLayout[{idxx}]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[1]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[2]/android.view.ViewGroup[1]/android.widget.FrameLayout[last()]/android.widget.TextView[1]'
                        if self.d.xpath(shop_name_xpath).exists:
                            shop_name = self.d.xpath(shop_name_xpath).text
                            print(f"shop_name_xpath列表当前商品店铺名称:{shop_name}")
                        elif self.d.xpath(shop_name_xpath2).exists:
                            shop_name = self.d.xpath(shop_name_xpath2).text
                            print(f"shop_name_xpath2列表当前商品店铺名称:{shop_name}")
                        else:
                            print(f"列表当前商品店铺名称不存在")

                        
                        #如果商品的名称、价格和生产厂家都不存在则直接下一条数据。 跳过一些不是商品的数据。
                        if product_title == '' and price == '' and shop_name == '':
                            continue   

                        scrape_date = self.get_current_date()

                        if  product_title and  price and  shop_name:
                            #判断数据表中是否存在
                            dup_data = {'product': product_title, 'min_price': price, 'shop': shop_name, 'scrape_date': scrape_date,'platform': '美团'}
                            if self.data_is_exists(dup_data):
                                print('列表存在相同数据不入库')
                                continue
                            
                        self.safe_exec(drug_one.click)
                        print('点击目标药品完毕')
                        time.sleep(2)
                        # 采集药品信息
                        try:
                            # self.integrate_data()
                            self.safe_exec(self.integrate_data)
                            # 检测下是否回退到列表页
                            if self.distinct_target():
                                print('回退到列表页', True)
                            else:
                                if self.d.xpath('//*[@text="搜索"]').exists:
                                    print("检测到搜索按钮，重新开始采集流程")
                                    if retry_count < MAX_RETRY:
                                        # 停止当前监控线程
                                        self.monitor.stop()
                                        self.monitor.join()
                                        # 递归重启采集
                                        return self.main(device_id, retry_count+1)
                                    else:
                                        print("超过最大重试次数，终止程序")
                                        return
                                else:
                                    print("无法恢复页面，终止采集")
                                    return

                                # print('回退到列表页失败，终止采集')
                                # return
                            time.sleep(self.get_sleep_time())
                            spider_no += 1
                        except Exception as e:
                            print(f'采集药品详情数据出错:{e}')
                            #增加阻塞的方法：
                            if not self.distinct_target():
                                for i in range(1):
                                    self.swipe_back(1)
                                    # 最外部有个定位按钮
                                    if self.distinct_target():
                                        break
                                    if i == 0 and not self.distinct_target():
                                        print('页面出错，退出采集')
                                        return
                            else:
                                continue
                if self.d.xpath('//*[@text="已经到底啦"]').exists:
                    print('已经到达列表页最底部')
                    return
                search_list = self.d.xpath('//android.support.v7.widget.RecyclerView').info
                bounds = search_list['bounds']
                #print('搜索列表高度', 1400 + bounds['top'] - bounds['bottom'])
                # self.d.swipe(200, 1400, 200, 1400 + bounds['top'] - bounds['bottom'])

                # 计算滑动距离
                scroll_distance = bounds['bottom'] - bounds['top']  # 正数
                start_y = 1600
                end_y = start_y - scroll_distance  # 向上滑动，y 坐标减小

                # 确保 end_y 不小于 0
                end_y = max(end_y, 304)  # 留出一点边距，避免滑出屏幕

                # print('滑动起点 y:', start_y, '终点 y:', end_y)
                # self.d.swipe(200, start_y, 200, end_y, 0.4)
                print('开始滑动')
                self.d.drag(300, 1400, 300, 400, 1)
                # self.safe_exec(self.d.drag, 300, 1400, 300, 400, 1)
                print('滑动结束')

                #print('搜索列表高度', 1400 + bounds['top'] - bounds['bottom'])
                # self.d.swipe(200, 1400, 200, 1400 + bounds['top'] - bounds['bottom'])
                # self.d.swipe(200, 1400, 200, 1400 + bounds['top'] - bounds['bottom'], 0.4)
                time.sleep(self.get_sleep_time())
        finally:
            # 确保监控线程被停止
            self.monitor.stop()
            self.monitor.join()

    def unitest(self):
        """
        单元测试
        :return:
        """
        save_data = {
                    'product':"[昆中药]舒肝颗粒(低糖型)",
                    'min_price': 14.0,
                    'manufacture_date': '',
                    'expiry_date': '36个月',
                    'shop': '美团自营大药房（快递电商）',
                    'business_license_company': '',
                    'province': '',
                    'city': '',
                    'manufacturer': '昆明中药厂有限公司',
                    'specification': '3g*16袋/盒',
                    'approval_number': '国药准字Z53021161',
                    'product_link': '',
                    'scrape_date': '2025/07/09',
                    'scrape_province': '广东',
                    'availability': '',
                    'credit_code': '',
                    'platform': '美团'
                }
        self.save_to_database(save_data)
    
        time.sleep(100000)    
        pass


# retrieve database
def get_retrieve_mysql():
    """
    建立远端连接并返回一个到数据库的连接对象
    """
    import pymysql
    return pymysql.connect(
        host='39.108.116.125',  # 修改后的主机
        port=3306,  # 添加端口号
        user='drug_retrieve',  # 修改后的用户名
        password='Pem287cwM58jNpe2',  # 修改后的密码
        db='drug_retrieve',  # 修改后的数据库名
        charset='utf8mb4'
    )



def main():

    #从配置的系统里面读取采集用到的设备和搜索关键词

    #1、数据库的连接，从数据库中获取采集品规和设备adb码，启动程序进行采集，如果配置了采集时间，还需要支持到了时间终止采集，如果配置了采集的页数，需要滑动到指定的页数后再进行采集

    #2、代码要支持多线程(线程池)的管理，每个线程有自己的生命周期。

    #获取未开始的美团平台的采集任务


    retrieve_conn = get_retrieve_mysql()
    cursor = retrieve_conn.cursor()
    query = "SELECT id,collect_equipment_id,product_name,start_page,end_page FROM retrieve_collect_task_allocate WHERE status = 1 AND platform = 4"
    cursor.execute(query)
    result = cursor.fetchone()

    if result:
        collect_equipment_id    = result [1]
        product_name            = result[2]
        start_page              = result[3]
        end_page                = result[4]

        print(f"collect_equipment_id={collect_equipment_id}")
        print(f"product_name={product_name}")

        if collect_equipment_id == 0:
            print("设备id不存在")            
            return
        
        if product_name == '':
            print("采集关键字获取失败")            
            return

        #通过 collect_equipment_id 获取设别adb码

        device_query = "SELECT device_id FROM retrieve_collect_equipment WHERE id = %s and status = 0"
        
        cursor.execute(device_query, (collect_equipment_id))

        device_result = cursor.fetchone()

        if device_result:
            device_id =  device_result[0]
            print(f"device_id={device_id}")
        else:
            # self.loggerMT.info("没有可用的设备进行数据采集")
            print("没有可用的设备进行数据采集")            
            return

    else:
        # self.loggerMT.info("MT 没有要采集的品规")
        print("MT 没有要采集的品规")
        return
    
    key = product_name

    try:
        mt = MT(key)          # 用当前关键字实例化
        mt.main(device_id,start_page,end_page)    # 执行一次完整采集
        logging.info(f'关键字 {key} 本轮采集完成')
    except Exception as e:
        # 发生异常直接跳过该关键字，继续下一轮
        logging.exception(f'关键字 {key} 采集异常：{e}')
    finally:
        # 关闭当前 MT 实例资源（如有需要）
        if hasattr(mt, 'close'):
            mt.close()
    


    # keys_list = [
    #     # '三九胃泰颗粒',
    #     # '999小柴胡颗粒',
    #     # '999强力枇杷露',
    #     # '[999]感冒清热颗粒',
    #     # '999抗病毒口服液',
    #     # '999皮炎平',
    #     # '999盐酸特比萘芬乳膏',
    #     # '999盐酸特比萘芬',
    #     # '999藿香正气合剂',
    #     # '999必无忧盐酸特比萘芬乳膏',
    #     # '999复方感冒灵颗粒',
    #     # '999糠酸莫米松凝胶',
    #     # '999铝碳酸镁咀嚼片',
    #     # '999阿奇霉素片',
    #     # '999选平硝酸咪康唑乳膏',
    #     # 按需继续添加,

    #     #暂时不需要
    #     # '999必无忧盐酸特比萘芬喷雾剂30'
    #     # '999冰连清咽'
    #     # '999复方金银花颗粒10g'
    #     # '999复方苦参肠炎康片12片'
    #     # '999强力枇杷露16袋'
    #     # '999三蛇胆川贝膏138'
    #     # '999维生素ec颗粒'
    #     # '三九胃泰养胃舒颗粒8袋'
    #     # '999止泻利颗粒15g*8'
    #     # '999阿奇霉素片'
    #     # '999可调式生理性海水鼻腔喷雾50'
    #     # '999小儿止咳糖浆120'              #不低于19.8
    #     # '999小儿止咳糖浆225'              #禁止挂网
    #     # '999小儿感冒颗粒6g*10'            #不低于24.9
    #     # '999小儿感冒颗粒6g*24'            #禁止挂网
    #     # '999小儿氨酚黄那敏颗粒6g*10袋'     #不低于15.8
    #     # '999小儿氨酚黄那敏颗粒6g*20袋'     #禁止挂网
    #     # '999小儿咽扁颗粒8g*10袋'           #仅限999官旗店


    #     #2025-08-01最新  其中 藿香正气合剂两种规格 10支和6支 抗病毒口服液 12支和18支 蒲地蓝 24片 36片和44片 枇杷露225ml 小柴胡颗粒9袋和15袋 养胃舒 6袋 复方感冒灵颗粒15袋,
    #     #曲安奈德益康唑乳膏 30g 葡萄糖酸锌口服溶液 12支 18支 24支和30支,
    #     # 1、999止泻利颗粒15g*8 没有数据 2、999维生素ec颗粒 没有数据 3、999三蛇胆川贝膏138 没有数据 4、999强力枇杷露16袋 没有数据  5、999冰连清咽 没有数据
    #     # '999藿香正气合剂',
    #     # '999糠酸莫米松凝胶15',
    #     # '999抗病毒口服液'
    #     # '999抗病毒口服液10ml*10'
    #     # '999抗病毒口服液10ml*12',
    #     # '999蒲地蓝消炎片',
    #     # '999强力枇杷露225ml',
    #     # '999小柴胡颗粒',
    #     # '999养胃舒颗粒',
    #     # '999复方感冒灵颗粒',
    #     # '999黄芪精',
    #     # '999皮炎平曲安奈德益康唑乳膏30',
    #     # '999葡萄糖酸锌口服溶液',
    #     # '今维多赐多康牌蛋白粉',
    #     # '佳美舒阿奇霉素肠溶胶囊4'
    #     # '999必无忧盐酸特比萘芬乳膏15g'        
    #     # '999复方板蓝根颗粒15g*15袋/盒'       
    #     # '999速复康布洛芬缓释胶囊'
    #     # '999维生素C咀嚼片'
    #     # '999精氨酸布洛芬颗粒'
    #     # '999强力枇杷露120ml' 

    #     #OTC
    #     # '999强力枇杷露150ml' 
    #     # '999糠酸莫米松乳膏10g支'
    #     # '999选平硝酸咪康唑乳膏20g'
    #     '999感冒清热颗粒(无糖)6g'
    #     # '999银菊清咽颗粒'         #只有一条数据
    #     # '999补脾益肠丸'
    #     # '999壮骨关节丸6g*20'
    #     # '999壮骨关节胶囊'
    #     # '999正天丸6g*15'
    #     # '999正天胶囊'
    #     # '三九胃泰胶囊'
    #     # '三九胃泰颗粒20g*10'
    #     # '三九胃泰颗粒(无糖)2.5g*6' # 没有数据

    #     #10.31 new add

    #     # '999感冒灵颗粒'                   #不低于15.5
    #     # '999皮炎平复方醋酸地塞米松乳膏20'  #不低于12.5
    #     # '三九胃泰颗粒20g*6袋'             #不低于13.5
    #     # '顺峰康王酮康他索乳膏' #包含10g和20g两个规格  10g 不低于7.5 20g 不低于12.5
    #     # '999糠酸莫米松凝胶10'             #不低于26.9
    #     # '999板蓝根颗粒10g*20'             #不低于26.9
    #     # '999复方氨酚烷胺胶囊12粒'          #不低于17.9 
    #     # '999复方氨酚烷胺胶囊10粒'          #禁止挂网 
    #     # '999复方氨酚烷胺胶囊6粒'           #禁止挂网 
    #      # '999复方氨酚烷胺胶囊'
    #     # '999咽炎片0.26g*12片*2板'         #不低于13.5
    #     # '999感冒灵胶囊'                   #仅限999官旗店
    #     # '999荆防颗粒'                     #美团没有数据 #禁止挂网
    #     # '999小儿感冒宁颗粒2.5g*10袋'       #禁止挂网
    #     # '999磷酸奥司他韦胶囊75mg*10'       #仅限999官旗店
    #     # '史达功右美沙芬愈创甘油醚糖浆120'   #仅限999官旗店
    #     # '999感冒清热颗粒12g*18'


    # ]
    
    # #美团手机号：
    # # device_id = '21885f5'      # 设备序列号
    # # device_id = '2e58510'      # 设备序列号
    # # device_id = 'KNNNEMNVWCJZQOLZ'
    # # device_id = 'B6JVE6AYSWU4LRLZ'
    # # device_id = '656DTOPRZDEALZ5X'
    # # device_id = 'GIOFIBRKZTUGJJAE'
    # # device_id = 'fcb3c749'
    # # device_id = 'UCQGF6CQFMU8WKHI'
    # # device_id = '4TZDUGTOAIFMJVGU'
    # # device_id = '95b2c764'
    # # device_id = 'ZDQWUSSWBEDI896T'
    # # device_id = 'R4SKMJPNBQAENRAM'
    # # device_id = '1462a51f' 

    # # device_id = '97ae80e0'      # 设备序列号
    # # device_id = 'IZTOWWDQT45D49BU'
    # # device_id = 'N7ZXBITOSOGMYXQS'
    # # device_id = '369dcf96'
    # # device_id = 'GQIRKB7LVOONM7VW'
    # device_id = 'T4UCEQGQEEYP65ZL'
    # # device_id = '49L7GMPRVS85LJHE'
    # # device_id = 'WWRO9LTGG6KFGQCM'
    # # device_id = 'DYF67TM7KJ4POJLF'
    # # device_id = 'ea4e4eb8' 
    # # device_id = 'U8ONIJJJS4CELVD6'

    # cycle_no  = 0               # 轮次计数

    # while True:
    #     cycle_no += 1
    #     logging.info(f'========== 第 {cycle_no} 轮采集开始 ==========')
    #     for idx, key in enumerate(keys_list, 1):
    #         logging.info(f'[{idx}/{len(keys_list)}] 开始采集关键字：{key}')
    #         try:
    #             mt = MT(key)          # 用当前关键字实例化
    #             mt.main(device_id)    # 执行一次完整采集
    #             logging.info(f'关键字 {key} 本轮采集完成')
    #         except Exception as e:
    #             # 发生异常直接跳过该关键字，继续下一轮
    #             logging.exception(f'关键字 {key} 采集异常：{e}')
    #         finally:
    #             # 关闭当前 MT 实例资源（如有需要）
    #             if hasattr(mt, 'close'):
    #                 mt.close()

        # logging.info('本轮全部关键字采集完成，等待 2 小时后下一轮...')
        # time.sleep(1 * 3600)   # 2 小时 = 7200 秒




    # keys = '小柴胡颗粒' # 参苓健脾胃颗粒  舒肝颗粒 清肺化痰丸 香砂平胃颗粒 小柴胡颗粒
    # mt = MT(keys)  # 参苓健脾胃颗粒  舒肝颗粒 清肺化痰丸 香砂平胃颗粒
    # # mt.main('95b2c764')
    # mt.main('fcb3c749')
            

class TimeoutException(Exception):
    pass

@contextmanager
def time_limit(seconds):
    """超时上下文管理器"""
    def signal_handler(signum, frame):
        raise TimeoutException("任务执行超时")
    
    signal.signal(signal.SIGALRM, signal_handler)
    signal.alarm(seconds)
    try:
        yield
    finally:
        signal.alarm(0)

# 如果需要并行处理（提高效率），可以使用线程池：
def process_tasks_in_parallel(max_workers=10):
    """使用线程池并行处理多个任务""" """使用线程池并行处理多个任务，每个任务最多执行30分钟"""
    from concurrent.futures import ThreadPoolExecutor, as_completed
    
    retrieve_conn = get_retrieve_mysql()
    cursor = retrieve_conn.cursor()
    
    query = """
    SELECT id, collect_equipment_id, product_name, start_page, end_page 
    FROM retrieve_collect_task_allocate 
    WHERE status = 1 AND platform = 4
    """
    cursor.execute(query)
    results = cursor.fetchall()

    print(f"获取到的任务结果={results}")
    
    if not results:
        print("MT 没有要采集的品规")
        return
    
    # 准备任务列表
    tasks = []
    device_map = {}
    
    for result in results:
        task_id = result[0]
        collect_equipment_id = result[1]
        product_name = result[2]
        start_page = result[3]
        end_page = result[4]
        
        if collect_equipment_id != 0 and product_name and product_name.strip():
            # 缓存设备查询
            if collect_equipment_id not in device_map:
                device_query = "SELECT device_id FROM retrieve_collect_equipment WHERE id = %s AND status = 0"
                cursor.execute(device_query, (collect_equipment_id,))
                device_result = cursor.fetchone()
                device_map[collect_equipment_id] = device_result[0] if device_result else None
            
            if device_map[collect_equipment_id]:
                tasks.append({
                    'task_id': task_id,
                    'device_id': device_map[collect_equipment_id],
                    'key': product_name.strip(),
                    'start_page': start_page,
                    'end_page': end_page
                })
    
    cursor.close()
    retrieve_conn.close()
    
    if not tasks:
        print("没有有效的采集任务")
        return
    
    print(f"准备并行处理 {len(tasks)} 个任务")
    
    def process_single_task(task):
        """处理单个任务的函数""""""处理单个任务的函数，带有30分钟超时限制"""

        start_time = time.time()
        timeout_seconds = 30 * 60  # 30分钟

        try:

            # 检查任务是否已经超时
            elapsed_time = time.time() - start_time
            if elapsed_time >= timeout_seconds:
                raise TimeoutException(f"任务执行已超过 {elapsed_time//60} 分钟")

            mt = MT(task['key'])

            # 使用超时机制执行主任务
            with time_limit(timeout_seconds):
                mt.main(task['device_id'], task['start_page'], task['end_page'])

            # mt.main(task['device_id'], task['start_page'], task['end_page'])
            # logging.info(f"任务 {task['task_id']}: 关键字 {task['key']} 采集完成")
            execution_time = time.time() - start_time
            logging.info(f"任务 {task['task_id']}: 关键字 {task['key']} 采集完成，耗时 {execution_time//60} 分钟 {execution_time%60:.1f} 秒")
            return task['task_id'], True, None, execution_time
        except TimeoutException as e:
            execution_time = time.time() - start_time
            logging.warning(f"任务 {task['task_id']}: 执行超时，已执行 {execution_time//60} 分钟")
            if 'mt' in locals() and hasattr(mt, 'close'):
                mt.close()
            return task['task_id'], False, str(e), execution_time
        except Exception as e:
            execution_time = time.time() - start_time
            logging.exception(f"任务 {task['task_id']}: 采集异常：{e}，已执行 {execution_time//60} 分钟")
            if 'mt' in locals() and hasattr(mt, 'close'):
                mt.close()
            return task['task_id'], False, str(e), execution_time
        finally:
            if 'mt' in locals() and hasattr(mt, 'close'):
                mt.close()
    
    # 使用线程池并行执行
    successful_tasks = 0
    failed_tasks = 0
    
    with ThreadPoolExecutor(max_workers=max_workers) as executor:
        # 提交所有任务，每个任务最多30分钟
        future_to_task = {
            executor.submit(process_single_task, task): task 
            for task in tasks
        }
        
        # 处理完成的任务
        for future in as_completed(future_to_task):
            task = future_to_task[future]
            try:
                # 设置future的超时时间为30分钟
                task_id, success, error, execution_time = future.result(timeout=30*60)
                total_execution_time += execution_time
                # task_id, success, error = future.result()
                if success:
                    successful_tasks += 1
                    # print(f"任务 {task_id}: 完成")
                    print(f"任务 {task_id}: 完成，耗时 {execution_time//60} 分钟 {execution_time%60:.1f} 秒")
                else:
                    failed_tasks += 1
                    # print(f"任务 {task_id}: 失败")
                    if "超时" in error or "Timeout" in error:
                        timeout_tasks += 1
                        print(f"任务 {task_id}: 超时失败，已执行 {execution_time//60} 分钟")
                    else:
                        print(f"任务 {task_id}: 失败，耗时 {execution_time//60} 分钟 {execution_time%60:.1f} 秒，错误：{error}")
            
            except TimeoutException as e:
                failed_tasks += 1
                timeout_tasks += 1
                print(f"任务 {task['task_id']}: 执行超时 (30分钟限制)")
            except Exception as e:
                failed_tasks += 1
                print(f"任务 {task['task_id']}: 执行异常 {e}")
    
    avg_time = total_execution_time / (successful_tasks + failed_tasks) if (successful_tasks + failed_tasks) > 0 else 0
    
    # print(f"\n并行采集完成: 成功 {successful_tasks} 个, 失败 {failed_tasks} 个")            
    print(f"\n并行采集完成:")
    print(f"成功: {successful_tasks} 个")
    print(f"失败: {failed_tasks} 个 (其中超时: {timeout_tasks} 个)")
    print(f"平均执行时间: {avg_time//60} 分钟 {avg_time%60:.1f} 秒")
    print(f"总计执行时间: {total_execution_time//60} 分钟 {total_execution_time%60:.1f} 秒")


if __name__ == '__main__':
    # main()

    process_tasks_in_parallel(max_workers=10)  # 可以同时处理3个任务


    # scheduler = BlockingScheduler()
    # scheduler.add_job(main, 'cron', hour=21, minute=30, misfire_grace_time=120)
    # try:
    #     scheduler.start()
    # except (KeyboardInterrupt, SystemExit):
    #     pass