no message

services/wx_user.go

@@ -99,237 +99,237 @@ func UpdateWxUserLabel(cont context.Context) (err error) {
 
 	//处理 前一天移动之后的用户的公司记录信息
 
-	{
-		startDate := time.Now().AddDate(0, 0, -1).Format(utils.FormatDate)
-		endDate := time.Now().Format(utils.FormatDate)
-		listUpdateUser, err := models.GetWxUserOpLogList(startDate, endDate)
-		if err != nil && err.Error() != utils.ErrNoRow() {
-			return err
-		}
-		var userIds string
-		var mobiles string
-		if len(listUpdateUser) > 0 {
-			for _, v := range listUpdateUser {
-				userIds += strconv.Itoa(v.UserId) + ","
-				mobiles += "'" + v.Mobile + "',"
-			}
-		}
-		userIds = strings.TrimRight(userIds, ",")
-		mobiles = strings.TrimRight(mobiles, ",")
-
-		//如果用户ID不为空那么就处理这些用户的记录信息
-		if userIds != "" {
-			var condition string
-			//condition = ` AND user_id IN (` + userIds + `)`
-			condition = ` AND mobile IN (` + mobiles + `)`
-			//处理用户的文章收藏
-			listCollect, err := models.GetCygxArticleCollectList(condition)
-			if err != nil && err.Error() != utils.ErrNoRow() {
-				fmt.Println("GetAddCygxArticleCollectList ，Err" + err.Error())
-			}
-			if len(listCollect) > 0 {
-				for _, v := range listCollect {
-					user, err := models.GetWxUserItemByUserId(v.UserId)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName)
-						err = models.UpdateCygxArticleCollect(user)
-						if err != nil {
-							fmt.Println("UpdateCygxArticleCollect ，Err" + err.Error())
-						}
-					}
-				}
-			}
-			//处理用户的文章收藏 end
-
-			//修改用户关注的产业
-			listIndustryFllow, err := models.GetCygxIndustryFllowList(condition)
-			if err != nil {
-				fmt.Println("GetCygxIndustryFllowList ，Err" + err.Error())
-			}
-			for k, v := range listIndustryFllow {
-				if v.Mobile != "" {
-					user, err := models.GetWxUserItemByUserId(v.UserId)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName, k)
-						err = models.UpdateCygxIndustryFllow(user)
-						if err != nil {
-							fmt.Println("UpdateCygxIndustryFllow ，Err" + err.Error())
-						}
-					}
-				}
-			}
-
-			//修改用户产业关注的产业end
-
-			//修改用户的阅读记录
-			listArticlePv, err := models.GetArticleHistoryRecordAllByMobileList(condition)
-			if err != nil {
-				fmt.Println("GetArticleHistoryRecordAllByMobileList ，Err" + err.Error())
-			}
-			for k, v := range listArticlePv {
-				if v.Mobile != "" {
-					user, err := models.GetWxUserItemByMobile(v.Mobile)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName, k)
-						err = models.UpdateCygxArticleHistoryRecordAll(user)
-						if err != nil {
-							fmt.Println("UpdateCygxArticleCollect ，Err" + err.Error())
-						}
-					}
-				}
-			}
-			//修改用户的阅读记录end
-
-			//处理用户的搜索记录
-			listSearch, err := models.GetCygxSearchKeyWordList(condition)
-			if err != nil {
-				fmt.Println("GetArticleHistoryRecordAllByMobileList ，Err" + err.Error())
-			}
-
-			for k, v := range listSearch {
-				if v.Mobile != "" {
-					user, err := models.GetWxUserItemByUserId(v.UserId)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName, k)
-						err = models.UpdateCygxSearchKeyWord(user)
-						if err != nil {
-							fmt.Println("UpdateCygxSearchKeyWord ，Err" + err.Error())
-						}
-					}
-				}
-			}
-
-			// 处理用户的作者关注
-			lisDepartmentF, err := models.GetArticleDepartmentFollowByMobileList(condition)
-			if err != nil {
-				fmt.Println("GetArticleDepartmentFollowByMobileList ，Err" + err.Error())
-				return err
-			}
-			for k, v := range lisDepartmentF {
-				if v.Mobile != "" {
-					user, err := models.GetWxUserItemByUserId(v.UserId)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName, k)
-						err = models.UpdateCygxArticleDepartmentFollow(user)
-						if err != nil {
-							fmt.Println("UpdateCygxArticleDepartmentFollow ，Err" + err.Error())
-						}
-					}
-				}
-			}
-			// 处理用户的作者关注end
-
-			// 处理用户的活动视频播放
-			listActivityVideo, err := models.GetActivityVideoHistoryByMobileList(condition)
-			if err != nil {
-				fmt.Println("GetArticleDepartmentFollowByMobileList ，Err" + err.Error())
-				return err
-			}
-			for k, v := range listActivityVideo {
-				if v.Mobile != "" {
-					user, err := models.GetWxUserItemByUserId(v.UserId)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName, k)
-						err = models.UpdateCygxActivityVideoHistory(user)
-						if err != nil {
-							fmt.Println("UpdateCygxActivityVideoHistory ，Err" + err.Error())
-						}
-					}
-				}
-			}
-			// 处理用户的活动视频播放end
-
-			// 处理用户的活动音频播放
-			listActivityVoice, err := models.GetActivityVoiceHistoryByMobileList(condition)
-			if err != nil {
-				fmt.Println("GetActivityVoiceHistoryByMobileList ，Err" + err.Error())
-				return err
-			}
-			for k, v := range listActivityVoice {
-				if v.Mobile != "" {
-					user, err := models.GetWxUserItemByUserId(v.UserId)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName, k)
-						err = models.UpdateCygxActivityVoiceHistory(user)
-						if err != nil {
-							fmt.Println("UpdateCygxActivityVoiceHistory ，Err" + err.Error())
-						}
-					}
-				}
-			}
-			// 处理用户的活动音频播放end
-
-			// 处理用户产业视频的播放记录
-			listMicroRoadshow, err := models.GetMicroRoadshowVideoHistoryByMobileList(condition)
-			if err != nil {
-				fmt.Println("GetMicroRoadshowVideoHistoryByMobileList ，Err" + err.Error())
-				return err
-			}
-			for k, v := range listMicroRoadshow {
-				if v.Mobile != "" {
-					user, err := models.GetWxUserItemByUserId(v.UserId)
-					if err != nil && err.Error() != utils.ErrNoRow() {
-						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-					}
-					if user != nil {
-						fmt.Println(user.RealName, k)
-						err = models.UpdateCygxMicroRoadshowVideoHistory(user)
-						if err != nil {
-							fmt.Println("UpdateCygxMicroRoadshowVideoHistory ，Err" + err.Error())
-						}
-					}
-				}
-			}
-			// 处理用户产业视频的播放记录 end
-
-			//如果手机号不为空，则更新用户的报名信息
-			if mobiles != "" {
-				condition = ` AND mobile IN (` + mobiles + `)`
-				listSingUp, err := models.GetCygxActivitySignupByMobileList(condition)
-				if err != nil {
-					fmt.Println("GetCygxChartCollectByMobileList ，Err" + err.Error())
-				}
-				//fmt.Println("更新用户的报名信息长度", len(listSingUp))
-				for _, v := range listSingUp {
-					if v.Mobile != "" {
-						user, err := models.GetWxUserItemByMobile(v.Mobile)
-						if err != nil && err.Error() != utils.ErrNoRow() {
-							fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
-						}
-						if user != nil {
-							err = models.UpdateCygxActivitySignup(user)
-							if err != nil {
-								fmt.Println("UpdateCygxActivitySignup ，Err" + err.Error())
-								//return err
-							}
-						}
-					}
-				}
-			}
-
-		}
-	}
+	//{
+	//	startDate := time.Now().AddDate(0, 0, -1).Format(utils.FormatDate)
+	//	endDate := time.Now().Format(utils.FormatDate)
+	//	listUpdateUser, err := models.GetWxUserOpLogList(startDate, endDate)
+	//	if err != nil && err.Error() != utils.ErrNoRow() {
+	//		return err
+	//	}
+	//	var userIds string
+	//	var mobiles string
+	//	if len(listUpdateUser) > 0 {
+	//		for _, v := range listUpdateUser {
+	//			userIds += strconv.Itoa(v.UserId) + ","
+	//			mobiles += "'" + v.Mobile + "',"
+	//		}
+	//	}
+	//	userIds = strings.TrimRight(userIds, ",")
+	//	mobiles = strings.TrimRight(mobiles, ",")
+	//
+	//	//如果用户ID不为空那么就处理这些用户的记录信息
+	//	if userIds != "" {
+	//		var condition string
+	//		//condition = ` AND user_id IN (` + userIds + `)`
+	//		condition = ` AND mobile IN (` + mobiles + `)`
+	//		//处理用户的文章收藏
+	//		listCollect, err := models.GetCygxArticleCollectList(condition)
+	//		if err != nil && err.Error() != utils.ErrNoRow() {
+	//			fmt.Println("GetAddCygxArticleCollectList ，Err" + err.Error())
+	//		}
+	//		if len(listCollect) > 0 {
+	//			for _, v := range listCollect {
+	//				user, err := models.GetWxUserItemByUserId(v.UserId)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName)
+	//					err = models.UpdateCygxArticleCollect(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxArticleCollect ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//		//处理用户的文章收藏 end
+	//
+	//		//修改用户关注的产业
+	//		listIndustryFllow, err := models.GetCygxIndustryFllowList(condition)
+	//		if err != nil {
+	//			fmt.Println("GetCygxIndustryFllowList ，Err" + err.Error())
+	//		}
+	//		for k, v := range listIndustryFllow {
+	//			if v.Mobile != "" {
+	//				user, err := models.GetWxUserItemByUserId(v.UserId)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName, k)
+	//					err = models.UpdateCygxIndustryFllow(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxIndustryFllow ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//
+	//		//修改用户产业关注的产业end
+	//
+	//		//修改用户的阅读记录
+	//		listArticlePv, err := models.GetArticleHistoryRecordAllByMobileList(condition)
+	//		if err != nil {
+	//			fmt.Println("GetArticleHistoryRecordAllByMobileList ，Err" + err.Error())
+	//		}
+	//		for k, v := range listArticlePv {
+	//			if v.Mobile != "" {
+	//				user, err := models.GetWxUserItemByMobile(v.Mobile)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName, k)
+	//					err = models.UpdateCygxArticleHistoryRecordAll(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxArticleCollect ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//		//修改用户的阅读记录end
+	//
+	//		//处理用户的搜索记录
+	//		listSearch, err := models.GetCygxSearchKeyWordList(condition)
+	//		if err != nil {
+	//			fmt.Println("GetArticleHistoryRecordAllByMobileList ，Err" + err.Error())
+	//		}
+	//
+	//		for k, v := range listSearch {
+	//			if v.Mobile != "" {
+	//				user, err := models.GetWxUserItemByUserId(v.UserId)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName, k)
+	//					err = models.UpdateCygxSearchKeyWord(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxSearchKeyWord ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//
+	//		// 处理用户的作者关注
+	//		lisDepartmentF, err := models.GetArticleDepartmentFollowByMobileList(condition)
+	//		if err != nil {
+	//			fmt.Println("GetArticleDepartmentFollowByMobileList ，Err" + err.Error())
+	//			return err
+	//		}
+	//		for k, v := range lisDepartmentF {
+	//			if v.Mobile != "" {
+	//				user, err := models.GetWxUserItemByUserId(v.UserId)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName, k)
+	//					err = models.UpdateCygxArticleDepartmentFollow(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxArticleDepartmentFollow ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//		// 处理用户的作者关注end
+	//
+	//		// 处理用户的活动视频播放
+	//		listActivityVideo, err := models.GetActivityVideoHistoryByMobileList(condition)
+	//		if err != nil {
+	//			fmt.Println("GetArticleDepartmentFollowByMobileList ，Err" + err.Error())
+	//			return err
+	//		}
+	//		for k, v := range listActivityVideo {
+	//			if v.Mobile != "" {
+	//				user, err := models.GetWxUserItemByUserId(v.UserId)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName, k)
+	//					err = models.UpdateCygxActivityVideoHistory(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxActivityVideoHistory ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//		// 处理用户的活动视频播放end
+	//
+	//		// 处理用户的活动音频播放
+	//		listActivityVoice, err := models.GetActivityVoiceHistoryByMobileList(condition)
+	//		if err != nil {
+	//			fmt.Println("GetActivityVoiceHistoryByMobileList ，Err" + err.Error())
+	//			return err
+	//		}
+	//		for k, v := range listActivityVoice {
+	//			if v.Mobile != "" {
+	//				user, err := models.GetWxUserItemByUserId(v.UserId)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName, k)
+	//					err = models.UpdateCygxActivityVoiceHistory(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxActivityVoiceHistory ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//		// 处理用户的活动音频播放end
+	//
+	//		// 处理用户产业视频的播放记录
+	//		listMicroRoadshow, err := models.GetMicroRoadshowVideoHistoryByMobileList(condition)
+	//		if err != nil {
+	//			fmt.Println("GetMicroRoadshowVideoHistoryByMobileList ，Err" + err.Error())
+	//			return err
+	//		}
+	//		for k, v := range listMicroRoadshow {
+	//			if v.Mobile != "" {
+	//				user, err := models.GetWxUserItemByUserId(v.UserId)
+	//				if err != nil && err.Error() != utils.ErrNoRow() {
+	//					fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//				}
+	//				if user != nil {
+	//					fmt.Println(user.RealName, k)
+	//					err = models.UpdateCygxMicroRoadshowVideoHistory(user)
+	//					if err != nil {
+	//						fmt.Println("UpdateCygxMicroRoadshowVideoHistory ，Err" + err.Error())
+	//					}
+	//				}
+	//			}
+	//		}
+	//		// 处理用户产业视频的播放记录 end
+	//
+	//		//如果手机号不为空，则更新用户的报名信息
+	//		if mobiles != "" {
+	//			condition = ` AND mobile IN (` + mobiles + `)`
+	//			listSingUp, err := models.GetCygxActivitySignupByMobileList(condition)
+	//			if err != nil {
+	//				fmt.Println("GetCygxChartCollectByMobileList ，Err" + err.Error())
+	//			}
+	//			//fmt.Println("更新用户的报名信息长度", len(listSingUp))
+	//			for _, v := range listSingUp {
+	//				if v.Mobile != "" {
+	//					user, err := models.GetWxUserItemByMobile(v.Mobile)
+	//					if err != nil && err.Error() != utils.ErrNoRow() {
+	//						fmt.Println("GetWxUserItemByUserId ，Err" + err.Error())
+	//					}
+	//					if user != nil {
+	//						err = models.UpdateCygxActivitySignup(user)
+	//						if err != nil {
+	//							fmt.Println("UpdateCygxActivitySignup ，Err" + err.Error())
+	//							//return err
+	//						}
+	//					}
+	//				}
+	//			}
+	//		}
+	//
+	//	}
+	//}
 
 	//处理用户标签
 	//for _, vUser := range listUser {