data_analyze_platform/LIB/MIDDLE/SaftyCenter/DataStatistics.py

import numpy as np
import pandas as pd
from LIB.MIDDLE.SaftyCenter.Common import FeiShuData
from LIB.MIDDLE.SaftyCenter.Common import DBDownload
import time, datetime
from datetime import timedelta
from pandas.core.frame import DataFrame
from apscheduler.schedulers.blocking import BlockingScheduler

class DataSta():
    def __init__(self) -> None:
        pass
    def SaftyWarningSta(df_fltinfo,start_time,end_time):
        SftyPlt_Data_Total=len(df_fltinfo)#总报警数
        CS_Warning_Total_Finish=df_fltinfo[df_fltinfo['batpos']==1]
        CS_Warning_Total_Finish_Count=len(CS_Warning_Total_Finish) #平台报警总运维数
        SftyPlt_Data_day=len(df_fltinfo[df_fltinfo['start_time']>=start_time])#周总报警数
        CS_Warning_day_Finish=CS_Warning_Total_Finish[CS_Warning_Total_Finish['start_time']>=start_time]#周运维数
        CS_Warning_day_Finish_Count=len(CS_Warning_day_Finish)
        SftyPlt_EmgcyData_day=df_fltinfo[df_fltinfo['start_time']>=start_time] #紧急报警数
        SftyPlt_EmgcyData_day_Count=len(SftyPlt_EmgcyData_day[SftyPlt_EmgcyData_day['level']>3])
        SftyPlt_EmgcyData_day_Finish=SftyPlt_EmgcyData_day[SftyPlt_EmgcyData_day['batpos']==1]
        SftyPlt_EmgcyData_day_Finish_Count=len(SftyPlt_EmgcyData_day_Finish)
        if int(SftyPlt_Data_Total)>0:
            OprationManageRate=round(float(CS_Warning_day_Finish_Count/SftyPlt_Data_day)*100,2)
        else:
            OprationManageRate=100
        if int(SftyPlt_EmgcyData_day_Count)>0:
            OprationManageEmgcyRate=round(float(SftyPlt_EmgcyData_day_Finish_Count/SftyPlt_EmgcyData_day_Count)*100,2)
        else:
            OprationManageEmgcyRate=100
        PK504FltData_Count=len(df_fltinfo[df_fltinfo['product_id'].str.contains('PK504')])
        PK502FltData_Count=len(df_fltinfo[df_fltinfo['product_id'].str.contains('PK502')])
        PK500FltData_Count=len(df_fltinfo[df_fltinfo['product_id'].str.contains('PK500')])
        MGMCLFltData_Count=len(df_fltinfo[df_fltinfo['product_id'].str.contains('MGMCL')])
        MGMLXFltData_Count=len(df_fltinfo[df_fltinfo['product_id'].str.contains('MGMLX')])
        # print('总报警数=',SftyPlt_Data_Total)
        # print('总完成运维数=',CS_Warning_Total_Finish_Count)
        # print('周报警数=',SftyPlt_Data_day)
        # print('周完成运维数=',CS_Warning_day_Finish_Count)
        # print('周紧急报警数=',SftyPlt_EmgcyData_day)
        # print('周紧急完成运维数=',SftyPlt_EmgcyData_day_Finish_Count)
        # print('周运维率=',OprationManageRate)
        # print('周紧急运维率=',OprationManageEmgcyRate)
        # print('PK504总报警=',PK504FltData_Count)
        # print('PK502总报警=',PK502FltData_Count)
        # print('PK500总报警=',PK500FltData_Count)
        # print('格林美总报警=',MGMCLFltData_Count)
        # print('自研总报警=',MGMLXFltData_Count)
        FltAlarmInfo=DataFrame(columns=['SftyPlt_Data_Total','CS_Warning_Total_Finish_Count','SftyPlt_Data_day','CS_Warning_day_Finish_Count','SftyPlt_EmgcyData_day','SftyPlt_EmgcyData_day_Finish_Count','OprationManageRate','OprationManageEmgcyRate'])
        Celltype=DataFrame(columns=['PK504','PK502','PK500','MGMCL','MGMLX'])
        FltAlarmInfo.loc[0]=[SftyPlt_Data_Total,CS_Warning_Total_Finish_Count,SftyPlt_Data_day,CS_Warning_day_Finish_Count,SftyPlt_EmgcyData_day_Count,SftyPlt_EmgcyData_day_Finish_Count,OprationManageRate,OprationManageEmgcyRate]
        Celltype.loc[0]=[PK504FltData_Count,PK502FltData_Count,PK500FltData_Count,MGMCLFltData_Count,MGMLXFltData_Count]
        return FltAlarmInfo,Celltype
    def WeekInfoSta(df_fltinfo,start_time,end_time):
        df_fltinfo=df_fltinfo[df_fltinfo['start_time']>=start_time]
        FaultLvlCount=DataFrame(columns=['level','count'])
        FaultLvlCount=df_fltinfo.groupby('level').count().T.head(1).T
        FaultLvlCount=FaultLvlCount.reset_index(drop=False)
        
        return FaultLvlCount
    def SftyWrngClsfy(df_fltinfo):
        DsnSaftyCode=[]
        DataSaftyCode=[]
        SamplingSaftyCode=[2,10,50,53,54,55,56]
        HvSaftyCode=[]
        SysSaftyCode=[]
        CellSaftyCode=[3,5,6,7,8,9,10,11,13,14,15,16,17,19,20,21,15,16,17,19,23,24,25,26,29,30,31,51,119]
        CtrlSatyCode=[4,12,18,20,21,22]
        StateSaftyCode=[27,28,52]
        
        DsnSaftyCodeCount=len(df_fltinfo[df_fltinfo['code'].isin(DsnSaftyCode)])
        DataSaftyCodeCount=len(df_fltinfo[df_fltinfo['code'].isin(DataSaftyCode)])
        HvSaftyCodeCount=len(df_fltinfo[df_fltinfo['code'].isin(HvSaftyCode)])
        SysSaftyCodeCount=len(df_fltinfo[df_fltinfo['code'].isin(SysSaftyCode)])
        SamplingSatyCount=len(df_fltinfo[df_fltinfo['code'].isin(SamplingSaftyCode)])
        CellSaftyCount=len(df_fltinfo[df_fltinfo['code'].isin(CellSaftyCode)])
        CtrlSaftyCodeCount=len(df_fltinfo[df_fltinfo['code'].isin(CtrlSatyCode)])
        StateSaftyCodeCount=len(df_fltinfo[df_fltinfo['code'].isin(StateSaftyCode)])
        SatftyCount=DataFrame(columns=['DsnSaftyCodeCount','DataSaftyCodeCount','HvSaftyCodeCount','SysSaftyCodeCount','SamplingSatyCount','CellSaftyCount','CtrlSaftyCodeCount','StateSaftyCodeCount'])
        SatftyCount.loc[0]=[DsnSaftyCodeCount,DataSaftyCodeCount,HvSaftyCodeCount,SysSaftyCodeCount,SamplingSatyCount,CellSaftyCount,CtrlSaftyCodeCount,StateSaftyCodeCount]
        # print('设计安全分数为',DsnSaftyCodeCount)
        # print('数据安全分数为',DataSaftyCodeCount)
        # print('高压安全分数为',HvSaftyCodeCount)
        # print('系统安全分数为',SysSaftyCodeCount)
        # print('采样安全分数为',SamplingSatyCount)
        # print('电芯安全分数为',CellSaftyCount)
        # print('控制安全分数为',CtrlSaftyCodeCount)
        # print('状态安全分数为',StateSaftyCodeCount)
        # print('---------------------------------------------------------------------------')
        return SatftyCount
    def AccumInfo(df_last_accum,df_FirstDataTime,end_time):
        df_last_accum=df_last_accum[~df_last_accum['devcode'].str.contains('TJMCL')]
        MaxAccumAh=df_last_accum['dsg_ahaccum'].max()
        TotalAccumAh=df_last_accum['dsg_ahaccum'].sum()
        PK504_Ah=df_last_accum[df_last_accum['devcode'].str.contains('PK504')]
        PK504_Ah_Max=(PK504_Ah['dsg_ahaccum'].max())/60
        PK502_Ah=df_last_accum[df_last_accum['devcode'].str.contains('PK502')]
        PK502_Ah_Max=(PK502_Ah['dsg_ahaccum'].max())/40
        PK500_Ah=df_last_accum[df_last_accum['devcode'].str.contains('PK500')]
        PK500_Ah_Max=(PK500_Ah['dsg_ahaccum'].max())/40
        MGMCL_Ah=df_last_accum[df_last_accum['devcode'].str.contains('MGMCL')]
        MGMCL_Ah_Max=(MGMCL_Ah['dsg_ahaccum'].max())/50
        MGMLX_Ah=df_last_accum[df_last_accum['devcode'].str.contains('MGMLX')]
        MGMLX_Ah_Max=(MGMLX_Ah['dsg_ahaccum'].max())/50
        MaxCycle=round(max(PK504_Ah_Max,PK502_Ah_Max,PK500_Ah_Max,MGMCL_Ah_Max,MGMLX_Ah_Max),0)
        deltatimeMax=0
        deltatime=DataFrame(columns=['runningdate'])
        df_FirstDataTime=df_FirstDataTime.dropna(how='any')
        df_FirstDataTime=df_FirstDataTime.reset_index(drop=False)
        for i in range(0,len(df_FirstDataTime)):
            End_time=datetime.datetime.now()
            df_FirstDataTime.loc[i,'first_data_time']=df_FirstDataTime.loc[i,'first_data_time'].strftime('%Y-%m-%d')
            df_FirstDataTime.loc[i,'first_data_time']=datetime.datetime.strptime(df_FirstDataTime.loc[i,'first_data_time'],'%Y-%m-%d')
            deltatime.loc[i,'runningdate']=(End_time-df_FirstDataTime.loc[i,'first_data_time'])
            deltatime.loc[i,'runningdate']= deltatime.loc[i,'runningdate'].total_seconds()/3600
        MaxRunningHour=int(deltatime['runningdate'].max())
        TotalRunHour=int(deltatime['runningdate'].sum())
        return MaxAccumAh,TotalAccumAh,MaxCycle,MaxRunningHour,TotalRunHour

    def FltBatPosition(df_last_pos,df_Diag_Ram):
        all_location_info=DataFrame(columns=['factory','product_id','lat','lon'])
        df_last_pos.rename(columns={'devcode':'product_id'},inplace=True)
        df_Diag_Ram_Pos=pd.concat([df_Diag_Ram,df_last_pos,df_last_pos]).drop_duplicates(subset=['product_id'],keep=False)
        
        df_Diag_Ram_Pos=df_Diag_Ram_Pos.reset_index(drop=True)

        for i in range(0,len(df_Diag_Ram_Pos)):
                pos_la_temp=df_last_pos[df_last_pos['product_id']==(df_Diag_Ram_Pos.loc[i,'product_id'])]
                all_location_info[i,'lat']=pos_la_temp['latitude']
                all_location_info[i,'lon']=pos_la_temp['longitude']
                all_location_info[i,'factory']='骑享'
                all_location_info[i,'product_id']=df_Diag_Ram.loc[i,'product_id']
        
        print(all_location_info)
        return all_location_info