1.添加elk 日志

blade-biz-common/src/main/java/org/springblade/common/constant/LauncherConstant.java

@@ -105,6 +105,23 @@ public interface LauncherConstant {
 	String APPLICATION_PROD_LOGIN_ADDR = "172.16.128.147:8888";
 
 
+	/**
+	 * elk dev 地址
+	 */
+
+	String ELK_DEV_ADDR = "192.168.2.46:9000";
+
+	/**
+	 * elk prod 地址
+	 */
+	String ELK_PROD_ADDR = "172.30.0.72:9000";
+
+	/**
+	 * elk test 地址
+	 */
+	String ELK_TEST_ADDR = "192.168.2.110:9002";
+
+
 	/**
 	 * dbuuo提供者
 	 */
@@ -246,4 +263,21 @@ public interface LauncherConstant {
 		}
 	}
 
+	/**
+	 * 动态获取elk地址
+	 *
+	 * @param profile 环境变量
+	 * @return addr
+	 */
+	static String elkAddr(String profile) {
+		switch (profile) {
+			case (AppConstant.PROD_CODE):
+				return ELK_PROD_ADDR;
+			case (AppConstant.TEST_CODE):
+				return ELK_TEST_ADDR;
+			default:
+				return ELK_DEV_ADDR;
+		}
+	}
+
 }

blade-biz-common/src/main/java/org/springblade/common/launch/LauncherServiceImpl.java

@@ -40,6 +40,8 @@ public class LauncherServiceImpl implements LauncherService {
 		PropsUtil.setProperty(props, "spring.cloud.nacos.discovery.server-addr", LauncherConstant.nacosAddr(profile));
 		PropsUtil.setProperty(props, "spring.cloud.nacos.config.server-addr", LauncherConstant.nacosAddr(profile));
 
+		// 开启elk日志
+		PropsUtil.setProperty(props, "blade.log.elk.destination", LauncherConstant.elkAddr(profile));
 
 
 

blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/UnloadCarComHandler.java

@@ -14,6 +14,8 @@ import com.logpm.oldproject.feign.IAdvanceDetailClient;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.springblade.common.constant.RabbitConstant;
+import org.springblade.core.log.feign.ILogClient;
+import org.springblade.core.log.model.LogError;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.StringUtil;
 import org.springframework.amqp.core.Message;
@@ -51,6 +53,8 @@ public class UnloadCarComHandler {
 	@Autowired
 	private IMtPushDataService mtPushDataService;
 
+	private ILogClient logClient;
+
 
 	@RabbitHandler
 	public void unloadCarComDataHandler(Map map, Message message, Channel channel) {
@@ -99,14 +103,14 @@ public class UnloadCarComHandler {
 					r.add(carNum);
                 }
             }
-
 			r.forEach(t->{
 				sendDataCarNum(t, unloadCarDTO.getCompleteDate());
 			});
 
-
 		} catch (Exception e) {
 			log.error("##################unloadCarComDataHandler 解析数据出错：{}", e.getMessage());
+			
+
 		}