| | |
| | | } |
| | | |
| | | err = model.WithTransaction(func(db *gorm.DB) error { |
| | | err = taskService.UpdateProcedureStatusAndChannel(db, params.ProcedureId, model.ProcedureStatusProcessing, params.Channel) |
| | | err = taskService.UpdateProcedureStatusAndChannel(db, params.ProcedureId, model.ProcedureStatusProcessing, procedure.Channel) |
| | | if err != nil { |
| | | return err |
| | | } |
| | | procedure.Channel = params.Channel |
| | | err = taskService.UpdateOrderStatus(db, order.ID, model.OrderStatusProcessing) |
| | | if err != nil { |
| | | return err |
| | |
| | | if err != nil { |
| | | logx.Errorf("SendProcessParams: %v", err.Error()) |
| | | err = model.WithTransaction(func(db *gorm.DB) error { |
| | | err = taskService.UpdateProcedureStatusAndChannel(db, params.ProcedureId, model.ProcedureStatusWaitProcess, params.Channel) |
| | | err = taskService.UpdateProcedureStatusAndChannel(db, params.ProcedureId, model.ProcedureStatusWaitProcess, procedure.Channel) |
| | | if err != nil { |
| | | return err |
| | | } |
| | | procedure.Channel = params.Channel |
| | | err = taskService.UpdateOrderStatus(db, order.ID, model.OrderStatusWaitProcess) |
| | | if err != nil { |
| | | return err |
| | |
| | | return |
| | | } |
| | | plcConfig.CurrentTryTimes = 0 |
| | | err = service.PlcWrite(plcConfig, constvar.PlcStartAddressTypeTotalNumber, params.Channel, order.Amount.IntPart()) |
| | | err = service.PlcWrite(plcConfig, constvar.PlcStartAddressTypeTotalNumber, procedure.Channel, order.Amount.IntPart()) |
| | | if err != nil { |
| | | ctx.FailWithMsg(ecode.NeedConfirmedErr, "PLC请求失败,请检查PLC配置") |
| | | return |
| | |
| | | "procedureId" |
| | | ], |
| | | "properties": { |
| | | "channel": { |
| | | "type": "integer" |
| | | }, |
| | | "procedureId": { |
| | | "type": "integer" |
| | | } |
| | |
| | | "procedureId" |
| | | ], |
| | | "properties": { |
| | | "channel": { |
| | | "type": "integer" |
| | | }, |
| | | "procedureId": { |
| | | "type": "integer" |
| | | } |
| | |
| | | type: object |
| | | request.SendProcessParams: |
| | | properties: |
| | | channel: |
| | | type: integer |
| | | procedureId: |
| | | type: integer |
| | | required: |
| | |
| | | } |
| | | |
| | | type SendProcessParams struct { |
| | | ProcedureId int `json:"procedureId" binding:"required"` |
| | | Channel int32 `json:"channel"` |
| | | ProcedureId int `json:"procedureId" binding:"required"` |
| | | } |
| | | |
| | | type GetProductProgress struct { |
| | |
| | | ProgressCacheUnset(channel) |
| | | } |
| | | return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{ |
| | | "status": status, |
| | | "channel": channel, |
| | | "status": status, |
| | | }) |
| | | } |
| | | |