Commit 34662b8e by fudahua

同步优化初步3-同步成员重试

parent 4c0a2643
...@@ -78,7 +78,7 @@ public class ClerkSyncOperation implements BaseSyncOperation { ...@@ -78,7 +78,7 @@ public class ClerkSyncOperation implements BaseSyncOperation {
@Override @Override
public void dealSingleByMq(DealParamMqDTO dealParamMqDTO, TabHaobanPreDealLog dataPre) { public void dealSingleByMq(DealParamMqDTO dealParamMqDTO, TabHaobanPreDealLog dataPre) {
logger.info("成员处理:{}", JSONObject.toJSONString(dealParamMqDTO)); logger.info("成员处理:{}", JSONObject.toJSONString(dealParamMqDTO));
ClerkDTO clerkDTO = clerkService.getClerkByClerkId(dealParamMqDTO.getData()); ClerkDTO clerkDTO = clerkService.getClerkByClerkIdNoStatus(dealParamMqDTO.getData());
boolean dealFlag = true; boolean dealFlag = true;
if (clerkDTO == null) { if (clerkDTO == null) {
logger.info("成员不存在:t:{},d:{}", dealParamMqDTO.getTaskId(), dealParamMqDTO.getData()); logger.info("成员不存在:t:{},d:{}", dealParamMqDTO.getTaskId(), dealParamMqDTO.getData());
......
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