| | |
| | | return &TaskService{} |
| | | } |
| | | |
| | | // GetTask 获取任务,未完成的开始时间最早的任务 |
| | | // GetTask 获取任务,未完成的开始时间小于等于当前时间,结束时间大于当前时间的任务 |
| | | func (slf TaskService) GetTask(page, pageSize int) (taskResp *response.TaskResponse, code int) { |
| | | var taskList []*response.TaskData |
| | | var count int64 |
| | |
| | | ) |
| | | procedures, err = model.NewProceduresSearch(nil).SetOrder("start_time asc"). |
| | | SetStartTimeMax(nowTs). |
| | | SetEndTimeMin(nowTs). |
| | | SetDeviceId(conf.Conf.System.DeviceId). |
| | | SetStatusNot(model.ProcedureStatusFinished). |
| | | SetPage(page, pageSize). |
| | | SetOrder("status desc"). |
| | | FindNotTotal() |
| | | if err != nil { |
| | | return nil, ecode.DBErr |
| | |
| | | |
| | | func (slf TaskService) GetProcessParams(procedure *model.Procedures, order *model.Order) (processModel *model.ProcessModel, err error) { |
| | | data, err := model.NewProcessModelSearch(). |
| | | SetWorkOrder(procedure.WorkOrderID). |
| | | SetDevice(procedure.ProceduresInfo.DeviceName). |
| | | SetOrderId(procedure.OrderID). |
| | | SetProcedure(procedure.ProceduresInfo.ProcedureName). |
| | | SetProduct(order.ProductName). |
| | | SetOrder("id desc").First() |