From 11768ae318689ecffaec21b1bcf1bbba5d41b209 Mon Sep 17 00:00:00 2001 From: lzy Date: Thu, 25 Nov 2021 15:03:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=89=8B=E9=BA=BB=E9=87=87?= =?UTF-8?q?=E9=9B=86=E5=99=A8=E9=9C=80=E6=B1=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dataConfig/homeQualitySet.json | 10 +- .../com/docus/bgts/config/MyConstruct.java | 38 ++++ .../com/docus/bgts/config/MyScheduling.java | 31 +++- .../com/docus/bgts/entity/AfCollectAdd.java | 21 +++ .../com/docus/bgts/entity/MrReportError.java | 23 +++ .../com/docus/bgts/entity/VDocumentPdf.java | 12 ++ .../com/docus/bgts/facade/IBgtsService.java | 14 +- .../mapper/dbmysql/AfCollectAddMapper.java | 13 ++ .../mapper/dbmysql/MrReportErrorMapper.java | 8 + .../mapper/dboracle/VDocumentPdfMapper.java | 23 +++ .../service/AfCollectTaskServiceImpl.java | 15 +- .../docus/bgts/service/BgtsServiceImpl.java | 174 +++++++++++++++--- .../java/com/docus/bgts/web/FilterConfig.java | 16 ++ .../java/com/docus/bgts/web/MyFilter.java | 33 ++++ src/main/resources/application.yml | 2 +- .../mapper/dbmysql/AfCollectAddMapper.xml | 9 + .../mapper/dbmysql/MrReportErrorMapper.xml | 10 + .../mapper/dboracle/VDocumentPdfMapper.xml | 33 ++++ 18 files changed, 441 insertions(+), 44 deletions(-) create mode 100644 src/main/java/com/docus/bgts/config/MyConstruct.java create mode 100644 src/main/java/com/docus/bgts/entity/AfCollectAdd.java create mode 100644 src/main/java/com/docus/bgts/entity/MrReportError.java create mode 100644 src/main/java/com/docus/bgts/mapper/dbmysql/AfCollectAddMapper.java create mode 100644 src/main/java/com/docus/bgts/mapper/dbmysql/MrReportErrorMapper.java create mode 100644 src/main/java/com/docus/bgts/mapper/dboracle/VDocumentPdfMapper.java create mode 100644 src/main/java/com/docus/bgts/web/FilterConfig.java create mode 100644 src/main/java/com/docus/bgts/web/MyFilter.java create mode 100644 src/main/resources/mapper/dbmysql/AfCollectAddMapper.xml create mode 100644 src/main/resources/mapper/dbmysql/MrReportErrorMapper.xml create mode 100644 src/main/resources/mapper/dboracle/VDocumentPdfMapper.xml diff --git a/dataConfig/homeQualitySet.json b/dataConfig/homeQualitySet.json index 718972d..d8ec0b4 100644 --- a/dataConfig/homeQualitySet.json +++ b/dataConfig/homeQualitySet.json @@ -10,9 +10,9 @@ //下载地址 "downurl":"IMAGE_URL", //分类id - "assortid":"63E20FC9AAB74C5FB6446083EBA5607D", + "assortid":"15E7FE7803F545CB81390BC88E725240", //系统id - "collectorid":"3", + "collectorid":"5", //采集类型(文件来源 1:采集器；2：扫描生产软件) "filesource":1, //下载类型(1:服务器本地；2：ftp服务器；3：共享文件夹) @@ -36,6 +36,10 @@ //检查报告明細列表响应信息根路径 "bgtsDetailParam":["Request","Msg","EXAM_NO"], //检查报告明細列表响应信息根路径 - "bgtsDetailRespon":["MsgInfo","Msg","ReportInfo"] + "bgtsDetailRespon":["MsgInfo","Msg","ReportInfo"], + //采集日期 + "startCollectTime":"2016-04-11", + //是否开启全量采集 1:是 0 :否 + "isStartCollect":"0" } \ No newline at end of file diff --git a/src/main/java/com/docus/bgts/config/MyConstruct.java b/src/main/java/com/docus/bgts/config/MyConstruct.java new file mode 100644 index 0000000..b4202cd --- /dev/null +++ b/src/main/java/com/docus/bgts/config/MyConstruct.java @@ -0,0 +1,38 @@ +package com.docus.bgts.config; + +import com.docus.bgts.facade.IBgtsService; +import com.docus.bgts.utils.FileUtils; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; +import javax.annotation.PreDestroy; + +@Component +public class MyConstruct { + + @Autowired + IBgtsService bgtsService; + + /** + * 开启全量采集 + */ + @PostConstruct + public void startCollectAll(){ + String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid")); + String startCollectTime = String.valueOf(FileUtils.getJsonByName("startCollectTime")); + String isStartCollect = String.valueOf(FileUtils.getJsonByName("isStartCollect")); + if(collectorid.equals("5")&& StringUtils.isNotBlank(startCollectTime)&&isStartCollect!=null&&isStartCollect.equals("1")){ + bgtsService.collectAll(); + } + } + + + //在spring容器关闭时，释放 + @PreDestroy + public void destroy() { + //系统运行结束 + } + +} diff --git a/src/main/java/com/docus/bgts/config/MyScheduling.java b/src/main/java/com/docus/bgts/config/MyScheduling.java index a5bc622..4a3241e 100644 --- a/src/main/java/com/docus/bgts/config/MyScheduling.java +++ b/src/main/java/com/docus/bgts/config/MyScheduling.java @@ -1,14 +1,14 @@ package com.docus.bgts.config; +import com.docus.bgts.facade.IBgtsService; import com.docus.bgts.utils.FileUtils; import com.docus.bgts.utils.HttpUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; - -import java.net.URISyntaxException; import java.util.HashMap; import java.util.Map; @@ -17,22 +17,41 @@ public class MyScheduling { @Value("${beat.url}") private String beatUrl; + @Autowired + IBgtsService bgtsService; + private Logger logger = LogManager.getLogger(MyScheduling.class); //5分钟执行一次 @Scheduled(fixedRate = 1000 * 60 * 5) public void beat() { - logger.info("------------心跳开始---------------"); + String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid")); + if(collectorid.equals("5")){ + return; + } Map params = new HashMap<>(); params.put("code", String.valueOf(FileUtils.getJsonByName("collectorid"))); try { HttpUtils.get(beatUrl, params); - } catch (URISyntaxException e) { + } catch (Exception e) { e.printStackTrace(); logger.info("心跳推送出错，可能是住院服务没有开启"); - } finally { - logger.info("-------------心跳结束---------------"); } } + /** + * 手麻采集器 + * 10分钟执行一次 + */ + @Scheduled(fixedRate = 1000 * 60 * 10) + public void collect(){ + String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid")); + if(!collectorid.equals("5")){ + return; + } + bgtsService.timerCollect(); + } + + + } diff --git a/src/main/java/com/docus/bgts/entity/AfCollectAdd.java b/src/main/java/com/docus/bgts/entity/AfCollectAdd.java new file mode 100644 index 0000000..50131c5 --- /dev/null +++ b/src/main/java/com/docus/bgts/entity/AfCollectAdd.java @@ -0,0 +1,21 @@ +package com.docus.bgts.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.util.Date; + +@ApiModel("采集日志") +@Data +public class AfCollectAdd { + @ApiModelProperty("id") + @TableId(value = "id",type = IdType.ASSIGN_ID) + private Long id; + @ApiModelProperty("上次更新时间") + private Date beginStageDate; + @ApiModelProperty("分类") + private Integer classify; +} diff --git a/src/main/java/com/docus/bgts/entity/MrReportError.java b/src/main/java/com/docus/bgts/entity/MrReportError.java new file mode 100644 index 0000000..d9f7db8 --- /dev/null +++ b/src/main/java/com/docus/bgts/entity/MrReportError.java @@ -0,0 +1,23 @@ +package com.docus.bgts.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.util.Date; + +@Data +@ApiModel("错误日志表") +public class MrReportError { + @ApiModelProperty(value = "id") + @TableId(value = "id", type = IdType.ASSIGN_ID) + private Long id; + @ApiModelProperty("上报信息") + private String xml; + @ApiModelProperty("上报类型") + private Integer reportType; + @ApiModelProperty("上报时间") + private Date createTime; +} diff --git a/src/main/java/com/docus/bgts/entity/VDocumentPdf.java b/src/main/java/com/docus/bgts/entity/VDocumentPdf.java index 924071b..edf7075 100644 --- a/src/main/java/com/docus/bgts/entity/VDocumentPdf.java +++ b/src/main/java/com/docus/bgts/entity/VDocumentPdf.java @@ -1,4 +1,16 @@ package com.docus.bgts.entity; +import io.swagger.annotations.ApiModel; +import lombok.Data; + +import java.util.Date; + +@Data +@ApiModel("手麻采集器") public class VDocumentPdf { + private String 手术申请单号; + private String 文书名; + private String WEB_ADDRESS; + private String PATIENT_ID; + private Date ARCHIVE_DATE_TIME; } diff --git a/src/main/java/com/docus/bgts/facade/IBgtsService.java b/src/main/java/com/docus/bgts/facade/IBgtsService.java index c271eda..f8db8e2 100644 --- a/src/main/java/com/docus/bgts/facade/IBgtsService.java +++ b/src/main/java/com/docus/bgts/facade/IBgtsService.java @@ -1,8 +1,4 @@ package com.docus.bgts.facade; - -import java.io.UnsupportedEncodingException; -import java.rmi.RemoteException; - public interface IBgtsService { /** * 采集 @@ -16,4 +12,14 @@ public interface IBgtsService { * @param empId */ void collectByExamNo(String emamNo, String empId) throws Exception; + + /** + * 全量采集 + */ + void collectAll(); + + /** + * 定时采集 + */ + void timerCollect(); } diff --git a/src/main/java/com/docus/bgts/mapper/dbmysql/AfCollectAddMapper.java b/src/main/java/com/docus/bgts/mapper/dbmysql/AfCollectAddMapper.java new file mode 100644 index 0000000..c9ca2a2 --- /dev/null +++ b/src/main/java/com/docus/bgts/mapper/dbmysql/AfCollectAddMapper.java @@ -0,0 +1,13 @@ +package com.docus.bgts.mapper.dbmysql; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.docus.bgts.entity.AfCollectAdd; + +import java.util.Date; + +public interface AfCollectAddMapper extends BaseMapper { + /** + * 获取最新的采集时间 + */ + Date getTimeByAdd(); +} diff --git a/src/main/java/com/docus/bgts/mapper/dbmysql/MrReportErrorMapper.java b/src/main/java/com/docus/bgts/mapper/dbmysql/MrReportErrorMapper.java new file mode 100644 index 0000000..2d2d261 --- /dev/null +++ b/src/main/java/com/docus/bgts/mapper/dbmysql/MrReportErrorMapper.java @@ -0,0 +1,8 @@ +package com.docus.bgts.mapper.dbmysql; + +import com.docus.bgts.entity.MrReportError; +import org.apache.ibatis.annotations.Param; + +public interface MrReportErrorMapper { + void insert(@Param("mrReportError") MrReportError mrReportError); +} diff --git a/src/main/java/com/docus/bgts/mapper/dboracle/VDocumentPdfMapper.java b/src/main/java/com/docus/bgts/mapper/dboracle/VDocumentPdfMapper.java new file mode 100644 index 0000000..191f239 --- /dev/null +++ b/src/main/java/com/docus/bgts/mapper/dboracle/VDocumentPdfMapper.java @@ -0,0 +1,23 @@ +package com.docus.bgts.mapper.dboracle; + +import com.docus.bgts.entity.VDocumentPdf; +import org.apache.ibatis.annotations.Param; + +import javax.xml.crypto.Data; +import java.util.Date; +import java.util.List; + +public interface VDocumentPdfMapper { + /** + * 获取采集数据 + * @param current + * @param size + * @param startCollectTime + * @param date + * @return + */ + List listCollectPage(@Param("current") int current, + @Param("size") int size, + @Param("startTime") String startCollectTime, + @Param("endTime") String date); +} diff --git a/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java b/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java index 399101c..f1ca7e0 100644 --- a/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java +++ b/src/main/java/com/docus/bgts/service/AfCollectTaskServiceImpl.java @@ -47,7 +47,6 @@ public class AfCollectTaskServiceImpl extends ServiceImpl exams = getExamNo(empId); + //获取插入表数据 + ReportDownDto reportDownDto = getUrlCreateReportDto(exams, empId); + //插入文件af_collect_task表数据 + afCollectTaskService.insert(reportDownDto); //通过报告单号集合采集 - collectExams(exams, empId); + collectExams(exams, empId,reportDownDto); } @Override @@ -60,7 +74,126 @@ public class BgtsServiceImpl implements IBgtsService { strings[1] = afCollectTask.getC2(); List exams = new ArrayList<>(); exams.add(strings); - collectExams(exams, empId); + //获取插入表数据 + ReportDownDto reportDownDto = getUrlCreateReportDto(exams, empId); + collectExams(exams, empId,reportDownDto); + } + + @Override + public void collectAll() { + logger.info("----------全量采集开始-----------"); + //1.获取最早采集日期 + SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String startCollectTime = null; + startCollectTime = String.valueOf(FileUtils.getJsonByName("startCollectTime")); + + logger.info("----------采集初始时间：" + startCollectTime + " -------------------"); + //当前日期 + Date date = new Date(); + String dateStr = simpleDateFormat.format(date); + collectByDates(startCollectTime, dateStr); + //更新采集时间 + addAfCollectAdd(date); + logger.info("--------------全量采集结束------------------"); + } + + /** + * 根据时间到采集任务 + * + * @param startDate + * @param endDate + */ + private void collectByDates(String startDate, String endDate) { + //页码 + int current; + //每页10条数据 + int size; + List vDocumentPdfs; + String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid")); + String assortid = String.valueOf(FileUtils.getJsonByName("assortid")); + int filesource = Integer.parseInt(String.valueOf(FileUtils.getJsonByName("filesource"))); + int filestoragetype = Integer.parseInt(String.valueOf(FileUtils.getJsonByName("filestoragetype"))); + Map headMap = new HashMap<>(); + headMap.put("Content-Type", "application/json"); + //2.获取第一页10条数据开始采集 + for (current = 1; ; current++) { + size = 10 * current; + vDocumentPdfs = vDocumentPdfMapper.listCollectPage(current, size, startDate, endDate); + if (null == vDocumentPdfs || vDocumentPdfs.size() <= 0) { + break; + } + vDocumentPdfs.stream().forEach(vDocumentPdf -> { + ReportDownDto reportDownDto = new ReportDownDto(); + reportDownDto.setCollectorid(collectorid); + reportDownDto.setAssortid(assortid); + + ReportDownPatientDto reportDownPatientDto = new ReportDownPatientDto(); + reportDownPatientDto.setJzh(vDocumentPdf.getPATIENT_ID()); + reportDownDto.setPatient(reportDownPatientDto); + + List reportDownScanFileDtos = new ArrayList<>(); + ReportDownScanFileDto reportDownScanFileDto = new ReportDownScanFileDto(); + reportDownScanFileDto.setDownurl(vDocumentPdf.getWEB_ADDRESS()); + reportDownScanFileDto.setFilestoragetype(filestoragetype); + reportDownScanFileDto.setFilesource(filesource); + reportDownScanFileDto.setFiletitle(vDocumentPdf.get文书名()); + reportDownScanFileDto.setSerialnum(vDocumentPdf.get手术申请单号()); + reportDownScanFileDtos.add(reportDownScanFileDto); + reportDownDto.setScanfiles(reportDownScanFileDtos); + afCollectTaskService.insert(reportDownDto); + String post = null; + try { + post = HttpUtils.post(String.valueOf(FileUtils.getJsonByName(Codes.UPLOAD.getMessage())), headMap, JSON.parseObject(JSON.toJSONString(reportDownDto), Map.class)); + Map resMap = JSON.parseObject(post, Map.class); + if (String.valueOf(resMap.get("code")).equals("500")) { + throw new RuntimeException(String.valueOf(resMap.get("msg"))); + } + } catch (Exception e) { + addMrReportErrorLog(reportDownDto); + e.printStackTrace(); + } + }); + } + } + + @Override + public void timerCollect() { + logger.info("------手麻采集器开始采集---------"); + //1.获取上次采集时间 + Date time = afCollectAddMapper.getTimeByAdd(); + SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String startDate = simpleDateFormat.format(time); + //当前日期 + Date date = new Date(); + String endDate = simpleDateFormat.format(date); + collectByDates(startDate, endDate); + //更新采集时间 + addAfCollectAdd(date); + logger.info("--------手麻采集器结束采集------"); + } + + /** + * 更新采集时间 + */ + private void addAfCollectAdd(Date date) { + String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid")); + AfCollectAdd afCollectAdd = new AfCollectAdd(); + afCollectAdd.setBeginStageDate(date); + afCollectAddMapper.update(afCollectAdd,new QueryWrapper().eq("classify",collectorid)); + } + + /** + * 全量采集错误记录日志 + * + * @param reportDownDto + */ + private void addMrReportErrorLog(ReportDownDto reportDownDto) { + MrReportError mrReportError = new MrReportError(); + mrReportError.setCreateTime(new Date()); + String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid")); + mrReportError.setReportType(Integer.parseInt(collectorid)); + mrReportError.setXml(JSON.toJSONString(reportDownDto)); + mrReportErrorMapper.insert(mrReportError); } /** @@ -69,11 +202,7 @@ public class BgtsServiceImpl implements IBgtsService { * @param exams * @param empId */ - private void collectExams(List exams, String empId) throws Exception { - //获取插入表数据 - ReportDownDto reportDownDto = getUrlCreateReportDto(exams, empId); - //插入文件af_collect_task表数据 - afCollectTaskService.insert(reportDownDto); + private void collectExams(List exams, String empId,ReportDownDto reportDownDto) throws Exception { // reportDownDto.setTaskid(id); //调用上传接口 Map headMap = new HashMap<>(); @@ -141,7 +270,7 @@ public class BgtsServiceImpl implements IBgtsService { // } // } Element esbEntry = document.addElement("ESBEntry"); - Element request = HttpUtils.reqElement(esbEntry,0); + Element request = HttpUtils.reqElement(esbEntry, 0); request.addElement("EXAM_NO").setText(exam[0]); String resXml = invokeWs(esbEntry.asXML()); //解析XML @@ -180,9 +309,9 @@ public class BgtsServiceImpl implements IBgtsService { // } // } Element esbEntry = document.addElement("ESBEntry"); - Element reqElement = HttpUtils.reqElement(esbEntry,1); + Element reqElement = HttpUtils.reqElement(esbEntry, 1); reqElement.addElement("EMPI_ID").setText(empId); - logger.info("-------根据患者主索引号查询多个报告单号,地址："+wsUrl+",方法："+wsLocalMethod+"---------"); + logger.info("-------根据患者主索引号查询多个报告单号,地址：" + wsUrl + ",方法：" + wsLocalMethod + "---------"); String xml = esbEntry.asXML(); logger.info("---------------------------"); logger.info(xml); @@ -220,6 +349,7 @@ public class BgtsServiceImpl implements IBgtsService { /** * 调用web service + * * @param xml * @return * @throws Exception @@ -239,11 +369,11 @@ public class BgtsServiceImpl implements IBgtsService { // call.setTimeout(100000);//超时 // String result = (String) call.invoke(object);// 远程调用 // System.out.println(result); - logger.info("-----\n客户端调用服务端："+wsUrl+"方法："+wsLocalMethod+"\n------------"); + logger.info("-----\n客户端调用服务端：" + wsUrl + "方法：" + wsLocalMethod + "\n------------"); JAXDynamicClientFactory dcf = JAXDynamicClientFactory.newInstance(); Client client = dcf.createClient(wsUrl); - Object[] objects = client.invoke(wsLocalMethod,xml); - String str = objects[0].toString(); + Object[] objects = client.invoke(wsLocalMethod, xml); + String str = objects[0].toString(); logger.info("----------结果---------"); logger.info(str); return str; diff --git a/src/main/java/com/docus/bgts/web/FilterConfig.java b/src/main/java/com/docus/bgts/web/FilterConfig.java new file mode 100644 index 0000000..8f7820d --- /dev/null +++ b/src/main/java/com/docus/bgts/web/FilterConfig.java @@ -0,0 +1,16 @@ +package com.docus.bgts.web; + +import org.springframework.boot.web.servlet.FilterRegistrationBean; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +@Configuration +public class FilterConfig { + + @Bean + public FilterRegistrationBean getFilter(){ + FilterRegistrationBean bean=new FilterRegistrationBean(new MyFilter()); + return bean; + } + +} diff --git a/src/main/java/com/docus/bgts/web/MyFilter.java b/src/main/java/com/docus/bgts/web/MyFilter.java new file mode 100644 index 0000000..eaf8bcd --- /dev/null +++ b/src/main/java/com/docus/bgts/web/MyFilter.java @@ -0,0 +1,33 @@ +package com.docus.bgts.web; + + +import com.docus.bgts.utils.FileUtils; +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; + +import javax.servlet.*; +import javax.servlet.annotation.WebFilter; +import java.io.IOException; + +@WebFilter(filterName = "myFilter",urlPatterns = {"/*"}) +public class MyFilter implements Filter { + + private Logger logger= LogManager.getLogger(); + + + @Override + public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException { + logger.info("拦截开始"); + String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid")); + if(collectorid.equals("5")){ + logger.info("当前请求已被拦截..."); + }else { + filterChain.doFilter(servletRequest,servletResponse); + } + } + + @Override + public void destroy() { + + } +} diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 1c3bbc5..0b21316 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -24,7 +24,7 @@ spring: driver-class-name: com.mysql.cj.jdbc.Driver username: docus password: docus702 - url: jdbc:mysql://db.docus.cn:3306/docus_archivefile?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true + url: jdbc:mysql://db.docus.cn:3306/docus_archivefile?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true oracle-docus: driver-class-name: oracle.jdbc.driver.OracleDriver url: jdbc:oracle:thin:@192.168.117.100:1521:helowin diff --git a/src/main/resources/mapper/dbmysql/AfCollectAddMapper.xml b/src/main/resources/mapper/dbmysql/AfCollectAddMapper.xml new file mode 100644 index 0000000..09a79dc --- /dev/null +++ b/src/main/resources/mapper/dbmysql/AfCollectAddMapper.xml @@ -0,0 +1,9 @@ + + + + + \ No newline at end of file diff --git a/src/main/resources/mapper/dbmysql/MrReportErrorMapper.xml b/src/main/resources/mapper/dbmysql/MrReportErrorMapper.xml new file mode 100644 index 0000000..53802d5 --- /dev/null +++ b/src/main/resources/mapper/dbmysql/MrReportErrorMapper.xml @@ -0,0 +1,10 @@ + + + + + insert into docus_medicalrecord.mr_report_error(xml,report_type,create_time) + values(#{mrReportError.xml},#{mrReportError.reportType},#{mrReportError.createTime}) + + \ No newline at end of file diff --git a/src/main/resources/mapper/dboracle/VDocumentPdfMapper.xml b/src/main/resources/mapper/dboracle/VDocumentPdfMapper.xml new file mode 100644 index 0000000..2de8592 --- /dev/null +++ b/src/main/resources/mapper/dboracle/VDocumentPdfMapper.xml @@ -0,0 +1,33 @@ + + + + + + \ No newline at end of file