健康管理系统第六天（移动端开发之体检预约_经典五表联查_调用阿里云提供的短信服务进行短信验证码发送）

一、移动端开发

`1.移动端开发方式`

随着移动互联网的兴起和手机的普及，目前移动端应用变得愈发重要，成为了各个商家的必争之地。例如，我们可以使用手机购物、支付、打车、玩游戏、订酒店、购票等，以前只能通过PC端完成的事情，现在通过手机都能够实现，而且更加方便，而这些都需要移动端开发进行支持，那如何进行移动端开发呢？
移动端开发主要有三种方式：
1、基于手机API开发（原生APP）
2、基于手机浏览器开发（移动web）
3、混合开发（混合APP）

1.1 基于手机API开发
手机端使用手机API，例如使用Android、ios 等进行开发，服务端只是一个数据提供者。手机端请求服务端获取数据（json、xml格式）并在界面进行展示。这种方式相当于传统开发中的C/S模式，即需要在手机上安装一个客户端软件。
这种方式需要针对不同的手机系统分别进行开发，目前主要有以下几个平台：
1、苹果ios系统版本，开发语言是Objective-C
2、安卓Android系统版本，开发语言是Java
3、微软Windows phone系统版本，开发语言是C#
4、塞班symbian系统版本，开发语言是C++
此种开发方式举例：手机淘宝、抖音、今日头条、大众点评

1.2 基于手机浏览器开发
生存在浏览器中的应用，基本上可以说是触屏版的网页应用。这种开发方式相当于传统开发中的B/S模式，也就是手机上不需要额外安装软件，直接基于手机上的浏览器进行访问。这就需要我们编写的html页面需要根据不同手机的尺寸进行自适应调节，目前比较流行的是html5开发。除了直接通过手机浏览器访问，还可以将页面内嵌到一些应用程序中，例如通过微信公众号访问html5页面。
这种开发方式不需要针对不同的手机系统分别进行开发，只需要开发一个版本，就可以在不同的手机上正常访问。

1.3 混合开发
是半原生半Web的混合类App。需要下载安装，看上去类似原生App，访问的内容是Web 网页。其实就是把HTML5页面嵌入到一个原生容器里面

二、需求分析和环境搭建

`1.搭建移动端工程`

本项目是基于SOA架构进行开发，前面我们已经完成了后台系统的部分功能开发，在后台系统中都是通过Dubbo调用服务层发布的服务进行相关的操作。本章节我们开发移动端工程也是同样的模式，所以我们也需要在移动端工程中通过Dubbo调用服务层发布的服务。
1.1 导入maven坐标
在health_common工程的pom.xml文件中导入阿里短信发送的maven坐标

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>3.3.1</version>
</dependency>
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-dysmsapi</artifactId>
    <version>1.0.0</version>
</dependency>

1.2 导入通用组件

在health_common工程中导入如下通用组件

ValidateCodeUtils工具类：

/**
 * 随机生成验证码工具类
 */
public class ValidateCodeUtils {
    /**
     * 随机生成验证码
     * @param length 长度为4位或者6位
     * @return
     */
    public static Integer generateValidateCode(int length){
        Integer code =null;
        if(length == 4){
            code = new Random().nextInt(9999);//生成随机数，最大为9999
            if(code < 1000){
                code = code + 1000;//保证随机数为4位数字
            }
        }else if(length == 6){
            code = new Random().nextInt(999999);//生成随机数，最大为999999
            if(code < 100000){
                code = code + 100000;//保证随机数为6位数字
            }
        }else{
            throw new RuntimeException("只能生成4位或6位数字验证码");
        }
        return code;
    }

    /**
     * 随机生成指定长度字符串验证码
     * @param length 长度
     * @return
     */
    public static String generateValidateCode4String(int length){
        Random rdm = new Random();
        String hash1 = Integer.toHexString(rdm.nextInt());
        String capstr = hash1.substring(0, length);
        return capstr;
    }
}

SMSUtils工具类：

/**
 * 短信发送工具类
 */
public class SMSUtils {
   public static final String VALIDATE_CODE = "SMS_159620392";//发送短信验证码
   public static final String ORDER_NOTICE = "SMS_159771588";//体检预约成功通知

