package org.jeecg.modules.tms.controller; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.parser.Feature; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import org.jeecg.common.system.query.QueryGenerator; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import lombok.extern.slf4j.Slf4j; import org.jeecg.common.system.base.controller.JeecgController; import org.jeecg.common.api.vo.Result; import org.jeecg.common.util.TranslateDictTextUtils; import org.jeecg.modules.tms.entity.dto.OutBoundOrderFlowDto; import org.jeecg.modules.tms.entity.dto.OutBoundRequestDto; import org.jeecg.modules.tms.entity.dto.OutboundOrderAndDetailDto; import org.jeecg.modules.tms.entity.vo.OutboundDetailVo; import org.jeecg.modules.tms.enums.OutBillStatus; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.springframework.web.servlet.ModelAndView; import java.util.Arrays; import org.jeecg.common.util.oConvertUtils; import org.jeecg.modules.tms.entity.OutboundDetail; import org.jeecg.modules.tms.entity.OutboundOrder; import org.jeecg.modules.tms.service.IOutboundOrderService; import org.jeecg.modules.tms.service.IOutboundDetailService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.jeecg.common.aspect.annotation.AutoLog; import org.apache.shiro.SecurityUtils; import org.jeecg.common.system.vo.LoginUser; import org.jeecgframework.poi.excel.ExcelImportUtil; import org.jeecgframework.poi.excel.def.NormalExcelConstants; import org.jeecgframework.poi.excel.entity.ExportParams; import org.jeecgframework.poi.excel.entity.ImportParams; import org.jeecgframework.poi.excel.view.JeecgEntityExcelView; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import java.io.IOException; import java.util.List; import java.util.Map; import java.util.stream.Collectors; /** * @Description: tms_outbound_order * @Author: jeecg-boot * @Date: 2025-05-16 * @Version: V1.0 */ @Api(tags="tms_outbound_order") @RestController @RequestMapping("/tms/outboundOrder") @Slf4j public class OutboundOrderController extends JeecgController { @Autowired private IOutboundOrderService outboundOrderService; @Autowired private IOutboundDetailService outboundDetailService; @Autowired private ObjectMapper objectMapper; @Autowired private TranslateDictTextUtils translateDictTextUtils; /*---------------------------------主表处理-begin-------------------------------------*/ /** * 分页列表查询 * @param outboundOrder * @param pageNo * @param pageSize * @param req * @return */ //@AutoLog(value = "tms_outbound_order-分页列表查询") @ApiOperation(value="tms_outbound_order-分页列表查询", notes="tms_outbound_order-分页列表查询") @GetMapping(value = "/list") public Result> queryPageList(OutboundOrder outboundOrder, @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, HttpServletRequest req) { Map parameterMap = req.getParameterMap(); QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(outboundOrder, parameterMap); Page page = new Page(pageNo, pageSize); IPage pageList = outboundOrderService.queryPageList(page, parameterMap); return Result.OK(pageList); } @ApiOperation(value="tms_outbound_order-通过id查询", notes="tms_outbound_order-通过id查询") @GetMapping(value = "/queryById") public Result queryById(@RequestParam("id") String id) { OutboundOrder outboundOrder = outboundOrderService.getById(id); if (outboundOrder == null) { return Result.error("未找到对应数据"); } try { String jsonStr = objectMapper.writeValueAsString(outboundOrder); JSONObject item = JSONObject.parseObject(jsonStr, Feature.OrderedField); translateDictTextUtils.translateField("outStorehouseType", outboundOrder.getOutStorehouseType(), item, "out_storehouse_type"); translateDictTextUtils.translateField("handler", outboundOrder.getHandler(), item, "sys_user,realname,id"); translateDictTextUtils.translateField("orderStatus", outboundOrder.getOrderStatus(), item, "out_bill_status"); translateDictTextUtils.translateField("outStatus", outboundOrder.getOutStatus(), item, "out_storehouse_status"); translateDictTextUtils.translateField("createBy", outboundOrder.getCreateBy(), item, "sys_user,realname,username"); translateDictTextUtils.translateField("updateBy", outboundOrder.getUpdateBy(), item, "sys_user,realname,username"); return Result.OK(item); } catch (JsonProcessingException e) { return Result.error("数据转译失败！"); } } /** * 添加 * @param outboundOrder * @return */ @AutoLog(value = "tms_outbound_order-添加") @ApiOperation(value="tms_outbound_order-添加", notes="tms_outbound_order-添加") //@RequiresPermissions("org.jeecg.modules:tms_outbound_order:add") @PostMapping(value = "/add") public Result add(@RequestBody OutboundOrder outboundOrder) { outboundOrderService.save(outboundOrder); return Result.OK("添加成功！"); } @AutoLog(value = "tms_outbound_order-添加出库申请单主表及明细信息") @ApiOperation(value="tms_outbound_order-添加出库申请单主表及明细信息", notes="tms_outbound_order-添加出库申请单主表及明细信息") @PostMapping(value = "/addTotal") public Result addTotal(@RequestBody OutboundOrderAndDetailDto outboundOrder) { outboundOrderService.addTotal(outboundOrder); return Result.OK("添加成功！"); } @AutoLog(value = "tms_outbound_order-编辑出库申请单主表及明细信息") @ApiOperation(value="tms_outbound_order-编辑出库申请单主表及明细信息", notes="tms_outbound_order-编辑出库申请单主表及明细信息") //@RequiresPermissions("org.jeecg.modules:tms_outbound_order:edit") @RequestMapping(value = "/editTotal", method = {RequestMethod.PUT,RequestMethod.POST}) public Result editTotal(@RequestBody OutboundOrderAndDetailDto outboundOrder) { outboundOrderService.editTotal(outboundOrder); return Result.OK("编辑成功！"); } /** * 编辑 * @param outboundOrder * @return */ @AutoLog(value = "tms_outbound_order-编辑") @ApiOperation(value="tms_outbound_order-编辑", notes="tms_outbound_order-编辑") //@RequiresPermissions("org.jeecg.modules:tms_outbound_order:edit") @RequestMapping(value = "/edit", method = {RequestMethod.PUT,RequestMethod.POST}) public Result edit(@RequestBody OutboundOrder outboundOrder) { outboundOrderService.updateById(outboundOrder); return Result.OK("编辑成功!"); } @AutoLog(value = "tms_outbound_order-提交出库申请单") @ApiOperation(value="tms_outbound_order-提交出库申请单", notes="tms_outbound_order-提交出库申请单") @GetMapping(value = "/submit") public Result submit(@RequestParam(name="id") String id) { outboundOrderService.submit(id); return Result.OK("提交成功!"); } @AutoLog(value = "审批流程") @ApiOperation(value = "出库申请单-审批流程", notes = "出库申请单-审批流程") @PostMapping("/approval") public Result approval(@RequestBody OutBoundOrderFlowDto outBoundOrderFlowDto) { outboundOrderService.approvalProcess(outBoundOrderFlowDto); return Result.OK("操作成功"); } @AutoLog(value = "申请单方式出库") @ApiOperation(value = "申请单方式出库", notes = "申请单方式出库") @PostMapping(value = "/outBound") public Result outBound(@RequestBody List outBoundRequestList) { outboundOrderService.outBound(outBoundRequestList); return Result.OK("出库成功"); } /** * 通过id删除 * @param id * @return */ @AutoLog(value = "tms_outbound_order-通过id删除") @ApiOperation(value="tms_outbound_order-通过id删除", notes="tms_outbound_order-通过id删除") //@RequiresPermissions("org.jeecg.modules:tms_outbound_order:delete") @DeleteMapping(value = "/delete") public Result delete(@RequestParam(name="id",required=true) String id) { outboundOrderService.delMain(id); return Result.OK("删除成功!"); } /** * 批量删除 * @param ids * @return */ @AutoLog(value = "tms_outbound_order-批量删除") @ApiOperation(value="tms_outbound_order-批量删除", notes="tms_outbound_order-批量删除") //@RequiresPermissions("org.jeecg.modules:tms_outbound_order:deleteBatch") @DeleteMapping(value = "/deleteBatch") public Result deleteBatch(@RequestParam(name="ids",required=true) String ids) { this.outboundOrderService.delBatchMain(Arrays.asList(ids.split(","))); return Result.OK("批量删除成功!"); } /** * 导出 * @return */ //@RequiresPermissions("org.jeecg.modules:tms_outbound_order:exportXls") @RequestMapping(value = "/exportXls") public ModelAndView exportXls(HttpServletRequest request, OutboundOrder outboundOrder) { return super.exportXls(request, outboundOrder, OutboundOrder.class, "tms_outbound_order"); } /** * 导入 * @return */ //@RequiresPermissions("org.jeecg.modules:tms_outbound_order:importExcel") @RequestMapping(value = "/importExcel", method = RequestMethod.POST) public Result importExcel(HttpServletRequest request, HttpServletResponse response) { return super.importExcel(request, response, OutboundOrder.class); } /*---------------------------------主表处理-end-------------------------------------*/ /*--------------------------------子表处理-出库申请单明细-begin----------------------------------------------*/ /** * 通过主表ID查询 * @return */ //@AutoLog(value = "出库申请单明细-通过主表ID查询") @ApiOperation(value="出库申请单明细-通过主表ID查询", notes="出库申请单明细-通过主表ID查询") @GetMapping(value = "/listOutboundDetailByMainId") public Result> listOutboundDetailByMainId(OutboundDetail outboundDetail, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) { Map parameterMap = req.getParameterMap(); QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(outboundDetail, parameterMap); Page page = new Page(pageNo, pageSize); IPage pageList = outboundDetailService.queryPageList(page, parameterMap); return Result.OK(pageList); } /** * 添加 * @param outboundDetail * @return */ @AutoLog(value = "出库申请单明细-添加") @ApiOperation(value="出库申请单明细-添加", notes="出库申请单明细-添加") @PostMapping(value = "/addOutboundDetail") public Result addOutboundDetail(@RequestBody OutboundDetail outboundDetail) { outboundDetailService.save(outboundDetail); return Result.OK("添加成功！"); } /** * 编辑 * @param outboundDetail * @return */ @AutoLog(value = "出库申请单明细-编辑") @ApiOperation(value="出库申请单明细-编辑", notes="出库申请单明细-编辑") @RequestMapping(value = "/editOutboundDetail", method = {RequestMethod.PUT,RequestMethod.POST}) public Result editOutboundDetail(@RequestBody OutboundDetail outboundDetail) { outboundDetailService.updateById(outboundDetail); return Result.OK("编辑成功!"); } /** * 通过id删除 * @param id * @return */ @AutoLog(value = "出库申请单明细-通过id删除") @ApiOperation(value="出库申请单明细-通过id删除", notes="出库申请单明细-通过id删除") @DeleteMapping(value = "/deleteOutboundDetail") public Result deleteOutboundDetail(@RequestParam(name="id",required=true) String id) { outboundDetailService.removeById(id); return Result.OK("删除成功!"); } /** * 批量删除 * @param ids * @return */ @AutoLog(value = "出库申请单明细-批量删除") @ApiOperation(value="出库申请单明细-批量删除", notes="出库申请单明细-批量删除") @DeleteMapping(value = "/deleteBatchOutboundDetail") public Result deleteBatchOutboundDetail(@RequestParam(name="ids",required=true) String ids) { this.outboundDetailService.removeByIds(Arrays.asList(ids.split(","))); return Result.OK("批量删除成功!"); } /** * 导出 * @return */ @RequestMapping(value = "/exportOutboundDetail") public ModelAndView exportOutboundDetail(HttpServletRequest request, OutboundDetail outboundDetail) { // Step.1 组装查询条件 QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(outboundDetail, request.getParameterMap()); LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); // Step.2 获取导出数据 List pageList = outboundDetailService.list(queryWrapper); List exportList = null; // 过滤选中数据 String selections = request.getParameter("selections"); if (oConvertUtils.isNotEmpty(selections)) { List selectionList = Arrays.asList(selections.split(",")); exportList = pageList.stream().filter(item -> selectionList.contains(item.getId())).collect(Collectors.toList()); } else { exportList = pageList; } // Step.3 AutoPoi 导出Excel ModelAndView mv = new ModelAndView(new JeecgEntityExcelView()); //此处设置的filename无效,前端会重更新设置一下 mv.addObject(NormalExcelConstants.FILE_NAME, "出库申请单明细"); mv.addObject(NormalExcelConstants.CLASS, OutboundDetail.class); mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("出库申请单明细报表", "导出人:" + sysUser.getRealname(), "出库申请单明细")); mv.addObject(NormalExcelConstants.DATA_LIST, exportList); return mv; } /** * 导入 * @return */ @RequestMapping(value = "/importOutboundDetail/{mainId}") public Result importOutboundDetail(HttpServletRequest request, HttpServletResponse response, @PathVariable("mainId") String mainId) { MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request; Map fileMap = multipartRequest.getFileMap(); for (Map.Entry entity : fileMap.entrySet()) { // 获取上传文件对象 MultipartFile file = entity.getValue(); ImportParams params = new ImportParams(); params.setTitleRows(2); params.setHeadRows(1); params.setNeedSave(true); try { List list = ExcelImportUtil.importExcel(file.getInputStream(), OutboundDetail.class, params); for (OutboundDetail temp : list) { temp.setOutStorehouseId(mainId); } long start = System.currentTimeMillis(); outboundDetailService.saveBatch(list); log.info("消耗时间" + (System.currentTimeMillis() - start) + "毫秒"); return Result.OK("文件导入成功！数据行数：" + list.size()); } catch (Exception e) { log.error(e.getMessage(), e); return Result.error("文件导入失败:" + e.getMessage()); } finally { try { file.getInputStream().close(); } catch (IOException e) { e.printStackTrace(); } } } return Result.error("文件导入失败！"); } /*--------------------------------子表处理-出库申请单明细-end----------------------------------------------*/ }