Compare commits

...

5 Commits

Author SHA1 Message Date
wjm b4992b038d 第一次提交
9 months ago
zst 6cc0ba2ee5 v1.0
9 months ago
hjl e9c7163786 v1.0
9 months ago
zst eca74c632f v1.0
9 months ago
zst 74c1f3fe2f v1.0
9 months ago

@ -0,0 +1,351 @@
package com.controller;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Map;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Date;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import com.utils.ValidatorUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.web.bind.annotation.PathVariable;
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 com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.annotation.IgnoreAuth;
import com.entity.ChatEntity;
import com.entity.view.ChatView;
import com.service.ChatService;
import com.service.TokenService;
import com.utils.PageUtils;
import com.utils.R;
import com.utils.MD5Util;
import com.utils.MPUtil;
import com.utils.CommonUtil;
/**
* 线
*
* @author
* @email
* @date 2023-02-21 09:46:06
*/
@RestController
@RequestMapping("/chat")
public class ChatController {
// 自动注入ChatService实例用于处理与聊天相关的业务逻辑
@Autowired
private ChatService chatService;
/**
*
*
* @param params Map
* @param chat ChatEntity
* @param request HttpServletRequest
* @return R
*/
@RequestMapping("/page")
public R page(@RequestParam Map<String, Object> params, ChatEntity chat,
HttpServletRequest request) {
// 如果当前用户不是管理员角色,设置查询条件,只查询当前用户的聊天记录
if (!request.getSession().getAttribute("role").toString().equals("管理员")) {
chat.setUserid((Long) request.getSession().getAttribute("userId"));
}
// 创建一个EntityWrapper对象用于构建MyBatis Plus的查询条件
EntityWrapper<ChatEntity> ew = new EntityWrapper<ChatEntity>();
// 调用chatService的queryPage方法进行分页查询传入构建好的查询条件和参数
PageUtils page = chatService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, chat), params), params));
// 将查询结果设置到请求属性中,可能用于在后续的视图渲染中使用
request.setAttribute("data", page);
// 返回包含查询结果的R对象通常R对象用于统一封装返回结果的状态和数据
return R.ok().put("data", page);
}
/**
*
*
* @param params Map
* @param chat ChatEntity
* @param request HttpServletRequest
* @return R
*/
@RequestMapping("/list")
public R list(@RequestParam Map<String, Object> params, ChatEntity chat,
HttpServletRequest request) {
// 如果当前用户不是管理员角色,设置查询条件,只查询当前用户的聊天记录
if (!request.getSession().getAttribute("role").toString().equals("管理员")) {
chat.setUserid((Long) request.getSession().getAttribute("userId"));
}
// 创建一个EntityWrapper对象用于构建MyBatis Plus的查询条件
EntityWrapper<ChatEntity> ew = new EntityWrapper<ChatEntity>();
// 调用chatService的queryPage方法进行分页查询传入构建好的查询条件和参数
PageUtils page = chatService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, chat), params), params));
// 将查询结果设置到请求属性中,可能用于在后续的视图渲染中使用
request.setAttribute("data", page);
// 返回包含查询结果的R对象通常R对象用于统一封装返回结果的状态和数据
return R.ok().put("data", page);
}
/**
*
* ChatEntity
* @param chat ChatEntity
* @return R
*/
@RequestMapping("/lists")
public R list(ChatEntity chat) {
// 创建一个EntityWrapper对象用于构建MyBatis Plus的查询条件
EntityWrapper<ChatEntity> ew = new EntityWrapper<ChatEntity>();
// 根据传入的ChatEntity对象构建等值查询条件
ew.allEq(MPUtil.allEQMapPre(chat, "chat"));
// 调用chatService的selectListView方法进行查询并返回结果
return R.ok().put("data", chatService.selectListView(ew));
}
/**
*
* 线
* @param chat ChatEntity
* @return R线
*/
@RequestMapping("/query")
public R query(ChatEntity chat) {
// 创建一个EntityWrapper对象用于构建MyBatis Plus的查询条件
EntityWrapper<ChatEntity> ew = new EntityWrapper<ChatEntity>();
// 根据传入的ChatEntity对象构建等值查询条件
ew.allEq(MPUtil.allEQMapPre(chat, "chat"));
// 调用chatService的selectView方法进行查询获取ChatView对象可能是包含详细信息的视图对象
ChatView chatView = chatService.selectView(ew);
// 返回包含查询结果的R对象以及提示信息和查询到的详细信息视图
return R.ok("查询在线咨询成功").put("data", chatView);
}
/**
*
* ID
* @param id ID
* @return R
*/
@RequestMapping("/info/{id}")
public R info(@PathVariable("id") Long id) {
// 调用chatService的selectById方法根据ID查询聊天记录
ChatEntity chat = chatService.selectById(id);
// 返回包含查询结果的R对象
return R.ok().put("data", chat);
}
/**
*
* @IgnoreAuth
* @param id ID
* @return R
*/
@IgnoreAuth
@RequestMapping("/detail/{id}")
public R detail(@PathVariable("id") Long id) {
// 调用chatService的selectById方法根据ID查询聊天记录
ChatEntity chat = chatService.selectById(id);
// 返回包含查询结果的R对象
return R.ok().put("data", chat);
}
/**
*
*
* @param chat ChatEntity
* @param request HttpServletRequest
* @return R
*/
@RequestMapping("/save")
public R save(@RequestBody ChatEntity chat, HttpServletRequest request) {
// 设置聊天记录的ID由当前时间戳加上一个随机数生成
chat.setId(new Date().getTime() + new Double(Math.floor(Math.random() * 1000)).longValue());
// 此处原本可能用于验证ChatEntity对象的合法性但被注释掉了
//ValidatorUtils.validateEntity(chat);
// 如果聊天记录的提问内容不为空
if (StringUtils.isNotBlank(chat.getAsk())) {
// 更新当前用户的未回复状态为0表示有新提问
chatService.updateForSet("isreply=0", new EntityWrapper<ChatEntity>().eq("userid", request.getSession().getAttribute("userId")));
// 设置聊天记录的用户ID为当前用户ID
chat.setUserid((Long) request.getSession().getAttribute("userId"));
// 设置回复状态为1表示已提问等待回复
chat.setIsreply(1);
}
// 如果聊天记录的回复内容不为空
if (StringUtils.isNotBlank(chat.getReply())) {
// 更新当前用户提问用户的未回复状态为0表示有新回复
chatService.updateForSet("isreply=0", new EntityWrapper<ChatEntity>().eq("userid", chat.getUserid()));
// 设置聊天记录的管理员ID为当前用户ID可能表示回复的管理员
chat.setAdminid((Long) request.getSession().getAttribute("userId"));
}
// 调用chatService的insert方法插入新的聊天记录
chatService.insert(chat);
// 返回表示保存成功的R对象
return R.ok();
}
/**
*
*
* @param chat ChatEntity
* @param request HttpServletRequest
* @return R
*/
@RequestMapping("/add")
public R add(@RequestBody ChatEntity chat, HttpServletRequest request) {
// 设置聊天记录的ID由当前时间戳加上一个随机数生成
chat.setId(new Date().getTime() + new Double(Math.floor(Math.random() * 1000)).longValue());
// 设置聊天记录的用户ID为当前用户ID
chat.setUserid((Long) request.getSession().getAttribute("userId"));
// 如果聊天记录的提问内容不为空
if (StringUtils.isNotBlank(chat.getAsk())) {
// 更新当前用户的未回复状态为0表示有新提问
chatService.updateForSet("isreply=0", new EntityWrapper<ChatEntity>().eq("userid", request.getSession().getAttribute("userId")));
// 设置聊天记录的用户ID为当前用户ID
chat.setUserid((Long) request.getSession().getAttribute("UserId"));
// 设置回复状态为1表示已提问等待回复
chat.setIsreply(1);
}
// 如果聊天记录的回复内容不为空
if (StringUtils.isNotBlank(chat.getReply())) {
// 更新当前用户提问用户的未回复状态为0表示有新回复
chatService.updateForSet("isreply=0", new EntityWrapper<ChatEntity>().eq("userid", chat.getUserid()));
// 设置聊天记录的管理员ID为当前用户ID可能表示回复的管理员
chat.setAdminid((Long) request.getSession().getAttribute("UserId"));
}
// 调用chatService的insert方法插入新的聊天记录
chatService.insert(chat);
// 返回表示保存成功的R对象
return R.ok();
}
/**
*
*
* @param chat ChatEntity
* @param request HttpServletRequest
* @return R
*/
@RequestMapping("/update")
@Transactional
public R update(@RequestBody ChatEntity chat, HttpServletRequest request) {
// 此处原本可能用于验证ChatEntity对象的合法性但被注释掉了
//ValidatorUtils.validateEntity(chat);
// 调用chatService的updateById方法根据ID更新聊天记录
chatService.updateById(chat); //全部更新
// 返回表示修改成功的R对象
return R.ok();
}
/**
*
* ID
* @param ids ID
* @return R
*/
@RequestMapping("/delete")
public R delete(@RequestBody Long[] ids) {
// 调用chatService的deleteBatchIds方法批量删除指定ID的聊天记录
chatService.deleteBatchIds(Arrays.asList(ids));
// 返回表示删除成功的R对象
return R.ok();
}
/**
*
*
* @param columnName
* @param request HttpServletRequest
* @param type
* @param map Map
* @return R
*/
@RequestMapping("/remind/{columnName}/{type}")
public R remindCount(@PathVariable("columnName") String columnName, HttpServletRequest request,
@PathVariable("type") String type, @RequestParam Map<String, Object> map) {
// 将列名和类型添加到查询条件Map中
map.put("column", columnName);
map.put("type", type);
// 如果提醒类型为2
if (type.equals("2")) {
// 创建SimpleDateFormat对象用于日期格式化
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
// 获取Calendar实例用于日期计算
Calendar c = Calendar.getInstance();
Date remindStartDate = null;
Date remindEndDate = null;
// 如果查询条件Map中包含remindstart开始提醒时间
if (map.get("remindstart")!= null) {
// 将remindstart转换为整数表示要添加的天数
Integer remindStart = Integer.parseInt(map.get("remindstart").toString());
// 设置当前日期为基础日期
c.setTime(new Date());
// 根据提醒开始天数添加到当前日期上
c.add(Calendar.DAY_OF_MONTH, remindStart);
// 获取计算后的提醒开始日期
remindStartDate = c.getTime();
// 将提醒开始日期格式化为指定格式并更新到查询条件Map中
map.put("remindstart", sdf.format(remindStartDate));
}
// 如果查询条件Map中包含remindend结束提醒时间
if (map.get("remindend")!= null) {
// 将remindend转换为整数表示要添加的天数
Integer remindEnd = Integer.parseInt(map.get("remindend").toString());
// 设置当前日期为基础日期
c.setTime(new Date());
// 根据提醒结束天数添加到当前日期上
c.add(Calendar.DAY_OF_MONTH, remindEnd);
// 获取计算后的提醒结束日期
remindEndDate = c.getTime();
// 将提醒结束日期格式化为指定格式并更新到查询条件Map中
map.put("remindend", sdf.format(remindEndDate));
}
}
// 创建一个EntityWrapper对象用于构建MyBatis Plus的查询条件
Wrapper<ChatEntity> wrapper = new EntityWrapper<ChatEntity>();
// 如果查询条件Map中包含remindstart开始提醒时间添加大于等于条件到查询条件中
if (map.get("remindstart")!= null) {
wrapper.ge(columnName, map.get("remindstart"));
}
// 如果查询条件Map中包含remindend结束提醒时间添加小于等于条件到查询条件中
if (map.get("remindend")!= null) {
wrapper.le(columnName, map.get("remindend"));
}
// 调用chatService的selectCount方法根据构建好的查询条件统计符合条件的聊天记录数量
int count = chatService.selectCount(wrapper);
// 返回包含统计结果的R对象
return R.ok().put("count", count);
}
}

