소스 검색

修复三单管理bug

sola 9 달 전
부모
커밋
60590132a5
1개의 변경된 파일6개의 추가작업 그리고 3개의 파일을 삭제
  1. 6 3
      business-common/src/main/java/com/rongwei/bscommon/sys/service/impl/ZhcxPMQMServiceImpl.java

+ 6 - 3
business-common/src/main/java/com/rongwei/bscommon/sys/service/impl/ZhcxPMQMServiceImpl.java

@@ -33,6 +33,8 @@ public class ZhcxPMQMServiceImpl implements ZhcxPMQMService {
     private String nxdbuser;
     @Value("${nxsystem.dbpw:#{null}}")
     private String nxdbpw;
+    @Value("${nxsystem.dburlfix:#{null}}")
+    private String nxurlfix;
 
     @Autowired
     private ZhcxPMQMDao pmqmDao;
@@ -203,15 +205,15 @@ public class ZhcxPMQMServiceImpl implements ZhcxPMQMService {
                 .map(map -> (String) map.get("PROJECT_CODE"))
                 .collect(Collectors.toSet());
         List<ZhcxPmqManagementRecoredDo> tempList1 = recoredDao.getMaxDatetime();
-        String maxTime = "2000-01-01 00:00:01";
+        String maxTime = "2024-07-01 10:01:01";
         if (!tempList1.isEmpty() && tempList1.get(0) != null && tempList1.get(0).getDistributetime() != null) {
             maxTime = DateFormatUtils.format(tempList1.get(0).getDistributetime(), "yyyy-MM-dd HH:mm:ss");
         }
         List<ZhcxPmqManagementSourceDo> list = new ArrayList<>();
-        String url ="jdbc:sqlserver://"+nxurl+":1433;databaseName="+nxdbname+";encrypt=true;trustServerCertificate=true";
+        String url ="jdbc:sqlserver://"+nxurl+":1433;databaseName="+nxdbname+";"+nxurlfix+"";
         try(Connection connection = DriverManager.getConnection(url,nxdbuser,nxdbpw);
             Statement statement = connection.createStatement()) {
-            String sqlStr = "SELECT * FROM JUV1841 WHERE 下发日期 > '"+maxTime+"'";
+            String sqlStr = "SELECT TOP (300) * FROM JUV1841 WHERE 下发日期 > '"+maxTime+"'";
             try(ResultSet resultSet = statement.executeQuery(sqlStr)) {
                 while (resultSet.next()) {
                     ZhcxPmqManagementSourceDo entity = new ZhcxPmqManagementSourceDo();
@@ -245,6 +247,7 @@ public class ZhcxPMQMServiceImpl implements ZhcxPMQMService {
                 e1.printStackTrace();
             }
         }catch(SQLException e2){
+
             e2.printStackTrace();
     }