devbox
Monodyee
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Java项目:进销存管理系统(前后端分离+java+vue+Springboot+ssm+mysql+maven+redis)_java+vue+mysql前后端分离:文件下载接口

作者：Monodyee | 2024-03-26 11:37:18

赞

踩

java+vue+mysql前后端分离:文件下载接口

源码获取：博客首页 "资源" 里下载！

一、项目简述

本系统功能包括： 库存管理，入库管理，出库管理，往来管理，基础资料, 系统管理，消息中心，系统监控等等。

二、项目运行

环境配置： Jdk1.8 + Tomcat8.5 + Mysql + HBuilderX （ Webstorm也 行）+ Eclispe （ IntelliJ IDEA ,Eclispe,MyEclispe , Sts都支持）。

项目技术： Springboot + Maven + Mybatis-plus+ Vue + Redis + Shiro + Druid + logback 组成，B/S模萤；,其他：fastjson, poi, Swagger-ui, quartz, lombok （简化代码）等

接口返回数据格式：

  1. /**
  2.  *   接口返回数据格式
  3.  * @author scott
  4.  */
  5. @Data
  6. @ApiModel(value="接口返回对象", description="接口返回对象")
  7. public class Result<T> implements Serializable {
  8.  
  9. 	private static final long serialVersionUID = 1L;
  10.  
  11. 	/**
  12. 	 * 成功标志
  13. 	 */
  14. 	@ApiModelProperty(value = "成功标志")
  15. 	private boolean success = true;
  16.  
  17. 	/**
  18. 	 * 返回处理消息
  19. 	 */
  20. 	@ApiModelProperty(value = "返回处理消息")
  21. 	private String message = "操作成功！";
  22.  
  23. 	/**
  24. 	 * 返回代码
  25. 	 */
  26. 	@ApiModelProperty(value = "返回代码")
  27. 	private Integer code = 0;
  28. 	
  29. 	/**
  30. 	 * 返回数据对象 data
  31. 	 */
  32. 	@ApiModelProperty(value = "返回数据对象")
  33. 	private T result;
  34. 	
  35. 	/**
  36. 	 * 时间戳
  37. 	 */
  38. 	@ApiModelProperty(value = "时间戳")
  39. 	private long timestamp = System.currentTimeMillis();
  40.  
  41. 	public Result() {
  42. 		
  43. 	}
  44. 	
  45. 	public Result<T> success(String message) {
  46. 		this.message = message;
  47. 		this.code = CommonConstant.SC_OK_200;
  48. 		this.success = true;
  49. 		return this;
  50. 	}
  51. 	
  52. 	
  53. 	public static Result<Object> ok() {
  54. 		Result<Object> r = new Result<Object>();
  55. 		r.setSuccess(true);
  56. 		r.setCode(CommonConstant.SC_OK_200);
  57. 		r.setMessage("成功");
  58. 		return r;
  59. 	}
  60. 	
  61. 	public static Result<Object> ok(String msg) {
  62. 		Result<Object> r = new Result<Object>();
  63. 		r.setSuccess(true);
  64. 		r.setCode(CommonConstant.SC_OK_200);
  65. 		r.setMessage(msg);
  66. 		return r;
  67. 	}
  68. 	
  69. 	public static Result<Object> ok(Object data) {
  70. 		Result<Object> r = new Result<Object>();
  71. 		r.setSuccess(true);
  72. 		r.setCode(CommonConstant.SC_OK_200);
  73. 		r.setResult(data);
  74. 		return r;
  75. 	}
  76. 	
  77. 	public static Result<Object> error(String msg) {
  78. 		return error(CommonConstant.SC_INTERNAL_SERVER_ERROR_500, msg);
  79. 	}
  80. 	
  81. 	public static Result<Object> error(int code, String msg) {
  82. 		Result<Object> r = new Result<Object>();
  83. 		r.setCode(code);
  84. 		r.setMessage(msg);
  85. 		r.setSuccess(false);
  86. 		return r;
  87. 	}
  88.  
  89. 	public Result<T> error500(String message) {
  90. 		this.message = message;
  91. 		this.code = CommonConstant.SC_INTERNAL_SERVER_ERROR_500;
  92. 		this.success = false;
  93. 		return this;
  94. 	}
  95. 	/**
  96. 	 * 无权限访问返回结果
  97. 	 */
  98. 	public static Result<Object> noauth(String msg) {
  99. 		return error(CommonConstant.SC_JEECG_NO_AUTHZ, msg);
  100. 	}
  101. }

