1.txt 1.4 KB

12345678910111213141516171819202122232425262728
  1. for (int i = 0; i < objects.size(); i++) {
  2. response = (List<String>) objects.get(i);
  3. value = response.get(1);
  4. if (value == null || "".equals(value) || value.contains("-nan")) continue;
  5. datetime = response.get(2);
  6. if (StringUtils.isEmpty(datetime)) continue;
  7. pointid = response.get(0);
  8. if (StringUtils.isEmpty(pointid)) continue;
  9. if (ChangedSave.map.containsKey(pointid)) {
  10. if (!Objects.equals(ChangedSave.map.get(pointid), datetime)) {
  11. ChangedSave.map.put(pointid, datetime);
  12. ts = Long.valueOf(datetime) * 1000;
  13. val = Double.valueOf(value);
  14. //j++;
  15. sb.append(pointid).append(" VALUES (").append(ts).append(",").append(val).append(") ");
  16. }
  17. } else {
  18. ChangedSave.map.put(pointid, datetime);
  19. }
  20. }
  21. sb2str = sb.toString();
  22. if ("INSERT INTO ".equals(sb2str)) return;
  23. for (String taosUrl : redisConfig.getTaosUrls().split(",")) {
  24. redis2TaosApi.putSql(URI.create(taosUrl), sb2str);
  25. }