LocationServiceImpl.java
14.5 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
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
package com.huaheng.pc.config.location.service;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.huaheng.common.exception.service.ServiceException;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.common.utils.security.ShiroUtils;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.config.location.domain.LocationInfo;
import com.huaheng.pc.config.locationType.domain.LocationType;
import com.huaheng.pc.config.locationType.service.LocationTypeService;
import com.huaheng.pc.config.zone.domain.Zone;
import com.huaheng.pc.config.zone.service.ZoneService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.huaheng.pc.config.location.domain.Location;
import com.huaheng.pc.config.location.mapper.LocationMapper;
@Service("LocationService")
public class LocationServiceImpl extends ServiceImpl<LocationMapper, Location> implements LocationService{
@Resource
private LocationService locationService;
@Resource
private LocationTypeService locationTypeService;
@Resource
private ZoneService zoneService;
@Resource
private LocationMapper locationMapper;
/**
* //新增库位，需要建立code，并判断是否重复
* 1. 库区和库位没有绝对关系。 先建立库区，然后在库区的位置进行建立库位类型。
* TODO：胡海--在判断库位类型和库区是否匹配，应该用库位类型表进行判断。库位类型在库区存在即可
* @param location
* @return
*/
@Override
public AjaxResult addsave(Location location){
//库区与库位类型的匹配判断
if(!location.getZoneCode().equals(location.getLocationType())){
throw new ServiceException(location.getLocationType()+"的库位类型与"+location.getZoneCode()+"库区不匹配");
}
//TODO:胡海-- 库位编码长度应该是弹性的，即我们的库位是由4个维度组成的，正常情况下 平库（行列） 立体仓库（行列层） AGV料架库（行列层格）
// 这里可以判断下 然后决定库位编码长度。
//创建库位编码code
String prefix = location.getLocationType().substring(1);
String code = MessageFormat.format("{0}{1}-{2}-{3}-{4}",
prefix,
String.format("%02d", location.getIRow()),
String.format("%02d", location.getIColumn()),
String.format("%02d", location.getILayer()),
String.format("%02d", location.getIGrid()));
//判断code是否重复
LambdaQueryWrapper<Location> lam = Wrappers.lambdaQuery();
lam.eq(Location::getWarehouseCode,ShiroUtils.getWarehouseCode())
.eq(Location::getCode,code);
if(this.getOne(lam)!=null){
return AjaxResult.error("该位置已有库位生成，请重新输入位置");
}
//插入数据库
location.setCode(code);
location.setWarehouseCode(ShiroUtils.getWarehouseCode());
location.setCreatedBy(ShiroUtils.getLoginName());
Boolean flag=this.save(location);
if(flag == false){
return AjaxResult.error("新增库位失败，插入数据库时失败");
}
return AjaxResult.success("新增库位成功");
}
/**
* 批量新增库位
* @param location
* @return boolean
*/
@Override
public boolean insertLocation(Location location) {
/* 判断库位类型编码是否存在*/
LambdaQueryWrapper<LocationType> typeLambda = Wrappers.lambdaQuery();
typeLambda.eq(LocationType::getCode,location.getLocationType())
.select(LocationType::getCode);
List<Map<String, Object>> list = locationTypeService.listMaps(typeLambda);
if (list.size() < 1){
throw new ServiceException("库位类型编码不存在");
}
/* 判断库区编码是否存在*/
LambdaQueryWrapper<Zone> zoneLambda= Wrappers.lambdaQuery();
zoneLambda.eq(Zone::getCode, location.getZoneCode())
.select(Zone::getCode);
list = zoneService.listMaps(zoneLambda);
if (list.size() < 1){
throw new ServiceException("库区编码不存在");
}
//TODO：胡海--在判断库位类型和库区是否匹配，应该用库位类型表进行判断。库位类型在库区存在即可
if(!location.getZoneCode().equals(location.getLocationType())){
throw new ServiceException(location.getLocationType()+"的库位类型与"+location.getZoneCode()+"库区不匹配");
}
List<Location> locations = new ArrayList<>();
for (int i=1; i<=location.getIRow().intValue(); i++) {
for (int j=1; j<=location.getIColumn().intValue(); j++) {
for (int k=1; k<=location.getILayer().intValue(); k++) {
for (int m=1; m<=location.getIGrid().intValue(); m++) {
//Integer roadway = (j / 2) + 1;
Location param = new Location();
param.setIRow(i);
param.setIColumn(j);
param.setILayer(k);
param.setIGrid(m);
param.setRoadway(location.getRoadway());
param.setZoneCode(location.getZoneCode());
param.setLocationType(location.getLocationType());
param.setStatus(location.getStatus());
param.setWarehouseCode(ShiroUtils.getWarehouseCode());
param.setCreatedBy(ShiroUtils.getLoginName());
param.setLastUpdatedBy(ShiroUtils.getLoginName());
String code = MessageFormat.format("{0}{1}_{2}_{3}",
location.getLocationType(),
String.format("%02d", i),
String.format("%02d", j),
String.format("%02d", k));
//查询该库位编码是否存在
LambdaQueryWrapper<Location> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(Location::getCode,code)
.eq(Location::getWarehouseCode,ShiroUtils.getWarehouseCode());
List<Location> locationList = locationService.list(queryWrapper);
if (locationList.size() == 0) {
param.setCode(code);
locations.add(param);
}
}
}
}
}
int num =0;
List<Location> locations1 = new ArrayList<>();
if(locations.size() >1000 ){
for(Location item : locations){
num++;
locations1.add(item);
if(num % 1000 ==0 || num == locations.size()){
locationMapper.addList(locations1);
locations1=new ArrayList<>();
}
}
}else {
locationMapper.addList(locations);
}
List<Integer> integerList = new ArrayList<>();
for(Location location2 : locations) {
if(integerList.size() == 0) {
integerList.add(location2.getIRow());
} else {
for(int i = 0; i< integerList.size(); i++) {
if(integerList.get(i).intValue() == location2.getIRow().intValue()) {
break;
} else {
if(i == (integerList.size() - 1)) {
integerList.add(location2.getIRow());
}
}
}
}
}
if(integerList.size() == 4) {
for (Location location3 : locations) {
for (int i = 0; i < integerList.size(); i++) {
if (location3.getIRow().intValue() == integerList.get(i).intValue()) {
if (i == 0 || i == (integerList.size() - 1)) {
location3.setRowFlag(1);
} else {
location3.setRowFlag(0);
}
}
}
}
locationMapper.updateList(locations);
}
return true;
}
/**
* 根据库位编码对库位表格的状态进行更新
* @param locationCode
* @param status
*/
@Override
public void updateStatus(String locationCode, String status) {
if (StringUtils.isNotEmpty(locationCode)) {
locationMapper.updateStatus(ShiroUtils.getWarehouseCode(), locationCode, status);
}
}
/**
* 通过定位规则查找库位
* @param locatingRule
* @return
*/
@Override
public String position(String locatingRule){
return locationMapper.position(locatingRule).getCode();
}
/**
* 修改容器和库位状态
* */
@Override
public void updateContainerCodeAndStatus(String locationCode, String containerCode, String status) {
if (StringUtils.isNotEmpty(locationCode) || StringUtils.isNotEmpty(containerCode)) {
LambdaUpdateWrapper<Location> updateWrapper = Wrappers.lambdaUpdate();
updateWrapper.set(Location::getContainerCode, containerCode)
.set(Location::getStatus, status)
.eq(Location::getWarehouseCode, ShiroUtils.getWarehouseCode())
.eq(Location::getCode, locationCode);
this.update(updateWrapper);
}
}
@Override
public LocationInfo getAllLocation(String type) {
if (StringUtils.isNotEmpty(type)) {
Location location = locationMapper.getAllLocation(ShiroUtils.getWarehouseCode(), type);
LocationInfo locationInfo = new LocationInfo();
locationInfo.setMaxRow(location.getIRow());
locationInfo.setMaxLine(location.getIColumn());
locationInfo.setMaxLayer(location.getILayer());
locationInfo.setMaxGrid(location.getIGrid());
return locationInfo;
}
return null;
}
/**
* 验证库位合法性
*
* @param code
* @return
*/
@Override
public boolean checkLocation(String code) {
LambdaQueryWrapper<Location> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(Location::getWarehouseCode, ShiroUtils.getWarehouseCode())
.eq(Location::getDeleted,false)
.eq(Location::getCode, code);
List<Location> locations = list(queryWrapper);
if (locations.size() >= 1){
Location location = locations.get(0);
String containerCode =location.getContainerCode();
if (containerCode != null && containerCode.length() > 0) {
throw new ServiceException("货架上已有容器");
}
String status = location.getStatus();
if(!"empty".equals(status)) {
throw new ServiceException("库位状态不为空");
}
return true;
} else {
return false;
}
}
@Override
public boolean getFreeLocation(String materialCode, String batch) {
LambdaQueryWrapper<Location> lambdaQueryWrapper = Wrappers.lambdaQuery();
lambdaQueryWrapper.eq(Location::getWarehouseCode, ShiroUtils.getWarehouseCode())
.eq(Location::getContainerCode, "")
.eq(Location::getDeleted, false)
.eq(Location::getStatus, "empty");
List<Location> locations = locationService.list(lambdaQueryWrapper);
if(locations != null && locations.size() > 0) {
return true;
}
return false;
}
/**
* 查询库位利用率
* @return
*/
@Override
public List<LinkedHashMap<String, Object>> getLocationProp() {
return locationMapper.getLocationProp();
}
/**
* 根据库位编码查询库位信息
* @param code
* @return
*/
@Override
public Location findLocationByCode(String code) {
LambdaQueryWrapper<Location> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(Location::getCode, code);
return getOne(queryWrapper);
}
@Override
public List<Location> pickLocation() {
return locationMapper.pickLocation();
}
@Override
public List<Location> selectContainerEmpty(String warehouseCode) {
return locationMapper.selectContainerEmpty(warehouseCode);
}
@Override
public Location getInsideNear(Location location) {
LambdaQueryWrapper<Location> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(Location::getWarehouseCode, location.getWarehouseCode());
queryWrapper.eq(Location::getZoneCode, "L");
queryWrapper.eq(Location::getRoadway, location.getRoadway());
queryWrapper.eq(Location::getIColumn, location.getIColumn());
queryWrapper.eq(Location::getILayer, location.getILayer());
queryWrapper.eq(Location::getLocationType, location.getLocationType());
queryWrapper.eq(Location::getRowFlag, 0);
List<Location> locationList = list(queryWrapper);
for(Location location1 : locationList) {
int diff = Math.abs(location1.getIRow().intValue() - location.getIRow().intValue());
if(diff == 1) {
return location1;
}
}
return null;
}
@Override
public Location getEmptyInsideLocation(Location location) {
LambdaQueryWrapper<Location> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.eq(Location::getWarehouseCode, location.getWarehouseCode());
queryWrapper.eq(Location::getZoneCode, "L");
queryWrapper.eq(Location::getRoadway, location.getRoadway());
queryWrapper.eq(Location::getRowFlag, 0);
queryWrapper.eq(Location::getContainerCode, "");
queryWrapper.eq(Location::getLocationType, location.getLocationType());
List<Location> locationList = list(queryWrapper);
Location location1 = locationList.get(0);
return location1;
}
}