Skip to content

wang / go_upload_sync

Go to a project
Commit 20d76816 by mushishixian
Options

fix

parent a9a1c24d
Inline Side-by-side
Showing with 10 additions and 13 deletions
app/queue/supplier.go
...@@ -11,24 +11,21 @@ import ( ...@@ -11,24 +11,21 @@ import (
type RecvPro struct { type RecvPro struct {
} }
var number int
func init() { func init() {
//queueExchange := rabbitmq.QueueExchange{ queueExchange := rabbitmq.QueueExchange{
// "supplier_erp", "supplier_erp",
// "", "",
// "", "",
// "", "",
// "amqp://guest:guest@192.168.2.232:5672/", "amqp://guest:guest@192.168.2.232:5672/",
//} }
//
//str := `{"supplierNumber":"C0000102","PTID":"L0000002","supplierID":"LxYAAAG0CQA3xn38","supplierName":"TestName"}` str := `{"supplierNumber":"C0000102","PTID":"L0000002","supplierID":"LxYAAAG0CQA3xn38","supplierName":"TestName"}`
//str := `{"supplierNumber":"C0000102","PTID":"12324","supplierID":"LxYAAAG0CQA3xn38"}` //str := `{"supplierNumber":"C0000102","PTID":"12324","supplierID":"LxYAAAG0CQA3xn38"}`
//rabbitmq.Send(queueExchange, str) rabbitmq.Send(queueExchange, str)
} }
func (t *RecvPro) Consumer(dataByte []byte) (err error) { func (t *RecvPro) Consumer(dataByte []byte) (err error) {
number++
message := string(dataByte) message := string(dataByte)
supplierCode := gjson.Get(message, "PTID").String() supplierCode := gjson.Get(message, "PTID").String()
erpSupplierCode := gjson.Get(message, "supplierNumber").String() erpSupplierCode := gjson.Get(message, "supplierNumber").String()
......
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