from .base_request import my_Request
import json
from task.request_task_proxy import retry

@retry
def fetch_dust_data(self, obj):
    """
    获取站点监测数据

    Args:
      sTime: 开始时间
      eTime: 结束时间
      site: 站点编号
      typeID: 站点类型
    
    Returns:
      [
        {
          "longitude": "121.32",
          "latitude": "30.840834",
          "Address": "西新泾黄汶泾",
          "DustValue": 0.207,
          "Grade": 1,
          "GroupID": 16,
          "GroupName": "金山区",
          "LST": "2023-10-16 12:00:00",
          "LST1": "1697457600",
          "Name": "大信.中信海直华东无人机总部基地项目——1号点",
          "MNCode": "SHXH0JS0100306",
          "NoiseValue": 59.4,
          "ProjectID": 45879,
          "Quality": "好",
          "SName": "上海小慧",
          "TypeName": "建筑工地",
          "flag": "N"
        }
      ]
    """

    data = {
        'time': 'Quarter',
        'div': 16,
    }
    data.update(obj)

    url_site_data = my_Request.base_url+'/DustManger/ReportData/GetSiteData'
    res = my_Request.post(url_site_data, data)
    if res == False:
        return False
    else:
        return json.loads(res.text)