mirror of
https://github.com/kxgx/2.13-Ink-screen-clock.git
synced 2026-03-15 07:03:16 +08:00
98 lines
3.2 KiB
Python
98 lines
3.2 KiB
Python
#!/usr/bin/env python
|
||
# -*- coding:utf-8 -*-
|
||
import os
|
||
import json
|
||
import time
|
||
import logging
|
||
import requests
|
||
from threading import Timer
|
||
|
||
logging.basicConfig(
|
||
level=logging.INFO,
|
||
format='%(asctime)s - %(message)s',
|
||
datefmt='%Y-%m-%d %H:%M:%S'
|
||
)
|
||
|
||
def get_area_id(city_name):
|
||
"""从city.js中检索AREAID，无限重试直到成功"""
|
||
url = "https://j.i8tq.com/weather2020/search/city.js"
|
||
while True:
|
||
try:
|
||
resp = requests.get(url, timeout=10)
|
||
resp.encoding = 'utf-8' # 显式设置编码
|
||
city_data = json.loads(resp.text.split('=', 1)[1].rstrip(';'))
|
||
for province in city_data.values():
|
||
for city in province.values():
|
||
for district, info in city.items():
|
||
if info['NAMECN'] == city_name:
|
||
return info['AREAID']
|
||
logging.error("未找到城市: %s", city_name)
|
||
except Exception as e:
|
||
logging.error("获取城市ID失败: %s", str(e))
|
||
time.sleep(180)
|
||
|
||
def get_current_city():
|
||
"""获取当前定位城市并去除'市'后缀"""
|
||
url = "http://ip-api.com/json/?lang=zh-CN"
|
||
while True:
|
||
try:
|
||
resp = requests.get(url, timeout=10)
|
||
resp.encoding = 'utf-8' # 显式设置编码
|
||
data = resp.json()
|
||
if data['status'] == 'success':
|
||
return data['city'].rstrip('市')
|
||
logging.error("定位失败: %s", data.get('message'))
|
||
except Exception as e:
|
||
logging.error("定位异常: %s", str(e))
|
||
time.sleep(180)
|
||
|
||
def schedule_getWeath():
|
||
"""定时任务调度"""
|
||
try:
|
||
getWeath()
|
||
finally:
|
||
Timer(180, schedule_getWeath).start()
|
||
|
||
def getWeath(default_city='101060101'):
|
||
"""获取天气数据核心函数"""
|
||
city_name = get_current_city()
|
||
area_id = default_city # 设置默认值
|
||
|
||
if city_name:
|
||
try:
|
||
area_id = get_area_id(city_name) or default_city
|
||
except Exception as e:
|
||
logging.error("获取区域ID失败: %s", str(e))
|
||
|
||
headers = {
|
||
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
|
||
'Referer': 'https://www.weather.com.cn/'
|
||
}
|
||
|
||
try:
|
||
resp = requests.get(
|
||
f'https://d1.weather.com.cn/sk_2d/{area_id}.html',
|
||
headers=headers,
|
||
timeout=15
|
||
)
|
||
resp.encoding = 'utf-8' # 关键修改：强制设置响应编码
|
||
resp.raise_for_status()
|
||
|
||
# 直接处理原始字节数据
|
||
weather_data = resp.content[11:].decode('utf-8')
|
||
|
||
# 使用utf-8编码写入文件
|
||
with open('/root/2.13-Ink-screen-clock/bin/weather.json', 'w', encoding='utf-8') as f:
|
||
f.write(weather_data)
|
||
|
||
logging.info("天气数据更新成功")
|
||
except Exception as e:
|
||
logging.error("天气更新失败: %s", str(e))
|
||
|
||
if __name__ == "__main__":
|
||
try:
|
||
schedule_getWeath()
|
||
while True:
|
||
time.sleep(1) # 保持主线程存活
|
||
except KeyboardInterrupt:
|
||
logging.info("程序已终止") |