package cache
|
|
import (
|
"basic.com/valib/logger.git"
|
"ruleModelEngine/db"
|
)
|
|
var Device = make(map[string]db.Device)
|
var PublicHouse = make(map[string]map[string]string, 0) // 公租房数据 身份证号:小区
|
var PublicHouseAlarmCache = make(map[string]struct{}, 0) // 保存申住不一的数据, 同一个身份证号暂时报警一次
|
|
func DeviceCacheInit() error {
|
var err error
|
var Devices []db.Device
|
Devices, err = db.GetDeviceData()
|
if err != nil {
|
logger.Error("GetDeviceData", err)
|
return err
|
}
|
for _, device := range Devices {
|
Device[device.DeviceCode] = device
|
}
|
return nil
|
}
|
|
func PublicHouseCacheInit() error {
|
ph, err := db.GetPublicHouseData()
|
if err != nil {
|
logger.Error("GetDeviceData", err)
|
return err
|
}
|
|
for _, v := range ph {
|
if _, ok := PublicHouse[v.CommunityID]; !ok {
|
PublicHouse[v.CommunityID] = make(map[string]string, 0)
|
}
|
|
PublicHouse[v.CommunityID][v.IdCard] = v.EndTime
|
}
|
|
return nil
|
}
|
