(源码)基于Java和Spring Boot框架的考编论坛网站.zip

/* **代码功能解释**： 这是一个基于Java的Spring框架的Controller层代码，主要用于处理一些通用功能。 1. **MySQL数据库备份与恢复**： - `beifen` 方法：用于导出MySQL数据库到一个文件，使用`mysqldump`命令。 - `huanyuan` 方法：用于从文件导入MySQL数据库，使用`mysql`命令。 2. **饼状图与柱状图数据处理**： - `pieSum` 方法：计算饼状图的数据总和。 - `pieCount` 方法：计算饼状图的数据统计。 - `barSumOne` 方法：计算单列柱状图的数据总和。 - `barCountOne` 方法：计算单列柱状图的数据统计。 - `barSumTwo` 方法：计算双列柱状图的数据总和。 - `barCountTwo` 方法：计算双列柱状图的数据统计。 3. **评分查询**： - `queryScore` 方法：查询并返回字典表的分组统计总条数。 4. **字典表统计**： - `newSelectGroupCount` 方法：查询并返回字典表的分组统计总条数。 - `newSelectGroupSum` 方法：查询并返回字典表的分组求和。 5. **柱状图数据处理**： - `barSum` 方法：计算柱状图的数据总和，支持处理包含两个维度的数据。 - `barCount` 方法：计算柱状图的数据统计，同样支持处理包含两个维度的数据。 6. **其他**： - `IgnoreAuth` 注解：用于标记某些接口不需要进行权限验证。 - 日志记录：使用`Logger`类进行日志记录。 该代码主要服务于后端接口，通过HTTP请求处理数据库操作、数据展示、数据计算等功能。 */ package com.controller; import java.io.*; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.text.SimpleDateFormat; import java.util.*; import javax.servlet.http.HttpServletRequest; import com.alibaba.fastjson.JSON; import com.utils.StringUtil; import org.apache.commons.lang3.StringUtils; import org.json.JSONObject; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.util.ResourceUtils; 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.baomidou.mybatisplus.mapper.Wrapper; import com.entity.ConfigEntity; import com.service.CommonService; import com.service.ConfigService; import com.utils.BaiduUtil; import com.utils.FileUtil; import com.utils.R; /** * 通用接口 */ @RestController public class CommonController { private static final Logger logger = LoggerFactory.getLogger(CommonController.class); @Autowired private CommonService commonService; /** * Java代码实现MySQL数据库导出 * * @param mysqlUrl MySQL安装路径 * @param hostIP MySQL数据库所在服务器地址IP * @param userName 进入数据库所需要的用户名 * @param hostPort 数据库端口 * @param password 进入数据库所需要的密码 * @param savePath 数据库文件保存路径 * @param fileName 数据库导出文件文件名 * @param databaseName 要导出的数据库名 * @return 返回true表示导出成功，否则返回false。 */ @IgnoreAuth @RequestMapping("/beifen") public R beifen(String mysqlUrl, String hostIP, String userName, String hostPort, String password, String savePath, String fileName, String databaseName) { File saveFile = new File(savePath); if (!saveFile.exists()) {// 如果目录不存在  saveFile.mkdirs();// 创建文件夹  } if (!savePath.endsWith(File.separator)) { savePath = savePath + File.separator; } PrintWriter printWriter = null; BufferedReader bufferedReader = null; try { Runtime runtime = Runtime.getRuntime(); String cmd = mysqlUrl + "mysqldump -h" + hostIP + " -u" + userName + " -P" + hostPort + " -p" + password + " " + databaseName; runtime.exec(cmd); Process process = runtime.exec(cmd); InputStreamReader inputStreamReader = new InputStreamReader(process.getInputStream(), "utf8"); bufferedReader = new BufferedReader(inputStreamReader); printWriter = new PrintWriter(new OutputStreamWriter(new FileOutputStream(savePath + fileName), "utf8")); String line; while ((line = bufferedReader.readLine()) != null) { printWriter.println(line); } printWriter.flush(); } catch (Exception e) { e.printStackTrace(); return R.error("备份数据出错"); } finally { try { if (bufferedReader != null) { bufferedReader.close(); } if (printWriter != null) { printWriter.close(); } } catch (Exception e) { e.printStackTrace(); } } return R.ok(); } /** * Java实现MySQL数据库导入 * * @param mysqlUrl MySQL安装路径 * @param hostIP MySQL数据库所在服务器地址IP * @param userName 进入数据库所需要的用户名 * @param hostPort 数据库端口 * @param password 进入数据库所需要的密码 * @param savePath 数据库文件保存路径 * @param fileName 数据库导出文件文件名 * @param databaseName 要导出的数据库名 */ @IgnoreAuth @RequestMapping("/huanyuan") public R huanyuan(String mysqlUrl, String hostIP, String userName, String hostPort, String password, String savePath, String fileName, String databaseName) { try { Runtime rt = Runtime.getRuntime(); Process child1 = rt.exec(mysqlUrl+"mysql.exe -h" + hostIP + " -u" + userName + " -P" + hostPort + " -p" + password + " " + databaseName); OutputStream out = child1.getOutputStream();//控制台的输入信息作为输出流 String inStr; StringBuffer sb = new StringBuffer(""); String outStr; BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(savePath+"/"+fileName), "utf-8")); while ((inStr = br.readLine()) != null) { sb.append(inStr + "\r\n"); } outStr = sb.toString(); OutputStreamWriter writer = new OutputStreamWriter(out, "utf8"); writer.write(outStr); writer.flush(); out.close(); br.close(); writer.close(); } catch (Exception e) { e.printStackTrace(); return R.error("数据导入出错"); } return R.ok(); } /** * 饼状图求和 * @return */ @RequestMapping("/pieSum") public R pieSum(@RequestParam Map<String,Object> params) { logger.debug("饼状图求和:,,Controller:{},,params:{}",this.getClass().getName(),params); List<Map<String, Object>> result = commonService.pieSum(params); return R.ok().put("data", result); } /** * 饼状图统计 * @return */ @RequestMapping("/pieCount") public R pieCount(@RequestParam Map<Strin