Merge branch 'dev' of http://git.qmth.com.cn/wangliang/distributed-print-service into dev

# Conflicts:
#	distributed-print-business/src/main/java/com/qmth/distributed/print/business/service/impl/BasicMessageServiceImpl.java

distributed-print-business/src/main/java/com/qmth/distributed/print/business/domain/SysDomain.java

@@ -38,6 +38,16 @@ public class SysDomain implements Serializable {
 
     Integer threadPoolCoreSize;
 
+    boolean customThreadPoolCoreSize;
+
+    public boolean isCustomThreadPoolCoreSize() {
+        return customThreadPoolCoreSize;
+    }
+
+    public void setCustomThreadPoolCoreSize(boolean customThreadPoolCoreSize) {
+        this.customThreadPoolCoreSize = customThreadPoolCoreSize;
+    }
+
     public Integer getAutoCreatePdfResetMaxCount() {
         return autoCreatePdfResetMaxCount;
     }

distributed-print-business/src/main/java/com/qmth/distributed/print/business/service/impl/BasicMessageServiceImpl.java

@@ -197,9 +197,11 @@ public class BasicMessageServiceImpl extends ServiceImpl<BasicMessageMapper, Bas
         }
     }
 
-    private void checkData(Object... objects) {
+    private void checkData(Object ... objects) {
         for (Object object : objects) {
-            if (object instanceof String) {
+            if (Objects.isNull(object)) {
+                throw ExceptionResultEnum.ERROR.exception("调用发送短信方法时必传参数缺失");
+            } else if (object instanceof String) {
                 String param = String.valueOf(object);
                 if (param.length() == 0 || param.equals("null")) {
                     throw ExceptionResultEnum.ERROR.exception("调用发送短信方法时必传参数缺失");

distributed-print-business/src/main/java/com/qmth/distributed/print/business/threadPool/MyThreadPool.java

@@ -30,6 +30,9 @@ public class MyThreadPool extends ThreadPoolTaskExecutor {
     @Value("${sys.config.threadPoolCoreSize}")
     Integer threadPoolCoreSize;
 
+    @Value("${sys.config.customThreadPoolCoreSize}")
+    boolean customThreadPoolCoreSize;
+
     @PostConstruct
     public void init() {
         taskThreadPool();
@@ -45,7 +48,7 @@ public class MyThreadPool extends ThreadPoolTaskExecutor {
         if (Objects.isNull(threadPoolTaskExecutor)) {
             log.info("cpuNum:{}", cpuNum);
             threadPoolTaskExecutor = new MyThreadPool();
-            if (cpuNum > 0) {
+            if (!customThreadPoolCoreSize && cpuNum > 0) {
                 threadPoolTaskExecutor.setCorePoolSize(cpuNum);//核心线程数
                 threadPoolTaskExecutor.setMaxPoolSize(cpuNum * 2);//最大线程数
             } else {