Commit 792cad52 by mushishixian

优化

parent 14ecfe48
Showing with 7 additions and 3 deletions
/logs /logs
/.idea /.idea
/config/*.toml /config/*.toml
*.properties
*.exe
*.exe~
gowatch.yml
...@@ -23,7 +23,7 @@ func init() { ...@@ -23,7 +23,7 @@ func init() {
//} //}
// //
//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)
} }
...@@ -33,8 +33,8 @@ func (t *RecvPro) Consumer(dataByte []byte) (err error) { ...@@ -33,8 +33,8 @@ func (t *RecvPro) Consumer(dataByte []byte) (err error) {
supplierCode := gjson.Get(message, "PTID").String() supplierCode := gjson.Get(message, "PTID").String()
erpSupplierCode := gjson.Get(message, "supplierNumber").String() erpSupplierCode := gjson.Get(message, "supplierNumber").String()
erpSupplierName := gjson.Get(message, "supplierName").String() erpSupplierName := gjson.Get(message, "supplierName").String()
err = service.AddSupplierSync(supplierCode, erpSupplierCode,erpSupplierName) err = service.AddSupplierSync(supplierCode, erpSupplierCode, erpSupplierName)
if err!=nil { if err != nil {
fmt.Println(err) fmt.Println(err)
} }
return nil return nil
......
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