pai2/geo/views.py

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

from __future__ import division

import json

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.connect import r
from utils.redis.rkeys import (TOUR_GUIDE_GROUP_CUR_SESSION, TOUR_GUIDE_GROUP_GEO_INFO, TOUR_GUIDE_GROUP_GEO_SUBMIT_DT,
                               TOUR_GUIDE_GROUP_USER_GEO_LIST)
from utils.redis.rtouruser import get_tour_user_belong_group


@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 = get_tour_user_belong_group(user_id)
    if not group_id:
        return response(GroupUserStatusCode.USER_HAS_NOT_JOIN_GROUP)

    r.pipeline().geoadd(
        TOUR_GUIDE_GROUP_GEO_INFO % group_id, longitude, latitude, user_id
    ).hset(
        TOUR_GUIDE_GROUP_GEO_SUBMIT_DT % group_id, user_id, tc.utc_string(format='%Y-%m-%dT%H:%M:%SZ')
    ).execute()

    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(ms=False),
    }, cls=DjangoJSONEncoder))

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