|
@@ -0,0 +1,153 @@
|
|
|
+package com.yc.ship.module.product.controller.admin.pricevoyage;
|
|
|
+
|
|
|
+import com.yc.ship.framework.apilog.core.annotation.ApiAccessLog;
|
|
|
+import com.yc.ship.framework.common.pojo.CommonResult;
|
|
|
+import com.yc.ship.framework.common.pojo.PageParam;
|
|
|
+import com.yc.ship.framework.common.pojo.PageResult;
|
|
|
+import com.yc.ship.framework.common.util.collection.CollectionUtils;
|
|
|
+import com.yc.ship.framework.common.util.object.BeanUtils;
|
|
|
+import com.yc.ship.framework.excel.core.util.ExcelUtils;
|
|
|
+import com.yc.ship.module.product.controller.admin.pricetemplate.vo.PriceFloorRespVO;
|
|
|
+import com.yc.ship.module.product.controller.admin.pricetemplate.vo.PriceRoomModelRespVO;
|
|
|
+import com.yc.ship.module.product.controller.admin.pricetemplate.vo.PriceSingleSettingRespVO;
|
|
|
+import com.yc.ship.module.product.controller.admin.pricevoyage.vo.PriceVoyagePageReqVO;
|
|
|
+import com.yc.ship.module.product.controller.admin.pricevoyage.vo.PriceVoyageRespVO;
|
|
|
+import com.yc.ship.module.product.controller.admin.pricevoyage.vo.PriceVoyageSaveReqVO;
|
|
|
+import com.yc.ship.module.product.dal.dataobject.pricefloor.PriceFloorDO;
|
|
|
+import com.yc.ship.module.product.dal.dataobject.priceroommodel.PriceRoomModelDO;
|
|
|
+import com.yc.ship.module.product.dal.dataobject.pricesinglesetting.PriceSingleSettingDO;
|
|
|
+import com.yc.ship.module.product.dal.dataobject.pricevoyage.PriceVoyageDO;
|
|
|
+import com.yc.ship.module.product.dal.dataobject.voyage.VoyageDO;
|
|
|
+import com.yc.ship.module.product.service.pricefloor.PriceFloorService;
|
|
|
+import com.yc.ship.module.product.service.priceroommodel.PriceRoomModelService;
|
|
|
+import com.yc.ship.module.product.service.pricesinglesetting.PriceSingleSettingService;
|
|
|
+import com.yc.ship.module.product.service.pricevoyage.PriceVoyageService;
|
|
|
+import com.yc.ship.module.product.service.voyage.VoyageService;
|
|
|
+import com.yc.ship.module.resource.api.route.RouteApi;
|
|
|
+import com.yc.ship.module.resource.api.route.dto.RouteRespDTO;
|
|
|
+import com.yc.ship.module.resource.api.ship.ShipApi;
|
|
|
+import com.yc.ship.module.resource.api.ship.dto.ShipRespDTO;
|
|
|
+import com.yc.ship.module.resource.dal.dataobject.ship.ResourceShipDO;
|
|
|
+import io.swagger.v3.oas.annotations.Operation;
|
|
|
+import io.swagger.v3.oas.annotations.Parameter;
|
|
|
+import io.swagger.v3.oas.annotations.tags.Tag;
|
|
|
+import org.springframework.security.access.prepost.PreAuthorize;
|
|
|
+import org.springframework.validation.annotation.Validated;
|
|
|
+import org.springframework.web.bind.annotation.*;
|
|
|
+
|
|
|
+import javax.annotation.Resource;
|
|
|
+import javax.servlet.http.HttpServletResponse;
|
|
|
+import javax.validation.Valid;
|
|
|
+import java.io.IOException;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+
|
|
|
+import static com.yc.ship.framework.apilog.core.enums.OperateTypeEnum.EXPORT;
|
|
|
+import static com.yc.ship.framework.common.pojo.CommonResult.success;
|
|
|
+
|
|
|
+@Tag(name = "管理后台 - 航次价格")
|
|
|
+@RestController
|
|
|
+@RequestMapping("/product/price-voyage")
|
|
|
+@Validated
|
|
|
+public class PriceVoyageController {
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PriceVoyageService priceVoyageService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PriceRoomModelService priceRoomModelService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PriceFloorService priceFloorService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PriceSingleSettingService priceSingleSettingService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private VoyageService voyageService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private ShipApi shipApi;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private RouteApi routeApi;
|
|
|
+
|
|
|
+
|
|
|
+ @PostMapping("/create")
|
|
|
+ @Operation(summary = "创建航次价格")
|
|
|
+ @PreAuthorize("@ss.hasPermission('product:price-voyage:create')")
|
|
|
+ public CommonResult<Long> createPriceVoyage(@Valid @RequestBody PriceVoyageSaveReqVO createReqVO) {
|
|
|
+ return success(priceVoyageService.createPriceVoyage(createReqVO));
|
|
|
+ }
|
|
|
+
|
|
|
+ @PutMapping("/update")
|
|
|
+ @Operation(summary = "更新航次价格")
|
|
|
+ @PreAuthorize("@ss.hasPermission('product:price-voyage:update')")
|
|
|
+ public CommonResult<Boolean> updatePriceVoyage(@Valid @RequestBody PriceVoyageSaveReqVO updateReqVO) {
|
|
|
+ priceVoyageService.updatePriceVoyage(updateReqVO);
|
|
|
+ return success(true);
|
|
|
+ }
|
|
|
+
|
|
|
+ @DeleteMapping("/delete")
|
|
|
+ @Operation(summary = "删除航次价格")
|
|
|
+ @Parameter(name = "id", description = "编号", required = true)
|
|
|
+ @PreAuthorize("@ss.hasPermission('product:price-voyage:delete')")
|
|
|
+ public CommonResult<Boolean> deletePriceVoyage(@RequestParam("id") Long id) {
|
|
|
+ priceVoyageService.deletePriceVoyage(id);
|
|
|
+ return success(true);
|
|
|
+ }
|
|
|
+
|
|
|
+ @GetMapping("/get")
|
|
|
+ @Operation(summary = "获得航次价格")
|
|
|
+ @Parameter(name = "id", description = "编号", required = true, example = "1024")
|
|
|
+ @PreAuthorize("@ss.hasPermission('product:price-voyage:query')")
|
|
|
+ public CommonResult<PriceVoyageRespVO> getPriceVoyage(@RequestParam("id") Long id) {
|
|
|
+ PriceVoyageDO priceVoyage = priceVoyageService.getPriceVoyage(id);
|
|
|
+ PriceVoyageRespVO respVO = BeanUtils.toBean(priceVoyage, PriceVoyageRespVO.class);
|
|
|
+ PriceSingleSettingDO singleSettingDO = priceSingleSettingService.getByObjectId(id);
|
|
|
+ respVO.setSingleSetting(BeanUtils.toBean(singleSettingDO, PriceSingleSettingRespVO.class));
|
|
|
+ List<PriceRoomModelDO> roomModelDOList = priceRoomModelService.getListByObjectId(id);
|
|
|
+ respVO.setRoomModelList(BeanUtils.toBean(roomModelDOList, PriceRoomModelRespVO.class));
|
|
|
+ List<PriceFloorDO> floorDOList = priceFloorService.getListByObjectId(id);
|
|
|
+ respVO.setFloorList(BeanUtils.toBean(floorDOList, PriceFloorRespVO.class));
|
|
|
+ return success(respVO);
|
|
|
+ }
|
|
|
+
|
|
|
+ @GetMapping("/page")
|
|
|
+ @Operation(summary = "获得航次价格分页")
|
|
|
+ @PreAuthorize("@ss.hasPermission('product:price-voyage:query')")
|
|
|
+ public CommonResult<PageResult<PriceVoyageRespVO>> getPriceVoyagePage(@Valid PriceVoyagePageReqVO pageReqVO) {
|
|
|
+ PageResult<PriceVoyageDO> pageResult = priceVoyageService.getPriceVoyagePage(pageReqVO);
|
|
|
+ PageResult<PriceVoyageRespVO> page = BeanUtils.toBean(pageResult, PriceVoyageRespVO.class);
|
|
|
+ List<PriceVoyageRespVO> list = page.getList();
|
|
|
+ List<Long> shipIds = CollectionUtils.convertList(list, PriceVoyageRespVO::getShipId);
|
|
|
+ Map<Long, ShipRespDTO> shipMap = shipApi.queryShip(shipIds);
|
|
|
+
|
|
|
+ List<Long> voyageIds = CollectionUtils.convertList(list, PriceVoyageRespVO::getVoyageId);
|
|
|
+ Map<Long, VoyageDO> voyageMap = voyageService.getListMap(voyageIds);
|
|
|
+
|
|
|
+ List<Long> routeIds = CollectionUtils.convertList(list, PriceVoyageRespVO::getRouteId);
|
|
|
+ Map<Long, RouteRespDTO> routeMap = routeApi.queryRoute(routeIds);
|
|
|
+
|
|
|
+ list.stream().forEach(item -> {
|
|
|
+ item.setShipName(shipMap.get(item.getShipId()).getName());
|
|
|
+ item.setVoyageName(voyageMap.get(item.getVoyageId()).getName());
|
|
|
+ item.setRouteName(routeMap.get(item.getRouteId()).getName());
|
|
|
+ });
|
|
|
+ return success(page);
|
|
|
+ }
|
|
|
+
|
|
|
+ @GetMapping("/export-excel")
|
|
|
+ @Operation(summary = "导出航次价格 Excel")
|
|
|
+ @PreAuthorize("@ss.hasPermission('product:price-voyage:export')")
|
|
|
+ @ApiAccessLog(operateType = EXPORT)
|
|
|
+ public void exportPriceVoyageExcel(@Valid PriceVoyagePageReqVO pageReqVO,
|
|
|
+ HttpServletResponse response) throws IOException {
|
|
|
+ pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
|
|
|
+ List<PriceVoyageDO> list = priceVoyageService.getPriceVoyagePage(pageReqVO).getList();
|
|
|
+ // 导出 Excel
|
|
|
+ ExcelUtils.write(response, "航次价格.xls", "数据", PriceVoyageRespVO.class,
|
|
|
+ BeanUtils.toBean(list, PriceVoyageRespVO.class));
|
|
|
+ }
|
|
|
+
|
|
|
+}
|