@ -0,0 +1,35 @@
package com.dao;
import com.entity.ChatEntity;
import com.baomidou.mybatisplus.mapper.BaseMapper;
import java.util.List;
import java.util.Map;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.pagination.Pagination;
import org.apache.ibatis.annotations.Param;
import com.entity.vo.ChatVO;
import com.entity.view.ChatView;
/**
* 线
*
* @author
* @email
* @date 2023-02-21 09:46:06
*/
public interface ChatDao extends BaseMapper<ChatEntity> {
List<ChatVO> selectListVO(@Param("ew") Wrapper<ChatEntity> wrapper);//根据给定的条件包装器Wrapper查询并返回符合条件的ChatVO列表
ChatVO selectVO(@Param("ew") Wrapper<ChatEntity> wrapper);//根据给定的条件包装器Wrapper查询并返回符合条件的ChatView列表
List<ChatView> selectListView(@Param("ew") Wrapper<ChatEntity> wrapper);
List<ChatView> selectListView(Pagination page,@Param("ew") Wrapper<ChatEntity> wrapper);
ChatView selectView(@Param("ew") Wrapper<ChatEntity> wrapper);
}

@ -0,0 +1,111 @@
package com.entity.model;
import com.entity.ChatEntity;
import com.baomidou.mybatisplus.annotations.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import java.util.Date;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
/**
* 线
*
* @author
* @email
* @date 2023-02-21 09:46:06
*/
public class ChatModel implements Serializable {
private static final long serialVersionUID = 1L;
/**
* id
*/
private Long adminid;
/**
*
*/
private String ask;
/**
*
*/
private String reply;
/**
*
*/
private Integer isreply;
/**
* id
*/
public void setAdminid(Long adminid) {
this.adminid = adminid;
}
/**
* id
*/
public Long getAdminid() {
return adminid;
}
/**
*
*/
public void setAsk(String ask) {
this.ask = ask;
}
/**
*
*/
public String getAsk() {
return ask;
}
/**
*
*/
public void setReply(String reply) {
this.reply = reply;
}
/**
*
*/
public String getReply() {
return reply;
}
/**
*
*/
public void setIsreply(Integer isreply) {
this.isreply = isreply;
}
/**
*
*/
public Integer getIsreply() {
return isreply;
}
}

