liang.cheng
/
weaver-hrm-organization
2
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

职级职等导入更新

Browse Source
pull/53/head^2
‘ml’ 3 years ago
parent 33fe824cae
commit 1baf55e04f
1 changed files with 125 additions and 77 deletions
Show Stats Download Patch File Download Diff File

158
src/com/engine/organization/service/impl/ImportCommonServiceImpl.java
Unescape Escape View File

@ -1569,11 +1569,11 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
} }
map.put(infoPO.getFieldName(), reallyValue); map.put(infoPO.getFieldName(), reallyValue);
// 方案页校验 // 方案页校验
if ("scheme_no".equals(infoPO.getFieldName()) && s == 0) { if ("scheme_no".equals(infoPO.getFieldName()) && s == 0 && "add".equals(operateType)) {
List<SchemePO> schemePOS = MapperProxyFactory.getProxy(SchemeMapper.class).listByNo(Util.null2String(reallyValue)); List<SchemePO> schemePOS = MapperProxyFactory.getProxy(SchemeMapper.class).listByNo(Util.null2String(reallyValue));
if (schemePOS.size() > 0) { if (schemePOS.size() > 0) {
historyDetailPO.setOperateDetail("方案页导入：方案编号[" + reallyValue + "]与原有编号重复"); historyDetailPO.setOperateDetail("方案编号[" + reallyValue + "]与原有编号重复");
historyDetailPO.setRelatedName(cellValue); historyDetailPO.setRelatedName("方案页导入");
historyDetailPO.setStatus("0"); historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO); saveImportDetailLog(historyDetailPO);
continue nextRow; continue nextRow;
@ -1583,8 +1583,8 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
if ("scheme_no".equals(infoPO.getFieldName()) && s == 1) { if ("scheme_no".equals(infoPO.getFieldName()) && s == 1) {
List<SchemePO> schemePOS = MapperProxyFactory.getProxy(SchemeMapper.class).listByNo(Util.null2String(reallyValue)); List<SchemePO> schemePOS = MapperProxyFactory.getProxy(SchemeMapper.class).listByNo(Util.null2String(reallyValue));
if (schemePOS.size() == 0) { if (schemePOS.size() == 0) {
historyDetailPO.setOperateDetail("职等页导入：未找到编号为[" + reallyValue + "]的方案"); historyDetailPO.setOperateDetail("未找到编号为[" + reallyValue + "]的方案");
historyDetailPO.setRelatedName(cellValue); historyDetailPO.setRelatedName("职等页导入");
historyDetailPO.setStatus("0"); historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO); saveImportDetailLog(historyDetailPO);
continue nextRow; continue nextRow;
@ -1594,8 +1594,8 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
if ("scheme_no".equals(infoPO.getFieldName()) && s == 2) { if ("scheme_no".equals(infoPO.getFieldName()) && s == 2) {
List<SchemePO> schemePOS = MapperProxyFactory.getProxy(SchemeMapper.class).listByNo(Util.null2String(reallyValue)); List<SchemePO> schemePOS = MapperProxyFactory.getProxy(SchemeMapper.class).listByNo(Util.null2String(reallyValue));
if (schemePOS.size() == 0) { if (schemePOS.size() == 0) {
historyDetailPO.setOperateDetail("职级页导入：未找到编号为[" + reallyValue + "]的方案"); historyDetailPO.setOperateDetail("未找到编号为[" + reallyValue + "]的方案");
historyDetailPO.setRelatedName(cellValue); historyDetailPO.setRelatedName("职级页导入");
historyDetailPO.setStatus("0"); historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO); saveImportDetailLog(historyDetailPO);
continue nextRow; continue nextRow;
@ -1607,8 +1607,8 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
for (int index = 0; index < split.length - 1; index++) { for (int index = 0; index < split.length - 1; index++) {
List<LevelPO> levelPOS = MapperProxyFactory.getProxy(LevelMapper.class).listByNo(split[index]); List<LevelPO> levelPOS = MapperProxyFactory.getProxy(LevelMapper.class).listByNo(split[index]);
if (levelPOS.size() == 0) { if (levelPOS.size() == 0) {
historyDetailPO.setOperateDetail("职级页导入：未找到编号为[" + reallyValue + "]的职等"); historyDetailPO.setOperateDetail("未找到编号为[" + reallyValue + "]的职等");
historyDetailPO.setRelatedName(cellValue); historyDetailPO.setRelatedName("职级页导入");
historyDetailPO.setStatus("0"); historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO); saveImportDetailLog(historyDetailPO);
continue nextRow; continue nextRow;
@ -1670,6 +1670,12 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
levelPO.setUpdateTime((Date) map.get("update_time")); levelPO.setUpdateTime((Date) map.get("update_time"));
MapperProxyFactory.getProxy(LevelMapper.class).insertIgnoreNull(levelPO); MapperProxyFactory.getProxy(LevelMapper.class).insertIgnoreNull(levelPO);
} }
} else {
historyDetailPO.setRelatedName("职等页导入");
historyDetailPO.setOperateDetail("未找到编号为[" + schemeNo + "]的方案");
historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO);
continue nextRow;
} }
} else if (s == 2) { } else if (s == 2) {
String gradeNo = (String) map.get("grade_no"); String gradeNo = (String) map.get("grade_no");
@ -1677,14 +1683,27 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
String levelNo = (String) map.get("level_no"); String levelNo = (String) map.get("level_no");
schemeNew = MapperProxyFactory.getProxy(SchemeMapper.class).getSchemeByNo(schemeNo); schemeNew = MapperProxyFactory.getProxy(SchemeMapper.class).getSchemeByNo(schemeNo);
if (schemeNew == null) {
historyDetailPO.setRelatedName("职级页导入");
historyDetailPO.setOperateDetail("未找到编号为[" + schemeNo + "]的方案");
historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO);
continue nextRow;
}
gradeNew = MapperProxyFactory.getProxy(GradeMapper.class).getGradeByNoAndSid(gradeNo, schemeNew.getId()); gradeNew = MapperProxyFactory.getProxy(GradeMapper.class).getGradeByNoAndSid(gradeNo, schemeNew.getId());
if (gradeNew == null) {
historyDetailPO.setRelatedName("职级页导入");
historyDetailPO.setOperateDetail("未找到编号为[" + schemeNo + "]的职等");
historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO);
continue nextRow;
}
gradePO.setGradeNo(gradeNo); gradePO.setGradeNo(gradeNo);
gradePO.setGradeName((String) map.get("grade_name")); gradePO.setGradeName((String) map.get("grade_name"));
gradePO.setDescription((String) map.get("grade_description")); gradePO.setDescription((String) map.get("grade_description"));
// 关联方案id // 关联方案id
gradePO.setSchemeId(schemeNew.getId()); gradePO.setSchemeId(schemeNew.getId());
// 关联职等id
gradePO.setGradeNo((String) map.get("grade_no")); gradePO.setGradeNo((String) map.get("grade_no"));
gradePO.setForbiddenTag((int) map.get("forbidden_tag")); gradePO.setForbiddenTag((int) map.get("forbidden_tag"));
gradePO.setIsUsed(1); gradePO.setIsUsed(1);
@ -1697,20 +1716,21 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
if (split.length > 0) { if (split.length > 0) {
for (int index = 0; index < split.length; index++) { for (int index = 0; index < split.length; index++) {
levelNew = MapperProxyFactory.getProxy(LevelMapper.class).getLevelByNoAndSid(split[index], schemeNew.getId()); levelNew = MapperProxyFactory.getProxy(LevelMapper.class).getLevelByNoAndSid(split[index], schemeNew.getId());
if(levelIds!=null){ if (levelIds != null) {
levelIds = levelIds+ "," +levelNew.getId(); levelIds = levelIds + "," + levelNew.getId();
}else { } else {
levelIds = String.valueOf(levelNew.getId()); levelIds = String.valueOf(levelNew.getId());
} }
} }
} }
if (gradeNew != null) { if (gradeNew != null) {
historyDetailPO.setRelatedName("职级编号"); historyDetailPO.setRelatedName("职级页导入");
historyDetailPO.setOperateDetail("职级页导入:同一方案[" + schemeNo + "]下，职级编号不可重复"); historyDetailPO.setOperateDetail("同一方案[" + schemeNo + "]下，职级编号不可重复");
historyDetailPO.setStatus("0"); historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO); saveImportDetailLog(historyDetailPO);
continue nextRow; continue nextRow;
}else{ } else {
// 关联职等id
gradePO.setLevelId(levelIds); gradePO.setLevelId(levelIds);
MapperProxyFactory.getProxy(GradeMapper.class).insertIgnoreNull(gradePO); MapperProxyFactory.getProxy(GradeMapper.class).insertIgnoreNull(gradePO);
} }
@ -1720,31 +1740,27 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
historyDetailPO.setStatus("1"); historyDetailPO.setStatus("1");
saveImportDetailLog(historyDetailPO); saveImportDetailLog(historyDetailPO);
} else if ("update".equals(operateType)) { } else if ("update".equals(operateType)) {
if (s == 0) {
schemeNew = MapperProxyFactory.getProxy(SchemeMapper.class).getSchemeByNo((String) map.get("scheme_no")); schemeNew = MapperProxyFactory.getProxy(SchemeMapper.class).getSchemeByNo((String) map.get("scheme_no"));
if (schemeNew != null) { if (schemeNew != null) {
schemeNew.setSchemeNo((String) map.get("scheme_no"));
schemeNew.setSchemeName((String) map.get("scheme_name")); schemeNew.setSchemeName((String) map.get("scheme_name"));
schemeNew.setSchemeDescription((String) map.get("scheme_description")); schemeNew.setSchemeDescription((String) map.get("scheme_description"));
schemeNew.setUpdateTime((Date) map.get("update_time")); schemeNew.setUpdateTime((Date) map.get("update_time"));
MapperProxyFactory.getProxy(SchemeMapper.class).updateScheme(schemeNew); MapperProxyFactory.getProxy(SchemeMapper.class).updateScheme(schemeNew);
} else { } else {
schemeNew.setSchemeNo((String) map.get("scheme_no")); historyDetailPO.setRelatedName("方案更新");
schemeNew.setSchemeName((String) map.get("scheme_name")); historyDetailPO.setOperateDetail("未找到编号为[" + map.get("scheme_no") + "]的方案");
schemeNew.setSchemeDescription((String) map.get("scheme_description")); historyDetailPO.setStatus("0");
schemeNew.setForbiddenTag((int) map.get("forbidden_tag")); saveImportDetailLog(historyDetailPO);
schemeNew.setIsUsed(1); continue nextRow;
schemeNew.setCreator((long) user.getUID());
schemeNew.setDeleteType((int) map.get("delete_type"));
schemeNew.setCreateTime((Date) map.get("create_time"));
schemeNew.setUpdateTime((Date) map.get("update_time"));
MapperProxyFactory.getProxy(SchemeMapper.class).insertIgnoreNull(schemeNew);
} }
} else if (s == 1) {
//查询职等信息 String schemeNo = (String) map.get("scheme_no");
schemeNew = MapperProxyFactory.getProxy(SchemeMapper.class).getSchemeByNo((String) map.get("scheme_no")); String levelNo = (String) map.get("level_no");
levelNew = MapperProxyFactory.getProxy(LevelMapper.class).getLevelByNoAndSid((String) map.get("level_no"), schemeNew.getId()); schemeNew = MapperProxyFactory.getProxy(SchemeMapper.class).getSchemeByNo(schemeNo);
if (schemeNew != null) {
levelNew = MapperProxyFactory.getProxy(LevelMapper.class).getLevelByNoAndSid(levelNo, schemeNew.getId());
if (levelNew != null) { if (levelNew != null) {
levelNew.setLevelNo((String) map.get("level_no"));
levelNew.setLevelName((String) map.get("level_name")); levelNew.setLevelName((String) map.get("level_name"));
levelNew.setDescription((String) map.get("level_description")); levelNew.setDescription((String) map.get("level_description"));
//关联方案id //关联方案id
@ -1752,39 +1768,71 @@ public class ImportCommonServiceImpl extends Service implements ImportCommonServ
levelNew.setUpdateTime((Date) map.get("update_time")); levelNew.setUpdateTime((Date) map.get("update_time"));
MapperProxyFactory.getProxy(LevelMapper.class).updateLevel(levelNew); MapperProxyFactory.getProxy(LevelMapper.class).updateLevel(levelNew);
} else { } else {
levelNew.setLevelNo((String) map.get("level_no")); historyDetailPO.setRelatedName("职等页更新");
levelNew.setLevelName((String) map.get("level_name")); historyDetailPO.setOperateDetail("未找到编号为[" + schemeNo + "]的方案");
levelNew.setDescription((String) map.get("level_description")); historyDetailPO.setStatus("0");
//关联方案id saveImportDetailLog(historyDetailPO);
levelNew.setSchemeId(schemeNew.getId()); continue nextRow;
levelNew.setForbiddenTag((int) map.get("forbidden_tag")); }
levelNew.setIsUsed(1); } else {
levelNew.setCreator((long) user.getUID()); historyDetailPO.setRelatedName("职等页更新");
levelNew.setDeleteType((int) map.get("delete_type")); historyDetailPO.setOperateDetail("未找到编号为[" + schemeNo + "]的方案，无法更新");
levelNew.setCreateTime((Date) map.get("create_time")); historyDetailPO.setStatus("0");
levelNew.setUpdateTime((Date) map.get("update_time")); saveImportDetailLog(historyDetailPO);
MapperProxyFactory.getProxy(LevelMapper.class).insertIgnoreNull(levelNew); continue nextRow;
}
} else if (s == 2) {
String gradeNo = (String) map.get("grade_no");
String schemeNo = (String) map.get("scheme_no");
String levelNo = (String) map.get("level_no");
schemeNew = MapperProxyFactory.getProxy(SchemeMapper.class).getSchemeByNo(schemeNo);
if (schemeNew == null) {
historyDetailPO.setRelatedName("职级页更新");
historyDetailPO.setOperateDetail("未找到编号为[" + schemeNo + "]的方案");
historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO);
continue nextRow;
}
gradeNew = MapperProxyFactory.getProxy(GradeMapper.class).getGradeByNoAndSid(gradeNo, schemeNew.getId());
if (gradeNew == null) {
historyDetailPO.setRelatedName("职级页更新");
historyDetailPO.setOperateDetail("未找到编号为[" + schemeNo + "]的职等");
historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO);
continue nextRow;
} }
gradeNew = MapperProxyFactory.getProxy(GradeMapper.class).getGradeByNoAndSid((String) map.get("grade_no"), schemeNew.getId()); String[] split = levelNo.split(",");
String levelIds = null;
if (split.length > 0) {
for (int index = 0; index < split.length; index++) {
levelNew = MapperProxyFactory.getProxy(LevelMapper.class).getLevelByNoAndSid(split[index], schemeNew.getId());
if (levelIds != null) {
levelIds = levelIds + "," + levelNew.getId();
} else {
levelIds = String.valueOf(levelNew.getId());
}
}
}
if (gradeNew != null) { if (gradeNew != null) {
gradeNew.setGradeNo((String) map.get("grade_no")); gradeNew.setSchemeId(schemeNew.getId());
gradeNew.setGradeName((String) map.get("grade_name")); gradeNew.setGradeName((String) map.get("grade_name"));
gradeNew.setDescription((String) map.get("grade_description")); gradeNew.setDescription((String) map.get("grade_description"));
// 关联方案id
gradeNew.setSchemeId(schemeNew.getId());
// 关联职等id // 关联职等id
gradeNew.setLevelId(String.valueOf(levelNew.getId())); gradeNew.setLevelId(levelIds);
gradeNew.setUpdateTime((Date) map.get("update_time")); gradeNew.setUpdateTime((Date) map.get("update_time"));
GradePO gradePOTmp = MapperProxyFactory.getProxy(GradeMapper.class).getGradeByID(gradeNew.getId());
if (gradePOTmp != null) {
MapperProxyFactory.getProxy(GradeMapper.class).updateGrade(gradeNew); MapperProxyFactory.getProxy(GradeMapper.class).updateGrade(gradeNew);
}
} else { } else {
MapperProxyFactory.getProxy(GradeMapper.class).insertIgnoreNull(gradePO); historyDetailPO.setRelatedName("职级页更新");
historyDetailPO.setOperateDetail("未找到编号[" + schemeNo + "]的职级，无法更新");
historyDetailPO.setStatus("0");
saveImportDetailLog(historyDetailPO);
continue nextRow;
}
} }
historyDetailPO.setOperateDetail("更新成功");
historyDetailPO.setStatus("1");
saveImportDetailLog(historyDetailPO);
} }
} }

Write Preview
Loading…
Cancel
Save