From 903d87efd3def40b0f2200df55f322a020d16235 Mon Sep 17 00:00:00 2001 From: Qing Date: Wed, 21 Feb 2024 19:49:13 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=BE=AE=E4=BF=A1=E5=85=AC=E4=BC=97?= =?UTF-8?q?=E5=8F=B7=E6=A8=A1=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/UserController.java | 25 +++- .../domain/service/AuthUserDomainService.java | 2 + .../impl/AuthUserDomainServiceImpl.java | 34 ++++- .../src/main/resources/application.yml | 2 +- .../qing-yu-club-application/pom.xml | 7 + .../src/main/resources/application.yml | 2 +- qing-yu-wechat/pom.xml | 123 ++++++++++++++++++ .../landaiqing/wechat/WeChatApplication.java | 19 +++ .../wechat/controller/CallBackController.java | 87 +++++++++++++ .../wechat/handler/ReceiveTextMsgHandler.java | 54 ++++++++ .../wechat/handler/SubscribeMsgHandler.java | 33 +++++ .../wechat/handler/WeChatMsgFactory.java | 31 +++++ .../wechat/handler/WeChatMsgHandler.java | 11 ++ .../wechat/handler/WeChatMsgTypeEnum.java | 26 ++++ .../landaiqing/wechat/redis/RedisConfig.java | 47 +++++++ .../landaiqing/wechat/redis/RedisUtil.java | 107 +++++++++++++++ .../landaiqing/wechat/utils/MessageUtil.java | 47 +++++++ .../com/landaiqing/wechat/utils/SHA1.java | 56 ++++++++ .../src/main/resources/application.yml | 25 ++++ 19 files changed, 731 insertions(+), 7 deletions(-) create mode 100644 qing-yu-wechat/pom.xml create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/WeChatApplication.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/controller/CallBackController.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/ReceiveTextMsgHandler.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/SubscribeMsgHandler.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgFactory.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgHandler.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgTypeEnum.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisConfig.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisUtil.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/MessageUtil.java create mode 100644 qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/SHA1.java create mode 100644 qing-yu-wechat/src/main/resources/application.yml diff --git a/qing-yu-club-auth/qing-yu-club-auth-application/qing-yu-club-auth-application-controller/src/main/java/com/landaiqing/auth/application/controller/UserController.java b/qing-yu-club-auth/qing-yu-club-auth-application/qing-yu-club-auth-application-controller/src/main/java/com/landaiqing/auth/application/controller/UserController.java index cebb2be..8ab36bd 100644 --- a/qing-yu-club-auth/qing-yu-club-auth-application/qing-yu-club-auth-application-controller/src/main/java/com/landaiqing/auth/application/controller/UserController.java +++ b/qing-yu-club-auth/qing-yu-club-auth-application/qing-yu-club-auth-application-controller/src/main/java/com/landaiqing/auth/application/controller/UserController.java @@ -1,5 +1,7 @@ package com.landaiqing.auth.application.controller; +import cn.dev33.satoken.stp.SaTokenInfo; +import cn.dev33.satoken.stp.StpUtil; import com.alibaba.fastjson.JSON; import com.google.common.base.Preconditions; import com.landaiqing.auth.application.convert.AuthUserDTOConverter; @@ -9,10 +11,7 @@ import com.landaiqing.auth.domain.entity.AuthUserBO; import com.landaiqing.auth.domain.service.AuthUserDomainService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; @@ -118,6 +117,24 @@ public class UserController { } } + @RequestMapping("doLogin") + public Result doLogin(@RequestParam("validCode") String validCode) { + try { + Preconditions.checkArgument(!StringUtils.isBlank(validCode), "验证码不能为空!"); + return Result.ok(authUserDomainService.doLogin(validCode)); + } catch (Exception e) { + log.error("UserController.doLogin.error:{}", e.getMessage(), e); + return Result.fail("用户登录失败"); + } + } + + // 查询登录状态，浏览器访问： http://localhost:8081/user/isLogin + @RequestMapping("isLogin") + public String isLogin() { + return "当前会话是否登录：" + StpUtil.isLogin(); + } + + private void checkUserInfo(@RequestBody AuthUserDTO authUserDTO) { Preconditions.checkArgument(!StringUtils.isBlank(authUserDTO.getUserName()),"用户名不能为空"); Preconditions.checkArgument(!StringUtils.isBlank(authUserDTO.getEmail()),"邮箱不能为空"); diff --git a/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthUserDomainService.java b/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthUserDomainService.java index d994d70..014ad0d 100644 --- a/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthUserDomainService.java +++ b/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/AuthUserDomainService.java @@ -22,5 +22,7 @@ public interface AuthUserDomainService { Object update(AuthUserBO authUserBO); Object delete(AuthUserBO authUserBO); + + Object doLogin(String validCode); } diff --git a/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthUserDomainServiceImpl.java b/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthUserDomainServiceImpl.java index afc909c..3fbe85f 100644 --- a/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthUserDomainServiceImpl.java +++ b/qing-yu-club-auth/qing-yu-club-auth-domain/src/main/java/com/landaiqing/auth/domain/service/impl/AuthUserDomainServiceImpl.java @@ -1,6 +1,8 @@ package com.landaiqing.auth.domain.service.impl; import cn.dev33.satoken.secure.SaSecureUtil; +import cn.dev33.satoken.stp.SaTokenInfo; +import cn.dev33.satoken.stp.StpUtil; import com.google.gson.Gson; import com.landaiqing.auth.common.enums.AuthUserStatusEnum; import com.landaiqing.auth.common.enums.IsDeletedFlagEnum; @@ -13,6 +15,7 @@ import com.landaiqing.auth.infra.basic.entity.*; import com.landaiqing.auth.infra.basic.service.*; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -47,12 +50,26 @@ public class AuthUserDomainServiceImpl implements AuthUserDomainService { private String salt="landaiqing"; + private static final String LOGIN_PREFIX = "loginCode"; + @Override @SneakyThrows @Transactional(rollbackFor = Exception.class) public Boolean register(AuthUserBO authUserBO) { + //校验用户是否存在 + AuthUser existAuthUser = new AuthUser(); + existAuthUser.setUserName(authUserBO.getUserName()); + List existUser = authUserService.queryByCondition(existAuthUser); + if (existUser.size() > 0) { + return true; + } AuthUser authUser = AuthUserBOConverter.INSTANCE.convertBOToEntity(authUserBO); - authUser.setPassword(SaSecureUtil.md5BySalt(authUser.getPassword(),salt)); + if (StringUtils.isNotBlank(authUser.getPassword())) { + authUser.setPassword(SaSecureUtil.md5BySalt(authUser.getPassword(), salt)); + } + if (StringUtils.isBlank(authUser.getAvatar())) { + authUser.setAvatar("http://117.72.10.84:9000/user/icon/微信图片_20231203153718(1).png"); + } authUser.setStatus(AuthUserStatusEnum.OPEN.getCode()); authUser.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode()); Integer count = authUserService.insert(authUser); @@ -103,4 +120,19 @@ public class AuthUserDomainServiceImpl implements AuthUserDomainService { Integer count = authUserService.update(authUser); return count > 0; } + + @Override + public SaTokenInfo doLogin(String validCode) { + String loginKey = redisUtil.buildKey(LOGIN_PREFIX, validCode); + String openId = redisUtil.get(loginKey); + if (StringUtils.isBlank(openId)) { + return null; + } + AuthUserBO authUserBO = new AuthUserBO(); + authUserBO.setUserName(openId); + this.register(authUserBO); + StpUtil.login(openId); + SaTokenInfo tokenInfo = StpUtil.getTokenInfo(); + return tokenInfo; + } } diff --git a/qing-yu-club-auth/qing-yu-club-auth-starter/src/main/resources/application.yml b/qing-yu-club-auth/qing-yu-club-auth-starter/src/main/resources/application.yml index d34e883..57d4583 100644 --- a/qing-yu-club-auth/qing-yu-club-auth-starter/src/main/resources/application.yml +++ b/qing-yu-club-auth/qing-yu-club-auth-starter/src/main/resources/application.yml @@ -5,7 +5,7 @@ spring: username: landaiqing password: iPHzskWvLGI2TrPw2AV7pu4C8O4bfxSSeQrkIqq0ZwM5tpBmx4aI6xN/8xjYgSmIir5v2Cv35Fn2732AypFKww== driver-class-name: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://116.196.80.239:3306/qing-yu-club?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=true + url: jdbc:mysql://116.196.80.239:3306/jc-club?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=true type: com.alibaba.druid.pool.DruidDataSource druid: initial-size: 20 diff --git a/qing-yu-club-subject/qing-yu-club-application/pom.xml b/qing-yu-club-subject/qing-yu-club-application/pom.xml index f3668ed..75290c2 100644 --- a/qing-yu-club-subject/qing-yu-club-application/pom.xml +++ b/qing-yu-club-subject/qing-yu-club-application/pom.xml @@ -14,7 +14,14 @@ http://maven.apache.org + 8 + 8 + 1.8 UTF-8 + UTF-8 + 2.4.2 + 2021.1 + 2020.0.6 diff --git a/qing-yu-club-subject/qing-yu-club-starter/src/main/resources/application.yml b/qing-yu-club-subject/qing-yu-club-starter/src/main/resources/application.yml index 8d3653b..10d8877 100644 --- a/qing-yu-club-subject/qing-yu-club-starter/src/main/resources/application.yml +++ b/qing-yu-club-subject/qing-yu-club-starter/src/main/resources/application.yml @@ -5,7 +5,7 @@ spring: username: landaiqing password: iPHzskWvLGI2TrPw2AV7pu4C8O4bfxSSeQrkIqq0ZwM5tpBmx4aI6xN/8xjYgSmIir5v2Cv35Fn2732AypFKww== driver-class-name: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://116.196.80.239:3306/qing-yu-club?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=true + url: jdbc:mysql://116.196.80.239:3306/jc-club?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=true type: com.alibaba.druid.pool.DruidDataSource druid: initial-size: 20 diff --git a/qing-yu-wechat/pom.xml b/qing-yu-wechat/pom.xml new file mode 100644 index 0000000..9fa79aa --- /dev/null +++ b/qing-yu-wechat/pom.xml @@ -0,0 +1,123 @@ + + 4.0.0 + + com.landaiqing + qing-yu-wechat + 1.0-SNAPSHOT + jar + + qing-yu-wechat + http://maven.apache.org + + + 8 + 8 + 1.8 + UTF-8 + UTF-8 + 2.4.2 + + + + + org.springframework.boot + spring-boot-starter-web + + + spring-boot-starter-logging + org.springframework.boot + + + + + org.projectlombok + lombok + 1.18.16 + + + org.springframework.boot + spring-boot-starter-log4j2 + + + com.thoughtworks.xstream + xstream + 1.4.18 + + + com.google.code.gson + gson + 2.8.5 + + + org.dom4j + dom4j + 2.1.1 + + + com.fasterxml.jackson.core + jackson-core + 2.12.7 + + + com.fasterxml.jackson.core + jackson-databind + 2.12.7 + + + org.springframework.boot + spring-boot-starter-data-redis + + + org.apache.commons + commons-pool2 + 2.9.0 + + + + + + + + org.springframework.boot + spring-boot-dependencies + ${spring-boot.version} + pom + import + + + + + + + central + aliyun maven + https://maven.aliyun.com/nexus/content/groups/public/ + default + + true + + + true + + + + + ${project.artifactId} + + + + org.springframework.boot + spring-boot-maven-plugin + 2.3.0.RELEASE + + + + repackage + + + + + + + diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/WeChatApplication.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/WeChatApplication.java new file mode 100644 index 0000000..323a68c --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/WeChatApplication.java @@ -0,0 +1,19 @@ +package com.landaiqing.wechat; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.annotation.ComponentScan; + +/** + * 微信微服务启动类 + * + * @author: landaiqing + * @date: 2024/2/7 + */ +@SpringBootApplication +@ComponentScan("com.landaiqing") +public class WeChatApplication { + public static void main(String[] args) { + SpringApplication.run(WeChatApplication.class); + } +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/controller/CallBackController.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/controller/CallBackController.java new file mode 100644 index 0000000..37b6268 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/controller/CallBackController.java @@ -0,0 +1,87 @@ +package com.landaiqing.wechat.controller; + +import com.landaiqing.wechat.handler.WeChatMsgFactory; +import com.landaiqing.wechat.handler.WeChatMsgHandler; +import com.landaiqing.wechat.utils.MessageUtil; +import com.landaiqing.wechat.utils.SHA1; +import lombok.extern.slf4j.Slf4j; +import org.springframework.util.StringUtils; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import java.util.Map; +import java.util.Objects; + +/** + * @Classname CallBackController + * @BelongsProject: qing-yu-club + * @BelongsPackage: com.landaiqing.wechat.controller + * @Author: landaiqing + * @CreateTime: 2024-02-21 16:41 + * @Description: TODO + * @Version: 1.0 + */ +@RestController +@Slf4j +public class CallBackController { + + @Resource + private WeChatMsgFactory weChatMsgFactory; + private static final String token = "LDQ20020618xxx"; + + @RequestMapping("/test") + public String test() { + return "HELLO WORLD"; + } + + /** + * @description: 回调消息校验 + * @param: [signature, timestamp, nonce, echostr] + * @return: java.lang.String + * @author landaiqing + * @date: 2024/2/21 17:16 + */ + @GetMapping("/callback") + public String callback(@RequestParam("signature") String signature, + @RequestParam("timestamp") String timestamp, + @RequestParam("nonce") String nonce, + @RequestParam("echostr") String echostr) { + log.info("get验签请求参数:signature: {}，timestamp: {}， nonce: {}，echostr: {}", + signature, timestamp, nonce, echostr); + + String shaStr = SHA1.getSHA1(token, timestamp, nonce, ""); + if (signature.equals(shaStr)) { + return echostr; + } + return "unKnown"; + } + + @PostMapping(value = "callback", produces = "application/xml;charset=UTF-8") + public String callback( + @RequestBody String requestBody, + @RequestParam("signature") String signature, + @RequestParam("timestamp") String timestamp, + @RequestParam("nonce") String nonce, + @RequestParam(value = "msg_signature", required = false) String msgSignature) { + log.info("接收到微信消息：requestBody：{}", requestBody); + Map messageMap = MessageUtil.parseXml(requestBody); + String msgType = messageMap.get("MsgType"); + String event = messageMap.get("Event") == null ? "" : messageMap.get("Event"); + log.info("msgType:{},event:{}", msgType, event); + + StringBuilder sb = new StringBuilder(); + sb.append(msgType); + if (!StringUtils.isEmpty(event)) { + sb.append("."); + sb.append(event); + } + String msgTypeKey = sb.toString(); + WeChatMsgHandler weChatMsgHandler = weChatMsgFactory.getHandlerByMsgType(msgTypeKey); + if (Objects.isNull(weChatMsgHandler)) { + return "unknown"; + } + String replyContent = weChatMsgHandler.dealMsg(messageMap); + log.info("replyContent:{}", replyContent); + return replyContent; + } +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/ReceiveTextMsgHandler.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/ReceiveTextMsgHandler.java new file mode 100644 index 0000000..36ecff5 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/ReceiveTextMsgHandler.java @@ -0,0 +1,54 @@ +package com.landaiqing.wechat.handler; + +import com.landaiqing.wechat.redis.RedisUtil; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.Map; +import java.util.Random; +import java.util.concurrent.TimeUnit; + +@Component +@Slf4j +public class ReceiveTextMsgHandler implements WeChatMsgHandler { + + private static final String KEY_WORD = "验证码"; + + private static final String LOGIN_PREFIX = "loginCode"; + + @Resource + private RedisUtil redisUtil; + + @Override + public WeChatMsgTypeEnum getMsgType() { + return WeChatMsgTypeEnum.TEXT_MSG; + } + + @Override + public String dealMsg(Map messageMap) { + log.info("接收到文本消息事件"); + String content = messageMap.get("Content"); + if (!KEY_WORD.equals(content)) { + return ""; + } + String fromUserName = messageMap.get("FromUserName"); + String toUserName = messageMap.get("ToUserName"); + + Random random = new Random(); + int num = random.nextInt(1000); + String numKey = redisUtil.buildKey(LOGIN_PREFIX, String.valueOf(num)); + redisUtil.setNx(numKey, fromUserName, 5L, TimeUnit.MINUTES); + String numContent = "您当前的验证码是：【" + num + "】 ， 5分钟内有效"; + String replyContent = "\n" + + " \n" + + " \n" + + " 12345678\n" + + " \n" + + " \n" + + ""; + + return replyContent; + } + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/SubscribeMsgHandler.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/SubscribeMsgHandler.java new file mode 100644 index 0000000..f2ea342 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/SubscribeMsgHandler.java @@ -0,0 +1,33 @@ +package com.landaiqing.wechat.handler; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.Map; + +@Component +@Slf4j +public class SubscribeMsgHandler implements WeChatMsgHandler { + + @Override + public WeChatMsgTypeEnum getMsgType() { + return WeChatMsgTypeEnum.SUBSCRIBE; + } + + @Override + public String dealMsg(Map messageMap) { + log.info("触发用户关注事件！"); + String fromUserName = messageMap.get("FromUserName"); + String toUserName = messageMap.get("ToUserName"); + String subscribeContent = "感谢您的关注，我是清语博客！"; + String content = "\n" + + " \n" + + " \n" + + " 12345678\n" + + " \n" + + " \n" + + ""; + return content; + } + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgFactory.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgFactory.java new file mode 100644 index 0000000..68329e6 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgFactory.java @@ -0,0 +1,31 @@ +package com.landaiqing.wechat.handler; + +import org.springframework.beans.factory.InitializingBean; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@Component +public class WeChatMsgFactory implements InitializingBean { + + @Resource + private List weChatMsgHandlerList; + + private Map handlerMap = new HashMap<>(); + + public WeChatMsgHandler getHandlerByMsgType(String msgType) { + WeChatMsgTypeEnum msgTypeEnum = WeChatMsgTypeEnum.getByMsgType(msgType); + return handlerMap.get(msgTypeEnum); + } + + @Override + public void afterPropertiesSet() throws Exception { + for (WeChatMsgHandler weChatMsgHandler : weChatMsgHandlerList) { + handlerMap.put(weChatMsgHandler.getMsgType(), weChatMsgHandler); + } + } + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgHandler.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgHandler.java new file mode 100644 index 0000000..9c1862f --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgHandler.java @@ -0,0 +1,11 @@ +package com.landaiqing.wechat.handler; + +import java.util.Map; + +public interface WeChatMsgHandler { + + WeChatMsgTypeEnum getMsgType(); + + String dealMsg(Map messageMap); + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgTypeEnum.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgTypeEnum.java new file mode 100644 index 0000000..bea7a36 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/handler/WeChatMsgTypeEnum.java @@ -0,0 +1,26 @@ +package com.landaiqing.wechat.handler; + +public enum WeChatMsgTypeEnum { + + SUBSCRIBE("event.subscribe", "用户关注事件"), + TEXT_MSG("text", "接收用户文本消息"); + + private String msgType; + + private String desc; + + WeChatMsgTypeEnum(String msgType, String desc) { + this.msgType = msgType; + this.desc = desc; + } + + public static WeChatMsgTypeEnum getByMsgType(String msgType) { + for (WeChatMsgTypeEnum weChatMsgTypeEnum : WeChatMsgTypeEnum.values()) { + if (weChatMsgTypeEnum.msgType.equals(msgType)) { + return weChatMsgTypeEnum; + } + } + return null; + } + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisConfig.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisConfig.java new file mode 100644 index 0000000..04c0649 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisConfig.java @@ -0,0 +1,47 @@ +package com.landaiqing.wechat.redis; + +import com.fasterxml.jackson.annotation.JsonAutoDetect; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.PropertyAccessor; +import com.fasterxml.jackson.databind.DeserializationFeature; +import com.fasterxml.jackson.databind.ObjectMapper; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.data.redis.connection.RedisConnectionFactory; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; +import org.springframework.data.redis.serializer.RedisSerializer; +import org.springframework.data.redis.serializer.StringRedisSerializer; + +/** + * Redis的config处理 + * + * @author: ChickenWing + * @date: 2023/10/28 + */ +@Configuration +public class RedisConfig { + + @Bean + public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { + RedisTemplate redisTemplate = new RedisTemplate<>(); + RedisSerializer redisSerializer = new StringRedisSerializer(); + redisTemplate.setConnectionFactory(redisConnectionFactory); + redisTemplate.setKeySerializer(redisSerializer); + redisTemplate.setHashKeySerializer(redisSerializer); + redisTemplate.setValueSerializer(jackson2JsonRedisSerializer()); + redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer()); + return redisTemplate; + } + + private Jackson2JsonRedisSerializer jackson2JsonRedisSerializer() { + Jackson2JsonRedisSerializer jsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class); + ObjectMapper objectMapper = new ObjectMapper(); + objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); + objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); + objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY); + jsonRedisSerializer.setObjectMapper(objectMapper); + return jsonRedisSerializer; + } + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisUtil.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisUtil.java new file mode 100644 index 0000000..9b91b37 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/redis/RedisUtil.java @@ -0,0 +1,107 @@ +package com.landaiqing.wechat.redis; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.Set; +import java.util.concurrent.TimeUnit; +import java.util.stream.Collectors; +import java.util.stream.Stream; + +/** + * RedisUtil工具类 + * + * @author: ChickenWing + * @date: 2023/10/28 + */ +@Component +@Slf4j +public class RedisUtil { + + @Resource + private RedisTemplate redisTemplate; + + private static final String CACHE_KEY_SEPARATOR = "."; + + /** + * 构建缓存key + */ + public String buildKey(String... strObjs) { + return Stream.of(strObjs).collect(Collectors.joining(CACHE_KEY_SEPARATOR)); + } + + /** + * 是否存在key + */ + public boolean exist(String key) { + return redisTemplate.hasKey(key); + } + + /** + * 删除key + */ + public boolean del(String key) { + return redisTemplate.delete(key); + } + + /** + * set(不带过期) + */ + public void set(String key, String value) { + redisTemplate.opsForValue().set(key, value); + } + + /** + * set(带过期) + */ + public boolean setNx(String key, String value, Long time, TimeUnit timeUnit) { + return redisTemplate.opsForValue().setIfAbsent(key, value, time, timeUnit); + } + + /** + * 获取string类型缓存 + */ + public String get(String key) { + return (String) redisTemplate.opsForValue().get(key); + } + + public Boolean zAdd(String key, String value, Long score) { + return redisTemplate.opsForZSet().add(key, value, Double.valueOf(String.valueOf(score))); + } + + public Long countZset(String key) { + return redisTemplate.opsForZSet().size(key); + } + + public Set rangeZset(String key, long start, long end) { + return redisTemplate.opsForZSet().range(key, start, end); + } + + public Long removeZset(String key, Object value) { + return redisTemplate.opsForZSet().remove(key, value); + } + + public void removeZsetList(String key, Set value) { + value.stream().forEach((val) -> redisTemplate.opsForZSet().remove(key, val)); + } + + public Double score(String key, Object value) { + return redisTemplate.opsForZSet().score(key, value); + } + + public Set rangeByScore(String key, long start, long end) { + return redisTemplate.opsForZSet().rangeByScore(key, Double.valueOf(String.valueOf(start)), Double.valueOf(String.valueOf(end))); + } + + public Object addScore(String key, Object obj, double score) { + return redisTemplate.opsForZSet().incrementScore(key, obj, score); + } + + public Object rank(String key, Object obj) { + return redisTemplate.opsForZSet().rank(key, obj); + } + + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/MessageUtil.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/MessageUtil.java new file mode 100644 index 0000000..36b9c09 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/MessageUtil.java @@ -0,0 +1,47 @@ +package com.landaiqing.wechat.utils; + +import org.dom4j.Document; +import org.dom4j.Element; +import org.dom4j.io.SAXReader; + +import java.io.ByteArrayInputStream; +import java.io.InputStream; +import java.nio.charset.StandardCharsets; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +public class MessageUtil { + + /** + * 解析微信发来的请求（XML）. + * + * @param msg 消息 + * @return map + */ + public static Map parseXml(final String msg) { + // 将解析结果存储在HashMap中 + Map map = new HashMap(); + + // 从request中取得输入流 + try (InputStream inputStream = new ByteArrayInputStream(msg.getBytes(StandardCharsets.UTF_8.name()))) { + // 读取输入流 + SAXReader reader = new SAXReader(); + Document document = reader.read(inputStream); + // 得到xml根元素 + Element root = document.getRootElement(); + // 得到根元素的所有子节点 + List elementList = root.elements(); + + // 遍历所有子节点 + for (Element e : elementList) { + map.put(e.getName(), e.getText()); + } + } catch (Exception e) { + e.printStackTrace(); + } + + return map; + } + +} diff --git a/qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/SHA1.java b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/SHA1.java new file mode 100644 index 0000000..39e98b1 --- /dev/null +++ b/qing-yu-wechat/src/main/java/com/landaiqing/wechat/utils/SHA1.java @@ -0,0 +1,56 @@ +package com.landaiqing.wechat.utils; + +import lombok.extern.slf4j.Slf4j; + +import java.security.MessageDigest; +import java.util.Arrays; + +/** + * sha1生成签名工具 + * + * @author: landaiqing + * @date: 2023/11/5 + */ +@Slf4j +public class SHA1 { + + /** + * 用SHA1算法生成安全签名 + * + * @param token 票据 + * @param timestamp 时间戳 + * @param nonce 随机字符串 + * @param encrypt 密文 + * @return 安全签名 + */ + public static String getSHA1(String token, String timestamp, String nonce, String encrypt) { + try { + String[] array = new String[]{token, timestamp, nonce, encrypt}; + StringBuffer sb = new StringBuffer(); + // 字符串排序 + Arrays.sort(array); + for (int i = 0; i < 4; i++) { + sb.append(array[i]); + } + String str = sb.toString(); + // SHA1签名生成 + MessageDigest md = MessageDigest.getInstance("SHA-1"); + md.update(str.getBytes()); + byte[] digest = md.digest(); + + StringBuffer hexStr = new StringBuffer(); + String shaHex = ""; + for (int i = 0; i < digest.length; i++) { + shaHex = Integer.toHexString(digest[i] & 0xFF); + if (shaHex.length() < 2) { + hexStr.append(0); + } + hexStr.append(shaHex); + } + return hexStr.toString(); + } catch (Exception e) { + log.error("sha加密生成签名失败:", e); + return null; + } + } +} diff --git a/qing-yu-wechat/src/main/resources/application.yml b/qing-yu-wechat/src/main/resources/application.yml new file mode 100644 index 0000000..d770e15 --- /dev/null +++ b/qing-yu-wechat/src/main/resources/application.yml @@ -0,0 +1,25 @@ +server: + port: 3012 +spring: + # redis配置 + redis: + # Redis数据库索引（默认为0） + database: 1 + # Redis服务器地址 + host: 116.196.80.239 + # Redis服务器连接端口 + port: 6379 + # Redis服务器连接密码（默认为空） + password: LDQ20020618xxx + # 连接超时时间 + timeout: 2s + lettuce: + pool: + # 连接池最大连接数 + max-active: 200 + # 连接池最大阻塞等待时间（使用负值表示没有限制） + max-wait: -1ms + # 连接池中的最大空闲连接 + max-idle: 10 + # 连接池中的最小空闲连接 + min-idle: 0