   /**
    * 发送短信
    * @param phoneNumbers
    * @param param
    * @throws ClientException
    */
   public static void sendShortMessage(String templateCode,String phoneNumbers,String param) throws ClientException{
      // 设置超时时间-可自行调整
      System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
      System.setProperty("sun.net.client.defaultReadTimeout", "10000");
      // 初始化ascClient需要的几个参数
      final String product = "Dysmsapi";// 短信API产品名称（短信产品名固定，无需修改）
      final String domain = "dysmsapi.aliyuncs.com";// 短信API产品域名（接口地址固定，无需修改）
      // 替换成你的AK
      final String accessKeyId = "LTAIak3CfAehK7cE";// 你的accessKeyId,参考本文档步骤2
      final String accessKeySecret = "zsykwhTIFa48f8fFdU06GOKjHWHel4";// 你的accessKeySecret，参考本文档步骤2
      // 初始化ascClient,暂时不支持多region（请勿修改）
      IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
      DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
      IAcsClient acsClient = new DefaultAcsClient(profile);
      // 组装请求对象
      SendSmsRequest request = new SendSmsRequest();
      // 使用post提交
      request.setMethod(MethodType.POST);
      // 必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式
      request.setPhoneNumbers(phoneNumbers);
      // 必填:短信签名-可在短信控制台中找到
      request.setSignName("健康管理");
      // 必填:短信模板-可在短信控制台中找到
      request.setTemplateCode(templateCode);
      // 可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时,此处的值为
      // 友情提示:如果JSON中需要带换行符,请参照标准的JSON协议对换行符的要求,比如短信内容中包含\r\n的情况在JSON中需要表示成\\r\\n,否则会导致JSON在服务端解析失败
      request.setTemplateParam("{\"code\":\""+param+"\"}");
      // 可选-上行短信扩展码(扩展码字段控制在7位或以下，无特殊需求用户请忽略此字段)
      // request.setSmsUpExtendCode("90997");
      // 可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者
      // request.setOutId("yourOutId");
      // 请求失败这里会抛ClientException异常
      SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request);
      if (sendSmsResponse.getCode() != null && sendSmsResponse.getCode().equals("OK")) {
         // 请求成功
         System.out.println("请求成功");
      }
   }
}

RedisMessageConstant常量类：

public class RedisConstant {
    //套餐图片所有图片名称
    public static final String SETMEAL_PIC_RESOURCES = "setmealPicResources";
    //套餐图片保存在数据库中的图片名称
    public static final String SETMEAL_PIC_DB_RESOURCES = "setmealPicDbResources";
}

最后定义目录结构如下:

1.3 health_mobile
创建移动端工程health_mobile，打包方式为war，用于存放Controller，在Controller中通过Dubbo可以远程访问服务层相关服务，所以需要依赖health_interface接口工程。

pom.xml

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>health_parent</artifactId>
        <groupId>com.bianyi</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.bianyi</groupId>
    <artifactId>health_mobile</artifactId>
    <packaging>war</packaging>

    <name>health_mobile Maven Webapp</name>
    <!-- FIXME change it to the project's website -->
    <url>http://www.example.com</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.bianyi</groupId>
            <artifactId>health_interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.tomcat.maven</groupId>
                <artifactId>tomcat7-maven-plugin</artifactId>
                <configuration>
                    <!-- 指定端口 -->
                    <port>80</port>
                    <!-- 请求路径 -->
                    <path>/</path>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

静态资源（CSS、html、img等，详见资料）：

web.xml：

<!DOCTYPE web-app PUBLIC
        "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
        "http://java.sun.com/dtd/web-app_2_3.dtd" >

<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <!-- 解决post乱码 -->
  <filter>
    <filter-name>CharacterEncodingFilter</filter-name>
    <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
    <init-param>
      <param-name>encoding</param-name>
      <param-value>utf-8</param-value>
    </init-param>
    <init-param>
      <param-name>forceEncoding</param-name>
      <param-value>true</param-value>
    </init-param>
  </filter>
  <filter-mapping>
    <filter-name>CharacterEncodingFilter</filter-name>
    <url-pattern>/*</url-pattern>
  </filter-mapping>
  <servlet>
    <servlet-name>springmvc</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载 -->
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath:springmvc.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>springmvc</servlet-name>
    <url-pattern>*.do</url-pattern>
  </servlet-mapping>
  <welcome-file-list>
    <welcome-file>/pages/index.html</welcome-file>
  </welcome-file-list>
</web-app>

springmvc.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
          http://www.springframework.org/schema/mvc
          http://www.springframework.org/schema/mvc/spring-mvc.xsd
          http://code.alibabatech.com/schema/dubbo
          http://code.alibabatech.com/schema/dubbo/dubbo.xsd
          http://www.springframework.org/schema/context
          http://www.springframework.org/schema/context/spring-context.xsd">

    <mvc:annotation-driven>
        <mvc:message-converters register-defaults="true">
            <bean class="com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter">
                <property name="supportedMediaTypes" value="application/json"/>
                <property name="features">
                    <list>
                        <value>WriteMapNullValue</value>
                        <value>WriteDateUseDateFormat</value>
                    </list>
                </property>
            </bean>
        </mvc:message-converters>
    </mvc:annotation-driven>
    <!-- 指定应用名称 -->
    <dubbo:application name="health_mobile" />
    <!--指定服务注册中心地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!--批量扫描-->
    <dubbo:annotation package="com.bianyi.controller" />
    <!--
        超时全局设置 10分钟
        check=false 不检查服务提供方，开发阶段建议设置为false
        check=true 启动时检查服务提供方，如果服务提供方没有启动则报错
    -->
    <dubbo:consumer timeout="600000" check="false"/>
    <import resource="spring-redis.xml"></import>
</beans>

spring-redis.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
          http://www.springframework.org/schema/mvc
          http://www.springframework.org/schema/mvc/spring-mvc.xsd
          http://code.alibabatech.com/schema/dubbo
          http://code.alibabatech.com/schema/dubbo/dubbo.xsd
          http://www.springframework.org/schema/context
          http://www.springframework.org/schema/context/spring-context.xsd">

    <context:property-placeholder location="classpath:redis.properties" />

    <!--Jedis连接池的相关配置-->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <property name="maxTotal">
            <value>${redis.pool.maxActive}</value>
        </property>
        <property name="maxIdle">
            <value>${redis.pool.maxIdle}</value>
        </property>
        <property name="testOnBorrow" value="true"/>
        <property name="testOnReturn" value="true"/>
    </bean>

    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
        <constructor-arg name="host" value="${redis.host}" />
        <constructor-arg name="port" value="${redis.port}" type="int" />
        <constructor-arg name="timeout" value="${redis.timeout}" type="int" />
    </bean>
</beans>

redis.properties：

#最大分配的对象数
redis.pool.maxActive=200
#最大能够保持idel状态的对象数
redis.pool.maxIdle=50
redis.pool.minIdle=10
redis.pool.maxWaitMillis=20000
#当池内没有返回对象时，最大等待时间
redis.pool.maxWait=300

#格式：redis://:[密码]@[服务器地址]:[端口]/[db index]
#redis.uri = redis://:12345@127.0.0.1:6379/0

redis.host = 127.0.0.1
redis.port = 6379
redis.timeout = 30000

log4j.properties:

### direct log messages to stdout ###
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.err
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n

### direct messages to file mylog.log ###
log4j.appender.file=org.apache.log4j.FileAppender
log4j.appender.file.File=c:\\mylog.log
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n

### set log levels - for more verbose logging change 'info' to 'debug' ###

log4j.rootLogger=debug, stdout

最后定义目录结构如下:

三、套餐列表页面动态展示

移动端首页为http://192.168.7.45:84/pages/index.html,效果如下：

点击体检预约直接跳转到体检套餐列表页面（/pages/setmeal.html）
1.点击体检预约，整个前端页面的执行流程

2.完善SetmealController

package com.oracle.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.oracle.constant.MessageConstant;
import com.oracle.entity.Result;
import com.oracle.pojo.Setmeal;
import com.oracle.service.SetmealService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/setmeal")
public class SetmealController {

    @Reference
    SetmealService setmealService;

    /**
     * 查询所有的套餐信息
     * @return
     */
    @RequestMapping("/getAllSetmeal")
    public Result getAllSetmeal(){
        try {
            List<Setmeal> list = setmealService.findAllFromSetmeal();
            return new Result(true, MessageConstant.GET_SETMEAL_LIST_SUCCESS,list);
        } catch (Exception e) {
            e.printStackTrace();
            return new Result(false, MessageConstant.GET_SETMEAL_LIST_FAIL);
        }
    }
}

