Skip to content

孙龙 / golang_asynctask

Go to a project
Commit 2354f43f by 孙龙
Options

up

parent 750bf4aa
Inline Side-by-side
Showing with 6 additions and 0 deletions
app/service/crm/recv_com_user_scrvice.go
...@@ -38,6 +38,9 @@ func DispenseMsg(data string) (err error){ ...@@ -38,6 +38,9 @@ func DispenseMsg(data string) (err error){
if php2go.InArray(field,lie_invoice_company_field){ if php2go.InArray(field,lie_invoice_company_field){
//分发 //分发
pushMsg.ComId = gjson.Parse(data).Get("data.id").Int() pushMsg.ComId = gjson.Parse(data).Get("data.id").Int()
if pushMsg.ComId == 0{
return
}
data,err := json.Marshal(&pushMsg) data,err := json.Marshal(&pushMsg)
if err == nil{ if err == nil{
DispenseMsgToMq(string(data)) DispenseMsgToMq(string(data))
...@@ -54,6 +57,9 @@ func DispenseMsg(data string) (err error){ ...@@ -54,6 +57,9 @@ func DispenseMsg(data string) (err error){
pushMsg.ComId = gjson.Parse(data).Get("data.com_id").Int() pushMsg.ComId = gjson.Parse(data).Get("data.com_id").Int()
pushMsg.UserId = gjson.Parse(data).Get("data.user_id").Int() pushMsg.UserId = gjson.Parse(data).Get("data.user_id").Int()
pushMsg.SaleId = gjson.Parse(data).Get("data.sale_id").Int() pushMsg.SaleId = gjson.Parse(data).Get("data.sale_id").Int()
if pushMsg.ComId == 0{
return
}
data,err := json.Marshal(&pushMsg) data,err := json.Marshal(&pushMsg)
if err == nil{ if err == nil{
DispenseMsgToMq(string(data)) DispenseMsgToMq(string(data))
......
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