小程序登录接口

.idea/compiler.xml

@@ -12,6 +12,7 @@
         <module name="service-gateway" />
         <module name="rabbit_util" />
         <module name="service-product" />
+        <module name="service-user" />
         <module name="service-sys" />
         <module name="service-search" />
         <module name="model" />
@@ -35,6 +36,7 @@
       <module name="service-product-client" options="-parameters" />
       <module name="service-search" options="-parameters" />
       <module name="service-sys" options="-parameters" />
+      <module name="service-user" options="-parameters" />
       <module name="service-util" options="-parameters" />
     </option>
   </component>

.idea/encodings.xml

@@ -16,6 +16,7 @@
     <file url="file://$PROJECT_DIR$/guigu-ssyx-parent/service/service-product/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/guigu-ssyx-parent/service/service-search/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/guigu-ssyx-parent/service/service-sys/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/guigu-ssyx-parent/service/service-user/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/guigu-ssyx-parent/service/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/guigu-ssyx-parent/service/src/main/resources" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/guigu-ssyx-parent/src/main/java" charset="UTF-8" />

.idea/inspectionProfiles/Project_Default.xml

@@ -2,5 +2,8 @@
   <profile version="1.0">
     <option name="myName" value="Project Default" />
     <inspection_tool class="Eslint" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="JavadocDeclaration" enabled="true" level="WARNING" enabled_by_default="true">
+      <option name="ADDITIONAL_TAGS" value="Create" />
+    </inspection_tool>
   </profile>
 </component>

.idea/vcs.xml

@@ -2,6 +2,5 @@
 <project version="4">
   <component name="VcsDirectoryMappings">
     <mapping directory="$PROJECT_DIR$" vcs="Git" />
-    <mapping directory="$PROJECT_DIR$/atguigu-tuan" vcs="Git" />
   </component>
 </project>

atguigu-tuan/common/http.interceptor.js

