Skip to content

D
dc-java
Commit ed7907ed by wutong
Options

同步Saas公司信息和职员信息

parent 916786f0
Showing with 953 additions and 0 deletions
data-base/base-sync-company/Dockerfile 0 → 100644
FROM maven:3.6.0-alpine
RUN apk add ca-certificates && \
apk add tzdata && \
ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && \
echo "Asia/Shanghai" > /etc/timezone
# make source folder
RUN mkdir -p /usr/app
WORKDIR /usr/app
# install maven dependency packages (keep in image)
COPY data-parent /usr/app/data-parent
COPY data-common /usr/app/data-common
COPY data-base /usr/app/data-base
COPY data-mid /usr/app/data-mid
COPY data-show /usr/app/data-show
RUN cd /usr/app/data-parent && mvn -T 1C install -pl ../data-base/base-sync-company -am
#指定容器启动程序及参数 <ENTRYPOINT> "<CMD>"
EXPOSE 8080
ENTRYPOINT ["java","-jar","/usr/app/data-base/base-sync-company/target/base-sync-company-1.0-SNAPSHOT.jar"]
\ No newline at end of file
data-base/base-sync-company/pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>data-base</artifactId>
<groupId>com.bailuntec</groupId>
<version>1.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>base-sync-company</artifactId>
<dependencies>
<dependency>
<groupId>com.bailuntec</groupId>
<artifactId>data-common</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter-api</artifactId>
<version>RELEASE</version>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
</plugin>
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<archive>
<manifest>
<mainClass>com.bailuntec.Application</mainClass>
</manifest>
</archive>
<descriptorRefs>
<descriptorRef>jar-with-dependencies</descriptorRef>
</descriptorRefs>
<appendAssemblyId>false</appendAssemblyId>
</configuration>
<executions>
<execution>
<id>make-assembly</id>
<phase>package</phase>
<goals>
<goal>single</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
<resources>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.xml</include>
<include>**/*.properties</include>
</includes>
<!--默认是true-->
<filtering>true</filtering>
</resource>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.xml</include>
<include>**/*.properties</include>
</includes>
</resource>
</resources>
</build>
</project>
\ No newline at end of file
data-base/base-sync-company/src/main/java/com/bailuntec/Application.java 0 → 100644
package com.bailuntec;
import com.alibaba.druid.pool.DruidDataSource;
import com.bailuntec.job.CompanyInfoSyncJob;
import com.bailuntec.job.CompanyStaffSyncJob;
import com.bailuntec.utils.PropertiesUtil;
import com.dangdang.ddframe.job.config.JobCoreConfiguration;
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
import com.dangdang.ddframe.job.event.JobEventConfiguration;
import com.dangdang.ddframe.job.event.rdb.JobEventRdbConfiguration;
import com.dangdang.ddframe.job.lite.api.JobScheduler;
import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
import com.dangdang.ddframe.job.reg.base.CoordinatorRegistryCenter;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import lombok.extern.slf4j.Slf4j;
import javax.sql.DataSource;
@Slf4j
public class Application {
private static PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("job");
private static final String EVENT_RDB_STORAGE_DRIVER = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_DRIVER");
private static final String EVENT_RDB_STORAGE_URL = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_URL");
private static final String EVENT_RDB_STORAGE_USERNAME = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_USERNAME");
private static final String EVENT_RDB_STORAGE_PASSWORD = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_PASSWORD");
public static void main(String[] args) {
new JobScheduler(createRegistryCenter(), createJobConfiguration1()).init();
new JobScheduler(createRegistryCenter(), createJobConfiguration2()).init();
}
private static CoordinatorRegistryCenter createRegistryCenter() {
CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration(propertiesUtil.getPropertyAsString("ZOOKEEPER_SERVER"), propertiesUtil.getPropertyAsString("NAME_SPACE")));
regCenter.init();
return regCenter;
}
private static LiteJobConfiguration createJobConfiguration1() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_NAME_COMPANY_INFO"), propertiesUtil.getPropertyAsString("JOB_CRON_COMPANY_INFO"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, CompanyInfoSyncJob.class.getCanonicalName());
LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
return simpleJobRootConfig;
}
private static LiteJobConfiguration createJobConfiguration2() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_NAME_COMPANY_STAFF"), propertiesUtil.getPropertyAsString("JOB_CRON_COMPANY_STAFF"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, CompanyStaffSyncJob.class.getCanonicalName());
LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
return simpleJobRootConfig;
}
private static JobEventConfiguration createJobEventConfiguration() {
JobEventConfiguration jobEventRdbConfig = new JobEventRdbConfiguration(setUpEventTraceDataSource());
return jobEventRdbConfig;
}
private static DataSource setUpEventTraceDataSource() {
DruidDataSource result = new DruidDataSource();
result.setDriverClassName(EVENT_RDB_STORAGE_DRIVER);
result.setUrl(EVENT_RDB_STORAGE_URL);
result.setUsername(EVENT_RDB_STORAGE_USERNAME);
result.setPassword(EVENT_RDB_STORAGE_PASSWORD);
return result;
}
}
data-base/base-sync-company/src/main/java/com/bailuntec/domain/pojo/CompanyInfo.java 0 → 100644
package com.bailuntec.domain.pojo;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
@Data
public class CompanyInfo {
@JSONField(name = "id")
private Integer companyId;
private String companyCode;
private String companyName;
}
data-base/base-sync-company/src/main/java/com/bailuntec/domain/pojo/CompanyStaff.java 0 → 100644
package com.bailuntec.domain.pojo;
import lombok.Data;
import java.util.List;
@Data
public class CompanyStaff {
private List<CompanyStaffInfo> users;
private Boolean success;
@Data
public class CompanyStaffInfo {
private Integer companyId;
private Integer userId;
private String userName;
}
}
data-base/base-sync-company/src/main/java/com/bailuntec/domain/pojo/Result.java 0 → 100644
package com.bailuntec.domain.pojo;
import lombok.Data;
import java.util.List;
@Data
public class Result<T> {
private List<T> result;
private Integer statusCode;
private String message;
}
data-base/base-sync-company/src/main/java/com/bailuntec/job/CompanyInfoSyncJob.java 0 → 100644
package com.bailuntec.job;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.bailuntec.domain.entity.DcBaseCompanyInfo;
import com.bailuntec.domain.entity.JobPointLog;
import com.bailuntec.domain.example.DcBaseCompanyInfoExample;
import com.bailuntec.domain.pojo.CompanyInfo;
import com.bailuntec.domain.pojo.Result;
import com.bailuntec.mapper.DcBaseCompanyInfoMapper;
import com.bailuntec.support.PointJob;
import com.bailuntec.utils.OkHttpUtil;
import com.bailuntec.utils.PropertiesUtil;
import com.bailuntec.utils.SessionUtil;
import com.dangdang.ddframe.job.api.ShardingContext;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.lang3.StringUtils;
import java.io.IOException;
import java.time.LocalDateTime;
import java.util.List;
@Slf4j
public class CompanyInfoSyncJob extends PointJob {
private PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("const");
private OkHttpClient client = OkHttpUtil.getInstance();
@Override
public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
Request request = new Request.Builder()
.url(propertiesUtil.getPropertyAsString("COMPANY_INFO_URL"))
.get()
.addHeader("Content-Type", "application/json")
.build();
Response response = null;
String resultStr = null;
try {
response = client.newCall(request).execute();
resultStr = response.body().string();
} catch (IOException e) {
throw new RuntimeException("调用公司信息接口失败", e);
} finally {
if (response != null) {
response.close();
}
}
if (StringUtils.isNotBlank(resultStr)) {
Result<CompanyInfo> companyInfoResult = JSONObject.parseObject(resultStr, new TypeReference<Result<CompanyInfo>>(){});
if (companyInfoResult.getStatusCode()!= null && companyInfoResult.getStatusCode().equals(200)) {
List<CompanyInfo> result = companyInfoResult.getResult();
if (result != null && result.size() > 0) {
DcBaseCompanyInfoMapper mapper = SessionUtil.getSession().getMapper(DcBaseCompanyInfoMapper.class);
DcBaseCompanyInfo dcBaseCompanyInfo = new DcBaseCompanyInfo();
try {
for (CompanyInfo companyInfo : result) {
BeanUtils.copyProperties(dcBaseCompanyInfo, companyInfo);
dcBaseCompanyInfo.setGmtModified(LocalDateTime.now());
int i = mapper.updateByExampleSelective(dcBaseCompanyInfo, DcBaseCompanyInfoExample.newAndCreateCriteria().andCompanyIdEqualTo(dcBaseCompanyInfo.getCompanyId()).example());
if (i == 0) {
mapper.insertSelective(dcBaseCompanyInfo);
}
}
} catch (Exception e) {
throw new RuntimeException("Mybatis操作DB失败",e);
} finally {
SessionUtil.closeSession();
}
}
} else {
throw new RuntimeException("调用公司信息接口返回错误");
}
} else {
throw new RuntimeException("调用公司信息接口返回null");
}
}
}
data-base/base-sync-company/src/main/java/com/bailuntec/job/CompanyStaffSyncJob.java 0 → 100644
package com.bailuntec.job;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.bailuntec.domain.entity.DcBaseCompanyStaff;
import com.bailuntec.domain.entity.JobPointLog;
import com.bailuntec.domain.example.DcBaseCompanyStaffExample;
import com.bailuntec.domain.pojo.CompanyStaff;
import com.bailuntec.domain.pojo.Result;
import com.bailuntec.mapper.DcBaseCompanyStaffMapper;
import com.bailuntec.support.PointJob;
import com.bailuntec.utils.OkHttpUtil;
import com.bailuntec.utils.PropertiesUtil;
import com.bailuntec.utils.SessionUtil;
import com.dangdang.ddframe.job.api.ShardingContext;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.lang3.StringUtils;
import java.io.IOException;
import java.time.LocalDateTime;
import java.util.List;
@Slf4j
public class CompanyStaffSyncJob extends PointJob {
private PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("const");
private OkHttpClient client = OkHttpUtil.getInstance();
@Override
public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
Request request = new Request.Builder()
.url(propertiesUtil.getPropertyAsString("COMPANY_STAFF_URL"))
.get()
.addHeader("Content-Type", "application/json")
.build();
Response response = null;
String resultStr = null;
try {
response = client.newCall(request).execute();
resultStr = response.body().string();
} catch (IOException e) {
throw new RuntimeException("调用公司员工信息接口失败", e);
} finally {
if (response != null) {
response.close();
}
}
if (StringUtils.isNotBlank(resultStr)) {
Result<CompanyStaff> CompanyStaffResult = JSONObject.parseObject(resultStr, new TypeReference<Result<CompanyStaff>>(){});
if (CompanyStaffResult.getStatusCode()!= null && CompanyStaffResult.getStatusCode().equals(200)) {
List<CompanyStaff.CompanyStaffInfo> result = CompanyStaffResult.getResult().get(0).getUsers();
if (result != null && result.size() > 0) {
DcBaseCompanyStaffMapper mapper = SessionUtil.getSession().getMapper(DcBaseCompanyStaffMapper.class);
DcBaseCompanyStaff dcBaseCompanyStaff = new DcBaseCompanyStaff();
try {
for (CompanyStaff.CompanyStaffInfo companyStaff : result) {
BeanUtils.copyProperties(dcBaseCompanyStaff, companyStaff);
dcBaseCompanyStaff.setGmtModified(LocalDateTime.now());
int i = mapper.updateByExampleSelective(dcBaseCompanyStaff, DcBaseCompanyStaffExample.newAndCreateCriteria().andCompanyIdEqualTo(dcBaseCompanyStaff.getCompanyId()).andUserIdEqualTo(dcBaseCompanyStaff.getUserId()).example());
if (i == 0) {
mapper.insertSelective(dcBaseCompanyStaff);
}
}
} catch (Exception e) {
throw new RuntimeException("Mybatis操作DB失败",e);
} finally {
SessionUtil.closeSession();
}
}
} else {
throw new RuntimeException("调用公司员工信息接口返回错误");
}
} else {
throw new RuntimeException("调用公司员工信息接口返回null");
}
}
}
data-base/base-sync-company/src/main/java/com/bailuntec/mapper/DcBaseCompanyInfoMapper.java 0 → 100644
package com.bailuntec.mapper;
import com.bailuntec.domain.entity.DcBaseCompanyInfo;
import com.bailuntec.domain.example.DcBaseCompanyInfoExample;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface DcBaseCompanyInfoMapper {
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
long countByExample(DcBaseCompanyInfoExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int deleteByExample(DcBaseCompanyInfoExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int deleteByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int insert(DcBaseCompanyInfo record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int insertSelective(DcBaseCompanyInfo record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
DcBaseCompanyInfo selectOneByExample(DcBaseCompanyInfoExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
List<DcBaseCompanyInfo> selectByExample(DcBaseCompanyInfoExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
DcBaseCompanyInfo selectByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int updateByExampleSelective(@Param("record") DcBaseCompanyInfo record, @Param("example") DcBaseCompanyInfoExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int updateByExample(@Param("record") DcBaseCompanyInfo record, @Param("example") DcBaseCompanyInfoExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int updateByPrimaryKeySelective(DcBaseCompanyInfo record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
int updateByPrimaryKey(DcBaseCompanyInfo record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsert(DcBaseCompanyInfo record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsertSelective(DcBaseCompanyInfo record);
}
\ No newline at end of file
data-base/base-sync-company/src/main/java/com/bailuntec/mapper/DcBaseCompanyStaffMapper.java 0 → 100644
package com.bailuntec.mapper;
import com.bailuntec.domain.entity.DcBaseCompanyStaff;
import com.bailuntec.domain.example.DcBaseCompanyStaffExample;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface DcBaseCompanyStaffMapper {
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
long countByExample(DcBaseCompanyStaffExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int deleteByExample(DcBaseCompanyStaffExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int deleteByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int insert(DcBaseCompanyStaff record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int insertSelective(DcBaseCompanyStaff record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
DcBaseCompanyStaff selectOneByExample(DcBaseCompanyStaffExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
List<DcBaseCompanyStaff> selectByExample(DcBaseCompanyStaffExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
DcBaseCompanyStaff selectByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int updateByExampleSelective(@Param("record") DcBaseCompanyStaff record, @Param("example") DcBaseCompanyStaffExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int updateByExample(@Param("record") DcBaseCompanyStaff record, @Param("example") DcBaseCompanyStaffExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int updateByPrimaryKeySelective(DcBaseCompanyStaff record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
int updateByPrimaryKey(DcBaseCompanyStaff record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsert(DcBaseCompanyStaff record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsertSelective(DcBaseCompanyStaff record);
}
\ No newline at end of file
data-base/base-sync-company/src/main/resources/const.properties 0 → 100644
COMPANY_INFO_URL=http://sso.bailuntec.com/GetCompanys
COMPANY_STAFF_URL=http://sso.bailuntec.com/GetUserByCompany
data-base/base-sync-company/src/main/resources/job.properties 0 → 100644
#EVENT_RDB_STORAGE_URL=jdbc:mysql://192.168.6.140:3306/bailun_datacenter?serverTimezone=GMT%2B8&characterEncoding=utf-8
#EVENT_RDB_STORAGE_USERNAME=root
#EVENT_RDB_STORAGE_PASSWORD=123456
#ZOOKEEPER_SERVER=127.0.0.1:2181
EVENT_RDB_STORAGE_DRIVER=com.mysql.jdbc.Driver
EVENT_RDB_STORAGE_URL=jdbc:mysql://10.0.8.15:3306/bailun_datacenter?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
EVENT_RDB_STORAGE_USERNAME=root
EVENT_RDB_STORAGE_PASSWORD=#7kfnymAM$Y9-Ntf
ZOOKEEPER_SERVER=172.31.255.120:2181
NAME_SPACE=data-center
JOB_NAME_COMPANY_INFO=base-sync-company-info
JOB_NAME_COMPANY_STAFF=base-sync-company-staff
JOB_CRON_COMPANY_INFO=0 0 2/4 * * ? *
JOB_CRON_COMPANY_STAFF=5 5 1/4 * * ? *
SHARDING_TOTAL_COUNT=1
\ No newline at end of file
data-base/base-sync-company/src/test/java/CompanyTest.java 0 → 100644
import com.bailuntec.domain.entity.JobPointLog;
import com.bailuntec.job.CompanyInfoSyncJob;
import com.bailuntec.job.CompanyStaffSyncJob;
import org.junit.jupiter.api.Test;
import java.time.LocalDateTime;
public class CompanyTest {
@Test
public void test() {
CompanyInfoSyncJob skuSyncJob = new CompanyInfoSyncJob();
skuSyncJob.executeJob(null, new JobPointLog("base-sku",0 ,100,1,1, LocalDateTime.now().minusMonths(1),LocalDateTime.now().minusDays(29)));
}
@Test
public void test2() {
CompanyStaffSyncJob skuSyncJob = new CompanyStaffSyncJob();
skuSyncJob.executeJob(null, new JobPointLog("base-sku",0 ,100,1,1, LocalDateTime.now().minusMonths(1),LocalDateTime.now().minusDays(29)));
}
}
data-base/pom.xml
......@@ -26,6 +26,7 @@
<module>base-sync-crm-refund</module>
<module>base-sync-oms-order-for-tj</module>
<module>base-sync-cost-first</module>
<module>base-sync-company</module>
</modules>
<packaging>pom</packaging>
......
data-common/src/main/java/com/bailuntec/domain/entity/DcBaseCompanyInfo.java 0 → 100644
package com.bailuntec.domain.entity;
import lombok.Data;
import java.time.LocalDateTime;
@Data
public class DcBaseCompanyInfo {
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_info.id
*
* @mbg.generated
*/
private Integer id;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_info.company_id
*
* @mbg.generated
*/
private Integer companyId;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_info.company_code
*
* @mbg.generated
*/
private String companyCode;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_info.company_name
*
* @mbg.generated
*/
private String companyName;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_info.gmt_create
*
* @mbg.generated
*/
private LocalDateTime gmtCreate;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_info.gmt_modified
*
* @mbg.generated
*/
private LocalDateTime gmtModified;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_info.status
*
* @mbg.generated
*/
private Boolean status;
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
@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(", companyId=").append(companyId);
sb.append(", companyCode=").append(companyCode);
sb.append(", companyName=").append(companyName);
sb.append(", gmtCreate=").append(gmtCreate);
sb.append(", gmtModified=").append(gmtModified);
sb.append(", status=").append(status);
sb.append("]");
return sb.toString();
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
@Override
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
DcBaseCompanyInfo other = (DcBaseCompanyInfo) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getCompanyId() == null ? other.getCompanyId() == null : this.getCompanyId().equals(other.getCompanyId()))
&& (this.getCompanyCode() == null ? other.getCompanyCode() == null : this.getCompanyCode().equals(other.getCompanyCode()))
&& (this.getCompanyName() == null ? other.getCompanyName() == null : this.getCompanyName().equals(other.getCompanyName()))
&& (this.getGmtCreate() == null ? other.getGmtCreate() == null : this.getGmtCreate().equals(other.getGmtCreate()))
&& (this.getGmtModified() == null ? other.getGmtModified() == null : this.getGmtModified().equals(other.getGmtModified()))
&& (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()));
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_info
*
* @mbg.generated
*/
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getCompanyId() == null) ? 0 : getCompanyId().hashCode());
result = prime * result + ((getCompanyCode() == null) ? 0 : getCompanyCode().hashCode());
result = prime * result + ((getCompanyName() == null) ? 0 : getCompanyName().hashCode());
result = prime * result + ((getGmtCreate() == null) ? 0 : getGmtCreate().hashCode());
result = prime * result + ((getGmtModified() == null) ? 0 : getGmtModified().hashCode());
result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
return result;
}
}
\ No newline at end of file
data-common/src/main/java/com/bailuntec/domain/entity/DcBaseCompanyStaff.java 0 → 100644
package com.bailuntec.domain.entity;
import lombok.Data;
import java.time.LocalDateTime;
@Data
public class DcBaseCompanyStaff {
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_staff.id
*
* @mbg.generated
*/
private Integer id;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_staff.company_id
*
* @mbg.generated
*/
private Integer companyId;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_staff.user_id
*
* @mbg.generated
*/
private Integer userId;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_staff.user_name
*
* @mbg.generated
*/
private String userName;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_staff.gmt_create
*
* @mbg.generated
*/
private LocalDateTime gmtCreate;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_staff.gmt_modified
*
* @mbg.generated
*/
private LocalDateTime gmtModified;
/**
*
* This field was generated by MyBatis Generator.
* This field corresponds to the database column dc_base_company_staff.status
*
* @mbg.generated
*/
private Boolean status;
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
@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(", companyId=").append(companyId);
sb.append(", userId=").append(userId);
sb.append(", userName=").append(userName);
sb.append(", gmtCreate=").append(gmtCreate);
sb.append(", gmtModified=").append(gmtModified);
sb.append(", status=").append(status);
sb.append("]");
return sb.toString();
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
@Override
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
DcBaseCompanyStaff other = (DcBaseCompanyStaff) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getCompanyId() == null ? other.getCompanyId() == null : this.getCompanyId().equals(other.getCompanyId()))
&& (this.getUserId() == null ? other.getUserId() == null : this.getUserId().equals(other.getUserId()))
&& (this.getUserName() == null ? other.getUserName() == null : this.getUserName().equals(other.getUserName()))
&& (this.getGmtCreate() == null ? other.getGmtCreate() == null : this.getGmtCreate().equals(other.getGmtCreate()))
&& (this.getGmtModified() == null ? other.getGmtModified() == null : this.getGmtModified().equals(other.getGmtModified()))
&& (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()));
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_base_company_staff
*
* @mbg.generated
*/
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getCompanyId() == null) ? 0 : getCompanyId().hashCode());
result = prime * result + ((getUserId() == null) ? 0 : getUserId().hashCode());
result = prime * result + ((getUserName() == null) ? 0 : getUserName().hashCode());
result = prime * result + ((getGmtCreate() == null) ? 0 : getGmtCreate().hashCode());
result = prime * result + ((getGmtModified() == null) ? 0 : getGmtModified().hashCode());
result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
return result;
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment