ruoyi-admin/src/main/resources/application-dev.yml

@@ -0,0 +1,61 @@
+# 数据源配置
+spring:
+    datasource:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driverClassName: com.mysql.cj.jdbc.Driver
+        druid:
+            # 主库数据源
+            master:
+                url: jdbc:mysql://47.103.79.143:3306/tony-invest-uat?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
+                username: oneportal
+                password: Dgtis_oneportal
+            # 从库数据源
+            slave:
+                # 从数据源开关/默认关闭
+                enabled: false
+                url: 
+                username: 
+                password: 
+            # 初始连接数
+            initialSize: 5
+            # 最小连接池数量
+            minIdle: 10
+            # 最大连接池数量
+            maxActive: 20
+            # 配置获取连接等待超时的时间
+            maxWait: 60000
+            # 配置连接超时时间
+            connectTimeout: 30000
+            # 配置网络超时时间
+            socketTimeout: 60000
+            # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
+            timeBetweenEvictionRunsMillis: 60000
+            # 配置一个连接在池中最小生存的时间，单位是毫秒
+            minEvictableIdleTimeMillis: 300000
+            # 配置一个连接在池中最大生存的时间，单位是毫秒
+            maxEvictableIdleTimeMillis: 900000
+            # 配置检测连接是否有效
+            validationQuery: SELECT 1 FROM DUAL
+            testWhileIdle: true
+            testOnBorrow: false
+            testOnReturn: false
+            webStatFilter: 
+                enabled: true
+            statViewServlet:
+                enabled: true
+                # 设置白名单，不填则允许所有访问
+                allow: 222.141.1.33
+                url-pattern: /druid/*
+                # 控制台管理用户名和密码
+                login-username: ruoyi
+                login-password: DGT1qaz2wsx
+            filter:
+                stat:
+                    enabled: true
+                    # 慢SQL记录
+                    log-slow-sql: true
+                    slow-sql-millis: 10000
+                    merge-sql: true
+                wall:
+                    config:
+                        multi-statement-allow: true

ruoyi-flowable/src/main/java/com/ruoyi/flowable/service/impl/ApprovalServiceImpl.java

@@ -6,6 +6,7 @@ import com.ruoyi.common.enums.FileType;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.sms.SmsSenderUtils;
 import com.ruoyi.common.utils.uuid.IdUtils;
 import com.ruoyi.flowable.common.constant.ProcessConstants;
 import com.ruoyi.flowable.common.constant.UUIDGenerator;
@@ -29,9 +30,11 @@ import org.flowable.task.api.Task;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
 import java.util.*;
 
 /**
@@ -44,6 +47,8 @@ import java.util.*;
 public class ApprovalServiceImpl extends FlowServiceFactory implements IApprovalService
 {
     protected final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Value("${spring.profiles.active}")
+    private String active;
     @Autowired
     private ApprovalMapper approvalMapper;
     @Autowired
@@ -205,8 +210,10 @@ public class ApprovalServiceImpl extends FlowServiceFactory implements IApproval
                     if(flowBaseInfo.isFlag()){
                         getAssignee(tProjectApproval,flowBaseInfo);
                     }
-                    //todo 短信
-                    //sendMessage(flowBaseInfo,"");
+                    if (Objects.equals(active, "druid")) {
+                        //todo 短信
+                        sendMessage(flowBaseInfo,"");
+                    }
                     return AjaxResult.success();
                 }
                 return AjaxResult.error();
@@ -451,8 +458,10 @@ public class ApprovalServiceImpl extends FlowServiceFactory implements IApproval
             if(flow.isFlag()){
                 getAssignee(tProjectApproval,flow);
             }
-            // todo 短信提醒
-            //sendMessage(flow,result);
+            if (Objects.equals(active, "druid")) {
+                // todo 短信提醒
+                sendMessage(flow,result);
+            }
         }
         return AjaxResult.success();
     }
@@ -514,25 +523,23 @@ public class ApprovalServiceImpl extends FlowServiceFactory implements IApproval
                             String assignee = task.getAssignee();
                             if (org.apache.commons.lang3.StringUtils.isNotBlank(assignee)) { // 给审批人发送短信
                                 SysUser auditUser = sysUserService.selectUserById(Long.valueOf(assignee));
-                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectApproval.getProjectName() + "的项目立项流程待处理";
-                                System.out.println(auditContents);
+                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectApproval.getProjectName() + "的项目立项流程待处理，请查看！";
                                 if (auditUser != null && StringUtils.isNotBlank(auditUser.getPhonenumber())) {
-                                    /*try{
+                                    try{
                                         SmsSenderUtils.sendSms(auditUser.getPhonenumber(), auditContents);
                                     } catch (IOException e) {
                                         logger.error("短信发送失败"+e.getMessage());
-                                    }*/
+                                    }
                                 }
                             }
                         } else { // 审批人驳回，给申请人发短信
-                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectApproval.getProjectName() + "的项目立项申请已审核，结果为【驳回】";
-                            System.out.println(rejectContents);
+                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectApproval.getProjectName() + "的项目立项申请已审核，结果为【驳回】，请查看！";
                             if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                                /*try{
-                                    SmsSenderUtils.sendSms(rejectUser.getPhonenumber(), rejectContents);
+                                try{
+                                    SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), rejectContents);
                                 } catch (IOException e) {
                                     logger.error("短信发送失败"+e.getMessage());
-                                }*/
+                                }
                             }
                         }
                     }
