自动更新行业深度，新 相关标签

models/industrial_management.go

@@ -1,8 +1,10 @@
 package models
 
 import (
+	"hongze/hongze_cygx/utils"
 	"rdluck_tools/orm"
 	"strconv"
+	"time"
 )
 
 type IndustrialManagementRep struct {
@@ -147,3 +149,51 @@ ORDER BY
 	err = o.Raw(sql, industrialManagementId).QueryRow(&item)
 	return
 }
+
+//修改产业是否属于新标签
+func UpdateIndustrialIsNewLabel() (err error) {
+	o := orm.NewOrm()
+	resultTime := time.Now().AddDate(0, -2, 0).Format(utils.FormatDateTime)
+	var condition string
+	condition += ` AND is_hand_new_label = 0 AND  create_time < ` + "'" + resultTime + "'"
+	msql := " UPDATE cygx_industrial_management SET is_new_label = 0 WHERE 1 = 1 " + condition
+	_, err = o.Raw(msql).Exec()
+	return
+}
+
+type IndustrialManagementId struct {
+	IndustrialManagementId string `description:"产业Id"`
+}
+
+//获取归类产业报告数量大于10的
+func GetIndustrialMorethan10() (items []*IndustrialManagementId, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM
+			( SELECT industrial_management_id, COUNT( 1 ) AS ca FROM cygx_industrial_article_group_management GROUP BY industrial_management_id ) AS na 
+			WHERE ca > 10 `
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}
+
+//修改产业是否属于深度标签
+func UpdateIndustrialIsDeepLabel(idStr string) (err error) {
+	o := orm.NewOrm()
+	msql := `UPDATE cygx_industrial_management
+	SET is_deep_label = 1
+	WHERE
+	industrial_management_id IN (
+		SELECT
+	industrial_management_id
+	FROM
+	cygx_industrial_article_group_management AS a
+	INNER JOIN cygx_article AS b ON b.id = a.cygx_article_id
+	WHERE
+	1 = 1
+	AND b.match_type_name = '行业深度'
+	AND a.industrial_management_id IN ( ` + idStr + `)
+	AND is_hand_deep_label = 0
+	GROUP BY
+	a.industrial_management_id)`
+	_, err = o.Raw(msql).Exec()
+	return
+}

models/tactics.go

@@ -105,7 +105,7 @@ func GetTacticsListAll2() (list []*Tactics2, err error) {
 			INNER JOIN article_content AS b ON a.id=b.article_id
 			INNER JOIN article_category AS c ON a.id=c.article_id
 			INNER JOIN article_categoryinfo AS d ON c.category_id=d.id
-			WHERE a.publish_status=1  AND d.id IN (7,9,11,28,32,45,51,52,57,62,64,65,66,67,69,71,72,74,79,80,84,85,86,87,88,89,90,93,95,96,98,100) `
+	WHERE a.publish_status=1  AND d.id IN (7,9,11,28,32,45,51,52,57,62,64,65,66,67,69,71,72,74,79,80,84,85,86,87,88,89,90,93,95,96,98,100) `
 	//AND a.id NOT IN (3454,3456,3457,3459,2449,2450,2453,2454,2459,2530,2583,2663,2670,2699,2715,2732,2748,2759,2399,2356,2870,3173,2978,2826,3470) `
 	//IN(85,71)
 	_, err = o.Raw(sql).QueryRows(&list)

services/industrial_management.go

@@ -0,0 +1,37 @@
+package services
+
+import (
+	"fmt"
+	"hongze/hongze_cygx/models"
+	"strings"
+)
+
+//修改活动状态
+func UpdateIndustrialManagementLabel() (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println("修改失败，Err:", err.Error())
+		}
+	}()
+	fmt.Println("修改状态0000")
+	go models.UpdateIndustrialIsNewLabel()
+
+	list, err := models.GetIndustrialMorethan10()
+	if err != nil {
+		return err
+	}
+	if len(list) == 0 {
+		return
+	}
+	var idStr string
+	for _, v := range list {
+		idStr += v.IndustrialManagementId + ","
+	}
+	idStr = strings.TrimRight(idStr, ",")
+
+	go models.UpdateIndustrialIsDeepLabel(idStr)
+	fmt.Println(idStr)
+	//go models.UpdateActivitySattusToComplete()
+	fmt.Println("修改状态完成")
+	return
+}

services/task.go

@@ -30,9 +30,12 @@ func Task() {
 
 	//updateActivitySattus := toolbox.NewTask("updateActivitySattus", "0 */5 * * * *", UpdateActivitySattus)
 	//toolbox.AddTask("updateActivitySattus", updateActivitySattus)
+	//SyncTacticsListAddreport()
+	//UpdateActivitySattus()
+	//updateActivitySattus := toolbox.NewTask("syncTacticsListAddreport", "0 */1 * * * *", UpdateActivitySattus)
+	//toolbox.AddTask("updateActivitySattus", updateActivitySattus)
 
-	UpdateActivitySattus()
-
+	UpdateIndustrialManagementLabel()
 	toolbox.StartTask()
 
 	//if utils.RunMode == "debug" {