From 4e78d940733a214e88b0a72dfd6335f29322bf68 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 11:05:53 +0800 Subject: [PATCH 1/9] =?UTF-8?q?[xss,sql=E5=A4=84=E7=90=86][=E4=BF=AE?= =?UTF-8?q?=E6=94=B9]:user-agent=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/interceptor/HttpServletRequestWrapperFilter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java b/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java index a042741..68bf202 100644 --- a/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java +++ b/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java @@ -46,7 +46,7 @@ public class HttpServletRequestWrapperFilter implements Filter { */ //sql,xss过滤 - XssHttpServletRequestWrapper xssHttpServletRequestWrapper = new XssHttpServletRequestWrapper((HttpServletRequest)request); + // XssHttpServletRequestWrapper xssHttpServletRequestWrapper = new XssHttpServletRequestWrapper((HttpServletRequest)request); if (request instanceof HttpServletRequest) { String url = ((HttpServletRequest) request).getRequestURI(); @@ -55,7 +55,7 @@ public class HttpServletRequestWrapperFilter implements Filter { } } if (null == requestWrapper) { - chain.doFilter(xssHttpServletRequestWrapper, response); + chain.doFilter(request, response); } else { chain.doFilter(requestWrapper, response); } From 7ab043122e2b33b6961b4efb074e212a14a73abc Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 11:13:47 +0800 Subject: [PATCH 2/9] =?UTF-8?q?[ticket][=E4=BF=AE=E6=94=B9]:=E7=9B=B4?= =?UTF-8?q?=E6=8E=A5=E8=BF=94=E5=9B=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/controller/WechatCalllbackController.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java index 8987ab4..40afe43 100644 --- a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java +++ b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java @@ -79,7 +79,8 @@ public class WechatCalllbackController extends BaseController { this.logger.info("接收微信回调,消息解密后内容为:{} ", inMessage.toString()); // 处理 - return handleTicket(inMessage); + handleTicket(inMessage); + return "success"; } /** From d5de6a06ad022bf46d23b63d8df5b447c16a1e2e Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 12:47:40 +0800 Subject: [PATCH 3/9] =?UTF-8?q?[redis][=E4=BF=AE=E6=94=B9]:database1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mlWechatOpen/src/main/resources/application-dev.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mlWechatOpen/src/main/resources/application-dev.yml b/mlWechatOpen/src/main/resources/application-dev.yml index 9d13e8e..c56aab3 100644 --- a/mlWechatOpen/src/main/resources/application-dev.yml +++ b/mlWechatOpen/src/main/resources/application-dev.yml @@ -32,7 +32,7 @@ spring: password: ENC(aYJ3Wr2UWtkORRQjjrWWpz2ZeTISsHOA) timeout: 3600 expire: 1800 #30分钟 - database: 10 + database: 1 defaultExpiration: 2592000 # 默认生命周期30天 jedis: pool: From e32c50b153bcdd5f3922f949a368cb7ae9ae1c87 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 13:11:15 +0800 Subject: [PATCH 4/9] =?UTF-8?q?[redis][=E4=BF=AE=E6=94=B9]:database?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wechat/FmOpenInRedisDBConfigStorage.java | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java index eb5228c..f8e9e2f 100644 --- a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java +++ b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java @@ -1,8 +1,6 @@ package com.iformall.service.wechat; import com.iformall.common.FmHttpClientBuilder; -import com.iformall.domain.po.WxAuthorizerInfo; -import com.iformall.domain.po.WxComponentVerifyTicket; import com.iformall.mapper.WxAuthorizerInfoMapper; import com.iformall.mapper.WxComponentVerifyTicketMapper; import me.chanjar.weixin.common.util.http.apache.ApacheHttpClientBuilder; @@ -15,8 +13,6 @@ import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.util.Pool; -import java.util.Date; - public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { private final static String COMPONENT_VERIFY_TICKET_KEY = "wechat_component_verify_ticket:"; private final static String COMPONENT_ACCESS_TOKEN_KEY = "wechat_component_access_token:"; @@ -112,13 +108,15 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public void updateComponentAccessTokent(String componentAccessToken, int expiresInSeconds) { try (Jedis jedis = this.jedisPool.getResource()) { jedis.setex(this.componentAccessTokenKey, expiresInSeconds - 200, componentAccessToken); - + /* WxComponentVerifyTicket ticket = new WxComponentVerifyTicket(); ticket.setComponentAppid(getComponentAppId()); ticket.setAccessToken(componentAccessToken); ticket.setAccessTokenExpire(new Date(Long.valueOf(System.currentTimeMillis() + (expiresInSeconds * 1000)))); int num = wxComponentVerifyTicketMapper.updateAccessToken(ticket); logger.info("updateComponentVerifyTicketAccessToken rows: " + num); + */ + logger.info("updateComponentVerifyTicketAccessToken " + componentAccessToken); } } @@ -137,12 +135,14 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public void setAuthorizerRefreshToken(String appId, String authorizerRefreshToken) { try (Jedis jedis = this.jedisPool.getResource()) { jedis.set(this.getKey(this.authorizerRefreshTokenKey, appId), authorizerRefreshToken); + /* WxAuthorizerInfo authorizerInfo = new WxAuthorizerInfo(); authorizerInfo.setAuthorizerAppid(appId); authorizerInfo.setRefreshToken(authorizerRefreshToken); int num = wxAuthorizerInfoMapper.updateRefreshToken(authorizerInfo); - logger.info("setAuthorizerRefreshToken " + appId + " rows: " + num); + */ + logger.info("setAuthorizerRefreshToken " + appId); } } @@ -170,13 +170,15 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { @Override public void updateAuthorizerAccessToken(String appId, WxOpenAuthorizerAccessToken authorizerAccessToken) { this.updateAuthorizerAccessToken(appId, authorizerAccessToken.getAuthorizerAccessToken(), authorizerAccessToken.getExpiresIn()); - + /* WxAuthorizerInfo authorizerInfo = new WxAuthorizerInfo(); authorizerInfo.setAuthorizerAppid(appId); authorizerInfo.setAccessToken(authorizerAccessToken.getAuthorizerAccessToken()); authorizerInfo.setAccessTokenExpire(new Date(Long.valueOf(System.currentTimeMillis() + (authorizerAccessToken.getExpiresIn() * 1000)))); int num = wxAuthorizerInfoMapper.updateAccessToken(authorizerInfo); logger.info("updateAuthorizerAccessToken " + appId + " rows: " + num); + */ + logger.info("updateAuthorizerAccessToken " + appId); } @Override From f5765b53c284386d48beb9543fa969baaccd4473 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 13:17:51 +0800 Subject: [PATCH 5/9] =?UTF-8?q?[redis][=E4=BF=AE=E6=94=B9]:database?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/service/wechat/FmOpenInRedisDBConfigStorage.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java index f8e9e2f..1356a33 100644 --- a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java +++ b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java @@ -72,6 +72,7 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { @Override public String getComponentVerifyTicket() { try (Jedis jedis = this.jedisPool.getResource()) { + logger.info("getComponentVerifyTicket " + this.componentVerifyTicketKey); return jedis.get(this.componentVerifyTicketKey); } } @@ -80,6 +81,7 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public void setComponentVerifyTicket(String componentVerifyTicket) { try (Jedis jedis = this.jedisPool.getResource()) { jedis.set(this.componentVerifyTicketKey, componentVerifyTicket); + logger.info("setComponentVerifyTicket " + componentVerifyTicket); } } From 242c1c9daebe2248fc77ba425e121987cc7532d0 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 13:53:40 +0800 Subject: [PATCH 6/9] =?UTF-8?q?[=E5=BE=AE=E4=BF=A1=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=9B=9E=E8=B0=83][=E4=BF=AE=E6=94=B9]:=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=9B=9E=E8=B0=83=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/controller/WechatCalllbackController.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java index 40afe43..7ecceab 100644 --- a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java +++ b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java @@ -88,7 +88,7 @@ public class WechatCalllbackController extends BaseController { * @param inMessage * @return */ - private String handleTicket(WxOpenXmlMessage inMessage) { + private void handleTicket(WxOpenXmlMessage inMessage) { if (inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.COMPONENT_VERIFY_TICKET.getMessage())) { // 保存component_verify_ticket componentVerifyTicketService.saveOrUpdate(new WxComponentVerifyTicket() { @@ -99,11 +99,10 @@ public class WechatCalllbackController extends BaseController { setDeadline(new Date(Long.valueOf(System.currentTimeMillis() + (60 * 60 * 1000)))); } }); - return "success"; } else if (inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.AUTHORIZED.getMessage()) || inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.UPDATEAUTHORIZED.getMessage())) { // 审核通过 - if (handleWeappAuditedMessage(inMessage)) return "success"; + handleWeappAuditedMessage(inMessage); } else if (inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.UNAUTHORIZED.getMessage())) { // 授权取消 authorizerInfoService.saveOrUpdate(new WxAuthorizerInfo() { @@ -113,7 +112,6 @@ public class WechatCalllbackController extends BaseController { setAuthTime(new Date()); } }); - return "success"; } try { @@ -122,7 +120,6 @@ public class WechatCalllbackController extends BaseController { } catch (WxErrorException e) { this.logger.error("notify", e); } - return "success"; } /** From 6cbda7c9bd2d64b90421ded85415c47f601f8701 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 14:18:10 +0800 Subject: [PATCH 7/9] =?UTF-8?q?[=E5=BE=AE=E4=BF=A1=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=9B=9E=E8=B0=83][=E4=BF=AE=E6=94=B9]:=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=9B=9E=E8=B0=83=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wechat/FmOpenInRedisDBConfigStorage.java | 75 ++++++++++++++----- .../controller/WechatCalllbackController.java | 19 +++-- 2 files changed, 65 insertions(+), 29 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java index 1356a33..5e7d636 100644 --- a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java +++ b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenInRedisDBConfigStorage.java @@ -1,6 +1,8 @@ package com.iformall.service.wechat; import com.iformall.common.FmHttpClientBuilder; +import com.iformall.domain.po.WxAuthorizerInfo; +import com.iformall.domain.po.WxComponentVerifyTicket; import com.iformall.mapper.WxAuthorizerInfoMapper; import com.iformall.mapper.WxComponentVerifyTicketMapper; import me.chanjar.weixin.common.util.http.apache.ApacheHttpClientBuilder; @@ -9,10 +11,13 @@ import me.chanjar.weixin.open.bean.WxOpenAuthorizerAccessToken; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.scheduling.annotation.Async; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.util.Pool; +import java.util.Date; + public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { private final static String COMPONENT_VERIFY_TICKET_KEY = "wechat_component_verify_ticket:"; private final static String COMPONENT_ACCESS_TOKEN_KEY = "wechat_component_access_token:"; @@ -73,7 +78,27 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public String getComponentVerifyTicket() { try (Jedis jedis = this.jedisPool.getResource()) { logger.info("getComponentVerifyTicket " + this.componentVerifyTicketKey); - return jedis.get(this.componentVerifyTicketKey); + String ticket = jedis.get(this.componentVerifyTicketKey); + if(StringUtils.isBlank(ticket)) { + String appId; + String [] keys = componentAccessTokenKey.split(":"); + if(StringUtils.isBlank(keyPrefix)) { + appId = keys[1]; + } else { + appId = keys[2]; + } + WxComponentVerifyTicket wxComponentVerifyTicket = new WxComponentVerifyTicket(); + wxComponentVerifyTicket.setComponentAppid(getComponentAppId()); + try { + wxComponentVerifyTicket = wxComponentVerifyTicketMapper.selectOne(wxComponentVerifyTicket); + if(wxComponentVerifyTicket != null) { + ticket = wxComponentVerifyTicket.getComponentVerifyTicket(); + } + }catch (Exception e) { + logger.error(e.getMessage()); + } + } + return ticket; } } @@ -110,18 +135,22 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public void updateComponentAccessTokent(String componentAccessToken, int expiresInSeconds) { try (Jedis jedis = this.jedisPool.getResource()) { jedis.setex(this.componentAccessTokenKey, expiresInSeconds - 200, componentAccessToken); - /* - WxComponentVerifyTicket ticket = new WxComponentVerifyTicket(); - ticket.setComponentAppid(getComponentAppId()); - ticket.setAccessToken(componentAccessToken); - ticket.setAccessTokenExpire(new Date(Long.valueOf(System.currentTimeMillis() + (expiresInSeconds * 1000)))); - int num = wxComponentVerifyTicketMapper.updateAccessToken(ticket); - logger.info("updateComponentVerifyTicketAccessToken rows: " + num); - */ logger.info("updateComponentVerifyTicketAccessToken " + componentAccessToken); + + saveComponentVerifyTicket(componentAccessToken, expiresInSeconds); } } + @Async + public void saveComponentVerifyTicket(String componentAccessToken, int expiresInSeconds) { + WxComponentVerifyTicket ticket = new WxComponentVerifyTicket(); + ticket.setComponentAppid(getComponentAppId()); + ticket.setAccessToken(componentAccessToken); + ticket.setAccessTokenExpire(new Date(Long.valueOf(System.currentTimeMillis() + (expiresInSeconds * 1000)))); + int num = wxComponentVerifyTicketMapper.updateAccessToken(ticket); + logger.info("updateComponentVerifyTicketAccessToken rows: " + num); + } + private String getKey(String prefix, String appId) { return prefix.endsWith(":") ? prefix.concat(appId) : prefix.concat(":").concat(appId); } @@ -137,17 +166,20 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { public void setAuthorizerRefreshToken(String appId, String authorizerRefreshToken) { try (Jedis jedis = this.jedisPool.getResource()) { jedis.set(this.getKey(this.authorizerRefreshTokenKey, appId), authorizerRefreshToken); - /* - - WxAuthorizerInfo authorizerInfo = new WxAuthorizerInfo(); - authorizerInfo.setAuthorizerAppid(appId); - authorizerInfo.setRefreshToken(authorizerRefreshToken); - int num = wxAuthorizerInfoMapper.updateRefreshToken(authorizerInfo); - */ logger.info("setAuthorizerRefreshToken " + appId); + + saveAuthorizerRefreshToken(appId, authorizerRefreshToken); } } + @Async + public void saveAuthorizerRefreshToken(String appId, String authorizerRefreshToken) { + WxAuthorizerInfo authorizerInfo = new WxAuthorizerInfo(); + authorizerInfo.setAuthorizerAppid(appId); + authorizerInfo.setRefreshToken(authorizerRefreshToken); + int num = wxAuthorizerInfoMapper.updateRefreshToken(authorizerInfo); + } + @Override public String getAuthorizerAccessToken(String appId) { try (Jedis jedis = this.jedisPool.getResource()) { @@ -172,15 +204,20 @@ public class FmOpenInRedisDBConfigStorage extends WxOpenInMemoryConfigStorage { @Override public void updateAuthorizerAccessToken(String appId, WxOpenAuthorizerAccessToken authorizerAccessToken) { this.updateAuthorizerAccessToken(appId, authorizerAccessToken.getAuthorizerAccessToken(), authorizerAccessToken.getExpiresIn()); - /* + + logger.info("updateAuthorizerAccessToken " + appId); + + dbUpdateAccessToken(appId, authorizerAccessToken); + } + + @Async + public void dbUpdateAccessToken(String appId, WxOpenAuthorizerAccessToken authorizerAccessToken) { WxAuthorizerInfo authorizerInfo = new WxAuthorizerInfo(); authorizerInfo.setAuthorizerAppid(appId); authorizerInfo.setAccessToken(authorizerAccessToken.getAuthorizerAccessToken()); authorizerInfo.setAccessTokenExpire(new Date(Long.valueOf(System.currentTimeMillis() + (authorizerAccessToken.getExpiresIn() * 1000)))); int num = wxAuthorizerInfoMapper.updateAccessToken(authorizerInfo); logger.info("updateAuthorizerAccessToken " + appId + " rows: " + num); - */ - logger.info("updateAuthorizerAccessToken " + appId); } @Override diff --git a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java index 7ecceab..fb1e0c2 100644 --- a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java +++ b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java @@ -89,7 +89,13 @@ public class WechatCalllbackController extends BaseController { * @return */ private void handleTicket(WxOpenXmlMessage inMessage) { - if (inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.COMPONENT_VERIFY_TICKET.getMessage())) { + try { + String out = openService.getWxOpenComponentService().route(inMessage); + this.logger.info("组装回复信息:{}", out); + } catch (WxErrorException e) { + this.logger.error("notify", e); + } + if (inMessage.getInfoType().equalsIgnoreCase(EnumWxAuthorizationInfoType.COMPONENT_VERIFY_TICKET.getMessage())) { // 保存component_verify_ticket componentVerifyTicketService.saveOrUpdate(new WxComponentVerifyTicket() { { @@ -99,8 +105,8 @@ public class WechatCalllbackController extends BaseController { setDeadline(new Date(Long.valueOf(System.currentTimeMillis() + (60 * 60 * 1000)))); } }); - } else if (inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.AUTHORIZED.getMessage()) || - inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.UPDATEAUTHORIZED.getMessage())) { + } else if (inMessage.getInfoType().equalsIgnoreCase(EnumWxAuthorizationInfoType.AUTHORIZED.getMessage()) || + inMessage.getInfoType().equalsIgnoreCase(EnumWxAuthorizationInfoType.UPDATEAUTHORIZED.getMessage())) { // 审核通过 handleWeappAuditedMessage(inMessage); } else if (inMessage.getInfoType().equals(EnumWxAuthorizationInfoType.UNAUTHORIZED.getMessage())) { @@ -113,13 +119,6 @@ public class WechatCalllbackController extends BaseController { } }); } - - try { - String out = openService.getWxOpenComponentService().route(inMessage); - this.logger.info("组装回复信息:{}", out); - } catch (WxErrorException e) { - this.logger.error("notify", e); - } } /** From 5990d5e3ff1923c3970615940485213902219237 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 14:19:40 +0800 Subject: [PATCH 8/9] =?UTF-8?q?[=E5=BE=AE=E4=BF=A1=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=9B=9E=E8=B0=83][=E4=BF=AE=E6=94=B9]:=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=9B=9E=E8=B0=83=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/service/wechat/FmOpenService.java | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenService.java b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenService.java index 182eab2..48e9a4d 100644 --- a/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenService.java +++ b/mallinkService/src/main/java/com/iformall/service/wechat/FmOpenService.java @@ -72,14 +72,7 @@ public class FmOpenService extends WxOpenServiceImpl { wxOpenMessageRouter = new WxOpenMessageRouter(this); wxOpenMessageRouter.rule().handler((wxMpXmlMessage, map, wxMpService, wxSessionManager) -> { String appId = wxMpService.getWxMpConfigStorage().getAppId(); - WxAuthorizerInfo authorizerInfo = authorizerInfoMapper.findByAppid(appId); - String appType; - if(authorizerInfo.getType() <= EnumAppType.C.getCode()) { - appType = "小程序"; - } else { - appType = "公众号"; - } - logger.info("\n接收到{}{}请求消息,内容:{}", appId, appType, wxMpXmlMessage); + logger.info("\n接收到 {} 请求消息,内容:{}", appId, wxMpXmlMessage); return null; }).next(); From a1d54fb5308929a2d14bb4e2a741f3bb08195b38 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 26 Apr 2019 14:25:57 +0800 Subject: [PATCH 9/9] =?UTF-8?q?[sql][=E4=BF=AE=E6=94=B9]:sql=E6=B3=A8?= =?UTF-8?q?=E5=85=A5=E9=A2=84=E9=98=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/interceptor/HttpServletRequestWrapperFilter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java b/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java index 68bf202..a042741 100644 --- a/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java +++ b/mlWechatOpen/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java @@ -46,7 +46,7 @@ public class HttpServletRequestWrapperFilter implements Filter { */ //sql,xss过滤 - // XssHttpServletRequestWrapper xssHttpServletRequestWrapper = new XssHttpServletRequestWrapper((HttpServletRequest)request); + XssHttpServletRequestWrapper xssHttpServletRequestWrapper = new XssHttpServletRequestWrapper((HttpServletRequest)request); if (request instanceof HttpServletRequest) { String url = ((HttpServletRequest) request).getRequestURI(); @@ -55,7 +55,7 @@ public class HttpServletRequestWrapperFilter implements Filter { } } if (null == requestWrapper) { - chain.doFilter(request, response); + chain.doFilter(xssHttpServletRequestWrapper, response); } else { chain.doFilter(requestWrapper, response); }