@@ -543,26 +550,24 @@ public class ApprovalServiceImpl extends FlowServiceFactory implements IApproval
             if(flag) {
                 // 审批完成，给申请人发短信
                 //XXX，您好。你在投资系统中提交“XXX”的项目立项申请已审核，结果为【通过】/【驳回】/【观望】！
-                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectApproval.getProjectName() + "的项目立项申请已审核，结果为【同意】";
-                System.out.println(completeContents);
+                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectApproval.getProjectName() + "的项目立项申请已审核，结果为【同意】，请查看！";
                 if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
+                    try{
+                        SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
                     } catch (IOException e) {
                         logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                    }
                 }
 
             }else{
                 if(StringUtils.isNotEmpty(result)){//代表是终止或者观望
-                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectApproval.getProjectName() + "的项目立项申请已审核，结果为"+result;
-                    System.out.println(completeContents);
+                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectApproval.getProjectName() + "的项目立项申请已审核，结果为"+result+"，请查看！";
                     if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
-                    } catch (IOException e) {
-                        logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                        try{
+                            SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
+                        } catch (IOException e) {
+                            logger.error("短信发送失败"+e.getMessage());
+                        }
                     }
                 }
             }

ruoyi-flowable/src/main/java/com/ruoyi/flowable/service/impl/DecisionServiceImpl.java

@@ -6,6 +6,7 @@ import com.ruoyi.common.enums.FileType;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.sms.SmsSenderUtils;
 import com.ruoyi.common.utils.uuid.IdUtils;
 import com.ruoyi.flowable.common.constant.ProcessConstants;
 import com.ruoyi.flowable.common.constant.UUIDGenerator;
@@ -29,6 +30,7 @@ import org.flowable.task.api.Task;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletRequest;
@@ -45,6 +47,8 @@ import java.util.*;
 public class DecisionServiceImpl extends FlowServiceFactory implements IDecisionService
 {
     protected final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Value("${spring.profiles.active}")
+    private String active;
     @Autowired
     private DecisionMapper decisionMapper;
     @Autowired
@@ -203,8 +207,10 @@ public class DecisionServiceImpl extends FlowServiceFactory implements IDecision
                     if(flowBaseInfo.isFlag()){
                         getAssignee(tProjectDecision,flowBaseInfo);
                     }
-                    // todo 短信
-                    //sendMessage(flowBaseInfo,"");
+                    if (Objects.equals(active, "druid")) {
+                        // todo 短信
+                        sendMessage(flowBaseInfo,"");
+                    }
                     return AjaxResult.success();
                 }
                 return AjaxResult.error();
@@ -409,8 +415,10 @@ public class DecisionServiceImpl extends FlowServiceFactory implements IDecision
             if(flow.isFlag()){
                 getAssignee(tProjectDecision,flow);
             }
