| | |
| | | logger.Debug("findEsData.param:", prama) |
| | | //数据解析 |
| | | tokenRes := esutil.GetEsDataReq(url, prama, true) |
| | | tmpAllDate := esutil.ResponseData(tokenRes) |
| | | //fmt.Println(tokenRes) |
| | | tmpAllDate := make(map[string]interface{}) |
| | | tmpDate := make(map[string][]interface{}) |
| | | tmpAllDate["total"] = tokenRes["total"] |
| | | data := tokenRes["datalist"] |
| | | for _, masterInfoValues := range data.([]interface{}) { |
| | | masterInfo := masterInfoValues.(map[string]interface{}) |
| | | sources := make(map[string]interface{}, 0) |
| | | activateInfo := make(map[string]interface{}) |
| | | if masterInfo["linkTagInfo"] != nil { |
| | | linkTagInfo := masterInfo["linkTagInfo"].([]interface{}) |
| | | delete(masterInfo, "linkTagInfo") |
| | | if len(linkTagInfo) > 0 { |
| | | slaveList := make([]interface{}, 0) |
| | | slaveList = append(slaveList, masterInfo) |
| | | slaveList = append(slaveList, linkTagInfo...) |
| | | for i, j := 0, len(slaveList)-1; i < j; i, j = i+1, j-1 { |
| | | slaveList[i], slaveList[j] = slaveList[j], slaveList[i] |
| | | } |
| | | sources["list"] = slaveList |
| | | activateInfo = slaveList[0].(map[string]interface{}) |
| | | } else { |
| | | sources["list"] = []interface{}{ |
| | | masterInfo, |
| | | } |
| | | activateInfo = masterInfo |
| | | } |
| | | } else { |
| | | if _, ok := masterInfo["linkTagInfo"]; ok { |
| | | delete(masterInfo, "linkTagInfo") |
| | | } |
| | | sources["list"] = []interface{}{ |
| | | masterInfo, |
| | | } |
| | | activateInfo = masterInfo |
| | | |
| | | } |
| | | |
| | | sources["activeObject"] = activateInfo |
| | | |
| | | tmpDate["datalist"] = append(tmpDate["datalist"], sources) |
| | | } |
| | | tmpAllDate["datalist"] = tmpDate["datalist"] |
| | | //tmpAllDate := make(map[string]interface{}) |
| | | //tmpDate := make(map[string][]interface{}) |
| | | //tmpAllDate["total"] = tokenRes["total"] |
| | | //data := tokenRes["datalist"] |
| | | //for _, masterInfoValues := range data.([]interface{}) { |
| | | // masterInfo := masterInfoValues.(map[string]interface{}) |
| | | // sources := make(map[string]interface{}, 0) |
| | | // activateInfo := make(map[string]interface{}) |
| | | // if masterInfo["linkTagInfo"] != nil { |
| | | // linkTagInfo := masterInfo["linkTagInfo"].([]interface{}) |
| | | // delete(masterInfo, "linkTagInfo") |
| | | // if len(linkTagInfo) > 0 { |
| | | // slaveList := make([]interface{}, 0) |
| | | // slaveList = append(slaveList, masterInfo) |
| | | // slaveList = append(slaveList, linkTagInfo...) |
| | | // for i, j := 0, len(slaveList)-1; i < j; i, j = i+1, j-1 { |
| | | // slaveList[i], slaveList[j] = slaveList[j], slaveList[i] |
| | | // } |
| | | // sources["list"] = slaveList |
| | | // activateInfo = slaveList[0].(map[string]interface{}) |
| | | // } else { |
| | | // sources["list"] = []interface{}{ |
| | | // masterInfo, |
| | | // } |
| | | // activateInfo = masterInfo |
| | | // } |
| | | // } else { |
| | | // if _, ok := masterInfo["linkTagInfo"]; ok { |
| | | // delete(masterInfo, "linkTagInfo") |
| | | // } |
| | | // sources["list"] = []interface{}{ |
| | | // masterInfo, |
| | | // } |
| | | // activateInfo = masterInfo |
| | | // |
| | | // } |
| | | // |
| | | // sources["activeObject"] = activateInfo |
| | | // |
| | | // tmpDate["datalist"] = append(tmpDate["datalist"], sources) |
| | | //} |
| | | //tmpAllDate["datalist"] = tmpDate["datalist"] |
| | | return tmpAllDate |
| | | } |
| | | |