尚医通-day14【创建订单】（内附源码）

宁睿  金牌会员 | 2023-6-19 21:37:46 | 来自手机 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 965|帖子 965|积分 2905

页面预览

订单详情



订单列表


第01章-创建订单

生成订单分析

  • 生成订单方法参数：就诊人id与 排班id
  • 生成订单需要获取就诊人信息（微服务远程调用service-user）
  • 获取排班信息与规则信息（微服务远程调用service-hosp）
  • 下单后，通过接口去医院预约下单（httpclient远程调用医院端的接口）
  • 下单成功更新排班信息并发送短信（向mq发送信息）
1、创建订单微服务

1.1、创建数据库

资料：资料>订单微服务>guigu_syt_order.sql
1.2、创建service-order微服务

在service模块下创建service-order模块

1.3、添加依赖

在service-order中添加依赖：
  1. <dependencies>
  2.    
  3.     <dependency>
  4.         <groupId>com.atguigu</groupId>
  5.         <artifactId>model</artifactId>
  6.         <version>1.0</version>
  7.     </dependency>
  9.    
  10.     <dependency>
  11.         <groupId>com.atguigu</groupId>
  12.         <artifactId>service-util</artifactId>
  13.         <version>1.0</version>
  14.     </dependency>
  16.    
  17.     <dependency>
  18.         <groupId>com.atguigu</groupId>
  19.         <artifactId>spring-security</artifactId>
  20.         <version>1.0</version>
  21.     </dependency>
  23.    
  24.     <dependency>
  25.         <groupId>mysql</groupId>
  26.         <artifactId>mysql-connector-java</artifactId>
  27.     </dependency>
  28.    
  29.    
  30.     <dependency>
  31.         <groupId>joda-time</groupId>
  32.         <artifactId>joda-time</artifactId>
  33.     </dependency>
  35.    
  36.     <dependency>
  37.         <groupId>org.springframework.boot</groupId>
  38.         <artifactId>spring-boot-starter-test</artifactId>
  39.         <scope>test</scope>
  40.     </dependency>
  41. </dependencies>
复制代码
1.4、使用代码生成器

找到service-util模块中的代码生成器，修改moduleName为order，并执行，然后删除entity包，相关类中引入model模块中的类
1.5、创建配置文件

在server-order模块中resources目录下创建文件
application.yml：
  1. spring:
  2.   application:
  3.     name: service-order
  4.   profiles:
  5.     active: dev,redis
复制代码
application-dev.yml：
  1. mybatis-plus:
  2.   configuration:
  3.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  4.   mapper-locations: classpath:com/atguigu/syt/order/mapper/xml/*.xml
  5. server:
  6.   port: 8205
  7. spring:
  8.   cloud:
  9.     nacos:
  10.       discovery:
  11.         server-addr: 127.0.0.1:8848
  12.   datasource:
  13.     driver-class-name: com.mysql.cj.jdbc.Driver
  14.     password: 123456
  15.     url: jdbc:mysql://localhost:3306/guigu_syt_order?characterEncoding=utf-8&serverTimezone=GMT%2B8&useSSL=false
  16.     username: root
  17.   jackson:
  18.     date-format: yyyy-MM-dd HH:mm:ss
  19.     time-zone: GMT+8
  21. logging:
  22.   level:
  23.     root: info
  24.   file:
  25.     path: order
  27. feign:
  28.   client:
  29.     config:
  30.       default:
  31.         connect-timeout: 2000 #连接建立的超时时长，单位是ms，默认1s
  32.         read-timeout: 2000 #处理请求的超时时间，单位是ms，默认为1s
  34.   sentinel:
  35.     enabled: true #开启Feign对Sentinel的支持
复制代码
1.6、配置网关

在server-gateway中配置网关路由
  1.         - id: service-order
  2.           predicates: Path=/*/order/**
  3.           uri: lb://service-order
复制代码
1.7、创建启动类
  1. package com.atguigu.syt.order;
  3. @SpringBootApplication
  4. @ComponentScan(basePackages = {"com.atguigu"})
  5. @EnableFeignClients("com.atguigu.syt")
  6. public class ServiceOrderApplication {
  7.     public static void main(String[] args) {
  8.         SpringApplication.run(ServiceOrderApplication.class, args);
  9.     }
  10. }
复制代码
2、获取就诊人接口

2.1、Controller

在service-user模块创建controller.inner包，创建InnerPatientController类
  1. package com.atguigu.syt.user.controller.inner;
  3. @Api(tags = "就诊人接口-供其他微服务远程调用")
  4. @RestController
  5. @RequestMapping("/inner/user/patient")
  6. public class InnerPatientController {
  8.     @Resource
  9.     private PatientService patientService;
  11.     @ApiOperation("获取就诊人")
  12.     @ApiImplicitParam(name = "id",value = "就诊人id", required = true)
  13.     @GetMapping("/get/{id}")
  14.     public Patient getPatient(@PathVariable("id") Long id) {
  15.         return patientService.getById(id);
  16.     }
  17. }
复制代码
2.2、创建service-user-client模块

在service-client下创建service-user-client
在service-client中添加依赖
  1. <dependency>
  2.     <groupId>com.atguigu</groupId>
  3.     <artifactId>model</artifactId>
  4.     <version>1.0</version>
  5. </dependency>
复制代码
2.3、创建Feign接口

在service-user-client中创建接口
  1. package com.atguigu.syt.user.client;
  3. @FeignClient(
  4.         value = "service-user",
  5.         contextId = "patientFeignClient",
  6.         fallback = PatientDegradeFeignClient.class)
  7. public interface PatientFeignClient {
  9.     /**
  10.      * 获取就诊人
  11.      * @param id
  12.      * @return
  13.      */
  14.     @GetMapping("/inner/user/patient/get/{id}")
  15.     Patient getPatient(@PathVariable Long id);
  16. }