-            //todo 短信
-            //sendMessage(flow,result);
+            if (Objects.equals(active, "druid")) {
+                //todo 短信
+                sendMessage(flow,result);
+            }
         }
         return AjaxResult.success();
     }
@@ -470,25 +478,23 @@ public class DecisionServiceImpl extends FlowServiceFactory implements IDecision
                             String assignee = task.getAssignee();
                             if (org.apache.commons.lang3.StringUtils.isNotBlank(assignee)) { // 给审批人发送短信
                                 SysUser auditUser = sysUserService.selectUserById(Long.valueOf(assignee));
-                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectDecision.getProjectName() + "的项目投决流程待处理";
-                                System.out.println(auditContents);
+                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectDecision.getProjectName() + "的项目投决流程待处理，请查看！";
                                 if (auditUser != null && StringUtils.isNotBlank(auditUser.getPhonenumber())) {
-                                    /*try{
+                                    try{
                                         SmsSenderUtils.sendSms(auditUser.getPhonenumber(), auditContents);
                                     } catch (IOException e) {
                                         logger.error("短信发送失败"+e.getMessage());
-                                    }*/
+                                    }
                                 }
                             }
                         } else { // 审批人驳回，给申请人发短信
-                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectDecision.getProjectName() + "的项目投决申请已审核，结果为【驳回】";
-                            System.out.println(rejectContents);
+                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectDecision.getProjectName() + "的项目投决申请已审核，结果为【驳回】，请查看！";
                             if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                                /*try{
-                                    SmsSenderUtils.sendSms(rejectUser.getPhonenumber(), rejectContents);
+                                try{
+                                    SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), rejectContents);
                                 } catch (IOException e) {
                                     logger.error("短信发送失败"+e.getMessage());
-                                }*/
+                                }
                             }
                         }
                     }
@@ -499,26 +505,24 @@ public class DecisionServiceImpl extends FlowServiceFactory implements IDecision
             if(flag) {
                 // 审批完成，给申请人发短信
                 //XXX，您好。你在投资系统中提交“XXX”的项目投决申请已审核，结果为【通过】/【驳回】/【观望】！
-                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectDecision.getProjectName() + "的项目投决申请已审核，结果为【同意】";
-                System.out.println(completeContents);
+                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectDecision.getProjectName() + "的项目投决申请已审核，结果为【同意】，请查看！";
                 if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
+                    try{
+                        SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
                     } catch (IOException e) {
                         logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                    }
                 }
 
             }else{
                 if(StringUtils.isNotEmpty(result)){//代表是终止或者观望
-                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectDecision.getProjectName() + "的项目投决申请已审核，结果为"+result;
-                    System.out.println(completeContents);
+                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectDecision.getProjectName() + "的项目投决申请已审核，结果为"+result+"，请查看！";
                     if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
-                    } catch (IOException e) {
-                        logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                        try{
+                            SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
+                        } catch (IOException e) {
+                            logger.error("短信发送失败"+e.getMessage());
+                        }
                     }
                 }
             }

ruoyi-flowable/src/main/java/com/ruoyi/flowable/service/impl/InvestigateServiceImpl.java

@@ -29,6 +29,7 @@ import org.flowable.task.api.Task;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletRequest;
@@ -45,6 +46,8 @@ import java.util.*;
 public class InvestigateServiceImpl extends FlowServiceFactory implements IInvestigateService
 {
     protected final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Value("${spring.profiles.active}")
+    private String active;
     @Autowired
     private InvestigateMapper investigateMapper;
     @Autowired
@@ -194,8 +197,10 @@ public class InvestigateServiceImpl extends FlowServiceFactory implements IInves
                     if(flowBaseInfo.isFlag()){
                         getAssignee(tProjectInvestigate,flowBaseInfo);
                     }
-                    //todo 短信
-                    //sendMessage(flowBaseInfo,"");
+                    if (Objects.equals(active, "druid")) {
+                        //todo 短信
+                        sendMessage(flowBaseInfo,"");
+                    }
                     return AjaxResult.success();
                 }
                 return AjaxResult.error();
@@ -376,8 +381,10 @@ public class InvestigateServiceImpl extends FlowServiceFactory implements IInves
             if(flow.isFlag()){
                 getAssignee(tProjectInvestigate,flow);
             }
