| | |
| | | package com.doumee.service.business.impl; |
| | | |
| | | import com.doumee.core.constants.Constants; |
| | | import com.doumee.core.constants.ResponseStatus; |
| | | import com.doumee.core.exception.BusinessException; |
| | | import com.doumee.core.model.LoginUserInfo; |
| | | import com.doumee.core.model.PageData; |
| | | import com.doumee.core.model.PageWrap; |
| | | import com.doumee.core.utils.Utils; |
| | | import com.doumee.dao.business.PricingDetailMapper; |
| | | import com.doumee.dao.business.join.PricingDetailJoinMapper; |
| | | import com.doumee.dao.business.model.BaseParam; |
| | | import com.doumee.dao.business.model.PricingDetail; |
| | | import com.doumee.service.business.PricingDetailService; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import org.apache.shiro.SecurityUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | |
| | | /** |
| | | * 定价方案明细配置Service实现 |
| | |
| | | @Autowired |
| | | private PricingDetailMapper pricingDetailMapper; |
| | | |
| | | @Autowired |
| | | PricingDetailJoinMapper pricingDetailJoinMapper; |
| | | |
| | | @Override |
| | | public String create(PricingDetail pricingDetail) { |
| | | |
| | | if ((pricingDetail.getBaseTime() < 0) && |
| | | Objects.isNull(pricingDetail.getBasePrice())){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"一口价价格不可为空"); |
| | | } |
| | | |
| | | if ((pricingDetail.getBaseTime() > 0) && |
| | | (Objects.isNull(pricingDetail.getBasePrice()) |
| | | || Objects.isNull(pricingDetail.getUnitTime()) |
| | | || Objects.isNull(pricingDetail.getUnitPrice()))){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"阶梯定价参数不可为空"); |
| | | } |
| | | |
| | | if ((pricingDetail.getHolidayBasePrice() < 0) && |
| | | Objects.isNull(pricingDetail.getBasePrice()) ){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"节假一口价价格不可为空"); |
| | | } |
| | | |
| | | if ((pricingDetail.getHolidayBasePrice() > 0) && |
| | | (Objects.isNull(pricingDetail.getHolidayBasePrice()) |
| | | || Objects.isNull(pricingDetail.getHolidayBasePrice()) |
| | | || Objects.isNull(pricingDetail.getHolidayBasePrice()))){ |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"节假阶梯定价参数不可为空"); |
| | | } |
| | | LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | PricingDetail insert = new PricingDetail(); |
| | | insert.setCreateDate(new Date()); |
| | | insert.setCreator(principal.getId()); |
| | | insert.setEditDate(new Date()); |
| | | insert.setEditor(principal.getId()); |
| | | insert.setIsdeleted(Constants.ZERO); |
| | | insert.setPricePramId(pricingDetail.getPricePramId()); |
| | | insert.setBikeTypeId(pricingDetail.getBikeTypeId()); |
| | | insert.setBaseTime(pricingDetail.getBaseTime()); |
| | | insert.setBasePrice(pricingDetail.getBasePrice()); |
| | | insert.setUnitTime(pricingDetail.getUnitTime()); |
| | | insert.setUnitPrice(pricingDetail.getUnitPrice()); |
| | | insert.setHolidayBaseTime(pricingDetail.getHolidayBaseTime()); |
| | | insert.setHolidayBasePrice(pricingDetail.getHolidayBasePrice()); |
| | | insert.setHolidayUnitTime(pricingDetail.getHolidayUnitTime()); |
| | | insert.setHolidayUnitPrice(pricingDetail.getHolidayUnitPrice()); |
| | | insert.setInfo(pricingDetail.getInfo()); |
| | | insert.setTitle(pricingDetail.getTitle()); |
| | | pricingDetailMapper.insert(pricingDetail); |
| | | return pricingDetail.getId(); |
| | | } |
| | |
| | | @Override |
| | | public PricingDetail findOne(PricingDetail pricingDetail) { |
| | | QueryWrapper<PricingDetail> wrapper = new QueryWrapper<>(pricingDetail); |
| | | return pricingDetailMapper.selectOne(wrapper); |
| | | return pricingDetailMapper.selectOne(wrapper.last(" limit 1")); |
| | | } |
| | | |
| | | @Override |
| | | public List<PricingDetail> findList(PricingDetail pricingDetail) { |
| | | QueryWrapper<PricingDetail> wrapper = new QueryWrapper<>(pricingDetail); |
| | | return pricingDetailMapper.selectList(wrapper); |
| | | MPJLambdaWrapper<PricingDetail> wrapper = new MPJLambdaWrapper<>(); |
| | | wrapper.leftJoin(BaseParam.class,BaseParam::getId,PricingDetail::getBikeTypeId) |
| | | .eq(BaseParam::getType,Constants.THREE); |
| | | wrapper.selectAll(PricingDetail.class) |
| | | .selectAs(BaseParam::getName,PricingDetail::getBikeTypeName); |
| | | return pricingDetailJoinMapper.selectJoinList(PricingDetail.class,wrapper); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public PageData<PricingDetail> findPage(PageWrap<PricingDetail> pageWrap) { |
| | | IPage<PricingDetail> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); |