| | |
|---|
| | | package com.consum.base.controller; |
|---|
| | | |
|---|
| | | import com.consum.base.BaseController; |
|---|
| | | import com.consum.base.pojo.BaseGoodsTemplateParam; |
|---|
| | | import com.consum.base.pojo.LWhFormOutputParam; |
|---|
| | | import com.consum.base.service.BaseCategoryServiceImpl; |
|---|
| | | import com.consum.base.service.LWhFormOutputServiceImpl; |
|---|
| | | import com.consum.model.po.BaseGoodsTemplate; |
|---|
| | | import com.consum.model.po.FinSysTenantUser; |
|---|
| | | import com.iplatform.model.po.S_user_core; |
|---|
| | | import com.walker.infrastructure.utils.StringUtils; |
|---|
| | | import com.walker.web.ResponseValue; |
|---|
| | | import java.io.InputStream; |
|---|
| | | import java.lang.reflect.Field; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.Optional; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import javax.servlet.http.HttpServletResponse; |
|---|
| | | |
|---|
| | | import org.apache.commons.compress.utils.Lists; |
|---|
| | | import org.apache.poi.hssf.usermodel.HSSFWorkbook; |
|---|
| | | import org.apache.poi.ss.usermodel.Workbook; |
|---|
| | | import org.springframework.beans.BeanUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.core.io.ClassPathResource; |
|---|
| | | import org.springframework.web.bind.annotation.GetMapping; |
|---|
| | | import org.springframework.web.bind.annotation.PostMapping; |
|---|
| | | import org.springframework.web.bind.annotation.RequestBody; |
|---|
| | | import org.springframework.web.bind.annotation.RequestMapping; |
|---|
| | | import org.springframework.web.bind.annotation.RestController; |
|---|
| | | |
|---|
| | | import com.consum.base.BaseController; |
|---|
| | | import com.consum.base.core.utils.CommonUtil; |
|---|
| | | import com.consum.base.core.utils.MapUtils; |
|---|
| | | import com.consum.base.core.utils.MapperUtil; |
|---|
| | | import com.consum.base.core.utils.PageUtil; |
|---|
| | | import com.consum.base.pojo.LWhFormOutputParam; |
|---|
| | | import com.consum.base.pojo.excel.OutputExcelTemplate; |
|---|
| | | import com.consum.base.pojo.query.LWhFormOutputQry; |
|---|
| | | import com.consum.base.pojo.response.FormOutputGoodsVO; |
|---|
| | | import com.consum.base.pojo.response.FormOutputVO; |
|---|
| | | import com.consum.base.pojo.response.GoodsModelVO; |
|---|
| | | import com.consum.base.pojo.response.GoodsTemplateCountVO; |
|---|
| | | import com.consum.base.pojo.response.LWhFormOutputExtendVO; |
|---|
| | | import com.consum.base.service.LWarehouseFlowService; |
|---|
| | | import com.consum.base.service.LWhFormOutputService; |
|---|
| | | import com.consum.base.service.LWhProcureModelService; |
|---|
| | | import com.consum.model.po.FinSysTenantUser; |
|---|
| | | import com.consum.model.po.LWhFormOutput; |
|---|
| | | import com.iplatform.model.po.S_user_core; |
|---|
| | | import com.walker.db.page.GenericPager; |
|---|
| | | import com.walker.infrastructure.utils.CollectionUtils; |
|---|
| | | import com.walker.infrastructure.utils.DateUtils; |
|---|
| | | import com.walker.web.ResponseValue; |
|---|
| | | |
|---|
| | | import cn.afterturn.easypoi.excel.ExcelExportUtil; |
|---|
| | | import cn.afterturn.easypoi.excel.entity.TemplateExportParams; |
|---|
| | | import cn.hutool.core.util.ReflectUtil; |
|---|
| | | import io.swagger.annotations.Api; |
|---|
| | | import io.swagger.annotations.ApiImplicitParam; |
|---|
| | | import io.swagger.annotations.ApiImplicitParams; |
|---|
| | | import io.swagger.annotations.ApiOperation; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Description 出库单 |
|---|
| | | * @Author 卢庆阳 |
|---|
| | | * @Date 2023/10/27 |
|---|
| | | */ |
|---|
| | | @Api(value = "出库单", tags = "出库单") |
|---|
| | | @RestController |
|---|
| | | @RequestMapping("/pc/l/wh/form/output") |
|---|
| | | public class LWhFormOutputController extends BaseController { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private LWhFormOutputServiceImpl lWhFormOutputService; |
|---|
| | | private LWhFormOutputService lWhFormOutputService; |
|---|
| | | @Autowired |
|---|
| | | private LWhProcureModelService lWhProcureModelService; |
|---|
| | | @Resource |
|---|
| | | private LWarehouseFlowService lWarehouseFlowService; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Description 新增出库单 |
|---|
| | | * @Author 卢庆阳 |
|---|
| | | * @Date 2023/10/27 |
|---|
| | | */ |
|---|
| | | @ApiOperation(value = "新增出库单", notes = "新增出库单") |
|---|
| | | @ApiImplicitParams({@ApiImplicitParam(name = "param", value = "出库单实体", dataType = "lWhFormOutputParam", |
|---|
| | | dataTypeClass = LWhFormOutputParam.class, paramType = "body")}) |
|---|
| | | @PostMapping("/add") |
|---|
| | | public ResponseValue add(@RequestBody LWhFormOutputParam param) { |
|---|
| | | public ResponseValue add() { |
|---|
| | | LWhFormOutputParam param = CommonUtil.getObjFromReqBody(LWhFormOutputParam.class); |
|---|
| | | S_user_core currentUser = this.getCurrentUser(); |
|---|
| | | if (currentUser == null) { |
|---|
| | | return ResponseValue.error("登录用户信息不存在"); |
|---|
| | | } |
|---|
| | | int result = this.lWhFormOutputService.add(param, currentUser,this.getSysInfo()); |
|---|
| | | if (result > 0) return ResponseValue.success(1); |
|---|
| | | int result = this.lWhFormOutputService.add(param, currentUser, this.getSysInfo()); |
|---|
| | | if (result > 0) { |
|---|
| | | return ResponseValue.success(1); |
|---|
| | | } |
|---|
| | | return ResponseValue.error("新增失败！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Description 列表查询 |
|---|
| | | */ |
|---|
| | | @ApiOperation(value = "列表查询", notes = "列表查询") |
|---|
| | | @ApiImplicitParam(name = "param", value = "出库单实体", required = true, dataType = "LWhFormOutputParam", |
|---|
| | | paramType = "query") |
|---|
| | | @GetMapping("/list") |
|---|
| | | public ResponseValue queryFormOutputList() { |
|---|
| | | LWhFormOutputQry param = CommonUtil.getObjFromReq(LWhFormOutputQry.class); |
|---|
| | | S_user_core currentUser = this.getCurrentUser(); |
|---|
| | | if (currentUser == null) { |
|---|
| | | return ResponseValue.error("登录用户信息不存在"); |
|---|
| | | } |
|---|
| | | /*当前登录人只能看到自己机构下的列表*/ |
|---|
| | | FinSysTenantUser sysInfo = this.getSysInfo(); |
|---|
| | | String tenantId = sysInfo.getTenantId(); |
|---|
| | | if (param.getAgencyId() == null) { |
|---|
| | | param.setAgencyId(Long.valueOf(tenantId)); |
|---|
| | | } |
|---|
| | | GenericPager genericPager = lWhFormOutputService.queryFormOutputList(param); |
|---|
| | | List<LWhFormOutput> data = genericPager.getDatas(); |
|---|
| | | |
|---|
| | | List<FormOutputVO> resultList = Lists.newArrayList(); |
|---|
| | | if (!CollectionUtils.isEmpty(data)) { |
|---|
| | | data.forEach(item -> { |
|---|
| | | FormOutputVO formOutputVO = new FormOutputVO(); |
|---|
| | | BeanUtils.copyProperties(item, formOutputVO); |
|---|
| | | |
|---|
| | | // 查询物品型号统计数量 |
|---|
| | | List<GoodsTemplateCountVO> goodsTemplateCount = |
|---|
| | | lWhProcureModelService.getGoodsTemplateCountByBusinessId(item.getId()); |
|---|
| | | formOutputVO.setFormOutputTemplateInfoList(goodsTemplateCount); |
|---|
| | | |
|---|
| | | resultList.add(formOutputVO); |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | try { |
|---|
| | | Field fieldDatas = GenericPager.class.getDeclaredField("datas"); |
|---|
| | | // fieldDatas.setAccessible(true); |
|---|
| | | // fieldDatas.set(genericPager, resultList); |
|---|
| | | ReflectUtil.setFieldValue(genericPager, fieldDatas, resultList); |
|---|
| | | } catch (Exception e) { |
|---|
| | | logger.error("查询出库单列表失败", e); |
|---|
| | | } |
|---|
| | | return ResponseValue.success(genericPager); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据id查询详情 |
|---|
| | | */ |
|---|
| | | @ApiOperation(value = "根据id查询详情", notes = "根据id查询详情") |
|---|
| | | @ApiImplicitParam(name = "id", value = "出库单id", required = true, dataType = "Long", paramType = "query") |
|---|
| | | @GetMapping("/detail") |
|---|
| | | public ResponseValue getById(Long id) throws IllegalAccessException { |
|---|
| | | if (id == null) { |
|---|
| | | return ResponseValue.error("出库单id为空"); |
|---|
| | | } |
|---|
| | | LWhFormOutput lWhFormOutput = lWhFormOutputService.get(new LWhFormOutput(id)); |
|---|
| | | LWhFormOutputExtendVO lWhFormOutputExtendVO = new LWhFormOutputExtendVO(); |
|---|
| | | BeanUtils.copyProperties(lWhFormOutput, lWhFormOutputExtendVO); |
|---|
| | | lWhFormOutputExtendVO.setDoc(lWhFormOutput.getOutputDoc()); |
|---|
| | | |
|---|
| | | String sql = "SELECT bgt.id, CATEGORY_ID, CATEGORY_NAME, GOODS_NAME " |
|---|
| | | + "FROM l_wh_procure_model pm LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID " |
|---|
| | | + "LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID " |
|---|
| | | + "WHERE pm.BUSINESS_ID =:id GROUP BY bgt.id "; |
|---|
| | | Map<String, Object> paramMap = new HashMap<>(); |
|---|
| | | paramMap.put("id", lWhFormOutputExtendVO.getId()); |
|---|
| | | List<Map<String, Object>> procureModelList = lWhFormOutputService.select(sql, paramMap, new MapperUtil()); |
|---|
| | | List<FormOutputGoodsVO> fromOutputGoods = Lists.newArrayList(); |
|---|
| | | for (Map<String, Object> map : procureModelList) { |
|---|
| | | FormOutputGoodsVO procureTemplateInfoVO = MapUtils.convertMapToObj(map, FormOutputGoodsVO.class); |
|---|
| | | |
|---|
| | | // 查询型号数量 |
|---|
| | | List<GoodsModelVO> goodsModelVOList = Lists.newArrayList(); |
|---|
| | | String sql2 = "SELECT pm.id,pm.BASE_GOODS_MODELS_NAME,bgm.UNIT,COUNTS,total_amount " |
|---|
| | | + "FROM l_wh_procure_model pm LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID " |
|---|
| | | + "LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID " + "WHERE pm.BUSINESS_ID =:id"; |
|---|
| | | List<Map<String, Object>> modelList = lWhFormOutputService.select(sql2, paramMap, new MapperUtil()); |
|---|
| | | modelList.forEach(item -> { |
|---|
| | | GoodsModelVO goodsModelVO = MapUtils.convertMapToObj(item, GoodsModelVO.class); |
|---|
| | | goodsModelVOList.add(goodsModelVO); |
|---|
| | | }); |
|---|
| | | procureTemplateInfoVO.setModels(goodsModelVOList); |
|---|
| | | fromOutputGoods.add(procureTemplateInfoVO); |
|---|
| | | } |
|---|
| | | lWhFormOutputExtendVO.setFromOutputGoods(fromOutputGoods); |
|---|
| | | |
|---|
| | | return ResponseValue.success("查询成功!", lWhFormOutputExtendVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "查询出库单详情明细", notes = "查询出库单详情明细") |
|---|
| | | @ApiImplicitParam(name = "formOutputQry", value = "出库单详情查询条件", required = true, dataType = "LWhFormOutputQry", |
|---|
| | | paramType = "query") |
|---|
| | | @GetMapping("/detail/list") |
|---|
| | | public ResponseValue queryFormOutputDetailList() { |
|---|
| | | LWhFormOutputQry formOutputQry = CommonUtil.getObjFromReq(LWhFormOutputQry.class); |
|---|
| | | S_user_core currentUser = this.getCurrentUser(); |
|---|
| | | if (currentUser == null) { |
|---|
| | | return ResponseValue.error("登录用户信息不存在"); |
|---|
| | | } |
|---|
| | | PageUtil genericPager = lWarehouseFlowService.queryAllBusinessFlow(formOutputQry); |
|---|
| | | return ResponseValue.success(genericPager); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "出库单导出", notes = "出库单导出") |
|---|
| | | @ApiImplicitParam(name = "id", value = "出库单id", required = true, dataType = "Long", paramType = "query") |
|---|
| | | @GetMapping("/list/export") |
|---|
| | | public void export(Long id, HttpServletResponse response) throws Exception { |
|---|
| | | FinSysTenantUser sysInfo = this.getSysInfo(); |
|---|
| | | if (sysInfo == null) { |
|---|
| | | throw new RuntimeException("登录用户信息不存在"); |
|---|
| | | } |
|---|
| | | ClassPathResource classPathResource = new ClassPathResource("import/出库单.xls"); |
|---|
| | | // 获取文件输入流 |
|---|
| | | InputStream inputStream = classPathResource.getInputStream(); |
|---|
| | | Workbook wb = new HSSFWorkbook(inputStream); |
|---|
| | | TemplateExportParams params = new TemplateExportParams(); |
|---|
| | | params.setTemplateWb(wb); |
|---|
| | | params.setHeadingStartRow(2); |
|---|
| | | |
|---|
| | | List<OutputExcelTemplate> exportList = lWhFormOutputService.getExportList(id); |
|---|
| | | |
|---|
| | | if (CollectionUtils.isEmpty(exportList)) { |
|---|
| | | throw new RuntimeException("数据为空"); |
|---|
| | | } |
|---|
| | | int countNum = |
|---|
| | | exportList.stream().filter(item -> item.getNum() != null).mapToInt(OutputExcelTemplate::getNum).sum(); |
|---|
| | | double totalAmount = exportList.stream().filter(item -> item.getTotalAmount() != null) |
|---|
| | | .mapToDouble(OutputExcelTemplate::getAmount).sum(); |
|---|
| | | Optional<OutputExcelTemplate> first = exportList.stream().findFirst(); |
|---|
| | | OutputExcelTemplate templateExcelExport = first.get(); |
|---|
| | | String businessFormCode = templateExcelExport.getBusinessFormCode(); |
|---|
| | | Long createTime = templateExcelExport.getCreateTime(); |
|---|
| | | String operatorName = templateExcelExport.getOperatorName(); |
|---|
| | | |
|---|
| | | Map<String, Object> map = new HashMap<>(); |
|---|
| | | map.put("code", businessFormCode); |
|---|
| | | map.put("date", DateUtils.toShowDate(createTime)); |
|---|
| | | map.put("name", operatorName); |
|---|
| | | map.put("countNum", countNum); |
|---|
| | | map.put("totalAmount", totalAmount); |
|---|
| | | |
|---|
| | | Workbook workbook = ExcelExportUtil.exportExcel(params, OutputExcelTemplate.class, exportList, map); |
|---|
| | | downLoadExcel("出库单", response, workbook); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
