CustomerServiceImpl.java
6.11 KB
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
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
package cn.fw.valhalla.service.data.impl;
import cn.fw.valhalla.dao.mapper.CustomerMapper;
import cn.fw.valhalla.domain.db.customer.Customer;
import cn.fw.valhalla.domain.dto.CustomerDetailDto;
import cn.fw.valhalla.domain.dto.StammkundeAnalyseDTO;
import cn.fw.valhalla.domain.query.CustomCustomerQuery;
import cn.fw.valhalla.domain.query.CustomerQueryVO;
import cn.fw.valhalla.domain.query.StammkundeAnalyseQueryVO;
import cn.fw.valhalla.domain.vo.customer.CustomerListVO;
import cn.fw.valhalla.sdk.param.CusCntReq;
import cn.fw.valhalla.sdk.result.BasicsCustomerDTO;
import cn.fw.valhalla.sdk.result.CusCntResult;
import cn.fw.valhalla.service.data.CustomerService;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.springframework.lang.NonNull;
import org.springframework.lang.Nullable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
/**
* @author : kurisu
* @className : CustomerServiceImpl
* @description : 档案
* @date: 2020-08-12 11:20
*/
@Service
@Slf4j
public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> implements CustomerService {
@Override
public List<CustomerListVO> getAppPageList(Integer startIndex, Integer pageSize, CustomerQueryVO queryVO) {
List<CustomerListVO> appPageList = getBaseMapper().getAppPageList(startIndex, queryVO.getPageSize(), queryVO);
return CollectionUtils.isEmpty(appPageList) ? new ArrayList<>() : appPageList;
}
@Override
public Customer queryById(Long id) {
return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
.eq(Customer::getId, id)
.eq(Customer::getYn, Boolean.TRUE)
.last("limit 1"));
}
@Override
public Customer queryByIdWithInvalid(Long id) {
return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
.eq(Customer::getId, id)
.last("limit 1"));
}
@Override
public Customer queryByPlateNo(String plateNo, Long groupId) {
return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
.eq(Customer::getPlateNo, plateNo)
.eq(Customer::getYn, Boolean.TRUE)
.eq(Customer::getGroupId, groupId)
.orderByDesc(Customer::getUpdateTime)
.last("limit 1"));
}
@Override
public Customer queryByFrameNo(String frameNo, Long groupId) {
return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
.eq(Customer::getFrameNo, frameNo)
.eq(Customer::getYn, Boolean.TRUE)
.eq(Customer::getGroupId, groupId)
.orderByDesc(Customer::getUpdateTime)
.last("limit 1"));
}
@Override
public Customer queryByEngineNo(String engineNo, Long groupId) {
return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
.eq(Customer::getEngineNo, engineNo)
.eq(Customer::getYn, Boolean.TRUE)
.eq(Customer::getGroupId, groupId)
.orderByDesc(Customer::getUpdateTime)
.last("limit 1"));
}
@Override
public List<Customer> queryByBaseId(Long baseId) {
return this.list(Wrappers.<Customer>lambdaQuery()
.eq(Customer::getBaseId, baseId)
.eq(Customer::getYn, Boolean.TRUE)
);
}
@Override
public void forbidden(Long customerId) {
this.update(Wrappers.<Customer>lambdaUpdate()
.set(Customer::getYn, Boolean.FALSE)
.eq(Customer::getId, customerId)
);
}
@Override
public void forbiddenPlate(String plateNo) {
this.update(Wrappers.<Customer>lambdaUpdate()
.set(Customer::getYn, Boolean.FALSE)
.eq(Customer::getPlateNo, plateNo)
.eq(Customer::getYn, Boolean.TRUE)
);
}
@Override
@Nullable
public List<Customer> queryByAdviserId(@NonNull Long adviserId) {
return this.list(Wrappers.<Customer>lambdaQuery()
.eq(Customer::getAdviserId, adviserId)
.eq(Customer::getYn, Boolean.TRUE)
);
}
@Override
public List<StammkundeAnalyseDTO> analyseList(final StammkundeAnalyseQueryVO queryVO) {
List<StammkundeAnalyseDTO> list = this.getBaseMapper().analyseList(queryVO);
return Optional.ofNullable(list).orElse(new ArrayList<>());
}
@Override
public List<CustomerDetailDto> queryCustomList(CustomCustomerQuery query) {
return Optional.ofNullable(getBaseMapper().queryCustomList(query)).orElse(new ArrayList<>());
}
@Override
public Long queryCustomListCount(CustomCustomerQuery query) {
return Optional.ofNullable(getBaseMapper().queryCustomCount(query)).orElse(0L);
}
@Override
public List<BasicsCustomerDTO> queryByKeyword(String keyword, Long groupId) {
return Optional.ofNullable(this.getBaseMapper().queryByKeyword(keyword, groupId)).orElse(new ArrayList<>());
}
@Override
@Transactional(rollbackFor = Exception.class)
public void afterDistributePubClue(final List<String> vinList, final Long userId, final Long shopId, final Long groupId) {
update(Wrappers.<Customer>lambdaUpdate()
.set(Customer::getAdviserId, userId)
.set(Customer::getShopId, shopId)
.set(Customer::getTemporary, Boolean.TRUE)
.eq(Customer::getYn, Boolean.TRUE)
.eq(Customer::getGroupId, groupId)
.in(Customer::getFrameNo, vinList)
.isNull(Customer::getAdviserId)
);
}
@Override
public List<CusCntResult> queryCusCnt(final CusCntReq req) {
if(!CollectionUtils.isEmpty(req.getShopIds())){
return getBaseMapper().queryShopCusCnt(req);
}
return getBaseMapper().queryAdviserCusCnt(req);
}
}