FranklinWH-Toolbox/service/repositories/repositories.go

package repositories

import (
	"fwh-toolbox-server/config"
	"fwh-toolbox-server/domain"
	"fwh-toolbox-server/repositories/api/acceleronix"
	"fwh-toolbox-server/repositories/api/fwh_es_mqtt"
	"fwh-toolbox-server/repositories/api/fwh_pro"
	"fwh-toolbox-server/repositories/api/fwh_test"
	"fwh-toolbox-server/repositories/api/plane_v1"
	"fwh-toolbox-server/repositories/api/plane_v2"
	"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"
)

// ============ Plane V2 新架构（PlaneService）============

// Plane Feedback 专用实例（绑定固定的 workspace/project/labels）
var Plane *plane_v2.FeedbackPlaneService

// InitPlane 初始化新架构 Plane（启动时调用） - 仅用于 fwh-toolbox 的 Feedback 模块
func InitPlane(cfg *config.PlaneWebApiConfig) {
	plane_v2.InitPlaneClient(cfg.Host, cfg.Email, cfg.Password)
	Plane = plane_v2.NewFeedbackPlaneService(cfg.WorkspaceSlug, cfg.ProjectId, cfg.LabelBugId, cfg.LabelFeatureId, cfg.LabelFeedbackId)
}

// 通用初始化接口（给MCP Server等外部模块使用）
var InitPlaneClient = plane_v2.InitPlaneClient
var NewPlaneService = plane_v2.NewPlaneService

// 聚合包