@ -0,0 +1,313 @@
package com.controller;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
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 com.annotation.IgnoreAuth;
import com.baidu.aip.face.AipFace;
import com.baidu.aip.face.MatchRequest;
import com.baidu.aip.util.Base64Util;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.entity.ConfigEntity;
// 导入相关的服务类和工具类
import com.service.CommonService;
import com.service.ConfigService;
import com.utils.BaiduUtil;
import com.utils.FileUtil;
import com.utils.R;
import com.utils.CommonUtil;
/**
*
* SpringRestController
*
*/
@RestController
public class CommonController {
// 自动注入CommonService用于处理通用的业务逻辑
@Autowired
private CommonService commonService;
// 定义百度AI人脸识别客户端对象初始化为null
private static AipFace client = null;
// 自动注入ConfigService可能用于获取配置相关信息
@Autowired
private ConfigService configService;
/**
* tablecolumn
*
*
* @param tableName
* @param columnName
* @param conditionColumn
* @param conditionValue conditionColumn使
* @param level
* @param parent
* @return RR
*/
@RequestMapping("/option/{tableName}/{columnName}")
@IgnoreAuth
public R getOption(@PathVariable("tableName") String tableName, @PathVariable("tableName") String columnName,
@RequestParam(required = false) String conditionColumn,
@RequestParam(required = false) String conditionValue, String level, String parent) {
// 创建一个用于存储参数的Map对象
Map<String, Object> params = new HashMap<String, Object>();
params.put("table", tableName);
params.put("column", columnName);
if (StringUtils.isNotBlank(level)) {
params.put("level", level);
}
if (StringUtils.isNotBlank(parent)) {
params.put("parent", parent);
}
if (StringUtils.isNotBlank(conditionColumn)) {
params.put("conditionColumn", conditionColumn);
}
if (StringUtils.isNotBlank(conditionValue)) {
params.put("conditionValue", conditionValue);
}
// 调用commonService的getOption方法获取数据列表
List<String> data = commonService.getOption(params);
// 返回包含数据列表的R对象结果状态为成功
return R.ok().put("data", data);
}
/**
* tablecolumn
*
*
* @param tableName
* @param columnName
* @param columnValue
* @return R
*/
@RequestMapping("/follow/{tableName}/{columnName}")
@IgnoreAuth
public R getFollowByOption(@PathVariable("tableName") String tableName, @PathVariable("columnName") String columnName,
@RequestParam String columnValue) {
// 创建一个用于存储参数的Map对象
Map<String, Object> params = new HashMap<String, Object>();
params.put("table", tableName);
params.put("column", columnName);
params.put("columnValue", columnValue);
// 调用commonService的getFollowByOption方法获取单条记录数据
Map<String, Object> result = commonService.getFollowByOption(params);
// 返回包含单条记录数据的R对象结果状态为成功
return R.ok().put("data", result);
}
/**
* tablesfsh
* MapcommonServiceshsfsh
*
* @param tableName
* @param map Map
* @return R
*/
@RequestMapping("/sh/{tableName}")
public R sh(@PathVariable("tableName") String tableName, @RequestBody Map<String, Object> map) {
map.put("table", tableName);
commonService.sh(map);
return R.ok();
}
/**
*
* Map
* 2
*
* @param tableName
* @param columnName
* @param type 12
* @param map Maptype2
* @return R
*/
@RequestMapping("/remind/{tableName}/{columnName}/{type}")
@IgnoreAuth
public R remindCount(@PathVariable("tableName") String tableName, @PathVariable("columnName") String columnName,
@PathVariable("type") String type, @RequestParam Map<String, Object> map) {
map.put("table", tableName);
map.put("column", columnName);
map.put("type", type);
if (type.equals("2")) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Calendar c = Calendar.getInstance();
Date remindStartDate = null;
Date remindEndDate = null;
if (map.get("remindstart")!= null) {
Integer remindStart = Integer.parseInt(map.get("remindstart").toString());
c.setTime(new Date());
c.add(Calendar.DAY_OF_MONTH, remindStart);
remindStartDate = c.getTime();
map.put("remindstart", sdf.format(remindStartDate));
}
if (map.get("remindend")!= null) {
Integer recommendEnd = Integer.parseInt(map.get("remindend").toString());
c.setTime(new Date());
c.add(Calendar.DAY_OF_MONTH, recommendEnd);
remindEndDate = c.getTime();
map.put("remindend", sdf.format(remindEndDate));
}
}
// 调用commonService的remindCount方法获取需要提醒的记录数
int count = commonService.remindCount(map);
// 返回包含记录数的R对象结果状态为成功
return R.ok().put("count", count);
}
/**
*
* commonServiceselectCal
*
* @param tableName
* @param columnName
* @return R
*/
@RequestMapping("/cal/{tableName}/{columnName}")
@IgnoreAuth
public R cal(@PathVariable("tableName") String tableName, @PathVariable("columnName") String columnName) {
Map<String, Object> params = new HashMap<String, Object>();
params.put("table", tableName);
params.put("column", columnName);
// 调用commonService的selectCal方法进行求和操作并获取结果
Map<String, Object> result = commonService.selectCal(params);
// 返回包含求和结果的R对象结果状态为成功
return R.ok().put("data", result);
}
/**
*
* commonServiceselectGroup
*
*
* @param tableName
@param columnName
* @return R
*/
@RequestMapping("/group/{tableName}/{columnName}")
@IgnoreAuth
public R group(@PathVariable("tableName") String tableName, @PathVariable("columnName") String columnName) {
Map<String, Object> params = new HashMap<String, Object>();
params.put("table", tableName);
params.put("column", columnName);
// 调用commonService的selectGroup方法进行分组统计操作并获取结果
List<Map<String, Object>> result = commonService.selectGroup(params);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
for (Map<String, Object> m : result) {
for (String k : m.keySet()) {
if (m.get(k) instanceof Date) {
m.put(k, sdf.format((Date) m.get(k)));
}
}
}
// 返回包含分组统计结果的R对象结果状态为成功
return R.ok().put("data", result);
}
/**
*
* xycommonServiceselectValue
*
*
* @param tableName
* @param yColumnName y
* @param xColumnName x
* @return R
*/
@RequestMapping("/value/{tableName}/{xColumnName}/{yColumnName}")
@IgnoreAuth
public R value(@PathVariable("tableName") String tableName, @PathVariable("yColumnName") String yColumnName,
@PathVariable("xColumnName") String xColumnName) {
Map<String, Object> params = new HashMap<String, Object>();
params.put("table", tableName);
params.put("xColumn", xColumnName);
params.put("yColumn", yColumnName);
// 调用commonService的selectValue方法进行按值统计操作并获取结果
List<Map<String, Object> > result = commonService.selectValue(params);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
for (Map<String, Object> m : result) {
for (String k : m.keySet()) {
if (m.get(k) instanceof Date) {
m.put(k, sdf.format((Date) m.get(k)));
}
}
}
// 返回包含按值统计结果的R对象结果状态为成功
return R.ok().put("data", result);
}
/**
*
* xycommonServiceselectTimeStatValue
*
*
* @param tableName
* @param yColumnName y
* @param xColumnName x
* @param timeStatType
* @return R
*/
@RequestMapping("/value/{tableName}/{xColumnName}/{yColumnName}/{timeStatType}")
@IgnoreAuth
public R valueDay(@PathVariable("tableName") String tableName, @PathVariable("yColumnName") String yColumnName,
@PathVariable("xColumnName") String xColumnName, @PathVariable("timeStatType") String timeStatType) {
Map<String, Object> params = new HashMap<String, Object>();
params.put("table", tableName);
params.put("xColumn", xColumnName);
params.put("yColumn", yColumnName);
params.put("timeStatType", timeStatType);
// 调用commonService的selectTimeStatValue方法进行按值统计操作并获取结果
List<Map<String, Object> > result = commonService.selectTimeStatValue(params);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
for (Map<String, Object> m : result) {
for (String k : m.keySet()) {
if (m.get(k) instanceof Date) {
m.put(k, sdf.format((Date) m.get(k)));
}
}
}
// 返回包含按值统计结果的R对象结果状态为成功
return R.ok().put("data", result);
}
}

