From 315a74a16e0e8ac218b9ca790ab52641ad02f995 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期三, 29 十二月 2021 17:32:22 +0800
Subject: [PATCH] 12/29  河门口大屏特殊修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/config/MybatisHmkInterceptor.java |   44 +++++++++++++++++++++++++-------------------
 1 files changed, 25 insertions(+), 19 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/config/MybatisHmkInterceptor.java b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/config/MybatisHmkInterceptor.java
index afcc6e8..94d868f 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/config/MybatisHmkInterceptor.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/config/MybatisHmkInterceptor.java
@@ -1,5 +1,6 @@
 package com.panzhihua.service_grid.config;
 
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.PluginUtils;
 import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor;
 import org.apache.ibatis.executor.Executor;
@@ -53,30 +54,35 @@
                 }
                 else{
                     if(((Map<?, ?>) parameter).containsKey("arg0")){
-                        Map<?, ?> param= (Map<?, ?>) boundSql.getAdditionalParameter("_parameter");
+                        Map<?, ?> param= (Map<?, ?>) parameter;
                         String finalSql = sql;
-                        param.forEach((k, v)->{
-                            try {
-                                Field field= v.getClass().getDeclaredField("communityId");
-                                if(field!=null){
-                                    field.setAccessible(true);
-                                    if((long)field.get(v)==10086L){
-                                        String sql1= finalSql.replace("community_id = ?","community_id in (30,31)");
-                                        boundSql.getParameterMappings().forEach(parameterMapping -> {
-                                            if(!parameterMapping.getProperty().contains("communityId")){
-                                                parameterMappingList.add(parameterMapping);
+                        if(!param.isEmpty()){
+                            param.forEach((k, v)->{
+                                List<ParameterMapping> parameterMappingList1=new ArrayList<>();
+                                try {
+                                    Field field= v.getClass().getDeclaredField("communityId");
+                                    if(field!=null){
+                                        field.setAccessible(true);
+                                        if((long)field.get(v)==10086L){
+                                            String sql1= finalSql.replace("community_id = ?","community_id in (30,31)");
+                                            if(!CollectionUtils.isEmpty(boundSql.getParameterMappings())){
+                                                boundSql.getParameterMappings().forEach(parameterMapping -> {
+                                                    if(!parameterMapping.getProperty().contains("communityId")){
+                                                        parameterMappingList1.add(parameterMapping);
+                                                    }
+                                                });
+                                                PluginUtils.mpBoundSql(boundSql).parameterMappings(parameterMappingList1);
                                             }
-                                        });
-                                        PluginUtils.mpBoundSql(boundSql).parameterMappings(parameterMappingList);
-                                        PluginUtils.mpBoundSql(boundSql).sql(sql1);
+                                            PluginUtils.mpBoundSql(boundSql).sql(sql1);
+                                        }
                                     }
+                                } catch (IllegalAccessException e) {
+                                    e.printStackTrace();
+                                } catch (NoSuchFieldException e) {
                                 }
-                            } catch (IllegalAccessException e) {
-                                e.printStackTrace();
-                            } catch (NoSuchFieldException e) {
+                            });
+                        }
 
-                            }
-                        });
                     }
                 }
             }

--
Gitblit v1.7.1