From f9691d544e62d6c04dbfe45d05a6c7bc5e004291 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期五, 29 十二月 2023 11:52:29 +0800 Subject: [PATCH] 服务商 --- server/services/src/main/java/com/doumee/service/business/impl/PricingDetailServiceImpl.java | 194 +++++++++++++++++++++++++++++++++++------------ 1 files changed, 143 insertions(+), 51 deletions(-) diff --git a/server/services/src/main/java/com/doumee/service/business/impl/PricingDetailServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/PricingDetailServiceImpl.java index c05d038..25b76a0 100644 --- a/server/services/src/main/java/com/doumee/service/business/impl/PricingDetailServiceImpl.java +++ b/server/services/src/main/java/com/doumee/service/business/impl/PricingDetailServiceImpl.java @@ -7,10 +7,12 @@ import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Utils; +import com.doumee.dao.business.BaseParamMapper; 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.BaseParamService; import com.doumee.service.business.PricingDetailService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; @@ -18,15 +20,17 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.wrapper.MPJLambdaWrapper; +import org.apache.commons.collections.MapUtils; +import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; +import sun.text.resources.et.CollationData_et; import java.math.BigDecimal; -import java.util.Date; -import java.util.List; -import java.util.Objects; +import java.util.*; +import java.util.stream.Collectors; /** * 瀹氫环鏂规鏄庣粏閰嶇疆Service瀹炵幇 @@ -42,70 +46,94 @@ @Autowired PricingDetailJoinMapper pricingDetailJoinMapper; + @Autowired + BaseParamMapper baseParamMapper; + + @Override public String create(PricingDetail pricingDetail) { + //鏍¢獙鍙傛暟鍚堟硶鎬� checkPricingDetail(pricingDetail); + LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); + UpdateWrapper<PricingDetail> wrapper = new UpdateWrapper<>(); + wrapper.lambda() + .set(PricingDetail::getIsdeleted,Constants.ONE) + .set(PricingDetail::getEditDate,new Date()) + .set(PricingDetail::getEditor,principal.getId()) + .eq(PricingDetail::getBikeTypeId,pricingDetail.getBikeTypeId()) + .eq(PricingDetail::getPricePramId,pricingDetail.getPricePramId()); + pricingDetailMapper.update(null, wrapper);//鍒犻櫎鑰佺殑閰嶇疆 + PricingDetail insert = new PricingDetail(); + insert.setId(Constants.getUUID()); 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.setBasePrice(Constants.formatDecimalNum(pricingDetail.getBasePrice()).multiply(new BigDecimal(100))); + insert.setUnitPrice(Constants.formatDecimalNum(pricingDetail.getUnitPrice()).multiply(new BigDecimal(100))); + insert.setHolidayBasePrice(Constants.formatDecimalNum(pricingDetail.getHolidayBasePrice()).multiply(new BigDecimal(100))); + insert.setHolidayUnitPrice(Constants.formatDecimalNum(pricingDetail.getHolidayUnitPrice()).multiply(new BigDecimal(100))); insert.setInfo(pricingDetail.getInfo()); - insert.setTitle(pricingDetail.getTitle()); - pricingDetailMapper.insert(pricingDetail); + String title = getRoleNameByParam(insert.getBasePrice(),insert.getBaseTime(),insert.getUnitPrice(),insert.getUnitTime()); + String info = getRoleNameByParam(insert.getHolidayBasePrice(),insert.getHolidayBaseTime(),insert.getHolidayUnitPrice(),insert.getHolidayUnitTime());; + insert.setTitle(title);//宸ヤ綔鏃ヨ浠烽厤缃鍒� + insert.setInfo(info);//鑺傚亣鏃ヨ浠烽厤缃鍒� + pricingDetailMapper.insert(insert); return pricingDetail.getId(); } + public static String getRoleNameByParam(BigDecimal basePrice, Integer baseTime, BigDecimal unitPrice, Integer unitTime) { + String title = "璁¤垂瑙勫垯锛�"; + if(baseTime < 0){ + title += (basePrice.divide(new BigDecimal(100))).doubleValue()+"鍏冪晠楠戜竴鏁村ぉ"; + }else { + title += "璧锋"; + int time = baseTime / 60; + int min = baseTime % 60; + if(time > 0){ + title += time+"灏忔椂"; + } + if(min >0){ + title += min+"鍒嗛挓"; + } + title += basePrice.divide(new BigDecimal(100)).doubleValue() + +"鍏冿紝瓒呰繃鍚�"+unitPrice.divide(new BigDecimal(100)).doubleValue()+"鍏�/" + +unitTime+"鍒嗛挓"; + } + return title; + } + private void checkPricingDetail(PricingDetail pricingDetail){ - if ((Objects.nonNull(pricingDetail.getBaseTime()) && pricingDetail.getBaseTime() < 0) && - Objects.isNull(pricingDetail.getBasePrice())){ - throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"涓�鍙d环浠锋牸涓嶅彲涓虹┖"); + if(StringUtils.isBlank(pricingDetail.getPricePramId()) + ||StringUtils.isBlank(pricingDetail.getBikeTypeId()) + ||pricingDetail.getBaseTime() == null + ||pricingDetail.getBaseTime()==0 + ||Constants.formatDecimalNum(pricingDetail.getBasePrice() ).doubleValue()<0 + ||Constants.formatDecimalNum(pricingDetail.getHolidayBasePrice() ).doubleValue()<0 + ||pricingDetail.getHolidayBaseTime() == null + || pricingDetail.getHolidayBaseTime()==0){ + //鍙傛暟閿欒 + throw new BusinessException(ResponseStatus.BAD_REQUEST); } - - if ((Objects.nonNull(pricingDetail.getBaseTime()) && pricingDetail.getBaseTime() > 0) && - (Objects.isNull(pricingDetail.getBasePrice()) - || Objects.isNull(pricingDetail.getUnitTime()) - || Objects.isNull(pricingDetail.getUnitPrice()))){ - throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"闃舵瀹氫环鍙傛暟涓嶅彲涓虹┖"); + pricingDetail.setUnitPrice(Constants.formatDecimalNum(pricingDetail.getUnitPrice())); + pricingDetail.setHolidayUnitPrice(Constants.formatDecimalNum(pricingDetail.getHolidayUnitPrice())); + pricingDetail.setUnitTime(Constants.formatIntegerNum(pricingDetail.getUnitTime())); + pricingDetail.setHolidayUnitTime(Constants.formatIntegerNum(pricingDetail.getHolidayUnitTime())); + if ( pricingDetail.getBaseTime() < 0){ + pricingDetail.setBaseTime(-1); } - - if ( (Objects.nonNull(pricingDetail.getHolidayBaseTime()) && pricingDetail.getHolidayBaseTime() < 0) - && ( Objects.isNull(pricingDetail.getHolidayBasePrice())) - ){ - throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鑺傚亣涓�鍙d环浠锋牸涓嶅彲涓虹┖"); + if ( pricingDetail.getHolidayBaseTime() < 0){ + pricingDetail.setHolidayBaseTime(-1); } - - if (((Objects.nonNull(pricingDetail.getHolidayBaseTime()) && pricingDetail.getHolidayBaseTime() > 0)) - && (Objects.isNull(pricingDetail.getHolidayBasePrice()) - || Objects.isNull(pricingDetail.getHolidayUnitTime()) - || Objects.isNull(pricingDetail.getHolidayUnitPrice()))){ - - throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鑺傚亣闃舵瀹氫环鍙傛暟涓嶅彲涓虹┖"); - } - - QueryWrapper<PricingDetail> wrapper = new QueryWrapper<>(); - wrapper.lambda() - .eq(PricingDetail::getIsdeleted,Constants.ZERO) - .eq(PricingDetail::getBikeTypeId,pricingDetail.getBikeTypeId()) - .eq(PricingDetail::getPricePramId,pricingDetail.getPricePramId()); - Integer exitCount = pricingDetailMapper.selectCount(wrapper); - - if (exitCount > Constants.ZERO){ - throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"璇ヨ溅鍨嬪凡閰嶇疆"); - } +// PricingDetail exitCount = pricingDetailMapper.selectOne(wrapper); } @@ -134,6 +162,11 @@ LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); pricingDetail.setEditDate(new Date()); pricingDetail.setEditor(principal.getId()); + pricingDetail.setBasePrice(Constants.formatDecimalNum(pricingDetail.getBasePrice()).multiply(new BigDecimal(100))); + pricingDetail.setUnitPrice(Constants.formatDecimalNum(pricingDetail.getUnitPrice()).multiply(new BigDecimal(100))); + pricingDetail.setHolidayBasePrice(Constants.formatDecimalNum(pricingDetail.getHolidayBasePrice()).multiply(new BigDecimal(100))); + pricingDetail.setHolidayUnitPrice(Constants.formatDecimalNum(pricingDetail.getHolidayUnitPrice()).multiply(new BigDecimal(100))); + pricingDetailMapper.updateById(pricingDetail); } @@ -149,24 +182,74 @@ @Override public PricingDetail findById(String id) { - return pricingDetailMapper.selectById(id); + PricingDetail model = pricingDetailMapper.selectById(id); + if(model !=null ){ + model.setBasePrice(Constants.translateMoney(model.getBasePrice())); + model.setHolidayBasePrice(Constants.translateMoney(model.getHolidayBasePrice())); + model.setUnitPrice(Constants.translateMoney(model.getUnitPrice())); + model.setHolidayUnitPrice(Constants.translateMoney(model.getHolidayUnitPrice())); + } + return model; } @Override public PricingDetail findOne(PricingDetail pricingDetail) { QueryWrapper<PricingDetail> wrapper = new QueryWrapper<>(pricingDetail); - return pricingDetailMapper.selectOne(wrapper.last(" limit 1")); + PricingDetail model = pricingDetailMapper.selectOne(wrapper.last(" limit 1")); + if(model !=null ){ + model.setBasePrice(Constants.translateMoney(model.getBasePrice())); + model.setHolidayBasePrice(Constants.translateMoney(model.getHolidayBasePrice())); + model.setUnitPrice(Constants.translateMoney(model.getUnitPrice())); + model.setHolidayUnitPrice(Constants.translateMoney(model.getHolidayUnitPrice())); + } + return model; } @Override public List<PricingDetail> findList(PricingDetail pricingDetail) { MPJLambdaWrapper<PricingDetail> wrapper = new MPJLambdaWrapper<>(); - wrapper.leftJoin(BaseParam.class,BaseParam::getId,PricingDetail::getBikeTypeId) - .eq(PricingDetail::getPricePramId,pricingDetail.getPricePramId()) - .eq(BaseParam::getType,Constants.THREE); + wrapper.eq(PricingDetail::getPricePramId,pricingDetail.getPricePramId()) + .eq(PricingDetail::getIsdeleted,Constants.ZERO); + wrapper.rightJoin(BaseParam.class,BaseParam::getId,PricingDetail::getBikeTypeId); wrapper.selectAll(PricingDetail.class) + .selectAs(BaseParam::getId,PricingDetail::getBikeTypeId) .selectAs(BaseParam::getName,PricingDetail::getBikeTypeName); - return pricingDetailJoinMapper.selectJoinList(PricingDetail.class,wrapper); + List<PricingDetail> result = pricingDetailJoinMapper.selectJoinList(PricingDetail.class,wrapper); + + Map<String, PricingDetail> stringPricingDetailMap = Optional.ofNullable(result) + .map(s -> s.stream().collect(Collectors.toMap(p -> p.getBikeTypeId(), p -> p))) + .orElse(new HashMap<>()); + QueryWrapper<BaseParam> baseParamQuery = new QueryWrapper(); + baseParamQuery.lambda() + .eq(BaseParam::getIsdeleted,Constants.ZERO) + .eq(BaseParam::getType,Constants.THREE) + .orderByAsc(BaseParam::getSortnum); + List<BaseParam> list = baseParamMapper.selectList(baseParamQuery); + if (CollectionUtils.isEmpty(list)){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍐呯疆鏁版嵁纭疄"); + } + + List<PricingDetail> collect = list.stream().map(s -> { + PricingDetail put = stringPricingDetailMap.getOrDefault(s.getId(), new PricingDetail()); + put.setBikeTypeId(s.getId()); + put.setPricePramId(pricingDetail.getPricePramId()); + put.setBikeTypeName(s.getName()); + put.setSortnum(s.getSortnum()); + put.setBasePrice(Objects.nonNull(put.getBasePrice()) ? Constants.translateMoney(put.getBasePrice()) : null); + put.setHolidayBasePrice(Objects.nonNull(put.getHolidayBasePrice()) ? Constants.translateMoney(put.getHolidayBasePrice()):null); + put.setUnitPrice(Objects.nonNull(put.getUnitPrice()) ? Constants.translateMoney(put.getUnitPrice()):null); + put.setHolidayUnitPrice(Objects.nonNull(put.getHolidayUnitPrice()) ? Constants.translateMoney(put.getHolidayUnitPrice()):null); + return put; + }).collect(Collectors.toList()); +// if(result!=null){ +// for(PricingDetail model :result){ +// model.setBasePrice(Constants.translateMoney(model.getBasePrice())); +// model.setHolidayBasePrice(Constants.translateMoney(model.getHolidayBasePrice())); +// model.setUnitPrice(Constants.translateMoney(model.getUnitPrice())); +// model.setHolidayUnitPrice(Constants.translateMoney(model.getHolidayUnitPrice())); +// } +// } + return collect; } @Override @@ -237,7 +320,16 @@ queryWrapper.orderByAsc(sortData.getProperty()); } } - return PageData.from(pricingDetailMapper.selectPage(page, queryWrapper)); + IPage<PricingDetail> result =pricingDetailMapper.selectPage(page, queryWrapper); + if(result.getRecords()!= null ){ + for(PricingDetail model : result.getRecords()){ + model.setBasePrice(Constants.translateMoney(model.getBasePrice())); + model.setHolidayBasePrice(Constants.translateMoney(model.getHolidayBasePrice())); + model.setUnitPrice(Constants.translateMoney(model.getUnitPrice())); + model.setHolidayUnitPrice(Constants.translateMoney(model.getHolidayUnitPrice())); + } + } + return PageData.from(result); } @Override -- Gitblit v1.9.3