| | |
| | | package com.vci.web.service.impl; |
| | | |
| | | import com.vci.client.common.providers.ServiceProvider; |
| | | import com.vci.corba.common.VCIError; |
| | | import com.vci.corba.framework.data.PvolumeInfo; |
| | | import com.vci.corba.volume.VolumeServicePrx; |
| | | import com.vci.corba.volumn.method.VolumnManagement; |
| | | import com.vci.file.constant.VciFileDefaultValueConstant; |
| | | import com.vci.file.constant.VciFileLangCodeConstant; |
| | |
| | | if(vciFileObjectDO.getSecretGrade() == null) { |
| | | vciFileObjectDO.setSecretGrade(DataSecretEnum.NONE.getValue()); |
| | | } |
| | | revisionModelUtil.wrapperForAdd(vciFileObjectDO); |
| | | //todo 先写固定 |
| | | vciFileObjectDO.setCreator("admin"); |
| | | vciFileObjectDO.setLastModifier("admin"); |
| | | // revisionModelUtil.wrapperForAdd(vciFileObjectDO); |
| | | //随机路径 |
| | | String randomPath = VciBaseUtil.getPk(); |
| | | //目标文件 |
| | |
| | | } |
| | | }else if(VciFileTransProtocolEnum.CORBA.getValue().equalsIgnoreCase(vciFileVolumeDO.getTransProtocol())){ |
| | | String volumeName = vciFileVolumeDO.getName(); |
| | | VolumnManagement volumnCorbaService = null; |
| | | try { |
| | | volumnCorbaService = platformClientUtil.getVolumeService(vciFileVolumeDO.getServiceUrl(),volumeName).getVolumnService(); |
| | | } catch (VCIError vciError) { |
| | | throw new VciBaseException("没有获取到{}的卷服务",new String[]{volumeName},vciError); |
| | | } |
| | | VolumeServicePrx volumnCorbaService = null; |
| | | // volumnCorbaService = platformClientUtil.getVolumeService(vciFileVolumeDO.getServiceUrl(),volumeName).getVolumnService(); |
| | | volumnCorbaService = ServiceProvider.getVolumeService(volumeName); |
| | | // volumnCorbaService = volumeService; |
| | | InputStream in = null; |
| | | if("filePathField".equalsIgnoreCase(vciFileObjectDO.getFileDocClassify())){ |
| | | vciFileObjectDO.setFilePath(volumeName + ":/" + vciFileObjectDO.getFilePath() + "." + vciFileObjectDO.getFileExtension()); |
| | |
| | | volumnCorbaService.receiveFile(vciFileObjectDO.getFilePath(), buffer, temp, currentTime, fileSize); |
| | | }catch(IOException e){ |
| | | throw new VciBaseException("读取文件[" + vciFileObjectDO.getName() + "]出现了错误," + e.getMessage() ,new String[0],e); |
| | | }catch (VCIError e){ |
| | | throw new VciBaseException("传输文件[" + vciFileObjectDO.getName() + "]出现了错误," + e.getMessage() ,new String[0],e); |
| | | }catch(Exception e){ |
| | | throw new VciBaseException("处理上传文件[" + vciFileObjectDO.getName() + "]出现了错误," + e.getMessage() ,new String[0],e); |
| | | }finally { |