From 5b84285b7b1feec082deaeb12d8a2240a0c4b64b Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 21 九月 2023 16:23:34 +0800
Subject: [PATCH] 获取任务，未完成的开始时间小于等于当前时间，结束时间大于当前时间的任务
---
service/task.go | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/service/task.go b/service/task.go
index 372c164..c07bbc8 100644
--- a/service/task.go
+++ b/service/task.go
@@ -23,7 +23,7 @@
return &TaskService{}
}
-// GetTask 鑾峰彇浠诲姟锛屾湭瀹屾垚鐨勫紑濮嬫椂闂存渶鏃╃殑浠诲姟
+// GetTask 鑾峰彇浠诲姟锛屾湭瀹屾垚鐨勫紑濮嬫椂闂村皬浜庣瓑浜庡綋鍓嶆椂闂达紝缁撴潫鏃堕棿澶т簬褰撳墠鏃堕棿
func (slf TaskService) GetTask(page, pageSize int) (taskResp *response.TaskResponse, code int) {
var taskList []*response.TaskData
var count int64
@@ -37,6 +37,7 @@
)
procedures, err = model.NewProceduresSearch(nil).SetOrder("start_time asc").
SetStartTimeMax(nowTs).
+ SetEndTimeMin(nowTs).
SetDeviceId(conf.Conf.System.DeviceId).
SetStatusNot(model.ProcedureStatusFinished).
SetPage(page, pageSize).
@@ -116,7 +117,7 @@
func (slf TaskService) UpdateProcedureStatusAndPosition(db *gorm.DB, id int, status model.ProcedureStatus, position int) error {
if status == model.ProcedureStatusFinished {
- ProgressCacheUnset()
+ ProgressCacheUnset(position)
}
return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{
"status": status,
@@ -124,9 +125,9 @@
})
}
-func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id int, status model.ProcedureStatus) error {
+func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id int, status model.ProcedureStatus, position int) error {
if status == model.ProcedureStatusFinished {
- ProgressCacheUnset()
+ ProgressCacheUnset(position)
}
return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{
"status": status,
--
Gitblit v1.8.0