LAPP_Acura_MES_Backend/task/ApsRelease.go

package task

import (
	"LAPP_ACURA_MOM_BACKEND/common"
	"LAPP_ACURA_MOM_BACKEND/infra/logger"
	"LAPP_ACURA_MOM_BACKEND/models/channel"
	"LAPP_ACURA_MOM_BACKEND/services/pln"
	"fmt"
)

func StartApsRelease() error {
	// 异步派工
	common.ReleaseTaskChannel = make(map[int]*channel.TaskChannel)
	custSvr := pln.NewCustOrderService()
	err := custSvr.ReleaseTask()
	return err
}

func StartCrossPlantTask() error {
	// 异步派工
	common.CrossPlantTaskCustOrderChannel = make(map[int]*channel.TaskChannel)
	custSvr := pln.NewCustOrderService()
	err := custSvr.CrossPlantTask()
	if err != nil {
		fmt.Println("执行跨工厂任务失败, 错误:" + err.Error())
		log, _ := logger.NewLogger("后台任务", "跨工厂任务")
		log.Error("执行跨工厂任务失败, 错误:" + err.Error())
	}
	return err
}

func StartTimingPutTaskToChannel() {
	// 异步派工
	custSvr := pln.NewCustOrderService()
	_ = custSvr.PutTaskToChannel()
}