由于项目采用的分布式的框架，所以不管是后台管理界面还是移动端界面获取的服务是在同一个接口里面的方法

3.完善SetmealService

package com.oracle.service;

import com.oracle.entity.PageResult;
import com.oracle.entity.QueryPageBean;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.Setmeal;

import java.util.List;

public interface SetmealService {
    /*打开新增套餐，从检查组中找出所有的信息显示*/
    List<CheckGroup> findAllFromCheckGroup();
    /*从套餐中查出信息然后进行分页展示*/
    PageResult findPageFromSetMeal(QueryPageBean queryPageBean);
    /*新增套餐*/
    void addSetmeal(Setmeal setmeal, Integer[] checkgroupIds);
    
    /*移动端获取所有的套餐信息*/
    List<Setmeal> findAllFromSetmeal();
}

4.完善SetmealServiceImpl

package com.oracle.service;

import com.alibaba.dubbo.config.annotation.Service;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.oracle.constant.RedisConstant;
import com.oracle.dao.SetmealDao;
import com.oracle.entity.PageResult;
import com.oracle.entity.QueryPageBean;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.Setmeal;
import org.springframework.beans.factory.annotation.Autowired;
import redis.clients.jedis.JedisPool;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service(interfaceClass = SetmealService.class)
public class SetmealServiceImpl implements SetmealService {

    @Autowired
    SetmealDao setmealDao;

    @Autowired
    JedisPool jedisPool;

    @Override
    public List<CheckGroup> findAllFromCheckGroup() {
        return setmealDao.findAllFromCheckGroup();
    }

    @Override
    public PageResult findPageFromSetMeal(QueryPageBean queryPageBean) {
        Integer currentPage = queryPageBean.getCurrentPage();
        Integer pageSize = queryPageBean.getPageSize();
        String queryString = queryPageBean.getQueryString();
        PageHelper.startPage(currentPage,pageSize);
        Page<Setmeal> setmealPage=setmealDao.findPageFromSetMeal(queryString);
        return new PageResult(setmealPage.getTotal(),setmealPage);
    }

    @Override
    public void addSetmeal(Setmeal setmeal, Integer[] checkgroupIds) {
        /*先将套餐信息添加进t_setmeal中，然后将对应关系封装进t_setmeal_checkgroup中*/
        setmealDao.addSetmeal(setmeal);
        /*将保存到数据库中的图片的名称存入redis中的另一个set集合中*/
        jedisPool.getResource().sadd(RedisConstant.SETMEAL_PIC_DB_RESOURCES,setmeal.getImg());
        /*获取保存在数据库中的ID*/
        Integer setmealId = setmeal.getId();
        /*通过一个方法将套餐信息与检查组的多对多关系存储进t_setmeal_checkgroup*/
        this.setSetmealAndCheckgroup(setmealId,checkgroupIds);
    }