-            // todo 短信
-            //sendMessage(flow,result);
+            if (Objects.equals(active, "druid")) {
+                // todo 短信
+                sendMessage(flow,result);
+            }
         }
         return AjaxResult.success();
     }
@@ -437,25 +444,23 @@ public class InvestigateServiceImpl extends FlowServiceFactory implements IInves
                             String assignee = task.getAssignee();
                             if (org.apache.commons.lang3.StringUtils.isNotBlank(assignee)) { // 给审批人发送短信
                                 SysUser auditUser = sysUserService.selectUserById(Long.valueOf(assignee));
-                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectInvestigate.getProjectName() + "的项目背调流程待处理";
-                                System.out.println(auditContents);
+                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectInvestigate.getProjectName() + "的项目背调流程待处理，请查看！";
                                 if (auditUser != null && StringUtils.isNotBlank(auditUser.getPhonenumber())) {
-                                    /*try{
+                                    try{
                                         SmsSenderUtils.sendSms(auditUser.getPhonenumber(), auditContents);
                                     } catch (IOException e) {
                                         logger.error("短信发送失败"+e.getMessage());
-                                    }*/
+                                    }
                                 }
                             }
                         } else { // 审批人驳回，给申请人发短信
-                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectInvestigate.getProjectName() + "的项目背调申请已审核，结果为【驳回】";
-                            System.out.println(rejectContents);
+                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectInvestigate.getProjectName() + "的项目背调申请已审核，结果为【驳回】，请查看！";
                             if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                                /*try{
-                                    SmsSenderUtils.sendSms(rejectUser.getPhonenumber(), rejectContents);
+                                try{
+                                    SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), rejectContents);
                                 } catch (IOException e) {
                                     logger.error("短信发送失败"+e.getMessage());
-                                }*/
+                                }
                             }
                         }
                     }
@@ -466,26 +471,24 @@ public class InvestigateServiceImpl extends FlowServiceFactory implements IInves
             if(flag) {
                 // 审批完成，给申请人发短信
                 //XXX，您好。你在投资系统中提交“XXX”的项目背调申请已审核，结果为【通过】/【驳回】/【观望】！
-                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectInvestigate.getProjectName() + "的项目背调申请已审核，结果为【同意】";
-                System.out.println(completeContents);
+                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectInvestigate.getProjectName() + "的项目背调申请已审核，结果为【同意】，请查看！";
                 if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
+                    try{
+                        SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
                     } catch (IOException e) {
                         logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                    }
                 }
 
             }else{
                 if(StringUtils.isNotEmpty(result)){//代表是终止或者观望
-                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectInvestigate.getProjectName() + "的项目背调申请已审核，结果为"+result;
-                    System.out.println(completeContents);
+                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectInvestigate.getProjectName() + "的项目背调申请已审核，结果为"+result+"，请查看！";
                     if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
-                    } catch (IOException e) {
-                        logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                        try{
+                            SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
+                        } catch (IOException e) {
+                            logger.error("短信发送失败"+e.getMessage());
+                        }
                     }
                 }
             }

ruoyi-flowable/src/main/java/com/ruoyi/flowable/service/impl/InvestmentOpportunityServiceImpl.java

@@ -6,6 +6,7 @@ import com.ruoyi.common.enums.FileType;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.sms.SmsSenderUtils;
 import com.ruoyi.common.utils.uuid.IdUtils;
 import com.ruoyi.flowable.common.constant.ProcessConstants;
 import com.ruoyi.flowable.common.constant.UUIDGenerator;