@ -0,0 +1,73 @@
package com.dao;
import java.util.List;
import java.util.Map;
/**
*
*/
public interface CommonDao {
/**
*
* @param params
* @return
*/
List<String> getOption(Map<String, Object> params);
/**
*
* @param params
* @return
*/
Map<String, Object> getFollowByOption(Map<String, Object> params);
/**
*
* @param params
* @return
*/
List<String> getFollowByOption2(Map<String, Object> params);
/**
*
* @param params
*/
void sh(Map<String, Object> params);
/**
*
* @param params
* @return
*/
int remindCount(Map<String, Object> params);
/**
*
* @param params
* @return
*/
Map<String, Object> selectCal(Map<String, Object> params);
/**
*
* @param params
* @return
*/
List<Map<String, Object>> selectGroup(Map<String, Object> params);
/**
*
* @param params
* @return
*/
List<Map<String, Object>> selectValue(Map<String, Object> params);
/**
*
* @param params
* @return
*/
List<Map<String, Object>> selectTimeStatValue(Map<String, Object> params);
}

@ -1,2 +0,0 @@
# j2ee

@ -0,0 +1,401 @@
package com.controller;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Map;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Date;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import com.utils.ValidatorUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.web.bind.annotation.PathVariable;
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 com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.annotation.IgnoreAuth;
import com.entity.YonghuEntity;
import com.entity.view.YonghuView;
import com.service.YonghuService;
import com.service.TokenService;
import com.utils.PageUtils;
import com.utils.R;
import com.utils.MD5Util;
import com.utils.MPUtil;
import com.utils.CommonUtil;
/**
*
*
* @author
* @email
* @date 2023-02-21 09:46:06
*/
@RestController
@RequestMapping("/yonghu")
public class YonghuController {
// 自动注入用户服务类,用于处理与用户相关的业务逻辑
@Autowired
private YonghuService yonghuService;
// 自动注入令牌服务类,用于生成和管理用户令牌
@Autowired
private TokenService tokenService;
/**
*
* @param username
* @param password
* @param captcha
* @param request Http
* @return R
*/
@IgnoreAuth
@RequestMapping(value = "/login")
public R login(String username, String password, String captcha, HttpServletRequest request) {
// 根据用户名查询用户实体
YonghuEntity u = yonghuService.selectOne(new EntityWrapper<YonghuEntity>().eq("zhanghao", username));
if (u == null ||!u.getMima().equals(password)) {
// 若用户不存在或密码不匹配,返回错误信息
return R.error("账号或密码不正确");
}
// 生成用户令牌
String token = tokenService.generateToken(u.getId(), username, "yonghu", "用户");
return R.ok().put("token", token);
}
/**
*
* @param yonghu YonghuEntity
* @return R
*/
@IgnoreAuth
@RequestMapping("/register")
public R register(@RequestBody YonghuEntity yonghu) {
// 此处原本应有对用户实体的验证逻辑,但被注释掉了
//ValidatorUtils.validateEntity(yonghu);
// 根据用户名查询是否已存在该用户
YonghuEntity u = yonghuService.selectOne(new EntityWrapper<YonghuEntity>().eq("zhanghao", yonghu.getZhanghao()));
if (u!= null) {
// 若用户已存在,返回错误信息
return R.error("注册用户已存在");
}
// 设置用户ID为当前时间戳
Long uId = new Date().getTime();
yonghu.setId(uId);
// 插入新用户信息到数据库
yonghuService.insert(yonghu);
return R.ok();
}
/**
* 退
* @param request Http
* @return 退R
*/
@RequestMapping("/logout")
public R logout(HttpServletRequest request) {
// 使当前会话失效,实现用户退出
request.getSession().invalidate();
return R.ok("退出成功");
}
/**
*
* @param request Http
* @return R
*/
@RequestMapping("/session")
public R getCurrUser(HttpServletRequest request) {
// 从会话中获取用户ID
Long id = (Long) request.getSession().getAttribute("userId");
// 根据用户ID查询用户实体
YonghuEntity u = yonghuService.selectById(id);
return R.ok().put("data", u);
}
/**
*
* @param username
* @param request Http
* @return R
*/
@IgnoreAuth
@RequestMapping(value = "/resetPass")
public R resetPass(String username, HttpServletRequest request) {
// 根据用户名查询用户实体
YonghuEntity u = yonghuService.selectOne(new EntityWrapper<YonghuEntity>().eq("zhanghao", username));
if (u == null) {
// 若用户不存在,返回错误信息
return R.error("账号不存在");
}
// 将用户密码重置为"123456"
u.setMima("123456");
// 更新用户信息到数据库
yonghuService.updateById(u);
return R.ok("密码已重置为123456");
}
/**
*
* @param params Map
* @param yonghu YonghuEntity
* @param request Http
* @return R
*/
@RequestMapping("/page")
public R page(@RequestParam Map<String, Object> params, YonghuEntity yonghu,
HttpServletRequest request) {
// 创建用于构建查询条件的EntityWrapper对象
EntityWrapper<YonghuEntity> ew = new EntityWrapper<YonghuEntity>();
// 调用服务类的方法进行分页查询,并进行排序、条件筛选等操作
PageUtils page = yonghuService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, yonghu), params), params));
request.setAttribute("data", page);
return R.ok().put("data", page);
}
/**
*
* page@IgnoreAuth访
* @param params Map
* @param yonghu YonghuEntity
* @param request Http
* @return R
*/
@IgnoreAuth
@RequestMapping("/list")
public R list(@RequestParam Map<String, Object> params, YonghuEntity yonghu,
HttpServletRequest request) {
EntityWrapper<YonghuEntity> ew = new EntityWrapper<YonghuEntity>();
PageUtils page = yonghuService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, yonghu), params), params));
request.setAttribute("data", page);
return R.ok().put("data", page);
}
/**
*
* @param yonghu YonghuEntity
* @return R
*/
@RequestMapping("/lists")
public R list(YonghuEntity yonghu) {
EntityWrapper<YonghuEntity> ew = new EntityWrapper<YonghuEntity>();
ew.allEq(MPUtil.allEQMapPre(yonghu, "yonghu"));
return R.ok().put("data", yonghuService.selectListView(ew));
}
/**
*
* @param yonghu YonghuEntity
* @return R
*/
@RequestMapping("/query")
public R query(YonghuEntity yonghu) {
EntityWrapper<YonghuEntity> ew = new EntityWrapper<YonghuEntity>();
ew.allEq(MPUtil.allEQMapPre(yonghu, "yonghu"));
YonghuView yonghuView = yonghuService.selectView(ew);
return R.ok("查询用户成功").put("data", yonghuView);
}
/**
*
* @param id ID
* @return R
*/
@RequestMapping("/info/{id}")
public R info(@PathVariable("id") Long id) {
YonghuEntity yonghu = yonghuService.selectById(id);
return R.ok().put("data", yonghu);
}
/**
*
* info@IgnoreAuth访
* @param id ID
* @return R
*/
@IgnoreAuth
@RequestMapping("/detail/{id}")
public R detail(@PathVariable("id") Long id) {
YonghuEntity yonghu = yonghuService.selectById(id);
return R.ok().put("data", yonghu);
}
/**
*
* @param yonghu YonghuEntity
* @param request Http
* @return R
*/
@RequestMapping("/save")
public R save(@RequestBody YonghuEntity yonghu, HttpServletRequest request) {
// 设置用户ID为当前时间戳加上一个随机数
yonghu.setId(new Date().getTime() + new Double(Math.floor(Math.random() * 1000)).longValue());
// 此处原本应有对用户实体的验证逻辑,但被注释掉了
//ValidatorUtils.validateEntity(yonghu);
YonghuEntity u = yonghuService.selectOne(new EntityWrapper<YonghuEntity>().eq("zhanghao", yonghu.getZhanghao()));
if (u!= null) {
// 若用户已存在,返回错误信息
return R.error("用户已存在");
}
yonghu.setId(new Date().getTime());
yonghuService.insert(yonghu);
return R.ok();
}
/**
*
* save
* @param yonghu YonghuEntity
* @param request Http
* @return R
*/
@RequestMapping("/add")
public R add(@RequestBody YonghuEntity yonghu, HttpServletRequest request) {
yonghu.setId(new Date().getTime() + new Double(Math.floor(Math.random() * 1000)).longValue());
// 此处原本应有对用户实体的验证逻辑,但被注释掉了
//ValidatorUtils.validateEntity(yonghu);
YonghuEntity u = yonghuService.selectOne(new EntityWrapper<YonghuEntity>().eq("zhanghao", yonghu.getZhanghao()));
if (u!= null) {
// 若用户已存在,返回错误信息
return R.error("用户已存在");
}
yonghu.setId(new Date().getTime());
yonghuService.insert(yonghu);
return R.ok();
}
/**
*
* @param yonghu YonghuEntity
* @param request Http
* @return R
*/
@RequestMapping("/update")
@Transactional
public R update(@RequestBody YonghuEntity yonghu, HttpServletRequest request) {
// 此处原本应有对用户实体的验证逻辑,但被注释掉了
//ValidatorUtils.validateEntity(yonghu);
yonghuService.updateById(yonghu); // 全部更新
return R.ok();
}
/**
*
* @param ids ID
* @return R
*/
@RequestMapping("/delete")
public R delete(@RequestBody Long[] ids) {
yonghuService.deleteBatchIds(Arrays.asList(ids));
return R.ok();
}
/**
*
* @param columnName
* @param request Http
* @param type
* @param map Map
* @return R
*/
@RequestMapping("/remind/{columnName}/{type}")
public R remindCount(@PathVariable("columnName") String columnName, HttpServletRequest request,
@PathVariable("type") String type, @RequestParam Map<String, Object> map) {
map.put("column", columnName);
map.put("type", type);
if (type.equals("2")) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Calendar c = Calendar.getInstance();
Date remindStartDate = null;
Date remindEndDate = null;
if (map.get("remindstart")!= null) {
Integer remindStart = Integer.parseInt(map.get("remindstart").toString());
c.setTime(new Date());
c.add(Calendar.DAY_OF_MONTH, remindStart);
remindStartDate = c.getTime();
map.put("remindstart", sdf.format(remindStartDate));
}
if (map.get("remindend")!= null) {
Integer remindEnd = Integer.parseInt(map.get("remindend").toString());
c.setTime(new Date());
c.add(Calendar.DAY_OF_MONTH, remindEnd);
remindEndDate = c.getTime();
map.put("remindend", sdf.format(remindEndDate));
}
}
Wrapper<YonghuEntity> wrapper = new EntityWrapper<YonghuEntity>();
if (map.get("remindstart")!= null) {
wrapper.ge(columnName, map.get("remindstart"));
}
if (map.get("remindend")!= null) {
wrapper.le(columnName, map.get("remindend"));
}
int count = yonghuService.selectCount(wrapper);
return R.ok().put("count", count);
}
/**
*
* @param yColumnName
* @param xColumnName
* @param request Http
* @return R
*/
@RequestMapping("/value/{xColumnName}/{yColumnName}")
public R value(@PathVariable("yColumnName") String yColumnName, @PathVariable("xColumnName") String xColumnName, HttpServletRequest request) {
Map<String, Object> params = new HashMap<String, Object>();
params.put("xColumn", xColumnName);
params.put("yColumn", yColumnName);
EntityWrapper<YonghuEntity> ew = new EntityWrapper<YonghuEntity>();
List<Map<String, Object>> result = yonghuService.selectValue(params, ew);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
for (Map<String, Object> m : result) {
for (String k : m.keySet()) {
if (m.get(k) instanceof Date) {
m.put(k, sdf.format((Date) m.get(k)));
}
}
}
return R.ok().put("data", result);
}
/**
*
* @param yColumnName
* @param xColumnName
* @param timeStatType
* @param request Http
* @return R
*/
@RequestMapping("/value/{xColumnName}/{yColumnName}/{timeStatType}")
public R valueDay(@PathVariable("yColumnName") String yColumnName, @PathVariable("xColumnName") String xColumnName, @PathVariable("timeStatType") String timeStatType, HttpServletRequest request) {
Map<String, Object> params = new HashMap<String, Object>();
params.put("xColumn", xColumnName);
params.put("yColumn", yColumnName);
params.put("timeStatType", timeStatType);
EntityWrapper<YonghuEntity> ew = new EntityWrapper<YonghuEntity>();
List<Map<String, Object>> result

@ -0,0 +1,42 @@
package com.dao;
import com.entity.YonghuEntity;
import com.baomidou.mybatisplus.mapper.BaseMapper;
import java.util.List;
import java.util.Map;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.pagination.Pagination;
import org.apache.ibatis.annotations.Param;
import com.entity.vo.YonghuVO;
import com.entity.view.YonghuView;
/**
* 访MyBatis-PlusBaseMapper
* YonghuEntity
*/
public interface YonghuDao extends BaseMapper<YonghuEntity> {
// 根据条件查询用户视图对象列表
List<YonghuVO> selectListVO(@Param("ew") Wrapper<YonghuEntity> wrapper);
// 根据条件查询单个用户视图对象
YonghuVO selectVO(@Param("ew") Wrapper<YonghuEntity> wrapper);
// 根据条件查询用户视图对象列表
List<YonghuView> selectListView(@Param("ew") Wrapper<YonghuEntity> wrapper);
// 根据分页信息和条件查询用户视图对象列表
List<YonghuView> selectListView(Pagination page, @Param("ew") Wrapper<YonghuEntity> wrapper);
// 根据条件查询单个用户视图对象
YonghuView selectView(@Param("ew") Wrapper<YonghuEntity> wrapper);
// 根据参数和条件查询值映射列表
List<Map<String, Object>> selectValue(@Param("params") Map<String, Object> params, @Param("ew") Wrapper<YonghuEntity> wrapper);
// 根据参数和条件查询时间统计值映射列表
List<Map<String, Object>> selectTimeStatValue(@Param("params") Map<String, Object> params, @Param("ew") Wrapper<YonghuEntity> wrapper);
// 根据参数和条件分组查询映射列表
List<Map<String, Object>> selectGroup(@Param("params") Map<String, Object> params, @Param("ew") Wrapper<YonghuEntity> wrapper);
}

@ -0,0 +1,156 @@
package com.entity.model;
import com.entity.YonghuEntity;
import com.baomidou.mybatisplus.annotations.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import java.util.Date;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
/**
*
*
* ModelAndView model
* @author
* @email
* @date 2023-02-21 09:46:06
*/
public class YonghuModel implements Serializable {
private static final long serialVersionUID = 1L;
/**
*
*/
private String mima;
/**
*
*/
private String xingming;
/**
*
*/
private String xingbie;
/**
*
*/
private String youxiang;
/**
*
*/
private String shoujihaoma;
/**
*
*/
private String touxiang;
/**
*
*/
public void setMima(String mima) {
this.mima = mima;
}
/**
*
*/
public String getMima() {
return mima;
}
/**
*
*/
public void setXingming(String xingming) {
this.xingming = xingming;
}
/**
*
*/
public String getXingming() {
return xingming;
}
/**
*
*/
public void setXingbie(String xingbie) {
this.xingbie = xingbie;
}
/**
*
*/
public String getXingbie() {
return xingbie;
}
/**
*
*/
public void setYouxiang(String youxiang) {
this.youxiang = youxiang;
}
/**
*
*/
public String getYouxiang() {
return youxiang;
}
/**
*
*/
public void setShoujihaoma(String shoujihaoma) {
this.shoujihaoma = shoujihaoma;
}
/**
*
*/
public String getShoujihaoma() {
return shoujihaoma;
}
/**
*
*/
public void setTouxiang(String touxiang) {
this.touxiang = touxiang;
}
/**
*
*/
public String getTouxiang() {
return touxiang;
}
}
Loading…
Cancel
Save