From f10ddf1ed29cf99cacdad3ece9b014e705da0196 Mon Sep 17 00:00:00 2001 From: ZhangYingJie Date: Thu, 17 Apr 2025 13:12:25 +0800 Subject: [PATCH] dev --- .../clinic/server/common/util/DateUtil.java | 4 + .../clinic/server/common/util/HttpUtil.java | 5 + .../mapper/social/SocialDirectoryMapper.java | 5 + .../clinic/server/service/BaseService.java | 6 +- .../social/SocialDirectoryService.java | 178 +++++++++++++++++- .../resources/xml/SocialDirectoryMapper.xml | 28 ++- .../clinic/server/ServerApplicationTests.java | 9 +- 7 files changed, 226 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/syjiaer/clinic/server/common/util/DateUtil.java b/src/main/java/com/syjiaer/clinic/server/common/util/DateUtil.java index e293057..d5f5c11 100644 --- a/src/main/java/com/syjiaer/clinic/server/common/util/DateUtil.java +++ b/src/main/java/com/syjiaer/clinic/server/common/util/DateUtil.java @@ -34,6 +34,10 @@ public class DateUtil { return LocalDateTime.parse(dateTimeStr, DateTimeFormatter.ofPattern(DATE_TIME_FORMAT)); } + public static DateTimeFormatter getDateTimeFormatter(String dateTimeStr) { + return DateTimeFormatter.ofPattern(dateTimeStr); + } + //加一天 public static LocalDateTime addDay(LocalDateTime dateTime) { return dateTime.plusDays(1); diff --git a/src/main/java/com/syjiaer/clinic/server/common/util/HttpUtil.java b/src/main/java/com/syjiaer/clinic/server/common/util/HttpUtil.java index 38e67e2..7b1c218 100644 --- a/src/main/java/com/syjiaer/clinic/server/common/util/HttpUtil.java +++ b/src/main/java/com/syjiaer/clinic/server/common/util/HttpUtil.java @@ -194,6 +194,11 @@ public class HttpUtil { JSONObject output = post(config.get("social", "url"), JSON.toJSONString(getparms(infno, tag, input)),true); return output; } + public JSONObject callBackMsgId(String infno, String tag, Map input) { + + JSONObject output = post(config.get("social", "url"), JSON.toJSONString(getparms(infno, tag, input)),true); + return output; + } public JSONObject callWithOutLog(String infno, String tag, Map input) { JSONObject output = post(config.get("social", "url"), JSON.toJSONString(getparms(infno, tag, input)), false); diff --git a/src/main/java/com/syjiaer/clinic/server/mapper/social/SocialDirectoryMapper.java b/src/main/java/com/syjiaer/clinic/server/mapper/social/SocialDirectoryMapper.java index 95108a6..1718835 100644 --- a/src/main/java/com/syjiaer/clinic/server/mapper/social/SocialDirectoryMapper.java +++ b/src/main/java/com/syjiaer/clinic/server/mapper/social/SocialDirectoryMapper.java @@ -2,6 +2,10 @@ package com.syjiaer.clinic.server.mapper.social; import com.syjiaer.clinic.server.entity.social.SocialDirectory; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.syjiaer.clinic.server.entity.social.dto.SocialDirectoryView; +import org.apache.ibatis.annotations.Param; + +import java.util.List; /** @@ -14,5 +18,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; */ public interface SocialDirectoryMapper extends BaseMapper { + List selectSocialDirectoryView(@Param("codeList") List codeList); } diff --git a/src/main/java/com/syjiaer/clinic/server/service/BaseService.java b/src/main/java/com/syjiaer/clinic/server/service/BaseService.java index 03d114e..0dbe5e2 100644 --- a/src/main/java/com/syjiaer/clinic/server/service/BaseService.java +++ b/src/main/java/com/syjiaer/clinic/server/service/BaseService.java @@ -81,11 +81,11 @@ public abstract class BaseService { return managerUser; } - protected Page pageHelper(int pageNum, int pageSize, QueryWrapper queryWrapper, BaseMapper mapper){ + protected Page pageHelper(int pageNum, int pageSize, QueryWrapper queryWrapper, BaseMapper mapper){ Long totalCount = mapper.selectCount(queryWrapper); queryWrapper.last("LIMIT " + (pageNum - 1) * pageSize + ", " + pageSize); - List list = mapper.selectList(queryWrapper); - Page page = new Page(); + List list = mapper.selectList(queryWrapper); + Page page = new Page<>(); page.setList(list); page.setTotal_count(totalCount); page.setTotal_page((int) Math.ceil(totalCount / (double) pageSize)); diff --git a/src/main/java/com/syjiaer/clinic/server/service/social/SocialDirectoryService.java b/src/main/java/com/syjiaer/clinic/server/service/social/SocialDirectoryService.java index f06763e..bff26f9 100644 --- a/src/main/java/com/syjiaer/clinic/server/service/social/SocialDirectoryService.java +++ b/src/main/java/com/syjiaer/clinic/server/service/social/SocialDirectoryService.java @@ -1,17 +1,193 @@ package com.syjiaer.clinic.server.service.social; +import com.alibaba.fastjson2.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.syjiaer.clinic.server.common.config.Config; +import com.syjiaer.clinic.server.common.exception.MessageException; +import com.syjiaer.clinic.server.common.util.*; import com.syjiaer.clinic.server.common.vo.Page; +import com.syjiaer.clinic.server.entity.social.SocialDirectory; +import com.syjiaer.clinic.server.entity.social.SocialDirectoryVersion; import com.syjiaer.clinic.server.entity.social.dto.SocialDirectoryView; +import com.syjiaer.clinic.server.mapper.social.SocialDirectoryMapper; +import com.syjiaer.clinic.server.mapper.social.SocialDirectoryVersionMapper; import com.syjiaer.clinic.server.service.BaseService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import java.nio.file.Files; +import java.nio.file.Path; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@Service public class SocialDirectoryService extends BaseService { + @Autowired + private HttpUtil httpUtil; + @Autowired + private Config config; + @Autowired + private FileUtil fileUtil; + @Autowired + private DictoryUtil dictoryUtil; + @Autowired + private StringUtil stringUtil; + @Autowired + private SocialDirectoryMapper socialDirectoryMapper; + @Autowired + private SocialDirectoryVersionMapper socialDirectoryVersionMapper; + /* * 下载接口 * @param version_name 版本名称 * @param type 类型 */ - public void download(String version_name,int type){ + public JSONObject download(String version_name,int type){ + Map input = new HashMap<>(); + input.put("ver", version_name); + String infno = String.valueOf(type); + System.out.println("上个版本号:" + version_name); + JSONObject result=null; + try { + result = httpUtil.callBackMsgId(infno,"data", input); + }catch (Exception e){ + return null; + } + String filename = result.getString("filename"); + String file_qury_no = result.getString("file_qury_no"); + String fixmedins_code = config.get("social", "fixmedinsCode"); + String path = ""; + try { + // 创建临时目录 + Path tempDir = Files.createTempDirectory("temp"); + path = tempDir.toString(); + } catch (Exception e) { + throw new MessageException("创建临时下载目录失败"); + } + Map input_dw = new HashMap<>(); + input_dw.put("file_qury_no", file_qury_no); + input_dw.put("fixmedins_code", fixmedins_code); + input_dw.put("filename", filename); + System.out.println("文件地址:"+path+"/"+filename); + httpUtil.callToFile("9102", "fsDownloadIn", input_dw, path + "/" + filename); + List file_list = fileUtil.unzip(path, filename); + List read_list = fileUtil.readToList(file_list); + List tab_list = new ArrayList<>(); + //将read_list中的每一行按tab分割，存入tab_list中 + for (String s : read_list) { + String[] line_array = s.split("\t"); + for (int j = 0; j < line_array.length; j++) { + if (line_array[j].equals("null")) { + line_array[j] = ""; + } + } + tab_list.add(line_array); + } + + + //清楚原有的code + int batchSize = 100; + for (int i = 0; i < tab_list.size(); i += batchSize) { + List code_list = new ArrayList<>(); + for (int j = i; j < i + batchSize && j < tab_list.size(); j++) { + String[] line_array = tab_list.get(j); + String val = line_array[0]; + code_list.add(val); + } + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.in("code", code_list); + socialDirectoryMapper.delete(queryWrapper); + } + + //将tab_list中的每一行存入数据库 + Map title_map = dictoryUtil.getTitleMap(infno); + List list = new ArrayList<>(); + HashMap tmp_map = new HashMap<>(); + for (String[] line_array : tab_list) { + SocialDirectory socialDirectory = new SocialDirectory(); + socialDirectory.setType(type); + String code = line_array[0]; + socialDirectory.setId(code); + socialDirectory.setCode(code); + Map map = new HashMap<>(); + for (String key_str : title_map.keySet()) { + int key = Integer.parseInt(key_str); + String title = title_map.get(key_str); + if (!title.startsWith("json.")) { + continue; + } + title = title.substring(5); + String val = line_array[key - 1]; + map.put(title, val); + } + socialDirectory.setData(JSONObject.toJSONString(map)); + socialDirectory.setName(map.get("name")); + socialDirectory.setVersionName(map.get("version_name")); + String flag = ""; + DateTimeFormatter dateTimeFormatter = DateUtil.getDateTimeFormatter(DateUtil.DATE_TIME_FORMAT); + if (type == 1301) { + flag = line_array[78]; + socialDirectory.setProducer(line_array[53]); + socialDirectory.setKeyword(line_array[1] + "," + line_array[3] + "," + line_array[61]); + socialDirectory.setCreateDatetime(LocalDateTime.parse(line_array[80], dateTimeFormatter)); + socialDirectory.setUpdateDatetime(LocalDateTime.parse(line_array[81], dateTimeFormatter)); + } + if (type == 1302) { + flag = line_array[13]; + socialDirectory.setKeyword(line_array[19]); + socialDirectory.setCreateDatetime(LocalDateTime.parse(line_array[15], dateTimeFormatter)); + socialDirectory.setUpdateDatetime(LocalDateTime.parse(line_array[16], dateTimeFormatter)); + } + if (type == 1305) { + flag = line_array[6]; + socialDirectory.setKeyword(line_array[9] + "," + line_array[2]); + } + if (type == 1306) { + flag = line_array[67]; + socialDirectory.setProducer(line_array[59]); + socialDirectory.setKeyword(line_array[4]); + } + if (type == 1307) { + flag = line_array[18]; + socialDirectory.setKeyword(line_array[5] + "," + line_array[7]); + } + if (type == 1309) { + flag = line_array[5]; + //因为1309不使用版本名称，而是版本编号，所以需要手动设置 + socialDirectory.setVersionName(line_array[11]); + } + if (type == 1320) { + flag = line_array[28]; + socialDirectory.setKeyword(line_array[23] + "," + line_array[3] + "," + line_array[4]); + } + if (type == 1321) { + flag = line_array[13]; + socialDirectory.setKeyword(line_array[6] + "," + line_array[10]); + } + SocialDirectory tmp_socialDirectory = tmp_map.get(code); + if (tmp_socialDirectory == null && flag.equals("1")) { + list.add(socialDirectory); + tmp_map.put(code, socialDirectory); + } + } + socialDirectoryMapper.insert(list, 100); + SocialDirectoryVersion socialDirectoryVersion = new SocialDirectoryVersion(); + socialDirectoryVersion.setId(stringUtil.generateRandomId()); + socialDirectoryVersion.setType(type); + socialDirectoryVersion.setPreVersionName(version_name); + socialDirectoryVersion.setCurrentVersionName(list.get(0).getVersionName()); + socialDirectoryVersion.setSize(list.size()); + socialDirectoryVersion.setCreateDatetime(LocalDateTime.now()); + socialDirectoryVersionMapper.insert(socialDirectoryVersion); + JSONObject result_object = new JSONObject(); + result_object.put("current_version_name", list.get(0).getVersionName()); + result_object.put("pre_version_name", version_name); + return result_object; } /* diff --git a/src/main/resources/xml/SocialDirectoryMapper.xml b/src/main/resources/xml/SocialDirectoryMapper.xml index 6ca5c9c..ce49015 100644 --- a/src/main/resources/xml/SocialDirectoryMapper.xml +++ b/src/main/resources/xml/SocialDirectoryMapper.xml @@ -1,5 +1,31 @@ - + + + diff --git a/src/test/java/com/syjiaer/clinic/server/ServerApplicationTests.java b/src/test/java/com/syjiaer/clinic/server/ServerApplicationTests.java index c4ff269..5b3d4e1 100644 --- a/src/test/java/com/syjiaer/clinic/server/ServerApplicationTests.java +++ b/src/test/java/com/syjiaer/clinic/server/ServerApplicationTests.java @@ -1,7 +1,10 @@ package com.syjiaer.clinic.server; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.syjiaer.clinic.server.common.vo.Page; +import com.syjiaer.clinic.server.entity.social.dto.SocialDirectoryView; import com.syjiaer.clinic.server.mapper.social.SocialDirectoryMapper; +import com.syjiaer.clinic.server.service.social.SocialDirectoryService; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; @@ -10,12 +13,10 @@ import org.springframework.boot.test.context.SpringBootTest; class ServerApplicationTests { @Autowired - private SocialDirectoryMapper socialDirectoryMapper; + private SocialDirectoryService socialDirectoryService; @Test void contextLoads() { - QueryWrapper queryWrapper = new QueryWrapper(); - queryWrapper.last("limit 100"); - socialDirectoryMapper.selectList(queryWrapper); + } }