FranklinWH-Toolbox/service/repositories/repositories.go

package repositories

import (
	"fwh-toolbox-server/repositories/api/fwh_pro"
	"fwh-toolbox-server/repositories/api/smartHub"
	"fwh-toolbox-server/repositories/events"
	"fwh-toolbox-server/repositories/mongo"
	"fwh-toolbox-server/repositories/mqtt/fwh_mqtt"
	pgsql_alarmSnapshot "fwh-toolbox-server/repositories/pgsql/alarmSnapshot"
	pgsql_original "fwh-toolbox-server/repositories/pgsql/original"
	"fwh-toolbox-server/repositories/redis"
)

// 聚合包

/*************** API ***************/
// fwh_pro
type EventAlarmType = fwh_pro.EventAlarmType

const (
	EventAndAlarm EventAlarmType = fwh_pro.All   // 0
	Event         EventAlarmType = fwh_pro.Event // 1
	Alarm         EventAlarmType = fwh_pro.Alarm // 2
)

var FwhHttpInit = fwh_pro.FwhHttpInit

var QuerySiteBaseInfoList = fwh_pro.QuerySiteBaseInfoList
var QuerySiteInfoList = fwh_pro.QuerySiteInfoList
var QuerySiteList = fwh_pro.QuerySiteList
var QuerySiteModeInfo = fwh_pro.QuerySiteModeInfo
var QuerySitePowerFlow = fwh_pro.QuerySitePowerFlow
var QuerySiteAlarmList = fwh_pro.QuerySiteAlarmList

var QueryEventOrAlarmListOnTimeRange = fwh_pro.QueryEventOrAlarmListOnTimeRange
var QueryAlarmSnapshotInfo = fwh_pro.QueryAlarmSnapshotInfo

var QueryMqttLogListOnTimeRange = fwh_pro.QueryMqttLogListOnTimeRange

var QuerySiteShutdownList = fwh_pro.QuerySiteShutdownList

var QueryAlarmStatistics = fwh_pro.QueryAlarmStatistics
var QueryAlarmStatisticsFromCode = fwh_pro.QueryAlarmStatisticsFromCode

// fwh_emsLog
var QueryCallEmsLog = fwh_pro.QueryCallEmsLog                 // 召唤EMS日志
var QueryEmsLogCallRecord = fwh_pro.QueryEmsLogCallRecord     // 查询EMS日志下载地址
var QueryDownloadEmsLogFile = fwh_pro.QueryDownloadEmsLogFile // 请求下载EMS日志文件

// fwh_faultRecord
var QueryFaultRecordList = fwh_pro.QueryFaultRecordList                     // 查询故障录波日志
var QueryFaultRecordCallableList = fwh_pro.QueryFaultRecordCallableList     // 查询设备可召唤数据列表 - 仅自动录播
var QueryCellFaultRecord = fwh_pro.QueryCellFaultRecord                     // 召唤故障录波日志
var QueryFaultRecordCallRecordList = fwh_pro.QueryFaultRecordCallRecordList // 查询故障录波召唤记录
var QueryFaultRecordSubList = fwh_pro.QueryFaultRecordSubList               // 查询故障录波子记录
var QueryDownloadFaultRecordData = fwh_pro.QueryDownloadFaultRecordData     // 请求下载录波数据

// fwh_update
var QuerySystemUpdateLog = fwh_pro.QuerySystemUpdateLog             // 查询系统升级记录
var QuerySystemUpdateLogDetail = fwh_pro.QuerySystemUpdateLogDetail // 查询系统升级记录详细信息
var QueryAHubUpdateLog = fwh_pro.QueryAHubUpdateLog                 // 查询aHub升级记录

// SmartHub
var QuerySmartHubBatchSimCardInfo = smartHub.QueryBatchSimCardInfo // 批量查询SIM卡信息

/*************** EVENTS ***************/
// Xlog
var GetXlogManageList = events.GetXlogManageList
var SendXlogCmd = events.SendXlogCmd

