FT/foton-slrs-system-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

国内 清单bug修复

Browse Source
This commit is contained in:
yuezhihang
2022-06-23 14:35:46 +08:00
parent 6cd06641ca
commit 03b4ba0d1e
2 changed files with 74 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files
adc-da-slrs/src/main/java/com/adc/da/slrs/sarLawsDetailedList/entity/AddDetailedDto.java
+2
View File
@@ -42,4 +42,6 @@ public class AddDetailedDto {
private String inforlist2; private String inforlist2;
@ApiModelProperty(value = "新车型实施时间") @ApiModelProperty(value = "新车型实施时间")
private String inforlist3; private String inforlist3;
@ApiModelProperty(value = "适用认证")
private String inforlist4;
} }
adc-da-slrs/src/main/java/com/adc/da/slrs/sarLawsDetailedList/service/impl/SarLawsDetailedListServiceImpl.java
+41 -18
View File
@@ -323,30 +323,50 @@ public class SarLawsDetailedListServiceImpl extends ServiceImpl<SarLawsDetailedL
sarLawsDetailedListDao.insert(sarLawsDetailedList); sarLawsDetailedListDao.insert(sarLawsDetailedList);
if (addDetailedDto.getInforlist() != null) { if (addDetailedDto.getInforlist() != null) {
if (addDetailedDto.getInforlist().contains(",")) { if (addDetailedDto.getInforlist().contains(",")) {
String[] id = addDetailedDto.getInforlist().split(","); String[] id = new String[]{};
String[] putTime = addDetailedDto.getInforlist1().split(";"); String[] putTime = new String[]{};
String[] zcc = addDetailedDto.getInforlist2().split(";"); String[] zcc = new String[]{};
String[] xcx = addDetailedDto.getInforlist3().split(";"); String[] xcx = new String[]{};
String[] syrz = new String[]{};
if (StringUtils.isNotEmpty(addDetailedDto.getInforlist())) {
id = addDetailedDto.getInforlist().split(",");
}
if (StringUtils.isNotEmpty(addDetailedDto.getInforlist1())) {
putTime = addDetailedDto.getInforlist1().split(";");
}
if (StringUtils.isNotEmpty(addDetailedDto.getInforlist2())) {
zcc = addDetailedDto.getInforlist2().split(";");
}
if (StringUtils.isNotEmpty(addDetailedDto.getInforlist3())) {
xcx = addDetailedDto.getInforlist3().split(";");
}
if (StringUtils.isNotEmpty(addDetailedDto.getInforlist4())) {
syrz = addDetailedDto.getInforlist4().split(";");
}
for (int a = 0; a < id.length; a++) { for (int a = 0; a < id.length; a++) {
TimeDto dto = new TimeDto(); TimeDto dto = new TimeDto();
dto.setStandId(id[a]); dto.setStandId(id[a]);
//putTiem即ssrq可能为空 '' //putTiem即ssrq可能为空 ''
if (putTime.length > 0) {
if ("-".equals(putTime[a]) || null == putTime[a]) { if (putTime.length <= a) {
dto.setSsrq(null); dto.setSsrq(null);
} else { } else {
dto.setSsrq(putTime[a]); dto.setSsrq(putTime[a]);
} }
if ("-".equals(putTime[a]) || null == xcx[a]) { if (xcx.length <= a) {
dto.setXcxssrqgj(null); dto.setXcxssrqgj(null);
} else { } else {
dto.setXcxssrqgj(xcx[a]); dto.setXcxssrqgj(xcx[a]);
} }
if ("-".equals(putTime[a]) || null == zcc[a]) { if (zcc.length <= a) {
dto.setZccssrqgj(null); dto.setZccssrqgj(null);
} else { } else {
dto.setZccssrqgj(zcc[a]); dto.setZccssrqgj(zcc[a]);
} }
if (syrz.length <= a) {
dto.setSyrz(null);
} else {
dto.setSyrz(syrz[a]);
} }
timeDto.add(dto); timeDto.add(dto);
} }
@@ -356,22 +376,25 @@ public class SarLawsDetailedListServiceImpl extends ServiceImpl<SarLawsDetailedL
dto.setSsrq(addDetailedDto.getInforlist1()); dto.setSsrq(addDetailedDto.getInforlist1());
dto.setXcxssrqgj(addDetailedDto.getInforlist2()); dto.setXcxssrqgj(addDetailedDto.getInforlist2());
dto.setZccssrqgj(addDetailedDto.getInforlist3()); dto.setZccssrqgj(addDetailedDto.getInforlist3());
dto.setSyrz(addDetailedDto.getInforlist4());
timeDto.add(dto); timeDto.add(dto);
} }
} else { } else {
timeDto = null; timeDto = null;
} }
service.insertDetailedList(sarLawsDetailedList.getId(), timeDto); service.insertDetailedList(sarLawsDetailedList.getId(), timeDto);
if (null != timeDto) { List<String> list1 = new ArrayList<>();
List<SarStandardsInfo> sarStandardsInfos = new ArrayList<>(); List<String> list2 = new ArrayList<>();
timeDto.forEach(timeDto1 -> { //避免出现数据丢失 处理一下适用认证信息
SarStandardsInfo sarStandardsInfo = new SarStandardsInfo(); list1.addAll(Arrays.asList(addDetailedDto.getInforlist().split(",")));
sarStandardsInfo.setId(timeDto1.getStandId()); Hashtable<String, String> hashtable = new Hashtable<>();
sarStandardsInfo.setIsRelateAccess("1"); for (TimeDto dto:timeDto) {
sarStandardsInfos.add(sarStandardsInfo); if (StringUtils.isNotBlank(dto.getSyrz())) {
}); hashtable.put(dto.getStandId(), dto.getSyrz());
sarStandardsInfoService.updateBatchById(sarStandardsInfos);
} }
}
//下面写消息队列了开始
createUpdateMQService.sendMQ(hashtable, list2, list1);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
@@ -722,7 +745,7 @@ public class SarLawsDetailedListServiceImpl extends ServiceImpl<SarLawsDetailedL
if (list1.size() > 0) { if (list1.size() > 0) {
QueryWrapper<SarLawsAttrDetailedList> wrapper1 = new QueryWrapper<>(); QueryWrapper<SarLawsAttrDetailedList> wrapper1 = new QueryWrapper<>();
wrapper1.in("stand_id", list1); wrapper1.in("stand_id", list1);
List<SarLawsAttrDetailedList> res = sarLawsAttrDetailedListDao.selectList(wrapper); List<SarLawsAttrDetailedList> res = sarLawsAttrDetailedListDao.selectList(wrapper1);
if (res.size() > 0) { if (res.size() > 0) {
res.forEach(sarLawsAttrDetailedList -> { res.forEach(sarLawsAttrDetailedList -> {
dealWithHashTableData(list1, list2, hashtable, sarLawsAttrDetailedList); dealWithHashTableData(list1, list2, hashtable, sarLawsAttrDetailedList);