qixiaoning
22 小时以前 03880bf61cf059f063e252ef17dfea50c932c9dc
清理数据接口修改
2个文件已修改
31 ■■■■■ 已修改文件
camera-common/models/Record.go 13 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
camera-service/controllers/camera.go 18 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
camera-common/models/Record.go
@@ -260,34 +260,29 @@
                    VideoPath := VideoPathColumn[i]
                    videoPaths = append(videoPaths, VideoPath)
                }
            }
        }
    }
    // 图片删除文件
    deletedFiles := 0
    if len(ids) > 0 {
        idField := entity.NewColumnInt64("id", ids)
        err = do.client.client.DeleteByPks(ctx, collectionName, "", idField)
        if err != nil {
            return 0, fmt.Errorf("failed to delete from Milvus: %v", err)
        }
        deletedFiles = len(ids)
    }
    // 图片删除文件
    deletedFiles := 0
    for _, path := range imgPaths {
        if err := do.deleteFile(path); err != nil {
            logger.Debug("failed to delete file " + path + " " + err.Error())
        } else {
            deletedFiles++
        }
    }
    //删除描述图片
    for _, path := range imgDesPaths {
        if err := do.deleteFile(path); err != nil {
            logger.Debug("failed to delete file " + path + " " + err.Error())
        } else {
            deletedFiles++
        }
    }
@@ -295,8 +290,6 @@
    for _, path := range videoPaths {
        if err := do.deleteFile(path); err != nil {
            logger.Debug("failed to delete file " + path + " " + err.Error())
        } else {
            deletedFiles++
        }
    }
camera-service/controllers/camera.go
@@ -1068,8 +1068,12 @@
        return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
    }
    startTime := info.StartTime
    endTime := info.EndTime
    if len(startTime) > 0 && len(endTime) > 0 {
    if len(startTime) > 0 && len(info.EndTime) > 0 {
        endTime, err1 := addDaySimple(info.EndTime)
        if err1 != nil {
            endTime = info.EndTime
        }
        filter += fmt.Sprintf(" and detect_time > '%s'", startTime)
        filter += fmt.Sprintf(" and detect_time < '%s'", endTime)
        deleteRecord, err := models.DeleteRecord("smartobject", filter)
@@ -1083,6 +1087,16 @@
    }
}
func addDaySimple(dateStr string) (string, error) {
    // 假设格式为 "2006-01-02"
    t, err := time.Parse("2006-01-02", dateStr)
    if err != nil {
        return "", err
    }
    t = t.AddDate(0, 0, 1)
    return t.Format("2006-01-02"), nil
}
/**
 *  获取抓拍记录
 */