From 53d80c839ad2aad0a0482ca43fca1fc3a95b9d1c Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 03 十一月 2023 17:30:54 +0800
Subject: [PATCH] 更改路由
---
service/task.go | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/service/task.go b/service/task.go
index 8f6388d..bebd3ff 100644
--- a/service/task.go
+++ b/service/task.go
@@ -1,7 +1,6 @@
package service
import (
- "apsClient/conf"
"apsClient/constvar"
"apsClient/model"
"apsClient/model/common"
@@ -9,6 +8,7 @@
"apsClient/model/response"
"apsClient/pkg/ecode"
"apsClient/pkg/logx"
+ "apsClient/pkg/timex"
"fmt"
"github.com/jinzhu/gorm"
"time"
@@ -22,7 +22,7 @@
}
// GetTask 鑾峰彇浠诲姟锛屾湭瀹屾垚鐨勫紑濮嬫椂闂村皬浜庣瓑浜庡綋鍓嶆椂闂达紝缁撴潫鏃堕棿澶т簬褰撳墠鏃堕棿鐨勪换鍔�
-func (slf TaskService) GetTask(page, pageSize int, mode constvar.TaskMode, channels []int32) (taskResp *response.TaskResponse, code int) {
+func (slf TaskService) GetTask(deviceID string, page, pageSize int, mode constvar.TaskMode, channels []int32) (taskResp *response.TaskResponse, code int) {
var taskList []*response.TaskData
var count int64
var workers []*common.ProcedureWorker
@@ -40,7 +40,7 @@
workOrderIds []string
)
search := model.NewProceduresSearch(nil).
- SetDeviceId(conf.Conf.System.DeviceId).
+ SetDeviceId(deviceID).
SetPage(page, pageSize)
if mode == constvar.TaskModeUnStarted {
@@ -106,8 +106,8 @@
}
return taskResp, ecode.OK
}
-func (slf TaskService) NewTaskCount() (count int64) {
- count, _ = model.NewProceduresSearch(nil).SetDeviceId(conf.Conf.System.DeviceId).SetStatus(model.ProcedureStatusWaitProcess).Count()
+func (slf TaskService) NewTaskCount(deviceId string) (count int64) {
+ count, _ = model.NewProceduresSearch(nil).SetDeviceId(deviceId).SetStatus(model.ProcedureStatusWaitProcess).Count()
return count
}
@@ -204,7 +204,7 @@
}
// GetTask2 鑾峰彇浠诲姟鍒楄〃2
-func (slf TaskService) GetTask2(offset, limit int, channels []int32, queryType request.QueryType) (taskResp *response.TaskResponse, err error) {
+func (slf TaskService) GetTask2(deviceID string, offset, limit int, channels []int32, queryType request.QueryType) (taskResp *response.TaskResponse, err error) {
var taskList []*response.TaskData
var count int64
var workers []*common.ProcedureWorker
@@ -221,14 +221,14 @@
workOrderIds []string
)
search := model.NewProceduresSearch(nil).
- SetDeviceId(conf.Conf.System.DeviceId).
+ SetDeviceId(deviceID).
SetOffset(offset, limit).SetChannels(channels)
- nowTs := time.Now().Unix()
+ todayStartTs := timex.TodayStartTs()
switch queryType {
case request.QueryTypeUnFinish:
search.SetStatusNot(model.ProcedureStatusFinished).SetOrder("status desc, start_time asc")
case request.QueryTypeToday:
- search.SetStatusNot(model.ProcedureStatusFinished).SetStartTimeMin(nowTs).SetEndTimeMax(nowTs + 86400).SetOrder("status desc, start_time asc")
+ search.SetStatusNot(model.ProcedureStatusFinished).SetStartTimeMin(todayStartTs).SetEndTimeMax(todayStartTs + 86400).SetOrder("status desc, start_time asc")
case request.QueryTypeFinished:
search.SetStatus(model.ProcedureStatusFinished).SetOrder("start_time desc")
}
--
Gitblit v1.8.0