优化

cmd/queue/sync_audit_status/main.go

@@ -34,7 +34,7 @@ type StoreData struct {
 type StoreGoods struct {
 	ErpEntrySn  string `json:"erp_entry_sn"`
 	Number      string `json:"number"`
-	CountryCode string `json:"country_code"`
+	CountryCode string `json:"country"`
 }
 
 func (t *RecvPro) Consumer(dataByte []byte) (err error) {

cmd/queue/sync_goods/product.go → cmd/queue/sync_goods/product/product.go

-package sync_goods
+package main
 
 import (
 	"encoding/json"
@@ -12,10 +12,10 @@ func main() {
 	message = map[string]interface{}{
 		"type": "delete",
 		"data": map[string]string{
-			"FID":    "BUqVwVoBTRm/BY9kIKL7fEQJ5/A=",
-			"FGoods": "光电耦合器",
-			"FBrand": "VISHAY",
-			"FModel": "LH1512BB",
+			"FID":    "imqWd01vR7qdD/+CY8FKHkQJ5/A=",
+			"FGoods": "test123145",
+			"FBrand": "TEST123145",
+			"FModel": "test123145",
 		},
 	}
 	data, err := json.Marshal(message)

conf/config.ini

@@ -2,7 +2,7 @@
 username = root
 password = root
 host = 192.168.2.250
-database = lie_scm_sync
+database = lie_scm_wms_sync
 
 [rabbitmq]
 url = "amqp://huntadmin:jy2y2900@192.168.1.237:5672/"