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;
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;
@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;
@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);
}
@RequestMapping(value = "/getLiveList")
public ResponseVO getLiveList(HttpServletRequest request, @RequestBody JSonObject json) {
Map params = new HashMap();
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 results = liveService.queryPages(params);
return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, results);
}
@RequestMapping(value = "/getLiveList_new")
public ResponseVO getLiveList_new(HttpServletRequest request, @RequestBody JSonObject json) {
Map params = new HashMap();
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 results = liveService.list(params);
params.clear();
params.put("results", results);
return ResponseCode.buildEnumResponseVO(ResponseCode.SUCCESS, params);
}
@RequestMapping(value = "/getLiveListAll")
public ResponseVO getLiveListAll(HttpServletRequest request, @RequestBody JSonObject json) {
Map params = new HashMap();
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 list = liveService.queryPages(params);
HashMap
1. 涉及平台
平台管理、商家端(PC端、手机端)、买家平台(H5/公众号、小程序、APP端(IOS/Android)、微服务平台(业务服务)
2. 核心架构
Spring Cloud、Spring Boot、Mybatis、Redis
3. 前端框架
VUE、Uniapp、Bootstrap/H5/CSS3、IOS、Android、小程序
评论列表(0条)