class QueryAuthMiddleware:

	def __init__(self, inner):
		self.inner = inner

	def __call__(self, scope):
		close_old_connections()
		token = scope["query_string"]
		token = token.decode("utf-8")
		user = AnonymousUser()
		if token:
			user = authenticate(token)

		return self.inner(dict(scope, user=user))


def authenticate(jwt_value):
	try:
		payload = jwt_decode_handler(jwt_value)
	except Exception:
		user = AnonymousUser()
		return user

	user = authenticate_credentials(payload)

	return user


def authenticate_credentials(payload):
	username = payload.get('username')
	try:
		User = get_user_model()
		user = User.objects.get(username=username)
	except Exception:
		user = AnonymousUser()
	return user

class ServiceConsumer(AsyncWebsocketConsumer):

	async def connect(self, *args, **kwargs):
		print('***********open************')
		user = self.scope["user"]
		user_id = ""
		# todo 如果用户没有登陆 可以直接关闭连接
		if not user.id:
			await self.close()

import time
import os
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "channels_demo.settings")

from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync
channel_layer = get_channel_layer()
# todo channel_name 是保存时 self.room_group_name 的名字


def send_channel_msg(channel_name, msg):
    async_to_sync(channel_layer.group_send)(channel_name,{'type': 'user_message','text': msg})

def screen_channel_msg(channel_name, msg):
     async_to_sync(channel_layer.group_send)(channel_name,{'type': 'send_message','text': msg})
 
    
if __name__ == '__main__':
    send_channel_msg("user_5", {"type": "affiche","info":{
    "id": 1,
    "classify": "公告",
    "content": "上班信息",
    "create_time": "2019-05-16"
}})
    screen_channel_msg("role_1",{"text":"update"})
    print(time.time())

daphne -b 0.0.0.0 -p 8018 channels_demo.asgi:application -v2

nohup daphne -b 0.0.0.0 -p 8018 channels_demo.asgi:application -v2  >/dev/null 2>&1 &