    @Override
    public Setmeal findSetmealById(Integer id) {
        return setmealDao.findSetmealById(id);
    }

    private void setSetmealAndCheckgroup(Integer setmealId, Integer[] checkgroupIds) {
        if(checkgroupIds!=null && checkgroupIds.length>0){
            for (Integer checkgroupId : checkgroupIds) {
                Map<String,Integer> map=new HashMap<String,Integer>();
                map.put("setmealId",setmealId);
                map.put("checkgroupId",checkgroupId);
                /*将put集合中的两个值保存在套餐的多对多关系中*/
                setmealDao.addSetmealAndCheckgroup(map);
            }
        }
    }
	
	/*上面是提供给后台管理人员的服务，下面这个是提供给移动端（用户）的服务*/
    @Override
    public List<Setmeal> findAllFromSetmeal() {
        return setmealDao.findAllFromSetmeal();
    }
}

5.完善SetmealDao

package com.oracle.dao;

import com.github.pagehelper.Page;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.Setmeal;
import org.springframework.stereotype.Repository;

import java.util.List;
import java.util.Map;

@Repository
public interface SetmealDao {
    /*打开新增套餐，从检查组中找出所有的信息显示*/
    List<CheckGroup> findAllFromCheckGroup();
    /*从套餐中查出信息然后进行分页展示*/
    Page<Setmeal> findPageFromSetMeal(String queryString);
    /*将套餐信息添加进t_setmeal中*/
    void addSetmeal(Setmeal setmeal);
    /*将套餐信息和检查组的多对多关系保存至t_setmeal_checkgroup*/
    void addSetmealAndCheckgroup(Map<String, Integer> map);
    
    /*移动端获取所有的套餐信息*/
    List<Setmeal> findAllFromSetmeal();
}

