Commit 94517f32 by 墨竹

fix:增加日志

parent 9b2bbf8e
package com.gic.haoban.manage.service.service.out.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.gic.api.base.commons.Page;
import com.gic.clerk.api.dto.ClerkDTO;
......@@ -105,28 +106,29 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
logger.info("待处理数据不存在:{}", params);
return;
}
//TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(dealParamMqDTO.getTaskId());
if (dataPre.getDataType().equals(PreDealTypeEnum.dept.getVal())) {
logger.info("dataPre:{}", JSON.toJSONString(dataPre));
Integer dataType = dataPre.getDataType();
logger.info("同步类型,dataType:{}",dataType);
if (dataType.equals(PreDealTypeEnum.dept.getVal())) {
//部门处理
operationMap.get("qywxDeptSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} else if (dataPre.getDataType().equals(PreDealTypeEnum.clerk.getVal())) {
} else if (dataType.equals(PreDealTypeEnum.clerk.getVal())) {
//成员处理
logger.info("成员处理:{}", params);
operationMap.get("qywxStaffSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} else if (dataPre.getDataType().equals(PreDealTypeEnum.friend_clerk.getVal())) {
} else if (dataType.equals(PreDealTypeEnum.friend_clerk.getVal())) {
logger.info("好友导购处理:{}", params);
operationMap.get("friendClerkSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} else if (dataPre.getDataType().equals(PreDealTypeEnum.friend.getVal())) {
} else if (dataType.equals(PreDealTypeEnum.friend.getVal())) {
logger.info("第三方好友处理:{}", params);
operationMap.get("friendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} else if (dataPre.getDataType().equals(PreDealTypeEnum.self_friend.getVal())) {
} else if (dataType.equals(PreDealTypeEnum.self_friend.getVal())) {
logger.info("自建好友处理:{}", params);
operationMap.get("selfFriendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} else if (dataPre.getDataType().equals(PreDealTypeEnum.tag.getVal())) {
} else if (dataType.equals(PreDealTypeEnum.tag.getVal())) {
logger.info("会员标签处理:{}", params);
operationMap.get("friendTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} else if (dataPre.getDataType().equals(PreDealTypeEnum.tag_member.getVal())) {
} else if (dataType.equals(PreDealTypeEnum.tag_member.getVal())) {
logger.info("会员标签处理标签项:{}", params);
operationMap.get("friendMemberTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} else {
......
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