增加在数据点计算规则后数据点名称加_n的适配

yangys

2024-10-09 7ef593e1e3c35aaeecf9318f0b3941230d3ed002

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
package com.qianwen.mdc.collect.utils;
 
import java.util.HashMap;
import java.util.List;
import java.util.Map;
//import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
//import org.apache.rocketmq.common.UtilAll;
import com.qianwen.core.tool.utils.StringUtil;
 
public class CommonUtil {
    /*
    public static String changeInstanceNameToPID(DefaultMQPushConsumer consumer) {
        String instanceName = consumer.getInstanceName();
        if (consumer.getInstanceName().equals("DEFAULT")) {
            instanceName = UtilAll.getPid() + "#" + System.nanoTime();
        }
        return instanceName;
    }
    */
    public static String getReallyCacheName(String cacheName, String keyPrefix, String key) {
        return cacheName.concat("::").concat(keyPrefix).concat(key);
    }
 
    public static String getReallyCacheName(String cacheName, String keyPrefix, String key, Object... args) {
        return StringUtil.format(cacheName.concat("::").concat(keyPrefix).concat(key), args);
    }
    /*
    public static Map<String, List> groupList(List list, int size) {
        int listSize = list.size();
        int index = size;
        int keyToken = 0;
        Map map = new HashMap();
        int i = 0;
        while (true) {
            int i2 = i;
            if (i2 < list.size()) {
                if (i2 + size > listSize) {
                    index = listSize - i2;
                }
                List newList = list.subList(i2, i2 + index);
                map.put("keyName" + keyToken, newList);
                keyToken++;
                i = i2 + size;
            } else {
                return map;
            }
        }
    }*/
}