完成10个工程的代码
This commit is contained in:
@ -4,7 +4,7 @@
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>com.enzhico</groupId>
|
||||
<groupId>com.xncoding</groupId>
|
||||
<artifactId>springboot-batch</artifactId>
|
||||
<version>1.0.0-SNAPSHOT</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans;
|
||||
package com.xncoding.trans;
|
||||
|
||||
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
|
||||
import org.springframework.boot.SpringApplication;
|
||||
@ -1,8 +1,8 @@
|
||||
package com.enzhico.trans.config;
|
||||
package com.xncoding.trans.config;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.baomidou.mybatisplus.plugins.PaginationInterceptor;
|
||||
import com.enzhico.trans.config.properties.DruidProperties;
|
||||
import com.xncoding.trans.config.properties.DruidProperties;
|
||||
import org.mybatis.spring.annotation.MapperScan;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
@ -18,7 +18,7 @@ import javax.annotation.Resource;
|
||||
*/
|
||||
@Configuration
|
||||
@EnableTransactionManagement(order = 2)
|
||||
@MapperScan(basePackages = {"com.enzhico.trans.dao.repository"})
|
||||
@MapperScan(basePackages = {"com.xncoding.trans.dao.repository"})
|
||||
public class MybatisPlusConfig {
|
||||
|
||||
@Resource
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.config.properties;
|
||||
package com.xncoding.trans.config.properties;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.alibaba.druid.util.JdbcConstants;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.config.properties;
|
||||
package com.xncoding.trans.config.properties;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.alibaba.druid.util.JdbcConstants;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.dao.entity;
|
||||
package com.xncoding.trans.dao.entity;
|
||||
|
||||
import com.baomidou.mybatisplus.activerecord.Model;
|
||||
import com.baomidou.mybatisplus.annotations.TableId;
|
||||
@ -1,7 +1,7 @@
|
||||
package com.enzhico.trans.dao.repository;
|
||||
package com.xncoding.trans.dao.repository;
|
||||
|
||||
import com.baomidou.mybatisplus.mapper.BaseMapper;
|
||||
import com.enzhico.trans.dao.entity.User;
|
||||
import com.xncoding.trans.dao.entity.User;
|
||||
|
||||
public interface UserMapper extends BaseMapper<User> {
|
||||
}
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules;
|
||||
package com.xncoding.trans.modules;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules;
|
||||
package com.xncoding.trans.modules;
|
||||
|
||||
import org.springframework.batch.item.validator.ValidationException;
|
||||
import org.springframework.batch.item.validator.Validator;
|
||||
@ -1,7 +1,7 @@
|
||||
package com.enzhico.trans.modules;
|
||||
package com.xncoding.trans.modules;
|
||||
|
||||
import com.baomidou.mybatisplus.toolkit.StringUtils;
|
||||
import com.enzhico.trans.modules.common.DateUtil;
|
||||
import com.xncoding.trans.modules.common.DateUtil;
|
||||
import org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper;
|
||||
import org.springframework.validation.DataBinder;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules;
|
||||
package com.xncoding.trans.modules;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules.canton;
|
||||
package com.xncoding.trans.modules.canton;
|
||||
|
||||
/**
|
||||
* Canton
|
||||
@ -1,8 +1,8 @@
|
||||
package com.enzhico.trans.modules.canton;
|
||||
package com.xncoding.trans.modules.canton;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.enzhico.trans.modules.MyBeanValidator;
|
||||
import com.enzhico.trans.modules.MyJobListener;
|
||||
import com.xncoding.trans.modules.MyBeanValidator;
|
||||
import com.xncoding.trans.modules.MyJobListener;
|
||||
import org.springframework.batch.core.Job;
|
||||
import org.springframework.batch.core.Step;
|
||||
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
|
||||
@ -1,10 +1,10 @@
|
||||
package com.enzhico.trans.modules.common;
|
||||
package com.xncoding.trans.modules.common;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.enzhico.trans.config.properties.CommonProperties;
|
||||
import com.enzhico.trans.modules.MyBeanValidator;
|
||||
import com.enzhico.trans.modules.MyBeanWrapperFieldSetMapper;
|
||||
import com.enzhico.trans.modules.MyJobListener;
|
||||
import com.xncoding.trans.config.properties.CommonProperties;
|
||||
import com.xncoding.trans.modules.MyBeanValidator;
|
||||
import com.xncoding.trans.modules.MyBeanWrapperFieldSetMapper;
|
||||
import com.xncoding.trans.modules.MyJobListener;
|
||||
import org.springframework.batch.core.Job;
|
||||
import org.springframework.batch.core.Step;
|
||||
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules.common;
|
||||
package com.xncoding.trans.modules.common;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
import java.text.ParseException;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules.common.anno;
|
||||
package com.xncoding.trans.modules.common.anno;
|
||||
|
||||
import java.lang.annotation.*;
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
package com.enzhico.trans.modules.common.vo;
|
||||
package com.xncoding.trans.modules.common.vo;
|
||||
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
|
||||
/**
|
||||
* BscCanton
|
||||
@ -1,6 +1,6 @@
|
||||
package com.enzhico.trans.modules.common.vo;
|
||||
package com.xncoding.trans.modules.common.vo;
|
||||
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
||||
import java.sql.Timestamp;
|
||||
@ -1,6 +1,6 @@
|
||||
package com.enzhico.trans.modules.common.vo;
|
||||
package com.xncoding.trans.modules.common.vo;
|
||||
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
|
||||
/**
|
||||
* BscOfficeExeItem
|
||||
@ -1,6 +1,6 @@
|
||||
package com.enzhico.trans.modules.common.vo;
|
||||
package com.xncoding.trans.modules.common.vo;
|
||||
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.sql.Timestamp;
|
||||
@ -1,6 +1,6 @@
|
||||
package com.enzhico.trans.modules.common.vo;
|
||||
package com.xncoding.trans.modules.common.vo;
|
||||
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules.vtoll;
|
||||
package com.xncoding.trans.modules.vtoll;
|
||||
|
||||
import javax.validation.constraints.Size;
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
package com.enzhico.trans.modules.vtoll;
|
||||
package com.xncoding.trans.modules.vtoll;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.enzhico.trans.modules.MyBeanValidator;
|
||||
import com.enzhico.trans.modules.MyJobListener;
|
||||
import com.xncoding.trans.modules.MyBeanValidator;
|
||||
import com.xncoding.trans.modules.MyJobListener;
|
||||
import org.springframework.batch.core.Job;
|
||||
import org.springframework.batch.core.Step;
|
||||
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
|
||||
@ -1,6 +1,6 @@
|
||||
package com.enzhico.trans.modules.zapp;
|
||||
package com.xncoding.trans.modules.zapp;
|
||||
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
|
||||
/**
|
||||
* App
|
||||
@ -1,8 +1,8 @@
|
||||
package com.enzhico.trans.modules.zapp;
|
||||
package com.xncoding.trans.modules.zapp;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.enzhico.trans.modules.MyBeanValidator;
|
||||
import com.enzhico.trans.modules.MyJobListener;
|
||||
import com.xncoding.trans.modules.MyBeanValidator;
|
||||
import com.xncoding.trans.modules.MyJobListener;
|
||||
import org.springframework.batch.core.Job;
|
||||
import org.springframework.batch.core.Step;
|
||||
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.trans.modules.zlog;
|
||||
package com.xncoding.trans.modules.zlog;
|
||||
|
||||
/**
|
||||
* Log
|
||||
@ -1,8 +1,8 @@
|
||||
package com.enzhico.trans.modules.zlog;
|
||||
package com.xncoding.trans.modules.zlog;
|
||||
|
||||
import com.alibaba.druid.pool.DruidDataSource;
|
||||
import com.enzhico.trans.modules.MyBeanValidator;
|
||||
import com.enzhico.trans.modules.MyJobListener;
|
||||
import com.xncoding.trans.modules.MyBeanValidator;
|
||||
import com.xncoding.trans.modules.MyJobListener;
|
||||
import org.springframework.batch.core.Job;
|
||||
import org.springframework.batch.core.Step;
|
||||
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
|
||||
@ -1,11 +1,11 @@
|
||||
package com.enzhico.trans.service;
|
||||
package com.xncoding.trans.service;
|
||||
|
||||
import com.enzhico.trans.config.properties.CommonProperties;
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.enzhico.trans.modules.common.vo.BscCanton;
|
||||
import com.enzhico.trans.modules.common.vo.BscExeOffice;
|
||||
import com.enzhico.trans.modules.common.vo.BscOfficeExeItem;
|
||||
import com.enzhico.trans.modules.common.vo.BscTollItem;
|
||||
import com.xncoding.trans.config.properties.CommonProperties;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.vo.BscCanton;
|
||||
import com.xncoding.trans.modules.common.vo.BscExeOffice;
|
||||
import com.xncoding.trans.modules.common.vo.BscOfficeExeItem;
|
||||
import com.xncoding.trans.modules.common.vo.BscTollItem;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.batch.core.Job;
|
||||
@ -1,6 +1,6 @@
|
||||
package com.enzhico.trans.start;
|
||||
package com.xncoding.trans.start;
|
||||
|
||||
import com.enzhico.trans.service.CsvService;
|
||||
import com.xncoding.trans.service.CsvService;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.boot.CommandLineRunner;
|
||||
@ -22,9 +22,9 @@ spring:
|
||||
|
||||
################### mybatis-plus配置 ###################
|
||||
mybatis-plus:
|
||||
mapper-locations: classpath*:com/enzhico/trans/dao/repository/mapping/*.xml
|
||||
mapper-locations: classpath*:com/xncoding/trans/dao/repository/mapping/*.xml
|
||||
typeAliasesPackage: >
|
||||
com.enzhico.trans.dao.entity
|
||||
com.xncoding.trans.dao.entity
|
||||
global-config:
|
||||
id-type: 1 # 0:数据库ID自增 1:用户输入id 2:全局唯一id(IdWorker) 3:全局唯一ID(uuid)
|
||||
db-column-underline: false
|
||||
@ -49,7 +49,7 @@ spring:
|
||||
profiles: dev
|
||||
datasource:
|
||||
driver-class-name: oracle.jdbc.driver.OracleDriver
|
||||
url: jdbc:oracle:thin:@111.230.194.170:1521:orcl11g
|
||||
url: jdbc:oracle:thin:@127.0.0.1:1521:orcl11g
|
||||
username: adm_real
|
||||
password: adm_real
|
||||
|
||||
@ -61,7 +61,7 @@ logging:
|
||||
level:
|
||||
ROOT: INFO
|
||||
com:
|
||||
enzhico: DEBUG
|
||||
xncoding: DEBUG
|
||||
file: /var/logs/batch.log
|
||||
|
||||
---
|
||||
@ -85,6 +85,6 @@ logging:
|
||||
level:
|
||||
ROOT: INFO
|
||||
com:
|
||||
enzhico: DEBUG
|
||||
xncoding: DEBUG
|
||||
file: /var/logs/batch.log
|
||||
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
package com.enzhico.service;
|
||||
package com.xncoding.service;
|
||||
|
||||
import com.enzhico.trans.Application;
|
||||
import com.enzhico.trans.config.properties.CommonProperties;
|
||||
import com.enzhico.trans.modules.common.anno.TableName;
|
||||
import com.enzhico.trans.modules.common.vo.*;
|
||||
import com.enzhico.trans.service.CsvService;
|
||||
import com.xncoding.trans.Application;
|
||||
import com.xncoding.trans.config.properties.CommonProperties;
|
||||
import com.xncoding.trans.modules.common.anno.TableName;
|
||||
import com.xncoding.trans.modules.common.vo.*;
|
||||
import com.xncoding.trans.service.CsvService;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.slf4j.Logger;
|
||||
@ -108,7 +108,7 @@ public class BatchServiceTest {
|
||||
.addLong("time",System.currentTimeMillis())
|
||||
.addString(KEY_JOB_NAME, "App")
|
||||
.addString(KEY_FILE_NAME, p.getCsvApp())
|
||||
.addString(KEY_VO_NAME, "com.enzhico.trans.modules.zapp.App")
|
||||
.addString(KEY_VO_NAME, "com.xncoding.trans.modules.zapp.App")
|
||||
.addString(KEY_COLUMNS, String.join(",", new String[]{
|
||||
"appid", "zname", "flag"
|
||||
}))
|
||||
@ -120,7 +120,7 @@ public class BatchServiceTest {
|
||||
.addLong("time",System.currentTimeMillis())
|
||||
.addString(KEY_JOB_NAME, "Log")
|
||||
.addString(KEY_FILE_NAME, p.getCsvLog())
|
||||
.addString(KEY_VO_NAME, "com.enzhico.trans.modules.zlog.Log")
|
||||
.addString(KEY_VO_NAME, "com.xncoding.trans.modules.zlog.Log")
|
||||
.addString(KEY_COLUMNS, String.join(",", new String[]{
|
||||
"logid", "msg", "logtime"
|
||||
}))
|
||||
@ -145,7 +145,7 @@ public class BatchServiceTest {
|
||||
.addLong("time",System.currentTimeMillis())
|
||||
.addString(KEY_JOB_NAME, "BscExeOffice")
|
||||
.addString(KEY_FILE_NAME, p.getCsvExeOffice())
|
||||
.addString(KEY_VO_NAME, "com.enzhico.trans.modules.common.vo.BscExeOffice")
|
||||
.addString(KEY_VO_NAME, "com.xncoding.trans.modules.common.vo.BscExeOffice")
|
||||
.addString(KEY_COLUMNS, String.join(",", new String[]{
|
||||
"id","cantonid","code","name","memcode","supdeptid","comdeptid","contactman","tel","mobil","email","bgofficeid","infomobil","infoman","logpass","startdate","stopdate","status","memo","auditer","audittime","isaudit","edittime","platform_id","isprintbill"
|
||||
}))
|
||||
@ -158,7 +158,7 @@ public class BatchServiceTest {
|
||||
// .addLong("time",System.currentTimeMillis())
|
||||
// .addString(KEY_JOB_NAME, "Log")
|
||||
// .addString(KEY_FILE_NAME, p.getCsvLog())
|
||||
// .addString(KEY_VO_NAME, "com.enzhico.trans.modules.zlog.Log")
|
||||
// .addString(KEY_VO_NAME, "com.xncoding.trans.modules.zlog.Log")
|
||||
// .addString(KEY_COLUMNS, String.join(",", new String[]{
|
||||
// "logid", "msg", "logtime"
|
||||
// }))
|
||||
@ -1,4 +1,4 @@
|
||||
package com.enzhico.service;
|
||||
package com.xncoding.service;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
Reference in New Issue
Block a user