Skip to content

杨树贤 / scm_server

Go to a project
Commit 20db06bd by mushishixian
Options

mq配置地址

parent 3b7ea87b
Inline Side-by-side
Showing with 25 additions and 18 deletions
cmd/queue/sync_customer/main.go
...@@ -186,6 +186,6 @@ func main() { ...@@ -186,6 +186,6 @@ func main() {
"store_customer", "store_customer",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
}, t, 1) }, t, 1)
} }
cmd/queue/sync_customer/product.go
...@@ -4,6 +4,7 @@ import ( ...@@ -4,6 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"scm_server/configs"
) )
func main() { func main() {
...@@ -24,8 +25,8 @@ func main() { ...@@ -24,8 +25,8 @@ func main() {
"CFNAME": "深圳市肯特尔科技有限公司", "CFNAME": "深圳市肯特尔科技有限公司",
}, },
} }
data,err := json.Marshal(message) data, err := json.Marshal(message)
if err!=nil { if err != nil {
fmt.Println(err) fmt.Println(err)
} }
body := string(data) body := string(data)
...@@ -34,7 +35,7 @@ func main() { ...@@ -34,7 +35,7 @@ func main() {
"store_customer", "store_customer",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
rabbitmq.Send(queueExchange, body) rabbitmq.Send(queueExchange, body)
......
cmd/queue/sync_goods/main.go
...@@ -190,6 +190,6 @@ func main() { ...@@ -190,6 +190,6 @@ func main() {
"store_goods", "store_goods",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
}, t, 1) }, t, 1)
} }
cmd/queue/sync_goods/product.go
...@@ -4,6 +4,7 @@ import ( ...@@ -4,6 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"scm_server/configs"
) )
func main() { func main() {
...@@ -27,7 +28,7 @@ func main() { ...@@ -27,7 +28,7 @@ func main() {
"store_goods", "store_goods",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
rabbitmq.Send(queueExchange, body) rabbitmq.Send(queueExchange, body)
......
cmd/queue/sync_in_store/main.go
...@@ -248,6 +248,6 @@ func main() { ...@@ -248,6 +248,6 @@ func main() {
"store_in", "store_in",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
}, t, 1) }, t, 1)
} }
cmd/queue/sync_in_store/product.go
...@@ -4,6 +4,7 @@ import ( ...@@ -4,6 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"scm_server/configs"
) )
func main() { func main() {
...@@ -48,7 +49,7 @@ func main() { ...@@ -48,7 +49,7 @@ func main() {
"store_in", "store_in",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
rabbitmq.Send(queueExchange, body) rabbitmq.Send(queueExchange, body)
......
cmd/queue/sync_out_store/main.go
...@@ -228,6 +228,6 @@ func main() { ...@@ -228,6 +228,6 @@ func main() {
"store_out", "store_out",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
}, t, 1) }, t, 1)
} }
cmd/queue/sync_out_store/product.go
...@@ -4,6 +4,7 @@ import ( ...@@ -4,6 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"scm_server/configs"
) )
func main() { func main() {
...@@ -46,7 +47,7 @@ func main() { ...@@ -46,7 +47,7 @@ func main() {
"store_out", "store_out",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
rabbitmq.Send(queueExchange, body) rabbitmq.Send(queueExchange, body)
......
cmd/queue/sync_status/main.go
...@@ -217,6 +217,6 @@ func main() { ...@@ -217,6 +217,6 @@ func main() {
"store_sync_status", "store_sync_status",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
}, t, 1) }, t, 1)
} }
cmd/queue/sync_status/product/product_status_queue.go
...@@ -3,6 +3,7 @@ package product ...@@ -3,6 +3,7 @@ package product
import ( import (
"encoding/json" "encoding/json"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"scm_server/configs"
) )
func SyncErpStatus(syncName string, ErpId string) (err error) { func SyncErpStatus(syncName string, ErpId string) (err error) {
...@@ -22,7 +23,7 @@ func SyncErpStatus(syncName string, ErpId string) (err error) { ...@@ -22,7 +23,7 @@ func SyncErpStatus(syncName string, ErpId string) (err error) {
"store_sync_status", "store_sync_status",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
rabbitmq.Send(queueExchange, body) rabbitmq.Send(queueExchange, body)
......
cmd/queue/sync_status/request.go
...@@ -3,6 +3,7 @@ package main ...@@ -3,6 +3,7 @@ package main
import ( import (
"encoding/json" "encoding/json"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"scm_server/configs"
) )
func main(){ func main(){
...@@ -23,7 +24,7 @@ func main(){ ...@@ -23,7 +24,7 @@ func main(){
"store_sync_status", "store_sync_status",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
rabbitmq.Send(queueExchange, body) rabbitmq.Send(queueExchange, body)
......
cmd/queue/sync_supplier/main.go
...@@ -186,6 +186,6 @@ func main() { ...@@ -186,6 +186,6 @@ func main() {
"store_supplier", "store_supplier",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
}, t, 1) }, t, 1)
} }
cmd/queue/sync_supplier/product.go
...@@ -4,6 +4,7 @@ import ( ...@@ -4,6 +4,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"scm_server/configs"
) )
func main() { func main() {
...@@ -26,7 +27,7 @@ func main() { ...@@ -26,7 +27,7 @@ func main() {
"store_supplier", "store_supplier",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
rabbitmq.Send(queueExchange, body) rabbitmq.Send(queueExchange, body)
......
cmd/source/customer/customer.go
...@@ -18,7 +18,7 @@ func init() { ...@@ -18,7 +18,7 @@ func init() {
"store_customer", "store_customer",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
} }
func Import() { func Import() {
......
cmd/source/goods/goods.go
...@@ -18,7 +18,7 @@ func init() { ...@@ -18,7 +18,7 @@ func init() {
"store_goods", "store_goods",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
} }
......
cmd/source/supplier/supplier.go
...@@ -18,7 +18,7 @@ func init() { ...@@ -18,7 +18,7 @@ func init() {
"store_supplier", "store_supplier",
"store", "store",
"direct", "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", configs.RABBITMQDSN,
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment