package service
|
|
import (
|
"apsClient/model"
|
"apsClient/model/response"
|
"apsClient/pkg/ecode"
|
"gorm.io/gorm"
|
"time"
|
)
|
|
type TaskService struct {
|
}
|
|
func NewTaskService() *TaskService {
|
return &TaskService{}
|
}
|
|
// GetTask 获取任务，未完成的开始时间最早的任务
|
func (slf TaskService) GetTask() (taskData *response.TaskData, code int) {
|
nowTs := time.Now().Unix()
|
orderSearch := model.NewOrderSearch(nil)
|
orderSearch.SetOrder("created_at asc").
|
SetStartTimeMax(nowTs).
|
SetStatus(model.OrderStatusUnFinished)
|
var (
|
err error
|
order *model.Order
|
)
|
order, err = orderSearch.First() //先取进行中的任务
|
if err == gorm.ErrRecordNotFound {
|
err = nil
|
return nil, ecode.OK
|
}
|
if err != nil {
|
return nil, ecode.DBErr
|
}
|
procedure, err := model.NewProceduresSearch(nil).
|
SetWorkOrderId(order.WorkOrderID).
|
SetStartTimeMax(nowTs).
|
SetStatus(model.ProcedureStatusUnFinished).
|
First()
|
if err == gorm.ErrRecordNotFound { //该订单本设备全部工序完成，把订单置为完成状态（只是对本设备完成）
|
err = nil
|
err = model.NewOrderSearch(nil).SetWorkOrderId(order.WorkOrderID).UpdateByMap(map[string]interface{}{
|
"status": model.OrderStatusFinished,
|
})
|
if err != nil {
|
return nil, ecode.DBErr
|
}
|
return slf.GetTask() //当前订单已完全，继续查询未完成订单
|
}
|
if err != nil {
|
return nil, ecode.DBErr
|
}
|
taskData = new(response.TaskData)
|
taskData.Order = order
|
taskData.Procedure = procedure
|
return taskData, ecode.OK
|
}
|
|
func (slf TaskService) GetProcedureById(id int) (*model.Procedures, int) {
|
procedure, err := model.NewProceduresSearch(nil).SetId(id).First()
|
if err != nil {
|
return nil, ecode.DBErr
|
}
|
return procedure, ecode.OK
|
}
|
|
func (slf TaskService) UpdateProcedureStatus(id int, status model.ProcedureStatus) error {
|
return model.NewProceduresSearch(nil).SetId(id).UpdateByMap(map[string]interface{}{
|
"status": status,
|
})
|
}
|
|
func (slf TaskService) GetOrderByWorkOrderId(workOrderId string) (order *model.Order, err error) {
|
return model.NewOrderSearch(nil).SetWorkOrderId(workOrderId).First()
|
}
|
