File size: 4,533 Bytes
a757bd3 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 | # coding: utf-8
# -------------------------------------------------------------------
# 宝塔Linux面板
# -------------------------------------------------------------------
# Copyright (c) 2015-2099 宝塔软件(http://bt.cn) All rights reserved.
# -------------------------------------------------------------------
# Author: sww <sww@bt.cn>
# -------------------------------------------------------------------
# 网站关联数据库，ftp模块
# ------------------------------
import traceback
from panelModel.base import panelBase
import public, config
class main(panelBase):
def get_site_info(self, get=None):
"""
@name 获取网站关联信息
"""
sites = public.M('sites').where('project_type=?', ('PHP',)).select()
if type(sites) == str:
raise public.PanelError(sites)
site_id = {}
for i in sites:
if i.get('rname','') == '':
i['rname'] = i['name']
del i['name']
site_id[i['id']] = i
site_id[i['id']]['ftp'] = {}
site_id[i['id']]['mysql'] = {}
ftps = public.M('ftps').field('id,pid,name').select()
mysqls = public.M('databases').where('type=?', ('MySQL',)).field('id,pid,name').select()
for i in ftps:
if i['pid'] != 0 and i['pid'] in site_id.keys():
site_id[i['pid']]['ftp'] = i
for i in mysqls:
if i['pid'] != 0 and i['pid'] in site_id.keys():
site_id[i['pid']]['mysql'] = i
return list(site_id.values())
def get_mysql_info(self, get=None):
try:
mysqls = public.M('databases').where('type=?', ('MySQL',)).field('id,pid,name').select()
for i in mysqls:
if i['pid'] != 0:
site = public.M('sites').where('id=?', (i['pid'],)).field('name,rname').select()
if type(site) != str and site:
site = site[0]
else:
site = {'name': '', 'rname': ''}
if site['rname'] == '':
site['rname'] = site['name']
i['rname'] = site['rname']
i['is_band'] = 1
return mysqls
except:
return traceback.format_exc()
def get_ftp_info(self, get=None):
ftps = public.M('ftps').field('id,pid,name').select()
return ftps
def modify_mysql_link(self, get):
try:
if not hasattr(get, 'sql_id') or not get.sql_id:
return public.returnMsg(False, '参数错误!')
if not hasattr(get, 'pid') or not get.pid:
return public.returnMsg(False, '参数错误!')
sql_id = get.sql_id
pid = get.pid
data = public.M('databases').where('id=?', (sql_id,)).field('id,pid,name')
if type(data) != str and data:
if public.M('databases').where('pid=?', (pid,)).count() > 0:
old_link = public.M('databases').where('pid=?', (pid,)).field('id,pid,name').select()
for i in old_link:
public.M('databases').where('id=?', (i['id'],)).setField('pid', 0)
public.M('databases').where('id=?', (sql_id,)).setField('pid', pid)
return public.returnMsg(True, '修改成功!')
return public.returnMsg(False, '修改失败!')
except:
return traceback.format_exc()
def modify_ftp_link(self, get):
try:
if not hasattr(get, 'ftp_id') or not get.ftp_id:
return public.returnMsg(False, '参数错误!')
if not hasattr(get, 'pid') or not get.pid:
return public.returnMsg(False, '参数错误!')
ftp_id = get.ftp_id
pid = get.pid
data = public.M('ftps').where('id=?', (ftp_id,)).select()
if type(data) != str and data:
if public.M('ftps').where('pid=?', (pid,)).count() > 0:
old_link = public.M('ftps').where('pid=?', (pid,)).field('id,pid,name').select()
for i in old_link:
public.M('ftps').where('id=?', (i['id'],)).setField('pid', 0)
public.M('ftps').where('id=?', (ftp_id,)).setField('pid', pid)
return public.returnMsg(True, '修改成功!')
return public.returnMsg(False, '修改失败!')
except:
return traceback.format_exc()
|