SpringBoot仓库管理系统代码

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); // 注：这里如果用缓冲方式写入文件的话，会导致中文乱码，用flush()方法则可以避免 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<String,Object> params) { logger.debug("饼状图统计:,,Controller:{},,params:{}",this.getClass().getName(),params); List<Map<String, Object>> result = commonService.pieCount(params); return R.ok().put("data", result); } /** * 柱状图求和单列 * @return */ @RequestMapping("/barSumOne") public R barSumOne(@RequestParam Map<String,Object> params) { logger.debug("柱状图求和单列:,,Controller:{},,params:{}",this.getClass().getName(),params); List<Map<String, Object>> result = commonService.barSumOne(params); List<String> xAxis = new ArrayList<>();//报表x轴 List<List<String>> yAxis = new ArrayList<>();//y轴 List<String> legend = new ArrayList<>();//标题 List<String> yAxis0 = new ArrayList<>(); yAxis.add(yAxis0); legend.add(""); for(Map<String, Object> map :result){ String oneValue = String.valueOf(map.get("name")); String value = String.valueOf(map.get("value")); xAxis.add(oneValue); yAxis0.add(value); } Map<String, Object> resultMap = new HashMap<>(); resultMap.put("xAxis",xAxis); resultMap.put("yAxis",yAxis); resultMap.put("legend",legend); return R.ok().put("data", resultMap); } /** * 柱状图统计单列 * @return */ @RequestMapping("/barCountOne") public R barCountOne(@Requ