SpringBoot jpa调用MySQL存储过程

########################################################
###datasource  配置MYSQL数据源；
########################################################
## 数据库
spring.jpa.database = MYSQL
spring.jpa.show-sql = true
spring.datasource.url=jdbc:mysql://IP:3306/food?useUnicode=true&characterEncoding=UTF-8
spring.datasource.username=root
#spring.datasource.password=root
spring.datasource.password=123456
########################################################
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.tomcat.max-active=100
spring.datasource.tomcat.max-idle=200
spring.datasource.tomcat.initialSize=20
# Hibernate ddl auto (create, create-drop, update)
spring.jpa.properties.hibernate.hbm2ddl.auto=update
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect
spring.jpa.database-platform=org.hibernate.dialect.MySQL5Dialect
#这个东西建议有，不知道为什么，放他之后，请求数据库的一些问题自动就没了
spring.cache.ehcache.config=classpath:ehcache.xml

<?xml version="1.0" encoding="UTF-8"?>
<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:noNamespaceSchemaLocation="ehcache.xsd">
    <cache name="SysUsers"  maxEntriesLocalHeap="200"  timeToLiveSeconds="600"> </cache>
</ehcache>

@Entity
@Table(name = "prod_sale_master") //表名
@Component
/***********配置存储过程地方***************************/
@NamedStoredProcedureQueries({//一个实体类涉及多个存储过程时，注意配置的格式@***（{}）
    @NamedStoredProcedureQuery(//配置单个存储过程
name="p_prod_sale_make" ,//springboot jpa 调用的名字
procedureName = "p_prod_sale_make" ,//mysql调用存储过程的名字
 parameters = {//要传的参数
//in表示传入 out表示传出或者说是返回值
//name表示存储过程要用的参数名称
//type表示要传入参数的类型
@StoredProcedureParameter(mode=ParameterMode.IN,name="v_rec_emp",type=String.class),
        @StoredProcedureParameter(mode=ParameterMode.IN,name="v_mem_card",type=String.class),
        @StoredProcedureParameter(mode=ParameterMode.IN,name="v_Room_Code",type=String.class),
        @StoredProcedureParameter(mode=ParameterMode.IN,name="v_Mem_Cnt",type=Integer.class),
        @StoredProcedureParameter(mode=ParameterMode.OUT,name="v_Err_Msg",type=String.class)
    }),
    @NamedStoredProcedureQuery(name="p_chg_room" ,procedureName = "p_chg_room" , parameters = {
        @StoredProcedureParameter(mode=ParameterMode.IN,name="v_Bill_Code",type=String.class),
        @StoredProcedureParameter(mode=ParameterMode.IN,name="v_Room_Code",type=String.class),
        @StoredProcedureParameter(mode=ParameterMode.OUT,name="v_Err_Msg",type=String.class)
    })
    })
})
/*****************************************/
public class ProdSaleMaster {//实体名
  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  @Column(name="rec_id")//建议个数据库的名字一样 全部对应 无论大小写
  private Integer rec_id;//序号
  @Column(name="bill_code")
          /////set()/get()
}