6.完善SetmealDao的映射文件

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.oracle.dao.SetmealDao">
    <!--查询所有的检查项-->
    <select id="findAllFromCheckGroup" resultType="com.oracle.pojo.CheckGroup">
        select * from t_checkgroup
    </select>
    <!--分页查询所有的套餐-->
    <select id="findPageFromSetMeal" parameterType="String" resultType="com.oracle.pojo.Setmeal">
        select * from t_setmeal
    </select>
    <!--添加套餐信息至t_setmeal中-->
    <insert id="addSetmeal" parameterType="com.oracle.pojo.Setmeal">
        <selectKey keyColumn="id" keyProperty="id" order="AFTER" resultType="Integer">
            SELECT LAST_INSERT_ID()
        </selectKey>
        insert into t_setmeal values(null,#{name},#{code},#{helpCode},#{sex},#{age},#{price},#{remark},#{attention},#{img})
    </insert>
    <!--将套餐信息和检查组的多对多关系保存至t_setmeal_checkgroup-->
    <insert id="addSetmealAndCheckgroup" parameterType="map">
        insert into t_setmeal_checkgroup(setmeal_id,checkgroup_id)
        values
        (#{setmealId},#{checkgroupId})
    </insert>

    <!--移动端获取所有的套餐信息-->
    <select id="findAllFromSetmeal" resultType="com.oracle.pojo.Setmeal">
        select * from t_setmeal
    </select>
</mapper>

7.启动测试

四、套餐详情页面动态展示

前面我们已经完成了体检套餐列表页面动态展示，点击其中任意一个套餐则跳转到对应1.4.1 的套餐详情页面/pages/setmeal_detail.html，并且会携带此套餐的id作为参数提交。
请求路径格式：http://localhost/pages/setmeal_detail.html?id=10
在套餐详情页面需要展示当前套餐的信息（包括图片、套餐名称、套餐介绍、适用性别、适用年龄）、此套餐包含的检查组信息、检查组包含的检查项信息等。

1.点击任意一个套餐，进入setmeal_detail界面然后显示该套餐包含的检查组、检查项的执行流程

2.完善SetmealController

package com.oracle.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.oracle.constant.MessageConstant;
import com.oracle.entity.Result;
import com.oracle.pojo.Setmeal;
import com.oracle.service.SetmealService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/setmeal")
public class SetmealController {

    @Reference
    SetmealService setmealService;

    /**
     * 查询所有的套餐信息
     * @return
     */
    @RequestMapping("/getAllSetmeal")
    public Result getAllSetmeal(){
        try {
            List<Setmeal> list = setmealService.findAllFromSetmeal();
            return new Result(true, MessageConstant.GET_SETMEAL_LIST_SUCCESS,list);
        } catch (Exception e) {
            e.printStackTrace();
            return new Result(false, MessageConstant.GET_SETMEAL_LIST_FAIL);
        }
    }

	/**
     * 根据套餐id查询套餐详情
     * @param id
     * @return
     */
    @RequestMapping("/findById")
    public Result findById(Integer id){
        try {
            Setmeal setmeal = setmealService.findSetmealById(id);
            return new Result(true,MessageConstant.QUERY_SETMEAL_SUCCESS,setmeal);
        } catch (Exception e) {
            e.printStackTrace();
            return new Result(false,MessageConstant.QUERY_SETMEAL_FAIL);
        }
    }
}

3.完善SetmealService

package com.oracle.service;

import com.oracle.entity.PageResult;
import com.oracle.entity.QueryPageBean;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.Setmeal;

import java.util.List;

public interface SetmealService {
    /*打开新增套餐，从检查组中找出所有的信息显示*/
    List<CheckGroup> findAllFromCheckGroup();
    /*从套餐中查出信息然后进行分页展示*/
    PageResult findPageFromSetMeal(QueryPageBean queryPageBean);
    /*新增套餐*/
    void addSetmeal(Setmeal setmeal, Integer[] checkgroupIds);
    
    /*移动端获取所有的套餐信息*/
    List<Setmeal> findAllFromSetmeal();
    /*移动端根据setmeal的id获取它下面的checkGroup和checkItem*/
    Setmeal findSetmealById(Integer id);
}

4.完善SetmealServiceImpl

package com.oracle.service;

import com.alibaba.dubbo.config.annotation.Service;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.oracle.constant.RedisConstant;
import com.oracle.dao.SetmealDao;
import com.oracle.entity.PageResult;
import com.oracle.entity.QueryPageBean;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.Setmeal;
import org.springframework.beans.factory.annotation.Autowired;
import redis.clients.jedis.JedisPool;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service(interfaceClass = SetmealService.class)
public class SetmealServiceImpl implements SetmealService {

    @Autowired
    SetmealDao setmealDao;

    @Autowired
    JedisPool jedisPool;

    @Override
    public List<CheckGroup> findAllFromCheckGroup() {
        return setmealDao.findAllFromCheckGroup();
    }

    @Override
    public PageResult findPageFromSetMeal(QueryPageBean queryPageBean) {
        Integer currentPage = queryPageBean.getCurrentPage();
        Integer pageSize = queryPageBean.getPageSize();
        String queryString = queryPageBean.getQueryString();
        PageHelper.startPage(currentPage,pageSize);
        Page<Setmeal> setmealPage=setmealDao.findPageFromSetMeal(queryString);
        return new PageResult(setmealPage.getTotal(),setmealPage);
    }

    @Override
    public void addSetmeal(Setmeal setmeal, Integer[] checkgroupIds) {
        /*先将套餐信息添加进t_setmeal中，然后将对应关系封装进t_setmeal_checkgroup中*/
        setmealDao.addSetmeal(setmeal);
        /*将保存到数据库中的图片的名称存入redis中的另一个set集合中*/
        jedisPool.getResource().sadd(RedisConstant.SETMEAL_PIC_DB_RESOURCES,setmeal.getImg());
        /*获取保存在数据库中的ID*/
        Integer setmealId = setmeal.getId();
        /*通过一个方法将套餐信息与检查组的多对多关系存储进t_setmeal_checkgroup*/
        this.setSetmealAndCheckgroup(setmealId,checkgroupIds);
    }

    @Override
    public Setmeal findSetmealById(Integer id) {
        return setmealDao.findSetmealById(id);
    }

    private void setSetmealAndCheckgroup(Integer setmealId, Integer[] checkgroupIds) {
        if(checkgroupIds!=null && checkgroupIds.length>0){
            for (Integer checkgroupId : checkgroupIds) {
                Map<String,Integer> map=new HashMap<String,Integer>();
                map.put("setmealId",setmealId);
                map.put("checkgroupId",checkgroupId);
                /*将put集合中的两个值保存在套餐的多对多关系中*/
                setmealDao.addSetmealAndCheckgroup(map);
            }
        }
    }
	
	/*上面是提供给后台管理人员的服务，下面这个是提供给移动端（用户）的服务*/
    @Override
    public List<Setmeal> findAllFromSetmeal() {
        return setmealDao.findAllFromSetmeal();
    }
	@Override
    public Setmeal findSetmealById(Integer id) {
        return setmealDao.findSetmealById(id);
    }
}

5.完善SetmealDao

package com.oracle.dao;

import com.github.pagehelper.Page;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.Setmeal;
import org.springframework.stereotype.Repository;

import java.util.List;
import java.util.Map;

@Repository
public interface SetmealDao {
    /*打开新增套餐，从检查组中找出所有的信息显示*/
    List<CheckGroup> findAllFromCheckGroup();
    /*从套餐中查出信息然后进行分页展示*/
    Page<Setmeal> findPageFromSetMeal(String queryString);
    /*将套餐信息添加进t_setmeal中*/
    void addSetmeal(Setmeal setmeal);
    /*将套餐信息和检查组的多对多关系保存至t_setmeal_checkgroup*/
    void addSetmealAndCheckgroup(Map<String, Integer> map);
    
    /*移动端获取所有的套餐信息*/
    List<Setmeal> findAllFromSetmeal();
    /*移动端根据setmeal的id获取它下面的checkGroup和checkItem*/
    Setmeal findSetmealById(Integer id);
}

从setmealDao的映射文件开始进行五表联查

6.完善SetmealDao的映射文件

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.oracle.dao.SetmealDao">
    <!--查询所有的检查项-->
    <select id="findAllFromCheckGroup" resultType="com.oracle.pojo.CheckGroup">
        select * from t_checkgroup
    </select>
    <!--分页查询所有的套餐-->
    <select id="findPageFromSetMeal" parameterType="String" resultType="com.oracle.pojo.Setmeal">
        select * from t_setmeal
    </select>
    <!--添加套餐信息至t_setmeal中-->
    <insert id="addSetmeal" parameterType="com.oracle.pojo.Setmeal">
        <selectKey keyColumn="id" keyProperty="id" order="AFTER" resultType="Integer">
            SELECT LAST_INSERT_ID()
        </selectKey>
        insert into t_setmeal values(null,#{name},#{code},#{helpCode},#{sex},#{age},#{price},#{remark},#{attention},#{img})
    </insert>
    <!--将套餐信息和检查组的多对多关系保存至t_setmeal_checkgroup-->
    <insert id="addSetmealAndCheckgroup" parameterType="map">
        insert into t_setmeal_checkgroup(setmeal_id,checkgroup_id)
        values
        (#{setmealId},#{checkgroupId})
    </insert>

    <!--移动端获取所有的套餐信息-->
    <select id="findAllFromSetmeal" resultType="com.oracle.pojo.Setmeal">
        select * from t_setmeal
    </select>
    <!--根据setmeal的id获取setmeal的所有基本信息-->
    <select id="findSetmealById" parameterType="Integer" resultMap="findSetMealById">
        select * from t_setmeal where id=#{id}
    </select>
    <resultMap id="findSetMealById" type="com.oracle.pojo.Setmeal">
        <id column="id" property="id"></id>
        <result column="name" property="name"></result>
        <result column="code" property="code"></result>
        <result column="helpCode" property="helpCode"></result>
        <result column="sex" property="sex"></result>
        <result column="age" property="age"></result>
        <result column="price" property="price"></result>
        <result column="remark" property="remark"></result>
        <result column="attention" property="attention"></result>
        <result column="img" property="img"></result>
        <collection property="checkGroups" column="id" ofType="com.oracle.pojo.CheckGroup" select="com.oracle.dao.CheckGroupDao.findCheckGroupBySetmealId"></collection>
    </resultMap>
</mapper>

7.完善CheckGroupDao

package com.oracle.dao;

import com.github.pagehelper.Page;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.CheckItem;
import org.springframework.stereotype.Repository;

import java.util.List;
import java.util.Map;

@Repository
public interface CheckGroupDao {
    /*根据setmeal的id从关联表中查找出所有的checkgroup的id的集合，然后根据id一个一个去checkgroup中获取检查组的基本信息*/
    CheckGroup findCheckGroupBySetmealId(Integer id);
}

8.完善CheckGroupDao的映射文件

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.oracle.dao.CheckGroupDao">
    <select id="findCheckGroupBySetmealId" parameterType="Integer" resultMap="findCheckGroupBySetmealId">
        select * from t_checkgroup where id in(
            select checkgroup_id from t_setmeal_checkgroup WHERE setmeal_id =#{id}
        )
    </select>
    <resultMap id="findCheckGroupBySetmealId" type="com.oracle.pojo.CheckGroup">
        <id column="id" property="id"></id>
        <result column="code" property="code"></result>
        <result column="name" property="name"></result>
        <result column="helpCode" property="helpCode"></result>
        <result column="sex" property="sex"></result>
        <result column="remark" property="remark"></result>
        <result column="attention" property="attention"></result>
        <collection property="checkItems" column="id" ofType="com.oracle.pojo.CheckItem"
                    select="com.oracle.dao.CheckItemDao.findCheckItemByCheckGroupId"></collection>
    </resultMap>
</mapper>

9.完善CheckItemDao

package com.oracle.dao;

import com.github.pagehelper.Page;
import com.oracle.pojo.CheckItem;
import org.springframework.stereotype.Repository;

@Repository
public interface CheckItemDao {
    /*根据用户选择套餐的id得到checkGroup的id，然后根据checkgroup的id得到checkitem的基本信息*/
    CheckItem findCheckItemByCheckGroupId(Integer id);
}

10.完善CheckItemDao的映射文件

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.oracle.dao.CheckItemDao">

    <select id="findCheckItemByCheckGroupId" parameterType="Integer" resultType="com.oracle.pojo.CheckItem">
        select * from t_checkitem where id in(
            select checkitem_id from t_checkgroup_checkitem where checkgroup_id=#{id}
        )
    </select>
</mapper>

12.编写测试代码进行测试

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <plugins>
        <!-- com.github.pagehelper 为 PageHelper 类所在包名 -->
        <plugin interceptor="com.github.pagehelper.PageInterceptor"></plugin>
    </plugins>
    <!--配置环境信息-->
    <environments default="mysql">
        <environment id="mysql">
            <transactionManager type="JDBC"></transactionManager>
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/health"/>
                <property name="username" value="root"/>
                <property name="password" value="123"/>
            </dataSource>
        </environment>
    </environments>
    <!--配置映射文件的位置-->
    <mappers>
        <mapper resource="com/oracle/dao/CheckItemDao.xml"></mapper>
        <mapper resource="com/oracle/dao/CheckGroupDao.xml"></mapper>
        <mapper resource="com/oracle/dao/SetmealDao.xml"></mapper>
        <mapper resource="com/oracle/dao/OrderSettingDao.xml"></mapper>
    </mappers>
</configuration>

package com.oracle.test;

import com.oracle.dao.SetmealDao;
import com.oracle.pojo.CheckGroup;
import com.oracle.pojo.Setmeal;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class TestMobileDao {
    public SqlSession sqlSession;
    public SetmealDao setmealDao;
    @Before
    public void before() throws IOException {
        //1.启动mybatis
        InputStream resourceAsStream = Resources.getResourceAsStream("SqlMapConfigDao.xml");
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);
        sqlSession = sqlSessionFactory.openSession();
        setmealDao = sqlSession.getMapper(SetmealDao.class);
    }
    @After
    public void after(){
        sqlSession.close();
    }

    /*测试mapper文件中的查询是否可行*/
    @Test
    public void TestSetmealDao_findSetmealById(){
        Setmeal setmeal = setmealDao.findSetmealById(12);
        System.out.println(setmeal);
    }
}

13.启动测试

Setmeal{id=12, name='入职无忧体检套餐（男女通用）', code='0001', helpCode='RZTJ', sex='0', age='18-60', price=300.0, remark='入职体检套餐', attention='null', img='c420c66f-241b-42bf-be82-ec34210d76300.jpg', 
checkGroups=[
		CheckGroup{id=5, code='0001', name='一般检查', helpCode='YBJC', sex='0', remark='一般检查', attention='无', 
			checkItems=[
				CheckItem{id=31, code='0004', name='心肺复苏', sex='1', age='0-100', price=51.0, type='2', remark='心肺复苏', attention='无'}, 
				CheckItem{id=33, code='0006', name='裸视力（右）', sex='0', age='0-100', price=5.0, type='1', remark='裸视力（右）', attention='无'}
			]
		}, 
		CheckGroup{id=6, code='0002', name='视力色觉', helpCode='SLSJ', sex='0', remark='视力色觉', attention='null', 
			checkItems=[
				CheckItem{id=33, code='0006', name='裸视力（右）', sex='0', age='0-100', price=5.0, type='1', remark='裸视力（右）', attention='无'}, 
				CheckItem{id=34, code='0007', name='裸视力（左）', sex='0', age='0-100', price=5.0, type='1', remark='裸视力（左）', attention='无'}, 
				CheckItem{id=35, code='0008', name='矫正视力（右）', sex='0', age='0-100', price=5.0, type='1', remark='矫正视力（右）', attention='无'}, 
				CheckItem{id=36, code='0009', name='矫正视力（左）', sex='0', age='0-100', price=5.0, type='1', remark='矫正视力（左）', attention='无'}, 
				CheckItem{id=37, code='0010', name='色觉', sex='0', age='0-100', price=5.0, type='1', remark='色觉', attention='无'}
			]
		}, 
		CheckGroup{id=7, code='0003', name='血常规', helpCode='XCG', sex='0', remark='血常规', attention='null', 
			checkItems=[
				CheckItem{id=38, code='0011', name='白细胞计数', sex='0', age='0-100', price=10.0, type='2', remark='白细胞计数', attention='无'}, 
				CheckItem{id=39, code='0012', name='红细胞计数', sex='0', age='0-100', price=10.0, type='2', remark='红细胞计数', attention='null'},
				CheckItem{id=40, code='0013', name='血红蛋白', sex='0', age='0-100', price=10.0, type='2', remark='血红蛋白', attention='null'}, 
				CheckItem{id=41, code='0014', name='红细胞压积', sex='0', age='0-100', price=10.0, type='2', remark='红细胞压积', attention='null'}, 
				CheckItem{id=42, code='0015', name='平均红细胞体积', sex='0', age='0-100', price=10.0, type='2', remark='平均红细胞体积', attention='null'}, 
			    CheckItem{id=43, code='0016', name='平均红细胞血红蛋白含量', sex='0', age='0-100', price=10.0, type='2', remark='平均红细胞血红蛋白含量', attention='null'}, 
			    CheckItem{id=44, code='0017', name='平均红细胞血红蛋白浓度', sex='0', age='0-100', price=10.0, type='2', remark='平均红细胞血红蛋白浓度', attention='null'}, 
			    CheckItem{id=45, code='0018', name='红细胞分布宽度-变异系数', sex='0', age='0-100', price=10.0, type='2', remark='红细胞分布宽度-变异系数', attention='null'}, CheckItem{id=46, code='0019', name='血小板计数', sex='0', age='0-100', price=10.0, type='2', remark='血小板计数', attention='null'}, 
			    CheckItem{id=47, code='0020', name='平均血小板体积', sex='0', age='0-100', price=10.0, type='2', remark='平均血小板体积', attention='null'}, 
			    CheckItem{id=48, code='0021', name='血小板分布宽度', sex='0', age='0-100', price=10.0, type='2', remark='血小板分布宽度', attention='null'}, 
			    CheckItem{id=49, code='0022', name='淋巴细胞百分比', sex='0', age='0-100', price=10.0, type='2', remark='淋巴细胞百分比', attention='null'}, 
			    CheckItem{id=50, code='0023', name='中间细胞百分比', sex='0', age='0-100', price=10.0, type='2', remark='中间细胞百分比', attention='null'}, 
			    CheckItem{id=51, code='0024', name='中性粒细胞百分比', sex='0', age='0-100', price=10.0, type='2', remark='中性粒细胞百分比', attention='null'}, 
			    CheckItem{id=52, code='0025', name='淋巴细胞绝对值', sex='0', age='0-100', price=10.0, type='2', remark='淋巴细胞绝对值', attention='null'}, 
			    CheckItem{id=53, code='0026', name='中间细胞绝对值', sex='0', age='0-100', price=10.0, type='2', remark='中间细胞绝对值', attention='null'}, 
			    CheckItem{id=54, code='0027', name='中性粒细胞绝对值', sex='0', age='0-100', price=10.0, type='2', remark='中性粒细胞绝对值', attention='null'}, 
			    CheckItem{id=55, code='0028', name='红细胞分布宽度-标准差', sex='0', age='0-100', price=10.0, type='2', remark='红细胞分布宽度-标准差', attention='null'},
			    CheckItem{id=56, code='0029', name='血小板压积', sex='0', age='0-100', price=10.0, type='2', remark='血小板压积', attention='null'}
			]
		}, 
	]
}

五、短信发送

1.短信服务介绍

目前市面上有很多第三方提供的短信服务，这些第三方短信服务会和各个运营商（移动、联通、电信）对接，我们只需要注册成为会员并且按照提供的开发文档进行调用就可以发送短信。需要说明的是这些短信服务都是收费的服务。
本项目短信发送我们选择的是阿里云提供的短信服务。
短信服务（Short Message Service）是阿里云为用户提供的一种通信服务的能力，支持快速发送短信验证码、短信通知等。三网合一专属通道，与工信部携号转网平台实时互联。电信级运维保障，实时监控自动切换，到达率高达99%。短信服务API提供短信发送、发送状态查询、短信批量发送等能力，在短信服务控制台上添加签名、模板并通过审核之后，可以调用短信服务API完成短信发送等操作。

2.注册阿里云账号：阿里云官网：https://www.aliyun.com/

验证通过之后，然后快速实名认证。

点击个人实名认证，推荐使用个人支付宝授权认证

注册短信业务：

创建AccessKey

3.发送短信

在health_common工程中添加依赖:

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>3.3.1</version>
</dependency>
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-dysmsapi</artifactId>
    <version>1.0.0</version>
</dependency>

封装工具类，前面已经导入SMSUtis工具类。
测试短信是否能够成功发送

package com.oracle.utils;

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsRequest;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.http.MethodType;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;

/**
 * 短信发送工具类
 */
public class SMSUtils {
    public static final String VALIDATE_CODE = "SMS_193233372";//发送短信验证码
    public static final String ORDER_NOTICE = "SMS_159771588";//体检预约成功通知

    /**
     * 发送短信
     * @param phoneNumbers
     * @param param
     * @throws ClientException
     */
    public static void sendShortMessage(String templateCode,String phoneNumbers,String param) throws ClientException {
        // 设置超时时间-可自行调整
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");
        // 初始化ascClient需要的几个参数
        final String product = "Dysmsapi";// 短信API产品名称（短信产品名固定，无需修改）
        final String domain = "dysmsapi.aliyuncs.com";// 短信API产品域名（接口地址固定，无需修改）
        // 替换成你的AK
        final String accessKeyId = "LTAI4GEC5ULqFHxSsxXUPS4P";// 你的accessKeyId,参考本文档步骤2
        final String accessKeySecret = "QxCqQM6TXXyjv8ZbIEC4NgCDkMPdID";// 你的accessKeySecret，参考本文档步骤2
        // 初始化ascClient,暂时不支持多region（请勿修改）
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
        IAcsClient acsClient = new DefaultAcsClient(profile);
        // 组装请求对象
        SendSmsRequest request = new SendSmsRequest();
        // 使用post提交
        request.setMethod(MethodType.POST);
        // 必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式
        request.setPhoneNumbers(phoneNumbers);
        // 必填:短信签名-可在短信控制台中找到
        request.setSignName("FlyHigh健康管理云");
        // 必填:短信模板-可在短信控制台中找到
        request.setTemplateCode(templateCode);
        // 可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时,此处的值为
        // 友情提示:如果JSON中需要带换行符,请参照标准的JSON协议对换行符的要求,比如短信内容中包含\r\n的情况在JSON中需要表示成\\r\\n,否则会导致JSON在服务端解析失败
        request.setTemplateParam("{\"code\":\""+param+"\"}");
        // 可选-上行短信扩展码(扩展码字段控制在7位或以下，无特殊需求用户请忽略此字段)
        // request.setSmsUpExtendCode("90997");
        // 可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者
        // request.setOutId("yourOutId");
        // 请求失败这里会抛ClientException异常
        SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request);
        if (sendSmsResponse.getCode() != null && sendSmsResponse.getCode().equals("OK")) {
            // 请求成功
            System.out.println("请求成功");
        }
    }
}

package com.oracle.test;

import com.oracle.utils.SMSUtils;
import com.oracle.utils.ValidateCodeUtils;
import org.junit.Test;

public class TestSMSUtis {
    @Test
    public void test() throws Exception{
        SMSUtils.sendShortMessage("SMS_193233372","18573144847","1234");
    }
}

短信发送工具类注意事项

项目几个容易忽略的出错的地方

原文链接：https://blog.csdn.net/weixin_43908333/article/details/106815822