MiFaZhan
21 lines
629 B
Go
21 lines
629 B
Go
package tasks
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/gogf/gf/v2/frame/g"
|
|
|
|
"git.5iot.com/iotlcm-public/iotlcm-admin-svr/internal/service"
|
|
)
|
|
|
|
func init() { RegisterInnerTask("syns_sim_status_queue", "SynsSimStatusQueue") }
|
|
|
|
// SynsSimStatusQueue is the sole scheduled entry point for full status sync.
|
|
// The legacy admin-process implementation was removed after the queue path
|
|
// became the supported production flow.
|
|
func (t Task) SynsSimStatusQueue() {
|
|
if err := service.SimStatusQueue().StartFullSync(context.Background()); err != nil {
|
|
g.Log().Errorf(context.Background(), "start sim status queue sync failed: %+v", err)
|
|
}
|
|
}
|