wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3300) - 增加群聊重复创建的校验

Browse Source
This commit is contained in:
wangli 2025-02-21 14:45:20 +08:00
parent 547bb4e03f
commit cca98d43bc
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/service/impl/ChangeRecordServiceImpl.java
View File

@ -102,6 +102,7 @@ import cn.axzo.workflow.common.model.request.bpmn.task.BpmnTaskDelegateAssigner;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Assert;
import cn.hutool.core.lang.Pair; import cn.hutool.core.lang.Pair;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
@ -681,9 +682,8 @@ public class ChangeRecordServiceImpl extends ServiceImpl<ChangeRecordDao, Change
IM_GROUP_BIZ_INFO_VISA_TYPE, req.getType().name())); IM_GROUP_BIZ_INFO_VISA_TYPE, req.getType().name()));
GroupCreateResponse imGroup = msgCenterGateway.createImGroup(request); GroupCreateResponse imGroup = msgCenterGateway.createImGroup(request);
AssertUtil.notNull(imGroup, "IM 群创建失败"); AssertUtil.notNull(imGroup, "IM 群创建失败");
updateImInfo(visaId, imGroup); ChangeRecord visa = updateImInfo(visaId, imGroup);
ChangeRecord visa = changeRecordService.getById(visaId);
sendCardAndMsgToImGroup(ChangeRecordButtonOperationReq.builder() sendCardAndMsgToImGroup(ChangeRecordButtonOperationReq.builder()
.operatorPersonId(req.getOperatorPersonId()) .operatorPersonId(req.getOperatorPersonId())
.operatorOuId(req.getOperatorOuId()) .operatorOuId(req.getOperatorOuId())
@ -706,11 +706,12 @@ public class ChangeRecordServiceImpl extends ServiceImpl<ChangeRecordDao, Change
.build(); .build();
} }
private void updateImInfo(Long visaId, GroupCreateResponse imGroup) { private ChangeRecord updateImInfo(Long visaId, GroupCreateResponse imGroup) {
ChangeRecord changeRecord = new ChangeRecord(); ChangeRecord changeRecord = changeRecordService.getById(visaId);
changeRecord.setId(visaId); AssertUtil.isNull(changeRecord.getImGroupId(), "已创建群聊，请勿重复创建");
changeRecord.setImGroupId(imGroup.getTid()); changeRecord.setImGroupId(imGroup.getTid());
updateById(changeRecord); updateById(changeRecord);
return changeRecord;
} }
/** /**