@@ -27,9 +28,11 @@ import org.flowable.task.api.Task;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
 import java.util.*;
 
 /**
@@ -42,6 +45,8 @@ import java.util.*;
 public class InvestmentOpportunityServiceImpl extends FlowServiceFactory implements IInvestmentOpportunityService
 {
     protected final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Value("${spring.profiles.active}")
+    private String active;
     @Autowired
     private InvestmentOpportunityMapper investmentOpportunityMapper;
 
@@ -220,8 +225,10 @@ public class InvestmentOpportunityServiceImpl extends FlowServiceFactory impleme
                     if (flowBaseInfo.isFlag()) {
                         getAssignee(tProjectPool, flowBaseInfo);
                     }
-                    //todo 短信
-                    //sendMessage(flowBaseInfo,"");
+                    if (Objects.equals(active, "druid")) {
+                        //todo 短信
+                        sendMessage(flowBaseInfo,"");
+                    }
                     return AjaxResult.success();
                 }
                 return AjaxResult.error();
@@ -391,8 +398,10 @@ public class InvestmentOpportunityServiceImpl extends FlowServiceFactory impleme
             if(flow.isFlag()){
                 getAssignee(tProjectPool,flow);
             }
-            //todo 短信
-            //sendMessage(flow,result);
+            if (Objects.equals(active, "druid")) {
+                //todo 短信
+                sendMessage(flow,result);
+            }
         }
         return AjaxResult.success();
     }
@@ -426,25 +435,23 @@ public class InvestmentOpportunityServiceImpl extends FlowServiceFactory impleme
                             String assignee = task.getAssignee();
                             if (org.apache.commons.lang3.StringUtils.isNotBlank(assignee)) { // 给审批人发送短信
                                 SysUser auditUser = sysUserService.selectUserById(Long.valueOf(assignee));
-                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectPool.getProjectName() + "的项目机会流程待处理";
-                                System.out.println(auditContents);
+                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectPool.getProjectName() + "的项目机会流程待处理，请查看！";
                                 if (auditUser != null && StringUtils.isNotBlank(auditUser.getPhonenumber())) {
-                                    /*try{
+                                    try{
                                         SmsSenderUtils.sendSms(auditUser.getPhonenumber(), auditContents);
                                     } catch (IOException e) {
                                         logger.error("短信发送失败"+e.getMessage());
-                                    }*/
+                                    }
                                 }
                             }
                         } else { // 审批人驳回，给申请人发短信
-                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectPool.getProjectName() + "的项目机会申请已审核，结果为【驳回】";
-                            System.out.println(rejectContents);
+                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectPool.getProjectName() + "的项目机会申请已审核，结果为【驳回】，请查看！";
                             if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                                /*try{
-                                    SmsSenderUtils.sendSms(rejectUser.getPhonenumber(), rejectContents);
+                                try{
+                                    SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), rejectContents);
                                 } catch (IOException e) {
                                     logger.error("短信发送失败"+e.getMessage());
-                                }*/
+                                }
                             }
                         }
                     }
@@ -455,26 +462,24 @@ public class InvestmentOpportunityServiceImpl extends FlowServiceFactory impleme
             if(flag) {
                 // 审批完成，给申请人发短信
                 //XXX，您好。你在投资系统中提交“XXX”的项目立项申请已审核，结果为【通过】/【驳回】/【观望】！
-                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" +projectPool.getProjectName() + "的项目机会申请已审核，结果为【同意】";
-                System.out.println(completeContents);
+                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" +projectPool.getProjectName() + "的项目机会申请已审核，结果为【同意】，请查看！";
                 if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
+                    try{
+                        SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
                     } catch (IOException e) {
                         logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                    }
                 }
 
             }else{
                 if(StringUtils.isNotEmpty(result)){//代表是终止或者观望
-                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" +projectPool.getProjectName() + "的项目机会申请已审核，结果为"+result;
-                    System.out.println(completeContents);
+                    completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" +projectPool.getProjectName() + "的项目机会申请已审核，结果为"+result+"，请查看！";
                     if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
-                    } catch (IOException e) {
-                        logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                        try{
+                            SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
+                        } catch (IOException e) {
+                            logger.error("短信发送失败"+e.getMessage());
+                        }
                     }
                 }
             }

ruoyi-flowable/src/main/java/com/ruoyi/flowable/service/impl/TerminationServiceImpl.java

@@ -5,6 +5,7 @@ import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.sms.SmsSenderUtils;
 import com.ruoyi.common.utils.uuid.IdUtils;
 import com.ruoyi.flowable.common.constant.ProcessConstants;
 import com.ruoyi.flowable.common.constant.UUIDGenerator;
