去除ELK配置

beta
kk 2 years ago
parent 127cbf3cda
commit 97eb06d5ed
  1. 6
      jianshui-admin/src/main/resources/application-dev.yml
  2. 6
      jianshui-admin/src/main/resources/application-prod-中车.yml
  3. 6
      jianshui-admin/src/main/resources/application-prod.yml
  4. 138
      jianshui-admin/src/main/resources/logback-spring.xml
  5. 40
      jianshui-invoice/src/main/java/com/jianshui/invoice/service/impl/api/AisinoConsoleInvoiceApiZhongQiServiceImpl.java

@ -89,6 +89,6 @@ spring:
ele_auth_url: https://openapi.zncspt.com/api/
ele_check_url: https://openapi.zncspt.com/api/
elephant_entcode_check: 91370102MA3UD2FG21
logstash:
host: 43.138.58.64:14560
indexname: jianshui-dev
#logstash:
# host: 43.138.58.64:14560
# indexname: jianshui-dev

@ -83,6 +83,6 @@ spring:
ele_auth_url: https://openapi.ele-cloud.com/api/dxhy-open-income/v1/
ele_check_url: https://openapi.zncspt.com/api/
elephant_entcode_check: 91370102MA3UD2FG21
logstash:
host: 43.138.58.64:14560
indexname: jianshui-prod
#logstash:
# host: 43.138.58.64:14560
# indexname: jianshui-prod

@ -83,6 +83,6 @@ spring:
ele_auth_url: https://openapi.ele-cloud.com/api/dxhy-open-income/v1/
ele_check_url: https://openapi.zncspt.com/api/
elephant_entcode_check: 91370102MA3UD2FG21
logstash:
host: 43.138.58.64:14560
indexname: jianshui-prod
#logstash:
# host: 43.138.58.64:14560
# indexname: jianshui-prod

@ -1,138 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<!-- 日志存放路径 -->
<property name="log.path" value="${user.dir}/logs" />
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n" />
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/sys-info.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/sys-info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/sys-error.log</file>
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/sys-error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 用户访问日志输出 -->
<appender name="sys-user" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/sys-user.log</file>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 按天回滚 daily -->
<fileNamePattern>${log.path}/sys-user.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
</appender>
<!--处理elk-->
<!--输出到logstash的appender-->
<springProperty scope="context" name="logstash-host" source="logstash.host"/>
<springProperty scope="context" name="logstash-indexname" source="logstash.indexname"/>
<appender name="logstash" class="net.logstash.logback.appender.LogstashTcpSocketAppender">
<!--可以访问的logstash日志收集端口-->
<destination>${logstash-host}</destination>
<encoder charset="UTF-8" class="net.logstash.logback.encoder.LoggingEventCompositeJsonEncoder">
<!--自定义字段,区分应用名称-->
<providers>
<pattern>
<pattern>
<!--输出日志可自定义,可根据自己需要配置-->
{
<!--es索引名称 -->
"indexname":"${logstash-indexname}",
<!--应用名称 -->
"appname":"${spring.application.name}",
<!--服务器ip -->
<!--"host": "%ip",-->
<!--应用端口 -->
<!--"port": "${spring.application.index}",-->
<!--打印时间 -->
"timestamp": "%d{yyyy-MM-dd HH:mm:ss.SSS}",
<!--线程名称 -->
"thread": "%thread",
<!--日志级别 -->
"level": "%level",
<!--日志名称 -->
"logger_name": "%logger",
<!--日志信息 -->
"message": "%msg",
<!--日志堆栈 -->
"stack_trace": "%exception"
}
</pattern>
</pattern>
</providers>
</encoder>
</appender>
<root level="info">
<appender-ref ref="logstash" />
</root>
<!-- 系统模块日志级别控制 -->
<logger name="com.jianshui" level="info" />
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn" />
<root level="info">
<appender-ref ref="console" />
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info" />
<appender-ref ref="file_error" />
</root>
<!--系统用户操作日志-->
<logger name="sys-user" level="info">
<appender-ref ref="sys-user"/>
</logger>
</configuration>

@ -1039,7 +1039,47 @@ public class AisinoConsoleInvoiceApiZhongQiServiceImpl implements IInvoiceApiSer
// TODO: 2023/10/24 读取nginx地址,读取数据。
String indexPage = HttpUtil.get("http://localhost:8082/");
System.out.println(indexPage);
String startDate = "2023.10.10";
String endDate = "2023.10.12";
// 构建要匹配的日期范围字符串
String dateRange = startDate + "-" + endDate;
// 使用Jsoup解析HTML
Document doc = Jsoup.parse(indexPage);
// 获取带有动态日期范围的<a>标签
Elements aTags = doc.select("a[href*='%28" + dateRange + "%29.dat']");
// 遍历<a>标签,提取href属性内容
for (Element aTag : aTags) {
String href = aTag.attr("href");
log.info("读取到的机动车加密文件名为"+href);
continue;
}
// TODO: 2023/10/24 调用重汽的推送接口
HashMap<String, Object> paramMap = new HashMap<>();
paramMap.put("File", "");
paramMap.put("qyjc", "KS");
paramMap.put("zdr", "");
String result = HttpUtil.post("",paramMap);
cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(result);
String retCode = jsonObject.get("retCode") != null ? jsonObject.get("retCode").toString() : "";
String retMsg = jsonObject.get("retMsg") != null ? jsonObject.get("retMsg").toString() : "";
if("1".equals(retCode)){
} else if ("0".equals(retCode)) {
}else {
}

Loading…
Cancel
Save