wzy
2021-11-30 0e5aaeba97021c289485a652ec6af0bb37f92af7
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
132
133
134
135
136
137
138
139
140
141
142
143
144
package com.xzx.gc.order.service;
 
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.comparator.IndexedComparator;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.lang.Dict;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.entity.SysEnvironmentalInfo;
import com.xzx.gc.order.mapper.SysEnvironmentalInfoMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example;
 
import java.math.BigDecimal;
import java.util.List;
import java.util.stream.Collectors;
 
@Service
@Transactional
public class SysEnvironmentalInfoService {
    @Autowired
    private SysEnvironmentalInfoMapper sysEnvironmentalInfoMapper;
 
    public SysEnvironmentalInfo findById(Long id) {
        return sysEnvironmentalInfoMapper.selectByPrimaryKey(id);
    }
 
 
    public List<SysEnvironmentalInfo> find() {
        Example example=new Example(SysEnvironmentalInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("delFlag",Constants.DEL_NOT_FLAG);
        criteria.andIsNotNull("parentId");
        return sysEnvironmentalInfoMapper.selectByExample(example);
    }
 
 
    /**
     * 根据父Id查找子类
     * @param parentId
     * @return
     */
    public List<SysEnvironmentalInfo> findByParentId(Long parentId){
        SysEnvironmentalInfo sysEnvironmentalInfo=new SysEnvironmentalInfo();
        sysEnvironmentalInfo.setParentId(parentId);
        sysEnvironmentalInfo.setDelFlag(Constants.DEL_NOT_FLAG);
        List<SysEnvironmentalInfo> sysEnvironmentalInfo2 = sysEnvironmentalInfoMapper.select(sysEnvironmentalInfo);
        return  sysEnvironmentalInfo2;
    }
 
    /**
     * 查找所有子类的itemType集合
     * @param areaId
     * @param itemType
     * @return
     */
    public List<String> findChildItemTypeByType(String areaId,String itemType){
        SysEnvironmentalInfo sysEnvironmentalInfo1 =   findByItemTypeAndArea(itemType,Convert.toInt(areaId));
        long parentId = sysEnvironmentalInfo1.getId();
        List<SysEnvironmentalInfo> byParentId = findByParentId(parentId);
        return byParentId.stream().map(x->x.getItemType()).collect(Collectors.toList());
    }
 
 
 
    /**
     * 根据itemType查找类型
     * @param itemType
     * @param areaId
     * @return
     */
    public SysEnvironmentalInfo findByItemTypeAndArea(String itemType,Integer areaId) {
        Example example=new Example(SysEnvironmentalInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("itemType",itemType);
        criteria.andEqualTo("cityId",areaId);
//        criteria.andEqualTo("delFlag",Constants.DEL_NOT_FLAG);
        SysEnvironmentalInfo sysEnvironmentalInfo1 = sysEnvironmentalInfoMapper.selectOneByExample(example);
        return  sysEnvironmentalInfo1;
    }
 
    public SysEnvironmentalInfo findByItemTypeAndAreaNotDel(String itemType,Integer areaId) {
        Example example=new Example(SysEnvironmentalInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("itemType",itemType);
        criteria.andEqualTo("cityId",areaId);
        criteria.andEqualTo("delFlag",Constants.DEL_NOT_FLAG);
        SysEnvironmentalInfo sysEnvironmentalInfo1 = sysEnvironmentalInfoMapper.selectOneByExample(example);
        return  sysEnvironmentalInfo1;
    }
 
 
    /**
     * 根据区域查询废纸及杂纸的最低单价  先算废纸再算杂纸
     * @param areaIds
     * @return
     */
    public String findByMinItemPriceTypeAndAreaIds(List<String> areaIds) {
        String paperBasic=null;
        Dict dict=Dict.create();
        for (String areaId : areaIds) {
            SysEnvironmentalInfo byItemTypeAndArea = findByItemTypeAndArea(Constants.PAPER_WASTE_ITEM_TYPE, Convert.toInt(areaId));
            if (byItemTypeAndArea != null&&Convert.toBigDecimal(byItemTypeAndArea.getPrice(),Constants.MONEY_INIT).compareTo(BigDecimal.ZERO)>0) {
                //废纸
                List<BigDecimal> list= (List<BigDecimal>) dict.get("fz");
                if(CollUtil.isEmpty(list)){
                    list=CollUtil.newArrayList();
                }
                list.add(Convert.toBigDecimal(byItemTypeAndArea.getPrice()));
                dict.put("fz", list);
            } else {
                byItemTypeAndArea = findByItemTypeAndArea(Constants.PAPER_MIX_ITEM_TYPE, Convert.toInt(areaId));
                if (byItemTypeAndArea != null&&Convert.toBigDecimal(byItemTypeAndArea.getPrice(),Constants.MONEY_INIT).compareTo(BigDecimal.ZERO)>0) {
                    List<BigDecimal> list= (List<BigDecimal>) dict.get("zz");
                    if(CollUtil.isEmpty(list)){
                        list=CollUtil.newArrayList();
                    }
                    list.add(Convert.toBigDecimal(byItemTypeAndArea.getPrice()));
                    dict.put("zz", list);
                }
            }
        }
 
        List<BigDecimal> list= (List<BigDecimal>) dict.get("fz");
        if(CollUtil.isNotEmpty(list)) {
            CollUtil.sort(list, new IndexedComparator<>());
            return Convert.toStr(CollUtil.getFirst(list));
        }
 
        list= (List<BigDecimal>) dict.get("zz");
        if(CollUtil.isNotEmpty(list)) {
            CollUtil.sort(list, new IndexedComparator<>());
            return Convert.toStr(CollUtil.getFirst(list));
        }
 
        return paperBasic;
    }
 
 
 
 
 
}