feat:增加当前节点留资数据返回

src/service/action/info.go

@@ -41,6 +41,11 @@ type NewResultSales struct {
 	Url        string      `json:"url"`
 }
 
+type FuncResult struct {
+	Data interface{}            `json:"data"`
+	Info map[string]interface{} `json:"info"`
+}
+
 func (i *Info) CollectInfo() {
 	defer qu.Catch()
 	r := func() NewResultSales {
@@ -192,10 +197,10 @@ func (i *Info) RetainedCapital() {
 		return
 	}
 	userId, _ := i.GetSession("userId").(string)
-	i.ServeJson(Result{Data: M{
+	i.ServeJson(FuncResult{Data: M{
 		"retainedCapital": Whether.Do(userId, source),
 		"fource":          Sysconfig.Source[source] != nil && Sysconfig.Source[source].Force,
-	}})
+	}, Info: Whether.CNode(userId)})
 }
 
 //发送验证码

src/service/action/whether.go

@@ -23,6 +23,36 @@ type whether struct {
 	redisCode string
 }
 
+/*
+* 判断当前节点是否已留资
+* 其他节点留资信息是否已覆盖当前节点
+ */
+func (w *whether) CNode(userId string) map[string]interface{} {
+	rM := map[string]interface{}{}
+	rdata, ok := MQFW.Find("saleLeads", map[string]interface{}{
+		"userid": userId,
+	}, `{"createtime":-1}`, nil, false, 0, 10)
+	if rdata != nil && len(*rdata) > 0 && ok {
+		for _, v := range *rdata {
+			for kk, vv := range v {
+				if vv == nil {
+					continue
+				}
+				if rM[kk] != nil {
+					continue
+				}
+				rM[kk] = vv
+			}
+		}
+		delete(rM, "_id")
+		delete(rM, "userid")
+		delete(rM, "createtime")
+		delete(rM, "client")
+		return rM
+	}
+	return map[string]interface{}{}
+}
+
 /**
 * 判断用户是否需要留资
 * @param userId 用户id