Commit 9b7769d2 authored by 陈子龙's avatar 陈子龙

工单管理编辑 fix

parent ce822374
...@@ -36,7 +36,7 @@ type TimingCustom struct { ...@@ -36,7 +36,7 @@ type TimingCustom struct {
} }
type EditWorkOrderReq struct { type EditWorkOrderReq struct {
IsPush int `json:"is_push" binding:"required"` // 是否立刻下发(0否 1是) IsPush int `json:"is_push" binding:"oneof=0 1"` // 是否立刻下发(0否 1是)
Id int `json:"id" binding:"required"` // 主键id Id int `json:"id" binding:"required"` // 主键id
OrderLevel int `json:"order_level" binding:"oneof=1 2 3"` // 工单等级(1紧急任务 2重要任务 3一般任务) OrderLevel int `json:"order_level" binding:"oneof=1 2 3"` // 工单等级(1紧急任务 2重要任务 3一般任务)
OrderDesc string `json:"order_desc" binding:"required"` // 工单描述 OrderDesc string `json:"order_desc" binding:"required"` // 工单描述
......
...@@ -21,6 +21,8 @@ import ( ...@@ -21,6 +21,8 @@ import (
"time" "time"
) )
var workOrderCron = cron.New(cron.WithSeconds())
type WorkOrderManageSvc struct { type WorkOrderManageSvc struct {
User entity.SystemUserInfo User entity.SystemUserInfo
} }
...@@ -169,10 +171,9 @@ func (w *WorkOrderManageSvc) StateWorkOrderManage(req request.StateWorkOrderReq) ...@@ -169,10 +171,9 @@ func (w *WorkOrderManageSvc) StateWorkOrderManage(req request.StateWorkOrderReq)
return return
} }
if req.TimingState == 1 {
//创建定时任务 //创建定时任务
CronPushWorkOrder() CronPushWorkOrder()
}
return return
} }
...@@ -764,8 +765,6 @@ func PushObjMsg(obj, orderName string, orderLevel int) (err error) { ...@@ -764,8 +765,6 @@ func PushObjMsg(obj, orderName string, orderLevel int) (err error) {
return return
} }
var c = cron.New(cron.WithSeconds())
// CronPushWorkOrder 创建工单下发定时任务 // CronPushWorkOrder 创建工单下发定时任务
func CronPushWorkOrder() { func CronPushWorkOrder() {
db, err := client.GetDbClient() db, err := client.GetDbClient()
...@@ -784,8 +783,8 @@ func CronPushWorkOrder() { ...@@ -784,8 +783,8 @@ func CronPushWorkOrder() {
return return
} }
c.Stop() workOrderCron.Stop()
defer c.Start() defer workOrderCron.Start()
for _, v := range workOrderList { for _, v := range workOrderList {
var pushObj request.PushObj var pushObj request.PushObj
err = json.Unmarshal([]byte(v.PushObj), &pushObj) err = json.Unmarshal([]byte(v.PushObj), &pushObj)
...@@ -815,7 +814,7 @@ func CronPushWorkOrder() { ...@@ -815,7 +814,7 @@ func CronPushWorkOrder() {
expr := fmt.Sprintf("%d %d %d * * %s", t.Second(), t.Minute(), t.Hour(), strings.Join(util.IntsToStrings(timingWeekly.Week), ",")) expr := fmt.Sprintf("%d %d %d * * %s", t.Second(), t.Minute(), t.Hour(), strings.Join(util.IntsToStrings(timingWeekly.Week), ","))
//创建定时任务 //创建定时任务
c.AddFunc(expr, func() { workOrderCron.AddFunc(expr, func() {
err = svc.PushWorkOrderManage(request.PushWorkOrderReq{Id: v.Id, PushObj: pushObj}) err = svc.PushWorkOrderManage(request.PushWorkOrderReq{Id: v.Id, PushObj: pushObj})
//err = PushObjMsg(v.PushObj, v.OrderName, v.OrderLevel) //err = PushObjMsg(v.PushObj, v.OrderName, v.OrderLevel)
if err != nil { if err != nil {
...@@ -849,7 +848,7 @@ func CronPushWorkOrder() { ...@@ -849,7 +848,7 @@ func CronPushWorkOrder() {
for d := dateFrom; d.Before(dateTo); d = d.AddDate(0, 0, 1) { for d := dateFrom; d.Before(dateTo); d = d.AddDate(0, 0, 1) {
expr := fmt.Sprintf("%d %d %d %d %d %d", t.Second(), t.Minute(), t.Hour(), d.Day(), d.Month(), d.Year()) expr := fmt.Sprintf("%d %d %d %d %d %d", t.Second(), t.Minute(), t.Hour(), d.Day(), d.Month(), d.Year())
//创建定时任务 //创建定时任务
c.AddFunc(expr, func() { workOrderCron.AddFunc(expr, func() {
err = svc.PushWorkOrderManage(request.PushWorkOrderReq{Id: v.Id, PushObj: pushObj}) err = svc.PushWorkOrderManage(request.PushWorkOrderReq{Id: v.Id, PushObj: pushObj})
//err = PushObjMsg(v.PushObj, v.OrderName, v.OrderLevel) //err = PushObjMsg(v.PushObj, v.OrderName, v.OrderLevel)
if err != nil { if err != nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment