diff --git a/WebContent/WEB-INF/etc/jbo/jbo_customer.xml b/WebContent/WEB-INF/etc/jbo/jbo_customer.xml
index 6ef06ae79..04c7712f4 100644
--- a/WebContent/WEB-INF/etc/jbo/jbo_customer.xml
+++ b/WebContent/WEB-INF/etc/jbo/jbo_customer.xml
@@ -2288,5 +2288,27 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/src_app_fresh/apx/com/amarsoft/als/base/awe/util/AweDoCommUtil.java b/src_app_fresh/apx/com/amarsoft/als/base/awe/util/AweDoCommUtil.java
index c6cdc98bb..3c35a4007 100644
--- a/src_app_fresh/apx/com/amarsoft/als/base/awe/util/AweDoCommUtil.java
+++ b/src_app_fresh/apx/com/amarsoft/als/base/awe/util/AweDoCommUtil.java
@@ -8,26 +8,101 @@ import com.amarsoft.are.util.SpecialTools;
public class AweDoCommUtil {
public static void main(String[] args) throws Exception {
- System.out.println(SpecialTools.real2Amarsoft("123 "));
- String str = "((EXISTS( SELECT * FROM jbo.com .tenwa.lease.comm.LB_GUARANTEE_UNIT lgu "
- + "WHERE lgu.CONTRACT_ID=O.CONTRACT_ID AND lgu.ASSUROR=:customerid) "
- + "OR EXISTS( SELECT * FROM jbo.com .tenwa.lease.comm.LB_UNION_LESSEE lul "
- + "WHERE lul.CONTRACT_ID=O.CONTRACT_ID AND lul.CUSTOMER_ID=:customerid)))";
-
+ String str = "id=:id1 and (ida>=:id2 or idb<=:id3) and idc >: id4 (idd <: id5 and ide <>:id6)";
+ System.out.println(str);
Map map = new HashMap();
- map.put("ASSUROR", "123");
- map.put("ASSUROR".toLowerCase(), "123");
- map.put("CUSTOMER_ID", "123");
- map.put("CUSTOMER_ID".toLowerCase(), "123");
- System.out.println(whereHandle(str, map));
+ map.put("id", "1");
+ map.put("ida", "2");
+ map.put("idb", "3");
+ map.put("idc", "4");
+ map.put("idd", "5");
+ map.put("ide", "6");
+
+// map.put("ASSUROR".toLowerCase(), "123");
+// map.put("CUSTOMER_ID", "123");
+// map.put("CUSTOMER_ID".toLowerCase(), "123");
+// System.out.println(whereHandle(str, map));
+ whereHandle(str, map);
}
public static String whereHandle(String sJboWhere,
Map paramMap) {
- return whereHandle1(sJboWhere, paramMap);
+ return whereHandle2(sJboWhere, paramMap);
+ }
+
+ private static String whereHandle2(String sJboWhere,
+ Map paramMap) {
+ while (sJboWhere.contains(" ")) {
+ sJboWhere = sJboWhere.replace(" ", " ");
+ }
+ String where = sJboWhere;
+ String operation = "=";
+ if (where.contains(":")) {
+ String [] array = where.split(":");
+ String oldStr = "", newStr = "";
+ for (int i = 1; i < array.length; i++) {
+
+ String key = array[i - 1].trim();
+ String value = array[i].trim();
+
+ if (value.endsWith(")")) {
+ value = value.substring(0, value.length() - 1).trim();
+ }
+ String sKey = "", sKeyStr = "";
+ if (key.endsWith("==") || key.endsWith("!=") || key.endsWith("<>") || key.endsWith(">=") || key.endsWith("<=")
+ || key.equals("!<") || key.equals("!>")) {
+ sKey = key.substring(0, key.length() - 2).trim();
+ operation = key.substring(key.length() - 2, key.length()).trim();
+ } else if (key.endsWith("=") || key.endsWith(">") || key.endsWith("<")) {
+ sKey = key.substring(0, key.length() - 1).trim();
+ operation = key.substring(key.length() - 1, key.length()).trim();
+ }
+
+ String [] keyArray = sKey.split(" ");
+
+ if (keyArray.length > 0) {
+ sKeyStr = keyArray[keyArray.length - 1].trim();
+ } else {
+ sKeyStr = sKey.trim();
+ }
+
+ if (sKeyStr.startsWith("(")) {
+ sKeyStr = sKeyStr.substring(1, sKeyStr.length());
+ }
+
+ if (sKeyStr.contains(".")) {
+ String [] keyArray2 = sKeyStr.split("\\.");
+
+ sKeyStr = keyArray2[keyArray2.length - 1].trim();
+
+ }
+ if (value.contains(" ")) {
+ value = value.substring(0, value.indexOf(" "));
+ }
+ value = value.trim();
+ if (value.endsWith(")")) {
+ value = value.substring(0, value.indexOf(")"));
+ }
+ oldStr = array[i - 1] + ":" + value;
+// System.out.println("old: " + oldStr);
+
+ newStr = sKeyStr + operation + "'" + paramMap.get(sKeyStr) + "'";
+ System.out.println(sKeyStr + operation + ":" + value + " 替换成 " + newStr);
+ oldStr = sKeyStr + operation + ":" + value;
+ sJboWhere = sJboWhere.replace(oldStr, newStr);
+ oldStr = sKeyStr + " " + operation + ": " + value;
+ sJboWhere = sJboWhere.replace(oldStr, newStr);
+ oldStr = sKeyStr + operation + ": " + value;
+ sJboWhere = sJboWhere.replace(oldStr, newStr);
+ oldStr = sKeyStr + " " + operation + ":" + value;
+ sJboWhere = sJboWhere.replace(oldStr, newStr);
+ }
+ }
+ System.out.println(sJboWhere);
+ return sJboWhere;
}
private static String whereHandle1(String sJboWhere,
@@ -36,24 +111,23 @@ public class AweDoCommUtil {
where = where.replace(" AND ", " and ");
where = where.replace(" OR ", " or ");
String[] array = where.split("and");
+ String[] array1 = null;
+ String sKey = "";
+ String newStr = "";
for (String str : array) {
if (str.contains(":")) {
+ array1 = str.split(":");
String[] orArray = str.split("or");
if (orArray.length >= 2) {
- // [ (O.INPUTORGID=:inputOrgId , O.INPUTORGID like :inputOrgId1)]
for (String orStr : orArray) {
- // O.contract_id = :contract_id
- String[] array1 = orStr.split(":");
- // O.contract_id = > 0
- // contract_id> 1
- if (array1.length != 2)
- continue;
+// if (array1.length != 2)
+// continue;
if (!array1[0].contains(".")) {
- String sKey = array1[0].toLowerCase();
+ sKey = array1[0].toLowerCase();
sKey = sKey.trim();
sKey = sKey.substring(0, sKey.length() - 1);
sKey = sKey.trim();
- String newStr = array1[0] + "'"
+ newStr = array1[0] + "'"
+ paramMap.get(sKey) + "' ";
sJboWhere = sJboWhere.replace(orStr, newStr);
continue;
@@ -61,47 +135,42 @@ public class AweDoCommUtil {
String[] array2 = array1[0].split("\\.");
if (array2.length < 2)
continue;
- String sKey = array2[1].toLowerCase();
- // inputorgid like
+ sKey = array2[array2.length - 1].toLowerCase().trim();
+
if (sKey.contains("like") || sKey.contains("LIKE")) {
- String newStr = array1[0] + "'" + paramMap.get(sKey.trim().replaceAll("like", "").trim()) + "' ";
- String sStr = array1[1];
- while (sStr.endsWith(")")) {
- newStr += ")";
- sStr = sStr.substring(0, sStr.length() - 1);
- }
- sJboWhere = sJboWhere.replace(orStr, newStr);
+ newStr = array1[0] + "'" + paramMap.get(sKey.trim().replaceAll("like", "").trim()) + "' ".trim();
+ } else if (sKey.contains(" in ") || sKey.contains(" IN ")) {
+ newStr = array1[0] + "'" + paramMap.get(sKey.trim().replaceAll(" in ", "").trim()) + "' ".trim();
} else {
- sKey = sKey.trim();
- sKey = sKey.substring(0, sKey.length() - 1);
- sKey = sKey.trim();
- String newStr = array1[0] + "'"
- + paramMap.get(sKey) + "' ";
- String sStr = array1[1];
- while (sStr.endsWith(")")) {
- newStr += ")";
- sStr = sStr.substring(0, sStr.length() - 1);
- }
- sJboWhere = sJboWhere.replace(orStr, newStr);
+ sKey = sKey.substring(0, sKey.length() - 1).trim();
+ newStr = array1[0] + "'"
+ + paramMap.get(sKey) + "' ".trim();
+
}
+ String sStr = orStr.trim();
+ while (sStr.endsWith(")")) {
+// newStr += ")";
+ sStr = sStr.substring(0, sStr.length()-1);
+ }
+ sJboWhere = sJboWhere.replace(sStr, newStr);
sJboWhere += " ";
}
- sJboWhere = sJboWhere.substring(0, sJboWhere.length() - 1);
- } else {
- // O.contract_id = :contract_id
- String[] array1 = str.split(":");
- // O.contract_id = > 0
- // contract_id> 1
+ } else { // 没有 or
if (array1.length != 2)
continue;
- if (!array1[0].contains(".")) {
- String sKey = array1[0].toLowerCase();
- sKey = sKey.trim();
- sKey = sKey.substring(0, sKey.length() - 1);
- sKey = sKey.trim();
- String newStr = array1[0] + "'"
- + paramMap.get(sKey) + "' ";
- String sStr = array1[1];
+ if (!array1[0].contains(".")) { // 没有 O. xx.
+ sKey = array1[0].toLowerCase().trim();
+ newStr = "";
+ if (sKey.contains(" like ") || sKey.contains(" LIKE ")) { // flowUnid like : flowUnid
+ newStr = array1[0] + "'" + paramMap.get(sKey.replaceAll(" like ", "").trim()) + "'".trim();
+ } else if (sKey.contains(" in ") || sKey.contains(" IN ")) { // flowUnid in : flowUnid
+ newStr = array1[0] + "'" + paramMap.get(sKey.replaceAll(" in ", "").trim()) + "'".trim();
+ } else { // flowUnid = || > || < : flowUnid
+ sKey = sKey.substring(0, sKey.length() - 1).trim();
+ newStr = array1[0] + "'" + paramMap.get(sKey) + "' ".trim();
+ }
+
+ String sStr = array1[1].trim();
while (sStr.endsWith(")")) {
newStr += ")";
sStr = sStr.substring(0, sStr.length() - 1);
@@ -112,19 +181,25 @@ public class AweDoCommUtil {
String[] array2 = array1[0].split("\\.");
if (array2.length < 2)
continue;
- String sKey = array2[1].toLowerCase();
- sKey = sKey.trim();
- sKey = sKey.substring(0, sKey.length() - 1);
- sKey = sKey.trim();
- String newStr = array1[0] + "'"
- + paramMap.get(sKey) + "' ";
- String sStr = array1[1];
- while (sStr.endsWith(")")) {
- newStr += ")";
- sStr = sStr.substring(0, sStr.length() - 1);
+ sKey = array2[array2.length - 1].toLowerCase().trim();
+ newStr = "";
+ if (sKey.contains(" like ") || sKey.contains(" LIKE ")) { // flowUnid like : flowUnid
+ newStr = array1[0] + "'" + paramMap.get(sKey.replaceAll(" like ", "").trim()) + "'".trim();
+ } else if (sKey.contains(" in ") || sKey.contains(" IN ")) { // flowUnid in : flowUnid
+ newStr = array1[0] + "'" + paramMap.get(sKey.replaceAll(" in ", "").trim()) + "'".trim();
+ } else { // flowUnid = || > || < : flowUnid
+ sKey = sKey.substring(0, sKey.length() - 1).trim();
+ newStr = array1[0] + "'" + paramMap.get(sKey) + "' ".trim();
}
- sJboWhere = sJboWhere.replace(str, newStr);
}
+ newStr = newStr.trim();
+ String sStr = array1[1].trim();
+ while (sStr.endsWith(")")) {
+ newStr += ")";
+ sStr = sStr.substring(0, sStr.length() - 1);
+ }
+ newStr = " " + newStr + " ";
+ sJboWhere = sJboWhere.replace(str, newStr);
}
}
return sJboWhere;
diff --git a/src_tenwa/com/tenwa/collectaudit/cache/CollectAuditInfoCache.java b/src_tenwa/com/tenwa/collectaudit/cache/CollectAuditInfoCache.java
index 3c126c0ed..3b6606f74 100644
--- a/src_tenwa/com/tenwa/collectaudit/cache/CollectAuditInfoCache.java
+++ b/src_tenwa/com/tenwa/collectaudit/cache/CollectAuditInfoCache.java
@@ -1,635 +1,1451 @@
-package com.tenwa.collectaudit.cache;
-
-import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-
-
-
-
-
-
-
-
-import jbo.app.tenwa.calc.LC_RENT_INCOME;
-import jbo.app.tenwa.calc.LC_RENT_PLAN;
-import jbo.app.tenwa.customer.CUSTOMER_ACCOUNT;
-import jbo.com.tenwa.lease.comm.COLLECT_RECORD_LOG;
-import jbo.com.tenwa.lease.comm.COLLECT_RECORD_STATUS;
-import jbo.com.tenwa.lease.comm.VI_LC_AUDIT_RENT_PLAN;
-import jbo.sys.CODE_LIBRARY;
-
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-import com.amarsoft.app.awe.config.InitCollectConfig;
-import com.amarsoft.are.jbo.BizObject;
-import com.amarsoft.are.jbo.BizObjectManager;
-import com.amarsoft.are.jbo.JBOException;
-import com.amarsoft.are.jbo.JBOFactory;
-import com.amarsoft.are.jbo.JBOTransaction;
-import com.amarsoft.awe.util.SqlObject;
-import com.amarsoft.awe.util.Transaction;
-import com.tenwa.comm.util.date.DateAssistant;
-import com.tenwa.util.SerialNumberUtil;
-import com.zhongan.scorpoin.biz.common.CommonRequest;
-import com.zhongan.scorpoin.biz.common.CommonResponse;
-import com.zhongan.scorpoin.common.ZhongAnApiClient;
-import com.zhongan.scorpoin.common.ZhongAnOpenException;
-
-public class CollectAuditInfoCache {
-
-
- private String id;
- private String inputuserid;
- private String inputorgid;
-
- //校验是否已经收款
- public String checkRentIsIncome(JBOTransaction tx) throws JBOException{
- String[] ids = id.split("@");
- StringBuffer parms = new StringBuffer();
- for (String str : ids) {
- if (parms.length()==0) {
- parms.append("'"+str+"'");
- }else{
- parms.append(",'"+str+"'");
- }
- }
- BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
- List bolist = bm.createQuery("select v.getCustomerName(O.customer_id) as v.customer_name,O.contract_id,O.plan_list,O.plan_date,O.rent_over,crs.deduct_stata from O LEFT JOIN jbo.com.tenwa.lease.comm.COLLECT_RECORD_STATUS crs ON crs.contract_id = O.contract_id AND crs.rent_plan_id = O.id where O.id in ("+parms.toString()+")").getResultList(false);
- for (BizObject bo : bolist) {
- String name = bo.getAttribute("customer_name").toString().trim();
- String plan_list = bo.getAttribute("plan_list").toString().trim();
- String plan_date = bo.getAttribute("plan_date").toString().trim();
- String deductstata = bo.getAttribute("deduct_stata").toString().trim();
- String rent = bo.getAttribute("rent_over").toString();
- if ("processing".equals(deductstata)) {//判断是否在批量处理中
- return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金正在进行扣款处理中".trim();
- }
- if ("".equals(rent) || "0".equals(rent) || "0.0".equals(rent)) {//判断剩余收款金额
- return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金已经全部收取,无法再次扣款".trim();
- }
- }
- return "sucess";
- }
-
- //初审
- public String fristCollectAudit(JBOTransaction tx) throws JBOException{
- String[] ids = id.split("@");
- StringBuffer buff = new StringBuffer();
- for (String str : ids) {
- if (buff.length() == 0) {
- buff.append("'"+str+"'");
- }else{
- buff.append(",'"+str+"'");
- }
- }
- String parm = buff.toString();
- BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
- BizObjectManager acc = JBOFactory.getFactory().getManager(CUSTOMER_ACCOUNT.CLASS_NAME);
- List bolist = bm.createQuery("select v.getCustomerName(O.customer_id) as v.customer_name,O.account,O.acc_number,O.mobile,O.contract_id,O.plan_list,O.plan_date,O.COLLECT_STATUS,O.rent from O where O.id in ("+parm.toString()+")").getResultList(false);
- for (BizObject bo : bolist) {
- String name = bo.getAttribute("customer_name").toString().trim();
- BizObject ac = acc.createQuery("O.account=:account and O.acc_info = 'Debit' and O.acc_number=:acc_number and O.mobile=:mobile and O.contract_id=:contract_id")
- .setParameter("account", bo.getAttribute("account").toString())
- .setParameter("acc_number", bo.getAttribute("acc_number").toString())
- .setParameter("mobile", bo.getAttribute("mobile").toString())
- .setParameter("contract_id", bo.getAttribute("contract_id").toString())
- .getSingleResult(false);
- /*if (ac == null) {
- return "error@客户"+name+"尚未签约,请先进行签约".trim();
- }*/
- }
- BizObjectManager bmr = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
- bmr.createQuery("update O set O.AUDIT_STATE = 'Y' where id in ("+parm+")").executeUpdate();
-
- return "success";
- }
-
- //复审退回
- public String rebackCollectAudit(JBOTransaction tx) throws JBOException{
- String[] ids = id.split("@");
- StringBuffer parms = new StringBuffer();
- for (String str : ids) {
- if (parms.length() == 0) {
- parms.append("'"+str+"'");
- }else{
- parms.append(",'"+str+"'");
- }
- }
- BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
- List bolist = bm.createQuery("select v.getCustomerName(O.customer_id) as v.customer_name,O.fact_rent,O.account,O.acc_number,O.mobile,O.contract_id,O.plan_list,O.plan_date,O.COLLECT_STATUS,O.BATCH_STATUS,O.rent from O where O.id in ("+parms.toString()+")").getResultList(false);
- for (BizObject bo : bolist) {
- String name = bo.getAttribute("customer_name").toString().trim();
- String plan_list = bo.getAttribute("plan_list").toString();
- String plan_date = bo.getAttribute("plan_date").toString();
- String batchstatus = bo.getAttribute("BATCH_STATUS").toString();
- String rent = bo.getAttribute("rent").toString();
- double fact_rent = bo.getAttribute("fact_rent").getDouble();//实际租金
- double income_rent = bo.getAttribute("rent").getDouble();//已收租金
- if ("process".equals(batchstatus)) {//判断是否在批量处理中
- return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金正在进行批量扣款处理中,无法退回初审".trim();
- }
- if ("".equals(rent) || "0".equals(rent) || "0.0".equals(rent)) {//判断剩余收款金额
- return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金已经全部收取,无法退回初审".trim();
- }
- if (income_rent > 0 && (fact_rent > income_rent)) {//部分收款
- return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金已经部分收取,无法退回初审".trim();
- }
- }
- BizObjectManager bmlrp = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
- bmlrp.createQuery("update O set O.AUDIT_STATE = 'N' where id in ("+parms.toString()+")").executeUpdate();
-
- return "success";
- }
-
- /**
- * 代收-发送请求
- * @param tx
- * @return
- * @throws Exception
- */
- public String batchCollectManage(JBOTransaction tx) throws Exception{
- String[] ids = id.split("@");
- StringBuffer parms = new StringBuffer();
- for (String str : ids) {
- if (parms.length()==0) {
- parms.append("'"+str+"'");
- }else{
- parms.append(",'"+str+"'");
- }
- }
- BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
- BizObjectManager lrpbm = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
- List bolist = bm.createQuery("select O.contract_id,O.plan_date,O.id,ci.certid,ca.ACC_NUMBER,ca.mobile,ca.ACCOUNT,ca.BANK_NAME,O.rent from O , jbo.app.tenwa.customer.CUSTOMER_ACCOUNT ca,jbo.app.tenwa.customer.CUSTOMER_INFO ci where ci.customerid=ca.customerid and ca.customerid=O.customer_id and O.contract_id=ca.contract_id and ca.acc_type = 'Debit' and O.id in ("+parms.toString()+")").getResultList(false);
- for (BizObject biz : bolist) {
- String contract_id = biz.getAttribute("contract_id").toString();
- String plan_id = biz.getAttribute("id").toString();
- String bankname = biz.getAttribute("bank_name").toString();
- String customer_name = biz.getAttribute("account").toString();
- String certid = biz.getAttribute("certid").toString();
- String mobile = biz.getAttribute("mobile").toString();
- String acc_number = biz.getAttribute("ACC_NUMBER").toString();
- String account = biz.getAttribute("ACCOUNT").toString();
- String rent = biz.getAttribute("rent").toString();
- BigDecimal rent_over = new BigDecimal(rent).setScale(2);
- List codelist = JBOFactory.getFactory().getBizObjectManager(CODE_LIBRARY.CLASS_NAME).createQuery("O.codeno = 'selectCollectBank' and O.isinuse = '1' and O.itemattribute is not null ").getResultList(false);
- for (BizObject code : codelist) {
- String itemname = code.getAttribute("itemname").toString().trim();
- BigDecimal quota = new BigDecimal(code.getAttribute("itemattribute").toString()).setScale(2);
- String collect_sn = "";//代扣流水号
- if (bankname.indexOf(itemname) !=-1 && rent_over.compareTo(quota) == 1) {
- int index_z = rent_over.divide(quota).intValue();
- int index_y = rent_over.divideAndRemainder(quota)[1].compareTo(new BigDecimal(0)) == 1 ? 1 : 0;
- for (int i = 0; i < index_z; i++) {
- JBOTransaction tx1 = JBOFactory.createJBOTransaction();
- collect_sn = SerialNumberUtil.getBatchSerialNumber(tx1);
- //发起代扣
- Map result = singleBatchCollectMoeny(tx, collect_sn,certid, bankname, acc_number, account, quota.toString());
- if (result.containsKey("transStatus") && "3".equals(result.get("transStatus"))) {
- archiveRedcodeStatus(tx1, collect_sn, contract_id, plan_id, quota.toString());
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- lrpbm.createQuery("update O set O.collect_status = '1' where O.id =:plan_id ").setParameter("plan_id", plan_id).executeUpdate();
- }else if (result.containsKey("transStatus") && "9".equals(result.get("transStatus"))) {
- //不做任何操作
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- lrpbm.createQuery("update O set O.collect_msg =:collect_msg where O.id =:plan_id ").setParameter("collect_msg", result.get("resMsg").toString()).setParameter("plan_id", plan_id).executeUpdate();
- }else{
- //其他情况均认为是 处理中 状态
- archiveRedcodeStatus(tx1, collect_sn, contract_id, plan_id, quota.toString());
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- lrpbm.createQuery("update O set O.collect_status = '1' where O.id =:plan_id ").setParameter("plan_id", plan_id).executeUpdate();
- }
- //记录发起代扣信息
- archiveRedcodeLog(tx1, collect_sn, contract_id, plan_id, customer_name, certid, mobile, bankname, acc_number, account, quota.toString());
- tx1.commit();
- }
- if (index_y == 1) {
- //发起代扣
- JBOTransaction tx1 = JBOFactory.createJBOTransaction();
- collect_sn = SerialNumberUtil.getBatchSerialNumber(tx1);
- Map result = singleBatchCollectMoeny(tx, collect_sn,certid, bankname, acc_number, account, rent_over.subtract(quota.multiply(new BigDecimal(index_z))).toString());
- if (result.containsKey("transStatus") && "3".equals(result.get("transStatus"))) {
- archiveRedcodeStatus(tx1, collect_sn, contract_id, plan_id, rent_over.subtract(quota.multiply(new BigDecimal(index_z))).toString());
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- lrpbm.createQuery("update O set O.collect_status = '1' where O.id =:plan_id ").setParameter("plan_id", plan_id).executeUpdate();
- }else if (result.containsKey("transStatus") && "9".equals(result.get("transStatus"))) {
- //不做任何操作
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- lrpbm.createQuery("update O set O.collect_msg =:collect_msg where O.id =:plan_id ").setParameter("collect_msg", result.get("resMsg").toString()).setParameter("plan_id", plan_id).executeUpdate();
- }else{
- //其他情况均认为是 处理中 状态
- archiveRedcodeStatus(tx1, collect_sn, contract_id, plan_id, rent_over.subtract(quota.multiply(new BigDecimal(index_z))).toString());
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- lrpbm.createQuery("update O set O.collect_status = '1' where O.id =:plan_id ").setParameter("plan_id", plan_id).executeUpdate();
- }
- //记录发起代扣信息
- archiveRedcodeLog(tx1, collect_sn, contract_id, plan_id, customer_name, certid, mobile, bankname, acc_number, account, rent_over.subtract(quota.multiply(new BigDecimal(index_z))).toString());
- tx1.commit();
- }
- break;
- }else if (bankname.indexOf(itemname) !=-1 && rent_over.compareTo(quota) == -1) {//如果小于限额，则直接扣款
- JBOTransaction tx1 = JBOFactory.createJBOTransaction();
- collect_sn = SerialNumberUtil.getBatchSerialNumber(tx1);
- //发起代扣
- Map result = singleBatchCollectMoeny(tx, collect_sn, certid,bankname, acc_number, account, rent);
- if (result.containsKey("transStatus") && "3".equals(result.get("transStatus"))) {
- archiveRedcodeStatus(tx1, collect_sn, contract_id, plan_id, rent);
- }else if (result.containsKey("transStatus") && "9".equals(result.get("transStatus"))) {
- //不做任何操作
- }else{
- //其他情况均认为是 处理中 状态
- archiveRedcodeStatus(tx1, collect_sn, contract_id, plan_id, rent);
- }
- tx1.commit();
- break;
- }
- }
-
- }
- return "系统正在处理中，请稍后";
- }
-
- /**
- * 记录请求日志
- * @param tx1
- * @param contract_id 合同编号
- * @param plan_id 租金计划编号
- * @param bankname 银行名称
- * @param acc_number 银行账号
- * @param account 开户户名
- * @param rent 扣款金额
- * @throws JBOException
- */
- public void archiveRedcodeLog(JBOTransaction tx1,String collect_sn,String contract_id,String plan_id,String customer_name,String certid,String mobile,String bankname,String acc_number,String account,String rent) throws JBOException{
- BizObjectManager crlbm = JBOFactory.getFactory().getManager(COLLECT_RECORD_LOG.CLASS_NAME);
- BizObject crl = crlbm.newObject();
- tx1.join(crlbm);
- crl.setAttributeValue("contract_id", contract_id);
- crl.setAttributeValue("customer_name", customer_name);
- crl.setAttributeValue("collect_sn", collect_sn);
- crl.setAttributeValue("certid", certid);
- crl.setAttributeValue("mobile", mobile);
- crl.setAttributeValue("acc_number", acc_number);
- crl.setAttributeValue("money", new BigDecimal(rent).multiply(new BigDecimal(100)).intValue());
- crl.setAttributeValue("inputorg", getInputorgid());
- crl.setAttributeValue("inputuser", getInputuserid());
- crl.setAttributeValue("inputdate", DateAssistant.getToday());
- crlbm.saveObject(crl);
- }
-
- /**
- * 记录请求流水号标志位
- * @param tx1
- * @param contract_id 合同编号
- * @param plan_id 租金计划编号
- * @param bankname 银行名称
- * @param acc_number 银行账号
- * @param account 开户户名
- * @param rent 扣款金额
- * @throws JBOException
- */
- public void archiveRedcodeStatus(JBOTransaction tx1,String collect_sn,String contract_id,String plan_id,String rent) throws JBOException{
- BizObjectManager crsbm = JBOFactory.getFactory().getManager(COLLECT_RECORD_STATUS.CLASS_NAME);
- BizObject crs = crsbm.newObject();
- tx1.join(crsbm);
- crs.setAttributeValue("contract_id", contract_id);
- crs.setAttributeValue("rent_plan_id", plan_id);
- crs.setAttributeValue("collect_sn", collect_sn);
- crs.setAttributeValue("money", rent);
- //处理中,processing/处理完成,success/处理失败,failure
- crs.setAttributeValue("deduct_stata", "processing");
- crs.setAttributeValue("inputorg", getInputorgid());
- crs.setAttributeValue("inputuser", getInputuserid());
- crs.setAttributeValue("inputdate", DateAssistant.getToday());
- crsbm.saveObject(crs);
- }
-
- /**
- * 代收-发送请求
- * @param tx
- * @param bc
- * @param bo
- * @param rent
- * @return
- * @throws Exception
- */
- public Map singleBatchCollectMoeny(JBOTransaction tx,String collect_sn,String certid,String bankName,String accNumber,String account,String rent) throws Exception{
- int money = new BigDecimal(rent).setScale(2).multiply(new BigDecimal(100)).intValue();
- String serviceName = "payacq.transInTrans";
- ZhongAnApiClient client = new ZhongAnApiClient(InitCollectConfig.C_ENV, InitCollectConfig.C_APPKEY, InitCollectConfig.C_PRIVATEKEY, InitCollectConfig.C_VERSION);
- CommonRequest request = new CommonRequest(serviceName);
- JSONObject params = new JSONObject();
- //传入业务参数
- params.put("version", InitCollectConfig.C_VERSION);
- params.put("bizCat", InitCollectConfig.C_BIZCAT);
- params.put("bizSys", InitCollectConfig.C_BIZSYS);
- //交易流水号
- String outTradeNo = collect_sn;
- params.put("outTradeNo", outTradeNo);
- params.put("bizType", InitCollectConfig.C_BIZTYPE);//"1-消费 8-申购 30-追偿"
- System.out.println(new Date());
- params.put("subBusinessCode", InitCollectConfig.C_SUBBUSINESSCODE);
- params.put("businessCode", InitCollectConfig.C_BUSINESSCODE);
- params.put("reqTime", new Date());
- params.put("chanAcctId", InitCollectConfig.C_CHANACCTID);
- // params.put("ccy", "");
- params.put("orderAmt", money);
- /*
- 1:借记卡,
- 2:信用账户
- 3:中信电子账户
- 5:微信支付
- 7:二类户（备注 2类户）
- 8:余额支付工具
- */
- JSONObject values = new JSONObject();
- values.put("payerTool", "1");
- values.put("payerAcctId", "0");
- values.put("payerName", account);//户名
- values.put("payerIdType", "l");
- values.put("payerIdNo", accNumber);//银行卡号
- values.put("payerCardNo", certid);
- values.put("payAmt", money);
- params.put("payerInfoList", new Object[]{values});
- request.setParams(params);
- CommonResponse response = (CommonResponse) client.call(request);
- Map map = JSON.parseObject(response.getBizContent());
- if (null == map) {
- map = new HashMap();
- }
- return map;
- }
-
- /**
- * 查询批量收款状态
- * @return
- * @throws Exception
- */
- public String queryBatchCollectStatus(JBOTransaction tx,StringBuffer parms) throws Exception{
- BizObjectManager bc = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
- List bolist = bc.createQuery("select crs.rent_plan_id,crs.collect_sn,crs.money from O left join jbo.com.tenwa.lease.comm.COLLECT_RECORD_STATUS crs on crs.rent_plan_id = O.id where crs.collect_sn in ("+parms.toString()+")").getResultList(false);
- List listId = new ArrayList();
- for (BizObject bo : bolist) {
- String plan_id = bo.getAttribute("rent_plan_id").toString();
- String collect_sn = bo.getAttribute("collect_sn").toString();
- Map result = queryTransQry(collect_sn);
- JBOTransaction transaction = JBOFactory.createJBOTransaction();
- BizObjectManager crsbm = JBOFactory.getFactory().getManager(COLLECT_RECORD_STATUS.CLASS_NAME,transaction);
- if (result.containsKey("transStatus") && "3".equals(result.get("transStatus"))) {
- //回笼租金
- querysingleCollectMoeny(transaction, bo);
- //更新收款状态
- crsbm.createQuery("update O set O.deduct_stata = 'success',O.deduct_msg = '"+result.get("transMsg")+"' where O.rent_plan_id=:plan_id and O.collect_sn=:collect_sn ")
- .setParameter("plan_id", plan_id).setParameter("collect_sn", collect_sn).executeUpdate();
- }else if (result.containsKey("transStatus") && "9".equals(result.get("transStatus"))) {
- //如果扣款失败，更新状态，不回笼租金//////处理中,processing/处理完成,success/处理失败,failure
- crsbm.createQuery("update O set O.deduct_stata = 'failure',O.deduct_msg = '"+result.get("transMsg")+"' where O.rent_plan_id=:plan_id and O.collect_sn=:collect_sn ")
- .setParameter("plan_id", plan_id).setParameter("collect_sn", collect_sn).executeUpdate();
- } else{
- //正在处理中，不做任何操做
- }
- transaction.commit();
- if (!listId.contains(plan_id)) {
- listId.add(plan_id);
- }
-
- }
- Object[] arryId = listId.toArray();
- StringBuffer arryparm = new StringBuffer();
- for (Object string : arryId) {
- if (arryparm.length() == 0) {
- arryparm.append("'"+string+"'");
- }else {
- arryparm.append(",'"+string+"'");
- }
- }
- BizObjectManager crsbm = JBOFactory.getFactory().getManager(COLLECT_RECORD_STATUS.CLASS_NAME);
- List querylist = crsbm.createQuery("select v.GROUP_CONCAT(O.deduct_stata) AS v.debuct_statas,O.rent_plan_id from O where O.rent_plan_id in ("+arryparm.toString()+") ").getResultList(false);
- for (BizObject biz : querylist) {
- String deduct_stata = biz.getAttribute("debuct_statas").toString();
- String plan_id = biz.getAttribute("rent_plan_id").toString();
- //处理中,processing/处理完成,success/处理失败,failure
- if (deduct_stata.contains("processing") && deduct_stata.contains("success") && deduct_stata.contains("failure")) {
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- bc.createQuery("update O set O.collect_status = '1' where id = '"+plan_id+"'").executeUpdate();
- }else if (!deduct_stata.contains("processing") && deduct_stata.contains("success") && deduct_stata.contains("failure")){
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- bc.createQuery("update O set O.collect_status = '2' where id = '"+plan_id+"'").executeUpdate();
- }else if (!deduct_stata.contains("processing") && deduct_stata.contains("success") && !deduct_stata.contains("failure")){
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- bc.createQuery("update O set O.collect_status = '3' where id = '"+plan_id+"'").executeUpdate();
- }else if (!deduct_stata.contains("processing") && !deduct_stata.contains("success") && deduct_stata.contains("failure")){
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- bc.createQuery("update O set O.collect_status = '4' where id = '"+plan_id+"'").executeUpdate();
- }
- }
-
- return "sucess";
-
- }
-
- public static String getDeductStata(String plan_id){
- JBOTransaction tx = null;
- StringBuffer result = new StringBuffer();
- try {
- tx = JBOFactory.createJBOTransaction();
- BizObjectManager crsbm = JBOFactory.getFactory().getManager(COLLECT_RECORD_STATUS.CLASS_NAME,tx);
- BizObject querybiz = crsbm.createQuery("select v.GROUP_CONCAT(O.deduct_stata) AS v.debuct_statas,v.GROUP_CONCAT(O.deduct_msg) AS v.debuct_msgs from O where O.rent_plan_id =:plan_id ").setParameter("plan_id", plan_id).getSingleResult(false);
- if(null != querybiz) {
- String deduct_stata = querybiz.getAttribute("debuct_statas").toString();
- String[] deduct_statas = querybiz.getAttribute("debuct_statas").toString().trim().split(",");
- String[] debuct_msgs = querybiz.getAttribute("debuct_msgs").toString().trim().split(",");
- //处理中,processing/处理完成,success/处理失败,failure
- if (deduct_stata.contains("processing") && deduct_stata.contains("success") && deduct_stata.contains("failure")) {
- result.append("部分收款 >> 收款中 >> ");
- for (int i = 0; i < deduct_statas.length; i++) {
- if (deduct_statas[i].contains("failure")) {
- result.append(debuct_msgs[i]);
- break;
- }
- }
- }else if (deduct_stata.contains("processing") && !deduct_stata.contains("success") && !deduct_stata.contains("failure")){
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- result.append("收款中 ");
- }else if (!deduct_stata.contains("processing") && deduct_stata.contains("success") && deduct_stata.contains("failure")){
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- result.append("部分收款 >>> ");
- for (int i = 0; i < deduct_statas.length; i++) {
- if (deduct_statas[i].contains("failure")) {
- result.append(debuct_msgs[i]);
- break;
- }
- }
-
- }else if (!deduct_stata.contains("processing") && deduct_stata.contains("success") && !deduct_stata.contains("failure")){
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- result.append("收款成功 ");
- }else if (!deduct_stata.contains("processing") && !deduct_stata.contains("success") && deduct_stata.contains("failure")){
- //更新状态,1,处理中,2,部分收款,3,收款成功,4,收款失败,5,未收款
- result.append("收款失败 >>> ");
- for (int i = 0; i < deduct_statas.length; i++) {
- if (deduct_statas[i].contains("failure")) {
- result.append(debuct_msgs[i]);
- break;
- }
- }
- }
- }
- return result.toString().trim();
- } catch (JBOException e) {
- if (tx != null) {
- try {
- tx.rollback();
- } catch (JBOException e1) {
- // TODO Auto-generated catch block
- e1.printStackTrace();
- }
- }
- }finally{
- try {
- tx.commit();
- } catch (JBOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- return result.toString().trim();
-
- }
-
- /**
- * 查询扣款是否成功
- * @param outTradeNo
- * @return
- */
- public Map queryTransQry(String outTradeNo) {
- String serviceName = "payacq.transQry";
- Map result = new HashMap();
- try {
- ZhongAnApiClient client = new ZhongAnApiClient(InitCollectConfig.C_ENV, InitCollectConfig.C_APPKEY, InitCollectConfig.C_PRIVATEKEY, InitCollectConfig.C_VERSION);
- CommonRequest request = new CommonRequest(serviceName);
- JSONObject params = new JSONObject();
- //传入业务参数
- params.put("version", InitCollectConfig.C_VERSION);
- params.put("chanAcctId", InitCollectConfig.C_CHANACCTID);
- params.put("outTradeNo", outTradeNo);
- params.put("bizCat", InitCollectConfig.C_BIZCAT);
- params.put("bizSys", InitCollectConfig.C_BIZSYS);
- request.setParams(params);
- CommonResponse response = (CommonResponse) client.call(request);
- System.out.println(response);
- result = JSON.parseObject(response.getBizContent());
- } catch (ZhongAnOpenException e) {
- e.printStackTrace();
- }
- return result;
- }
-
- /**
- * 查询接口--回笼租金
- * @param tx
- * @param bc
- * @param bo
- * @param rent
- * @return
- * @throws Exception
- */
- public void querysingleCollectMoeny(JBOTransaction tx,BizObject bo) throws Exception{
- String cerrentDate = DateAssistant.getToday();
- JBOTransaction transaction = tx;
- int hire_index = JBOFactory.getBizObjectManager(LC_RENT_INCOME.CLASS_NAME, transaction).createQuery("select COUNT(O.plan_id) from O GROUP BY O.plan_id HAVING O.plan_id=:plan_id ").getResultList(false).size() + 1;
- BigDecimal money_value = new BigDecimal(bo.getAttribute("moeny").toString()).setScale(2);
- BizObjectManager bmi = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,transaction);
- BizObject boi = bmi.createQuery("SELECT v.REPLACE(v.UUID(),'-','') AS id, O.QUOT_ID AS QUOT_ID, O.CUST_ID AS CUST_ID, O.PROJECT_ID AS PROJECT_ID, O.PROJECT_PLAN_NUMBER AS PROJECT_PLAN_NUMBER, "
- + "O.CONTRACT_ID AS CONTRACT_ID, O.CONTRACT_PLAN_NUMBER AS CONTRACT_PLAN_NUMBER, "
- + "O.PAYMENT_NUMBER AS PAYMENT_NUMBER, '' AS v.EBANK_NUMBER, O.id AS v.PLAN_ID, "
- + "O.PLAN_LIST AS PLAN_LIST, '0' AS v.INTEREST_ADJUST, 'settlemethod6' AS SETTLE_METHOD, "
- + " '"+hire_index+"' AS v.HIRE_LIST, '"+cerrentDate+"' AS HIRE_DATE, vl.rent_over AS RENT, "
- + "vl.corpus_over AS CORPUS, vl.interest_over AS INTEREST, vl.penalty_over AS PENALTY,"
- + " '0' AS CORPUS_ADJUST, '0' AS PENALTY_ADJUST, '0' AS ROLL_BACK, O.COIN AS COIN FROM O, "
- + "jbo.app.tenwa.calc.VI_LC_RENT_PLAN vl WHERE O.id = vl.id AND vl.contract_id = :contract_id "
- + " AND vl.plan_date = :plan_date ").setParameter("contract_id", bo.getAttribute("contract_id").toString())
- .setParameter("plan_date", bo.getAttribute("plan_date").toString()).getSingleResult(false);
- if (boi != null) {
- String sql = "";
- BigDecimal interest_value = new BigDecimal(boi.getAttribute("interest").toString()).setScale(2);
- BigDecimal corpus_value = new BigDecimal(boi.getAttribute("corpus").toString()).setScale(2);
- BigDecimal penalty_value = new BigDecimal(boi.getAttribute("penalty").toString()).setScale(2);
- BigDecimal rent_value = new BigDecimal(boi.getAttribute("rent").toString()).setScale(2);
- BigDecimal rent = new BigDecimal(0);
- BigDecimal corpus = new BigDecimal(0);
- BigDecimal interest = new BigDecimal(0);
- BigDecimal penalty = new BigDecimal(0);
- if (rent_value.add(penalty_value).compareTo(money_value) == 0) {//如果 租金+罚息=本次扣款金额
- rent = rent_value;
- corpus = corpus_value;
- interest = interest_value;
- penalty = penalty_value;
- }else if (interest_value.doubleValue() > 0 && (money_value.compareTo(interest_value) == -1 || money_value.compareTo(interest_value) == 0)) {//剩余利息大于0,本次扣款金额小于或等于利息
- rent = money_value;
- interest = money_value;
- }else if (interest_value.doubleValue() > 0 && money_value.compareTo(interest_value) == 1) { //剩余利息大于0,本次扣款金额大于利息
- rent = money_value;
- corpus = money_value.subtract(interest_value).setScale(2);
- interest = interest_value;
- }else if (corpus_value.doubleValue() > 0 && (money_value.compareTo(corpus_value) == -1 || money_value.compareTo(corpus_value) == 0)) {//本金大于0,本次扣款金额小于或等于本金
- rent = money_value;
- corpus = money_value;
- }else if (corpus_value.doubleValue() > 0 && money_value.compareTo(corpus_value) == 1) {//本金大于0,本次扣款金额大于本金
- rent = money_value;
- corpus = corpus_value;
- penalty = money_value.subtract(corpus_value).setScale(2);
- }else if (penalty_value.doubleValue() > 0 && (money_value.compareTo(penalty_value) == -1 || money_value.compareTo(penalty_value) == 0)) {//罚息大于0,本次扣款金额小于或等于罚息
- rent = money_value;
- penalty = money_value;
- }else if (penalty_value.doubleValue() > 0 && money_value.compareTo(penalty_value) == 1) {//罚息大于0,本次扣款金额大于罚息
- rent = money_value;
- corpus = money_value.subtract(interest_value).subtract(corpus_value).setScale(2);
- interest = money_value.subtract(interest_value).setScale(2);
- penalty = penalty_value;
- }
- sql = "insert into LC_RENT_INCOME (ID, QUOT_ID, CUST_ID, PROJECT_ID, PROJECT_PLAN_NUMBER, CONTRACT_ID, CONTRACT_PLAN_NUMBER, PAYMENT_NUMBER,EBANK_NUMBER,PLAN_ID, PLAN_LIST,"
- + " INTEREST_ADJUST,SETTLE_METHOD,HIRE_LIST,HIRE_DATE, RENT,CORPUS,INTEREST,PENALTY,CORPUS_ADJUST,PENALTY_ADJUST,ROLL_BACK,COIN)"
- + "values ('"+boi.getAttribute("id")+"','"+boi.getAttribute("QUOT_ID")+"','"+boi.getAttribute("CUST_ID")+"','"+boi.getAttribute("PROJECT_ID")+"','"+boi.getAttribute("PROJECT_PLAN_NUMBER")+"',"
- + "'"+boi.getAttribute("CONTRACT_ID")+"','"+boi.getAttribute("CONTRACT_PLAN_NUMBER")+"','"+boi.getAttribute("PAYMENT_NUMBER")+"','"+boi.getAttribute("EBANK_NUMBER")+"','"+boi.getAttribute("PLAN_ID")+"',"
- + "'"+boi.getAttribute("PLAN_LIST")+"','"+boi.getAttribute("INTEREST_ADJUST")+"','"+boi.getAttribute("SETTLE_METHOD")+"','"+boi.getAttribute("HIRE_LIST")+"','"+boi.getAttribute("HIRE_DATE")+"','"+rent.toString()+"','"+corpus.toString()+"',"
- + "'"+interest.toString()+"','"+penalty.toString()+"','"+boi.getAttribute("CORPUS_ADJUST")+"','"+boi.getAttribute("PENALTY_ADJUST")+"','"+boi.getAttribute("ROLL_BACK")+"','"+boi.getAttribute("COIN")+"')";
- //插入数据
- Transaction Sqlca =null;
- Sqlca = Transaction.createTransaction(transaction);
- SqlObject asql = new SqlObject(sql);
- Sqlca.executeSQL(asql);
- }
- }
-
-
- public String getInputuserid() {
- return inputuserid;
- }
-
- public void setInputuserid(String inputuserid) {
- this.inputuserid = inputuserid;
- }
-
- public String getInputorgid() {
- return inputorgid;
- }
-
- public void setInputorgid(String inputorgid) {
- this.inputorgid = inputorgid;
- }
-
- public String getId() {
- return id;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
-}
+package com.tenwa.collectaudit.cache;
+
+import java.io.File;
+import java.math.BigDecimal;
+import java.text.DecimalFormat;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import jbo.app.tenwa.calc.LC_RENT_PLAN;
+import jbo.app.tenwa.customer.CUSTOMER_ACCOUNT;
+import jbo.com.tenwa.lease.comm.LB_CLEAR_FILE_RECORD;
+import jbo.com.tenwa.lease.comm.LB_INTFACE_FILE_RECORD;
+import jbo.com.tenwa.lease.comm.VI_LC_AUDIT_RENT_PLAN;
+import jbo.sys.CODE_LIBRARY;
+
+import com.amarsoft.app.als.sys.tools.DateTool;
+import com.amarsoft.app.awe.config.InitCollectConfig;
+import com.amarsoft.app.util.StringUtil;
+import com.amarsoft.are.jbo.BizObject;
+import com.amarsoft.are.jbo.BizObjectManager;
+import com.amarsoft.are.jbo.JBOException;
+import com.amarsoft.are.jbo.JBOFactory;
+import com.amarsoft.are.jbo.JBOTransaction;
+import com.amarsoft.awe.util.SqlObject;
+import com.amarsoft.awe.util.Transaction;
+import com.gnete.security.crypt.Crypt;
+import com.gnete.security.crypt.CryptException;
+import com.ibm.sslight.tools.mainExit;
+import com.tenwa.comm.util.date.DateAssistant;
+import com.tenwa.comm.util.jboutil.DataOperatorUtil;
+
+public class CollectAuditInfoCache {
+
+ private String id;
+ private String fileSavePath = "d:/tmp/als/InterFace";
+ private String inputuserid;
+ private String inputorgid;
+ private String clearDate;
+
+ //获取存盘文件
+ public static String getCollectIntface(String id) throws Exception{
+
+ String sql="select lr.filename from LB_INTFACE_FILE_RECORD lr "
+ + "where lr.id=:id";
+ Map map=new HashMap();
+ map.put("id", id);
+ JBOTransaction tx = null;
+ String filename="";
+ tx=JBOFactory.createJBOTransaction();
+ List> list=DataOperatorUtil.getDataBySql(tx, sql, map);
+ if(list.size()>0){
+ filename=StringUtil.nullToString(list.get(0).get("FILENAME")) ;
+ }
+ tx.commit();
+ return filename;
+ }
+ //校验是否已经收款
+ public String checkRentIsIncome(JBOTransaction tx) throws JBOException{
+ String[] ids = id.split("@");
+ StringBuffer parms = new StringBuffer();
+ for (String str : ids) {
+ if (parms.length()==0) {
+ parms.append("'"+str+"'");
+ }else{
+ parms.append(",'"+str+"'");
+ }
+ }
+ BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
+ List bolist = bm.createQuery("select v.getCustomerName(O.customer_id) as v.customer_name,O.account,O.acc_number,O.mobile,O.contract_id,O.plan_list,O.plan_date,O.COLLECT_STATUS,O.BATCH_STATUS,O.rent from O where O.id in ("+parms.toString()+")").getResultList(false);
+ for (BizObject bo : bolist) {
+ String name = bo.getAttribute("customer_name").toString().trim();
+ String plan_list = bo.getAttribute("plan_list").toString();
+ String plan_date = bo.getAttribute("plan_date").toString();
+ String batchstatus = bo.getAttribute("BATCH_STATUS").toString();
+ String rent = bo.getAttribute("rent").toString();
+ if ("process".equals(batchstatus)) {//判断是否在批量处理中
+ return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金正在进行批量扣款处理中".trim();
+ }
+ if ("".equals(rent) || "0".equals(rent) || "0.0".equals(rent)) {//判断剩余收款金额
+ return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金已经全部收取,无法再次扣款".trim();
+ }
+ }
+ return "sucess";
+ }
+ //上传清算文件
+ public String uploadClearFile(JBOTransaction tx) throws JBOException{
+ String currentDateTime = DateAssistant.getTodayNow();
+ String currenttime=currentDateTime.replaceAll("/", "");
+ currenttime=currenttime.replaceAll(":", "");
+ currenttime=currenttime.replaceAll(" ", "");
+ //String SETT_DATE = "20170920";
+ String SETT_DATE = this.getClearDate() != null ? this.getClearDate().replace("/", "") : "";
+ String SETT_NO = "01";
+ String SF_TYPE = InitCollectConfig.FLAG;
+ String USER_NAME = InitCollectConfig.USERNAME;
+ String MERCHANT_ID = InitCollectConfig.MERCHANTID;
+ String REQ_TIME = currenttime;
+ //String URL = "http://59.41.103.98:333/gzdsf/GetSettFile.do?";
+ String URL = InitCollectConfig.CLEARREQUESTURL+"?";
+ String SIGNED_MSG = "";
+ try {
+ Crypt crypt = new Crypt("gbk");
+ String pathPfx = InitCollectConfig.PRIVATEKEYURL;
+ //"D:\\BaiduNetdisk\\Download\\代收付系统接口文档和JAVA版测试demo及测试相关参数\\JAVA版测试DEMO及测试参数_20170825\\测试商户证书\\ORA@TEST1.p12";
+ SIGNED_MSG = SETT_DATE+"|"+SETT_NO+"|"+USER_NAME+"|"+MERCHANT_ID+"|"+REQ_TIME;
+ SIGNED_MSG = crypt.sign(SIGNED_MSG, pathPfx, "123456");
+ URL += "SETT_DATE="+SETT_DATE+"&SETT_NO="+SETT_NO+"&SF_TYPE="+SF_TYPE+"&USER_NAME="+USER_NAME+"&MERCHANT_ID="+MERCHANT_ID+"&REQ_TIME="+REQ_TIME+"&SIGNED_MSG="+SIGNED_MSG;
+ System.out.println(URL);
+ } catch (CryptException e) {
+ e.printStackTrace();
+ }
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LB_CLEAR_FILE_RECORD.CLASS_NAME);
+ bm.createQuery("update O set O.FULLPATH=:FULLPATH where O.id=:id").setParameter("FULLPATH", URL)
+ .setParameter("id", this.getId()).executeUpdate();
+ return "sucess";
+ }
+ //初审
+ public String fristCollectAudit(JBOTransaction tx) throws JBOException{
+ String[] ids = id.split("@");
+ StringBuffer buff = new StringBuffer();
+ for (String str : ids) {
+ if (buff.length() == 0) {
+ buff.append("'"+str+"'");
+ }else{
+ buff.append(",'"+str+"'");
+ }
+ }
+ String parm = buff.toString();
+ BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
+ BizObjectManager acc = JBOFactory.getFactory().getManager(CUSTOMER_ACCOUNT.CLASS_NAME);
+ List bolist = bm.createQuery("select v.getCustomerName(O.customer_id) as v.customer_name,O.account,O.acc_number,O.mobile,O.contract_id,O.plan_list,O.plan_date,O.COLLECT_STATUS,O.BATCH_STATUS,O.rent from O where O.id in ("+parm.toString()+")").getResultList(false);
+ for (BizObject bo : bolist) {
+ String name = bo.getAttribute("customer_name").toString().trim();
+ BizObject ac = acc.createQuery("O.account=:account and O.acc_info = 'Debit' and O.sign_status ='Y' and O.acc_number=:acc_number and O.mobile=:mobile and O.contract_id=:contract_id")
+ .setParameter("account", bo.getAttribute("account").toString())
+ .setParameter("acc_number", bo.getAttribute("acc_number").toString())
+ .setParameter("mobile", bo.getAttribute("mobile").toString())
+ .setParameter("contract_id", bo.getAttribute("contract_id").toString())
+ .getSingleResult(false);
+ if (ac == null) {
+ return "error@客户"+name+"尚未签约,请先进行签约".trim();
+ }
+ }
+ BizObjectManager bmr = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
+ String today=DateTool.getToday();
+ bmr.createQuery("update O set O.AUDIT_STATE = 'Y',CollectTime='"+today+"' where id in ("+parm+")").executeUpdate();
+ return "success";
+ }
+
+ //复审退回
+ public String rebackCollectAudit(JBOTransaction tx) throws JBOException{
+ String[] ids = id.split("@");
+ StringBuffer parms = new StringBuffer();
+ for (String str : ids) {
+ if (parms.length() == 0) {
+ parms.append("'"+str+"'");
+ }else{
+ parms.append(",'"+str+"'");
+ }
+ }
+ BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
+ List bolist = bm.createQuery("select v.getCustomerName(O.customer_id) as v.customer_name,O.fact_rent,O.account,O.acc_number,O.mobile,O.contract_id,O.plan_list,O.plan_date,O.COLLECT_STATUS,O.BATCH_STATUS,O.rent from O where O.id in ("+parms.toString()+")").getResultList(false);
+ for (BizObject bo : bolist) {
+ String name = bo.getAttribute("customer_name").toString().trim();
+ String plan_list = bo.getAttribute("plan_list").toString();
+ String plan_date = bo.getAttribute("plan_date").toString();
+ String batchstatus = bo.getAttribute("BATCH_STATUS").toString();
+ String rent = bo.getAttribute("rent").toString();
+ double fact_rent = bo.getAttribute("fact_rent").getDouble();//实际租金
+ double income_rent = bo.getAttribute("rent").getDouble();//已收租金
+ if ("process".equals(batchstatus)) {//判断是否在批量处理中
+ return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金正在进行批量扣款处理中,无法退回初审".trim();
+ }
+ if ("".equals(rent) || "0".equals(rent) || "0.0".equals(rent)) {//判断剩余收款金额
+ return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金已经全部收取,无法退回初审".trim();
+ }
+ if (income_rent > 0 && (fact_rent > income_rent)) {//部分收款
+ return "error@"+name+"的"+plan_list+"日期为"+plan_date+"的租金已经部分收取,无法退回初审".trim();
+ }
+ }
+ BizObjectManager bmlrp = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
+ bmlrp.createQuery("update O set O.AUDIT_STATE = 'N' where id in ("+parms.toString()+")").executeUpdate();
+
+ return "success";
+ }
+
+ /**
+ * 实时代收
+ * @param tx
+ * @return
+ * @throws Exception
+ */
+ public String barchCollectManage(JBOTransaction tx) throws Exception{
+ int i = 0,j = 0;
+ String[] ids = id.split("@");
+ StringBuffer parms = new StringBuffer();
+ for (String str : ids) {
+ if (parms.length()==0) {
+ parms.append("'"+str+"'");
+ }else{
+ parms.append(",'"+str+"'");
+ }
+ }
+ BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
+ BizObjectManager bc = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
+ List bolist = bm.createQuery("select distinct O.contract_id,O.plan_date,O.id,ca.ACC_NUMBER,ca.ACCOUNT,ca.BANK_NAME,ca.ACCOUNT_PROVINCE,ca.BANK_DEPOSIT,O.rent from O , jbo.app.tenwa.customer.CUSTOMER_ACCOUNT ca where ca.customerid=O.customer_id and O.contract_id=ca.contract_id and ca.acc_info = 'Debit' and O.id in ("+parms.toString()+")").getResultList(false);
+ for (BizObject bo : bolist) {
+ List codelist = JBOFactory.getFactory().getBizObjectManager(CODE_LIBRARY.CLASS_NAME).createQuery("O.codeno = 'bankType' and O.itemdescribe is not null ").getResultList(false);
+ for (BizObject code : codelist) {
+ String itemname = code.getAttribute("itemname").toString().trim();
+ double itemdescribe = code.getAttribute("itemdescribe").getDouble();
+ if (bo.getAttribute("BANK_NAME") != null && bo.getAttribute("bank_name").toString().indexOf(itemname) !=-1 && Double.parseDouble(bo.getAttribute("rent").toString()) > itemdescribe) {
+ BigDecimal m = new BigDecimal(bo.getAttribute("rent").toString());
+ int rent = m.multiply(new BigDecimal(100)).intValue();
+ BigDecimal mi = new BigDecimal(itemdescribe);
+ long divide = mi.multiply(new BigDecimal(100)).longValue();
+ int k = (int) Math.floor(rent/divide);
+ int l = (int) Math.ceil(rent%divide);
+ int im = 0;
+ for (int k2 = 1; k2 <= k; k2++) {
+ Map map = singleCollectMoeny(tx,bc,bo,itemdescribe+"",k2+"");
+ if ("0000".equals(map.get("RET_CODE"))) {
+ i++;
+ im++;
+ }else{
+ j++;
+ }
+ }
+ if (l != 0) {
+ String surprent = String.valueOf(new DecimalFormat("#.00").format(bo.getAttribute("rent").getDouble() - k*itemdescribe));
+ String hire_list = (k+1)+"";
+ Map map = singleCollectMoeny(tx,bc,bo,surprent,hire_list);
+ if ("0000".equals(map.get("RET_CODE"))) {
+ i++;
+ im++;
+ }else{
+ j++;
+ }
+ }
+ if(im > 1 && ((l != 0 && im != (k+1))||(l == 0 && im != k))){
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS where O.id=:id")
+ .setParameter("COLLECT_STATUS", "部分收款")
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }
+ }else {
+ Map map = singleCollectMoeny(tx,bc,bo,bo.getAttribute("rent").toString(),"1");
+ if ("0000".equals(map.get("RET_CODE"))) {
+ i++;
+ }else{
+ j++;
+ }
+ }
+ }
+ /*if (bo.getAttribute("BANK_NAME") != null && bo.getAttribute("bank_name").toString().indexOf("建设银行") !=-1 && Double.parseDouble(bo.getAttribute("rent").toString()) > 5000) {
+ BigDecimal m = new BigDecimal(bo.getAttribute("rent").toString());
+ int rent = m.multiply(new BigDecimal(100)).intValue();
+ int k = (int) Math.floor(rent/500000);
+ int l = (int) Math.ceil(rent%500000);
+ int im = 0;
+ for (int k2 = 1; k2 <= k; k2++) {
+ Map map = singleCollectMoeny(tx,bc,bo,"5000.00",k2+"");
+ if ("0000".equals(map.get("RET_CODE"))) {
+ i++;
+ im++;
+ }else{
+ j++;
+ }
+ }
+ if (l != 0) {
+ String surprent = String.valueOf(new DecimalFormat("#.00").format(bo.getAttribute("rent").getDouble() - k*5000));
+ String hire_list = (k+1)+"";
+ Map map = singleCollectMoeny(tx,bc,bo,surprent,hire_list);
+ if ("0000".equals(map.get("RET_CODE"))) {
+ i++;
+ im++;
+ }else{
+ j++;
+ }
+ }
+ if(im > 1 && ((l != 0 && im != (k+1))||(l == 0 && im != k))){
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS where O.id=:id")
+ .setParameter("COLLECT_STATUS", "部分收款")
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }
+ }else {
+ Map map = singleCollectMoeny(tx,bc,bo,bo.getAttribute("rent").toString(),"1");
+ if ("0000".equals(map.get("RET_CODE"))) {
+ i++;
+ }else{
+ j++;
+ }
+ }*/
+ }
+
+ return "总共有 "+i+" 笔租金收款成功\n"+j+" 笔租金收款失败";
+ }
+
+ /**
+ * 接口代付
+ * @param tx
+ * @param bc
+ * @param bo
+ * @param rent
+ * @return
+ * @throws Exception
+ */
+ public Map singleCollectMoeny(JBOTransaction tx,BizObjectManager bc,BizObject bo,String rent,String hire_list) throws Exception{
+ CollectAuditProcess cp = new CollectAuditProcess();
+ //创建文件名称
+ String currentDateTime = DateAssistant.getTodayNow();
+ String currentYear = currentDateTime.substring(0,4);
+ String month = currentDateTime.substring(5,7);
+ String day = currentDateTime.substring(8,10);
+ String merchantNumber = InitCollectConfig.MERCHANTID;
+ String flag = InitCollectConfig.FLAG;
+ String version = InitCollectConfig.C_VERSION;
+ String date = currentYear+month+day;//提交日期
+ String batch_title = "";
+ int i = 0,j = 0;
+ //创建文件路径
+ String rootDir = this.fileSavePath;
+ File file = new File(rootDir + File.separator + currentYear
+ + File.separator + month + File.separator
+ + day);
+ System.out.println(file.getAbsolutePath());
+ if(!file.exists()){//目录不存在则直接创建
+ file.mkdirs();
+ }
+ String req_sn = System.currentTimeMillis()+"";//当日批次号
+ batch_title = merchantNumber+"_"+flag+version+date+"_"+req_sn;
+ BigDecimal m = new BigDecimal(rent);
+ String fact_rent = String.valueOf(m.multiply(new BigDecimal(100)).intValue());
+ String acc_number = bo.getAttribute("ACC_NUMBER").toString();
+ String account = bo.getAttribute("ACCOUNT").toString();
+ String bank_code = bo.getAttribute("BANK_DEPOSIT").toString();
+ String province = bo.getAttribute("ACCOUNT_PROVINCE").toString();
+ StringBuffer strbuff = collectTimely(fact_rent, acc_number, account,bank_code,province, req_sn);
+ //响应报文
+ String strResp = cp.CollectAuditPayReq(strbuff,file.getAbsolutePath(), batch_title);
+ Map map = getRetAndCode(strResp);
+ if ("0000".equals(map.get("RET_CODE"))) {
+ i++;
+ }else{
+ j++;
+ }
+ if (map.containsKey("RET_CODE") && "0000".equals(map.get("RET_CODE"))) {
+ String cerrentDate = DateAssistant.getToday();
+ JBOTransaction transaction = JBOFactory.createJBOTransaction();
+ BizObjectManager bmi = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,transaction);
+ BizObject boi = bmi.createQuery("select v.sys_guid() as v.id,O.QUOT_ID as v.QUOT_ID,O.CUST_ID as v.CUST_ID,O.PROJECT_ID as v.PROJECT_ID,O.PROJECT_PLAN_NUMBER as v.PROJECT_PLAN_NUMBER,"
+ + "O.CONTRACT_ID as v.CONTRACT_ID,O.CONTRACT_PLAN_NUMBER as v.CONTRACT_PLAN_NUMBER,O.PAYMENT_NUMBER as v.PAYMENT_NUMBER,'' as v.EBANK_NUMBER,O.id as v.PLAN_ID,O.PLAN_LIST as v.PLAN_LIST,"
+ + "'0' as v.INTEREST_ADJUST,'settlemethod6' as v.SETTLE_METHOD,'"+hire_list+"' as v.HIRE_LIST,'"+cerrentDate+"' as v.HIRE_DATE,'"+rent+"' as v.RENT,case when ("+rent+" - vl.interest_over) > 0 then ("+rent+" - vl.interest_over) else 0 end as v.CORPUS,case when ("+rent+" - vl.interest_over) > 0 then (vl.interest_over) else "+rent+" end as v.INTEREST,vl.penalty_over as v.PENALTY,"
+ + "'0' as v.CORPUS_ADJUST,'0' as v.PENALTY_ADJUST,'0' as v.ROLL_BACK,O.COIN as v.COIN from O, jbo.app.tenwa.calc.VI_LC_RENT_PLAN vl where O.id = vl.id"
+ + " and vl.contract_id =:contract_id and vl.plan_date =:plan_date")
+ .setParameter("contract_id", bo.getAttribute("contract_id").toString())
+ .setParameter("plan_date", bo.getAttribute("plan_date").toString()).getSingleResult(false);
+ if (boi != null) {
+ //插入数据
+ String sql = "insert into LC_RENT_INCOME (ID, QUOT_ID, CUST_ID, PROJECT_ID, PROJECT_PLAN_NUMBER, CONTRACT_ID, CONTRACT_PLAN_NUMBER, PAYMENT_NUMBER,EBANK_NUMBER,PLAN_ID, PLAN_LIST,"
+ + " INTEREST_ADJUST,SETTLE_METHOD,HIRE_LIST,HIRE_DATE, RENT,CORPUS,INTEREST,PENALTY,CORPUS_ADJUST,PENALTY_ADJUST,ROLL_BACK,COIN)"
+ + "values ('"+boi.getAttribute("id")+"','"+boi.getAttribute("QUOT_ID")+"','"+boi.getAttribute("CUST_ID")+"','"+boi.getAttribute("PROJECT_ID")+"','"+boi.getAttribute("PROJECT_PLAN_NUMBER")+"',"
+ + "'"+boi.getAttribute("CONTRACT_ID")+"','"+boi.getAttribute("CONTRACT_PLAN_NUMBER")+"','"+boi.getAttribute("PAYMENT_NUMBER")+"','"+boi.getAttribute("EBANK_NUMBER")+"','"+boi.getAttribute("PLAN_ID")+"',"
+ + "'"+boi.getAttribute("PLAN_LIST")+"','"+boi.getAttribute("INTEREST_ADJUST")+"','"+boi.getAttribute("SETTLE_METHOD")+"','"+boi.getAttribute("HIRE_LIST")+"','"+boi.getAttribute("HIRE_DATE")+"','"+boi.getAttribute("RENT")+"','"+boi.getAttribute("CORPUS")+"',"
+ + "'"+boi.getAttribute("INTEREST")+"','"+boi.getAttribute("PENALTY")+"','"+boi.getAttribute("CORPUS_ADJUST")+"','"+boi.getAttribute("PENALTY_ADJUST")+"','"+boi.getAttribute("ROLL_BACK")+"','"+boi.getAttribute("COIN")+"')";
+ Transaction Sqlca =null;
+ Sqlca = Transaction.createTransaction(transaction);
+ SqlObject asql = new SqlObject(sql);
+ Sqlca.executeSQL(asql);
+ }
+ transaction.commit();
+ }
+ BizObject bco = bc.createQuery("id=:id").setParameter("id", bo.getAttribute("id").toString()).getSingleResult(false);
+ String batch_number = bco.getAttribute("batch_number").toString();
+ if ("0000".equals(map.get("RET_CODE"))){
+ if (batch_number.length() == 0) {
+ batch_number += "交易成功流水为:"+req_sn;
+ }else{
+ batch_number += ";交易成功流水为:"+req_sn;
+ }
+ }else{
+ if (batch_number.length() == 0) {
+ batch_number += "交易失败流水为:"+req_sn;
+ }else{
+ batch_number += ";交易失败流水为:"+req_sn;
+ }
+ }
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG,O.BATCH_NUMBER=:BATCH_NUMBER where O.id=:id")
+ .setParameter("COLLECT_STATUS", "0000".equals(map.get("RET_CODE")) ? "收款成功" : "未收款")
+ .setParameter("COLLECT_MSG", map.get("ERR_MSG"))
+ .setParameter("BATCH_NUMBER", batch_number)
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ //生成存盘、回盘文件
+ savaFile(tx, strResp,batch_title,bo);
+
+ return map;
+ }
+
+ /**
+ * 手动回笼租金
+ * @param tx
+ * @param bc
+ * @param bo
+ * @param rent
+ * @return
+ * @throws Exception
+ */
+ public Map handcraftsingleCollectMoeny(JBOTransaction tx,BizObjectManager bc,BizObject bo,String rent,String hire_list) throws Exception{
+ String cerrentDate = DateAssistant.getToday();//获取当前日期,格式为:yyyy/MM/dd
+ Map map = new HashMap();
+ JBOTransaction transaction = JBOFactory.createJBOTransaction();
+ BizObjectManager bmi = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,transaction);
+ BizObject boi = bmi.createQuery("select v.sys_guid() as v.id,O.QUOT_ID as v.QUOT_ID,O.CUST_ID as v.CUST_ID,O.PROJECT_ID as v.PROJECT_ID,O.PROJECT_PLAN_NUMBER as v.PROJECT_PLAN_NUMBER,"
+ + "O.CONTRACT_ID as v.CONTRACT_ID,O.CONTRACT_PLAN_NUMBER as v.CONTRACT_PLAN_NUMBER,O.PAYMENT_NUMBER as v.PAYMENT_NUMBER,'' as v.EBANK_NUMBER,O.id as v.PLAN_ID,O.PLAN_LIST as v.PLAN_LIST,"
+ + "'0' as v.INTEREST_ADJUST,'settlemethod6' as v.SETTLE_METHOD,'"+hire_list+"' as v.HIRE_LIST,'"+cerrentDate+"' as v.HIRE_DATE,'"+rent+"' as v.RENT,("+rent+"-vl.interest_over) as v.CORPUS,vl.interest_over as v.INTEREST,vl.penalty_over as v.PENALTY,"
+ + "'0' as v.CORPUS_ADJUST,'0' as v.PENALTY_ADJUST,'0' as v.ROLL_BACK,O.COIN as v.COIN from O, jbo.app.tenwa.calc.VI_LC_RENT_PLAN vl where O.id = vl.id"
+ + " and vl.contract_id =:contract_id and vl.plan_date =:plan_date")
+ .setParameter("contract_id", bo.getAttribute("contract_id").toString())
+ .setParameter("plan_date", bo.getAttribute("plan_date").toString()).getSingleResult(false);
+ if (boi != null) {
+ //插入数据
+ String sql = "insert into LC_RENT_INCOME (ID, QUOT_ID, CUST_ID, PROJECT_ID, PROJECT_PLAN_NUMBER, CONTRACT_ID, CONTRACT_PLAN_NUMBER, PAYMENT_NUMBER,EBANK_NUMBER,PLAN_ID, PLAN_LIST,"
+ + " INTEREST_ADJUST,SETTLE_METHOD,HIRE_LIST,HIRE_DATE, RENT,CORPUS,INTEREST,PENALTY,CORPUS_ADJUST,PENALTY_ADJUST,ROLL_BACK,COIN)"
+ + "values ('"+boi.getAttribute("id")+"','"+boi.getAttribute("QUOT_ID")+"','"+boi.getAttribute("CUST_ID")+"','"+boi.getAttribute("PROJECT_ID")+"','"+boi.getAttribute("PROJECT_PLAN_NUMBER")+"',"
+ + "'"+boi.getAttribute("CONTRACT_ID")+"','"+boi.getAttribute("CONTRACT_PLAN_NUMBER")+"','"+boi.getAttribute("PAYMENT_NUMBER")+"','"+boi.getAttribute("EBANK_NUMBER")+"','"+boi.getAttribute("PLAN_ID")+"',"
+ + "'"+boi.getAttribute("PLAN_LIST")+"','"+boi.getAttribute("INTEREST_ADJUST")+"','"+boi.getAttribute("SETTLE_METHOD")+"','"+boi.getAttribute("HIRE_LIST")+"','"+boi.getAttribute("HIRE_DATE")+"','"+boi.getAttribute("RENT")+"','"+boi.getAttribute("CORPUS")+"',"
+ + "'"+boi.getAttribute("INTEREST")+"','"+boi.getAttribute("PENALTY")+"','"+boi.getAttribute("CORPUS_ADJUST")+"','"+boi.getAttribute("PENALTY_ADJUST")+"','"+boi.getAttribute("ROLL_BACK")+"','"+boi.getAttribute("COIN")+"')";
+ Transaction Sqlca =null;
+ Sqlca = Transaction.createTransaction(transaction);
+ SqlObject asql = new SqlObject(sql);
+ Sqlca.executeSQL(asql);
+ }
+ transaction.commit();
+ BizObject bco = bc.createQuery("id=:id").setParameter("id", bo.getAttribute("id").toString()).getSingleResult(false);
+ String batch_number = bco.getAttribute("batch_number").toString();
+ if (batch_number.length() == 0) {
+ batch_number += "手工付款金额:"+rent;
+ }else{
+ batch_number += ";手工付款金额:"+rent;
+ }
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG,O.BATCH_NUMBER=:BATCH_NUMBER where O.id=:id")
+ .setParameter("COLLECT_STATUS", "收款成功")
+ .setParameter("COLLECT_MSG", map.get("ERR_MSG"))
+ .setParameter("BATCH_NUMBER", batch_number)
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ map.put("RET_CODE", "0000");
+ return map;
+ }
+ /**
+ * 手动收款修改状态,回笼租金
+ * @param tx
+ * @return
+ * @throws Exception
+ */
+ public String afterCollectManage(JBOTransaction tx) throws Exception{
+ int i = 0,j = 0;
+ String[] ids = id.split("@");
+ StringBuffer parms = new StringBuffer();
+ for (String str : ids) {
+ if (parms.length()==0) {
+ parms.append("'"+str+"'");
+ }else{
+ parms.append(",'"+str+"'");
+ }
+ }
+ BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
+ BizObjectManager bc = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
+ List bolist = bm.createQuery("select distinct O.contract_id,O.plan_date,O.id,ca.ACC_NUMBER,ca.ACCOUNT,O.rent from O , jbo.app.tenwa.customer.CUSTOMER_ACCOUNT ca where ca.customerid=O.customer_id and O.contract_id=ca.contract_id and ca.acc_info = 'Debit' and O.id in ("+parms.toString()+")").getResultList(false);
+ for (BizObject bo : bolist) {
+ Map map = handcraftsingleCollectMoeny(tx,bc,bo,bo.getAttribute("rent").toString(),"1");
+ i++;
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG where O.id=:id")
+ .setParameter("COLLECT_STATUS", "手工收款")
+ .setParameter("COLLECT_MSG", "手工扣款")
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+
+ }
+
+ return "总共有 "+i+" 笔租金收款成功\n"+j+" 笔租金收款失败";
+ }
+ /**
+ * 实时代收
+ * @param rent 租金
+ * @param acc_number 银行卡号
+ * @param account 开户名
+ * @param bankcode 银行代码
+ * @param province 银行卡所属省份
+ * @param req_sn 请求流水号
+ * @return
+ */
+ public StringBuffer collectTimely(String rent,String acc_number,String account,String bankcode,String province,String req_sn){
+ //拼接XML报文
+ String req = System.currentTimeMillis()+"";
+ StringBuffer strbuff = new StringBuffer();
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ Info info = new Info();
+ info.setTRX_CODE(InitCollectConfig.C_TRXCODE);
+ info.setVERSION(InitCollectConfig.C_VERSION);
+ info.setDATA_TYPE(InitCollectConfig.C_DATATYPE);
+ info.setLEVEL(InitCollectConfig.C_LEVEL);
+ info.setUSER_NAME(InitCollectConfig.USERNAME);
+ info.setUSER_PASS(InitCollectConfig.USERPASS);
+ info.setREQ_SN(req_sn);
+ info.setSIGNED_MSG("");
+ strbuff.append(EntityTransform.toXml(info));
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ Trans_Sum trans_sum = new Trans_Sum();
+ trans_sum.setBUSINESS_CODE(InitCollectConfig.BUSSINESSCODE);
+ trans_sum.setMERCHANT_ID(InitCollectConfig.MERCHANTID);
+ trans_sum.setEXPECT_SEND_TIME("");
+ trans_sum.setTOTAL_ITEM("1");
+ trans_sum.setTOTAL_SUM(rent);
+ strbuff.append(EntityTransform.toXml(trans_sum));
+ strbuff.append("");
+ strbuff.append("");
+ Trans_Detail trans_detail = new Trans_Detail();
+ trans_detail.setSN("0001");
+ trans_detail.setBANK_CODE(bankcode);//银行代码
+ trans_detail.setACCOUNT_TYPE("00");
+ trans_detail.setACCOUNT_NO(acc_number);
+ trans_detail.setACCOUNT_NAME(account);
+ trans_detail.setPROVINCE(province);//银行卡所属省份
+ trans_detail.setACCOUNT_PROP("0");
+ trans_detail.setAMOUNT(rent);
+ trans_detail.setCURRENCY("CNY");
+ trans_detail.setRECKON_ACCOUNT("");
+ strbuff.append(EntityTransform.toXmlByLotCollect(trans_detail));
+ strbuff.delete(strbuff.lastIndexOf(""), strbuff.length());
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+
+ return strbuff;
+ }
+
+ /**
+ * 批量代收-发送请求
+ * @param tx
+ * @return
+ * @throws Exception
+ */
+ public String batchCollectManage(JBOTransaction tx) throws Exception{
+ int i = 0,j = 0;
+ String[] ids = id.split("@");
+ StringBuffer parms = new StringBuffer();
+ for (String str : ids) {
+ if (parms.length()==0) {
+ parms.append("'"+str+"'");
+ }else{
+ parms.append(",'"+str+"'");
+ }
+ }
+ BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
+ BizObjectManager bc = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
+ List bolist = bm.createQuery("select distinct O.contract_id,O.plan_date,O.id,ca.ACC_NUMBER,ca.ACCOUNT,ca.ACCOUNT_PROVINCE,ca.BANK_DEPOSIT,ca.BANK_NAME,O.rent from O , jbo.app.tenwa.customer.CUSTOMER_ACCOUNT ca where ca.customerid=O.customer_id and O.contract_id=ca.contract_id and ca.acc_info = 'Debit' and O.id in ("+parms.toString()+")").getResultList(false);
+ if (bolist.size() != 0) {
+ singleBatchCollectMoeny(tx, bolist);
+ }
+ return "系统正在处理中，请稍后";
+ }
+
+ /**
+ * 查询批量收款状态
+ * @return
+ * @throws Exception
+ */
+ public String queryBatchCollectStatus(JBOTransaction tx,StringBuffer parms) throws Exception{
+ BizObjectManager bm = JBOFactory.getFactory().getManager(VI_LC_AUDIT_RENT_PLAN.CLASS_NAME);
+ BizObjectManager bc = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME);
+ List bolist = bm.createQuery("select distinct O.BATCH_NO,O.BATCH_SN,O.contract_id,O.plan_date,O.id,ca.ACC_NUMBER,ca.ACCOUNT,ca.ACCOUNT_PROVINCE,ca.BANK_DEPOSIT,ca.BANK_NAME,O.rent from O , jbo.app.tenwa.customer.CUSTOMER_ACCOUNT ca where ca.customerid=O.customer_id and O.contract_id=ca.contract_id and ca.acc_info = 'Debit' and O.id in ("+parms.toString()+")").getResultList(false);
+ for (BizObject bo : bolist) {
+ String query_sn = bo.getAttribute("BATCH_NO").toString();
+ String sn = bo.getAttribute("BATCH_SN").toString();
+ String rent = bo.getAttribute("rent").toString();
+ String bank_name = bo.getAttribute("BANK_NAME").toString();
+ int m = 0;
+ String[] singleRent = null;
+ List codelist = JBOFactory.getFactory().getBizObjectManager(CODE_LIBRARY.CLASS_NAME).createQuery("O.codeno = 'bankType' and O.itemdescribe is not null ").getResultList(false);
+ for (BizObject code : codelist) {
+ String itemname = code.getAttribute("itemname").toString().trim();
+ double itemdescribe = code.getAttribute("itemdescribe").getDouble();
+ if (bank_name.indexOf(itemname) !=-1 && Double.parseDouble(bo.getAttribute("rent").toString()) > itemdescribe) {
+ BigDecimal mi = new BigDecimal(bo.getAttribute("rent").toString());
+ int singlerent = mi.multiply(new BigDecimal(100)).intValue();
+ BigDecimal mj = new BigDecimal(itemdescribe);
+ long divide = mj.multiply(new BigDecimal(100)).longValue();
+ int k = (int) Math.floor(singlerent/divide);
+ int l = (int) Math.ceil(singlerent%divide);
+ for (int j = 0; j < k; j++) {
+ m++;
+ }
+ if (l!=0) {
+ m++;
+ }
+ singleRent = new String[m];
+ for (int i = 0; i < k; i++) {
+ singleRent[i] = itemdescribe+"";
+ }
+ singleRent[m-1] = String.format("%.2f",bo.getAttribute("rent").getDouble() - k*itemdescribe);
+ break;//如果匹配到，则跳出循环
+ }
+ }
+ String[] snArray = sn.split(",");
+ int n = 0;//拆分租金,扣款成功记录
+ for (int i = 1; i <= snArray.length; i++) {
+ Map map = querySingleBatchCollect(tx, bo, query_sn, snArray[(i-1)]);
+ if (snArray.length == 1) {
+ if (map.containsKey("RET_CODE") && "0000".equals(map.get("RET_CODE"))) {
+ querysingleCollectMoeny(tx, bc, bo, rent,i+"");
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG,O.BATCH_STATUS=:BATCH_STATUS where O.id=:id")
+ .setParameter("COLLECT_STATUS", "批量收款")
+ .setParameter("COLLECT_MSG", "批量代收,收款成功")
+ .setParameter("BATCH_STATUS", "complete")//更新批量处理状态-完成
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }else if (map.containsKey("RET_CODE") && ("2007".equals(map.get("RET_CODE")) || "2005".equals(map.get("RET_CODE")) || "2003".equals(map.get("RET_CODE")) || "2001".equals(map.get("RET_CODE")) || "2000".equals(map.get("RET_CODE")))){
+ //更新银联处理中的反馈信息
+ bc.createQuery("update O set O.COLLECT_MSG=:COLLECT_MSG where O.id=:id")
+ .setParameter("COLLECT_MSG", map.get("ERR_MSG"))
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }else{
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG,O.BATCH_STATUS=:BATCH_STATUS,O.BATCH_NO='',O.BATCH_SN='' where O.id=:id")
+ .setParameter("COLLECT_STATUS", "未收款")
+ .setParameter("COLLECT_MSG", map.get("ERR_MSG"))
+ .setParameter("BATCH_STATUS", "")//清空批量处理状态
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }
+ }else if (snArray.length > 1) {
+ if (map.containsKey("RET_CODE") && "0000".equals(map.get("RET_CODE"))) {
+ querysingleCollectMoeny(tx, bc, bo, singleRent[i-1],i+"");
+ n++;
+ if (n == snArray.length) {
+ n = 0;//将扣款成功项 置为 0
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG,O.BATCH_STATUS=:BATCH_STATUS where O.id=:id")
+ .setParameter("COLLECT_STATUS", "批量收款")
+ .setParameter("COLLECT_MSG", "批量代收,收款成功")
+ .setParameter("BATCH_STATUS", "complete")//更新批量处理状态-完成
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }else{
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG,O.BATCH_STATUS=:BATCH_STATUS where O.id=:id")
+ .setParameter("COLLECT_STATUS", "部分收款")
+ .setParameter("COLLECT_MSG", map.get("ERR_MSG"))
+ .setParameter("BATCH_STATUS", "complete")//清空批量处理状态-完成
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }
+ }else if (map.containsKey("RET_CODE") && ("2007".equals(map.get("RET_CODE")) || "2005".equals(map.get("RET_CODE")) || "2003".equals(map.get("RET_CODE")) || "2001".equals(map.get("RET_CODE")) || "2000".equals(map.get("RET_CODE")))){
+ //更新银联处理中的反馈信息
+ bc.createQuery("update O set O.COLLECT_MSG=:COLLECT_MSG where O.id=:id")
+ .setParameter("COLLECT_MSG", map.get("ERR_MSG"))
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }else{//批量拆分多笔扣款,如果扣款成功条数未 0 ,则更新扣款状态为 未扣款
+ if (i == snArray.length && n == 0) {
+ //更新收付状态
+ bc.createQuery("update O set O.COLLECT_STATUS=:COLLECT_STATUS ,O.COLLECT_MSG=:COLLECT_MSG,O.BATCH_STATUS=:BATCH_STATUS,O.BATCH_NO='',O.BATCH_SN='' where O.id=:id")
+ .setParameter("COLLECT_STATUS", "未收款")
+ .setParameter("COLLECT_MSG", map.get("ERR_MSG"))
+ .setParameter("BATCH_STATUS", "")//清空批量处理状态
+ .setParameter("id", bo.getAttribute("id").toString()).executeUpdate();
+ }
+ }
+ }
+ if (i == snArray.length) {//循环结束，将n置为 0
+ n = 0;
+ }
+ }
+ }
+
+ return "sucess";
+
+ }
+ /**
+ * 批量代收查询接口
+ * @param tx
+ * @param bo
+ * @param list
+ * @return
+ * @throws Exception
+ */
+ public Map querySingleBatchCollect(JBOTransaction tx,BizObject bo,String query_sn,String sn) throws Exception{
+ CollectAuditProcess cp = new CollectAuditProcess();
+ //创建文件名称
+ String currentDateTime = DateAssistant.getTodayNow();
+ String currentYear = currentDateTime.substring(0,4);
+ String month = currentDateTime.substring(5,7);
+ String day = currentDateTime.substring(8,10);
+ String merchantNumber = InitCollectConfig.MERCHANTID;
+ String flag = InitCollectConfig.FLAG;
+ String version = InitCollectConfig.C_VERSION;
+ String date = currentYear+month+day;//提交日期
+ String batch_title = "";
+ int i = 0,j = 0;
+ //创建文件路径
+ String rootDir = this.fileSavePath;
+ File file = new File(rootDir + File.separator + currentYear
+ + File.separator + month + File.separator
+ + day);
+ System.out.println(file.getAbsolutePath());
+ if(!file.exists()){//目录不存在则直接创建
+ file.mkdirs();
+ }
+ String req_sn = System.currentTimeMillis()+"";//当日批次号
+ batch_title = merchantNumber+"_"+flag+version+date+"_"+req_sn;
+ StringBuffer strbuff = queryBatchXML(req_sn, query_sn, sn);
+ //响应报文
+ String strResp = cp.CollectAuditPayReq(strbuff,file.getAbsolutePath(), batch_title);
+ Map map = getRetAndCode(strResp);
+ //生成存盘、回盘文件
+ savaFile(tx, strResp,batch_title,bo);
+
+ return map;
+ }
+ /**
+ * 批量查询接口--回笼租金
+ * @param tx
+ * @param bc
+ * @param bo
+ * @param rent
+ * @return
+ * @throws Exception
+ */
+ public Map querysingleCollectMoeny(JBOTransaction tx,BizObjectManager bc,BizObject bo,String rent,String hire_list) throws Exception{
+ String cerrentDate = DateAssistant.getToday();
+ Map map = new HashMap();
+ JBOTransaction transaction = JBOFactory.createJBOTransaction();
+ BizObjectManager bmi = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,transaction);
+ BizObject boi = bmi.createQuery("select v.sys_guid() as v.id,O.QUOT_ID as v.QUOT_ID,O.CUST_ID as v.CUST_ID,O.PROJECT_ID as v.PROJECT_ID,O.PROJECT_PLAN_NUMBER as v.PROJECT_PLAN_NUMBER,"
+ + "O.CONTRACT_ID as v.CONTRACT_ID,O.CONTRACT_PLAN_NUMBER as v.CONTRACT_PLAN_NUMBER,O.PAYMENT_NUMBER as v.PAYMENT_NUMBER,'' as v.EBANK_NUMBER,O.id as v.PLAN_ID,O.PLAN_LIST as v.PLAN_LIST,"
+ + "'0' as v.INTEREST_ADJUST,'settlemethod6' as v.SETTLE_METHOD,'"+hire_list+"' as v.HIRE_LIST,'"+cerrentDate+"' as v.HIRE_DATE,'"+rent+"' as v.RENT,case when ("+rent+" - vl.interest_over) > 0 then ("+rent+" - vl.interest_over) else 0 end as v.CORPUS,case when ("+rent+" - vl.interest_over) > 0 then (vl.interest_over) else "+rent+" end as v.INTEREST,vl.penalty_over as v.PENALTY,"
+ + "'0' as v.CORPUS_ADJUST,'0' as v.PENALTY_ADJUST,'0' as v.ROLL_BACK,O.COIN as v.COIN from O, jbo.app.tenwa.calc.VI_LC_RENT_PLAN vl where O.id = vl.id"
+ + " and vl.contract_id =:contract_id and vl.plan_date =:plan_date")
+ .setParameter("contract_id", bo.getAttribute("contract_id").toString())
+ .setParameter("plan_date", bo.getAttribute("plan_date").toString()).getSingleResult(false);
+ if (boi != null) {
+ //插入数据
+ String sql = "insert into LC_RENT_INCOME (ID, QUOT_ID, CUST_ID, PROJECT_ID, PROJECT_PLAN_NUMBER, CONTRACT_ID, CONTRACT_PLAN_NUMBER, PAYMENT_NUMBER,EBANK_NUMBER,PLAN_ID, PLAN_LIST,"
+ + " INTEREST_ADJUST,SETTLE_METHOD,HIRE_LIST,HIRE_DATE, RENT,CORPUS,INTEREST,PENALTY,CORPUS_ADJUST,PENALTY_ADJUST,ROLL_BACK,COIN)"
+ + "values ('"+boi.getAttribute("id")+"','"+boi.getAttribute("QUOT_ID")+"','"+boi.getAttribute("CUST_ID")+"','"+boi.getAttribute("PROJECT_ID")+"','"+boi.getAttribute("PROJECT_PLAN_NUMBER")+"',"
+ + "'"+boi.getAttribute("CONTRACT_ID")+"','"+boi.getAttribute("CONTRACT_PLAN_NUMBER")+"','"+boi.getAttribute("PAYMENT_NUMBER")+"','"+boi.getAttribute("EBANK_NUMBER")+"','"+boi.getAttribute("PLAN_ID")+"',"
+ + "'"+boi.getAttribute("PLAN_LIST")+"','"+boi.getAttribute("INTEREST_ADJUST")+"','"+boi.getAttribute("SETTLE_METHOD")+"','"+boi.getAttribute("HIRE_LIST")+"','"+boi.getAttribute("HIRE_DATE")+"','"+boi.getAttribute("RENT")+"','"+boi.getAttribute("CORPUS")+"',"
+ + "'"+boi.getAttribute("INTEREST")+"','"+boi.getAttribute("PENALTY")+"','"+boi.getAttribute("CORPUS_ADJUST")+"','"+boi.getAttribute("PENALTY_ADJUST")+"','"+boi.getAttribute("ROLL_BACK")+"','"+boi.getAttribute("COIN")+"')";
+ Transaction Sqlca =null;
+ Sqlca = Transaction.createTransaction(transaction);
+ SqlObject asql = new SqlObject(sql);
+ Sqlca.executeSQL(asql);
+ }
+ transaction.commit();
+ return map;
+ }
+ /**
+ * 批量查询接口报文-xml
+ * @param req_sn 请求流水号
+ * @param query_sn 查询流水号
+ * @param sn 查询明细项
+ * @return
+ */
+ public StringBuffer queryBatchXML(String req_sn,String query_sn,String sn){
+ StringBuffer strbuff = new StringBuffer();
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ Info info = new Info();
+ info.setTRX_CODE("200001");
+ info.setVERSION(InitCollectConfig.C_VERSION);
+ info.setDATA_TYPE(InitCollectConfig.C_DATATYPE);
+ info.setREQ_SN(req_sn);
+ info.setUSER_NAME(InitCollectConfig.USERNAME);
+ info.setUSER_PASS(InitCollectConfig.USERPASS);
+ info.setSIGNED_MSG("");
+ strbuff.append(EntityTransform.toXml(info));
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append(query_sn);//要查询的交易流水
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append(sn);//交易明细号
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ return strbuff;
+ }
+ /**
+ * 批量代收-发送请求
+ * @param tx
+ * @param bc
+ * @param bo
+ * @param rent
+ * @return
+ * @throws Exception
+ */
+ public Map singleBatchCollectMoeny(JBOTransaction tx,List list) throws Exception{
+ CollectAuditProcess cp = new CollectAuditProcess();
+ //创建文件名称
+ String currentDateTime = DateAssistant.getTodayNow();
+ String currentYear = currentDateTime.substring(0,4);
+ String month = currentDateTime.substring(5,7);
+ String day = currentDateTime.substring(8,10);
+ String merchantNumber = InitCollectConfig.MERCHANTID;
+ String flag = InitCollectConfig.FLAG;
+ String version = InitCollectConfig.C_VERSION;
+ String date = currentYear+month+day;//提交日期
+ String batch_title = "";
+ int i = 0,j = 0;
+ //创建文件路径
+ String rootDir = this.fileSavePath;
+ File file = new File(rootDir + File.separator + currentYear
+ + File.separator + month + File.separator
+ + day);
+ System.out.println(file.getAbsolutePath());
+ if(!file.exists()){//目录不存在则直接创建
+ file.mkdirs();
+ }
+ String req_sn = System.currentTimeMillis()+"";//当日批次号
+ batch_title = merchantNumber+"_"+flag+version+date+"_"+req_sn;
+ StringBuffer strbuff = collectBatch(req_sn,list);
+ //响应报文
+ String strResp = cp.CollectAuditPayReq(strbuff,file.getAbsolutePath(), batch_title);
+ for (BizObject bo : list) {
+ //生成存盘、回盘文件
+ savaFile(tx, strResp,batch_title,bo);
+ }
+ Map map = getRetAndCodeByBatch(strResp);
+ if (map.containsKey("RET_CODE")) {//清空批量代收状态
+ for (BizObject biz : list) {
+ //清空批量处理状态
+ JBOTransaction trans = JBOFactory.createJBOTransaction();
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,trans);
+ bm.createQuery("update O set O.BATCH_STATUS=:BATCH_STATUS,O.BATCH_NO=:BATCH_NO,O.BATCH_SN=:BATCH_SN where O.id=:id")
+ .setParameter("BATCH_STATUS", "")//处理中
+ .setParameter("BATCH_NO", "")
+ .setParameter("BATCH_SN", "")
+ .setParameter("id", biz.getAttribute("id").toString()).executeUpdate();
+ trans.commit();
+ }
+ }else{
+ int m = 0;//统计发送的代收的批数
+ for (int n = 1; n <= map.size(); n++) {
+ if (map.containsKey("SN"+n)) {
+ m++;
+ }
+ }
+ for (int k = 1; k <= m; k++) {
+ if (map.containsKey("REQ_SN") && map.containsKey("RET_CODE"+k) && "0000".equals(map.get("RET_CODE"+k))) {
+ JBOTransaction trans = JBOFactory.createJBOTransaction();
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,trans);
+ BizObject bo0 = bm.createQuery("O.BATCH_NO=:BATCH_NO and O.BATCH_SN like '%"+map.get("SN"+k)+"%'").setParameter("BATCH_NO", map.get("REQ_SN")).getSingleResult(false);
+ if (bo0 != null && "process".equals(bo0.getAttribute("BATCH_STATUS"))) {
+ bm.createQuery("update O set O.BATCH_STATUS=:BATCH_STATUS where O.BATCH_NO=:BATCH_NO and O.BATCH_SN like '%"+map.get("SN"+k)+"%' ")
+ .setParameter("BATCH_STATUS", "process")//处理状态标记为--处理中
+ .setParameter("BATCH_NO", map.get("REQ_SN")).executeUpdate();
+ trans.commit();
+ }else{
+ bm.createQuery("update O set O.BATCH_STATUS=:BATCH_STATUS where O.BATCH_NO=:BATCH_NO and O.BATCH_SN like '%"+map.get("SN"+k)+"%' ")
+ .setParameter("BATCH_STATUS", "process")//处理状态标记为--处理中
+ .setParameter("BATCH_NO", map.get("REQ_SN")).executeUpdate();
+ trans.commit();
+ }
+ }else{
+ JBOTransaction trans = JBOFactory.createJBOTransaction();
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,trans);
+ BizObject bo0 = bm.createQuery("O.BATCH_NO=:BATCH_NO and O.BATCH_SN like '%"+map.get("SN"+k)+"%'").setParameter("BATCH_NO", map.get("REQ_SN")).getSingleResult(false);
+ if (bo0 != null && "process".equals(bo0.getAttribute("BATCH_STATUS"))) {
+ //不做任何操作
+ }else{
+ bm.createQuery("update O set O.BATCH_STATUS=:BATCH_STATUS,O.BATCH_NO='',O.BATCH_SN='' where O.BATCH_NO=:BATCH_NO and O.BATCH_SN like '%"+map.get("SN"+k)+"%' ")
+ .setParameter("BATCH_STATUS", "")//清空批量处理状态
+ .setParameter("BATCH_NO", map.get("REQ_SN")).executeUpdate();
+ trans.commit();
+ }
+ }
+ }
+ }
+ return map;
+ }
+
+ /**
+ * 批量代收--报文拼接
+ * @param rent
+ * @param acc_number
+ * @param account
+ * @param req_sn
+ * @return
+ * @throws JBOException
+ */
+ public StringBuffer collectBatch(String req_sn,List list) throws JBOException{
+ //拼接XML报文
+ //String req = System.currentTimeMillis()+"";
+ StringBuffer strbuff = new StringBuffer();
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ Info info = new Info();
+ info.setTRX_CODE(InitCollectConfig.BATCH_TRXCODE);
+ info.setVERSION(InitCollectConfig.C_VERSION);
+ info.setDATA_TYPE(InitCollectConfig.C_DATATYPE);
+ info.setLEVEL(InitCollectConfig.C_LEVEL);
+ info.setUSER_NAME(InitCollectConfig.USERNAME);
+ info.setUSER_PASS(InitCollectConfig.USERPASS);
+ info.setREQ_SN(req_sn);
+ info.setSIGNED_MSG("");
+ strbuff.append(EntityTransform.toXml(info));
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ BigDecimal mutly = new BigDecimal("0");
+ int i = 0;
+ for (BizObject bo : list) {
+ String single = bo.getAttribute("rent").toString();
+ BigDecimal m = new BigDecimal(single);
+ mutly = mutly.add(m);
+ String bank_name = bo.getAttribute("BANK_NAME").toString();
+ List codelist = JBOFactory.getFactory().getBizObjectManager(CODE_LIBRARY.CLASS_NAME).createQuery("O.codeno = 'bankType' and O.itemdescribe is not null ").getResultList(false);
+ double itemdescribe = 0;
+ boolean flag = false;
+ for (BizObject code : codelist) {
+ String itemnameTmp = code.getAttribute("itemname").toString().trim();
+ double itemdescribeTmp = code.getAttribute("itemdescribe").getDouble();
+ String itemdescribeTmp1 = code.getAttribute("itemdescribe").toString();
+ if (bank_name.indexOf(itemnameTmp) != -1 && itemdescribeTmp1 != null && !"".equals(itemdescribeTmp1)) {
+ itemdescribe = new BigDecimal(itemdescribeTmp).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
+ flag = true;
+ break;
+ }
+ }
+
+ if (flag == true && Double.parseDouble(bo.getAttribute("rent").toString()) > itemdescribe) {
+ BigDecimal mi = new BigDecimal(bo.getAttribute("rent").toString());
+ int singlerent = mi.multiply(new BigDecimal(100)).intValue();
+ int singleitem = new BigDecimal(itemdescribe).multiply(new BigDecimal(100)).intValue();
+ int k = (int) Math.floor(singlerent/singleitem);
+ int l = (int) Math.ceil(singlerent%singleitem);
+ for (int j = 0; j < k; j++) {
+ i++;
+ }
+ if (l!=0) {
+ i++;
+ }
+ }else{
+ i++;
+ }
+
+ }
+ String totalSum = String.valueOf(mutly.multiply(new BigDecimal(100)).longValue());
+ String totalItem = String.valueOf(i);
+ Trans_Sum trans_sum = new Trans_Sum();
+ trans_sum.setBUSINESS_CODE(InitCollectConfig.BUSSINESSCODE);
+ trans_sum.setMERCHANT_ID(InitCollectConfig.MERCHANTID);
+ trans_sum.setEXPECT_SEND_TIME("");
+ trans_sum.setTOTAL_ITEM(totalItem);
+ trans_sum.setTOTAL_SUM(totalSum);
+ strbuff.append(EntityTransform.toXml(trans_sum));
+ strbuff.append("");
+ strbuff.append("");
+ int item = 0;
+ for (BizObject biz : list) {
+ BigDecimal m = new BigDecimal(biz.getAttribute("rent").toString());
+ String rent = String.valueOf(m.multiply(new BigDecimal(100)).longValue());
+ String acc_number = biz.getAttribute("acc_number").toString();
+ String account = biz.getAttribute("account").toString();
+ String bank_name = biz.getAttribute("BANK_NAME").toString();
+ String bank_code = biz.getAttribute("BANK_DEPOSIT").toString();
+ String province = biz.getAttribute("ACCOUNT_PROVINCE").toString();
+
+ List codelist = JBOFactory.getFactory().getBizObjectManager(CODE_LIBRARY.CLASS_NAME).createQuery("O.codeno = 'bankType' and O.itemdescribe is not null ").getResultList(false);
+ double itemdescribe = 0;
+ boolean flag = false;
+ for (BizObject code : codelist) {
+ String itemnameTmp = code.getAttribute("itemname").toString().trim();
+ double itemdescribeTmp = code.getAttribute("itemdescribe").getDouble();
+ String itemdescribeTmp1 = code.getAttribute("itemdescribe").toString();
+ if (bank_name.indexOf(itemnameTmp) != -1 && itemdescribeTmp1 != null && !"".equals(itemdescribeTmp1)) {
+ itemdescribe = new BigDecimal(itemdescribeTmp).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
+ flag = true;
+ break;
+ }
+ }
+ if (flag == true && Double.parseDouble(biz.getAttribute("rent").toString()) > itemdescribe) {
+ BigDecimal mi = new BigDecimal(biz.getAttribute("rent").toString());
+ int singlerent = mi.multiply(new BigDecimal(100)).intValue();
+ int singleitem = new BigDecimal(itemdescribe).multiply(new BigDecimal(100)).intValue();
+ int k = (int) Math.floor(singlerent/singleitem);
+ int l = (int) Math.ceil(singlerent%singleitem);
+ for (int k2 = 1; k2 <= k; k2++) {
+ Trans_Detail trans_detail = new Trans_Detail();
+ String sn = "";
+ if (item >= 10) {
+ sn = "000"+ (++item);
+ }else if(item >= 100){
+ sn = "00"+ (++item);
+ }else{
+ sn = "0000"+ (++item);
+ }
+ //追加批量处理状态
+ JBOTransaction trans = JBOFactory.createJBOTransaction();
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,trans);
+ BizObject bo = bm.createQuery("O.id=:id").setParameter("id", biz.getAttribute("id").toString()).getSingleResult(false);
+ String itemsn0 = "";
+ if (bo !=null) {
+ String itemsn = bo.getAttribute("batch_sn").toString();
+ if (itemsn.length() == 0) {
+ itemsn0 += sn;
+ }else{
+ itemsn0 += itemsn+","+sn;
+ }
+ }
+ bm.createQuery("update O set O.BATCH_STATUS=:BATCH_STATUS,O.BATCH_NO=:BATCH_NO,O.BATCH_SN=:BATCH_SN where O.id=:id")
+ .setParameter("BATCH_STATUS", "")//处理状态-为空
+ .setParameter("BATCH_NO", req_sn)
+ .setParameter("BATCH_SN", itemsn0)
+ .setParameter("id", biz.getAttribute("id").toString()).executeUpdate();
+ trans.commit();
+ trans_detail.setSN(sn);
+ trans_detail.setBANK_CODE(bank_code);
+ trans_detail.setACCOUNT_TYPE("");
+ trans_detail.setACCOUNT_NO(acc_number);
+ trans_detail.setACCOUNT_NAME(account);
+ trans_detail.setPROVINCE(province);
+ trans_detail.setACCOUNT_PROP("0");
+ trans_detail.setAMOUNT(String.valueOf(singleitem));
+ trans_detail.setCURRENCY("CNY");
+ trans_detail.setRECKON_ACCOUNT("");
+ strbuff.append(EntityTransform.toXmlByBatchCollect(trans_detail));
+ }
+ if (l != 0) {
+ String surprent = String.format("%.2f", biz.getAttribute("rent").getDouble() - k*itemdescribe);
+ BigDecimal mj = new BigDecimal(surprent);
+ String singlerent0 = String.valueOf(mj.multiply(new BigDecimal(100)).longValue());
+ Trans_Detail trans_detail = new Trans_Detail();
+ String sn = "";
+ if (item >= 10) {
+ sn = "000"+ (++item);
+ }else if(item >= 100){
+ sn = "00"+ (++item);
+ }else{
+ sn = "0000"+ (++item);
+ }
+ //追加批量处理状态
+ JBOTransaction trans = JBOFactory.createJBOTransaction();
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,trans);
+ BizObject bo = bm.createQuery("O.id=:id").setParameter("id", biz.getAttribute("id").toString()).getSingleResult(false);
+ String itemsn0 = "";
+ if (bo !=null) {
+ String itemsn = bo.getAttribute("batch_sn").toString();
+ if (itemsn.length() == 0) {
+ itemsn0 += sn;
+ }else{
+ itemsn0 += itemsn+","+sn;
+ }
+ }
+ bm.createQuery("update O set O.BATCH_STATUS=:BATCH_STATUS,O.BATCH_NO=:BATCH_NO,O.BATCH_SN=:BATCH_SN where O.id=:id")
+ .setParameter("BATCH_STATUS", "")//处理状态-为空
+ .setParameter("BATCH_NO", req_sn)
+ .setParameter("BATCH_SN", itemsn0)
+ .setParameter("id", biz.getAttribute("id").toString()).executeUpdate();
+ trans.commit();
+ trans_detail.setSN(sn);
+ trans_detail.setBANK_CODE(bank_code);
+ trans_detail.setACCOUNT_TYPE("");
+ trans_detail.setACCOUNT_NO(acc_number);
+ trans_detail.setACCOUNT_NAME(account);
+ trans_detail.setPROVINCE(province);
+ trans_detail.setACCOUNT_PROP("0");
+ trans_detail.setAMOUNT(singlerent0);
+ trans_detail.setCURRENCY("CNY");
+ trans_detail.setRECKON_ACCOUNT("");
+ strbuff.append(EntityTransform.toXmlByBatchCollect(trans_detail));
+ }
+ }else{
+ Trans_Detail trans_detail = new Trans_Detail();
+ String sn = "";
+ if (item >= 10) {
+ sn = "000"+ (++item);
+ }else if(item >= 100){
+ sn = "00"+ (++item);
+ }else{
+ sn = "0000"+ (++item);
+ }
+ //追加批量处理状态
+ JBOTransaction trans = JBOFactory.createJBOTransaction();
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LC_RENT_PLAN.CLASS_NAME,trans);
+ bm.createQuery("update O set O.BATCH_STATUS=:BATCH_STATUS,O.BATCH_NO=:BATCH_NO,O.BATCH_SN=:BATCH_SN where O.id=:id")
+ .setParameter("BATCH_STATUS", "")//处理状态-为空
+ .setParameter("BATCH_NO", req_sn)
+ .setParameter("BATCH_SN", sn)
+ .setParameter("id", biz.getAttribute("id").toString()).executeUpdate();
+ trans.commit();
+ trans_detail.setSN(sn);
+ trans_detail.setBANK_CODE(bank_code);
+ trans_detail.setACCOUNT_TYPE("");
+ trans_detail.setACCOUNT_NO(acc_number);
+ trans_detail.setACCOUNT_NAME(account);
+ trans_detail.setPROVINCE(province);
+ trans_detail.setACCOUNT_PROP("0");
+ trans_detail.setAMOUNT(rent);
+ trans_detail.setCURRENCY("CNY");
+ trans_detail.setRECKON_ACCOUNT("");
+ strbuff.append(EntityTransform.toXmlByBatchCollect(trans_detail));
+ }
+ }
+ strbuff.delete(strbuff.lastIndexOf(""), strbuff.length());
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+
+
+ return strbuff;
+ }
+
+ /**
+ * 保存存盘、回盘文件
+ * @param tx
+ * @param strResp
+ * @param batch_title
+ * @throws Exception
+ */
+ public void savaFile(JBOTransaction tx,String strResp,String batch_title,BizObject bo) throws Exception{
+ //创建文件名称
+ String currentDateTime = DateAssistant.getTodayNow();
+ String currentYear = currentDateTime.substring(0,4);
+ String month = currentDateTime.substring(5,7);
+ String day = currentDateTime.substring(8,10);
+ //创建文件路径
+ String rootDir = this.fileSavePath;
+ File file = new File(rootDir + File.separator + currentYear
+ + File.separator + month + File.separator
+ + day);
+ System.out.println(file.getAbsolutePath());
+ if(!file.exists()){//目录不存在则直接创建
+ file.mkdirs();
+ }
+ //保存存盘文件
+ BizObjectManager bm = JBOFactory.getFactory().getManager(LB_INTFACE_FILE_RECORD.CLASS_NAME);
+ BizObject send = bm.newObject();
+ send.setAttributeValue("filepath", (file.getAbsoluteFile().toString().substring(rootDir.length())+"/"+batch_title+".txt").replace("\\", "/"));
+ send.setAttributeValue("fullpath", (file.getAbsoluteFile().toString()+"/"+batch_title+".txt").replace("\\", "/"));
+ send.setAttributeValue("filename", batch_title+".txt");
+ send.setAttributeValue("FILE_TYPE", "S");
+ send.setAttributeValue("RELA_ID", bo.getAttribute("id"));
+ send.setAttributeValue("inputuserid", this.inputuserid);
+ send.setAttributeValue("inputorgid", this.inputorgid);
+ send.setAttributeValue("inputtime", currentDateTime);
+ bm.saveObject(send);
+ //筛选响应信息
+ Map map = getRetAndCode(strResp);
+ //getMsgAndCode(strResp);
+
+ //保存回盘文件
+ BizObject reply = bm.newObject();
+ reply.setAttributeValue("filepath", (file.getAbsoluteFile().toString().substring(rootDir.length())+"/"+batch_title+".rnt").replace("\\", "/"));
+ reply.setAttributeValue("fullpath", (file.getAbsoluteFile().toString()+"/"+batch_title+".rnt").replace("\\", "/"));
+ reply.setAttributeValue("filename", batch_title+".rnt");
+ reply.setAttributeValue("feedback_code", map.get("RET_CODE"));
+ reply.setAttributeValue("feedback_message", map.get("ERR_MSG"));
+ reply.setAttributeValue("FILE_TYPE", "B");
+ reply.setAttributeValue("RELA_ID", bo.getAttribute("id"));
+ reply.setAttributeValue("inputuserid", this.inputuserid);
+ reply.setAttributeValue("inputorgid", this.inputorgid);
+ reply.setAttributeValue("inputtime", currentDateTime);
+ bm.saveObject(reply);
+ }
+
+ /**
+ * 实时代收，响应文件处理
+ * @param strXML
+ * @return
+ */
+ public Map getRetAndCode(String strXML){
+ Map map = new HashMap();
+ Map res = new HashMap();
+ Pattern pm = Pattern.compile("(?<=)([\\S\\s]*?)(?=)");
+ Matcher mm = pm.matcher(strXML);
+ int i = 0;
+ while (mm.find())
+ {
+ map.put("RET_CODE"+i++, mm.group());
+ }
+ Pattern pc = Pattern.compile("(?<=)([\\S\\s]*?)(?=)");
+ Matcher mc = pc.matcher(strXML);
+ int j = 0;
+ while (mc.find())
+ {
+ map.put("ERR_MSG"+j++, mc.group());
+ }
+ if (map.containsKey("RET_CODE0") && "0000".equals(map.get("RET_CODE0"))) {
+ if (map.containsKey("RET_CODE1") && "0000".equals(map.get("RET_CODE1"))) {
+ res.put("RET_CODE", map.get("RET_CODE1"));
+ res.put("ERR_MSG", map.get("ERR_MSG1"));
+ }else{
+ res.put("RET_CODE", map.get("RET_CODE1"));
+ res.put("ERR_MSG", map.get("ERR_MSG1"));
+ }
+ }else{
+ res.put("RET_CODE", map.get("RET_CODE0"));
+ res.put("ERR_MSG", map.get("ERR_MSG0"));
+ }
+ return res;
+ }
+
+ /**
+ * 批量代收-返回报文处理
+ * @param strXML
+ * @return
+ */
+ public Map getRetAndCodeByBatch(String strXML){
+ Map map = new HashMap();
+ Map res = new HashMap();
+ System.out.println(1);
+ int iStart = strXML.indexOf("");
+ if (iStart != -1) {
+ int end = strXML.indexOf("");
+ String errMsg = strXML.substring(iStart+9, end);
+ map.put("ERR_MSG", errMsg);
+ }
+ int kStart = strXML.indexOf("");
+ if (kStart != -1) {
+ int end = strXML.indexOf("");
+ String reqSn = strXML.substring(kStart+8, end);
+ map.put("REQ_SN", reqSn);
+ }
+
+ Pattern pm = Pattern.compile("(?<=)([\\S\\s]*?)(?=)");
+ Matcher mm = pm.matcher(strXML);
+ int i = 0;
+ while (mm.find())
+ {
+ map.put("RET_CODE"+i++, mm.group());
+ }
+ Pattern pc = Pattern.compile("(?<=)([\\S\\s]*?)(?=)");
+ Matcher mc = pc.matcher(strXML);
+ int j = 1;
+ while (mc.find())
+ {
+ map.put("SN"+j++, mc.group());
+ }
+ if (map.containsKey("RET_CODE0") && "0000".equals(map.get("RET_CODE0"))) {
+ res.putAll(map);
+ res.remove("RET_CODE0");
+ res.remove("ERR_MSG");
+ }else{
+ res.put("RET_CODE", map.get("RET_CODE0"));
+ res.put("ERR_MSG", map.get("ERR_MSG0"));
+ }
+ return res;
+ }
+
+ public Map getMsgAndCode(String strXML){
+ Map map = new HashMap();
+ int iStart = strXML.indexOf("");
+ if (iStart != -1) {
+ int end = strXML.indexOf("");
+ String strMsg = strXML.substring(iStart+9, end);
+ map.put("ERR_MSG", strMsg);
+ }
+ int jStart = strXML.indexOf("");
+ if (jStart != -1) {
+ int end = strXML.indexOf("");
+ String strMsg = strXML.substring(jStart+10, end);
+ map.put("RET_CODE", strMsg);
+ }
+ return map;
+ }
+
+ /**
+ * 获取响应码
+ * @param strXML
+ * @return
+ */
+ public Map getInfoAndStatus(String strXML){
+ Map map = new HashMap();
+ Map res = new HashMap();
+
+ int jStart = strXML.indexOf("");
+ if (jStart != -1) {
+ int end = strXML.indexOf("");
+ String retCode = strXML.substring(jStart+10, end);
+ map.put("RET_CODE", retCode);
+ }
+ int iStart = strXML.indexOf("");
+ if (iStart != -1) {
+ int end = strXML.indexOf("");
+ String errMsg = strXML.substring(iStart+9, end);
+ map.put("ERR_MSG", errMsg);
+ }
+
+ int kStart = strXML.indexOf("");
+ if (kStart != -1) {
+ int end = strXML.indexOf("");
+ String errMsg = strXML.substring(kStart+14, end);
+ map.put("TRANS_STATUS", errMsg);
+ }
+ int lStart = strXML.indexOf("");
+ if (lStart != -1) {
+ int end = strXML.indexOf("");
+ String retCode = strXML.substring(lStart+12, end);
+ map.put("TRANS_INFO", retCode);
+ }
+ if (map.containsKey("RET_CODE") && map.get("RET_CODE").equals("0000")) {
+ if (map.containsKey("TRANS_STATUS") && map.get("TRANS_STATUS").equals("0000")) {
+ res.put("RET_CODE", map.get("TRANS_STATUS"));
+ res.put("ERR_MSG", map.get("TRANS_INFO"));
+ }else{
+ res.put("RET_CODE", map.get("TRANS_STATUS"));
+ res.put("ERR_MSG", map.get("TRANS_INFO"));
+ }
+ }else{
+ res.put("RET_CODE", map.get("RET_CODE"));
+ res.put("ERR_MSG", map.get("ERR_MSG"));
+ }
+ return res;
+ }
+ //验证银行卡四要素
+ public Map vitfyCollectManage(Map map) throws CryptException{
+ CollectAuditProcess cp = new CollectAuditProcess();
+ String currentDateTime = DateAssistant.getTodayNow();
+ String currenttime=currentDateTime.replaceAll("/", "");
+ currenttime=currenttime.replaceAll(":", "");
+ currenttime=currenttime.replaceAll(" ", "");
+ //验证银行卡二、三、四要素
+ String req = System.currentTimeMillis()+"";
+ StringBuffer strbuff = new StringBuffer();
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ Info info = new Info();
+ /*info.setTRX_CODE("100039");
+ info.setVERSION("03");
+ info.setDATA_TYPE("2");
+ info.setLEVEL("5");
+ info.setUSER_NAME("00019140020764901");
+ info.setUSER_PASS("TPSHauto123.");*/
+ info.setTRX_CODE(InitCollectConfig.B_TRXCODE);
+ info.setVERSION(InitCollectConfig.B_VERSION);
+ info.setDATA_TYPE(InitCollectConfig.B_DATATYPE);
+ info.setLEVEL(InitCollectConfig.B_LEVEL);
+ info.setUSER_NAME(InitCollectConfig.USERNAME);
+ info.setUSER_PASS(InitCollectConfig.USERPASS);
+ info.setREQ_SN(req);
+ info.setSIGNED_MSG("");
+ strbuff.append(EntityTransform.toXml(info));
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append(currenttime);//请求时间
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append(InitCollectConfig.MERCHANTID);//商户号
+ /*strbuff.append("000191400207649");//商户号
+*/ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append(map.get("ACCOUNT_NO"));//卡号
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append(map.get("ACCOUNT_NAME"));//户名
+ strbuff.append("");
+ //判断是否存在
+ if (map.containsKey("ID_TYPE")) {
+ strbuff.append("");
+ strbuff.append(map.get("ID_TYPE"));//开户证件类型
+ strbuff.append("");
+ }
+ if (map.containsKey("ID")) {
+ strbuff.append("");
+ strbuff.append(map.get("ID"));//证件号
+ strbuff.append("");
+ }
+ if (map.containsKey("TEL")) {
+ strbuff.append("");
+ strbuff.append(map.get("TEL"));//手机号
+ strbuff.append("");
+ }
+ strbuff.append("");
+ strbuff.append("");//贷记卡有效期
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");//贷记卡CV2
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ strbuff.append("");
+ String strResp = cp.CollectAuditVerifyReq(strbuff);
+ return getInfoAndStatus(strResp);
+ }
+
+
+ public String getInputuserid() {
+ return inputuserid;
+ }
+
+ public void setInputuserid(String inputuserid) {
+ this.inputuserid = inputuserid;
+ }
+
+ public String getInputorgid() {
+ return inputorgid;
+ }
+
+ public void setInputorgid(String inputorgid) {
+ this.inputorgid = inputorgid;
+ }
+
+ public String getFileSavePath() {
+ return fileSavePath;
+ }
+
+ public void setFileSavePath(String fileSavePath) {
+ this.fileSavePath = fileSavePath;
+ }
+
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+ public String getClearDate() {
+ return clearDate;
+ }
+ public void setClearDate(String clearDate) {
+ this.clearDate = clearDate;
+ }
+
+
+}