Commit ccb0b361 by fudahua

企业微信标签同步fix

parent 1f80a71b
...@@ -27,6 +27,13 @@ public interface MemberUnionidRelatedApiService { ...@@ -27,6 +27,13 @@ public interface MemberUnionidRelatedApiService {
void delMemberUnionidRelated(MemberUnionidRelatedDTO dto); void delMemberUnionidRelated(MemberUnionidRelatedDTO dto);
/** /**
* 修改
*
* @param dto
*/
void editMemberUnionidRelated(MemberUnionidRelatedDTO dto);
/**
* 处理外部联系人异步 * 处理外部联系人异步
* *
* @param params * @param params
......
...@@ -15,7 +15,9 @@ public class DealQywxExternalUserPojo implements Serializable { ...@@ -15,7 +15,9 @@ public class DealQywxExternalUserPojo implements Serializable {
//删除 //删除
del(0), del(0),
//新增 //新增
add(1); add(1),
//修改
edit(2),;
private int type; private int type;
DealType(int type) { DealType(int type) {
......
...@@ -912,7 +912,20 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -912,7 +912,20 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
} catch (Exception e) { } catch (Exception e) {
log.info("异步处理异常:{}", e); log.info("异步处理异常:{}", e);
} }
}
@Override
public void editMemberUnionidRelated(MemberUnionidRelatedDTO dto) {
DealQywxExternalUserPojo dealQywxExternalUserPojo = new DealQywxExternalUserPojo();
dealQywxExternalUserPojo.setType(DealQywxExternalUserPojo.DealType.edit.getType());
dealQywxExternalUserPojo.setData(dto);
GicMQClient instance = GICMQClientUtil.getClientInstance();
try {
instance.sendMessage("dealQywxExternalUserMq", JSONObject.toJSONString(dealQywxExternalUserPojo));
} catch (Exception e) {
log.info("异步处理异常:{}", e);
}
} }
/** /**
...@@ -926,6 +939,16 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -926,6 +939,16 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
} }
/**
* 删除好友
*
* @param dto
*/
private void editMemberUnionidRelatedProcess(MemberUnionidRelatedDTO dto) {
//todo 修改主要是修改标签 同步所有标签
log.info("修改标签/会员信息回调:{}", JSONObject.toJSONString(dto));
}
@Override @Override
public ExternalClerkRelatedDTO getByMemberId(String staffId, String memberId) { public ExternalClerkRelatedDTO getByMemberId(String staffId, String memberId) {
TabHaobanStaff staff = staffService.selectById(staffId); TabHaobanStaff staff = staffService.selectById(staffId);
......
...@@ -42,10 +42,6 @@ import static org.slf4j.LoggerFactory.getLogger; ...@@ -42,10 +42,6 @@ import static org.slf4j.LoggerFactory.getLogger;
public class QywxTagApiServiceImpl implements QywxTagApiService { public class QywxTagApiServiceImpl implements QywxTagApiService {
private static final Logger logger = getLogger(QywxTagApiServiceImpl.class); private static final Logger logger = getLogger(QywxTagApiServiceImpl.class);
@Autowired
private QywxUserApiService qywxUserApiService;
@Autowired @Autowired
private QywxSuiteApiService qywxSuiteApiService; private QywxSuiteApiService qywxSuiteApiService;
......
...@@ -45,6 +45,7 @@ import java.util.stream.Collectors; ...@@ -45,6 +45,7 @@ import java.util.stream.Collectors;
* @author hua * @author hua
*/ */
@Service @Service
@Deprecated
public class ClerkSyncOperation implements BaseSyncOperation { public class ClerkSyncOperation implements BaseSyncOperation {
private static final Logger logger = LoggerFactory.getLogger(ClerkSyncOperation.class); private static final Logger logger = LoggerFactory.getLogger(ClerkSyncOperation.class);
......
...@@ -28,6 +28,7 @@ import com.gic.mq.sdk.GicMQClient; ...@@ -28,6 +28,7 @@ import com.gic.mq.sdk.GicMQClient;
import com.gic.redis.data.util.RedisUtil; import com.gic.redis.data.util.RedisUtil;
@Service @Service
@Deprecated
public class FriendClerkSyncOperation implements BaseSyncOperation { public class FriendClerkSyncOperation implements BaseSyncOperation {
private static final Logger logger = LoggerFactory.getLogger(FriendClerkSyncOperation.class); private static final Logger logger = LoggerFactory.getLogger(FriendClerkSyncOperation.class);
......
...@@ -32,6 +32,7 @@ import com.gic.member.api.service.MemberOpenCardBusinessService; ...@@ -32,6 +32,7 @@ import com.gic.member.api.service.MemberOpenCardBusinessService;
import com.gic.redis.data.util.RedisUtil; import com.gic.redis.data.util.RedisUtil;
@Service @Service
@Deprecated
public class FriendMergeSyncOperation implements BaseSyncOperation{ public class FriendMergeSyncOperation implements BaseSyncOperation{
private static final Logger logger = LoggerFactory.getLogger(FriendMergeSyncOperation.class); private static final Logger logger = LoggerFactory.getLogger(FriendMergeSyncOperation.class);
@Autowired @Autowired
......
...@@ -38,6 +38,7 @@ import com.gic.mq.sdk.GicMQClient; ...@@ -38,6 +38,7 @@ import com.gic.mq.sdk.GicMQClient;
import com.gic.redis.data.util.RedisUtil; import com.gic.redis.data.util.RedisUtil;
@Service @Service
@Deprecated
public class FriendSyncOperation implements BaseSyncOperation { public class FriendSyncOperation implements BaseSyncOperation {
private static final Logger logger = LoggerFactory.getLogger(FriendSyncOperation.class); private static final Logger logger = LoggerFactory.getLogger(FriendSyncOperation.class);
@Autowired @Autowired
......
...@@ -40,6 +40,7 @@ import java.util.stream.Collectors; ...@@ -40,6 +40,7 @@ import java.util.stream.Collectors;
* @author hua * @author hua
*/ */
@Service @Service
@Deprecated
public class GroupSyncOperation implements BaseSyncOperation { public class GroupSyncOperation implements BaseSyncOperation {
private static final Logger logger = LoggerFactory.getLogger(GroupSyncOperation.class); private static final Logger logger = LoggerFactory.getLogger(GroupSyncOperation.class);
......
...@@ -41,6 +41,7 @@ import com.gic.member.api.service.MemberOpenCardBusinessService; ...@@ -41,6 +41,7 @@ import com.gic.member.api.service.MemberOpenCardBusinessService;
import com.gic.mq.sdk.GicMQClient; import com.gic.mq.sdk.GicMQClient;
@Service @Service
@Deprecated
public class SelfFriendSyncOperation implements BaseSyncOperation{ public class SelfFriendSyncOperation implements BaseSyncOperation{
private static final Logger logger = LoggerFactory.getLogger(SelfFriendSyncOperation.class); private static final Logger logger = LoggerFactory.getLogger(SelfFriendSyncOperation.class);
......
...@@ -43,6 +43,7 @@ import java.util.stream.Collectors; ...@@ -43,6 +43,7 @@ import java.util.stream.Collectors;
* @author hua * @author hua
*/ */
@Service @Service
@Deprecated
public class StoreSyncOperation implements BaseSyncOperation { public class StoreSyncOperation implements BaseSyncOperation {
private static final Logger logger = LoggerFactory.getLogger(StoreSyncOperation.class); private static final Logger logger = LoggerFactory.getLogger(StoreSyncOperation.class);
......
package com.gic.haoban.manage.service.task.tag;
import com.gic.haoban.manage.api.dto.DealParamMqDTO;
import com.gic.haoban.manage.service.entity.TabHaobanPreDealLog;
import com.gic.haoban.manage.service.task.BaseSyncOperation;
import org.springframework.stereotype.Service;
/**
* Created 2021/6/23.
*
* @author hua
*/
@Service
public class FriendTagSyncOperation extends BaseSyncOperation {
@Override
public void dealSingleByMq(DealParamMqDTO dealParamMqDTO, TabHaobanPreDealLog dataPre) {
}
@Override
public void dealException(String taskId, String dataId, String enterpriseId, String reason) {
}
@Override
public void dealSuccess(String taskId, String dataId, String enterpriseId, String wxEnterpriseId) {
}
@Override
public void checkDepartmentTask(String taskId) {
}
}
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