@@ -27,9 +28,11 @@ import org.flowable.task.api.Task;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
 import java.util.*;
 
 /**
@@ -42,6 +45,8 @@ import java.util.*;
 public class TerminationServiceImpl extends FlowServiceFactory implements ITerminationService
 {
     protected final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Value("${spring.profiles.active}")
+    private String active;
     @Autowired
     private TerminationMapper terminationMapper;
     @Autowired
@@ -184,8 +189,10 @@ public class TerminationServiceImpl extends FlowServiceFactory implements ITermi
                     if(flowBaseInfo.isFlag()){
                         getAssignee(tProjectTermination,flowBaseInfo);
                     }
-                    // todo 短信
-                    //sendMessage(flowBaseInfo);
+                    if (Objects.equals(active, "druid")) {
+                        // todo 短信
+                        sendMessage(flowBaseInfo);
+                    }
                     return AjaxResult.success();
                 }
                 return AjaxResult.error();
@@ -276,8 +283,10 @@ public class TerminationServiceImpl extends FlowServiceFactory implements ITermi
             if(flow.isFlag()){
                 getAssignee(tProjectTermination,flow);
             }
-            //todo 短信
-            //sendMessage(flow);
+            if (Objects.equals(active, "druid")) {
+                //todo 短信
+                sendMessage(flow);
+            }
         }
         return AjaxResult.success();
     }
@@ -343,25 +352,23 @@ public class TerminationServiceImpl extends FlowServiceFactory implements ITermi
                             String assignee = task.getAssignee();
                             if (org.apache.commons.lang3.StringUtils.isNotBlank(assignee)) { // 给审批人发送短信
                                 SysUser auditUser = sysUserService.selectUserById(Long.valueOf(assignee));
-                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectTermination.getProjectName() + "的项目终止流程待处理";
-                                System.out.println(auditContents);
+                                String auditContents = auditUser.getNickName() + ",您好。投资系统中" + projectTermination.getProjectName() + "的项目终止流程待处理，请查看！";
                                 if (auditUser != null && StringUtils.isNotBlank(auditUser.getPhonenumber())) {
-                                    /*try{
+                                    try{
                                         SmsSenderUtils.sendSms(auditUser.getPhonenumber(), auditContents);
                                     } catch (IOException e) {
                                         logger.error("短信发送失败"+e.getMessage());
-                                    }*/
+                                    }
                                 }
                             }
                         } else { // 审批人驳回，给申请人发短信
-                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectTermination.getProjectName() + "的项目终止申请已审核，结果为【驳回】";
-                            System.out.println(rejectContents);
+                            String rejectContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectTermination.getProjectName() + "的项目终止申请已审核，结果为【驳回】，请查看！";
                             if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                                /*try{
-                                    SmsSenderUtils.sendSms(rejectUser.getPhonenumber(), rejectContents);
+                                try{
+                                    SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), rejectContents);
                                 } catch (IOException e) {
                                     logger.error("短信发送失败"+e.getMessage());
-                                }*/
+                                }
                             }
                         }
                     }
@@ -372,14 +379,13 @@ public class TerminationServiceImpl extends FlowServiceFactory implements ITermi
             if(flag) {
                 // 审批完成，给申请人发短信
                 //XXX，您好。你在投资系统中提交“XXX”的项目终止申请已审核，结果为【通过】/【驳回】/【观望】！
-                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectTermination.getProjectName() + "的项目终止申请已审核，结果为【同意】";
-                System.out.println(completeContents);
+                completeContents = applyUserInfo.getNickName()+"，您好。你在投资系统中提交" + projectTermination.getProjectName() + "的项目终止申请已审核，结果为【同意】，请查看！";
                 if (applyUserInfo != null && StringUtils.isNotBlank(applyUserInfo.getPhonenumber())) {
-                    /*try{
-                        SmsSenderUtils.sendSms(completeUser.getPhonenumber(), completeContents);
+                    try{
+                        SmsSenderUtils.sendSms(applyUserInfo.getPhonenumber(), completeContents);
                     } catch (IOException e) {
                         logger.error("短信发送失败"+e.getMessage());
-                    }*/
+                    }
                 }
 
             }