复制代码
降级：
  1. package com.atguigu.syt.user.client.impl;
  3. @Component
  4. public class PatientDegradeFeignClient implements PatientFeignClient {
  6.     @Override
  7.     public Patient getPatient(Long id) {
  8.         return null;
  9.     }
  10. }
复制代码
3、获取排班信息接口

3.1、Controller

在service-hosp模块创建controller.inner包，创建InnerScheduleController类
  1. package com.atguigu.syt.hosp.controller.inner;
  3. @Api(tags = "医院接口-供其他微服务远程调用")
  4. @RestController
  5. @RequestMapping("/inner/hosp/hospital")
  6. public class InnerScheduleController {
  8.     @Resource
  9.     private ScheduleService scheduleService;
  11.     @ApiOperation("根据排班id获取预约下单数据")
  12.     @ApiImplicitParam(name = "scheduleId",value = "排班id", required = true)
  13.     @GetMapping("/getScheduleOrderVo/{scheduleId}")
  14.     public ScheduleOrderVo getScheduleOrderVo(@PathVariable String scheduleId) {
  15.         return scheduleService.getScheduleOrderVo(scheduleId);
  16.     }
  17. }
复制代码
3.2、Service

接口：ServiceScheduleService
  1. /**
  2. * 获取排班相关数据
  3. * @param scheduleId
  4. * @return
  5. */
  6. ScheduleOrderVo getScheduleOrderVo(String scheduleId);
复制代码
实现：ScheduleServiceImpl
  1. @Override
  2. public ScheduleOrderVo getScheduleOrderVo(String scheduleId) {
  4.     Schedule schedule = this.getDetailById(scheduleId);
  5.     String hosname = (String)schedule.getParam().get("hosname");
  6.     String depname = (String)schedule.getParam().get("depname");
  8.     ScheduleOrderVo scheduleOrderVo = new ScheduleOrderVo();
  9.     scheduleOrderVo.setHoscode(schedule.getHoscode()); //医院编号
  10.     scheduleOrderVo.setHosname(hosname); //医院名称
  11.     scheduleOrderVo.setDepcode(schedule.getDepcode()); //科室编号
  12.     scheduleOrderVo.setDepname(depname); //科室名称
  13.     scheduleOrderVo.setHosScheduleId(schedule.getHosScheduleId()); //医院端的排班主键
  14.     scheduleOrderVo.setAvailableNumber(schedule.getAvailableNumber()); //剩余预约数
  15.     scheduleOrderVo.setTitle(hosname + depname + "挂号费");
  16.     scheduleOrderVo.setReserveDate(schedule.getWorkDate()); //安排日期
  17.     scheduleOrderVo.setReserveTime(schedule.getWorkTime()); //安排时间（0：上午 1：下午）
  18.     scheduleOrderVo.setAmount(schedule.getAmount());//挂号费用
  20.     //获取预约规则相关数据
  21.     Hospital hospital = hospitalRepository.findByHoscode(schedule.getHoscode());
  22.     BookingRule bookingRule = hospital.getBookingRule();
  23.     String quitTime = bookingRule.getQuitTime();//退号时间
  24.     //退号实际时间（如：就诊前一天为-1，当天为0）
  25.     DateTime quitDay = new DateTime(schedule.getWorkDate()).plusDays(bookingRule.getQuitDay());//退号日期
  26.     DateTime quitDateTime = this.getDateTime(quitDay, quitTime);//可退号的具体的日期和时间
  27.     scheduleOrderVo.setQuitTime(quitDateTime.toDate());
  29.     return scheduleOrderVo;
  30. }
