influxdb

src/jfw/modules/weixin/src/wx/wx.go

@@ -936,6 +936,29 @@ func updateUserLog(openid string) {
 	)
 	if err != nil {
 		log.Println("取消关注用户信息报错：", err.Error())
+		err := util.InsertInto("jy_logs",
+			"user_log",
+			[]influxdb.Tag{
+				{Key: "province", Value: "中国"},
+				{Key: "action", Value: "取关"},
+				{Key: "usersource", Value: "no-source"},
+				{Key: "model", Value: "no-model"},
+				{Key: "s_date", Value: util.FormatDate(&date, util.Date_Short_Layout)},
+			},
+			map[string]interface{}{
+				"openid":     openid,
+				"nickname":   nickname,
+				"referer":    referer,
+				"paramkey":   paramkey,
+				"activecode": activecode,
+				"browse":     browse,
+				"os":         os,
+				"sourceid":   shareId,
+				//"s_date":     util.FormatDate(&date, util.Date_Full_Layout),
+			},
+			time.Now().Add(rand.Int(100000)*time.Millisecond),
+			"autogen",
+		)
 	} else {
 		//timelog := time.Unix(infoTime, 0).Format("2006-01-02 15:04:05")
 		//timestamp, _ := time.Parse("2006-01-02 15:04:05", timelog) //新用户关注取关日期
@@ -959,7 +982,7 @@ func updateUserLog(openid string) {
 				"sourceid":   shareId,
 				//"s_date":     util.FormatDate(&date, util.Date_Full_Layout),
 			},
-			time.Now(),
+			time.Now().Add(rand.Int(100000)*time.Millisecond),
 			"autogen",
 		)
 		if err != nil {