@Autowired
private EntityManager entityManager;
@Override
  public Object saveProdSaleMaster(String v_rec_emp, String v_mem_card, String v_Room_Code, int v_Mem_Cnt) {
    Result resultLogin = new Result();
    try {
/**************存储过程使用配置地方***********************************************/
//StoredProcedureQuery 创建存储过程仓库
//createStoredProcedureQuery（name） - 》 name表示 springboot jpa配置的名称：见entity.java的name
//registerStoredProcedureParameter表示存储过程中注册的参数
//ParameterMode 其中的in/out和entity.java中配置一样
      StoredProcedureQuery storedProcedureQuery = this.entityManager.createStoredProcedureQuery("p_prod_sale_make");
      storedProcedureQuery.registerStoredProcedureParameter("v_rec_emp", String.class, ParameterMode.IN);
      storedProcedureQuery.registerStoredProcedureParameter("v_mem_card", String.class, ParameterMode.IN);
      storedProcedureQuery.registerStoredProcedureParameter("v_Room_Code", String.class, ParameterMode.IN);
      storedProcedureQuery.registerStoredProcedureParameter("v_Mem_Cnt", Integer.class, ParameterMode.IN);
      storedProcedureQuery.registerStoredProcedureParameter("v_Err_Msg", String.class, ParameterMode.OUT);
//  setParameter 给存储过程配置你要传入的参数   
      storedProcedureQuery.setParameter("v_rec_emp",v_rec_emp);
      storedProcedureQuery.setParameter("v_mem_card", v_mem_card);
      storedProcedureQuery.setParameter("v_Room_Code",v_Room_Code);
      storedProcedureQuery.setParameter("v_Mem_Cnt", (int) v_Mem_Cnt);
//存储过程执行调用
      storedProcedureQuery.execute();
//getOutputParameterValue 存储过程执行后，返回的结果，直接取就可以，返回类型只有一个Object类型
      Object v_User_Rht = storedProcedureQuery.getOutputParameterValue("v_Err_Msg");
/*****************************************************************/
      return v_User_Rht;
    } catch (Exception e) {
      resultLogin.setStatus(0);
      resultLogin.setData(null);
      resultLogin.setMessage("请求失败！");
      e.printStackTrace();
      return resultLogin; 
    }finally {
      this.entityManager.close();
    }
  }

BEGIN
        IF  条件  THEN
                IF 条件 THEN 
                ELSEIF 条件 THEN
                ELSEIF 条件 THEN
                ELSE 
                END If;
        ELSE 
                IF 条件 THEN 
                ELSEIF 条件 THEN
                ELSEIF 条件 THEN
                ELSE 
                END If;
         END IF
END

CREATE DEFINER = 'root'@'localhost'
PROCEDURE logistics.p_scan_task(IN  v_billId varchar(255) CHARSET utf8mb4 COLLATE utf8mb4_unicode_ci, IN  v_courierUserId varchar(255) CHARSET utf8mb4 COLLATE utf8mb4_unicode_ci, OUT v_Err_Msg  varchar(255))
BEGIN
  DECLARE v_BillStatus varchar(255);
  DECLARE v_Userid varchar(255);
  DECLARE v_status varchar(255);
  DECLARE v_pay_status varchar(255);
  DECLARE v_pay_cost varchar(255);
  SELECT bill_status,courier_user_id,status,pay_status, pay_cost FROM platform_lading_bill WHERE bill_id=v_billId INTO v_BillStatus, v_Userid, v_pay_status , v_pay_cost;
  IF v_pay_status = '1' THEN
          IF  v_BillStatus='3' AND v_status='0' AND v_Userid IS NULL THEN  
              UPDATE platform_lading_bill SET bill_status='7', status='1' , courier_user_id=v_courierUserId  WHERE bill_id=v_billId  ;      
              SET v_Err_Msg = CONCAT('{"state":0,"msg":"Посылка готова, скоро отправиться!"}');##取件成功，准备派送
          ELSEIF v_BillStatus='7'  AND v_status='1' AND v_Userid IS NOT NULL AND v_Userid = v_courierUserId THEN 
              UPDATE platform_lading_bill SET bill_status='8', status='1' , courier_user_id=v_courierUserId  WHERE bill_id=v_billId  ;
              SET v_Err_Msg = CONCAT('{"state":0,"msg":"Уже отправлена, пользователь получил!"}') ;##派送已完成，用户已收货
          ELSEIF v_BillStatus='10'  AND v_Userid IS NOT NULL AND v_Userid = v_courierUserId THEN      
              SET v_Err_Msg = CONCAT('{"state":0,"msg":"Пользователь отказал в получении!"}') ;##用户已拒收       
          ELSE   
            SET v_Err_Msg = CONCAT('{"state":0,"msg":"Правильно отсканируйте трекинг-номер!"}') ;##请正确扫描物流单号
          END IF;
  ELSE
          SET v_Err_Msg = CONCAT('{"state":0,"msg":"未支付","data":{"billInfo":[{"courierUserId":"',v_courierUserId,'","pay_cost":"',v_pay_cost,'","pay_status":"',v_pay_status,'"}]}}') ;##未支付
       END IF;
END