Commit 7338f2fd by 徐高华

美邦延迟处理

parent f764f5d5
package com.gic.haoban.manage.service.service.out.impl;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
......@@ -1520,7 +1513,16 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
pojo.setEnterpriseId(enterpriseId);
GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
try {
clientInstance.sendMessage("qywxTagSyncDeal", JSONObject.toJSONString(pojo));
int delay = 0 ;
// 美邦要延迟处理
if(Arrays.asList("ff8080815dacd3a2015dacd3ef5c0000",
"ff8080817a3e9738017a803e348c5bef",
"ff8080817a3e96a4017a796c7947641b",
"ff80808179f15903017a13f03b953d8c",
"ff80808179f15878017a142445d644ee").contains(enterpriseId)) {
delay = 90 ;
}
clientInstance.sendMessage("qywxTagSyncDeal", JSONObject.toJSONString(pojo),delay);
} catch (Exception e) {
log.info("异常:{}", e);
}
......
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