岗位同步代码提交

This commit is contained in:
zhal 2022-10-06 21:37:21 +08:00
parent 696794b294
commit 5614c61d8b
2 changed files with 62 additions and 40 deletions

View File

@ -88,7 +88,8 @@ public class SynchronousPortJob implements IJob {
Connection open = DBSql.open();
try {
orgdepartmentList = DBSql.getMaps(open, "select DEPARTMENTNAME,ID,LAYER,PARENTDEPARTMENTID,ORDERINDEX from ORGDEPARTMENT where Closed=0 ");
orgdepartmentList = DBSql.getMaps(open, "select DEPARTMENTNAME,ID,LAYER,PARENTDEPARTMENTID,ORDERINDEX from ORGDEPARTMENT where Closed=0 ");
RowMap parentModel=DBSql.getMap("SELECT ID FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLNAME='内蒙古伊利实业集团股份有限公司' and PLMETHODID='org.normal'");
String parentModelIds=null;
@ -189,7 +190,7 @@ public class SynchronousPortJob implements IJob {
String updateSql = "UPDATE APP_ACT_COE_PAL_REPOSITORY SET PLNAME=? WHERE ID=? AND PLMETHODID='org.normal'";
DBSql.update(conn, String.format(updateSql, org.getString("DEPARTMENTNAME"), orgrowMap.getString("ID")));
}
createPostData(model.getId(), org.getString("ID"), model, conn);
createPostData(model.getId(), org.getString("ID"), model, conn);
}
@ -259,17 +260,10 @@ public class SynchronousPortJob implements IJob {
Map<String, String> idRelationMap = new HashMap<>();
BaseModel defineModel = CoeDesignerAPIManager.getInstance().getDefinition(model.getId(), 0);
if (defineModel == null) {
defineModel = CoeDesignerUtil.createModel(model.getId(), 0);
defineModel.setCreateHistory(false);
}
String define = defineModel.getDefinition();
JSONObject definition = JSONObject.parseObject(define);
JSONObject elements = definition.getJSONObject("elements");
List<RowMap> orgdepartmentList = DBSql.getMaps(conn, "select DESCR from BO_EU_ORG_POSTS WHERE DEPTID=? AND DESCR IS NOT NULL ", departmentId);
List<RowMap> orgdepartmentList = DBSql.getMaps(conn, "select DESCR,DEPTNAME from BO_EU_ORG_POSTS WHERE DEPTID=? AND DESCR IS NOT NULL ", departmentId);
JSONArray shapes = new JSONArray();
@ -279,7 +273,7 @@ public class SynchronousPortJob implements IJob {
boolean flag=true;
String positionName = orgdepartmentList.get(i).getString("DESCR");
String deptname = orgdepartmentList.get(i).getString("DEPTNAME");
//新建一个uuid
String shapeId = UUIDGener.getObjectId();
//拿到基础结构
@ -290,51 +284,79 @@ public class SynchronousPortJob implements IJob {
PALRepositoryModel parentModel = PALRepositoryCache.getCache().get(uuid);
List<Map<String, Object>> fileElements = CoeDesignerUtil.getShapeMessageJson4(uuid);
System.out.println("name=============="+parentModel.getName());
try {
List<Map<String, Object>> fileElements = CoeDesignerUtil.getShapeMessageJson4(uuid);
for (Map<String, Object> shape2 : fileElements) {
List result = new ArrayList();
if (fileElements.size() > 0) {
for (Map<String, Object> shape2 : fileElements) {
List result = new ArrayList();
if(positionName.equals(shape2.get("name"))){
flag=false;
}
}
if (positionName.equals(shape2.get("name"))) {
flag = false;
}
}
if(flag==true){
if (flag == true) {
System.out.println("uuid==============="+uuid);
System.out.println("部门名称为=================" + deptname);
System.out.println("新建岗位为==================" + positionName);
JSONObject newShape = JSONObject.parseObject(shape.toString());
newShape.put("id", shapeId);
newShape.put("text", positionName);
shapes.add(newShape);
}
}else{
JSONObject newShape = JSONObject.parseObject(shape.toString());
newShape.put("id", shapeId);
newShape.put("text", positionName);
shapes.add(newShape);
CoeRepositoryImportUtil util = new CoeRepositoryImportUtil();
int maxZIndex = getMaxPropsZIndex(elements);// 层级
int initY = getMaxPositionY(elements);// 默认的纵向坐标
JSONArray newShapes = getMethodElementsJSONArray(shapes, 6, maxZIndex, initY);
JSONObject elementsJson = JSONObject.parseObject(definition.getString("elements"));
for (int k = 0; k < newShapes.size(); k++) {
JSONObject shapeObj = newShapes.getJSONObject(k);
elementsJson.put(shapeObj.getString("id"), shapeObj);
}
definition.put("elements", elementsJson);
// 设置画布大小
DiagramsUtil.setDiagramHeightWidth(definition, elements);
defineModel.setDefinition(definition.toString());
// 保存文件
CoeDesignerAPIManager.getInstance().storeDefinition(defineModel);// dao操作*/
}
} catch (Exception e) {
e.printStackTrace();
}
}
try {
if(shapes.size()>0){
CoeRepositoryImportUtil util = new CoeRepositoryImportUtil();
BaseModel defineModel = CoeDesignerAPIManager.getInstance().getDefinition(uuid, 0);
if (defineModel == null) {
defineModel = CoeDesignerUtil.createModel(uuid, 0);
defineModel.setCreateHistory(false);
}
String define = defineModel.getDefinition();
JSONObject definition = JSONObject.parseObject(define);
JSONObject elements = definition.getJSONObject("elements");
int maxZIndex = getMaxPropsZIndex(elements);// 层级
int initY = getMaxPositionY(elements);// 默认的纵向坐标
JSONArray newShapes = getMethodElementsJSONArray(shapes, 6, maxZIndex, initY);
JSONObject elementsJson = JSONObject.parseObject(definition.getString("elements"));
for (int k = 0; k < newShapes.size(); k++) {
JSONObject shapeObj = newShapes.getJSONObject(k);
elementsJson.put(shapeObj.getString("id"), shapeObj);
}
definition.put("elements", elementsJson);
// 设置画布大小
DiagramsUtil.setDiagramHeightWidth(definition, elements);
defineModel.setDefinition(definition.toString());
// 保存文件
CoeDesignerAPIManager.getInstance().storeDefinition(defineModel);// dao操作*/
}
} catch (Exception e) {
e.printStackTrace();
}
}