diff --git a/mall_auth/src/main/java/com/mall/auth/config/ConfirmCallbackConfig.java b/mall_auth/src/main/java/com/mall/auth/config/ConfirmCallbackConfig.java new file mode 100644 index 0000000..4be9cba --- /dev/null +++ b/mall_auth/src/main/java/com/mall/auth/config/ConfirmCallbackConfig.java @@ -0,0 +1,31 @@ +package com.mall.auth.config; + +import lombok.extern.log4j.Log4j2; +import org.springframework.amqp.rabbit.connection.CorrelationData; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; + +@Component +@Log4j2 +public class ConfirmCallbackConfig implements RabbitTemplate.ConfirmCallback { + + @Autowired + private RabbitTemplate rabbitTemplate; + + @PostConstruct + public void init(){ + rabbitTemplate.setConfirmCallback(this); + } + + @Override + public void confirm(CorrelationData correlationData, boolean b, String s) { + if(b){//消费者投递broker 状态,true表示成功 + log.info("消息发送成功!"); + }else{ + log.error("消息发送异常,异常原因:{}",s); + } + } +} diff --git a/mall_auth/src/main/java/com/mall/auth/config/ReturnCallbackConfig.java b/mall_auth/src/main/java/com/mall/auth/config/ReturnCallbackConfig.java new file mode 100644 index 0000000..f2e6b92 --- /dev/null +++ b/mall_auth/src/main/java/com/mall/auth/config/ReturnCallbackConfig.java @@ -0,0 +1,27 @@ +package com.mall.auth.config; + +import org.springframework.amqp.core.ReturnedMessage; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; + +@Component +public class ReturnCallbackConfig implements RabbitTemplate.ReturnsCallback { + + @Autowired + private RabbitTemplate rabbitTemplate; + + + @PostConstruct + public void init(){ + rabbitTemplate.setReturnsCallback(this); + } + + @Override + public void returnedMessage(ReturnedMessage returnedMessage) { + System.out.println("消息"+returnedMessage.getMessage().toString()+"被交换机"+returnedMessage.getExchange()+"回退!" + +"退回原因为:"+returnedMessage.getReplyText()); + } +} diff --git a/mall_auth/src/main/java/com/mall/auth/controller/AuthController.java b/mall_auth/src/main/java/com/mall/auth/controller/AuthController.java new file mode 100644 index 0000000..0737bf2 --- /dev/null +++ b/mall_auth/src/main/java/com/mall/auth/controller/AuthController.java @@ -0,0 +1,80 @@ +package com.mall.auth.controller; + +import com.mall.auth.service.AuthService; +import com.mall.common.domain.UserInfo; +import com.mall.common.domain.request.LoginRequest; +import com.mall.common.domain.vo.LoginVo; +import com.mall.common.domain.vo.UserInfoVo; +import com.mall.common.result.Result; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 17:00 + * @Description: TODO + * @Version: 1.0 + */ +@RestController +@Slf4j +public class AuthController { + @Autowired + private AuthService authService; + + /** + * 账号密码登录接口 + * @param loginVo + * @return Result + */ + @PostMapping("/login") + public Result login(@RequestBody LoginVo loginVo){ + Result result = authService.login(loginVo); + return result; + } + + /** + * 发送验证码接口 + * @param loginRequest + * @return Result + */ + @PostMapping("send/code/{phone}") + public Result sendCode(@RequestBody LoginRequest loginRequest){ + Result result = authService.sendCode(loginRequest); + return result; + } + + /** + * 手机号登录接口 + * @param loginRequest + * @return Result + */ + @PostMapping("phoneLogin") + public Result phoneLogin(@RequestBody LoginRequest loginRequest) { + Result result = authService.phoneLogin(loginRequest); + return result; + } + + /** + * 手机号注册接口 + * @param userInfoVo + * @return Result + */ + @PostMapping("phoneRegister") + public Result phoneRegister(@RequestBody UserInfoVo userInfoVo) { + Result result = authService.phoneRegister(userInfoVo); + return result; + } + + /** + * 获取用户信息接口 + * @return Result + */ + @GetMapping("getUserInfo/{userId}") + public Result userInfo() { + Result result = authService.userInfo(); + return result; + } +} diff --git a/mall_auth/src/main/java/com/mall/auth/feign/UserServiceFeign.java b/mall_auth/src/main/java/com/mall/auth/feign/UserServiceFeign.java new file mode 100644 index 0000000..2fbfee7 --- /dev/null +++ b/mall_auth/src/main/java/com/mall/auth/feign/UserServiceFeign.java @@ -0,0 +1,24 @@ +package com.mall.auth.feign; + +import com.mall.common.domain.UserInfo; +import com.mall.common.result.Result; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.*; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 17:16 + * @Description: TODO + * @Version: 1.0 + */ +@FeignClient(name = "czk-user") +public interface UserServiceFeign { + @PostMapping("findLogin/{username}/{password}") + public Result findLogin(@PathVariable String username,@PathVariable String password); + + @GetMapping("findPhone/{phone}") + public Result findPhone(@PathVariable("phone") String phone); + + @PostMapping("register") + public Result register(@RequestBody UserInfo userInfo); +} \ No newline at end of file diff --git a/mall_auth/src/main/java/com/mall/auth/service/AuthService.java b/mall_auth/src/main/java/com/mall/auth/service/AuthService.java new file mode 100644 index 0000000..7f19a8b --- /dev/null +++ b/mall_auth/src/main/java/com/mall/auth/service/AuthService.java @@ -0,0 +1,19 @@ +package com.mall.auth.service; + +import com.mall.common.domain.UserInfo; +import com.mall.common.domain.request.LoginRequest; +import com.mall.common.domain.vo.LoginVo; +import com.mall.common.domain.vo.UserInfoVo; +import com.mall.common.result.Result; + +public interface AuthService { + Result login(LoginVo loginVo); + + Result sendCode(LoginRequest loginRequest); + + Result phoneLogin(LoginRequest loginRequest); + + Result phoneRegister(UserInfoVo userInfo); + + Result userInfo(); +} diff --git a/mall_auth/src/main/java/com/mall/auth/service/impl/AuthServiceImpl.java b/mall_auth/src/main/java/com/mall/auth/service/impl/AuthServiceImpl.java new file mode 100644 index 0000000..765433e --- /dev/null +++ b/mall_auth/src/main/java/com/mall/auth/service/impl/AuthServiceImpl.java @@ -0,0 +1,160 @@ +package com.mall.auth.service.impl; + +import cn.hutool.core.util.RandomUtil; +import cn.hutool.crypto.SecureUtil; +import com.mall.auth.feign.UserServiceFeign; +import com.mall.auth.service.AuthService; +import com.mall.common.constant.JwtConstants; +import com.mall.common.constant.RabbitConstants; +import com.mall.common.constant.TokenConstants; +import com.mall.common.domain.UserInfo; +import com.mall.common.domain.request.LoginRequest; +import com.mall.common.domain.response.JwtResponse; +import com.mall.common.domain.vo.LoginVo; +import com.mall.common.domain.vo.UserInfoVo; +import com.mall.common.redis.RedisCache; +import com.mall.common.result.BizException; +import com.mall.common.result.Result; +import com.mall.common.utils.IdUtils; +import com.mall.common.utils.JwtUtils; +import com.mall.common.utils.StringUtils; +import io.jsonwebtoken.lang.Assert; +import lombok.extern.log4j.Log4j2; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import java.util.Date; +import java.util.HashMap; +import java.util.UUID; +import java.util.concurrent.TimeUnit; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 17:01 + * @Description: TODO + * @Version: 1.0 + */ +@Service +@Log4j2 +public class AuthServiceImpl implements AuthService { + @Resource + private RedisCache redisCache; + @Autowired + private HttpServletRequest request; + @Autowired + private UserServiceFeign userServiceFeign; + @Autowired + private RabbitTemplate rabbitTemplate; + + @Override + public Result login(LoginVo loginVo) { + Result result = userServiceFeign.findLogin(loginVo.getUsername(),loginVo.getPassword()); + UserInfo data = result.getData(); + Assert.notNull( + data,"用户不存在" + ); +// String password = SecureUtil.md5( +// loginVo.getPassword()+ "|" + data.getSalt() +// ); + if (!loginVo.getPassword().equals(data.getPassword())){ + throw new BizException("密码错误"); + } + HashMap map = new HashMap<>(); + map.put(JwtConstants.USER_KEY,data.getId()); + String token = JwtUtils.createToken(map); + redisCache.setCacheObject(TokenConstants.LOGIN_TOKEN_KEY+token,data,TokenConstants.EXPIRATION, TimeUnit.HOURS); + JwtResponse jwtResponse = new JwtResponse(); + jwtResponse.setToken(token); + jwtResponse.setEndTim(TokenConstants.EXPIRATION); + return Result.success(jwtResponse); + } + + @Override + public Result sendCode(LoginRequest loginRequest) { + Result result = userServiceFeign.findPhone(loginRequest.getPhone()); + UserInfo data = result.getData(); + Assert.notNull( + data,"请注册" + ); + String code = RandomUtil.randomNumbers(6); + redisCache.setCacheObject("send_code"+loginRequest.getPhone(),code); + //rabbitTemplate发消息 +// rabbitTemplate.convertAndSend(RabbitConstants.SEND_CODE_BY_PHONE,"",message -> { +// message.getMessageProperties().setMessageId(UUID.randomUUID().toString().replaceAll("-","")); +// return message; +// }); + return Result.success("发送成功，验证码为："+code); + } + + @Override + public Result phoneLogin(LoginRequest loginRequest) { + Result result = userServiceFeign.findPhone(loginRequest.getPhone()); + UserInfo data = result.getData(); + Assert.notNull( + data,"请注册" + ); + if (StringUtils.isAllBlank(loginRequest.getCode(),loginRequest.getCode())){ + throw new BizException(408,"手机号验证码为空"); + } + String code = redisCache.getCacheObject("send_code" + loginRequest.getPhone()); + + if (StringUtils.isBlank(code)){ + throw new BizException(408,"验证码已过期"); + } + if (!loginRequest.getCode().equals(code)){ + throw new BizException(408,"验证码错误"); + } + HashMap map = new HashMap<>(); + String userKey = IdUtils.genId(); + map.put(JwtConstants.USER_KEY,userKey); + String token = JwtUtils.createToken(map); + redisCache.setCacheObject(TokenConstants.LOGIN_TOKEN_KEY+token,data,TokenConstants.EXPIRATION, TimeUnit.HOURS); + JwtResponse jwtResponse = new JwtResponse(); + jwtResponse.setToken(token); + jwtResponse.setEndTim(TokenConstants.EXPIRATION); + return Result.success(jwtResponse); + } + + @Override + public Result phoneRegister(UserInfoVo userInfoVo) { + String salt = RandomUtil.randomNumbers(6); + String password = SecureUtil.md5(userInfoVo.getPassword()+ "|" + salt); + UserInfo userInfo = UserInfo.builder() + .username(userInfoVo.getUsername()) + .password(password) + .salt(salt) + .nickname(userInfoVo.getNickname()) + .phone(userInfoVo.getPhone()) + .email(userInfoVo.getEmail()) + .header(userInfoVo.getHeader()) + .gender(userInfoVo.getGender()) + .birthday(userInfoVo.getBirthday()) + .city(userInfoVo.getCity()) + .role(userInfoVo.getRole()) + .sign(userInfoVo.getSign()) + .sourceType(userInfoVo.getSourceType()) + .integration(userInfoVo.getIntegration()) + .status(userInfoVo.getStatus()) + .identityFront(userInfoVo.getIdentityFront()) + .identityReverse(userInfoVo.getIdentityReverse()) + .identityAuthentication(userInfoVo.getIdentityAuthentication()) + .checkState(userInfoVo.getCheckState()) + .createTime(new Date()) + .build(); + userServiceFeign.register(userInfo); + return Result.success("注册成功"); + } + + @Override + public Result userInfo() { + String token = request.getHeader(TokenConstants.LOGIN_TOKEN_KEY); + if (StringUtils.isBlank(token)){ + throw new BizException(401,"未登录"); + } + UserInfo userInfo = redisCache.getCacheObject(TokenConstants.LOGIN_TOKEN_KEY + token); + return Result.success(userInfo); + } +} \ No newline at end of file diff --git a/mall_common/pom.xml b/mall_common/pom.xml index 718655c..2002848 100644 --- a/mall_common/pom.xml +++ b/mall_common/pom.xml @@ -78,12 +78,12 @@ - - - - - - + + cn.hutool + hutool-all + 4.1.1 + + com.alibaba.fastjson2 fastjson2 @@ -153,6 +153,21 @@ tomcat-embed-core 9.0.83 + + + org.springframework.boot + spring-boot-starter-amqp + + + redis.clients + jedis + 3.8.0 + + + com.aliyun + dysmsapi20170525 + 2.0.1 + diff --git a/mall_common/src/main/java/com/mall/common/domain/UserInfo.java b/mall_common/src/main/java/com/mall/common/domain/UserInfo.java new file mode 100644 index 0000000..84b3277 --- /dev/null +++ b/mall_common/src/main/java/com/mall/common/domain/UserInfo.java @@ -0,0 +1,107 @@ +package com.mall.common.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.models.auth.In; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.Date; + +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +@TableName("user_info") +public class UserInfo { + +/** + * id + */ + @TableId(type = IdType.AUTO) + private Long id; + /** + * 用户名 + */ + private String username; + /** + * 密码 + */ + private String password; + /** + * 盐 + */ + private String salt; + /** + * 昵称 + */ + private String nickname; + /** + * 手机号 + */ + private String phone; + /** + * 邮箱 + */ + private String email; + /** + * 头像 + */ + private String header; + /** + * 性别 + */ + private Integer gender; + /** + * 生日 + */ + private Date birthday; + /** + * 城市 + */ + private String city; + /** + * 角色 + */ + private String role; + /** + * 个性签名 + */ + private String sign; + /** + * 来源 + */ + private Integer sourceType; + /** + * 积分 + */ + private int integration; + /** + * 用户状态 + */ + private Integer status; + /** + * 身份证正面 + */ + private String identityFront; + /** + * 身份证反面 + */ + private String identityReverse; + /** + * 身份证视频认证 + */ + private String identityAuthentication; + /** + * 审核状态 + */ + private Integer checkState; + /** + * 注册时间 + */ + private Date createTime; +} diff --git a/mall_common/src/main/java/com/mall/common/domain/request/LoginRequest.java b/mall_common/src/main/java/com/mall/common/domain/request/LoginRequest.java new file mode 100644 index 0000000..4bfdb5b --- /dev/null +++ b/mall_common/src/main/java/com/mall/common/domain/request/LoginRequest.java @@ -0,0 +1,15 @@ +package com.mall.common.domain.request; + +import lombok.Data; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 18:48 + * @Description: TODO + * @Version: 1.0 + */ +@Data +public class LoginRequest { + private String phone; + private String code; +} diff --git a/mall_common/src/main/java/com/mall/common/domain/response/JwtResponse.java b/mall_common/src/main/java/com/mall/common/domain/response/JwtResponse.java new file mode 100644 index 0000000..617e7f9 --- /dev/null +++ b/mall_common/src/main/java/com/mall/common/domain/response/JwtResponse.java @@ -0,0 +1,21 @@ +package com.mall.common.domain.response; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 18:34 + * @Description: TODO + * @Version: 1.0 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class JwtResponse { + private String token; + private Long endTim; +} diff --git a/mall_common/src/main/java/com/mall/common/domain/vo/LoginVo.java b/mall_common/src/main/java/com/mall/common/domain/vo/LoginVo.java new file mode 100644 index 0000000..1f103cf --- /dev/null +++ b/mall_common/src/main/java/com/mall/common/domain/vo/LoginVo.java @@ -0,0 +1,15 @@ +package com.mall.common.domain.vo; + +import lombok.Data; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 17:03 + * @Description: TODO + * @Version: 1.0 + */ +@Data +public class LoginVo { + private String username; + private String password; +} diff --git a/mall_common/src/main/java/com/mall/common/domain/vo/UserInfoVo.java b/mall_common/src/main/java/com/mall/common/domain/vo/UserInfoVo.java new file mode 100644 index 0000000..63b264d --- /dev/null +++ b/mall_common/src/main/java/com/mall/common/domain/vo/UserInfoVo.java @@ -0,0 +1,105 @@ +package com.mall.common.domain.vo; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.Date; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 19:45 + * @Description: TODO + * @Version: 1.0 + */ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class UserInfoVo { + /** + * id + */ + private Long id; + /** + * 用户名 + */ + private String username; + /** + * 密码 + */ + private String password; + /** + * 盐 + */ + private String salt; + /** + * 昵称 + */ + private String nickname; + /** + * 手机号 + */ + private String phone; + /** + * 邮箱 + */ + private String email; + /** + * 头像 + */ + private String header; + /** + * 性别 + */ + private Integer gender; + /** + * 生日 + */ + private Date birthday; + /** + * 城市 + */ + private String city; + /** + * 角色 + */ + private String role; + /** + * 个性签名 + */ + private String sign; + /** + * 来源 + */ + private Integer sourceType; + /** + * 积分 + */ + private int integration; + /** + * 用户状态 + */ + private Integer status; + /** + * 身份证正面 + */ + private String identityFront; + /** + * 身份证反面 + */ + private String identityReverse; + /** + * 身份证视频认证 + */ + private String identityAuthentication; + /** + * 审核状态 + */ + private Integer checkState; + /** + * 注册时间 + */ + private Date createTime; +} diff --git a/mall_common/src/main/java/com/mall/common/utils/TelSmsUtils.java b/mall_common/src/main/java/com/mall/common/utils/TelSmsUtils.java new file mode 100644 index 0000000..7b01793 --- /dev/null +++ b/mall_common/src/main/java/com/mall/common/utils/TelSmsUtils.java @@ -0,0 +1,87 @@ +package com.mall.common.utils; + +import com.alibaba.fastjson.JSONObject; +import com.aliyun.dysmsapi20170525.Client; +import com.aliyun.dysmsapi20170525.models.SendSmsRequest; +import com.aliyun.dysmsapi20170525.models.SendSmsResponse; +import com.aliyun.teaopenapi.models.Config; +import lombok.extern.log4j.Log4j2; + +import java.util.Map; + +/** + * 短信工具类 + */ +@Log4j2 +public class TelSmsUtils { + + /** + * 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限 + */ + private static String accessKeyId = "LTAIEVXszCmcd1T5"; + private static String accessKeySecret = "2zHwciQXln8wExSEnkIYtRTSwLeRNd"; + + /** + * 短信访问域名 + */ + private static String endpoint = "dysmsapi.aliyuncs.com"; + /** + * 短信签名 + */ + private static String signName = "登录验证"; + + /** + * 实例化短信对象 + */ + private static Client client; + + static { + log.info("初始化短信服务开始"); + long startTime = System.currentTimeMillis(); + try { + client = initClient(); + log.info("初始化短信成功：{}",signName); + } catch (Exception e) { + e.printStackTrace(); + } + log.info("初始化短信服务结束：耗时：{}MS",(System.currentTimeMillis()-startTime)); + } + /** + * 初始化短信对象 + * @return + * @throws Exception + */ + private static Client initClient() throws Exception{ + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(accessKeyId) + // 您的AccessKey Secret + .setAccessKeySecret(accessKeySecret); + // 访问的域名 + config.endpoint = endpoint; + return new Client(config); + } + + /** + * 发送单条短信 + * @param tel + * @param templateCode SMS_153991546 + * @param sendDataMap + */ + public static String sendSms(String tel , String templateCode , Map sendDataMap){ + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(tel) + .setSignName(signName) + .setTemplateCode(templateCode) + .setTemplateParam(JSONObject.toJSONString(sendDataMap)); + SendSmsResponse sendSmsResponse = null; + try { + log.info("发送短信验证码：消息内容是：【{}】", JSONObject.toJSONString(sendDataMap)); + sendSmsResponse = client.sendSms(sendSmsRequest); + } catch (Exception e) { + log.error("短信发送异常，手机号：【{}】，短信内容：【{}】，异常信息：【{}】", tel, sendDataMap, e); + } + return JSONObject.toJSONString(sendSmsResponse.getBody()); + } + +} diff --git a/mall_modules/mall_system/src/main/java/com/mall/system/controller/UserController.java b/mall_modules/mall_system/src/main/java/com/mall/system/controller/UserController.java new file mode 100644 index 0000000..8e396c7 --- /dev/null +++ b/mall_modules/mall_system/src/main/java/com/mall/system/controller/UserController.java @@ -0,0 +1,55 @@ +package com.mall.system.controller; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.mall.common.domain.UserInfo; +import com.mall.common.result.Result; +import com.mall.system.service.UserService; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 17:05 + * @Description: TODO + * @Version: 1.0 + */ +@RestController +public class UserController { + + @Resource + private UserService userService; + + /** + * 查询用户名和密码 + * @return userInfo + */ + @PostMapping("findLogin/{username}/{password}") + public Result findLogin(@PathVariable String username, @PathVariable String password){ + LambdaQueryWrapper userInfoLambdaQueryWrapper = new LambdaQueryWrapper<>(); + userInfoLambdaQueryWrapper.eq(UserInfo::getUsername,username) + .eq(UserInfo::getPassword,password); + UserInfo userInfo = userService.getOne(userInfoLambdaQueryWrapper); + return Result.success(userInfo); + } + + /** + * 查询手机号 + * @return userInfo + */ + @GetMapping("findPhone/{phone}") + public Result findPhone(@PathVariable("phone") String phone){ + Result result = userService.findPhone(phone); + return result; + } + + /** + * 注册 + * @return userInfo + */ + @PostMapping("register") + public Result register(@RequestBody UserInfo userInfo){ + userService.register(userInfo); + return Result.success(); + } +} diff --git a/mall_modules/mall_system/src/main/java/com/mall/system/mapper/UserMapper.java b/mall_modules/mall_system/src/main/java/com/mall/system/mapper/UserMapper.java new file mode 100644 index 0000000..8f02902 --- /dev/null +++ b/mall_modules/mall_system/src/main/java/com/mall/system/mapper/UserMapper.java @@ -0,0 +1,15 @@ +package com.mall.system.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.mall.common.domain.UserInfo; +import org.mapstruct.Mapper; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 17:13 + * @Description: TODO + * @Version: 1.0 + */ +@Mapper +public interface UserMapper extends BaseMapper { +} diff --git a/mall_modules/mall_system/src/main/java/com/mall/system/service/UserService.java b/mall_modules/mall_system/src/main/java/com/mall/system/service/UserService.java new file mode 100644 index 0000000..1b57912 --- /dev/null +++ b/mall_modules/mall_system/src/main/java/com/mall/system/service/UserService.java @@ -0,0 +1,12 @@ +package com.mall.system.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.mall.common.domain.UserInfo; +import com.mall.common.result.Result; + +public interface UserService extends IService { + + Result findPhone(String phone); + + void register(UserInfo userInfo); +} \ No newline at end of file diff --git a/mall_modules/mall_system/src/main/java/com/mall/system/service/impl/UserServiceImpl.java b/mall_modules/mall_system/src/main/java/com/mall/system/service/impl/UserServiceImpl.java new file mode 100644 index 0000000..e74d73f --- /dev/null +++ b/mall_modules/mall_system/src/main/java/com/mall/system/service/impl/UserServiceImpl.java @@ -0,0 +1,41 @@ +package com.mall.system.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.mall.common.domain.UserInfo; +import com.mall.common.result.Result; +import com.mall.system.mapper.UserMapper; +import com.mall.system.service.UserService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +/** + * @Author: lzh + * @CreateTime: 2024-04-22 17:06 + * @Description: TODO + * @Version: 1.0 + */ +@Service +public class UserServiceImpl extends ServiceImpl + implements UserService { + @Resource + private UserMapper userMapper; + + @Override + public Result findPhone(String phone) { + UserInfo userInfo = this.getOne(new QueryWrapper().lambda() + .eq(UserInfo::getPhone, phone)); + return Result.success(userInfo); + } + + @Override + public void register(UserInfo userInfo) { + //校验手机号 + if (this.getOne(new QueryWrapper().lambda() + .eq(UserInfo::getPhone, userInfo.getPhone())) != null) { + throw new RuntimeException("手机号已存在"); + } + this.save(userInfo); + } +}