/*************** MONGO ***************/
// UserInfo
var UserInfoReadAllConfig = mongo.UserInfoReadAllConfig
var UserInfoUpdateAllConfig = mongo.UserInfoUpdateAllConfig
var UserInfoReadSiteInfoManageConfig = mongo.UserInfoReadSiteInfoManageConfig
var UserInfoUpdateSiteInfoManageConfig = mongo.UserInfoUpdateSiteInfoManageConfig
var UserInfoUpdateSiteInfoManageConfigTitleFilter = mongo.UserInfoUpdateSiteInfoManageConfigTitleFilter
var UserInfoUpdateSiteInfoManageConfigCustomQueryFilter = mongo.UserInfoUpdateSiteInfoManageConfigCustomQueryFilter

// SiteMonitor
var GetSiteMonitorConfig = mongo.GetSiteMonitorConfig
var GetSiteMonitorNameList = mongo.GetSiteMonitorNameList
var GetOneSiteMonitorConfig = mongo.GetOneSiteMonitorConfig
var InsertSiteMonitorConfig = mongo.InsertSiteMonitorConfig
var UpdateSiteMonitorConfig = mongo.UpdateSiteMonitorConfig
var DeleteSiteMonitorConfig = mongo.DeleteSiteMonitorConfig
var UpdateSiteMonitorPageConfig = mongo.UpdateSiteMonitorPageConfig

// SiteAnalysis
var GetSiteAnalysisManageList = mongo.GetSiteAnalysisManageList
var GetSiteAnalysisConfig = mongo.GetSiteAnalysisConfig
var InsertSiteAnalysisConfig = mongo.InsertSiteAnalysisConfig
var UpdateSiteAnalysisConfig = mongo.UpdateSiteAnalysisConfig
var UpdateSiteAnalysisDescription = mongo.UpdateSiteAnalysisDescription
var UpdateSiteAnalysisResult = mongo.UpdateSiteAnalysisResult
var DeleteSiteAnalysisConfig = mongo.DeleteSiteAnalysisConfig
var InsertSiteAnalysisData = mongo.InsertSiteAnalysisData
var InsertSiteAnalysisTimeline = mongo.InsertSiteAnalysisTimeline
var InsertSiteAnalysisRuntime = mongo.InsertSiteAnalysisRuntime

// StatisticsShutdown
var GetStatisticsShutdown = mongo.GetStatisticsShutdown
var GetLatestStatisticsShutdown = mongo.GetLatestStatisticsShutdown
var GetStatisticsShutdownByDateRange = mongo.GetStatisticsShutdownByDateRange
var InsertStatisticsShutdown = mongo.InsertStatisticsShutdown

// StatisticsAlarm
var GetStatisticsAlarm = mongo.GetStatisticsAlarm
var GetLatestStatisticsAlarm = mongo.GetLatestStatisticsAlarm
var GetStatisticsAlarmByDateRange = mongo.GetStatisticsAlarmByDateRange
var InsertStatisticsAlarm = mongo.InsertStatisticsAlarm

// BatchDownload
var GetBatchDownloadManageList = mongo.GetBatchDownloadManageList
var GetBatchDownloadConfig = mongo.GetBatchDownloadConfig
var InsertBatchDownloadConfig = mongo.InsertBatchDownloadConfig
var UpdateBatchDownloadDescription = mongo.UpdateBatchDownloadDescription
var UpdateBatchDownloadOwner = mongo.UpdateBatchDownloadOwner
var UpdateBatchDownloadResult = mongo.UpdateBatchDownloadResult
var DeleteBatchDownloadConfig = mongo.DeleteBatchDownloadConfig
var InsertBatchDownloadData = mongo.InsertBatchDownloadData
var GetBatchDownloadData = mongo.GetBatchDownloadData
var InsertBatchDownloadPathPowerFlow = mongo.InsertBatchDownloadPathPowerFlow
var InsertBatchDownloadPathMqttLogs = mongo.InsertBatchDownloadPathMqttLogs
var InsertBatchDownloadPathEventAlarm = mongo.InsertBatchDownloadPathEventAlarm
var InsertBatchDownloadPathEmsLogs = mongo.InsertBatchDownloadPathEmsLogs
var InsertBatchDownloadPathFaultRecord = mongo.InsertBatchDownloadPathFaultRecord
var InsertBatchDownloadPathAlarmSnapshot = mongo.InsertBatchDownloadPathAlarmSnapshot
var InsertBatchDownloadPathUpdateLog = mongo.InsertBatchDownloadPathUpdateLog
var InsertBatchDownloadPathSettings = mongo.InsertBatchDownloadPathSettings