/*************** 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 QueryCallEmsLogContext = fwh_pro.QueryCallEmsLogContext
var QueryEmsLogCallRecord = fwh_pro.QueryEmsLogCallRecord // 查询EMS日志下载地址
var QueryEmsLogCallRecordAfter = fwh_pro.QueryEmsLogCallRecordAfter
var QueryEmsLogCallRecordAfterContext = fwh_pro.QueryEmsLogCallRecordAfterContext
var LatestEmsLogCallRecordID = fwh_pro.LatestEmsLogCallRecordID
var LatestEmsLogCallRecordIDContext = fwh_pro.LatestEmsLogCallRecordIDContext
var QueryDownloadEmsLogFile = fwh_pro.QueryDownloadEmsLogFile // 请求下载EMS日志文件
var QueryDownloadEmsLogFileContext = fwh_pro.QueryDownloadEmsLogFileContext

// fwh_faultRecord
var QueryFaultRecordList = fwh_pro.QueryFaultRecordList                     // 查询故障录波日志
var QueryFaultRecordCallableList = fwh_pro.QueryFaultRecordCallableList     // 查询设备可召唤数据列表 - 仅自动录播
var QueryCellFaultRecord = fwh_pro.QueryCellFaultRecord                     // 召唤故障录波日志
var QueryFaultRecordCallRecordList = fwh_pro.QueryFaultRecordCallRecordList // 查询故障录波召唤记录
var QueryFaultRecordCallRecordPage = fwh_pro.QueryFaultRecordCallRecordPage // 分页查询故障录波召唤记录
var QueryFaultRecordCallRecordPageContext = fwh_pro.QueryFaultRecordCallRecordPageContext
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升级记录

// fwh_touTemplate
var QueryTouTemplateInfoList = fwh_pro.QueryTouTemplateInfoList // 查询模板列表
var QueryTouTemplateDetailInfo = fwh_pro.QueryTouTemplateDetailInfo

// ============ fwh_test（测试环境 API，与 fwh_pro 平行）============
type FwhTestEventAlarmType = fwh_test.EventAlarmType

const (
	FwhTestEventAndAlarm FwhTestEventAlarmType = fwh_test.All   // 0
	FwhTestEvent         FwhTestEventAlarmType = fwh_test.Event // 1
	FwhTestAlarm         FwhTestEventAlarmType = fwh_test.Alarm // 2
)

var FwhTestHttpInit = fwh_test.FwhHttpInit
var FwhTestLogin = fwh_test.Login

var FwhTestQuerySiteBaseInfoList = fwh_test.QuerySiteBaseInfoList
var FwhTestQuerySiteInfoList = fwh_test.QuerySiteInfoList
var FwhTestQuerySiteList = fwh_test.QuerySiteList
var FwhTestQuerySiteModeInfo = fwh_test.QuerySiteModeInfo
var FwhTestQuerySitePowerFlow = fwh_test.QuerySitePowerFlow
var FwhTestQuerySiteAlarmList = fwh_test.QuerySiteAlarmList

var FwhTestQueryEventOrAlarmListOnTimeRange = fwh_test.QueryEventOrAlarmListOnTimeRange
var FwhTestQueryAlarmSnapshotInfo = fwh_test.QueryAlarmSnapshotInfo

var FwhTestQueryMqttLogListOnTimeRange = fwh_test.QueryMqttLogListOnTimeRange

var FwhTestQuerySiteShutdownList = fwh_test.QuerySiteShutdownList

var FwhTestQueryAlarmStatistics = fwh_test.QueryAlarmStatistics
var FwhTestQueryAlarmStatisticsFromCode = fwh_test.QueryAlarmStatisticsFromCode

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

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

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

// fwh_touTemplate
var FwhTestQueryTouTemplateInfoList = fwh_test.QueryTouTemplateInfoList // 查询模板列表
var FwhTestQueryTouTemplateDetailInfo = fwh_test.QueryTouTemplateDetailInfo
var FwhTestUpdateOrSaveTouTemplate = fwh_test.UpdateOrSaveTouTemplate // 新增/更新模板
var FwhTestSelectCitesList = fwh_test.SelectCitesList                 // 查询国家下的省/市列表

// SmartHub
var QuerySmartHubBatchSimCardInfo = smartHub.QueryBatchSimCardInfo // 批量查询SIM卡信息
var QuerySmartHubSimCardInfo = smartHub.QuerySimCardInfo           // 获取SIM卡详细信息

// Acceleronix
var QueryAcceleronixSimCardList = acceleronix.QuerySimCardList                   // 查询SIM卡列表
var QueryAcceleronixSimCardInfo = acceleronix.QuerySimCardInfo                   // 查询SIM卡详情
var QueryAcceleronixBatchSimCardDataInfo = acceleronix.QueryBatchSimCardDataInfo // 批量获取SIM卡数据用量信息
var QueryAcceleronixDataPoolList = acceleronix.QueryDataPoolList                 // 查询流量池列表
var QueryAcceleronixDataPoolSimInfo = acceleronix.QueryDataPoolSimInfo           // 查询流量池SIM详情

// ============ fwh_es_mqtt（iotcore-stat Elasticsearch 报文统计）============
// 说明：站点即 equipNo（设备号）。看板 + 逐条查询。

// 类型/参数导出
type EsQueryMessageParam = fwh_es_mqtt.QueryMessageParam

var EsHttpInit = fwh_es_mqtt.EsHttpInit // 初始化 ES HTTP 客户端（启动时调用）

// 看板 - 报文总量
var EsGetDailyMessageTotal = fwh_es_mqtt.GetDailyMessageTotal     // 日总量
var EsGetMonthlyMessageTotal = fwh_es_mqtt.GetMonthlyMessageTotal // 月总量

// 看板 - 站点总量（分页降序）
var EsGetSiteMonthlyTotals = fwh_es_mqtt.GetSiteMonthlyTotals           // 站点月总量
var EsGetSiteDailyTotals = fwh_es_mqtt.GetSiteDailyTotals               // 站点日总量
var EsGetSiteDailyTotalsInMonth = fwh_es_mqtt.GetSiteDailyTotalsInMonth // 下钻：站点本月每日总量
var EsGetMonthlyDailyTrend = fwh_es_mqtt.GetMonthlyDailyTrend           // 全站本月每日总量（看板月度趋势图）
var EsGetSiteCmdTypeTotals = fwh_es_mqtt.GetSiteCmdTypeTotals           // 下钻：站点当日各命令类型总量

// 查询 - 逐条原始报文
var EsQueryMessages = fwh_es_mqtt.QueryMessages // 按过滤条件查询逐条报文（默认当天，按时间降序）

// ErrEsDeepPaging 逐条查询深分页超出 ES 窗口上限的哨兵错误（供 controller 识别并返回 400 友好提示）
var ErrEsDeepPaging = fwh_es_mqtt.ErrDeepPaging

// EsMaxMessagePageWindow 逐条查询 from+size 上限（ES max_result_window）
const EsMaxMessagePageWindow = fwh_es_mqtt.MaxMessagePageWindow

// Plane_V1
type PlaneConfig = plane_v1.PlaneConfig
type PlaneIntakeIssueRequest = plane_v1.IntakeIssueRequest
type PlaneIntakeIssue = plane_v1.IntakeIssue
type PlaneIntakeIssueResponse = plane_v1.IntakeIssueResponse
type PlaneIntakeListResponse = plane_v1.IntakeListResponse
type PlaneIntakeListItem = plane_v1.IntakeListItem
type PlaneIntakeIssueInfo = plane_v1.IntakeIssueInfo
type PlaneAssetUploadResult = plane_v1.AssetUploadResult
type PlaneAttachmentCreateResponse = plane_v1.AttachmentCreateResponse

var PlaneHttpInit = plane_v1.PlaneHttpInit              // 初始化Plane HTTP客户端
var PlaneGetLabelBugId = plane_v1.GetLabelBugId         // 获取Bug标签ID
var PlaneGetLabelFeatureId = plane_v1.GetLabelFeatureId // 获取Feature标签ID

// Plane_V1 - User
var PlaneGetMe = plane_v1.GetMe // 获取当前用户信息

// Plane_V1 - Project
var PlaneListProjects = plane_v1.ListProjects           // 列出项目
var PlaneCreateProject = plane_v1.CreateProject         // 创建项目
var PlaneGetProject = plane_v1.GetProject               // 获取项目详情
var PlaneUpdateProject = plane_v1.UpdateProject         // 更新项目
var PlaneDeleteProject = plane_v1.DeleteProject         // 删除项目
var PlaneArchiveProject = plane_v1.ArchiveProject       // 归档项目
var PlaneUnarchiveProject = plane_v1.UnarchiveProject   // 取消归档项目
var PlaneGetProjectSummary = plane_v1.GetProjectSummary // 获取项目摘要

// Plane_V1 - Work Item
var PlaneListWorkItems = plane_v1.ListWorkItems                     // 列出工作项
var PlaneCreateWorkItem = plane_v1.CreateWorkItem                   // 创建工作项
var PlaneGetWorkItem = plane_v1.GetWorkItem                         // 获取工作项详情
var PlaneUpdateWorkItem = plane_v1.UpdateWorkItem                   // 更新工作项
var PlaneDeleteWorkItem = plane_v1.DeleteWorkItem                   // 删除工作项
var PlaneGetWorkItemByIdentifier = plane_v1.GetWorkItemByIdentifier // 通过标识符获取工作项
var PlaneSearchWorkItems = plane_v1.SearchWorkItems                 // 搜索工作项

// Plane_V1 - Work Item Link
var PlaneListWorkItemLinks = plane_v1.ListWorkItemLinks   // 列出链接
var PlaneCreateWorkItemLink = plane_v1.CreateWorkItemLink // 创建链接
var PlaneGetWorkItemLink = plane_v1.GetWorkItemLink       // 获取链接详情
var PlaneUpdateWorkItemLink = plane_v1.UpdateWorkItemLink // 更新链接
var PlaneDeleteWorkItemLink = plane_v1.DeleteWorkItemLink // 删除链接

// Plane_V1 - Work Item Comment
var PlaneListWorkItemComments = plane_v1.ListWorkItemComments   // 列出评论
var PlaneCreateWorkItemComment = plane_v1.CreateWorkItemComment // 创建评论
var PlaneGetWorkItemComment = plane_v1.GetWorkItemComment       // 获取评论详情
var PlaneUpdateWorkItemComment = plane_v1.UpdateWorkItemComment // 更新评论
var PlaneDeleteWorkItemComment = plane_v1.DeleteWorkItemComment // 删除评论

// Plane_V1 - Work Item Activity
var PlaneListWorkItemActivities = plane_v1.ListWorkItemActivities // 列出活动历史
var PlaneGetWorkItemActivity = plane_v1.GetWorkItemActivity       // 获取单条活动

// Plane_V1 - Work Item Attachment
var PlaneListWorkItemAttachments = plane_v1.ListWorkItemAttachments     // 列出附件
var PlaneCreateWorkItemAttachment = plane_v1.CreateWorkItemAttachment   // 创建附件(获取预签名URL)
var PlaneConfirmWorkItemAttachment = plane_v1.ConfirmWorkItemAttachment // 确认附件上传
var PlaneDeleteWorkItemAttachment = plane_v1.DeleteWorkItemAttachment   // 删除附件
var PlaneUploadWorkItemAttachment = plane_v1.UploadWorkItemAttachment   // 完整附件上传流程

// Plane_V1 - Work Item Relation
var PlaneListWorkItemRelations = plane_v1.ListWorkItemRelations   // 列出关系
var PlaneCreateWorkItemRelation = plane_v1.CreateWorkItemRelation // 创建关系

// Plane_V1 - Intake
var PlaneCreateIntakeIssue = plane_v1.CreateIntakeIssue       // 创建Intake Issue
var PlaneGetIntakeIssueList = plane_v1.GetIntakeIssueList     // 查询Intake Issue列表
var PlaneGetIntakeIssueDetail = plane_v1.GetIntakeIssueDetail // 获取Intake Issue详情
var PlaneUpdateIntakeIssue = plane_v1.UpdateIntakeIssue       // 更新Intake Issue
var PlaneAcceptIntakeIssue = plane_v1.AcceptIntakeIssue       // 接受Intake Issue
var PlaneRejectIntakeIssue = plane_v1.RejectIntakeIssue       // 拒绝Intake Issue
var PlaneDeleteIntakeIssue = plane_v1.DeleteIntakeIssue       // 删除Intake Issue

// Plane_V1 - Asset
var PlaneUploadAsset = plane_v1.UploadAsset // 上传Asset文件
var PlaneDeleteAsset = plane_v1.DeleteAsset // 删除Asset文件

// Plane_V1 - Cycle
var PlaneListCycles = plane_v1.ListCycles                     // 列出迭代
var PlaneCreateCycle = plane_v1.CreateCycle                   // 创建迭代
var PlaneGetCycle = plane_v1.GetCycle                         // 获取迭代详情
var PlaneUpdateCycle = plane_v1.UpdateCycle                   // 更新迭代
var PlaneDeleteCycle = plane_v1.DeleteCycle                   // 删除迭代
var PlaneListCycleIssues = plane_v1.ListCycleIssues           // 列出迭代工作项
var PlaneAddIssuesToCycle = plane_v1.AddIssuesToCycle         // 添加工作项到迭代
var PlaneRemoveIssueFromCycle = plane_v1.RemoveIssueFromCycle // 从迭代移除工作项
var PlaneTransferCycleIssues = plane_v1.TransferCycleIssues   // 转移迭代工作项
var PlaneArchiveCycle = plane_v1.ArchiveCycle                 // 归档迭代

// Plane_V1 - Module
var PlaneListModules = plane_v1.ListModules                     // 列出模块
var PlaneCreateModule = plane_v1.CreateModule                   // 创建模块
var PlaneGetModule = plane_v1.GetModule                         // 获取模块详情
var PlaneUpdateModule = plane_v1.UpdateModule                   // 更新模块
var PlaneDeleteModule = plane_v1.DeleteModule                   // 删除模块
var PlaneListModuleIssues = plane_v1.ListModuleIssues           // 列出模块工作项
var PlaneAddIssuesToModule = plane_v1.AddIssuesToModule         // 添加工作项到模块
var PlaneRemoveIssueFromModule = plane_v1.RemoveIssueFromModule // 从模块移除工作项
var PlaneArchiveModule = plane_v1.ArchiveModule                 // 归档模块

// Plane_V1 - State
var PlaneListStates = plane_v1.ListStates   // 列出状态
var PlaneCreateState = plane_v1.CreateState // 创建状态
var PlaneGetState = plane_v1.GetState       // 获取状态详情
var PlaneUpdateState = plane_v1.UpdateState // 更新状态
var PlaneDeleteState = plane_v1.DeleteState // 删除状态

// Plane_V1 - Label
var PlaneListLabels = plane_v1.ListLabels   // 列出标签
var PlaneCreateLabel = plane_v1.CreateLabel // 创建标签
var PlaneGetLabel = plane_v1.GetLabel       // 获取标签详情
var PlaneUpdateLabel = plane_v1.UpdateLabel // 更新标签
var PlaneDeleteLabel = plane_v1.DeleteLabel // 删除标签

// Plane_V1 - Member
var PlaneListWorkspaceMembers = plane_v1.ListWorkspaceMembers       // 列出工作空间成员
var PlaneListProjectMembers = plane_v1.ListProjectMembers           // 列出项目成员
var PlaneAddProjectMember = plane_v1.AddProjectMember               // 添加项目成员
var PlaneGetProjectMember = plane_v1.GetProjectMember               // 获取项目成员详情
var PlaneUpdateProjectMemberRole = plane_v1.UpdateProjectMemberRole // 更新项目成员角色
var PlaneRemoveProjectMember = plane_v1.RemoveProjectMember         // 移除项目成员

// Plane_V1 - Invitation
var PlaneListInvitations = plane_v1.ListInvitations   // 列出邀请
var PlaneCreateInvitation = plane_v1.CreateInvitation // 创建邀请
var PlaneGetInvitation = plane_v1.GetInvitation       // 获取邀请详情
var PlaneUpdateInvitation = plane_v1.UpdateInvitation // 更新邀请
var PlaneDeleteInvitation = plane_v1.DeleteInvitation // 撤销邀请

// Plane_V1 - Sticky
var PlaneListStickies = plane_v1.ListStickies // 列出便签
var PlaneCreateSticky = plane_v1.CreateSticky // 创建便签
var PlaneGetSticky = plane_v1.GetSticky       // 获取便签详情
var PlaneUpdateSticky = plane_v1.UpdateSticky // 更新便签
var PlaneDeleteSticky = plane_v1.DeleteSticky // 删除便签

// Plane_V2 Web API (Session + CSRF 认证)

// Plane V2 类型导出（兼容旧调用）
type PlaneWebIntakeIssueRequest = plane_v2.WebIntakeIssueRequest
type PlaneWebIntakeIssueResponse = plane_v2.WebIntakeIssueResponse
type PlaneWebAssetUploadResult = plane_v2.WebAssetUploadResult

const PlaneWebEntityIssueDescription = plane_v2.EntityIssueDescription

/*************** 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 InitBatchDownloadItems = mongo.InitBatchDownloadItems
var FinishBatchDownloadItem = mongo.FinishBatchDownloadItem
var GetBatchDownloadItems = mongo.GetBatchDownloadItems
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
var GetSiteInfoManageListFromGiccid = mongo.GetSiteInfoManageListFromGiccid
var GetSiteInfoTags = mongo.GetSiteInfoTags
var GetSiteInfoTagsFromId = mongo.GetSiteInfoTagsFromId
var UpdateSiteInfoTag = mongo.UpdateSiteInfoTag

// SimCardManage
var GetSimCardBatchInfo = mongo.GetSimCardBatchInfo
var GetSimCardInfo = mongo.GetSimCardInfo
var GetSimCardInfoByIDs = mongo.GetSimCardInfoByIDs
var GetSimCardMonthlyData = mongo.GetSimCardMonthlyData
var UpdateSimCardInfo = mongo.UpdateSimCardInfo
var UpdateSimCardBatchInfo = mongo.UpdateSimCardBatchInfo
var UpdateSimCardDayData = mongo.UpdateSimCardDayData
var UpdateSimCardBatchDayData = mongo.UpdateSimCardBatchDayData

/*************** 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

// AIChat - Redis
type AiSessionItem = redis.AiSessionItem
type AiActiveSession = redis.AiActiveSession

var SaveAiSession = redis.SaveAiSession
var GetAiSession = redis.GetAiSession
var DeleteAiSession = redis.DeleteAiSession
var SaveAiSessionList = redis.SaveAiSessionList
var GetAiSessionList = redis.GetAiSessionList
var DeleteAiSessionList = redis.DeleteAiSessionList
var UpdateAiSessionTitle = redis.UpdateAiSessionTitle

// AIChat - MongoDB
type AiChatSession = domain.AiChatSession

var UpsertAiChatSession = mongo.UpsertAiChatSession
var GetAiChatSessionsByUser = mongo.GetAiChatSessionsByUser
var UpdateAiChatSessionTitle = mongo.UpdateAiChatSessionTitle
var UpdateAiChatSessionActive = mongo.UpdateAiChatSessionActive
var DeactivateAllAiChatSessions = mongo.DeactivateAllAiChatSessions
var DeleteAiChatSession = mongo.DeleteAiChatSession

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

// FwhMqtt - Xlog
var FwhMqttEnableXlog = fwh_mqtt.EnableXlog

// FwhMqtt - Fault Record
var FwhMqttFaultRecordChargeChannel = fwh_mqtt.ChargeChannel
var FwhMqttFaultRecordParamSetting = fwh_mqtt.FaultRecordParamSetting