Day_04 傳智健康項目-預約管理-套餐管理

胖ۣۖ虎ۣۖ 2022-06-23 06:19:15 阅读数:747

day_04day健康管理套餐

第4章 預約管理-套餐管理

1. 圖片存儲方案

1.1 介紹

在實際開發中,我們會有很多處理不同功能的服務器。例如:

應用服務器:負責部署我們的應用

數據庫服務器:運行我們的數據庫

文件服務器:負責存儲用戶上傳文件的服務器

請添加圖片描述

分服務器處理的目的是讓服務器各司其職,從而提高我們項目的運行效率。

常見的圖片存儲方案:

方案一:使用nginx搭建圖片服務器

方案二:使用開源的分布式文件存儲系統,例如Fastdfs、HDFS等

方案三:使用雲存儲,例如阿裏雲、七牛雲等

1.2 七牛雲存儲

七牛雲(隸屬於上海七牛信息技術有限公司)是國內領先的以視覺智能和數據智能為核心的企業級雲計算服務商,同時也是國內知名智能視頻雲服務商,累計為 70 多萬家企業提供服務,覆蓋了國內80%網民。圍繞富媒體場景推出了對象存儲、融合 CDN 加速、容器雲、大數據平臺、深度學習平臺等產品、並提供一站式智能視頻雲解决方案。為各行業及應用提供可持續發展的智能視頻雲生態,幫助企業快速上雲,創造更廣闊的商業價值。

官網:https://www.qiniu.com/

通過七牛雲官網介紹我們可以知道其提供了多種服務,我們主要使用的是七牛雲提供的對象存儲服務來存儲圖片。

1.2.1 注册、登錄

要使用七牛雲的服務,首先需要注册成為會員。地址:https://portal.qiniu.com/signup

請添加圖片描述

注册完成後就可以使用剛剛注册的郵箱和密碼登錄到七牛雲:

登錄成功後點擊頁面右上角管理控制臺:

請添加圖片描述

注意:登錄成功後還需要進行實名認證才能進行相關操作。

1.2.2 新建存儲空間

要進行圖片存儲,我們需要在七牛雲管理控制臺新建存儲空間。點擊管理控制臺首頁對象存儲下的立即添加按鈕,頁面跳轉到新建存儲空間頁面:

請添加圖片描述

可以創建多個存儲空間,各個存儲空間是相互獨立的。

1.2.3 查看存儲空間信息

存儲空間創建後,會在左側的存儲空間列錶菜單中展示創建的存儲空間名稱,點擊存儲空間名稱可以查看當前存儲空間的相關信息

請添加圖片描述

1.2.4 開發者中心

可以通過七牛雲提供的開發者中心學習如何操作七牛雲服務,地址:https://developer.qiniu.com/

請添加圖片描述

點擊對象存儲,跳轉到對象存儲開發頁面,地址:https://developer.qiniu.com/kodo

七牛雲提供了多種方式操作對象存儲服務,本項目采用Java SDK方式,地址:https://developer.qiniu.com/kodo/sdk/1239/java

請添加圖片描述

使用Java SDK操作七牛雲需要導入如下maven坐標:

<dependency>
<groupId>com.qiniu</groupId>
<artifactId>qiniu-java-sdk</artifactId>
<version>7.2.0</version>
</dependency>

1.2.5 鑒權

