Browse Source

feat(all): 修改发送消息到工厂报错问题

dist.1.3.0
zhaoqiaobo 9 months ago
parent
commit
9c400127b1
  1. 5
      blade-service-api/logpm-factory-data-api/src/main/java/com/logpm/factorydata/util/FactoryDataMessageSender.java
  2. 2
      blade-service-api/logpm-factory-data-api/src/main/java/com/logpm/factorydata/util/FactoryDataUtil.java

5
blade-service-api/logpm-factory-data-api/src/main/java/com/logpm/factorydata/util/FactoryDataMessageSender.java

@ -1,5 +1,7 @@
package com.logpm.factorydata.util; package com.logpm.factorydata.util;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.logpm.factorydata.feign.IFactoryDataClient; import com.logpm.factorydata.feign.IFactoryDataClient;
import com.logpm.factorydata.vo.NodePushMsg; import com.logpm.factorydata.vo.NodePushMsg;
@ -31,14 +33,13 @@ public class FactoryDataMessageSender {
public void sendNodeDataByBrand(NodePushMsg data) { public void sendNodeDataByBrand(NodePushMsg data) {
try{ try{
String routingKeyByName = FactoryDataUtil.findRoutingKeyByName(data.getBrand()); String routingKeyByName = FactoryDataUtil.findRoutingKeyByName(data.getBrand());
if(routingKeyByName == null){ if(StrUtil.isEmpty(routingKeyByName)){
return ; return ;
} }
SendMsg build = SendMsg.builder().exchange(FactoryDataConstants.Mq.Exchanges.NODE_DATA_PUSH).routingKey(routingKeyByName).message(JSONUtil.toJsonStr(data, HutoolConfigUtil.jsonConfigByDataTimeFormat())).build(); SendMsg build = SendMsg.builder().exchange(FactoryDataConstants.Mq.Exchanges.NODE_DATA_PUSH).routingKey(routingKeyByName).message(JSONUtil.toJsonStr(data, HutoolConfigUtil.jsonConfigByDataTimeFormat())).build();
factoryDataClient.sendMessage(build); factoryDataClient.sendMessage(build);
}catch (Exception e){ }catch (Exception e){
log.error("sendNodeDataByBrand >>>>" ,e); log.error("sendNodeDataByBrand >>>>" ,e);
} }
} }

2
blade-service-api/logpm-factory-data-api/src/main/java/com/logpm/factorydata/util/FactoryDataUtil.java

@ -35,7 +35,7 @@ public class FactoryDataUtil {
* @return 指定路由key * @return 指定路由key
*/ */
public static String findRoutingKeyByName(BrandEnums brand) { public static String findRoutingKeyByName(BrandEnums brand) {
if (ObjectUtil.isAllEmpty(brand, brand.getValue(),factorys.get(brand.getValue()))) { if (ObjectUtil.isEmpty(brand) || ObjectUtil.isEmpty(factorys.get(brand.getValue()))) {
// TODO 业务调用不规范,特殊处理 // TODO 业务调用不规范,特殊处理
return null; return null;
} }

Loading…
Cancel
Save