traccar各设备通讯协议分析（坐标转换、逆地址解析）

《traccar各设备通讯协议分析（坐标转换、逆地址解析）》有一条回应

1. BG6RSH说：

   2024年6月18日 16:06

   # 高德地图逆地址解析函数# 逆地址解析功能监听处理函数，PYTHON代码。

   Code: [全选] [Expand/Collapse]

   1. from http.server import BaseHTTPRequestHandler, HTTPServer
   2. import requests
   3. import json
   4. import urllib.parse
   5.  
   6. mapquest_addr = ”’
   7. "results": [
   8.    {{
   9.      "providedLocation": {{ }},
   10.      "locations": [
   11.        {{
   12.          "street": "{0}",
   13.          "adminArea5": "{1}",
   14.          "adminArea5Type": "City",
   15.          "adminArea4": "{2}",
   16.          "adminArea4Type": "County",
   17.          "adminArea3": "{3}",
   18.          "adminArea3Type": "State",
   19.          "adminArea1": "{4}",
   20.          "adminArea1Type": "Country",
   21.          "postalCode": "{5}",    
   22.        }}
   23.      ]
   24.    }}
   25.  ]
   26. ”’
   27.  
   28. proxies = {
   29.     "http": "http://D45623:[email protected]:9128",
   30.     "https": "http://D45623:[email protected]:9128",
   31. }
   32. traccar_url = ‘http://nas.atoo.top:8082’
   33.  
   34.  
   35. # 高德地图逆地址解析函数
   36. def amap_geocode(lat, lng):
   37.     # http://127.0.0.1/v3/geocode/regeo?output=xml&location=39.991957,116.310003
   38.     amap_url = ‘https://restapi.amap.com/v3/geocode/regeo?’
   39.     parameters = {
   40.         ‘output’: ‘json’,
   41.         ‘key’: ‘de6cf58608a044b643da48377c6bdbfb’,
   42.         ‘radius’: ‘1000’,
   43.         ‘xtensions’: ‘base’,
   44.         ‘location’: ‘{0},{1}’.format(lat, lng)
   45.     }
   46.  
   47.     response = requests.get(amap_url, parameters, proxies=proxies)
   48.     if response.status_code == 200:
   49.         print(response.text)
   50.         return response.text
   51.     else:
   52.         return ”
   53.  
   54.  
   55. # 高德地图坐标转换
   56. def amap_coordinate_convert(lat, lon):
   57.     amap_url = ‘https://restapi.amap.com/v3/assistant/coordinate/convert?’
   58.     parameters = {
   59.         ‘output’: ‘json’,
   60.         ‘key’: ‘de6cf58608a044b643da48377c6bdbfb’,
   61.         ‘coordsys’: ‘gps’,
   62.         ‘locations’: ‘{0},{1}’.format(lon, lat)
   63.     }
   64.     response = requests.get(amap_url, parameters, proxies=proxies)
   65.     # print(lat, lon, requests)
   66.     if response.status_code == 200:
   67.         # print(response.text)
   68.         coordinate_json = json.loads(response.text)
   69.         if coordinate_json[‘status’] == ‘1’:
   70.             coordinate = coordinate_json[‘locations’].split(‘,’)
   71.             return coordinate[0], coordinate[1]
   72.         return –1, –1
   73.  
   74.  
   75. # 逆地址解析功能监听处理函数
   76. class GeocodeHandler(BaseHTTPRequestHandler):
   77.     def do_GET(self) –> None:
   78.         request_str = self.requestline
   79.         # print(request_str)
   80.         l = request_str.find(‘location=’)
   81.         r = request_str.rfind(‘ HTTP’)
   82.         if l != –1 and r != –1:
   83.             request_str = request_str[l + 9:r]
   84.             point = request_str.split(‘,’)
   85.             # print(point[1],point[0])
   86.             address_json = json.loads(amap_geocode(point[1], point[0]))
   87.             address = mapquest_addr.format(address_json[‘regeocode’][‘formatted_address’],
   88.                                            address_json[‘regeocode’][‘addressComponent’][‘city’],
   89.                                            address_json[‘regeocode’][‘addressComponent’][‘district’],
   90.                                            address_json[‘regeocode’][‘addressComponent’][‘province’],
   91.                                            address_json[‘regeocode’][‘addressComponent’][‘country’],
   92.                                            address_json[‘regeocode’][‘addressComponent’][‘adcode’]
   93.                                            )
   94.             print(address)
   95.         else:
   96.             address = ”
   97.         self.send_response(200)
   98.         self.send_header(‘Content-type’, ‘text/html;charset=utf-8’)
   99.         self.end_headers()
   100.         self.wfile.write(bytes(address, ‘utf-8’))
   101.  
   102.  
   103. class OsmAndProtocolHandler(BaseHTTPRequestHandler):
   104.     def do_GET(self):
   105.         # content_length = int(self.headers[‘Content-Length’])
   106.         # body = self.rfile.read(content_length)
   107.         # data = json.loads(body.decode(‘utf-8’))
   108.         request_str = self.requestline
   109.         l = request_str.find(‘GET /?’)
   110.         r = request_str.rfind(‘ HTTP’)
   111.         if l != –1 and r != –1:
   112.             data = urllib.parse.parse_qs(self.requestline[l + 6:r])
   113.             print(‘Data’, data)
   114.             # data = json.loads(self.requestline)
   115.             lat, lon = amap_coordinate_convert(data[‘lat’][0], data[‘lon’][0])
   116.             parameters = {
   117.                 ‘id’: data[‘id’][0],
   118.                 ‘timestamp’: data[‘timestamp’][0],
   119.                 ‘lat’: lat,
   120.                 ‘lon’: lon,
   121.                 ‘speed’: data[‘speed’][0],
   122.                 ‘bearing’: data[‘bearing’][0],
   123.                 ‘altitude’: data[‘altitude’][0],
   124.                 ‘accuracy’: data[‘accuracy’][0],
   125.                 ‘batt’: data[‘batt’][0]
   126.             }
   127.             response = requests.post(traccar_url, parameters, proxies=proxies)
   128.             print(‘parameters’, parameters)
   129.             self.send_response(200)
   130.             self.send_header(‘Content-type’, ‘text/html;charset=utf-8’)
   131.             self.end_headers()
   132.             self.wfile.write(bytes(json.dumps(parameters), ‘utf-8’))
   133.  
   134.  
   135. def run(server_address, handler_class=BaseHTTPRequestHandler):
   136.     # server_address = (”, 8000)
   137.     httpd = HTTPServer(server_address, handler_class)
   138.     httpd.serve_forever()
   139.  
   140.  
   141. if __name__ == ‘__main__’:
   142.     print(‘traccar坐标转换代理服务器’)
   143.     # run((”, 80), GeocodeHandler)
   144.     run((”, 8082), OsmAndProtocolHandler)

   GeSHi © Codebox Plus Extension

   回复

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理。