Commit 2d23bdf9 by 徐高华

Merge branch 'master-xgh-好办停用' into 'developer'

Master xgh 好办停用

See merge request !222
parents 3de249e8 3f20c8ee
...@@ -140,7 +140,7 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService { ...@@ -140,7 +140,7 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService {
@Override @Override
public void stopHaoban(String enterpriseId) { public void stopHaoban(String enterpriseId) {
List<TabHaobanWxEnterpriseRelated> list = this.wxEnterpriseRelatedMapper.listByEnterpriseId(enterpriseId) ; List<TabHaobanWxEnterpriseRelated> list = this.wxEnterpriseRelatedMapper.listByEnterpriseId(enterpriseId) ;
logger.info("停用好办={},list={}",enterpriseId,JSON.toJSONString(list)); logger.info("停用好办={},商户list={}",enterpriseId,JSON.toJSONString(list));
if(CollectionUtils.isEmpty(list)){ if(CollectionUtils.isEmpty(list)){
return ; return ;
} }
...@@ -151,7 +151,7 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService { ...@@ -151,7 +151,7 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService {
} }
this.wxEnterpriseRelatedMapper.deleteByEnterpriseId(enterpriseId) ; this.wxEnterpriseRelatedMapper.deleteByEnterpriseId(enterpriseId) ;
Map<String,Object> enMap = new HashMap<>(); Map<String,Object> enMap = new HashMap<>();
enMap.put("enterpriseId", enterpriseId) ; enMap.put("enterpriseId", enterpriseId + list.get(0).getEnterpriseName()) ;
alert("删除商户企微关联告警", enMap); alert("删除商户企微关联告警", enMap);
for(String wxEnterpriseId : wxEnterpriseIdList) { for(String wxEnterpriseId : wxEnterpriseIdList) {
List<TabHaobanWxEnterpriseRelated> relationList = this.wxEnterpriseRelatedMapper.listByWxenterpriseId(wxEnterpriseId) ; List<TabHaobanWxEnterpriseRelated> relationList = this.wxEnterpriseRelatedMapper.listByWxenterpriseId(wxEnterpriseId) ;
...@@ -234,6 +234,6 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService { ...@@ -234,6 +234,6 @@ public class WxEnterpriseServiceImpl implements WxEnterpriseService {
private void alert(String title, Map<String, Object> map) { private void alert(String title, Map<String, Object> map) {
String msg = title + JSON.toJSONString(map); String msg = title + JSON.toJSONString(map);
String dingUrl = "https://oapi.dingtalk.com/robot/send?access_token=c38fdc53d26e9a019640755bdada1ce07ebd44a2555d1c8acc299de7a7b5b857"; String dingUrl = "https://oapi.dingtalk.com/robot/send?access_token=c38fdc53d26e9a019640755bdada1ce07ebd44a2555d1c8acc299de7a7b5b857";
DingUtils.send(msg, dingUrl, true); DingUtils.send(msg, dingUrl, false);
} }
} }
...@@ -29,9 +29,9 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService { ...@@ -29,9 +29,9 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
@Override @Override
public void putCommonMessage(CommonMQDTO dto) { public void putCommonMessage(CommonMQDTO dto) {
String message = JSONObject.toJSONString(dto); String message = JSONObject.toJSONString(dto);
log.info("接收信息={}",message); log.info("加入好办通用队列params={}",message);
try { try {
mqClient.sendCommonMessage("marketingCommonRouter", message, mqClient.sendCommonMessage("haobanCommonRouter", message,
"com.gic.haoban.manage.api.service.HaobanCommonMQApiService", "commonHandler"); "com.gic.haoban.manage.api.service.HaobanCommonMQApiService", "commonHandler");
} catch (Exception e) { } catch (Exception e) {
log.error("发送MQ异常"); log.error("发送MQ异常");
...@@ -41,6 +41,7 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService { ...@@ -41,6 +41,7 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
@Override @Override
public void commonHandler(String message) { public void commonHandler(String message) {
log.info("接收好办通用队列params={}",message);
CommonMQDTO dto = JSON.parseObject(message, CommonMQDTO.class); CommonMQDTO dto = JSON.parseObject(message, CommonMQDTO.class);
// 好办停用,删除定时 // 好办停用,删除定时
if(dto.getType()==1) { if(dto.getType()==1) {
......
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