Commit d03323e7 by fudahua

素材列表fix

parent 5a9a027e
...@@ -10,6 +10,7 @@ import com.gic.haoban.manage.api.dto.WxEnterpriseDTO; ...@@ -10,6 +10,7 @@ import com.gic.haoban.manage.api.dto.WxEnterpriseDTO;
import com.gic.haoban.manage.api.service.CheckQywxSettingApiService; import com.gic.haoban.manage.api.service.CheckQywxSettingApiService;
import com.gic.haoban.manage.service.service.WxEnterpriseService; import com.gic.haoban.manage.service.service.WxEnterpriseService;
import com.gic.redis.data.util.RedisUtil; import com.gic.redis.data.util.RedisUtil;
import org.apache.commons.lang3.StringUtils;
import org.redisson.api.RBucket; import org.redisson.api.RBucket;
import org.redisson.api.RMap; import org.redisson.api.RMap;
import org.redisson.api.RedissonClient; import org.redisson.api.RedissonClient;
...@@ -65,7 +66,7 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic ...@@ -65,7 +66,7 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic
@Override @Override
public void saveFriendCallback(String wxEnterpriseId, ExternalUserDTO externalUserDTO, MemberUnionidRelatedDTO dto) { public void saveFriendCallback(String wxEnterpriseId, ExternalUserDTO externalUserDTO, MemberUnionidRelatedDTO dto) {
if (null == externalUserDTO) { if (null == externalUserDTO) {
messageAlert(wxEnterpriseId, dto); messageAlert(wxEnterpriseId, dto, null);
//todo 告警 //todo 告警
return; return;
} }
...@@ -80,6 +81,7 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic ...@@ -80,6 +81,7 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic
} else { } else {
map.put(THIRD_APP, externalUserDTO); map.put(THIRD_APP, externalUserDTO);
} }
messageAlert(wxEnterpriseId, dto, "好友提醒:" + dto.getSuiteid());
} }
/** /**
...@@ -88,7 +90,8 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic ...@@ -88,7 +90,8 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic
* @param wxEnterpriseId * @param wxEnterpriseId
* @param dto * @param dto
*/ */
private void messageAlert(String wxEnterpriseId, MemberUnionidRelatedDTO dto) { private void messageAlert(String wxEnterpriseId, MemberUnionidRelatedDTO dto, String titleSub) {
titleSub = StringUtils.isBlank(titleSub) ? "加好友异常" : titleSub;
String key = ALERT_KEY + wxEnterpriseId; String key = ALERT_KEY + wxEnterpriseId;
RBucket<Object> bucket = RedisUtil.getRedisClient().getBucket(key); RBucket<Object> bucket = RedisUtil.getRedisClient().getBucket(key);
boolean b = bucket.trySet(1, 60L, TimeUnit.SECONDS); boolean b = bucket.trySet(1, 60L, TimeUnit.SECONDS);
...@@ -100,7 +103,7 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic ...@@ -100,7 +103,7 @@ public class CheckQywxSettingApiServiceImpl implements CheckQywxSettingApiServic
String traceId = providerLocalTag.traceId; String traceId = providerLocalTag.traceId;
String traceUrl = "http://212.64.4.231:8780/damo-stats/mongodb/getLogMessagesView?trace_id=" + traceId; String traceUrl = "http://212.64.4.231:8780/damo-stats/mongodb/getLogMessagesView?trace_id=" + traceId;
String title = wxEnterpriseDTO.getCorpName() + ": 加好友异常"; String title = wxEnterpriseDTO.getCorpName() + ": " + titleSub;
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
Map<String, Object> link = new HashMap<>(); Map<String, Object> link = new HashMap<>();
map.put("msgtype", "link"); map.put("msgtype", "link");
......
...@@ -76,9 +76,12 @@ public class ServiceTest { ...@@ -76,9 +76,12 @@ public class ServiceTest {
// wxEnterpriseRelatedApiService.flushBindStoreByEnterpriseId("ff8080815dacd3a2015dacd3ef5c0000", // wxEnterpriseRelatedApiService.flushBindStoreByEnterpriseId("ff8080815dacd3a2015dacd3ef5c0000",
// "-1", "-1", ChannelCodeEnum.SYNC_UNBIND.getCode()); // "-1", "-1", ChannelCodeEnum.SYNC_UNBIND.getCode());
// } // }
MemberUnionidRelatedDTO dto = new MemberUnionidRelatedDTO();
dto.setSuiteid("selfSuiteId"); checkQywxSettingApiService.setFriendSetting("ca66a01b79474c40b3e7c7f93daf1a3b", "宿命の战");
checkQywxSettingApiService.saveFriendCallback("ca66a01b79474c40b3e7c7f93daf1a3b", null, dto);
// MemberUnionidRelatedDTO dto = new MemberUnionidRelatedDTO();
// dto.setSuiteid("selfSuiteId");
// checkQywxSettingApiService.saveFriendCallback("ca66a01b79474c40b3e7c7f93daf1a3b", null, dto);
// wxEnterpriseRelatedApiService.flushBindStoreByEnterpriseId("ff808081593917d90159398ec6340012", // wxEnterpriseRelatedApiService.flushBindStoreByEnterpriseId("ff808081593917d90159398ec6340012",
// "ca66a01b79474c40b3e7c7f93daf1a3b", "-1", ChannelCodeEnum.SYNC_UNBIND.getCode()); // "ca66a01b79474c40b3e7c7f93daf1a3b", "-1", ChannelCodeEnum.SYNC_UNBIND.getCode());
......
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