Skip to content

孙龙 / golang_asynctask

Go to a project
Commit 9d1d18b2 by 孙龙
Options

up

parent 655e4321
Inline Side-by-side
Showing with 52 additions and 22 deletions
app/service/crm/recv_com_user_scrvice.go
...@@ -41,38 +41,68 @@ func DispenseMsg(data string) (err error){ ...@@ -41,38 +41,68 @@ func DispenseMsg(data string) (err error){
pushMsg := comUser{} pushMsg := comUser{}
if table == "lie_invoice_company" && php2go.InArray(action_type,action_type_slice){ if table == "lie_invoice_company" && php2go.InArray(action_type,action_type_slice){
for field,_ := range olddata{ if len(olddata) > 0{
if php2go.InArray(field,lie_invoice_company_field){ //修改
//分发 for field,_ := range olddata{
pushMsg.ComId = gjson.Parse(data).Get("data.id").Int() if php2go.InArray(field,lie_invoice_company_field){
if pushMsg.ComId == 0{ //分发
pushMsg.ComId = gjson.Parse(data).Get("data.id").Int()
if pushMsg.ComId == 0{
break
}
data,err := json.Marshal(&pushMsg)
if err == nil{
DispenseMsgToMq(string(data))
}
break break
} }
data,err := json.Marshal(&pushMsg) }
if err == nil{ }else{
DispenseMsgToMq(string(data)) //新增
} pushMsg.ComId = gjson.Parse(data).Get("data.id").Int()
break if pushMsg.ComId == 0{
return
}
_data,err := json.Marshal(&pushMsg)
if err == nil{
DispenseMsgToMq(string(_data))
} }
} }
} }
if table == "lie_invoice_com_user" && php2go.InArray(action_type,action_type_slice){ if table == "lie_invoice_com_user" && php2go.InArray(action_type,action_type_slice){
for field,_ := range olddata{ if len(olddata) > 0 {
if php2go.InArray(field,lie_invoice_com_user_field){ //修改
//分发 for field, _ := range olddata {
pushMsg.ComId = gjson.Parse(data).Get("data.com_id").Int() if php2go.InArray(field, lie_invoice_com_user_field) {
pushMsg.UserId = gjson.Parse(data).Get("data.user_id").Int() //分发
pushMsg.SaleId = gjson.Parse(data).Get("data.sale_id").Int() pushMsg.ComId = gjson.Parse(data).Get("data.com_id").Int()
if pushMsg.ComId == 0{ pushMsg.UserId = gjson.Parse(data).Get("data.user_id").Int()
pushMsg.SaleId = gjson.Parse(data).Get("data.sale_id").Int()
if pushMsg.ComId == 0 {
break
}
data, err := json.Marshal(&pushMsg)
if err == nil {
DispenseMsgToMq(string(data))
}
break break
} }
data,err := json.Marshal(&pushMsg) }
if err == nil{ }else{
DispenseMsgToMq(string(data)) //新增
} pushMsg.ComId = gjson.Parse(data).Get("data.com_id").Int()
break pushMsg.UserId = gjson.Parse(data).Get("data.user_id").Int()
pushMsg.SaleId = gjson.Parse(data).Get("data.sale_id").Int()
if pushMsg.ComId == 0 {
return
}
data, err := json.Marshal(&pushMsg)
if err == nil {
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