剑鱼

core/src/qfw/mobile/wxmenu.go

@@ -174,23 +174,26 @@ func (m *Mobile) SwordfishPay() error {
 								res["oprstatus"] = true
 								//初次提交积分时
 								//加上剑鱼是否推送过的逻辑判断
-								util.Try(func() {
-									//对用户进行推送
-									var repl int
-									clent, errs := rpc.DialHTTP("tcp", coreconfig.SysConfig.PushRpc)
-									defer clent.Close()
-									rpcData := qrpc.PushData{
-										Mopenid:  m.GetSession("s_m_openid").(string),
-										PushType: mapPush,
-									}
-									go clent.Call("PushInfo.PushMsg", &rpcData, &repl)
-									if errs == nil {
-										//修改剑鱼占位值
-
-									}
-								}, func(e interface{}) {
-									log.Println("给用户摄推送出错", e)
-								})
+								credit_a := util.IntAll(m.GetSession("credit_a"))
+								if !credit.AIsHasDo(credit.A_JYSCTS, credit_a) {
+									util.Try(func() {
+										//对用户进行推送
+										var repl int
+										clent, errs := rpc.DialHTTP("tcp", coreconfig.SysConfig.PushRpc)
+										defer clent.Close()
+										rpcData := qrpc.PushData{
+											Mopenid:  m.GetSession("s_m_openid").(string),
+											PushType: mapPush,
+										}
+										go clent.Call("PushInfo.PushMsg", &rpcData, &repl)
+										if errs == nil {
+											//修改剑鱼占位值
+											credit.CheckSword(userId.(string), credit.A_JYSCTS, credit_a, m.Action)
+										}
+									}, func(e interface{}) {
+										log.Println("给用户摄推送出错", e)
+									})
+								}
 							}
 						} else {
 							res["credit"] = i_credit