用户信息控制器：

  1. /**
  2.  * <p>
  3.  * 用户表 前端控制器
  4.  * </p>
  5.  *
  6.  */
  7. @Slf4j
  8. @RestController
  9. @RequestMapping("/sys/common")
  10. public class CommonController {
  11.  
  12. 	@Autowired
  13. 	private ISysBaseAPI sysBaseAPI;
  14.  
  15. 	@Value(value = "${jeecg.path.upload}")
  16. 	private String uploadpath;
  17.  
  18. 	/**
  19. 	 * 本地：local minio：minio 阿里：alioss
  20. 	 */
  21. 	@Value(value="${jeecg.uploadType}")
  22. 	private String uploadType;
  23.  
  24. 	/**
  25. 	 * @Author 政辉
  26. 	 * @return
  27. 	 */
  28. 	@GetMapping("/403")
  29. 	public Result<?> noauth()  {
  30. 		return Result.error("没有权限，请联系管理员授权");
  31. 	}
  32.  
  33. 	/**
  34. 	 * 文件上传统一方法
  35. 	 * @param request
  36. 	 * @param response
  37. 	 * @return
  38. 	 */
  39. 	@PostMapping(value = "/upload")
  40. 	public Result<?> upload(HttpServletRequest request, HttpServletResponse response) {
  41. 		Result<?> result = new Result<>();
  42. 		String savePath = "";
  43. 		String bizPath = request.getParameter("biz");
  44. 		MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
  45. 		MultipartFile file = multipartRequest.getFile("file");// 获取上传文件对象
  46. 		if(oConvertUtils.isEmpty(bizPath)){
  47. 			if(CommonConstant.UPLOAD_TYPE_OSS.equals(uploadType)){
  48. 				//未指定目录，则用阿里云默认目录 upload
  49. 				bizPath = "upload";
  50. 				//result.setMessage("使用阿里云文件上传时，必须添加目录！");
  51. 				//result.setSuccess(false);
  52. 				//return result;
  53. 			}else{
  54. 				bizPath = "";
  55. 			}
  56. 		}
  57. 		if(CommonConstant.UPLOAD_TYPE_LOCAL.equals(uploadType)){
  58. 			//针对jeditor编辑器如何使 lcaol模式，采用 base64格式存储
  59. 			String jeditor = request.getParameter("jeditor");
  60. 			if(oConvertUtils.isNotEmpty(jeditor)){
  61. 				result.setMessage(CommonConstant.UPLOAD_TYPE_LOCAL);
  62. 				result.setSuccess(true);
  63. 				return result;
  64. 			}else{
  65. 				savePath = this.uploadLocal(file,bizPath);
  66. 			}
  67. 		}else{
  68. 			savePath = sysBaseAPI.upload(file,bizPath,uploadType);
  69. 		}
  70. 		if(oConvertUtils.isNotEmpty(savePath)){
  71. 			result.setMessage(savePath);
  72. 			result.setSuccess(true);
  73. 		}else {
  74. 			result.setMessage("上传失败！");
  75. 			result.setSuccess(false);
  76. 		}
  77. 		return result;
  78. 	}
  79.  
  80. 	/**
  81. 	 * 本地文件上传
  82. 	 * @param mf 文件
  83. 	 * @param bizPath  自定义路径
  84. 	 * @return
  85. 	 */
  86. 	private String uploadLocal(MultipartFile mf,String bizPath){
  87. 		try {
  88. 			String ctxPath = uploadpath;
  89. 			String fileName = null;
  90. 			File file = new File(ctxPath + File.separator + bizPath + File.separator );
  91. 			if (!file.exists()) {
  92. 				file.mkdirs();// 创建文件根目录
  93. 			}
  94. 			String orgName = mf.getOriginalFilename();// 获取文件名
  95. 			orgName = CommonUtils.getFileName(orgName);
  96. 			if(orgName.indexOf(".")!=-1){
  97. 				fileName = orgName.substring(0, orgName.lastIndexOf(".")) + "_" + System.currentTimeMillis() + orgName.substring(orgName.indexOf("."));
  98. 			}else{
  99. 				fileName = orgName+ "_" + System.currentTimeMillis();
  100. 			}
  101. 			String savePath = file.getPath() + File.separator + fileName;
  102. 			File savefile = new File(savePath);
  103. 			FileCopyUtils.copy(mf.getBytes(), savefile);
  104. 			String dbpath = null;
  105. 			if(oConvertUtils.isNotEmpty(bizPath)){
  106. 				dbpath = bizPath + File.separator + fileName;
  107. 			}else{
  108. 				dbpath = fileName;
  109. 			}
  110. 			if (dbpath.contains("\\")) {
  111. 				dbpath = dbpath.replace("\\", "/");
  112. 			}
  113. 			return dbpath;
  114. 		} catch (IOException e) {
  115. 			log.error(e.getMessage(), e);
  116. 		}
  117. 		return "";
  118. 	}
  119.  
  120. //	@PostMapping(value = "/upload2")
  121. //	public Result<?> upload2(HttpServletRequest request, HttpServletResponse response) {
  122. //		Result<?> result = new Result<>();
  123. //		try {
  124. //			String ctxPath = uploadpath;
  125. //			String fileName = null;
  126. //			String bizPath = "files";
  127. //			String tempBizPath = request.getParameter("biz");
  128. //			if(oConvertUtils.isNotEmpty(tempBizPath)){
  129. //				bizPath = tempBizPath;
  130. //			}
  131. //			String nowday = new SimpleDateFormat("yyyyMMdd").format(new Date());
  132. //			File file = new File(ctxPath + File.separator + bizPath + File.separator + nowday);
  133. //			if (!file.exists()) {
  134. //				file.mkdirs();// 创建文件根目录
  135. //			}
  136. //			MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
  137. //			MultipartFile mf = multipartRequest.getFile("file");// 获取上传文件对象
  138. //			String orgName = mf.getOriginalFilename();// 获取文件名
  139. //			fileName = orgName.substring(0, orgName.lastIndexOf(".")) + "_" + System.currentTimeMillis() + orgName.substring(orgName.indexOf("."));
  140. //			String savePath = file.getPath() + File.separator + fileName;
  141. //			File savefile = new File(savePath);
  142. //			FileCopyUtils.copy(mf.getBytes(), savefile);
  143. //			String dbpath = bizPath + File.separator + nowday + File.separator + fileName;
  144. //			if (dbpath.contains("\\")) {
  145. //				dbpath = dbpath.replace("\\", "/");
  146. //			}
  147. //			result.setMessage(dbpath);
  148. //			result.setSuccess(true);
  149. //		} catch (IOException e) {
  150. //			result.setSuccess(false);
  151. //			result.setMessage(e.getMessage());
  152. //			log.error(e.getMessage(), e);
  153. //		}
  154. //		return result;
  155. //	}
  156.  
  157. 	/**
  158. 	 * 预览图片&下载文件
  159. 	 * 请求地址：http://localhost:8080/common/static/{user/20190119/e1fe9925bc315c60addea1b98eb1cb1349547719_1547866868179.jpg}
  160. 	 *
  161. 	 * @param request
  162. 	 * @param response
  163. 	 */
  164. 	@GetMapping(value = "/static/**")
  165. 	public void view(HttpServletRequest request, HttpServletResponse response) {
  166. 		// ISO-8859-1 ==> UTF-8 进行编码转换
  167. 		String imgPath = extractPathFromPattern(request);
  168. 		if(oConvertUtils.isEmpty(imgPath) || imgPath=="null"){
  169. 			return;
  170. 		}
  171. 		// 其余处理略
  172. 		InputStream inputStream = null;
  173. 		OutputStream outputStream = null;
  174. 		try {
  175. 			imgPath = imgPath.replace("..", "");
  176. 			if (imgPath.endsWith(",")) {
  177. 				imgPath = imgPath.substring(0, imgPath.length() - 1);
  178. 			}
  179. 			String filePath = uploadpath + File.separator + imgPath;
  180. 			File file = new File(filePath);
  181. 			if(!file.exists()){
  182. 				response.setStatus(404);
  183. 				throw new RuntimeException("文件不存在..");
  184. 			}
  185. 			response.setContentType("application/force-download");// 设置强制下载不打开
  186. 			response.addHeader("Content-Disposition", "attachment;fileName=" + new String(file.getName().getBytes("UTF-8"),"iso-8859-1"));
  187. 			inputStream = new BufferedInputStream(new FileInputStream(filePath));
  188. 			outputStream = response.getOutputStream();
  189. 			byte[] buf = new byte[1024];
  190. 			int len;
  191. 			while ((len = inputStream.read(buf)) > 0) {
  192. 				outputStream.write(buf, 0, len);
  193. 			}
  194. 			response.flushBuffer();
  195. 		} catch (IOException e) {
  196. 			log.error("预览文件失败" + e.getMessage());
  197. 			response.setStatus(404);
  198. 			e.printStackTrace();
  199. 		} finally {
  200. 			if (inputStream != null) {
  201. 				try {
  202. 					inputStream.close();
  203. 				} catch (IOException e) {
  204. 					log.error(e.getMessage(), e);
  205. 				}
  206. 			}
  207. 			if (outputStream != null) {
  208. 				try {
  209. 					outputStream.close();
  210. 				} catch (IOException e) {
  211. 					log.error(e.getMessage(), e);
  212. 				}
  213. 			}
  214. 		}
  215.  
  216. 	}
  217.  
  218. //	/**
  219. //	 * 下载文件
  220. //	 * 请求地址：http://localhost:8080/common/download/{user/20190119/e1fe9925bc315c60addea1b98eb1cb1349547719_1547866868179.jpg}
  221. //	 *
  222. //	 * @param request
  223. //	 * @param response
  224. //	 * @throws Exception
  225. //	 */
  226. //	@GetMapping(value = "/download/**")
  227. //	public void download(HttpServletRequest request, HttpServletResponse response) throws Exception {
  228. //		// ISO-8859-1 ==> UTF-8 进行编码转换
  229. //		String filePath = extractPathFromPattern(request);
  230. //		// 其余处理略
  231. //		InputStream inputStream = null;
  232. //		OutputStream outputStream = null;
  233. //		try {
  234. //			filePath = filePath.replace("..", "");
  235. //			if (filePath.endsWith(",")) {
  236. //				filePath = filePath.substring(0, filePath.length() - 1);
  237. //			}
  238. //			String localPath = uploadpath;
  239. //			String downloadFilePath = localPath + File.separator + filePath;
  240. //			File file = new File(downloadFilePath);
  241. //	         if (file.exists()) {
  242. //	         	response.setContentType("application/force-download");// 设置强制下载不打开            
  243. //	 			response.addHeader("Content-Disposition", "attachment;fileName=" + new String(file.getName().getBytes("UTF-8"),"iso-8859-1"));
  244. //	 			inputStream = new BufferedInputStream(new FileInputStream(file));
  245. //	 			outputStream = response.getOutputStream();
  246. //	 			byte[] buf = new byte[1024];
  247. //	 			int len;
  248. //	 			while ((len = inputStream.read(buf)) > 0) {
  249. //	 				outputStream.write(buf, 0, len);
  250. //	 			}
  251. //	 			response.flushBuffer();
  252. //	         }
  253. //
  254. //		} catch (Exception e) {
  255. //			log.info("文件下载失败" + e.getMessage());
  256. //			// e.printStackTrace();
  257. //		} finally {
  258. //			if (inputStream != null) {
  259. //				try {
  260. //					inputStream.close();
  261. //				} catch (IOException e) {
  262. //					e.printStackTrace();
  263. //				}
  264. //			}
  265. //			if (outputStream != null) {
  266. //				try {
  267. //					outputStream.close();
  268. //				} catch (IOException e) {
  269. //					e.printStackTrace();
  270. //				}
  271. //			}
  272. //		}
  273. //
  274. //	}
  275.  
  276. 	/**
  277. 	 * @功能：pdf预览Iframe
  278. 	 * @param modelAndView
  279. 	 * @return
  280. 	 */
  281. 	@RequestMapping("/pdf/pdfPreviewIframe")
  282. 	public ModelAndView pdfPreviewIframe(ModelAndView modelAndView) {
  283. 		modelAndView.setViewName("pdfPreviewIframe");
  284. 		return modelAndView;
  285. 	}
  286.  
  287. 	/**
  288. 	  *  把指定URL后的字符串全部截断当成参数
  289. 	  *  这么做是为了防止URL中包含中文或者特殊字符（/等）时，匹配不了的问题
  290. 	 * @param request
  291. 	 * @return
  292. 	 */
  293. 	private static String extractPathFromPattern(final HttpServletRequest request) {
  294. 		String path = (String) request.getAttribute(HandlerMapping.PATH_WITHIN_HANDLER_MAPPING_ATTRIBUTE);
  295. 		String bestMatchPattern = (String) request.getAttribute(HandlerMapping.BEST_MATCHING_PATTERN_ATTRIBUTE);
  296. 		return new AntPathMatcher().extractPathWithinPattern(bestMatchPattern, path);
  297. 	}
  298.  
  299.     /**
  300.      * 中转HTTP请求，解决跨域问题
  301.      *
  302.      * @param url 必填：请求地址
  303.      * @return
  304.      */
  305.     @RequestMapping("/transitRESTful")
  306.     public Result transitRESTful(@RequestParam("url") String url, HttpServletRequest request) {
  307.         try {
  308.             ServletServerHttpRequest httpRequest = new ServletServerHttpRequest(request);
  309.             // 中转请求method、body
  310.             HttpMethod method = httpRequest.getMethod();
  311.             JSONObject params;
  312.             try {
  313.                 params = JSON.parseObject(JSON.toJSONString(httpRequest.getBody()));
  314.             } catch (Exception e) {
  315.                 params = new JSONObject();
  316.             }
  317.             // 中转请求问号参数
  318.             JSONObject variables = JSON.parseObject(JSON.toJSONString(request.getParameterMap()));
  319.             variables.remove("url");
  320.             // 在 headers 里传递Token
  321.             String token = TokenUtils.getTokenByRequest(request);
  322.             HttpHeaders headers = new HttpHeaders();
  323.             headers.set("X-Access-Token", token);
  324.             // 发送请求
  325.             String httpURL = URLDecoder.decode(url, "UTF-8");
  326.             ResponseEntity<String> response = RestUtil.request(httpURL, method, headers , variables, params, String.class);
  327.             // 封装返回结果
  328.             Result<Object> result = new Result<>();
  329.             int statusCode = response.getStatusCodeValue();
  330.             result.setCode(statusCode);
  331.             result.setSuccess(statusCode == 200);
  332.             String responseBody = response.getBody();
  333.             try {
  334.                 // 尝试将返回结果转为JSON
  335.                 Object json = JSON.parse(responseBody);
  336.                 result.setResult(json);
  337.             } catch (Exception e) {
  338.                 // 转成JSON失败，直接返回原始数据
  339.                 result.setResult(responseBody);
  340.             }
  341.             return result;
  342.         } catch (Exception e) {
  343.             log.debug("中转HTTP请求失败", e);
  344.             return Result.error(e.getMessage());
  345.         }
  346.     }
  347.  
  348. }

 

