";
- }
- row += "| " + String.valueOf(cntO+cntV) + " | " + locust.eid + " | " + locust.lat_center + " | " + locust.lon_center + " | " + regionName + " = " + locust.region_id + " | " + locust.district + " = " + locust.district_id + " | " + locust.terrain + " | " + locust.village + " | " + locust.locust + " = " + locust.locust_type_id + " | " + locust.phase + " = " + locust.locust_have + " | " + locust.evp + " | " + locust.size + " = " + locust.drawPolygon + " | " + locust.date + " | ";
- row += "
\n";
+ locust.terrain = "null"; //У Россиян нет сельского округа
- //Если записи не существует то вставляем если существует то обновляем
- boolean exists = false; //Is there a record.
- Statement st;
- try {
- st = conn.createStatement();
- //ResultSet rs=null;
- try {
- sql = "select 1 from main.frmlocust where eid=" + String.valueOf(locust.eid);
- rs = st.executeQuery(sql);
- } catch (SQLException ex) {
- ex.printStackTrace();
- model.addAttribute("PreviewTable", "Error select");
- return "json";
- }
- if (rs != null) {
- if (rs.next())
- exists = true;
- }
- st.close();
- } catch (SQLException ex) {
- ex.printStackTrace();
- model.addAttribute("PreviewTable", "Error select 2");
- return "json";
- }
+ //Если те виды вредителей что нам нужны
+ if(!(
+ jsonObj.isNull("regionName") ||
+ jsonObj.getString("regionName").isEmpty() ||
+ locust.lat_center == null ||
+ Double.parseDouble(locust.lat_center) == 0 ||
+ locust.lon_center == null ||
+ Double.parseDouble(locust.lon_center) == 0 ||
+ locust.locust.equals("Совка ипсилон") ||
+ locust.locust.equals("Восточный майский хрущ") ||
+ locust.locust.equals("Кукурузный стеблевой мотылек") ||
+ locust.locust.equals("Картофельная, или болотная совка, лиловатая яровая совка") ||
+ locust.locust.equals("Луговой мотылёк") ||
+ locust.locust.equals("Хлопковая совка") ||
+ locust.locust.equals("Стеблевой кукурузный мотылек") ||
+ locust.locust.equals("Восточная луговая совка") ||
+ locust.locust.equals("Коричневая щитовка") ||
+ locust.locust.equals("Продолговатая (чайная) подушечница") ||
+ locust.locust.equals("Яблоневая запятовидная щитовка") ||
+ locust.locust.equals("Виноградная филлоксера") ||
+ locust.locust.equals("Бахчевая коровка")
+ )) {
- PreparedStatement stmt = null;
- sql = "";
- if (exists) {
- System.out.println(String.valueOf(cntV)+") update main.frmlocust");
- sql = "update main.frmlocust set\n"
- + " eid=?,\n"
- + " lat_center=?,\n"
- + " lon_center=?,\n"
- + " country_id=?,\n"
- + " region_id=?,\n"
- + " area=?,\n"
- + " district=?,\n"
- + " date=TO_TIMESTAMP(?, 'DD.MM.YYYY HH24:MI'),\n"
- + " description=?,\n"
- + " geom=ST_SetSRID(ST_GeomFromGeoJSON(?),4326),\n"
- + " locust_type_id=?,\n"
- + " imago_density=?,\n"
- + " kuliguli_density=?,\n"
- + " larva_density=?,\n"
- + " bio_hectare=?\n,"
- + " eggs_capsules_density=?,\n"
- + " bio_biotope_id=?\n"
- + " where eid='" + locust.eid + "'";
- try {
- stmt = conn.prepareStatement(sql);
- } catch (SQLException ex) {
- ex.printStackTrace();
- model.addAttribute("PreviewTable", "Error prepare 1");
- return "json";
- }
- } else {
- System.out.println(String.valueOf(cntV)+") insert into main.frmlocust");
- sql = "insert into main.frmlocust(\n"
- + " eid,\n" //1
- + " lat_center,\n" //2
- + " lon_center,\n" //3
- + " country_id,\n" //4
- + " region_id,\n" //5
- + " area,\n" //6
- + " district,\n" //7
- + " date,\n" //8
- + " description,\n" //9
- + " geom,\n" //10
- + " locust_type_id,\n" //11
- + " imago_density,\n" //12
- + " kuliguli_density,\n" //13
- + " larva_density,\n" //14
- + " bio_hectare,\n" //15
- + " eggs_capsules_density,\n" //16
- + " bio_biotope_id\n" //17
- + ")values(\n"
- + " ?,\n" //1 eid
- + " ?,\n" //2 lat1
- + " ?,\n" //3 lon1
- + " ?,\n" //4 country_id
- + " ?,\n" //5 region_id
- + " ?,\n" //6 district (area)
- + " ?,\n" //7 district (area)
- + " TO_TIMESTAMP(?, 'DD.MM.YYYY HH24:MI'),\n" //8 date
- + " ?,\n" //9 description
- + " ST_SetSRID(ST_GeomFromGeoJSON(?),4326),\n" //10 geom
- + " ?,\n" //11 locust_type_id
- + " ?,\n" //12 imago_density
- + " ?,\n" //13 kuliguli_density
- + " ?,\n" //14 larva_density
- + " ?,\n" //15
- + " ?,\n" //16
- + " ?\n" //17
- + ")";
- try {
- stmt = conn.prepareStatement(sql);
- } catch (SQLException ex) {
- ex.printStackTrace();
- model.addAttribute("PreviewTable", "Error prepare 2");
- return "json";
- }
- }
+ //I check if there is already such a record in the database, if not, I insert it, if there is, I update it
+ UpdateLocust updateLocust = new UpdateLocust(jdbcTemplate);
+ if(updateLocust.update(locust))
+ count++;
+ System.out.println("Count = "+count);
- try {
- stmt.setLong(1, Long.parseLong(locust.eid));
- stmt.setDouble(2, Double.parseDouble(locust.lat_center));
- stmt.setDouble(3, Double.parseDouble(locust.lon_center));
- stmt.setInt(4, 7);
- stmt.setInt(5, Integer.parseInt(locust.region_id));
- stmt.setString(6, locust.district); //Пишу в поле "area"
- stmt.setString(7, null);
- stmt.setTimestamp(8, locust.date);
- stmt.setString(9, locust.description);
- stmt.setString(10, locust.drawPolygon);
- stmt.setInt(11, Integer.parseInt(locust.locust_type_id));
- if (locust.imago_density != null)
- stmt.setFloat(12, Float.parseFloat(locust.imago_density));
- else
- stmt.setNull(12, Types.FLOAT);
- if (locust.kuliguli_density != null)
- stmt.setFloat(13, Float.parseFloat(locust.kuliguli_density));
- else
- stmt.setNull(13, Types.FLOAT);
- if (locust.larva_density != null)
- stmt.setFloat(14, Float.parseFloat(locust.larva_density));
- else
- stmt.setNull(14, Types.FLOAT);
- if (locust.bio_hectare != null)
- stmt.setFloat(15, Float.parseFloat(locust.bio_hectare));
- else
- stmt.setNull(15, Types.FLOAT);
- if (locust.eggs_capsules_density != null)
- stmt.setFloat(16, Float.parseFloat(locust.eggs_capsules_density));
- else
- stmt.setNull(16, Types.FLOAT);
- if (locust.bio_biotope_id != null)
- stmt.setFloat(17, Float.parseFloat(locust.bio_biotope_id));
- else
- stmt.setNull(17, Types.INTEGER);
-
- } catch (SQLException ex) {
- ex.printStackTrace();
- model.addAttribute("PreviewTable", "Error set data");
- return "json";
- }
- //Выпоняю запрос на свтавку либо обновление
- try {
- stmt.execute();
- } catch (SQLException ex) {
- ex.printStackTrace();
- model.addAttribute("PreviewTable", "Error execute 0");
- return "json";
- }
- cntV++;
-
- //Скачиваю фотографию для анкеты
+ //Downloading photos from locust survey forms
sb = new StringBuilder();
try {
String strURL = "https://rscagex.ru/pmon/rest/getPhotosByParentId?token=QVOUE97HBSI6LBSGJGQZMP3KPSS1QK&parentId=" + locust.eid;
- URL url = new URL(strURL);
+ URI uri = new URI(strURL);
+ URL url = uri.toURL();
HttpURLConnection hConn = (HttpURLConnection) url.openConnection();
hConn.setRequestMethod("GET");
- //hConn.setRequestProperty("Range","bytes=" + posStart + "-" + posEnd);
hConn.connect();
int responseCode = hConn.getResponseCode();
if (responseCode / 100 == 2) //Code 206 is "Partial Content"
{
InputStream inputStream = hConn.getInputStream();
- //FileOutputStream outputStream = new FileOutputStream(strFile);
int bytesRead;
byte[] buffer = new byte[BUFFER_SIZE];
while ((bytesRead = inputStream.read(buffer)) != -1) {
- //outputStream.write(buffer, 0, bytesRead);
sb.append(new String(buffer, 0, bytesRead));
}
- //outputStream.close();
inputStream.close();
}
hConn.disconnect();
@@ -1294,12 +1056,12 @@ public class AcceptJSON implements ServletContextAware {
String base64 = sb.toString();
if (base64.length() > 10) {
- //Так как мне присылаю неправильный jSOM то пытаюсь его поправить,.
+ //Trying to fix the malformed JSON string received in base64 format...
base64 = base64.replace("[", "[\"");
base64 = base64.replace("]", "\"]");
base64 = base64.replace(", ", "\",\"");
- String strFile = "O:\\temp\\CCALM\\ru_" + locust.eid;
+ String strFile = data_dir + "data/frmlocust/ru_" + locust.eid; //First pat of file name
int pos = 0;
JSONArray jsonArrayIMGS = new JSONArray(base64);
@@ -1308,14 +1070,6 @@ public class AcceptJSON implements ServletContextAware {
pos++;
if (pos > 3) break;
- //try {
- // BufferedWriter writer = new BufferedWriter(new FileWriter(strFile));
- // writer.write(jsonObjIMG);
- // writer.close();
- //} catch (IOException e1) {
- // e1.printStackTrace();
- //}
-
byte[] decodedString = null;
try {
decodedString = Base64.getDecoder().decode(jsonObjIMG);
@@ -1353,74 +1107,49 @@ public class AcceptJSON implements ServletContextAware {
buffered.getGraphics().drawImage(img, 0, 0, null);
}
try {
- //BufferedImage bIMG = toBufferedImage(img);
ImageIO.write(buffered, "jpg", new File(strFile + "_" + pos + ".jpg"));
} catch (IOException ex) {
ex.printStackTrace();
}
}
-
- if (pos > 3) {
- break;
- } else {
- sql = "";
- if (pos == 1) {
- sql = "update main.frmlocust set image_name1='ru_" + locust.eid + "_" + pos + ".jpg" + "' where eid=" + locust.eid;
- }
- if (pos == 2) {
- sql = "update main.frmlocust set image_name2='ru_" + locust.eid + "_" + pos + ".jpg" + "' where eid=" + locust.eid;
- }
- if (pos == 3) {
- sql = "update main.frmlocust set image_name3='ru_" + locust.eid + "_" + pos + ".jpg" + "' where eid=" + locust.eid;
- }
- if (sql.length() > 0) {
- try {
- st = conn.createStatement();
- st.execute(sql);
- st.close();
- } catch (SQLException ex) {
- ex.printStackTrace();
- model.addAttribute("PreviewTable", "Error update img");
- return "json";
- }
- }
+ sql = "";
+ if (pos == 1) {
+ sql = "update main.frmlocust set image_name1=:image_name where eid=:eid";
}
+ if (pos == 2) {
+ sql = "update main.frmlocust set image_name2=:image_name where eid=:eid";
+ }
+ if (pos == 3) {
+ sql = "update main.frmlocust set image_name3=:image_name where eid=:eid";
+ }
+ MapSqlParameterSource insertParams = new MapSqlParameterSource();
+ insertParams.addValue("image_name", "ru_" + locust.eid + "_" + pos + ".jpg", Types.VARCHAR);
+ insertParams.addValue("eid", locust.eid, Types.INTEGER);
+ jdbcTemplate.update(sql, insertParams);
+
}
}
}
} //equals("Вредители")
-
}
-
}
-
- table += row;
}
- System.out.println("Обработка = "+String.valueOf(cntO));
- System.out.println("Вредители = "+String.valueOf(cntV));
+ //Save last download date
+ String insertSql = """
+ insert into integration.days_ru(date, count) values (:date, :count)
+ """;
+ MapSqlParameterSource insertParams = new MapSqlParameterSource();
+ insertParams.addValue("date", lastDate, Types.DATE);
+ insertParams.addValue("count", count, Types.INTEGER);
+ jdbcTemplate.update(insertSql, insertParams);
- table += "