| | |
| | | JSONObject json = JSONObject.parseObject(item.toString()); |
| | | String collectId = firstNotBlank(json.getString("devDn"), json.getString("esnCode")); |
| | | String stationId = json.getString("stationCode"); |
| | | Integer devTypeId = json.getInteger("devTypeId"); |
| | | if (StringUtils.isBlank(collectId) || StringUtils.isBlank(stationId) |
| | | || existingKeys.contains(collectId) || !pendingKeys.add(collectId)) { |
| | | || existingKeys.contains(collectId) || !pendingKeys.add(collectId) || devTypeId != 1) { |
| | | continue; |
| | | } |
| | | TStationCollect collect = new TStationCollect(); |