java版直播商城之直播间代码介绍Spring Cloud+SpringBoot+mybatis+uniapp b2b2c微服务商城
2022/1/19 11:21:00
本文主要是介绍java版直播商城之直播间代码介绍Spring Cloud+SpringBoot+mybatis+uniapp b2b2c微服务商城,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
package com.honghu.cloud.controller; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.LinkedList; import java.util.List; import java.util.Map; @源码地址来源: https://minglisoft.cn/honghu2/business.html import javax.servlet.http.HttpServletRequest; import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.CrossOrigin; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import com.honghu.cloud.bean.Live; import com.honghu.cloud.bean.LiveBaby; import com.honghu.cloud.bean.LiveFollow; import com.honghu.cloud.bean.UserSearchLog; import com.honghu.cloud.code.ResponseCode; import com.honghu.cloud.code.ResponseVO; import com.honghu.cloud.common.page.Page; import com.honghu.cloud.dto.AccessoryDto; import com.honghu.cloud.dto.AddGoodsCarFormDto; import com.honghu.cloud.dto.MessageDto; import com.honghu.cloud.dto.SysConfigDto; import com.honghu.cloud.dto.UserDto; import com.honghu.cloud.feign.AccessoryFeignClient; import com.honghu.cloud.feign.GoodsCartFeignClient; import com.honghu.cloud.feign.GoodsShareFeignClient; import com.honghu.cloud.feign.MessageFeignClient; import com.honghu.cloud.feign.SysConfigFeignClient; import com.honghu.cloud.feign.UserFeignClient; import com.honghu.cloud.redis.RedisUtil; import com.honghu.cloud.service.IUserSearchLogService; import com.honghu.cloud.service.LiveBabyService; import com.honghu.cloud.service.LiveFollowService; import com.honghu.cloud.service.LiveService; import com.honghu.cloud.tools.LiveUtils; import com.honghu.cloud.tools.QueryTools; import com.honghu.cloud.tools.SecurityUserHolder; import com.honghu.cloud.util.CommUtil; import com.honghu.cloud.utils.tools.Md5Encrypt; import net.sf.json.JSONObject; /** * 直播间管理控制器 * * @author Administrator * */ @RestController @RequestMapping(value = "/live") public class LiveController { private static final Logger logger = LoggerFactory.getLogger(LiveController.class); @Autowired private LiveService liveService; @Autowired private LiveFollowService liveFollowService; @Autowired private AccessoryFeignClient accessoryFeignClient; @Autowired private SysConfigFeignClient sysConfigFeignClient; @Autowired private LiveBabyService liveBabyService; @Autowired private UserFeignClient userFeignClient; @Autowired private MessageFeignClient messageFeignClient; @Autowired private GoodsShareFeignClient shareFeignClient; @Autowired private IUserSearchLogService userSearchLogService; @Autowired private GoodsCartFeignClient goodsCartFeignClient; @Autowired private RedisUtil redisUtil; /** * 根据id查询直播 * * @param id * @return */ @RequestMapping(value = "/apiForFeign/selectByPrimaryKey", method = RequestMethod.GET) public Live selectByPrimaryKey(@RequestParam("id") Long id) { return liveService.selectByPrimaryKey(id); } @RequestMapping(value = "/apiForFeign/selectByPrimaryKey1", method = RequestMethod.GET) public Live selectByPrimaryKey1(@RequestParam("id") Long id) { return liveService.selectByPrimaryKey1(id); } /** * 我的直播间数据列表查询 * * @param params */ @RequestMapping(value = "/getLiveList") public ResponseVO getLiveList(HttpServletRequest request, @RequestBody JSONObject json) { Map<String, Object> params = new HashMap<String, Object>(); String currentPage = json.optString("currentPage"); // 当前页数 String pageSize = json.optString("pageSize"); // 数据长度 String userName = json.getString("userName"); // 主播用户 String orderBy = json.optString("orderBy"); // 排序字段 String orderType = json.optString("orderType"); // 排序方式 if (StringUtils.isNotBlank(userName)) { if (StringUtils.isNotBlank(currentPage)) { params.put("currentPage", CommUtil.null2Int(currentPage)); } if (StringUtils.isNotBlank(pageSize)) { params.put("pageSize", CommUtil.null2Int(pageSize)); } if (StringUtils.isNotBlank(orderBy)) { params.put("orderBy", orderBy); } if (StringUtils.isNotBlank(orderType)) { params.put("orderType", orderType); } params.put("creater_id", userName); // 当前用户编号 } List<Live> results = liveService.queryPages(params); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, results); } /** * 我的直播间数据列表查询 * * @param params */ @RequestMapping(value = "/getLiveList_new") public ResponseVO getLiveList_new(HttpServletRequest request, @RequestBody JSONObject json) { Map<String, Object> params = new HashMap<String, Object>(); String currentPage = json.optString("currentPage"); // 当前页数 String pageSize = json.optString("pageSize"); // 数据长度 String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } params = QueryTools.getParams(currentPage, 12, "live_status DESC ,addTime", "DESC"); params.put("user_id", user.getId()); // 当前用户编号 params.put("goods_num", "goods_num"); // 查询宝贝件数 Page<Live> results = liveService.list(params); params.clear(); params.put("results", results); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, params); } /** * 全部直播间数据列表查询 * * @param params */ @RequestMapping(value = "/getLiveListAll") public ResponseVO getLiveListAll(HttpServletRequest request, @RequestBody JSONObject json) { Map<String, Object> params = new HashMap<String, Object>(); String currentPage = json.optString("currentPage"); // 当前页数 String pageSize = json.optString("pageSize"); // 数据长度 String orderBy = json.optString("orderBy"); // 排序字段 String orderType = json.optString("orderType"); // 排序方式 String type = json.optString("type"); // 排序方式 params = QueryTools.getParams(currentPage, CommUtil.null2Int(pageSize), orderBy, orderType); if (StringUtils.isNotBlank(type) && "follow".equals(type)) { // 查询用户关注的主播 params.put("orderType", type); } List<Live> list = liveService.queryPages(params); HashMap<Object, Object> results = new HashMap<>(); results.put("list", list); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, results); } @RequestMapping(value = "/getLiveListAll1") public ResponseVO getLiveListAll1(HttpServletRequest request, @RequestBody JSONObject json) { String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } Map<String, Object> params = new HashMap<String, Object>(); String currentPage = json.optString("currentPage"); // 当前页数 String pageSize = json.optString("pageSize"); // 数据长度 String type = json.optString("type"); // 排序方式 String store_id = json.optString("store_id"); // 店铺id HashMap<Object, Object> results = new HashMap<>(); params = QueryTools.getParams(currentPage, CommUtil.null2Int(pageSize), "a.addTime", null); if (StringUtils.isNotBlank(type) && "follow".equals(type)) { // 查询用户关注的主播 params.put("follow", user.getId()); } if (StringUtils.isNotBlank(store_id)) { UserDto UserDto = userFeignClient.getUserByStoreId(CommUtil.null2Long(store_id)); if (UserDto == null) { Page<Live> list = new Page<>(); results.put("list", list); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, results); } params.put("a_user_id", UserDto.getId()); } Page<Live> list = liveService.list1(params); results.put("list", list); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, results); } /** * 查询直播间数据 * * @param id * @return */ @RequestMapping("/getLiveById") public ResponseVO getLiveById(@RequestBody JSONObject json, HttpServletRequest request) { String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); String live_id = json.optString("live_id"); if (user_id == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } if (StringUtils.isEmpty(live_id)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_ID_ISNULL, null); } Live live = liveService.selectByPrimaryKey(CommUtil.null2Long(live_id)); if (live == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.GOODSCLASS_CODE_NULL, null); } UserDto anchor = userFeignClient.selectByPrimaryKey(live.getUser_id()); if (anchor == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_CONCERN_ISNULL, null); } HashMap<String, Object> hashMap = new HashMap<>(); AccessoryDto accessoryDto = accessoryFeignClient.selectByPrimaryKey(anchor.getPhoto_id()); if (live.getLive_status() == 1) { // 若在直播中 添加热度 int n = (int) (Math.random() * 20 + 15); live.setPopularity_num(live.getPopularity_num() == null ? 0 : live.getPopularity_num() + n); liveService.updateById(live); Object currentNumber = redisUtil.get("NUMBER_" + live.getId()); redisUtil.set("NUMBER_" + live.getId(), null == currentNumber ? 1 : (int) currentNumber + 1); } if (user_id != null) { hashMap.put("concern", user_id); hashMap.put("to_concern", anchor.getId()); hashMap.put("deleteStatus", 0); LiveFollow liveFollow = liveFollowService.getLiveFollow(hashMap); if (liveFollow != null) { live.setFollow(1); // 已关注 } } hashMap.clear(); hashMap.put("anchorname", anchor.getNickName()); hashMap.put("anchorphoto", accessoryDto); hashMap.put("live", live); hashMap.put("user", user); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, hashMap); } /** * 创建直播间 添加直播间数据 * * @param live */ @RequestMapping("/add_live_baby") public ResponseVO add_live(HttpServletRequest request, @RequestBody JSONObject json) { String mulitId = null; // 商品id if (json.containsKey("goods_id")) { mulitId = json.optString("goods_id"); } String live_id = json.optString("live_id"); // 直播id String userName = json.optString("userName"); // 用户userName String live_title = json.optString("live_title"); // 直播间标题 String live_cover = json.optString("live_cover"); // 直播间封面路径完整路径 String live_status = json.optString("live_status"); // 直播状态 String play_time = json.optString("play_time"); // 直播间预播时间 // 直播间id if (StringUtils.isEmpty(live_id)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_ID_ISNULL, null); // 直播间ID不能为空 } if (StringUtils.isEmpty(live_title)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TITLE_ISNULL, null); // 直播间标题不能为空 } if (StringUtils.isEmpty(live_cover)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_COVER_ISNULL, null); // 直播间封面不能为空 } if (StringUtils.isEmpty(userName)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_USERNAME_ISNULL, null); // 用户userName不能为空 } if (StringUtils.isEmpty(live_status)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_STATUS, null); // 直播状态不能为空 } Live live = new Live(); live.setAddTime(new Date()); // 直播间创建时间 live.setLive_title(live_title); // 直播间标题 live.setLive_cover(live_cover); // 直播间封面完整路径 live.setLive_num(CommUtil.null2Long(live_id)); // 直播间房间号 live.setCreater_id(userName); // 创建用户 live.setLive_status(Integer.valueOf(live_status)); // 直播状态 // 日期转化格式 SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date date = null; try { date = simpleDateFormat.parse(play_time); live.setPlay_time(date); // 预播时间 } catch (ParseException e) { logger.error("LiveController >> add_live >> " + e.getMessage()); } liveService.addLive(live); // 保存直播间数据信息 if (null != mulitId) { String[] ids = mulitId.split(","); for (String id : ids) { LiveBaby liveBaby = new LiveBaby(); liveBaby.setAddTime(new Date()); liveBaby.setCreater_id(userName); liveBaby.setGoods_id(CommUtil.null2Long(id)); liveBaby.setLive_id(CommUtil.null2Long(live_id)); // 直播间id liveBaby.setDeleteStatus(0); // 删除标识 liveBabyService.addLiveBaby(liveBaby); // 添加直播间宝贝信息 } } try { UserDto liveUser = userFeignClient.selectByUserName(userName); Map<String, Object> maps = new HashMap<String, Object>(); maps.put("to_concern", liveUser.getId()); List<LiveFollow> list = liveFollowService.queryPages(maps); List<MessageDto> msgs = new ArrayList<MessageDto>(); for (LiveFollow lf : list) { // 发送站内消息 MessageDto msg = new MessageDto(); msg.setAddTime(new Date()); msg.setDeleteStatus(0); msg.setMsg_cat(0); msg.setReply_status(0); msg.setStatus(0); String nickName = liveUser.getNickName(); if (StringUtils.isBlank(nickName)) { StringBuilder sb = new StringBuilder(liveUser.getMobile()); if (sb.length() >= 11) { sb.replace(3, 7, "****"); } nickName = sb.toString(); } if (StringUtils.equals("1", live_status)) { msg.setTitle("直播通知"); msg.setContent("你关注的" + nickName + "正在直播,请及时观看。"); // TODO 添加公众号推送 } else { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String format = sdf.format(date); // 将Date类型转换成String类型 msg.setTitle("预播通知"); msg.setContent("你关注的" + nickName + "将于" + format + "开始直播,请及时观看哦!"); } msg.setType(2); msg.setFromUser_id(1L); msg.setToUser_id(lf.getConcern()); msgs.add(msg); } messageFeignClient.saveList(msgs); } catch (Exception e) { logger.error("LiveController >> add_live >> sendMsg error " + e.getMessage()); } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); // 请求处理成功 } /** * 创建直播间 添加直播间数据 * * @param live */ @RequestMapping(value = "/add_live_baby_new", method = RequestMethod.POST) public ResponseVO add_live_new(HttpServletRequest request, @RequestBody JSONObject json) { String mulitId = null; // 商品id if (json.containsKey("goods_id")) { mulitId = json.optString("goods_id"); } // String live_id = json.optString("live_id"); //直播id String live_title = json.optString("live_title"); // 直播间标题 String live_cover = json.optString("live_cover"); // 直播间封面路径完整路径 String live_status = json.optString("live_status"); // 直播状态 String play_time = json.optString("play_time"); // 直播间预播时间 String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } /* * if(StringUtils.isEmpty(live_id)){ return * ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_ID_ISNULL, null); * //直播间ID不能为空 } */ if (StringUtils.isEmpty(live_title)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TITLE_ISNULL, null); // 直播间标题不能为空 } if (StringUtils.isEmpty(live_cover)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_COVER_ISNULL, null); // 直播间封面不能为空 } if (StringUtils.isEmpty(live_status)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_STATUS, null); // 直播状态不能为空 } Map<String, Object> maps = new HashMap<String, Object>(); Live live = new Live(); Date date = null; if (live_status.equals("3")) { // 日期转化格式 SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); try { date = simpleDateFormat.parse(play_time); // 查询预播时间点是否存在 maps.put("a_user_id", user.getId()); maps.put("a_play_time", play_time); List<Live> queryPages = liveService.queryPages(maps); if (queryPages != null && queryPages.size() > 0) { // 该时间存在预播 // 不保存 return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_PREVIEW_IS, null); // 预播已存在 } live.setPlay_time(date); // 预播时间 } catch (ParseException e) { logger.error("LiveController >> add_live >> " + e.getMessage()); } } live.setAddTime(new Date()); // 直播间创建时间 live.setLive_title(live_title); // 直播间标题 live.setLive_cover(live_cover); // 直播间封面完整路径 Long selectMaxLiveCode = liveService.selectMaxLiveCode(); live.setLive_num(selectMaxLiveCode == null ? 100000 : selectMaxLiveCode + 1); // 直播间房间号 live.setUser_id(user.getId()); live.setCreater_id(user.getUserName()); // 创建用户 live.setLive_status(Integer.valueOf(live_status)); // 直播状态 if (live_status.equals("1")) { live.setDeleteStatus(1); // 若为直播,先置位删除状态 , 推流时修改 } liveService.addLive(live); // 保存直播间数据信息 if (null != mulitId) { String[] ids = mulitId.split(","); for (String id : ids) { if (!id.equals("")) { LiveBaby liveBaby = new LiveBaby(); liveBaby.setAddTime(new Date()); liveBaby.setCreater_id(user.getUsername()); liveBaby.setGoods_id(CommUtil.null2Long(id)); liveBaby.setLive_id(CommUtil.null2Long(live.getId())); // 直播间id liveBaby.setDeleteStatus(0); // 删除标识 liveBabyService.addLiveBaby(liveBaby); // 添加直播间宝贝信息 } } } try { // UserDto liveUser = userFeignClient.selectByUserName(userName); maps.clear(); maps.put("to_concern", user.getId()); List<LiveFollow> list = liveFollowService.queryPages(maps); List<MessageDto> msgs = new ArrayList<MessageDto>(); for (LiveFollow lf : list) { // 发送站内消息 MessageDto msg = new MessageDto(); msg.setAddTime(new Date()); msg.setDeleteStatus(0); msg.setMsg_cat(0); msg.setReply_status(0); msg.setStatus(0); String nickName = user.getNickName(); if (StringUtils.isBlank(nickName)) { StringBuilder sb = new StringBuilder(user.getMobile()); if (sb.length() >= 11) { sb.replace(3, 7, "****"); } nickName = sb.toString(); } if (StringUtils.equals("1", live_status)) { msg.setTitle("直播通知"); msg.setContent("你关注的" + nickName + "正在直播,请及时观看。"); // TODO 添加公众号推送 } else { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String format = sdf.format(date); // 将Date类型转换成String类型 msg.setTitle("预播通知"); msg.setContent("你关注的" + nickName + "将于" + format + "开始直播,请及时观看哦!"); } msg.setType(2); msg.setFromUser_id(1L); msg.setToUser_id(lf.getConcern()); msgs.add(msg); } messageFeignClient.saveList(msgs); } catch (Exception e) { logger.error("LiveController >> add_live >> sendMsg error " + e.getMessage()); } HashMap<Object, Object> hashMap = new HashMap<>(); hashMap.put("live", live); hashMap.put("nickName", user.getNickName()); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, hashMap); // 请求处理成功 } /** * 添加主播关注数据 * * @param live */ @RequestMapping("/add_live_follow") public ResponseVO add_live_follow(@RequestBody JSONObject json) { String concern = json.optString("concern"); // 关注者编号 String to_concern = json.optString("to_concern"); // 被关注者编号 if (StringUtils.isEmpty(concern)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_CONCERN_USERNAME_ISNULL, null); // 关注者userName不能为空 } if (StringUtils.isEmpty(to_concern)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_USERNAME_ISNULL, null); // 被关注者userName不能为空 } UserDto concernUser = userFeignClient.selectByUserName(concern); // 关注者用户 if (concernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_CONCERN_ISNULL, null); // 关注者用户不存在 } UserDto toConcernUser = userFeignClient.selectByUserName(to_concern); // 被关注者用户 if (toConcernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 被关注者用户不存在 } Map<String, Object> maps = new HashMap<String, Object>(); maps.put("concern", concernUser.getId()); maps.put("to_concern", toConcernUser.getId()); LiveFollow lFollow = liveFollowService.getLiveFollow(maps); if (null != lFollow) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_FOLLOW, null); // 主播已关注 } LiveFollow liveFollow = new LiveFollow(); liveFollow.setAddTime(new Date()); // 添加时间 liveFollow.setConcern(concernUser.getId()); // 关注者 liveFollow.setTo_concern(toConcernUser.getId()); // 被关注者 liveFollowService.addLiveFollow(liveFollow); // 关注信息添加 return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); // 请求处理成功 } /** * 添加主播关注数据 * * @param live */ @RequestMapping("/add_live_follow_new") public ResponseVO add_live_follow_new(@RequestBody JSONObject json, HttpServletRequest request) { String user_id = json.optString("user_id"); // 被关注者编号 String tokenStr = request.getHeader("token"); Long concern = SecurityUserHolder.getTokenUserId(tokenStr); if (concern == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(concern);// 关注者用户 if (user == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } UserDto toConcernUser = userFeignClient.selectByPrimaryKey(CommUtil.null2Long(user_id)); // 被关注者用户 if (toConcernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 被关注者用户不存在 } if (user.getId().toString().equals(user_id)) { // 关注者为登陆者 return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 被关注者用户不存在 } Map<String, Object> maps = new HashMap<String, Object>(); maps.put("concern", user.getId()); maps.put("to_concern", toConcernUser.getId()); LiveFollow lFollow = liveFollowService.getLiveFollow(maps); if (null != lFollow) { liveFollowService.deleteLiveFollow(maps); // 删除主播关注数据 // return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_FOLLOW, // null); // 主播已关注 } else { LiveFollow liveFollow = new LiveFollow(); liveFollow.setAddTime(new Date()); // 添加时间 liveFollow.setConcern(user.getId()); // 关注者 liveFollow.setTo_concern(toConcernUser.getId()); // 被关注者 liveFollowService.addLiveFollow(liveFollow); // 关注信息添加 } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); // 请求处理成功 } /** * 取消主播关注数据 * * @param live */ @RequestMapping("/del_live_follow") public ResponseVO del_live_follow(@RequestBody JSONObject json) { String concern = json.optString("concern"); // 关注者编号 String to_concern = json.optString("to_concern"); // 被关注者编号 if (StringUtils.isEmpty(concern)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_CONCERN_USERNAME_ISNULL, null); // 关注者userName不能为空 } if (StringUtils.isEmpty(to_concern)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_USERNAME_ISNULL, null); // 被关注者userName不能为空 } UserDto concernUser = userFeignClient.selectByUserName(concern); // 关注者用户 if (concernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 关注者用户不存在 } UserDto toConcernUser = userFeignClient.selectByUserName(to_concern); // 被关注者用户 if (toConcernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 被关注者用户不存在 } Map<String, Object> params = new HashMap<String, Object>(); params.put("concern", concernUser.getId()); params.put("to_concern", toConcernUser.getId()); LiveFollow lFollow = liveFollowService.getLiveFollow(params); if (null == lFollow) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_NOT_FOLLOW, null); // 还未关注主播 } liveFollowService.deleteLiveFollow(params); // 删除主播关注数据 return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); // 请求处理成功 } /** * 取消主播关注数据 * * @param live */ @RequestMapping("/del_live_follow_new") public ResponseVO del_live_follow_new(@RequestBody JSONObject json, HttpServletRequest request) { String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } String to_concern = json.optString("to_concern"); // 被关注者编号 if (StringUtils.isEmpty(to_concern)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_USERNAME_ISNULL, null); // 被关注者userName不能为空 } UserDto toConcernUser = userFeignClient.selectByUserName(to_concern); // 被关注者用户 if (toConcernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 被关注者用户不存在 } Map<String, Object> params = new HashMap<String, Object>(); params.put("concern", user.getId()); params.put("to_concern", toConcernUser.getId()); LiveFollow lFollow = liveFollowService.getLiveFollow(params); if (null == lFollow) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_NOT_FOLLOW, null); // 还未关注主播 } liveFollowService.deleteLiveFollow(params); // 删除主播关注数据 return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); // 请求处理成功 } /** * 关注用户数据信息列表 * * @param live */ @RequestMapping("/follow_user") public ResponseVO follow_user(HttpServletRequest request, @RequestBody JSONObject json) { String currentPage = json.optString("currentPage"); // 当前页数 String pageSize = json.optString("pageSize"); // 数据长度 String orderBy = json.optString("orderBy"); // 排序字段 String orderType = json.optString("orderType"); // 排序方式 List<Map<String, Object>> result = new LinkedList<Map<String, Object>>(); String userName = json.getString("userName"); // 被关注者编号 if (StringUtils.isEmpty(userName)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_USERNAME_ISNULL, null); // 用户userName不能为空 } UserDto user = userFeignClient.selectByUserName(userName); // 用户 if (user == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.USER_DOES_NOT_EXIST, null); // 用户不存在 } Map<String, Object> params = new HashMap<String, Object>(); if (StringUtils.isNotBlank(currentPage)) { params.put("currentPage", CommUtil.null2Int(currentPage)); } if (StringUtils.isNotBlank(pageSize)) { params.put("pageSize", CommUtil.null2Int(pageSize)); } if (StringUtils.isNotBlank(orderBy)) { params.put("orderBy", orderBy); } if (StringUtils.isNotBlank(orderType)) { params.put("orderType", orderType); } if (StringUtils.isNotBlank(userName)) { params.put("anchor_id", user.getId()); // 被关注用户 } List<UserDto> userDtos = userFeignClient.queryPageList(params); SysConfigDto sysConfigDto = sysConfigFeignClient.getSysConfig(); for (UserDto userDto : userDtos) { AccessoryDto acc = null; if (userDto.getPhoto_id() != null) { acc = accessoryFeignClient.selectByPrimaryKey(userDto.getPhoto_id()); } Map<String, Object> us = new HashMap<String, Object>(); us.put("user_id", userDto.getId()); us.put("nickName", userDto.getNickName()); // 用户昵称 us.put("autograph", ""); // 用户个性签名 if (null != sysConfigDto) { if (null != acc) { us.put("photo", sysConfigDto.getImageWebServer() + "/" + acc.getPath() + "/" + acc.getName()); // 用户头像 } else { us.put("photo", sysConfigDto.getImageWebServer() + "/" + sysConfigDto.getMemberIcon().getPath() + "/" + sysConfigDto.getMemberIcon().getName()); // 用户头像 } } result.add(us); } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); // 请求处理成功 } /** * 关注用户数据信息列表 * * @param live */ @RequestMapping("/follow_user_new") public ResponseVO follow_user_new(HttpServletRequest request, @RequestBody JSONObject json) { String currentPage = json.optString("currentPage"); // 当前页数 String pageSize = json.optString("pageSize"); // 数据长度 String orderBy = json.optString("orderBy"); // 排序字段 String orderType = json.optString("orderType"); // 排序方式 List<Map<String, Object>> result = new LinkedList<Map<String, Object>>(); String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } Map<String, Object> params = new HashMap<String, Object>(); if (StringUtils.isNotBlank(currentPage)) { params.put("currentPage", CommUtil.null2Int(currentPage)); } if (StringUtils.isNotBlank(pageSize)) { params.put("pageSize", CommUtil.null2Int(pageSize)); } if (StringUtils.isNotBlank(orderBy)) { params.put("orderBy", orderBy); } if (StringUtils.isNotBlank(orderType)) { params.put("orderType", orderType); } params.put("anchor_id", user.getId()); // 被关注用户 List<UserDto> userDtos = userFeignClient.queryPageList(params); SysConfigDto sysConfigDto = sysConfigFeignClient.getSysConfig(); for (UserDto userDto : userDtos) { AccessoryDto acc = null; if (userDto.getPhoto_id() != null) { acc = accessoryFeignClient.selectByPrimaryKey(userDto.getPhoto_id()); } Map<String, Object> us = new HashMap<String, Object>(); us.put("user_id", userDto.getId()); us.put("nickName", userDto.getNickName()); // 用户昵称 us.put("autograph", ""); // 用户个性签名 if (null != sysConfigDto) { if (null != acc) { us.put("photo", sysConfigDto.getImageWebServer() + "/" + acc.getPath() + "/" + acc.getName()); // 用户头像 } else { us.put("photo", sysConfigDto.getImageWebServer() + "/" + sysConfigDto.getMemberIcon().getPath() + "/" + sysConfigDto.getMemberIcon().getName()); // 用户头像 } } result.add(us); } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); // 请求处理成功 } /** * 查询直播用户数据信息 * * @param live */ @RequestMapping("/liveUser") public ResponseVO liveUser(@RequestBody JSONObject json) { String userName = json.optString("userName"); // 用户编号 String to_concern = json.optString("to_concern"); // 关注者userName if (StringUtils.isEmpty(userName)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_USERNAME_ISNULL, null); // 用户userName不能为空 } if (StringUtils.isEmpty(to_concern)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_USERNAME_ISNULL, null); // 被关注者userName不能为空 } UserDto userDto = userFeignClient.selectByUserName(userName); // 用户 if (userDto == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.USER_DOES_NOT_EXIST, null); // 用户不存在 } UserDto toConcernUser = userFeignClient.selectByUserName(to_concern); // 主播用户 if (toConcernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 被关注用户不存在 } SysConfigDto sysConfigDto = sysConfigFeignClient.getSysConfig(); Map<String, Object> result = new HashMap<String, Object>(); AccessoryDto acc = null; if (userDto.getPhoto_id() != null) { acc = accessoryFeignClient.selectByPrimaryKey(userDto.getPhoto_id()); } Map<String, Object> params = new HashMap<String, Object>(); params.put("concern", userDto.getId()); params.put("to_concern", toConcernUser.getId()); LiveFollow lf = liveFollowService.getLiveFollow(params); // 查询关注主播数据信息 result.put("nickName", userDto.getNickName()); // 用户昵称 result.put("autograph", ""); // 用户个性签名 if (null != sysConfigDto) { if (null != acc) { result.put("photo", sysConfigDto.getImageWebServer() + "/" + acc.getPath() + acc.getName()); // 用户头像 } else { result.put("photo", sysConfigDto.getImageWebServer() + "/" + sysConfigDto.getMemberIcon().getPath() + "/" + sysConfigDto.getMemberIcon().getName()); // 用户头像 } } if (null != lf) { result.put("anchor", true); // 是否关注主播 } else { result.put("anchor", false); // 是否关注主播 } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, result); } /** * 查询直播用户数据信息 * * @param live */ @RequestMapping("/liveUser_new") public ResponseVO liveUser_new(@RequestBody JSONObject json, HttpServletRequest request) { String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.TOKEN_EXPIRE, null); } UserDto userDto = userFeignClient.selectByPrimaryKey(user_id); if (userDto == null) { // 用户不存在 return ResponseCode.buildEnumResponseVO(ResponseCode.USER_NOT_EXISTS_ERROR, null); } String to_concern = json.optString("to_concern"); // 关注者userName if (StringUtils.isEmpty(to_concern)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_USERNAME_ISNULL, null); // 被关注者userName不能为空 } UserDto toConcernUser = userFeignClient.selectByUserName(to_concern); // 主播用户 if (toConcernUser == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TOCONCERN_ISNULL, null); // 被关注用户不存在 } SysConfigDto sysConfigDto = sysConfigFeignClient.getSysConfig(); Map<String, Object> result = new HashMap<String, Object>(); AccessoryDto acc = null; if (userDto.getPhoto_id() != null) { acc = accessoryFeignClient.selectByPrimaryKey(userDto.getPhoto_id()); } Map<String, Object> params = new HashMap<String, Object>(); params.put("concern", userDto.getId()); params.put("to_concern", toConcernUser.getId()); LiveFollow lf = liveFollowService.getLiveFollow(params); // 查询关注主播数据信息 result.put("nickName", userDto.getNickName()); // 用户昵称 result.put("autograph", ""); // 用户个性签名 if (null != sysConfigDto) { if (null != acc) { result.put("photo", sysConfigDto.getImageWebServer() + "/" + acc.getPath() + acc.getName()); // 用户头像 } else { result.put("photo", sysConfigDto.getImageWebServer() + "/" + sysConfigDto.getMemberIcon().getPath() + "/" + sysConfigDto.getMemberIcon().getName()); // 用户头像 } } if (null != lf) { result.put("anchor", true); // 是否关注主播 } else { result.put("anchor", false); // 是否关注主播 } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, result); } /** * 个人直播中心 */ @RequestMapping("/liveCenter") public Map<String, Object> liveCenter(HttpServletRequest request, @RequestBody JSONObject json) { SysConfigDto sysConfigDto = sysConfigFeignClient.getSysConfig(); String user_id = json.optString("user_id"); // 获取直播用户信息 if (StringUtils.isEmpty(user_id)) { return ResponseCode.buildCodeMap("20001", "用户id不能为空", null); } List<Map<String, Object>> result = new ArrayList<>(); UserDto userDto = userFeignClient.selectByUserName(user_id); // 用户 if (userDto == null) { return ResponseCode.buildCodeMap("30001", "用户不存在", null); } if (null != userDto.getPhoto_id()) { AccessoryDto acc = accessoryFeignClient.selectByPrimaryKey(userDto.getPhoto_id()); // 获取头像信息 Map<String, Object> user = new HashMap<String, Object>(); user.put("user_id", userDto.getId()); // 用户编号 user.put("userName", userDto.getUserName1()); // 用户名称 if (null != sysConfigDto) { if (null != acc) { user.put("photo", sysConfigDto.getImageWebServer() + "/" + acc.getPath() + acc.getName()); // 用户头像 } else { user.put("photo", sysConfigDto.getImageWebServer() + "/" + sysConfigDto.getMemberIcon().getPath() + "/" + sysConfigDto.getMemberIcon().getName()); // 用户头像 } Map<String, Object> params = new HashMap<String, Object>(); params.put("anchor_id", userDto.getId()); // 当前用户 List<LiveFollow> liveFollows = liveFollowService.queryPages(params); user.put("fans", liveFollows.size()); // 粉丝数量 result.add(user); } } return ResponseCode.buildSuccessMap(result); } /** * 个人直播中心 */ @RequestMapping("/liveCenter_new") public Map<String, Object> liveCenter_new(HttpServletRequest request, @RequestBody JSONObject json) { String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildCodeMap("508", "token已过期,请重新登录", null); } UserDto userDto = userFeignClient.selectByPrimaryKey(user_id); if (userDto == null) { // 用户不存在 return ResponseCode.buildCodeMap("30001", "用户不存在", null); } List<Map<String, Object>> result = new ArrayList<>(); if (null != userDto.getPhoto_id()) { AccessoryDto acc = accessoryFeignClient.selectByPrimaryKey(userDto.getPhoto_id()); // 获取头像信息 Map<String, Object> user = new HashMap<String, Object>(); user.put("user_id", userDto.getId()); // 用户编号 user.put("userName", userDto.getUserName1()); // 用户名称 SysConfigDto sysConfigDto = sysConfigFeignClient.getSysConfig(); if (null != sysConfigDto) { if (null != acc) { user.put("photo", sysConfigDto.getImageWebServer() + "/" + acc.getPath() + acc.getName()); // 用户头像 } else { user.put("photo", sysConfigDto.getImageWebServer() + "/" + sysConfigDto.getMemberIcon().getPath() + "/" + sysConfigDto.getMemberIcon().getName()); // 用户头像 } Map<String, Object> params = new HashMap<String, Object>(); params.put("anchor_id", userDto.getId()); // 当前用户 List<LiveFollow> liveFollows = liveFollowService.queryPages(params); user.put("fans", liveFollows.size()); // 粉丝数量 result.add(user); } } return ResponseCode.buildSuccessMap(result); } /** * 直播账户验证(用户+密码) * * @param params */ @RequestMapping(value = "/checking/account", method = RequestMethod.POST) public Map<String, Object> checkingAccount(@RequestBody JSONObject json, HttpServletRequest request) { String userName = json.optString("userName"); String password = json.optString("password"); if (StringUtils.isEmpty(userName) || StringUtils.isEmpty(password)) { ResponseCode.buildCodeMap("10001", "用户名和密码不能为空", null); } password = Md5Encrypt.md5(password).toLowerCase(); Map<String, String> paraMap = new HashMap<String, String>(); paraMap.put("userName", userName); paraMap.put("password", password); Long user_id = userFeignClient.checkingAccount(paraMap); if (user_id == null) { return ResponseCode.buildCodeMap("10002", "你未开通主播", null); } // 根据用户id获取登录token String token = SecurityUserHolder.getCurrentUser(user_id); return ResponseCode.buildSuccessMap(token); } /** * 直播账户验证(用户) * * @param params */ @RequestMapping(value = "/checking/username", method = RequestMethod.POST) public Map<String, Object> checkingUsername(@RequestBody JSONObject json, HttpServletRequest request) { String userName = json.optString("userName"); if (StringUtils.isEmpty(userName)) { ResponseCode.buildCodeMap("10001", "用户名不能为空", null); } Map<String, String> paraMap = new HashMap<String, String>(); paraMap.put("userName", userName); Long user_id = userFeignClient.checkingUserName(paraMap); if (user_id == null) { return ResponseCode.buildCodeMap("10002", "你未开通主播", null); } // 根据用户id获取登录token String token = SecurityUserHolder.getCurrentUser(user_id); return ResponseCode.buildSuccessMap(token); } /** * 通过直播间id查询用户 * * @param params */ @RequestMapping(value = "/getUser", method = RequestMethod.POST) public ResponseVO getUser(@RequestBody JSONObject json) { String live_id = json.optString("live_id"); if (StringUtils.isBlank(live_id)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_ID_ISNULL, null); // 直播间id不能为空 } Map<String, Object> maps = new HashMap<String, Object>(); maps.put("live_num", live_id); Live live = liveService.selectByLiveNum(maps); UserDto userDto = null; if (null != live && live.getCreater_id() != null) { userDto = userFeignClient.selectByUserName(live.getCreater_id()); // 获取用户信息 } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, userDto); } // 直播间分享海报 @RequestMapping(value = "/liveSharePic", method = RequestMethod.POST) public ResponseVO liveSharePic(@RequestBody JSONObject json) { String live_id = json.optString("live_id"); // 直播间ID String userName = json.optString("username"); // 直播间分享用户 String anchor_id = json.optString("anchor_id"); // 直播间主播 if (StringUtils.isBlank(anchor_id)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_ANCHOR_ID_ISNULL, null); // 主播id不能为空 } if (StringUtils.isBlank(live_id)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_ID_ISNULL, null); // 直播间id不能为空 } if (StringUtils.isBlank(userName)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_SHARE_ID_ISNULL, null); // 直播间分享用户名不能为空 } Map<String, Object> maps = new HashMap<String, Object>(); maps.put("live_num", live_id); Live live = liveService.selectByLiveNum(maps); if (null == live) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_NO_FIND, null); // 未找到直播间 } if (StringUtils.isBlank(live.getLive_title())) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_TITLE_NO_FIND, null); // 未找到直播间 } if (StringUtils.isBlank(live.getLive_cover())) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_COVER_NO_FIND, null); // 未找到直播间 } if (StringUtils.isBlank(live.getCreater_id())) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_CREATER_ID_NO_FIND, null); // 未找到直播间 } Map<String, Object> params = new HashMap<String, Object>(); params.put("live_title", live.getLive_title()); params.put("live_cover", live.getLive_cover()); params.put("creater_id", live.getCreater_id()); params.put("live_id", live_id); params.put("userName", userName); params.put("anchor_id", anchor_id.toString()); params.put("live_status", live.getLive_status().toString()); Map<String, Object> result = shareFeignClient.liveSharePicture(params); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, result); } /** * 查询用户搜索记录 */ @RequestMapping(value = "/userSearchLogList", method = RequestMethod.POST) public Map<String, Object> userSearchLogList(@RequestBody JSONObject json, HttpServletRequest request) { String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildFailMap("token无效", null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildReturnMap(ResponseCode.USER_NOT_EXISTS_ERROR, null); } HashMap<String, Object> result = new HashMap<>(); SysConfigDto sysConfig = sysConfigFeignClient.getSysConfig(); String[] split = sysConfig.getHotSearch().split(","); ArrayList<Object> arrayList = new ArrayList<>(); for (int a = 0; a < split.length - 1; a++) { arrayList.add(split[a]); } result.put("hot_search", arrayList); Map<String, Object> params = QueryTools.getParams(null, 6, null, null); params.put("user_id", user.getId()); Page<UserSearchLog> list = userSearchLogService.list(params); result.put("search_log", list.getResult()); return ResponseCode.buildSuccessMap(result); } /** * 清除用户搜索记录 */ @RequestMapping(value = "/delUserSearchLog", method = RequestMethod.POST) public Map<String, Object> delUserSearchLog(@RequestBody JSONObject json, HttpServletRequest request) { String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildFailMap("token无效", null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildReturnMap(ResponseCode.USER_NOT_EXISTS_ERROR, null); } userSearchLogService.delUserLog(user.getId()); return ResponseCode.buildSuccessMap(null); } /** * 保存搜索记录 */ @RequestMapping(value = "/saveUserSearchLog", method = RequestMethod.POST) public Map<String, Object> saveUserSearchLog(@RequestBody JSONObject json, HttpServletRequest request) { if (StringUtils.isBlank(json.optString("search_name"))) { // 为空不做操作 return ResponseCode.buildSuccessMap(null); } String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id != null) { UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user != null) {// 用户存在 Map<String, Object> params = QueryTools.getParams(null, 3, null, null); params.put("user_id", user.getId()); params.put("search_name", json.optString("search_name")); Page<UserSearchLog> list = userSearchLogService.list(params); if (list.getResult().size() < 1) { // 不存在, 保存记录 UserSearchLog userSearchLog = new UserSearchLog(); userSearchLog.setUser_id(user_id); userSearchLog.setAddTime(new Date()); userSearchLog.setSearch_name(json.optString("search_name")); userSearchLog.setDeleteStatus(0); userSearchLogService.saveEntity(userSearchLog); } else { list.getResult().get(0).setAddTime(new Date()); // 更新时间 userSearchLogService.updateById(list.getResult().get(0)); } } } return ResponseCode.buildSuccessMap(null); } /** * 直播添加购物车商品 * * @param params */ @RequestMapping(value = "/addLiveGoodsCart", method = RequestMethod.POST) public ResponseVO addLiveGoodsCart(@RequestBody JSONObject json, HttpServletRequest request) { Long id = CommUtil.null2Long(json.optString("id")); // 商品id Integer count = Integer.valueOf(json.optString("count")); String gsp = json.optString("gsp"); String buy_type = json.optString("buy_type"); String type = json.optString("type"); String combin_version = json.optString("combin_version"); String combin_ids = json.optString("combin_ids"); String userName = json.getString("userName"); String liverName = json.getString("liverName"); String liveroom_id = null; if (StringUtils.isNotBlank(liveroom_id) && !("-1").equals(liveroom_id)) { liveroom_id = json.optString("liveroom_id"); } if (StringUtils.isEmpty(userName) || StringUtils.isEmpty(liverName)) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_USERNAME_ISNULL, null); // 用户userName不能为空 } UserDto user = userFeignClient.selectByUserName(userName); // 用户 if (user == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.LIVE_USERNAME_ISNULL, null); // 用户不存在 } UserDto liver = userFeignClient.selectByUserName(liverName); // 用户 if (liver == null) { return ResponseCode.buildEnumResponseVO(ResponseCode.USER_DOES_NOT_EXIST, null); // 用户不存在 } AddGoodsCarFormDto addGoodsCarFormDto = new AddGoodsCarFormDto(); addGoodsCarFormDto.setId(id); addGoodsCarFormDto.setCount(count); addGoodsCarFormDto.setGsp(gsp); addGoodsCarFormDto.setBuy_type(buy_type); addGoodsCarFormDto.setCombin_ids(combin_ids); addGoodsCarFormDto.setCombin_version(combin_version); addGoodsCarFormDto.setApp_user_id(user.getId()); addGoodsCarFormDto.setType(type); addGoodsCarFormDto.setShare_user_id(liver.getId().toString()); addGoodsCarFormDto.setLiveroom_id(liveroom_id); Map addGoodsCart = goodsCartFeignClient.addGoodsCart(addGoodsCarFormDto); HashMap<Object, Object> result = new HashMap<>(); result.put("map", addGoodsCart); return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, result); } /** * 生成直播间推流地址 */ @RequestMapping(value = "/add_live_url", method = RequestMethod.POST) public Map<String, Object> add_live_url(@RequestBody JSONObject json, HttpServletRequest request) { String imgroup_id = json.optString("imgroup_id"); String live_id = json.optString("live_id"); String live_type = json.optString("live_type"); String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildFailMap("token无效", null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildReturnMap(ResponseCode.USER_NOT_EXISTS_ERROR, null); } if (StringUtils.isEmpty(live_id)) { return ResponseCode.buildReturnMap(ResponseCode.PARAMETER_ERROR, null); } if (StringUtils.isEmpty(imgroup_id)) { return ResponseCode.buildReturnMap(ResponseCode.LIVE_IMGROUP_ISNULL, null); } Live live = null; if (StringUtils.isNotEmpty(live_type) && live_type.equals("1")) { live = liveService.selectByPrimaryKey1(CommUtil.null2Long(live_id)); } else { live = liveService.selectByPrimaryKey(CommUtil.null2Long(live_id)); } if (live == null) { return ResponseCode.buildReturnMap(ResponseCode.LIVE_NO_FIND, null); } HashMap<String, Object> maps = new HashMap<>(); SysConfigDto sysConfig = sysConfigFeignClient.getSysConfig(); live.setImgroup_id(imgroup_id); // 聊天室id live.setStartTime(new Date()); // 添加时间 maps.put("to_concern", live.getUser_id()); maps.put("deleteStatus", 0); // 粉丝总数 Integer selectCount = liveFollowService.selectCount(maps); live.setFollow_num(CommUtil.null2Long(selectCount)); // 计算当前粉丝数, 之后结束在统计 live.setDeleteStatus(0); // 进行相减 拿到本场关注数 live.setLive_status(1); // 开始直播 String live_domian = sysConfig.getLive_play_domain(); String safeUrl = LiveUtils.getSafeUrl(sysConfig.getLive_key(), live_id, 86400000L); live.setLive_url(live_domian + "/live/" + live_id + "?" + safeUrl); liveService.updateById(live); String url = sysConfig.getLive_domain() + "/live/" + live_id + "?" + safeUrl; return ResponseCode.buildSuccessMap(url); } /** * 直播观看人数变化 * * @param params */ @RequestMapping(value = "/updateLiveAudience") public ResponseVO getLiveListAll(@RequestBody JSONObject json) { String live_id = json.optString("live_id"); // 直播间id String count = json.optString("count"); // 数量 if (StringUtils.isNotBlank(live_id)) { // 查询用户关注的主播 Live Live = liveService.selectByPrimaryKey(CommUtil.null2Long(live_id)); if (Live != null && Live.getLive_status() == 1) { Live.setAudience_num(CommUtil.null2Long(count)); liveService.updateAudienceById(CommUtil.null2Long(live_id), CommUtil.null2Long(count)); } } return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, null); } /** * 查询当前直播关注人数 * * @param params */ @RequestMapping(value = "/getFollowNum") public Map<String, Object> getFollowNum(@RequestBody JSONObject json) { String live_id = json.optString("live_id"); // 直播间id if (StringUtils.isEmpty(live_id)) { return ResponseCode.buildReturnMap(ResponseCode.PARAMETER_ERROR, null); } Live live = liveService.selectByPrimaryKey(CommUtil.null2Long(live_id)); if (live == null) { return ResponseCode.buildReturnMap(ResponseCode.LIVE_NO_FIND, null); } HashMap<String, Object> maps = new HashMap<>(); maps.put("to_concern", live.getUser_id()); maps.put("deleteStatus", 0); // 粉丝总数 Integer Count = liveFollowService.selectCount(maps); // 本场关注人数 进行相减 拿到本场关注数 long liveCount = Count.longValue() - live.getFollow_num().longValue(); return ResponseCode.buildSuccessMap(liveCount); } /** * * 结束直播 * * @param params */ @RequestMapping(value = "/endLive") public Map<String, Object> endLive(@RequestBody JSONObject json, HttpServletRequest request) { String tokenStr = request.getHeader("token"); String live_id = json.optString("live_id"); // 直播间id String pralis_num = json.optString("pralis_num"); // 点赞数 String duration = json.optString("duration"); // 直播间id Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildReturnMap(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildReturnMap(ResponseCode.USER_NOT_EXISTS_ERROR, null); } if (StringUtils.isEmpty(live_id)) { return ResponseCode.buildReturnMap(ResponseCode.PARAMETER_ERROR, null); } Live live = liveService.selectByPrimaryKey(CommUtil.null2Long(live_id)); if (live == null || live.getLive_status() == 2) { return ResponseCode.buildReturnMap(ResponseCode.LIVE_NO_FIND, null); } HashMap<String, Object> maps = new HashMap<>(); maps.put("to_concern", live.getUser_id()); maps.put("deleteStatus", 0); // 粉丝总数 Integer Count = liveFollowService.selectCount(maps); // 本场关注人数 进行相减 拿到本场关注数 long liveCount = Count.longValue() - live.getFollow_num().longValue(); live.setLive_status(2); // 结束直播 改为回播 live.setFollow_num(liveCount); // 本场关注人数 live.setDuration(CommUtil.null2Long(duration)); live.setEndTime(new Date()); live.setAudience_num(CommUtil.null2Long( null == redisUtil.get("NUMBER_" + live.getId()) ? 0 : redisUtil.get("NUMBER_" + live.getId())));// 观看人数 live.setPralis_num(CommUtil.null2Long(pralis_num)); liveService.updateById(live); return ResponseCode.buildSuccessMap(liveCount); } /** * 查询当前直播关注人数 * * @param params */ @RequestMapping(value = "/delLiveById") public Map<String, Object> delLiveById(@RequestBody JSONObject json, HttpServletRequest request) { String live_id = json.optString("live_id"); // String tokenStr = request.getHeader("token"); Long user_id = SecurityUserHolder.getTokenUserId(tokenStr); if (user_id == null) { return ResponseCode.buildReturnMap(ResponseCode.TOKEN_EXPIRE, null); } UserDto user = userFeignClient.selectByPrimaryKey(user_id); if (user == null) { // 用户不存在 return ResponseCode.buildReturnMap(ResponseCode.USER_NOT_EXISTS_ERROR, null); } if (StringUtils.isEmpty(live_id)) { return ResponseCode.buildReturnMap(ResponseCode.PARAMETER_ERROR, null); } Live live = liveService.selectByPrimaryKey(CommUtil.null2Long(live_id)); if (live != null && live.getUser_id().toString().equals(user_id + "")) { liveService.deleteLive(live.getId());// 删除 } else { return ResponseCode.buildReturnMap(ResponseCode.PARAMETER_ERROR, null); } return ResponseCode.buildSuccessMap(null); } /** * 直播结束接口回调 * * @param params */ @RequestMapping(value = "/returnEndLiveUrl") public void getEndLiveUrl(@RequestBody JSONObject json) { String event_type = json.optString("event_type"); // String stream_id = json.optString("stream_id"); // 观看人数 if (event_type.equals("100") && StringUtils.isNotBlank(stream_id)) { Live live = liveService.selectByPrimaryKey(CommUtil.null2Long(stream_id)); if (live != null) { String video_url = json.optString("video_url"); // live.setLive_url(video_url); liveService.updateById(live); } } // if (event_type.equals("0") && StringUtils.isNotBlank(stream_id)) { Live live = liveService.selectByPrimaryKey(CommUtil.null2Long(stream_id)); if (live != null && live.getLive_status() == 1) { HashMap<String, Object> maps = new HashMap<>(); maps.put("to_concern", live.getUser_id()); maps.put("deleteStatus", 0); // 粉丝总数 Integer Count = liveFollowService.selectCount(maps); // 本场关注人数 进行相减 拿到本场关注数 long liveCount = Count.longValue() - live.getFollow_num().longValue(); live.setLive_status(2); // 结束直播 改为回播 live.setFollow_num(liveCount); // 本场关注人数 double div = CommUtil.div(CommUtil.null2Long(json.optString("errcode")), 1000); live.setAudience_num(CommUtil.null2Long( null == redisUtil.get("NUMBER_" + live.getId()) ? 0 : redisUtil.get("NUMBER_" + live.getId())));// 观看人数 live.setDuration(CommUtil.null2Long(div)); long time = new Date().getTime() - live.getStartTime().getTime(); live.setDuration(CommUtil.null2Long(CommUtil.div(time, 1000))); live.setEndTime(new Date()); liveService.updateById(live); } } } }
@源码地址来源: https://minglisoft.cn/honghu2/business.html
搜索体验小程序: 海哇
这篇关于java版直播商城之直播间代码介绍Spring Cloud+SpringBoot+mybatis+uniapp b2b2c微服务商城的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-12-25初学者必备:订单系统资料详解与实操教程
- 2024-12-24内网穿透资料入门教程
- 2024-12-24微服务资料入门指南
- 2024-12-24微信支付系统资料入门教程
- 2024-12-24微信支付资料详解:新手入门指南
- 2024-12-24Hbase资料:新手入门教程
- 2024-12-24Java部署资料
- 2024-12-24Java订单系统资料:新手入门教程
- 2024-12-24Java分布式资料入门教程
- 2024-12-24Java监控系统资料详解与入门教程