浏览代码

Merge branch 'bzq/dev' of eta_mini/eta_mini_bridge into debug

鲍自强 8 月之前
父节点
当前提交
1893c739db
共有 3 个文件被更改,包括 28 次插入27 次删除
  1. 10 2
      controllers/report.go
  2. 15 22
      models/report.go
  3. 3 3
      services/template_msg.go

+ 10 - 2
controllers/report.go

@@ -560,6 +560,7 @@ func (this *ReportController) Today() {
 		chartPermissionMap1[v.ChartPermissionId] = v
 	}
 	// 组合数据
+	finalList := make([]*models.ReportList, 0)
 	for _, v := range list {
 		var permissionNames []string
 		for _, vv := range classifyToPermissionMap2[v.ClassifyIdSecond] {
@@ -569,10 +570,13 @@ func (this *ReportController) Today() {
 			}
 		}
 		v.PermissionNames = utils.Unique(permissionNames)
+		if len(v.PermissionNames) != 0 {
+			finalList = append(finalList, v)
+		}
 	}
 
 	resp := new(response.ReportListResp)
-	resp.List = list
+	resp.List = finalList
 
 	br.Ret = 200
 	br.Success = true
@@ -659,6 +663,7 @@ func (this *ReportController) RecentList() {
 		chartPermissionMap1[v.ChartPermissionId] = v
 	}
 	// 组合数据
+	finalList := make([]*models.ReportList, 0)
 	for _, v := range list {
 		var permissionNames []string
 		for _, vv := range classifyToPermissionMap2[v.ClassifyIdSecond] {
@@ -668,13 +673,16 @@ func (this *ReportController) RecentList() {
 			}
 		}
 		v.PermissionNames = utils.Unique(permissionNames)
+		if len(v.PermissionNames) != 0 {
+			finalList = append(finalList, v)
+		}
 	}
 
 	page := paging.GetPaging(currentIndex, pageSize, total)
 
 	resp := new(response.ReportListResp)
 	resp.Paging = page
-	resp.List = list
+	resp.List = finalList
 
 	br.Ret = 200
 	br.Success = true

+ 15 - 22
models/report.go

@@ -45,19 +45,22 @@ func GetReportDailyListCount() (count int, err error) {
 	return
 }
 
+//	func GetReportDailyList(startSize, pageSize int) (items []*ReportList, err error) {
+//		o := orm.NewOrmUsingDB("rddp")
+//		sql := ` SELECT a.id,a.add_type,a.classify_id_first,a.classify_name_first,a.classify_id_second,a.classify_name_second,a.title,a.abstract,a.author,a.frequency,
+//				a.create_time,a.modify_time,a.state,a.publish_time,a.stage,a.msg_is_send,b.id AS classify_id,b.classify_name,b.descript,b.report_author,b.author_descript,
+//	            b.report_img_url,b.head_img_url,b.avatar_img_url,b.column_img_url,a.video_url,a.video_name,a.video_play_seconds,a.video_size,
+//	            CASE WHEN DATE(a.publish_time)=DATE(NOW()) THEN 1 ELSE 0 END AS is_current_date
+//	            FROM report AS a
+//				INNER JOIN  classify AS b ON a.classify_id_second=b.id
+//				WHERE (a.state=2 OR a.state=6) AND DATE(a.publish_time)=DATE(NOW())
+//				ORDER BY  a.publish_time DESC LIMIT ?,?  `
+//		_, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
+//		return
+//	}
 func GetReportDailyList(startSize, pageSize int) (items []*ReportList, err error) {
 	o := orm.NewOrmUsingDB("rddp")
-	sql := ` SELECT a.id,a.add_type,a.classify_id_first,a.classify_name_first,a.classify_id_second,a.classify_name_second,a.title,a.abstract,a.author,a.frequency,
-			a.create_time,a.modify_time,a.state,a.publish_time,a.stage,a.msg_is_send,b.id AS classify_id,b.classify_name,b.descript,b.report_author,b.author_descript,
-            b.report_img_url,b.head_img_url,b.avatar_img_url,b.column_img_url,a.video_url,a.video_name,a.video_play_seconds,a.video_size,
-            CASE WHEN DATE(a.publish_time)=DATE(NOW()) THEN 1 ELSE 0 END AS is_current_date
-            FROM report AS a
-			INNER JOIN  classify AS b ON a.classify_id_second=b.id
-			WHERE (a.state=2 OR a.state=6) AND DATE(a.publish_time)=DATE(NOW()) AND a.classify_id_second IN (
-				SELECT DISTINCT classify_id
-				FROM chart_permission_search_key_word_mapping
-			)
-			ORDER BY  a.publish_time DESC LIMIT ?,?  `
+	sql := ` SELECT * FROM report WHERE (state=2 OR state=6) AND DATE(publish_time)=DATE(NOW()) ORDER BY publish_time DESC LIMIT ?,?  `
 	_, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
 	return
 }
@@ -76,17 +79,7 @@ func GetReportRecentListCount() (count int, err error) {
 
 func GetReportRecentList(startSize, pageSize int) (items []*ReportList, err error) {
 	o := orm.NewOrmUsingDB("rddp")
-	sql := ` SELECT a.id,a.add_type,a.classify_id_first,a.classify_name_first,a.classify_id_second,a.classify_name_second,a.title,a.abstract,a.author,a.frequency,
-			a.create_time,a.modify_time,a.state,a.publish_time,a.stage,a.msg_is_send,b.id AS classify_id,b.classify_name,b.descript,b.report_author,b.author_descript,
-            b.report_img_url,b.head_img_url,b.avatar_img_url,b.column_img_url,a.video_url,a.video_name,a.video_play_seconds,a.video_size,
-            CASE WHEN DATE(a.publish_time)=DATE(NOW()) THEN 1 ELSE 0 END AS is_current_date
-            FROM report AS a
-			INNER JOIN  classify AS b ON a.classify_id_second=b.id
-			WHERE (a.state=2 OR a.state=6) AND a.classify_id_second IN (
-				SELECT DISTINCT classify_id
-				FROM chart_permission_search_key_word_mapping
-			)
-			ORDER BY  a.publish_time DESC LIMIT ?,?  `
+	sql := ` SELECT * FROM report WHERE (state=2 OR state=6) ORDER BY publish_time DESC LIMIT ?,?  `
 	_, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
 	return
 }

+ 3 - 3
services/template_msg.go

@@ -171,18 +171,18 @@ func SendMultiTemplateMsg(sendData map[string]interface{}, items []*OpenIdList,
 		}
 		// 推送消息记录
 		{
-			go func(v *OpenIdList) {
+			go func() {
 				sendStatus := 1
 				if e != nil {
 					sendStatus = 0
 				}
 				resultJson, _ := json.Marshal(result)
-				err = AddUserTemplateRecord(v.UserId, sendStatus, sendType, v.OpenId, string(data), string(resultJson))
+				err = AddUserTemplateRecord(item.UserId, sendStatus, sendType, item.OpenId, string(data), string(resultJson))
 				if err != nil {
 					utils.FileLog.Info("新增模板消息推送记录失败, Err:" + err.Error())
 					return
 				}
-			}(item)
+			}()
 		}
 	}
 	return