Commit 742c9195 by xugaojun

Merge remote-tracking branch 'origin/developer' into developer

parents cd5e0eb7 48ac179b
...@@ -12,34 +12,45 @@ import java.util.List; ...@@ -12,34 +12,45 @@ import java.util.List;
public interface MemberUnionidRelatedApiService { public interface MemberUnionidRelatedApiService {
/** /**
* 根据导购导购微信id和会员id查询关联关系 * 根据导购导购微信id和会员id查询关联关系
* *
* @param wxUserId : 导购微信id * @param wxUserId : 导购微信id
* @param memberId : 会员id * @param memberId : 会员id
* @return : 返回导购与会员关联关系 * @return : 返回导购与会员关联关系
*/ */
ExternalClerkRelatedDTO getByWxUserIdMemberId(String wxUserId, String memberId); ExternalClerkRelatedDTO getByWxUserIdMemberId(String wxUserId, String memberId);
MemberUnionidRelatedDTO getByUnionId(String staffId, String memberId); MemberUnionidRelatedDTO getByUnionId(String staffId, String memberId);
/**
* 外部联系人新增(加好友)
*
* @param dto
* @return
*/
String addMemberUnionidRelated(MemberUnionidRelatedDTO dto); String addMemberUnionidRelated(MemberUnionidRelatedDTO dto);
/**
* 外部联系人删除(删好友)
*
* @param dto
*/
void delMemberUnionidRelated(MemberUnionidRelatedDTO dto); void delMemberUnionidRelated(MemberUnionidRelatedDTO dto);
/** /**
* 修改 * 修改
* *
* @param dto * @param dto
*/ */
void editMemberUnionidRelated(MemberUnionidRelatedDTO dto); void editMemberUnionidRelated(MemberUnionidRelatedDTO dto);
/** /**
* 处理外部联系人异步 * 处理外部联系人异步
* "routerName": "dealQywxExternalUserMq" * "routerName": "dealQywxExternalUserMq"
* *
* @param params * @param params
*/ */
void dealQywxExternalUser(String params); void dealQywxExternalUser(String params);
ExternalClerkRelatedDTO getByMemberId(String staffId, String memberId); ExternalClerkRelatedDTO getByMemberId(String staffId, String memberId);
......
...@@ -85,7 +85,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -85,7 +85,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
@Autowired @Autowired
private SecretSettingService secretSettingService; private SecretSettingService secretSettingService;
@Autowired @Autowired
private ClerkMainStoreRelatedService clerkMainStoreRelatedService; private ClerkMainStoreRelatedService clerkMainStoreRelatedService;
...@@ -128,20 +128,20 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -128,20 +128,20 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
} else { } else {
operationMap.get("qywxClerkSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre); operationMap.get("qywxClerkSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
} }
}else if(dataPre.getDataType().equals(PreDealTypeEnum.friend_clerk.getVal())){ } else if (dataPre.getDataType().equals(PreDealTypeEnum.friend_clerk.getVal())) {
logger.info("好友导购处理:{}", params); logger.info("好友导购处理:{}", params);
operationMap.get("friendClerkSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre); operationMap.get("friendClerkSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
}else if(dataPre.getDataType().equals(PreDealTypeEnum.friend.getVal())){ } else if (dataPre.getDataType().equals(PreDealTypeEnum.friend.getVal())) {
operationMap.get("friendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre); operationMap.get("friendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
logger.info("好友处理:{}", params); logger.info("好友处理:{}", params);
}else if(dataPre.getDataType().equals(PreDealTypeEnum.self_friend.getVal())){ } else if (dataPre.getDataType().equals(PreDealTypeEnum.self_friend.getVal())) {
operationMap.get("selfFriendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre); operationMap.get("selfFriendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
logger.info("好友处理:{}", params); logger.info("好友处理:{}", params);
} else if(dataPre.getDataType().equals(PreDealTypeEnum.friend_merge.getVal())){ } else if (dataPre.getDataType().equals(PreDealTypeEnum.friend_merge.getVal())) {
operationMap.get("friendMergeSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre); operationMap.get("friendMergeSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
logger.info("好友合并处理:{}", params); logger.info("好友合并处理:{}", params);
} else if (dataPre.getDataType().equals(PreDealTypeEnum.tag.getVal())) { } else if (dataPre.getDataType().equals(PreDealTypeEnum.tag.getVal())) {
operationMap.get("friendTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre); operationMap.get("friendTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
...@@ -150,7 +150,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -150,7 +150,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
operationMap.get("friendMemberTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre); operationMap.get("friendMemberTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
logger.info("会员标签处理标签项:{}", params); logger.info("会员标签处理标签项:{}", params);
} else { } else {
logger.info("不是正常数据:{}", params); logger.info("不是正常数据:{}", params);
} }
...@@ -228,7 +228,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -228,7 +228,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
RedisUtil.lock(key, 10L); RedisUtil.lock(key, 10L);
String taskLock = getTaskLock(wxEnterpriseId); String taskLock = getTaskLock(wxEnterpriseId);
if (StringUtils.isNotBlank(taskLock)) { if (StringUtils.isNotBlank(taskLock)) {
logger.info("【同步锁】taskLock={}",taskLock); logger.info("【同步锁】taskLock={}", taskLock);
RedisUtil.unlock(key); RedisUtil.unlock(key);
return null; return null;
} }
...@@ -307,8 +307,8 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -307,8 +307,8 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
eidListMap.forEach((k, v) -> { eidListMap.forEach((k, v) -> {
//获取所有分组列表 //获取所有分组列表
List<StoreGroupDTO> groupDTOList = storeGroupService.listStoreGroupAndChildren(v.toArray(new String[]{}), k); List<StoreGroupDTO> groupDTOList = storeGroupService.listStoreGroupAndChildren(v.toArray(new String[]{}), k);
List<String> hasKey=new ArrayList<>(); List<String> hasKey = new ArrayList<>();
List<TabHaobanPreDealLog> dealList = groupDTOList.stream().filter(dto->{ List<TabHaobanPreDealLog> dealList = groupDTOList.stream().filter(dto -> {
return !hasKey.contains(dto.getStoreGroupId()); return !hasKey.contains(dto.getStoreGroupId());
}).map(storeGroupDTO -> { }).map(storeGroupDTO -> {
TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog(); TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
...@@ -451,11 +451,11 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -451,11 +451,11 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
Date date = DateUtils.addMinutes(new Date(), -30); Date date = DateUtils.addMinutes(new Date(), -30);
Date dayDate = DateUtils.addDays(new Date(), -1); Date dayDate = DateUtils.addDays(new Date(), -1);
if (dealLogInfoDTO.getUpdateTime().before(date) if (dealLogInfoDTO.getUpdateTime().before(date)
&&syncTask.getUpdateTime().before(date) && syncTask.getUpdateTime().before(date)
&&syncTask.getCreateTime().after(dayDate)) { && syncTask.getCreateTime().after(dayDate)) {
logger.info("重试:{}",taskId); logger.info("重试:{}", taskId);
syncTaskService.updateTaskStatus(taskId,SyncTaskStatusEnum.exception_close.getVal()); syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.exception_close.getVal());
reDealDepartment(taskId,-1); reDealDepartment(taskId, -1);
return syncCheckDTO; return syncCheckDTO;
} }
...@@ -526,27 +526,16 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -526,27 +526,16 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
} }
} }
} }
}else if(syncTask.getTaskType().equals(2)){ } else if (syncTask.getTaskType().equals(2)) {
List<PreDealLogInfoDTO> result = page.getResult(); List<PreDealLogInfoDTO> result = page.getResult();
for (PreDealLogInfoDTO dto : result) { for (PreDealLogInfoDTO dto : result) {
dto.setDataCode(dto.getDataId()); dto.setDataCode(dto.getDataId());
TabHaobanStaff staff = staffService.selectByUserIdAndEnterpriseId(dto.getpDataId(), wxEnterpriseId); TabHaobanStaff staff = staffService.selectByUserIdAndEnterpriseId(dto.getpDataId(), wxEnterpriseId);
if(staff != null){ if (staff != null) {
dto.setDataName(staff.getStaffName()); dto.setDataName(staff.getStaffName());
} }
// if(dto.getDataType() == PreDealTypeEnum.friend.getVal()){
// dto.setDataName("第三方应用处理");
// }else if(dto.getDataType() == PreDealTypeEnum.friend_clerk.getVal()){
// dto.setDataName("导购处理");
// }else if(dto.getDataType() == PreDealTypeEnum.friend_merge.getVal()){
// dto.setDataName("合并处理");
// }else if(dto.getDataType() == PreDealTypeEnum.self_friend.getVal()){
// dto.setDataName("自建应用处理");
// }
//dto.setReason(reason);
} }
} } else {
else{
List<PreDealLogInfoDTO> result = page.getResult(); List<PreDealLogInfoDTO> result = page.getResult();
for (PreDealLogInfoDTO dto : result) { for (PreDealLogInfoDTO dto : result) {
dto.setDataCode(dto.getDataId()); dto.setDataCode(dto.getDataId());
...@@ -561,16 +550,16 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -561,16 +550,16 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
public String dealQywxDepartment(String taskId, String wxEnterpriseId) { public String dealQywxDepartment(String taskId, String wxEnterpriseId) {
WxEnterpriseDTO wxEnterpriseDTO = wxEnterpriseService.selectById(wxEnterpriseId); WxEnterpriseDTO wxEnterpriseDTO = wxEnterpriseService.selectById(wxEnterpriseId);
SecretSettingDTO secretSetting = secretSettingService.getSecretSetting(wxEnterpriseDTO.getWxEnterpriseId(), SecretTypeEnum.HAOBAN_HELP.getVal()); SecretSettingDTO secretSetting = secretSettingService.getSecretSetting(wxEnterpriseDTO.getWxEnterpriseId(), SecretTypeEnum.HAOBAN_HELP.getVal());
if (null == secretSetting||secretSetting.getCheckFlag()==0) { if (null == secretSetting || secretSetting.getCheckFlag() == 0) {
logger.info("没有配置secret"); logger.info("没有配置secret");
syncTaskService.updateTaskStatus(taskId,SyncTaskStatusEnum.exception_close.getVal()); syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.exception_close.getVal());
unlockTask(wxEnterpriseId); unlockTask(wxEnterpriseId);
return "没有配置secret"; return "没有配置secret";
} }
List<com.gic.wechat.api.dto.qywx.DepartmentDTO> list = qywxDepartmentApiService.listSelfDepartment(wxEnterpriseDTO.getCorpid(), secretSetting.getSecretVal(), 1); List<com.gic.wechat.api.dto.qywx.DepartmentDTO> list = qywxDepartmentApiService.listSelfDepartment(wxEnterpriseDTO.getCorpid(), secretSetting.getSecretVal(), 1);
if (CollectionUtils.isEmpty(list)) { if (CollectionUtils.isEmpty(list)) {
logger.info("没有数据同步"); logger.info("没有数据同步");
syncTaskService.updateTaskStatus(taskId,SyncTaskStatusEnum.exception_close.getVal()); syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.exception_close.getVal());
unlockTask(wxEnterpriseId); unlockTask(wxEnterpriseId);
return "没有数据同步或权限没设置全部"; return "没有数据同步或权限没设置全部";
} }
...@@ -607,8 +596,8 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -607,8 +596,8 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
if (CollectionUtils.isNotEmpty(staffIds)) { if (CollectionUtils.isNotEmpty(staffIds)) {
List<String> delStaffIds = staffService.listDelUserStaffId(wxEnterpriseId, staffIds); List<String> delStaffIds = staffService.listDelUserStaffId(wxEnterpriseId, staffIds);
if (CollectionUtils.isEmpty(delStaffIds)) { if (CollectionUtils.isEmpty(delStaffIds)) {
logger.info("没有要删除的用户:{}--{}",wxEnterpriseId,taskId); logger.info("没有要删除的用户:{}--{}", wxEnterpriseId, taskId);
}else { } else {
staffClerkRelationService.cleanStaffClerk(wxEnterpriseId, delStaffIds); staffClerkRelationService.cleanStaffClerk(wxEnterpriseId, delStaffIds);
staffService.cleanStaff(wxEnterpriseId, delStaffIds); staffService.cleanStaff(wxEnterpriseId, delStaffIds);
staffDepartmentRelatedService.cleanStaffDepartment(wxEnterpriseId, delStaffIds); staffDepartmentRelatedService.cleanStaffDepartment(wxEnterpriseId, delStaffIds);
...@@ -619,17 +608,17 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -619,17 +608,17 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
//清空cleak //清空cleak
if (CollectionUtils.isNotEmpty(groupList)) { if (CollectionUtils.isNotEmpty(groupList)) {
List<String> groupIdList = groupList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toList()); List<String> groupIdList = groupList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toList());
departmentService.cleanDepartment(wxEnterpriseId,groupIdList); departmentService.cleanDepartment(wxEnterpriseId, groupIdList);
} }
RedisUtil.delLocalCache("department-list-cache-"+wxEnterpriseId); RedisUtil.delLocalCache("department-list-cache-" + wxEnterpriseId);
} }
@Override @Override
public String createWxFriendTask(String wxEnterpriseId, String taskName, String staffId, String desc) { public String createWxFriendTask(String wxEnterpriseId, String taskName, String staffId, String desc) {
TabHaobanSyncTask tabHaobanSyncTask = new TabHaobanSyncTask(); TabHaobanSyncTask tabHaobanSyncTask = new TabHaobanSyncTask();
tabHaobanSyncTask.setAddUser(staffId); tabHaobanSyncTask.setAddUser(staffId);
tabHaobanSyncTask.setTaskName(taskName); tabHaobanSyncTask.setTaskName(taskName);
tabHaobanSyncTask.setTaskDesc(desc); tabHaobanSyncTask.setTaskDesc(desc);
...@@ -640,14 +629,14 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -640,14 +629,14 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
syncTaskService.createTask(tabHaobanSyncTask); syncTaskService.createTask(tabHaobanSyncTask);
lockTask(wxEnterpriseId, tabHaobanSyncTask.getTaskId()); lockTask(wxEnterpriseId, tabHaobanSyncTask.getTaskId());
return tabHaobanSyncTask.getTaskId(); return tabHaobanSyncTask.getTaskId();
} }
@Override @Override
public void dealWxFriendClerk(String taskId, String wxEnterpriseId) { public void dealWxFriendClerk(String taskId, String wxEnterpriseId) {
List<TabHaobanStaffClerkRelation> relationList = staffClerkRelationService.listByWxEnterpriseId(wxEnterpriseId); List<TabHaobanStaffClerkRelation> relationList = staffClerkRelationService.listByWxEnterpriseId(wxEnterpriseId);
List<TabHaobanClerkMainStoreRelated> mainStoreList = clerkMainStoreRelatedService.listByWxEnterpriseId(wxEnterpriseId); List<TabHaobanClerkMainStoreRelated> mainStoreList = clerkMainStoreRelatedService.listByWxEnterpriseId(wxEnterpriseId);
Map<String,TabHaobanClerkMainStoreRelated> map = mainStoreList.stream().collect(Collectors.toMap(TabHaobanClerkMainStoreRelated::getStaffId, s -> s)); Map<String, TabHaobanClerkMainStoreRelated> map = mainStoreList.stream().collect(Collectors.toMap(TabHaobanClerkMainStoreRelated::getStaffId, s -> s));
List<TabHaobanPreDealLog> dealLogList = relationList.stream().filter(ls->map.get(ls.getStaffId()) != null).map(dto -> { List<TabHaobanPreDealLog> dealLogList = relationList.stream().filter(ls -> map.get(ls.getStaffId()) != null).map(dto -> {
TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog(); TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
dealLog.setDataId(dto.getWxUserId()); dealLog.setDataId(dto.getWxUserId());
dealLog.setpDataId(dto.getStaffId()); dealLog.setpDataId(dto.getStaffId());
...@@ -662,9 +651,9 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -662,9 +651,9 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
preDealService.insert(dealLogList); preDealService.insert(dealLogList);
HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet()); HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());
dealFriendToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync); dealFriendToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
} }
@Override @Override
public String createWxFriendTaskSingle(String wxEnterpriseId, String taskName, String staffId, String staffName, int syncTaskType) { public String createWxFriendTaskSingle(String wxEnterpriseId, String taskName, String staffId, String staffName, int syncTaskType) {
String lockKey = FRIEND_LOCK + "_lock_" + staffId; String lockKey = FRIEND_LOCK + "_lock_" + staffId;
String staffLockKey = FRIEND_LOCK + staffId; String staffLockKey = FRIEND_LOCK + staffId;
...@@ -687,25 +676,25 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -687,25 +676,25 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
RedisUtil.setCache(staffLockKey, tabHaobanSyncTask.getTaskId(), 1L, TimeUnit.HOURS); RedisUtil.setCache(staffLockKey, tabHaobanSyncTask.getTaskId(), 1L, TimeUnit.HOURS);
RedisUtil.unlock(lockKey); RedisUtil.unlock(lockKey);
return tabHaobanSyncTask.getTaskId(); return tabHaobanSyncTask.getTaskId();
} }
@Override @Override
public void dealWxFriendClerkSingle(String taskId, String wxUserId, String staffId,String wxEnterpriseId) { public void dealWxFriendClerkSingle(String taskId, String wxUserId, String staffId, String wxEnterpriseId) {
TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog(); TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
dealLog.setDataId(wxUserId); dealLog.setDataId(wxUserId);
dealLog.setpDataId(staffId); dealLog.setpDataId(staffId);
dealLog.setDataType(PreDealTypeEnum.friend_clerk.getVal()); dealLog.setDataType(PreDealTypeEnum.friend_clerk.getVal());
dealLog.setStatusFlag(0); dealLog.setStatusFlag(0);
dealLog.setTaskId(taskId); dealLog.setTaskId(taskId);
dealLog.setDataContent("刷新"+staffId); dealLog.setDataContent("刷新" + staffId);
dealLog.setWxEnterpriseId(wxEnterpriseId); dealLog.setWxEnterpriseId(wxEnterpriseId);
List<TabHaobanPreDealLog> dealLogList = new ArrayList<TabHaobanPreDealLog>(); List<TabHaobanPreDealLog> dealLogList = new ArrayList<TabHaobanPreDealLog>();
dealLogList.add(dealLog); dealLogList.add(dealLog);
preDealService.insert(dealLogList); preDealService.insert(dealLogList);
HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet()); HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());
dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync); dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
} }
@Override @Override
public void dealWxFriendStore(String taskId, String storeId, String wxEnterpriseId) { public void dealWxFriendStore(String taskId, String storeId, String wxEnterpriseId) {
...@@ -731,28 +720,28 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -731,28 +720,28 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
@Override @Override
public void quartWxFriendClerk(String res) { public void quartWxFriendClerk(String res) {
List<TabHaobanSyncTask> taskList = syncTaskService.listTaskByType(2); List<TabHaobanSyncTask> taskList = syncTaskService.listTaskByType(2);
if(CollectionUtils.isNotEmpty(taskList)){ if (CollectionUtils.isNotEmpty(taskList)) {
for (TabHaobanSyncTask tabHaobanSyncTask : taskList) { for (TabHaobanSyncTask tabHaobanSyncTask : taskList) {
dealWxFriendClerk(tabHaobanSyncTask.getTaskId(), tabHaobanSyncTask.getWxEnterpriseId()); dealWxFriendClerk(tabHaobanSyncTask.getTaskId(), tabHaobanSyncTask.getWxEnterpriseId());
} }
} }
} }
@Override @Override
public void test(String wxEnterpriseId,String taskId){ public void test(String wxEnterpriseId, String taskId) {
List<TabHaobanStaffClerkRelation> relationList = new ArrayList<TabHaobanStaffClerkRelation>(); List<TabHaobanStaffClerkRelation> relationList = new ArrayList<TabHaobanStaffClerkRelation>();
TabHaobanStaffClerkRelation tab = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab1 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab1 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab2 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab2 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab3 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab3 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab4 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab4 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab5 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab5 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab6 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab6 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab7 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab7 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab8 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab8 = new TabHaobanStaffClerkRelation();
TabHaobanStaffClerkRelation tab9 = new TabHaobanStaffClerkRelation(); TabHaobanStaffClerkRelation tab9 = new TabHaobanStaffClerkRelation();
// tab.setWxUserId("12"); // tab.setWxUserId("12");
// tab1.setWxUserId("13989473881"); // tab1.setWxUserId("13989473881");
// tab2.setWxUserId("1545shiyao"); // tab2.setWxUserId("1545shiyao");
...@@ -762,8 +751,8 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -762,8 +751,8 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
// tab6.setWxUserId("2341578784"); // tab6.setWxUserId("2341578784");
// tab7.setWxUserId("234324"); // tab7.setWxUserId("234324");
// tab8.setWxUserId("niweizhong"); // tab8.setWxUserId("niweizhong");
tab9.setWxUserId("QiuWenMin"); tab9.setWxUserId("QiuWenMin");
// tab.setStaffId("12"); // tab.setStaffId("12");
// tab1.setStaffId("13989473881"); // tab1.setStaffId("13989473881");
// tab2.setStaffId("1545shiyao"); // tab2.setStaffId("1545shiyao");
...@@ -773,7 +762,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -773,7 +762,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
// tab6.setStaffId("2341578784"); // tab6.setStaffId("2341578784");
// tab7.setStaffId("234324"); // tab7.setStaffId("234324");
// tab8.setStaffId("niweizhong"); // tab8.setStaffId("niweizhong");
tab9.setStaffId("QiuWenMin"); tab9.setStaffId("QiuWenMin");
// relationList.add(tab); // relationList.add(tab);
// relationList.add(tab1); // relationList.add(tab1);
// relationList.add(tab2); // relationList.add(tab2);
...@@ -783,7 +772,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -783,7 +772,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
// relationList.add(tab6); // relationList.add(tab6);
// relationList.add(tab7); // relationList.add(tab7);
// relationList.add(tab8); // relationList.add(tab8);
relationList.add(tab9); relationList.add(tab9);
List<TabHaobanPreDealLog> dealLogList = relationList.stream().map(dto -> { List<TabHaobanPreDealLog> dealLogList = relationList.stream().map(dto -> {
TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog(); TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
dealLog.setDataId(dto.getWxUserId()); dealLog.setDataId(dto.getWxUserId());
...@@ -799,9 +788,9 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ ...@@ -799,9 +788,9 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
preDealService.insert(dealLogList); preDealService.insert(dealLogList);
HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet()); HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());
dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync); dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
} }
/** /**
* 放入mq处理部门数据 * 放入mq处理部门数据
* *
* @param taskId * @param taskId
......
...@@ -285,7 +285,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -285,7 +285,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
StaffClerkRelationDTO staffClerkRelationDTO = staffClerkRelationService.getOneBindByStoreId(staffId, storeId); StaffClerkRelationDTO staffClerkRelationDTO = staffClerkRelationService.getOneBindByStoreId(staffId, storeId);
if (staffClerkRelationDTO == null) { if (staffClerkRelationDTO == null) {
log.info("【新增外联系人】导购和clerk关联为空"); log.info("【新增外联系人】导购和clerk关联为空");
return; return;
} }
//新增导购和外部联系人关系 //新增导购和外部联系人关系
...@@ -293,7 +293,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -293,7 +293,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
ClerkDTO clerk = clerkService.getClerkByClerkCode(staffClerkRelationDTO.getEnterpriseId(), clerkCode); ClerkDTO clerk = clerkService.getClerkByClerkCode(staffClerkRelationDTO.getEnterpriseId(), clerkCode);
log.info("【新增外部联系人】clerkCode={},unionid:{}", clerkCode, unionId); log.info("【新增外部联系人】clerkCode={},unionid:{}", clerkCode, unionId);
if (clerk == null) { if (clerk == null) {
log.info("【新增外联系人】导购为空"); log.info("【新增外联系人】导购为空");
return; return;
} }
String qrcodeParam = clerk.getQrcodeParam(); String qrcodeParam = clerk.getQrcodeParam();
...@@ -353,6 +353,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -353,6 +353,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
* @param dto * @param dto
*/ */
private void insertExternalClerkRelatedNew(MemberUnionidRelatedDTO dto) { private void insertExternalClerkRelatedNew(MemberUnionidRelatedDTO dto) {
log.info("新增外部联系人,创建关联关系:{}", JSON.toJSONString(dto));
String wxUserId = dto.getWxUserId(); String wxUserId = dto.getWxUserId();
String wxEnterpriseId = dto.getWxEnterpriseId(); String wxEnterpriseId = dto.getWxEnterpriseId();
String name = dto.getExternalName(); String name = dto.getExternalName();
...@@ -378,7 +379,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -378,7 +379,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
} }
StaffClerkRelationDTO staffClerkRelationDTO = staffClerkRelationService.getOneBindByStoreId(staffId, mainStoreRelated.getStoreId()); StaffClerkRelationDTO staffClerkRelationDTO = staffClerkRelationService.getOneBindByStoreId(staffId, mainStoreRelated.getStoreId());
if (staffClerkRelationDTO == null) { if (staffClerkRelationDTO == null) {
log.info("【新增外联系人】导购和clerk关联为空"); log.info("【新增外联系人】导购和clerk关联为空");
return; return;
} }
...@@ -389,10 +390,11 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -389,10 +390,11 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
} }
//好友不开卡 发送欢迎语 //好友不开卡 发送欢迎语
if (wxEnterpriseRelated.getMemberOpenCardFlag() == 1) { if (wxEnterpriseRelated.getMemberOpenCardFlag() == 1) {
log.info("欢迎页面:"); log.info("不同开平,欢迎页面:");
addFriendByWelcome(dto, staffClerkRelationDTO); addFriendByWelcome(dto, staffClerkRelationDTO);
return; return;
} else { } else {
log.info("同一开平,创建关联关系...");
if (unionId == null) { if (unionId == null) {
log.info("unionid 不存在"); log.info("unionid 不存在");
return; return;
...@@ -402,7 +404,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -402,7 +404,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
ClerkDTO clerk = clerkService.getClerkByClerkCode(staffClerkRelationDTO.getEnterpriseId(), clerkCode); ClerkDTO clerk = clerkService.getClerkByClerkCode(staffClerkRelationDTO.getEnterpriseId(), clerkCode);
log.info("【新增外部联系人】clerkCode={},unionid:{}", clerkCode, unionId); log.info("【新增外部联系人】clerkCode={},unionid:{}", clerkCode, unionId);
if (clerk == null) { if (clerk == null) {
log.info("【新增外联系人】导购为空:{},{}", clerkCode, unionId); log.info("【新增外联系人】导购为空:{},{}", clerkCode, unionId);
return; return;
} }
...@@ -649,7 +651,6 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -649,7 +651,6 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
return null; return null;
} }
//校验friend //校验friend
CheckFriendSettingDTO friendSettingDTO = checkQywxSettingApiService.getFriendSetting();
String wxEnterpriseId = wxEnterprise.getWxEnterpriseId(); String wxEnterpriseId = wxEnterprise.getWxEnterpriseId();
String userId = dto.getWxUserId(); String userId = dto.getWxUserId();
String suiteid = dto.getSuiteid(); String suiteid = dto.getSuiteid();
...@@ -1357,7 +1358,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -1357,7 +1358,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
log.info("企业不存在"); log.info("企业不存在");
return null; return null;
} }
// String uJ = qywxUserApiService.getExternalUseridInfo(wxEnterprise.getCorpid(), "wwb3ef71aa8c6d9c06", externalUserId); //String uJ = qywxUserApiService.getExternalUseridInfo(wxEnterprise.getCorpid(), "ww2c34dc56739bb105", externalUserId);
String uJ = qywxUserApiService.getExternalUseridInfo(wxEnterprise.getCorpid(), config.getWxSuiteid(), externalUserId); String uJ = qywxUserApiService.getExternalUseridInfo(wxEnterprise.getCorpid(), config.getWxSuiteid(), externalUserId);
if (StringUtils.isBlank(uJ)) { if (StringUtils.isBlank(uJ)) {
log.info("好友不存在"); log.info("好友不存在");
...@@ -1529,7 +1530,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -1529,7 +1530,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
* @param enterpriseId * @param enterpriseId
*/ */
private void pushTagSync(String memberId, String wxEnterpriseId, String enterpriseId) { private void pushTagSync(String memberId, String wxEnterpriseId, String enterpriseId) {
this.pushTagSync(memberId, "-1", GicQywxSyncTypeEnum.SINGLE_WXENT_MEMNER_SYNC.getType(), QywxSyncTaskTypeEnum.MEMBER_SYNC.getType(), wxEnterpriseId,enterpriseId); this.pushTagSync(memberId, "-1", GicQywxSyncTypeEnum.SINGLE_WXENT_MEMNER_SYNC.getType(), QywxSyncTaskTypeEnum.MEMBER_SYNC.getType(), wxEnterpriseId, enterpriseId);
} }
@Override @Override
......
...@@ -85,11 +85,10 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi ...@@ -85,11 +85,10 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi
} }
@Override @Override
public List<EnterpriseDetailDTO> listEnterpriseByWxEnterpriseId( public List<EnterpriseDetailDTO> listEnterpriseByWxEnterpriseId(String wxEnterpriseId) {
String wxEnterpriseId) {
List<TabHaobanWxEnterpriseRelated> relatedList = wxEnterpriseRelatedMapper.listByWxenterpriseId(wxEnterpriseId); List<TabHaobanWxEnterpriseRelated> relatedList = wxEnterpriseRelatedMapper.listByWxenterpriseId(wxEnterpriseId);
List<EnterpriseDetailDTO> result = EntityUtil.changeEntityListByJSON(EnterpriseDetailDTO.class, relatedList); List<EnterpriseDetailDTO> result = EntityUtil.changeEntityListByJSON(EnterpriseDetailDTO.class, relatedList);
if (CollectionUtils.isEmpty(result)){ if (CollectionUtils.isEmpty(result)) {
return result; return result;
} }
return result; return result;
......
...@@ -182,13 +182,12 @@ public class WxEnterpriseController extends WebBaseController { ...@@ -182,13 +182,12 @@ public class WxEnterpriseController extends WebBaseController {
EnterpriseSearchVO vo = EntityUtil.changeEntityByJSON(EnterpriseSearchVO.class, dto); EnterpriseSearchVO vo = EntityUtil.changeEntityByJSON(EnterpriseSearchVO.class, dto);
if (vo != null) { if (vo != null) {
String enterpriseId = vo.getEnterpriseId(); String enterpriseId = vo.getEnterpriseId();
EnterpriseDTO enterprise = enterpriseService.getEnterpriseByEid(enterpriseId); EnterpriseDTO enterprise = enterpriseService.getEnterpriseById(enterpriseId);
if (enterprise != null) { if (enterprise != null) {
vo.setBrandName(enterprise.getBrandName()); vo.setBrandName(enterprise.getBrandName());
} }
} }
return resultResponse(HaoBanErrCode.ERR_1, vo); return resultResponse(HaoBanErrCode.ERR_1, vo);
} }
//微信企业绑定接口 //微信企业绑定接口
......
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