From 8335bd8f90803331fcbe81135c79ab0edc73f6c7 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期六, 26 八月 2023 19:16:03 +0800 Subject: [PATCH] 修正写入总量 --- service/task.go | 24 +++++++++++++++++------- 1 files changed, 17 insertions(+), 7 deletions(-) diff --git a/service/task.go b/service/task.go index 11b543b..5b7be1c 100644 --- a/service/task.go +++ b/service/task.go @@ -20,7 +20,7 @@ nowTs := time.Now().Unix() orderSearch := model.NewOrderSearch(nil) orderSearch.SetOrder("created_at asc"). - SetStartTimeMin(nowTs). + SetStartTimeMax(nowTs). SetStatus(model.OrderStatusUnFinished) var ( err error @@ -35,23 +35,24 @@ return nil, ecode.DBErr } procedure, err := model.NewProceduresSearch(nil). - SetOrderId(order.OrderID). - SetStartTimeMin(nowTs). + SetWorkOrderId(order.WorkOrderID). + SetStartTimeMax(nowTs). SetStatus(model.ProcedureStatusUnFinished). First() if err == gorm.ErrRecordNotFound { //璇ヨ鍗曟湰璁惧鍏ㄩ儴宸ュ簭瀹屾垚锛屾妸璁㈠崟缃负瀹屾垚鐘舵�侊紙鍙槸瀵规湰璁惧瀹屾垚锛� err = nil - err = model.NewOrderSearch(nil).SetOrderId(order.OrderID).UpdateByMap(map[string]interface{}{ + err = model.NewOrderSearch(nil).SetWorkOrderId(order.WorkOrderID).UpdateByMap(map[string]interface{}{ "status": model.OrderStatusFinished, }) if err != nil { return nil, ecode.DBErr } - return slf.GetTask() //褰撳墠璁㈠崟宸插畬鍏紝缁х画鏌ヨ鏈畬鎴愯鍗� + return slf.GetTask() //褰撳墠璁㈠崟宸插畬鎴愶紝缁х画鏌ヨ鏈畬鎴愯鍗� } if err != nil { return nil, ecode.DBErr } + taskData = new(response.TaskData) taskData.Order = order taskData.Procedure = procedure return taskData, ecode.OK @@ -71,6 +72,15 @@ }) } -func (slf TaskService) GetOrderByOrderId(orderId string) (order *model.Order, err error) { - return model.NewOrderSearch(nil).SetOrderId(orderId).First() +func (slf TaskService) GetOrderByWorkOrderId(workOrderId string) (order *model.Order, err error) { + return model.NewOrderSearch(nil).SetWorkOrderId(workOrderId).First() +} + +// GetComingTask 鑾峰彇鏃堕棿鏈埌鐨勬渶鏃╀换鍔� +func (slf TaskService) GetComingTask() (workOrder *model.Order, err error) { + nowTs := time.Now().Unix() + orderSearch := model.NewOrderSearch(nil) + return orderSearch.SetOrder("created_at asc"). + SetStartTimeMin(nowTs). + SetStatus(model.OrderStatusUnFinished).First() } -- Gitblit v1.8.0