78 lines
2.2 KiB
Go
78 lines
2.2 KiB
Go
package controller
|
|
|
|
import (
|
|
"encoding/json"
|
|
"net/http"
|
|
"planA/service"
|
|
"planA/tool"
|
|
_type "planA/type"
|
|
"planA/validator"
|
|
)
|
|
|
|
// GetTbOneBodyWait 查询淘宝bodyWait
|
|
func GetTbOneBodyWait(httpMsg http.ResponseWriter, data *http.Request) {
|
|
// 验证表单
|
|
dataVal, createTaskValidatorErr := validator.GetBodyWaitOneValidator(data)
|
|
if createTaskValidatorErr != nil {
|
|
tool.Error(httpMsg, createTaskValidatorErr.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
// 查询bodyWait
|
|
bodyWait, getTbBodyWaitErr := service.GetOneBodyFromRight(dataVal.TaskId)
|
|
if getTbBodyWaitErr != nil {
|
|
tool.Error(httpMsg, getTbBodyWaitErr.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
// 将 bodyWait 转为结构体
|
|
var bodyWaits _type.TaskBody
|
|
unmarshalErr := json.Unmarshal([]byte(bodyWait), &bodyWaits)
|
|
if unmarshalErr != nil {
|
|
tool.Error(httpMsg, unmarshalErr.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
// 返回结果
|
|
tool.Success(httpMsg, bodyWaits)
|
|
}
|
|
|
|
// InsertTbBodyOver 插入 bodyOver
|
|
func InsertTbBodyOver(httpMsg http.ResponseWriter, data *http.Request) {
|
|
// 验证表单
|
|
dataVal, createTaskValidatorErr := validator.InsertTbBodyOver(data)
|
|
if createTaskValidatorErr != nil {
|
|
tool.Error(httpMsg, createTaskValidatorErr.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
//解析bodyover
|
|
var bodyOver _type.TaskBody
|
|
unmarshalErr := json.Unmarshal([]byte(dataVal.Data), &bodyOver)
|
|
if unmarshalErr != nil {
|
|
tool.Error(httpMsg, unmarshalErr.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
|
|
//// 更新任务尾
|
|
//updateTaskFootersErr := service.UpdateTaskFooters(dataVal.TaskId, bodyOver.Detail.Status, 1)
|
|
//if updateTaskFootersErr != nil {
|
|
// tool.Error(httpMsg, updateTaskFootersErr.Error(), http.StatusInternalServerError)
|
|
// return
|
|
//}
|
|
//// 更新任务头
|
|
//updateTaskHeadersErr := service.UpdateTaskHeaders(dataVal.TaskId, bodyOver.Detail.Status, 1)
|
|
//if updateTaskHeadersErr != nil {
|
|
// tool.Error(httpMsg, updateTaskHeadersErr.Error(), http.StatusInternalServerError)
|
|
// return
|
|
//}
|
|
|
|
//插入bodyOver
|
|
insertErr := service.InsertOneBodyOver(dataVal.TaskId, dataVal.Data)
|
|
if insertErr != nil {
|
|
tool.Error(httpMsg, insertErr.Error(), http.StatusInternalServerError)
|
|
return
|
|
}
|
|
tool.Success(httpMsg, "")
|
|
}
|