package com.vincent.rsf.server.manager.controller; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.vincent.rsf.framework.common.Cools; import com.vincent.rsf.framework.common.R; import com.vincent.rsf.framework.exception.CoolException; import com.vincent.rsf.server.common.exception.BusinessException; import com.vincent.rsf.server.common.utils.ExcelUtil; import com.vincent.rsf.server.common.annotation.OperationLog; import com.vincent.rsf.server.common.domain.BaseParam; import com.vincent.rsf.server.common.domain.KeyValVo; import com.vincent.rsf.server.common.domain.PageParam; import com.vincent.rsf.server.manager.entity.Delivery; import com.vincent.rsf.server.manager.entity.DeliveryItem; import com.vincent.rsf.server.manager.entity.excel.DeliveryTemplate; import com.vincent.rsf.server.manager.enums.AsnExceStatus; import com.vincent.rsf.server.manager.enums.OrderType; import com.vincent.rsf.server.manager.enums.OrderWorkType; import com.vincent.rsf.server.manager.service.CompanysService; import com.vincent.rsf.server.manager.service.DeliveryItemService; import com.vincent.rsf.server.manager.service.DeliveryService; import com.vincent.rsf.server.system.constant.SerialRuleCode; import com.vincent.rsf.server.system.controller.BaseController; import com.vincent.rsf.server.system.service.SerialRuleService; import com.vincent.rsf.server.system.utils.SerialRuleUtils; import io.swagger.annotations.ApiOperation; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.util.*; @RestController public class DeliveryController extends BaseController { @Autowired private DeliveryService deliveryService; @Autowired private DeliveryItemService deliveryItemService; @PreAuthorize("hasAuthority('manager:delivery:list')") @PostMapping("/delivery/page") public R page(@RequestBody Map map) { BaseParam baseParam = buildParam(map, BaseParam.class); PageParam pageParam = new PageParam<>(baseParam, Delivery.class); return R.ok().add(deliveryService.page(pageParam, pageParam.buildWrapper(true))); } @PreAuthorize("hasAuthority('manager:delivery:list')") @PostMapping("/delivery/list") public R list(@RequestBody Map map) { return R.ok().add(deliveryService.list()); } @PreAuthorize("hasAuthority('manager:delivery:list')") @PostMapping({"/delivery/many/{ids}", "/deliverys/many/{ids}"}) public R many(@PathVariable Long[] ids) { return R.ok().add(deliveryService.listByIds(Arrays.asList(ids))); } @PreAuthorize("hasAuthority('manager:delivery:list')") @GetMapping("/delivery/{id}") public R get(@PathVariable("id") Long id) { return R.ok().add(deliveryService.getById(id)); } @PreAuthorize("hasAuthority('manager:delivery:save')") @OperationLog("Create 综合单据明细") @PostMapping("/delivery/save") public R save(@RequestBody Delivery delivery) { delivery.setCreateBy(getLoginUserId()); delivery.setUpdateBy(getLoginUserId()); if (Objects.isNull(delivery.getCode())) { String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_DELIVERY_RULE_CODE, delivery); if (Objects.isNull(ruleCode) || StringUtils.isBlank(ruleCode)) { return R.error("编码规则错误:编码「SYS_DELIVERY_RULE_CODE」是未设置成功!!"); } delivery.setCode(ruleCode); } if (!deliveryService.save(delivery)) { return R.error("Save Fail"); } return R.ok("Save Success").add(delivery); } @PreAuthorize("hasAuthority('manager:delivery:update')") @OperationLog("Update 综合单据明细") @PostMapping("/delivery/update") public R update(@RequestBody Delivery delivery) { delivery.setUpdateBy(getLoginUserId()); delivery.setUpdateTime(new Date()); if (Objects.isNull(delivery.getCode()) || StringUtils.isBlank(delivery.getCode())) { String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_DELIVERY_RULE_CODE, delivery); if (Objects.isNull(ruleCode) || StringUtils.isBlank(ruleCode)) { return R.error("编码规则错误:编码「SYS_DELIVERY_RULE_CODE」是未设置成功!!"); } delivery.setCode(ruleCode); } if (!deliveryService.updateById(delivery)) { return R.error("Update Fail"); } return R.ok("Update Success").add(delivery); } @PreAuthorize("hasAuthority('manager:delivery:remove')") @OperationLog("Delete 综合单据明细") @PostMapping("/delivery/remove/{ids}") public R remove(@PathVariable Long[] ids) { List list = Arrays.asList(ids); if (list.isEmpty()) { return R.error("参数不能为空!!"); } return R.ok("操作成功").add(deliveryService.removeDo(list)); } @PreAuthorize("hasAuthority('manager:delivery:list')") @PostMapping("/delivery/query") public R query(@RequestParam(required = false) String condition) { List vos = new ArrayList<>(); LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); if (!Cools.isEmpty(condition)) { wrapper.like(Delivery::getId, condition); } deliveryService.page(new Page<>(1, 30), wrapper).getRecords().forEach( item -> vos.add(new KeyValVo(item.getId(), item.getId())) ); return R.ok().add(vos); } @PreAuthorize("hasAuthority('manager:delivery:list')") @PostMapping("/delivery/export") public void export(@RequestBody Map map, HttpServletResponse response) throws Exception { if (!Cools.isEmpty(map) && !Cools.isEmpty(map.get("ids"))) { throw new CoolException("参数不能为空!!"); } List orders = new ArrayList<>(); if (!Objects.isNull(map.get("ids"))) { List ids = JSONArray.parseArray(JSONObject.toJSONString(map.get("ids")), Long.class); if (!ids.isEmpty()) { orders = deliveryService.list(new LambdaQueryWrapper().in(Delivery::getId, ids)); } else { orders = deliveryService.list(new LambdaQueryWrapper<>()); } } else { orders = deliveryService.list(); } List orderTemplates = new ArrayList<>(); for (Delivery order : orders) { List orderItems = deliveryItemService.list(new LambdaQueryWrapper().eq(DeliveryItem::getDeliveryId, order.getId())); for (DeliveryItem item : orderItems) { if (Objects.isNull(item)) { continue; } DeliveryTemplate template = new DeliveryTemplate(); template.setDoCode(order.getCode()) .setType(OrderType.getValType(order.getType())) .setWkType(OrderWorkType.getWorkDesc(order.getWkType())) .setAnfme(item.getAnfme() + "") .setMaktx(item.getMaktx()) .setMemo(item.getMemo()) .setMatnrCode(item.getMatnrCode()) .setPlatItemId(item.getPlatItemId()) .setSplrBatch(item.getSplrBatch()) .setSplrName(item.getSplrName()) .setSplrCode(item.getSplrCode()); orderTemplates.add(template); } } ExcelUtil.build(ExcelUtil.create(orderTemplates, DeliveryTemplate.class), response); } @PostMapping("/delivery/import") @ApiOperation("DO单导入接口") @PreAuthorize("hasAuthority('manager:delivery:update')") public R importExcel(@RequestParam(value = "file") MultipartFile file) throws Exception { if (Objects.isNull(file)) { return R.error("文件不能为空!!"); } Map hashMap = new HashMap<>(); return R.ok("导入成功").add(deliveryItemService.excelImport(file, hashMap, getLoginUserId())); } /** * @author Ryan * @description 下载模板 * @param * @return * @time 2025/4/18 08:17 */ @PostMapping("/delivery/template/download") @ApiOperation("下载收货单模板") @PreAuthorize("hasAuthority('manager:delivery:update')") public void downloadTemplate(@RequestBody Map map, HttpServletResponse response) throws Exception { DeliveryTemplate template = ExcelUtil.mockData(DeliveryTemplate.class); List list = Arrays.asList(template); ExcelUtil.build(ExcelUtil.create(list, DeliveryTemplate.class, true), response); } }