复制代码
3.3、创建service-hosp-client模块

在service-client下创建service-hosp-client
3.4、创建Feign接口

在service-hosp-client中创建接口
  1. package com.atguigu.syt.hosp.client;
  3. @FeignClient(
  4.     value = "service-hosp",
  5.     contextId = "scheduleFeignClient",
  6.     fallback = ScheduleDegradeFeignClient.class
  7. )
  8. public interface ScheduleFeignClient {
  9.     /**
  10.      * 根据排班id获取预约下单数据
  11.      * @param scheduleId
  12.      * @return
  13.      */
  14.     @GetMapping("/inner/hosp/hospital/getScheduleOrderVo/{scheduleId}")
  15.     ScheduleOrderVo getScheduleOrderVo(@PathVariable("scheduleId") String scheduleId);
  16. }
复制代码
降级：
  1. package com.atguigu.syt.hosp.client.impl;
  3. @Component
  4. public class ScheduleDegradeFeignClient implements ScheduleFeignClient {
  5.     @Override
  6.     public ScheduleOrderVo getScheduleOrderVo(String scheduleId) {
  7.         return null;
  8.     }
  9. }
复制代码
4、生成订单

4.1、service中引入依赖
  1. <dependency>
  2.     <groupId>com.atguigu</groupId>
  3.     <artifactId>service-user-client</artifactId>
  4.     <version>1.0</version>
  5. </dependency>
  6. <dependency>
  7.     <groupId>com.atguigu</groupId>
  8.     <artifactId>service-hosp-client</artifactId>
  9.     <version>1.0</version>
  10. </dependency>
复制代码
4.2、Controller

在service-order中创建controller.front包，创建FrontOrderInfoController类，定义创建订单接口
  1. package com.atguigu.syt.order.controller.front;
  3. @Api(tags = "订单接口")
  4. @RestController
  5. @RequestMapping("/front/order/orderInfo")
  6. public class FrontOrderInfoController {
  8.     @Resource
  9.     private OrderInfoService orderInfoService;
  11.     @Resource
  12.     private AuthContextHolder authContextHolder;
  14.     @ApiOperation("创建订单")
  15.     @ApiImplicitParams({
  16.             @ApiImplicitParam(name = "scheduleId",value = "排班id", required = true),
  17.             @ApiImplicitParam(name = "patientId",value = "就诊人id", required = true)})
  18.     @PostMapping("/auth/submitOrder/{scheduleId}/{patientId}")
  19.     public Result<Long> submitOrder(@PathVariable String scheduleId, @PathVariable Long patientId, HttpServletRequest request, HttpServletResponse response) {
  21.         authContextHolder.checkAuth(request, response);
  22.         Long orderId = orderInfoService.submitOrder(scheduleId, patientId);
  23.         return Result.ok(orderId);
  24.     }
  25. }
复制代码
4.3、Service

接口：OrderInfoService
  1. /**
  2.      * 根据排班id和就诊人id创建订单
  3.      * @param scheduleId
  4.      * @param patientId
  5.      * @return 新订单id
  6.      */
  7. Long submitOrder(String scheduleId, Long patientId);
