Commit 9d44daf8 by 墨竹

fix:增加转换判断

parent b73a6588
...@@ -368,6 +368,14 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA ...@@ -368,6 +368,14 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
serviceResponse.setMessage(corpName + "已经在转换中,请勿重复操作!"); serviceResponse.setMessage(corpName + "已经在转换中,请勿重复操作!");
return serviceResponse; return serviceResponse;
} }
Integer externalFlag = tabHaobanWxEnterprise.getExternalFlag();
if (externalFlag == 1 || externalFlag == 2) {
log.info("已经在转换成功或转换中,请勿重复操作:wxEnterpriseId:{}", wxEnterpriseId);
String corpName = tabHaobanWxEnterprise.getCorpName();
serviceResponse.setCode(HaoBanErrCodeCommon.ERR_0.getCode());
serviceResponse.setMessage(corpName + "已经在转换成功或转换中,请勿重复操作!");
return serviceResponse;
}
RedisUtil.lock(lockKey, 1L, TimeUnit.DAYS, 0L); RedisUtil.lock(lockKey, 1L, TimeUnit.DAYS, 0L);
try { try {
updateNewExUserId(tabHaobanWxEnterprise.getWxEnterpriseId(), tabHaobanWxEnterprise.getCorpid()); updateNewExUserId(tabHaobanWxEnterprise.getWxEnterpriseId(), tabHaobanWxEnterprise.getCorpid());
...@@ -454,9 +462,10 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA ...@@ -454,9 +462,10 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
} else { } else {
//失败 //失败
wxEnterriseMapper.updateExternalFlagById(3, wxEnterpriseId); wxEnterriseMapper.updateExternalFlagById(3, wxEnterpriseId);
externalUseridLogMapper.updateStatusFlagByWxEnterpriseId(0, wxEnterpriseId);
//回退老的 //回退老的
externalUseridLogMapper.updateOldExternalUserId(wxEnterpriseId); //externalUseridLogMapper.updateOldExternalUserId(wxEnterpriseId);
//更新状态为失败
externalUseridLogMapper.updateStatusFlagByWxEnterpriseId(0, wxEnterpriseId);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment