SnServiceImpl.java
3.36 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
package com.huaheng.pc.config.sn.service;
import java.util.List;
import java.util.Map;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.huaheng.common.exception.BusinessException;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.common.utils.security.ShiroUtils;
import com.huaheng.pc.config.material.domain.Material;
import com.huaheng.pc.config.sn.domain.Sn;
import com.huaheng.pc.config.sn.mapper.SnMapper;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@Service
public class SnServiceImpl extends ServiceImpl<SnMapper, Sn> implements SnService {
public Sn getSn(String code){
LambdaQueryWrapper<Sn> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(Sn::getCode, code);
lambdaQueryWrapper.last("limit 1");
// 验证是否存在这个用户
Sn m = this.getOne(lambdaQueryWrapper);
return m;
}
/**
* 导入数据
* @param snList 用户数据列表
* @param operName 操作用户
* @return 结果
*/
@Override
public String importSn(List<Sn> snList, String operName) {
if (StringUtils.isNull(snList) || snList.size() == 0) {
throw new BusinessException("导入数据不能为空！");
}
int successNum = 0;
int failureNum = 0;
StringBuilder successMsg = new StringBuilder();
StringBuilder failureMsg = new StringBuilder();
for (Sn sn : snList) {
try {
LambdaQueryWrapper<Sn> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(Sn::getCode, sn.getCode());
lambdaQueryWrapper.last("limit 1");
// 验证是否存在这个用户
Sn m = this.getOne(lambdaQueryWrapper);
if (StringUtils.isNull(m)) {
// System.out.println(ShiroUtils.getLoginName());
sn.setCreatedBy(ShiroUtils.getUser().getLoginName());
sn.setLastUpdatedBy(ShiroUtils.getLoginName());
this.save(sn);
successNum++;
successMsg.append("<br/>" + successNum + "、编码 " + sn.getCode() + " 导入成功");
}
} catch (Exception e) {
failureNum++;
String msg = "<br/>" + failureNum + "、编码" + sn.getCode() + " 导入失败：";
failureMsg.append(msg + e.getMessage());
log.error(msg, e);
}
}
if (failureNum > 0) {
failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
throw new BusinessException(failureMsg.toString());
} else {
successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
}
return successMsg.toString();
}
public List<Sn> getSnToLot(){
LambdaQueryWrapper<Sn> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(Sn::getSyncIot, 0);
lambdaQueryWrapper.orderByAsc(Sn::getId);
// lambdaQueryWrapper.last("limit 100");
// 验证是否存在这个用户
List<Sn> list = this.list(lambdaQueryWrapper);
return list;
}
}