import sys, os
import time
os.chdir('/www/server/panel')
sys.path.insert(0, "class/")
sys.path.insert(0, '/www/server/panel')
import public
from mod.base.push_mod import push_by_task_keyword

class main:

    def __check_auth(self):
        from pluginAuth import Plugin
        plugin_obj = Plugin(False)
        plugin_list = plugin_obj.get_plugin_list()
        return int(plugin_list['ltd']) > time.time()

    def run(self):
        pay = self.__check_auth()
        msg_list = []
        if not pay:
            from panelSite import panelSite
            site_obj = panelSite()
            res = site_obj.get_Scan(None)
            if int(res['loophole_num']):
                msg_list.append('扫描网站【{}】，发现【{}】条漏洞'.format(res['site_num'], res['loophole_num']))
            else:
                msg_list.append('扫描网站【{}】个，状态【安全】'.format(res['site_num']))
        else:
            import PluginLoader
            args = public.dict_obj()
            args.model_index = 'project'
            res = PluginLoader.module_run('scanning', 'startScan', args)
            if int(res['loophole_num']):
                msg_list.append('扫描网站【{}】，发现【{}】条漏洞'.format(res['site_num'], res['loophole_num']))
                for i in res['info']:
                    msg_list.append('网站【{}】，存在【{}】个风险项，请及时处理'.format(
                        i['rname'] if i['rname'] else i['name'],
                        len(i['cms'])
                    ))
            else:
                msg_list.append('扫描网站【{}】个，状态【安全】'.format(res['site_num']))
        return {"msg_list": msg_list}


if __name__ == '__main__':
    channels = sys.argv[1]
    main = main()
    msg = main.run()
    push_by_task_keyword("vulnerability_scanning", "vulnerability_scanning", push_data=msg)