Commit 08a1aa4b by qwmqiuwenmin

fix

parent 191a04ee
......@@ -150,7 +150,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
} else if(dataPre.getDataType().equals(PreDealTypeEnum.friend_merge.getVal())){
operationMap.get("friendMergeSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
logger.info("好友处理:{}", params);
logger.info("好友合并处理:{}", params);
} else {
logger.info("不是正常数据:{}", params);
......
......@@ -32,6 +32,8 @@ public class FriendMergeSyncOperation implements BaseSyncOperation{
String res = memberUnionidRelatedApiService.addExternal(pojo);
if(StringUtils.isBlank(res)){
dealSuccess(dealParamMqDTO.getTaskId(), dataPre.getDataId(), null, null);
}else{
dealException(dealParamMqDTO.getTaskId(), dealParamMqDTO.getData(), dataPre.getEnterpriseId(), "好友不存在");
}
} catch (Exception e) {
e.printStackTrace();
......
......@@ -86,6 +86,7 @@ public class FriendSyncOperation implements BaseSyncOperation {
pojo.setEnterpriseId(staffClerkRelationDTO.getEnterpriseId());
pojo.setStoreId(mainStore.getStoreId());
pojo.setClerkId(staffClerkRelationDTO.getClerkId());
pojo.setWxUserId(wxUserId);
if(pojo != null){
dealSuccess(taskId, externalUserId,JSON.toJSONString(pojo),wxEnterpriseId);
}
......
......@@ -97,6 +97,7 @@ public class SelfFriendSyncOperation implements BaseSyncOperation{
pojo.setEnterpriseId(staffClerkRelationDTO.getEnterpriseId());
pojo.setStoreId(mainStore.getStoreId());
pojo.setClerkId(staffClerkRelationDTO.getClerkId());
pojo.setWxUserId(wxUserId);
//新增导购和外部联系人关系
String clerkCode = staffClerkRelationDTO.getClerkCode();
......
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