同步嘉悦增量指标

services/data/base_edb_lib.go

@@ -131,6 +131,9 @@ func HttpPost(url, postData string, params ...string) ([]byte, error) {
 	req.Header.Set("Content-Type", contentType)
 	req.Header.Set("authorization", utils.MD5(utils.APP_EDB_LIB_NAME_EN+utils.EDB_LIB_Md5_KEY))
 	resp, err := client.Do(req)
+	if err != nil {
+		return nil, err
+	}
 	defer resp.Body.Close()
 	b, err := ioutil.ReadAll(resp.Body)
 	fmt.Println("HttpPost:" + string(b))

services/data/base_from_jiayue.go

@@ -0,0 +1,32 @@
+package data
+
+import (
+	"context"
+	"eta/eta_task/services/alarm_msg"
+	"eta/eta_task/utils"
+	"fmt"
+)
+
+// SyncJiaYueNewIndex 同步嘉悦物产增量指标-每分钟
+func SyncJiaYueNewIndex(cont context.Context) (err error) {
+	defer func() {
+		if err != nil {
+			tips := "SyncJiaYueNewIndex-同步嘉悦物产增量指标失败, ErrMsg:\n" + err.Error()
+			utils.FileLog.Info(tips)
+			go alarm_msg.SendAlarmMsg(tips, 3)
+		}
+	}()
+
+	param := make(map[string]interface{})
+	uri := "jiayue_index/sync_new_index"
+	res, e := postRefreshEdbData(param, uri)
+	if e != nil {
+		err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
+		return
+	}
+	if res != nil && res.Ret != 200 {
+		err = fmt.Errorf("postRefreshEdbData fail")
+		return
+	}
+	return
+}

services/task.go

@@ -24,7 +24,7 @@ func Task() {
 // 生产环境需要走的任务
 func releaseTask() {
 	//同步指标
-	if utils.BusinessCode != "E2023080900" {
+	if utils.BusinessCode != utils.BusinessCodeRelease {
 		syncHzDataIndex := task.NewTask("syncHzDataIndex", "0 10,20,40,50 16,18 * * *", SyncHzDataIndex)
 		task.AddTask("syncHzDataIndex", syncHzDataIndex)
 	}
@@ -82,6 +82,12 @@ func releaseTask() {
 	// 每天清理三个月前的用户操作日志
 	clearAdminOperateLog := task.NewTask("clearAdminOperateLog", "0 20 23 * * *", ClearAdminOperateLog)
 	task.AddTask("定时清理用户操作日志", clearAdminOperateLog)
+
+	// 嘉悦物产-每分钟定时同步增量指标
+	if utils.BusinessCode == utils.BusinessCodeJiaYue {
+		syncJiaYueNewIndex := task.NewTask("syncJiaYueNewIndex", "0 */1 * * * *", data.SyncJiaYueNewIndex)
+		task.AddTask("定时同步嘉悦物产增量指标", syncJiaYueNewIndex)
+	}
 }
 
 func RefreshData(cont context.Context) (err error) {

utils/constants.go

@@ -116,3 +116,9 @@ var (
 const (
 	TEMPLATE_MSG_REPORT = iota + 1 //日度点评报告推送
 )
+
+// 商户号
+const (
+	BusinessCodeRelease = "E2023080900" // 生产环境
+	BusinessCodeJiaYue  = "E2023092201" // 嘉悦物产
+)