| | |
| | | import com.ruoyi.framework.web.domain.AjaxResult; |
| | | import com.ruoyi.framework.web.page.TableDataInfo; |
| | | import com.ruoyi.purchase.dto.PurchaseLedgerDto; |
| | | import com.ruoyi.purchase.mapper.PurchaseLedgerTemplateMapper; |
| | | import com.ruoyi.purchase.mapper.SalesLedgerProductTemplateMapper; |
| | | import com.ruoyi.purchase.pojo.PurchaseLedger; |
| | | import com.ruoyi.purchase.pojo.PurchaseLedgerTemplate; |
| | | import com.ruoyi.purchase.pojo.SalesLedgerProductTemplate; |
| | | import com.ruoyi.purchase.service.IPurchaseLedgerService; |
| | | import com.ruoyi.sales.pojo.SalesLedgerProduct; |
| | | import com.ruoyi.sales.service.ISalesLedgerProductService; |
| | | import com.ruoyi.sales.service.ISalesLedgerService; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import io.swagger.annotations.ApiParam; |
| | | import lombok.AllArgsConstructor; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.FileNotFoundException; |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.io.OutputStream; |
| | | import java.math.BigDecimal; |
| | | import java.net.URLEncoder; |
| | | import java.util.List; |
| | | import java.util.Optional; |
| | | import java.util.stream.Collectors; |
| | |
| | | @RestController |
| | | @RequestMapping("/purchase/ledger") |
| | | @AllArgsConstructor |
| | | @Api(tags = "111") |
| | | @Api(tags = "采购台账") |
| | | @Slf4j |
| | | public class PurchaseLedgerController extends BaseController { |
| | | private IPurchaseLedgerService purchaseLedgerService; |
| | | |
| | | private ISalesLedgerService salesLedgerService; |
| | | private ISalesLedgerProductService salesLedgerProductService; |
| | | |
| | | private PurchaseLedgerTemplateMapper purchaseLedgerTemplateMapper; |
| | | |
| | | private SalesLedgerProductTemplateMapper salesLedgerProductTemplateMapper; |
| | | |
| | | |
| | | /** |
| | | * 导入采购台账 |
| | | */ |
| | | @Log(title = "导入采购台账", businessType = BusinessType.INSERT) |
| | | @PostMapping("/import") |
| | | @ApiOperation("导入采购台账") |
| | | public AjaxResult importData(@RequestParam("file") |
| | | @ApiParam(value = "Excel文件", required = true) |
| | | MultipartFile file) { |
| | | return purchaseLedgerService.importData(file); |
| | | } |
| | | |
| | | @ApiOperation("导出采购台账模板") |
| | | @PostMapping("/exportTemplate") |
| | | public void exportTemplate(HttpServletResponse response) { |
| | | // 1. 模板文件在resources/static下的路径 |
| | | String templatePath = "static/采购台账导入模板.xlsx"; |
| | | |
| | | // 2. 获取模板文件的输入流 |
| | | try (InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream(templatePath)) { |
| | | if (inputStream == null) { |
| | | throw new FileNotFoundException("模板文件不存在:" + templatePath); |
| | | } |
| | | |
| | | // 3. 设置响应头,触发浏览器下载 |
| | | response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"); |
| | | response.setCharacterEncoding("utf-8"); |
| | | String fileName = URLEncoder.encode("采购台账导入模板.xlsx", "utf-8").replaceAll("\\+", "%20"); |
| | | response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName); |
| | | |
| | | // 4. 将模板文件写入响应输出流 |
| | | try (OutputStream outputStream = response.getOutputStream()) { |
| | | byte[] buffer = new byte[1024]; |
| | | int len; |
| | | while ((len = inputStream.read(buffer)) > 0) { |
| | | outputStream.write(buffer, 0, len); |
| | | } |
| | | outputStream.flush(); |
| | | } |
| | | } catch (IOException e) { |
| | | log.error("导出销售台账模板失败", e); |
| | | // 若模板文件读取失败,返回错误提示 |
| | | try { |
| | | response.getWriter().write("模板导出失败:" + e.getMessage()); |
| | | } catch (IOException ex) { |
| | | log.error("响应输出错误", ex); |
| | | } |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 查询采购台账列表 |
| | |
| | | */ |
| | | @Log(title = "采购台账", businessType = BusinessType.INSERT) |
| | | @PostMapping("/addOrEditPurchase") |
| | | public AjaxResult addOrEditPurchase(@RequestBody PurchaseLedgerDto purchaseLedgerDto) throws IOException { |
| | | public AjaxResult addOrEditPurchase(@RequestBody PurchaseLedgerDto purchaseLedgerDto) throws Exception { |
| | | return toAjax(purchaseLedgerService.addOrEditPurchase(purchaseLedgerDto)); |
| | | } |
| | | /** |
| | | * 新增采购模板 |
| | | */ |
| | | @PostMapping("/addPurchaseTemplate") |
| | | public AjaxResult addPurchaseTemplate(@RequestBody PurchaseLedgerDto purchaseLedgerDto) throws IOException { |
| | | return toAjax(purchaseLedgerService.addPurchaseTemplate(purchaseLedgerDto)); |
| | | } |
| | | |
| | | /** |
| | | * 查询采购模板 |
| | | */ |
| | | @ApiOperation("/2222") |
| | | @ApiOperation("/查询采购模板") |
| | | @GetMapping("/getPurchaseTemplateList") |
| | | public AjaxResult getPurchaseTemplateList() { |
| | | PurchaseLedgerDto purchaseLedgerDto = new PurchaseLedgerDto(); |
| | | purchaseLedgerDto.setApprovalStatus(3); |
| | | IPage<PurchaseLedgerDto> purchaseLedgerDtoIPage = purchaseLedgerService.selectPurchaseLedgerListPage(new Page(1, -1), purchaseLedgerDto); |
| | | List<PurchaseLedgerDto> purchaseLedgers = purchaseLedgerDtoIPage.getRecords(); |
| | | |
| | | List<PurchaseLedgerTemplate> purchaseLedgers = purchaseLedgerTemplateMapper.selectList(null); |
| | | purchaseLedgers.forEach(purchaseLedgerDto1 -> { |
| | | LambdaQueryWrapper<SalesLedgerProduct> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(SalesLedgerProduct::getSalesLedgerId, purchaseLedgerDto1.getId()) |
| | | .eq(SalesLedgerProduct::getType, 2); |
| | | List<SalesLedgerProduct> list = salesLedgerProductService.list(queryWrapper); |
| | | LambdaQueryWrapper<SalesLedgerProductTemplate> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(SalesLedgerProductTemplate::getSalesLedgerId, purchaseLedgerDto1.getId()) |
| | | .eq(SalesLedgerProductTemplate::getType, 2); |
| | | List<SalesLedgerProductTemplate> list = salesLedgerProductTemplateMapper.selectList(queryWrapper); |
| | | if (!list.isEmpty()) { |
| | | purchaseLedgerDto1.setProductData(list); |
| | | purchaseLedgerDto1.setProductList(list); |
| | | } |
| | | }); |
| | | return AjaxResult.success(purchaseLedgers); |
| | |
| | | */ |
| | | @GetMapping("/listPage") |
| | | public AjaxResult listPage(Page page, PurchaseLedgerDto purchaseLedger) { |
| | | IPage<PurchaseLedgerDto> purchaseLedgerDtoIPage = Optional.ofNullable( |
| | | purchaseLedgerService.selectPurchaseLedgerListPage(page, purchaseLedger) |
| | | ).orElse(new Page<>()); |
| | | |
| | | // 处理null |
| | | Optional.ofNullable(purchaseLedgerDtoIPage.getRecords()) |
| | | .filter(CollectionUtils::isNotEmpty) |
| | | .ifPresent(records -> { |
| | | // 过滤approvalStatus=3的记录 |
| | | records.removeIf(dto -> dto != null && dto.getApprovalStatus() == 3); |
| | | // 修正未收付款金额 |
| | | records.forEach(dto -> { |
| | | if (dto == null) return; |
| | | BigDecimal unReceiptAmt = Optional.ofNullable(dto.getUnReceiptPaymentAmount()).orElse(BigDecimal.ZERO); |
| | | if (unReceiptAmt.compareTo(BigDecimal.ZERO) == 0) { |
| | | dto.setUnReceiptPaymentAmount(Optional.ofNullable(dto.getContractAmount()).orElse(BigDecimal.ZERO)); |
| | | } |
| | | }); |
| | | }); |
| | | |
| | | return AjaxResult.success(purchaseLedgerDtoIPage); |
| | | return AjaxResult.success(purchaseLedgerService.selectPurchaseLedgerListPage(page, purchaseLedger)); |
| | | } |
| | | |
| | | @ApiOperation("生成采购序列号") |