mirror of
https://github.com/kingmo888/rustdesk-api-server.git
synced 2026-02-23 11:27:21 +08:00
Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
71c6f290d1 | ||
|
|
d04154aa7e | ||
|
|
175e1165db |
@ -15,6 +15,9 @@
|
|||||||
</p>
|
</p>
|
||||||
|
|
||||||
# 1.2.3版本与1.2.6+版本区别
|
# 1.2.3版本与1.2.6+版本区别
|
||||||
|
#### **请使用自定义key,因不填写key、或使用服务端自动生成的key而引起的链接超时或建立链接时间过长的问题,不在本项目解决范围内。**
|
||||||
|
|
||||||
|
|
||||||
> rustdesk官方在其新版服务端中已[强制要求key](https://rustdesk.com/docs/zh-cn/self-host/rustdesk-server-oss/install/#key)(rustdesk-server版本号大概>=1.1.10)
|
> rustdesk官方在其新版服务端中已[强制要求key](https://rustdesk.com/docs/zh-cn/self-host/rustdesk-server-oss/install/#key)(rustdesk-server版本号大概>=1.1.10)
|
||||||
|
|
||||||
- rustdesk版本<=1.2.3, 服务端请配合使用rustdesk-server<=1.1.10
|
- rustdesk版本<=1.2.3, 服务端请配合使用rustdesk-server<=1.1.10
|
||||||
|
|||||||
@ -14,6 +14,15 @@ from .views_front import *
|
|||||||
from django.utils.translation import gettext as _
|
from django.utils.translation import gettext as _
|
||||||
|
|
||||||
|
|
||||||
|
def get_client_ip(request):
|
||||||
|
x_forwarded_for = request.META.get('HTTP_X_FORWARDED_FOR')
|
||||||
|
if x_forwarded_for:
|
||||||
|
ip = x_forwarded_for.split(',')[0]
|
||||||
|
else:
|
||||||
|
ip = request.META.get('REMOTE_ADDR')
|
||||||
|
return ip
|
||||||
|
|
||||||
|
|
||||||
def login(request):
|
def login(request):
|
||||||
result = {}
|
result = {}
|
||||||
if request.method == 'GET':
|
if request.method == 'GET':
|
||||||
@ -226,7 +235,7 @@ def sysinfo(request):
|
|||||||
if request.method == 'GET':
|
if request.method == 'GET':
|
||||||
result['error'] = _('错误的提交方式!')
|
result['error'] = _('错误的提交方式!')
|
||||||
return JsonResponse(result)
|
return JsonResponse(result)
|
||||||
client_ip = request.META.get('REMOTE_ADDR')
|
client_ip = get_client_ip(request)
|
||||||
postdata = json.loads(request.body)
|
postdata = json.loads(request.body)
|
||||||
device = RustDesDevice.objects.filter(Q(rid=postdata['id']) & Q(uuid=postdata['uuid'])).first()
|
device = RustDesDevice.objects.filter(Q(rid=postdata['id']) & Q(uuid=postdata['uuid'])).first()
|
||||||
if not device:
|
if not device:
|
||||||
@ -255,7 +264,7 @@ def heartbeat(request):
|
|||||||
postdata = json.loads(request.body)
|
postdata = json.loads(request.body)
|
||||||
device = RustDesDevice.objects.filter(Q(rid=postdata['id']) & Q(uuid=postdata['uuid'])).first()
|
device = RustDesDevice.objects.filter(Q(rid=postdata['id']) & Q(uuid=postdata['uuid'])).first()
|
||||||
if device:
|
if device:
|
||||||
client_ip = request.META.get('REMOTE_ADDR')
|
client_ip = get_client_ip(request)
|
||||||
device.ip_address = client_ip
|
device.ip_address = client_ip
|
||||||
device.save()
|
device.save()
|
||||||
# token保活
|
# token保活
|
||||||
|
|||||||
@ -229,6 +229,9 @@ def get_all_info():
|
|||||||
if device:
|
if device:
|
||||||
devices[peer.rid]['rust_user'] = user.username
|
devices[peer.rid]['rust_user'] = user.username
|
||||||
|
|
||||||
|
for rid in devices.keys():
|
||||||
|
if not devices[rid].get('rust_user', ''):
|
||||||
|
devices[rid]['rust_user'] = _('未登录')
|
||||||
for k, v in devices.items():
|
for k, v in devices.items():
|
||||||
devices[k]['status'] = _('在线') if (now - datetime.datetime.strptime(v['update_time'], '%Y-%m-%d %H:%M')).seconds <= 120 else _('离线')
|
devices[k]['status'] = _('在线') if (now - datetime.datetime.strptime(v['update_time'], '%Y-%m-%d %H:%M')).seconds <= 120 else _('离线')
|
||||||
return [v for k, v in devices.items()]
|
return [v for k, v in devices.items()]
|
||||||
@ -295,7 +298,7 @@ def share(request):
|
|||||||
sharelinks = ShareLink.objects.filter(Q(uid=request.user.id) & Q(is_used=False) & Q(is_expired=False))
|
sharelinks = ShareLink.objects.filter(Q(uid=request.user.id) & Q(is_used=False) & Q(is_expired=False))
|
||||||
|
|
||||||
# 省资源:处理已过期请求,不主动定时任务轮询请求,在任意地方请求时,检查是否过期,过期则保存。
|
# 省资源:处理已过期请求,不主动定时任务轮询请求,在任意地方请求时,检查是否过期,过期则保存。
|
||||||
now = datetime.datetime.now()
|
# now = datetime.datetime.now()
|
||||||
for sl in sharelinks:
|
for sl in sharelinks:
|
||||||
check_sharelink_expired(sl)
|
check_sharelink_expired(sl)
|
||||||
sharelinks = ShareLink.objects.filter(Q(uid=request.user.id) & Q(is_used=False) & Q(is_expired=False))
|
sharelinks = ShareLink.objects.filter(Q(uid=request.user.id) & Q(is_used=False) & Q(is_expired=False))
|
||||||
@ -327,7 +330,7 @@ def share(request):
|
|||||||
# 自己的peers若重叠,需要跳过
|
# 自己的peers若重叠,需要跳过
|
||||||
peers_self_ids = [x.rid for x in RustDeskPeer.objects.filter(Q(uid=request.user.id))]
|
peers_self_ids = [x.rid for x in RustDeskPeer.objects.filter(Q(uid=request.user.id))]
|
||||||
peers_share = RustDeskPeer.objects.filter(Q(rid__in=peers) & Q(uid=sharelink.uid))
|
peers_share = RustDeskPeer.objects.filter(Q(rid__in=peers) & Q(uid=sharelink.uid))
|
||||||
peers_share_ids = [x.rid for x in peers_share]
|
# peers_share_ids = [x.rid for x in peers_share]
|
||||||
|
|
||||||
for peer in peers_share:
|
for peer in peers_share:
|
||||||
if peer.rid in peers_self_ids:
|
if peer.rid in peers_self_ids:
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user