Commit 58142a0f authored by 赵啸非's avatar 赵啸非

添加自定义导入

parent 6697fa3b
...@@ -2063,11 +2063,8 @@ public class MatterServiceImpl extends AbstractCRUDServiceImpl<MatterDao, Matter ...@@ -2063,11 +2063,8 @@ public class MatterServiceImpl extends AbstractCRUDServiceImpl<MatterDao, Matter
//内部先去重复 //内部先去重复
list = list.stream().distinct().collect(Collectors.toList()); list = list.stream().distinct().collect(Collectors.toList());
int SucessCount = 0; int SucessCount = 0;
int failCount = 0; int failCount = 0;
for (MatterCustomImportEntity matterCustomImportEntity : list) { for (MatterCustomImportEntity matterCustomImportEntity : list) {
if (ObjectUtils.isEmpty(matterCustomImportEntity.getAreaCode())) { if (ObjectUtils.isEmpty(matterCustomImportEntity.getAreaCode())) {
failCount++; failCount++;
continue; continue;
...@@ -2088,40 +2085,34 @@ public class MatterServiceImpl extends AbstractCRUDServiceImpl<MatterDao, Matter ...@@ -2088,40 +2085,34 @@ public class MatterServiceImpl extends AbstractCRUDServiceImpl<MatterDao, Matter
matterEntity.setCreateUserId(1L); matterEntity.setCreateUserId(1L);
this.save(matterEntity); this.save(matterEntity);
SiteEntity siteEntity = siteService.selectOne(new SiteQuery().areaCode(matterEntity.getAreaCode()));
if (ObjectUtils.isEmpty(siteEntity)) {
//创建一个本级站点
siteEntity = new SiteEntity();
siteEntity.initAttrValue();
siteEntity.setAreaCode(matterEntity.getAreaCode());
siteEntity.setAreaName(matterEntity.getAreaName());
siteEntity.setSiteName(matterEntity.getAreaName());
siteEntity.setCreateTime(new Date());
siteEntity.setCreateUserId(1L);
siteService.save(siteEntity);
}
//保存区域站点部门 //保存区域站点部门
DeptEntity deptEntity = deptService.selectOne(new DeptQuery().name(matterEntity.getDeptName())); DeptEntity deptEntity = deptService.selectOne(new DeptQuery().siteId(siteEntity.getId()).name(matterEntity.getDeptName()));
if (ObjectUtils.isEmpty(deptEntity)) { if (ObjectUtils.isEmpty(deptEntity)) {
deptEntity = new DeptEntity(); deptEntity = new DeptEntity();
deptEntity.initAttrValue(); deptEntity.initAttrValue();
deptEntity.setName(matterEntity.getDeptName()); deptEntity.setName(matterEntity.getDeptName());
deptEntity.setDeptNumber(RandomUtil.randomString(12)); deptEntity.setDeptNumber(RandomUtil.randomString(12));
deptEntity.setSiteId(siteEntity.getId());
SiteEntity siteEntity = siteService.selectOne(new SiteQuery().areaCode(matterEntity.getAreaCode()));
if (!ObjectUtils.isEmpty(siteEntity)) {
deptEntity.setSiteId(siteEntity.getId());
} else {
//创建一个本级站点
siteEntity = new SiteEntity();
siteEntity.initAttrValue();
siteEntity.setAreaCode(matterEntity.getAreaCode());
siteEntity.setAreaName(matterEntity.getAreaName());
siteEntity.setSiteName(matterEntity.getAreaName());
siteEntity.setCreateTime(new Date());
siteEntity.setCreateUserId(1L);
siteService.save(siteEntity);
deptEntity.setSiteId(siteEntity.getId());
}
deptEntity.setCreateTime(new Date()); deptEntity.setCreateTime(new Date());
deptEntity.setCreateUserId(1L); deptEntity.setCreateUserId(1L);
deptService.save(deptEntity); deptService.save(deptEntity);
matterEntity.setDeptCode(deptEntity.getDeptNumber()); matterEntity.setDeptCode(deptEntity.getDeptNumber());
this.update(matterEntity); this.update(matterEntity);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment