Skip to content

D
dc-java
Commit 9d1d9d21 by wutong
Options

调整项目结构, 修改README

parent 7e7e6ad8
Showing with 13 additions and 572 deletions
README.md
......@@ -26,6 +26,8 @@
[上传仓储费]()
### 调用接口wiki
[CRM退款接口文档](http://code.bailuntec.com/blt/kefu-web/wikis/%E9%80%80%E6%AC%BE%E6%97%A5%E5%BF%97%E6%8E%A5%E5%8F%A3)
[采购流水接口文档](http://code.bailuntec.com/blt/purchase/wikis/%E8%8E%B7%E5%8F%96%E9%87%87%E8%B4%AD%E5%8D%95%E7%9A%84%E9%87%87%E8%B4%AD%E6%95%B0%E3%80%81%E5%8F%91%E8%B4%A7%E6%95%B0%E3%80%81%E5%88%B0%E8%B4%A7%E6%95%B0%E3%80%81%E8%B4%A8%E6%A3%80%E6%95%B0%E3%80%81%E5%85%A5%E5%BA%93%E6%95%B0%E6%B5%81%E6%B0%B4%E5%88%97%E8%A1%A8)
[调拨流水接口文档](http://193.112.143.129/blt/BailunWms/wikis/%E8%B0%83%E6%8B%A8%E5%8D%95sku%E6%B5%81%E6%B0%B4%E8%AE%B0%E5%BD%95%E6%9F%A5%E8%AF%A2)
......@@ -69,20 +71,22 @@
| data-api 对外提供HTTP接口
| data-common 公共模块,一些工具类和共用的实体
| data-parent 依赖统一管理
|-data-base 基础数据对接
|-data-base base-基础数据对接
|-base-sync-amazon-ad 同步亚马逊广告费用
|-base-sync-company 同步公司和账户信息
|-base-sync-cost-first 同步物流头程费用
|-base-sync-crm-refund 同步CRM系统退款
|-base-sync-finance-ebay 同步EBAY费用信息
|-base-sync-finance-wish 同步WISH费用信息
|-base-sync-oms-order 同步OMS系统订单
|-base-sync-oms-order-for-tj 为TJ系统写的同步OMS系统订单(已废弃)
|-base-sync-paypal 同步Paypal流水
|-base-sync-purchase 同步采购系统流水
|-base-sync-purchase-details 同步采购系统详情
|-base-sync-sku 同步SKUMS
|-base-sync-stock 同步环球库存(已废弃)
|-base-sync-stock-wms 同步WMS系统库存
|-base-sync-transfer 同步调拨流水
|-base-sync-warehouse 同步仓库信息
|-data-mid 中间数据处理
|-data-mid mid-中间数据处理
|-mid-auto-turnover-prepare 扫描数据进自动周转列表
|-mid-calculate-cost-first 计算头程费
|-mid-calculate-sales 计算销量
......@@ -91,9 +95,9 @@
|-mid-ebay-uk-report ebay uk发货分析报表
|-mid-fba-fee-avg 计算FBA平均费用
|-mid-stored-procedure 帮.net同事跑一些定时任务
|-data-finance 财务相关报表
|-data-finance finance-财务相关报表
|-finance-accounting-entry 会计分录
|-finance-balance-sheet 资产负债表
|-data-show 数据价值展现
|-data-show show-数据价值展现
|-show-auto-turnover 自动周转逻辑
```
\ No newline at end of file
data-base/base-sync-finance-amazon/Dockerfile deleted 100644 → 0
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-finance-amazon -am
#指定容器启动程序及参数 <ENTRYPOINT> "<CMD>"
EXPOSE 8080
ENTRYPOINT ["java","-Xms30m","-Xmx80m","-jar","/usr/app/data-base/base-sync-finance-amazon/target/base-sync-finance-amazon-1.0-SNAPSHOT.jar"]
\ No newline at end of file
data-base/base-sync-finance-amazon/pom.xml deleted 100644 → 0
<?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>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>base-sync-finance-amazon</artifactId>
<name>base-sync-finance-amazon</name>
<!-- FIXME change it to the project's website -->
<url>http://www.example.com</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
</properties>
<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>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<scope>compile</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-finance-amazon/src/main/java/com/bailuntec/Application.java deleted 100644 → 0
package com.bailuntec;
import com.alibaba.druid.pool.DruidDataSource;
import com.bailuntec.job.AdvertAddTaskSyncJob;
import com.bailuntec.job.AdvertResultSyncJob;
import com.bailuntec.listener.AdvertSyncJobListener;
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(), createJobEventConfiguration(), new AdvertSyncJobListener()).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_ADDTASK"), propertiesUtil.getPropertyAsString("JOB_CRON_ADDTASK"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, AdvertAddTaskSyncJob.class.getCanonicalName());
LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
return simpleJobRootConfig;
}
private static LiteJobConfiguration createJobConfiguration2() {
JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("JOB_NAME_GETRESULT"), propertiesUtil.getPropertyAsString("JOB_CRON_GETRESULT"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, AdvertResultSyncJob.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-finance-amazon/src/main/java/com/bailuntec/domain/AccountTokenInfo.java deleted 100644 → 0
package com.bailuntec.domain;
import lombok.Data;
import java.util.List;
import java.util.Map;
@Data
public class AccountTokenInfo {
private Boolean success;
private String message;
private List<Map> data;
}
data-base/base-sync-finance-amazon/src/main/java/com/bailuntec/domain/AdvertResultData.java deleted 100644 → 0
package com.bailuntec.domain;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
import java.util.List;
@Data
public class AdvertResultData {
@JSONField(name = "task_id")
private Integer taskId;
private Boolean success;
private List<String> data;
}
data-base/base-sync-finance-amazon/src/main/java/com/bailuntec/domain/AdvertResultInfo.java deleted 100644 → 0
package com.bailuntec.domain;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
import java.util.List;
@Data
public class AdvertResultInfo {
private Integer code;
private String msg;
private List<AdvertResultData> results;
@JSONField(name= "task_ids")
private String taskIds;
}
data-base/base-sync-finance-amazon/src/main/java/com/bailuntec/domain/AmazonAdvert.java deleted 100644 → 0
package com.bailuntec.domain;
import com.alibaba.fastjson.annotation.JSONField;
import lombok.Data;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
@Data
public class AmazonAdvert {
private Integer id;
private String campaignName;
private String campaignId;
private String campaignStatus;
private Integer campaignBudget;
@JSONField(name = "attributedConversions1d")
private Integer attributedConversionsOneday;
@JSONField(name = "attributedUnitsOrdered1d")
private Integer attributedUnitsOrderedOneday;
@JSONField(name = "attributedSales1d")
private Integer attributedSalesOneday;
@JSONField(name = "attributedUnitsOrdered7d")
private Integer attributedUnitsOrderedSevenday;
private Integer impressions;
private Integer clicks;
private BigDecimal cost;
@JSONField(name = "attributedConversions30d")
private Integer attributedConversionsThirtyday;
@JSONField(name = "attributedConversions14d")
private Integer attributedConversionsFourteenday;
@JSONField(name = "attributedConversions7d")
private Integer attributedConversionsSevenday;
@JSONField(name = "attributedSales30d")
private Integer attributedSalesThirtyday;
@JSONField(name = "attributedSales14d")
private Integer attributedSalesFourteenday;
@JSONField(name = "attributedSales7d")
private Integer attributedSalesSevenday;
private String currency;
private Integer accountId;
private Integer companyId;
private LocalDateTime gmtCreateTime;
private LocalDateTime gmtModifyTime;
private LocalDate reportDate;
private String reportType;
}
data-base/base-sync-finance-amazon/src/main/java/com/bailuntec/job/AdvertResultSyncJob.java deleted 100644 → 0
package com.bailuntec.job;
import com.bailuntec.domain.entity.JobPointLog;
import com.bailuntec.support.PointJob;
import com.bailuntec.utils.OkHttpUtil;
import com.bailuntec.utils.PropertiesUtil;
import com.dangdang.ddframe.job.api.ShardingContext;
import lombok.extern.slf4j.Slf4j;
import okhttp3.*;
@Slf4j
public class AdvertResultSyncJob extends PointJob {
private PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("const");
private OkHttpClient client = OkHttpUtil.getInstance();
@Override
public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
/* int totalPage = getCount(jobPointLog);//分片即将处理的账号总数
try {
JobAccountLogMapper jobAccountLogMapper = SessionUtil.getSession().getMapper(JobAccountLogMapper.class);
int pageSize = totalPage % shardingContext.getShardingTotalCount() == 0 ? totalPage / shardingContext.getShardingTotalCount() : totalPage / shardingContext.getShardingTotalCount() + 1;
List<JobAccountLog> listByPage = jobAccountLogMapper.getListByPage(AccountPlatformType.Amazon.code(), pageSize * shardingContext.getShardingItem(), pageSize);
for (JobAccountLog jobAccountLog : listByPage) {
String taskIds = jobAccountLog.getTaskIds();
if(StringUtils.isNotBlank(taskIds)) {
List<List<Integer>> taskIdsList = (List<List<Integer>>) JSONArray.parse(taskIds);
for (List<Integer> ids : taskIdsList) {
callSaasApi(jobAccountLog, ids);
}
}
}
} catch (Exception e) {
e.printStackTrace();
log.warn("Amazon广告费接口调用错误", e);
} finally {
SessionUtil.closeSession();
}*/
}
/*
private int getCount(JobPointLog jobPointLog) {
int i = 0;
try {
DcBaseCompanyAccountMapper accountMapper = SessionUtil.getSession().getMapper(DcBaseCompanyAccountMapper.class);
i = (int) accountMapper.countByExample(DcBaseCompanyAccountExample.newAndCreateCriteria().andPlatformIdEqualTo(AccountPlatformType.Amazon.code()).example());
} catch (Exception e) {
e.printStackTrace();
} finally {
SessionUtil.closeSession();
}
return i;
}
public void callSaasApi(JobAccountLog job, List<Integer> ids) {
HashMap<String, Object> map = new HashMap<>(2);
map.put("app_id", 1);
map.put("task_ids", ids);
MediaType mediaType = MediaType.parse("application/json");
Response response = null;
try {
DcBaseFinanceAmazonMapper dcBaseFinanceAmazonMapper = SessionUtil.getSession().getMapper(DcBaseFinanceAmazonMapper.class);
RequestBody body = RequestBody.create(mediaType, JSON.toJSONString(map));
Request request = new Request.Builder()
.url(propertiesUtil.getPropertyAsString("GETRESULT_FINANCE_URL"))
.post(body)
.addHeader("Content-Type", "application/json")
.build();
response = client.newCall(request).execute();
if (response.isSuccessful()) {
AdvertResultInfo advertResult = JSON.parseObject(response.body().string(), AdvertResultInfo.class);
if (advertResult != null && advertResult.getCode() == 0) {
List<AdvertResultData> accountEntries = advertResult.getResults();
if (accountEntries != null && accountEntries.size() > 0) {
List<AmazonAdvert> advertList = JSON.parseArray(accountEntries.get(0).getData().get(0), AmazonAdvert.class);
for (AmazonAdvert amazonAdvert : advertList) {
amazonAdvert.setAccountId(job.getAccountId());
amazonAdvert.setCompanyId(job.getCompanyId());
dcBaseFinanceAmazonMapper.upsertSelective(amazonAdvert);
}
}
} else {
throw new RuntimeException("授权错误");
}
} else {
throw new RuntimeException("接口调用失败");
}
} catch (Exception e) {
job.setMessage(e.getMessage());
} finally {
if (response != null) {
response.close();
}
}
}*/
}
data-base/base-sync-finance-amazon/src/main/java/com/bailuntec/listener/AdvertSyncJobListener.java deleted 100644 → 0
package com.bailuntec.listener;
import com.dangdang.ddframe.job.executor.ShardingContexts;
import com.dangdang.ddframe.job.lite.api.listener.ElasticJobListener;
public class AdvertSyncJobListener implements ElasticJobListener {
@Override
public void beforeJobExecuted(ShardingContexts shardingContexts) {
}
@Override
public void afterJobExecuted(ShardingContexts shardingContexts) {
}
}
data-base/base-sync-finance-amazon/src/main/java/com/bailuntec/utils/RedisUtil.java deleted 100644 → 0
package com.bailuntec.utils;
import lombok.extern.slf4j.Slf4j;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
@Slf4j
public class RedisUtil {
private static PropertiesUtil propertiesUtil = PropertiesUtil.getInstance("redis");
private static JedisPool jedisPool = null;
/*
* 初始化连接池
*/
static{
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(propertiesUtil.getPropertyAsInt("SETMAXTOTAL"));
config.setMaxIdle(propertiesUtil.getPropertyAsInt("SETMAXIDLE"));
config.setMaxWaitMillis(propertiesUtil.getPropertyAsInt("SETMAXWAITMILLLIS"));
config.setTestOnBorrow(true);
jedisPool = new JedisPool(config, propertiesUtil.getPropertyAsString("REDIS_URL"), propertiesUtil.getPropertyAsInt("REDIS_PORT"));
log.warn("初始化连接池");
}
/*
* 获取redis实例
*/
public synchronized static Jedis getJedis() {
Jedis jedis = null;
try{
jedis =jedisPool.getResource();
}catch(Exception e) {
e.printStackTrace();
}
return jedis;
}
/*
* 回收redis对象资源
*/
public synchronized static void returnResource(Jedis jedis) {
if(jedis != null) {
try{
jedis.close();
}catch (Exception e){
e.printStackTrace();
}
}
}
/*
* 获取key值
*/
public String getValueByKey(String key) {
Jedis jedis = null;
String result = null;
try {
jedis = getJedis();
result = jedis.get(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
returnResource(jedis);
}
return result;
}
/*
* 删除key
*/
public void deleteByKey(String key) throws Exception {
Jedis jedis = null;
try {
jedis = getJedis();
jedis.del(key);
} catch (Exception e) {
throw e;
} finally {
returnResource(jedis);
}
}
/*
* 设置过期时间值
*/
public void saveValueByKey(String key, String value) throws Exception {
Jedis jedis = null;
try {
jedis = getJedis();
jedis.set(key, value);
jedis.expire(key, propertiesUtil.getPropertyAsInt("EXPIRETIME"));
} catch (Exception e) {
throw e;
} finally {
returnResource(jedis);
}
}
}
data-base/base-sync-finance-amazon/src/main/resources/const.properties deleted 100644 → 0
ADDTASK_FINANCE_URL=http://10.0.3.5:18321/outer/addtask
GETRESULT_FINANCE_URL=http://10.0.3.5:18321/outer/getresult
ACCOUNT_API=http://pams.bailuntec.com/Api/GetAccountToken?platform=Amazon
CAMPAIGNS_REPORT=https://advertising-api.amazon.com/v2/sp/productAds/report
#HSA_CAMPAIGNS_REPORT=https://advertising-api.amazon.com/v2/hsa/campaigns/report
V2_REPORTS=https://advertising-api.amazon.com/v2/reports/
WARN_API=https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=b4655a50-927a-4c3c-87ad-a900e54dcc8e
#METRICS=campaignName,campaignId,campaignStatus,campaignBudget,attributedConversions1d,attributedUnitsOrdered1d,attributedSales1d,attributedUnitsOrdered7d,attributedSales1d,impressions,clicks,cost,attributedConversions30d,attributedConversions14d,attributedConversions7d,attributedSales30d,attributedSales14d,attributedSales7d
METRICS=campaignName,campaignId,adGroupName,adGroupId,impressions,clicks,cost,currency,asin,sku,attributedConversions1d,attributedConversions7d,attributedConversions14d,attributedConversions30d,attributedConversions1dSameSKU,attributedConversions7dSameSKU,attributedConversions14dSameSKU,attributedConversions30dSameSKU,attributedUnitsOrdered1d,attributedUnitsOrdered7d,attributedUnitsOrdered14d,attributedUnitsOrdered30d,attributedSales1d,attributedSales7d,attributedSales14d,attributedSales30d,attributedSales1dSameSKU,attributedSales7dSameSKU,attributedSales14dSameSKU,attributedSales30dSameSKU,attributedUnitsOrdered1dSameSKU,attributedUnitsOrdered7dSameSKU,attributedUnitsOrdered14dSameSKU,attributedUnitsOrdered30dSameSKU
#METRICS=campaignName,campaignId,cost,campaignStatus,campaignBudget,currency
data-base/base-sync-finance-amazon/src/main/resources/job.properties deleted 100644 → 0
#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_ADDTASK=base-sync-finance-amazon-advert
JOB_CRON_ADDTASK=0 17 11 16 * ? *
JOB_NAME_GETRESULT=base-sync-finance-amazon-getresult
JOB_CRON_GETRESULT=0 0 6,23 * * ? *
SHARDING_TOTAL_COUNT=1
\ No newline at end of file
data-base/base-sync-finance-amazon/src/main/resources/redis.properties deleted 100644 → 0
REDIS_URL=94.191.111.219
REDIS_PORT=6379
#REDIS_URL=redis.blt.com
#REDIS_PORT=6379
SETMAXTOTAL=100
SETMAXIDLE=10
SETMAXWAITMILLLIS=10000
EXPIRETIME=172800
data-base/pom.xml
......@@ -27,7 +27,6 @@
<module>base-sync-company</module>
<module>base-sync-finance-ebay</module>
<module>base-sync-paypal</module>
<module>base-sync-finance-amazon</module>
<module>base-sync-amazon-ad</module>
<module>base-sync-finance-wish</module>
</modules>
......
data-common/src/main/resources/mybatis-config.xml
......@@ -4,8 +4,8 @@
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!--<properties resource="db-tj.properties"/>-->
<!-- <properties resource="db-dev.properties"/>-->
<properties resource="db-prod.properties"/>
<properties resource="db-dev.properties"/>
<!-- <properties resource="db-prod.properties"/>-->
<settings>
<setting name="mapUnderscoreToCamelCase" value="true"/>
</settings>
......
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