From 6a7b2e5be037e410c2549fc488077a3b69039123 Mon Sep 17 00:00:00 2001 From: renhao Date: Thu, 3 Apr 2025 20:21:11 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9B=91=E6=8E=A7=E7=82=B9=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/dkl/large/utli/zzjgxxUtil.java | 186 ++++++++++++++++++ 1 file changed, 186 insertions(+) create mode 100644 Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/utli/zzjgxxUtil.java diff --git a/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/utli/zzjgxxUtil.java b/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/utli/zzjgxxUtil.java new file mode 100644 index 0000000..c2b0cdf --- /dev/null +++ b/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/utli/zzjgxxUtil.java @@ -0,0 +1,186 @@ +package com.dkl.large.utli; + + +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.dkl.common.core.domain.entity.SysDept; +import com.dkl.common.utils.StringUtils; +import com.dkl.system.service.ISysDeptService; +import okhttp3.*; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.OutputStream; +import java.net.HttpURLConnection; +import java.net.URL; +import java.nio.charset.StandardCharsets; +import java.util.Date; + +@Component("zzjgxxUtil") +public class zzjgxxUtil { + + @Autowired + private ISysDeptService deptService; + public void getDeptAll() throws IOException { + OkHttpClient client = new OkHttpClient(); + + // 构建请求体 + MediaType mediaType = MediaType.parse("application/json"); + RequestBody body = RequestBody.create(mediaType, "{\n" + + " \"jsonObject\": {\n" + + " \"key\": \"value\"\n" + + " },\n" + + " \"method\": \"GET\",\n" + + " \"pageNum\": 1,\n" + + " \"pageSize\": 1000000,\n" + + " \"path\": \"/edataservice/api/zzjgxx\",\n" + + " \"secret\": \"7231958b69385ff66a1900584a72c0b85dbc0b602d54ec7a23f9ccdeeb17018c\",\n" + + " \"sortParam\": \"zzjgdm\",\n" + + " \"sortType\": \"ASC\"\n" + + "}"); + + // 构建请求 + Request request = new Request.Builder() + .url("http://10.22.245.216:29999/jeecg-data-service/edataservice/api/") + .post(body) + .addHeader("Content-Type", "application/json") + .build(); + + // 执行请求并处理响应 + try (Response response = client.newCall(request).execute()) { +// System.out.println("Response Code: " + response.code()); +// System.out.println("Response Body: " + response.body().string()); + String jsonString = response.body().string(); + // 创建ObjectMapper实例 + ObjectMapper objectMapper = new ObjectMapper(); + try { + // 解析JSON字符串为JsonNode对象 + JsonNode rootNode = objectMapper.readTree(jsonString); + + // 获取code字段的值 + String code = rootNode.get("code").asText(); + System.out.println("Code: " + code); + + // 获取success字段的值 + boolean success = rootNode.get("success").asBoolean(); + System.out.println("Success: " + success); + + // 获取data字段的值（是一个数组） + JsonNode dataNode = rootNode.get("result"); + JsonNode dataList= dataNode.get("records"); + // 遍历data数组中的每个元素 + for (JsonNode deptNode : dataList) { + //获取所有部门 + SysDept sysDept =new SysDept(); + //如果组织机构机构代码不为空 + if(StringUtils.isNotEmpty( deptNode.get("zzjgdm").asText())){ + SysDept gainfo = deptService.selectDeptBygajgjgdm(deptNode.get("zzjgdm").asText()); + //部门是空 + if (gainfo == null) { + //创建 + //上级组织机构不能不空 + if(StringUtils.isNotEmpty( deptNode.get("sjzzjg").asText())){ + SysDept info = deptService.selectDeptBysjgajgjgdm(deptNode.get("sjzzjg").asText()); + //如果上级机构存在 + if (info != null) { + //部门名称 = 对接组织机构名称 zzjgmc + if(StringUtils.isNotEmpty( deptNode.get("zzjgmc").asText())){ + sysDept.setDeptName(deptNode.get("zzjgmc").asText()); + } + sysDept.setParentId(info.getDeptId()); + + //显示顺序 = 对接显示顺序 xssx + if(StringUtils.isNotEmpty( deptNode.get("xssx").asText())){ + sysDept.setOrderNum(Integer.valueOf(deptNode.get("xssx").asText())); + } + + //单位类别 + if(StringUtils.isNotEmpty( deptNode.get("dwlb").asText())){ + sysDept.setDwlb(deptNode.get("dwlb").asText()); + } + + //组织机构单位性质类别 zzjgdwxzlbdm + if(StringUtils.isNotEmpty( deptNode.get("zzjgdwxzlbdm").asText())){ + sysDept.setGajgbmlbdm(deptNode.get("zzjgdwxzlbdm").asText()); + } + + + + //单位级别 + if(StringUtils.isNotEmpty( deptNode.get("dwjb").asText())){ + sysDept.setGajgbmlbdm(deptNode.get("dwjb").asText()); + } + + //组织机构代码 + if(StringUtils.isNotEmpty( deptNode.get("zzjgdm").asText())){ + sysDept.setGajgjgdm(deptNode.get("zzjgdm").asText()); + } + + //上级组织机构不能不空 + if(StringUtils.isNotEmpty( deptNode.get("sjzzjg").asText())){ + sysDept.setSjgajgjgdm(deptNode.get("sjzzjg").asText()); + } + + //组织机构简称不能不空 + if(StringUtils.isNotEmpty( deptNode.get("zzjgjc").asText())){ + sysDept.setZzjgjc(deptNode.get("zzjgjc").asText()); + } + //行政区划代码不能不空 + if(StringUtils.isNotEmpty( deptNode.get("xzqhdm").asText())){ + sysDept.setXzqhdm(deptNode.get("xzqhdm").asText()); + } + //单位类型不能不空 + if(StringUtils.isNotEmpty( deptNode.get("dwlx").asText())){ + sysDept.setDwlx(deptNode.get("dwlx").asText()); + } + //派出所类型代码不能不空 + if(StringUtils.isNotEmpty( deptNode.get("pcslxdm").asText())){ + sysDept.setDwlb(deptNode.get("pcslxdm").asText()); + } + + //联系人不能不空 + if(StringUtils.isNotEmpty( deptNode.get("lxr").asText())){ + sysDept.setLeader(deptNode.get("lxr").asText()); + } + + //联系电话不能不空 + if(StringUtils.isNotEmpty( deptNode.get("lxdh").asText())){ + sysDept.setPhone(deptNode.get("lxdh").asText()); + } + //值班电话不能不空 + if(StringUtils.isNotEmpty( deptNode.get("zbdh").asText())){ + sysDept.setZbdh(deptNode.get("zbdh").asText()); + } + + //帐号状态（0正常 1停用） + sysDept.setStatus("0"); + //删除状态 + sysDept.setDelFlag("0"); + //创建时间 + sysDept.setCreateTime(new Date()); + //创建人 + sysDept.setCreateBy("admin"); + //修改时间 + sysDept.setUpdateTime(new Date()); + //修改人 + sysDept.setUpdateBy("admin"); + deptService.insertDept(sysDept); + } + } + } + + } + } + System.out.println(dataList); + } catch (IOException e) { + e.printStackTrace(); + } + } catch (Exception e) { + e.printStackTrace(); + } + } + + }