| | |
| | | package com.example.utils; |
| | | |
| | | import cn.hutool.core.util.RandomUtil; |
| | | import cn.hutool.json.JSONArray; |
| | | import cn.hutool.json.JSONObject; |
| | | import cn.hutool.json.JSONUtil; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | |
| | | import java.io.BufferedReader; |
| | | import java.io.IOException; |
| | | import java.io.InputStreamReader; |
| | | import java.io.OutputStream; |
| | | import java.io.*; |
| | | import java.net.HttpURLConnection; |
| | | import java.net.URL; |
| | | import java.nio.charset.StandardCharsets; |
| | | import java.sql.*; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.ArrayList; |
| | | import java.util.*; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * @Company: 西安路泰科技有限公司 |
| | |
| | | * @Date: 2024/5/21 16:41 |
| | | */ |
| | | public class DictionaryUtil { |
| | | private static final String CONFIG_PATH = "D:\\ltkjprojectconf\\config.properties"; |
| | | private static final Logger log = LoggerFactory.getLogger(DictionaryUtil.class); |
| | | private static String BASE_API_URL = "https://mock.mengxuegu.com/mock/664d3dbce45d2156fa209c80/example/api/His/HisRequest"; |
| | | private static String BASE_API_URL = ""; |
| | | // 请求代码总集合 |
| | | private static List<String> methods = new ArrayList<>(); |
| | | private static final String url = "jdbc:mysql://localhost:3306/test_urlreq"; |
| | | private static final String user = "root"; |
| | | private static final String password = "Root_ltkj123"; |
| | | // private static final String url = "jdbc:mysql://localhost:3306/test_urlreq"; |
| | | // private static final String user = "root"; |
| | | // private static final String password = "Root_ltkj123"; |
| | | // 需要分页的代码集合 |
| | | private static List<String> limits = new ArrayList<>(); |
| | | |
| | |
| | | // methods.add("XYZDZD"); |
| | | // methods.add("ZYZDZD"); |
| | | // methods.add("SSZD"); |
| | | // methods.add("ZLXTXZD"); |
| | | methods.add("ZLXTXZD"); |
| | | // methods.add("ZYZZZFZD"); |
| | | // methods.add("YJJFXMZD"); |
| | | // methods.add("EJJFXMZD"); |
| | |
| | | // methods.add("JCBWFLZD"); |
| | | // methods.add("JCBWZD"); |
| | | // methods.add("JCBWMSZD"); |
| | | // methods.add("JFXMGLJCBWZD"); |
| | | methods.add("JFXMGLJCBWZD"); |
| | | // methods.add("JFZHXMGLJCBWZD"); |
| | | // |
| | | // methods.add("TJDWXZZD"); |
| | |
| | | |
| | | public static void main(String[] args) { |
| | | DictionaryUtil util = new DictionaryUtil(); |
| | | // util.exec(); |
| | | // String json = "{\"Response\":{\"ResultCode\":\"0\",\"ResultContent\":\"查询成功\",\"ResultData\":[{\"RowNumber\":1,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0000000002\",\"KSMC\":\"质控股\",\"KSPY\":\"ZKG\",\"FLKSDM\":\"0000000001\",\"FLKSMC\":\"办公\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":2,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0001\",\"KSMC\":\"总务库房\",\"KSPY\":\"ZWKF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"\",\"KSDZ\":null,\"LXDH\":\"\",\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":3,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0002\",\"KSMC\":\"西药库房\",\"KSPY\":\"XYKF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":4,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0003\",\"KSMC\":\"门诊西药房\",\"KSPY\":\"MZXYF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"门诊一楼西药房取药\",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":5,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0004\",\"KSMC\":\"门诊中药房\",\"KSPY\":\"MZZYF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"门诊一楼中药房取药\",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":6,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0005\",\"KSMC\":\"住院药房\",\"KSPY\":\"ZYYF\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"住院部二楼药房取药\",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":7,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0006\",\"KSMC\":\"办公室\",\"KSPY\":\"BGS\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":8,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0007\",\"KSMC\":\"总务股\",\"KSPY\":\"ZWG\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":9,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0008\",\"KSMC\":\"医务股\",\"KSPY\":\"YWG\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":null,\"KSMS\":null,\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"},{\"RowNumber\":10,\"totalCount\":171,\"YLJGDM\":\"43899007-X\",\"YLJGMC\":\"泾川县人民医院\",\"KSDM\":\"0009\",\"KSMC\":\"门诊收费室\",\"KSPY\":\"MZSFS\",\"FLKSDM\":\"01\",\"FLKSMC\":\"医疗\",\"KSLXDM\":\"0\",\"KSLXMC\":\"公用\",\"BZNCW\":null,\"BZWCW\":null,\"KSJJ\":\"\",\"KSMS\":\"门诊楼一楼、门诊楼二楼缴费\",\"KSDZ\":null,\"LXDH\":null,\"ZKDM\":null,\"BQDM\":null,\"YQDM\":null,\"CJRQ\":\"2022-04-15T10:01:06.77\",\"JLZT\":\"0\",\"BZ\":\"\"}]}}"; |
| | | util.exec1(); |
| | | // Connection connection = util.getConnection(); |
| | | // String tabName = "ltkj_kszd"; |
| | | // JSONObject entries = JSONUtil.parseObj(json); |
| | | // util.LimitInsertData(connection,tabName,entries.getJSONObject("Response")); |
| | | } |
| | | |
| | | private void exec1() { |
| | | public JSONObject addInputVal(JSONObject jsonObject){ |
| | | JSONObject obj = JSONUtil.createObj(); |
| | | obj.putOpt("jgbm",""); |
| | | obj.putOpt("bm",""); |
| | | obj.putOpt("flbm",""); |
| | | jsonObject.putOpt("input",obj); |
| | | return jsonObject; |
| | | } |
| | | |
| | | public void exec1() { |
| | | int size = 1000; |
| | | Connection connection = getConnection(); |
| | | methods.forEach(method -> { |
| | | System.out.println("循坏的接口代码 ->" + method); |
| | | String tabName = "ltkj_" + method; |
| | | // String params = "method="+method; |
| | | log.info("开始请求代码 ->{}",method); |
| | | String tabName = "ltkj_" + method.toLowerCase(); |
| | | boolean isLimit = false; |
| | | int page = 1; |
| | | int maxPage = 1; |
| | |
| | | object.putOpt("method", method); |
| | | if (limits.contains(method)) { |
| | | isLimit = true; |
| | | // params+="&pagecount="+size+"&page="+page; |
| | | object.putOpt("pagecount", size); |
| | | object.putOpt("page", page); |
| | | } |
| | | object = addInputVal(object); |
| | | log.info("请求接口 ->{},请求参数 ->{}",BASE_API_URL,object.toString()); |
| | | JSONObject entries = execRequest(object.toString()); |
| | | // JSONObject entries = execRequest(params); |
| | | log.info("请求返回 ->{}",entries.toString()); |
| | | assert entries != null; |
| | | JSONObject response = entries.getJSONObject("Response"); |
| | | if ("0".equals(response.getStr("ResultCode"))) { |
| | |
| | | if (maxPage > 1) { |
| | | page += 1; |
| | | for (int i = page; i <= maxPage; i++) { |
| | | // params+="&pagecount="+size+"&page="+page; |
| | | object.clear(); |
| | | object.putOpt("method", method); |
| | | object.putOpt("pagecount", size); |
| | | object.putOpt("page", page); |
| | | // entries = execRequest(params); |
| | | object = addInputVal(object); |
| | | log.info("请求接口 ->{},请求参数 ->{}",BASE_API_URL,object.toString()); |
| | | entries = execRequest(object.toString()); |
| | | assert entries != null; |
| | | log.info("请求返回 ->{}",entries.toString()); |
| | | response = entries.getJSONObject("Response"); |
| | | if ("0".equals(response.getStr("ResultCode"))) { |
| | | LimitInsertData(connection, tabName, response); |
| | | } else { |
| | | // log.error("请求失败:"+params); |
| | | log.error("请求失败:" + object.toString()); |
| | | log.error("{} 请求失败:{}",method,object.toString()); |
| | | } |
| | | page++; |
| | | } |
| | |
| | | editDataBase(connection, tabName, resultData, jsonObject); |
| | | } |
| | | } else { |
| | | // log.error("请求失败:"+params); |
| | | log.error("请求失败:" + object.toString()); |
| | | log.error("{}请求失败 - 请求状态码不为0:{}", method,object.toString()); |
| | | } |
| | | }); |
| | | } |
| | |
| | | * @return |
| | | */ |
| | | private int LimitInsertData(Connection connection, String tabName, JSONObject response) { |
| | | int maxPage; |
| | | // 行数 |
| | | Integer rowNumber = response.getInt("RowNumber"); |
| | | // 总条数 |
| | | Integer totalCount = response.getInt("totalCount"); |
| | | JSONArray jsonArray = response.getJSONArray("ResultData"); |
| | | JSONObject entries = (JSONObject) jsonArray.get(0); |
| | | int maxPage; |
| | | // 行数 数据返回的第几行 |
| | | Integer rowNumber = entries.getInt("RowNumber"); |
| | | // 总条数 |
| | | Integer totalCount = entries.getInt("totalCount"); |
| | | maxPage = (totalCount + 1000 - 1) / 1000; |
| | | System.out.println("集合大小 ->" + jsonArray.size()); |
| | | log.info("请求返回集合大小 ->{},总页数 ->{}",jsonArray.size(),maxPage); |
| | | jsonArray.forEach(obj -> { |
| | | editDataBase(connection, tabName, jsonArray, (JSONObject) obj); |
| | | }); |
| | |
| | | } |
| | | } |
| | | |
| | | private void exec() { |
| | | JSONObject entries = execRequest(); |
| | | if (entries != null) { |
| | | JSONObject response = entries.getJSONObject("Response"); |
| | | // 0 成功 -1失败 |
| | | if ("0".equals(response.getStr("ResultCode"))) { |
| | | JSONArray jsonArray = response.getJSONArray("ResultData"); |
| | | JSONObject resultDataIndex1 = jsonArray.getJSONObject(0); |
| | | String method = entries.getStr("method"); |
| | | String tabName = "ltkj_" + method; |
| | | Connection connection = getConnection(); |
| | | try { |
| | | if (!tabIsExists(connection, tabName)) { |
| | | // 创建表 |
| | | creatTable(resultDataIndex1, tabName, connection); |
| | | } |
| | | // 对比字段 并插入数据 |
| | | operationTable((JSONObject) jsonArray.get(0), tabName, connection); |
| | | } catch (SQLException throwables) { |
| | | throwables.printStackTrace(); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | // private void exec() { |
| | | // JSONObject entries = execRequest(); |
| | | // if (entries != null) { |
| | | // JSONObject response = entries.getJSONObject("Response"); |
| | | // // 0 成功 -1失败 |
| | | // if ("0".equals(response.getStr("ResultCode"))) { |
| | | // JSONArray jsonArray = response.getJSONArray("ResultData"); |
| | | // JSONObject resultDataIndex1 = jsonArray.getJSONObject(0); |
| | | // String method = entries.getStr("method"); |
| | | // String tabName = "ltkj_" + method; |
| | | // Connection connection = getConnection(); |
| | | // try { |
| | | // if (!tabIsExists(connection, tabName)) { |
| | | // // 创建表 |
| | | // creatTable(resultDataIndex1, tabName, connection); |
| | | // } |
| | | // // 对比字段 并插入数据 |
| | | // operationTable((JSONObject) jsonArray.get(0), tabName, connection); |
| | | // } catch (SQLException throwables) { |
| | | // throwables.printStackTrace(); |
| | | // } |
| | | // } |
| | | // } |
| | | // } |
| | | |
| | | /** |
| | | * 执行post请求 |
| | |
| | | URL url = null; |
| | | HttpURLConnection connection = null; |
| | | try { |
| | | BASE_API_URL = "http://localhost:5011/api/His/HisRequest"; |
| | | url = new URL(BASE_API_URL); |
| | | connection = (HttpURLConnection) url.openConnection(); |
| | | connection.setRequestMethod("POST"); |
| | |
| | | connection.setDoOutput(true); |
| | | OutputStream stream = connection.getOutputStream(); |
| | | stream.write(params.getBytes(StandardCharsets.UTF_8)); |
| | | // System.out.println(connection.getResponseCode()); |
| | | BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream())); |
| | | StringBuilder builder = new StringBuilder(); |
| | | String str; |
| | | while ((str = reader.readLine()) != null) { |
| | | builder.append(str); |
| | | } |
| | | log.info("请求参数 ->{}", params); |
| | | // log.info("执行请求响应:{}", builder.toString()); |
| | | return JSONUtil.parseObj(builder.toString()); |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |
| | |
| | | * |
| | | * @return |
| | | */ |
| | | private JSONObject execRequest() { |
| | | URL url = null; |
| | | HttpURLConnection connection = null; |
| | | try { |
| | | url = new URL(BASE_API_URL); |
| | | connection = (HttpURLConnection) url.openConnection(); |
| | | connection.setRequestMethod("POST"); |
| | | connection.setDoOutput(true); |
| | | connection.setRequestProperty("Accept", "application/json"); |
| | | connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); |
| | | OutputStream stream = connection.getOutputStream(); |
| | | int index = 0; |
| | | if (methods.size() > 1) { |
| | | index = RandomUtil.randomInt(0, methods.size() - 1); |
| | | } |
| | | String method = methods.get(index); |
| | | String param = "method=" + method; |
| | | stream.write(param.getBytes(StandardCharsets.UTF_8)); |
| | | BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream())); |
| | | StringBuilder builder = new StringBuilder(); |
| | | String str; |
| | | while ((str = reader.readLine()) != null) { |
| | | builder.append(str); |
| | | } |
| | | log.info("执行请求响应:{}", builder.toString()); |
| | | JSONObject entries = JSONUtil.parseObj(builder.toString()); |
| | | entries.set("method", method); |
| | | return entries; |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |
| | | } finally { |
| | | if (connection != null) { |
| | | connection.disconnect(); |
| | | } |
| | | } |
| | | return null; |
| | | } |
| | | // private JSONObject execRequest() { |
| | | // URL url = null; |
| | | // HttpURLConnection connection = null; |
| | | // try { |
| | | // url = new URL(BASE_API_URL); |
| | | // connection = (HttpURLConnection) url.openConnection(); |
| | | // connection.setRequestMethod("POST"); |
| | | // connection.setDoOutput(true); |
| | | // connection.setRequestProperty("Accept", "application/json"); |
| | | // connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); |
| | | // OutputStream stream = connection.getOutputStream(); |
| | | // int index = 0; |
| | | // if (methods.size() > 1) { |
| | | // index = RandomUtil.randomInt(0, methods.size() - 1); |
| | | // } |
| | | // String method = methods.get(index); |
| | | // String param = "method=" + method; |
| | | // stream.write(param.getBytes(StandardCharsets.UTF_8)); |
| | | // BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream())); |
| | | // StringBuilder builder = new StringBuilder(); |
| | | // String str; |
| | | // while ((str = reader.readLine()) != null) { |
| | | // builder.append(str); |
| | | // } |
| | | // log.info("执行请求响应:{}", builder.toString()); |
| | | // JSONObject entries = JSONUtil.parseObj(builder.toString()); |
| | | // entries.set("method", method); |
| | | // return entries; |
| | | // } catch (IOException e) { |
| | | // e.printStackTrace(); |
| | | // } finally { |
| | | // if (connection != null) { |
| | | // connection.disconnect(); |
| | | // } |
| | | // } |
| | | // return null; |
| | | // } |
| | | |
| | | private Connection getConnection() { |
| | | try { |
| | | FileInputStream inputStream = new FileInputStream(CONFIG_PATH); |
| | | Properties props = new Properties(); |
| | | props.load(inputStream); |
| | | String name = props.getProperty("name"); |
| | | String url = "jdbc:mysql://" + props.getProperty("ip") + ":" + props.getProperty("prot") + "/" + name + "" + |
| | | "?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8"; |
| | | String user = props.getProperty("username"); |
| | | String password = props.getProperty("password"); |
| | | String apiUrl = props.getProperty("his_api_url"); |
| | | String apiPort = props.getProperty("his_api_port"); |
| | | BASE_API_URL = apiUrl+":"+apiPort+"/api/His/HisRequest"; |
| | | return DriverManager.getConnection(url, user, password); |
| | | } catch (SQLException throwables) { |
| | | } catch (Exception throwables) { |
| | | log.error("获取sql连接失败"); |
| | | throwables.printStackTrace(); |
| | | } |
| | | return null; |
| | |
| | | * @throws SQLException |
| | | */ |
| | | private void insertData(String tabName, Connection connection, JSONObject jsonObject) throws SQLException { |
| | | // System.out.println("jsonObject = " + jsonObject); |
| | | // 插入数据前 先查询数据是否存在 |
| | | StringBuilder selectSqlBuilder = new StringBuilder(); |
| | | StringBuilder insertSqlBuilder = new StringBuilder(); |