readme.md更新

readme.md

@@ -15,13 +15,29 @@
 2、ALTER TABLE uims_user ADD login_secret_key varchar(50) comment '登录第三方密钥'
 3、ALTER TABLE uims_user ADD login_code varchar(50) comment '登录第三方厂家编码'
 4、ALTER TABLE uims_user ADD login_org_code varchar(50) comment '登录第三方机构编码'
-### sms_device_parm 添加字段
-1、ALTER TABLE sms_device_parm ADD CLASSIFY varchar(50) comment '归类'
-2、ALTER TABLE sms_device_parm ADD SHOW_ON_OFF smallint comment '展示开关'
-3、ALTER TABLE sms_device_parm ADD SHOW_MIN_VALUE smallint comment '是否展示最小值'
-4、ALTER TABLE sms_device_parm ADD SHOW_AVG_VALUE smallint comment '是否展示平均值'
-5、ALTER TABLE sms_device_parm ADD SHOW_MAX_VALUE smallint comment '是否展示最大值'
-6、ALTER TABLE sms_device_parm ADD SHOW_SUM_VALUE smallint comment '是否展示合计值'
-7、ALTER TABLE sms_device_parm ADD SHOW_LATEST_VALUE smallint comment '是否展示最新值'
 ### sms_month_report表添加索引
-1.ALTER TABLE sms_month_report ADD  INDEX `index_collect_date`(`COLLECT_DATE`) USING BTREE 
+1.ALTER TABLE sms_month_report ADD  INDEX `index_collect_date`(`COLLECT_DATE`) USING BTREE 
+
+# 创建报表维度配置表 sms_report_dimension_setting
+SET NAMES utf8mb4;
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- ----------------------------
+-- Table structure for sms_report_dimension_setting
+-- ----------------------------
+DROP TABLE IF EXISTS `sms_report_dimension_setting`;
+CREATE TABLE `sms_report_dimension_setting`  (
+`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+`user_id` int(11) NULL DEFAULT NULL COMMENT '用户ID',
+`tenant_id` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '租户ID',
+`device_parm_id` int(11) NULL DEFAULT NULL COMMENT '设备参数ID',
+`classify` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '归类',
+`show_on_off` smallint(6) NULL DEFAULT NULL COMMENT '展示开关',
+`show_min_value` smallint(6) NULL DEFAULT NULL COMMENT '是否展示最小值',
+`show_avg_value` smallint(6) NULL DEFAULT NULL COMMENT '是否展示平均值',
+`show_max_value` smallint(6) NULL DEFAULT NULL COMMENT '是否展示最大值',
+`show_sum_value` smallint(6) NULL DEFAULT NULL COMMENT '是否展示合计值',
+`show_latest_value` smallint(6) NULL DEFAULT NULL COMMENT '是否展示最新值',
+PRIMARY KEY (`id`) USING BTREE
+) ENGINE = InnoDB AUTO_INCREMENT = 72 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
+SET FOREIGN_KEY_CHECKS = 1;

sms_water/src/main/java/com/huaxu/config/AsyncConfig.java

@@ -10,6 +10,7 @@ import org.springframework.scheduling.annotation.AsyncConfigurer;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
 
 @Configuration
 @Slf4j
@@ -59,13 +60,16 @@ public class AsyncConfig implements AsyncConfigurer {
         /** 拒绝异常处理 - 在调用线程中执行（当线程池中线程都以被占用且queue已满，则拒绝新提交的task，
          * 默认为ThreadPoolExecutor.AbortPolicy抛出异常到上层应用 - 导致异步调用死掉，无法再处理新任务，
          * 此处实现照搬ThreadPoolExecutor.CallerRunsPolicy且添加日志记录
-         * */
+         *
         executor.setRejectedExecutionHandler((r, e) -> {
             log.error("Async thread pool over load - caller run - queue.size={} - 请devops人员考虑扩展服务实例", e.getQueue().size());
             if (!e.isShutdown()) {
                 r.run();
             }
-        });
+        });*/
+        // 设置拒绝策略：当pool已经达到max size的时候，如何处理新任务
+        // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
         //如果不初始化，导致找到不到执行器（此语句需放到最后）
         executor.initialize();
         return executor;