taxbot

+!.gitignore
+.idea/*
+__pycache__/*
+*.pyc
+*.log
+*.db
+*.spec
+*.xlsx
+*.xls
+*.doc
+*.docx
+*.csv
+dist/
+build/

+# 智能数据助手
+## 需要修改配置（main）
+```
+----taxbot
+      |
+      |--common
+           |
+           |--constant.py
+```
+           
+       
++     

+import sys
+import socket
+from common.utils import *
+from PyQt5.QtWidgets import QApplication
+from forms import mainform
+from forms import loginform
+from forms import floderfrom
+from common.config import *
+from common.log import BotLogger
+
+logger = BotLogger(os.path.basename(__file__), logname=1).getLogger()
+BOT_STATUS = False
+HOST = '127.0.0.1'
+PORT = 55555
+
+
+if __name__ == '__main__':
+    filename = sys.argv[0]
+    if not load_config():
+        logger.error("加载配置文件失败！")
+        sys.exit()
+
+    db_path = os.path.join(os.getcwd(), get_cfg().db_path)
+    if not os.path.exists(db_path):
+        if not DBClass().init_db():
+            logger.error("初始化数据库文件失败！")
+            sys.exit(1)
+
+    tenant_id = get_cfg().tenant_id
+    tenant_type = get_cfg().tenant_type
+
+    if tenant_id == "" or tenant_id is None:
+        logger.error("获取配置文件tenant_id数据异常")
+        sys.exit(2)
+    if tenant_type not in ['0', '1']:
+        logger.error("获取配置文件tenant_type数据异常")
+        sys.exit(3)
+
+    crease_shoutcut()  # 创建快捷方式到自启动文件夹中
+
+    app = QApplication(sys.argv)
+
+    login_form = loginform.Ui_LoginWindow()
+    login_form.setupUi()
+
+    main_form = mainform.Ui_MainWindow()
+    main_form.setupUi()
+
+    floder_form = floderfrom.Ui_FloderWindow(main_form)
+    floder_form.setupUi()
+
+    is_err = False, ''
+    result = login_check(tenant_id, tenant_type)
+    if result == 0:
+        login_form.LoginWindow.show()
+        login_form.pushButton_2.clicked.connect(lambda: login_form.login(floder_form, tenant_id, tenant_type))
+    elif result == 1:
+        floder_form.FloderWindow.show()
+    elif result == 2:
+        main_form.mainform_show()
+    elif result == -1:
+        is_err = True, '连接数据库失败！'
+    elif result == -2:
+        is_err = True, '网络连接异常，请稍后重试！'
+
+    if not is_err[0]:
+        do_task_thread = mainform.UpdateDoTask()
+        do_task_thread.update_date.connect(main_form.update_dotask)  # 更新待办理账户管理线程
+        do_task_thread.start()
+
+        doed_task_thread = mainform.UpdateDoedTask()
+        doed_task_thread.update_date.connect(main_form.update_doedtask)  # 更新已办理账户管理线程
+        doed_task_thread.start()
+
+        main_form.commandLinkButton_2.clicked.connect(lambda: main_form.login_off(filename))
+        main_form.commandLinkButton_3.clicked.connect(lambda: main_form.get_do_task())
+        main_form.commandLinkButton_4.clicked.connect(lambda: main_form.get_doed_task())
+        main_form.commandLinkButton_5.clicked.connect(lambda: main_form.start_task(tenant_id, tenant_type))
+    else:
+        logger.info("socket对象关闭")
+        open_msg(is_err[1])
+
+    sys.exit(app.exec_())

+import requests
+import time
+import oss2
+from common.log import *
+
+logger = BotLogger(os.path.basename(__file__), logname=1).getLogger()
+
+
+def handle_error(res, normal_status_code):
+    """
+    统一处理workai平台返回的error
+    :param res: 调用接口的返回
+    :param normal_status_code: 正常返回的status code
+    :return: 返回错误信息
+    """
+    if res is None or res.status_code == normal_status_code:
+        return ''
+
+    logger.info('The res is %s' % res)
+    err = '网络或服务器繁忙！'
+    try:
+        if 'message' in res.json():
+            err = res.json()['message']
+    except Exception as e:
+        logger.error(str(e))
+
+    return err
+
+
+def get_token_by_password(username, password, tenant_id, tenant_type):
+    """
+    密码方式获取access_token
+    :param username: 系统管理员用户
+    :param password: 系统管理员密码
+    :param tenant_id: 客户在workai云平台唯一表示
+    :return: 返回access_token, refresh_token 以及error, access_token用于访问接口的令牌, refresh_token
+    用于刷新获取新的access_token, error为返回的错误信息
+    """
+    data = {
+        'grant_type': 'password',
+        'username': username,
+        'password': password,
+        'scope': 'global_access:tenant_admin,tenant:%s,tenant_type:%s' % (tenant_id, tenant_type),
+    }
+
+    path = '%s/uaa/v1/auth/tokens' % WACLOUD_API_ENDPOINT
+    try:
+        res = requests.post(path, json=data, timeout=10)
+        err = handle_error(res, 200)
+        if err != '':
+            logger.error('Could not get the token by password for user: %s, tenant: %s' % (username, tenant_id))
+            return '', '', err, None
+
+        ret = res.json()
+        company, username, play_type = '', '', ''
+        if tenant_type == '0':
+            play_type = 'HRO'
+        elif tenant_type == '1':
+            play_type = 'HR'
+
+        try:
+            company = ret['tenant']['name']
+            username = ret['user']['name']
+        except Exception as e:
+            logger.error(str(e))
+
+        return ret['access_token'], ret['refresh_token'], '', (company, username, play_type)
+    except Exception as e:
+        logger.error(str(e))
+        return '', '', '网络或服务器异常，请稍后再试！', None
+
+
+def refresh_token(rtoken, tenant_id):
+    """
+    刷新token方式获取access_token
+    :return: 返回access_token, refresh_token 以及error, access_token用于访问接口的令牌, refresh_token
+    用于刷新获取新的access_token, error为返回的错误信息
+    """
+    data = {
+        'grant_type': 'refresh_token',
+        'refresh_token': rtoken,
+        'scope': 'global_access:tenant_admin,tenant:%s' % tenant_id,
+    }
+
+    path = '%s/uaa/v1/auth/tokens' % WACLOUD_API_ENDPOINT
+    res = requests.post(path, json=data)
+
+    err = handle_error(res, 200)
+    if err != '':
+        logger.error('Could not get the token by refresh token for tenant: %s' % (tenant_id,))
+        return '', '', err
+
+    ret = res.json()
+    return ret['access_token'], ret['refresh_token'], ''
+
+
+def upload_file(ctx, local_path, tenant_type, file_name):
+    """上传附件"""
+    object_path = ""
+    if ctx is None or local_path is None:
+        return 401, object_path
+
+    headers = {'Authorization': 'Bearer %s' % ctx['access_token']}
+    path = '%s/filemeta/v2/inits' % (WACLOUD_API_ENDPOINT,)
+    if tenant_type == "0":
+        data = {"object_type": "hro", "access_type": "sdk"}
+    elif tenant_type == "1":
+        data = {"object_type": "hr", "access_type": "sdk"}
+    else:
+        return 401, '配置文件设置tenant_type的值有误'
+
+    res = None
+    try:
+        res = requests.post(path, json=data, headers=headers, timeout=120)
+        if res.status_code == 401:
+            access_token, _refresh_token, err = refresh_token(ctx['refresh_token'], ctx['tenant_id'])
+            if err != '':
+                return 401, object_path
+            ctx['access_token'] = access_token
+            ctx['refresh_token'] = _refresh_token
+            headers = {'Authorization': 'Bearer %s' % ctx['access_token']}
+            res = requests.post(path, json=data, headers=headers, timeout=120)
+
+        err = handle_error(res, 200)
+        if err != '':
+            return res.status_code, object_path
+    except Exception as e:
+        logger.error(str(e))
+        return 401, str(e)
+
+    try:
+        datas = res.json()
+        # 使用临时token中的认证信息初始化StsAuth实例。
+        # auth = oss2.Auth(datas['access_key_id'], datas['access_key_secret'])
+        auth = oss2.StsAuth(datas['access_key_id'], datas['access_key_secret'], datas['security_token'])
+        # 使用StsAuth实例初始化存储空间。
+        bucket = oss2.Bucket(auth, datas['domain'], datas['bucket'])
+        object_path = datas['object_path'] + "/" + file_name
+        result = bucket.put_object_from_file(object_path, local_path)
+        return result.status, object_path
+    except Exception as e:
+        logger.error(str(e))
+        return 403, str(e)
+
+
+def update_object_path(ctx, tenant_type, object_path, types, file_name):
+    """上传文件路径到saas平台"""
+    if tenant_type == "0" or tenant_type == "1":
+        path = '%s/payroll/v1/do-import-data?type=%s' % (WACLOUD_API_ENDPOINT, types)
+    else:
+        return False, '平台类型设置有误'
+
+    headers = {'Authorization': 'Bearer %s' % ctx['access_token']}
+    bucket = '/hro/'
+    if 'hx' in WACLOUD_API_ENDPOINT:
+        bucket = '/hxhro/'
+    elif "xsb" in WACLOUD_API_ENDPOINT:
+        bucket = "/xsbhro/"
+    elif "engma" in WACLOUD_API_ENDPOINT:
+        bucket = "/engmahro/"
+    elif "anbo" in WACLOUD_API_ENDPOINT:
+        bucket = "/anbohro/"
+    elif "teda" in WACLOUD_API_ENDPOINT:
+        bucket = "/tedahro/"
+    elif "hwapi" in WACLOUD_API_ENDPOINT:
+        bucket = "/hro/"
+    elif "jincao" in WACLOUD_API_ENDPOINT:
+        bucket = "/jchro/"
+    elif 'jincao' in WACLOUD_API_ENDPOINT:
+        bucket = '/jchro/'
+    elif 'bhgn' in WACLOUD_API_ENDPOINT:
+        bucket = '/bhgnhro/'
+    elif 'gongyuanhr' in WACLOUD_API_ENDPOINT:
+        bucket = '/szgyhro/'
+
+
+    object_path = bucket + object_path
+    data = {
+        "object_path": object_path,
+        "file_name": file_name
+    }
+
+    try:
+        res = requests.post(path, json=data, headers=headers, timeout=120)
+        if res.status_code == 401:
+            time.sleep(2)
+            res = requests.post(path, json=data, headers=headers, timeout=120)
+
+        err = handle_error(res, 200)
+        if err != '':
+            logger.error("上传失败：{file}, 原因：{reason}".format(file=object_path, reason=err))
+            if 'Internal Server Error' in err:
+                err = '数据助手sheet附表内容错误'
+            return False, err
+        return True, '任务办理成功'
+    except Exception as e:
+        logger.error(str(e))
+        return False, '请求服务器异常：{}'.format(str(e))

+from configparser import *
+import os
+from common.log import *
+
+logger = BotLogger(os.path.basename(__file__)).getLogger()
+
+
+class Config(object):
+    """
+    controller配置项
+    """
+    def __init__(self, config_path=''):
+        self.config_path = config_path
+        if self.config_path != '':
+            self.__parse()
+
+    def __parse(self):
+        config_parser = ConfigParser()
+        config_parser.read(self.config_path)
+
+        self.db_path = 'taxbot.db'
+        self.server_name = '数据智能助手.exe'
+
+        try:
+            self.db_path = config_parser.get('data', 'path')
+            self.server_name = config_parser.get('data', 'server_name')
+        except (NoSectionError, NoOptionError) as e:
+            logger.debug('The config file does not include the data path: ' + str(e))
+
+        self.tenant_id = ''
+        self.tenant_type = '0'
+        try:
+            self.tenant_id = config_parser.get('hro', 'tenant_id')
+            self.tenant_type = config_parser.get('hro', 'tenant_type')
+        except (NoSectionError, NoOptionError) as e:
+            logger.error(str(e))
+        logger.info('db tenant_id is {tenant_id}'.format(tenant_id=self.tenant_id))
+        logger.info('db tenant_type is {tenant_type}'.format(tenant_type=self.tenant_type))
+
+        # self.ac_floder = ''
+        # try:
+        #     self.ac_floder = config_parser.get('ac_floder', 'path')
+        # except (NoSectionError, NoOptionError) as e:
+        #     logger.error(str(e))
+
+
+        self.delay = 600
+        self.mid_delay = 7200
+        try:
+            self.delay = config_parser.get('delay_time', 'delay')
+            self.mid_delay = config_parser.get('delay_time', 'mid_delay')
+        except (NoSectionError, NoOptionError) as e:
+            logger.error(str(e))
+        # logger.info('delay is: {delay}, mid_delay is: {mid_delay}'.format(delay=self.delay, mid_delay=self.mid_delay))
+
+
+cfg = Config()
+
+
+def configure(config_path):
+    global cfg
+    cfg = Config(config_path)
+    return cfg
+
+
+def get_cfg():
+    return cfg

+
+# WACLOUD_API_ENDPOINT = "https://api.workai.com.cn"
+# WACLOUD_API_ENDPOINT = "https://xsb.cnthr.com/bizapi"
+# WACLOUD_API_ENDPOINT = "http://api.engma.net"
+WACLOUD_API_ENDPOINT = "https://api.fjhxrl.com"
+# WACLOUD_API_ENDPOINT = "https://api.anbohro.com"
+# WACLOUD_API_ENDPOINT = "https://pay.tedahr.com/bizapi"
+# WACLOUD_API_ENDPOINT = "https://api.jincaohr.com"
+# WACLOUD_API_ENDPOINT = "https://api.jincaohr.com"
+# WACLOUD_API_ENDPOINT = "https://hwapi.workai.com.cn"
+# WACLOUD_API_ENDPOINT = "http://api.bhgnhr.com"
+# WACLOUD_API_ENDPOINT = "http://47.110.158.110:20000"
+# WACLOUD_API_ENDPOINT = "https://api.ghyc.com.cn"
+# WACLOUD_API_ENDPOINT = "https://api.gongyuanhr.com"
+
+
+# log name begin
+LOG_COMMON_NAME = 'common.log'  # 0
+LOG_SERVER_NAME = 'server.log'  # 1
+LOG_LOGIN_NAME = 'login.log'    # 2
+LOG_FLODER_NAME = 'floder.log'  # 3
+# log name end
+
+# status begin
+DB_STATUS_FAIL = 'fail'
+# status end
+
+STATUS_AVAIL = 'avail'
+STATUS_RUNNING = 'running'
+STATUS_FAIL = 'fail'
+STATUS_SUCCESS = 'success'
+
+# type begin
+TASK_TYPE_INSURANCE = "insurance"
+TASK_TYPE_SALARY = "salary"
+# type end
+
+# 根据上面的api 修改
+# VERSION = 'bhgnhr-V2.5'
+# VERSION = 'gongyuanhr-V2.5'
+# VERSION = 'workai-V2.5'
+VERSION = 'fjhxrl-V2.5'
+
+
+#  修改配置
+# taxbot.conf 中[hro]   tenant_id
+
+# 福建海峡人力资源股份有限公司 302972189366300672

+import os
+import sqlite3
+from common.constant import *
+from common.config import *
+from common.log import BotLogger
+
+logger = BotLogger(os.path.basename(__file__), logname=1).getLogger()
+
+
+class DBClass(object):
+    """数据库操作类"""
+    def __init__(self):
+        self.db_path = get_cfg().db_path
+        self.conn = None
+        self.cur = None
+
+    def get_conn(self):
+        """获取数据库操作对象"""
+        self.conn = sqlite3.connect(self.db_path)
+        if self.conn is None:
+            self.conn = sqlite3.connect(':memory:')
+
+        self.cur = self.conn.cursor()
+
+    def close_all(self):
+        """关闭数据库操作对象"""
+        if self.cur is not None:
+            self.cur.close()
+
+        if self.conn is not None:
+            self.conn.close()
+
+    def init_db(self):
+        account_table_sql = '''
+        CREATE TABLE IF NOT EXISTS account (
+        ac_account VARCHAR(30) UNIQUE ,
+        ac_passwd VARCHAR(50) NOT NULL,
+        ac_floder VARCHAR(300),
+        company VARCHAR(100),
+        username VARCHAR(20),
+        plat_type VARCHAR(10)
+        )
+        '''
+
+        task_table_sql = '''
+        CREATE TABLE IF NOT EXISTS task (
+        task_id VARCHAR(20) PRIMARY KEY,
+        filename VARCHAR(100) NOT NULL,
+        bus_type VARCHAR(10) NOT NULL,
+        plat_type VARCHAR(10) NOT NULL,
+        task_time VARCHAR(30) NOT NULL,
+        status VARCHAR(20),
+        comment VARCHAR(100)
+        )
+        '''
+
+        self.get_conn()
+        if self.conn is None or self.cur is None:
+            logger.error('初始化数据库失败')
+            return False
+        else:
+            self.cur.execute(account_table_sql)
+            self.cur.execute(task_table_sql)
+            logger.info('初始化数据库成功')
+            self.conn.commit()
+            self.close_all()
+            return True
+
+    def execute(self, sql, args=tuple()):
+        try:
+            self.get_conn()
+            if self.conn is None or self.cur is None:
+                logger.error('获取数据库操作对象失败')
+                return False
+            else:
+                try:
+                    self.cur.execute(sql, args)
+                    result = self.cur.fetchall()
+                    self.conn.commit()
+                    self.close_all()
+                    return result
+                except Exception as e:
+                    logger.error(str(e))
+                    return DB_STATUS_FAIL
+        except Exception as e:
+            logger.error(str(e))

+import logging
+import sys
+import os
+from common.constant import *
+
+
+class BotLogger(object):
+    def __init__(self, filename, logname=0, out=1):
+        """
+        获取日志处理对象
+        :param appName: 应用程序名
+        :param logFileName: 日志文件名
+        :param out: 设置输出端：0：默认控制台，1：输入文件，其他：控制台和文件都输出
+        :return: 返回日志对象
+        """
+        self.appName = filename.split('.')[0]
+        self.logFileName = os.getcwd() + "\\log\\"
+        if not os.path.exists(self.logFileName):
+            os.makedirs(self.logFileName)
+        if logname == 1:
+            self.logFileName += LOG_SERVER_NAME
+        elif logname == 2:
+            self.logFileName += LOG_LOGIN_NAME
+        elif logname == 3:
+            self.logFileName += LOG_FLODER_NAME
+        elif logname == 0:
+            self.logFileName += LOG_COMMON_NAME
+        self.out = out
+
+    def getLogger(self):
+        # 获取logging实例
+        logger = logging.getLogger(self.appName)
+        # 指定输出的格式
+        formatter = logging.Formatter('%(name)s  %(lineno)d  %(asctime)s  %(levelname)-8s:%(message)s')
+
+        # 文件日志
+        file_handler = logging.FileHandler(self.logFileName, encoding='utf-8')
+        file_handler.setFormatter(formatter)
+
+        # 控制台日志
+        console_handler = logging.StreamHandler(sys.stdout)
+        console_handler.setFormatter(formatter)
+
+        # # 指定日志的最低输出级别
+        logger.setLevel(logging.INFO)  # 20
+
+        # 为logger添加具体的日志处理器输出端
+        if self.out == 1:
+            logger.addHandler(file_handler)
+        elif self.out == 0:
+            logger.addHandler(console_handler)
+        else:
+            logger.addHandler(file_handler)
+            logger.addHandler(console_handler)
+        return logger
+
+
+
+

+import hashlib, requests, platform
+import uuid, os, time, sys
+import shutil, datetime
+import win32com.client
+from optparse import OptionParser
+from common import config
+from forms import msgform
+from common.api import *
+from common.log import BotLogger
+from common.dbutils import *
+from threading import Thread
+from queue import Queue
+import win32api, win32con
+from os import path
+import winshell
+import socket
+
+logger = BotLogger(os.path.basename(__file__), logname=1).getLogger()
+q = Queue()
+
+
+def open_msg(msg=''):
+    """打开自定义消息提示框"""
+    msg_form = msgform.Ui_MsgWindow()
+    msg_form.setupUi(msg)
+    msg_form.MsgWindow.show()
+
+    Thread(target=auto_form, args=(msg_form,), daemon=True).start()
+
+
+def auto_form(form):
+    time.sleep(5)
+    if form.MsgWindow.isVisible():
+        form.MsgWindow.close()
+
+
+def check_net_isactive():
+    """检查当前机器网络是否可用"""
+    url = 'https://hro.workai.com.cn/'
+    for i in range(3):
+        try:
+            res = requests.get(url)
+            if res.status_code == 200:
+                return True
+        except Exception as e:
+            logger.error("网络不可用：" + str(e))
+        time.sleep(1)
+
+    return False
+
+
+def hash_md5(attrs):
+    md5 = hashlib.md5()
+    md5.update(''.join(attrs).encode('utf-8'))
+    return md5.hexdigest()
+
+
+def hash_file(file_path):
+    try:
+        f = open(file_path)
+    except IOError:
+        return None
+    digest = hashlib.sha512()
+    while True:
+        chunk = f.read(2048)
+        if not chunk:
+            break
+        digest.update(chunk.encode('utf-8'))
+    f.close()
+    return digest.hexdigest()
+
+
+def get_datetime():
+    """返回固定格式的日期、时间格式"""
+    now = datetime.datetime.now()
+    now = now.strftime("%Y-%m-%d %H:%M:%S")
+    return now
+
+
+def get_timestamp():
+    """返回毫秒级时间戳"""
+    t = time.time()
+    now_stamp = int(round(t * 1000))
+    return now_stamp
+
+
+def check_procname_exist(procname):
+    """检查进程名是否存在"""
+    try:
+        wmi = win32com.client.GetObject('winmgmts:')
+        proc_code_cov = wmi.ExecQuery("select * from Win32_Process where Name='%s'" % procname)
+        if len(proc_code_cov) > 0:
+            logger.info('Check ProName: {} Exist'.format(procname))
+            return True
+        return False
+    except Exception as e:
+        logger.error(str(e))
+        return False
+
+
+def kill_procname(procname):
+    """杀掉已经启动的进程"""
+    if check_procname_exist(procname):
+        os.system('taskkill /F /IM ' + procname)
+
+
+def load_config():
+    """加载配置文件"""
+    try:
+        parser = OptionParser(prog='salary', usage="%prog [options]")
+
+        parser.add_option("-c", "--config_path", action="store", type="string", dest="config_path", help="配置文件路径")
+        (options, args) = parser.parse_args()
+
+        config_path = options.config_path
+        if not config_path:
+            config_path = os.getcwd() + '/taxbot.conf'
+        if not os.path.exists(config_path):
+            logger.error('The config file %s does not exist' % config_path)
+            return False
+        if not os.path.isfile(config_path):
+            logger.error('The config path %s is not a file' % config_path)
+            return False
+
+        try:
+            config.configure(config_path)
+        except Exception as e:
+            logger.error(str(e))
+            return False
+        return True
+    except Exception as e:
+        logger.error(str(e))
+        return False
+
+
+def login_check(tenant_id, tenant_type):
+    global q
+    Thread(target=__start_login_check, args=(tenant_id, tenant_type, q)).start()
+    result = q.get()
+    return result
+
+
+def __start_login_check(tenant_id, tenant_type, q):
+    result = DBClass().execute('SELECT * FROM account')
+    if result == DB_STATUS_FAIL:
+        q.put(-1)
+    elif not result:
+        q.put(0)
+    else:
+        if check_net_isactive():
+            # 调用登录接口，检查用户名密码的有效性
+            access_token, refresh_token, err, t_info = get_token_by_password(result[0][0], result[0][1], tenant_id, tenant_type)
+            if err != '':
+                logger.error("获取授权信息失败： " + err)
+                DBClass().execute("DELETE FROM account")
+                q.put(0)
+            else:
+                # 检工作目录文件夹是否存在
+                floder = result[0][2]
+                if floder or floder != '':
+                    if not os.path.exists(floder):
+                        logger.error("当前设置的目录不存在：" + floder)
+                        q.put(1)
+                    else:
+                        q.put(2)
+                else:
+                    q.put(1)
+        else:
+            q.put(-2)
+
+
+def order_task(file_list):
+    """排序列表中的文件名，社保优先、工资最后"""
+    ins_file_list, salary_file_list = [], []
+    for item in file_list:
+        if '社保' in item[1]:
+            ins_file_list.append(item)
+        elif '工资' in item[1]:
+            salary_file_list.append(item)
+    return ins_file_list, salary_file_list
+
+
+def check_is_file(work_path, files):
+    """检查是否是所需要的文件"""
+    sure_lst, err_lst = [], []
+    if not files:
+        return sure_lst
+    for file in files:
+        file_path = work_path + '/' + file
+        if os.path.isfile(file_path) and file.split('.')[-1] in ['xls', 'xlsx']:
+            if '~$' not in file:
+                sure_lst.append(file)
+            else:
+                err_lst.append(file)
+    return sure_lst, err_lst
+
+
+def clean_up_file(tenant_type, sure_lst, err_lst):
+    """清理并插入文件"""
+    for file in sure_lst:
+        if "~$" + file in err_lst:
+            logger.error("文件为打开状态无法上传：" + file)
+            insert_tasks([file], tenant_type, status=STATUS_FAIL, comment='文件为打开状态无法办理')
+        elif '社保' not in file and '工资' not in file:
+            insert_tasks([file], tenant_type, status=STATUS_FAIL, comment='文件名不识别')
+        elif '社保' in file and '工资' in file:
+            insert_tasks([file], tenant_type, status=STATUS_FAIL, comment='文件名不能同时包含社保和工资')
+        else:
+            insert_tasks([file], tenant_type, status=STATUS_AVAIL, comment='')
+    return list_do_task()
+
+
+def insert_tasks(file_list, tenant_type, status=STATUS_AVAIL, comment=''):
+    """把任务插入到数据库中"""
+    if not file_list:
+        return
+    for file in file_list:
+        task_id = str(get_timestamp())
+        bus_type = '社保' if '社保' in file else '工资'
+        plat_type = 'HR' if tenant_type == '1' else 'HRO'
+        task_time = get_datetime()
+        params = (task_id, file, bus_type, plat_type, task_time, status, comment)
+        DBClass().execute('INSERT INTO task VALUES(?, ?, ?, ?, ?, ?, ?)', params)
+        time.sleep(1)
+
+
+def move_del_file(work_path, file, types, task_id):
+    """移动和删除传成功的文件到已完成文件夹中"""
+    finished_floder = ""
+    data_floder = time.strftime("%Y%m%d", time.localtime())
+    if types == TASK_TYPE_INSURANCE:
+        finished_floder = work_path + "/" + "已完成（社保）"
+    elif types == TASK_TYPE_SALARY:
+        finished_floder = work_path + "/" + "已完成（工资）"
+    try:
+        if not os.path.exists(finished_floder):
+            os.mkdir(finished_floder)
+        finished_floder += "/" + data_floder
+        if not os.path.exists(finished_floder):
+            os.mkdir(finished_floder)
+    except Exception as e:
+        logger.error(str(e))
+        return
+
+    src = work_path + "/" + file
+    finish_src = finished_floder + "/" + file
+    if os.path.exists(finish_src):
+        try:
+            time_floder = time.strftime("%Y%m%d-%H%M%S", time.localtime())
+            lst = file.split(".")
+            new_file = ''.join(lst[:-1]) + "_" + time_floder + "." + lst[-1]
+            new_src = work_path + "/" + new_file
+            os.rename(src, new_src)
+            shutil.move(new_src, finished_floder)
+            DBClass().execute("UPDATE task SET filename = ? WHERE task_id = ?", (new_file, task_id))
+        except Exception as e:
+            logger.error(str(e))
+            return
+    else:
+        shutil.move(src, finished_floder)
+
+
+def batch_update_files(work_path, file_list, tenant_id, tenant_type):
+    """批量上传文件"""
+    ctx = {
+        "access_token": "",
+        "refresh_token": "",
+        "tenant_id": tenant_id
+    }
+    result = DBClass().execute('SELECT * FROM account')
+    if result == DB_STATUS_FAIL or not result:
+        return
+    access_token, refresh_tokens, err, t_info = get_token_by_password(result[0][0], result[0][1], tenant_id, tenant_type)
+    ctx['access_token'] = access_token
+    ctx['refresh_token'] = refresh_tokens
+    if err != "":
+        _access_token, _refresh_token, _err, t_info = refresh_token(ctx['refresh_token'], ctx['tenant_id'], tenant_type)
+        ctx['access_token'] = _access_token
+        ctx['refresh_token'] = _refresh_token
+        if _err != "":
+            return
+
+    for file in file_list:
+        if file[5] == STATUS_FAIL:
+            continue
+        update_task(file[0], STATUS_RUNNING, '')
+        local_path = work_path + "/" + file[1]
+        if "社保" in file[1]:
+            types = TASK_TYPE_INSURANCE
+        elif "工资" in file[1]:
+            types = TASK_TYPE_SALARY
+        else:
+            logger.error("文件名不识别：" + file[1])
+            update_task(file[0], STATUS_FAIL, '文件名不识别')
+            continue
+
+        try:
+            code, object_path = upload_file(ctx, local_path, tenant_type, file[1])
+            logger.info("上传结果：" + str(code) + ", 存储路径：" + object_path)
+            if code != 200:
+                update_task(file[0], STATUS_FAIL, '上传文件失败')
+                continue
+
+            status, reason = update_object_path(ctx, tenant_type, object_path, types, file[1])
+            if status:
+                logger.info("上传成功：" + file[1])
+                move_del_file(work_path, file[1], types, file[0])
+                update_task(file[0], STATUS_SUCCESS, reason)
+            else:
+                update_task(file[0], STATUS_FAIL, reason)
+        except Exception as e:
+            logger.error(str(e))
+            update_task(file[0], STATUS_FAIL, '网络或服务器异常')
+
+
+def update_task(task_id, status, comment=''):
+    """更新任务状态的函数"""
+    sql = "UPDATE task SET status = ?, comment = ? WHERE task_id = ?"
+    params = (status, comment, task_id)
+    DBClass().execute(sql, params)
+
+
+def reg_auto_start(path):
+    """设置开启自启动写入注册表"""
+    runpath = 'SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\Run'
+    # runpath = 'Software\\Microsoft\\Windows\\CurrentVersion\\Run'
+    hKey = win32api.RegOpenKeyEx(win32con.HKEY_LOCAL_MACHINE, runpath, 0, win32con.KEY_WRITE | win32con.KEY_WOW64_64KEY)
+    win32api.RegSetValueEx(hKey, 'taxbot', 0, win32con.REG_SZ, path)
+    win32api.RegCloseKey(hKey)
+
+
+def crease_shoutcut():
+    """创建自启动快捷方式到启动项"""
+    target = sys.argv[0]
+    title = '智能数据助手'
+    file = path.basename(target)
+    fname = path.splitext(file)[0]
+    root = path.dirname(target)
+    shout_path = path.join(winshell.startup(), fname + '.lnk')
+    if not os.path.exists(shout_path):
+        winshell.CreateShortcut(StartIn=root, Path=shout_path, Target=target,
+                                Icon=(target, 0), Description=title)
+
+
+def list_do_task():
+    """获取待办任务列表"""
+    try:
+        result = DBClass().execute('SELECT * FROM task WHERE status != ?  ORDER BY task_id ASC', (STATUS_SUCCESS, ))
+        if result == DB_STATUS_FAIL:
+            logger.error("读写数据库数据错误")
+            return None
+        return result
+    except sqlite3.Error as e:
+        logger.error('获取代办理任务数据失败: %s' % (str(e)))
+
+    return None
+
+
+def list_doed_task():
+    """获取已办任务列表数据"""
+    try:
+        result = DBClass().execute('SELECT * FROM task WHERE status = ? ORDER BY task_id DESC', (STATUS_SUCCESS, ))
+        if result == DB_STATUS_FAIL:
+            logger.error("读写数据库数据错误")
+            return None
+        return result
+    except sqlite3.Error as e:
+        logger.error('获取已办理任务数据错误: %s' % (str(e)))
+
+    return None
+
+
+def get_userinfo():
+    """获取登录用户信息函数"""
+    try:
+        result = DBClass().execute('SELECT * FROM account')
+        if result == DB_STATUS_FAIL:
+            logger.error("读写数据库数据错误")
+            return None
+        return result
+    except sqlite3.Error as e:
+        logger.error('获取用户信息错误 %s' % (str(e)))
+
+    return None
+
+
+def get_socket(HOST, PORT):
+    """给应用程序注册socket端口"""
+    try:
+        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        s.bind((HOST, PORT))
+        s.listen(2)
+        return s
+    except Exception as e:
+        logger.error(str(e))
+    return None
+
+
+def port_is_use(HOST, PORT):
+    """检查端口是否被占用"""
+    try:
+        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        s.connect((HOST, PORT))
+        s.shutdown(2)
+        logger.info('端口 %s 是被占用的' % str(PORT))
+        return True
+    except Exception as e:
+        logger.error(str(e))
+    return False
+
+
+def socket_listen(s):
+    while True:
+        connsd, addr = s.accept()
+        logger.info("连接对象：%s, 请求地址：%s" % (str(connsd), addr))
+        time.sleep(1)
+    s.close()
+    logger.info("socket对象关闭")
+
+
+def check_system():
+    """检查操作系统类型"""
+    try:
+        sys_str = platform.platform()
+        if not sys_str:
+            if 'Windows-7' in sys_str:
+                return 7
+            elif 'Windows-10' in sys_str:
+                return 10
+    except Exception as e:
+        logger.error(str(e))
+
+    return 10

+# -*- coding: utf-8 -*-
+import os
+import win32com.client
+from PyQt5 import QtCore, QtGui, QtWidgets
+from PyQt5.QtWidgets import QMainWindow, QMessageBox, QFileDialog
+from PyQt5.QtCore import Qt
+from common.dbutils import *
+from common.constant import *
+from qrc import icon
+
+
+class Ui_FloderWindow(object):
+    def __init__(self, main_form):
+        self.FloderWindow = QMainWindow()
+        self.font = QtGui.QFont()
+        self.font.setFamily("微软雅黑")
+        self.font.setPointSize(9)
+        self.main_form = main_form
+
+    def setupUi(self):
+        self.FloderWindow.setObjectName("FloderWindow")
+        self.FloderWindow.setFixedSize(340, 150)
+        self.FloderWindow.setWindowFlags(Qt.WindowStaysOnTopHint)
+        self.FloderWindow.setWindowFlags(Qt.WindowMinimizeButtonHint)
+
+        icon = QtGui.QIcon()
+        icon.addPixmap(QtGui.QPixmap(":/icon/imgs/logo.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.FloderWindow.setWindowIcon(icon)
+        self.centralwidget = QtWidgets.QWidget(self.FloderWindow)
+        self.centralwidget.setObjectName("centralwidget")
+        self.lineEdit = QtWidgets.QLineEdit(self.centralwidget)
+        self.lineEdit.setGeometry(QtCore.QRect(30, 30, 220, 26))
+        self.lineEdit.setFont(self.font)
+        self.lineEdit.setReadOnly(True)
+
+        self.pushButton = QtWidgets.QPushButton(self.centralwidget)
+        self.pushButton.setGeometry(QtCore.QRect(260, 30, 50, 26))
+        self.pushButton.setFont(self.font)
+        self.pushButton_2 = QtWidgets.QPushButton(self.centralwidget)
+        self.pushButton_2.setGeometry(QtCore.QRect(197, 90, 75, 26))
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.pushButton_2.sizePolicy().hasHeightForWidth())
+        self.pushButton_2.setSizePolicy(sizePolicy)
+        self.pushButton_2.setFont(self.font)
+
+        self.pushButton_3 = QtWidgets.QPushButton(self.centralwidget)
+        self.pushButton_3.setGeometry(QtCore.QRect(60, 90, 75, 26))
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.pushButton_3.sizePolicy().hasHeightForWidth())
+        self.pushButton_3.setSizePolicy(sizePolicy)
+        self.pushButton_3.setFont(self.font)
+        self.FloderWindow.setCentralWidget(self.centralwidget)
+
+        self.retranslateUi(self.FloderWindow)
+        self.__init_click()
+
+        QtCore.QMetaObject.connectSlotsByName(self.FloderWindow)
+
+    def retranslateUi(self, MainWindow):
+        _translate = QtCore.QCoreApplication.translate
+        MainWindow.setWindowTitle(_translate("FloderWindow", "选择工作目录"))
+        self.lineEdit.setPlaceholderText(_translate("FloderWindow", "选择工作目录文件夹"))
+        self.pushButton.setText(_translate("FloderWindow", "选择"))
+        self.pushButton_2.setText(_translate("FloderWindow", "保存"))
+        self.pushButton_3.setText(_translate("FloderWindow", "取消"))
+
+    def __init_click(self):
+        self.pushButton.clicked.connect(self.__select)
+        self.pushButton_2.setShortcut('return')
+        self.pushButton_3.clicked.connect(self.__exit)
+        self.pushButton_3.setShortcut('Esc')
+        self.pushButton_2.clicked.connect(self.save)
+
+    def __select(self):
+        """选择工作目录文件夹"""
+        path = os.getcwd()
+        try:
+            path = QFileDialog.getExistingDirectory(parent=self.FloderWindow, caption='选择工作目录', directory=os.getcwd())
+        except Exception as e:
+            print(str(e))
+
+        self.lineEdit.setText(path)
+
+    def __exit(self):
+        """退出启动窗口事件"""
+        result = QMessageBox.question(self.FloderWindow, '提示', '确定要取消选择工作目录吗？', QMessageBox.Yes | QMessageBox.No)
+        if result == 16384:
+            self.FloderWindow.close()
+            return True
+        return False
+
+    def save(self):
+        path = self.lineEdit.text()
+        if not path:
+            QMessageBox.warning(self.FloderWindow, '消息', '请选择工作目录！')
+            return
+
+        result = DBClass().execute('UPDATE account SET ac_floder = ?', (path, ))
+        if result == DB_STATUS_FAIL:
+            QMessageBox.warning(self.FloderWindow, '消息', '保存工作目录失败！')
+        else:
+            self.FloderWindow.close()
+            self.main_form.mainform_show()

+# -*- coding: utf-8 -*-
+import re
+import time
+from PyQt5 import QtCore, QtGui, QtWidgets
+from PyQt5.QtWidgets import QMainWindow, QMessageBox
+from PyQt5.QtCore import Qt
+from common.dbutils import *
+from common.constant import *
+from common.api import *
+from threading import Thread
+from queue import Queue
+from qrc import icon
+
+q_login = Queue()
+
+
+class Ui_LoginWindow(object):
+    def __init__(self):
+        self.LoginWindow = QMainWindow()
+        self.font = QtGui.QFont()
+        self.font.setFamily("微软雅黑")
+        self.font.setPointSize(10)
+        self.centralwidget = QtWidgets.QWidget(self.LoginWindow)
+        self._translate = QtCore.QCoreApplication.translate
+
+    def __init_window_ui(self):
+        """初始化窗口框架"""
+        self.LoginWindow.setObjectName("LoginWindow")
+        self.LoginWindow.setFixedSize(320, 200)
+        self.LoginWindow.setWindowFlags(Qt.WindowStaysOnTopHint)
+        self.LoginWindow.setWindowFlags(Qt.WindowMinimizeButtonHint)
+        # self.LoginWindow.setWindowFlags(Qt.FramelessWindowHint)
+        icon = QtGui.QIcon()
+        icon.addPixmap(QtGui.QPixmap(":/icon/imgs/logo.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.LoginWindow.setWindowIcon(icon)
+        self.LoginWindow.setWindowTitle(self._translate("LoginWindow", "智能数据助手"))
+
+    def __init_ui(self):
+        """初始化标签界面"""
+        self.layoutWidget = QtWidgets.QWidget(self.centralwidget)
+        self.layoutWidget.setGeometry(QtCore.QRect(40, 25, 241, 151))
+        self.layoutWidget.setObjectName("layoutWidget")
+        # self.layoutWidget.setStyleSheet("background-image: url(:/icon/imgs/bg.png);")
+        self.gridLayout = QtWidgets.QGridLayout(self.layoutWidget)
+        self.gridLayout.setSpacing(5)
+
+        self.horizontalLayout = QtWidgets.QHBoxLayout()
+        self.label = QtWidgets.QLabel(self.layoutWidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Preferred)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.label.sizePolicy().hasHeightForWidth())
+        self.label.setSizePolicy(sizePolicy)
+        self.label.setFont(self.font)
+        self.label.setText(self._translate("LoginWindow", "账号： "))
+        self.horizontalLayout.addWidget(self.label)
+
+        self.lineEdit = QtWidgets.QLineEdit(self.layoutWidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Preferred, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.lineEdit.sizePolicy().hasHeightForWidth())
+        self.lineEdit.setSizePolicy(sizePolicy)
+        self.lineEdit.setMinimumSize(QtCore.QSize(0, 25))
+        self.font.setPointSize(9)
+        self.lineEdit.setFont(self.font)
+        self.lineEdit.setMaxLength(11)
+        self.lineEdit.setPlaceholderText(self._translate("LoginWindow", "请输入手机号"))
+        self.lineEdit.setClearButtonEnabled(True)
+        self.horizontalLayout.addWidget(self.lineEdit)
+        self.gridLayout.addLayout(self.horizontalLayout, 0, 0, 1, 1)
+
+        self.horizontalLayout_2 = QtWidgets.QHBoxLayout()
+        self.label_2 = QtWidgets.QLabel(self.layoutWidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Preferred)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.label_2.sizePolicy().hasHeightForWidth())
+        self.label_2.setSizePolicy(sizePolicy)
+        self.font.setPointSize(10)
+        self.label_2.setFont(self.font)
+        self.label_2.setText(self._translate("LoginWindow", "密码： "))
+        self.horizontalLayout_2.addWidget(self.label_2)
+
+        self.lineEdit_2 = QtWidgets.QLineEdit(self.layoutWidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Preferred, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.lineEdit_2.sizePolicy().hasHeightForWidth())
+        self.lineEdit_2.setSizePolicy(sizePolicy)
+        self.lineEdit_2.setMinimumSize(QtCore.QSize(0, 25))
+        self.font.setPointSize(9)
+        self.lineEdit_2.setFont(self.font)
+        self.lineEdit_2.setPlaceholderText(self._translate("LoginWindow", "请输入密码"))
+        self.lineEdit_2.setEchoMode(QtWidgets.QLineEdit.Password)
+        self.lineEdit_2.setMaxLength(16)
+        self.lineEdit_2.setClearButtonEnabled(True)
+        self.horizontalLayout_2.addWidget(self.lineEdit_2)
+        self.gridLayout.addLayout(self.horizontalLayout_2, 1, 0, 1, 1)
+
+        self.horizontalLayout_3 = QtWidgets.QHBoxLayout()
+        self.horizontalLayout_3.setContentsMargins(-1, 10, -1, -1)
+        self.horizontalLayout_3.setSpacing(50)
+        self.pushButton = QtWidgets.QPushButton(self.layoutWidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.pushButton.sizePolicy().hasHeightForWidth())
+        self.pushButton.setSizePolicy(sizePolicy)
+        self.font.setPointSize(9)
+        self.pushButton.setFont(self.font)
+        self.pushButton.setText(self._translate("LoginWindow", "取消"))
+        self.horizontalLayout_3.addWidget(self.pushButton)
+
+        self.pushButton_2 = QtWidgets.QPushButton(self.layoutWidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.pushButton_2.sizePolicy().hasHeightForWidth())
+        self.pushButton_2.setSizePolicy(sizePolicy)
+        self.pushButton_2.setFont(self.font)
+        self.pushButton_2.setText(self._translate("LoginWindow", "登录"))
+        self.horizontalLayout_3.addWidget(self.pushButton_2)
+        self.gridLayout.addLayout(self.horizontalLayout_3, 2, 0, 1, 1)
+
+        # self.pushButton_3 = QtWidgets.QPushButton(self.centralwidget)
+        # self.pushButton_3.setGeometry(QtCore.QRect(280, 0, 36, 23))
+        # self.pushButton_3.setMinimumSize(QtCore.QSize(20, 20))
+        # self.pushButton_3.setText("")
+        # icon = QtGui.QIcon()
+        # icon.addPixmap(QtGui.QPixmap(":/icon/imgs/close.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        # self.pushButton_3.setIcon(icon)
+        # self.pushButton_3.setIconSize(QtCore.QSize(12, 12))
+        #
+        # self.pushButton_4 = QtWidgets.QPushButton(self.centralwidget)
+        # self.pushButton_4.setGeometry(QtCore.QRect(240, 0, 36, 23))
+        # self.pushButton_4.setMinimumSize(QtCore.QSize(20, 20))
+        # self.pushButton_4.setText("")
+        # icon1 = QtGui.QIcon()
+        # icon1.addPixmap(QtGui.QPixmap(":/icon/imgs/min.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        # self.pushButton_4.setIcon(icon1)
+        # self.pushButton_4.setIconSize(QtCore.QSize(14, 14))
+
+    def __init_click(self):
+        self.pushButton.clicked.connect(self.__exit)
+        self.pushButton.setShortcut('Esc')
+        self.pushButton_2.setShortcut('return')
+        # self.pushButton_3.clicked.connect(self.__exit)
+        # self.pushButton_4.clicked.connect(self.__min)
+
+    def __exit(self):
+        """退出启动窗口事件"""
+        result = QMessageBox.question(self.LoginWindow, '提示', '确定要退出系统吗？', QMessageBox.Yes | QMessageBox.No)
+        if result == 16384:
+            self.LoginWindow.close()
+            return True
+        return False
+
+    def login(self, floder_form, tenant_id, tenant_type):
+        account = self.lineEdit.text()
+        passwd = self.lineEdit_2.text()
+        if not account or len(account) != 11:
+            QMessageBox.warning(self.LoginWindow, '消息', '账号长度必须为11位手机号。')
+        elif not re.findall('^\d{11}$', account):
+            QMessageBox.warning(self.LoginWindow, '消息', '输入的手机号不正确。')
+        elif not re.findall('^1[356789]\d{9}$', account):
+            QMessageBox.warning(self.LoginWindow, '消息', '手机号输入有误')
+        elif not passwd or len(passwd) < 6:
+            QMessageBox.warning(self.LoginWindow, '消息', '密码长度不能小于6位。')
+        else:
+            global q_login
+            Thread(target=self.__start_login, args=(account, passwd, tenant_id, tenant_type, q_login)).start()
+            code, err = q_login.get()
+
+            if code in [404, 1010, 500, 400]:
+                QMessageBox.warning(self.LoginWindow, '消息', err)
+
+            if code == 200:
+                self.LoginWindow.close()
+                floder_form.FloderWindow.show()
+
+    def __start_login(self, account, passwd, tenant_id, tenant_type, q):
+        """处理登录接口处理函数"""
+        try:
+            access_token, refresh_token, err, t_info = get_token_by_password(account, passwd, tenant_id, tenant_type)
+            if err != '':
+                logger.error("登录失败： " + err)
+                t = (404, err)
+                q.put(t)
+            else:
+                company = t_info[0]
+                username = t_info[1]
+                play_typt = t_info[2]
+                result = DBClass().execute('INSERT INTO account VALUES(?, ?, ?, ?, ?, ?)', (account, passwd, '', company, username, play_typt))
+                if result == DB_STATUS_FAIL:
+                    logger.error("读写数据库数据错误")
+                    t = (1010, '保存登录信息失败，请稍后再试！')
+                    q.put(t)
+                else:
+                    logger.error("登录成功")
+                    t = (200, '登录成功！')
+                    q.put(t)
+        except Exception as e:
+            logger.error(str(e))
+            t = (500, '网络或服务器异常，请稍后再试！')
+            q.put(t)
+
+    def __min(self):
+        """窗口最小化到托盘"""
+        self.LoginWindow.showMinimized()
+
+    def setupUi(self):
+        self.__init_window_ui()
+        self.__init_ui()
+        self.__init_click()
+
+        self.LoginWindow.setCentralWidget(self.centralwidget)
+        QtCore.QMetaObject.connectSlotsByName(self.LoginWindow)
+
+
+
+
+
+
+

+# -*- coding: utf-8 -*-
+import re
+import time
+import queue
+import json
+from PyQt5 import QtCore, QtGui, QtWidgets
+from PyQt5.QtGui import QBrush, QColor
+from PyQt5.QtWidgets import *
+from PyQt5.QtCore import *
+from common.utils import *
+from threading import Thread
+from qrc import icon
+
+q_do_task = queue.Queue()
+q_doed_task = queue.Queue()
+q_start = queue.Queue()
+q_task = queue.Queue()
+
+q_floder = queue.Queue()  # 是否工作目录有效
+q_files = queue.Queue()   # 是否有可办理得任务表格
+
+
+class UpdateDoTask(QThread):
+    update_date = pyqtSignal(str)
+
+    def run(self):
+        while True:
+            if q_do_task.get():
+                tasks = list_do_task()
+                if not tasks or len(tasks) == 0:
+                    data1 = {}
+                    self.update_date.emit(json.dumps(data1))  # 发射信号
+                else:
+                    row = 0
+                    for task in tasks:
+                        data = {'cnt': len(tasks), 'row': row, 'task_id': task[0], 'filename': task[1],
+                                'bus_type': task[2], 'plat_type': task[3], 'task_time': task[4], 'comment': task[6]}
+                        if task[5] == STATUS_AVAIL or task[5] == '':
+                            data['status'] = '等待办理'
+                        elif task[5] == STATUS_RUNNING:
+                            data['status'] = '正在办理'
+                        elif task[5] == STATUS_SUCCESS:
+                            data['status'] = '办理成功'
+                        elif task[5] == STATUS_FAIL:
+                            data['status'] = '办理失败'
+                        self.update_date.emit(json.dumps(data))  # 发射信号
+                        row += 1
+            time.sleep(1)
+
+
+class UpdateDoedTask(QThread):
+    update_date = pyqtSignal(str)
+
+    def run(self):
+        while True:
+            if q_doed_task.get():
+                tasks = list_doed_task()
+                if not tasks or len(tasks) == 0:
+                    data1 = {}
+                    self.update_date.emit(json.dumps(data1))  # 发射信号
+                else:
+                    row = 0
+                    for task in tasks:
+                        data = {'cnt': len(tasks), 'row': row, 'task_id': task[0], 'filename': task[1],
+                                'bus_type': task[2], 'plat_type': task[3], 'task_time': task[4], 'comment': task[6]}
+                        if task[5] == STATUS_AVAIL or task[5] == '':
+                            data['status'] = '等待办理'
+                        elif task[5] == STATUS_RUNNING:
+                            data['status'] = '正在办理'
+                        elif task[5] == STATUS_SUCCESS:
+                            data['status'] = '办理成功'
+                        elif task[5] == STATUS_FAIL:
+                            data['status'] = '办理失败'
+                        self.update_date.emit(json.dumps(data))  # 发射信号
+                        row += 1
+            time.sleep(1)
+
+
+class myLable(QLabel):
+    def __init__(self, parent=None):
+        super(myLable, self).__init__(parent)
+
+    def mousePressEvent(self, QMouseEvent):
+        self.setStyleSheet("color: rgb(255, 0, 0);")
+
+    def mouseReleaseEvent(self, QMouseEvent):
+        self.setStyleSheet("color: rgb(85, 0, 255);")
+
+
+class Ui_MainWindow(object):
+    def __init__(self):
+        self.MainWindow = QMainWindow()
+        self.MainWindow.setWindowFlags(Qt.WindowStaysOnTopHint)
+        # self.MainWindow.setWindowFlags(Qt.WindowMinMaxButtonsHint)
+        self._translate = QtCore.QCoreApplication.translate
+        self.cur_btn = None
+        self.work_path = ''
+        self.is_refresh = False
+        self.sure_lst = []
+        self.err_lst = []
+        self.sys_type = check_system()
+        self.MainObjectName = 'MainWindow'
+
+    def setupUi(self):
+        self.MainWindow.setObjectName("MainWindow")
+        self.MainWindow.resize(950, 600)
+        self.MainWindow.setMinimumSize(QtCore.QSize(900, 600))
+        icon = QtGui.QIcon()
+        icon.addPixmap(QtGui.QPixmap(":/icon/imgs/logo.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.MainWindow.setWindowIcon(icon)
+        self.MainWindow.setAutoFillBackground(False)
+        self.MainWindow.setStyleSheet("")
+        self.centralwidget = QtWidgets.QWidget(self.MainWindow)
+        self.centralwidget.setObjectName("centralwidget")
+        self.verticalLayout_2 = QtWidgets.QVBoxLayout(self.centralwidget)
+        self.verticalLayout_2.setContentsMargins(10, 0, 10, 0)
+        self.verticalLayout_2.setSpacing(0)
+        self.verticalLayout_2.setObjectName("verticalLayout_2")
+        self.horizontalLayout_2 = QtWidgets.QHBoxLayout()
+        self.horizontalLayout_2.setSpacing(0)
+        self.horizontalLayout_2.setObjectName("horizontalLayout_2")
+        self.frame = QtWidgets.QFrame(self.centralwidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.frame.sizePolicy().hasHeightForWidth())
+        self.frame.setSizePolicy(sizePolicy)
+        self.frame.setMinimumSize(QtCore.QSize(0, 60))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.frame.setFont(font)
+        self.frame.setFrameShape(QtWidgets.QFrame.StyledPanel)
+        self.frame.setFrameShadow(QtWidgets.QFrame.Raised)
+        self.frame.setObjectName("frame")
+        self.horizontalLayout = QtWidgets.QHBoxLayout(self.frame)
+        self.horizontalLayout.setContentsMargins(0, 0, 0, 8)
+        self.horizontalLayout.setSpacing(0)
+        self.horizontalLayout.setObjectName("horizontalLayout")
+        self.verticalLayout = QtWidgets.QVBoxLayout()
+        self.verticalLayout.setSpacing(0)
+        self.verticalLayout.setObjectName("verticalLayout")
+        self.label = myLable(self.frame)
+        # self.label = QtWidgets.QLabel(self.frame)
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(16)
+        font.setBold(True)
+        font.setWeight(75)
+        self.label.setFont(font)
+        self.label.setStyleSheet("color: rgb(85, 0, 255);")
+        self.label.setAlignment(QtCore.Qt.AlignLeading|QtCore.Qt.AlignLeft|QtCore.Qt.AlignVCenter)
+        self.label.setObjectName("label")
+        self.verticalLayout.addWidget(self.label)
+        self.label_2 = QtWidgets.QLabel(self.frame)
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(10)
+        font.setBold(False)
+        font.setWeight(50)
+        self.label_2.setFont(font)
+        self.label_2.setStyleSheet("")
+        self.label_2.setAlignment(QtCore.Qt.AlignLeading|QtCore.Qt.AlignLeft|QtCore.Qt.AlignVCenter)
+        self.label_2.setObjectName("label_2")
+        self.verticalLayout.addWidget(self.label_2)
+        self.verticalLayout.setStretch(0, 2)
+        self.horizontalLayout.addLayout(self.verticalLayout)
+        self.horizontalLayout_2.addWidget(self.frame)
+        self.frame_2 = QtWidgets.QFrame(self.centralwidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.frame_2.sizePolicy().hasHeightForWidth())
+        self.frame_2.setSizePolicy(sizePolicy)
+        self.frame_2.setMinimumSize(QtCore.QSize(0, 60))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.frame_2.setFont(font)
+        self.frame_2.setLayoutDirection(QtCore.Qt.LeftToRight)
+        self.frame_2.setFrameShape(QtWidgets.QFrame.StyledPanel)
+        self.frame_2.setFrameShadow(QtWidgets.QFrame.Raised)
+        self.frame_2.setObjectName("frame_2")
+        self.horizontalLayout_3 = QtWidgets.QHBoxLayout(self.frame_2)
+        if self.sys_type == 10:
+            self.horizontalLayout_3.setContentsMargins(0, 10, 50, 10)
+            self.horizontalLayout_3.setSpacing(50)
+        else:
+            self.horizontalLayout_3.setContentsMargins(0, 10, 10, 10)
+            self.horizontalLayout_3.setSpacing(20)
+        self.horizontalLayout_3.setObjectName("horizontalLayout_3")
+        self.label_3 = QtWidgets.QLabel(self.frame_2)
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.label_3.setFont(font)
+        self.label_3.setText("")
+        self.label_3.setObjectName("label_3")
+        self.horizontalLayout_3.addWidget(self.label_3)
+        self.commandLinkButton_2 = QtWidgets.QCommandLinkButton(self.frame_2)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Expanding)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.commandLinkButton_2.sizePolicy().hasHeightForWidth())
+        self.commandLinkButton_2.setSizePolicy(sizePolicy)
+        self.commandLinkButton_2.setMinimumSize(QtCore.QSize(80, 40))
+        self.commandLinkButton_2.setMaximumSize(QtCore.QSize(80, 40))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.commandLinkButton_2.setFont(font)
+        self.commandLinkButton_2.setLayoutDirection(QtCore.Qt.LeftToRight)
+        icon1 = QtGui.QIcon()
+        icon1.addPixmap(QtGui.QPixmap(":/icon/imgs/login_off.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.commandLinkButton_2.setIcon(icon1)
+        self.commandLinkButton_2.setAutoRepeatDelay(30)
+        self.commandLinkButton_2.setAutoRepeatInterval(10)
+        self.commandLinkButton_2.setObjectName("commandLinkButton_2")
+        self.horizontalLayout_3.addWidget(self.commandLinkButton_2)
+        self.commandLinkButton = QtWidgets.QCommandLinkButton(self.frame_2)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Expanding)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.commandLinkButton.sizePolicy().hasHeightForWidth())
+        self.commandLinkButton.setSizePolicy(sizePolicy)
+        self.commandLinkButton.setMinimumSize(QtCore.QSize(80, 40))
+        self.commandLinkButton.setMaximumSize(QtCore.QSize(80, 40))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.commandLinkButton.setFont(font)
+        self.commandLinkButton.setLayoutDirection(QtCore.Qt.LeftToRight)
+        icon2 = QtGui.QIcon()
+        icon2.addPixmap(QtGui.QPixmap(":/icon/imgs/login_out.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.commandLinkButton.setIcon(icon2)
+        self.commandLinkButton.setAutoRepeatDelay(30)
+        self.commandLinkButton.setAutoRepeatInterval(10)
+        self.commandLinkButton.setObjectName("commandLinkButton")
+        self.horizontalLayout_3.addWidget(self.commandLinkButton)
+        self.commandLinkButton.raise_()
+        self.commandLinkButton_2.raise_()
+        self.label_3.raise_()
+        self.horizontalLayout_2.addWidget(self.frame_2)
+        self.verticalLayout_2.addLayout(self.horizontalLayout_2)
+        self.line = QtWidgets.QFrame(self.centralwidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.line.sizePolicy().hasHeightForWidth())
+        self.line.setSizePolicy(sizePolicy)
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.line.setFont(font)
+        self.line.setFrameShape(QtWidgets.QFrame.HLine)
+        self.line.setFrameShadow(QtWidgets.QFrame.Sunken)
+        self.line.setObjectName("line")
+        self.verticalLayout_2.addWidget(self.line)
+        self.frame_4 = QtWidgets.QFrame(self.centralwidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.frame_4.sizePolicy().hasHeightForWidth())
+        self.frame_4.setSizePolicy(sizePolicy)
+        self.frame_4.setMinimumSize(QtCore.QSize(0, 60))
+        self.frame_4.setMaximumSize(QtCore.QSize(16777215, 60))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.frame_4.setFont(font)
+        self.frame_4.setFrameShape(QtWidgets.QFrame.StyledPanel)
+        self.frame_4.setFrameShadow(QtWidgets.QFrame.Raised)
+        self.frame_4.setObjectName("frame_4")
+        self.horizontalLayout_5 = QtWidgets.QHBoxLayout(self.frame_4)
+        if self.sys_type == 10:
+            self.horizontalLayout_5.setContentsMargins(50, 0, 50, 0)
+            self.horizontalLayout_5.setSpacing(50)
+        else:
+            self.horizontalLayout_5.setContentsMargins(10, 0, 10, 0)
+            self.horizontalLayout_5.setSpacing(20)
+        self.horizontalLayout_5.setObjectName("horizontalLayout_5")
+        self.commandLinkButton_3 = QtWidgets.QCommandLinkButton(self.frame_4)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.commandLinkButton_3.sizePolicy().hasHeightForWidth())
+        self.commandLinkButton_3.setSizePolicy(sizePolicy)
+        self.commandLinkButton_3.setMinimumSize(QtCore.QSize(110, 40))
+        self.commandLinkButton_3.setMaximumSize(QtCore.QSize(110, 40))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.commandLinkButton_3.setFont(font)
+        icon3 = QtGui.QIcon()
+        icon3.addPixmap(QtGui.QPixmap(":/icon/imgs/do_task.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.commandLinkButton_3.setIcon(icon3)
+        self.commandLinkButton_3.setIconSize(QtCore.QSize(20, 20))
+        self.commandLinkButton_3.setAutoRepeatDelay(30)
+        self.commandLinkButton_3.setAutoRepeatInterval(10)
+        self.commandLinkButton_3.setObjectName("commandLinkButton_3")
+        self.horizontalLayout_5.addWidget(self.commandLinkButton_3)
+        self.commandLinkButton_4 = QtWidgets.QCommandLinkButton(self.frame_4)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.commandLinkButton_4.sizePolicy().hasHeightForWidth())
+        self.commandLinkButton_4.setSizePolicy(sizePolicy)
+        self.commandLinkButton_4.setMinimumSize(QtCore.QSize(110, 40))
+        self.commandLinkButton_4.setMaximumSize(QtCore.QSize(110, 40))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.commandLinkButton_4.setFont(font)
+        icon4 = QtGui.QIcon()
+        icon4.addPixmap(QtGui.QPixmap(":/icon/imgs/doed_task.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.commandLinkButton_4.setIcon(icon4)
+        self.commandLinkButton_4.setIconSize(QtCore.QSize(22, 20))
+        self.commandLinkButton_4.setAutoRepeatDelay(30)
+        self.commandLinkButton_4.setAutoRepeatInterval(10)
+        self.commandLinkButton_4.setObjectName("commandLinkButton_4")
+        self.horizontalLayout_5.addWidget(self.commandLinkButton_4)
+        self.label_6 = QtWidgets.QLabel(self.frame_4)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.label_6.sizePolicy().hasHeightForWidth())
+        self.label_6.setSizePolicy(sizePolicy)
+        self.label_6.setMinimumSize(QtCore.QSize(0, 40))
+        self.label_6.setMaximumSize(QtCore.QSize(16777215, 40))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(14)
+        font.setBold(True)
+        font.setWeight(75)
+        self.label_6.setFont(font)
+        self.label_6.setStyleSheet("color: rgb(85, 170, 0);")
+        self.label_6.setAlignment(QtCore.Qt.AlignCenter)
+        self.label_6.setObjectName("label_6")
+        self.horizontalLayout_5.addWidget(self.label_6)
+        self.commandLinkButton_5 = QtWidgets.QCommandLinkButton(self.frame_4)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.commandLinkButton_5.sizePolicy().hasHeightForWidth())
+        self.commandLinkButton_5.setSizePolicy(sizePolicy)
+        self.commandLinkButton_5.setMinimumSize(QtCore.QSize(110, 40))
+        self.commandLinkButton_5.setMaximumSize(QtCore.QSize(110, 40))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.commandLinkButton_5.setFont(font)
+        icon5 = QtGui.QIcon()
+        icon5.addPixmap(QtGui.QPixmap(":/icon/imgs/start.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.commandLinkButton_5.setIcon(icon5)
+        self.commandLinkButton_5.setAutoRepeatDelay(30)
+        self.commandLinkButton_5.setAutoRepeatInterval(10)
+        self.commandLinkButton_5.setObjectName("commandLinkButton_5")
+        self.horizontalLayout_5.addWidget(self.commandLinkButton_5)
+        self.verticalLayout_2.addWidget(self.frame_4)
+        self.tableWidget = QtWidgets.QTableWidget(self.centralwidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Expanding)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.tableWidget.sizePolicy().hasHeightForWidth())
+        self.tableWidget.setSizePolicy(sizePolicy)
+        font = QtGui.QFont()
+        font.setFamily("微软雅黑")
+        font.setPointSize(11)
+        self.tableWidget.setFont(font)
+        self.tableWidget.setObjectName("tableWidget")
+        self.tableWidget.setColumnCount(0)
+        self.tableWidget.setRowCount(0)
+        self.verticalLayout_2.addWidget(self.tableWidget)
+        self.frame_3 = QtWidgets.QFrame(self.centralwidget)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Fixed)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.frame_3.sizePolicy().hasHeightForWidth())
+        self.frame_3.setSizePolicy(sizePolicy)
+        self.frame_3.setMinimumSize(QtCore.QSize(0, 35))
+        self.frame_3.setMaximumSize(QtCore.QSize(16777215, 35))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(11)
+        self.frame_3.setFont(font)
+        self.frame_3.setFrameShape(QtWidgets.QFrame.StyledPanel)
+        self.frame_3.setFrameShadow(QtWidgets.QFrame.Raised)
+        self.frame_3.setObjectName("frame_3")
+        self.horizontalLayout_4 = QtWidgets.QHBoxLayout(self.frame_3)
+        self.horizontalLayout_4.setContentsMargins(10, 0, 0, 0)
+        self.horizontalLayout_4.setSpacing(2)
+        self.horizontalLayout_4.setObjectName("horizontalLayout_4")
+        self.label_7 = QtWidgets.QLabel(self.frame_3)
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(10)
+        font.setBold(True)
+        font.setWeight(75)
+        self.label_7.setFont(font)
+        self.label_7.setObjectName("label_7")
+        self.horizontalLayout_4.addWidget(self.label_7)
+        self.label_4 = QtWidgets.QLabel(self.frame_3)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Expanding)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.label_4.sizePolicy().hasHeightForWidth())
+        self.label_4.setSizePolicy(sizePolicy)
+        self.label_4.setMinimumSize(QtCore.QSize(0, 0))
+        self.label_4.setMaximumSize(QtCore.QSize(16777215, 16777215))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(10)
+        font.setBold(False)
+        font.setWeight(50)
+        self.label_4.setFont(font)
+        self.label_4.setStyleSheet("")
+        self.label_4.setText("")
+        self.label_4.setAlignment(QtCore.Qt.AlignLeading|QtCore.Qt.AlignLeft|QtCore.Qt.AlignVCenter)
+        self.label_4.setObjectName("label_4")
+        self.horizontalLayout_4.addWidget(self.label_4)
+        self.label_8 = QtWidgets.QLabel(self.frame_3)
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(10)
+        font.setBold(True)
+        font.setWeight(75)
+        self.label_8.setFont(font)
+        self.label_8.setObjectName("label_8")
+        self.horizontalLayout_4.addWidget(self.label_8)
+        self.label_5 = QtWidgets.QLabel(self.frame_3)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Expanding)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.label_5.sizePolicy().hasHeightForWidth())
+        self.label_5.setSizePolicy(sizePolicy)
+        self.label_5.setMinimumSize(QtCore.QSize(0, 0))
+        self.label_5.setMaximumSize(QtCore.QSize(16777215, 16777215))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(10)
+        self.label_5.setFont(font)
+        self.label_5.setStyleSheet("")
+        self.label_5.setObjectName("label_5")
+        self.horizontalLayout_4.addWidget(self.label_5)
+        self.label_9 = QtWidgets.QLabel(self.frame_3)
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(10)
+        font.setBold(True)
+        font.setWeight(75)
+        self.label_9.setFont(font)
+        self.label_9.setObjectName("label_9")
+        self.horizontalLayout_4.addWidget(self.label_9)
+        self.label_10 = QtWidgets.QLabel(self.frame_3)
+        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Expanding)
+        sizePolicy.setHorizontalStretch(0)
+        sizePolicy.setVerticalStretch(0)
+        sizePolicy.setHeightForWidth(self.label_10.sizePolicy().hasHeightForWidth())
+        self.label_10.setSizePolicy(sizePolicy)
+        self.label_10.setMinimumSize(QtCore.QSize(60, 0))
+        self.label_10.setMaximumSize(QtCore.QSize(60, 16777215))
+        font = QtGui.QFont()
+        font.setFamily("宋体")
+        font.setPointSize(10)
+        self.label_10.setFont(font)
+        self.label_10.setText("")
+        self.label_10.setAlignment(QtCore.Qt.AlignLeading|QtCore.Qt.AlignLeft|QtCore.Qt.AlignVCenter)
+        self.label_10.setObjectName("label_10")
+        self.horizontalLayout_4.addWidget(self.label_10)
+        self.horizontalLayout_4.setStretch(1, 2)
+        self.horizontalLayout_4.setStretch(3, 1)
+        self.verticalLayout_2.addWidget(self.frame_3)
+        self.MainWindow.setCentralWidget(self.centralwidget)
+
+        self.retranslateUi(self.MainWindow)
+        self.cur_btn = self.commandLinkButton_3
+        self.__init_click()
+
+        self.set_content()
+        DBClass().execute('DELETE FROM task where status != ?', (STATUS_SUCCESS,))
+        q_do_task.put(True)
+
+        QtCore.QMetaObject.connectSlotsByName(self.MainWindow)
+
+    def retranslateUi(self, MainWindow):
+        _translate = QtCore.QCoreApplication.translate
+        MainWindow.setWindowTitle(_translate("MainWindow", "智能数据助手 " + VERSION))
+        # self.label.setText(_translate("MainWindow", "北京小爱智能科技有限公司"))
+        # self.label.setText(_translate("MainWindow", "北京冠华英才（测试）智能数据助手"))
+        self.label.setText(_translate("MainWindow", "深圳工源智能数据助手"))
+        self.label_2.setText(_translate("MainWindow", "Social Tax Intelligent Data Assistant " + VERSION))
+        self.commandLinkButton_2.setText(_translate("MainWindow", "注销"))
+        self.commandLinkButton.setText(_translate("MainWindow", "退出"))
+        self.commandLinkButton_3.setText(_translate("MainWindow", "待办任务"))
+        self.commandLinkButton_4.setText(_translate("MainWindow", "已办任务"))
+        self.label_6.setText(_translate("MainWindow", "空闲中..."))
+        self.commandLinkButton_5.setText(_translate("MainWindow", "立即办理"))
+        self.label_7.setText(_translate("MainWindow", "公司名称："))
+        self.label_8.setText(_translate("MainWindow", "用户姓名："))
+        self.label_9.setText(_translate("MainWindow", "平台类型："))
+
+    def __init_click(self):
+        self.commandLinkButton.clicked.connect(self.login_out)
+
+    def login_out(self):
+        """退出启动窗口事件"""
+        result = QMessageBox.question(self.MainWindow, '提示', '确定要退出智能数据助手吗？', QMessageBox.Yes | QMessageBox.No)
+        if result == 16384:
+            self.MainWindow.close()
+            return True
+        return False
+
+    def login_off(self, filename):
+        """退出启动窗口事件"""
+        result = QMessageBox.question(self.MainWindow, '提示', '确定要注销当前账号吗？', QMessageBox.Yes | QMessageBox.No)
+        if result == 16384:
+            DBClass().execute('DELETE FROM account')
+            os.system('start ' + filename)
+            self.MainWindow.close()
+
+    def set_content(self):
+        """设置待办任务和已办任务标题信息"""
+        column_name = ['文件名称', '业务类型', '平台类型', '办理时间', '任务状态', '备注信息']
+        if self.cur_btn == self.commandLinkButton_3:
+            self.commandLinkButton_3.setEnabled(False)
+            self.commandLinkButton_4.setEnabled(True)
+            column_name = ['文件名称', '业务类型', '平台类型', '办理时间', '任务状态', '备注信息']
+        elif self.cur_btn == self.commandLinkButton_4:
+            self.commandLinkButton_3.setEnabled(True)
+            self.commandLinkButton_4.setEnabled(False)
+            column_name = ['文件名称', '业务类型', '平台类型', '完成时间', '任务状态', '备注信息']
+
+        self.tableWidget.setColumnCount(6)
+        self.tableWidget.horizontalHeader().setDefaultSectionSize(265)
+        self.tableWidget.verticalHeader().setDefaultSectionSize(35)
+        self.tableWidget.setColumnWidth(1, 90)
+        self.tableWidget.setColumnWidth(2, 90)
+        self.tableWidget.setColumnWidth(3, 150)
+        self.tableWidget.setColumnWidth(4, 90)
+        self.tableWidget.setHorizontalHeaderLabels(column_name)
+
+    def update_dotask(self, data):
+        """更新待办理任务列表"""
+        _data = json.loads(data)
+        if len(_data) == 0:
+            self.tableWidget.setRowCount(0)
+        else:
+            flag = 0
+            if _data['status'] == '正在办理':
+                flag = 1
+            elif _data['status'] == '办理失败':
+                flag = 2
+            elif _data['status'] == '办理成功':
+                flag = 3
+
+            self.tableWidget.setRowCount(_data['cnt'])
+            self.tableWidget.setItem(_data['row'], 0, self.__create_item(_data['filename'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 1, self.__create_item(_data['bus_type'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 2, self.__create_item(_data['plat_type'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 3, self.__create_item(_data['task_time'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 4, self.__create_item(_data['status'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 5, self.__create_item(_data['comment'], flag=flag))
+
+    def update_doedtask(self, data):
+        """更新已办理任务列表"""
+        _data = json.loads(data)
+        if len(_data) == 0:
+            self.tableWidget.setRowCount(0)
+        else:
+            flag = 0
+            if _data['status'] == '正在办理':
+                flag = 1
+            elif _data['status'] == '办理失败':
+                flag = 2
+            elif _data['status'] == '办理成功':
+                flag = 3
+
+            self.tableWidget.setRowCount(_data['cnt'])
+            self.tableWidget.setItem(_data['row'], 0, self.__create_item(_data['filename'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 1, self.__create_item(_data['bus_type'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 2, self.__create_item(_data['plat_type'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 3, self.__create_item(_data['task_time'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 4, self.__create_item(_data['status'], flag=flag))
+            self.tableWidget.setItem(_data['row'], 5, self.__create_item(_data['comment'], flag=flag))
+
+    def __create_item(self, content, flag=0):
+        """创建列表item对象"""
+        item = QTableWidgetItem(content)
+        font = QtGui.QFont("微软雅黑", 10, QtGui.QFont.Normal)
+        item.setFont(font)
+        item.setTextAlignment(Qt.AlignVCenter | Qt.AlignHCenter)
+        if flag == 1:
+            item.setForeground(QBrush(QColor(255, 170, 0)))
+        elif flag == 2:
+            item.setForeground(QBrush(QColor(255, 0, 0)))
+        elif flag == 3:
+            item.setForeground(QBrush(QColor(0, 0, 255)))
+        else:
+            item.setForeground(QBrush(QColor(0, 0, 0)))
+        item.setFlags(QtCore.Qt.ItemIsEnabled)
+        return item
+
+    def get_do_task(self):
+        """获取待办任务列表"""
+        self.cur_btn = self.commandLinkButton_3
+        self.set_content()
+        q_do_task.put(True)
+
+    def get_doed_task(self):
+        """获取待办任务列表"""
+        self.cur_btn = self.commandLinkButton_4
+        self.set_content()
+        q_doed_task.put(True)
+
+    def start_task(self, tenant_id, tenant_type):
+        """立即办理任务"""
+        Thread(target=self.check_work_floder, daemon=True).start()
+        result = q_floder.get()
+        if result == -1:
+            QMessageBox.warning(self.MainWindow, '消息', "查询并获取用户配置信息失败！")
+        elif result == 0:
+            QMessageBox.warning(self.MainWindow, '消息', "您设置的工作目录不存在，请注销后重新设定！")
+        elif result == 1:
+            QMessageBox.warning(self.MainWindow, '消息', "您的工作目录没有检测到可被办理的任务！")
+        elif result == 2:
+            Thread(target=self.get_file_tasks, args=(tenant_id, tenant_type), daemon=True).start()
+            Thread(target=self.update_task, daemon=True).start()
+        else:
+            QMessageBox.warning(self.MainWindow, '消息', "网络或服务器异常，请稍后再试！")
+
+    def check_work_floder(self):
+        """检查工作目录是否存在有效"""
+        try:
+            self.set_enable()
+            result = DBClass().execute('SELECT ac_floder FROM account')
+            if not result or result == DB_STATUS_FAIL:
+                logger.error("查询用户设置的工作目录失败...")
+                self.set_enable(flag=1)
+                q_floder.put(-1)
+            else:
+                work_path = result[0][0]
+                if not os.path.exists(work_path):
+                    self.set_enable(flag=1)
+                    q_floder.put(0)
+                else:
+                    logger.info("工作目录：" + work_path)
+                    self.work_path = work_path
+                    files = os.listdir(self.work_path)
+                    sure_lst, err_lst = check_is_file(self.work_path, files)
+                    if not sure_lst:
+                        self.set_enable(flag=1)
+                        q_floder.put(1)
+                    else:
+                        self.sure_lst = sure_lst
+                        self.err_lst = err_lst
+                        q_floder.put(2)
+        except Exception as e:
+            logger.error(str(e))
+            self.set_enable(flag=1)
+            q_floder.put(-2)
+
+    def get_file_tasks(self, tenant_id, tenant_type):
+        """开始办理文件任务"""
+        try:
+            DBClass().execute('DELETE FROM task where status != ?', (STATUS_SUCCESS,))
+            file_list = clean_up_file(tenant_type, self.sure_lst, self.err_lst)
+            if file_list:
+                ins_list, salary_list = order_task(file_list)
+                if tenant_type == "0":
+                    if ins_list:
+                        for item in ins_list:
+                            t_err = Thread(target=update_task, args=(item[0], STATUS_FAIL, 'HRO平台不支持社保业务'))
+                            t_err.start()
+                            t_err.join()
+                    if salary_list:
+                        args = self.work_path, salary_list, tenant_id, tenant_type
+                        t_salary = Thread(target=batch_update_files, args=args)
+                        t_salary.start()
+                        t_salary.join()
+                elif tenant_type == "1":
+                    if ins_list:
+                        args = self.work_path, ins_list, tenant_id, tenant_type
+                        t_ins = Thread(target=batch_update_files, args=args)
+                        t_ins.start()
+                        t_ins.join()
+                        if salary_list:
+                            time.sleep(2)
+                            args = self.work_path, salary_list, tenant_id, tenant_type
+                            t_salary = Thread(target=batch_update_files, args=args)
+                            t_salary.start()
+                            t_salary.join()
+                    else:
+                        if salary_list:
+                            args = self.work_path, salary_list, tenant_id, tenant_type
+                            t_salary = Thread(target=batch_update_files, args=args)
+                            t_salary.start()
+                            t_salary.join()
+            self.set_enable(flag=1)
+        except Exception as e:
+            logger.error(str(e))
+            self.set_enable(flag=1)
+
+    def update_task(self):
+        """动态更新待办和已办任务列表"""
+        while True:
+            if self.cur_btn == self.commandLinkButton_3:
+                q_do_task.put(True)
+            elif self.cur_btn == self.commandLinkButton_4:
+                q_doed_task.put(True)
+            if not self.is_refresh:
+                self.commandLinkButton.setEnabled(True)
+                self.commandLinkButton_2.setEnabled(True)
+                self.commandLinkButton_5.setEnabled(True)
+                break
+            time.sleep(1)
+
+    def set_enable(self, flag=0):
+        if flag == 0:
+            self.commandLinkButton.setEnabled(False)
+            self.commandLinkButton_2.setEnabled(False)
+            self.commandLinkButton_5.setEnabled(False)
+            self.is_refresh = True
+            self.label_6.setStyleSheet("color: rgb(255, 0, 0);")
+            self.label_6.setText(self._translate("MainWindow", "办理中..."))
+        else:
+            self.label_6.setStyleSheet("color: rgb(0, 0, 255);")
+            self.label_6.setText(self._translate("MainWindow", "已结束..."))
+            time.sleep(3)
+            self.label_6.setStyleSheet("color: rgb(85, 170, 0);")
+            self.label_6.setText(self._translate("MainWindow", "空闲中..."))
+            self.commandLinkButton.setEnabled(True)
+            self.commandLinkButton_2.setEnabled(True)
+            self.commandLinkButton_5.setEnabled(True)
+            self.is_refresh = False
+
+    def mainform_show(self):
+        self.MainWindow.show()
+        if self.MainWindow.isVisible():
+            userinfo = get_userinfo()[0]
+            if userinfo:
+                company = userinfo[3]
+                username = userinfo[4]
+                self.label_4.setText(self._translate('MainWindow', company))
+                self.label_5.setText(self._translate('MainWindow', username))
+                self.label_10.setText(self._translate('MainWindow', userinfo[5]))
+
+    def change_title_color(self):
+        delay = 2
+        while True:
+            self.label.setStyleSheet("color: rgb(85, 0, 255);")
+            time.sleep(delay)
+            self.label.setStyleSheet("color: rgb(255, 0, 0);")
+            time.sleep(delay)
+            self.label.setStyleSheet("color: rgb(85, 170, 0);")
+            time.sleep(delay)

+# -*- coding: utf-8 -*-
+from PyQt5.QtCore import Qt
+from PyQt5 import QtCore, QtGui, QtWidgets
+from PyQt5.QtWidgets import QMainWindow
+from qrc import icon
+
+
+class Ui_MsgWindow(object):
+    def __init__(self):
+        self.MsgWindow = QMainWindow()
+        self.font = QtGui.QFont()
+        self.msg = '智能数据助手启动成功！'
+        self.font.setFamily("微软雅黑")
+        self.font.setPointSize(10)
+        self.centralwidget = QtWidgets.QWidget(self.MsgWindow)
+        self._translate = QtCore.QCoreApplication.translate
+
+    def __init_window_ui(self):
+        """初始化窗口框架"""
+        self.MsgWindow.setObjectName("MsgWindow")
+        self.MsgWindow.setFixedSize(230, 120)
+        self.MsgWindow.setWindowFlags(Qt.WindowStaysOnTopHint)
+        self.MsgWindow.setWindowFlags(Qt.WindowMinimizeButtonHint)
+        # self.LoginWindow.setWindowFlags(Qt.FramelessWindowHint)
+        icon = QtGui.QIcon()
+        icon.addPixmap(QtGui.QPixmap(":/icon/imgs/logo.png"), QtGui.QIcon.Normal, QtGui.QIcon.Off)
+        self.MsgWindow.setWindowIcon(icon)
+        self.MsgWindow.setWindowTitle(self._translate("MsgWindow", "消息"))
+
+        self.label = QtWidgets.QLabel(self.centralwidget)
+        self.label.setGeometry(QtCore.QRect(10, 20, 211, 30))
+        self.label.setFont(self.font)
+        self.label.setAlignment(QtCore.Qt.AlignCenter)
+        self.label.setText(self._translate("MsgWindow", self.msg))
+        self.pushButton = QtWidgets.QPushButton(self.centralwidget)
+        self.pushButton.setGeometry(QtCore.QRect(80, 70, 70, 26))
+        self.pushButton.setText(self._translate("MsgWindow", "确定"))
+        self.MsgWindow.setCentralWidget(self.centralwidget)
+        QtCore.QMetaObject.connectSlotsByName(self.MsgWindow)
+
+    def setupUi(self, msg):
+        if msg != '':
+            self.msg = msg
+        self.__init_window_ui()
+        self.__init_click()
+
+    def __init_click(self):
+        self.pushButton.clicked.connect(self.__sure)
+
+    def __sure(self):
+        """退出启动窗口事件"""
+        self.MsgWindow.close()

+
+
+class Task(object):
+    def __init__(self, *args):
+        self.task_id = args[0]
+        self.filename = args[1]
+        self.bus_type = args[2]
+        self.plat_type = args[3]
+        self.task_time = args[4]
+        self.status = args[5]
+        self.comment = args[6]

+<RCC>
+  <qresource prefix="icon">
+    <file>../imgs/logo.png</file>
+    <file>../imgs/login_off.png</file>
+    <file>../imgs/login_out.png</file>
+    <file>../imgs/do_task.png</file>
+    <file>../imgs/doed_task.png</file>
+    <file>../imgs/start.png</file>
+  </qresource>
+</RCC>

+[hro]
+tenant_id=518927439657705472
+tenant_type=0
+
+[delay_time]
+delay=600
+mid_delay=7200
+
+[data]
+path=taxbot.db
+
+