工序增加实际开始时间和实际结束时间

zhangqian

2023-10-26 e4957d48bb364f7ee34bd672f53b71a66ca31e14

工序增加实际开始时间和实际结束时间

 api/v1/task.go

@@ -376,7 +376,7 @@
        ctx.FailWithMsg(ecode.NeedConfirmedErr, "PLC请求失败，请检查PLC配置！")
        return
    }
    _ = taskService.UpdateProcedureStatusAndChannel(nil, params.ProcedureId, model.ProcedureStatusProcessing, procedure.Channel, processModel.Number)
    _ = taskService.UpdateProcessModelNumber(nil, params.ProcedureId, processModel.Number)
    ctx.Ok()
}


 model/procedures.go

@@ -20,6 +20,8 @@
        ProcessModelNumber string `gorm:"index;" json:"processModelNumber"` //工艺模型编号
        StartTime          int64  `json:"startTime"`
        EndTime            int64  `json:"endTime"`
        RealStartTime      int64  `json:"realStartTime"`
        RealEndTime        int64  `json:"realEndTime"`
        Status             ProcedureStatus
        ProcedureData      string                  `json:"-"`                  //common.ProductProcedure  json串
        ProceduresInfo     common.ProductProcedure `json:"procedure" gorm:"-"` //common.ProductProcedure  对象

 service/task.go

@@ -137,13 +137,21 @@
    upMap := map[string]interface{}{"status": status}
    if status == model.ProcedureStatusProcessing {
        upMap["process_model_number"] = processModelNumber
        upMap["real_start_time"] = time.Now().Unix()
    } else if status == model.ProcedureStatusWaitProcess {
        upMap["process_model_number"] = ""
    } else if status == model.ProcedureStatusFinished {
        upMap["real_end_time"] = time.Now().Unix()
    }

    return model.NewProceduresSearch(db).SetId(id).UpdateByMap(upMap)
}

func (slf TaskService) UpdateProcessModelNumber(db *gorm.DB, id uint, processModelNumber string) error {
    upMap := map[string]interface{}{"process_model_number": processModelNumber}
    return model.NewProceduresSearch(db).SetId(id).UpdateByMap(upMap)
}

func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id uint, status model.ProcedureStatus, channel int32) error {
    if status == model.ProcedureStatusFinished {
        ProgressCacheUnset(channel)