复制代码
实现：OrderInfoServiceImpl
  1. @Resource
  2. private PatientFeignClient patientFeignClient;
  4. @Resource
  5. private ScheduleFeignClient scheduleFeignClient;
  7. @Override
  8. public Long submitOrder(String scheduleId, Long patientId) {
  10.     //就诊人数据：远程获取就诊人数据（openfeign）
  11.     Patient patient = patientFeignClient.getPatient(patientId);
  12.     if(patient == null) {
  13.         throw new GuiguException(ResultCodeEnum.PARAM_ERROR);
  14.     }
  16.     //获取医院排班相关数据
  17.     ScheduleOrderVo scheduleOrderVo = scheduleFeignClient.getScheduleOrderVo(scheduleId);
  18.     if(scheduleOrderVo == null) {
  19.         throw new GuiguException(ResultCodeEnum.PARAM_ERROR);
  20.     }
  22.     //SignInfoVo signInfoVo = hospitalFeignClient.getSignInfoVo(scheduleOrderVo.getHoscode());
  23.     SignInfoVo signInfoVo = new SignInfoVo();
  24.     signInfoVo.setSignKey("8af52af00baf6aec434109fc17164aae");
  25.     signInfoVo.setApiUrl("http://localhost:9998");
  26.     if(signInfoVo == null) {
  27.         throw new GuiguException(ResultCodeEnum.PARAM_ERROR);
  28.     }
  30.     if(scheduleOrderVo.getAvailableNumber() <= 0) {
  31.         throw new GuiguException(ResultCodeEnum.NUMBER_NO);
  32.     }
  34.     //创建订单对象
  35.     OrderInfo orderInfo = new OrderInfo();
  37.     //基本信息
  38.     String outTradeNo = UUID.randomUUID().toString().replace("-", "");
  39.     orderInfo.setOutTradeNo(outTradeNo); //订单号
  40.     orderInfo.setOrderStatus(OrderStatusEnum.UNPAID.getStatus());//未支付
  42.     //就诊人数据
  43.     orderInfo.setPatientId(patientId);
  44.     orderInfo.setPatientPhone(patient.getPhone());
  45.     orderInfo.setPatientName(patient.getName());
  46.     orderInfo.setUserId(patient.getUserId());
  48.     //医院排班相关数据
  49.     orderInfo.setScheduleId(scheduleId);
  50.     BeanUtils.copyProperties(scheduleOrderVo, orderInfo);//拷贝相关属性
  52.     //step4：调用医院端接口获取相关数据
  53.     Map<String, Object> paramsMap = new HashMap<>();
  54.     paramsMap.put("hoscode", scheduleOrderVo.getHoscode());
  55.     paramsMap.put("depcode", scheduleOrderVo.getDepcode());
  56.     paramsMap.put("hosScheduleId", scheduleOrderVo.getHosScheduleId());
  57.     paramsMap.put(
  58.         "reserveDate",
  59.         new DateTime(scheduleOrderVo.getReserveDate()).toString("yyyy-MM-dd")
  60.     );
  61.     paramsMap.put("reserveTime", scheduleOrderVo.getReserveTime());
  62.     paramsMap.put("amount", scheduleOrderVo.getAmount());
  63.     paramsMap.put("name", patient.getName());
  64.     paramsMap.put("certificatesType", patient.getCertificatesType());
  65.     paramsMap.put("certificatesNo", patient.getCertificatesNo());
  66.     paramsMap.put("sex", patient.getSex());
  67.     paramsMap.put("birthdate", patient.getBirthdate());
  68.     paramsMap.put("phone", patient.getPhone());
  69.     paramsMap.put("isMarry", patient.getIsMarry());
  70.     paramsMap.put("timestamp", HttpRequestHelper.getTimestamp());
  72.     paramsMap.put("sign", HttpRequestHelper.getSign(paramsMap, signInfoVo.getSignKey()));//标准签名
  73.     JSONObject jsonResult = HttpRequestHelper.sendRequest(
  74.         paramsMap, signInfoVo.getApiUrl() + "/order/submitOrder"
  75.     );
  76.     log.info("结果：" + jsonResult.toJSONString());
  78.     if(jsonResult.getInteger("code") != 200){//失败
  80.         log.error("预约失败，"
  81.                   + "code：" + jsonResult.getInteger("code")
  82.                   + "，message：" + jsonResult.getString("message")
  83.                  );
  84.         throw new GuiguException(ResultCodeEnum.FAIL.getCode(), jsonResult.getString("message"));
  85.     }
  87.     JSONObject data = jsonResult.getJSONObject("data");
  88.     String hosOrderId = data.getString("hosOrderId");
  89.     Integer number = data.getInteger("number");
  90.     String fetchTime = data.getString("fetchTime");
  91.     String fetchAddress = data.getString("fetchAddress");
  92.     orderInfo.setHosOrderId(hosOrderId);
  93.     orderInfo.setNumber(number);
  94.     orderInfo.setFetchTime(fetchTime);
  95.     orderInfo.setFetchAddress(fetchAddress);
  96.     baseMapper.insert(orderInfo);
  98.     //使用这两个数据更新平台端的最新的排班数量
  99.     Integer reservedNumber = data.getInteger("reservedNumber");
  100.     Integer availableNumber = data.getInteger("availableNumber");
  102.     //目的1：更新mongodb数据库中的排班数量
  103.     //TODO 中间件：MQ 异步解耦
  105.     //目的2：给就诊人发短信 TODO：MQ
  107.     return orderInfo.getId(); //返回订单id
  108. }
