宿舍电费监控

import requests
def get_df(code):
    url = "http://10.128.13.25/feemanager/findSurplusElectricByMeterSearchPower.action"    i = 0    while i < 5:
        response = requests.request(
            "POST", url, data={"equipmentInfoId": "10.150.132.63#" + code}
        ).json()
        i += 1        print(response)
        if response.get('equipmentList'):
            break    equipmentList = response['equipmentList']
    return {
        # 充值电量        'surplus': float(equipmentList['roomSurplusBuyElecNum']),
        # 赠送电量        'give': float(equipmentList['roomSurplusGiveElecNum']),
        # 总电量        'total': float(equipmentList['roomSurplusBuyElecNum']) + float(equipmentList['roomSurplusGiveElecNum']),
        # 按当前电压        'voltage': equipmentList['line1Voltage'],
        # 当前电流        'electricity': equipmentList['line1Electricity'],
    }

from peewee import *import datetime
db = MySQLDatabase('dianfei', host="localhost", user='root', passwd='123456', port=3306)
class ChaZuo(Model):
    charge = DecimalField()
    time = DateTimeField()
    class Meta:
        database = db
class KongTiao(Model):
    charge = DecimalField()
    time = DateTimeField()
    class Meta:
        database = db
# 插座response = get_df('')
print('插座：  ', response)
ChaZuo.create(charge=response['total'], time=datetime.datetime.now())
# 插座response = get_df('')
print('空调：  ',response)
KongTiao.create(charge=response['total'], time=datetime.datetime.now())

*/10 * * * * python dianfei.py

import streamlit as st
import pandas as pd
import altair as alt
from peewee import MySQLDatabase, Model, DecimalField, DateTimeField
from playhouse.shortcuts import model_to_dict
# 连接到 MySQL 数据库db = MySQLDatabase('dianfei', host="192.168.1.190", user='root', passwd='123456', port=3306)
# 定义模型class ChaZuo(Model):
    charge = DecimalField()
    time = DateTimeField()
    class Meta:
        database = db
class KongTiao(Model):
    charge = DecimalField()
    time = DateTimeField()
    class Meta:
        database = db
# 查询数据def get_data(model):
    query = model.select()
    data = pd.DataFrame(list(map(model_to_dict, query)))
    data['time'] = pd.to_datetime(data['time'])  # 确保时间字段是 datetime 类型    return data
def web(title='插座', model=ChaZuo):
    # 获取数据并转换为 DataFrame    data = get_data(model)
    # 确保时间列是索引    data.set_index('time', inplace=True)
    st.markdown(f"### {title}耗电")
    # 选择时间间隔，并设置默认值为 "10分钟"    time_interval = st.selectbox(
        "选择时间间隔",
        ["10分钟", "半小时", "小时", "天"],
        index=0,  # index=0 表示默认选中第一个选项，即 "10分钟"        key=title
    )
    # 根据选择的时间间隔调整数据    if time_interval == "10分钟":
        resampled_data = data.resample("10T").last()
    elif time_interval == "半小时":
        resampled_data = data.resample("30T").last()
    elif time_interval == "天":
        resampled_data = data.resample("D").last()
    else:  # 默认为小时        resampled_data = data.resample("H").last()
    # 计算电量的变化值，并取绝对值    resampled_data['charge_diff'] = resampled_data['charge'].diff().fillna(resampled_data['charge']).abs()
    resampled_data['charge_diff'] = resampled_data['charge_diff'].astype(float)
    # 重置索引    resampled_data = resampled_data.reset_index()
    x_format = "%m-%d %H:%M"    # 绘制折线图    line_chart = alt.Chart(resampled_data[1:]).mark_line(point=True).encode(
        x=alt.X("time:T",timeUnit='monthdatehoursminutes', axis=alt.Axis(format=x_format), title="时间"),  # 添加 title 属性        y=alt.Y("charge_diff:Q", axis=alt.Axis(format=".3f"), title="使用电费"),  # 添加 axis 属性        tooltip=[alt.Tooltip("time:T",timeUnit='monthdatehoursminutes', title="时间", format=x_format),
                alt.Tooltip("charge_diff:Q", format=".3f", title="使用电费")]
    ).interactive()
    st.altair_chart(line_chart, use_container_width=True)
web('插座', ChaZuo)
web('空调', KongTiao)