继续整合

cmd/queue/main.go

@@ -2,6 +2,7 @@ package main
 
 
 import (
 import (
 	"github.com/imroc/req"
 	"github.com/imroc/req"
+	"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"
@@ -57,6 +58,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()
 	//定时请求open falcon证明自己没挂
 	//定时请求open falcon证明自己没挂
 	for {
 	for {
 		pushAlive()
 		pushAlive()

cmd/queue/sync_audit_status/main.go

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