复制代码
第02章-订单详情（作业）

1、后端接口

1.1、Controller

在FrontOrderInfoController中添加方法
  1. import request from '@/utils/request'
  2. export default {
  3.   //生成订单
  4.   submitOrder(scheduleId, patientId) {
  5.     return request({
  6.       url: `/front/order/orderInfo/auth/submitOrder/${scheduleId}/${patientId}`,
  7.       method: 'post'
  8.     })
  9.   }
  10. }
复制代码
1.2、Service

接口：OrderInfoService
  1. {{orderText}}
复制代码
实现：OrderInfoServiceImpl
  1. orderBtnDisabled: false, //防止重复提交
  2. orderText: '确认挂号'
复制代码
辅助方法
  1. import orderInfoApi from '~/api/orderInfo'
复制代码
3、前端整合

3.1、api

在orderInfo.js添加方法
  1. //确认挂号
  2. submitOrder() {
  3.     if (this.orderBtnDisabled) return
  4.     this.orderBtnDisabled = true
  5.     this.orderText = '预约挂号中...'
  6.     orderInfoApi
  7.         .submitOrder(this.scheduleId, this.patient.id)
  8.         .then((response) => {
  9.         window.location.href = '/order/show?orderId=' + response.data
  10.     })
  11. },
复制代码
2、页面渲染

资料：资料>订单微服务>order
pages/order/show.vue组件
第03章-订单列表（作业）

1、后端接口

1.1、Controller

在FrontOrderInfoController中添加方法
  1. @ApiOperation("根据订单id查询订单详情")
  2. @ApiImplicitParam(name = "orderId",value = "订单id", required = true)
  3. @GetMapping("/auth/getOrder/{orderId}")
  4. public Result<OrderInfo> getOrder(@PathVariable Long orderId, HttpServletRequest request, HttpServletResponse response) {
  5.     authContextHolder.checkAuth(request, response);
  6.     OrderInfo orderInfo = orderInfoService.getOrderInfo(orderId);
  7.     return Result.ok(orderInfo);
  8. }
复制代码
1.2、Service

接口：OrderInfoService
  1. /**
  2.      * 根据订单id获取订单详情
  3.      * @param orderId
  4.      * @return
  5.      */
  6. OrderInfo getOrderInfo(Long orderId);
复制代码
实现：OrderInfoServiceImpl
  1. @Override
  2. public OrderInfo getOrderInfo(Long orderId) {
  3.     OrderInfo orderInfo = baseMapper.selectById(orderId);
  4.     return this.packOrderInfo(orderInfo);
  5. }
复制代码
2、前端整合

2.1、api

在orderInfo.js添加方法
  1. /**
  2.      * 封装订单数据
  3.      * @param orderInfo
  4.      * @return
  5.      */
  6. private OrderInfo packOrderInfo(OrderInfo orderInfo) {
  7.     orderInfo.getParam().put(
  8.         "orderStatusString",
  9.         OrderStatusEnum.getStatusNameByStatus(orderInfo.getOrderStatus())
  10.     );
  11.     return orderInfo;
  12. }
复制代码
2.2、页面渲

资料：资料>订单微服务>order
pages/order/index.vue组件
源码：https://gitee.com/dengyaojava/guigu-syt-parent

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

宁睿

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表