Commit eda3e3f9 by fudahua

会员标签同步-告警

parent c3665785
...@@ -21,7 +21,6 @@ public class AlertMessageDTO implements Serializable { ...@@ -21,7 +21,6 @@ public class AlertMessageDTO implements Serializable {
private String alertTitle; private String alertTitle;
private Map<String, Object> contentMap; private Map<String, Object> contentMap;
private LinkedHashMap<String, Object> contentLinkMap;
public String getKey() { public String getKey() {
return key; return key;
...@@ -79,11 +78,4 @@ public class AlertMessageDTO implements Serializable { ...@@ -79,11 +78,4 @@ public class AlertMessageDTO implements Serializable {
this.contentMap = contentMap; this.contentMap = contentMap;
} }
public LinkedHashMap<String, Object> getContentLinkMap() {
return contentLinkMap;
}
public void setContentLinkMap(LinkedHashMap<String, Object> contentLinkMap) {
this.contentLinkMap = contentLinkMap;
}
} }
...@@ -847,14 +847,14 @@ public class QywxTagApiServiceImpl implements QywxTagApiService { ...@@ -847,14 +847,14 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
List<TabQywxTagRelation> qywxTagRelations = tagRelations.stream().filter(dto -> dto.getRelationType() == QywxTagRelationTypeEnum.TAG_GROUP.getType()).collect(Collectors.toList()); List<TabQywxTagRelation> qywxTagRelations = tagRelations.stream().filter(dto -> dto.getRelationType() == QywxTagRelationTypeEnum.TAG_GROUP.getType()).collect(Collectors.toList());
for (TabQywxTagRelation qywxTagRelation : qywxTagRelations) { for (TabQywxTagRelation qywxTagRelation : qywxTagRelations) {
LinkedHashMap<String, Object> map = checkQywxSyncByQywxTag(qywxTagRelation, wxEnterprise, pojo); Map<String, Object> map = checkQywxSyncByQywxTag(qywxTagRelation, wxEnterprise, pojo);
if (MapUtils.isNotEmpty(map)) { if (MapUtils.isNotEmpty(map)) {
AlertMessageDTO messageDTO = new AlertMessageDTO(); AlertMessageDTO messageDTO = new AlertMessageDTO();
messageDTO.setAlertTitle("企微与好办同步标签不相同"); messageDTO.setAlertTitle("企微与好办同步标签不相同");
messageDTO.setEnterpriseId(qywxTagRelation.getEnterpriseId()); messageDTO.setEnterpriseId(qywxTagRelation.getEnterpriseId());
messageDTO.setAlertType(AlertTypeEnum.QYWX_TAG_SYNC.getType()); messageDTO.setAlertType(AlertTypeEnum.QYWX_TAG_SYNC.getType());
messageDTO.setWxEnterpriseId(wxEnterprise.getWxEnterpriseId()); messageDTO.setWxEnterpriseId(wxEnterprise.getWxEnterpriseId());
messageDTO.setContentLinkMap(map); messageDTO.setContentMap(map);
messageDTO.setTraceId(traceId); messageDTO.setTraceId(traceId);
GicMQClient clientInstance = GICMQClientUtil.getClientInstance(); GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
try { try {
...@@ -940,8 +940,8 @@ public class QywxTagApiServiceImpl implements QywxTagApiService { ...@@ -940,8 +940,8 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
//企业微信存在 gic不存在 //企业微信存在 gic不存在
Sets.SetView<String> gicUnHaves = Sets.difference(qywxKeysSet, gicQywxKeysSet); Sets.SetView<String> gicUnHaves = Sets.difference(qywxKeysSet, gicQywxKeysSet);
ret.put("企微标签项", tagItems.stream().filter(dto -> dto.isDeleted() == false).map(dto -> dto.getName()).collect(Collectors.joining("],[", "[", "]"))); ret.put("企微标签项", tagItems.stream().filter(dto -> dto.isDeleted() == false).map(dto -> dto.getName()).collect(Collectors.joining("],[", "[", "]")));
ret.put("gic标签项", gicTagItems.stream().map(dto -> dto.getTagItemName()).collect(Collectors.joining("],[", "[", "]"))); ret.put("gic标签项", gicTagItems.stream().map(dto -> dto.getTagItemName()).collect(Collectors.joining("],[", "[", "]")));
//企业微信缺少 //企业微信缺少
if (!CollectionUtils.isEmpty(qywxUnHaves)) { if (!CollectionUtils.isEmpty(qywxUnHaves)) {
......
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