|
|
|
|
@ -1,20 +1,29 @@
|
|
|
|
|
package com.fr.start.module; |
|
|
|
|
|
|
|
|
|
import com.fr.base.FRContext; |
|
|
|
|
import com.fr.base.ModifiedTable; |
|
|
|
|
import com.fr.base.Parameter; |
|
|
|
|
import com.fr.base.StoreProcedureParameter; |
|
|
|
|
import com.fr.base.TableData; |
|
|
|
|
import com.fr.base.env.serializer.OldSerializerAdapter; |
|
|
|
|
import com.fr.base.env.serializer.ProcedureDataModelSerializer; |
|
|
|
|
import com.fr.base.env.user.RemoteUserCenter; |
|
|
|
|
import com.fr.core.env.operator.user.UserCenter; |
|
|
|
|
import com.fr.core.env.EnvConfig; |
|
|
|
|
import com.fr.core.env.EnvEvent; |
|
|
|
|
import com.fr.core.env.proxy.EnvProxy; |
|
|
|
|
import com.fr.core.env.resource.EnvConfigUtils; |
|
|
|
|
import com.fr.core.env.resource.LocalEnvConfig; |
|
|
|
|
import com.fr.core.env.resource.RemoteEnvConfig; |
|
|
|
|
import com.fr.data.core.db.TableProcedure; |
|
|
|
|
import com.fr.data.impl.Connection; |
|
|
|
|
import com.fr.data.impl.storeproc.ProcedureDataModel; |
|
|
|
|
import com.fr.data.impl.storeproc.StoreProcedure; |
|
|
|
|
import com.fr.dav.DavXMLUtils; |
|
|
|
|
import com.fr.dav.LocalEnv; |
|
|
|
|
import com.fr.design.DesignerEnvManager; |
|
|
|
|
import com.fr.env.RemoteEnv; |
|
|
|
|
import com.fr.event.Event; |
|
|
|
|
import com.fr.event.EventDispatcher; |
|
|
|
|
import com.fr.event.Listener; |
|
|
|
|
import com.fr.file.filetree.FileNode; |
|
|
|
|
import com.fr.general.ComparatorUtils; |
|
|
|
|
import com.fr.module.Activator; |
|
|
|
|
@ -44,181 +53,190 @@ public class DesignerEnvProvider extends Activator {
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
initDesignerEnv(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
getRoot().setSingleton(EnvSwitcher.class, new EnvSwitcher()); |
|
|
|
|
//设置好环境即可，具体跟环境有关的模块会自动调用
|
|
|
|
|
getRoot().getSingleton(EnvSwitcher.class).switch2LastEnv(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private void initDesignerEnv() { |
|
|
|
|
|
|
|
|
|
addSerializers(); |
|
|
|
|
EnvProxy.addRemoteService(UserCenter.class, new RemoteUserCenter()); |
|
|
|
|
EventDispatcher.listen(EnvEvent.BEFORE_SIGN_IN, new Listener<EnvConfig>() { |
|
|
|
|
@Override |
|
|
|
|
public void on(Event event, EnvConfig envConfig) { |
|
|
|
|
if (envConfig instanceof RemoteEnvConfig) { |
|
|
|
|
RemoteEnv remoteEnv = new RemoteEnv(envConfig.getPath(), EnvConfigUtils.getUsername(envConfig), EnvConfigUtils.getPassword(envConfig)); |
|
|
|
|
FRContext.setCurrentEnv(remoteEnv); |
|
|
|
|
} else if (envConfig instanceof LocalEnvConfig) { |
|
|
|
|
FRContext.setCurrentEnv(new LocalEnv()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private void addSerializers() { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(ProcedureDataModel[].class, new ProcedureDataModelSerializer()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(ModifiedTable.class, new OldSerializerAdapter<ModifiedTable>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<ModifiedTable>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(ModifiedTable obj, OutputStream out) throws Exception { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLModifiedTables(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<ModifiedTable>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public ModifiedTable deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLModifiedTables(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<ModifiedTable>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(ModifiedTable obj, OutputStream out) throws Exception { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLModifiedTables(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<ModifiedTable>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public ModifiedTable deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLModifiedTables(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(com.fr.data.impl.Connection.class, new OldSerializerAdapter<com.fr.data.impl.Connection>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<Connection>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(Connection obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileDatabaseConnection(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<Connection>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public Connection deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLDatabaseConnection(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<Connection>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(Connection obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileDatabaseConnection(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<Connection>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public Connection deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLDatabaseConnection(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(FileNode[].class, new OldSerializerAdapter<FileNode[]>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<FileNode[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(FileNode[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileNodes(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<FileNode[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public FileNode[] deserializer(InputStream in) { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLFileNodes(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<FileNode[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(FileNode[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileNodes(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<FileNode[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public FileNode[] deserializer(InputStream in) { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLFileNodes(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(TableProcedure[].class, new OldSerializerAdapter<TableProcedure[]>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<TableProcedure[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(TableProcedure[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileSQLTable(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<TableProcedure[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public TableProcedure[] deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLSQLTables(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<TableProcedure[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(TableProcedure[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileSQLTable(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<TableProcedure[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public TableProcedure[] deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLSQLTables(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(TableData.class, new OldSerializerAdapter<TableData>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<TableData>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(TableData obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileTableData(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<TableData>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public TableData deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLTableData(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<TableData>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(TableData obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileTableData(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<TableData>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public TableData deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLTableData(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(Parameter[].class, new OldSerializerAdapter<Parameter[]>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<Parameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(Parameter[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileParameters(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<Parameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public Parameter[] deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLParameters(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<Parameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(Parameter[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileParameters(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<Parameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public Parameter[] deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLParameters(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(StoreProcedure.class, new OldSerializerAdapter<StoreProcedure>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<StoreProcedure>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(StoreProcedure obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileStoreProcedure(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<StoreProcedure>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public StoreProcedure deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLStoreProcedure(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<StoreProcedure>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(StoreProcedure obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileStoreProcedure(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<StoreProcedure>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public StoreProcedure deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLStoreProcedure(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EnvProxy.addSerializer(StoreProcedureParameter[].class, new OldSerializerAdapter<StoreProcedureParameter[]>( |
|
|
|
|
new OldSerializerAdapter.OldSerializer<StoreProcedureParameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(StoreProcedureParameter[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileParameters(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<StoreProcedureParameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public StoreProcedureParameter[] deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLStoreProcedureParameters(in); |
|
|
|
|
new OldSerializerAdapter.OldSerializer<StoreProcedureParameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void serializer(StoreProcedureParameter[] obj, OutputStream out) { |
|
|
|
|
|
|
|
|
|
DavXMLUtils.writeXMLFileParameters(obj, out); |
|
|
|
|
} |
|
|
|
|
}, |
|
|
|
|
new OldSerializerAdapter.OldDeserializer<StoreProcedureParameter[]>() { |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public StoreProcedureParameter[] deserializer(InputStream in) throws Exception { |
|
|
|
|
|
|
|
|
|
return DavXMLUtils.readXMLStoreProcedureParameters(in); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void stop() { |
|
|
|
|
//清空模块
|
|
|
|
|
getRoot().removeSingleton(EnvSwitcher.class); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
hzzz
6 years ago