110 lines
3.6 KiB
Go
110 lines
3.6 KiB
Go
package handler
|
||
|
||
import (
|
||
"encoding/json"
|
||
"net/http"
|
||
|
||
"bj_power_workstation/internal/svc"
|
||
|
||
"github.com/zeromicro/go-zero/core/logx"
|
||
)
|
||
|
||
// processDoneHandler POST /api/report/process-done
|
||
// {dockCode, orderNo, sn, processCode, operator}
|
||
// 流程：先冲刷一轮积压 → 实时报 MES /api/internal/station/done；
|
||
// MES 不可达则写入 report_queue(kind=process_done) 并返回 data.queued=true（离线缓存稍后自动重传）。
|
||
func processDoneHandler(ctx *svc.ServiceContext) http.HandlerFunc {
|
||
return func(w http.ResponseWriter, r *http.Request) {
|
||
var req struct {
|
||
DockCode string `json:"dockCode"`
|
||
OrderNo string `json:"orderNo"`
|
||
Sn string `json:"sn"`
|
||
ProcessCode string `json:"processCode"`
|
||
Operator string `json:"operator"`
|
||
}
|
||
if err := parseJSON(r, &req); err != nil {
|
||
fail(w, http.StatusBadRequest, "参数错误")
|
||
return
|
||
}
|
||
if req.DockCode == "" {
|
||
fail(w, http.StatusBadRequest, "缺少 dockCode")
|
||
return
|
||
}
|
||
|
||
// 先尽力冲刷历史积压，失败不影响本次上报
|
||
ctx.Syncer.RunOnce(r.Context())
|
||
|
||
body := map[string]any{
|
||
"dockCode": req.DockCode,
|
||
"orderNo": req.OrderNo,
|
||
"sn": req.Sn,
|
||
"processCode": req.ProcessCode,
|
||
"operator": req.Operator,
|
||
}
|
||
payloadBytes, _ := json.Marshal(body)
|
||
|
||
ctx.Store.AddEventLog(req.OrderNo, req.Operator, "process_done",
|
||
"工序完成上报 dockCode="+req.DockCode+" sn="+req.Sn+" processCode="+req.ProcessCode)
|
||
|
||
if _, _, err := ctx.Mes.Post("/api/internal/station/done", json.RawMessage(payloadBytes)); err != nil {
|
||
if qerr := ctx.Store.InsertQueueItem("process_done", string(payloadBytes)); qerr != nil {
|
||
fail(w, http.StatusInternalServerError, "上报失败且离线队列写入失败："+qerr.Error())
|
||
return
|
||
}
|
||
logx.Errorf("工序完成上报失败已离线排队: %v", err)
|
||
ok(w, map[string]any{"queued": true})
|
||
return
|
||
}
|
||
|
||
ok(w, map[string]any{"queued": false})
|
||
}
|
||
}
|
||
|
||
// tempStoreHandler POST /api/report/temp-store
|
||
// {dockCode, orderNo, sn, operator} → 调 MES /api/internal/station/checkin，
|
||
// body 附带 type=temp_store；不可达时以同样 payload 写入 report_queue(kind=temp_store)。
|
||
func tempStoreHandler(ctx *svc.ServiceContext) http.HandlerFunc {
|
||
return func(w http.ResponseWriter, r *http.Request) {
|
||
var req struct {
|
||
DockCode string `json:"dockCode"`
|
||
OrderNo string `json:"orderNo"`
|
||
Sn string `json:"sn"`
|
||
Operator string `json:"operator"`
|
||
}
|
||
if err := parseJSON(r, &req); err != nil {
|
||
fail(w, http.StatusBadRequest, "参数错误")
|
||
return
|
||
}
|
||
if req.DockCode == "" {
|
||
fail(w, http.StatusBadRequest, "缺少 dockCode")
|
||
return
|
||
}
|
||
|
||
// 先尽力冲刷历史积压，失败不影响本次上报
|
||
ctx.Syncer.RunOnce(r.Context())
|
||
|
||
body := map[string]any{
|
||
"type": "temp_store", // checkin 类型标识：暂存退库
|
||
"dockCode": req.DockCode,
|
||
"orderNo": req.OrderNo,
|
||
"sn": req.Sn,
|
||
"operator": req.Operator,
|
||
}
|
||
payloadBytes, _ := json.Marshal(body)
|
||
|
||
ctx.Store.AddEventLog(req.OrderNo, req.Operator, "temp_store",
|
||
"暂存/退回库房 dockCode="+req.DockCode+" sn="+req.Sn)
|
||
|
||
if _, _, err := ctx.Mes.Post("/api/internal/station/checkin", json.RawMessage(payloadBytes)); err != nil {
|
||
if qerr := ctx.Store.InsertQueueItem("temp_store", string(payloadBytes)); qerr != nil {
|
||
fail(w, http.StatusInternalServerError, "上报失败且离线队列写入失败："+qerr.Error())
|
||
return
|
||
}
|
||
logx.Errorf("暂存退库上报失败已离线排队: %v", err)
|
||
ok(w, map[string]any{"queued": true})
|
||
return
|
||
}
|
||
|
||
ok(w, map[string]any{"queued": false})
|
||
}
|
||
} |