// AutoUpdateConfig
var GetAutoUpdateConfigOption = mongo.GetAutoUpdateConfigOption
var GetAutoUpdatePackages = mongo.GetAutoUpdatePackages
var CreateAutoUpdatePackage = mongo.CreateAutoUpdatePackage
var UpdateAutoUpdatePackage = mongo.UpdateAutoUpdatePackage
var DeleteAutoUpdatePackage = mongo.DeleteAutoUpdatePackage
var GetAutoUpdateAPowerVersion = mongo.GetAutoUpdateAPowerVersion
var UpdateAutoUpdateAPowerVersion = mongo.UpdateAutoUpdateAPowerVersion
var DeleteAutoUpdateAPowerVersion = mongo.DeleteAutoUpdateAPowerVersion
var GetAutoUpdateConfig = mongo.GetAutoUpdateConfig
var UpdateAutoUpdateConfig = mongo.UpdateAutoUpdateConfig
var DeleteAutoUpdateConfig = mongo.DeleteAutoUpdateConfig
var CreateAutoUpdateSpecialConfig = mongo.CreateAutoUpdateSpecialConfig
var DeleteAutoUpdateSpecialConfig = mongo.DeleteAutoUpdateSpecialConfig

// SiteInfoManage
var CreateSiteInfoUpdateInfo = mongo.CreateSiteInfoUpdateInfo
var UpdateSiteInfoUpdateResult = mongo.UpdateSiteInfoUpdateResult
var GetSiteInfoUpdateNewRecord = mongo.GetSiteInfoUpdateNewRecord
var GetSiteInfoManageList = mongo.GetSiteInfoManageList
var InsertSiteInfoData = mongo.InsertSiteInfoData

/*************** PGSQL ***************/

// Alarm Snapshot
var QuerySnapshotFileRecord = pgsql_alarmSnapshot.QuerySnapshotFileRecord
var InsertSnapshotFileRecord = pgsql_alarmSnapshot.InsertSnapshotFileRecord
var QuerySnapshotData = pgsql_alarmSnapshot.QuerySnapshotData
var InsertSnapshotData = pgsql_alarmSnapshot.InsertSnapshotData

// Original
type QuerySitesAnalysisRecord = pgsql_original.QuerySitesAnalysisRecord

var CreateSitesAnalysisRecordTable = pgsql_original.CreateSitesAnalysisRecordTable

/*************** MYSQL ***************/

/*************** REDIS ***************/

// Auth
type SessionInfo = redis.SessionInfo

var StoreSession = redis.StoreSession
var GetSession = redis.GetSession
var DeleteSession = redis.DeleteSession

// BatchDownload
var CreateBatchDownloadCallFileTaskList = redis.CreateCallFileTaskList
var GetBatchDownloadCallFileTaskStandbyList = redis.GetCallFileTaskStandbyList
var GetBatchDownloadCallFileTaskFailedList = redis.GetCallFileTaskFailedList
var DeleteBatchDownloadCallFileTaskList = redis.DeleteCallFileTaskList
var UpdateBatchDownloadCallFileResult = redis.UpdateCallFileResult

// EMS Para
var UpdateEmspara = redis.UpdateEmspara
var GetEmsparaVidInfo = redis.GetEmsparaVidInfo
var GetEmsparaPidInfo = redis.GetEmsparaPidInfo

// AutoUpdateConfig
var RefreshAutoUpdateConfigFileInfo = redis.RefreshAutoUpdateConfigFileInfo
var GetAutoUpdateConfigFileInfoTotal = redis.GetAutoUpdateConfigFileInfoTotal
var GetAutoUpdateConfigFileInfoByPage = redis.GetAutoUpdateConfigFileInfoByPage

/*************** MQTT ***************/
// FwhMqtt
var FwhMqttInit = fwh_mqtt.InitFwhMqttClient
var FwhMqttEnableXlog = fwh_mqtt.EnableXlog