12345678910111213141516171819202122232425262728 |
- for (int i = 0; i < objects.size(); i++) {
- response = (List<String>) objects.get(i);
- value = response.get(1);
- if (value == null || "".equals(value) || value.contains("-nan")) continue;
- datetime = response.get(2);
- if (StringUtils.isEmpty(datetime)) continue;
- pointid = response.get(0);
- if (StringUtils.isEmpty(pointid)) continue;
- if (ChangedSave.map.containsKey(pointid)) {
- if (!Objects.equals(ChangedSave.map.get(pointid), datetime)) {
- ChangedSave.map.put(pointid, datetime);
- ts = Long.valueOf(datetime) * 1000;
- val = Double.valueOf(value);
- //j++;
- sb.append(pointid).append(" VALUES (").append(ts).append(",").append(val).append(") ");
- }
- } else {
- ChangedSave.map.put(pointid, datetime);
- }
- }
- sb2str = sb.toString();
- if ("INSERT INTO ".equals(sb2str)) return;
- for (String taosUrl : redisConfig.getTaosUrls().split(",")) {
- redis2TaosApi.putSql(URI.create(taosUrl), sb2str);
- }
|