Przeglądaj źródła

Merge branch 'cygx_10.3' of http://8.136.199.33:3000/hongze/hongze_cygx into debug

xingzai 1 rok temu
rodzic
commit
0f1ac7a21c
3 zmienionych plików z 69 dodań i 4 usunięć
  1. 42 0
      models/xzs_choose_category.go
  2. 4 4
      services/chart.go
  3. 23 0
      services/init_10.3.go

+ 42 - 0
models/xzs_choose_category.go

@@ -16,6 +16,7 @@ type CygxXzsChooseCategory struct {
 	CategoryId  int       `description:"权益文章对应分类,cygx_article"`
 	CreateTime  time.Time `description:"创建时间"`
 	ModifyTime  time.Time `description:"更新时间"`
+	IdCygx      int       `description:"cygx_report_mapping_cygx 表主键ID"`
 }
 
 // 根据手机号获取用户关注的产业
@@ -40,3 +41,44 @@ func RemoveCygxCategoryFllow(mobile string, CategoryId int) (err error) {
 	_, err = o.Raw(sql, mobile, CategoryId).Exec()
 	return
 }
+
+// 根据手机号获取用户关注的产业
+func GetCygxXzsChooseCategoryWhithIdCygxList() (items []*CygxXzsChooseCategory, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM cygx_xzs_choose_category WHERE id_cygx = 0`
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}
+
+type XzsChooseMapResp struct {
+	Id                  int    `description:"id"`
+	CategoryId          int    `description:"权益文章对应分类,cygx_article"`
+	CharPpermissionName string `description:"权限名称"`
+	MatchTypeName       string `description:"分类名称"`
+}
+
+// 根据手机号获取用户关注的产业
+func GetCygxXzsChooseCategoryMapList() (items []*XzsChooseMapResp, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT
+			r.id,
+			r.chart_permission_name,
+			r.match_type_name,
+			c.category_id 
+		FROM
+			cygx_report_mapping_cygx AS r
+			INNER JOIN cygx_report_mapping_group AS p ON p.id_cygx = r.id
+			INNER JOIN cygx_report_mapping_celue AS c ON c.category_id = p.category_id_celue 
+		WHERE
+			r.chart_permission_id IN (23,100000)`
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}
+
+// 修改数据
+func UpdateCygxXzsChooseCategory(idCygx, id int) (err error) {
+	o := orm.NewOrm()
+	sql := `UPDATE cygx_xzs_choose_category SET id_cygx=?  WHERE id=?   `
+	_, err = o.Raw(sql, idCygx, id).Exec()
+	return
+}

+ 4 - 4
services/chart.go

@@ -399,7 +399,7 @@ func DeleteCollectionChart(mobile string, chartId int) (err error) {
 func GetChartDetailByChartId(cont context.Context) (err error) {
 	listUpdate, err := models.GetChartCeluePushList()
 	if err != nil && err.Error() != utils.ErrNoRow() {
-		go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表ID:"+err.Error(), 2)
+		go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表1ID:"+err.Error(), 2)
 	}
 	//如果长度为零就不处理
 	if len(listUpdate) == 0 {
@@ -408,11 +408,11 @@ func GetChartDetailByChartId(cont context.Context) (err error) {
 	for _, v := range listUpdate {
 		err = GetChartDetailByApi(v.ChartId)
 		if err != nil {
-			go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表ID:"+strconv.Itoa(v.ChartId)+err.Error(), 2)
+			go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表2ID:"+strconv.Itoa(v.ChartId)+err.Error(), 2)
 		}
 		err = models.UpdateCygxChartCeluePush(v.ChartId)
 		if err != nil {
-			go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表ID:"+strconv.Itoa(v.ChartId)+err.Error(), 2)
+			go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表3ID:"+strconv.Itoa(v.ChartId)+err.Error(), 2)
 		}
 	}
 	return
@@ -427,7 +427,7 @@ func GetChartDetailByApi(chartId int) (err error) {
 	defer func() {
 		if err != nil {
 			//fmt.Println(err)
-			go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表ID:"+strconv.Itoa(chartId)+err.Error(), 2)
+			go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败,图表4ID:"+strconv.Itoa(chartId)+err.Error(), 2)
 			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetArticleListByApi ,图表ID:"+strconv.Itoa(chartId)+"ErrMsg:"+err.Error(), utils.EmailSendToUsers)
 		}
 	}()

+ 23 - 0
services/init_10.3.go

@@ -73,3 +73,26 @@ func init333() {
 	}
 	fmt.Println(listrMeet)
 }
+
+func init444() {
+	listMap, err := models.GetCygxXzsChooseCategoryMapList()
+	if err != nil {
+		fmt.Println(err)
+	}
+	mapReport := make(map[int]int)
+	for _, v := range listMap {
+		mapReport[v.CategoryId] = v.Id
+	}
+
+	list, err := models.GetCygxXzsChooseCategoryWhithIdCygxList()
+	if err != nil {
+		fmt.Println(err)
+	}
+	for _, v := range list {
+		fmt.Println(mapReport[v.CategoryId])
+		err = models.UpdateCygxXzsChooseCategory(mapReport[v.CategoryId], v.Id)
+		if err != nil {
+			fmt.Println(err)
+		}
+	}
+}