解开注释添加oracle数据

src/main/java/com/emr/controller/beHospitaledController.java

@@ -253,8 +253,10 @@ public class beHospitaledController {
                 log.error("优先采集查询oracle出错,请查看error.log文件");
             }
             //赋值两时间：最近上传时间与最新手动提交时间
-            setTwoTimeForList(list);
-            log.info("优先采集查询成功!");
+            if(!CollectionUtils.isEmpty(list)) {
+                setTwoTimeForList(list);
+                log.info("优先采集查询成功!");
+            }
             return JSON.toJSONString(list);
         } catch (Exception e) {
             e.printStackTrace();
@@ -265,36 +267,34 @@ public class beHospitaledController {
 
     //赋值两时间：最近上传时间与最新手动提交时间
     private void setTwoTimeForList(List<HisCollectInfo> list) {
-        if(!CollectionUtils.isEmpty(list)){
-            StringBuilder fileIdsStr = new StringBuilder();
-            for (int i = 0; i < list.size(); i++) {
-                String ffileId = list.get(i).getFfileId();
-                if(i != 0){
-                    fileIdsStr.append(",");
-                }
-                fileIdsStr.append("'").append(ffileId).append("'");
+        StringBuilder fileIdsStr = new StringBuilder();
+        for (int i = 0; i < list.size(); i++) {
+            String ffileId = list.get(i).getFfileId();
+            if(i != 0){
+                fileIdsStr.append(",");
             }
-            //查询detail表的上传时间
-            List<Archive_Detail> archiveDetails = detailMapper.selectUpdateTimeBySubAssort(fileIdsStr.toString());
-            //查询archive_sumbitDate_info的提交时间
-            List<ArchiveSumbitdateInfo> archiveSumbitdateInfoList = sumbitdateInfoMapper.selectOneByFileId(fileIdsStr.toString());
-            if(!CollectionUtils.isEmpty(archiveDetails) || !CollectionUtils.isEmpty(archiveSumbitdateInfoList)){
-                for (HisCollectInfo hisCollectInfo : list) {
-                    String ffileId = hisCollectInfo.getFfileId();
-                    if(!CollectionUtils.isEmpty(archiveDetails)){
-                        for (Archive_Detail archiveDetail : archiveDetails) {
-                            if (ffileId.equals(archiveDetail.getSubassort())) {
-                                hisCollectInfo.setUpdateLoadTime(archiveDetail.getUploaddatetime());
-                                break;
-                            }
+            fileIdsStr.append("'").append(ffileId).append("'");
+        }
+        //查询detail表的上传时间
+        List<Archive_Detail> archiveDetails = detailMapper.selectUpdateTimeBySubAssort(fileIdsStr.toString());
+        //查询archive_sumbitDate_info的提交时间
+        List<ArchiveSumbitdateInfo> archiveSumbitdateInfoList = sumbitdateInfoMapper.selectOneByFileId(fileIdsStr.toString());
+        if(!CollectionUtils.isEmpty(archiveDetails) || !CollectionUtils.isEmpty(archiveSumbitdateInfoList)){
+            for (HisCollectInfo hisCollectInfo : list) {
+                String ffileId = hisCollectInfo.getFfileId();
+                if(!CollectionUtils.isEmpty(archiveDetails)){
+                    for (Archive_Detail archiveDetail : archiveDetails) {
+                        if (ffileId.equals(archiveDetail.getSubassort())) {
+                            hisCollectInfo.setUpdateLoadTime(archiveDetail.getUploaddatetime());
+                            break;
                         }
                     }
-                    if(!CollectionUtils.isEmpty(archiveSumbitdateInfoList)){
-                        for (ArchiveSumbitdateInfo info : archiveSumbitdateInfoList) {
-                            if (ffileId.equals(info.getFileId())) {
-                                hisCollectInfo.setSumbitTime(info.getCreateTime());
-                                break;
-                            }
+                }
+                if(!CollectionUtils.isEmpty(archiveSumbitdateInfoList)){
+                    for (ArchiveSumbitdateInfo info : archiveSumbitdateInfoList) {
+                        if (ffileId.equals(info.getFileId())) {
+                            hisCollectInfo.setSumbitTime(info.getCreateTime());
+                            break;
                         }
                     }
                 }
@@ -350,7 +350,7 @@ public class beHospitaledController {
                 String sql = "insert into pacs.p_pdf_print(FENTRYNO,FPATNO,FAPPLYTIME,FFILE_ID) values('"+fentryNoList[i]+"','"+fpatno+"','"+fapplytime+"','"+ffileIdList[i]+"')";
                 log.info("优先采集插入语句:"+sql);
                 try {
-                    //OracleConnect.insert(sql);
+                    OracleConnect.insert(sql);
                     log.info("优先采集插入oracle成功");
                 }catch (Exception e){
                     e.printStackTrace();

src/main/java/com/emr/util/OracleConnect.java

@@ -108,17 +108,17 @@ public class OracleConnect {
         rs = pst.executeQuery();
         List<HisCollectInfo> list = new ArrayList<>();
         if (rs != null) {
-            ResultSetMetaData md = rs.getMetaData();
-            int columnCount = md.getColumnCount();
-            Map rowData = new HashMap();
-            while (rs.next()) {
-                HisCollectInfo info = new HisCollectInfo();
-                info.setFentryNo(rs.getString(1));
-                info.setFentryName(rs.getString(2));
-                info.setFrecName(rs.getString(3));
-                info.setFfileId(rs.getString(4));
-                info.setPdfflag(rs.getString(5));
-                list.add(info);
+            System.out.println("查询oracle");
+            if(!rs.next()) {
+                while (rs.next()) {
+                    HisCollectInfo info = new HisCollectInfo();
+                    info.setFentryNo(rs.getString(1));
+                    info.setFentryName(rs.getString(2));
+                    info.setFrecName(rs.getString(3));
+                    info.setFfileId(rs.getString(4));
+                    info.setPdfflag(rs.getString(5));
+                    list.add(info);
+                }
             }
         }
         OracleConnect.CloseConn(rs, pst, conn);