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