|
|
@@ -1,5 +1,6 @@
|
|
|
package com.goer.project.model.modelEntity.controller;
|
|
|
|
|
|
+import java.io.File;
|
|
|
import java.util.*;
|
|
|
|
|
|
import com.goer.common.chiner.model.TableEntity;
|
|
|
@@ -212,10 +213,33 @@ public class ModelEntityController extends BaseController
|
|
|
@GetMapping("/importTable/{projectId}")
|
|
|
public String importTable(@PathVariable("projectId") Long projectId, ModelMap mmap)
|
|
|
{
|
|
|
- ModelProject modelProject = modelProjectService.selectModelProjectById(projectId);
|
|
|
- mmap.put("modelProject", modelProject);
|
|
|
-// ModelDbs modelDbs = modelDbsService.selectDefaultDbByProjectId(projectId);
|
|
|
-// mmap.put("modelDbs", modelDbs);
|
|
|
+ ModelDbs modelDbs = new ModelDbs();
|
|
|
+ modelDbs.setProjectId(projectId);
|
|
|
+ List<ModelDbs> list = modelDbsService.selectModelDbsList(modelDbs);
|
|
|
+ for (Iterator<ModelDbs> iterator = list.listIterator(); iterator.hasNext();) {
|
|
|
+ ModelDbs next = iterator.next();
|
|
|
+ if("Y".equalsIgnoreCase(next.getDefaultDb())) {
|
|
|
+ modelDbs = next;
|
|
|
+ iterator.remove();
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ list.sort(Comparator.comparing(ModelDbs::getId));
|
|
|
+ list.add(0, modelDbs);
|
|
|
+
|
|
|
+// Collections.sort(list,new Comparator<ModelDbs>(){
|
|
|
+// @Override
|
|
|
+// public int compare(ModelDbs m1,ModelDbs m2){
|
|
|
+// int i = m1.getDefaultDb().compareTo(m2.getDefaultDb());
|
|
|
+// if(i != 0) {
|
|
|
+// return i;
|
|
|
+// }
|
|
|
+// return Long.compare(m1.getId(), m2.getId().longValue());
|
|
|
+// }
|
|
|
+// });
|
|
|
+ mmap.put("projectId", projectId);
|
|
|
+ mmap.put("modelDbs", list);
|
|
|
+
|
|
|
return prefix + "/importTable";
|
|
|
}
|
|
|
|
|
|
@@ -225,33 +249,38 @@ public class ModelEntityController extends BaseController
|
|
|
@RequiresPermissions("model:modelEntity:list")
|
|
|
@PostMapping("/db/list")
|
|
|
@ResponseBody
|
|
|
- public TableDataInfo dataList(ModelEntity modelEntity){
|
|
|
- ModelDbs modelDbs = modelDbsService.selectDefaultDbByProjectId(modelEntity.getProjectId());
|
|
|
+ public TableDataInfo dataList(ModelDbs modelDbs){
|
|
|
+ ModelDbs dbs = modelDbsService.selectModelDbsById(modelDbs.getId());
|
|
|
DBReverseGetAllTablesListImpl reverse = new DBReverseGetAllTablesListImpl();
|
|
|
Map<String, String> argsMap = new HashMap<String, String>();
|
|
|
- argsMap.put(AbstractDBCommand.KEY_DRIVER_CLASS_NAME,modelDbs.getDriverClassName());
|
|
|
- argsMap.put(AbstractDBCommand.KEY_URL,modelDbs.getUrl());
|
|
|
- argsMap.put(AbstractDBCommand.KEY_USERNAME,modelDbs.getUserName());
|
|
|
- argsMap.put(AbstractDBCommand.KEY_PASSWORD,modelDbs.getPassword());
|
|
|
+ argsMap.put(AbstractDBCommand.KEY_DRIVER_CLASS_NAME,dbs.getDriverClassName());
|
|
|
+ argsMap.put(AbstractDBCommand.KEY_URL,dbs.getUrl());
|
|
|
+ argsMap.put(AbstractDBCommand.KEY_USERNAME,dbs.getUserName());
|
|
|
+ argsMap.put(AbstractDBCommand.KEY_PASSWORD,dbs.getPassword());
|
|
|
ExecResult ret = reverse.exec(argsMap);
|
|
|
List<TableEntity> listTable = (List<TableEntity>)ret.getBody();
|
|
|
|
|
|
- modelEntity.setVersionId(0L);
|
|
|
- List<ModelEntity> listEntity = modelEntityService.selectModelEntityList(modelEntity);
|
|
|
List<ModelEntity> retList = new ArrayList<>();
|
|
|
- for(TableEntity t : listTable) {
|
|
|
- boolean existFlag = false;
|
|
|
- for(ModelEntity m : listEntity) {
|
|
|
- if(t.getDefKey().equalsIgnoreCase(m.getEntityCode())) {
|
|
|
- existFlag = true;
|
|
|
- break;
|
|
|
+ if(listTable != null && listTable.size() >0) {
|
|
|
+ ModelEntity modelEntity = new ModelEntity();
|
|
|
+ modelEntity.setProjectId(modelDbs.getProjectId());
|
|
|
+ modelEntity.setVersionId(0L);
|
|
|
+ List<ModelEntity> listEntity = modelEntityService.selectModelEntityList(modelEntity);
|
|
|
+
|
|
|
+ for (TableEntity t : listTable) {
|
|
|
+ boolean existFlag = false;
|
|
|
+ for (ModelEntity m : listEntity) {
|
|
|
+ if (t.getDefKey().equalsIgnoreCase(m.getEntityCode())) {
|
|
|
+ existFlag = true;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (!existFlag) {
|
|
|
+ ModelEntity ne = new ModelEntity();
|
|
|
+ ne.setEntityCode(t.getDefKey());
|
|
|
+ ne.setEntityName(t.getDefName());
|
|
|
+ retList.add(ne);
|
|
|
}
|
|
|
- }
|
|
|
- if(!existFlag) {
|
|
|
- ModelEntity ne = new ModelEntity();
|
|
|
- ne.setEntityCode(t.getDefKey());
|
|
|
- ne.setEntityName(t.getDefName());
|
|
|
- retList.add(ne);
|
|
|
}
|
|
|
}
|
|
|
return getDataTable(retList);
|