Skip to content

D
dc-java
Commit 7b7da759 by yinyong
Options

同步半成品订单信息

parent a5187f5a
Showing with 311 additions and 0 deletions
data-base/base-sync-semi-order/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-semi-order -am
#指定容器启动程序及参数 <ENTRYPOINT> "<CMD>"
EXPOSE 8080
ENTRYPOINT ["java","-Xms30m","-Xmx80m","-jar","/usr/app/data-base/base-sync-semi-order/target/base-sync-semi-order-1.0-SNAPSHOT.jar"]
\ No newline at end of file
data-base/base-sync-semi-order/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-semi-order</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>
data-base/base-sync-semi-order/src/main/java/com/bailuntec/Application.java 0 → 100644
package com.bailuntec;
import com.alibaba.druid.pool.DruidDataSource;
import com.bailuntec.job.SemiOrderSyncJob;
import com.bailuntec.listener.SemiOrderSyncJobListener;
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(), createJobConfiguration(),createJobEventConfiguration(), new SemiOrderSyncJobListener()).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 createJobConfiguration() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_NAME"), propertiesUtil.getPropertyAsString("JOB_CRON"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, SemiOrderSyncJob.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-semi-order/src/main/resources/const.properties 0 → 100644
SEMI_ORDER_URL=http://api.mjplan.bailuntec.com/api/applyorderlist
data-base/base-sync-semi-order/src/main/resources/job.properties 0 → 100644
#EVENT_RDB_STORAGE_DRIVER=com.mysql.jdbc.Driver
#EVENT_RDB_STORAGE_URL=jdbc:mysql://127.0.0.1:3306/bailun_datacenter?useUnicode=true&characterEncoding=UTF-8&serverTimeZone=GMT&useSSL=false&allowPublicKeyRetrieval=true&allowMultiQueries=true
#EVENT_RDB_STORAGE_USERNAME=root
#EVENT_RDB_STORAGE_PASSWORD=root
#ZOOKEEPER_SERVER=94.191.111.219: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=base-sync-semi-order
JOB_CRON=0/1 * * * * ? *
SHARDING_TOTAL_COUNT=1
\ No newline at end of file
data-base/pom.xml
......@@ -30,6 +30,7 @@
<module>base-sync-amazon-ad</module>
<module>base-sync-finance-wish</module>
<module>base-sync-cashier</module>
<module>base-sync-semi-order</module>
</modules>
<packaging>pom</packaging>
......
data-common/src/main/java/com/bailuntec/mapper/DcSemiOrderMapper.java 0 → 100644
package com.bailuntec.mapper;
import com.bailuntec.domain.entity.DcSemiOrder;
import com.bailuntec.domain.example.DcSemiOrderExample;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface DcSemiOrderMapper {
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
long countByExample(DcSemiOrderExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int deleteByExample(DcSemiOrderExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int deleteByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int insert(DcSemiOrder record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int insertSelective(DcSemiOrder record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
DcSemiOrder selectOneByExample(DcSemiOrderExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
List<DcSemiOrder> selectByExample(DcSemiOrderExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
DcSemiOrder selectByPrimaryKey(Integer id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int updateByExampleSelective(@Param("record") DcSemiOrder record, @Param("example") DcSemiOrderExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int updateByExample(@Param("record") DcSemiOrder record, @Param("example") DcSemiOrderExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int updateByPrimaryKeySelective(DcSemiOrder record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
*/
int updateByPrimaryKey(DcSemiOrder record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsert(DcSemiOrder record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table dc_semi_order
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
int upsertSelective(DcSemiOrder record);
}
\ 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