优化速度

cmd/queue/sync_goods/main.go

@@ -6,7 +6,6 @@ import (
 	"fmt"
 	"fmt"
 	"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
 	"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
 	"github.com/imroc/req"
 	"github.com/imroc/req"
-	"scm_server/cmd/queue/sync_status/product"
 	"scm_server/configs"
 	"scm_server/configs"
 	"scm_server/internal/common"
 	"scm_server/internal/common"
 	"scm_server/internal/logic"
 	"scm_server/internal/logic"
@@ -79,9 +78,9 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 	if err = SyncGoodsData(operateType, goods); err != nil {
 	if err = SyncGoodsData(operateType, goods); err != nil {
 		goto ERR
 		goto ERR
 	}
 	}
-	if err = product.SyncErpStatus("material", goods.ErpId); err != nil {
-		goto ERR
-	}
+	//if err = product.SyncErpStatus("material", goods.ErpId); err != nil {
+	//	goto ERR
+	//}
 	return nil
 	return nil
 ERR:
 ERR:
 	return logic.DealSyncError(dataByte, goods.ErpId, "goods", err)
 	return logic.DealSyncError(dataByte, goods.ErpId, "goods", err)