Forráskód Böngészése

Merge branch 'hotfix/fix_gpr_risk_classify' into debug

# Conflicts:
#	utils/constants.go
xyxie 3 hónapja
szülő
commit
ab032067f8
4 módosított fájl, 13 hozzáadás és 9 törlés
  1. 1 1
      services/gpr_risk.go
  2. 6 6
      services/sync_hz_data.go
  3. 5 1
      static/pcsg_task.json
  4. 1 1
      utils/constants.go

+ 1 - 1
services/gpr_risk.go

@@ -51,7 +51,7 @@ func SyncBaseFromGprRisk() (err error) {
 // GprRiskGPR地缘风险指数-分类
 func SyncBaseFromGprRiskClassify() (err error) {
 	data := make(map[string]interface{})
-	data["Source"] = utils.DATA_SOURCE_USDA_FAS
+	data["Source"] = utils.DATA_SOURCE_GPR_RISK
 	method := `classify/list`
 	result, err := HttpPost("SyncBaseFromGprRiskClassify", method, data)
 	if err != nil {

+ 6 - 6
services/sync_hz_data.go

@@ -157,12 +157,12 @@ func SyncHzDataIndex(cont context.Context) (err error) {
 
 	//GPR地缘风险指数
 	{
-		/*	//分类信息
-			err = SyncBaseFromGprRiskClassify()
-			if err != nil {
-				fmt.Println("SyncBaseFromGprRiskClassify Err:" + err.Error())
-				return
-			}*/
+		//分类信息
+		err = SyncBaseFromGprRiskClassify()
+		if err != nil {
+			fmt.Println("SyncBaseFromGprRiskClassify Err:" + err.Error())
+			return
+		}
 		//指标信息
 		err = SyncBaseFromGprRisk()
 		if err != nil {

+ 5 - 1
static/pcsg_task.json

@@ -58,5 +58,9 @@
   {
     "TaskKey": "IDpcsgDailyRun11",
     "TaskTime": "08:00"
+  },
+  {
+    "TaskKey": "IDpcsgDailyRunHistU3",
+    "TaskTime": "08:00"
   }
-]
+]

+ 1 - 1
utils/constants.go

@@ -120,8 +120,8 @@ const (
 	DATA_SOURCE_USDA_FAS                             = 96       //美国农业部
 	DATA_SOURCE_RZD                                  = 97       // 睿姿得数据
 	DATA_SOURCE_CALCULATE_STL                        = 98       // STL趋势分解 -> 98
-	DATA_SOURCE_AI_PREDICT_MODEL                     = 103      // AI预测模型
 	DATA_SOURCE_GPR_RISK                             = 102      //GPR地缘风险指数
+	DATA_SOURCE_AI_PREDICT_MODEL                     = 103      // AI预测模型
 )
 
 // 数据刷新频率