|
|
@ -697,8 +697,13 @@ public class TaskDeliverService implements ITaskDeliverService { |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void deleteDeliver(Long currentUserId, Long deliverId, Long taskId) throws Exception { |
|
|
|
ProTaskDeliver deliver = taskDeliverDao.selectByPrimaryKey(deliverId); |
|
|
|
if(ObjectUtil.isNull(deliver)){ |
|
|
|
// ProTaskDeliver deliver = taskDeliverDao.selectByPrimaryKey(deliverId);
|
|
|
|
// if(ObjectUtil.isNull(deliver)){
|
|
|
|
// throw new BaseException(CodeEnum.NOT_DELIVER);
|
|
|
|
// }
|
|
|
|
|
|
|
|
ProTaskDeliverPostLog deliverPostLog = deliverPostLogDao.selectByPrimaryKey(deliverId); |
|
|
|
if(ObjectUtil.isNull(deliverPostLog)){ |
|
|
|
throw new BaseException(CodeEnum.NOT_DELIVER); |
|
|
|
} |
|
|
|
Long subTimeId = isTaskOrSubTime(taskId); |
|
|
@ -708,13 +713,13 @@ public class TaskDeliverService implements ITaskDeliverService { |
|
|
|
List<Long> userIdList = new ArrayList<>(); |
|
|
|
//同步锁,防止多个用户同时操作该数据
|
|
|
|
synchronized (this) { |
|
|
|
//查找此交付物与文件的中间表
|
|
|
|
ProTaskDeliverPostLogExample deliverPostLogExample = new ProTaskDeliverPostLogExample(); |
|
|
|
deliverPostLogExample.createCriteria().andDeliverIdEqualTo(deliverId).andTaskSubTimeIdEqualTo(subTimeId); |
|
|
|
List<ProTaskDeliverPostLog> deliverPostLogList = deliverPostLogDao.selectByExample(deliverPostLogExample); |
|
|
|
// //查找此交付物与文件的中间表
|
|
|
|
// ProTaskDeliverPostLogExample deliverPostLogExample = new ProTaskDeliverPostLogExample();
|
|
|
|
// deliverPostLogExample.createCriteria().andDeliverIdEqualTo(deliverId).andTaskSubTimeIdEqualTo(subTimeId);
|
|
|
|
// List<ProTaskDeliverPostLog> deliverPostLogList = deliverPostLogDao.selectByExample(deliverPostLogExample);
|
|
|
|
|
|
|
|
if (CollectionUtil.isNotEmpty(deliverPostLogList)) { |
|
|
|
for (ProTaskDeliverPostLog deliverPostLog : deliverPostLogList) { |
|
|
|
// if (ObjectUtil.isNotNull(deliverPostLog)) {
|
|
|
|
// for (ProTaskDeliverPostLog deliverPostLog : deliverPostLogList) {
|
|
|
|
if (currentUserId.longValue() == deliverPostLog.getUserId().longValue()) { |
|
|
|
if (deliverPostLog.getIsHistory() == 0) { |
|
|
|
deliverPostLog.setIsHistory(1); |
|
|
@ -732,8 +737,9 @@ public class TaskDeliverService implements ITaskDeliverService { |
|
|
|
} else { |
|
|
|
throw new BaseException("您无法删除别人上传的交付物"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
// }
|
|
|
|
// }
|
|
|
|
ProTaskDeliver deliver = taskDeliverDao.selectByPrimaryKey(deliverPostLog.getDeliverId()); |
|
|
|
deliver.setIsUpload(0); |
|
|
|
taskDeliverDao.updateByPrimaryKeySelective(deliver); |
|
|
|
|
|
|
@ -768,11 +774,6 @@ public class TaskDeliverService implements ITaskDeliverService { |
|
|
|
deleteMessage.setReceivers(messageUserList); |
|
|
|
rabbitTemplate.convertAndSend(RabbitMQConfig.RabbitMQ_QUEUE_NAME, |
|
|
|
JacksonUtil.beanToJson(deleteMessage)); |
|
|
|
// MessageRule messageRule = MessageRule.defaultRule(MessageConstant.DomainType.User);
|
|
|
|
// String s = JacksonUtil.beanToJson(deleteMessage);
|
|
|
|
// InMessage inMessage = InMessage.newToUserMessage(currentUserId.toString(),userIdSet,null,messageRule,s);
|
|
|
|
//
|
|
|
|
// messageService.sendDeliverMessageWithDelete(inMessage);
|
|
|
|
|
|
|
|
//用智能助手发送消息
|
|
|
|
robotService.deleteDeliverRobotSend(currentUserId,deliver.getName(),subTimeId); |
|
|
|