| | |
| | | reportWork, err := service.GetLastReportWork(params.ProcedureId) |
| | | if err == nil { |
| | | finishNumber = reportWork.ReportAmount |
| | | } |
| | | workOrder, err := model.NewOrderSearch(nil).SetWorkOrderId(reportWork.WorkOrderID).First() |
| | | if err == nil { |
| | | totalNumber = workOrder.Amount.IntPart() |
| | | workOrder, err := model.NewOrderSearch(nil).SetWorkOrderId(reportWork.WorkOrderID).First() |
| | | if err == nil { |
| | | totalNumber = workOrder.Amount.IntPart() |
| | | } |
| | | } else { |
| | | _, workOrder, _ := service.NewTaskService().GetProcedureAndWorkOrder(params.ProcedureId) |
| | | if workOrder != nil { |
| | | totalNumber = workOrder.Amount.IntPart() |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | return procedure, ecode.OK |
| | | } |
| | | |
| | | func (slf TaskService) GetProcedureAndWorkOrder(procedureId uint) (procedure *model.Procedures, workOrder *model.Order, err error) { |
| | | procedure, err = model.NewProceduresSearch(nil).SetId(procedureId).First() |
| | | if err != nil { |
| | | return nil, nil, err |
| | | } |
| | | workOrder, err = model.NewOrderSearch(nil).SetWorkOrderId(procedure.WorkOrderID).First() |
| | | if err != nil { |
| | | return nil, nil, err |
| | | } |
| | | return procedure, workOrder, nil |
| | | } |
| | | |
| | | func (slf TaskService) UpdateProcedureStatusAndChannel(db *gorm.DB, id uint, status model.ProcedureStatus, channel int32, processModelNumber string) error { |
| | | if status == model.ProcedureStatusFinished || status == model.ProcedureStatusWaitProcess { |
| | | ProgressCacheUnset(conf.Conf.CurrentDeviceID, channel) |