Commit 0b6b5dc1 authored by 陈祥烨's avatar 陈祥烨

删除、导出修改

parent c9a0abf1
...@@ -4,9 +4,11 @@ import com.alibaba.fastjson.JSON; ...@@ -4,9 +4,11 @@ import com.alibaba.fastjson.JSON;
import com.yeejoin.amos.api.tool.enums.SourceEnum; import com.yeejoin.amos.api.tool.enums.SourceEnum;
import com.yeejoin.amos.api.tool.face.model.DataBaseLinkModel; import com.yeejoin.amos.api.tool.face.model.DataBaseLinkModel;
import com.yeejoin.amos.api.tool.face.model.DataBaseNameListModel;
import com.yeejoin.amos.api.tool.face.model.RelationModel; import com.yeejoin.amos.api.tool.face.model.RelationModel;
import com.yeejoin.amos.api.tool.face.model.RelationTreeModel; import com.yeejoin.amos.api.tool.face.model.RelationTreeModel;
import com.yeejoin.amos.api.tool.face.orm.dao.RelationMapper; import com.yeejoin.amos.api.tool.face.orm.dao.RelationMapper;
import com.yeejoin.amos.api.tool.face.orm.entity.DataBaseNameList;
import com.yeejoin.amos.api.tool.face.orm.entity.Relation; import com.yeejoin.amos.api.tool.face.orm.entity.Relation;
import com.yeejoin.amos.api.tool.face.orm.entity.TableColumn; import com.yeejoin.amos.api.tool.face.orm.entity.TableColumn;
import com.yeejoin.amos.api.tool.utils.TableUtils; import com.yeejoin.amos.api.tool.utils.TableUtils;
...@@ -41,14 +43,16 @@ public class RelationService extends BaseService<RelationModel, Relation, Relati ...@@ -41,14 +43,16 @@ public class RelationService extends BaseService<RelationModel, Relation, Relati
@Autowired @Autowired
JdbcTemplate jdbcTemplate; JdbcTemplate jdbcTemplate;
@Autowired @Autowired
StudioResourceService studioResourceService; private DataBaseNameListService dataBaseNameListService;
/** /**
* 根据机构删除 * 根据机构删除
*/ */
public void deleteAgency(String agencyCode, String sequenceNbrs) throws Exception { public void deleteAgency(String agencyCode, String sequenceNbrs) throws Exception {
for (Long seq : (Long[]) ConvertUtils.convert(StringUtil.string2Array(sequenceNbrs), Long.class)) { for (Long seq : (Long[]) ConvertUtils.convert(StringUtil.string2Array(sequenceNbrs), Long.class)) {
DataBaseLinkModel model = dataBaseLinkService.queryBySeq(seq); DataBaseNameListModel nameListModel = dataBaseNameListService.queryBySeq(seq);
DataBaseLinkModel model = dataBaseLinkService.queryBySeq(nameListModel.getParentId());
model.setDbName(nameListModel.getDbName());
Connection connection = dataBaseLinkService.connectNewDatabase(model); Connection connection = dataBaseLinkService.connectNewDatabase(model);
this.deleteDataBase( this.deleteDataBase(
connection, agencyCode, model.getDbName()); connection, agencyCode, model.getDbName());
...@@ -60,7 +64,9 @@ public class RelationService extends BaseService<RelationModel, Relation, Relati ...@@ -60,7 +64,9 @@ public class RelationService extends BaseService<RelationModel, Relation, Relati
*/ */
public void outputAgency(String agencyCode, String sequenceNbrs, HttpServletResponse response) throws Exception { public void outputAgency(String agencyCode, String sequenceNbrs, HttpServletResponse response) throws Exception {
for (Long seq : (Long[]) ConvertUtils.convert(StringUtil.string2Array(sequenceNbrs), Long.class)) { for (Long seq : (Long[]) ConvertUtils.convert(StringUtil.string2Array(sequenceNbrs), Long.class)) {
DataBaseLinkModel model = dataBaseLinkService.queryBySeq(seq); DataBaseNameListModel nameListModel = dataBaseNameListService.queryBySeq(seq);
DataBaseLinkModel model = dataBaseLinkService.queryBySeq(nameListModel.getParentId());
model.setDbName(nameListModel.getDbName());
Connection connection = dataBaseLinkService.connectNewDatabase(model); Connection connection = dataBaseLinkService.connectNewDatabase(model);
this.insertData( this.insertData(
connection, agencyCode, model.getDbName(), response); connection, agencyCode, model.getDbName(), response);
......
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