丽知:钉钉回调优化,防止重复回调

This commit is contained in:
zhengyf 2024-11-08 16:25:53 +08:00
parent 2fdd86ef4f
commit de751c32e1
1 changed files with 22 additions and 16 deletions

View File

@ -38,6 +38,7 @@ import java.util.stream.Collectors;
public class CallBackServiceImpl implements CallBackService { public class CallBackServiceImpl implements CallBackService {
protected static Logger logger = LogManager.getLogger(CallBackServiceImpl.class); protected static Logger logger = LogManager.getLogger(CallBackServiceImpl.class);
public String dingId="";
@Autowired @Autowired
private IDingU8cBillDao dingU8cBillDao; private IDingU8cBillDao dingU8cBillDao;
@ -77,6 +78,10 @@ public class CallBackServiceImpl implements CallBackService {
String eventType = eventJson.getString("EventType"); String eventType = eventJson.getString("EventType");
//防止钉钉回调
if(!eventJson.getString("processInstanceId").equals(dingId)) {
dingId = eventJson.getString("processInstanceId");
// 4. 根据EventType分类处理 // 4. 根据EventType分类处理
if (eventJson.getString("processCode") != null) { if (eventJson.getString("processCode") != null) {
switch (eventJson.getString("processCode")) { switch (eventJson.getString("processCode")) {
@ -94,6 +99,7 @@ public class CallBackServiceImpl implements CallBackService {
break; break;
} }
} }
}
// 5. 返回success的加密数据 // 5. 返回success的加密数据
Map<String, String> successMap = callbackCrypto.getEncryptedMap("success"); Map<String, String> successMap = callbackCrypto.getEncryptedMap("success");
@ -520,7 +526,7 @@ public class CallBackServiceImpl implements CallBackService {
//上传附件,获取附件的表单转base64上传u8c //上传附件,获取附件的表单转base64上传u8c
List<FileModuleVO> fileModuleVOList = JSONUtil.toList(fjJson, FileModuleVO.class); List<FileModuleVO> fileModuleVOList = JSONUtil.toList(fjJson, FileModuleVO.class);
List<SysFileVO> sysFileVOS = fileUtil.DingFileTransBase64(fileModuleVOList, processInstanceId, token); List<SysFileVO> sysFileVOS = fileUtil.DingFileTransBase64(fileModuleVOList, token, processInstanceId);
for (SysFileVO sysFileVO : sysFileVOS) { for (SysFileVO sysFileVO : sysFileVOS) {
//上传u8c单据 //上传u8c单据