修改bug

src/main/java/com/example/demo/service/QrTaskService.java

@@ -14,6 +14,7 @@ import com.example.demo.domain.entity.QrtzTaskDetail;
 import com.example.demo.domain.entity.WebLoginConfig;
 import com.example.demo.mapper.QrtzTaskMapper;
 import com.example.demo.model.vo.PersonnelVO;
+import com.example.demo.util.CacheUtils;
 import com.example.demo.util.LoginUtils;
 import com.example.demo.util.Response;
 import lombok.RequiredArgsConstructor;
@@ -44,6 +45,7 @@ public class QrTaskService extends ServiceImpl<QrtzTaskMapper, QrtzTask> {
     private final QrTaskDetailService qrTaskDetailService;
     private final LoginUtils loginUtils;
     private final WebLoginConfigService webLoginConfigService;
+    private  final CacheUtils cacheUtils;
     /**
      * 新增任务
      *
@@ -52,8 +54,9 @@ public class QrTaskService extends ServiceImpl<QrtzTaskMapper, QrtzTask> {
     public QrtzTask addQuartzTask(QrtzTaskAddNewDTO qrtzTaskAddNewDTO) {
         log.info("开始处理【新增任务条件】的业务，参数为：{}", qrtzTaskAddNewDTO);
          Integer webId =   qrtzTaskAddNewDTO.getConfigId();
+        PersonnelVO personnelVO = cacheUtils.getLoginUserPersonnel(loginUtils.getId());
          //根据网站id获得配置
-       WebLoginConfig webLoginConfig = webLoginConfigService.getLoginConfig(webId);
+       WebLoginConfig webLoginConfig = webLoginConfigService.getLoginConfig(webId,personnelVO.getTenantId());
        if(webLoginConfig==null){
            return  null;
        }
@@ -61,6 +64,7 @@ public class QrTaskService extends ServiceImpl<QrtzTaskMapper, QrtzTask> {
         QrtzTask qrtzTask = new QrtzTask();
         BeanUtils.copyProperties(qrtzTaskAddNewDTO, qrtzTask);
         qrtzTask.setCreatePersonId(loginUtils.getId());
+        qrtzTask.setTenantId(personnelVO.getTenantId());
         List<String> cells = qrtzTaskAddNewDTO.getConfigCells();
         if (cells == null) {
             qrtzTask.setConfigCells("");
@@ -71,7 +75,6 @@ public class QrTaskService extends ServiceImpl<QrtzTaskMapper, QrtzTask> {
 
         log.info("数据入任务条件表");
         qrtzTask.insert();
-
         //若是普通任务则新增一条任务执行情况
         if (qrtzTask.getTaskType() != 1) {
             QrtzTaskDetail qrtzTaskDetail = new QrtzTaskDetail()

src/main/java/com/example/demo/service/UploadFromWebService.java

@@ -72,7 +72,9 @@ public class UploadFromWebService {
             //conditions = this.formatConditions(conditions);
             //根据id 获得网站配置
             WebConfig webConfig = webConfigService.getConfigById(id);
-            if (webConfig == null) {
+            //根据网站id和用户的租户获得登录信息
+            WebLoginConfig webLoginConfig = webLoginConfigService.getLoginConfig(webConfig.getId(),qrtzTask.getTenantId());
+            if (webLoginConfig == null) {
                 qrtzTaskDetail.setTaskDetailState(3);
                 qrtzTaskDetail.setSuccessNum(successNum);
                 qrtzTaskDetail.setDefaultNum(qrtzTaskDetail.getAllNum() - successNum);
@@ -91,8 +93,6 @@ public class UploadFromWebService {
                         .setTotal(successNum), ResponseEnum.PATENT_IMPORT_TASK_SUCCESS), "null");
                 return null;
             }
-            //根据网站id和用户的租户获得登录信息
-            WebLoginConfig webLoginConfig = webLoginConfigService.getLoginConfig(webConfig.getId());
             //1.获得驱动
             //  System.setProperty("webdriver.chrome.driver", "D:\\driver\\chromedriver.exe");
             System.setProperty("webdriver.chrome.driver", url);
@@ -514,21 +514,41 @@ public class UploadFromWebService {
     public List<PatentCell> getEPO(WebQueryDTO webQueryDTO) throws Exception {
         log.info("开始处理【下载欧专局专利数据】的业务，参数为：{}", webQueryDTO);
         List<PatentCell> patentCells = new ArrayList<>();
-        //当前任务执行情况
-//        QrtzTaskDetail qrtzTaskDetail = qrTaskDetailService.getById(webQueryDTO.getTaskId());
-//        Integer successNum = qrtzTaskDetail.getSuccessNum();
-//        int startPage = successNum / 5;
-//        int startNum = successNum % 5;
-//        //当前任务条件
-//        QrtzTask qrtzTask = qrTaskService.getById(qrtzTaskDetail.getTaskId());
-
+        QrtzTaskDetail qrtzTaskDetail = qrTaskDetailService.getById(webQueryDTO.getTaskId());
+        Integer successNum = qrtzTaskDetail.getSuccessNum();
+        int startPage = successNum / 5;
+        int startNum = successNum % 5;
+        //当前任务条件
+        QrtzTask qrtzTask = qrTaskService.getById(qrtzTaskDetail.getTaskId());
         //1.从DTO中取出网站id、检索信息条件、下载字段、专题库id、报告id
         Integer webId = webQueryDTO.getWebConfigId();
         List<String> cells = webQueryDTO.getConCells();
         String conditions = webQueryDTO.getConditions();
         Integer projectId = webQueryDTO.getProjectId();
         Integer reportId = webQueryDTO.getReportId();
-
+        //根据id 获得网站配置
+        WebConfig webConfig = webConfigService.getConfigById(webId);
+        //根据网站id和用户的租户获得登录信息
+        WebLoginConfig webLoginConfig = webLoginConfigService.getLoginConfig(webConfig.getId(),qrtzTask.getTenantId());
+        if (webLoginConfig == null) {
+            qrtzTaskDetail.setTaskDetailState(3);
+            qrtzTaskDetail.setSuccessNum(successNum);
+            qrtzTaskDetail.setDefaultNum(qrtzTaskDetail.getAllNum() - successNum);
+            qrtzTaskDetail.setFailure("未配置登录信息");
+            qrtzTaskDetail.setEndTime(new Date());
+            qrtzTaskDetail.updateById();
+            WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
+                    .setId(webQueryDTO.getTaskId())
+                    .setProjectId(webQueryDTO.getProjectId())
+                    .setComplete(true)
+                    .setIndex(successNum)
+                    .setPercentage(0.0)
+                    .setTaskDetailState(3)
+                    .setFileName("")
+                    .setUrl("")
+                    .setTotal(successNum), ResponseEnum.PATENT_IMPORT_TASK_SUCCESS), "null");
+            return null;
+        }
         //定义每次检索的专利数量(每次检索50件)
         int size = 50;
 
@@ -541,9 +561,41 @@ public class UploadFromWebService {
 
         //获得专利总数量
         Integer count = serachBiblioData.getTotals();
-
+        //计算进度值
+        double percentage = count == 0 ? 0 : (count.equals(successNum) ? (successNum * 1D) : (successNum + 1D) / count * 100D);
+        percentage = MathUtils.saveTwoDecimal(percentage);
         //3.根据专利总数量count计算检索次数，来循环检索
         for (int i = 1; i <= count; i += size) {
+            //查看任务状态
+            QrtzTaskDetail qrtzTaskDetail1 = qrTaskDetailService.getById(webQueryDTO.getTaskId());
+            if (qrtzTaskDetail1.getTaskDetailState().equals(7)) {
+                qrtzTaskDetail1.setTaskDetailState(5);
+                qrtzTaskDetail1.setSuccessNum(successNum);
+                qrtzTaskDetail1.setTaskProcess(percentage);
+                qrtzTaskDetail1.updateById();
+                WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
+                        .setId(webQueryDTO.getTaskId())
+                        .setProjectId(webQueryDTO.getProjectId())
+                        .setComplete(false)
+                        .setIndex(successNum)
+                        .setTaskDetailState(5)
+                        .setTotal(count), ResponseEnum.PATENT_IMPORT_TASK_SUCCESS), "null");
+                return null;
+            } else if (qrtzTaskDetail1.getTaskDetailState().equals(8)) {
+                qrtzTaskDetail1.setTaskDetailState(6);
+                qrtzTaskDetail1.setSuccessNum(successNum);
+                qrtzTaskDetail1.setTaskProcess(percentage);
+                qrtzTaskDetail1.updateById();
+                WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
+                        .setId(webQueryDTO.getTaskId())
+                        .setProjectId(webQueryDTO.getProjectId())
+                        .setComplete(false)
+                        .setIndex(successNum)
+                        .setTaskDetailState(6)
+                        .setTotal(count), ResponseEnum.PATENT_IMPORT_TASK_SUCCESS), "null");
+                return null;
+            }
+
             //3.1根据检索式conditions、专利开始数i、专利最后数i + size - 1检索专利著录信息
             serachBiblioData = getSerachBiblioData(conditions, i, i + size - 1);
             //获取检索结果中的所有专利著录信息
@@ -555,7 +607,7 @@ public class UploadFromWebService {
             //3.2遍历专利
             for (PatentZhuLu patent : patents) {
                 PatentCell patentCell = new PatentCell();
-                patentCell.setProjectId(projectId);
+                patentCell.setProjectId(qrtzTask.getProjectId());
                 PubNo pubNO = new PubNo();
                 //装载专利著录
                 if (cells.contains("1")) {
@@ -635,33 +687,93 @@ public class UploadFromWebService {
                     if (cells.contains("7")) {
                         setFuJian(drawingLink, drawingPage, drawingType, patentCell, ".tiff");
                     }
+                    if (patentCell.getPatentNo() != null) {
+                        String res = outInterfaceService.importPatents(patentCell);
+                        JSONObject jsonObject = JSONObject.parseObject(res);
+                        if (jsonObject.get("code").toString().equals("500")) {
+                            //任务执行情况状态设为失败，任务条件状态设为已完成(若是任务条件是定时任务则设为等待下一次执行)
+                            qrtzTaskDetail.setTaskDetailState(3);
+                            qrtzTaskDetail.setSuccessNum(successNum);
+                            qrtzTaskDetail.setDefaultNum(count - successNum);
+                            qrtzTaskDetail.setEndTime(new Date());
+                            qrtzTaskDetail.updateById();
+                            if (qrtzTask.getTaskType() == 1) {
+                                qrtzTask.setTaskState(4);
+                            } else {
+                                qrtzTask.setTaskState(3);
+                            }
+                            qrtzTask.updateById();
+                            return null;
+                        }
+                    }
+
+                    QrtzTaskDetail qrtzTaskDetail11 = qrTaskDetailService.getById(qrtzTaskDetail.getId());
+                    percentage = count == 0 ? 0 : (count.equals(successNum) ? (successNum * 1D) : (successNum + 1D) / count * 100D);
+                    percentage = MathUtils.saveTwoDecimal(percentage);
+                    WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
+                            .setId(webQueryDTO.getTaskId())
+                            .setProjectId(webQueryDTO.getProjectId())
+                            .setComplete(false)
+                            .setIndex(successNum)
+                            .setPercentage(percentage)
+                            .setTaskDetailState(qrtzTaskDetail11.getTaskDetailState())
+                            .setFileName("")
+                            .setUrl("")
+                            .setTotal(count), ResponseEnum.PATENT_IMPORT_TASK_SUCCESS), "null");
                 } catch (XiaoShiException e) {
                     //虽然拿不到所有附图，但是可以拿其他的，能拿到啥是啥
                     log.info(e.getMessage());
+                    qrtzTaskDetail.setTaskDetailState(3);
+                    qrtzTaskDetail.setSuccessNum(successNum);
+                    qrtzTaskDetail.setDefaultNum(qrtzTaskDetail.getAllNum() - successNum);
+                    qrtzTaskDetail.setFailure("拉取节点失败");
+                    qrtzTaskDetail.setEndTime(new Date());
+                    qrtzTaskDetail.updateById();
+                    if (qrtzTask.getTaskType() == 1) {
+                        qrtzTask.setTaskState(4);
+                    } else {
+                        qrtzTask.setTaskState(3);
+                    }
+                    qrtzTask.updateById();
+                    WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
+                            .setId(webQueryDTO.getTaskId())
+                            .setProjectId(webQueryDTO.getProjectId())
+                            .setComplete(true)
+                            .setIndex(successNum)
+                            .setPercentage(100D)
+                            .setTaskDetailState(qrtzTaskDetail.getTaskDetailState())
+                            .setFileName("")
+                            .setUrl("")
+                            .setTotal(successNum), ResponseEnum.PATENT_IMPORT_TASK_SUCCESS), "");
                 }
 
                 //4.保存专利信息(发送给专题库)
-                String res = outInterfaceService.importPatents(patentCell);
-                JSONObject jsonObject = JSONObject.parseObject(res);
-                if (jsonObject.get("code").toString().equals("500")) {
-//                    //任务执行情况状态设为失败，任务条件状态设为已完成(若是任务条件是定时任务则设为等待下一次执行)
-//                    qrtzTaskDetail.setTaskDetailState(3);
-//                    qrtzTaskDetail.setSuccessNum(successNum);
-//                    qrtzTaskDetail.setDefaultNum(count - successNum);
-//                    qrtzTaskDetail.setEndTime(new Date());
-//                    qrtzTaskDetail.updateById();
-//                    if (qrtzTask.getTaskType() == 1) {
-//                        qrtzTask.setTaskState(4);
-//                    } else {
-//                        qrtzTask.setTaskState(3);
-//                    }
-//                    qrtzTask.updateById();
-//                    return null;
-                }
                 patentCells.add(patentCell);
             }
         }
-
+        WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
+                .setId(webQueryDTO.getTaskId())
+                .setProjectId(webQueryDTO.getProjectId())
+                .setComplete(true)
+                .setIndex(count)
+                .setPercentage(100D)
+                .setTaskDetailState(qrtzTaskDetail.getTaskDetailState())
+                .setFileName("")
+                .setUrl("")
+                .setTotal(count), ResponseEnum.PATENT_IMPORT_TASK_SUCCESS), "");
+        //任务执行情况状态设为成功，任务条件状态设为已完成(若是任务条件是定时任务则设为等待下一次执行)
+        qrtzTaskDetail.setTaskDetailState(2);
+        qrtzTaskDetail.setSuccessNum(successNum);
+        qrtzTaskDetail.setDefaultNum(qrtzTaskDetail.getAllNum() - successNum);
+        qrtzTaskDetail.setTaskProcess(100);
+        qrtzTaskDetail.setEndTime(new Date());
+        qrtzTaskDetail.updateById();
+        if (qrtzTask.getTaskType() == 1) {
+            qrtzTask.setTaskState(4);
+        } else {
+            qrtzTask.setTaskState(2);
+        }
+        qrtzTask.updateById();
         return patentCells;
 
     }
@@ -722,71 +834,49 @@ public class UploadFromWebService {
             byte[] buffer = outInterfaceService.getPatentFile(getFuTuParamsDTO);
             InputStream inputStream = new ByteArrayInputStream(buffer);
             streams[i - 1] = inputStream;
-            //如果不是说明书pdf
-            if (!FuJianSuffix.equals(".pdf")) {
-                File file = File.createTempFile("new_url", FuJianSuffix);
-                FileOutputStream out = new FileOutputStream(file);
-                out.write(buffer);
-                out.close();
-                streams[i - 1] = new FileInputStream(file);
-                DiskFileItemFactory diskFileItemFactory = new DiskFileItemFactory(16, null);
-                FileItem item = diskFileItemFactory.createItem(file.getName(), "text/plain", true, file.getName());
-                int bytesRead = 0;
-                buffer = new byte[8192];
-                try {
-                    FileInputStream fis = new FileInputStream(file);
-                    OutputStream os = item.getOutputStream();
-                    int len = 8192;
-                    while ((bytesRead = fis.read(buffer, 0, len)) != -1) {
-                        os.write(buffer, 0, bytesRead);
-                    }
-                    os.close();
-                    fis.close();
-                } catch (IOException e) {
-                    e.printStackTrace();
-                }
-                MultipartFile multipartFile = new CommonsMultipartFile(item);
-                UploadFileDTO fileDTO = fileUtils.uploadFile(multipartFile);
-                //如果是摘要附图
-                if (FuJianSuffix.equals(".jpeg")) {
-                    patentCell.setPicUrl(fileDTO.getPath());
-                }
-                //如果是其他附图
-                if (FuJianSuffix.equals(".tiff")) {
-                    otherUrls.add(fileDTO.getPath());
-                }
-            }
+//            File file = File.createTempFile("new_url", FuJianSuffix);
+//            FileOutputStream out = new FileOutputStream(file);
+//            out.write(buffer);
+//            out.close();
+//            streams[i - 1] = new FileInputStream(file);
+//            DiskFileItemFactory diskFileItemFactory = new DiskFileItemFactory(16, null);
+//            FileItem item = diskFileItemFactory.createItem(file.getName(), "text/plain", true, file.getName());
+//            int bytesRead = 0;
+//            buffer = new byte[8192];
+//            try {
+//                FileInputStream fis = new FileInputStream(file);
+//                OutputStream os = item.getOutputStream();
+//                int len = 8192;
+//                while ((bytesRead = fis.read(buffer, 0, len)) != -1) {
+//                    os.write(buffer, 0, bytesRead);
+//                }
+//                os.close();
+//                fis.close();
+//            } catch (IOException e) {
+//                e.printStackTrace();
+//            }
+//            MultipartFile multipartFile = new CommonsMultipartFile(item);
+//            UploadFileDTO fileDTO = fileUtils.uploadFile(multipartFile);
+//            switch (FuJianSuffix) {
+//                case ".pdf":
+//                    streams[i - 1] = new FileInputStream(fileDTO.getPath());
+//                    break;
+//                case ".jpeg":
+//                    patentCell.setPicUrl(fileDTO.getPath());
+//                    break;
+//                case ".tiff":
+//                    otherUrls.add(fileDTO.getPath());
+//                    break;
+//            }
         }
 
-        //如果是说明书pdf
         if (FuJianSuffix.equals(".pdf")) {
             //合并说明书多个pdf文件
             PdfDocumentBase doc = PdfDocument.mergeFiles(streams);
             //保存结果文件
             doc.save("merge.pdf", FileFormat.PDF);
-            doc.close();
 
-            //手动将合并后的pdf文件转成MultipartFile，上传文件并获取path装载到patentCell
-            File file = new File("merge.pdf");
-            DiskFileItemFactory diskFileItemFactory = new DiskFileItemFactory(16, null);
-            FileItem item = diskFileItemFactory.createItem(file.getName(), "text/plain", true, file.getName());
-            int bytesRead = 0;
-            byte[] buffer = new byte[8192];
-            try {
-                FileInputStream fis = new FileInputStream(file);
-                OutputStream os = item.getOutputStream();
-                int len = 8192;
-                while ((bytesRead = fis.read(buffer, 0, len)) != -1) {
-                    os.write(buffer, 0, bytesRead);
-                }
-                os.close();
-                fis.close();
-            } catch (IOException e) {
-                e.printStackTrace();
-            }
-            MultipartFile multipartFile = new CommonsMultipartFile(item);
-            UploadFileDTO fileDTO = fileUtils.uploadFile(multipartFile);
-            patentCell.setPdf(fileDTO);
+            doc.close();
         } else if (FuJianSuffix.equals(".tiff")) {
             patentCell.setOtherUrls(otherUrls);
         }
@@ -885,7 +975,7 @@ public class UploadFromWebService {
             }
         }
         //装载申请日
-        patentCell.setApplicationDate(patent.getAppDate().substring(0, patent.getAppDate().indexOf("T")));
+        patentCell.setApplicationDate(patent.getAppDate());
         //装载国家/省市
         patentCell.setCountry(patent.getAppCountry());
         //装载公开号
@@ -898,7 +988,7 @@ public class UploadFromWebService {
         //装载专利号
         patentCell.setPatentNo(patentCell.getPublicNo());
         //装载公开日
-        patentCell.setPubilcDate(patent.getPubDate().substring(0, patent.getPubDate().indexOf("T")));
+        patentCell.setPubilcDate(patent.getPubDate());
         //装载授权公告号(未找到)
         //装载授权公告日(未找到)
         //装载主分类号
@@ -953,7 +1043,7 @@ public class UploadFromWebService {
                     Priority priority = new Priority()
                             .setPriorityNo(number.getNumber().substring(2))
                             .setPriorityCountry(number.getNumber().substring(0, 2))
-                            .setPriorityDate(priorty.getDate().substring(0, priorty.getDate().indexOf("T")));
+                            .setPriorityDate(priorty.getDate());
                     priorities.add(priority);
                 }
             }

src/main/java/com/example/demo/service/WebLoginConfigService.java

@@ -50,11 +50,10 @@ public class WebLoginConfigService extends ServiceImpl<WebLoginConfigMapper, Web
         this.saveOrUpdate(config);
     }
 
-    public WebLoginConfig getLoginConfig(Integer webId) {
-        PersonnelVO personnelVO = cacheUtils.getLoginUserPersonnel(loginUtils.getId());
+    public WebLoginConfig getLoginConfig(Integer webId,Integer tenantId) {
         LambdaQueryWrapper<WebLoginConfig> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(WebLoginConfig::getWebId, webId)
-                .eq(WebLoginConfig::getTenantId, personnelVO.getTenantId());
+                .eq(WebLoginConfig::getTenantId,tenantId);
         List<WebLoginConfig> configs = this.list(wrapper);
         WebLoginConfig config = new WebLoginConfig();
         if (configs.size() > 0) {

src/main/java/com/example/demo/service/WebUploadJob.java

@@ -77,7 +77,13 @@ public class WebUploadJob extends QuartzJobBean {
                 webQueryDTO.setProjectId(qrtzTask.getProjectId());
                 webQueryDTO.setTaskId(qrtzTaskDetail.getId());
                 try {
-                    uploadFromWebService.getPatentStar(webQueryDTO);
+                    //专利之星
+                    if (webQueryDTO.getWebConfigId() == 1 || webQueryDTO.getWebConfigId() == 4) {
+                       uploadFromWebService.getPatentStar(webQueryDTO);
+                        //欧专局
+                    } else if (webQueryDTO.getWebConfigId() == 2) {
+                         uploadFromWebService.getEPO(webQueryDTO);
+                    }
                 } catch (Exception e) {
                     e.printStackTrace();
                 }

src/main/resources/application-prodNetIn.yml

@@ -0,0 +1,67 @@
+
+spring:
+  redis:
+    host: 172.27.247.174
+    port: 6379
+    database: 3
+    password: Xx0GWxdWQJxx6Swe
+    lettuce:
+      pool:
+        max-active: 20
+        max-idle: 20
+        min-idle: 0
+        max-wait: -1ms
+    timeout: 2000ms
+  datasource:
+    url: jdbc:mysql://172.27.247.174:3306/pas-prod?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=GMT%2B8
+    username: root
+    password: TU5x6IeBi7rl
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    type: com.alibaba.druid.pool.DruidDataSource
+    druid:
+      stat-view-servlet:
+        login-username: admin
+        login-password: 123456
+      web-stat-filter:
+        exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
+  quartz:
+    #相关属性配置
+    properties:
+      org:
+        quartz:
+          scheduler:
+            instanceName: DefaultQuartzScheduler
+            instanceId: AUTO
+          jobStore:
+            class: org.springframework.scheduling.quartz.LocalDataSourceJobStore
+            driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
+            tablePrefix: QRTZ_
+            isClustered: false
+            clusterCheckinInterval: 10000
+            useProperties: false
+          threadPool:
+            class: org.quartz.simpl.SimpleThreadPool
+            threadCount: 10
+            threadPriority: 5
+            threadsInheritContextClassLoaderOfInitializingThread: true
+          dataSource:
+            default:
+              URL: jdbc:mysql://172.27.247.174:3306/pas-prod?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=GMT%2B8
+              user: root
+              password: TU5x6IeBi7rl
+              driver: com.mysql.jdbc.Driver
+
+    #数据库方式
+    job-store-type: jdbc
+    #初始化表结构
+    jdbc:
+      initialize-schema: never
+PCSUrl: http://localhost:8879
+PASUrl: http://localhost:8877
+OPSUrl: http://192.168.1.24:5001
+mybatis-plus:
+  mapper-locations: classpath:mapper/*.xml
+logging:
+  level:
+    com.example.demo: debug
+driverUrl: /opt/google/chrome/chromedriver

src/main/resources/application-prodNetOut.yml

@@ -0,0 +1,67 @@
+
+spring:
+  redis:
+    host: 47.101.137.223
+    port: 6379
+    database: 3
+    password: Xx0GWxdWQJxx6Swe
+    lettuce:
+      pool:
+        max-active: 20
+        max-idle: 20
+        min-idle: 0
+        max-wait: -1ms
+    timeout: 2000ms
+  datasource:
+    url: jdbc:mysql://47.101.137.223:3306/pas-prod?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=GMT%2B8
+    username: root
+    password: TU5x6IeBi7rl
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    type: com.alibaba.druid.pool.DruidDataSource
+    druid:
+      stat-view-servlet:
+        login-username: admin
+        login-password: 123456
+      web-stat-filter:
+        exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
+  quartz:
+    #相关属性配置
+    properties:
+      org:
+        quartz:
+          scheduler:
+            instanceName: DefaultQuartzScheduler
+            instanceId: AUTO
+          jobStore:
+            class: org.springframework.scheduling.quartz.LocalDataSourceJobStore
+            driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
+            tablePrefix: QRTZ_
+            isClustered: false
+            clusterCheckinInterval: 10000
+            useProperties: false
+          threadPool:
+            class: org.quartz.simpl.SimpleThreadPool
+            threadCount: 10
+            threadPriority: 5
+            threadsInheritContextClassLoaderOfInitializingThread: true
+          dataSource:
+            default:
+              URL: jdbc:mysql://47.101.137.223:3306/pas-prod?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=GMT%2B8
+              user: root
+              password: TU5x6IeBi7rl
+              driver: com.mysql.jdbc.Driver
+
+    #数据库方式
+    job-store-type: jdbc
+    #初始化表结构
+    jdbc:
+      initialize-schema: never
+PCSUrl: http://localhost:8879
+PASUrl: http://localhost:8877
+OPSUrl: http://192.168.1.24:5001
+mybatis-plus:
+  mapper-locations: classpath:mapper/*.xml
+logging:
+  level:
+    com.example.demo: debug
+driverUrl: /opt/google/chrome/chromedriver

src/main/resources/application.yml

@@ -21,7 +21,7 @@ spring:
       max-file-size: 1000MB
       max-request-size: 1000MB
   profiles:
-    active: dev
+    active: prodNetIn
   jackson:
     default-property-inclusion: non_null
     serialization:

src/main/resources/mapper/WebLoginConfigMapper.xml

@@ -7,8 +7,8 @@
         select web_name as webName,web_address as webAddress ,login_account as loginAccount ,login_password as
         loginPassword,b.id as id
         ,a.id as webId
-        from pas.web_config a
-        left join pas.web_login_config b
+        from web_config a
+        left join web_login_config b
         on a.id=b.web_id
         <where>
             b.tenant_id=#{params.tenantId}