基于Java的品达物流TMS运输管理系统设计源码

package com.itheima.pinda.controller; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.itheima.pinda.DTO.transportline.TransportLineDto; import com.itheima.pinda.DTO.transportline.TransportLineTypeDto; import com.itheima.pinda.DTO.transportline.TransportTripsDto; import com.itheima.pinda.DTO.transportline.TransportTripsTruckDriverDto; import com.itheima.pinda.authority.api.OrgApi; import com.itheima.pinda.authority.api.UserApi; import com.itheima.pinda.authority.entity.auth.User; import com.itheima.pinda.authority.entity.core.Org; import com.itheima.pinda.authority.enumeration.common.StaticStation; import com.itheima.pinda.authority.enumeration.core.OrgType; import com.itheima.pinda.base.R; import com.itheima.pinda.common.utils.Constant; import com.itheima.pinda.common.utils.PageResponse; import com.itheima.pinda.common.utils.Result; import com.itheima.pinda.DTO.angency.FleetDto; import com.itheima.pinda.DTO.base.GoodsTypeDto; import com.itheima.pinda.DTO.truck.TruckDto; import com.itheima.pinda.DTO.truck.TruckLicenseDto; import com.itheima.pinda.DTO.truck.TruckTypeDto; import com.itheima.pinda.DTO.user.TruckDriverDto; import com.itheima.pinda.DTO.user.TruckDriverLicenseDto; import com.itheima.pinda.feign.agency.FleetFeign; import com.itheima.pinda.feign.common.GoodsTypeFeign; import com.itheima.pinda.feign.transportline.TransportLineFeign; import com.itheima.pinda.feign.transportline.TransportLineTypeFeign; import com.itheima.pinda.feign.transportline.TransportTripsFeign; import com.itheima.pinda.feign.truck.TruckFeign; import com.itheima.pinda.feign.truck.TruckLicenseFeign; import com.itheima.pinda.feign.truck.TruckTypeFeign; import com.itheima.pinda.feign.user.DriverFeign; import com.itheima.pinda.future.PdCompletableFuture; import com.itheima.pinda.util.BeanUtil; import com.itheima.pinda.vo.base.angency.AgencySimpleVo; import com.itheima.pinda.vo.base.angency.AgencyVo; import com.itheima.pinda.vo.base.businessHall.GoodsTypeVo; import com.itheima.pinda.vo.base.transforCenter.business.*; import com.itheima.pinda.vo.base.userCenter.SysUserVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import lombok.extern.java.Log; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; import java.time.LocalDate; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.stream.Collectors; /** * 转运中心管理-业务信息管理 */ @RestController @RequestMapping("transfor-center/bussiness") @Api(tags = "转运中心管理-业务信息管理") @Log public class TransforCenterBusinessController { @Autowired private TruckTypeFeign truckTypeFeign; @Autowired private GoodsTypeFeign goodsTypeFeign; @Autowired private TransportLineTypeFeign transportLineTypeFeign; @Autowired private FleetFeign fleetFeign; @Autowired private OrgApi orgApi; @Autowired private TruckFeign truckFeign; @Autowired private TruckLicenseFeign truckLicenseFeign; @Autowired private TransportLineFeign transportLineFeign; @Autowired private TransportTripsFeign transportTripsFeign; @Autowired private UserApi userApi; @Autowired private DriverFeign driverFeign; @ApiOperation(value = "添加车辆类型") @PostMapping("/truckType") public TruckTypeVo saveTruckType(@RequestBody TruckTypeVo vo) { TruckTypeDto dto = new TruckTypeDto(); BeanUtils.copyProperties(vo, dto); if (vo.getGoodsTypes() != null) { dto.setGoodsTypeIds(vo.getGoodsTypes().stream().map(goodsTypeVo -> goodsTypeVo.getId()).collect(Collectors.toList())); } TruckTypeDto resultDto = truckTypeFeign.saveTruckType(dto); BeanUtils.copyProperties(resultDto, vo); return vo; } @ApiOperation(value = "更新车辆类型") @ApiImplicitParams({ @ApiImplicitParam(name = "id", value = "车辆类型id", required = true, example = "1", paramType = "{path}") }) @PutMapping("/truckType/{id}") public TruckTypeVo updateTruckType(@PathVariable(name = "id") String id, @RequestBody TruckTypeVo vo) { vo.setId(id); TruckTypeDto dto = new TruckTypeDto(); BeanUtils.copyProperties(vo, dto); if (vo.getGoodsTypes() != null) { dto.setGoodsTypeIds(vo.getGoodsTypes().stream().map(goodsTypeVo -> goodsTypeVo.getId()).collect(Collectors.toList())); } TruckTypeDto resultDto = truckTypeFeign.update(id, dto); BeanUtils.copyProperties(resultDto, vo); return vo; } @ApiOperation(value = "获取车辆类型分页数据") @ApiImplicitParams({ @ApiImplicitParam(name = "page", value = "页码", required = true, example = "1"), @ApiImplicitParam(name = "pageSize", value = "页尺寸", required = true, example = "10"), @ApiImplicitParam(name = "name", value = "车辆类型名称"), @ApiImplicitParam(name = "allowableLoad", value = "车型载重"), @ApiImplicitParam(name = "allowableVolume", value = "车型体积") }) @GetMapping("/truckType/page") public PageResponse<TruckTypeVo> findTruckTypeByPage(@RequestParam(name = "page") Integer page, @RequestParam(name = "pageSize") Integer pageSize, @RequestParam(name = "name", required = false) String name, @RequestParam(name = "allowableLoad", required = false) BigDecimal allowableLoad, @RequestParam(name = "allowableVolume", required = false) BigDecimal allowableVolume) { // TODO: 2020/1/8 载重与体积查询条件，是否使用基于该值的上下区间浮动查询 PageResponse<TruckTypeDto> truckTypeDtoPage = truckTypeFeign.findByPage(page, pageSize, name, allowableLoad, allowableVolume); Set<String> goodsTypeSet = new HashSet<>(); List<TruckTypeDto> truckTypeDtoList = truckTypeDtoPage.getItems(); truckTypeDtoList.forEach(dto -> { if (dto.getGoodsTypeIds() != null) { goodsTypeSet.addAll(dto.getGoodsTypeIds()); } }); //处理货物类型数据 CompletableFuture<Map> goodsTypeFuture = null; if (goodsTypeSet.size() > 0) { goodsTypeFuture = PdCompletableFuture.goodsTypeMapFuture(goodsTypeFeign, goodsTypeSet); CompletableFuture.allOf(goodsTypeFuture).join(); } CompletableFuture<Map> finalGoodsTypeFuture = goodsTypeFuture; List<TruckTypeVo> truckTypeVoList = truckTypeDtoList.stream().map(dto -> { TruckTypeVo vo = new TruckTypeVo(); BeanUtils.copyProperties(dto, vo); try { if (dto.getGoodsTypeIds() != null) { List<GoodsTypeVo> goodsTypeVoList = new ArrayList<>(); for (String goodsTypeId : dto.getGoodsTypeIds()) { goodsTypeVoList.add(finalGoodsTypeFuture == null ? null : (GoodsTypeVo) finalGoodsTypeFuture.get().get(goodsTypeId)); } vo.setGoodsTypes(goodsTypeVoList); } } catch (Exception e) { // TODO: 2020/1/2 此处异常处理依赖于业务是否为弱关系，如强关系，则返回错误 e.printStackTrace(); } return vo; }).collect(Collectors.toList()); return PageResponse.<TruckTypeVo>builder().items(truckTypeVoList).page(page).pagesize(page