浏览代码

增加积分调用

zhangjinkun@topnet.net.cn 9 年之前
父节点
当前提交
a6e4c862fc
共有 3 个文件被更改,包括 41 次插入39 次删除
  1. 1 1
      core/src/main.go
  2. 0 38
      core/src/qfw/credit/credit.go
  3. 40 0
      core/src/qfw/member/credit/credit.go

+ 1 - 1
core/src/main.go

@@ -6,12 +6,12 @@ import (
 	"github.com/go-xweb/xweb"
 	_ "qfw/chat"
 	. "qfw/coreconfig"
-	_ "qfw/credit"
 	"qfw/filemanage"
 	_ "qfw/filter"
 	_ "qfw/front"
 	_ "qfw/manage"
 	_ "qfw/member"
+	_ "qfw/member/credit"
 	_ "qfw/member/message"
 	_ "qfw/microwebsite"
 	_ "qfw/mobile"

+ 0 - 38
core/src/qfw/credit/credit.go

@@ -1,38 +0,0 @@
-// credit
-package credit
-
-import (
-	"github.com/go-xweb/xweb"
-	"log"
-	. "qfw/coreconfig"
-	"qfw/util"
-	"qfw/util/rpc"
-)
-
-var Rc *rpc.RpcCall
-
-func init() {
-	util.ReadConfig(&SysConfig)
-	Rc = new(rpc.RpcCall)
-	Rc.Addr = SysConfig.CreditRpc
-	//添加模块解析
-	xweb.AddAction(&Credit{})
-}
-
-type Credit struct {
-	*xweb.Action
-	increditAjaxRqe xweb.Mapper `xweb:"/incredit"` //增加积分
-}
-
-//增加积分
-func (c *Credit) IncreditAjaxRqe() error {
-	otherParam := make(map[string]interface{})
-	otherParam["name"] = "zhangsan"
-	otherParam["age"] = 18
-	replay := 0
-	err := Rc.InCreadit(&rpc.CreditData{Code: "1", Uid: "2", Num: 3, OtherParam: otherParam}, &replay)
-	if err == nil {
-		log.Println("加分成功")
-	}
-	return nil
-}

+ 40 - 0
core/src/qfw/member/credit/credit.go

@@ -0,0 +1,40 @@
+// credit
+package credit
+
+import (
+	"github.com/go-xweb/xweb"
+	. "gopkg.in/mgo.v2/bson"
+	. "qfw/coreconfig"
+	"qfw/util"
+	"qfw/util/rpc"
+)
+
+var rc rpc.RpcCall
+var replay *int
+
+func init() {
+	util.ReadConfig(&SysConfig)
+	rc = rpc.RpcCall{Addr: SysConfig.CreditRpc}
+	//添加模块解析
+	xweb.AddAction(&Credit{})
+}
+
+type Credit struct {
+	*xweb.Action
+	increditAjaxRqe xweb.Mapper `xweb:"/member/incredit"` //增加积分
+}
+
+//增加积分
+func (c *Credit) IncreditAjaxRqe() error {
+	userId := c.GetSession("userId").(string)
+	code := c.GetString("code")
+	num, _ := c.GetInt("num")
+	param := make(map[string]interface{})
+	err := rc.InCreadit(&rpc.CreditData{Code: code, Uid: userId, Num: int(num), OtherParam: param}, replay)
+	result := false
+	if err == nil {
+		result = true
+	}
+	c.ServeJson(M{"result": result})
+	return nil
+}