add

yj

2024-12-05 b9900893177c78fc559223521fe839aa21000017

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
package com.iotechn.unimall.biz.service.freight;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.dobbinsoft.fw.core.exception.BizServiceException;
import com.dobbinsoft.fw.core.exception.ServiceException;
import com.dobbinsoft.fw.support.component.CacheComponent;
import com.iotechn.unimall.data.constant.CacheConst;
import com.iotechn.unimall.data.domain.FreightTemplateCarriageDO;
import com.iotechn.unimall.data.domain.FreightTemplateDO;
import com.iotechn.unimall.data.dto.freight.FreightTemplateDTO;
import com.iotechn.unimall.data.dto.freight.ShipTraceDTO;
import com.iotechn.unimall.data.exception.ExceptionDefinition;
import com.iotechn.unimall.data.mapper.FreightTemplateCarriageMapper;
import com.iotechn.unimall.data.mapper.FreightTemplateMapper;
import com.iotechn.unimall.data.model.FreightCalcModel;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
 
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
 
/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: kbq
 * Date: 2019-07-07
 * Time: 下午7:48
 */
@Service
public class FreightTemplateBizService {
 
    @Autowired
    private FreightTemplateMapper templateMapper;
 
    @Autowired
    private FreightTemplateCarriageMapper carriageMapper;
 
    @Autowired
    private CacheComponent cacheComponent;
 
    @Autowired
    private ShipTraceQuery shipTraceQuery;
 
    public int computePostage(FreightCalcModel freightCalcModel) throws ServiceException {
        List<FreightCalcModel.FreightAndWeight> freightAndWeights = freightCalcModel.getFreightAndWeights();
        if(CollectionUtils.isEmpty(freightAndWeights)){
            throw new BizServiceException(ExceptionDefinition.FREIGHT_PARAM_CHECK_FAILED);
        }
        HashSet<Long> templateIds = freightAndWeights.stream().map(item ->{
            return item.getId();
        }).collect(Collectors.toCollection(HashSet::new));
 
         // 统计每个模板下的商品重量和，key为模板ID
        Map<Long, Integer> weightMap = templateIds.stream().collect(Collectors.toMap(key -> key, value -> 0));
        // 统计每个模板下的商品价格和，key为模板ID
        Map<Long, Integer> priceMap = templateIds.stream().collect(Collectors.toMap(key -> key, value -> 0));
 
        // 计算每个模板的商品重量和购买商品价格
        for (FreightCalcModel.FreightAndWeight freightAndWeight : freightAndWeights) {
            weightMap.put(freightAndWeight.getId(),freightAndWeight.getWeight() + weightMap.get(freightAndWeight.getId()));
            priceMap.put(freightAndWeight.getId(),freightAndWeight.getPrice() + priceMap.get(freightAndWeight.getId()));
        }
 
        int postage = 0;
        for (Long templateId : templateIds) {
            FreightTemplateDTO freightTemplateById = getFreightTemplateById(templateId);
            Integer weight = weightMap.get(templateId);
            Integer price = priceMap.get(templateId);
 
            boolean judge = true;
            List<FreightTemplateCarriageDO> carriageDOList = freightTemplateById.getCarriageDOList();
            if(!CollectionUtils.isEmpty(carriageDOList)){
                for (FreightTemplateCarriageDO carriageDO : carriageDOList) {
                    if(carriageDO.getDesignatedArea().contains(freightCalcModel.getProvince())){
                        postage += calcPostage(carriageDO.getFreePrice(),carriageDO.getFirstWeight(),carriageDO.getFirstPrice(),carriageDO.getContinueWeight(),carriageDO.getContinuePrice(),weight,price);
                        judge = false;
                        break;
                    }
                }
            }
            if(judge){
                postage += calcPostage(freightTemplateById.getDefaultFreePrice(),freightTemplateById.getDefaultFirstWeight(),freightTemplateById.getDefaultFirstPrice(),freightTemplateById.getDefaultContinueWeight(),freightTemplateById.getDefaultContinuePrice(),weight,price);
            }
        }
        return postage;
    }
 
    public ShipTraceDTO getShipTraceList(String shipNo, String shipCode) throws ServiceException {
        return shipTraceQuery.query(shipNo, shipCode);
    }
 
    // 内部有调用，不用切面
    public FreightTemplateDTO getFreightTemplateById(Long id) throws ServiceException {
        FreightTemplateDTO obj = cacheComponent.getObj(CacheConst.FREIGHT_TEMPLATE + id, FreightTemplateDTO.class);
        if(obj != null){
            return obj;
        }
 
        FreightTemplateDO freightTemplateDO = templateMapper.selectById(id);
        if(freightTemplateDO == null){
            throw new BizServiceException(ExceptionDefinition.FREIGHT_TEMPLATE_NOT_EXIST);
        }
        List<FreightTemplateCarriageDO> template_id = carriageMapper.selectList(
                new QueryWrapper<FreightTemplateCarriageDO>()
                .eq("template_id", freightTemplateDO.getId()));
        FreightTemplateDTO resultDTO = new FreightTemplateDTO();
        BeanUtils.copyProperties(freightTemplateDO,resultDTO);
        resultDTO.setCarriageDOList(template_id);
 
        cacheComponent.putObj(CacheConst.FREIGHT_TEMPLATE + id , resultDTO);
        return resultDTO;
    }
 
    private int calcPostage(Integer freePrice,Integer firstWeight, Integer firstPrice, Integer continueWeight, Integer continuePrice, Integer weight, Integer price){
        if(freePrice.intValue() == 0 || (freePrice.intValue() > 0 && freePrice.intValue() <= price)){
            return 0;
        }
 
        int count = firstPrice;
        weight -= firstWeight;
        while(weight > 0){
            count += continuePrice;
            weight -= continueWeight;
        }
        return count;
    }
}