package report
|
|
import (
|
"context"
|
"time"
|
|
"kingdee-dbapi/config"
|
"kingdee-dbapi/logger"
|
)
|
|
var ctx context.Context
|
var cancel context.CancelFunc
|
|
func Start() {
|
ctx, cancel = context.WithCancel(context.Background())
|
go queryTasks(ctx)
|
}
|
|
func RestartReport() {
|
cancel()
|
|
Start()
|
}
|
|
func queryTasks(c context.Context) {
|
logger.Debug("启动数据上报任务")
|
for {
|
select {
|
case <-c.Done():
|
logger.Debug("停止上报")
|
return
|
default:
|
// 上报订单
|
if config.Options.OrderTopic != "" {
|
SendOrder()
|
}
|
|
// 上报即时库存
|
if config.Options.InventoryTopic != "" {
|
SendInventory()
|
}
|
|
// 上报bom
|
if config.Options.BomTopic != "" {
|
SendBom(false)
|
}
|
|
time.Sleep(time.Duration(config.Options.SyncInterval) * time.Second)
|
}
|
}
|
}
|
|
func HandleBomQuery(msg []byte) error {
|
SendBom(true)
|
|
return nil
|
}
|
