恢复

cmd/queue/sync_customer/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"
@@ -75,9 +76,9 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 	if err = SyncCustomerData(operateType, customer); err != nil {
 	if err = SyncCustomerData(operateType, customer); err != nil {
 		goto ERR
 		goto ERR
 	}
 	}
-	//if err = product.SyncErpStatus("customer", customer.ErpId); err != nil {
-	//	goto ERR
-	//}
+	if err = product.SyncErpStatus("customer", customer.ErpId); err != nil {
+		goto ERR
+	}
 	return nil
 	return nil
 ERR:
 ERR:
 	return logic.DealSyncError(dataByte, customer.ErpId, "customer", err)
 	return logic.DealSyncError(dataByte, customer.ErpId, "customer", err)

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)

cmd/queue/sync_supplier/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"
@@ -76,9 +77,9 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 	if err = SyncSupplierData(operateType, supplier); err != nil {
 	if err = SyncSupplierData(operateType, supplier); err != nil {
 		goto ERR
 		goto ERR
 	}
 	}
-	//if err = product.SyncErpStatus("supplier", supplier.ErpId); err != nil {
-	//	goto ERR
-	//}
+	if err = product.SyncErpStatus("supplier", supplier.ErpId); err != nil {
+		goto ERR
+	}
 	return nil
 	return nil
 ERR:
 ERR:
 	return logic.DealSyncError(dataByte, supplier.ErpId, "supplier", err)
 	return logic.DealSyncError(dataByte, supplier.ErpId, "supplier", err)