取消

cmd/queue/sync_goods/main.go

@@ -6,6 +6,7 @@ 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"
@@ -78,9 +79,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)