|
| 1 | +package innchkeckerpack.service; |
| 2 | + |
| 3 | +import com.google.gson.Gson; |
| 4 | +import innchkeckerpack.domain.Organization; |
| 5 | +import innchkeckerpack.domain.Suggestions; |
| 6 | +import innchkeckerpack.repos.OrganizationRepo; |
| 7 | +import org.apache.http.HttpResponse; |
| 8 | +import org.apache.http.client.ClientProtocolException; |
| 9 | +import org.apache.http.client.HttpClient; |
| 10 | +import org.apache.http.client.methods.HttpPost; |
| 11 | +import org.apache.http.entity.ContentType; |
| 12 | +import org.apache.http.entity.StringEntity; |
| 13 | +import org.apache.http.impl.client.DefaultHttpClient; |
| 14 | +import org.jsoup.Jsoup; |
| 15 | +import org.jsoup.nodes.Document; |
| 16 | + |
| 17 | +import java.io.BufferedReader; |
| 18 | +import java.io.IOException; |
| 19 | +import java.io.InputStreamReader; |
| 20 | +import java.io.UnsupportedEncodingException; |
| 21 | +import java.util.HashMap; |
| 22 | +import java.util.Map; |
| 23 | + |
| 24 | +public class OrganizationService implements OrganizationRepo { |
| 25 | + |
| 26 | + private final String USER_AGENT = "Mozilla/5.0"; |
| 27 | + private final String URL = "https://suggestions.dadata.ru/suggestions/api/4_1/rs/suggest/party"; |
| 28 | + private String postResultString; |
| 29 | + |
| 30 | + @Override |
| 31 | + public String sendingPost(String inn) { |
| 32 | + |
| 33 | + |
| 34 | + HttpClient client = new DefaultHttpClient(); |
| 35 | + HttpPost post = new HttpPost(URL); |
| 36 | + |
| 37 | + post.setHeader("User-Agent", USER_AGENT); |
| 38 | + post.setHeader("Content-Type", "application/json"); |
| 39 | + post.setHeader("Accept", "application/json"); |
| 40 | + post.setHeader("Authorization", "Token 3312ffbd375be3421d41e78a7a8e414f2bce1d6c"); |
| 41 | + HttpResponse response = null; |
| 42 | + try { |
| 43 | + //StringEntity requestEntity = new StringEntity("{ \"query\": \"сбербанк\" }", ContentType.APPLICATION_JSON);post.setEntity(requestEntity); // По имени организации |
| 44 | + post.setEntity(new StringEntity("{ \"query\": \"" + inn + "\" }", ContentType.create("application/json"))); |
| 45 | + response = client.execute(post); |
| 46 | + System.out.println("\nSending 'POST' request to URL : " + URL); |
| 47 | + System.out.println("Post parameters : " + post.getEntity()); |
| 48 | + System.out.println("Response Code : " + |
| 49 | + response.getStatusLine().getStatusCode()); |
| 50 | + |
| 51 | + } catch (ClientProtocolException e) { |
| 52 | + e.printStackTrace(); |
| 53 | + } catch (IOException e) { |
| 54 | + e.printStackTrace(); |
| 55 | + } |
| 56 | + |
| 57 | + |
| 58 | + try { |
| 59 | + BufferedReader rd = new BufferedReader( |
| 60 | + new InputStreamReader(response.getEntity().getContent(), "UTF8")); |
| 61 | + |
| 62 | + StringBuffer result = new StringBuffer(); |
| 63 | + String line = ""; |
| 64 | + while ((line = rd.readLine()) != null) { |
| 65 | + result.append(line); |
| 66 | + } |
| 67 | + postResultString = result.toString(); |
| 68 | + |
| 69 | + } catch (IOException e) { |
| 70 | + e.printStackTrace(); |
| 71 | + } |
| 72 | + |
| 73 | + |
| 74 | + return postResultString; |
| 75 | + } |
| 76 | + |
| 77 | + @Override |
| 78 | + public Suggestions jsonParsing(String postResultString) { |
| 79 | + Gson g = new Gson(); |
| 80 | + Suggestions suggestions = g.fromJson(postResultString.toString(), Suggestions.class); |
| 81 | + |
| 82 | + for (Organization organization : suggestions.getSuggestions()) |
| 83 | + { |
| 84 | + organization.setValue(organization.getValue() != null ? organization.getValue() : "Не указано"); |
| 85 | + organization.setUnrestricted_value(organization.getUnrestricted_value() != null ? organization.getUnrestricted_value() : "Не указано"); |
| 86 | + //organization.getData().setCapital(organization.getData().getCapital() != null ? toUTF(organization.getData().getCapital()) : "Не указано"); |
| 87 | + // organization.getData().setFounders(organization.getData().getFounders() != null ? toUTF(organization.getData().getFounders()) : "Не указано"); |
| 88 | + organization.getData().setInn(organization.getData().getInn() != null ? organization.getData().getInn() : "Не указано"); |
| 89 | + organization.getData().setKpp(organization.getData().getKpp() != null ? organization.getData().getKpp() : "Не указано"); |
| 90 | + organization.getData().setOgrn(organization.getData().getOgrn() != null ? organization.getData().getOgrn() : "Не указано"); |
| 91 | + organization.getData().setOkpo(organization.getData().getOkpo() != null ? organization.getData().getOkpo() : "Не указано"); |
| 92 | + organization.getData().setOkved(organization.getData().getOkved() != null ? organization.getData().getOkved() : "Не указано"); |
| 93 | + // organization.getData().setManagers(organization.getData().getManagers() != null ? toUTF(organization.getData().getManagers()) : "Не указано"); |
| 94 | + //organization.getData().setPhones(organization.getData().getPhones() != null ? toUTF(organization.getData().getPhones()) : "Не указано"); |
| 95 | + //organization.getData().setEmails(organization.getData().getEmails() != null ? toUTF(organization.getData().getEmails()) : "Не указано"); |
| 96 | + //organization.getData().getManagement().setName(organization.getData().getManagement().getName() != null ? toUTF(organization.getData().getManagement().getName()) : "Не указано"); |
| 97 | + // organization.getData().getManagement().setPost(organization.getData().getManagement().getPost() != null ? toUTF(organization.getData().getManagement().getPost()) : "Не указано"); |
| 98 | + organization.getData().getOpf().setType(organization.getData().getOpf().getType() != null ? organization.getData().getOpf().getType() : "Не указано"); |
| 99 | + organization.getData().getOpf().setFull(organization.getData().getOpf().getFull() != null ? organization.getData().getOpf().getFull() : "Не указано"); |
| 100 | + organization.getData().getName().setFull(organization.getData().getName().getFull() != null ? organization.getData().getName().getFull() : "Не указано"); |
| 101 | + organization.getData().getName().setFull_with_opf(organization.getData().getName().getFull_with_opf() != null ? organization.getData().getName().getFull_with_opf() : "Не указано"); |
| 102 | + organization.getData().getName().setShort_with_opf(organization.getData().getName().getShort_with_opf() != null ? organization.getData().getName().getShort_with_opf() : "Не указано"); |
| 103 | + organization.getData().getAddress().setValue(organization.getData().getAddress().getValue() != null ? organization.getData().getAddress().getValue() : "Не указано"); |
| 104 | + |
| 105 | + } |
| 106 | + |
| 107 | + return suggestions; |
| 108 | + } |
| 109 | + |
| 110 | + @Override |
| 111 | + public String gettingUpDate() { |
| 112 | + Document html = null; |
| 113 | + |
| 114 | + |
| 115 | + try { |
| 116 | + html = Jsoup.connect("https://dadata.ru/clean/").get(); |
| 117 | + } catch (IOException e) { |
| 118 | + e.printStackTrace(); |
| 119 | + } |
| 120 | + |
| 121 | + String[] servNames = html.body().getElementsByClass("col-xs-7").text().split(" "); |
| 122 | + String[] servUpdates = html.body().getElementsByClass("col-xs-5").text().split(" "); |
| 123 | + Map<String, String> dictionares = new HashMap<>(); |
| 124 | + |
| 125 | + System.out.println(servUpdates[3]); |
| 126 | + return servUpdates[3]; |
| 127 | + } |
| 128 | + |
| 129 | + |
| 130 | + |
| 131 | +} |
0 commit comments