「小程序JAVA实战」小程序搜索功能（55）
通过用户搜索热销词，将热销词添加到数据库中，搜索页面通过热销词的频率展示出来那些词属于热销词。并添加列表参数，可以通过搜索关键字查询列表功能。源码：https://github.com/limingios/wxProgram.git 中wx-springboot 和 No.15
后台接口的开发。
- 增加关键字查询视频列表功能
VideosUserMapper.xml
- 热销词统计功能
SearchRecordsMapper.xml
- java对应xml的方法
VideosUsersMapper.java
package com.idig8.mapper;import java.util.List;import org.apache.ibatis.annotations.Param;import com.idig8.pojo.Videos;
import com.idig8.pojo.vo.VideosVO;
import com.idig8.utils.MyMapper;public interface VideosUsersMapper extends MyMapper {public List queryAllVideos(@Param("videoDesc") String videoDesc);
}
SearchRecordsMapper.java
package com.idig8.mapper;import java.util.List;import com.idig8.pojo.SearchRecords;
import com.idig8.utils.MyMapper;public interface SearchRecordsMapper extends MyMapper {public List gethotList();
}
- service 添加2个方法，
>列表中添加保存关键字，查询视频添加关键字的，
>获取热销词列表
VideoService.java
package com.idig8.service;import java.util.List;import com.idig8.pojo.Videos;
import com.idig8.utils.PagedResult;public interface VideoService {/*** 保存视频信息* @param Id* @return*/public String saveVideo(Videos video);/*** 分析查询视频列表* @param video* @param isSaveRecord* @param page* @param pageSize* @return*/public PagedResult getAllVideos(Videos video,Integer isSaveRecord,Integer page,Integer pageSize);/*** 获取热搜词列表* @return*/public List gethostList();
} VideoServiceImpl.java
package com.idig8.service.Impl;import java.util.List;import org.n3r.idworker.Sid;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.github.pagehelper.autoconfigure.PageHelperAutoConfiguration;
import com.idig8.mapper.SearchRecordsMapper;
import com.idig8.mapper.VideosMapper;
import com.idig8.mapper.VideosUsersMapper;
import com.idig8.pojo.SearchRecords;
import com.idig8.pojo.Videos;
import com.idig8.pojo.vo.VideosVO;
import com.idig8.service.VideoService;
import com.idig8.utils.PagedResult;@Service
public class VideoServiceImpl implements VideoService {@Autowiredprivate VideosMapper videosMapper;@Autowiredprivate VideosUsersMapper videosUsersMapper;@Autowiredprivate SearchRecordsMapper searchRecordsMapper;@Autowiredprivate Sid sid;@Transactional(propagation =Propagation.REQUIRED)public String saveVideo(Videos video){String id = sid.nextShort();video.setId(id);videosMapper.insertSelective(video);return id;}@Override@Transactional(propagation =Propagation.REQUIRED)public PagedResult getAllVideos(Videos video,Integer isSaveRecord,Integer page, Integer pageSize) {String desc = video.getVideoDesc();if(isSaveRecord!=null && isSaveRecord ==1){SearchRecords record = new SearchRecords();String recordId = sid.nextShort();record.setId(recordId);record.setContent(desc);searchRecordsMapper.insert(record);}PageHelper.startPage(page,pageSize);List list = videosUsersMapper.queryAllVideos(desc);PageInfo pageList =new PageInfo<>(list);PagedResult result = new PagedResult();result.setPage(page);result.setTotal(pageList.getPages());result.setRows(list);result.setRecords(pageList.getTotal());return result;}@Transactional(propagation =Propagation.SUPPORTS)@Overridepublic List gethostList() {return searchRecordsMapper.gethotList();}
} - controller 控制器开发
package com.idig8.controller;import java.io.File;
import java.util.Date;
import java.util.UUID;import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;import com.idig8.pojo.Bgm;
import com.idig8.pojo.Videos;
import com.idig8.service.BgmService;
import com.idig8.service.VideoService;
import com.idig8.utils.FetchVideoCover;
import com.idig8.utils.JSONResult;
import com.idig8.utils.MergeVideoMp3;
import com.idig8.utils.PagedResult;
import com.idig8.utils.enums.VideoStatusEnum;
import com.idig8.utils.file.FileUtil;import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;@RestController
@Api(value="视频相关业务的接口", tags= {"视频相关业务的controller"})
@RequestMapping("/video")
public class VideoController extends BasicController {@Autowiredprivate BgmService bgmService;@Autowiredprivate VideoService videosService;@Value("${server.file.path}")private String fileSpace;@Value("${server.ffmpeg.path}")private String ffmpegexe;@ApiOperation(value="上传视频", notes="上传视频的接口")@ApiImplicitParams({@ApiImplicitParam(name="userId", value="用户id", required=true, dataType="String", paramType="form"),@ApiImplicitParam(name="bgmId", value="背景音乐id", required=false, dataType="String", paramType="form"),@ApiImplicitParam(name="videoSeconds", value="背景音乐播放长度", required=true, dataType="String", paramType="form"),@ApiImplicitParam(name="videoWidth", value="视频宽度", required=true, dataType="String", paramType="form"),@ApiImplicitParam(name="videoHeight", value="视频高度", required=true, dataType="String", paramType="form"),@ApiImplicitParam(name="desc", value="视频描述", required=false, dataType="String", paramType="form")})@PostMapping(value="/upload", headers="content-type=multipart/form-data")public JSONResult upload(String userId, String bgmId, double videoSeconds, int videoWidth, int videoHeight,String desc,@ApiParam(value="短视频", required=true)MultipartFile file) throws Exception {if (StringUtils.isBlank(userId)) {return JSONResult.errorMsg("用户id不能为空...");}// 文件保存的命名空间String fileName = file.getOriginalFilename();// 保存到数据库中的相对路径String path = "";String videOutPath = "";String ImagePath = "";try {path = FileUtil.uploadFile(file.getBytes(), fileSpace, fileName);} catch (Exception e) {e.getStackTrace();return JSONResult.errorMsg(e.getMessage());} if(StringUtils.isNotBlank(bgmId)){Bgm bgm = bgmService.queryBgmById(bgmId);String mp3BgmPath = fileSpace + bgm.getPath();MergeVideoMp3 mergeVideoMp3 = new MergeVideoMp3(ffmpegexe);String videOutPathName = UUID.randomUUID().toString()+".mp4";File targetFile = new File(fileSpace + userId);if (!targetFile.exists()) {targetFile.mkdirs();}videOutPath = "/"+userId+"/"+videOutPathName;String videoInput = fileSpace +path;mergeVideoMp3.convertor(videoInput, mp3BgmPath, videoSeconds, fileSpace +videOutPath);}else{videOutPath = path;}ImagePath = "/"+userId+"/"+UUID.randomUUID().toString()+".jpg";;FetchVideoCover fetchVideoCover = new FetchVideoCover(ffmpegexe);fetchVideoCover.getCover(fileSpace +videOutPath, fileSpace +ImagePath);Videos videos = new Videos();videos.setAudioId(bgmId);videos.setCreateTime(new Date());videos.setVideoDesc(desc);videos.setId(UUID.randomUUID().toString());videos.setUserId(userId);videos.setVideoHeight(videoHeight);videos.setVideoWidth(videoWidth);videos.setVideoPath(videOutPath);videos.setCoverPath(ImagePath);videos.setStatus(VideoStatusEnum.SUCCESS.value);videosService.saveVideo(videos);return JSONResult.ok(path);}@PostMapping(value="/showAll")@ApiOperation(value="视频列表", notes="分页的视频列表")public JSONResult upload(@RequestBody Videos video,Integer isSaveRecord,Integer page) throws Exception {if(page == null){page = 1;}PagedResult result = videosService.getAllVideos(video,isSaveRecord,page, PAGE_SIZE); return JSONResult.ok(result);}@PostMapping(value="/hot")@ApiOperation(value="热搜词列表", notes="热搜词列表")public JSONResult upload() throws Exception {return JSONResult.ok(videosService.gethostList());}
}
前端功能开发
调后端url，获取热销关键字展示。
var WxSearch = require('../../wxSearchView/wxSearchView.js');
const app = getApp()
Page({/*** 页面的初始数据*/data: {},onLoad: function () {// 2 搜索栏初始化var that = this;wx.request({url: app.serverUrl +"/video/hot",method: "POST",header: {'content-type': 'application/json' // 默认值},success: function (res) {var searchHot = res.data.data;WxSearch.init(that, // 本页面一个引用searchHot, // 热点搜索推荐，[]表示不使用searchHot,// 搜索匹配，[]表示不使用that.mySearchFunction, // 提供一个搜索回调函数that.myGobackFunction //提供一个返回回调函数);}})},// 3 转发函数，固定部分，直接拷贝即可wxSearchInput: WxSearch.wxSearchInput, // 输入变化时的操作wxSearchKeyTap: WxSearch.wxSearchKeyTap, // 点击提示或者关键字、历史记录时的操作wxSearchDeleteAll: WxSearch.wxSearchDeleteAll, // 删除所有的历史记录wxSearchConfirm: WxSearch.wxSearchConfirm, // 搜索函数wxSearchClear: WxSearch.wxSearchClear, // 清空函数// 4 搜索回调函数 mySearchFunction: function (value) {// do your job here// 示例：跳转wx.redirectTo({url: '../index/index?isSaveRecord=1&searchValue=' + value})},// 5 返回回调函数myGobackFunction: function () {// do your job here// 示例：返回wx.redirectTo({url: '../index/index'})},/*** 生命周期函数--监听页面初次渲染完成*/onReady: function () {},/*** 生命周期函数--监听页面显示*/onShow: function () {},/*** 生命周期函数--监听页面隐藏*/onHide: function () {},/*** 生命周期函数--监听页面卸载*/onUnload: function () {},/*** 页面相关事件处理函数--监听用户下拉动作*/onPullDownRefresh: function () {},/*** 页面上拉触底事件的处理函数*/onReachBottom: function () {},/*** 用户点击右上角分享*/onShareAppMessage: function () {}
})
- 输入搜索后跳转到index页面，展示搜索结果
>增加isSaveRecord 和 searchValue 关键字根据搜索传递过来，然后修改请求列表参数。
const app = getApp()Page({data: {// 用于分页的属性totalPage: 1,page: 1,videoList: [],screenWidth: 350,serverUrl: "",searchValue:""},onLoad: function (params) {var me = this;var screenWidth = wx.getSystemInfoSync().screenWidth;me.setData({screenWidth: screenWidth,});var searchValue = params.searchValue;var isSaveRecord = params.isSaveRecord;if (isSaveRecord == null || isSaveRecord == "" || isSaveRecord == undefined){isSaveRecord = 0;}me.setData({searchValue: searchValue,});// 获取当前的分页数var page = me.data.page;me.getAllVideosList(page, isSaveRecord);},getAllVideosList: function (page, isSaveRecord){var me = this;var serverUrl = app.serverUrl;wx.showLoading({title: '请等待，加载中...',});wx.request({url: serverUrl + '/video/showAll?page=' + page + "&isSaveRecord =" + isSaveRecord,method: "POST",data:{videoDesc: me.data.searchValue},success: function (res) {wx.hideLoading();wx.hideNavigationBarLoading();wx.stopPullDownRefresh();console.log(res.data);// 判断当前页page是否是第一页，如果是第一页，那么设置videoList为空if (page === 1) {me.setData({videoList: []});}var videoList = res.data.data.rows;var newVideoList = me.data.videoList;me.setData({videoList: newVideoList.concat(videoList),page: page,totalPage: res.data.data.total,serverUrl: serverUrl});}})},onPullDownRefresh: function (params) {var me = this;wx.showNavigationBarLoading();me.getAllVideosList(1,0);},onReachBottom: function (params){var me = this;var currentPage = me.data.page;var totalPage = me.data.totalPage;//判断当前页数和总页数是否相等，如果相同已经无需请求if (currentPage == totalPage){wx.showToast({title: '已经没有视频啦~',icon:"none"})return;}var page = currentPage+1;me.getAllVideosList(page,0);}})PS：搜索功能，后台提供url，直接赋值到插件就可以了，通过输入关键字点击搜索，将关键字保存标识传递，关键字传递给index页面，index获取后在根据关键字查询结果。
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！