付款单控制层：

  1. /**
  2.  * @Description: 付款单
  3.  */
  4. @Api(tags="付款单")
  5. @RestController
  6. @RequestMapping("/finance/finPayment")
  7. @Slf4j
  8. public class FinPaymentController {
  9. 	@Autowired
  10. 	private IFinPaymentService finPaymentService;
  11. 	@Autowired
  12. 	private IFinPaymentEntryService finPaymentEntryService;
  13. 	
  14. 	/**
  15. 	 * 分页列表查询
  16. 	 *
  17. 	 * @param finPayment
  18. 	 * @param pageNo
  19. 	 * @param pageSize
  20. 	 * @param req
  21. 	 * @return
  22. 	 */
  23. 	@AutoLog(value = "付款单-分页列表查询")
  24. 	@ApiOperation(value="付款单-分页列表查询", notes="付款单-分页列表查询")
  25. 	@GetMapping(value = {"/list", "/list/{paymentType}"})  //paymentType会传至finPayment.paymentType
  26. 	public Result<?> queryPageList(FinPayment finPayment,
  27. 								   @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
  28. 								   @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
  29. 								   HttpServletRequest req) {
  30. 		QueryWrapper<FinPayment> queryWrapper = QueryGenerator.initQueryWrapper(finPayment, req.getParameterMap());
  31. 		Page<FinPayment> page = new Page<FinPayment>(pageNo, pageSize);
  32. 		IPage<FinPayment> pageList = finPaymentService.page(page, queryWrapper);
  33. 		return Result.ok(pageList);
  34. 	}
  35.  
  36. 	 @GetMapping(value = "/checkableList")
  37. 	 public Result<?> queryCheckablePageList(FinPayment finPayment,
  38. 											 @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
  39. 											 @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
  40. 											 HttpServletRequest req) {
  41. 		 QueryWrapper<FinPayment> queryWrapper = QueryGenerator.initQueryWrapper(finPayment, req.getParameterMap());
  42. 		 List<String>  list = new ArrayList<String>();
  43. 		 list.add("23");
  44. 		 list.add("31");
  45. 		 list.add("32");
  46. 		 queryWrapper.in("bill_proc_Status", list);
  47. 		 queryWrapper.eq("is_approved", 1);
  48. 		 queryWrapper.eq("is_closed", 0);
  49. 		 queryWrapper.eq("is_voided", 0);
  50. 		 queryWrapper.apply("amt - deducted_amt - checked_amt > 0");
  51. 		 Page<FinPayment> page = new Page<FinPayment>(pageNo, pageSize);
  52. 		 IPage<FinPayment> pageList = finPaymentService.page(page, queryWrapper);
  53. 		 return Result.ok(pageList);
  54. 	 }
  55. 	 
  56. 	 /**
  57. 	 *   添加
  58. 	 *
  59. 	 * @param finPaymentPage
  60. 	 * @return
  61. 	 */
  62. 	@AutoLog(value = "付款单-添加")
  63. 	@ApiOperation(value="付款单-添加", notes="付款单-添加")
  64. 	@PostMapping(value = "/add")
  65. 	public Result<?> add(@RequestBody FinPaymentPage finPaymentPage) {
  66. 		FinPayment finPayment = new FinPayment();
  67. 		BeanUtils.copyProperties(finPaymentPage, finPayment);
  68. 		finPaymentService.saveMain(finPayment, finPaymentPage.getFinPaymentEntryList());
  69. 		return Result.ok("添加成功！");
  70. 	}
  71. 	
  72. 	/**
  73. 	 *  编辑
  74. 	 *
  75. 	 * @param finPaymentPage
  76. 	 * @return
  77. 	 */
  78. 	@AutoLog(value = "付款单-编辑")
  79. 	@ApiOperation(value="付款单-编辑", notes="付款单-编辑")
  80. 	@PutMapping(value = "/edit")
  81. 	public Result<?> edit(@RequestBody FinPaymentPage finPaymentPage) {
  82. 		FinPayment finPayment = new FinPayment();
  83. 		BeanUtils.copyProperties(finPaymentPage, finPayment);
  84. 		FinPayment finPaymentEntity = finPaymentService.getById(finPayment.getId());
  85. 		if(finPaymentEntity==null) {
  86. 			return Result.error("未找到对应数据");
  87. 		}
  88. 		finPaymentService.updateMain(finPayment, finPaymentPage.getFinPaymentEntryList());
  89. 		return Result.ok("编辑成功!");
  90. 	}
  91. 	
  92. 	/**
  93. 	 *   通过id删除
  94. 	 *
  95. 	 * @param id
  96. 	 * @return
  97. 	 */
  98. 	@AutoLog(value = "付款单-通过id删除")
  99. 	@ApiOperation(value="付款单-通过id删除", notes="付款单-通过id删除")
  100. 	@DeleteMapping(value = "/delete")
  101. 	public Result<?> delete(@RequestParam(name="id",required=true) String id) {
  102. 		finPaymentService.delMain(id);
  103. 		return Result.ok("删除成功!");
  104. 	}
  105. 	
  106. 	/**
  107. 	 *  批量删除
  108. 	 *
  109. 	 * @param ids
  110. 	 * @return
  111. 	 */
  112. 	@AutoLog(value = "付款单-批量删除")
  113. 	@ApiOperation(value="付款单-批量删除", notes="付款单-批量删除")
  114. 	@DeleteMapping(value = "/deleteBatch")
  115. 	public Result<?> deleteBatch(@RequestParam(name="ids",required=true) String ids) {
  116. 		this.finPaymentService.delBatchMain(Arrays.asList(ids.split(",")));
  117. 		return Result.ok("批量删除成功！");
  118. 	}
  119. 	
  120. 	/**
  121. 	 * 通过id查询
  122. 	 *
  123. 	 * @param id
  124. 	 * @return
  125. 	 */
  126. 	@AutoLog(value = "付款单-通过id查询")
  127. 	@ApiOperation(value="付款单-通过id查询", notes="付款单-通过id查询")
  128. 	@GetMapping(value = "/queryById")
  129. 	public Result<?> queryById(@RequestParam(name="id",required=true) String id) {
  130. 		FinPayment finPayment = finPaymentService.getById(id);
  131. 		if(finPayment==null) {
  132. 			return Result.error("未找到对应数据");
  133. 		}
  134. 		return Result.ok(finPayment);
  135.  
  136. 	}
  137. 	
  138. 	/**
  139. 	 * 通过id查询
  140. 	 *
  141. 	 * @param id
  142. 	 * @return
  143. 	 */
  144. 	@AutoLog(value = "付款明细集合-通过id查询")
  145. 	@ApiOperation(value="付款明细集合-通过id查询", notes="付款明细-通过id查询")
  146. 	@GetMapping(value = "/queryFinPaymentEntryByMainId")
  147. 	public Result<?> queryFinPaymentEntryListByMainId(@RequestParam(name="id",required=true) String id) {
  148. 		List<FinPaymentEntry> finPaymentEntryList = finPaymentEntryService.selectByMainId(id);
  149. 		return Result.ok(finPaymentEntryList);
  150. 	}
  151.  
  152.     /**
  153.     * 导出excel
  154.     *
  155.     * @param request
  156.     * @param finPayment
  157.     */
  158.     @RequestMapping(value =  {"/exportXls", "/exportXls/{paymentType}"})
  159.     public ModelAndView exportXls(HttpServletRequest request, FinPayment finPayment) {
  160.       // Step.1 组装查询条件查询数据
  161.       QueryWrapper<FinPayment> queryWrapper = QueryGenerator.initQueryWrapper(finPayment, request.getParameterMap());
  162.       LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
  163.  
  164.       //Step.2 获取导出数据
  165.       List<FinPayment> queryList = finPaymentService.list(queryWrapper);
  166.       // 过滤选中数据
  167.       String selections = request.getParameter("selections");
  168.       List<FinPayment> finPaymentList = new ArrayList<FinPayment>();
  169.       if(oConvertUtils.isEmpty(selections)) {
  170.           finPaymentList = queryList;
  171.       }else {
  172.           List<String> selectionList = Arrays.asList(selections.split(","));
  173.           finPaymentList = queryList.stream().filter(item -> selectionList.contains(item.getId())).collect(Collectors.toList());
  174.       }
  175.  
  176.       // Step.3 组装pageList
  177.       List<FinPaymentPage> pageList = new ArrayList<FinPaymentPage>();
  178.       for (FinPayment main : finPaymentList) {
  179.           FinPaymentPage vo = new FinPaymentPage();
  180.           BeanUtils.copyProperties(main, vo);
  181.           List<FinPaymentEntry> finPaymentEntryList = finPaymentEntryService.selectByMainId(main.getId());
  182.           vo.setFinPaymentEntryList(finPaymentEntryList);
  183.           pageList.add(vo);
  184.       }
  185.  
  186.       // Step.4 AutoPoi 导出Excel
  187.       ModelAndView mv = new ModelAndView(new JeecgEntityExcelView());
  188.       mv.addObject(NormalExcelConstants.FILE_NAME, "付款单列表");
  189.       mv.addObject(NormalExcelConstants.CLASS, FinPaymentPage.class);
  190.       mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("付款单数据", "导出人:"+sysUser.getRealname(), "付款单"));
  191.       mv.addObject(NormalExcelConstants.DATA_LIST, pageList);
  192.       return mv;
  193.     }
  194.  
  195.     /**
  196.     * 通过excel导入数据
  197.     *
  198.     * @param request
  199.     * @param response
  200.     * @return
  201.     */
  202.     @RequestMapping(value = "/importExcel", method = RequestMethod.POST)
  203.     public Result<?> importExcel(HttpServletRequest request, HttpServletResponse response) {
  204.       MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
  205.       Map<String, MultipartFile> fileMap = multipartRequest.getFileMap();
  206.       for (Map.Entry<String, MultipartFile> entity : fileMap.entrySet()) {
  207.           MultipartFile file = entity.getValue();// 获取上传文件对象
  208.           ImportParams params = new ImportParams();
  209.           params.setTitleRows(2);
  210.           params.setHeadRows(1);
  211.           params.setNeedSave(true);
  212.           try {
  213.               List<FinPaymentPage> list = ExcelImportUtil.importExcel(file.getInputStream(), FinPaymentPage.class, params);
  214.               for (FinPaymentPage page : list) {
  215.                   FinPayment po = new FinPayment();
  216.                   BeanUtils.copyProperties(page, po);
  217.                   finPaymentService.saveMain(po, page.getFinPaymentEntryList());
  218.               }
  219.               return Result.ok("文件导入成功！数据行数:" + list.size());
  220.           } catch (Exception e) {
  221.               log.error(e.getMessage(),e);
  222.               return Result.error("文件导入失败:"+e.getMessage());
  223.           } finally {
  224.               try {
  225.                   file.getInputStream().close();
  226.               } catch (IOException e) {
  227.                   e.printStackTrace();
  228.               }
  229.           }
  230.       }
  231.       return Result.ok("文件导入失败！");
  232.     }
  233.  
  234. 	 @AutoLog(value = "付款单-通过id审核")
  235. 	 @ApiOperation(value="付款单-通过id审核", notes="付款单-通过id审核")
  236. 	 @PutMapping(value = "/approve")
  237. 	 public Result<?> approve(@RequestBody JSONObject json) {
  238. 		 finPaymentService.approve(json.getString("id"));
  239. 		 return Result.ok("审核通过!");
  240. 	 }
  241. }

源码获取：博客首页 "资源" 里下载！

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Monodyee/article/detail/317008
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号