整合启动

cmd/queue/sync_audit_status/main.go

-package main
+package sync_audit_status
 
 
 import (
 import (
 	"encoding/json"
 	"encoding/json"
@@ -165,7 +165,7 @@ func (t *RecvPro) FailAction(dataByte []byte) error {
 	return nil
 	return nil
 }
 }
 
 
-func main() {
+func Sync() {
 	defer func() {
 	defer func() {
 		if err := recover(); err != nil {
 		if err := recover(); err != nil {
 			service.SendDingTalkRobotToApi(fmt.Sprintf("%s", err))
 			service.SendDingTalkRobotToApi(fmt.Sprintf("%s", err))

main.go

 package main
 package main
 
 
 import (
 import (
+	"scm_server/cmd/queue/sync_audit_status"
 	"scm_server/cmd/queue/sync_customer"
 	"scm_server/cmd/queue/sync_customer"
 	"scm_server/cmd/queue/sync_goods"
 	"scm_server/cmd/queue/sync_goods"
 	"scm_server/cmd/queue/sync_in_store"
 	"scm_server/cmd/queue/sync_in_store"
@@ -58,7 +59,7 @@ func main() {
 	go sync_in_store.Sync()
 	go sync_in_store.Sync()
 	go sync_out_store.Sync()
 	go sync_out_store.Sync()
 	go sync_status.Sync()
 	go sync_status.Sync()
-	// go sync_audit_status.Sync()
+	go sync_audit_status.Sync()
 	//定时请求open falcon证明自己没挂
 	//定时请求open falcon证明自己没挂
 	for {
 	for {
 		pushAlive()
 		pushAlive()