|
@@ -195,10 +195,10 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
|
|
workService.updateOfflineStatus(param.getWorkId(), 3);
|
|
workService.updateOfflineStatus(param.getWorkId(), 3);
|
|
String ossUrl = fileStorageTemplate.calculateUrl(zipOssKey);
|
|
String ossUrl = fileStorageTemplate.calculateUrl(zipOssKey);
|
|
log.info("上传OSS完成,{}", ossUrl );
|
|
log.info("上传OSS完成,{}", ossUrl );
|
|
-// WorkOfflineDoneDTO workOfflineDoneDTO=new WorkOfflineDoneDTO();
|
|
|
|
-// workOfflineDoneDTO.setWorkId(workEntity.getId());
|
|
|
|
-// workOfflineDoneDTO.setUrl(ossUrl);
|
|
|
|
-// rabbitMqProducerUtil.sendByWorkQueue(workOfflineDoneQueue,workOfflineDoneDTO);
|
|
|
|
|
|
+ WorkOfflineDoneDTO workOfflineDoneDTO=new WorkOfflineDoneDTO();
|
|
|
|
+ workOfflineDoneDTO.setWorkId(workEntity.getId());
|
|
|
|
+ workOfflineDoneDTO.setUrl(ossUrl);
|
|
|
|
+ rabbitMqProducerUtil.sendByWorkQueue(workOfflineDoneQueue,workOfflineDoneDTO);
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|