1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
package com.iailab.module.data.channel.http.collector.asdb;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.iailab.framework.common.util.http.HttpUtils;
import com.iailab.module.data.channel.http.entity.HttpApiEntity;
import com.iailab.module.data.channel.http.service.HttpApiService;
import com.iailab.module.data.common.enums.DataSourceType;
import com.iailab.module.data.common.utils.DateUtils;
import com.iailab.module.data.common.utils.TagUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
 
import java.util.*;
 
/**
 * 鞍信平均值接口
 * GET
 * http://10.50.37.1:8806/batch/xxb/getDagongHistoryPointAvg?point=E1Q00001001&startTime=2025-06-25 09:16:00&endTime=2025-06-25 09:17:00
 * {
 * "E1Q00001001": 16.747500000000002
 * }
 *
 * @author PanZhibao
 * @Description
 * @createTime 2025年06月27日
 */
@Slf4j
@Component
public class HttpCollectorForAsag {
 
    @Autowired
    private HttpApiService httpApiService;
 
    @Autowired
    private RedisTemplate redisTemplate;
 
    public static final long offset = 10;
 
    private final static String API_CODE = "ASAG";
 
    private static String api_url;
 
    private HttpApiEntity getHttpApi(String id) {
        return httpApiService.getFromCatch(id);
    }
 
    public Map<String, Object> getTagValues(List<Object[]> params, Date collectTime, Map<String, Object> result) {
        try {
            this.getByHtp(result, params, collectTime);
        } catch (Exception ex) {
            log.info("getTagValues异常");
            ex.printStackTrace();
            throw ex;
        }
        return result;
    }
 
    private void getByHtp(Map<String, Object> result, List<Object[]> params, Date collectTime) {
        if (StringUtils.isBlank(api_url)) {
            HttpApiEntity apiEntity = httpApiService.getByCode(API_CODE);
            api_url = apiEntity.getUrl();
        }
        for (Object[] item : params) {
            HttpApiEntity httpApi = this.getHttpApi(item[0].toString());
            String sourceName = httpApi.getCode();
            Calendar calendar = Calendar.getInstance();
            calendar.setTime(collectTime);
            Date endTime = calendar.getTime();
            calendar.add(Calendar.MINUTE, (Integer) item[2] * -1);
            Date startTime = calendar.getTime();
 
            Map<String, String> queryMap = new HashMap<>();
            String point = item[1].toString();
            queryMap.put("point", point);
            queryMap.put("startTime", DateUtils.format(startTime, "yyyy-MM-dd%20HH:mm:ss"));
            queryMap.put("endTime", DateUtils.format(endTime, "yyyy-MM-dd%20HH:mm:ss"));
            log.info("HttpCollectorForAsag:queryMap={}", JSON.toJSONString(queryMap));
            String responseStr = HttpUtils.sendGet(api_url, queryMap, "");
            log.info("HttpCollectorForAsag:responseStr={}", responseStr);
            JSONObject obj = JSON.parseObject(responseStr);
            if (obj.containsKey(point)) {
                Double value = obj.getDouble(point);
                result.put(TagUtils.genTagId(DataSourceType.HTTP.getCode(), sourceName, point), value);
            }
        }
    }
}