| | |
| | | import org.dromara.common.satoken.utils.LoginHelper; |
| | | import org.dromara.system.domain.SysOss; |
| | | import org.dromara.system.domain.bo.SysOssBo; |
| | | import org.dromara.system.domain.properties.Boundary; |
| | | import org.dromara.system.domain.vo.SysOssVo; |
| | | import org.dromara.system.mapper.SysOssMapper; |
| | | import org.dromara.system.service.ISysOssService; |
| | |
| | | @Service |
| | | public class SysOssServiceImpl implements ISysOssService, OssService { |
| | | |
| | | private final Boundary boundary; |
| | | private final SysOssMapper baseMapper; |
| | | |
| | | @Override |
| | |
| | | //拼接同步信息 |
| | | SynchronousRequest request = new SynchronousRequest(); |
| | | request.setFile(file); |
| | | request.setPath(uploadResult.getFilename() + "123"); |
| | | request.setPath(uploadResult.getFilename() + "1"); |
| | | // request.setCreateTime(new Date()); |
| | | request.setPassword(oss.getPassword()); |
| | | request.setCreateBy(String.valueOf(oss.getCreateBy())); |
| | | request.setOssId(String.valueOf(oss.getOssId())); |
| | | // request.setOssId(String.valueOf(oss.getOssId())); |
| | | request.setOssId("12312312"); |
| | | post(request); |
| | | |
| | | SysOssVo sysOssVo = MapstructUtils.convert(oss, SysOssVo.class); |
| | |
| | | UploadResult uploadResult, String ossId, String password, |
| | | String createBy) { |
| | | SysOss oss = new SysOss(); |
| | | oss.setOssId(Long.valueOf(ossId.substring(0,ossId.length()-3) + "000")); |
| | | oss.setOssId(Long.valueOf(ossId)); |
| | | oss.setUrl(uploadResult.getUrl()); |
| | | oss.setFileSuffix(suffix); |
| | | oss.setFileName(uploadResult.getFilename()); |
| | |
| | | storage.delete(sysOss.getUrl()); |
| | | if(sysOss.getPassword().equals(password) || password.equals("000000")){ |
| | | baseMapper.deleteById(sysOss.getOssId()); |
| | | HttpUtils.sendDeleteRequest("http://192.168.3.43/resource/synchronization/delete",String.valueOf(sysOss.getOssId())); |
| | | HttpUtils.sendDeleteRequest(boundary.getLocalhost() + "/resource/synchronization/delete",String.valueOf(sysOss.getOssId())); |
| | | return true; |
| | | } |
| | | return false; |
| | |
| | | |
| | | private String post(SynchronousRequest request) throws IOException { |
| | | HashMap<String, String> headers = new HashMap<>(3); |
| | | String requestUrl = "http://192.168.3.43:8080/resource/synchronization/upload"; |
| | | String requestUrl = boundary.getLocalhost() + "/resource/synchronization/upload"; |
| | | ObjectMapper objectMapper = new ObjectMapper(); |
| | | String jsonString = ""; |
| | | try { |