import datetime from smartfarming.models.device import MongoDevice, MongoSCDData, MongoDeviceType, MongoXYCBData from kedong.decoration import kedong_deco, PortError from smartfarming.utils import get_address_by_lntlat, get_weather_info @kedong_deco(login_required=False) def weathers(request): """ 天气接口 参数 lat 必传(str) 纬度 lng 必传(str) 经度 返回值： "data": [ { "id": 1201, "province": "新疆维吾尔自治区", 省 "city": "克孜勒苏柯尔克孜自治州", 市 "district": "阿克陶县", 县 "lng": "75.945159", 经度 "lat": "39.147079", 纬度 "at": "31", 温度 "ah": "14", 湿度 "upl_time": "2021-10-25 14:39:48", 时间 "win": "东风", 风向 "win_speed": "1级", 风速 "win_meter": "5km/h", 风力 "wea": "多云", 天气 "visibility": "30km", 能见度 "pressure": "863", 压力 "air": "40", 空气 "air_pm25": "19", 空气PM2.5 "air_level": "优", 空气等级 "air_tips": "空气很好,可以外出活动,呼吸新鲜空气,拥抱大自然！" 空气说明 } ], "params": { "lat": "039.1850853", "lng": "075.8749465" } } """ lat = request.POST.get('lat', '') lng = request.POST.get('lng', '') device_id = request.POST.get('device_id') if not lat and not lng: raise PortError('', '未传经纬度') province, city, district = "", "", "" if device_id: try: instance = MongoDevice.objects.get(device_id=device_id) province, city, district = instance.province, instance.city, instance.district if (not city) and district: city = district except Exception as e: pass if not (province and city): province, city, district = get_address_by_lntlat(lng, lat) result = [] weather_info = get_weather_info(lng, lat) try: upl_time = weather_info.get('upl_time') upl_time = datetime.datetime.fromtimestamp(int(upl_time)).strftime("%Y-%m-%d %H:%M:%S") except Exception as e: upl_time = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S") result.append({ "province": province, "city": city, "district": district, "lng": lng, "lat": lat, "at": weather_info.get('at', ''), "ah": weather_info.get('ah', ''), "upl_time": upl_time, "win": weather_info.get('win', ''), "win_speed": weather_info.get('win_speed', ''), "win_meter": weather_info.get('win_meter', ''), "wea": weather_info.get('wea', ''), "visibility": weather_info.get('visibility', ''), "pressure": weather_info.get('pressure', ''), "air": weather_info.get('air', ''), "air_pm25": weather_info.get('air_pm25', ''), "air_level": weather_info.get('air_level', ''), "air_tips": weather_info.get('air_tips', ''), }) return result @kedong_deco(login_required=True) def scd_gis_info(request): """ 杀虫灯GIS展示信息 参数 device_id 必传(str) 设备ID 返回值： "data": { "address": "河南省新乡市原阳县", 设备地址 "uptime": "2022-01-02 12:12:12", 最新上传时间 "device_name": "xxxxxx", 设备名称 "device_id":"xxxxxxxxxxx", 设备ID 'device_status': "在线", 设备状态 "at": "30", 温度 "ah": "50", 湿度 "ws_status": "待机", 工作状态 "rps_status": "正常", 雨控状态 "tt": "4", 定时时长 "ct": "0", 电击次数 "csq": "0" 信号强度 } """ device_id = request.POST.get('device_id') try: device_info = MongoDevice.objects.get(device_id=device_id) except Exception as e: raise PortError("device_id", "设备id参数异常") device_name = device_info.device_name if not device_name: device_name = MongoDeviceType.objects.get(id=4).type_name up_date = datetime.datetime.utcfromtimestamp(device_info.uptime) try: queryset = MongoSCDData.objects.filter(device_id=device_info.id).order_by('-id')[0] data_info = eval(queryset.device_data) except Exception as e: data_info = {} ws = data_info.get('ws', '0') ws_status = "待机" if ws == "1": ws_status = "工作" elif ws == "2": ws_status = "充电" tt = data_info.get('tt', '0') if tt == '0': tt = '常亮' rps_status = "正常" if data_info.get("rps", "0") == "0" else "保护" data = { "address": f"{device_info.province}{device_info.city}{device_info.district}", "uptime": up_date.strftime("%Y-%m-%d %H:%M:%S"), "device_name": device_name, "device_id": device_info.device_id, 'device_status': "在线" if device_info.device_status == 1 else "离线", "ws_status": ws_status, "rps_status": rps_status, "tt": tt, "at": data_info.get('at', ''), "ah": data_info.get('ah', ''), "ct": data_info.get('ct', '0'), "csq": data_info.get('csq', '0') } return data @kedong_deco(login_required=True) def xycb_gis_info(request): """ 性诱测报GIS展示信息 参数 device_id 必传(str) 设备ID 返回值： "data": { "address": "河南省新乡市原阳县", 设备地址 "uptime": "2022-01-02 12:12:12", 最新上传时间 "device_name": "xxxxxx", 设备名称 "device_id":"xxxxxxxxxxx", 设备ID 'device_status': "在线", 设备状态 "at": "30", 温度 "ah": "50", 湿度 "ws_status": "待机", 工作状态 "cs_status": "非充电", 充电状态 "bs_status": "正常", 电池状态 "infr_ct": "0", 击虫次数 "csq": "0" 信号强度 } """ device_id = request.POST.get('device_id') try: device_info = MongoDevice.objects.get(device_id=device_id) except Exception as e: raise PortError("device_id", "设备id参数异常") device_name = device_info.device_name if not device_name: device_name = MongoDeviceType.objects.get(id=4).type_name up_date = datetime.datetime.utcfromtimestamp(device_info.uptime) try: queryset = MongoXYCBData.objects.filter(device_id=device_info.id).order_by('-id')[0] data_info = eval(queryset.device_data) except Exception as e: data_info = {} ws = data_info.get('ws', '0') ws_status = "待机" if ws == "1": ws_status = "工作" elif ws == "2": ws_status = "充电" bs = data_info.get('bs', '0') bs_status = '正常' if bs == '1': bs_status = '欠压' elif bs == '2': bs_status = '过压' cs_status = '非充电' if data_info.get('cs', '0') == '0' else '充电' data = { "address": f"{device_info.province}{device_info.city}{device_info.district}", "uptime": up_date.strftime("%Y-%m-%d %H:%M:%S"), "device_name": device_name, "device_id": device_info.device_id, 'device_status': "在线" if device_info.device_status == 1 else "离线", "at": data_info.get('at', ''), "ah": data_info.get('ah', ''), "ws_status": ws_status, "cs_status": cs_status, "bs_status": bs_status, "infr_ct": data_info.get('infr_ct', '0'), "csq": data_info.get('csq') } return data