# -*- coding: utf-8 -*-

from __future__ import division

import json

from django.conf import settings
from django.core.serializers.json import DjangoJSONEncoder
from logit import logit
from TimeConvert import TimeConvert as tc

from utils.error.errno_utils import GroupUserStatusCode
from utils.error.response_utils import response
from utils.redis.rkeys import (TOUR_GUIDE_GROUP_CUR_SESSION, TOUR_GUIDE_GROUP_GEO_INFO, TOUR_GUIDE_GROUP_USER_BELONG,
                               TOUR_GUIDE_GROUP_USER_GEO_LIST)


r = settings.REDIS_CACHE


@logit
def geo_submit_api(request):
    user_id = request.POST.get('user_id', '')
    longitude = request.POST.get('lon', '')  # 经度
    latitude = request.POST.get('lat', '')  # 纬度

    # 获取用户当前所处旅行团
    group_id = r.get(TOUR_GUIDE_GROUP_USER_BELONG % user_id)
    if not group_id:
        return response(GroupUserStatusCode.USER_HAS_NOT_JOIN_GROUP)

    r.geoadd(TOUR_GUIDE_GROUP_GEO_INFO % group_id, longitude, latitude, user_id)

    session_id = r.get(TOUR_GUIDE_GROUP_CUR_SESSION % group_id)
    r.rpush(TOUR_GUIDE_GROUP_USER_GEO_LIST % (group_id, session_id, user_id), json.dumps({
        'lon': longitude,
        'lat': latitude,
        'current_time': tc.utc_datetime(),
    }, cls=DjangoJSONEncoder))

    return response(200, 'Geo Info Submit Success', u'地理位置信息上传成功')