4.0.0
+
- com.roncoo.pay.common
+ com.roncoo.pay
roncoo-pay
- 0.0.4-SNAPSHOT
+ 2.1.2-SNAPSHOT
- com.roncoo.pay.app
+
+ com.roncoo.pay
roncoo-pay-app-reconciliation
roncoo-pay-app-reconciliation
- http://maven.apache.org
+ 对账流程app,发起对账核心业务
UTF-8
-
-
- com.roncoo.pay.common
- roncoo-pay-common-core
- ${project.parent.version}
-
-
-
com.roncoo.pay.service
roncoo-pay-service
- ${project.parent.version}
-
-
- junit
- junit
-
- test
+ org.springframework.boot
+ spring-boot-starter-web
+
+ commons-io
+ commons-io
+
+
+ org.springframework.boot
+ spring-boot-devtools
+ runtime
+
-
- roncoo-pay-app-reconciliation
+ ${project.name}
-
-
-
- org.apache.maven.plugins
- maven-jar-plugin
-
- target/classes/
-
-
- com.roncoo.pay.app.reconciliation.ReconciliationTask
-
- false
- true
- lib/
-
-
- .
-
-
-
-
-
-
- org.apache.maven.plugins
- maven-dependency-plugin
-
-
- copy-dependencies
- package
-
- copy-dependencies
-
-
- jar
- jar
-
- ${project.build.directory}/lib
-
-
-
-
-
-
-
- org.apache.maven.plugins
- maven-deploy-plugin
- 2.7
-
- false
-
-
-
- org.apache.maven.plugins
- maven-eclipse-plugin
- 2.8
-
-
- org.apache.maven.plugins
- maven-compiler-plugin
- 3.2
-
- true
- true
- true
- -nowarn
-
- 1.7
- UTF-8
-
-
-
- org.apache.maven.plugins
- maven-source-plugin
- 2.1.2
-
-
- attach-sources
-
- jar
-
-
-
+ org.springframework.boot
+ spring-boot-maven-plugin
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/AppReconciliationApplication.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/AppReconciliationApplication.java
new file mode 100644
index 0000000000000000000000000000000000000000..e431acd6cf67f164acdb145a8de8322be3968349
--- /dev/null
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/AppReconciliationApplication.java
@@ -0,0 +1,22 @@
+package com.roncoo.pay;
+
+import org.springframework.boot.WebApplicationType;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@SpringBootApplication
+@EnableScheduling
+public class AppReconciliationApplication {
+
+ public static ConfigurableApplicationContext context;
+
+
+ public static void main(String[] args) {
+// SpringApplication.run(AppReconciliationApplication.class, args);
+ context = new SpringApplicationBuilder().sources(AppReconciliationApplication.class).web(WebApplicationType.NONE).run(args);
+ }
+
+}
+
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/ReconciliationTask.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/ReconciliationTask.java
index 75e3c9f4e5ea6b8a22fc14f6450fa0c4963f621e..55e14cf34c282d3a3113f77258ad6896ed374b9d 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/ReconciliationTask.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/ReconciliationTask.java
@@ -1,12 +1,12 @@
/*
* Copyright 2015-2102 RonCoo(http://www.roncoo.com) Group.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,145 +15,153 @@
*/
package com.roncoo.pay.app.reconciliation;
-import java.io.File;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.List;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
+import com.roncoo.pay.AppReconciliationApplication;
import com.roncoo.pay.app.reconciliation.biz.ReconciliationCheckBiz;
import com.roncoo.pay.app.reconciliation.biz.ReconciliationFileDownBiz;
import com.roncoo.pay.app.reconciliation.biz.ReconciliationFileParserBiz;
import com.roncoo.pay.app.reconciliation.biz.ReconciliationValidateBiz;
import com.roncoo.pay.app.reconciliation.utils.DateUtil;
-import com.roncoo.pay.app.reconciliation.utils.SpringContextUtil;
import com.roncoo.pay.app.reconciliation.vo.ReconciliationInterface;
import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
import com.roncoo.pay.reconciliation.enums.BatchStatusEnum;
import com.roncoo.pay.reconciliation.service.RpAccountCheckBatchService;
import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
import com.roncoo.pay.user.service.BuildNoService;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.io.File;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
/**
* 对账处理(包括下载对账文件、转换对账文件、对账) .
- *
+ *
* 龙果学院:www.roncoo.com
- *
+ *
* @author:shenjialong
*/
+@Component
public class ReconciliationTask {
- private static final Log LOG = LogFactory.getLog(ReconciliationTask.class);
-
- public static void main(String[] args) {
-
- SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
-
- try {
- // 加载Spring配置文件
- ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "spring-context.xml" });
- // 初始化SpringContextUtil
- final SpringContextUtil ctxUtil = new SpringContextUtil();
- ctxUtil.setApplicationContext(context);
-
- @SuppressWarnings("rawtypes")
- // 获取全部有效的对账接口(目前是写死了,可以做持久化到数据库,再查出来)
- List reconciliationInterList = ReconciliationInterface.getInterface();
-
- // 获取业务biz实体
- ReconciliationFileDownBiz fileDownBiz = (ReconciliationFileDownBiz) SpringContextUtil.getBean("reconciliationFileDownBiz");
- ReconciliationFileParserBiz parserBiz = (ReconciliationFileParserBiz) SpringContextUtil.getBean("reconciliationFileParserBiz");
- ReconciliationCheckBiz checkBiz = (ReconciliationCheckBiz) SpringContextUtil.getBean("reconciliationCheckBiz");
- ReconciliationValidateBiz validateBiz = (ReconciliationValidateBiz) SpringContextUtil.getBean("reconciliationValidateBiz");
- RpAccountCheckBatchService batchService = (RpAccountCheckBatchService) SpringContextUtil.getBean("rpAccountCheckBatchService");
- BuildNoService buildNoService = (BuildNoService) SpringContextUtil.getBean("buildNoService");
-
- // 根据不同的渠道发起对账
- for (int num = 0; num < reconciliationInterList.size(); num++) {
- // 判断接口是否正确
- ReconciliationInterface reconciliationInter = (ReconciliationInterface) reconciliationInterList.get(num);
- if (reconciliationInter == null) {
- LOG.info("对账接口信息" + reconciliationInter + "为空");
- continue;
- }
- // 获取需要对账的对账单时间
- Date billDate = DateUtil.addDay(new Date(), -reconciliationInter.getBillDay());
- // 获取对账渠道
- String interfaceCode = reconciliationInter.getInterfaceCode();
-
- /** step1:判断是否对过账 **/
- RpAccountCheckBatch batch = new RpAccountCheckBatch();
- Boolean checked = validateBiz.isChecked(interfaceCode, billDate);
- if (checked) {
- LOG.info("账单日[" + sdf.format(billDate) + "],支付方式[" + interfaceCode + "],已经对过账,不能再次发起自动对账。");
- continue;
- }
- // 创建对账批次
- batch.setCreater("reconciliationSystem");
- batch.setCreateTime(new Date());
- batch.setBillDate(billDate);
- batch.setBatchNo(buildNoService.buildReconciliationNo());
- batch.setBankType(interfaceCode);
-
- /** step2:对账文件下载 **/
- File file = null;
- try {
- LOG.info("ReconciliationFileDownBiz,对账文件下载开始");
- file = fileDownBiz.downReconciliationFile(interfaceCode, billDate);
- if (file == null) {
- continue;
- }
- LOG.info("对账文件下载结束");
- } catch (Exception e) {
- LOG.error("对账文件下载异常:", e);
- batch.setStatus(BatchStatusEnum.FAIL.name());
- batch.setRemark("对账文件下载异常");
- batchService.saveData(batch);
- continue;
- }
-
- /** step3:解析对账文件 **/
- List bankList = null;
- try {
- LOG.info("=ReconciliationFileParserBiz=>对账文件解析开始>>>");
-
- // 解析文件
- bankList = parserBiz.parser(batch, file, billDate, interfaceCode);
- // 如果下载文件异常,退出
- if (BatchStatusEnum.ERROR.name().equals(batch.getStatus())) {
- continue;
- }
- LOG.info("对账文件解析结束");
- } catch (Exception e) {
- LOG.error("对账文件解析异常:", e);
- batch.setStatus(BatchStatusEnum.FAIL.name());
- batch.setRemark("对账文件解析异常");
- batchService.saveData(batch);
- continue;
- }
-
- /** step4:对账流程 **/
- try {
- checkBiz.check(bankList, interfaceCode, batch);
- } catch (Exception e) {
- LOG.error("对账异常:", e);
- batch.setStatus(BatchStatusEnum.FAIL.name());
- batch.setRemark("对账异常");
- batchService.saveData(batch);
- continue;
- }
-
- }
-
- /** step5:清理缓冲池 **/
- // 如果缓冲池中有三天前的数据就清理掉并记录差错
- validateBiz.validateScratchPool();
- } catch (Exception e) {
- LOG.error("roncoo-app-reconciliation error:", e);
- }
-
- }
+ private static final Log LOG = LogFactory.getLog(ReconciliationTask.class);
+
+ @Autowired
+ private ReconciliationFileDownBiz fileDownBiz;
+ @Autowired
+ private ReconciliationFileParserBiz parserBiz;
+ @Autowired
+ private ReconciliationCheckBiz checkBiz;
+ @Autowired
+ private ReconciliationValidateBiz validateBiz;
+ @Autowired
+ private RpAccountCheckBatchService batchService;
+ @Autowired
+ private BuildNoService buildNoService;
+
+ @PostConstruct
+ public void taskRun() {
+
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+
+ try {
+
+ @SuppressWarnings("rawtypes")
+ // 获取全部有效的对账接口(目前是写死了,可以做持久化到数据库,再查出来)
+ List reconciliationInterList = ReconciliationInterface.getInterface();
+
+ // 根据不同的渠道发起对账
+ for (int num = 0; num < reconciliationInterList.size(); num++) {
+ // 判断接口是否正确
+ ReconciliationInterface reconciliationInter = (ReconciliationInterface) reconciliationInterList.get(num);
+ if (reconciliationInter == null) {
+ LOG.info("对账接口信息" + reconciliationInter + "为空");
+ continue;
+ }
+ // 获取需要对账的对账单时间
+ Date billDate = DateUtil.addDay(new Date(), -reconciliationInter.getBillDay());
+ // 获取对账渠道
+ String interfaceCode = reconciliationInter.getInterfaceCode();
+
+ /** step1:判断是否对过账 **/
+ RpAccountCheckBatch batch = new RpAccountCheckBatch();
+ Boolean checked = validateBiz.isChecked(interfaceCode, billDate);
+ if (checked) {
+ LOG.info("账单日[" + sdf.format(billDate) + "],支付方式[" + interfaceCode + "],已经对过账,不能再次发起自动对账。");
+ continue;
+ }
+ // 创建对账批次
+ batch.setCreater("reconciliationSystem");
+ batch.setCreateTime(new Date());
+ batch.setBillDate(billDate);
+ batch.setBatchNo(buildNoService.buildReconciliationNo());
+ batch.setBankType(interfaceCode);
+
+ /** step2:对账文件下载 **/
+ File file = null;
+ try {
+ LOG.info("ReconciliationFileDownBiz,对账文件下载开始");
+ file = fileDownBiz.downReconciliationFile(interfaceCode, billDate);
+ if (file == null) {
+ continue;
+ }
+ LOG.info("对账文件下载结束");
+ } catch (Exception e) {
+ LOG.error("对账文件下载异常:", e);
+ batch.setStatus(BatchStatusEnum.FAIL.name());
+ batch.setRemark("对账文件下载异常");
+ batchService.saveData(batch);
+ continue;
+ }
+
+ /** step3:解析对账文件 **/
+ List bankList = null;
+ try {
+ LOG.info("=ReconciliationFileParserBiz=>对账文件解析开始>>>");
+
+ // 解析文件
+ bankList = parserBiz.parser(batch, file, billDate, interfaceCode);
+ // 如果下载文件异常,退出
+ if (BatchStatusEnum.ERROR.name().equals(batch.getStatus())) {
+ continue;
+ }
+ LOG.info("对账文件解析结束");
+ } catch (Exception e) {
+ LOG.error("对账文件解析异常:", e);
+ batch.setStatus(BatchStatusEnum.FAIL.name());
+ batch.setRemark("对账文件解析异常");
+ batchService.saveData(batch);
+ continue;
+ }
+
+ /** step4:对账流程 **/
+ try {
+ checkBiz.check(bankList, interfaceCode, batch);
+ } catch (Exception e) {
+ LOG.error("对账异常:", e);
+ batch.setStatus(BatchStatusEnum.FAIL.name());
+ batch.setRemark("对账异常");
+ batchService.saveData(batch);
+ continue;
+ }
+
+ }
+
+ /** step5:清理缓冲池 **/
+ // 如果缓冲池中有三天前的数据就清理掉并记录差错
+ validateBiz.validateScratchPool();
+ } catch (Exception e) {
+ LOG.error("roncoo-app-reconciliation error:", e);
+ } finally {
+ try {
+ AppReconciliationApplication.context.close();
+ } catch (Exception e) {
+ LOG.error(e);
+ }
+ }
+ }
}
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationCheckBiz.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationCheckBiz.java
index 3b27557ae18f3069aeffddb7af911480d5a1ff8c..faa9a5650f7f839da1fa7af1e134b936e8bad411 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationCheckBiz.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationCheckBiz.java
@@ -15,15 +15,6 @@
*/
package com.roncoo.pay.app.reconciliation.biz;
-import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
import com.roncoo.pay.reconciliation.entity.RpAccountCheckMistake;
import com.roncoo.pay.reconciliation.entity.RpAccountCheckMistakeScratchPool;
@@ -34,6 +25,14 @@ import com.roncoo.pay.reconciliation.service.RpAccountCheckTransactionService;
import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
import com.roncoo.pay.trade.entity.RpTradePaymentRecord;
import com.roncoo.pay.trade.enums.TradeStatusEnum;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
/**
* 对账的核心业务biz.
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationDataGetBiz.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationDataGetBiz.java
index 7d1600e3f3b60bfc22e5fd630da7fc69edd08a3c..b6045a35cfb847c6c0fc90872bd72421d48b69de 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationDataGetBiz.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationDataGetBiz.java
@@ -15,21 +15,16 @@
*/
package com.roncoo.pay.app.reconciliation.biz;
-import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
+import com.roncoo.pay.trade.entity.RpTradePaymentRecord;
+import com.roncoo.pay.trade.enums.TradeStatusEnum;
+import com.roncoo.pay.trade.service.RpTradePaymentQueryService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import com.roncoo.pay.trade.entity.RpTradePaymentRecord;
-import com.roncoo.pay.trade.enums.TradeStatusEnum;
-import com.roncoo.pay.trade.service.RpTradePaymentQueryService;
+import java.text.SimpleDateFormat;
+import java.util.*;
/**
* 平台数据获取biz业务类.
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileDownBiz.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileDownBiz.java
index 6153725518cc350e3e4ce5d42be771781ebef476..d03c53c8be4feb2242f2f592ee2121b57a18dc1b 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileDownBiz.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileDownBiz.java
@@ -15,16 +15,15 @@
*/
package com.roncoo.pay.app.reconciliation.biz;
-import java.io.File;
-import java.util.Date;
-
+import com.roncoo.pay.common.core.utils.StringUtil;
+import com.roncoo.pay.reconciliation.fileDown.service.ReconciliationFactory;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import com.roncoo.pay.common.core.utils.StringUtil;
-import com.roncoo.pay.reconciliation.fileDown.service.ReconciliationFactory;
+import java.io.File;
+import java.util.Date;
/**
* 对账文件下载业务逻辑.
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileParserBiz.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileParserBiz.java
index 5ae1a7670b748a2479f1d1dbbf4dc0faee86cfa9..e467e0c71f21a6caa12044ee26f3fd3d475011e4 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileParserBiz.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationFileParserBiz.java
@@ -15,11 +15,9 @@
*/
package com.roncoo.pay.app.reconciliation.biz;
-import java.io.File;
-import java.io.IOException;
-import java.util.Date;
-import java.util.List;
-
+import com.roncoo.pay.app.reconciliation.parser.ParserInterface;
+import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
+import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.BeanFactory;
@@ -27,9 +25,10 @@ import org.springframework.beans.factory.BeanFactoryAware;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
import org.springframework.stereotype.Component;
-import com.roncoo.pay.app.reconciliation.parser.ParserInterface;
-import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
-import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
+import java.io.File;
+import java.io.IOException;
+import java.util.Date;
+import java.util.List;
/**
* 对账文件解析业务逻辑.
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationValidateBiz.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationValidateBiz.java
index 6279e17e25a78e11b2a7415103345c28faf6f838..f5ef1913faebfeef21be796cb2d1c30fa0666e5a 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationValidateBiz.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/biz/ReconciliationValidateBiz.java
@@ -15,18 +15,6 @@
*/
package com.roncoo.pay.app.reconciliation.biz;
-import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
import com.roncoo.pay.app.reconciliation.utils.DateUtil;
import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
import com.roncoo.pay.reconciliation.entity.RpAccountCheckMistake;
@@ -37,6 +25,13 @@ import com.roncoo.pay.reconciliation.enums.ReconciliationMistakeTypeEnum;
import com.roncoo.pay.reconciliation.service.RpAccountCheckBatchService;
import com.roncoo.pay.reconciliation.service.RpAccountCheckMistakeScratchPoolService;
import com.roncoo.pay.reconciliation.service.RpAccountCheckTransactionService;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.util.*;
/**
* 对账验证biz,(检查是否已经对过账).
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ALIPAYParser.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ALIPAYParser.java
index 57b5cee717b9b61c732638c970268402a79f1008..58bc1be13b36bf007558281a44d69b20c2ac41b1 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ALIPAYParser.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ALIPAYParser.java
@@ -15,6 +15,19 @@
*/
package com.roncoo.pay.app.reconciliation.parser;
+import com.roncoo.pay.app.reconciliation.vo.AlipayAccountLogVO;
+import com.roncoo.pay.common.core.enums.PayWayEnum;
+import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
+import com.roncoo.pay.reconciliation.enums.BatchStatusEnum;
+import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.dom4j.Document;
+import org.dom4j.DocumentException;
+import org.dom4j.Element;
+import org.dom4j.io.SAXReader;
+import org.springframework.stereotype.Component;
+
import java.io.File;
import java.io.IOException;
import java.math.BigDecimal;
@@ -25,20 +38,6 @@ import java.util.Date;
import java.util.Iterator;
import java.util.List;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.dom4j.Document;
-import org.dom4j.DocumentException;
-import org.dom4j.Element;
-import org.dom4j.io.SAXReader;
-import org.springframework.stereotype.Component;
-
-import com.roncoo.pay.app.reconciliation.vo.AlipayAccountLogVO;
-import com.roncoo.pay.common.core.enums.PayWayEnum;
-import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
-import com.roncoo.pay.reconciliation.enums.BatchStatusEnum;
-import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
-
/**
* 支付宝对账单解析器 .
*
@@ -74,7 +73,7 @@ public class ALIPAYParser implements ParserInterface {
try {
document = reader.read(file);
// 使用dom4j的Xpath找到AccountQueryAccountLogVO节点
- List projects = document.selectNodes("alipay/response/account_page_query_result/account_log_list/AccountQueryAccountLogVO");
+ List projects = document.getRootElement().element("response").element("account_page_query_result").element("account_log_list").elements();;
Iterator it = projects.iterator();
// 业务类型为在线支付的账户历史
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ParserInterface.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ParserInterface.java
index 5fdc6dbab6aa0e5481a62027c38592d00ff63c36..8db91253045435b671ee4415fb02a4e2359c015b 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ParserInterface.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/ParserInterface.java
@@ -15,14 +15,14 @@
*/
package com.roncoo.pay.app.reconciliation.parser;
+import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
+import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
+
import java.io.File;
import java.io.IOException;
import java.util.Date;
import java.util.List;
-import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
-import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
-
/**
* 定义一个解析的接口,实现着必须override接口中的parser方法.
*
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/WEIXINParser.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/WEIXINParser.java
index 26e174e272b33e167648dde6f81cef1d3b097d55..c4dc94319015f032d19581f0113e444a7116370c 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/WEIXINParser.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/parser/WEIXINParser.java
@@ -15,32 +15,27 @@
*/
package com.roncoo.pay.app.reconciliation.parser;
-import java.io.File;
-import java.io.IOException;
-import java.math.BigDecimal;
-import java.text.ParseException;
-import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
+import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
+import com.roncoo.pay.reconciliation.enums.BatchStatusEnum;
+import com.roncoo.pay.reconciliation.service.RpAccountCheckBatchService;
+import com.roncoo.pay.reconciliation.utils.XmlUtils;
+import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.jdom2.JDOMException;
+import org.dom4j.DocumentException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import com.roncoo.pay.reconciliation.entity.RpAccountCheckBatch;
-import com.roncoo.pay.reconciliation.enums.BatchStatusEnum;
-import com.roncoo.pay.reconciliation.service.RpAccountCheckBatchService;
-import com.roncoo.pay.reconciliation.utils.XmlUtils;
-import com.roncoo.pay.reconciliation.vo.ReconciliationEntityVo;
+import java.io.File;
+import java.io.IOException;
+import java.math.BigDecimal;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
/**
* 微信对账单解析器 .
@@ -267,7 +262,7 @@ public class WEIXINParser implements ParserInterface {
rpAccountCheckBatchService.saveData(batch);
}
}
- } catch (JDOMException e) {
+ } catch (DocumentException e) {
LOG.error("解析微信账单(判断返回是否正确)失败", e);
} catch (IOException e) {
LOG.error("解析微信账单(判断返回是否正确)失败", e);
diff --git a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/vo/ReconciliationInterface.java b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/vo/ReconciliationInterface.java
index fbe85bb55acdd876a448c149dfeb1a1f953a192b..a9acfc52bf57d6066af4335af4c6b78c9b475db8 100644
--- a/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/vo/ReconciliationInterface.java
+++ b/roncoo-pay-app-reconciliation/src/main/java/com/roncoo/pay/app/reconciliation/vo/ReconciliationInterface.java
@@ -15,12 +15,12 @@
*/
package com.roncoo.pay.app.reconciliation.vo;
-import java.util.ArrayList;
-import java.util.List;
-
import com.roncoo.pay.common.core.enums.PayWayEnum;
import com.roncoo.pay.common.core.enums.PublicStatusEnum;
+import java.util.ArrayList;
+import java.util.List;
+
/**
* 对账接口实体
*
diff --git a/roncoo-pay-app-reconciliation/src/main/resources/application.yml b/roncoo-pay-app-reconciliation/src/main/resources/application.yml
new file mode 100644
index 0000000000000000000000000000000000000000..3297cabd8bcdcd6cf1c19e5d20c2b5dbc256670c
--- /dev/null
+++ b/roncoo-pay-app-reconciliation/src/main/resources/application.yml
@@ -0,0 +1,13 @@
+server:
+ port: 8097
+ servlet:
+ session:
+ timeout: 30
+spring:
+ application:
+ name: roncoo-pay-app-reconciliation
+logging:
+ config: classpath:logback.xml
+mybatis:
+ mapper-locations: classpath*:mybatis/mapper/**/*.xml
+
diff --git a/roncoo-pay-app-reconciliation/src/main/resources/log4j.properties b/roncoo-pay-app-reconciliation/src/main/resources/log4j.properties
deleted file mode 100644
index 1398082d38eb22c49a8d52402d7c8ab2120f9844..0000000000000000000000000000000000000000
--- a/roncoo-pay-app-reconciliation/src/main/resources/log4j.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-#\u5F00\u53D1\u65E5\u5FD7\u5C06\u5728\u672C\u5730\u8F93\u51FA\uFF0C\u5E76\u8F93\u51FASQL
-
-log4j.rootLogger=${log4j.leve},A1,DRF
-log4j.appender.A1=org.apache.log4j.ConsoleAppender
-log4j.appender.A1.layout=org.apache.log4j.PatternLayout
-# log4j.appender.A1.layout.ConversionPattern=%d %5p [%t] (%F:%L) - %m%n
-log4j.appender.A1.layout.ConversionPattern=%d %5p [%F:%L] : %m%n
-
-log4j.appender.DRF=org.apache.log4j.DailyRollingFileAppender
-log4j.appender.DRF.Threshold=${log4j.leve}
-log4j.appender.DRF.DatePattern='.'yyyy-MM-dd
-log4j.appender.DRF.File=logs/gw-app-reconcliation.log
-log4j.appender.DRF.Append=true
-log4j.appender.DRF.layout=org.apache.log4j.PatternLayout
-log4j.appender.DRF.layout.ConversionPattern=[%-5p][%d{yyyyMMdd HH:mm:ss,SSS}][%C{1}:%L] %m%n
-
-
-###\u8F93\u51FASQL
-log4j.logger.com.ibatis=${log4j.ale}
-log4j.logger.com.ibatis.common.jdbc.SimpleDataSource=${log4j.ale}
-log4j.logger.com.ibatis.common.jdbc.ScriptRunner=${log4j.ale}
-log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate=${log4j.ale}
-log4j.logger.java.sql.Connection=${log4j.ale}
-log4j.logger.java.sql.Statement=${log4j.ale}
-log4j.logger.java.sql.PreparedStatement=${log4j.ale}
-log4j.logger.com.alibaba.dubbo=${log4j.ale}
-
-
diff --git a/roncoo-pay-app-reconciliation/src/main/resources/logback.xml b/roncoo-pay-app-reconciliation/src/main/resources/logback.xml
new file mode 100644
index 0000000000000000000000000000000000000000..2002a79b1454be204d80db4c3711b8d7dd4220e0
--- /dev/null
+++ b/roncoo-pay-app-reconciliation/src/main/resources/logback.xml
@@ -0,0 +1,39 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${PATTERN}
+
+
+
+
+
+ ${FILE_PATH}/${APPLICATION_NAME}/${APPLICATION_NAME}.log
+
+ ${FILE_PATH}/${APPLICATION_NAME}/${APPLICATION_NAME}.%d{yyyy-MM-dd}.log
+
+ 100
+
+
+ ${PATTERN}
+
+
+
+
+
+
+
+
+
+
+
diff --git a/roncoo-pay-app-reconciliation/src/main/resources/spring-context.xml b/roncoo-pay-app-reconciliation/src/main/resources/spring-context.xml
deleted file mode 100644
index c9a8ebe256fd180a492a17e93f55353c90cd71bd..0000000000000000000000000000000000000000
--- a/roncoo-pay-app-reconciliation/src/main/resources/spring-context.xml
+++ /dev/null
@@ -1,20 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/roncoo-pay-app-reconciliation/src/main/resources/spring-task.xml b/roncoo-pay-app-reconciliation/src/main/resources/spring-task.xml
deleted file mode 100644
index a3a778de47b9d3f0471fdc76cdd7bacce490dd50..0000000000000000000000000000000000000000
--- a/roncoo-pay-app-reconciliation/src/main/resources/spring-task.xml
+++ /dev/null
@@ -1,18 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/roncoo-pay-app-settlement/.classpath b/roncoo-pay-app-settlement/.classpath
deleted file mode 100644
index 698778fef3378d2b00e5d4e260491f33b776287d..0000000000000000000000000000000000000000
--- a/roncoo-pay-app-settlement/.classpath
+++ /dev/null
@@ -1,31 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/roncoo-pay-app-settlement/.gitignore b/roncoo-pay-app-settlement/.gitignore
new file mode 100644
index 0000000000000000000000000000000000000000..c456c4a3ad64e41cb40d64cf0ed1cfa63e4ebac4
--- /dev/null
+++ b/roncoo-pay-app-settlement/.gitignore
@@ -0,0 +1,25 @@
+/target/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+/build/
diff --git a/roncoo-pay-app-settlement/.project b/roncoo-pay-app-settlement/.project
deleted file mode 100644
index daa25e6e85abec0140b82c7f4339eb1eb5742b70..0000000000000000000000000000000000000000
--- a/roncoo-pay-app-settlement/.project
+++ /dev/null
@@ -1,23 +0,0 @@
-
-
- roncoo-app-settlement
-
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.m2e.core.maven2Builder
-
-
-
-
-
- org.eclipse.jdt.core.javanature
- org.eclipse.m2e.core.maven2Nature
-
-
diff --git a/roncoo-pay-app-settlement/pom.xml b/roncoo-pay-app-settlement/pom.xml
index df6999bd1d1240b281a5603c591e452d563ab9c6..e942046174e0ee585d8d187a8e6bdd0ecc7ff8c5 100644
--- a/roncoo-pay-app-settlement/pom.xml
+++ b/roncoo-pay-app-settlement/pom.xml
@@ -1,137 +1,49 @@
- 4.0.0
-
- com.roncoo.pay.common
- roncoo-pay
- 0.0.4-SNAPSHOT
-
- com.roncoo.pay.app
- roncoo-pay-app-settlement
- roncoo-pay-app-settlement
- http://maven.apache.org
-
- UTF-8
-
-
-
-
- com.roncoo.pay.common
- roncoo-pay-common-core
- ${project.parent.version}
-
-
-
-
- com.roncoo.pay.service
- roncoo-pay-service
- ${project.parent.version}
-
-
-
-
- junit
- junit
-
- test
-
-
-
-
-
-
-
-
-
- roncoo-pay-app-settlement
-
-
-
-
-
- org.apache.maven.plugins
- maven-jar-plugin
-
- target/classes/
-
-
- com.roncoo.pay.app.settlement.SettTask
-
- false
- true
- lib/
-
-
- .
-
-
-
-
-
-
- org.apache.maven.plugins
- maven-dependency-plugin
-
-
- copy-dependencies
- package
-
- copy-dependencies
-
-
- jar
- jar
-
- ${project.build.directory}/lib
-
-
-
-
-
-
-
- org.apache.maven.plugins
- maven-deploy-plugin
- 2.7
-
- false
-
-
-
- org.apache.maven.plugins
- maven-eclipse-plugin
- 2.8
-
-
- org.apache.maven.plugins
- maven-compiler-plugin
- 3.2
-
- true
- true
- true
- -nowarn
-
- 1.7
- UTF-8
-
-
-
-
- org.apache.maven.plugins
- maven-source-plugin
- 2.1.2
-
-
- attach-sources
-
- jar
-
-
-
-
-
-
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+ 4.0.0
+
+ com.roncoo.pay
+ roncoo-pay
+ 2.1.2-SNAPSHOT
+
+
+ com.roncoo.pay
+ roncoo-pay-app-settlement
+
+ roncoo-pay-app-settlement
+ 结算定时处理app,发起定时跑批处理,统计结算数据
+
+
+ UTF-8
+
+
+
+
+ com.roncoo.pay.service
+ roncoo-pay-service
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ org.springframework.boot
+ spring-boot-devtools
+ runtime
+
+
+
+
+ ${project.name}
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
diff --git a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/AppSettlementApplication.java b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/AppSettlementApplication.java
new file mode 100644
index 0000000000000000000000000000000000000000..809a7df8cc8eb6baea65c016ab0a534a7946c057
--- /dev/null
+++ b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/AppSettlementApplication.java
@@ -0,0 +1,19 @@
+package com.roncoo.pay;
+
+import org.springframework.boot.WebApplicationType;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.context.ConfigurableApplicationContext;
+
+@SpringBootApplication
+public class AppSettlementApplication {
+
+ public static ConfigurableApplicationContext context;
+
+ public static void main(String[] args) {
+// SpringApplication.run(AppSettlementApplication.class, args);
+ context = new SpringApplicationBuilder().sources(AppSettlementApplication.class).web(WebApplicationType.NONE).run(args);
+ }
+
+}
+
diff --git a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/SettTask.java b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/SettTask.java
index aec0d07a2d9f4fda713efb7d570befe85cb25cb7..3de8aa88473989976a682fdd7b0044b9755ee450 100644
--- a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/SettTask.java
+++ b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/SettTask.java
@@ -15,38 +15,35 @@
*/
package com.roncoo.pay.app.settlement;
+import com.roncoo.pay.AppSettlementApplication;
+import com.roncoo.pay.app.settlement.scheduled.SettScheduled;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
-import com.roncoo.pay.app.settlement.scheduled.SettScheduled;
+import javax.annotation.PostConstruct;
/**
* 结算定时任务.(分商户统计账户历史进行汇总)
* 龙果学院:www.roncoo.com
* @author zenghao
*/
+@Component
public class SettTask {
private static final Log LOG = LogFactory.getLog(SettTask.class);
private static final long MILLIS = 1000L;
- private SettTask(){
-
- }
-
+ @Autowired
+ private SettScheduled settScheduled;
- public static void main(String[] args) {
+ @PostConstruct
+ public void runTask() {
try {
- @SuppressWarnings("resource")
- final ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "spring-context.xml" });
- context.start();
- LOG.debug("结算定时任务开始执行");
- SettScheduled settScheduled = (SettScheduled) context.getBean("settScheduled");
-
LOG.debug("执行(每日待结算数据汇总)任务开始");
settScheduled.launchDailySettCollect();
LOG.debug("执行(每日待结算数据汇总)任务结束");
@@ -57,11 +54,16 @@ public class SettTask {
settScheduled.launchAutoSett();
LOG.debug("执行(定期自动结算)任务结束");
- context.stop();
+
} catch (Exception e) {
LOG.error("SettTask execute error:", e);
} finally {
- System.exit(0);
+ try {
+ AppSettlementApplication.context.close();
+ } catch (Exception e) {
+ LOG.error(e);
+ }
+// System.exit(0);
LOG.debug("SettTask Complete");
}
}
diff --git a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/DailySettCollectBiz.java b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/DailySettCollectBiz.java
index 3f1b1dc8fd7b687e301e8be4ae66761576306123..c07add70d22afda4edeaaa574896b92053ec822c 100644
--- a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/DailySettCollectBiz.java
+++ b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/DailySettCollectBiz.java
@@ -15,17 +15,16 @@
*/
package com.roncoo.pay.app.settlement.biz;
-import java.util.Date;
-
+import com.roncoo.pay.account.entity.RpAccount;
+import com.roncoo.pay.account.service.RpSettHandleService;
+import com.roncoo.pay.user.entity.RpUserPayConfig;
+import com.roncoo.pay.user.service.RpUserPayConfigService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import com.roncoo.pay.account.entity.RpAccount;
-import com.roncoo.pay.account.service.RpSettHandleService;
-import com.roncoo.pay.user.entity.RpUserPayConfig;
-import com.roncoo.pay.user.service.RpUserPayConfigService;
+import java.util.Date;
/**
* 每日待结算数据汇总.
diff --git a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/SettBiz.java b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/SettBiz.java
index 664319af99727b6e17167116c9e91098e60a7cee..12d017e42c72581e7627ebc4978ec132c3607d07 100644
--- a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/SettBiz.java
+++ b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/biz/SettBiz.java
@@ -15,19 +15,18 @@
*/
package com.roncoo.pay.app.settlement.biz;
-import java.util.Date;
-import java.util.List;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
import com.roncoo.pay.account.entity.RpAccount;
import com.roncoo.pay.account.service.RpSettHandleService;
import com.roncoo.pay.common.core.enums.PublicEnum;
import com.roncoo.pay.user.entity.RpUserPayConfig;
import com.roncoo.pay.user.service.RpUserPayConfigService;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
/**
* 结算业务逻辑类.
diff --git a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/scheduled/impl/SettScheduledImpl.java b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/scheduled/impl/SettScheduledImpl.java
index 28b3338acc4469eb9028c4e148330f7e3acaa0bd..a0d139bf883b0f7f2d9a405eb71b4da2d178fec5 100644
--- a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/scheduled/impl/SettScheduledImpl.java
+++ b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/scheduled/impl/SettScheduledImpl.java
@@ -15,16 +15,15 @@
*/
package com.roncoo.pay.app.settlement.scheduled.impl;
-import java.util.Date;
-import java.util.List;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
import com.roncoo.pay.account.entity.RpAccount;
import com.roncoo.pay.account.service.RpAccountQueryService;
import com.roncoo.pay.app.settlement.biz.SettBiz;
import com.roncoo.pay.app.settlement.scheduled.SettScheduled;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
/**
diff --git a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/utils/SettThreadPoolExecutor.java b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/utils/SettThreadPoolExecutor.java
index a43577707ada721cc0fd167707dfbe5fd587209f..30360cc034d9a505b4a3a98059f147f979e35311 100644
--- a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/utils/SettThreadPoolExecutor.java
+++ b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/app/settlement/utils/SettThreadPoolExecutor.java
@@ -15,14 +15,14 @@
*/
package com.roncoo.pay.app.settlement.utils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
/**
* 线程池工具类
* 龙果学院:www.roncoo.com
diff --git a/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/config/ThreadPoolTaskConfig.java b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/config/ThreadPoolTaskConfig.java
new file mode 100644
index 0000000000000000000000000000000000000000..dc9fdae50ecc08a40043a43ea3f74cba6d6f740e
--- /dev/null
+++ b/roncoo-pay-app-settlement/src/main/java/com/roncoo/pay/config/ThreadPoolTaskConfig.java
@@ -0,0 +1,34 @@
+package com.roncoo.pay.config;
+
+import com.roncoo.pay.app.settlement.utils.SettThreadPoolExecutor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+@Configuration
+public class ThreadPoolTaskConfig {
+
+ @Bean(name = "settThreadPoolExecutor", initMethod = "init", destroyMethod = "destroy")
+ public SettThreadPoolExecutor settThreadPoolExecutor() {
+ SettThreadPoolExecutor settThreadPoolExecutor = new SettThreadPoolExecutor();
+ //最小线程数
+ settThreadPoolExecutor.setCorePoolSize(5);
+ //最大线程数
+ settThreadPoolExecutor.setMaxPoolSize(10);
+ //线程池缓冲队列大小
+ settThreadPoolExecutor.setWorkQueueSize(256);
+ //许线程闲置时间,单位:秒
+ settThreadPoolExecutor.setKeepAliveTime(3);
+ return settThreadPoolExecutor;
+ }
+
+ @Bean(name = "threadPoolTaskExecutor")
+ public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
+ ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
+ threadPoolTaskExecutor.setCorePoolSize(20);
+ threadPoolTaskExecutor.setKeepAliveSeconds(30000);
+ threadPoolTaskExecutor.setMaxPoolSize(200);
+ threadPoolTaskExecutor.setQueueCapacity(1000);
+ return threadPoolTaskExecutor;
+ }
+}
diff --git a/roncoo-pay-app-settlement/src/main/resources/application.yml b/roncoo-pay-app-settlement/src/main/resources/application.yml
new file mode 100644
index 0000000000000000000000000000000000000000..06a3aeef0edc553e103fabc351e3c7785f6aa83a
--- /dev/null
+++ b/roncoo-pay-app-settlement/src/main/resources/application.yml
@@ -0,0 +1,14 @@
+server:
+ port: 8098
+ servlet:
+ session:
+ timeout: 30
+spring:
+ application:
+ name: roncoo-pay-app-settlement
+logging:
+ config: classpath:logback.xml
+mybatis:
+ mapper-locations: classpath*:mybatis/mapper/**/*.xml
+
+
diff --git a/roncoo-pay-app-settlement/src/main/resources/log4j.properties b/roncoo-pay-app-settlement/src/main/resources/log4j.properties
deleted file mode 100644
index 1398082d38eb22c49a8d52402d7c8ab2120f9844..0000000000000000000000000000000000000000
--- a/roncoo-pay-app-settlement/src/main/resources/log4j.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-#\u5F00\u53D1\u65E5\u5FD7\u5C06\u5728\u672C\u5730\u8F93\u51FA\uFF0C\u5E76\u8F93\u51FASQL
-
-log4j.rootLogger=${log4j.leve},A1,DRF
-log4j.appender.A1=org.apache.log4j.ConsoleAppender
-log4j.appender.A1.layout=org.apache.log4j.PatternLayout
-# log4j.appender.A1.layout.ConversionPattern=%d %5p [%t] (%F:%L) - %m%n
-log4j.appender.A1.layout.ConversionPattern=%d %5p [%F:%L] : %m%n
-
-log4j.appender.DRF=org.apache.log4j.DailyRollingFileAppender
-log4j.appender.DRF.Threshold=${log4j.leve}
-log4j.appender.DRF.DatePattern='.'yyyy-MM-dd
-log4j.appender.DRF.File=logs/gw-app-reconcliation.log
-log4j.appender.DRF.Append=true
-log4j.appender.DRF.layout=org.apache.log4j.PatternLayout
-log4j.appender.DRF.layout.ConversionPattern=[%-5p][%d{yyyyMMdd HH:mm:ss,SSS}][%C{1}:%L] %m%n
-
-
-###\u8F93\u51FASQL
-log4j.logger.com.ibatis=${log4j.ale}
-log4j.logger.com.ibatis.common.jdbc.SimpleDataSource=${log4j.ale}
-log4j.logger.com.ibatis.common.jdbc.ScriptRunner=${log4j.ale}
-log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate=${log4j.ale}
-log4j.logger.java.sql.Connection=${log4j.ale}
-log4j.logger.java.sql.Statement=${log4j.ale}
-log4j.logger.java.sql.PreparedStatement=${log4j.ale}
-log4j.logger.com.alibaba.dubbo=${log4j.ale}
-
-
diff --git a/roncoo-pay-app-settlement/src/main/resources/logback.xml b/roncoo-pay-app-settlement/src/main/resources/logback.xml
new file mode 100644
index 0000000000000000000000000000000000000000..ea4fd7f74d3b693cd5551ff5933a81c9aa225968
--- /dev/null
+++ b/roncoo-pay-app-settlement/src/main/resources/logback.xml
@@ -0,0 +1,39 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ${PATTERN}
+
+
+
+
+
+ ${FILE_PATH}/${APPLICATION_NAME}/${APPLICATION_NAME}.log
+
+ ${FILE_PATH}/${APPLICATION_NAME}/${APPLICATION_NAME}.%d{yyyy-MM-dd}.log
+
+ 100
+
+
+ ${PATTERN}
+
+
+
+
+
+
+
+
+
+
+
diff --git a/roncoo-pay-app-settlement/src/main/resources/spring-context.xml b/roncoo-pay-app-settlement/src/main/resources/spring-context.xml
deleted file mode 100644
index ad491ed6c1eb5754238fccb5ee048724437b8058..0000000000000000000000000000000000000000
--- a/roncoo-pay-app-settlement/src/main/resources/spring-context.xml
+++ /dev/null
@@ -1,45 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/roncoo-pay-common-core/.classpath b/roncoo-pay-common-core/.classpath
deleted file mode 100644
index a67314913efb2ec1ed7b610ce7c35f6ef3018d1f..0000000000000000000000000000000000000000
--- a/roncoo-pay-common-core/.classpath
+++ /dev/null
@@ -1,27 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/roncoo-pay-common-core/.gitignore b/roncoo-pay-common-core/.gitignore
new file mode 100644
index 0000000000000000000000000000000000000000..c456c4a3ad64e41cb40d64cf0ed1cfa63e4ebac4
--- /dev/null
+++ b/roncoo-pay-common-core/.gitignore
@@ -0,0 +1,25 @@
+/target/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+/build/
diff --git a/roncoo-pay-common-core/.project b/roncoo-pay-common-core/.project
deleted file mode 100644
index b936c4d14e1b1dddd6ff24d4674e8784255ee6d7..0000000000000000000000000000000000000000
--- a/roncoo-pay-common-core/.project
+++ /dev/null
@@ -1,36 +0,0 @@
-
-
- roncoo-common-core
-
-
-
-
-
- org.eclipse.wst.common.project.facet.core.builder
-
-
-
-
- org.eclipse.jdt.core.javabuilder
-
-
-
-
- org.eclipse.wst.validation.validationbuilder
-
-
-
-
- org.eclipse.m2e.core.maven2Builder
-
-
-
-
-
- org.eclipse.jem.workbench.JavaEMFNature
- org.eclipse.wst.common.modulecore.ModuleCoreNature
- org.eclipse.jdt.core.javanature
- org.eclipse.m2e.core.maven2Nature
- org.eclipse.wst.common.project.facet.core.nature
-
-
diff --git a/roncoo-pay-common-core/pom.xml b/roncoo-pay-common-core/pom.xml
index 7f2cd95767061603c4744dcd5e301a6fcc7b30d0..d1d28c9a7c6d18e9c8e5877fbc6069353b96b75b 100644
--- a/roncoo-pay-common-core/pom.xml
+++ b/roncoo-pay-common-core/pom.xml
@@ -1,254 +1,57 @@
4.0.0
+
- com.roncoo.pay.common
+ com.roncoo.pay
roncoo-pay
- 0.0.4-SNAPSHOT
+ 2.1.2-SNAPSHOT
+
+ com.roncoo.pay.common
roncoo-pay-common-core
+
roncoo-pay-common-core
- http://maven.apache.org
+ core 是支付系统核心基础包
+
+
UTF-8
-
+
+ com.google.code.gson
+ gson
+
+
+ org.apache.httpcomponents
+ httpclient
+
+
- org.springframework
- spring-core
+ org.springframework.boot
+ spring-boot-starter-web
-
- org.springframework
- spring-aop
-
-
-
- org.springframework
- spring-aspects
-
-
- org.springframework
- spring-beans
-
-
- org.springframework
- spring-context
-
-
- org.springframework
- spring-context-support
-
-
- org.springframework
- spring-expression
-
-
- org.springframework
- spring-instrument
-
-
- org.springframework
- spring-instrument-tomcat
-
-
- org.springframework
- spring-jdbc
-
-
- org.springframework
- spring-jms
-
-
- org.springframework
- spring-orm
-
-
- org.springframework
- spring-oxm
-
-
- org.springframework
- spring-test
- test
-
-
- org.springframework
- spring-tx
-
-
- org.springframework
- spring-web
-
-
- org.springframework
- spring-webmvc
-
-
- org.springframework
- spring-webmvc-portlet
-
-
-
-
-
-
- org.mybatis
- mybatis
-
-
- org.mybatis
- mybatis-spring
-
-
-
-
-
- org.slf4j
- slf4j-api
-
-
- org.slf4j
- slf4j-log4j12
-
-
- log4j
- log4j
-
-
-
-
-
-
- mysql
- mysql-connector-java
-
-
-
- commons-dbcp
- commons-dbcp
-
-
-
-
-
-
-
- javassist
- javassist
-
-
- javax.transaction
- jta
-
-
-
- cglib
- cglib
-
-
-
- jstl
- jstl
-
-
-
- com.alibaba
- druid
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+
com.alibaba
fastjson
+
commons-lang
commons-lang
-
- commons-io
- commons-io
-
-
-
-
- commons-codec
- commons-codec
-
-
-
-
- commons-configuration
- commons-configuration
-
-
-
-
- com.google.zxing
- core
-
-
-
-
- com.google.code.gson
- gson
-
-
-
-
- org.hamcrest
- hamcrest-core
-
-
-
- org.jdom
- jdom
-
-
-
- alipay
- alipay-sdk-java20151021120052
-
-
-
- alipay
- alipay-trade-sdk
-
-
-
-
-
- org.apache.activemq
- activemq-all
-
-
- org.apache.activemq
- activemq-pool
-
-
-
- javax.validation
- validation-api
-
-
-
- org.hibernate
- hibernate-validator
-
-
-
- jaxen
- jaxen
-
-
-
- commons-codec
- commons-codec
-
-
-
+
+
+ ${project.name}
+
diff --git a/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/config/MqConfig.java b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/config/MqConfig.java
new file mode 100644
index 0000000000000000000000000000000000000000..fe80926a1d45749486d494736cc9a08a6de01857
--- /dev/null
+++ b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/config/MqConfig.java
@@ -0,0 +1,39 @@
+package com.roncoo.pay.common.core.config;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+public class MqConfig {
+
+ private static final Log LOG = LogFactory.getLog(MqConfig.class);
+
+ /** 商户通知队列 **/
+ public static String MERCHANT_NOTIFY_QUEUE = "";
+
+ /** 订单通知队列 **/
+ public static String ORDER_NOTIFY_QUEUE = "";
+
+ private static Properties properties = null;
+
+ static{
+ if(null == properties){
+ properties = new Properties();
+ }
+ InputStream proFile = Thread.currentThread().getContextClassLoader().getResourceAsStream("mq_config.properties");
+ try {
+ properties.load(proFile);
+ init(properties);
+ } catch (IOException e) {
+ LOG.error("=== load and init mq exception:" + e);
+ }
+ }
+
+ private static void init(Properties properties){
+ MERCHANT_NOTIFY_QUEUE = properties.getProperty("tradeQueueName.notify");
+ ORDER_NOTIFY_QUEUE = properties.getProperty("orderQueryQueueName.query");
+ }
+}
diff --git a/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/BaseDao.java b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/BaseDao.java
index 6d69006e814b8d830d887e8e70ae35d879311409..6a0598274307c75edd01158564f8adb8d09ff4c6 100644
--- a/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/BaseDao.java
+++ b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/BaseDao.java
@@ -15,14 +15,12 @@
*/
package com.roncoo.pay.common.core.dao;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.ibatis.session.SqlSession;
-import org.mybatis.spring.SqlSessionTemplate;
-
import com.roncoo.pay.common.core.page.PageBean;
import com.roncoo.pay.common.core.page.PageParam;
+import org.mybatis.spring.SqlSessionTemplate;
+
+import java.util.List;
+import java.util.Map;
/**
* 数据访问层基础支撑接口.
@@ -172,9 +170,8 @@ public interface BaseDao {
* @return:PageBean
* @throws
*/
- public PageBean listPage(PageParam pageParam, Map paramMap);
+ PageBean listPage(PageParam pageParam, Map paramMap);
- public SqlSessionTemplate getSessionTemplate();
+ SqlSessionTemplate getSessionTemplate();
- public SqlSession getSqlSession();
}
diff --git a/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/impl/BaseDaoImpl.java b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/impl/BaseDaoImpl.java
index 2ee6ca6deefcdb1dc318c42f79eb743b83982cb4..1c3b21266030ff14d7909e917168ce91d8187d71 100644
--- a/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/impl/BaseDaoImpl.java
+++ b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/dao/impl/BaseDaoImpl.java
@@ -1,12 +1,12 @@
/*
* Copyright 2015-2102 RonCoo(http://www.roncoo.com) Group.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,29 +15,27 @@
*/
package com.roncoo.pay.common.core.dao.impl;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.ibatis.session.SqlSession;
-import org.mybatis.spring.SqlSessionTemplate;
-import org.mybatis.spring.support.SqlSessionDaoSupport;
-import org.springframework.beans.factory.annotation.Autowired;
-
import com.roncoo.pay.common.core.dao.BaseDao;
import com.roncoo.pay.common.core.entity.BaseEntity;
import com.roncoo.pay.common.core.exception.BizException;
import com.roncoo.pay.common.core.page.PageBean;
import com.roncoo.pay.common.core.page.PageParam;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.mybatis.spring.SqlSessionTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
/**
* 据访问层基础支撑类.
+ *
* @company:广州领课网络科技有限公司(龙果学院 www.roncoo.com).
*/
-public abstract class BaseDaoImpl extends SqlSessionDaoSupport implements BaseDao {
+public abstract class BaseDaoImpl implements BaseDao {
protected static final Log LOG = LogFactory.getLog(BaseDaoImpl.class);
@@ -56,7 +54,7 @@ public abstract class BaseDaoImpl extends SqlSessionDaoSup
public static final String SQL_LIST_BY = "listBy";
public static final String SQL_LIST_PAGE_COUNT = "listPageCount";
public static final String SQL_COUNT_BY_PAGE_PARAM = "countByPageParam"; // 根据当前分页参数进行统计
-
+
/**
* 注入SqlSessionTemplate实例(要求Spring中进行SqlSessionTemplate的配置).
@@ -73,10 +71,6 @@ public abstract class BaseDaoImpl extends SqlSessionDaoSup
this.sessionTemplate = sessionTemplate;
}
- public SqlSession getSqlSession() {
- return super.getSqlSession();
- }
-
/**
* 单条插入数据.
*/
@@ -161,7 +155,7 @@ public abstract class BaseDaoImpl extends SqlSessionDaoSup
/**
* 根据条件查询 getBy: selectOne
- *
+ *
* @param paramMap
* @return
*/
@@ -171,7 +165,7 @@ public abstract class BaseDaoImpl extends SqlSessionDaoSup
}
return sessionTemplate.selectOne(getStatement(SQL_LIST_BY), paramMap);
}
-
+
/**
* 根据条件查询列表数据.
*/
@@ -270,11 +264,11 @@ public abstract class BaseDaoImpl extends SqlSessionDaoSup
/**
* 函数功能说明 : 获取Mapper命名空间. 修改者名字: Along 修改日期: 2016-1-8 修改内容:
- *
+ *
+ * @throws
* @参数:@param sqlId
* @参数:@return
* @return:String
- * @throws
*/
public String getStatement(String sqlId) {
String name = this.getClass().getName();
diff --git a/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/entity/ApiCommonResultVo.java b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/entity/ApiCommonResultVo.java
new file mode 100644
index 0000000000000000000000000000000000000000..39d0ce53338ef7732fb49fd927c8a7734385b861
--- /dev/null
+++ b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/entity/ApiCommonResultVo.java
@@ -0,0 +1,85 @@
+/*
+ * Copyright 2015-2102 RonCoo(http://www.roncoo.com) Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.roncoo.pay.common.core.entity;
+
+import com.alibaba.fastjson.JSONObject;
+
+/**
+ * api请求正常返回结果,该实体作为API请求时,按照规范返回的实体. code 为返回码 msg 为返回描述 data 为返回的具体结果 Created
+ * 龙果学院:www.roncoo.com
+ * @author zenghao
+ */
+public class ApiCommonResultVo {
+
+ public ApiCommonResultVo(int code, String msg, Object data) {
+ this.code = code;
+ this.msg = msg;
+ if (data != null) {
+ this.data = data;
+ }
+ }
+
+ public ApiCommonResultVo(Object data) {
+ this.code = 0;
+ this.msg = "";
+ if (data != null) {
+ this.data = data;
+ }
+ }
+
+ /**
+ * 返回码
+ */
+ private int code;
+
+ /**
+ * 返回描述
+ */
+ private String msg = "";
+
+ /**
+ * 返回数据
+ */
+ private Object data = new Object();
+
+ public void setCode(int code) {
+ this.code = code;
+ }
+
+ public void setMsg(String msg) {
+ this.msg = msg;
+ }
+
+ public void setData(Object data) {
+ this.data = data;
+ }
+
+ public int getCode() {
+ return code;
+ }
+
+ public String getMsg() {
+ return msg;
+ }
+
+ public Object getData() {
+ return data;
+ }
+
+ public static void main(String[] args) {
+ System.out.println(JSONObject.toJSONString(new ApiCommonResultVo(-1, "", null)));
+ }
+}
diff --git a/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/entity/ApiPageListResultVo.java b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/entity/ApiPageListResultVo.java
new file mode 100644
index 0000000000000000000000000000000000000000..385ce8b807ab2ae7366f3163439f593675387618
--- /dev/null
+++ b/roncoo-pay-common-core/src/main/java/com/roncoo/pay/common/core/entity/ApiPageListResultVo.java
@@ -0,0 +1,83 @@
+/*
+ * Copyright 2015-2102 RonCoo(http://www.roncoo.com) Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.roncoo.pay.common.core.entity;
+
+import com.alibaba.fastjson.JSONObject;
+
+import java.util.ArrayList;
+
+/**
+ * API请求,返回分页数据时,统一实体类,将返回的数据统一封装到该实体中,返回给客户端
+ * 龙果学院:www.roncoo.com
+ * @author zenghao
+ */
+public class ApiPageListResultVo {
+
+ /**
+ * 返回码
+ */
+ private int code;
+
+ /**
+ * 返回描述
+ */
+ private String msg = "";
+
+ /**
+ * 返回分页数据,默认为0页0条
+ */
+ private PageListVO data = new PageListVO(0,0,0,new ArrayList());
+
+ public void setCode(int code) {
+ this.code = code;
+ }
+
+ public void setMsg(String msg) {
+ this.msg = msg;
+ }
+
+ public void setData(PageListVO data) {
+ this.data = data;
+ }
+
+ public int getCode() {
+ return code;
+ }
+
+ public String getMsg() {
+ return msg;
+ }
+
+ public PageListVO getData() {
+ return data;
+ }
+
+
+
+ public static void main(String [] args ){
+
+ ApiPageListResultVo apiPageListResultVo = new ApiPageListResultVo();
+ apiPageListResultVo.setCode(-1);
+ apiPageListResultVo.setMsg("测试数据");
+
+ PageListVO pageListVO = new PageListVO(0,2,33,new ArrayList