Toggle navigation
Toggle navigation
This project
Loading...
Sign in
Fedex
/
iClear-Connect-Pre-Clearance
Go to a project
Toggle navigation
Toggle navigation pinning
Projects
Groups
Snippets
Help
Project
Activity
Repository
Pipelines
Graphs
Issues
0
Merge Requests
0
Wiki
Snippets
Network
Create a new issue
Builds
Commits
Issue Boards
Authored by
tao.mo
2024-10-31 18:40:09 +0800
Browse Files
Options
Browse Files
Download
Email Patches
Plain Diff
Commit
cdcce413b225f2c2adb1ed933fd73ad65d4f7fc2
cdcce413
1 parent
82f26b7a
系统基础配置
mt 2024年10月31日18:39:56
Hide whitespace changes
Inline
Side-by-side
Showing
18 changed files
with
1314 additions
and
34 deletions
server/base-starter/src/main/java/com/fedex/connect/base/autoconfiguration/AutoConfiguration.java
server/base-starter/src/main/resources/META-INF/spring.factories
server/biz-customer/src/main/java/com/fedex/connect/customer/CustomerApplication.java
server/biz-customer/src/main/java/com/fedex/connect/customer/package-info.java
server/common-dao/pom.xml
server/common-dao/src/main/java/com/fedex/connect/common/mapper/biz/CeInfoMapper.xml
server/common-dao/src/main/java/com/fedex/connect/common/model/biz/CeInfo.java
server/common-dao/src/main/resources/generatorConfig.xml
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/KafkaApplication.java
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/base/AbstractDaoRepository.java
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/dao/CeInfoMapperExt.java
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/repo/ICeInfoRepository.java
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/repo/impl/CeInfoRepositoryImpl.java
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/service/impl/Dm501ServiceImpl.java
server/manager-server/src/main/java/com/fedex/connect/manager/ManagerApplication.java
server/manager-server/src/main/java/com/fedex/connect/manager/package-info.java
server/task-schedule/src/main/java/com/fedex/connect/task/TaskApplication.java
server/task-schedule/src/main/java/com/fedex/connect/task/package-info.java
server/base-starter/src/main/java/com/fedex/connect/base/autoconfiguration/AutoConfiguration.java
View file @
cdcce41
...
...
@@ -2,6 +2,6 @@ package com.fedex.connect.base.autoconfiguration;
import
org.springframework.context.annotation.ComponentScan
;
@ComponentScan
(
value
=
{
"com.fedex.base"
})
@ComponentScan
(
value
=
{
"com.fedex.
connect.
base"
})
public
class
AutoConfiguration
{
}
...
...
server/base-starter/src/main/resources/META-INF/spring.factories
View file @
cdcce41
org.springframework.boot.autoconfigure.EnableAutoConfiguration=com.fedex.base.autoconfiguration.AutoConfiguration
\ No newline at end of file
org.springframework.boot.autoconfigure.EnableAutoConfiguration=com.fedex.connect.base.autoconfiguration.AutoConfiguration
\ No newline at end of file
...
...
server/biz-customer/src/main/java/com/fedex/connect/customer/CustomerApplication.java
0 → 100644
View file @
cdcce41
package
com
.
fedex
.
connect
.
customer
;
import
org.mybatis.spring.annotation.MapperScan
;
import
org.springframework.boot.SpringApplication
;
import
org.springframework.boot.autoconfigure.SpringBootApplication
;
import
org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration
;
import
org.springframework.boot.builder.SpringApplicationBuilder
;
import
org.springframework.boot.web.servlet.support.SpringBootServletInitializer
;
import
org.springframework.transaction.annotation.EnableTransactionManagement
;
import
org.springframework.web.WebApplicationInitializer
;
import
springfox.documentation.swagger2.annotations.EnableSwagger2
;
@SpringBootApplication
(
exclude
=
SecurityAutoConfiguration
.
class
)
@MapperScan
({
"com.fedex.connect.common.dao.*.**"
,
"com.fedex.connect.customer.repository.dao.*"
})
@EnableTransactionManagement
@EnableSwagger2
public
class
CustomerApplication
extends
SpringBootServletInitializer
implements
WebApplicationInitializer
{
public
static
void
main
(
String
[]
args
)
{
SpringApplication
.
run
(
CustomerApplication
.
class
,
args
);
}
@Override
protected
SpringApplicationBuilder
configure
(
SpringApplicationBuilder
builder
)
{
return
builder
.
sources
(
CustomerApplication
.
class
);
}
}
server/biz-customer/src/main/java/com/fedex/connect/customer/package-info.java
deleted
100644 → 0
View file @
82f26b7
package
com
.
fedex
.
connect
.
common
.
customer
;
\ No newline at end of file
server/common-dao/pom.xml
View file @
cdcce41
...
...
@@ -83,23 +83,23 @@
</dependency>
</dependencies>
</plugin>
<plugin
>
<groupId>
org.apache.maven.plugins
</groupId
>
<artifactId>
maven-javadoc-plugin
</artifactId
>
<version>
2.10.2
</version
>
<configuration
>
<aggregate>
true
</aggregate
>
</configuration
>
<executions
>
<execution
>
<id>
attach-javadocs
</id
>
<goals
>
<goal>
jar
</goal
>
</goals
>
</execution
>
</executions
>
</plugin
>
<!--输出doc文档插件禁用-->
<!-- <plugin>--
>
<!-- <groupId>org.apache.maven.plugins</groupId>--
>
<!-- <artifactId>maven-javadoc-plugin</artifactId>--
>
<!-- <version>2.10.2</version>--
>
<!-- <configuration>--
>
<!-- <aggregate>true</aggregate>--
>
<!-- </configuration>--
>
<!-- <executions>--
>
<!-- <execution>--
>
<!-- <id>attach-javadocs</id>--
>
<!-- <goals>--
>
<!-- <goal>jar</goal>--
>
<!-- </goals>--
>
<!-- </execution>--
>
<!-- </executions>--
>
<!-- </plugin>--
>
</plugins>
</build>
</project>
\ No newline at end of file
...
...
server/common-dao/src/main/java/com/fedex/connect/common/mapper/biz/CeInfoMapper.xml
0 → 100644
View file @
cdcce41
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper
namespace=
"com.fedex.connect.common.dao.biz.CeInfoMapper"
>
<resultMap
id=
"BaseResultMap"
type=
"com.fedex.connect.common.model.biz.CeInfo"
>
<id
column=
"ID"
jdbcType=
"NUMERIC"
property=
"id"
/>
<result
column=
"CONSIGNMENT_CODE"
jdbcType=
"VARCHAR"
property=
"consignmentCode"
/>
<result
column=
"SEND_TIME"
jdbcType=
"TIMESTAMP"
property=
"sendTime"
/>
<result
column=
"SHIP_DATE"
jdbcType=
"TIMESTAMP"
property=
"shipDate"
/>
<result
column=
"SHIPPER_COUNTRY"
jdbcType=
"VARCHAR"
property=
"shipperCountry"
/>
<result
column=
"RECIPIENT_COUNTRY"
jdbcType=
"VARCHAR"
property=
"recipientCountry"
/>
<result
column=
"DEST_IATA_CODE"
jdbcType=
"VARCHAR"
property=
"destIataCode"
/>
<result
column=
"CREATE_TIME"
jdbcType=
"TIMESTAMP"
property=
"createTime"
/>
<result
column=
"CREATE_USER_ID"
jdbcType=
"NUMERIC"
property=
"createUserId"
/>
<result
column=
"CREATE_USER_NAME"
jdbcType=
"VARCHAR"
property=
"createUserName"
/>
<result
column=
"MODIFY_TIME"
jdbcType=
"TIMESTAMP"
property=
"modifyTime"
/>
<result
column=
"MODIFY_USER_ID"
jdbcType=
"NUMERIC"
property=
"modifyUserId"
/>
<result
column=
"MODIFY_USER_NAME"
jdbcType=
"VARCHAR"
property=
"modifyUserName"
/>
<result
column=
"COUNT_ORIGIN"
jdbcType=
"VARCHAR"
property=
"countOrigin"
/>
<result
column=
"DESTINATION_COUNTRY"
jdbcType=
"VARCHAR"
property=
"destinationCountry"
/>
<result
column=
"CUSTOMS_CURRENCY"
jdbcType=
"VARCHAR"
property=
"customsCurrency"
/>
<result
column=
"CUSTOMS_VALUE"
jdbcType=
"NUMERIC"
property=
"customsValue"
/>
<result
column=
"WEIGHT"
jdbcType=
"NUMERIC"
property=
"weight"
/>
<result
column=
"WEIGHTUNIT"
jdbcType=
"NUMERIC"
property=
"weightunit"
/>
<result
column=
"SCANDATE"
jdbcType=
"TIMESTAMP"
property=
"scandate"
/>
<result
column=
"SHIPPER_CONTACT_NAME"
jdbcType=
"VARCHAR"
property=
"shipperContactName"
/>
<result
column=
"SHIPPER_PHONE"
jdbcType=
"VARCHAR"
property=
"shipperPhone"
/>
<result
column=
"SHIPPER_ACCOUNT"
jdbcType=
"VARCHAR"
property=
"shipperAccount"
/>
<result
column=
"SHIPPER_COMPANY"
jdbcType=
"VARCHAR"
property=
"shipperCompany"
/>
<result
column=
"SHIPPER_ADDR_LINE1"
jdbcType=
"VARCHAR"
property=
"shipperAddrLine1"
/>
<result
column=
"SHIPPER_ADDR_LINE2"
jdbcType=
"VARCHAR"
property=
"shipperAddrLine2"
/>
<result
column=
"SHIPPER_CITY"
jdbcType=
"VARCHAR"
property=
"shipperCity"
/>
<result
column=
"SHIPPER_EMAIL"
jdbcType=
"VARCHAR"
property=
"shipperEmail"
/>
<result
column=
"RECIPIENT_CONTACT_NAME"
jdbcType=
"VARCHAR"
property=
"recipientContactName"
/>
<result
column=
"RECIPIENT_PHONE"
jdbcType=
"VARCHAR"
property=
"recipientPhone"
/>
<result
column=
"RECIPIENT_COMPANY"
jdbcType=
"VARCHAR"
property=
"recipientCompany"
/>
<result
column=
"RECIPIENT_ADDR_LINE1"
jdbcType=
"VARCHAR"
property=
"recipientAddrLine1"
/>
<result
column=
"RECIPIENT_ADDR_LINE2"
jdbcType=
"VARCHAR"
property=
"recipientAddrLine2"
/>
<result
column=
"RECIPIENT_ADDR_LINE3"
jdbcType=
"VARCHAR"
property=
"recipientAddrLine3"
/>
<result
column=
"RECIPIENT_CITY"
jdbcType=
"VARCHAR"
property=
"recipientCity"
/>
</resultMap>
<sql
id=
"Example_Where_Clause"
>
<where>
<foreach
collection=
"oredCriteria"
item=
"criteria"
separator=
"or"
>
<if
test=
"criteria.valid"
>
<trim
prefix=
"("
prefixOverrides=
"and"
suffix=
")"
>
<foreach
collection=
"criteria.criteria"
item=
"criterion"
>
<choose>
<when
test=
"criterion.noValue"
>
and ${criterion.condition}
</when>
<when
test=
"criterion.singleValue"
>
and ${criterion.condition} #{criterion.value}
</when>
<when
test=
"criterion.betweenValue"
>
and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
</when>
<when
test=
"criterion.listValue"
>
and ${criterion.condition}
<foreach
close=
")"
collection=
"criterion.value"
item=
"listItem"
open=
"("
separator=
","
>
#{listItem}
</foreach>
</when>
</choose>
</foreach>
</trim>
</if>
</foreach>
</where>
</sql>
<sql
id=
"Update_By_Example_Where_Clause"
>
<where>
<foreach
collection=
"example.oredCriteria"
item=
"criteria"
separator=
"or"
>
<if
test=
"criteria.valid"
>
<trim
prefix=
"("
prefixOverrides=
"and"
suffix=
")"
>
<foreach
collection=
"criteria.criteria"
item=
"criterion"
>
<choose>
<when
test=
"criterion.noValue"
>
and ${criterion.condition}
</when>
<when
test=
"criterion.singleValue"
>
and ${criterion.condition} #{criterion.value}
</when>
<when
test=
"criterion.betweenValue"
>
and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
</when>
<when
test=
"criterion.listValue"
>
and ${criterion.condition}
<foreach
close=
")"
collection=
"criterion.value"
item=
"listItem"
open=
"("
separator=
","
>
#{listItem}
</foreach>
</when>
</choose>
</foreach>
</trim>
</if>
</foreach>
</where>
</sql>
<sql
id=
"Base_Column_List"
>
ID, CONSIGNMENT_CODE, SEND_TIME, SHIP_DATE, SHIPPER_COUNTRY, RECIPIENT_COUNTRY, DEST_IATA_CODE,
CREATE_TIME, CREATE_USER_ID, CREATE_USER_NAME, MODIFY_TIME, MODIFY_USER_ID, MODIFY_USER_NAME,
COUNT_ORIGIN, DESTINATION_COUNTRY, CUSTOMS_CURRENCY, CUSTOMS_VALUE, WEIGHT, WEIGHTUNIT,
SCANDATE, SHIPPER_CONTACT_NAME, SHIPPER_PHONE, SHIPPER_ACCOUNT, SHIPPER_COMPANY,
SHIPPER_ADDR_LINE1, SHIPPER_ADDR_LINE2, SHIPPER_CITY, SHIPPER_EMAIL, RECIPIENT_CONTACT_NAME,
RECIPIENT_PHONE, RECIPIENT_COMPANY, RECIPIENT_ADDR_LINE1, RECIPIENT_ADDR_LINE2, RECIPIENT_ADDR_LINE3,
RECIPIENT_CITY
</sql>
<select
id=
"selectByExample"
parameterType=
"com.fedex.connect.common.model.biz.CeInfoExample"
resultMap=
"BaseResultMap"
>
<include
refid=
"OracleDialectPrefix"
/>
select
<if
test=
"distinct"
>
distinct
</if>
'true' as QUERYID,
<include
refid=
"Base_Column_List"
/>
from ICLEARIMP.T_BIZ_CE_INFO
<if
test=
"_parameter != null"
>
<include
refid=
"Example_Where_Clause"
/>
</if>
<if
test=
"orderByClause != null"
>
order by ${orderByClause}
</if>
<include
refid=
"OracleDialectSuffix"
/>
</select>
<select
id=
"selectByPrimaryKey"
parameterType=
"java.lang.Long"
resultMap=
"BaseResultMap"
>
select
<include
refid=
"Base_Column_List"
/>
from ICLEARIMP.T_BIZ_CE_INFO
where ID = #{id,jdbcType=NUMERIC}
</select>
<delete
id=
"deleteByPrimaryKey"
parameterType=
"java.lang.Long"
>
delete from ICLEARIMP.T_BIZ_CE_INFO
where ID = #{id,jdbcType=NUMERIC}
</delete>
<delete
id=
"deleteByExample"
parameterType=
"com.fedex.connect.common.model.biz.CeInfoExample"
>
delete from ICLEARIMP.T_BIZ_CE_INFO
<if
test=
"_parameter != null"
>
<include
refid=
"Example_Where_Clause"
/>
</if>
</delete>
<insert
id=
"insert"
parameterType=
"com.fedex.connect.common.model.biz.CeInfo"
>
<selectKey
keyProperty=
"id"
order=
"BEFORE"
resultType=
"java.lang.Long"
>
SELECT SEQ_T_BIZ_CE_INFO.NEXTVAL FROM DUAL
</selectKey>
insert into ICLEARIMP.T_BIZ_CE_INFO (ID, CONSIGNMENT_CODE, SEND_TIME,
SHIP_DATE, SHIPPER_COUNTRY, RECIPIENT_COUNTRY,
DEST_IATA_CODE, CREATE_TIME, CREATE_USER_ID,
CREATE_USER_NAME, MODIFY_TIME, MODIFY_USER_ID,
MODIFY_USER_NAME, COUNT_ORIGIN, DESTINATION_COUNTRY,
CUSTOMS_CURRENCY, CUSTOMS_VALUE, WEIGHT,
WEIGHTUNIT, SCANDATE, SHIPPER_CONTACT_NAME,
SHIPPER_PHONE, SHIPPER_ACCOUNT, SHIPPER_COMPANY,
SHIPPER_ADDR_LINE1, SHIPPER_ADDR_LINE2, SHIPPER_CITY,
SHIPPER_EMAIL, RECIPIENT_CONTACT_NAME, RECIPIENT_PHONE,
RECIPIENT_COMPANY, RECIPIENT_ADDR_LINE1, RECIPIENT_ADDR_LINE2,
RECIPIENT_ADDR_LINE3, RECIPIENT_CITY)
values (#{id,jdbcType=NUMERIC}, #{consignmentCode,jdbcType=VARCHAR}, #{sendTime,jdbcType=TIMESTAMP},
#{shipDate,jdbcType=TIMESTAMP}, #{shipperCountry,jdbcType=VARCHAR}, #{recipientCountry,jdbcType=VARCHAR},
#{destIataCode,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP}, #{createUserId,jdbcType=NUMERIC},
#{createUserName,jdbcType=VARCHAR}, #{modifyTime,jdbcType=TIMESTAMP}, #{modifyUserId,jdbcType=NUMERIC},
#{modifyUserName,jdbcType=VARCHAR}, #{countOrigin,jdbcType=VARCHAR}, #{destinationCountry,jdbcType=VARCHAR},
#{customsCurrency,jdbcType=VARCHAR}, #{customsValue,jdbcType=NUMERIC}, #{weight,jdbcType=NUMERIC},
#{weightunit,jdbcType=NUMERIC}, #{scandate,jdbcType=TIMESTAMP}, #{shipperContactName,jdbcType=VARCHAR},
#{shipperPhone,jdbcType=VARCHAR}, #{shipperAccount,jdbcType=VARCHAR}, #{shipperCompany,jdbcType=VARCHAR},
#{shipperAddrLine1,jdbcType=VARCHAR}, #{shipperAddrLine2,jdbcType=VARCHAR}, #{shipperCity,jdbcType=VARCHAR},
#{shipperEmail,jdbcType=VARCHAR}, #{recipientContactName,jdbcType=VARCHAR}, #{recipientPhone,jdbcType=VARCHAR},
#{recipientCompany,jdbcType=VARCHAR}, #{recipientAddrLine1,jdbcType=VARCHAR}, #{recipientAddrLine2,jdbcType=VARCHAR},
#{recipientAddrLine3,jdbcType=VARCHAR}, #{recipientCity,jdbcType=VARCHAR})
</insert>
<insert
id=
"insertSelective"
parameterType=
"com.fedex.connect.common.model.biz.CeInfo"
>
<selectKey
keyProperty=
"id"
order=
"BEFORE"
resultType=
"java.lang.Long"
>
SELECT SEQ_T_BIZ_CE_INFO.NEXTVAL FROM DUAL
</selectKey>
insert into ICLEARIMP.T_BIZ_CE_INFO
<trim
prefix=
"("
suffix=
")"
suffixOverrides=
","
>
ID,
<if
test=
"consignmentCode != null"
>
CONSIGNMENT_CODE,
</if>
<if
test=
"sendTime != null"
>
SEND_TIME,
</if>
<if
test=
"shipDate != null"
>
SHIP_DATE,
</if>
<if
test=
"shipperCountry != null"
>
SHIPPER_COUNTRY,
</if>
<if
test=
"recipientCountry != null"
>
RECIPIENT_COUNTRY,
</if>
<if
test=
"destIataCode != null"
>
DEST_IATA_CODE,
</if>
<if
test=
"createTime != null"
>
CREATE_TIME,
</if>
<if
test=
"createUserId != null"
>
CREATE_USER_ID,
</if>
<if
test=
"createUserName != null"
>
CREATE_USER_NAME,
</if>
<if
test=
"modifyTime != null"
>
MODIFY_TIME,
</if>
<if
test=
"modifyUserId != null"
>
MODIFY_USER_ID,
</if>
<if
test=
"modifyUserName != null"
>
MODIFY_USER_NAME,
</if>
<if
test=
"countOrigin != null"
>
COUNT_ORIGIN,
</if>
<if
test=
"destinationCountry != null"
>
DESTINATION_COUNTRY,
</if>
<if
test=
"customsCurrency != null"
>
CUSTOMS_CURRENCY,
</if>
<if
test=
"customsValue != null"
>
CUSTOMS_VALUE,
</if>
<if
test=
"weight != null"
>
WEIGHT,
</if>
<if
test=
"weightunit != null"
>
WEIGHTUNIT,
</if>
<if
test=
"scandate != null"
>
SCANDATE,
</if>
<if
test=
"shipperContactName != null"
>
SHIPPER_CONTACT_NAME,
</if>
<if
test=
"shipperPhone != null"
>
SHIPPER_PHONE,
</if>
<if
test=
"shipperAccount != null"
>
SHIPPER_ACCOUNT,
</if>
<if
test=
"shipperCompany != null"
>
SHIPPER_COMPANY,
</if>
<if
test=
"shipperAddrLine1 != null"
>
SHIPPER_ADDR_LINE1,
</if>
<if
test=
"shipperAddrLine2 != null"
>
SHIPPER_ADDR_LINE2,
</if>
<if
test=
"shipperCity != null"
>
SHIPPER_CITY,
</if>
<if
test=
"shipperEmail != null"
>
SHIPPER_EMAIL,
</if>
<if
test=
"recipientContactName != null"
>
RECIPIENT_CONTACT_NAME,
</if>
<if
test=
"recipientPhone != null"
>
RECIPIENT_PHONE,
</if>
<if
test=
"recipientCompany != null"
>
RECIPIENT_COMPANY,
</if>
<if
test=
"recipientAddrLine1 != null"
>
RECIPIENT_ADDR_LINE1,
</if>
<if
test=
"recipientAddrLine2 != null"
>
RECIPIENT_ADDR_LINE2,
</if>
<if
test=
"recipientAddrLine3 != null"
>
RECIPIENT_ADDR_LINE3,
</if>
<if
test=
"recipientCity != null"
>
RECIPIENT_CITY,
</if>
</trim>
<trim
prefix=
"values ("
suffix=
")"
suffixOverrides=
","
>
#{id,jdbcType=NUMERIC},
<if
test=
"consignmentCode != null"
>
#{consignmentCode,jdbcType=VARCHAR},
</if>
<if
test=
"sendTime != null"
>
#{sendTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"shipDate != null"
>
#{shipDate,jdbcType=TIMESTAMP},
</if>
<if
test=
"shipperCountry != null"
>
#{shipperCountry,jdbcType=VARCHAR},
</if>
<if
test=
"recipientCountry != null"
>
#{recipientCountry,jdbcType=VARCHAR},
</if>
<if
test=
"destIataCode != null"
>
#{destIataCode,jdbcType=VARCHAR},
</if>
<if
test=
"createTime != null"
>
#{createTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"createUserId != null"
>
#{createUserId,jdbcType=NUMERIC},
</if>
<if
test=
"createUserName != null"
>
#{createUserName,jdbcType=VARCHAR},
</if>
<if
test=
"modifyTime != null"
>
#{modifyTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"modifyUserId != null"
>
#{modifyUserId,jdbcType=NUMERIC},
</if>
<if
test=
"modifyUserName != null"
>
#{modifyUserName,jdbcType=VARCHAR},
</if>
<if
test=
"countOrigin != null"
>
#{countOrigin,jdbcType=VARCHAR},
</if>
<if
test=
"destinationCountry != null"
>
#{destinationCountry,jdbcType=VARCHAR},
</if>
<if
test=
"customsCurrency != null"
>
#{customsCurrency,jdbcType=VARCHAR},
</if>
<if
test=
"customsValue != null"
>
#{customsValue,jdbcType=NUMERIC},
</if>
<if
test=
"weight != null"
>
#{weight,jdbcType=NUMERIC},
</if>
<if
test=
"weightunit != null"
>
#{weightunit,jdbcType=NUMERIC},
</if>
<if
test=
"scandate != null"
>
#{scandate,jdbcType=TIMESTAMP},
</if>
<if
test=
"shipperContactName != null"
>
#{shipperContactName,jdbcType=VARCHAR},
</if>
<if
test=
"shipperPhone != null"
>
#{shipperPhone,jdbcType=VARCHAR},
</if>
<if
test=
"shipperAccount != null"
>
#{shipperAccount,jdbcType=VARCHAR},
</if>
<if
test=
"shipperCompany != null"
>
#{shipperCompany,jdbcType=VARCHAR},
</if>
<if
test=
"shipperAddrLine1 != null"
>
#{shipperAddrLine1,jdbcType=VARCHAR},
</if>
<if
test=
"shipperAddrLine2 != null"
>
#{shipperAddrLine2,jdbcType=VARCHAR},
</if>
<if
test=
"shipperCity != null"
>
#{shipperCity,jdbcType=VARCHAR},
</if>
<if
test=
"shipperEmail != null"
>
#{shipperEmail,jdbcType=VARCHAR},
</if>
<if
test=
"recipientContactName != null"
>
#{recipientContactName,jdbcType=VARCHAR},
</if>
<if
test=
"recipientPhone != null"
>
#{recipientPhone,jdbcType=VARCHAR},
</if>
<if
test=
"recipientCompany != null"
>
#{recipientCompany,jdbcType=VARCHAR},
</if>
<if
test=
"recipientAddrLine1 != null"
>
#{recipientAddrLine1,jdbcType=VARCHAR},
</if>
<if
test=
"recipientAddrLine2 != null"
>
#{recipientAddrLine2,jdbcType=VARCHAR},
</if>
<if
test=
"recipientAddrLine3 != null"
>
#{recipientAddrLine3,jdbcType=VARCHAR},
</if>
<if
test=
"recipientCity != null"
>
#{recipientCity,jdbcType=VARCHAR},
</if>
</trim>
</insert>
<select
id=
"countByExample"
parameterType=
"com.fedex.connect.common.model.biz.CeInfoExample"
resultType=
"java.lang.Long"
>
select count(*) from ICLEARIMP.T_BIZ_CE_INFO
<if
test=
"_parameter != null"
>
<include
refid=
"Example_Where_Clause"
/>
</if>
</select>
<update
id=
"updateByExampleSelective"
parameterType=
"map"
>
update ICLEARIMP.T_BIZ_CE_INFO
<set>
<if
test=
"record.id != null"
>
ID = #{record.id,jdbcType=NUMERIC},
</if>
<if
test=
"record.consignmentCode != null"
>
CONSIGNMENT_CODE = #{record.consignmentCode,jdbcType=VARCHAR},
</if>
<if
test=
"record.sendTime != null"
>
SEND_TIME = #{record.sendTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"record.shipDate != null"
>
SHIP_DATE = #{record.shipDate,jdbcType=TIMESTAMP},
</if>
<if
test=
"record.shipperCountry != null"
>
SHIPPER_COUNTRY = #{record.shipperCountry,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientCountry != null"
>
RECIPIENT_COUNTRY = #{record.recipientCountry,jdbcType=VARCHAR},
</if>
<if
test=
"record.destIataCode != null"
>
DEST_IATA_CODE = #{record.destIataCode,jdbcType=VARCHAR},
</if>
<if
test=
"record.createTime != null"
>
CREATE_TIME = #{record.createTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"record.createUserId != null"
>
CREATE_USER_ID = #{record.createUserId,jdbcType=NUMERIC},
</if>
<if
test=
"record.createUserName != null"
>
CREATE_USER_NAME = #{record.createUserName,jdbcType=VARCHAR},
</if>
<if
test=
"record.modifyTime != null"
>
MODIFY_TIME = #{record.modifyTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"record.modifyUserId != null"
>
MODIFY_USER_ID = #{record.modifyUserId,jdbcType=NUMERIC},
</if>
<if
test=
"record.modifyUserName != null"
>
MODIFY_USER_NAME = #{record.modifyUserName,jdbcType=VARCHAR},
</if>
<if
test=
"record.countOrigin != null"
>
COUNT_ORIGIN = #{record.countOrigin,jdbcType=VARCHAR},
</if>
<if
test=
"record.destinationCountry != null"
>
DESTINATION_COUNTRY = #{record.destinationCountry,jdbcType=VARCHAR},
</if>
<if
test=
"record.customsCurrency != null"
>
CUSTOMS_CURRENCY = #{record.customsCurrency,jdbcType=VARCHAR},
</if>
<if
test=
"record.customsValue != null"
>
CUSTOMS_VALUE = #{record.customsValue,jdbcType=NUMERIC},
</if>
<if
test=
"record.weight != null"
>
WEIGHT = #{record.weight,jdbcType=NUMERIC},
</if>
<if
test=
"record.weightunit != null"
>
WEIGHTUNIT = #{record.weightunit,jdbcType=NUMERIC},
</if>
<if
test=
"record.scandate != null"
>
SCANDATE = #{record.scandate,jdbcType=TIMESTAMP},
</if>
<if
test=
"record.shipperContactName != null"
>
SHIPPER_CONTACT_NAME = #{record.shipperContactName,jdbcType=VARCHAR},
</if>
<if
test=
"record.shipperPhone != null"
>
SHIPPER_PHONE = #{record.shipperPhone,jdbcType=VARCHAR},
</if>
<if
test=
"record.shipperAccount != null"
>
SHIPPER_ACCOUNT = #{record.shipperAccount,jdbcType=VARCHAR},
</if>
<if
test=
"record.shipperCompany != null"
>
SHIPPER_COMPANY = #{record.shipperCompany,jdbcType=VARCHAR},
</if>
<if
test=
"record.shipperAddrLine1 != null"
>
SHIPPER_ADDR_LINE1 = #{record.shipperAddrLine1,jdbcType=VARCHAR},
</if>
<if
test=
"record.shipperAddrLine2 != null"
>
SHIPPER_ADDR_LINE2 = #{record.shipperAddrLine2,jdbcType=VARCHAR},
</if>
<if
test=
"record.shipperCity != null"
>
SHIPPER_CITY = #{record.shipperCity,jdbcType=VARCHAR},
</if>
<if
test=
"record.shipperEmail != null"
>
SHIPPER_EMAIL = #{record.shipperEmail,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientContactName != null"
>
RECIPIENT_CONTACT_NAME = #{record.recipientContactName,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientPhone != null"
>
RECIPIENT_PHONE = #{record.recipientPhone,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientCompany != null"
>
RECIPIENT_COMPANY = #{record.recipientCompany,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientAddrLine1 != null"
>
RECIPIENT_ADDR_LINE1 = #{record.recipientAddrLine1,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientAddrLine2 != null"
>
RECIPIENT_ADDR_LINE2 = #{record.recipientAddrLine2,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientAddrLine3 != null"
>
RECIPIENT_ADDR_LINE3 = #{record.recipientAddrLine3,jdbcType=VARCHAR},
</if>
<if
test=
"record.recipientCity != null"
>
RECIPIENT_CITY = #{record.recipientCity,jdbcType=VARCHAR},
</if>
</set>
<if
test=
"_parameter != null"
>
<include
refid=
"Update_By_Example_Where_Clause"
/>
</if>
</update>
<update
id=
"updateByExample"
parameterType=
"map"
>
update ICLEARIMP.T_BIZ_CE_INFO
set ID = #{record.id,jdbcType=NUMERIC},
CONSIGNMENT_CODE = #{record.consignmentCode,jdbcType=VARCHAR},
SEND_TIME = #{record.sendTime,jdbcType=TIMESTAMP},
SHIP_DATE = #{record.shipDate,jdbcType=TIMESTAMP},
SHIPPER_COUNTRY = #{record.shipperCountry,jdbcType=VARCHAR},
RECIPIENT_COUNTRY = #{record.recipientCountry,jdbcType=VARCHAR},
DEST_IATA_CODE = #{record.destIataCode,jdbcType=VARCHAR},
CREATE_TIME = #{record.createTime,jdbcType=TIMESTAMP},
CREATE_USER_ID = #{record.createUserId,jdbcType=NUMERIC},
CREATE_USER_NAME = #{record.createUserName,jdbcType=VARCHAR},
MODIFY_TIME = #{record.modifyTime,jdbcType=TIMESTAMP},
MODIFY_USER_ID = #{record.modifyUserId,jdbcType=NUMERIC},
MODIFY_USER_NAME = #{record.modifyUserName,jdbcType=VARCHAR},
COUNT_ORIGIN = #{record.countOrigin,jdbcType=VARCHAR},
DESTINATION_COUNTRY = #{record.destinationCountry,jdbcType=VARCHAR},
CUSTOMS_CURRENCY = #{record.customsCurrency,jdbcType=VARCHAR},
CUSTOMS_VALUE = #{record.customsValue,jdbcType=NUMERIC},
WEIGHT = #{record.weight,jdbcType=NUMERIC},
WEIGHTUNIT = #{record.weightunit,jdbcType=NUMERIC},
SCANDATE = #{record.scandate,jdbcType=TIMESTAMP},
SHIPPER_CONTACT_NAME = #{record.shipperContactName,jdbcType=VARCHAR},
SHIPPER_PHONE = #{record.shipperPhone,jdbcType=VARCHAR},
SHIPPER_ACCOUNT = #{record.shipperAccount,jdbcType=VARCHAR},
SHIPPER_COMPANY = #{record.shipperCompany,jdbcType=VARCHAR},
SHIPPER_ADDR_LINE1 = #{record.shipperAddrLine1,jdbcType=VARCHAR},
SHIPPER_ADDR_LINE2 = #{record.shipperAddrLine2,jdbcType=VARCHAR},
SHIPPER_CITY = #{record.shipperCity,jdbcType=VARCHAR},
SHIPPER_EMAIL = #{record.shipperEmail,jdbcType=VARCHAR},
RECIPIENT_CONTACT_NAME = #{record.recipientContactName,jdbcType=VARCHAR},
RECIPIENT_PHONE = #{record.recipientPhone,jdbcType=VARCHAR},
RECIPIENT_COMPANY = #{record.recipientCompany,jdbcType=VARCHAR},
RECIPIENT_ADDR_LINE1 = #{record.recipientAddrLine1,jdbcType=VARCHAR},
RECIPIENT_ADDR_LINE2 = #{record.recipientAddrLine2,jdbcType=VARCHAR},
RECIPIENT_ADDR_LINE3 = #{record.recipientAddrLine3,jdbcType=VARCHAR},
RECIPIENT_CITY = #{record.recipientCity,jdbcType=VARCHAR}
<if
test=
"_parameter != null"
>
<include
refid=
"Update_By_Example_Where_Clause"
/>
</if>
</update>
<update
id=
"updateByPrimaryKeySelective"
parameterType=
"com.fedex.connect.common.model.biz.CeInfo"
>
update ICLEARIMP.T_BIZ_CE_INFO
<set>
<if
test=
"consignmentCode != null"
>
CONSIGNMENT_CODE = #{consignmentCode,jdbcType=VARCHAR},
</if>
<if
test=
"sendTime != null"
>
SEND_TIME = #{sendTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"shipDate != null"
>
SHIP_DATE = #{shipDate,jdbcType=TIMESTAMP},
</if>
<if
test=
"shipperCountry != null"
>
SHIPPER_COUNTRY = #{shipperCountry,jdbcType=VARCHAR},
</if>
<if
test=
"recipientCountry != null"
>
RECIPIENT_COUNTRY = #{recipientCountry,jdbcType=VARCHAR},
</if>
<if
test=
"destIataCode != null"
>
DEST_IATA_CODE = #{destIataCode,jdbcType=VARCHAR},
</if>
<if
test=
"createTime != null"
>
CREATE_TIME = #{createTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"createUserId != null"
>
CREATE_USER_ID = #{createUserId,jdbcType=NUMERIC},
</if>
<if
test=
"createUserName != null"
>
CREATE_USER_NAME = #{createUserName,jdbcType=VARCHAR},
</if>
<if
test=
"modifyTime != null"
>
MODIFY_TIME = #{modifyTime,jdbcType=TIMESTAMP},
</if>
<if
test=
"modifyUserId != null"
>
MODIFY_USER_ID = #{modifyUserId,jdbcType=NUMERIC},
</if>
<if
test=
"modifyUserName != null"
>
MODIFY_USER_NAME = #{modifyUserName,jdbcType=VARCHAR},
</if>
<if
test=
"countOrigin != null"
>
COUNT_ORIGIN = #{countOrigin,jdbcType=VARCHAR},
</if>
<if
test=
"destinationCountry != null"
>
DESTINATION_COUNTRY = #{destinationCountry,jdbcType=VARCHAR},
</if>
<if
test=
"customsCurrency != null"
>
CUSTOMS_CURRENCY = #{customsCurrency,jdbcType=VARCHAR},
</if>
<if
test=
"customsValue != null"
>
CUSTOMS_VALUE = #{customsValue,jdbcType=NUMERIC},
</if>
<if
test=
"weight != null"
>
WEIGHT = #{weight,jdbcType=NUMERIC},
</if>
<if
test=
"weightunit != null"
>
WEIGHTUNIT = #{weightunit,jdbcType=NUMERIC},
</if>
<if
test=
"scandate != null"
>
SCANDATE = #{scandate,jdbcType=TIMESTAMP},
</if>
<if
test=
"shipperContactName != null"
>
SHIPPER_CONTACT_NAME = #{shipperContactName,jdbcType=VARCHAR},
</if>
<if
test=
"shipperPhone != null"
>
SHIPPER_PHONE = #{shipperPhone,jdbcType=VARCHAR},
</if>
<if
test=
"shipperAccount != null"
>
SHIPPER_ACCOUNT = #{shipperAccount,jdbcType=VARCHAR},
</if>
<if
test=
"shipperCompany != null"
>
SHIPPER_COMPANY = #{shipperCompany,jdbcType=VARCHAR},
</if>
<if
test=
"shipperAddrLine1 != null"
>
SHIPPER_ADDR_LINE1 = #{shipperAddrLine1,jdbcType=VARCHAR},
</if>
<if
test=
"shipperAddrLine2 != null"
>
SHIPPER_ADDR_LINE2 = #{shipperAddrLine2,jdbcType=VARCHAR},
</if>
<if
test=
"shipperCity != null"
>
SHIPPER_CITY = #{shipperCity,jdbcType=VARCHAR},
</if>
<if
test=
"shipperEmail != null"
>
SHIPPER_EMAIL = #{shipperEmail,jdbcType=VARCHAR},
</if>
<if
test=
"recipientContactName != null"
>
RECIPIENT_CONTACT_NAME = #{recipientContactName,jdbcType=VARCHAR},
</if>
<if
test=
"recipientPhone != null"
>
RECIPIENT_PHONE = #{recipientPhone,jdbcType=VARCHAR},
</if>
<if
test=
"recipientCompany != null"
>
RECIPIENT_COMPANY = #{recipientCompany,jdbcType=VARCHAR},
</if>
<if
test=
"recipientAddrLine1 != null"
>
RECIPIENT_ADDR_LINE1 = #{recipientAddrLine1,jdbcType=VARCHAR},
</if>
<if
test=
"recipientAddrLine2 != null"
>
RECIPIENT_ADDR_LINE2 = #{recipientAddrLine2,jdbcType=VARCHAR},
</if>
<if
test=
"recipientAddrLine3 != null"
>
RECIPIENT_ADDR_LINE3 = #{recipientAddrLine3,jdbcType=VARCHAR},
</if>
<if
test=
"recipientCity != null"
>
RECIPIENT_CITY = #{recipientCity,jdbcType=VARCHAR},
</if>
</set>
where ID = #{id,jdbcType=NUMERIC}
</update>
<update
id=
"updateByPrimaryKey"
parameterType=
"com.fedex.connect.common.model.biz.CeInfo"
>
update ICLEARIMP.T_BIZ_CE_INFO
set CONSIGNMENT_CODE = #{consignmentCode,jdbcType=VARCHAR},
SEND_TIME = #{sendTime,jdbcType=TIMESTAMP},
SHIP_DATE = #{shipDate,jdbcType=TIMESTAMP},
SHIPPER_COUNTRY = #{shipperCountry,jdbcType=VARCHAR},
RECIPIENT_COUNTRY = #{recipientCountry,jdbcType=VARCHAR},
DEST_IATA_CODE = #{destIataCode,jdbcType=VARCHAR},
CREATE_TIME = #{createTime,jdbcType=TIMESTAMP},
CREATE_USER_ID = #{createUserId,jdbcType=NUMERIC},
CREATE_USER_NAME = #{createUserName,jdbcType=VARCHAR},
MODIFY_TIME = #{modifyTime,jdbcType=TIMESTAMP},
MODIFY_USER_ID = #{modifyUserId,jdbcType=NUMERIC},
MODIFY_USER_NAME = #{modifyUserName,jdbcType=VARCHAR},
COUNT_ORIGIN = #{countOrigin,jdbcType=VARCHAR},
DESTINATION_COUNTRY = #{destinationCountry,jdbcType=VARCHAR},
CUSTOMS_CURRENCY = #{customsCurrency,jdbcType=VARCHAR},
CUSTOMS_VALUE = #{customsValue,jdbcType=NUMERIC},
WEIGHT = #{weight,jdbcType=NUMERIC},
WEIGHTUNIT = #{weightunit,jdbcType=NUMERIC},
SCANDATE = #{scandate,jdbcType=TIMESTAMP},
SHIPPER_CONTACT_NAME = #{shipperContactName,jdbcType=VARCHAR},
SHIPPER_PHONE = #{shipperPhone,jdbcType=VARCHAR},
SHIPPER_ACCOUNT = #{shipperAccount,jdbcType=VARCHAR},
SHIPPER_COMPANY = #{shipperCompany,jdbcType=VARCHAR},
SHIPPER_ADDR_LINE1 = #{shipperAddrLine1,jdbcType=VARCHAR},
SHIPPER_ADDR_LINE2 = #{shipperAddrLine2,jdbcType=VARCHAR},
SHIPPER_CITY = #{shipperCity,jdbcType=VARCHAR},
SHIPPER_EMAIL = #{shipperEmail,jdbcType=VARCHAR},
RECIPIENT_CONTACT_NAME = #{recipientContactName,jdbcType=VARCHAR},
RECIPIENT_PHONE = #{recipientPhone,jdbcType=VARCHAR},
RECIPIENT_COMPANY = #{recipientCompany,jdbcType=VARCHAR},
RECIPIENT_ADDR_LINE1 = #{recipientAddrLine1,jdbcType=VARCHAR},
RECIPIENT_ADDR_LINE2 = #{recipientAddrLine2,jdbcType=VARCHAR},
RECIPIENT_ADDR_LINE3 = #{recipientAddrLine3,jdbcType=VARCHAR},
RECIPIENT_CITY = #{recipientCity,jdbcType=VARCHAR}
where ID = #{id,jdbcType=NUMERIC}
</update>
<sql
id=
"OracleDialectPrefix"
>
<if
test=
"limitStart != null and limitStart>=0"
>
select * from ( select row_.*, rownum rownum_ from (
</if>
</sql>
<sql
id=
"OracleDialectSuffix"
>
<if
test=
"limitStart != null and limitStart>=0"
>
<![CDATA[ ) row_ ) where rownum_ > #{limitStart} and rownum_ <= #{limitStart}+#{limitSize} ]]>
</if>
</sql>
</mapper>
\ No newline at end of file
server/common-dao/src/main/java/com/fedex/connect/common/model/biz/CeInfo.java
0 → 100644
View file @
cdcce41
package
com
.
fedex
.
connect
.
common
.
model
.
biz
;
import
java.io.Serializable
;
import
java.util.Date
;
/**
* DESC: CE501报文业务表
* TABLE: ICLEARIMP.T_BIZ_CE_INFO
*/
public
class
CeInfo
implements
Serializable
{
/**
* ID,自动增加
*/
private
Long
id
;
/**
* 运单号
*/
private
String
consignmentCode
;
/**
* DM发送时间
*/
private
Date
sendTime
;
/**
* 预计取件时间
*/
private
Date
shipDate
;
/**
* 发货人国家
*/
private
String
shipperCountry
;
/**
* 收件人国家
*/
private
String
recipientCountry
;
/**
* 目的国口岸
*/
private
String
destIataCode
;
/**
* 创建时间
*/
private
Date
createTime
;
/**
* 创建人ID,关联用户表ID
*/
private
Long
createUserId
;
/**
* 创建人名称
*/
private
String
createUserName
;
/**
* 修改时间
*/
private
Date
modifyTime
;
/**
* 修改人ID,关联用户表ID
*/
private
Long
modifyUserId
;
/**
* 修改人名称
*/
private
String
modifyUserName
;
/**
* 原产国全称
*/
private
String
countOrigin
;
/**
* 目的国全称
*/
private
String
destinationCountry
;
/**
* 申报币制
*/
private
String
customsCurrency
;
/**
* 申报价格
*/
private
Long
customsValue
;
/**
* 重量
*/
private
Long
weight
;
/**
* 重量单位
*/
private
Long
weightunit
;
/**
* 扫描状态日期
*/
private
Date
scandate
;
/**
* 发货联系人姓名
*/
private
String
shipperContactName
;
/**
* 发货人手机号
*/
private
String
shipperPhone
;
/**
* 发货人计费账号
*/
private
String
shipperAccount
;
/**
* 发货人公司
*/
private
String
shipperCompany
;
/**
* 发货人地址1
*/
private
String
shipperAddrLine1
;
/**
* 发货人地址2
*/
private
String
shipperAddrLine2
;
/**
* 发货人城市
*/
private
String
shipperCity
;
/**
* 发货人邮箱
*/
private
String
shipperEmail
;
/**
* 收件联系人姓名
*/
private
String
recipientContactName
;
/**
* 收件人手机号
*/
private
String
recipientPhone
;
/**
* 收件人公司
*/
private
String
recipientCompany
;
/**
* 收件人地址1
*/
private
String
recipientAddrLine1
;
/**
* 收件人地址2
*/
private
String
recipientAddrLine2
;
/**
* 收件人地址3
*/
private
String
recipientAddrLine3
;
/**
* 收件人城市
*/
private
String
recipientCity
;
private
static
final
long
serialVersionUID
=
1L
;
public
Long
getId
()
{
return
id
;
}
public
void
setId
(
Long
id
)
{
this
.
id
=
id
;
}
public
String
getConsignmentCode
()
{
return
consignmentCode
;
}
public
void
setConsignmentCode
(
String
consignmentCode
)
{
this
.
consignmentCode
=
consignmentCode
==
null
?
null
:
consignmentCode
.
trim
();
}
public
Date
getSendTime
()
{
return
sendTime
;
}
public
void
setSendTime
(
Date
sendTime
)
{
this
.
sendTime
=
sendTime
;
}
public
Date
getShipDate
()
{
return
shipDate
;
}
public
void
setShipDate
(
Date
shipDate
)
{
this
.
shipDate
=
shipDate
;
}
public
String
getShipperCountry
()
{
return
shipperCountry
;
}
public
void
setShipperCountry
(
String
shipperCountry
)
{
this
.
shipperCountry
=
shipperCountry
==
null
?
null
:
shipperCountry
.
trim
();
}
public
String
getRecipientCountry
()
{
return
recipientCountry
;
}
public
void
setRecipientCountry
(
String
recipientCountry
)
{
this
.
recipientCountry
=
recipientCountry
==
null
?
null
:
recipientCountry
.
trim
();
}
public
String
getDestIataCode
()
{
return
destIataCode
;
}
public
void
setDestIataCode
(
String
destIataCode
)
{
this
.
destIataCode
=
destIataCode
==
null
?
null
:
destIataCode
.
trim
();
}
public
Date
getCreateTime
()
{
return
createTime
;
}
public
void
setCreateTime
(
Date
createTime
)
{
this
.
createTime
=
createTime
;
}
public
Long
getCreateUserId
()
{
return
createUserId
;
}
public
void
setCreateUserId
(
Long
createUserId
)
{
this
.
createUserId
=
createUserId
;
}
public
String
getCreateUserName
()
{
return
createUserName
;
}
public
void
setCreateUserName
(
String
createUserName
)
{
this
.
createUserName
=
createUserName
==
null
?
null
:
createUserName
.
trim
();
}
public
Date
getModifyTime
()
{
return
modifyTime
;
}
public
void
setModifyTime
(
Date
modifyTime
)
{
this
.
modifyTime
=
modifyTime
;
}
public
Long
getModifyUserId
()
{
return
modifyUserId
;
}
public
void
setModifyUserId
(
Long
modifyUserId
)
{
this
.
modifyUserId
=
modifyUserId
;
}
public
String
getModifyUserName
()
{
return
modifyUserName
;
}
public
void
setModifyUserName
(
String
modifyUserName
)
{
this
.
modifyUserName
=
modifyUserName
==
null
?
null
:
modifyUserName
.
trim
();
}
public
String
getCountOrigin
()
{
return
countOrigin
;
}
public
void
setCountOrigin
(
String
countOrigin
)
{
this
.
countOrigin
=
countOrigin
==
null
?
null
:
countOrigin
.
trim
();
}
public
String
getDestinationCountry
()
{
return
destinationCountry
;
}
public
void
setDestinationCountry
(
String
destinationCountry
)
{
this
.
destinationCountry
=
destinationCountry
==
null
?
null
:
destinationCountry
.
trim
();
}
public
String
getCustomsCurrency
()
{
return
customsCurrency
;
}
public
void
setCustomsCurrency
(
String
customsCurrency
)
{
this
.
customsCurrency
=
customsCurrency
==
null
?
null
:
customsCurrency
.
trim
();
}
public
Long
getCustomsValue
()
{
return
customsValue
;
}
public
void
setCustomsValue
(
Long
customsValue
)
{
this
.
customsValue
=
customsValue
;
}
public
Long
getWeight
()
{
return
weight
;
}
public
void
setWeight
(
Long
weight
)
{
this
.
weight
=
weight
;
}
public
Long
getWeightunit
()
{
return
weightunit
;
}
public
void
setWeightunit
(
Long
weightunit
)
{
this
.
weightunit
=
weightunit
;
}
public
Date
getScandate
()
{
return
scandate
;
}
public
void
setScandate
(
Date
scandate
)
{
this
.
scandate
=
scandate
;
}
public
String
getShipperContactName
()
{
return
shipperContactName
;
}
public
void
setShipperContactName
(
String
shipperContactName
)
{
this
.
shipperContactName
=
shipperContactName
==
null
?
null
:
shipperContactName
.
trim
();
}
public
String
getShipperPhone
()
{
return
shipperPhone
;
}
public
void
setShipperPhone
(
String
shipperPhone
)
{
this
.
shipperPhone
=
shipperPhone
==
null
?
null
:
shipperPhone
.
trim
();
}
public
String
getShipperAccount
()
{
return
shipperAccount
;
}
public
void
setShipperAccount
(
String
shipperAccount
)
{
this
.
shipperAccount
=
shipperAccount
==
null
?
null
:
shipperAccount
.
trim
();
}
public
String
getShipperCompany
()
{
return
shipperCompany
;
}
public
void
setShipperCompany
(
String
shipperCompany
)
{
this
.
shipperCompany
=
shipperCompany
==
null
?
null
:
shipperCompany
.
trim
();
}
public
String
getShipperAddrLine1
()
{
return
shipperAddrLine1
;
}
public
void
setShipperAddrLine1
(
String
shipperAddrLine1
)
{
this
.
shipperAddrLine1
=
shipperAddrLine1
==
null
?
null
:
shipperAddrLine1
.
trim
();
}
public
String
getShipperAddrLine2
()
{
return
shipperAddrLine2
;
}
public
void
setShipperAddrLine2
(
String
shipperAddrLine2
)
{
this
.
shipperAddrLine2
=
shipperAddrLine2
==
null
?
null
:
shipperAddrLine2
.
trim
();
}
public
String
getShipperCity
()
{
return
shipperCity
;
}
public
void
setShipperCity
(
String
shipperCity
)
{
this
.
shipperCity
=
shipperCity
==
null
?
null
:
shipperCity
.
trim
();
}
public
String
getShipperEmail
()
{
return
shipperEmail
;
}
public
void
setShipperEmail
(
String
shipperEmail
)
{
this
.
shipperEmail
=
shipperEmail
==
null
?
null
:
shipperEmail
.
trim
();
}
public
String
getRecipientContactName
()
{
return
recipientContactName
;
}
public
void
setRecipientContactName
(
String
recipientContactName
)
{
this
.
recipientContactName
=
recipientContactName
==
null
?
null
:
recipientContactName
.
trim
();
}
public
String
getRecipientPhone
()
{
return
recipientPhone
;
}
public
void
setRecipientPhone
(
String
recipientPhone
)
{
this
.
recipientPhone
=
recipientPhone
==
null
?
null
:
recipientPhone
.
trim
();
}
public
String
getRecipientCompany
()
{
return
recipientCompany
;
}
public
void
setRecipientCompany
(
String
recipientCompany
)
{
this
.
recipientCompany
=
recipientCompany
==
null
?
null
:
recipientCompany
.
trim
();
}
public
String
getRecipientAddrLine1
()
{
return
recipientAddrLine1
;
}
public
void
setRecipientAddrLine1
(
String
recipientAddrLine1
)
{
this
.
recipientAddrLine1
=
recipientAddrLine1
==
null
?
null
:
recipientAddrLine1
.
trim
();
}
public
String
getRecipientAddrLine2
()
{
return
recipientAddrLine2
;
}
public
void
setRecipientAddrLine2
(
String
recipientAddrLine2
)
{
this
.
recipientAddrLine2
=
recipientAddrLine2
==
null
?
null
:
recipientAddrLine2
.
trim
();
}
public
String
getRecipientAddrLine3
()
{
return
recipientAddrLine3
;
}
public
void
setRecipientAddrLine3
(
String
recipientAddrLine3
)
{
this
.
recipientAddrLine3
=
recipientAddrLine3
==
null
?
null
:
recipientAddrLine3
.
trim
();
}
public
String
getRecipientCity
()
{
return
recipientCity
;
}
public
void
setRecipientCity
(
String
recipientCity
)
{
this
.
recipientCity
=
recipientCity
==
null
?
null
:
recipientCity
.
trim
();
}
@Override
public
String
toString
()
{
StringBuilder
sb
=
new
StringBuilder
();
sb
.
append
(
getClass
().
getSimpleName
());
sb
.
append
(
" ["
);
sb
.
append
(
"Hash = "
).
append
(
hashCode
());
sb
.
append
(
", id="
).
append
(
id
);
sb
.
append
(
", consignmentCode="
).
append
(
consignmentCode
);
sb
.
append
(
", sendTime="
).
append
(
sendTime
);
sb
.
append
(
", shipDate="
).
append
(
shipDate
);
sb
.
append
(
", shipperCountry="
).
append
(
shipperCountry
);
sb
.
append
(
", recipientCountry="
).
append
(
recipientCountry
);
sb
.
append
(
", destIataCode="
).
append
(
destIataCode
);
sb
.
append
(
", createTime="
).
append
(
createTime
);
sb
.
append
(
", createUserId="
).
append
(
createUserId
);
sb
.
append
(
", createUserName="
).
append
(
createUserName
);
sb
.
append
(
", modifyTime="
).
append
(
modifyTime
);
sb
.
append
(
", modifyUserId="
).
append
(
modifyUserId
);
sb
.
append
(
", modifyUserName="
).
append
(
modifyUserName
);
sb
.
append
(
", countOrigin="
).
append
(
countOrigin
);
sb
.
append
(
", destinationCountry="
).
append
(
destinationCountry
);
sb
.
append
(
", customsCurrency="
).
append
(
customsCurrency
);
sb
.
append
(
", customsValue="
).
append
(
customsValue
);
sb
.
append
(
", weight="
).
append
(
weight
);
sb
.
append
(
", weightunit="
).
append
(
weightunit
);
sb
.
append
(
", scandate="
).
append
(
scandate
);
sb
.
append
(
", shipperContactName="
).
append
(
shipperContactName
);
sb
.
append
(
", shipperPhone="
).
append
(
shipperPhone
);
sb
.
append
(
", shipperAccount="
).
append
(
shipperAccount
);
sb
.
append
(
", shipperCompany="
).
append
(
shipperCompany
);
sb
.
append
(
", shipperAddrLine1="
).
append
(
shipperAddrLine1
);
sb
.
append
(
", shipperAddrLine2="
).
append
(
shipperAddrLine2
);
sb
.
append
(
", shipperCity="
).
append
(
shipperCity
);
sb
.
append
(
", shipperEmail="
).
append
(
shipperEmail
);
sb
.
append
(
", recipientContactName="
).
append
(
recipientContactName
);
sb
.
append
(
", recipientPhone="
).
append
(
recipientPhone
);
sb
.
append
(
", recipientCompany="
).
append
(
recipientCompany
);
sb
.
append
(
", recipientAddrLine1="
).
append
(
recipientAddrLine1
);
sb
.
append
(
", recipientAddrLine2="
).
append
(
recipientAddrLine2
);
sb
.
append
(
", recipientAddrLine3="
).
append
(
recipientAddrLine3
);
sb
.
append
(
", recipientCity="
).
append
(
recipientCity
);
sb
.
append
(
", serialVersionUID="
).
append
(
serialVersionUID
);
sb
.
append
(
"]"
);
return
sb
.
toString
();
}
}
\ No newline at end of file
server/common-dao/src/main/resources/generatorConfig.xml
View file @
cdcce41
...
...
@@ -85,17 +85,13 @@
<!-- selectByExampleQueryId="true">-->
<!-- <generatedKey column="ID" sqlStatement="SELECT SEQ_T_LOG_EMAIL_HISTORY.NEXTVAL FROM DUAL" />-->
<!-- </table>-->
<!-- <table tableName="T_BIZ_ATTACHMENT" domainObjectName="Attachment"-->
<!-- enableCountByExample="true" enableUpdateByExample="true"-->
<!-- enableDeleteByExample="true" enableSelectByExample="true"-->
<!-- selectByExampleQueryId="true">-->
<!-- <generatedKey column="ID" sqlStatement="SELECT SEQ_T_BIZ_ATTACHMENT.NEXTVAL FROM DUAL" />-->
<!-- </table>-->
<table
tableName=
"T_BIZ_CE_INFO"
domainObjectName=
"CeInfo"
<table
schema=
"ICLEARIMP"
tableName=
"T_BIZ_CE_INFO"
domainObjectName=
"CeInfo"
enableCountByExample=
"true"
enableUpdateByExample=
"true"
enableDeleteByExample=
"true"
enableSelectByExample=
"true"
selectByExampleQueryId=
"true"
>
...
...
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/KafkaApplication.java
View file @
cdcce41
...
...
@@ -11,7 +11,7 @@ import org.springframework.web.WebApplicationInitializer;
import
springfox.documentation.swagger2.annotations.EnableSwagger2
;
@SpringBootApplication
(
exclude
=
SecurityAutoConfiguration
.
class
)
@MapperScan
(
"com.fedex.connect.kafka.repository.dao"
)
@MapperScan
(
{
"com.fedex.connect.common.dao.*.**"
,
"com.fedex.connect.kafka.repository.dao.*"
}
)
@EnableTransactionManagement
@EnableSwagger2
public
class
KafkaApplication
extends
SpringBootServletInitializer
implements
WebApplicationInitializer
{
...
...
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/base/AbstractDaoRepository.java
View file @
cdcce41
package
com
.
fedex
.
connect
.
kafka
.
repository
.
base
;
import
com.fedex.connect.common.dao.biz.CeInfoMapper
;
import
com.fedex.connect.common.dao.sys.KafkaStorageHistoryMapper
;
import
com.fedex.connect.common.dao.sys.KafkaTemporaryStorageMapper
;
import
com.fedex.connect.kafka.repository.dao.CeInfoMapperExt
;
...
...
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/dao/CeInfoMapperExt.java
View file @
cdcce41
package
com
.
fedex
.
connect
.
kafka
.
repository
.
dao
;
import
com.fedex.connect.common.model.biz.CeInfo
;
import
org.apache.ibatis.annotations.Mapper
;
import
org.apache.ibatis.annotations.Param
;
import
org.apache.ibatis.annotations.Select
;
...
...
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/repo/ICeInfoRepository.java
View file @
cdcce41
package
com
.
fedex
.
connect
.
kafka
.
repository
.
repo
;
import
com.fedex.connect.common.model.biz.CeInfo
;
import
java.util.List
;
/**
...
...
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/repository/repo/impl/CeInfoRepositoryImpl.java
View file @
cdcce41
package
com
.
fedex
.
connect
.
kafka
.
repository
.
repo
.
impl
;
import
com.fedex.connect.common.model.biz.CeInfo
;
import
com.fedex.connect.kafka.repository.base.AbstractDaoRepository
;
import
com.fedex.connect.kafka.repository.repo.ICeInfoRepository
;
import
org.springframework.stereotype.Repository
;
...
...
server/kafka-cndc-server/src/main/java/com/fedex/connect/kafka/service/impl/Dm501ServiceImpl.java
View file @
cdcce41
...
...
@@ -3,7 +3,6 @@ package com.fedex.connect.kafka.service.impl;
import
com.alibaba.fastjson.JSONObject
;
import
com.fedex.connect.common.dependencies.util.DateUtil
;
import
com.fedex.connect.common.dependencies.util.Utils
;
import
com.fedex.connect.common.model.biz.CeInfo
;
import
com.fedex.connect.common.model.sys.KafkaTemporaryStorage
;
import
com.fedex.connect.kafka.constants.Constant
;
import
com.fedex.connect.kafka.data.dto.DmProcessResults
;
...
...
server/manager-server/src/main/java/com/fedex/connect/manager/ManagerApplication.java
0 → 100644
View file @
cdcce41
package
com
.
fedex
.
connect
.
manager
;
import
org.mybatis.spring.annotation.MapperScan
;
import
org.springframework.boot.SpringApplication
;
import
org.springframework.boot.autoconfigure.SpringBootApplication
;
import
org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration
;
import
org.springframework.boot.builder.SpringApplicationBuilder
;
import
org.springframework.boot.web.servlet.support.SpringBootServletInitializer
;
import
org.springframework.transaction.annotation.EnableTransactionManagement
;
import
org.springframework.web.WebApplicationInitializer
;
import
springfox.documentation.swagger2.annotations.EnableSwagger2
;
@SpringBootApplication
(
exclude
=
SecurityAutoConfiguration
.
class
)
@MapperScan
({
"com.fedex.connect.common.dao.*.**"
,
"com.fedex.connect.manager.repository.dao.*"
})
@EnableTransactionManagement
@EnableSwagger2
public
class
ManagerApplication
extends
SpringBootServletInitializer
implements
WebApplicationInitializer
{
public
static
void
main
(
String
[]
args
)
{
SpringApplication
.
run
(
ManagerApplication
.
class
,
args
);
}
@Override
protected
SpringApplicationBuilder
configure
(
SpringApplicationBuilder
builder
)
{
return
builder
.
sources
(
ManagerApplication
.
class
);
}
}
server/manager-server/src/main/java/com/fedex/connect/manager/package-info.java
deleted
100644 → 0
View file @
82f26b7
package
com
.
fedex
.
connect
.
kafka
.
connect
.
manager
;
\ No newline at end of file
server/task-schedule/src/main/java/com/fedex/connect/task/TaskApplication.java
0 → 100644
View file @
cdcce41
package
com
.
fedex
.
connect
.
task
;
import
org.mybatis.spring.annotation.MapperScan
;
import
org.springframework.boot.SpringApplication
;
import
org.springframework.boot.autoconfigure.SpringBootApplication
;
import
org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration
;
import
org.springframework.boot.builder.SpringApplicationBuilder
;
import
org.springframework.boot.web.servlet.support.SpringBootServletInitializer
;
import
org.springframework.transaction.annotation.EnableTransactionManagement
;
import
org.springframework.web.WebApplicationInitializer
;
import
springfox.documentation.swagger2.annotations.EnableSwagger2
;
@SpringBootApplication
(
exclude
=
SecurityAutoConfiguration
.
class
)
@MapperScan
({
"com.fedex.connect.common.dao.*.**"
,
"com.fedex.connect.task.repository.dao.*"
})
@EnableTransactionManagement
@EnableSwagger2
public
class
TaskApplication
extends
SpringBootServletInitializer
implements
WebApplicationInitializer
{
public
static
void
main
(
String
[]
args
)
{
SpringApplication
.
run
(
TaskApplication
.
class
,
args
);
}
@Override
protected
SpringApplicationBuilder
configure
(
SpringApplicationBuilder
builder
)
{
return
builder
.
sources
(
TaskApplication
.
class
);
}
}
server/task-schedule/src/main/java/com/fedex/connect/task/package-info.java
deleted
100644 → 0
View file @
82f26b7
package
com
.
fedex
.
connect
.
kafka
.
connect
.
task
;
\ No newline at end of file
Please
register
or
login
to post a comment