commit f0b65297417eb5b0075e695838cf4df2bc76728e Author: 张小东 <13396135+anton-aoi@user.noreply.gitee.com> Date: Thu Oct 19 22:43:18 2023 +0800 实现药品列表 实现药品分类 图片上传 banner图实现 diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..94a25f7 --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/bwie-auth/pom.xml b/bwie-auth/pom.xml new file mode 100644 index 0000000..dc3beb9 --- /dev/null +++ b/bwie-auth/pom.xml @@ -0,0 +1,54 @@ + + + 4.0.0 + + org.example + health-zxd + 1.0-SNAPSHOT + + + bwie-auth + + + 8 + 8 + UTF-8 + + + + + org.example + bwie-common + 1.0-SNAPSHOT + + + + org.springframework.boot + spring-boot-starter-web + + + + org.springframework.boot + spring-boot-starter-amqp + + + org.springframework.boot + spring-boot-starter-test + + + org.springframework.kafka + spring-kafka + + + org.apache.kafka + kafka-clients + + + + org.projectlombok + lombok + + + diff --git a/bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java b/bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java new file mode 100644 index 0000000..858bacd --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java @@ -0,0 +1,52 @@ +package com.bwie.auth.controller; + +import com.alibaba.fastjson.JSONObject; +import com.bwie.auth.service.AuthService; + + +import com.bwie.common.domain.User; +import com.bwie.common.domain.request.UserLogin; +import com.bwie.common.domain.response.JwtResponse; +import com.bwie.common.result.Result; +import lombok.extern.log4j.Log4j2; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +import javax.servlet.http.HttpServletRequest; + +@Log4j2 +@RestController +@Component +public class AuthController { + @Autowired + private AuthService service; + @Autowired + private HttpServletRequest request; + + @PostMapping("/userLogin") + public Result userLogin(@RequestBody UserLogin login){ + log.info("功能名称：【邮箱密码登录】，请求路径：【{}】，请求方式：【{}】，请求参数：【{}】", + request.getRequestURI(),request.getMethod(), JSONObject.toJSONString(login)); + Result result = service.userLogin(login); + log.info("返回结果：【{}】",result); + return result; + } + + @GetMapping("/info") + public Result info(){ + log.info("功能名称：【获取token】，请求路径：【{}】，请求方式：【{}】", + request.getRequestURI(),request.getMethod()); + Result result = service.info(); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/logout") + public Result logout(){ + return service.logout(); + } +} diff --git a/bwie-auth/src/main/java/com/bwie/auth/feign/AuthFeign.java b/bwie-auth/src/main/java/com/bwie/auth/feign/AuthFeign.java new file mode 100644 index 0000000..ddec0b7 --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/feign/AuthFeign.java @@ -0,0 +1,13 @@ +package com.bwie.auth.feign; + +import com.bwie.common.domain.User; +import com.bwie.common.result.Result; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; + +@FeignClient("bwie-system") +public interface AuthFeign { + @PostMapping("/getUserByEmailNumber/{emailNumber}") + public Result getUserByEmailNumber(@PathVariable String emailNumber); +} diff --git a/bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java b/bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java new file mode 100644 index 0000000..5b90449 --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java @@ -0,0 +1,13 @@ +package com.bwie.auth.service; + +import com.bwie.common.domain.request.UserLogin; +import com.bwie.common.domain.response.JwtResponse; +import com.bwie.common.result.Result; + +public interface AuthService { + Result userLogin(UserLogin login); + + Result info(); + + Result logout(); +} diff --git a/bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java b/bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java new file mode 100644 index 0000000..374af67 --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java @@ -0,0 +1,82 @@ +package com.bwie.auth.service.impl; + +import com.alibaba.fastjson.JSONObject; +import com.bwie.auth.feign.AuthFeign; +import com.bwie.auth.service.AuthService; +import com.bwie.common.constants.JwtConstants; +import com.bwie.common.constants.TokenConstants; +import com.bwie.common.domain.User; +import com.bwie.common.domain.request.UserLogin; +import com.bwie.common.domain.response.JwtResponse; +import com.bwie.common.result.Result; +import com.bwie.common.utils.JwtUtils; +import com.bwie.common.utils.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.stereotype.Service; + +import javax.servlet.http.HttpServletRequest; +import java.util.HashMap; +import java.util.UUID; +import java.util.concurrent.TimeUnit; +import java.util.regex.Pattern; + +@Service +public class AuthServiceImpl implements AuthService { + @Autowired + private AuthFeign feign; + @Autowired + private RedisTemplate redisTemplate; + @Autowired + private HttpServletRequest request; + + @Override + public Result userLogin(UserLogin login) { + boolean emailMatches = Pattern.matches("^[0-9a-zA-Z_-]+@[0-9a-zA-Z_-]+\\.(com|cn|net|vip|cloud)$",login.getEmailNumber()); + if (!emailMatches) { + throw new IllegalArgumentException("邮箱格式错误，请重新输入"); + } + Result user = feign.getUserByEmailNumber(login.getEmailNumber()); + User data = user.getData(); + if (null==data){ + return Result.error("对不起您还未注册，请先注册完成后进行登录"); + } + if (!login.getPassword().equals(data.getPassword())){ + return Result.error("密码错误"); + } + + HashMap map = new HashMap<>(); + String userKey = UUID.randomUUID().toString(); + map.put(JwtConstants.USER_KEY,userKey); + map.put(JwtConstants.DETAILS_USER_ID,data.getUserId()); + String token = JwtUtils.createToken(map); + redisTemplate.opsForValue().set(TokenConstants.LOGIN_TOKEN_KEY+userKey, JSONObject.toJSONString(data),1500, TimeUnit.MINUTES); + JwtResponse jwtResponse = new JwtResponse(); + jwtResponse.setToken(token); + return Result.success(jwtResponse); + } + + @Override + public Result info() { + String token = request.getHeader(TokenConstants.TOKEN); + + // 添加参数校验 + if (StringUtils.isBlank(token)) { + // Token为空，可以根据业务需求返回错误信息或进行其他处理 + return Result.error("Token cannot be null or empty"); + } + String userKey = JwtUtils.getUserKey(token); + String s = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey); + User user = JSONObject.parseObject(s, User.class); + System.out.println(userKey); + return Result.success(user); + } + + @Override + public Result logout() { + String token = request.getHeader(TokenConstants.TOKEN); + String userKey = JwtUtils.getUserKey(token); + redisTemplate.delete(TokenConstants.LOGIN_TOKEN_KEY+userKey); + return Result.success("退出成功"); + } +} diff --git a/bwie-auth/src/main/resources/bootstrap.yml b/bwie-auth/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..f1b2f8d --- /dev/null +++ b/bwie-auth/src/main/resources/bootstrap.yml @@ -0,0 +1,59 @@ +# Tomcat +server: + port: 9001 +# Spring +spring: + main: + allow-circular-references: true + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + application: + # 应用名称 + name: bwie-auth + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 106.54.220.85:8848 + config: + # 配置中心地址 + server-addr: 106.54.220.85:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} + rabbitmq: + host: 106.54.220.85 + port: 5672 + username: guest + password: guest + virtual-host: / + publisher-confirm-type: correlated #确认消息已发送到交换机(Exchange) + publisher-returns: true #确认消息已发送到队列(Queue) + listener: + simple: + prefetch: 1 # 每次只能获取一条，处理完成才能获取下一条 + acknowledge-mode: manual # 设置消费端手动ack确认 + retry: + enabled: true # 是否支持重试 + template: + # 只要消息抵达Queue，就会异步发送优先回调return firm + mandatory: true + kafka: + bootstrap-servers: 106.54.220.85:9092 + producer: + key-serializer: org.apache.kafka.common.serialization.StringSerializer + value-serializer: org.apache.kafka.common.serialization.StringSerializer + retries: 3 + acks: all + compression-type: lz4 + consumer: + key-deserializer: org.apache.kafka.common.serialization.StringDeserializer + value-deserializer: org.apache.kafka.common.serialization.StringDeserializer + group-id: bw-gp + enable-auto-commit: false diff --git a/bwie-common/src/main/java/com/bwie/common/domain/Banner.java b/bwie-common/src/main/java/com/bwie/common/domain/Banner.java new file mode 100644 index 0000000..2f8365c --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/Banner.java @@ -0,0 +1,9 @@ +package com.bwie.common.domain; + +import lombok.Data; + +@Data +public class Banner { + private Integer bannerId; + private String bannerImage; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/DrugType.java b/bwie-common/src/main/java/com/bwie/common/domain/DrugType.java new file mode 100644 index 0000000..26671c4 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/DrugType.java @@ -0,0 +1,9 @@ +package com.bwie.common.domain; + +import lombok.Data; + +@Data +public class DrugType { + private Integer drugTypeId; + private String drugTypeName; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/SymptomDetails.java b/bwie-common/src/main/java/com/bwie/common/domain/SymptomDetails.java new file mode 100644 index 0000000..8e0d5fe --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/SymptomDetails.java @@ -0,0 +1,16 @@ +package com.bwie.common.domain; + +import lombok.Data; + +@Data +public class SymptomDetails { + private Integer detailsId; + private Integer symptomId; + private String symptomName; + private String pathology; + private String symptom; + private String suitableFood; + private String avoidFood; + private String traditionalMedicineTreatment; + private String westernMedicineTreatment; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/request/UserLogin.java b/bwie-common/src/main/java/com/bwie/common/domain/request/UserLogin.java new file mode 100644 index 0000000..6865a44 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/request/UserLogin.java @@ -0,0 +1,9 @@ +package com.bwie.common.domain.request; + +import lombok.Data; + +@Data +public class UserLogin { + private String emailNumber; + private String password; +} diff --git a/bwie-modules/bwie-system/pom.xml b/bwie-modules/bwie-system/pom.xml new file mode 100644 index 0000000..1ca672b --- /dev/null +++ b/bwie-modules/bwie-system/pom.xml @@ -0,0 +1,62 @@ + + + 4.0.0 + + org.example + health-zxd + 1.0-SNAPSHOT + ../../pom.xml + + + bwie-system + + + 8 + 8 + UTF-8 + + + + + org.example + bwie-common + 1.0-SNAPSHOT + + + + org.springframework.boot + spring-boot-starter-web + + + + com.alibaba + druid-spring-boot-starter + 1.2.8 + + + + mysql + mysql-connector-java + + + + org.mybatis.spring.boot + mybatis-spring-boot-starter + 2.2.2 + + + + com.github.pagehelper + pagehelper-spring-boot-starter + 1.4.1 + + + org.example + bwie-common + 1.0-SNAPSHOT + compile + + + diff --git a/bwie-modules/bwie-system/src/main/java/com/bwie/system/controller/SystemController.java b/bwie-modules/bwie-system/src/main/java/com/bwie/system/controller/SystemController.java new file mode 100644 index 0000000..14467dd --- /dev/null +++ b/bwie-modules/bwie-system/src/main/java/com/bwie/system/controller/SystemController.java @@ -0,0 +1,107 @@ +package com.bwie.system.controller; + +import com.bwie.common.domain.*; +import com.bwie.common.result.Result; +import com.bwie.system.service.SystemService; +import lombok.extern.log4j.Log4j2; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Bean; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; + +import javax.servlet.http.HttpServletRequest; +import java.util.List; + +@RestController +@Log4j2 +public class SystemController { + @Autowired + private SystemService service; + @Autowired + private HttpServletRequest request; + + @PostMapping("/getUserByEmailNumber/{emailNumber}") + public Result getUserByEmailNumber(@PathVariable String emailNumber){ + log.info("功能名称：【根据邮箱账号】，请求路径：【{}】,请求发送：【{}】，请求参数：【{}】", + request.getRequestURI(),request.getMethod(),emailNumber); + Result result = service.getUserByEmailNumber(emailNumber); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/departmentList") + public Result> departmentList(){ + log.info("功能名称：【科室列表】，请求路径：【{}】,请求发送：【{}】", + request.getRequestURI(),request.getMethod()); + Result> result = service.departmentList(); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/findSymptomByDepartmentId/{departmentId}") + public Result> findSymptomByDepartmentId (@PathVariable Integer departmentId){ + log.info("功能名称：【病状列表】，请求路径：【{}】,请求发送：【{}】,请求参数：【{}】", + request.getRequestURI(),request.getMethod(),departmentId); + Result> result = service.findSymptomByDepartmentId(departmentId); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/findSymptomDetailsByDepartmentId/{symptomId}") + public Result findSymptomDetailsByDepartmentId (@PathVariable Integer symptomId){ + log.info("功能名称：【病状详情列表】，请求路径：【{}】,请求发送：【{}】,请求参数：【{}】", + request.getRequestURI(),request.getMethod(),symptomId); + Result result = service.findSymptomDetailsByDepartmentId(symptomId); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/ossUpLoad") + public Result ossUpLoad(@RequestParam("file") MultipartFile file){ + log.info("功能名称：【图片上传】，请求路径：【{}】,请求发送：【{}】,请求参数：【{}】", + request.getRequestURI(),request.getMethod(),file); + Result result = service.ossUpLoad(file); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/bannerList") + public Result> bannerList(){ + log.info("功能名称：【banner列表】，请求路径：【{}】,请求发送：【{}】", + request.getRequestURI(),request.getMethod()); + Result> result = service.bannerList(); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/drugTypeList") + public Result> drugTypeList(){ + log.info("功能名称：【药品类型列表】，请求路径：【{}】,请求发送：【{}】", + request.getRequestURI(),request.getMethod()); + Result> result = service.drugTypeList(); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/findDrugByDrugTypeId/{drugTypeId}") + public Result> findDrugByDrugTypeId(@PathVariable Integer drugTypeId){ + log.info("功能名称：【药品列表】，请求路径：【{}】,请求发送：【{}】,请求参数：【{}】", + request.getRequestURI(),request.getMethod(),drugTypeId); + Result> result = service.findDrugByDrugTypeId(drugTypeId); + log.info("返回结果：【{}】",result); + return result; + } + + @PostMapping("/findDrugDetailsByDrugId/{drugId}") + public Result> findDrugDetailsByDrugId(@PathVariable Integer drugId){ + log.info("功能名称：【可用药品】，请求路径：【{}】,请求发送：【{}】,请求参数：【{}】", + request.getRequestURI(),request.getMethod(),drugId); + Result> result = service.findDrugDetailsByDrugId(drugId); + log.info("返回结果：【{}】",result); + return result; + } + +} diff --git a/bwie-modules/bwie-system/src/main/java/com/bwie/system/mapper/SystemMapper.java b/bwie-modules/bwie-system/src/main/java/com/bwie/system/mapper/SystemMapper.java new file mode 100644 index 0000000..deafde0 --- /dev/null +++ b/bwie-modules/bwie-system/src/main/java/com/bwie/system/mapper/SystemMapper.java @@ -0,0 +1,30 @@ +package com.bwie.system.mapper; + +import com.bwie.common.domain.*; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; +import org.springframework.stereotype.Repository; + +import java.util.List; + +@Mapper +@Repository +public interface SystemMapper { + + + List departmentList(); + + List findSymptomByDepartmentId(@Param("departmentId") Integer departmentId); + + SymptomDetails findSymptomDetailsByDepartmentId(@Param("symptomId") Integer symptomId); + + List bannerList(); + + User getUser(@Param("emailNumber") String emailNumber); + + List drugTypeList(); + + List findDrugByDrugTypeId(@Param("drugTypeId") Integer drugTypeId); + + List findDrugDetailsByDrugId(@Param("drugId") Integer drugId); +} diff --git a/bwie-modules/bwie-system/src/main/java/com/bwie/system/service/SystemService.java b/bwie-modules/bwie-system/src/main/java/com/bwie/system/service/SystemService.java new file mode 100644 index 0000000..cca2323 --- /dev/null +++ b/bwie-modules/bwie-system/src/main/java/com/bwie/system/service/SystemService.java @@ -0,0 +1,27 @@ +package com.bwie.system.service; + +import com.bwie.common.domain.*; +import com.bwie.common.result.Result; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +public interface SystemService { + Result getUserByEmailNumber(String emailNumber); + + Result> departmentList(); + + Result> findSymptomByDepartmentId(Integer departmentId); + + Result findSymptomDetailsByDepartmentId(Integer symptomId); + + Result ossUpLoad(MultipartFile file); + + Result> bannerList(); + + Result> drugTypeList(); + + Result> findDrugByDrugTypeId(Integer drugTypeId); + + Result> findDrugDetailsByDrugId(Integer drugId); +} diff --git a/bwie-modules/bwie-system/src/main/java/com/bwie/system/service/impl/SystemServiceImpl.java b/bwie-modules/bwie-system/src/main/java/com/bwie/system/service/impl/SystemServiceImpl.java new file mode 100644 index 0000000..e213ee2 --- /dev/null +++ b/bwie-modules/bwie-system/src/main/java/com/bwie/system/service/impl/SystemServiceImpl.java @@ -0,0 +1,81 @@ +package com.bwie.system.service.impl; + +import com.bwie.common.domain.*; +import com.bwie.common.result.Result; +import com.bwie.common.utils.OssUtil; +import com.bwie.system.mapper.SystemMapper; +import com.bwie.system.service.SystemService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.web.multipart.MaxUploadSizeExceededException; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + + +@Service +public class SystemServiceImpl implements SystemService { + @Autowired + private SystemMapper mapper; + @Override + public Result getUserByEmailNumber(String emailNumber) { + User user1 = mapper.getUser(emailNumber); + return Result.success(user1); + } + + @Override + public Result> departmentList() { + List departments = mapper.departmentList(); + return Result.success(departments); + } + + @Override + public Result> findSymptomByDepartmentId(Integer departmentId) { + List symptom = mapper.findSymptomByDepartmentId(departmentId); + return Result.success(symptom); + } + + @Override + public Result findSymptomDetailsByDepartmentId(Integer symptomId) { + SymptomDetails details = mapper.findSymptomDetailsByDepartmentId(symptomId); + return Result.success(details); + } + + @Override + public Result ossUpLoad(MultipartFile file) { + if (file.isEmpty()){ + return Result.error("文件不能为空"); + } + try { + String s = OssUtil.uploadMultipartFile(file); + return Result.success(s); + } catch (MaxUploadSizeExceededException e) { + e.printStackTrace(); + return Result.error("上传的文件大小超过了20MB，请选择大小不超过20MB的文件上传"); + } + } + + @Override + public Result> bannerList() { + List banners = mapper.bannerList(); + return Result.success(banners); + } + + @Override + public Result> drugTypeList() { + List drugTypes = mapper.drugTypeList(); + return Result.success(drugTypes); + } + + @Override + public Result> findDrugByDrugTypeId(Integer drugTypeId) { + List drugs = mapper.findDrugByDrugTypeId(drugTypeId); + return Result.success(drugs); + } + + @Override + public Result> findDrugDetailsByDrugId(Integer drugId) { + List drugDetails = mapper.findDrugDetailsByDrugId(drugId); + return Result.success(drugDetails); + } +} diff --git a/bwie-modules/bwie-system/src/main/resources/bootstrap.yml b/bwie-modules/bwie-system/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..8fac886 --- /dev/null +++ b/bwie-modules/bwie-system/src/main/resources/bootstrap.yml @@ -0,0 +1,31 @@ +# Tomcat +server: + port: 9002 + +# Spring +spring: + main: + allow-circular-references: true + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + application: + # 应用名称 + name: bwie-system + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 106.54.220.85:8848 + config: + # 配置中心地址 + server-addr: 106.54.220.85:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} + diff --git a/bwie-modules/bwie-system/src/main/resources/mapper/SystemMapper.xml b/bwie-modules/bwie-system/src/main/resources/mapper/SystemMapper.xml new file mode 100644 index 0000000..878267a --- /dev/null +++ b/bwie-modules/bwie-system/src/main/resources/mapper/SystemMapper.xml @@ -0,0 +1,94 @@ + + + + + + + + + + + + + + +