@@ -1,7 +1,7 @@
 const install = (Vue, vm) => {
 	Vue.prototype.$u.http.setConfig({
 		//baseUrl: 'https://gmall-prod.atguigu.cn/api',
-		baseUrl: 'http://ggkt2.vipgz1.91tunnel.com/api',
+        baseUrl: 'http://localhost:8200/api',
 		loadingText: '请求中...', // 请求loading中的文字提示
 		loadingTime: 800, // 在此时间内，请求还没回来的话，就显示加载中动画，单位ms
 		loadingMask: true, // 展示loading的时候，是否给一个透明的蒙层，防止触摸穿透

atguigu-tuan/pages/login/login.vue

@@ -59,11 +59,11 @@ export default {
                 data: result.token,
                 success: async () => {
                   // 更新用户信息
-                  await this.$u.api.postUpdateUser({
+                  // await this.$u.api.postUpdateUser({
-                    sex,
+                  //   sex,
-                    photoUrl,
+                  //   photoUrl,
-                    nickName
+                  //   nickName
-                  });
+                  // });
                   // 路由跳转至首页
                   uni.reLaunch({
                     url: '/pages/index/index',

guigu-ssyx-parent/common/common-util/src/main/java/com/atguigu/ssyx/common/utils/JwtHelper.java

@@ -0,0 +1,64 @@
+package com.atguigu.ssyx.common.utils;
+
+import io.jsonwebtoken.*;
+import org.springframework.util.StringUtils;
+
+import java.util.Date;
+
+/**
+ * ClassName: JwtHelper
+ * Package: com.atguigu.ssyx.common.utils
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 15:50
+ */
+public class JwtHelper {
+
+    private static final long tokenExpiration = 365L * 24 * 60 * 60 * 1000;
+    private static final String tokenSignKey = "ssyx";
+
+    public static String createToken(Long userId, String userName) {
+        String token = Jwts.builder()
+                           .setSubject("ssyx-USER")
+                           .setExpiration(new Date(System.currentTimeMillis() + tokenExpiration))
+                           .claim("userId", userId)
+                           .claim("userName", userName)
+                           .signWith(SignatureAlgorithm.HS512, tokenSignKey)
+                           .compressWith(CompressionCodecs.GZIP)
+                           .compact();
+        return token;
+    }
+
+    public static Long getUserId(String token) {
+        if (StringUtils.isEmpty(token)) return null;
+
+        Jws<Claims> claimsJws = Jwts.parser()
+                                    .setSigningKey(tokenSignKey)
+                                    .parseClaimsJws(token);
+        Claims claims = claimsJws.getBody();
+        Integer userId = (Integer) claims.get("userId");
+        return userId.longValue();
+        // return 1L;
+    }
+
+    public static String getUserName(String token) {
+        if (StringUtils.isEmpty(token)) return "";
+
+        Jws<Claims> claimsJws = Jwts.parser()
+                                    .setSigningKey(tokenSignKey)
+                                    .parseClaimsJws(token);
+        Claims claims = claimsJws.getBody();
+        return (String) claims.get("userName");
+    }
+
+    public static void removeToken(String token) {
+        //jwttoken无需删除，客户端扔掉即可。
+    }
+
+    public static void main(String[] args) {
+        String token = JwtHelper.createToken(7L, "admin");
+        System.out.println(token);
+        System.out.println(JwtHelper.getUserId(token));
+        System.out.println(JwtHelper.getUserName(token));
+    }
+}

guigu-ssyx-parent/common/service-util/src/main/java/com/atguigu/ssyx/common/auth/AuthContextHolder.java

@@ -0,0 +1,50 @@
+package com.atguigu.ssyx.common.auth;
+
+import com.atguigu.ssyx.vo.user.UserLoginVo;
+
+/**
+ * ClassName: AuthContextHolder
+ * Package: com.atguigu.ssyx.common.auth
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 17:40
+ */
+//ThreadLocal工具类
+public class AuthContextHolder {
+
+    //用户id
+    private static final ThreadLocal<Long> userId = new ThreadLocal<>();
+
+    //用户仓库id
+    private static final ThreadLocal<Long> wareId = new ThreadLocal<>();
+
+    //用户信息对象
+    private static final ThreadLocal<UserLoginVo> userLoginVo = new ThreadLocal<>();
+
+    public static Long getUserId() {
+        return userId.get();
+    }
+
+    //userId操作的方法
+    public static void setUserId(Long _userId) {
+        userId.set(_userId);
+    }
+
+    public static Long getWareId() {
+        return wareId.get();
+    }
+
+    public static void setWareId(Long _wareId) {
+        wareId.set(_wareId);
+    }
+
+    public static UserLoginVo getUserLoginVo() {
+        return userLoginVo.get();
+    }
+
+    public static void setUserLoginVo(UserLoginVo _userLoginVo) {
+        userLoginVo.set(_userLoginVo);
+    }
+
+
+}

guigu-ssyx-parent/common/service-util/src/main/java/com/atguigu/ssyx/common/auth/LoginMvcConfigurerAdapter.java

@@ -0,0 +1,30 @@
+package com.atguigu.ssyx.common.auth;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
+
+import javax.annotation.Resource;
+
+/**
+ * ClassName: LoginMvcConfigurerAdapter
+ * Package: com.atguigu.ssyx.common.auth
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 23:58
+ */
+@Configuration
+public class LoginMvcConfigurerAdapter extends WebMvcConfigurationSupport {
+
+    @Resource
+    private RedisTemplate redisTemplate;
+
+    @Override
+    public void addInterceptors(InterceptorRegistry registry) {
+        registry.addInterceptor(new UserLoginInterceptor(redisTemplate))
+                .addPathPatterns("/api/**")
+                .excludePathPatterns("/api/user/weixin/wxLogin/*");
+        super.addInterceptors(registry);
+    }
+}

guigu-ssyx-parent/common/service-util/src/main/java/com/atguigu/ssyx/common/auth/UserLoginInterceptor.java

@@ -0,0 +1,53 @@
+package com.atguigu.ssyx.common.auth;
+
+import com.atguigu.ssyx.common.constant.RedisConst;
+import com.atguigu.ssyx.common.utils.JwtHelper;
+import com.atguigu.ssyx.vo.user.UserLoginVo;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.util.StringUtils;
+import org.springframework.web.servlet.HandlerInterceptor;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * ClassName: UserLoginInterceptor
+ * Package: com.atguigu.ssyx.common.auth
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 23:47
+ */
+public class UserLoginInterceptor implements HandlerInterceptor {
+
+    private final RedisTemplate redisTemplate;
+
+    public UserLoginInterceptor(RedisTemplate redisTemplate) {
+        this.redisTemplate = redisTemplate;
+    }
+
+    @Override
+    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
+        this.getUserLoginVo(request);
+        return true;
+    }
+
+    private void getUserLoginVo(HttpServletRequest request) {
+        //从请求头获取token
+        String token = request.getHeader("token");
+
+        //判断token不为空
+        if (!StringUtils.isEmpty(token)) {
+            //从token获取userId
+            Long userId = JwtHelper.getUserId(token);
+            //根据userId到Redis获取用户信息
+            UserLoginVo userLoginVo = (UserLoginVo) redisTemplate.opsForValue()
+                                                                 .get(RedisConst.USER_LOGIN_KEY_PREFIX + userId);
+            //获取数据放到ThreadLocal里面
+            if (userLoginVo != null) {
+                AuthContextHolder.setUserId(userLoginVo.getUserId());
+                AuthContextHolder.setWareId(userLoginVo.getWareId());
+                AuthContextHolder.setUserLoginVo(userLoginVo);
+            }
+        }
+    }
+}

guigu-ssyx-parent/common/service-util/src/main/java/com/atguigu/ssyx/common/config/RedisConfig.java

@@ -0,0 +1,105 @@
+package com.atguigu.ssyx.common.config;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.interceptor.KeyGenerator;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+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.RedisSerializationContext;
+import org.springframework.data.redis.serializer.RedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import java.lang.reflect.Method;
+import java.time.Duration;
+
+/**
+ * ClassName: RedisConfig
+ * Package: com.atguigu.ssyx.common.config
+ * Redis配置类
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 15:55
+ */
+
+@Configuration
+@EnableCaching
+public class RedisConfig {
+
+    // 使用默认标签做缓存
+    @Bean
+    public KeyGenerator wiselyKeyGenerator() {
+        return new KeyGenerator() {
+            @Override
+            public Object generate(Object target, Method method, Object... params) {
+                StringBuilder sb = new StringBuilder();
+                sb.append(target.getClass()
+                                .getName());
+                sb.append(method.getName());
+                for (Object obj : params) {
+                    sb.append(obj.toString());
+                }
+                return sb.toString();
+            }
+        };
+    }
+
+    // 声明模板
+    /*
+    ref = 表示引用
+    value = 具体的值
+    <bean class="org.springframework.data.redis.core.RedisTemplate" >
+        <property name="defaultSerializer" ref = "">
+    </bean>
+     */
+    //  工具类：
+    @Bean
+    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
+        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(redisConnectionFactory);
+        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
+        ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
+        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
+        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
+        //  将Redis 中 string ，hash 数据类型，自动序列化！
+        redisTemplate.setKeySerializer(new StringRedisSerializer());
+        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
+        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
+        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
+
+        redisTemplate.afterPropertiesSet();
+        return redisTemplate;
+    }
+
+    @Bean
+    public CacheManager cacheManager(RedisConnectionFactory factory) {
+        RedisSerializer<String> redisSerializer = new StringRedisSerializer();
+        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
+
+        //解决查询缓存转换异常的问题
+        ObjectMapper om = new ObjectMapper();
+        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
+        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
+        jackson2JsonRedisSerializer.setObjectMapper(om);
+
+        // 配置序列化（解决乱码的问题）,过期时间600秒
+        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
+                                                                .entryTtl(Duration.ofDays(365))
+                                                                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
+                                                                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
+                                                                .disableCachingNullValues();
+
+        RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
+                                                          .cacheDefaults(config)
+                                                          .build();
+        return cacheManager;
+    }
+}

guigu-ssyx-parent/common/service-util/src/main/java/com/atguigu/ssyx/common/constant/RedisConst.java

@@ -0,0 +1,49 @@
+package com.atguigu.ssyx.common.constant;
+
+/**
+ * ClassName: RedisConst
+ * Package: com.atguigu.ssyx.common.constant
+ * Redis常量配置类
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 15:57
+ */
+public class RedisConst {
+
+    public static final String SKUKEY_PREFIX = "sku:";
+    public static final String SKUKEY_SUFFIX = ":info";
+    //单位：秒
+    public static final long SKUKEY_TIMEOUT = 24 * 60 * 60;
+    // 定义变量，记录空对象的缓存过期时间 缓存穿透key的过期时间
+    public static final long SKUKEY_TEMPORARY_TIMEOUT = 10 * 60;
+
+    //单位：秒 尝试获取锁的最大等待时间
+    public static final long SKULOCK_EXPIRE_PX1 = 1;
+    //单位：秒 锁的持有时间
+    public static final long SKULOCK_EXPIRE_PX2 = 1;
+    public static final String SKULOCK_SUFFIX = ":lock";
+
+    public static final String USER_KEY_PREFIX = "user:";
+    public static final String USER_CART_KEY_SUFFIX = ":cart";
+    public static final long USER_CART_EXPIRE = 60 * 60 * 24 * 7;
+    public static final String SROCK_INFO = "stock:info:";
+    public static final String ORDER_REPEAT = "order:repeat:";
+
+    //用户登录
+    public static final String USER_LOGIN_KEY_PREFIX = "user:login:";
+    public static final String ADMIN_LOGIN_KEY_PREFIX = "admin:login:";
+    //    public static final String userinfoKey_suffix = ":info";
+    public static final int USERKEY_TIMEOUT = 365;
+    public static final String ORDER_SKU_MAP = "order:sku:";
+
+    //秒杀商品前缀
+    public static final String SECKILL_TIME_MAP = "seckill:time:map";
+    public static final String SECKILL_SKU_MAP = "seckill:sku:map";
+    public static final String SECKILL_SKU_LIST = "seckill:sku:list:";
+    public static final String SECKILL_USER_MAP = "seckill:user:map:";
+    public static final String SECKILL_ORDERS_USERS = "seckill:orders:users";
+    public static final String SECKILL_STOCK_PREFIX = "seckill:stock:";
+    public static final String SECKILL_USER = "seckill:user:";
+    //用户锁定时间 单位：秒
+    public static final int SECKILL__TIMEOUT = 60 * 60;
+}

guigu-ssyx-parent/service/pom.xml

@@ -17,6 +17,7 @@
         <module>service-product</module>
         <module>service-search</module>
         <module>service-activity</module>
+        <module>service-user</module>
     </modules>
 
     <dependencies>

guigu-ssyx-parent/service/service-user/Dockerfile

@@ -0,0 +1,5 @@
+FROM openjdk:8-jdk-alpine
+LABEL authors="yovinchen"
+VOLUME /tmp
+ADD ./target/service-user.jar service-user.jar
+ENTRYPOINT ["java","-jar","/service-user.jar", "&"]

guigu-ssyx-parent/service/service-user/pom.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.atguigu</groupId>
+        <artifactId>service</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>service-user</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/ServiceUserApplication.java

@@ -0,0 +1,22 @@
+package com.atguigu.ssyx;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+/**
+ * ClassName: ServiceUserApplication
+ * Package: com.atguigu.ssyx
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 15:39
+ */
+@SpringBootApplication
+@EnableDiscoveryClient
+@EnableFeignClients
+public class ServiceUserApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(ServiceUserApplication.class, args);
+    }
+}

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/controller/WeixinApiController.java

@@ -0,0 +1,41 @@
+package com.atguigu.ssyx.user.controller;
+
+import com.atguigu.ssyx.common.result.Result;
+import com.atguigu.ssyx.model.user.User;
+import com.atguigu.ssyx.user.service.LoginWxService;
+import com.atguigu.ssyx.user.service.UserService;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * ClassName: WeixinApiController
+ * Package: com.atguigu.ssyx.user.controller
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:23
+ */
+@RestController
+@RequestMapping("/api/user/weixin")
+public class WeixinApiController {
+
+    @Autowired
+    private LoginWxService loginWxService;
+
+    @Autowired
+    private UserService userService;
+
+    //用户微信授权登录
+    @ApiOperation(value = "微信登录获取openid(小程序)")
+    @GetMapping("/wxLogin/{code}")
+    public Result loginWx(@PathVariable String code) {
+        return Result.ok(loginWxService.loginWx(code));
+    }
+
+    @PostMapping("/auth/updateUser")
+    @ApiOperation(value = "更新用户昵称与头像")
+    public Result updateUser(@RequestBody User user) {
+        userService.updateUser(user);
+        return Result.ok(null);
+    }
+}

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/mapper/LeaderMapper.java

@@ -0,0 +1,17 @@
+package com.atguigu.ssyx.user.mapper;
+
+import com.atguigu.ssyx.model.user.Leader;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * ClassName: LeaderMapper
+ * Package: com.atguigu.ssyx.user.mapper
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:57
+ */
+@Repository
+public interface LeaderMapper extends BaseMapper<Leader> {
+}
+

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/mapper/UserDeliveryMapper.java

@@ -0,0 +1,17 @@
+package com.atguigu.ssyx.user.mapper;
+
+import com.atguigu.ssyx.model.user.UserDelivery;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * ClassName: UserDeliveryMapper
+ * Package: com.atguigu.ssyx.user.mapper
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:57
+ */
+@Repository
+public interface UserDeliveryMapper extends BaseMapper<UserDelivery> {
+}
+

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/mapper/UserMapper.java

@@ -0,0 +1,17 @@
+package com.atguigu.ssyx.user.mapper;
+
+import com.atguigu.ssyx.model.user.User;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+
+/**
+ * ClassName: UserMapper
+ * Package: com.atguigu.ssyx.user.mapper
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:50
+ */
+@Repository
+public interface UserMapper extends BaseMapper<User> {
+}

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/service/LoginWxService.java

@@ -0,0 +1,100 @@
+package com.atguigu.ssyx.user.service;
+
+import com.alibaba.fastjson.JSONObject;
+import com.atguigu.ssyx.common.constant.RedisConst;
+import com.atguigu.ssyx.common.exception.SsyxException;
+import com.atguigu.ssyx.common.result.ResultCodeEnum;
+import com.atguigu.ssyx.common.utils.JwtHelper;
+import com.atguigu.ssyx.enums.UserType;
+import com.atguigu.ssyx.model.user.User;
+import com.atguigu.ssyx.user.utils.ConstantPropertiesUtil;
+import com.atguigu.ssyx.user.utils.HttpClientUtils;
+import com.atguigu.ssyx.vo.user.LeaderAddressVo;
+import com.atguigu.ssyx.vo.user.UserLoginVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * ClassName: LoginWxService
+ * Package: com.atguigu.ssyx.user.service
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 17:08
+ */
+@Service
+public class LoginWxService {
+
+    @Autowired
+    private UserService userService;
+
+    @Autowired
+    private RedisTemplate redisTemplate;
+
+
+    public Map<String, Object> loginWx(String code) {
+        //1 得到微信返回code临时票据值
+        //2 拿着code + 小程序id + 小程序秘钥 请求微信接口服务
+        //// 使用HttpClient工具请求
+        //小程序id
+        String wxOpenAppId = ConstantPropertiesUtil.WX_OPEN_APP_ID;
+        //小程序秘钥
+        String wxOpenAppSecret = ConstantPropertiesUtil.WX_OPEN_APP_SECRET;
+        //get请求
+        //拼接请求地址+参数
+        /// 地址?name=value&name1=value1
+        String url = "https://api.weixin.qq.com/sns/jscode2session" + "?appid=%s" + "&secret=%s" + "&js_code=%s" + "&grant_type=authorization_code";
+        String tokenUrl = String.format(url, wxOpenAppId, wxOpenAppSecret, code);
+        //HttpClient发送get请求
+        String result = null;
+        try {
+            result = HttpClientUtils.get(tokenUrl);
+        } catch (Exception e) {
+            throw new SsyxException(ResultCodeEnum.FETCH_ACCESSTOKEN_FAILD);
+        }
+
+        //3 请求微信接口服务，返回两个值 session_key 和 openid
+        //// openId是你微信唯一标识
+        JSONObject jsonObject = JSONObject.parseObject(result);
+        String session_key = jsonObject.getString("session_key");
+        String openid = jsonObject.getString("openid");
+
+        //4 添加微信用户信息到数据库里面
+        //// 操作user表
+        //// 判断是否是第一次使用微信授权登录：如何判断？openId
+        User user = userService.getUserByOpenId(openid);
+        if (user == null) {
+            user = new User();
+            user.setOpenId(openid);
+            user.setNickName(openid);
+            user.setPhotoUrl("");
+            user.setUserType(UserType.USER);
+            user.setIsNew(0);
+            userService.save(user);
+        }
+
+        //5 根据userId查询提货点和团长信息
+        ////提货点  user表  user_delivery表
+        ////团长    leader表
+        LeaderAddressVo leaderAddressVo = userService.getLeaderAddressByUserId(user.getId());
+
+        //6 使用JWT工具根据userId和userName生成token字符串
+        String token = JwtHelper.createToken(user.getId(), user.getNickName());
+
+        //7 获取当前登录用户信息，放到Redis里面，设置有效时间
+        UserLoginVo userLoginVo = userService.getUserLoginVo(user.getId());
+        redisTemplate.opsForValue()
+                     .set(RedisConst.USER_LOGIN_KEY_PREFIX + user.getId(), userLoginVo, RedisConst.USERKEY_TIMEOUT, TimeUnit.DAYS);
+
+        //8 需要数据封装到map返回
+        Map<String, Object> map = new HashMap<>();
+        map.put("user", user);
+        map.put("token", token);
+        map.put("leaderAddressVo", leaderAddressVo);
+        return map;
+    }
+}

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/service/UserService.java

@@ -0,0 +1,46 @@
+package com.atguigu.ssyx.user.service;
+
+import com.atguigu.ssyx.model.user.User;
+import com.atguigu.ssyx.vo.user.LeaderAddressVo;
+import com.atguigu.ssyx.vo.user.UserLoginVo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * ClassName: UserService
+ * Package: com.atguigu.ssyx.user.service
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:33
+ */
+public interface UserService extends IService<User> {
+    /**
+     * 根据微信openid获取用户信息
+     *
+     * @param openid
+     * @return
+     */
+    User getUserByOpenId(String openid);
+
+    /**
+     * 根据userId查询提货点和团长信息
+     *
+     * @param id
+     * @return
+     */
+    LeaderAddressVo getLeaderAddressByUserId(Long id);
+
+    /**
+     * 获取当前登录用户信息
+     *
+     * @param id
+     * @return
+     */
+    UserLoginVo getUserLoginVo(Long id);
+
+    /**
+     * 更新用户昵称与头像
+     *
+     * @param user
+     */
+    void updateUser(User user);
+}

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/service/impl/UserServiceImpl.java

@@ -0,0 +1,97 @@
+package com.atguigu.ssyx.user.service.impl;
+
+import com.atguigu.ssyx.common.auth.AuthContextHolder;
+import com.atguigu.ssyx.model.user.Leader;
+import com.atguigu.ssyx.model.user.User;
+import com.atguigu.ssyx.model.user.UserDelivery;
+import com.atguigu.ssyx.user.mapper.LeaderMapper;
+import com.atguigu.ssyx.user.mapper.UserDeliveryMapper;
+import com.atguigu.ssyx.user.mapper.UserMapper;
+import com.atguigu.ssyx.user.service.UserService;
+import com.atguigu.ssyx.vo.user.LeaderAddressVo;
+import com.atguigu.ssyx.vo.user.UserLoginVo;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * ClassName: UserServiceImpl
+ * Package: com.atguigu.ssyx.user.service.impl
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:34
+ */
+@Service
+public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
+    @Autowired
+    private UserDeliveryMapper userDeliveryMapper;
+
+    @Autowired
+    private LeaderMapper leaderMapper;
+
+    //// 判断是否是第一次使用微信授权登录：如何判断？openId
+    @Override
+    public User getUserByOpenId(String openid) {
+        User user = baseMapper.selectOne(new LambdaQueryWrapper<User>().eq(User::getOpenId, openid));
+        return user;
+    }
+
+    //5 根据userId查询提货点和团长信息
+    @Override
+    public LeaderAddressVo getLeaderAddressByUserId(Long userId) {
+        //根据userId查询用户默认的团长id
+        UserDelivery userDelivery = userDeliveryMapper.selectOne(new LambdaQueryWrapper<UserDelivery>().eq(UserDelivery::getUserId, userId)
+                                                                                                       .eq(UserDelivery::getIsDefault, 1));
+        if (userDelivery == null) {
+            return null;
+        }
+        //拿着上面查询团长id查询leader表查询团长其他信息
+        Leader leader = leaderMapper.selectById(userDelivery.getLeaderId());
+        //封装数据到LeaderAddressVo
+        LeaderAddressVo leaderAddressVo = new LeaderAddressVo();
+        BeanUtils.copyProperties(leader, leaderAddressVo);
+        leaderAddressVo.setUserId(userId);
+        leaderAddressVo.setLeaderId(leader.getId());
+        leaderAddressVo.setLeaderName(leader.getName());
+        leaderAddressVo.setLeaderPhone(leader.getPhone());
+        leaderAddressVo.setWareId(userDelivery.getWareId());
+        leaderAddressVo.setStorePath(leader.getStorePath());
+        return leaderAddressVo;
+    }
+
+    //7 获取当前登录用户信息，
+    @Override
+    public UserLoginVo getUserLoginVo(Long id) {
+        User user = baseMapper.selectById(id);
+        UserLoginVo userLoginVo = new UserLoginVo();
+        userLoginVo.setUserId(id);
+        userLoginVo.setNickName(user.getNickName());
+        userLoginVo.setPhotoUrl(user.getPhotoUrl());
+        userLoginVo.setIsNew(user.getIsNew());
+        userLoginVo.setOpenId(user.getOpenId());
+
+        UserDelivery userDelivery = userDeliveryMapper.selectOne(new LambdaQueryWrapper<UserDelivery>().eq(UserDelivery::getUserId, id)
+                                                                                                       .eq(UserDelivery::getIsDefault, 1));
+        if (userDelivery != null) {
+            userLoginVo.setLeaderId(userDelivery.getLeaderId());
+            userLoginVo.setWareId(userDelivery.getWareId());
+        } else {
+            userLoginVo.setLeaderId(1L);
+            userLoginVo.setWareId(1L);
+        }
+        return userLoginVo;
+    }
+
+    @Override
+    public void updateUser(User user) {
+        //获取当前登录用户id
+        User user1 = baseMapper.selectById(AuthContextHolder.getUserId());
+        //把昵称更新为微信用户
+        user1.setNickName(user.getNickName()
+                              .replaceAll("[ue000-uefff]", "*"));
+        user1.setPhotoUrl(user.getPhotoUrl());
+        baseMapper.updateById(user1);
+    }
+}

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/utils/ConstantPropertiesUtil.java

@@ -0,0 +1,29 @@
+package com.atguigu.ssyx.user.utils;
+
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * ClassName: ConstantPropertiesUtil
+ * Package: com.atguigu.ssyx.user.utils
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:19
+ */
+@Component
+public class ConstantPropertiesUtil implements InitializingBean {
+
+    public static String WX_OPEN_APP_ID;
+    public static String WX_OPEN_APP_SECRET;
+    @Value("${wx.open.app_id}")
+    private String appId;
+    @Value("${wx.open.app_secret}")
+    private String appSecret;
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        WX_OPEN_APP_ID = appId;
+        WX_OPEN_APP_SECRET = appSecret;
+    }
+}

guigu-ssyx-parent/service/service-user/src/main/java/com/atguigu/ssyx/user/utils/HttpClientUtils.java

@@ -0,0 +1,317 @@
+package com.atguigu.ssyx.user.utils;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang.StringUtils;
+import org.apache.http.Consts;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.config.RequestConfig.Builder;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.conn.ConnectTimeoutException;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.conn.ssl.SSLContextBuilder;
+import org.apache.http.conn.ssl.TrustStrategy;
+import org.apache.http.conn.ssl.X509HostnameVerifier;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.message.BasicNameValuePair;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.SSLException;
+import javax.net.ssl.SSLSession;
+import javax.net.ssl.SSLSocket;
+import java.io.IOException;
+import java.net.SocketTimeoutException;
+import java.security.GeneralSecurityException;
+import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Set;
+
+/**
+ * ClassName: HttpClientUtils
+ * Package: com.atguigu.ssyx.user.utils
+ *
+ * @author yovinchen
+ * @Create 2023/9/22 16:20
+ */
+public class HttpClientUtils {
+
+    public static final int connTimeout = 10000;
+    public static final int readTimeout = 10000;
+    public static final String charset = "UTF-8";
+    private static HttpClient client = null;
+
+    static {
+        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
+        cm.setMaxTotal(128);
+        cm.setDefaultMaxPerRoute(128);
+        client = HttpClients.custom()
+                            .setConnectionManager(cm)
+                            .build();
+    }
+
+    public static String postParameters(String url, String parameterStr) throws Exception {
+        return post(url, parameterStr, "application/x-www-form-urlencoded", charset, connTimeout, readTimeout);
+    }
+
+    public static String postParameters(String url, String parameterStr, String charset, Integer connTimeout, Integer readTimeout) throws Exception {
+        return post(url, parameterStr, "application/x-www-form-urlencoded", charset, connTimeout, readTimeout);
+    }
+
+    public static String postParameters(String url, Map<String, String> params) throws Exception {
+        return postForm(url, params, null, connTimeout, readTimeout);
+    }
+
+    public static String postParameters(String url, Map<String, String> params, Integer connTimeout, Integer readTimeout) throws Exception {
+        return postForm(url, params, null, connTimeout, readTimeout);
+    }
+
+    public static String get(String url) throws Exception {
+        return get(url, charset, null, null);
+    }
+
+    public static String get(String url, String charset) throws Exception {
+        return get(url, charset, connTimeout, readTimeout);
+    }
+
+    /**
+     * 发送一个 Post 请求, 使用指定的字符集编码.
+     *
+     * @param url
+     * @param body        RequestBody
+     * @param mimeType    例如 application/xml "application/x-www-form-urlencoded" a=1&b=2&c=3
+     * @param charset     编码
+     * @param connTimeout 建立链接超时时间,毫秒.
+     * @param readTimeout 响应超时时间,毫秒.
+     * @return ResponseBody, 使用指定的字符集编码.
+     * @throws ConnectTimeoutException 建立链接超时异常
+     * @throws SocketTimeoutException  响应超时
+     * @throws Exception
+     */
+    public static String post(String url, String body, String mimeType, String charset, Integer connTimeout, Integer readTimeout) throws ConnectTimeoutException, SocketTimeoutException, Exception {
+        HttpClient client = null;
+        HttpPost post = new HttpPost(url);
+        String result = "";
+        try {
+            if (StringUtils.isNotBlank(body)) {
+                HttpEntity entity = new StringEntity(body, ContentType.create(mimeType, charset));
+                post.setEntity(entity);
+            }
+            // 设置参数
+            Builder customReqConf = RequestConfig.custom();
+            if (connTimeout != null) {
+                customReqConf.setConnectTimeout(connTimeout);
+            }
+            if (readTimeout != null) {
+                customReqConf.setSocketTimeout(readTimeout);
+            }
+            post.setConfig(customReqConf.build());
+
+            HttpResponse res;
+            if (url.startsWith("https")) {
+                // 执行 Https 请求.
+                client = createSSLInsecureClient();
+                res = client.execute(post);
+            } else {
+                // 执行 Http 请求.
+                client = HttpClientUtils.client;
+                res = client.execute(post);
+            }
+            result = IOUtils.toString(res.getEntity()
+                                         .getContent(), charset);
+        } finally {
+            post.releaseConnection();
+            if (url.startsWith("https") && client != null && client instanceof CloseableHttpClient) {
+                ((CloseableHttpClient) client).close();
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 提交form表单
+     *
+     * @param url
+     * @param params
+     * @param connTimeout
+     * @param readTimeout
+     * @return
+     * @throws ConnectTimeoutException
+     * @throws SocketTimeoutException
+     * @throws Exception
+     */
+    public static String postForm(String url, Map<String, String> params, Map<String, String> headers, Integer connTimeout, Integer readTimeout) throws ConnectTimeoutException, SocketTimeoutException, Exception {
+
+        HttpClient client = null;
+        HttpPost post = new HttpPost(url);
+        try {
+            if (params != null && !params.isEmpty()) {
+                List<NameValuePair> formParams = new ArrayList<NameValuePair>();
+                Set<Entry<String, String>> entrySet = params.entrySet();
+                for (Entry<String, String> entry : entrySet) {
+                    formParams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
+                }
+                UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formParams, Consts.UTF_8);
+                post.setEntity(entity);
+            }
+
+            if (headers != null && !headers.isEmpty()) {
+                for (Entry<String, String> entry : headers.entrySet()) {
+                    post.addHeader(entry.getKey(), entry.getValue());
+                }
+            }
+            // 设置参数
+            Builder customReqConf = RequestConfig.custom();
+            if (connTimeout != null) {
+                customReqConf.setConnectTimeout(connTimeout);
+            }
+            if (readTimeout != null) {
+                customReqConf.setSocketTimeout(readTimeout);
+            }
+            post.setConfig(customReqConf.build());
+            HttpResponse res = null;
+            if (url.startsWith("https")) {
+                // 执行 Https 请求.
+                client = createSSLInsecureClient();
+                res = client.execute(post);
+            } else {
+                // 执行 Http 请求.
+                client = HttpClientUtils.client;
+                res = client.execute(post);
+            }
+            return IOUtils.toString(res.getEntity()
+                                       .getContent(), "UTF-8");
+        } finally {
+            post.releaseConnection();
+            if (url.startsWith("https") && client != null && client instanceof CloseableHttpClient) {
+                ((CloseableHttpClient) client).close();
+            }
+        }
+    }
+
+    /**
+     * 发送一个 GET 请求
+     *
+     * @param url
+     * @param charset
+     * @param connTimeout 建立链接超时时间,毫秒.
+     * @param readTimeout 响应超时时间,毫秒.
+     * @return
+     * @throws ConnectTimeoutException 建立链接超时
+     * @throws SocketTimeoutException  响应超时
+     * @throws Exception
+     */
+    public static String get(String url, String charset, Integer connTimeout, Integer readTimeout) throws ConnectTimeoutException, SocketTimeoutException, Exception {
+
+        HttpClient client = null;
+        HttpGet get = new HttpGet(url);
+        String result = "";
+        try {
+            // 设置参数
+            Builder customReqConf = RequestConfig.custom();
+            if (connTimeout != null) {
+                customReqConf.setConnectTimeout(connTimeout);
+            }
+            if (readTimeout != null) {
+                customReqConf.setSocketTimeout(readTimeout);
+            }
+            get.setConfig(customReqConf.build());
+
+            HttpResponse res = null;
+
+            if (url.startsWith("https")) {
+                // 执行 Https 请求.
+                client = createSSLInsecureClient();
+                res = client.execute(get);
+            } else {
+                // 执行 Http 请求.
+                client = HttpClientUtils.client;
+                res = client.execute(get);
+            }
+            result = IOUtils.toString(res.getEntity()
+                                         .getContent(), charset);
+        } finally {
+            get.releaseConnection();
+            if (url.startsWith("https") && client != null && client instanceof CloseableHttpClient) {
+                ((CloseableHttpClient) client).close();
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 从 response 里获取 charset
+     *
+     * @param ressponse
+     * @return
+     */
+    @SuppressWarnings("unused")
+    private static String getCharsetFromResponse(HttpResponse ressponse) {
+        // Content-Type:text/html; charset=GBK
+        if (ressponse.getEntity() != null && ressponse.getEntity()
+                                                      .getContentType() != null && ressponse.getEntity()
+                                                                                            .getContentType()
+                                                                                            .getValue() != null) {
+            String contentType = ressponse.getEntity()
+                                          .getContentType()
+                                          .getValue();
+            if (contentType.contains("charset=")) {
+                return contentType.substring(contentType.indexOf("charset=") + 8);
+            }
+        }
+        return null;
+    }
+
+    /**
+     * 创建 SSL连接
+     *
+     * @return
+     * @throws GeneralSecurityException
+     */
+    private static CloseableHttpClient createSSLInsecureClient() throws GeneralSecurityException {
+        try {
+            SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
+                                                               public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
+                                                                   return true;
+                                                               }
+                                                           })
+                                                           .build();
+            SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, new X509HostnameVerifier() {
+
+                @Override
+                public boolean verify(String arg0, SSLSession arg1) {
+                    return true;
+                }
+
+                @Override
+                public void verify(String host, SSLSocket ssl) throws IOException {
+                }
+
+                @Override
+                public void verify(String host, X509Certificate cert) throws SSLException {
+                }
+
+                @Override
+                public void verify(String host, String[] cns, String[] subjectAlts) throws SSLException {
+                }
+            });
+            return HttpClients.custom()
+                              .setSSLSocketFactory(sslsf)
+                              .build();
+        } catch (GeneralSecurityException e) {
+            throw e;
+        }
+    }
+}

guigu-ssyx-parent/service/service-user/src/main/resources/application-dev.yml

@@ -0,0 +1,36 @@
+server:
+  port: 8206
+
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  type-enums-package: com.atguigu.ssyx.enums
+
+spring:
+  datasource:
+    type: com.zaxxer.hikari.HikariDataSource
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    url: jdbc:mysql://82.157.68.223:3306/shequ-user?characterEncoding=utf-8&useSSL=false
+    username: shequ-user
+    password: shequ-user
+  jackson:
+    date-format: yyyy-MM-dd HH:mm:ss
+    time-zone: GMT+8
+  redis:
+    host: 82.157.68.223
+    port: 6379
+    database: 0
+    timeout: 1800000
+    password:
+    lettuce:
+      pool:
+        max-active: 20 #最大连接数
+        max-wait: -1    #最大阻塞等待时间(负数表示没限制)
+        max-idle: 5    #最大空闲
+        min-idle: 0     #最小空闲
+wx:
+  open:
+    # 小程序微信公众平台appId
+    app_id: wx2edefe049c6a37b9
+    # 小程序微信公众平台api秘钥
+    app_secret: 1cb2b7aec97a28f0cdf4b74defa1792a

guigu-ssyx-parent/service/service-user/src/main/resources/application.yml

@@ -0,0 +1,11 @@
+spring:
+  application:
+    name: service-user
+  profiles:
+    active: dev
+  cloud:
+    nacos:
+      discovery:
+        server-addr: 82.157.68.223:8848
+        username: nacos
+        password: nacos