新增任务开启通知接口，接收到通知或去查询工艺模型

zhangqian

2023-08-15 f5461743f6542e6b4a793117e05777769f9c3377

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package v1
 
import (
    "apsClient/model/request"
    _ "apsClient/model/response"
    "apsClient/pkg/contextx"
    "apsClient/pkg/logx"
    "apsClient/pkg/safe"
    "apsClient/service"
    "github.com/gin-gonic/gin"
)
 
type NoticeApi struct{}
 
// TaskStart
// @Tags      Base
// @Summary   任务开启通知
// @Produce   application/json
// @Param     object  body    request.TaskInfo true  "查询参数"
// @Success   200   {object}  contextx.Response{data=response.LoginResponse}  "成功"
// @Router    /v1/notice/task/start [post]
func (slf *NoticeApi) TaskStart(c *gin.Context) {
    var params request.TaskInfo
    ctx, ok := contextx.NewContext(c, &params)
    if !ok {
        return
    }
    safe.Go(func() {
        resp, err := service.ProcessModel{}.GetProcessModel(service.GetProcessModelParams{
            WorkOrder: params.WorkOrder,
            OrderId:   params.OrderId,
            Product:   params.Product,
            Procedure: params.Procedure,
            Device:    params.Device,
        })
        if err != nil {
            logx.Errorf("TaskStart Notice GetProcessModel error: %v", err.Error())
            return
        }
        logx.Infof("TaskStart Notice GetProcessModel: %+v", resp)
    })
 
    ctx.Ok()
}