Java SDK的所有的功能,都需要合法的授權。授權憑證的簽算需要七牛賬號下的一對有效的Access Key和Secret Key,這對密鑰可以在七牛雲管理控制臺的個人中心(https://portal.qiniu.com/user/key)獲得,如下圖:
請添加圖片描述

1.2.6 Java SDK操作七牛雲

本章節我們就需要使用七牛雲提供的Java SDK完成圖片上傳和删除,我們可以參考官方提供的例子。

//構造一個帶指定Zone對象的配置類
Configuration cfg = new Configuration(Zone.zone0());
//...其他參數參考類注釋
UploadManager uploadManager = new UploadManager(cfg);
//...生成上傳憑證,然後准備上傳
String accessKey = "your access key";
String secretKey = "your secret key";
String bucket = "your bucket name";
//如果是Windows情况下,格式是 D:\\qiniu\\test.png
String localFilePath = "/home/qiniu/test.png";
//默認不指定key的情况下,以文件內容的hash值作為文件名
String key = null;
Auth auth = Auth.create(accessKey, secretKey);
String upToken = auth.uploadToken(bucket);
try {

Response response = uploadManager.put(localFilePath, key, upToken);
//解析上傳成功的結果
DefaultPutRet putRet = new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
System.out.println(putRet.key);
System.out.println(putRet.hash);
} catch (QiniuException ex) {

Response r = ex.response;
System.err.println(r.toString());
try {

System.err.println(r.bodyString());
} catch (QiniuException ex2) {

//ignore
}
}
//構造一個帶指定Zone對象的配置類
Configuration cfg = new Configuration(Zone.zone0());
//...其他參數參考類注釋
String accessKey = "your access key";
String secretKey = "your secret key";
String bucket = "your bucket name";
String key = "your file key";
Auth auth = Auth.create(accessKey, secretKey);
BucketManager bucketManager = new BucketManager(auth, cfg);
try {

bucketManager.delete(bucket, key);
} catch (QiniuException ex) {

//如果遇到异常,說明删除失敗
System.err.println(ex.code());
System.err.println(ex.response.toString());
}

1.2.7 封裝工具類

為了方便操作七牛雲存儲服務,我們可以將官方提供的案例簡單改造成一個工具類,在我們的項目中直接使用此工具類來操作就可以:

package com.itheima.utils;
import com.google.gson.Gson;
import com.qiniu.common.QiniuException;
import com.qiniu.common.Zone;
import com.qiniu.http.Response;
import com.qiniu.storage.BucketManager;
import com.qiniu.storage.Configuration;
import com.qiniu.storage.UploadManager;
import com.qiniu.storage.model.DefaultPutRet;
import com.qiniu.util.Auth;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
/** * 七牛雲工具類 */
public class QiniuUtils {

public static String accessKey = "dulF9Wze9bxujtuRvu3yyYb9JX1Sp23jzd3tO708";
public static String secretKey = "vZkhW7iot3uWwcWz9vXfbaP4JepdWADFDHVLMZOe";
public static String bucket = "qiniutest";
public static void upload2Qiniu(String filePath,String fileName){

//構造一個帶指定Zone對象的配置類
Configuration cfg = new Configuration(Zone.zone0());
UploadManager uploadManager = new UploadManager(cfg);
Auth auth = Auth.create(accessKey, secretKey);
String upToken = auth.uploadToken(bucket);
try {

Response response = uploadManager.put(filePath, fileName, upToken);
//解析上傳成功的結果
DefaultPutRet putRet =
new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
} catch (QiniuException ex) {

Response r = ex.response;
try {

System.err.println(r.bodyString());
} catch (QiniuException ex2) {

//ignore
}
}
}
//上傳文件
public static void upload2Qiniu(byte[] bytes, String fileName){

//構造一個帶指定Zone對象的配置類
Configuration cfg = new Configuration(Zone.zone0());
//...其他參數參考類注釋
UploadManager uploadManager = new UploadManager(cfg);
//默認不指定key的情况下,以文件內容的hash值作為文件名
String key = fileName;
Auth auth = Auth.create(accessKey, secretKey);
String upToken = auth.uploadToken(bucket);
try {

Response response = uploadManager.put(bytes, key, upToken);
//解析上傳成功的結果
DefaultPutRet putRet =
new Gson().fromJson(response.bodyString(), DefaultPutRet.class);
System.out.println(putRet.key);
System.out.println(putRet.hash);
} catch (QiniuException ex) {

Response r = ex.response;
System.err.println(r.toString());
try {

System.err.println(r.bodyString());
} catch (QiniuException ex2) {

//ignore
}
}
}
//删除文件
public static void deleteFileFromQiniu(String fileName){

//構造一個帶指定Zone對象的配置類
Configuration cfg = new Configuration(Zone.zone0());
String key = fileName;
Auth auth = Auth.create(accessKey, secretKey);
BucketManager bucketManager = new BucketManager(auth, cfg);
try {

bucketManager.delete(bucket, key);
} catch (QiniuException ex) {

//如果遇到异常,說明删除失敗
System.err.println(ex.code());
System.err.println(ex.response.toString());
}
}
}

將此工具類放在health_common工程中,後續會使用到。

2. 新增套餐

2.1 需求分析

套餐其實就是檢查組的集合,例如有一個套餐為“入職體檢套餐”,這個體檢套餐可以包括多個檢查組:一般檢查、血常規、尿常規、肝功三項等。所以在添加套餐時需要選擇這個套餐包括的檢查組。

套餐對應的實體類為Setmeal,對應的數據錶為t_setmeal。套餐和檢查組為多對多關系,所以需要中間錶t_setmeal_checkgroup進行關聯。

2.2 完善頁面

套餐管理頁面對應的是setmeal.html頁面,根據產品設計的原型已經完成了頁面基本結構的編寫,現在需要完善頁面動態效果。

2.2.1 彈出新增窗口

頁面中已經提供了新增窗口,只是出於隱藏狀態。只需要將控制展示狀態的屬性dialogFormVisible改為true接口顯示出新增窗口。點擊新建按鈕時綁定的方法為handleCreate,所以在handleCreate方法中修改dialogFormVisible屬性的值為true即可。同時為了增加用戶體驗度,需要每次點擊新建按鈕時清空錶單輸入項。

由於新增套餐時還需要選擇此套餐包含的檢查組,所以新增套餐窗口分為兩部分信息:基本信息和檢查組信息,如下圖:

請添加圖片描述

新建按鈕綁定單擊事件,對應的處理函數為handleCreate

<el-button type="primary" class="butT" @click="handleCreate()">新建</el-button>
// 重置錶單
resetForm() {

this.formData = {
};
this.activeName='first';
this.checkgroupIds = [];
this.imageUrl = null;
}
// 彈出添加窗口
handleCreate() {

this.dialogFormVisible = true;
this.resetForm();
}

2.2.2 動態展示檢查組列錶

現在雖然已經完成了新增窗口的彈出,但是在檢查組信息標簽頁中需要動態展示所有的檢查組信息列錶數據,並且可以進行勾選。具體操作步驟如下:

(1)定義模型數據

tableData:[],//添加錶單窗口中檢查組列錶數據
checkgroupIds:[],//添加錶單窗口中檢查組複選框對應id

(2)動態展示檢查組列錶數據,數據來源於上面定義的tableData模型數據

<table class="datatable">
<thead>
<tr>
<th>選擇</th>
<th>項目編碼</th>
<th>項目名稱</th>
<th>項目說明</th>
</tr>
</thead>
<tbody>
<tr v-for="c in tableData">
<td>
<input :id="c.id" v-model="checkgroupIds" type="checkbox" :value="c.id">
</td>
<td><label :for="c.id">{
{c.code}}</label></td>
<td><label :for="c.id">{
{c.name}}</label></td>
<td><label :for="c.id">{
{c.remark}}</label></td>
</tr>
</tbody>
</table>

(3)完善handleCreate方法,發送ajax請求查詢所有檢查組數據並將結果賦值給tableData模型數據用於頁面錶格展示

// 彈出添加窗口
handleCreate() {

this.dialogFormVisible = true;
this.resetForm();
axios.get("/checkgroup/findAll.do").then((res)=> {

if(res.data.flag){

this.tableData = res.data.data;
}else{

this.$message.error(res.data.message);
}
});
}

(4)分別在CheckGroupController、CheckGroupService、CheckGroupServiceImpl、CheckGroupDao、CheckGroupDao.xml中擴展方法查詢所有檢查組數據

CheckGroupController:

//查詢所有
@RequestMapping("/findAll")
public Result findAll(){

List<CheckGroup> checkGroupList = checkGroupService.findAll();
if(checkGroupList != null && checkGroupList.size() > 0){

Result result = new Result(true, MessageConstant.QUERY_CHECKGROUP_SUCCESS);
result.setData(checkGroupList);
return result;
}
return new Result(false,MessageConstant.QUERY_CHECKGROUP_FAIL);
}

CheckGroupService:

List<CheckGroup> findAll();

CheckGroupServiceImpl:

public List<CheckGroup> findAll() {

return checkGroupDao.findAll();
}

CheckGroupDao:

List<CheckGroup> findAll();

CheckGroupDao.xml:

<select id="findAll" resultType="com.itheima.pojo.CheckGroup">
select * from t_checkgroup
</select>

2.2.3 圖片上傳並預覽

此處使用的是ElementUI提供的上傳組件el-upload,提供了多種不同的上傳效果,上傳成功後可以進行預覽。

實現步驟:

(1)定義模型數據,用於後面上傳文件的圖片預覽:

imageUrl:null,//模型數據,用於上傳圖片完成後圖片預覽

(2)定義上傳組件:

<!-- el-upload:上傳組件 action:上傳的提交地址 auto-upload:選中文件後是否自動上傳 name:上傳文件的名稱,服務端可以根據名稱獲得上傳的文件對象 show-file-list:是否顯示已上傳文件列錶 on-success:文件上傳成功時的鉤子 before-upload:上傳文件之前的鉤子 -->
<el-upload class="avatar-uploader" action="/setmeal/upload.do" :auto-upload="autoUpload" name="imgFile" :show-file-list="false" :on-success="handleAvatarSuccess" :before-upload="beforeAvatarUpload">
<!--用於上傳圖片預覽-->
<img v-if="imageUrl" :src="imageUrl" class="avatar">
<!--用於展示上傳圖標-->
<i v-else class="el-icon-plus avatar-uploader-icon"></i>
</el-upload>

(3)定義對應的鉤子函數:

//文件上傳成功後的鉤子,response為服務端返回的值,file為當前上傳的文件封裝成的js對象
handleAvatarSuccess(response, file) {

this.imageUrl = "http://pqjroc654.bkt.clouddn.com/"+response.data;
this.$message({

message: response.message,
type: response.flag ? 'success' : 'error'
});
//設置模型數據(圖片名稱),後續提交ajax請求時會提交到後臺最終保存到數據庫
this.formData.img = response.data;
}
//上傳文件之前的鉤子
beforeAvatarUpload(file) {

const isJPG = file.type === 'image/jpeg';
const isLt2M = file.size / 1024 / 1024 < 2;
if (!isJPG) {

this.$message.error('上傳套餐圖片只能是 JPG 格式!');
}
if (!isLt2M) {

this.$message.error('上傳套餐圖片大小不能超過 2MB!');
}
return isJPG && isLt2M;
}

(4)創建SetmealController,接收上傳的文件

package com.itheima.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.itheima.constant.MessageConstant;
import com.itheima.entity.PageResult;
import com.itheima.entity.QueryPageBean;
import com.itheima.entity.Result;
import com.itheima.pojo.CheckGroup;
import com.itheima.pojo.Setmeal;
import com.itheima.service.CheckGroupService;
import com.itheima.service.SetmealService;
import com.itheima.utils.QiniuUtils;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import java.io.File;
import java.util.List;
import java.util.UUID;
/** * 套餐管理 */
@RestController
@RequestMapping("/setmeal")
public class SetmealController {

@Reference
private SetmealService setmealService;
//圖片上傳
@RequestMapping("/upload")
public Result upload(@RequestParam("imgFile")MultipartFile imgFile){

try{

//獲取原始文件名
String originalFilename = imgFile.getOriginalFilename();
int lastIndexOf = originalFilename.lastIndexOf(".");
//獲取文件後綴
String suffix = originalFilename.substring(lastIndexOf - 1);
//使用UUID隨機產生文件名稱,防止同名文件覆蓋
String fileName = UUID.randomUUID().toString() + suffix;
QiniuUtils.upload2Qiniu(imgFile.getBytes(),fileName);
//圖片上傳成功
Result result = new Result(true, MessageConstant.PIC_UPLOAD_SUCCESS);
result.setData(fileName);
return result;
}catch (Exception e){

e.printStackTrace();
//圖片上傳失敗
return new Result(false,MessageConstant.PIC_UPLOAD_FAIL);
}
}
}

注意:別忘了在spring配置文件中配置文件上傳組件

<!--文件上傳組件-->
<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
<property name="maxUploadSize" value="104857600" />
<property name="maxInMemorySize" value="4096" />
<property name="defaultEncoding" value="UTF-8"/>
</bean>

2.2.4 提交請求

當用戶點擊新增窗口中的確定按鈕時發送ajax請求將數據提交到後臺進行數據庫操作。提交到後臺的數據分為兩部分:套餐基本信息(對應的模型數據為formData)和檢查組id數組(對應的模型數據為checkgroupIds)。

為確定按鈕綁定單擊事件,對應的處理函數為handleAdd

<el-button type="primary" @click="handleAdd()">確定</el-button>

完善handleAdd方法

//添加
handleAdd () {

axios.post("/setmeal/add.do?checkgroupIds=" + this.checkgroupIds,this.formData).
then((response)=> {

this.dialogFormVisible = false;
if(response.data.flag){

this.$message({

message: response.data.message,
type: 'success'
});
}else{

this.$message.error(response.data.message);
}
}).finally(()=> {

this.findPage();
});
}

2.3 後臺代碼

2.3.1 Controller

在SetmealController中增加方法

//新增
@RequestMapping("/add")
public Result add(@RequestBody Setmeal setmeal, Integer[] checkgroupIds){

try {

setmealService.add(setmeal,checkgroupIds);
}catch (Exception e){

//新增套餐失敗
return new Result(false,MessageConstant.ADD_SETMEAL_FAIL);
}
//新增套餐成功
return new Result(true,MessageConstant.ADD_SETMEAL_SUCCESS);
}

2.3.2 服務接口

創建SetmealService接口並提供新增方法

package com.itheima.service;
import com.itheima.entity.PageResult;
import com.itheima.pojo.CheckGroup;
import com.itheima.pojo.Setmeal;
import java.util.List;
/** * 體檢套餐服務接口 */
public interface SetmealService {

public void add(Setmeal setmeal, Integer[] checkgroupIds);
}

2.3.3 服務實現類

創建SetmealServiceImpl服務實現類並實現新增方法

package com.itheima.service;
import com.alibaba.dubbo.config.annotation.Service;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.itheima.dao.SetmealDao;
import com.itheima.entity.PageResult;
import com.itheima.pojo.Setmeal;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/** * 體檢套餐服務實現類 */
@Service(interfaceClass = SetmealService.class)
@Transactional
public class SetmealServiceImpl implements SetmealService {

@Autowired
private SetmealDao setmealDao;
//新增套餐
public void add(Setmeal setmeal, Integer[] checkgroupIds) {

setmealDao.add(setmeal);
if(checkgroupIds != null && checkgroupIds.length > 0){

//綁定套餐和檢查組的多對多關系
setSetmealAndCheckGroup(setmeal.getId(),checkgroupIds);
}
}
//綁定套餐和檢查組的多對多關系
private void setSetmealAndCheckGroup(Integer id, Integer[] checkgroupIds) {

for (Integer checkgroupId : checkgroupIds) {

Map<String,Integer> map = new HashMap<>();
map.put("setmeal_id",id);
map.put("checkgroup_id",checkgroupId);
setmealDao.setSetmealAndCheckGroup(map);
}
}
}

2.3.4 Dao接口

創建SetmealDao接口並提供相關方法

package com.itheima.dao;
import com.itheima.pojo.Setmeal;
import java.util.Map;
public interface SetmealDao {

public void add(Setmeal setmeal);
public void setSetmealAndCheckGroup(Map<String, Integer> map);
}

2.3.5 Mapper映射文件

創建SetmealDao.xml文件並定義相關SQL語句

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.itheima.dao.SetmealDao" >
<!--新增-->
<insert id="add" parameterType="com.itheima.pojo.Setmeal">
<selectKey resultType="java.lang.Integer" order="AFTER" keyProperty="id">
SELECT LAST_INSERT_ID()
</selectKey>
insert into t_setmeal
(code,name,sex,age,helpCode,price,remark,attention,img)
values
(#{code},#{name},#{sex},#{age},#{helpCode},#{price},#{remark},#{attention},#{img})
</insert>
<!--綁定套餐和檢查組多對多關系-->
<insert id="setSetmealAndCheckGroup" parameterType="hashmap">
insert into t_setmeal_checkgroup
(setmeal_id,checkgroup_id)
values
(#{setmeal_id},#{checkgroup_id})
</insert>
</mapper>

2.4 完善文件上傳

前面我們已經完成了文件上傳,將圖片存儲在了七牛雲服務器中。但是這個過程存在一個問題,就是如果用戶只上傳了圖片而沒有最終保存套餐信息到我們的數據庫,這時我們上傳的圖片就變為了垃圾圖片。對於這些垃圾圖片我們需要定時清理來釋放磁盤空間。這就需要我們能够區分出來哪些是垃圾圖片,哪些不是垃圾圖片。如何實現呢?

方案就是利用redis來保存圖片名稱,具體做法為:

1、當用戶上傳圖片後,將圖片名稱保存到redis的一個Set集合中,例如集合名稱為setmealPicResources

2、當用戶添加套餐後,將圖片名稱保存到redis的另一個Set集合中,例如集合名稱為setmealPicDbResources

3、計算setmealPicResources集合與setmealPicDbResources集合的差值,結果就是垃圾圖片的名稱集合,清理這些圖片即可

本小節我們先來完成前面2個環節,第3個環節(清理圖片環節)在後面會通過定時任務再實現。

實現步驟:

(1)在health_backend項目中提供Spring配置文件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">
<!--Jedis連接池的相關配置-->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxTotal">
<value>200</value>
</property>
<property name="maxIdle">
<value>50</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="127.0.0.1" />
<constructor-arg name="port" value="6379" type="int" />
<constructor-arg name="timeout" value="30000" type="int" />
</bean>
</beans>

(2)在health_common工程中提供Redis常量類

package com.itheima.constant;
public class RedisConstant {

//套餐圖片所有圖片名稱
public static final String SETMEAL_PIC_RESOURCES = "setmealPicResources";
//套餐圖片保存在數據庫中的圖片名稱
public static final String SETMEAL_PIC_DB_RESOURCES = "setmealPicDbResources";
}

(3)完善SetmealController,在文件上傳成功後將圖片名稱保存到redis集合中

@Autowired
private JedisPool jedisPool;
//圖片上傳
@RequestMapping("/upload")
public Result upload(@RequestParam("imgFile")MultipartFile imgFile){

try{

//獲取原始文件名
String originalFilename = imgFile.getOriginalFilename();
int lastIndexOf = originalFilename.lastIndexOf(".");
//獲取文件後綴
String suffix = originalFilename.substring(lastIndexOf - 1);
//使用UUID隨機產生文件名稱,防止同名文件覆蓋
String fileName = UUID.randomUUID().toString() + suffix;
QiniuUtils.upload2Qiniu(imgFile.getBytes(),fileName);
//圖片上傳成功
Result result = new Result(true, MessageConstant.PIC_UPLOAD_SUCCESS);
result.setData(fileName);
//將上傳圖片名稱存入Redis,基於Redis的Set集合存儲
jedisPool.getResource().sadd(RedisConstant.SETMEAL_PIC_RESOURCES,fileName);
return result;
}catch (Exception e){

e.printStackTrace();
//圖片上傳失敗
return new Result(false,MessageConstant.PIC_UPLOAD_FAIL);
}
}

(4)在health_service_provider項目中提供Spring配置文件applicationContext-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">
<!--Jedis連接池的相關配置-->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxTotal">
<value>200</value>
</property>
<property name="maxIdle">
<value>50</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="127.0.0.1" />
<constructor-arg name="port" value="6379" type="int" />
<constructor-arg name="timeout" value="30000" type="int" />
</bean>
</beans>

(5)完善SetmealServiceImpl服務類,在保存完成套餐信息後將圖片名稱存儲到redis集合中

@Autowired
private JedisPool jedisPool;
//新增套餐
public void add(Setmeal setmeal, Integer[] checkgroupIds) {

setmealDao.add(setmeal);
if(checkgroupIds != null && checkgroupIds.length > 0){

setSetmealAndCheckGroup(setmeal.getId(),checkgroupIds);
}
//將圖片名稱保存到Redis
savePic2Redis(setmeal.getImg());
}
//將圖片名稱保存到Redis
private void savePic2Redis(String pic){

jedisPool.getResource().sadd(RedisConstant.SETMEAL_PIC_DB_RESOURCES,pic);
}

3. 體檢套餐分頁

3.1 完善頁面

3.1.1 定義分頁相關模型數據

pagination: {
//分頁相關模型數據
currentPage: 1,//當前頁碼
pageSize:10,//每頁顯示的記錄數
total:0,//總記錄數
queryString:null//查詢條件
},
dataList: [],//當前頁要展示的分頁列錶數據

3.1.2 定義分頁方法

在頁面中提供了findPage方法用於分頁查詢,為了能够在setmeal.html頁面加載後直接可以展示分頁數據,可以在VUE提供的鉤子函數created中調用findPage方法

//鉤子函數,VUE對象初始化完成後自動執行
created() {

this.findPage();
}
//分頁查詢
findPage() {

//分頁參數
var param = {

currentPage:this.pagination.currentPage,//頁碼
pageSize:this.pagination.pageSize,//每頁顯示的記錄數
queryString:this.pagination.queryString//查詢條件
};
//請求後臺
axios.post("/setmeal/findPage.do",param).then((response)=> {

//為模型數據賦值,基於VUE的雙向綁定展示到頁面
this.dataList = response.data.rows;
this.pagination.total = response.data.total;
});
}

3.1.3 完善分頁方法執行時機

除了在created鉤子函數中調用findPage方法查詢分頁數據之外,當用戶點擊查詢按鈕或者點擊分頁條中的頁碼時也需要調用findPage方法重新發起查詢請求。

為查詢按鈕綁定單擊事件,調用findPage方法

<el-button @click="findPage()" class="dalfBut">查詢</el-button>

為分頁條組件綁定current-change事件,此事件是分頁條組件自己定義的事件,當頁碼改變時觸發,對應的處理函數為handleCurrentChange

<el-pagination class="pagiantion" @current-change="handleCurrentChange" :current-page="pagination.currentPage" :page-size="pagination.pageSize" layout="total, prev, pager, next, jumper" :total="pagination.total">
</el-pagination>

定義handleCurrentChange方法

//切換頁碼
handleCurrentChange(currentPage) {

//currentPage為切換後的頁碼
this.pagination.currentPage = currentPage;
this.findPage();
}

3.2 後臺代碼

3.2.1 Controller

在SetmealController中增加分頁查詢方法

//分頁查詢
@RequestMapping("/findPage")
public PageResult findPage(@RequestBody QueryPageBean queryPageBean){

PageResult pageResult = setmealService.pageQuery(
queryPageBean.getCurrentPage(),
queryPageBean.getPageSize(),
queryPageBean.getQueryString()
);
return pageResult;
}

3.2.2 服務接口

在SetmealService服務接口中擴展分頁查詢方法

public PageResult pageQuery(Integer currentPage, Integer pageSize, String queryString);

3.2.3 服務實現類

在SetmealServiceImpl服務實現類中實現分頁查詢方法,基於Mybatis分頁助手插件實現分頁

public PageResult pageQuery(Integer currentPage, Integer pageSize, String queryString) {

PageHelper.startPage(currentPage,pageSize);
Page<CheckItem> page = checkGroupDao.selectByCondition(queryString);
return new PageResult(page.getTotal(),page.getResult());
}

3.2.4 Dao接口

在SetmealDao接口中擴展分頁查詢方法

public Page<Setmeal> selectByCondition(String queryString);

3.2.5 Mapper映射文件

在SetmealDao.xml文件中增加SQL定義

<!--根據條件查詢-->
<select id="selectByCondition" parameterType="string" resultType="com.itheima.pojo.Setmeal">
select * from t_setmeal
<if test="value != null and value.length > 0">
where code = #{value} or name = #{value} or helpCode = #{value}
</if>
</select>

4. 定時任務組件Quartz

4.1 Quartz介紹

Quartz是Job scheduling(作業調度)領域的一個開源項目,Quartz既可以單獨使用也可以跟spring框架整合使用,在實際開發中一般會使用後者。使用Quartz可以開發一個或者多個定時任務,每個定時任務可以單獨指定執行的時間,例如每隔1小時執行一次、每個月第一天上午10點執行一次、每個月最後一天下午5點執行一次等。

官網:http://www.quartz-scheduler.org/

maven坐標:

<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
<version>2.2.1</version>
</dependency>

4.2 Quartz入門案例

本案例基於Quartz和spring整合的方式使用。具體步驟:

(1)創建maven工程quartzdemo,導入Quartz和spring相關坐標,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">
<modelVersion>4.0.0</modelVersion>
<groupId>com.itheima</groupId>
<artifactId>quartdemo</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
<version>2.2.1</version>
</dependency>
</dependencies>
</project>

(2)自定義一個Job

package com.itheima.jobs;
/** * 自定義Job */
public class JobDemo {

public void run(){

System.out.println("job execute...");
}
}

(3)提供Spring配置文件spring-jobs.xml,配置自定義Job、任務描述、觸發器、調度工廠等

<?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: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">
<!-- 注册自定義Job -->
<bean id="jobDemo" class="com.itheima.jobs.JobDemo"></bean>
<!-- 注册JobDetail,作用是負責通過反射調用指定的Job -->
<bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<!-- 注入目標對象 -->
<property name="targetObject" ref="jobDemo"/>
<!-- 注入目標方法 -->
<property name="targetMethod" value="run"/>
</bean>
<!-- 注册一個觸發器,指定任務觸發的時間 -->
<bean id="myTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
<!-- 注入JobDetail -->
<property name="jobDetail" ref="jobDetail"/>
<!-- 指定觸發的時間,基於Cron錶達式 -->
<property name="cronExpression">
<value>0/10 * * * * ?</value>
</property>
</bean>
<!-- 注册一個統一的調度工廠,通過這個調度工廠調度任務 -->
<bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<!-- 注入多個觸發器 -->
<property name="triggers">
<list>
<ref bean="myTrigger"/>
</list>
</property>
</bean>
</beans>

(4)編寫main方法進行測試

package com.itheima.jobs.com.itheima.app;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class App {

public static void main(String[] args) {

new ClassPathXmlApplicationContext("spring-jobs.xml");
}
}

執行上面main方法觀察控制臺,可以發現每隔10秒會輸出一次,說明每隔10秒自定義Job被調用一次。

4.3 cron錶達式

上面的入門案例中我們指定了一個錶達式:0/10 * * * * ?

這種錶達式稱為cron錶達式,通過cron錶達式可以靈活的定義出符合要求的程序執行的時間。本小節我們就來學習一下cron錶達式的使用方法。如下圖:

請添加圖片描述

cron錶達式分為七個域,之間使用空格分隔。其中最後一個域(年)可以為空。每個域都有自己允許的值和一些特殊字符構成。使用這些特殊字符可以使我們定義的錶達式更加靈活。

下面是對這些特殊字符的介紹:

逗號(,):指定一個值列錶,例如使用在月域上1,4,5,7錶示1月、4月、5月和7月

橫杠(-):指定一個範圍,例如在時域上3-6錶示3點到6點(即3點、4點、5點、6點)

星號(*):錶示這個域上包含所有合法的值。例如,在月份域上使用星號意味著每個月都會觸發

斜線(/):錶示遞增,例如使用在秒域上0/15錶示每15秒

問號(?):只能用在日和周域上,但是不能在這兩個域上同時使用。錶示不指定

井號(#):只能使用在周域上,用於指定月份中的第幾周的哪一天,例如6#3,意思是某月的第三個周五 (6=星期五,3意味著月份中的第三周)

L:某域上允許的最後一個值。只能使用在日和周域上。當用在日域上,錶示的是在月域上指定的月份的最後一天。用於周域上時,錶示周的最後一天,就是星期六

W:W 字符代錶著工作日 (星期一到星期五),只能用在日域上,它用來指定離指定日的最近的一個工作日

4.4 cron錶達式在線生成器

前面介紹了cron錶達式,但是自己編寫錶達式還是有一些困難的,我們可以借助一些cron錶達式在線生成器來根據我們的需求生成錶達式即可。

http://cron.qqe2.com/

請添加圖片描述

5. 定時清理垃圾圖片

前面我們已經完成了體檢套餐的管理,在新增套餐時套餐的基本信息和圖片是分兩次提交到後臺進行操作的。也就是用戶首先將圖片上傳到七牛雲服務器,然後再提交新增窗口中錄入的其他信息。如果用戶只是上傳了圖片而沒有提交錄入的其他信息,此時的圖片就變為了垃圾圖片,因為在數據庫中並沒有記錄它的存在。此時我們要如何處理這些垃圾圖片呢?

解决方案就是通過定時任務組件定時清理這些垃圾圖片。為了能够區分出來哪些圖片是垃圾圖片,我們在文件上傳成功後將圖片保存到了一個redis集合中,當套餐數據插入到數據庫後我們又將圖片名稱保存到了另一個redis集合中,通過計算這兩個集合的差值就可以獲得所有垃圾圖片的名稱。

本章節我們就會基於Quartz定時任務,通過計算redis兩個集合的差值找出所有的垃圾圖片,就可以將垃圾圖片清理掉。

操作步驟:

(1)創建maven工程health_jobs,打包方式為war,導入Quartz等相關坐標

<?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.itheima</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>health_jobs</artifactId>
<packaging>war</packaging>
<name>health_jobs Maven Webapp</name>
<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.itheima</groupId>
<artifactId>health_interface</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<configuration>
<!-- 指定端口 -->
<port>83</port>
<!-- 請求路徑 -->
<path>/</path>
</configuration>
</plugin>
</plugins>
</build>
</project>

(2)配置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>
<!-- 加載spring容器 -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath*:applicationContext*.xml</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
</web-app>

(3)配置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=info, stdout

(4)配置applicationContext-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">
<!--Jedis連接池的相關配置-->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxTotal">
<value>200</value>
</property>
<property name="maxIdle">
<value>50</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="127.0.0.1" />
<constructor-arg name="port" value="6379" type="int" />
<constructor-arg name="timeout" value="30000" type="int" />
</bean>
</beans>

(5)配置applicationContext-jobs.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: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:annotation-config></context:annotation-config>
<bean id="clearImgJob" class="com.itheima.jobs.ClearImgJob"></bean>
<bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<!-- 注入目標對象 -->
<property name="targetObject" ref="clearImgJob"/>
<!-- 注入目標方法 -->
<property name="targetMethod" value="clearImg"/>
</bean>
<!-- 注册一個觸發器,指定任務觸發的時間 -->
<bean id="myTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
<!-- 注入JobDetail -->
<property name="jobDetail" ref="jobDetail"/>
<!-- 指定觸發的時間,基於Cron錶達式 -->
<property name="cronExpression">
<value>0 0 2 * * ?</value>
</property>
</bean>
<!-- 注册一個統一的調度工廠,通過這個調度工廠調度任務 -->
<bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<!-- 注入多個觸發器 -->
<property name="triggers">
<list>
<ref bean="myTrigger"/>
</list>
</property>
</bean>
</beans>

(6)創建ClearImgJob定時任務類

package com.itheima.jobs;
import com.itheima.constant.RedisConstant;
import com.itheima.utils.QiniuUtils;
import org.springframework.beans.factory.annotation.Autowired;
import redis.clients.jedis.JedisPool;
import java.util.Set;
/** * 自定義Job,實現定時清理垃圾圖片 */
public class ClearImgJob {

@Autowired
private JedisPool jedisPool;
public void clearImg(){

//根據Redis中保存的兩個set集合進行差值計算,獲得垃圾圖片名稱集合
Set<String> set =
jedisPool.getResource().sdiff(RedisConstant.SETMEAL_PIC_RESOURCES,
RedisConstant.SETMEAL_PIC_DB_RESOURCES);
if(set != null){

for (String picName : set) {

//删除七牛雲服務器上的圖片
QiniuUtils.deleteFileFromQiniu(picName);
//從Redis集合中删除圖片名稱
jedisPool.getResource().
srem(RedisConstant.SETMEAL_PIC_RESOURCES,picName);
}
}
}
}

請添加圖片描述
請添加圖片描述

版权声明:本文为[胖ۣۖ虎ۣۖ]所创,转载请带上原文链接,感谢。 https://gsmany.com/2022/174/202206230438165125.html