| Server IP : 104.21.38.3 / Your IP : 162.158.189.58 Web Server : Apache System : Linux krdc-ubuntu-s-2vcpu-4gb-amd-blr1-01.localdomain 5.15.0-142-generic #152-Ubuntu SMP Mon May 19 10:54:31 UTC 2025 x86_64 User : www ( 1000) PHP Version : 7.4.33 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /www/server/panel/class_v2/ |
Upload File : |
#coding: utf-8
# +-------------------------------------------------------------------
# | aaPanel
# +-------------------------------------------------------------------
# | Copyright (c) 2015-2099 aaPanel(www.aapanel.com) All rights reserved.
# +-------------------------------------------------------------------
# | Author: hwliang <[email protected]>
# +-------------------------------------------------------------------
import os,sys,public,json,time
class downloadFile:
logPath = 'data/speed.json'
timeoutCount = 0;
oldTime = 0;
writeTime = 0;
down_count = 0;
#下载文件
def DownloadFile(self,url,filename):
try:
path = os.path.dirname(filename)
if not os.path.exists(path): os.makedirs(path)
import urllib,socket,ssl
try:
ssl._create_default_https_context = ssl._create_unverified_context
except:pass
socket.setdefaulttimeout(30)
self.pre = 0;
self.oldTime = time.time();
if sys.version_info[0] == 2:
urllib.urlretrieve(url,filename=filename,reporthook= self.DownloadHook)
else:
urllib.request.urlretrieve(url,filename=filename,reporthook= self.DownloadHook)
speed = self.GetSpeed()
speed['pre'] = 100;
speed['used'] = speed['total']
self.WriteLogs(json.dumps(speed));
except:
if self.timeoutCount > 5: return;
self.timeoutCount += 1
time.sleep(5)
self.DownloadFile(url,filename)
#下载文件进度回调
def DownloadHook(self,count, blockSize, totalSize):
used = count * blockSize
pre1 = int((100.0 * used / totalSize))
my_time = time.time()
if self.pre != pre1 or (my_time - self.writeTime) > 1:
dspeed = ((count -self.down_count) * blockSize) / (my_time - self.oldTime)
speed = {'name':public.GetMsg("DOWNLOAD_FILE"),'total':totalSize,'used':used,'pre':self.pre,'speed':dspeed}
self.WriteLogs(json.dumps(speed))
self.pre = pre1
self.writeTime = my_time
self.down_count = count
self.oldTime = my_time
#取下载进度
def GetSpeed(self):
speedLog = public.ReadFile(self.logPath)
if not speedLog: return {'name':public.GetMsg("DOWNLOAD_FILE"),'total':0,'used':0,'pre':0,'speed':0}
return json.loads(speedLog)
#写输出日志
def WriteLogs(self,logMsg):
public.WriteFile(self.logPath,logMsg)