diff --git a/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/Inventory.java b/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/Inventory.java index 3e5e632..5ae2df5 100644 --- a/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/Inventory.java +++ b/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/Inventory.java @@ -38,4 +38,5 @@ public class Inventory { private String materiel_group_text;//"线缆" @ApiModelProperty("最后更新时间明文") private String update_time_text;//"2023-05-22 10:45:25" + private String time; } diff --git a/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryQuery.java b/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryQuery.java index 9dcb769..34780df 100644 --- a/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryQuery.java +++ b/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryQuery.java @@ -11,4 +11,5 @@ import lombok.Data; @Data @ApiModel(value = "库存列表 分页查询字段") public class InventoryQuery implements Query { + private String storehouse_name; } diff --git a/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryVo.java b/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryVo.java index 556a5fe..6420c8d 100644 --- a/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryVo.java +++ b/yxt-supervise-gf-api/src/main/java/com/yxt/supervise/gf/api/inventory/InventoryVo.java @@ -36,4 +36,5 @@ public class InventoryVo { private String materiel_group_text;//"线缆" @ApiModelProperty("最后更新时间明文") private String update_time_text;//"2023-05-22 10:45:25" + private String time; } diff --git a/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryMapper.java b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryMapper.java new file mode 100644 index 0000000..0fa0caf --- /dev/null +++ b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryMapper.java @@ -0,0 +1,25 @@ +package com.yxt.supervise.gf.biz.inventory; + +import com.baomidou.mybatisplus.core.conditions.Wrapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.Constants; +import com.yxt.supervise.gf.api.inventory.Inventory; +import com.yxt.supervise.gf.api.inventory.InventoryVo; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; + +import java.util.List; + +/** + * @author feikefei + * @create 2023-07-12-15:43 + */ +@Mapper +public interface InventoryMapper extends BaseMapper { + IPage selectPageVo(IPage page, @Param(Constants.WRAPPER) Wrapper qw); + + @Select("select * from inventory where storehouse_name = #{storehouse_name}") + List selectInventoryByStorehouseName(@Param("storehouse_name") String storehouse_name); +} diff --git a/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryMapper.xml b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryMapper.xml new file mode 100644 index 0000000..fef043d --- /dev/null +++ b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryMapper.xml @@ -0,0 +1,14 @@ + + + + + + \ No newline at end of file diff --git a/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryRest.java b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryRest.java new file mode 100644 index 0000000..eca86d1 --- /dev/null +++ b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryRest.java @@ -0,0 +1,47 @@ +package com.yxt.supervise.gf.biz.inventory; + +import com.yxt.common.core.query.PagerQuery; +import com.yxt.common.core.result.ResultBean; +import com.yxt.common.core.vo.PagerVo; +import com.yxt.supervise.gf.api.inventory.InventoryQuery; +import com.yxt.supervise.gf.api.inventory.InventoryVo; +import com.yxt.supervise.gf.shanhai.req.InventoryIndex; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import javax.servlet.http.HttpServletResponse; + +/** + * @author feikefei + * @create 2023-07-12-15:42 + */ +@Api(value = "货物库存明细表") +@RestController +@RequestMapping("gf/inventory") +public class InventoryRest { + + @Autowired + private InventoryService inventoryService; + + @PostMapping("/save") + @ApiOperation("添加入库数据") + public ResultBean save(@RequestBody InventoryIndex inventoryIndex){ + return inventoryService.save(inventoryIndex); + } + + @PostMapping("/listPage") + @ApiOperation("分页查询") + public ResultBean listPage(@RequestBody PagerQuery pq){ + ResultBean rb = ResultBean.fireFail(); + PagerVo pagerVo = inventoryService.listPage(pq); + return rb.success().setData(pagerVo); + } + + @PostMapping("/export/{storehouse_name}") + @ApiOperation("导出数据") + public void export(@PathVariable String storehouse_name, HttpServletResponse response) throws Exception{ + inventoryService.export(storehouse_name, response); + } +} diff --git a/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryService.java b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryService.java new file mode 100644 index 0000000..e3cbb3f --- /dev/null +++ b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/biz/inventory/InventoryService.java @@ -0,0 +1,253 @@ +package com.yxt.supervise.gf.biz.inventory; + +import cn.hutool.core.bean.BeanUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.yxt.common.base.utils.PagerUtil; +import com.yxt.common.core.query.PagerQuery; +import com.yxt.common.core.result.ResultBean; +import com.yxt.common.core.vo.PagerVo; +import com.yxt.supervise.gf.api.inventory.Inventory; +import com.yxt.supervise.gf.api.inventory.InventoryQuery; +import com.yxt.supervise.gf.api.inventory.InventoryVo; +import com.yxt.supervise.gf.shanhai.ShRequester; +import com.yxt.supervise.gf.shanhai.req.InventoryIndex; +import com.yxt.supervise.gf.shanhai.resp.BaseResponse; +import com.yxt.supervise.gf.shanhai.resp.BaseResponseListObj; +import org.apache.poi.ss.usermodel.*; +import org.apache.poi.ss.util.CellRangeAddress; +import org.apache.poi.xssf.usermodel.XSSFWorkbook; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Service; + +import javax.servlet.http.HttpServletResponse; +import java.io.File; +import java.io.FileOutputStream; +import java.io.OutputStream; +import java.net.URLEncoder; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.List; + +/** + * @author feikefei + * @create 2023-07-12-15:43 + */ +@Service +public class InventoryService extends ServiceImpl { + + @Value("${import.filePath}") + private String filePath; + @Autowired + private HttpServletResponse response; + + public ResultBean save(InventoryIndex inventoryIndex){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + Date date = new Date(); + ResultBean rb = ResultBean.fireFail(); + BaseResponse> api$system$inventory$index = ShRequester.getApi$system$inventory$index(inventoryIndex); + List list = api$system$inventory$index.getData().getList(); + try { + exportExcel(response,list); + }catch (Exception e){ + e.printStackTrace(); + } + for (com.yxt.supervise.gf.shanhai.resp.Inventory inventory : list) { + Inventory inventory1 = new Inventory(); + BeanUtil.copyProperties(inventory,inventory1); + inventory1.setTime(sdf.format(date)); + baseMapper.insert(inventory1); + } + return rb.success().setMsg("添加成功"); + } + + /** + * 添加到数据库数据时生成的表格 + * @param list 导出数据 + * @throws Exception + */ + public void exportExcel(HttpServletResponse response, List list) throws Exception { + SimpleDateFormat sdf1 = new SimpleDateFormat("yyyyMMddHHmmss"); + XSSFWorkbook wb = new XSSFWorkbook(); + //标题行抽出字段 + String[] head = {"序号","库存数量","仓库编码", "物料id", "物料编码", "物料组id", "物料品牌", "物料名称", "物料单价（成本价）", "最后更新时间", "物料组明文", "最后更新时间明文", "仓库名称"}; + + //设置sheet名称，并创建新的sheet对象 + Sheet stuSheet = wb.createSheet(); + //获取表头行 + Row titleRow = stuSheet.createRow(0); + //创建单元格，设置style居中，字体，单元格大小等 + CellStyle style = wb.createCellStyle(); + Cell cell = null; + //把已经写好的标题行写入excel文件中 + for (int i = 0; i < head.length; i++) { + cell = titleRow.createCell(i); + cell.setCellValue(head[i]); + cell.setCellStyle(style); + } + //把从数据库中取得的数据一一写入excel文件中 + Row row = null; + for (int i = 0; i < list.size(); i++) { + //创建list.size()行数据 + row = stuSheet.createRow(i + 1); + //把值一一写进单元格里 + //设置第一列为自动递增的序号 + row.createCell(0).setCellValue(i + 1); + row.createCell(1).setCellValue(list.get(i).getNum()); + row.createCell(2).setCellValue(list.get(i).getStorehouse_code()); + row.createCell(3).setCellValue(list.get(i).getMateriel_id()); + row.createCell(4).setCellValue(list.get(i).getMateriel_no()); + row.createCell(5).setCellValue(list.get(i).getMateriel_group()); + row.createCell(6).setCellValue(list.get(i).getBrand_name()); + row.createCell(7).setCellValue(list.get(i).getMateriel_name()); + row.createCell(8).setCellValue(list.get(i).getPrice()); + row.createCell(9).setCellValue(list.get(i).getUpdate_time()); + row.createCell(10).setCellValue(list.get(i).getMateriel_group_text()); + row.createCell(11).setCellValue(list.get(i).getUpdate_time_text()); + row.createCell(12).setCellValue(list.get(i).getStorehouse_name()); + } + //设置单元格宽度自适应，在此基础上把宽度调至1.5倍 + for (int i = 0; i < head.length; i++) { + stuSheet.autoSizeColumn(i, true); + stuSheet.setColumnWidth(i, stuSheet.getColumnWidth(i) * 15 / 10); + } + File file = new File(filePath); + if (!file.exists()) { + file.mkdirs(); + } + //设置文件名 + String fileName = sdf1.format(new Date()) + "库存记录" + ".xlsx"; + String savePath = filePath + File.separator + fileName; + //下载 + OutputStream fileOut = new FileOutputStream(savePath); + wb.write(fileOut); + fileOut.close(); + } + + public PagerVo listPage(PagerQuery pq){ + InventoryQuery params = pq.getParams(); + QueryWrapper wq = new QueryWrapper<>(); + if (params != null){ + if (params.getStorehouse_name() != null || !params.getStorehouse_name().equals("")) + wq.eq("storehouse_name",params.getStorehouse_name()); + } + IPage page = PagerUtil.queryToPage(pq); + IPage inventoryVoIPage = baseMapper.selectPageVo(page, wq); + PagerVo vo = PagerUtil.pageToVo(inventoryVoIPage, null); + return vo; + } + + public void export(String storehouse_name, HttpServletResponse response) throws Exception{ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + Date date = new Date(); + OutputStream out = response.getOutputStream(); + Workbook wb = new XSSFWorkbook(); + try { + response.setCharacterEncoding("UTF-8"); + response.setContentType("application/octet-stream; charset=utf-8"); + // 下载文件能正常显示中文 + response.setHeader( + "Content-Disposition", + "attachment;filename=" + URLEncoder.encode(storehouse_name + sdf.format(date)+".xlsx", "UTF-8"));//导出的Excel文件名称 +// response.setHeader("Access-Control-Expose-Headers", "FileName"); + List inventories = baseMapper.selectInventoryByStorehouseName(storehouse_name);//数据查询--需要导出的数据 + //行标题设置 + String[] headList = {"序号","仓库名称", "物料组", "物料编号", "物料名称", "物料品牌", "物料单价", "库存数量", "货值"}; + /*Excel文件创建完毕*/ + CreationHelper createHelper = wb.getCreationHelper(); //创建帮助工具 + /*创建表单*/ + Sheet sheet = wb.createSheet(storehouse_name != null ? storehouse_name : "Sheet"); + //设置字体 + Font headFont = wb.createFont(); + headFont.setFontHeightInPoints((short) 15); + headFont.setFontName("Courier New"); + headFont.setItalic(false); + headFont.setStrikeout(false); + //设置头部单元格样式 + CellStyle headStyle = wb.createCellStyle(); + headStyle.setAlignment(HorizontalAlignment.CENTER); //设置水平对齐方式 + headStyle.setVerticalAlignment(VerticalAlignment.CENTER); //设置垂直对齐方式 + headStyle.setShrinkToFit(true); //自动伸缩 + headStyle.setFont(headFont); //设置字体 + /*设置数据单元格格式*/ + CellStyle dataStyle = wb.createCellStyle(); + dataStyle.setVerticalAlignment(VerticalAlignment.CENTER); //设置垂直对齐方式 + dataStyle.setAlignment(HorizontalAlignment.CENTER); //设置水平对齐方式 + dataStyle.setShrinkToFit(true); //自动伸缩 + /*创建行Rows及单元格Cells*/ + Row headRow = sheet.createRow(0); //第一行为头 + Font head = wb.createFont(); + head.setFontHeightInPoints((short) 25); + CellStyle cellStyle = wb.createCellStyle(); + cellStyle.setFont(head); + cellStyle.setAlignment(HorizontalAlignment.CENTER); //设置水平对齐方式 + cellStyle.setVerticalAlignment(VerticalAlignment.CENTER); //设置垂直对齐方式 + CellRangeAddress callRangeAddress = new CellRangeAddress(0,0,0,headList.length-1); + Cell cell1 = headRow.createCell(0); + cell1.setCellStyle(cellStyle); + cell1.setCellValue(storehouse_name + "("+ sdf.format(date) +")"); + sheet.addMergedRegion(callRangeAddress); + Row headRow2 = sheet.createRow(1); + for (int i = 0; i < headList.length; i++) { //遍历表头数据 + Cell cell = headRow2.createCell(i); //创建单元格 + cell.setCellValue(createHelper.createRichTextString(headList[i])); //设置值 + cell.setCellStyle(headStyle); //设置样式 + } + int rowIndex = 2; //当前行索引 + int a = 1; + Double count = 0.0; + for (int j = 0; j < inventories.size(); j++) { //编译每一行 + Row row = sheet.createRow(rowIndex++); //第一行为头 + Cell cell = row.createCell(0); + cell.setCellStyle(dataStyle); + cell.setCellValue(createHelper.createRichTextString(String.valueOf(a++))); + cell = row.createCell(1); + cell.setCellValue(createHelper.createRichTextString(inventories.get(j) + .getStorehouse_name()==null?"":inventories.get(j).getStorehouse_name().toString())); + cell = row.createCell(2); + cell.setCellValue(createHelper.createRichTextString(inventories.get(j) + .getMateriel_group_text()==null?"":inventories.get(j).getMateriel_group_text().toString())); + cell = row.createCell(3); + cell.setCellValue(createHelper.createRichTextString(inventories.get(j) + .getMateriel_no()==null?"":inventories.get(j).getMateriel_no().toString())); + cell = row.createCell(4); + cell.setCellValue(createHelper.createRichTextString(inventories.get(j) + .getMateriel_name()==null?"":inventories.get(j).getMateriel_name().toString())); + cell = row.createCell(5); + cell.setCellValue(createHelper.createRichTextString(inventories.get(j) + .getBrand_name() == null?"":inventories.get(j).getBrand_name().toString())); + cell = row.createCell(6); + cell.setCellValue(createHelper.createRichTextString(inventories.get(j) + .getPrice()==null?"":inventories.get(j).getPrice().toString())); + cell = row.createCell(7); + cell.setCellValue(createHelper.createRichTextString(inventories.get(j) + .getNum()==null?"":inventories.get(j).getNum().toString())); + cell = row.createCell(8); + Double v = inventories.get(j).getPrice() * inventories.get(j).getNum(); + count+=v; + cell.setCellValue(createHelper.createRichTextString(v == null ? "":v.toString())); + } + + //创建合计 + Row row = sheet.createRow(inventories.size()+2); + Cell cell = row.createCell(0); + cell.setCellStyle(dataStyle); + cell.setCellValue(createHelper.createRichTextString("合计")); + cell = row.createCell(8); + cell.setCellValue(createHelper.createRichTextString(String.valueOf(count))); + /*创建rows和cells完毕*/ + /*设置列自动对齐*/ + for (int i = 0; i < headList.length; i++) { + sheet.autoSizeColumn(i); + } + wb.write(out); //将workbook写入文件流 + }catch (Exception e){ + e.printStackTrace(); + }finally { + wb.close(); + out.close(); + } + } +} diff --git a/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/shanhai/timedtask/ShanHaiTimedTask.java b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/shanhai/timedtask/ShanHaiTimedTask.java new file mode 100644 index 0000000..36cd1a2 --- /dev/null +++ b/yxt-supervise-gf-biz/src/main/java/com/yxt/supervise/gf/shanhai/timedtask/ShanHaiTimedTask.java @@ -0,0 +1,28 @@ +package com.yxt.supervise.gf.shanhai.timedtask; + +import com.yxt.common.core.result.ResultBean; +import com.yxt.supervise.gf.biz.inventory.InventoryService; +import com.yxt.supervise.gf.shanhai.req.InventoryIndex; +import io.swagger.annotations.ApiModel; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +/** + * @author feikefei + * @create 2023-07-13-11:44 + */ +@ApiModel(value = "定时查询第三方库存管理数据并添加到本地库") +@Component +public class ShanHaiTimedTask { + + @Autowired + private InventoryService inventoryService; + +// @Scheduled(cron = "0 0 3 * * ?") + public void timedTask(){ + InventoryIndex inventoryIndex = new InventoryIndex(); + inventoryService.save(inventoryIndex); + } +} diff --git a/yxt-supervise-gf-biz/src/main/resources/application-devv.yml b/yxt-supervise-gf-biz/src/main/resources/application-devv.yml index 4788493..c687783 100644 --- a/yxt-supervise-gf-biz/src/main/resources/application-devv.yml +++ b/yxt-supervise-gf-biz/src/main/resources/application-devv.yml @@ -28,4 +28,6 @@ image: path: D:\supervise\upload\ url: prefix: http://127.0.0.1:8112/upload/ +import: + filePath: E:/yxt-supervise-gf/upload/