bjguahao.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
北京市预约挂号统一平台
"""

import os
import sys
import re
import json
import time
import datetime
import logging
from lib.prettytable import PrettyTable
import base64
from Crypto.Cipher import AES
from tqdm import tqdm, trange


if sys.version_info.major != 3:
    logging.error("请在python3环境下运行本程序")
    sys.exit(-1)

try:
    import requests
except ModuleNotFoundError as e:
    logging.error("请安装python3 requests")
    sys.exit(-1)

from browser import Browser
from idcard_information import GetInformation

try:
    import yaml
except ModuleNotFoundError as e:
    logging.error("请安装python3 yaml模块")
    sys.exit(-1)


class Config(object):

    def __init__(self, config_path):
        try:
            with open(config_path, "r", encoding="utf-8") as yaml_file:
                data = yaml.load(yaml_file)
                debug_level = data["DebugLevel"]
                if debug_level == "debug":
                    self.debug_level = logging.DEBUG
                elif debug_level == "info":
                    self.debug_level = logging.INFO
                elif debug_level == "warning":
                    self.debug_level = logging.WARNING
                elif debug_level == "error":
                    self.debug_level = logging.ERROR
                elif debug_level == "critical":
                    self.debug_level = logging.CRITICAL

                logging.basicConfig(level=self.debug_level,
                                    format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
                                    datefmt='%a, %d %b %Y %H:%M:%S')

                self.mobile_no = data["username"]
                self.password = data["password"]
                self.date = data["date"]
                self.hospital_id = data["hospitalId"]
                self.department_id = data["departmentId"]
                self.duty_code = data["dutyCode"]
                self.patient_name = data["patientName"]
                self.hospital_card_id = data["hospitalCardId"]
                self.medicare_card_id = data["medicareCardId"]
                self.reimbursement_type = data["reimbursementType"]
                self.doctorName = data["doctorName"]
                self.children_name = data["childrenName"]
                self.children_idno = data["childrenIdNo"]
                self.cid_type = data["cidType"]
                self.children = data["children"]
                self.assign = data['assign']
                self.remaining = data['remaining']
                self.week = data['week']
                self.chooseBest = {"yes": True, "no": False}[data["chooseBest"]]
                self.patient_id = int()
                self.web_password = "hyde2019hyde2019"
                try:
                    self.useIMessage = data["useIMessage"]
                except KeyError:
                    self.useIMessage = "false"
                try:
                    self.useQPython3 = data["useQPython3"]
                except KeyError:
                    self.useQPython3 = "false"
                try:
                    self.children = data["children"]
                except KeyError:
                    self.children = "false"
                #
                logging.info("配置加载完成")
                logging.debug("手机号:" + str(self.mobile_no))
                logging.debug("挂号日期:" + str(self.date))
                logging.debug("医院id:" + str(self.hospital_id))
                logging.debug("科室id:" + str(self.department_id))
                logging.debug("上午/下午:" + str(self.duty_code))
                logging.debug("就诊人姓名:" + str(self.patient_name))
                logging.debug("所选医生:" + str(self.doctorName))
                logging.debug("是否挂指定医生:"+str(self.assign))
                logging.debug("检索每天余票:"+str(self.remaining))
                logging.debug("检索周:"+str(self.week))
                logging.debug("是否挂儿童号:" + str(self.children))
                if self.children == "true":
                    logging.debug("患儿姓名:" + str(self.children_name))
                    logging.debug("患儿证件号" + str(self.children_idno))
                    logging.debug("患儿证件类型:" + str(self.cid_type))
                    logging.debug("患儿性别:" + str(GetInformation(self.children_idno).get_sex()))
                    logging.debug("患儿生日:" + str(GetInformation(self.children_idno).get_birthday()))
                logging.debug("使用mac电脑接收验证码:" + str(self.useIMessage))
                logging.debug("是否使用 QPython3 运行本脚本:" + str(self.useQPython3))

                if not self.date:
                    logging.error("请填写挂号时间")
                    exit(-1)

        except Exception as e:
            logging.error(repr(e))
            sys.exit()

class AES_encrypt():

    def __init__(self, key, mode='ecb', iv=''):

        self.key = key#.decode("hex")
        self.iv = iv
        self.cryptor = None
        if mode == "ecb":
            self.cryptor = AES.new(str.encode(self.key), AES.MODE_ECB)
        elif mode == 'cbc':
            self.cryptor = AES.new(str.encode(self.key), AES.MODE_CBC, self.iv)
        else:
            return "Error Mode"



    def __pad(self, text):
        """填充方式，PKCS7"""
        text_length = len(text)
        amount_to_pad = AES.block_size - (text_length % AES.block_size)
        # if amount_to_pad == 0:
        #     amount_to_pad = AES.block_size
        padd = chr(amount_to_pad)
        return text + padd * amount_to_pad

    def __unpad(self, text):
        padd = ord(text[-1])
        return text[:-padd]

    def encrypt(self, text):
        text = self.__pad(text)
        self.ciphertext = self.cryptor.encrypt(str.encode(text))
        word = base64.b64encode(self.ciphertext)
        word = str(word,encoding="utf-8").replace('/', '_')
        word = word.replace('+', '-')
        return word

    def decrypt(self, text):

        plain_text = self.cryptor.decrypt(base64.b64decode(text))
        return self.__unpad(plain_text)

    def get_byte(self,str_in):
        str_out = ""

        for i in range(0, len(str_in), 2):
            str_out = str_out+"0x%s" % str_in[i:i+2]+","
        str_out = str_out[:-1]
        return str_out

class Guahao(object):
    """
    挂号
    """

    def __init__(self, config_path="config.yaml"):
        self.browser = Browser()
        self.dutys = ""
        self.refresh_time = ''
        self.verify_url = "http://www.114yygh.com/web/verify"
        self.login_url = "http://www.114yygh.com/web/login"
        self.send_code_url = "http://www.114yygh.com/web/getVerifyCode"
        self.duty_url = "http://www.114yygh.com/web/product/detail"
        self.confirm_url = "http://www.114yygh.com/web/order/saveOrder"
        self.patient_id_url = "http://www.114yygh.com/order/confirm/"
        self.query_hospital_url = "http://www.114yygh.com/web/queryHospitalById"
        self.calendar = "http://www.114yygh.com/web/product/list"
        self.order_patient_list = "http://www.114yygh.com/web/patient/orderPatientList"

        self.config = Config(config_path)                       # config对象
        if self.config.useIMessage == 'true':
            # 按需导入 imessage.py
            import imessage
            self.imessage = imessage.IMessage()
        else:
            self.imessage = None

        if self.config.useQPython3 == 'true':
            try: # Android QPython3 验证
                # 按需导入 qpython3.py
                import qpython3
                self.qpython3 = qpython3.QPython3()
            except ModuleNotFoundError:
                self.qpython3 = None
        else:
            self.qpython3 = None

    def is_login(self):
        logging.info("开始检查是否已经登录")
        response = self.browser.get("http://www.114yygh.com/web/patient/validPatientList"+"?rd="+str(self.timestamp()), data='')
        try:
            data = json.loads(response.text)
            if data["resCode"] == 0:
                logging.debug("response data:" + response.text)
                return True
            else:
                logging.debug("response data: HTML body")
                return False
        except Exception as e:
            logging.error(e)
            return False

    def auth_login(self):
        """
        登录
        """
        try:
            # patch for qpython3
            cookies_file = os.path.join(os.path.dirname(sys.argv[0]), "." + self.config.mobile_no + ".cookies")
            self.browser.load_cookies(cookies_file)
            if self.is_login():
                logging.info("cookies登录成功")
                return True
        except Exception as e:
            pass
          
        aes = AES_encrypt(self.config.web_password, 'ecb', '')
        logging.info("cookies登录失败")

        logging.info("开始使用账号密码登录")
        self.browser.get(self.verify_url+"?mobile="+self.config.mobile_no+"&rd="+str(self.timestamp()),"")
        sms_code = self.get_sms_verify_code("LOGIN")
        time.sleep(1)

        mobile_no = self.config.mobile_no
        payload = {
            'loginType': 'SMS_CODE_LOGIN',
            'mobile': aes.encrypt(mobile_no),
            'password': aes.encrypt(sms_code)
        }
        response = self.browser.post(self.login_url, data=payload)
        logging.debug("response data:" + response.text)
        try:
            data = json.loads(response.text)
            if data['resCode'] == 0:#data["msg"] == "OK" and not data["hasError"] and data["code"] == 200:
                # patch for qpython3
                cookies_file = os.path.join(os.path.dirname(sys.argv[0]), "." + self.config.mobile_no + ".cookies")
                self.browser.save_cookies(cookies_file)
                logging.info("登录成功")
                return True
            else:
                logging.error(data["msg"])
                raise Exception()

        except Exception as e:
            logging.error(e)
            logging.error("登录失败")
            sys.exit(-1)
    def calendar_vec(self):
        param = {
            "hospitalId": self.config.hospital_id,
            "departmentId": self.config.department_id,
            "week": "1",
            "latitude" : "39.91488908",
            "longitude" : "116.40387397"
            }
        response = self.browser.post(self.calendar,param)
        logging.debug("response data:" + response.text)
        data = json.loads(response.text)
        rt = []
        if data['resCode'] == 0:
            for duty in data['data']['calendars']:
                if duty['remainAvailableNumberWeb']>=0 and str(duty['dutyWeek']) in self.config.week:
                    rt.append(duty['dutyDate'])
        logging.info('该科室可挂'+','.join(rt)+'号')
        self.calendar_vec_param = rt
    def select_doctor(self):
        if self.config.remaining == "true":
            for duty_date in self.calendar_vec_param:
                    logging.info("查询"+duty_date+"号源")
                    doctor = self.select_doctor_one_day(duty_date)
                    if doctor == 'NoDuty' or doctor == 'NotReady' :
                        time.sleep(3)
                        continue
                    else:
                        return doctor
            return 'NoDuty'
        else:
            doctor = self.select_doctor_one_day(self.config.date)
            return doctor
 
    def select_doctor_one_day(self,duty_date):
        """选择合适的大夫"""
        hospital_id = self.config.hospital_id
        department_id = self.config.department_id
        duty_code = self.config.duty_code
        # log current date
        logging.debug("当前挂号日期: " + self.config.date)

        payload = {
            'hospitalId': hospital_id,
            'departmentId': department_id,
            'dutyDate': duty_date
        }
        response = self.browser.post(self.duty_url, data=payload)
        logging.debug("response data:" + response.text)
        try:
            data = json.loads(response.text)
            if  data["resCode"] == 0:
                dutys =[]
                if self.config.duty_code == '1': #上午
                    dutys = [1]
                elif self.config.duty_code == '2': #下午
                    dutys = [2]
                else: #全天
                    dutys = [1,2]
                for duty in dutys:
                    for duty_result in data['data']:
                        if(duty_result['dutyCode'] == duty):
                            self.dutys = duty_result['detail']
                            doctor = self.select_doctor_by_vec()
                            if doctor == 'NoDuty' or doctor == 'NotReady' :
                                continue
                            return doctor
                return 'NoDuty'
        except Exception as e:
            logging.error(repr(e))
            sys.exit()
    def select_doctor_by_vec(self):
        if len(self.dutys) == 0:
            return "NotReady"
        self.print_doctor()
        doctors = self.dutys
        if self.config.assign == 'true':
            for doctor_conf in self.config.doctorName:
                for doctor in doctors:
                    if self.get_doctor_name(doctor) == doctor_conf and (doctor['totalCount']%2!=0):
                        logging.info("选中:" + self.get_doctor_name(doctor))
                        return doctor
            return "NoDuty"
        # 按照配置优先级选择医生
        for doctor_conf in self.config.doctorName:
            for doctor in doctors:
                if self.get_doctor_name(doctor) == doctor_conf and doctor['totalCount']%2!=0:
                    return doctor

        # 若没有合适的医生，默认返回最好的医生
        for doctor in doctors:
            if doctor['totalCount']%2 != 0:
                logging.info("选中:" + self.get_doctor_name(doctor))
                return doctor
        return "NoDuty"

    def get_doctor_name(self,doctor):
        if doctor['doctorName'] is not None:
            return str(doctor['doctorName'])
        else:
            return str(doctor['doctorTitleName'])

    def print_doctor(self):
        logging.info("当前号余量:")
        x = PrettyTable()
        x.border = True
        x.field_names = ["医生姓名", "擅长", "号余量"]
        for doctor in self.dutys:
            x.add_row([self.get_doctor_name(doctor), doctor['doctorSkill'], "无" if doctor['totalCount']%2 == 0 else "有"])
        print(x.get_string())
        pass

    def get_it(self, doctor, sms_code):
        """
        挂号
        """
        duty_source_id = str(doctor['dutySourceId'])
        hospital_id = self.config.hospital_id
        department_id = self.config.department_id
        patient_id = str(self.config.patient_id)
        hospital_card_id = self.config.hospital_card_id
        medicare_card_id = self.config.medicare_card_id
        reimbursement_type = self.config.reimbursement_type
        doctor_id = str(doctor['doctorId'])
        #新版可能不区分儿童与成人,需测试
        if self.config.children == 'true':
            cid_type = self.config.cid_type
            children_name = self.config.children_name
            children_idno = self.config.children_idno
            children_gender = GetInformation(children_idno).get_sex()
            children_birthday = GetInformation(children_idno).get_birthday()
            payload = {
                'phone':self.config.mobile_no,
                'dutySourceId': duty_source_id,
                'hospitalId': hospital_id,
                'departmentId': department_id,
                'doctorId': doctor_id,
                'patientId': patient_id,
                'hospitalCardId': hospital_card_id,
                'medicareCardId': medicare_card_id,
                "reimbursementType": reimbursement_type,  # 报销类型
                'smsVerifyCode': sms_code,  # TODO 获取验证码
                'childrenName': children_name,
                'childrenIdNo': children_idno,
                'cidType': cid_type,
                'childrenGender': children_gender,
                'childrenBirthday': children_birthday,
                'isAjax': 'true'
            }
        else:
            payload = {
                "hospitalId": hospital_id,
                "departmentId": department_id,
                "dutySourceId": duty_source_id,
                "doctorId": doctor_id,
                "patientId": patient_id,
                "dutyDate": doctor['dutyDate'],
                "dutyCode": doctor['dutyCode'],
                "totalFee":doctor['totalFee'],
                "period":"",
                "mapDepartmentId":"",
                "mapDoctorId":"",
                "planCode":"",
                "medicareCardId": medicare_card_id,
                "jytCardId":"",
                "hospitalCardId": hospital_card_id,
                "mapDutySourceId":"",
                "smsCode": sms_code,
                "mobileNo": self.config.mobile_no
            }
        #save order 
        response = self.browser.post(self.confirm_url, data=payload)
        logging.debug("payload:" + json.dumps(payload))
        logging.debug("response data:" + response.text)

        try:
            data = json.loads(response.text)
            if data["resCode"] == 0:
                #20181027,成功result：
                #{"msg":"成功","code":1,"orderId":"97465746","isLineUp":false}
                logging.info("挂号成功")
                return True
            if data["resCode"] == 8008:
                #重复订单，说明挂号成功
                #{"code":8008,"msg":"科室预约规则检查重复订单","data":null}
                logging.error(data["msg"])
                return True
            else:
                logging.error(data["msg"])
                return False

        except Exception as e:
            logging.error(repr(e))
            time.sleep(1)

    def get_patient_id(self):
        """获取就诊人Id"""
        response = self.browser.get(self.order_patient_list+"?rd="+str(self.timestamp()), "")
        ret = response.text
        data = json.loads(ret)
        if data['resCode'] != 0:
            sys.exit("获取患者id失败")
        else:
            #TODO 如果重名,提供输入选择
            for patient in data['data']:
                if patient['name'][1:] in self.config.patient_name:
                    self.config.patient_id = patient['id']
                    break
            logging.info("病人ID:" + str(self.config.patient_id))
        return self.config.patient_id

    def gen_department_url(self):
        return self.query_hospital_url + "?hosId="+str(self.config.hospital_id)+"&rd="+str(self.timestamp())
    def timestamp(self):
        return int(round(time.time()*1000))
    def get_duty_time(self):
        """获取放号时间"""
        addr = self.gen_department_url()
        response = self.browser.get(addr, "")
        ret = response.text
        data = json.loads(ret)
        if data['resCode'] == 0:
            # 放号时间
            refresh_time = data['data']['fhTime']
            # 放号日期
            appoint_day = data['data']['fhPeriod']
            today = datetime.date.today()
            # 优先确认最新可挂号日期
            self.stop_date = today + datetime.timedelta(days=int(appoint_day))
            logging.info("今日可挂号到: " + self.stop_date.strftime("%Y-%m-%d"))
            # 自动挂最新一天的号
            if self.config.date == 'latest':
                self.config.date = self.stop_date.strftime("%Y-%m-%d")
                logging.info("当前挂号日期变更为: " + self.config.date)
            # 生成放号时间和程序开始时间
            con_data_str = self.config.date + " " + refresh_time + ":00"
            self.start_time = datetime.datetime.strptime(con_data_str, '%Y-%m-%d %H:%M:%S') + datetime.timedelta(days= - int(appoint_day))
            logging.info("放号时间: " + self.start_time.strftime("%Y-%m-%d %H:%M"))
    #type:LOGIN
    def get_sms_verify_code(self,type):
        """获取短信验证码"""
        payload = {
        "mobile":self.config.mobile_no,
        "smsKey":type,
        "rd":str(self.timestamp())
        }
        response = self.browser.get(self.send_code_url+"?"+'&'.join([ str(key)+'='+str(value) for key,value in payload.items() ]) , "")
        data = json.loads(response.text)
        logging.debug(response.text)
        if data["resCode"] == 0:
            logging.info("获取验证码成功")
            if self.imessage is not None: # 如果使用 iMessage
                code = self.imessage.get_verify_code()
            elif self.qpython3 is not None: # 如果使用 QPython3
                code = self.qpython3.get_verify_code()
            else:
                code = input("输入短信验证码: ")
            return code
        elif data["msg"] == "短信发送太频繁" and data["code"] == 812:
            logging.error(data["msg"])
            sys.exit()
        elif data["msg"] == "抱歉，短信验证码发送次数已达到今日上限！" and data["code"] == 817:
            logging.error(data["msg"])
            sys.exit()
        else:
            logging.error(data["msg"])
            return None

    def lazy(self):
        cur_time = datetime.datetime.now() + datetime.timedelta(seconds=int(time.timezone + 8*60*60))
        if self.start_time > cur_time:
            seconds = (self.start_time - cur_time).total_seconds()
            logging.info("距离放号时间还有" + str(seconds) + "秒")
            hour = seconds // 3600
            minute = (seconds % 3600) // 60
            second = seconds % 60
            logging.info("距离放号时间还有"+str(int(hour))+" h " + str(int(minute))+" m "+ str(int(second))+ " s")

            sleep_time = seconds - 60
            if sleep_time > 0:
                logging.info("程序休眠" + str(sleep_time) + "秒后开始运行")
                #  time.sleep(sleep_time)

                if sleep_time > 3600:
                    sleep_time -= 60
                    for i in trange(1000):
                        for j in trange(int(sleep_time/1000), leave=False, unit_scale=True):
                            time.sleep(1)
                else:
                    for i in tqdm(range(int(sleep_time)-60)):
                        time.sleep(1)

                # 自动重新登录
                self.auth_login()

    def run(self):
        """主逻辑"""
        self.get_duty_time()
        self.auth_login()                       # 1. 登录
        self.lazy()
        self.calendar_vec()
        self.get_patient_id()                   # 2. 获取病人id
        doctor = ""
        while True:
            doctor = self.select_doctor()       # 3. 选择医生
            if doctor == "NoDuty":
                # 如果当前时间 > 放号时间 + 30s
                if self.start_time + datetime.timedelta(seconds=30) < datetime.datetime.now():
                    # 确认无号，终止程序
                    logging.info("没号了,亲~,休息一下继续刷")
                    time.sleep(1)
                else:
                    # 未到时间，强制重试
                    logging.debug("放号时间: " + self.start_time.strftime("%Y-%m-%d %H:%M"))
                    logging.debug("当前时间: " + datetime.datetime.now().strftime("%Y-%m-%d %H:%M"))
                    logging.info("没号了,但截止时间未到，重试中")
                    time.sleep(1)
            elif doctor == "NotReady":
                logging.info("好像还没放号？重试中")
                time.sleep(1)
            else:
                sms_code = self.get_sms_verify_code('ORDER_CODE')               # 获取验证码
                print('sms_code:',sms_code)
                if sms_code is None:
                    time.sleep(1)
                result = self.get_it(doctor, sms_code)              # 4.挂号
                if result:
                    break                                           # 挂号成功


if __name__ == "__main__":

    if (len(sys.argv) == 3) and (sys.argv[1] == '-c') and (isinstance(sys.argv[2], str)):
        config_path = sys.argv[2]
        guahao = Guahao(config_path)
    else:
        guahao = Guahao()
    guahao.run()