fix
zhangqian
2023-10-08 ab430aa505095accb2886060ef9f44107852852c
fix
1个文件已添加
2个文件已修改
7 ■■■■ 已修改文件
aps - 副本.db 补丁 | 查看 | 原始文档 | blame | 历史
model/procedures.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/cache_store.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
aps - 副本.db
Binary files differ
model/procedures.go
@@ -140,11 +140,6 @@
    return slf
}
func (slf *ProceduresSearch) SetChannel(channel int32) *ProceduresSearch {
    slf.Channel = channel
    return slf
}
func (slf *ProceduresSearch) build() *gorm.DB {
    var db = slf.Orm.Model(&Procedures{})
service/cache_store.go
@@ -92,7 +92,7 @@
    if v, ok := defaultCacheStore.Get(fmt.Sprintf(CurrentTaskCacheKey, channel)); ok {
        return v.(bool)
    }
    _, err := model.NewProceduresSearch(nil).SetDeviceId(conf.Conf.System.DeviceId).SetStatus(model.ProcedureStatusProcessing).SetChannel(channel).First()
    _, err := model.NewProceduresSearch(nil).SetDeviceId(conf.Conf.System.DeviceId).SetStatus(model.ProcedureStatusProcessing).SetChannels([]int32{channel}).First()
    if err == gorm.ErrRecordNotFound {
        defaultCacheStore.Add(fmt.Sprintf(CurrentTaskCacheKey, channel), false)
        return false