package org.jeecg.modules.dry.controller; import java.math.BigDecimal; import java.util.Arrays; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.jeecg.common.api.vo.Result; import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.util.oConvertUtils; import org.jeecg.modules.dry.entity.DrySpareParts; import org.jeecg.modules.dry.entity.DrySpareStockLog; import org.jeecg.modules.dry.service.IDrySparePartsService; import org.jeecg.modules.dry.service.IDrySpareStockLogService; 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.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.jeecg.common.system.base.controller.JeecgController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import org.springframework.web.servlet.ModelAndView; import com.alibaba.fastjson.JSON; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.jeecg.common.aspect.annotation.AutoLog; import org.apache.shiro.authz.annotation.RequiresPermissions; import java.time.LocalDate; import java.time.format.DateTimeFormatter; import java.util.concurrent.atomic.AtomicInteger; /** * @Description: 出入库记录表 * @Author: jeecg-boot * @Date: 2025-07-23 * @Version: V1.0 */ @Api(tags="出入库记录表") @RestController @RequestMapping("/dry/drySpareStockLog") @Slf4j public class DrySpareStockLogController extends JeecgController { @Autowired private IDrySpareStockLogService drySpareStockLogService; @Autowired private IDrySparePartsService drySparePartsService; private static final AtomicInteger dailySequence = new AtomicInteger(0); private static LocalDate lastResetDate = null; /** * 分页列表查询 * * @param drySpareStockLog * @param pageNo * @param pageSize * @param req * @return */ //@AutoLog(value = "出入库记录表-分页列表查询") @ApiOperation(value="出入库记录表-分页列表查询", notes="出入库记录表-分页列表查询") @GetMapping(value = "/list") public Result> queryPageList(DrySpareStockLog drySpareStockLog, @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, HttpServletRequest req) { QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(drySpareStockLog, req.getParameterMap()); Page page = new Page(pageNo, pageSize); IPage pageList = drySpareStockLogService.page(page, queryWrapper); return Result.OK(pageList); } /** * 添加 * * @param drySpareStockLog * @return */ @AutoLog(value = "出入库记录表-添加") @ApiOperation(value="出入库记录表-添加", notes="出入库记录表-添加") @RequiresPermissions("dry:dry_spare_stock_log:add") @PostMapping(value = "/add") @Transactional public Result add(@RequestBody DrySpareStockLog drySpareStockLog) { String partNumber = drySpareStockLog.getPartNumber(); BigDecimal quantity = drySpareStockLog.getQuantity(); String operationType = drySpareStockLog.getOperationType(); if (partNumber == null || quantity == null || quantity.compareTo(BigDecimal.ZERO) <= 0 || operationType == null) { return Result.error("备件编号、数量或操作类型不能为空且数量必须大于0!"); } QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("part_number", partNumber); DrySpareParts drySpareParts = drySparePartsService.getOne(queryWrapper); if (drySpareParts == null) { return Result.error("未找到对应备件!"); } if ("0".equals(operationType)) { // 入库 drySpareParts.setCurrentStock(drySpareParts.getCurrentStock().add(quantity)); } else if ("1".equals(operationType)) { // 出库 if (drySpareParts.getCurrentStock().compareTo(quantity) < 0) { return Result.error("库存不足!"); } drySpareParts.setCurrentStock(drySpareParts.getCurrentStock().subtract(quantity)); } else { return Result.error("无效的操作类型!"); } drySparePartsService.updateById(drySpareParts); drySpareStockLogService.save(drySpareStockLog); return Result.OK("添加成功!"); } /** * 编辑 * * @param drySpareStockLog * @return */ // @AutoLog(value = "出入库记录表-编辑") // @ApiOperation(value="出入库记录表-编辑", notes="出入库记录表-编辑") // @RequiresPermissions("dry:dry_spare_stock_log:edit") // @RequestMapping(value = "/edit", method = {RequestMethod.PUT,RequestMethod.POST}) // public Result edit(@RequestBody DrySpareStockLog drySpareStockLog) { // drySpareStockLogService.updateById(drySpareStockLog); // return Result.OK("编辑成功!"); // } /** * 通过id删除 * * @param id * @return */ @AutoLog(value = "出入库记录表-通过id删除") @ApiOperation(value="出入库记录表-通过id删除", notes="出入库记录表-通过id删除") @RequiresPermissions("dry:dry_spare_stock_log:delete") @DeleteMapping(value = "/delete") public Result delete(@RequestParam(name="id",required=true) String id) { drySpareStockLogService.removeById(id); return Result.OK("删除成功!"); } /** * 批量删除 * * @param ids * @return */ @AutoLog(value = "出入库记录表-批量删除") @ApiOperation(value="出入库记录表-批量删除", notes="出入库记录表-批量删除") @RequiresPermissions("dry:dry_spare_stock_log:deleteBatch") @DeleteMapping(value = "/deleteBatch") public Result deleteBatch(@RequestParam(name="ids",required=true) String ids) { this.drySpareStockLogService.removeByIds(Arrays.asList(ids.split(","))); return Result.OK("批量删除成功!"); } /** * 通过id查询 * * @param id * @return */ //@AutoLog(value = "出入库记录表-通过id查询") @ApiOperation(value="出入库记录表-通过id查询", notes="出入库记录表-通过id查询") @GetMapping(value = "/queryById") public Result queryById(@RequestParam(name="id",required=true) String id) { DrySpareStockLog drySpareStockLog = drySpareStockLogService.getById(id); if(drySpareStockLog==null) { return Result.error("未找到对应数据"); } return Result.OK(drySpareStockLog); } /** * 导出excel * * @param request * @param drySpareStockLog */ @RequiresPermissions("dry:dry_spare_stock_log:exportXls") @RequestMapping(value = "/exportXls") public ModelAndView exportXls(HttpServletRequest request, DrySpareStockLog drySpareStockLog) { return super.exportXls(request, drySpareStockLog, DrySpareStockLog.class, "出入库记录表"); } /** * 通过excel导入数据 * * @param request * @param response * @return */ @RequiresPermissions("dry:dry_spare_stock_log:importExcel") @RequestMapping(value = "/importExcel", method = RequestMethod.POST) public Result importExcel(HttpServletRequest request, HttpServletResponse response) { return super.importExcel(request, response, DrySpareStockLog.class); } /** * 生成出入库单号 * * @param type 单号类型,CK(出库)或 RK(入库) * @return */ @AutoLog(value = "出入库记录表-生成出入库单号") @ApiOperation(value="出入库记录表-生成出入库单号", notes="出入库记录表-生成出入库单号") @GetMapping(value = "/generateStockNo") public Result generateStockNo(@RequestParam(name="type",required=true) String type) { LocalDate today = LocalDate.now(); if (lastResetDate == null || !today.equals(lastResetDate)) { dailySequence.set(0); lastResetDate = today; } // 获取并递增序列号 int sequence = dailySequence.incrementAndGet(); // 格式化日期 String dateStr = today.format(DateTimeFormatter.ofPattern("yyyyMMdd")); // 格式化序列号为三位,不足补零 String sequenceStr = String.format("%03d", sequence); // 组合生成维修单号 String stockNo = type + dateStr + sequenceStr; return Result.OK(stockNo); } }