arrival_data_analysis / cgoasm_arrival · 提交

转到一个项目

作者 王勇
提交 2bb024fc7a53c7e50d5f1c002daf775690cfb13d 0 个父辈

初始化代理人，进港服务

内嵌 并排对比
正在显示 34 个修改的文件 包含 1597 行增加 和 0 行删除
  1 +HELP.md
  2 +target/
  3 +!.mvn/wrapper/maven-wrapper.jar
  4 +!**/src/main/**
  5 +!**/src/test/**
  6 +
  7 +### STS ###
  8 +.apt_generated
  9 +.classpath
  10 +.factorypath
  11 +.project
  12 +.settings
  13 +.springBeans
  14 +.sts4-cache
  15 +
  16 +### IntelliJ IDEA ###
  17 +.idea
  18 +*.iws
  19 +*.iml
  20 +*.ipr
  21 +
  22 +### NetBeans ###
  23 +/nbproject/private/
  24 +/nbbuild/
  25 +/dist/
  26 +/nbdist/
  27 +/.nb-gradle/
  28 +build/
  29 +
  30 +### VS Code ###
  31 +.vscode/
  1 +server:
  2 + port: 9012
  3 +
  4 +# spring \u914D\u7F6E
  5 +spring:
  6 + application:
  7 + name: cgoasm-arrival
  8 + datasource:
  9 + type: com.alibaba.druid.pool.DruidDataSource
  10 + driver-class-name: oracle.jdbc.OracleDriver
  11 + url: jdbc:oracle:thin:@192.168.1.253:1522:ORCLL
  12 + username: CGOASM
  13 + password: vmvnv1v2
  14 + profiles:
  15 + active: dev
  16 + jackson:
  17 + default-property-inclusion: ALWAYS
  18 + time-zone: GMT+8
  19 + date-format: yyyy-MM-dd
  20 + security:
  21 + user:
  22 + name: admin
  23 + password: 123456
  24 + # \u94FE\u8DEF\u8FFD\u8E2A\u914D\u7F6E
  25 + zipkin:
  26 + base-url: http://192.168.1.63:9411
  27 + sleuth:
  28 + sampler:
  29 + probability: 1
  30 +
  31 +# mybatis\u914D\u7F6E
  32 +mybatis:
  33 + mapper-locations: classpath:mapper/*.xml
  34 + type-aliases-package: com.sunyo.wlpt.cgoasm.arrival.domain
  35 +
  36 +# \u65E5\u5FD7\u6253\u5370
  37 +logging:
  38 + config: config/logback-dev.xml
  39 + level:
  40 + com.sunyo.wlpt.cgoasm.arrival.mapper: debug
  41 +logback:
  42 + appname: cgoasm-arrival
  43 + logdir: ./log
  44 +
  45 +
  46 +#eureka client
  47 +eureka:
  48 + instance:
  49 + status-page-url: http://${eureka.instance.hostname}:${server.port}/index
  50 + prefer-ip-address: true
  51 + instance-id: ${spring.cloud.client.ip-address}:${server.port}
  52 + hostname: ${spring.cloud.client.ip-address}
  53 + metadata-map:
  54 + user:
  55 + name: "admin"
  56 + passwoed: "123456"
  57 + client:
  58 + healthcheck:
  59 + enabled: true
  60 + service-url:
  61 + defaultZone: http://192.168.1.53:12345/eureka/
  62 +
  63 +feign:
  64 + hystrix:
  65 + enabled: true
  66 + client:
  67 + config:
  68 + default:
  69 + connectTimeout: 600000 # feign 的超时设置
  70 + readTimeout: 600000
  71 +# boot admin
  72 +management:
  73 + endpoints:
  74 + enabled-by-default: true
  75 + web:
  76 + exposure:
  77 + include: ["*"]
  78 + endpoint:
  79 + health:
  80 + show-details: always
  81 + shutdown:
  82 + enabled: true
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<!--参考文档链接:https://blog.csdn.net/qq_34912478/article/details/80877132-->
  3 +<!-- 日志级别从低到高分为TRACE < DEBUG < INFO < WARN < ERROR < FATAL，如果设置为WARN，则低于WARN的信息都不会输出 -->
  4 +<!-- scan:当此属性设置为true时，配置文件如果发生改变，将会被重新加载，默认值为true -->
  5 +<!-- scanPeriod:设置监测配置文件是否有修改的时间间隔，如果没有给出时间单位，默认单位是毫秒。当scan为true时，此属性生效。默认的时间间隔为1分钟。 -->
  6 +<!-- debug:当此属性设置为true时，将打印出logback内部日志信息，实时查看logback运行状态。默认值为false。 -->
  7 +<configuration scan="true" scanPeriod="10 seconds">
  8 +
  9 + <!--<include resource="org/springframework/boot/logging/logback/base.xml" />-->
  10 +
  11 + <contextName>logback</contextName>
  12 + <!-- name的值是变量的名称，value的值时变量定义的值。通过定义的值会被插入到logger上下文中。定义变量后，可以使“${}”来使用变量。 -->
  13 + <property name="log.path" value="./logs" />
  14 +
  15 + <!-- 彩色日志 -->
  16 + <!-- 彩色日志依赖的渲染类 -->
  17 + <conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter" />
  18 + <conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter" />
  19 + <conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter" />
  20 + <!-- 彩色日志格式 -->
  21 + <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}}"/>
  22 +
  23 +
  24 + <!--输出到控制台-->
  25 + <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
  26 + <!--此日志appender是为开发使用，只配置最底级别，控制台输出的日志级别是大于或等于此级别的日志信息-->
  27 + <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
  28 + <level>debug</level>
  29 + </filter>
  30 + <encoder>
  31 + <Pattern>${CONSOLE_LOG_PATTERN}</Pattern>
  32 + <!-- 设置字符集 windows系统这里设置成GBK-->
  33 + <charset>UTF-8</charset>
  34 + </encoder>
  35 + </appender>
  36 +
  37 +
  38 + <!--输出到文件-->
  39 +
  40 + <!-- 时间滚动输出 level为 DEBUG 日志 -->
  41 + <appender name="DEBUG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
  42 + <!-- 正在记录的日志文件的路径及文件名 -->
  43 + <file>${log.path}/log_debug.log</file>
  44 + <!--日志文件输出格式-->
  45 + <encoder>
  46 + <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
  47 + <charset>UTF-8</charset> <!-- 设置字符集 -->
  48 + </encoder>
  49 + <!-- 日志记录器的滚动策略，按日期，按大小记录 -->
  50 + <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  51 + <!-- 日志归档 -->
  52 + <fileNamePattern>${log.path}/debug/log-debug-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
  53 + <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
  54 + <maxFileSize>100MB</maxFileSize>
  55 + </timeBasedFileNamingAndTriggeringPolicy>
  56 + <!--日志文件保留天数-->
  57 + <maxHistory>15</maxHistory>
  58 + </rollingPolicy>
  59 + <!-- 此日志文件只记录debug级别的 -->
  60 + <filter class="ch.qos.logback.classic.filter.LevelFilter">
  61 + <level>debug</level>
  62 + <onMatch>ACCEPT</onMatch>
  63 + <onMismatch>DENY</onMismatch>
  64 + </filter>
  65 + </appender>
  66 +
  67 + <!-- 时间滚动输出 level为 INFO 日志 -->
  68 + <appender name="INFO_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
  69 + <!-- 正在记录的日志文件的路径及文件名 -->
  70 + <file>${log.path}/log_info.log</file>
  71 + <!--日志文件输出格式-->
  72 + <encoder>
  73 + <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
  74 + <charset>UTF-8</charset>
  75 + </encoder>
  76 + <!-- 日志记录器的滚动策略，按日期，按大小记录 -->
  77 + <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  78 + <!-- 每天日志归档路径以及格式 -->
  79 + <fileNamePattern>${log.path}/info/log-info-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
  80 + <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
  81 + <maxFileSize>100MB</maxFileSize>
  82 + </timeBasedFileNamingAndTriggeringPolicy>
  83 + <!--日志文件保留天数-->
  84 + <maxHistory>15</maxHistory>
  85 + </rollingPolicy>
  86 + <!-- 此日志文件只记录info级别的 -->
  87 + <filter class="ch.qos.logback.classic.filter.LevelFilter">
  88 + <level>info</level>
  89 + <onMatch>ACCEPT</onMatch>
  90 + <onMismatch>DENY</onMismatch>
  91 + </filter>
  92 + </appender>
  93 +
  94 + <!-- 时间滚动输出 level为 WARN 日志 -->
  95 + <appender name="WARN_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
  96 + <!-- 正在记录的日志文件的路径及文件名 -->
  97 + <file>${log.path}/log_warn.log</file>
  98 + <!--日志文件输出格式-->
  99 + <encoder>
  100 + <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
  101 + <charset>UTF-8</charset> <!-- 此处设置字符集 -->
  102 + </encoder>
  103 + <!-- 日志记录器的滚动策略，按日期，按大小记录 -->
  104 + <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  105 + <fileNamePattern>${log.path}/warn/log-warn-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
  106 + <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
  107 + <maxFileSize>100MB</maxFileSize>
  108 + </timeBasedFileNamingAndTriggeringPolicy>
  109 + <!--日志文件保留天数-->
  110 + <maxHistory>15</maxHistory>
  111 + </rollingPolicy>
  112 + <!-- 此日志文件只记录warn级别的 -->
  113 + <filter class="ch.qos.logback.classic.filter.LevelFilter">
  114 + <level>warn</level>
  115 + <onMatch>ACCEPT</onMatch>
  116 + <onMismatch>DENY</onMismatch>
  117 + </filter>
  118 + </appender>
  119 +
  120 +
  121 + <!-- 时间滚动输出 level为 ERROR 日志 -->
  122 + <appender name="ERROR_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
  123 + <!-- 正在记录的日志文件的路径及文件名 -->
  124 + <file>${log.path}/log_error.log</file>
  125 + <!--日志文件输出格式-->
  126 + <encoder>
  127 + <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
  128 + <charset>UTF-8</charset> <!-- 此处设置字符集 -->
  129 + </encoder>
  130 + <!-- 日志记录器的滚动策略，按日期，按大小记录 -->
  131 + <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  132 + <fileNamePattern>${log.path}/error/log-error-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
  133 + <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
  134 + <maxFileSize>100MB</maxFileSize>
  135 + </timeBasedFileNamingAndTriggeringPolicy>
  136 + <!--日志文件保留天数-->
  137 + <maxHistory>15</maxHistory>
  138 + </rollingPolicy>
  139 + <!-- 此日志文件只记录ERROR级别的 -->
  140 + <filter class="ch.qos.logback.classic.filter.LevelFilter">
  141 + <level>ERROR</level>
  142 + <onMatch>ACCEPT</onMatch>
  143 + <onMismatch>DENY</onMismatch>
  144 + </filter>
  145 + </appender>
  146 +
  147 + <!-- 时间滚动输出 level为 trace 日志 -->
  148 + <appender name="TRACE_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
  149 + <!-- 正在记录的日志文件的路径及文件名 -->
  150 + <file>${log.path}/log_trace.log</file>
  151 + <!--日志文件输出格式-->
  152 + <encoder>
  153 + <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
  154 + <charset>UTF-8</charset> <!-- 此处设置字符集 -->
  155 + </encoder>
  156 + <!-- 日志记录器的滚动策略，按日期，按大小记录 -->
  157 + <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  158 + <fileNamePattern>${log.path}/trace/log-trace-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
  159 + <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
  160 + <maxFileSize>100MB</maxFileSize>
  161 + </timeBasedFileNamingAndTriggeringPolicy>
  162 + <!--日志文件保留天数-->
  163 + <maxHistory>15</maxHistory>
  164 + </rollingPolicy>
  165 + <!-- 此日志文件只记录trace级别的 -->
  166 + <filter class="ch.qos.logback.classic.filter.LevelFilter">
  167 + <level>TRACE</level>
  168 + <onMatch>ACCEPT</onMatch>
  169 + <onMismatch>DENY</onMismatch>
  170 + </filter>
  171 + </appender>
  172 +
  173 +
  174 + <!--
  175 + <logger>用来设置某一个包或者具体的某一个类的日志打印级别、
  176 + 以及指定<appender>。<logger>仅有一个name属性，
  177 + 一个可选的level和一个可选的addtivity属性。
  178 + name:用来指定受此logger约束的某一个包或者具体的某一个类。
  179 + level:用来设置打印级别，大小写无关：TRACE, DEBUG, INFO, WARN, ERROR, ALL 和 OFF，
  180 + 还有一个特俗值INHERITED或者同义词NULL，代表强制执行上级的级别。
  181 + 如果未设置此属性，那么当前logger将会继承上级的级别。
  182 + addtivity:是否向上级logger传递打印信息。默认是true。
  183 + -->
  184 + <!--<logger name="org.springframework.web" level="info"/>-->
  185 + <!--<logger name="org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor" level="INFO"/>-->
  186 + <!--
  187 + 使用mybatis的时候，sql语句是debug下才会打印，而这里我们只配置了info，所以想要查看sql语句的话，有以下两种操作：
  188 + 第一种把<root level="info">改成<root level="DEBUG">这样就会打印sql，不过这样日志那边会出现很多其他消息
  189 + 第二种就是单独给dao下目录配置debug模式，代码如下，这样配置sql语句会打印，其他还是正常info级别：
  190 + -->
  191 +
  192 +
  193 + <!--
  194 + root节点是必选节点，用来指定最基础的日志输出级别，只有一个level属性
  195 + level:用来设置打印级别，大小写无关：TRACE, DEBUG, INFO, WARN, ERROR, ALL 和 OFF，
  196 + 不能设置为INHERITED或者同义词NULL。默认是DEBUG
  197 + 可以包含零个或多个元素，标识这个appender将会添加到这个logger。
  198 + -->
  199 + <!--<logger name="com.tianbo.analysis" level="trace">-->
  200 + <!--<appender-ref ref="CONSOLE" />-->
  201 + <!--<appender-ref ref="TRACE_FILE" />-->
  202 + <!--<appender-ref ref="DEBUG_FILE" />-->
  203 + <!--<appender-ref ref="INFO_FILE" />-->
  204 + <!--<appender-ref ref="WARN_FILE" />-->
  205 + <!--<appender-ref ref="ERROR_FILE" />-->
  206 + <!--</logger>-->
  207 +
  208 + <!--开发环境:打印控制台-->
  209 + <springProfile name="dev">
  210 + <logger name="org.springframework" level="info"/>
  211 + <logger name="com.sunyo.wlpt.nmms.mapper" level="debug">
  212 + <appender-ref ref="CONSOLE" />
  213 + <appender-ref ref="DEBUG_FILE" />
  214 + </logger>
  215 + <logger name="org.apache.tomcat" level="info" />
  216 + <root level="info">
  217 + <appender-ref ref="CONSOLE" />
  218 + <appender-ref ref="TRACE_FILE" />
  219 + <appender-ref ref="DEBUG_FILE" />
  220 + <appender-ref ref="INFO_FILE" />
  221 + <appender-ref ref="WARN_FILE" />
  222 + <appender-ref ref="ERROR_FILE" />
  223 + </root>
  224 + </springProfile>
  225 +
  226 + <!--生产环境:输出到文件-->
  227 + <springProfile name="pro">
  228 + <logger name="org.springframework" level="INFO"/>
  229 + <root level="info">
  230 + <appender-ref ref="CONSOLE" />
  231 + <appender-ref ref="DEBUG_FILE" />
  232 + <appender-ref ref="INFO_FILE" />
  233 + <appender-ref ref="ERROR_FILE" />
  234 + <appender-ref ref="WARN_FILE" />
  235 + <appender-ref ref="TRACE_FILE" />
  236 + </root>
  237 + </springProfile>
  238 +
  239 +</configuration>
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<configuration scan="ture" scanPeriod="60 seconds" debug="false">
  3 +
  4 + <springProperty scope="context" name="appname" source="logback.appname"/>
  5 + <springProperty scope="context" name="logdir" source="logback.logdir"/>
  6 + <!--文件名-->
  7 + <contextName>${appname}</contextName>
  8 +
  9 + <!--输出到控制面板-->
  10 + <appender name="consoleLog1" class="ch.qos.logback.core.ConsoleAppender">
  11 + <!-- layout输出方式输出-->
  12 + <layout class="ch.qos.logback.classic.PatternLayout">
  13 + <pattern>%d [%thread] %-5level %logger{36} - %msg%n</pattern>
  14 + </layout>
  15 + </appender>
  16 + <!--输出到控制面板-->
  17 + <appender name="consoleLog" class="ch.qos.logback.core.ConsoleAppender">
  18 + <encoder>
  19 + <pattern>%d [%thread] %-5level %logger{36} - %msg%n</pattern>
  20 + </encoder>
  21 + </appender>
  22 + <!--输出info级别日志-->
  23 + <appender name="fileInfoLog" class="ch.qos.logback.core.rolling.RollingFileAppender">
  24 + <filter class="ch.qos.logback.classic.filter.LevelFilter">
  25 + <!--过滤 Error-->
  26 + <level>ERROR</level>
  27 + <!--匹配到就禁止-->
  28 + <onMatch>DENY</onMatch>
  29 + <!--没有匹配到就允许-->
  30 + <onMismatch>ACCEPT</onMismatch>
  31 + </filter>
  32 + <!--<File>../logs</File>-->
  33 + <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  34 + <FileNamePattern>${logdir}/info.${appname}.%d{yyyy-MM-dd}.log</FileNamePattern>
  35 + <maxHistory>100</maxHistory>
  36 + <totalSizeCap>100MB</totalSizeCap>
  37 + </rollingPolicy>
  38 + <encoder>
  39 + <charset>UTF-8</charset>
  40 + <pattern>%d [%thread] %-5level %logger{36} %line - %msg%n</pattern>
  41 + </encoder>
  42 + </appender>
  43 + <!--输出Error级别日志-->
  44 + <!--<appender name="fileErrorLog" class="ch.qos.logback.core.rolling.RollingFileAppender">-->
  45 + <!--<filter class="ch.qos.logback.classic.filter.LevelFilter">-->
  46 + <!--&lt;!&ndash;过滤 Error &ndash;&gt;-->
  47 + <!--<level>ERROR</level>-->
  48 + <!--</filter>-->
  49 + <!--&lt;!&ndash;<File>../logs</File>&ndash;&gt;-->
  50 + <!--<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">-->
  51 + <!--<FileNamePattern>${logdir}/error.${appname}.%d{yyyy-MM-dd}.log</FileNamePattern>-->
  52 + <!--<maxHistory>100</maxHistory>-->
  53 + <!--<totalSizeCap>100MB</totalSizeCap>-->
  54 + <!--</rollingPolicy>-->
  55 + <!--<encoder>-->
  56 + <!--<charset>UTF-8</charset>-->
  57 + <!--<pattern>%d [%thread] %-5level %logger{36} %line - %msg%n</pattern>-->
  58 + <!--</encoder>-->
  59 + <!--</appender>-->
  60 + <!--监控下列类的所有日志，定义输出级别-->
  61 + <logger name="java.sql.PreparedStatement" level="DEBUG" additivity="false">
  62 + <appender-ref ref="consoleLog"/>
  63 + </logger>    
  64 + <logger name="java.sql.Connection" level="DEBUG" additivity="false"> 
  65 + <appender-ref ref="consoleLog"/>
  66 + </logger>  
  67 + <logger name="java.sql.Statement" level="DEBUG" additivity="false">
  68 + <appender-ref ref="consoleLog"/>
  69 + </logger>    
  70 + <logger name="com.ibatis" level="DEBUG" additivity="false">
  71 + <appender-ref ref="consoleLog"/>
  72 + </logger>    
  73 + <logger name="com.ibatis.common.jdbc.SimpleDataSource" level="DEBUG" additivity="false">
  74 + <appender-ref ref="consoleLog"/>
  75 + </logger>    
  76 + <logger name="com.ibatis.common.jdbc.ScriptRunner" level="DEBUG" additivity="false">
  77 + <appender-ref ref="consoleLog"/>
  78 + </logger>    
  79 + <logger name="com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate" level="DEBUG" additivity="false">
  80 + <appender-ref ref="consoleLog"/>
  81 + </logger> 
  82 + <!--输出-->
  83 + <root level="INFO">
  84 + <appender-ref ref="consoleLog"/>
  85 + <!--<appender-ref ref="consoleLog"/>-->
  86 + <appender-ref ref="fileInfoLog"/>
  87 + <!--<appender-ref ref="fileErrorLog"/>-->
  88 + </root>
  89 +
  90 +</configuration>
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3 + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4 + <modelVersion>4.0.0</modelVersion>
  5 + <parent>
  6 + <groupId>org.springframework.boot</groupId>
  7 + <artifactId>spring-boot-starter-parent</artifactId>
  8 + <version>2.1.7.RELEASE</version>
  9 + <relativePath/> <!-- lookup parent from repository -->
  10 + </parent>
  11 + <groupId>com.sunyo</groupId>
  12 + <artifactId>cgoasm_arrival</artifactId>
  13 + <version>0.0.1-SNAPSHOT</version>
  14 + <name>cgoasm_arrival</name>
  15 + <description>提供者代理人</description>
  16 +
  17 + <properties>
  18 + <java.version>1.8</java.version>
  19 + <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  20 + <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  21 + <spring-cloud.version>Greenwich.SR2</spring-cloud.version>
  22 + </properties>
  23 +
  24 + <dependencies>
  25 + <!-- SpringBoot start -->
  26 + <dependency>
  27 + <groupId>org.springframework.boot</groupId>
  28 + <artifactId>spring-boot-starter</artifactId>
  29 + </dependency>
  30 +
  31 + <dependency>
  32 + <groupId>org.springframework.boot</groupId>
  33 + <artifactId>spring-boot-starter-web</artifactId>
  34 + </dependency>
  35 + <!-- SpringBoot end -->
  36 +
  37 + <!-- Security start -->
  38 + <dependency>
  39 + <groupId>org.springframework.boot</groupId>
  40 + <artifactId>spring-boot-starter-security</artifactId>
  41 + </dependency>
  42 + <!-- Security end -->
  43 +
  44 + <!-- SpringCloud start -->
  45 + <dependency>
  46 + <groupId>org.springframework.cloud</groupId>
  47 + <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  48 + </dependency>
  49 +
  50 + <dependency>
  51 + <groupId>org.springframework.cloud</groupId>
  52 + <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  53 + </dependency>
  54 +
  55 + <dependency>
  56 + <groupId>org.springframework.cloud</groupId>
  57 + <artifactId>spring-cloud-starter-openfeign</artifactId>
  58 + </dependency>
  59 +
  60 + <dependency>
  61 + <groupId>org.springframework.cloud</groupId>
  62 + <artifactId>spring-cloud-starter-zipkin</artifactId>
  63 + </dependency>
  64 +
  65 + <dependency>
  66 + <groupId>de.codecentric</groupId>
  67 + <artifactId>spring-boot-admin-starter-client</artifactId>
  68 + <version>2.2.0</version>
  69 + </dependency>
  70 + <dependency>
  71 + <groupId>org.springframework.boot</groupId>
  72 + <artifactId>spring-boot-starter-actuator</artifactId>
  73 + </dependency>
  74 + <!-- SpringCloud end -->
  75 +
  76 + <!-- database start -->
  77 + <dependency>
  78 + <groupId>org.mybatis.spring.boot</groupId>
  79 + <artifactId>mybatis-spring-boot-starter</artifactId>
  80 + <version>2.1.1</version>
  81 + </dependency>
  82 +
  83 + <dependency>
  84 + <groupId>com.github.pagehelper</groupId>
  85 + <artifactId>pagehelper-spring-boot-starter</artifactId>
  86 + <version>1.2.12</version>
  87 + </dependency>
  88 +
  89 + <dependency>
  90 + <groupId>com.alibaba</groupId>
  91 + <artifactId>druid-spring-boot-starter</artifactId>
  92 + <version>1.1.9</version>
  93 + </dependency>
  94 + <!-- database end -->
  95 +
  96 + <!-- tools start -->
  97 + <dependency>
  98 + <groupId>org.projectlombok</groupId>
  99 + <artifactId>lombok</artifactId>
  100 + <optional>true</optional>
  101 + </dependency>
  102 +
  103 + <dependency>
  104 + <groupId>log4j</groupId>
  105 + <artifactId>log4j</artifactId>
  106 + <version>1.2.17</version>
  107 + </dependency>
  108 +
  109 + <dependency>
  110 + <groupId>io.springfox</groupId>
  111 + <artifactId>springfox-swagger2</artifactId>
  112 + <version>2.9.2</version>
  113 + </dependency>
  114 + <dependency>
  115 + <groupId>io.springfox</groupId>
  116 + <artifactId>springfox-swagger-ui</artifactId>
  117 + <version>2.9.2</version>
  118 + </dependency>
  119 + <dependency>
  120 + <groupId>io.swagger</groupId>
  121 + <artifactId>swagger-annotations</artifactId>
  122 + <version>1.5.22</version>
  123 + </dependency>
  124 + <dependency>
  125 + <groupId>io.swagger</groupId>
  126 + <artifactId>swagger-models</artifactId>
  127 + <version>1.5.22</version>
  128 + </dependency>
  129 +
  130 + <dependency>
  131 + <groupId>com.alibaba</groupId>
  132 + <artifactId>fastjson</artifactId>
  133 + <version>1.2.49</version>
  134 + </dependency>
  135 + <dependency>
  136 + <groupId>joda-time</groupId>
  137 + <artifactId>joda-time</artifactId>
  138 + <version>2.10.5</version>
  139 + </dependency>
  140 + <!-- tools end -->
  141 +
  142 + <!-- test start -->
  143 + <dependency>
  144 + <groupId>org.springframework.boot</groupId>
  145 + <artifactId>spring-boot-starter-test</artifactId>
  146 + <scope>test</scope>
  147 + <exclusions>
  148 + <exclusion>
  149 + <groupId>org.junit.vintage</groupId>
  150 + <artifactId>junit-vintage-engine</artifactId>
  151 + </exclusion>
  152 + </exclusions>
  153 + </dependency>
  154 + <!-- test end -->
  155 + </dependencies>
  156 +
  157 + <dependencyManagement>
  158 + <dependencies>
  159 + <dependency>
  160 + <groupId>org.springframework.cloud</groupId>
  161 + <artifactId>spring-cloud-dependencies</artifactId>
  162 + <version>${spring-cloud.version}</version>
  163 + <type>pom</type>
  164 + <scope>import</scope>
  165 + </dependency>
  166 + </dependencies>
  167 + </dependencyManagement>
  168 +
  169 + <build>
  170 + <plugins>
  171 + <plugin>
  172 + <groupId>org.springframework.boot</groupId>
  173 + <artifactId>spring-boot-maven-plugin</artifactId>
  174 + <configuration>
  175 + <mainClass>com.sunyo.wlpt.cgoasm.arrival.CgoasmArrivalApplication</mainClass>
  176 + </configuration>
  177 + </plugin>
  178 + </plugins>
  179 + </build>
  180 +
  181 + <repositories>
  182 + <repository>
  183 + <id>spring-snapshots</id>
  184 + <name>Spring Snapshots</name>
  185 + <url>https://repo.spring.io/snapshot</url>
  186 + <snapshots>
  187 + <enabled>true</enabled>
  188 + </snapshots>
  189 + </repository>
  190 + <repository>
  191 + <id>spring-milestones</id>
  192 + <name>Spring Milestones</name>
  193 + <url>https://repo.spring.io/milestone</url>
  194 + <snapshots>
  195 + <enabled>false</enabled>
  196 + </snapshots>
  197 + </repository>
  198 + </repositories>
  199 +
  200 +</project>
  1 +package com.sunyo.wlpt.cgoasm.arrival;
  2 +
  3 +import org.mybatis.spring.annotation.MapperScan;
  4 +import org.springframework.boot.SpringApplication;
  5 +import org.springframework.boot.autoconfigure.SpringBootApplication;
  6 +import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7 +import org.springframework.cloud.openfeign.EnableFeignClients;
  8 +import org.springframework.transaction.annotation.EnableTransactionManagement;
  9 +
  10 +/**
  11 + * @author 子诚
  12 + */
  13 +@SpringBootApplication
  14 +@MapperScan("com.sunyo.wlpt.cgoasm.arrival.mapper")
  15 +@EnableFeignClients
  16 +@EnableEurekaClient
  17 +@EnableTransactionManagement
  18 +public class CgoasmArrivalApplication {
  19 +
  20 + public static void main(String[] args) {
  21 + SpringApplication.run(CgoasmArrivalApplication.class, args);
  22 + }
  23 +
  24 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.common;
  2 +
  3 +import com.fasterxml.jackson.annotation.JsonFormat;
  4 +import lombok.AllArgsConstructor;
  5 +import lombok.Data;
  6 +import lombok.NoArgsConstructor;
  7 +
  8 +import java.io.Serializable;
  9 +import java.util.Date;
  10 +
  11 +/**
  12 + * @author 子诚
  13 + * Description：进港统计结果集
  14 + * 时间：2020/6/9 15:21
  15 + */
  16 +@Data
  17 +@AllArgsConstructor
  18 +@NoArgsConstructor
  19 +public class ResultArrivalData implements Serializable {
  20 +
  21 + private static final long serialVersionUID = 7514297833139174998L;
  22 +
  23 + /**
  24 + * 1、id
  25 + */
  26 + private String autoId;
  27 +
  28 + /**
  29 + * 2、运单号
  30 + */
  31 + private String waybillNoMaster;
  32 +
  33 + /**
  34 + * 3、航班号
  35 + */
  36 + private String flightNo;
  37 +
  38 + /**
  39 + * 4、航班日期
  40 + */
  41 + @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
  42 + private Date flightDate;
  43 +
  44 + /**
  45 + * 5、出发站
  46 + */
  47 + private String originatingStation;
  48 +
  49 + /**
  50 + * 6、目的站
  51 + */
  52 + private String destinationStation;
  53 +
  54 + /**
  55 + * 7、件数
  56 + */
  57 + private String totalPiece;
  58 +
  59 + /**
  60 + * 8、重量
  61 + */
  62 + private String totalWeight;
  63 +
  64 + /**
  65 + * 9、航段
  66 + */
  67 + private String segment;
  68 +
  69 + /**
  70 + * 10.承运人二字码
  71 + */
  72 + private String carrier;
  73 +
  74 + /**
  75 + * 11.发货人名称
  76 + */
  77 + private String shipperName;
  78 +
  79 + /**
  80 + * 12.收货人名称
  81 + */
  82 + private String consigneeName;
  83 +
  84 + /**
  85 + * 13.货物目的站
  86 + */
  87 + private String aimStation;
  88 +
  89 + /**
  90 + * 14.国家代码
  91 + */
  92 + private String country;
  93 +
  94 + /**
  95 + * 15.航班目的区域，中文描述，所属洲
  96 + */
  97 + private String areaDescChn;
  98 +
  99 + /**
  100 + * 16.订仓代理人
  101 + */
  102 + private String orderName;
  103 +
  104 + /**
  105 + * 17.结算代理人
  106 + */
  107 + private String countName;
  108 +
  109 + /**
  110 + * 代理人服务
  111 + * 18.品名
  112 + */
  113 + private String sdCargoName;
  114 +
  115 + /**
  116 + * 代理人服务
  117 + * 19.二级类名称
  118 + */
  119 + private String twoTypeName;
  120 +
  121 + /**
  122 + * 代理人服务
  123 + * 20.一级类名称
  124 + */
  125 + private String typeName;
  126 +
  127 + /**
  128 + * 21.航空公司
  129 + */
  130 + private String airCompany;
  131 +
  132 + /**
  133 + * 22.机型
  134 + */
  135 + private String cfTp;
  136 +
  137 + /**
  138 + * 23.机号
  139 + */
  140 + private String cfNo;
  141 +
  142 + /**
  143 + * 24.航班（起飞）时间
  144 + */
  145 + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
  146 + private Date flightTime;
  147 +
  148 + /**
  149 + * 25.航班计划日期
  150 + */
  151 + @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
  152 + private Date flightPlanDate;
  153 +
  154 + /**
  155 + * 26.航班计划时间
  156 + */
  157 + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
  158 + private Date flightPlanTime;
  159 +
  160 + /**
  161 + * 27.出港日期
  162 + */
  163 + @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
  164 + private Date arrivalDate;
  165 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.config;
  2 +
  3 +import org.springframework.context.annotation.Configuration;
  4 +import org.springframework.security.config.annotation.web.builders.HttpSecurity;
  5 +import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
  6 +import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
  7 +
  8 +/**
  9 + * @author 子诚
  10 + * Description：SpringSecurity 权限配置框架
  11 + * 时间：2020/6/8 18:42
  12 + */
  13 +@EnableWebSecurity
  14 +@Configuration
  15 +public class SecurityConfig extends WebSecurityConfigurerAdapter {
  16 + @Override
  17 + protected void configure(HttpSecurity http) throws Exception {
  18 + http.authorizeRequests()
  19 + .antMatchers("/","/arrival/**","/cgoasm/**","/ws/**")
  20 + .permitAll()
  21 + .and()
  22 + .csrf().disable();
  23 + }
  24 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.controller;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.common.ResultArrivalData;
  5 +import com.sunyo.wlpt.cgoasm.arrival.domain.*;
  6 +import com.sunyo.wlpt.cgoasm.arrival.service.*;
  7 +import org.springframework.web.bind.annotation.*;
  8 +
  9 +import javax.annotation.Resource;
  10 +import java.util.List;
  11 +
  12 +/**
  13 + * @author 子诚
  14 + * Description：获取 代理人服务 的相关信息
  15 + * 时间：2020/5/21 14:39
  16 + */
  17 +@CrossOrigin
  18 +@RequestMapping("cgoasm")
  19 +@RestController
  20 +public class CgoAsmController {
  21 +
  22 + @Resource
  23 + private HzWaybillInfoService hzWaybillInfoService;
  24 +
  25 + @Resource
  26 + private HzShipperInformationService hzShipperInformationService;
  27 +
  28 + @Resource
  29 + private SdCargoNameService sdCargoNameService;
  30 +
  31 + @Resource
  32 + private SdTwoTypeService sdTwoTypeService;
  33 +
  34 + @Resource
  35 + private SdBigTypeService sdBigTypeService;
  36 +
  37 + /**
  38 + * 根据运单号，获取，代理人服务中的相关数据
  39 + *
  40 + * @param waybillNoMaster 运单号
  41 + * @return
  42 + */
  43 + @GetMapping("/getInfo")
  44 + public ResultArrivalData getInfo(@RequestParam(value = "waybillNoMaster", required = false) String waybillNoMaster) {
  45 + ResultArrivalData result = new ResultArrivalData();
  46 + /**
  47 + * 2.根据运单号，获取品名，二级品类，一级品类
  48 + */
  49 + List<SdCargoName> sd = sdCargoNameService.getSdCargoName(waybillNoMaster);
  50 + if (sd != null && sd.size() > 0) {
  51 + // 品名
  52 + result.setSdCargoName(sd.get(0).getSdCargoName());
  53 + List<SdTwoType> twoType = sdTwoTypeService.getSdTwoTypeInfo(sd.get(0).getSdCargoName());
  54 + if (twoType != null && twoType.size() > 0) {
  55 + // 二级品类名称
  56 + result.setTwoTypeName(twoType.get(0).getTwoTypeName());
  57 + List<SdBigType> big = sdBigTypeService.getSdBigTypeInfo(twoType.get(0).getBigTypeId());
  58 + if (big != null && big.size() > 0) {
  59 + // 一级品类
  60 + result.setTypeName(big.get(0).getTypeName());
  61 + }
  62 + }
  63 + }
  64 + /**
  65 + * 1.根据运单号，获取货主信息表ID,最终获取：代理人名称，代理人类型
  66 + */
  67 + List<HzWaybillInfo> hz = hzWaybillInfoService.getHzWaybillInfo(waybillNoMaster);
  68 + if (hz != null && hz.size() > 0) {
  69 + /**
  70 + * 同样运单号，货主信息表的ID不止一个，需要遍历
  71 + */
  72 + for (int i = 0; i < hz.size(); i++) {
  73 + HzShipperInformation hzInfo = new HzShipperInformation();
  74 + hzInfo = hzShipperInformationService.getHzInfo(hz.get(i).getHzInforId());
  75 + if ("222".equals(hzInfo.getTheShipperType())) {
  76 + //订仓代理人
  77 + result.setOrderName(hzInfo.getFullName());
  78 + }
  79 + if ("333".equals(hzInfo.getTheShipperType())) {
  80 + //结算代理人
  81 + result.setCountName(hzInfo.getFullName());
  82 + }
  83 + }
  84 + }
  85 + return result;
  86 + }
  87 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.domain;
  2 +
  3 +import lombok.AllArgsConstructor;
  4 +import lombok.Data;
  5 +import lombok.NoArgsConstructor;
  6 +
  7 +import java.io.Serializable;
  8 +import java.math.BigDecimal;
  9 +
  10 +/**
  11 + * @author 子诚
  12 + * Description：代理人货主信息表
  13 + * 时间：2020/5/21 12:04
  14 + */
  15 +@Data
  16 +@AllArgsConstructor
  17 +@NoArgsConstructor
  18 +public class HzShipperInformation implements Serializable {
  19 +
  20 + private static final long serialVersionUID = -5945024810650089134L;
  21 +
  22 + /**
  23 + * 代理人货主信息表
  24 + */
  25 + private BigDecimal id;
  26 +
  27 + /**
  28 + * 代理人三字码简称
  29 + */
  30 + private String forShort;
  31 +
  32 + /**
  33 + * 代理人全称
  34 + */
  35 + private String fullName;
  36 +
  37 + /**
  38 + * 货主类型
  39 + * 111 = 发货代理
  40 + * 222 = 订舱代理
  41 + * 333 = 操作代理/结算代理
  42 + */
  43 + private String theShipperType;
  44 +
  45 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.domain;
  2 +
  3 +import lombok.AllArgsConstructor;
  4 +import lombok.Data;
  5 +import lombok.NoArgsConstructor;
  6 +
  7 +import java.io.Serializable;
  8 +
  9 +/**
  10 + * @author 子诚
  11 + * Description：代理人——预配货主信息关系表
  12 + * 时间：2020/5/21 11:56
  13 + */
  14 +@Data
  15 +@AllArgsConstructor
  16 +@NoArgsConstructor
  17 +public class HzWaybillInfo implements Serializable {
  18 +
  19 + private static final long serialVersionUID = 366306104328586736L;
  20 +
  21 + /**
  22 + * 预配运单号
  23 + */
  24 + private String waybillId;
  25 +
  26 + /**
  27 + * 货主信息表ID
  28 + */
  29 + private String hzInforId;
  30 +
  31 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.domain;
  2 +
  3 +import lombok.AllArgsConstructor;
  4 +import lombok.Data;
  5 +import lombok.NoArgsConstructor;
  6 +
  7 +import java.io.Serializable;
  8 +import java.math.BigDecimal;
  9 +
  10 +/**
  11 + * @author 子诚
  12 + * Description：代理人一级分类表
  13 + * 时间：2020/5/21 14:19
  14 + */
  15 +@Data
  16 +@AllArgsConstructor
  17 +@NoArgsConstructor
  18 +public class SdBigType implements Serializable {
  19 +
  20 + private static final long serialVersionUID = 6232806925901558585L;
  21 +
  22 + /**
  23 + * 所属大类ID
  24 + */
  25 + private BigDecimal id;
  26 +
  27 + /**
  28 + * 一级类名称
  29 + */
  30 + private String typeName;
  31 +
  32 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.domain;
  2 +
  3 +import lombok.AllArgsConstructor;
  4 +import lombok.Data;
  5 +import lombok.NoArgsConstructor;
  6 +
  7 +import java.io.Serializable;
  8 +
  9 +/**
  10 + * @author 子诚
  11 + * Description：代理人——安检品名表
  12 + * 时间：2020/5/21 14:13
  13 + */
  14 +@Data
  15 +@AllArgsConstructor
  16 +@NoArgsConstructor
  17 +public class SdCargoName implements Serializable {
  18 +
  19 + private static final long serialVersionUID = 2990223703718832899L;
  20 +
  21 + /**
  22 + * 运单号
  23 + */
  24 + private String sdWaybill;
  25 +
  26 + /**
  27 + * 品名
  28 + */
  29 + private String sdCargoName;
  30 +
  31 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.domain;
  2 +
  3 +import lombok.AllArgsConstructor;
  4 +import lombok.Data;
  5 +import lombok.NoArgsConstructor;
  6 +
  7 +import java.io.Serializable;
  8 +import java.math.BigDecimal;
  9 +
  10 +/**
  11 + * @author 子诚
  12 + * Description：代理人——二级分类表
  13 + * 时间：2020/5/21 14:17
  14 + */
  15 +@Data
  16 +@AllArgsConstructor
  17 +@NoArgsConstructor
  18 +public class SdTwoType implements Serializable {
  19 +
  20 + private static final long serialVersionUID = -2679111453569335424L;
  21 +
  22 + /**
  23 + * 品名
  24 + */
  25 + private String cargoName;
  26 +
  27 + /**
  28 + * 二级类名称
  29 + */
  30 + private String twoTypeName;
  31 +
  32 + /**
  33 + * 所属大类
  34 + */
  35 + private BigDecimal bigTypeId;
  36 +
  37 +
  38 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.mapper;
  2 +
  3 +
  4 +
  5 +import com.sunyo.wlpt.cgoasm.arrival.domain.HzShipperInformation;
  6 +import org.apache.ibatis.annotations.Mapper;
  7 +
  8 +/**
  9 + * @author 子诚
  10 + * Description：
  11 + * 时间：2020/5/21 12:04
  12 + */
  13 +@Mapper
  14 +public interface HzShipperInformationMapper {
  15 + /**
  16 + * 获取代理人货主信息表的相关信息
  17 + *
  18 + * @param hzInforId 货主信息表ID
  19 + * @return {@link HzShipperInformation}
  20 + */
  21 + HzShipperInformation getHzInfo(String hzInforId);
  22 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.mapper;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.HzWaybillInfo;
  5 +import org.apache.ibatis.annotations.Mapper;
  6 +import org.springframework.stereotype.Repository;
  7 +
  8 +import java.util.List;
  9 +
  10 +/**
  11 + * @author 子诚
  12 + * Description：
  13 + * 时间：2020/5/21 11:56
  14 + */
  15 +@Mapper
  16 +@Repository
  17 +public interface HzWaybillInfoMapper {
  18 + /**
  19 + * 获取 代理人——预配货主信息关系表 中的相关信息
  20 + *
  21 + * @param waybillNoMaster 主单号
  22 + * @return {@link HzWaybillInfo}
  23 + */
  24 + List<HzWaybillInfo> getHzWaybillInfo(String waybillNoMaster);
  25 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.mapper;
  2 +
  3 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdBigType;
  4 +import org.apache.ibatis.annotations.Mapper;
  5 +
  6 +import java.math.BigDecimal;
  7 +import java.util.List;
  8 +
  9 +/**
  10 + * @author 子诚
  11 + * Description：
  12 + * 时间：2020/5/21 14:19
  13 + */
  14 +@Mapper
  15 +public interface SdBigTypeMapper {
  16 + /**
  17 + * 查询一级品类
  18 + *
  19 + * @param bigTypeId 所属大类id
  20 + * @return
  21 + */
  22 + List<SdBigType> getSdBigTypeInfo(BigDecimal bigTypeId);
  23 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.mapper;
  2 +
  3 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdCargoName;
  4 +import org.apache.ibatis.annotations.Mapper;
  5 +
  6 +import java.util.List;
  7 +
  8 +/**
  9 + * @author 子诚
  10 + * Description：
  11 + * 时间：2020/5/21 14:13
  12 + */
  13 +@Mapper
  14 +public interface SdCargoNameMapper {
  15 + /**
  16 + * 根据运单号，获取品名和品类
  17 + *
  18 + * @param waybillNoMaster 运单号
  19 + * @return
  20 + */
  21 + List<SdCargoName> getSdCargoName(String waybillNoMaster);
  22 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.mapper;
  2 +
  3 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdTwoType;
  4 +import org.apache.ibatis.annotations.Mapper;
  5 +
  6 +import java.util.List;
  7 +
  8 +/**
  9 + * @author 子诚
  10 + * Description：
  11 + * 时间：2020/5/21 14:17
  12 + */
  13 +@Mapper
  14 +public interface SdTwoTypeMapper {
  15 + /**
  16 + * 根据品名，查询二级品类
  17 + *
  18 + * @param sdCargoName 品名
  19 + * @return
  20 + */
  21 + List<SdTwoType> getSdTwoTypeInfo(String sdCargoName);
  22 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.service;
  2 +
  3 +import com.sunyo.wlpt.cgoasm.arrival.domain.HzShipperInformation;
  4 +
  5 +/**
  6 + * @author 子诚
  7 + * Description：
  8 + * 时间：2020/5/21 12:04
  9 + */
  10 +
  11 +public interface HzShipperInformationService {
  12 +
  13 + /**
  14 + * 获取代理人货主信息表的相关信息
  15 + *
  16 + * @param hzInforId 货主信息表ID
  17 + * @return {@link HzShipperInformation}
  18 + */
  19 + HzShipperInformation getHzInfo(String hzInforId);
  20 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.service;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.HzWaybillInfo;
  5 +
  6 +import java.util.List;
  7 +
  8 +
  9 +/**
  10 + * @author 子诚
  11 + * Description：
  12 + * 时间：2020/5/21 11:52
  13 + */
  14 +public interface HzWaybillInfoService {
  15 +
  16 + /**
  17 + * 获取 代理人——预配货主信息关系表 中的相关信息
  18 + *
  19 + * @param waybillNoMaster 主单号
  20 + * @return {@link HzWaybillInfo}
  21 + */
  22 + List<HzWaybillInfo> getHzWaybillInfo(String waybillNoMaster);
  23 +}
  24 +
  25 +
  1 +package com.sunyo.wlpt.cgoasm.arrival.service;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdBigType;
  5 +
  6 +import java.math.BigDecimal;
  7 +import java.util.List;
  8 +
  9 +/**
  10 + * @author 子诚
  11 + * Description：
  12 + * 时间：2020/5/21 14:19
  13 + */
  14 +public interface SdBigTypeService {
  15 +
  16 + /**
  17 + * 查询一级品类
  18 + *
  19 + * @param bigTypeId 所属大类id
  20 + * @return
  21 + */
  22 + List<SdBigType> getSdBigTypeInfo(BigDecimal bigTypeId);
  23 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.service;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdCargoName;
  5 +
  6 +import java.util.List;
  7 +
  8 +/**
  9 + * @author 子诚
  10 + * Description：
  11 + * 时间：2020/5/21 14:13
  12 + */
  13 +public interface SdCargoNameService {
  14 +
  15 + /**
  16 + * 根据运单号，获取品名和品类
  17 + *
  18 + * @param waybillNoMaster 运单号
  19 + * @return
  20 + */
  21 + List<SdCargoName> getSdCargoName(String waybillNoMaster);
  22 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.service;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdTwoType;
  5 +
  6 +import java.util.List;
  7 +
  8 +/**
  9 + * @author 子诚
  10 + * Description：
  11 + * 时间：2020/5/21 14:16
  12 + */
  13 +public interface SdTwoTypeService {
  14 +
  15 + /**
  16 + * 根据品名，查询二级品类
  17 + *
  18 + * @param sdCargoName 品名
  19 + * @return
  20 + */
  21 + List<SdTwoType> getSdTwoTypeInfo(String sdCargoName);
  22 +}
  23 +
  1 +package com.sunyo.wlpt.cgoasm.arrival.service.impl;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.HzShipperInformation;
  5 +import com.sunyo.wlpt.cgoasm.arrival.mapper.HzShipperInformationMapper;
  6 +import com.sunyo.wlpt.cgoasm.arrival.service.HzShipperInformationService;
  7 +import org.springframework.stereotype.Service;
  8 +
  9 +import javax.annotation.Resource;
  10 +
  11 +/**
  12 + * @author 子诚
  13 + * Description：
  14 + * 时间：2020/5/21 12:04
  15 + */
  16 +@Service
  17 +public class HzShipperInformationServiceImpl implements HzShipperInformationService {
  18 +
  19 + @Resource
  20 + private HzShipperInformationMapper hzShipperInformationMapper;
  21 +
  22 + @Override
  23 + public HzShipperInformation getHzInfo(String hzInforId) {
  24 + return hzShipperInformationMapper.getHzInfo(hzInforId);
  25 + }
  26 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.service.impl;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.HzWaybillInfo;
  5 +import com.sunyo.wlpt.cgoasm.arrival.mapper.HzWaybillInfoMapper;
  6 +import com.sunyo.wlpt.cgoasm.arrival.service.HzWaybillInfoService;
  7 +import org.springframework.stereotype.Service;
  8 +
  9 +import javax.annotation.Resource;
  10 +import java.util.List;
  11 +
  12 +/**
  13 + * @author 子诚
  14 + * Description：
  15 + * 时间：2020/5/21 11:52
  16 + */
  17 +@Service
  18 +public class HzWaybillInfoServiceImpl implements HzWaybillInfoService {
  19 +
  20 + @Resource
  21 + private HzWaybillInfoMapper hzWaybillInfoMapper;
  22 +
  23 +
  24 + @Override
  25 + public List<HzWaybillInfo> getHzWaybillInfo(String waybillNoMaster) {
  26 + return hzWaybillInfoMapper.getHzWaybillInfo(waybillNoMaster);
  27 + }
  28 +}
  29 +
  30 +
  1 +package com.sunyo.wlpt.cgoasm.arrival.service.impl;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdBigType;
  5 +import com.sunyo.wlpt.cgoasm.arrival.mapper.SdBigTypeMapper;
  6 +import com.sunyo.wlpt.cgoasm.arrival.service.SdBigTypeService;
  7 +import org.springframework.stereotype.Service;
  8 +
  9 +import javax.annotation.Resource;
  10 +import java.math.BigDecimal;
  11 +import java.util.List;
  12 +
  13 +/**
  14 + * @author 子诚
  15 + * Description：
  16 + * 时间：2020/5/21 14:19
  17 + */
  18 +@Service
  19 +public class SdBigTypeServiceImpl implements SdBigTypeService {
  20 +
  21 + @Resource
  22 + private SdBigTypeMapper sdBigTypeMapper;
  23 +
  24 + @Override
  25 + public List<SdBigType> getSdBigTypeInfo(BigDecimal bigTypeId) {
  26 + return sdBigTypeMapper.getSdBigTypeInfo(bigTypeId);
  27 + }
  28 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.service.impl;
  2 +
  3 +
  4 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdCargoName;
  5 +import com.sunyo.wlpt.cgoasm.arrival.mapper.SdCargoNameMapper;
  6 +import com.sunyo.wlpt.cgoasm.arrival.service.SdCargoNameService;
  7 +import org.springframework.stereotype.Service;
  8 +
  9 +import javax.annotation.Resource;
  10 +import java.util.List;
  11 +
  12 +/**
  13 + * @author 子诚
  14 + * Description：
  15 + * 时间：2020/5/21 14:13
  16 + */
  17 +@Service
  18 +public class SdCargoNameServiceImpl implements SdCargoNameService {
  19 +
  20 + @Resource
  21 + private SdCargoNameMapper sdCargoNameMapper;
  22 +
  23 + @Override
  24 + public List<SdCargoName> getSdCargoName(String waybillNoMaster) {
  25 + return sdCargoNameMapper.getSdCargoName(waybillNoMaster);
  26 + }
  27 +}
  1 +package com.sunyo.wlpt.cgoasm.arrival.service.impl;
  2 +
  3 +
  4 +
  5 +import com.sunyo.wlpt.cgoasm.arrival.domain.SdTwoType;
  6 +import com.sunyo.wlpt.cgoasm.arrival.mapper.SdTwoTypeMapper;
  7 +import com.sunyo.wlpt.cgoasm.arrival.service.SdTwoTypeService;
  8 +import org.springframework.stereotype.Service;
  9 +
  10 +import javax.annotation.Resource;
  11 +import java.util.List;
  12 +
  13 +/**
  14 + * @author 子诚
  15 + * Description：
  16 + * 时间：2020/5/21 14:16
  17 + */
  18 +@Service
  19 +public class SdTwoTypeServiceImpl implements SdTwoTypeService {
  20 +
  21 + @Resource
  22 + private SdTwoTypeMapper sdTwoTypeMapper;
  23 +
  24 + @Override
  25 + public List<SdTwoType> getSdTwoTypeInfo(String sdCargoName) {
  26 + return sdTwoTypeMapper.getSdTwoTypeInfo(sdCargoName);
  27 + }
  28 +}
  29 +
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3 +<mapper namespace="com.sunyo.wlpt.cgoasm.arrival.mapper.HzShipperInformationMapper">
  4 + <resultMap id="BaseResultMap" type="com.sunyo.wlpt.cgoasm.arrival.domain.HzShipperInformation">
  5 + <!--@mbg.generated-->
  6 + <!--@Table HZ_SHIPPER_INFORMATION-->
  7 + <id column="ID" jdbcType="DECIMAL" property="id"/>
  8 + <result column="FOR_SHORT" jdbcType="VARCHAR" property="forShort"/>
  9 + <result column="FULL_NAME" jdbcType="VARCHAR" property="fullName"/>
  10 + <result column="THE_SHIPPER_TYPE" jdbcType="VARCHAR" property="theShipperType"/>
  11 + </resultMap>
  12 + <sql id="Base_Column_List">
  13 + <!--@mbg.generated-->
  14 + ID, FOR_SHORT, FULL_NAME, THE_SHIPPER_TYPE
  15 + </sql>
  16 + <select id="getHzInfo" parameterType="java.lang.String"
  17 + resultMap="BaseResultMap">
  18 + select
  19 + <include refid="Base_Column_List"/>
  20 + from HZ_SHIPPER_INFORMATION
  21 + where ID = #{hzInforId,jdbcType=VARCHAR}
  22 + </select>
  23 +</mapper>
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3 +<mapper namespace="com.sunyo.wlpt.cgoasm.arrival.mapper.HzWaybillInfoMapper">
  4 + <resultMap id="BaseResultMap" type="com.sunyo.wlpt.cgoasm.arrival.domain.HzWaybillInfo">
  5 + <!--@mbg.generated-->
  6 + <!--@Table HZ_WAYBILL_INFO-->
  7 + <result column="WAYBILL_ID" jdbcType="VARCHAR" property="waybillId"/>
  8 + <result column="HZINFOR_ID" jdbcType="VARCHAR" property="hzInforId"/>
  9 + </resultMap>
  10 + <sql id="Base_Column_List">
  11 + <!--@mbg.generated-->
  12 + WAYBILL_ID, HZINFOR_ID
  13 + </sql>
  14 +
  15 + <select id="getHzWaybillInfo" parameterType="java.lang.String"
  16 + resultMap="BaseResultMap">
  17 + select
  18 + <include refid="Base_Column_List"/>
  19 + from HZ_WAYBILL_INFO
  20 + where WAYBILL_ID = #{waybillNoMaster,jdbcType=VARCHAR}
  21 + </select>
  22 +</mapper>
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3 +<mapper namespace="com.sunyo.wlpt.cgoasm.arrival.mapper.SdBigTypeMapper">
  4 + <resultMap id="BaseResultMap" type="com.sunyo.wlpt.cgoasm.arrival.domain.SdBigType">
  5 + <!--@mbg.generated-->
  6 + <!--@Table SD_BIG_TYPE-->
  7 + <id column="ID" jdbcType="DECIMAL" property="id" />
  8 + <result column="TYPE_NAME" jdbcType="VARCHAR" property="typeName" />
  9 + </resultMap>
  10 + <sql id="Base_Column_List">
  11 + <!--@mbg.generated-->
  12 + ID, TYPE_NAME
  13 + </sql>
  14 + <select id="getSdBigTypeInfo" parameterType="java.math.BigDecimal" resultMap="BaseResultMap">
  15 + select
  16 + <include refid="Base_Column_List"/>
  17 + from SD_BIG_TYPE
  18 + where ID = #{bigTypeId,jdbcType=DECIMAL}
  19 + </select>
  20 +</mapper>
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3 +<mapper namespace="com.sunyo.wlpt.cgoasm.arrival.mapper.SdCargoNameMapper">
  4 + <resultMap id="BaseResultMap" type="com.sunyo.wlpt.cgoasm.arrival.domain.SdCargoName">
  5 + <!--@mbg.generated-->
  6 + <!--@Table SD_CARGO_NAME-->
  7 + <result column="SD_WAYBILL" jdbcType="VARCHAR" property="sdWaybill"/>
  8 + <result column="SD_CARGO_NAME" jdbcType="VARCHAR" property="sdCargoName"/>
  9 +
  10 + </resultMap>
  11 + <sql id="Base_Column_List">
  12 + <!--@mbg.generated-->
  13 + SD_WAYBILL, SD_CARGO_NAME
  14 + </sql>
  15 + <select id="getSdCargoName" parameterType="java.lang.String"
  16 + resultMap="BaseResultMap">
  17 + select
  18 + <include refid="Base_Column_List"/>
  19 + from
  20 + SD_CARGO_NAME
  21 + where
  22 + SD_WAYBILL=#{waybillNoMaster,jdbcType=VARCHAR}
  23 +
  24 + </select>
  25 +</mapper>
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3 +<mapper namespace="com.sunyo.wlpt.cgoasm.arrival.mapper.SdTwoTypeMapper">
  4 + <resultMap id="BaseResultMap" type="com.sunyo.wlpt.cgoasm.arrival.domain.SdTwoType">
  5 + <!--@mbg.generated-->
  6 + <!--@Table SD_TWO_TYPE-->
  7 + <result column="TWO_TYPE_NAME" jdbcType="VARCHAR" property="twoTypeName"/>
  8 + <result column="BIG_TYPE_ID" jdbcType="DECIMAL" property="bigTypeId"/>
  9 + <result column="CARGO_NAME" jdbcType="VARCHAR" property="cargoName"/>
  10 + </resultMap>
  11 + <sql id="Base_Column_List">
  12 + <!--@mbg.generated-->
  13 + TWO_TYPE_NAME, BIG_TYPE_ID, CARGO_NAME
  14 + </sql>
  15 + <select id="getSdTwoTypeInfo" parameterType="java.lang.String" resultMap="BaseResultMap">
  16 + select
  17 + <include refid="Base_Column_List"/>
  18 + from SD_TWO_TYPE
  19 + where CARGO_NAME = #{sdCargoName,jdbcType=VARCHAR}
  20 + </select>
  21 +</mapper>