新增广期所数据同步

services/hz_data_api.go

@@ -50,6 +50,7 @@ func HttpPost(funcName, method string, postDataMap map[string]interface{}) (resu
 			return "", err
 		}
 		result = string(body)
+		fmt.Println("HttpPost Result:" + string(body))
 	}
 	utils.FileLog.Info(fmt.Sprintf("请求函数:%s ;返回体:%s", funcName, result))
 	return

services/task.go

@@ -17,6 +17,7 @@ func Task() {
 	//如果是生产环境，才需要走这些任务
 	if utils.RunMode == "release" {
 		releaseTask()
+
 	}
 
 	// 定时发布智能研报

services/trade_guangzhou.go

@@ -17,8 +17,9 @@ func SyncFromGuangzhouClassify() (err error) {
 	result, err := HttpPost("SyncFromGuangzhouClassify", method, data)
 	if err != nil {
 		fmt.Println("SyncFromGuangzhouClassify HttpPost Err:", err.Error())
+		return err
 	}
-	utils.FileLog.Info(result)
+	utils.FileLog.Info("SyncFromGuangzhouClassify:" + result)
 	fmt.Println("SyncFromGuangzhouClassify result:", result)
 
 	respObj := new(data_manage.GuangzhouClassifyResp)
@@ -59,7 +60,7 @@ func SyncFromGuangzhouIndex() (err error) {
 		fmt.Println("SyncFromGuangzhou HttpPost Err:", err.Error())
 	}
 	utils.FileLog.Info(result)
-	fmt.Println("SyncFromGuangzhou result:", result)
+	fmt.Println("SyncFromGuangzhouIndex result:", result)
 
 	respObj := new(data_manage.GuangzhouIndexResp)
 	err = json.Unmarshal([]byte(result), &respObj)
@@ -79,6 +80,7 @@ func SyncFromGuangzhouIndex() (err error) {
 
 	for _, item := range respObj.Data {
 		if _, ok := existIndexMap[item.BaseFromTradeGuangzhouIndexId]; !ok {
+			
 			newID, err := data_manage.AddBaseFromTradeGuangzhouIndex(item)
 			if err != nil {
 				fmt.Println("insert error:", err)
@@ -120,7 +122,7 @@ func SyncFromGuangzhouContract() (err error) {
 	obj := new(data_manage.BaseFromTradeGuangzhouIndex)
 
 	for _, item := range respObj.Data {
-		if _, ok := existContractMap[item.BaseFromTradeGuangzhouClassifyId]; !ok {
+		if _, ok := existContractMap[item.BaseFromTradeGuangzhouContractId]; !ok {
 			err = obj.AddBaseFromTradeGuangzhouContract(item)
 			if err != nil {
 				fmt.Println("AddBaseFromTradeGuangzhouContract error:", err)