Commit 00e0852e by fudahua

好友批处理 优化

parent 8135425d
...@@ -29,6 +29,19 @@ public class ExternalUserDTO implements Serializable{ ...@@ -29,6 +29,19 @@ public class ExternalUserDTO implements Serializable{
private String staffId; private String staffId;
private String selfExternalUserId; private String selfExternalUserId;
/**
* 好友类型
* 1表示该外部联系人是微信用户,2表示该外部联系人是企业微信用户
*/
private Integer friendType;
public Integer getFriendType() {
return friendType;
}
public void setFriendType(Integer friendType) {
this.friendType = friendType;
}
public String getSelfExternalUserId() { public String getSelfExternalUserId() {
return selfExternalUserId; return selfExternalUserId;
......
...@@ -15,6 +15,19 @@ public class ExternalUserPojo implements Serializable{ ...@@ -15,6 +15,19 @@ public class ExternalUserPojo implements Serializable{
private String addCreateTime; private String addCreateTime;
private String externalUserId; private String externalUserId;
/**
* 好友类型
* 1表示该外部联系人是微信用户,2表示该外部联系人是企业微信用户
*/
private Integer friendType;
public Integer getFriendType() {
return friendType;
}
public void setFriendType(Integer friendType) {
this.friendType = friendType;
}
public String getWxEnterpriseId() { public String getWxEnterpriseId() {
return wxEnterpriseId; return wxEnterpriseId;
......
...@@ -66,7 +66,8 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService { ...@@ -66,7 +66,8 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService {
TabHaobanWxEnterprise enterprise = new TabHaobanWxEnterprise(); TabHaobanWxEnterprise enterprise = new TabHaobanWxEnterprise();
enterprise.setWxEnterpriseId(wxEnterpriseId); enterprise.setWxEnterpriseId(wxEnterpriseId);
enterprise.setStatusFlag(0); enterprise.setStatusFlag(0);
return this.mapper.updateByPrimaryKeySelective(enterprise); enterprise.setUpdateTime(new Date());
return this.mapper.updateByPrimaryKeySelective(enterprise);
} }
@Override @Override
......
...@@ -1335,6 +1335,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -1335,6 +1335,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
String name = ""; String name = "";
String createTime = ""; String createTime = "";
String avatar = ""; String avatar = "";
Integer friendType = 1;
if(StringUtils.isNotBlank(uJ)){ if(StringUtils.isNotBlank(uJ)){
JSONObject jo = JSON.parseObject(uJ); JSONObject jo = JSON.parseObject(uJ);
String external_contact = jo.getString("external_contact"); String external_contact = jo.getString("external_contact");
...@@ -1343,6 +1344,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -1343,6 +1344,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
if(StringUtils.isNotBlank(external_contact)){ if(StringUtils.isNotBlank(external_contact)){
jt = JSON.parseObject(external_contact); jt = JSON.parseObject(external_contact);
name = EmojiFilterUtil.filterEmojiLast(jt.getString("name"), true); name = EmojiFilterUtil.filterEmojiLast(jt.getString("name"), true);
friendType = jt.getInteger("type");
if(StringUtils.isBlank(name)){ if(StringUtils.isBlank(name)){
name = "--"; name = "--";
} }
...@@ -1371,6 +1373,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -1371,6 +1373,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
pojo.setAddCreateTime(createTime); pojo.setAddCreateTime(createTime);
pojo.setWxEnterpriseId(wxEnterpriseId); pojo.setWxEnterpriseId(wxEnterpriseId);
pojo.setAvatar(avatar); pojo.setAvatar(avatar);
pojo.setFriendType(friendType);
return EntityUtil.changeEntityByJSON(ExternalUserDTO.class, pojo); return EntityUtil.changeEntityByJSON(ExternalUserDTO.class, pojo);
} }
@Override @Override
......
...@@ -165,6 +165,9 @@ public class FriendSyncNewOperation implements BaseSyncOperation { ...@@ -165,6 +165,9 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
String wxUserId = dataPre.getpDataId(); String wxUserId = dataPre.getpDataId();
String taskId = dataPre.getTaskId(); String taskId = dataPre.getTaskId();
if (externalUserDTO.getFriendType() == 2) {
return "不是微信好友,是企业微信好友:" + externalUserDTO.getFriendType();
}
//staff信息 //staff信息
StaffDTO staff = staffApiService.selectByUserIdAndEnterpriseId(wxUserId, wxEnterpriseId); StaffDTO staff = staffApiService.selectByUserIdAndEnterpriseId(wxUserId, wxEnterpriseId);
if (staff == null) { if (staff == null) {
...@@ -219,7 +222,7 @@ public class FriendSyncNewOperation implements BaseSyncOperation { ...@@ -219,7 +222,7 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
externalUserDTO.getUnionId(), "", externalUserDTO.getName(), externalUserDTO.getAvatar(), qrcodeParam); externalUserDTO.getUnionId(), "", externalUserDTO.getName(), externalUserDTO.getAvatar(), qrcodeParam);
} }
if (member == null) { if (member == null) {
return "会员不存在:" + externalUserDTO.getUnionId(); return "会员不存在:unionid:" + externalUserDTO.getUnionId();
} }
externalUserDTO.setMemberId(member.getMemberId()); externalUserDTO.setMemberId(member.getMemberId());
return memberUnionidRelatedApiService.addExternal(externalUserDTO); return memberUnionidRelatedApiService.addExternal(externalUserDTO);
......
...@@ -51,13 +51,15 @@ public class GicDepartmentController extends WebBaseController{ ...@@ -51,13 +51,15 @@ public class GicDepartmentController extends WebBaseController{
Map<String, StoreRangeInfoDTO> storeRangeMap = new HashMap<>(); Map<String, StoreRangeInfoDTO> storeRangeMap = new HashMap<>();
if (CollectionUtils.isNotEmpty(rangeInfoDTOList)) { if (CollectionUtils.isNotEmpty(rangeInfoDTOList)) {
List<WxEnterpriseDTO> wxEnterpriseDTOS = wxEnterpriseRelatedApiService.listWxEnterpriseByEid(enterpriseId); List<WxEnterpriseDTO> wxEnterpriseDTOS = wxEnterpriseRelatedApiService.listWxEnterpriseByEid(enterpriseId);
Map<String, WxEnterpriseDTO> wxEnterpriseDTOMap = wxEnterpriseDTOS.stream().collect(Collectors.toMap(dto -> dto.getWxEnterpriseId(), dto -> dto)); if (CollectionUtils.isNotEmpty(wxEnterpriseDTOS)) {
Map<String, WxEnterpriseDTO> wxEnterpriseDTOMap = wxEnterpriseDTOS.stream().collect(Collectors.toMap(dto -> dto.getWxEnterpriseId(), dto -> dto));
storeRangeMap = rangeInfoDTOList.stream().filter(dto -> (!dto.getWxEnterpriseId().equals(wxEnterpriseId)) && dto.getRelationType() == 1) storeRangeMap = rangeInfoDTOList.stream().filter(dto -> (!dto.getWxEnterpriseId().equals(wxEnterpriseId)) && dto.getRelationType() == 1)
.map(dto -> { .map(dto -> {
dto.setWxEnterpriseName(wxEnterpriseDTOMap.get(dto.getWxEnterpriseId()).getCorpName()); dto.setWxEnterpriseName(wxEnterpriseDTOMap.get(dto.getWxEnterpriseId()).getCorpName());
return dto; return dto;
}).collect(Collectors.toMap(dto -> dto.getRelationId(), dto -> dto)); }).collect(Collectors.toMap(dto -> dto.getRelationId(), dto -> dto));
}
} }
Map<String, StoreRangeInfoDTO> finalStoreRangeMap = storeRangeMap; Map<String, StoreRangeInfoDTO> finalStoreRangeMap = storeRangeMap;
List<StoreGroupVo> ret = departmentList.stream().map(dto -> { List<StoreGroupVo> ret = departmentList.stream().map(dto -> {
......
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