|
|
@@ -1,178 +1,249 @@
|
|
|
-package com.uas.erp.schedular.finance.task;
|
|
|
-
|
|
|
-
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.List;
|
|
|
-
|
|
|
-import com.uas.erp.schedular.task.support.Method;
|
|
|
-import com.usoft.fin.external.open.api.entity.CapitalSideLoan;
|
|
|
-import com.usoft.fin.external.open.api.entity.FinanceOfferListOrBuilder;
|
|
|
-import com.usoft.fin.external.open.api.entity.OfferQuotaInfoRest;
|
|
|
-import com.usoft.sdk.fin.client.CapitalSideSdk;
|
|
|
-
|
|
|
-import org.springframework.stereotype.Component;
|
|
|
-
|
|
|
-import com.uas.erp.schedular.task.support.Role;
|
|
|
-import com.uas.erp.schedular.task.support.TaskMapping;
|
|
|
-import com.usoft.fin.external.open.api.entity.FinanceOfferDetails;
|
|
|
-import com.usoft.fin.external.open.api.entity.OfferDetailAndFinanceAccept;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetCapitalSideLoanReq;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetCapitalSideLoanResp;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetFinanceOfferDetailsReq;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetFinanceOfferDetailsResp;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetFinanceOfferListReq;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetFinanceOfferListResp;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetOfferQuotaInfoListReq;
|
|
|
-import com.usoft.fin.external.open.api.protobuf.GetOfferQuotaInfoListResp;
|
|
|
-
|
|
|
-@Component
|
|
|
-@TaskMapping(title = "U智融对接服务", role = Role.SELLER)
|
|
|
-public class B2BInformation extends AbstractTask{
|
|
|
-
|
|
|
- private CapitalSideSdk capitalSideSdk = new CapitalSideSdk("https://finrest.uuzcc.cn", "10050877", "b78d577449b64f56a8a6cf1feeb3fbf5");
|
|
|
-
|
|
|
- /**
|
|
|
- * 下载放款记录列表
|
|
|
- * @throws Exception
|
|
|
- */
|
|
|
- @TaskMapping(title = "放款记录下载", fixedDelay = 360000, method = Method.DOWNLOAD)
|
|
|
- public void getCapitalSideLoan() throws Exception {
|
|
|
- final List<String> sqls = new ArrayList<>();
|
|
|
- GetCapitalSideLoanReq.Builder req = GetCapitalSideLoanReq.newBuilder();
|
|
|
- req.setPageSize(100);
|
|
|
- req.setPageNumber(1);
|
|
|
- req.setCsEnuu(10042875); //优软商城企业UU com.usoft.fin.external.open.api.entity.
|
|
|
- GetCapitalSideLoanResp resp = capitalSideSdk.getCapitalSideLoan(req);
|
|
|
- java.util.List<CapitalSideLoan> rlist = resp.getCapitalSideLoanList();
|
|
|
- for(CapitalSideLoan loan :rlist){
|
|
|
- sqls.add("insert into CapitalSideLoan(ID,CODE,FINANCEDEMANDCODE,ACCEPTOFFERCODE,LOANCODE,CSENUU,"
|
|
|
- + "FSENUU,FSNAME,RECEIVABLESARRIVALDATE,FINANCERATE,LOANAMOUNT,LOANDATE,REPAYMENTDATA,LOANRATE,"
|
|
|
- + "REPAYMENTFREQUENCY,FSCOLLECTIONBANK,FSCOLLECTIONACCOUNT,FSCOLLECTIONNAME,RECEIPTFORLOAN,INTERESTPAYABLE,"
|
|
|
- + "BEOVERDUE,SETTLE,APPLYDATE,PERSONINCHARGE,STATUS,APPROVALDATE,APPROVALMAN,UPLOADSTATUS) "
|
|
|
- + "values (CapitalSideLoan_seq.nextval,'"+loan.getCode()+"','"+loan.getFinanceDemandCode()+"','"+loan.getAcceptOfferCode()+"',"
|
|
|
- + "'"+loan.getLoanCode()+"','"+loan.getCsEnuu()+"','"+loan.getFsEnuu()+"','"+loan.getFsName()+"',"
|
|
|
- + "'"+loan.getReceivablesArrivalDate()+"','"+loan.getFinanceRate()+"','"+loan.getLoanAmount()+"','"+loan.getLoanDate()+"',"
|
|
|
- + "'"+loan.getRepaymentData()+"','"+loan.getLoanRate()+"','"+loan.getRepaymentFrequency()+"','"+loan.getFsCollectionBank()+"',"
|
|
|
- + "'"+loan.getFsCollectionAccount()+"','"+loan.getFsCollectionName()+"','"+loan.getReceiptForLoan()+"','"+loan.getInterestPayable()+"',"
|
|
|
- + "'"+loan.getBeOverdue()+"','"+loan.getSettle()+"','"+loan.getApplyDate()+"','"+loan.getPersonInCharge()+"','"+loan.getStatus()+"','"+loan.getApprovalDate()+"','"+loan.getApprovalMan()+"','已上传')");
|
|
|
- }
|
|
|
- jdbcTemplate.batchExecute(sqls);
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 报价记录下载
|
|
|
- * @throws Exception
|
|
|
- */
|
|
|
- @TaskMapping(title = "报价记录下载", fixedDelay = 360000, method = Method.DOWNLOAD)
|
|
|
- public void getFinanceOfferList() throws Exception {
|
|
|
- final List<String> sqls = new ArrayList<>();
|
|
|
- final List<String> sqlsDemand = new ArrayList<>();
|
|
|
- GetFinanceOfferListReq.Builder req = GetFinanceOfferListReq.newBuilder();
|
|
|
- req.setEnuu(10042875);
|
|
|
- req.setPageNumber(1);
|
|
|
- req.setPageSize(100);
|
|
|
- GetFinanceOfferListResp resp = capitalSideSdk.getFinanceOfferList(req);
|
|
|
-
|
|
|
- List<? extends FinanceOfferListOrBuilder> flist = resp.getFinanceOfferInfoOrBuilderList();
|
|
|
-
|
|
|
- for(FinanceOfferListOrBuilder Finance :flist){
|
|
|
- sqls.add("insert into AcceptOffer(ID,CODE,FINANCECODE,OFFERAMOUNT,FINANCERATE,FINANCEDAYS,"
|
|
|
- + "CAPITALSIDENAME,CSCONTACTSMAN,CSCONTACTSPHONE,CSENUU,CSUSERUU,CSUSERNAME,FINANCESIDENAME,FSCONTACTSMAN,"
|
|
|
- + "FSCONTACTSPHONE,OFFERTIME,STATUS,PAYMENTS,OFFERRATE,FINANCINGRATIO,UPLOADSTATUS) "
|
|
|
- + "values (AcceptOffer_seq.nextval,'"+Finance.getAcceptOfferInfo().getCode()+"','"+Finance.getAcceptOfferInfo().getFinanceCode()+"','"+Finance.getAcceptOfferInfo().getOfferAmount()+"',"
|
|
|
- + "'"+Finance.getAcceptOfferInfo().getFinanceRate()+"','"+Finance.getAcceptOfferInfo().getFinanceDays()+"','"+Finance.getAcceptOfferInfo().getCapitalSideName()+"','"+Finance.getAcceptOfferInfo().getCsContactsMan()+"',"
|
|
|
- + "'"+Finance.getAcceptOfferInfo().getCsContactsPhone()+"','"+Finance.getAcceptOfferInfo().getCsEnuu()+"','"+Finance.getAcceptOfferInfo().getCsUseruu()+"','"+Finance.getAcceptOfferInfo().getCsUserName()+"',"
|
|
|
- + "'"+Finance.getAcceptOfferInfo().getFinanceSideName()+"','"+Finance.getAcceptOfferInfo().getFsContactsMan()+"','"+Finance.getAcceptOfferInfo().getFsContactsPhone()+"','"+Finance.getAcceptOfferInfo().getOfferTime()+"',"
|
|
|
- + "'"+Finance.getAcceptOfferInfo().getStatus()+"','"+Finance.getAcceptOfferInfo().getPayments()+"','"+Finance.getAcceptOfferInfo().getOfferRate()+"',"
|
|
|
- + "'"+Finance.getAcceptOfferInfo().getFinancingRatio()+"','已上传')");
|
|
|
- sqlsDemand.add("insert into ACCEPTFINANCEDEMAND(ID,CODE,ADOPTCODE,FINANCEDAYS,STATUS,AMOUNT,"
|
|
|
- + "DEALAMOUNT,DEALRATE,FSENNAME,FSENUU,FSUSERNAME,FSUSERUU,FSCONTACTSMAN,FSCONTACTSPHONE,"
|
|
|
- + "CSENNAME,CSENUU,CSUSERNAME,CSUSERUU,CSCONTACTSMAN,CSCONTACTSPHONE,PUBTIME,ENDTIME,"
|
|
|
- + "DEALTIME,OFFERCOUNT,FSDEMANDAMOUNT,UPLOADSTATUS) "
|
|
|
- + "values (ACCEPTFINANCEDEMAND_seq.nextval,'"+Finance.getFinanceDemandInfo().getCode()+"','"+Finance.getFinanceDemandInfo().getAdoptCode()+"','"+Finance.getFinanceDemandInfo().getFinanceDays()+"',"
|
|
|
- + "'"+Finance.getFinanceDemandInfo().getStatus()+"','"+Finance.getFinanceDemandInfo().getAmount()+"','"+Finance.getFinanceDemandInfo().getDealAmount()+"','"+Finance.getFinanceDemandInfo().getDealRate()+"',"
|
|
|
- + "'"+Finance.getFinanceDemandInfo().getFsEnName()+"','"+Finance.getFinanceDemandInfo().getFsEnuu()+"','"+Finance.getFinanceDemandInfo().getFsUserName()+"','"+Finance.getFinanceDemandInfo().getFsUseruu()+"',"
|
|
|
- + "'"+Finance.getFinanceDemandInfo().getFsContactsMan()+"','"+Finance.getFinanceDemandInfo().getFsContactsPhone()+"','"+Finance.getFinanceDemandInfo().getCsEnName()+"','"+Finance.getFinanceDemandInfo().getCsEnuu()+"',"
|
|
|
- + "'"+Finance.getFinanceDemandInfo().getCsUserName()+"','"+Finance.getFinanceDemandInfo().getCsUseruu()+"','"+Finance.getFinanceDemandInfo().getCsContactsMan()+"',"
|
|
|
- + "'"+Finance.getFinanceDemandInfo().getCsContactsPhone()+"','"+Finance.getFinanceDemandInfo().getPubTime()+"','"+Finance.getFinanceDemandInfo().getEndTime()+"'"
|
|
|
- + ",'"+Finance.getFinanceDemandInfo().getDealTime()+"','"+Finance.getFinanceDemandInfo().getOfferCount()+"','"+Finance.getFinanceDemandInfo().getFsDemandAmount()+"'"
|
|
|
- + ",'已上传')");
|
|
|
-
|
|
|
- }
|
|
|
- jdbcTemplate.batchExecute(sqls); //报价信息
|
|
|
- jdbcTemplate.batchExecute(sqlsDemand); //融资信息
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 额度申请
|
|
|
- * @throws Exception
|
|
|
- */
|
|
|
- @TaskMapping(title = "额度申请下载", fixedDelay = 360000, method = Method.DOWNLOAD)
|
|
|
- public void getOfferQuotaInfoList() throws Exception {
|
|
|
- final List<String> sqls = new ArrayList<>();
|
|
|
- GetOfferQuotaInfoListReq.Builder req = GetOfferQuotaInfoListReq.newBuilder();
|
|
|
- req.setCsEnuu(10042875);
|
|
|
- req.setPageNumber(1);
|
|
|
- req.setPageSize(100);
|
|
|
- GetOfferQuotaInfoListResp resp = capitalSideSdk.getOfferQuotaInfoList(req);
|
|
|
- java.util.List<OfferQuotaInfoRest> restlist = resp.getOfferQuoteInfoList();
|
|
|
- for(OfferQuotaInfoRest rest :restlist){
|
|
|
- sqls.add("insert into OfferQuotaInfoRest(CSENUU,CSENNAME,FSENUU,FSENNAME,QUOTAAMOUNT,CREDDAYS,FINANCERATE,OFFERRATE,REPAYMENT,APPLYTIME,"
|
|
|
- + "APPLYUU,APPLYUSERNAME,CHECKERTIME,CHECKERUU,CHECKERUSERNAME,STATUS,CHECKERCONTENT,ID,CODE,UPLOADSTATUS) "
|
|
|
- + "values ('"+rest.getCsEnuu()+"','"+rest.getCsEnName()+"','"+rest.getFsEnuu()+"',"
|
|
|
- + "'"+rest.getFsEnName()+"','"+rest.getQuotaAmount()+"','"+rest.getCredDays()+"','"+rest.getFinanceRate()+"',"
|
|
|
- + "'"+rest.getOfferRate()+"','"+rest.getRepayment()+"','"+rest.getApplyTime()+"','"+rest.getApplyUu()+"',"
|
|
|
- + "'"+rest.getApplyUsername()+"','"+rest.getCheckerTime()+"','"+rest.getCheckerUu()+"','"+rest.getCheckerUsername()+"',"
|
|
|
- + "'"+rest.getStatus()+"','"+rest.getCheckerContent()+"',OfferQuotaInfoRest_seq.nextval,'"+rest.getCode()+"','已上传')");
|
|
|
- }
|
|
|
- jdbcTemplate.batchExecute(sqls);
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /**
|
|
|
- * 下载报价详情
|
|
|
- */
|
|
|
- public void getFinanceOfferDetails() throws Exception {
|
|
|
- final List<String> ordersqls = new ArrayList<>(); //订单详情
|
|
|
- final List<String> acceptsqls = new ArrayList<>(); //验收单详情
|
|
|
- GetFinanceOfferDetailsReq.Builder req = GetFinanceOfferDetailsReq.newBuilder();
|
|
|
- req.setOfferCode("71191218666434955543");//financeDemandDetail
|
|
|
- GetFinanceOfferDetailsResp resp = capitalSideSdk.getFinanceOfferDetails(req);
|
|
|
- FinanceOfferDetails adetaillist = resp.getFinanceOfferInfo();
|
|
|
- List<OfferDetailAndFinanceAccept> restlist = adetaillist.getOfferDetailAndFinanceAcceptInfoList();
|
|
|
- for(OfferDetailAndFinanceAccept rest :restlist){
|
|
|
- ordersqls.add("insert into ACCEPTFINANCEDEMANDDETAIL(ID,CODE,FINANCEDEMANDCODE,CUSTENUU,CUSTENNAME,CUSTGRADE,PAYMENTS,ORDERID,ORDERCODE,ORDERTOTAL,"
|
|
|
- + "ACCEPTAMOUNT,UPLOADSTATUS) "
|
|
|
- + "values (ACCEPTFINANCEDEMANDDETAIL_seq.nextval,'"+rest.getFinanceDemandDetail().getCode()+"','"+rest.getFinanceDemandDetail().getFinanceDemandCode()+"','"+rest.getFinanceDemandDetail().getCustEnuu()+"',"
|
|
|
- + "'"+rest.getFinanceDemandDetail().getCustEnName()+"','"+rest.getFinanceDemandDetail().getCustGrade()+"','"+rest.getFinanceDemandDetail().getPayments()+"','"+rest.getFinanceDemandDetail().getOrderId()+"',"
|
|
|
- + "'"+rest.getFinanceDemandDetail().getOrderCode()+"','"+rest.getFinanceDemandDetail().getOrderTotal()+"','"+rest.getFinanceDemandDetail().getAcceptAmount()+"','已上传'");
|
|
|
-
|
|
|
- acceptsqls.add("insert into FINANCEDEMANDDETAILACCEPT(ID,CODE,FINANCEDEMANDCODE,FINANCEDEMANDDETAILCODE,ORDERITEMID,ACCEPTITEMID,ACCEPTID,ACCEPTAMOUNT,ACCEPTDATE,ACCEPTCODE,"
|
|
|
- + "ACCEPTSTATUS,TITLE,SPEC,PRODUCTCODE,STATUS,UPLOADSTATUS) "
|
|
|
- + "values (FINANCEDEMANDDETAILACCEPT_seq.nextval,'"+rest.getFinanceDemandDetailAccept().getCode()+"','"+rest.getFinanceDemandDetailAccept().getFinanceDemandCode()+"','"+rest.getFinanceDemandDetailAccept().getFinanceDemandDetailCode()+"',"
|
|
|
- + "'"+rest.getFinanceDemandDetailAccept().getOrderItemId()+"','"+rest.getFinanceDemandDetailAccept().getAcceptId()+"','"+rest.getFinanceDemandDetailAccept().getAcceptAmount()+"','"+rest.getFinanceDemandDetailAccept().getAcceptDate()+"',"
|
|
|
- + "'"+rest.getFinanceDemandDetailAccept().getAcceptCode()+"','"+rest.getFinanceDemandDetailAccept().getAcceptStatus()+"','"+rest.getFinanceDemandDetailAccept().getTitle()+"','"+rest.getFinanceDemandDetailAccept().getSpec()+"','"+rest.getFinanceDemandDetailAccept().getProductCode()+"','"+rest.getFinanceDemandDetailAccept().getStatus()+"','已上传'");
|
|
|
- }
|
|
|
- System.out.println(ordersqls);
|
|
|
- jdbcTemplate.batchExecute(ordersqls);
|
|
|
- jdbcTemplate.batchExecute(acceptsqls);
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+package com.uas.erp.schedular.finance.task;
|
|
|
+
|
|
|
+
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.uas.erp.schedular.task.support.Method;
|
|
|
+import com.usoft.fin.external.open.api.entity.CapitalSideLoan;
|
|
|
+import com.usoft.fin.external.open.api.entity.FinanceOfferListOrBuilder;
|
|
|
+import com.usoft.fin.external.open.api.entity.OfferQuotaInfoRest;
|
|
|
+import com.usoft.fin.external.open.api.protobuf.*;
|
|
|
+import com.usoft.sdk.fin.client.CapitalSideSdk;
|
|
|
+
|
|
|
+import com.usoft.sdk.fin.utils.ProtoBufUtil;
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
+
|
|
|
+import com.uas.erp.schedular.task.support.Role;
|
|
|
+import com.uas.erp.schedular.task.support.TaskMapping;
|
|
|
+import com.usoft.fin.external.open.api.entity.FinanceOfferDetails;
|
|
|
+import com.usoft.fin.external.open.api.entity.OfferDetailAndFinanceAccept;
|
|
|
+import org.springframework.util.CollectionUtils;
|
|
|
+
|
|
|
+@Component
|
|
|
+@TaskMapping(title = "U智融对接服务", role = Role.SELLER)
|
|
|
+public class B2BInformation extends AbstractTask{
|
|
|
+
|
|
|
+ private CapitalSideSdk capitalSideSdk = new CapitalSideSdk("https://finrest.uuzcc.cn", "10050877", "b78d577449b64f56a8a6cf1feeb3fbf5");
|
|
|
+ /**
|
|
|
+ * 下载放款记录列表
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ @TaskMapping(title = "放款记录下载", fixedDelay = 360000, method = Method.DOWNLOAD)
|
|
|
+ public void getCapitalSideLoan() throws Exception {
|
|
|
+ final List<String> sqls = new ArrayList<>();
|
|
|
+ GetCapitalSideLoanReq.Builder req = GetCapitalSideLoanReq.newBuilder();
|
|
|
+ req.setPageSize(100);
|
|
|
+ req.setPageNumber(1);
|
|
|
+ req.setCsEnuu(10042875); //优软商城企业UU com.usoft.fin.external.open.api.entity.
|
|
|
+ GetCapitalSideLoanResp resp = capitalSideSdk.getCapitalSideLoan(req);
|
|
|
+ java.util.List<CapitalSideLoan> rlist = resp.getCapitalSideLoanList();
|
|
|
+ for(CapitalSideLoan loan :rlist){
|
|
|
+ sqls.add("insert into CapitalSideLoan(ID,CODE,FINANCEDEMANDCODE,ACCEPTOFFERCODE,LOANCODE,CSENUU,"
|
|
|
+ + "FSENUU,FSNAME,RECEIVABLESARRIVALDATE,FINANCERATE,LOANAMOUNT,LOANDATE,REPAYMENTDATA,LOANRATE,"
|
|
|
+ + "REPAYMENTFREQUENCY,FSCOLLECTIONBANK,FSCOLLECTIONACCOUNT,FSCOLLECTIONNAME,RECEIPTFORLOAN,INTERESTPAYABLE,"
|
|
|
+ + "BEOVERDUE,SETTLE,APPLYDATE,PERSONINCHARGE,STATUS,APPROVALDATE,APPROVALMAN,UPLOADSTATUS) "
|
|
|
+ + "values (CapitalSideLoan_seq.nextval,'"+loan.getCode()+"','"+loan.getFinanceDemandCode()+"','"+loan.getAcceptOfferCode()+"',"
|
|
|
+ + "'"+loan.getLoanCode()+"','"+loan.getCsEnuu()+"','"+loan.getFsEnuu()+"','"+loan.getFsName()+"',"
|
|
|
+ + "'"+loan.getReceivablesArrivalDate()+"','"+loan.getFinanceRate()+"','"+loan.getLoanAmount()+"','"+loan.getLoanDate()+"',"
|
|
|
+ + "'"+loan.getRepaymentData()+"','"+loan.getLoanRate()+"','"+loan.getRepaymentFrequency()+"','"+loan.getFsCollectionBank()+"',"
|
|
|
+ + "'"+loan.getFsCollectionAccount()+"','"+loan.getFsCollectionName()+"','"+loan.getReceiptForLoan()+"','"+loan.getInterestPayable()+"',"
|
|
|
+ + "'"+loan.getBeOverdue()+"','"+loan.getSettle()+"','"+loan.getApplyDate()+"','"+loan.getPersonInCharge()+"','"+loan.getStatus()+"','"+loan.getApprovalDate()+"','"+loan.getApprovalMan()+"','已上传')");
|
|
|
+ }
|
|
|
+ jdbcTemplate.batchExecute(sqls);
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 报价记录下载
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ @TaskMapping(title = "报价记录下载", fixedDelay = 360000, method = Method.DOWNLOAD)
|
|
|
+ public void getFinanceOfferList() throws Exception {
|
|
|
+ final List<String> sqls = new ArrayList<>();
|
|
|
+ final List<String> sqlsDemand = new ArrayList<>();
|
|
|
+ GetFinanceOfferListReq.Builder req = GetFinanceOfferListReq.newBuilder();
|
|
|
+ req.setEnuu(10042875);
|
|
|
+ req.setPageNumber(1);
|
|
|
+ req.setPageSize(100);
|
|
|
+ GetFinanceOfferListResp resp = capitalSideSdk.getFinanceOfferList(req);
|
|
|
+
|
|
|
+ List<? extends FinanceOfferListOrBuilder> flist = resp.getFinanceOfferInfoOrBuilderList();
|
|
|
+
|
|
|
+ for(FinanceOfferListOrBuilder Finance :flist){
|
|
|
+ sqls.add("insert into AcceptOffer(ID,CODE,FINANCECODE,OFFERAMOUNT,FINANCERATE,FINANCEDAYS,"
|
|
|
+ + "CAPITALSIDENAME,CSCONTACTSMAN,CSCONTACTSPHONE,CSENUU,CSUSERUU,CSUSERNAME,FINANCESIDENAME,FSCONTACTSMAN,"
|
|
|
+ + "FSCONTACTSPHONE,OFFERTIME,STATUS,PAYMENTS,OFFERRATE,FINANCINGRATIO,UPLOADSTATUS) "
|
|
|
+ + "values (AcceptOffer_seq.nextval,'"+Finance.getAcceptOfferInfo().getCode()+"','"+Finance.getAcceptOfferInfo().getFinanceCode()+"','"+Finance.getAcceptOfferInfo().getOfferAmount()+"',"
|
|
|
+ + "'"+Finance.getAcceptOfferInfo().getFinanceRate()+"','"+Finance.getAcceptOfferInfo().getFinanceDays()+"','"+Finance.getAcceptOfferInfo().getCapitalSideName()+"','"+Finance.getAcceptOfferInfo().getCsContactsMan()+"',"
|
|
|
+ + "'"+Finance.getAcceptOfferInfo().getCsContactsPhone()+"','"+Finance.getAcceptOfferInfo().getCsEnuu()+"','"+Finance.getAcceptOfferInfo().getCsUseruu()+"','"+Finance.getAcceptOfferInfo().getCsUserName()+"',"
|
|
|
+ + "'"+Finance.getAcceptOfferInfo().getFinanceSideName()+"','"+Finance.getAcceptOfferInfo().getFsContactsMan()+"','"+Finance.getAcceptOfferInfo().getFsContactsPhone()+"','"+Finance.getAcceptOfferInfo().getOfferTime()+"',"
|
|
|
+ + "'"+Finance.getAcceptOfferInfo().getStatus()+"','"+Finance.getAcceptOfferInfo().getPayments()+"','"+Finance.getAcceptOfferInfo().getOfferRate()+"',"
|
|
|
+ + "'"+Finance.getAcceptOfferInfo().getFinancingRatio()+"','已上传')");
|
|
|
+ sqlsDemand.add("insert into ACCEPTFINANCEDEMAND(ID,CODE,ADOPTCODE,FINANCEDAYS,STATUS,AMOUNT,"
|
|
|
+ + "DEALAMOUNT,DEALRATE,FSENNAME,FSENUU,FSUSERNAME,FSUSERUU,FSCONTACTSMAN,FSCONTACTSPHONE,"
|
|
|
+ + "CSENNAME,CSENUU,CSUSERNAME,CSUSERUU,CSCONTACTSMAN,CSCONTACTSPHONE,PUBTIME,ENDTIME,"
|
|
|
+ + "DEALTIME,OFFERCOUNT,FSDEMANDAMOUNT,UPLOADSTATUS) "
|
|
|
+ + "values (ACCEPTFINANCEDEMAND_seq.nextval,'"+Finance.getFinanceDemandInfo().getCode()+"','"+Finance.getFinanceDemandInfo().getAdoptCode()+"','"+Finance.getFinanceDemandInfo().getFinanceDays()+"',"
|
|
|
+ + "'"+Finance.getFinanceDemandInfo().getStatus()+"','"+Finance.getFinanceDemandInfo().getAmount()+"','"+Finance.getFinanceDemandInfo().getDealAmount()+"','"+Finance.getFinanceDemandInfo().getDealRate()+"',"
|
|
|
+ + "'"+Finance.getFinanceDemandInfo().getFsEnName()+"','"+Finance.getFinanceDemandInfo().getFsEnuu()+"','"+Finance.getFinanceDemandInfo().getFsUserName()+"','"+Finance.getFinanceDemandInfo().getFsUseruu()+"',"
|
|
|
+ + "'"+Finance.getFinanceDemandInfo().getFsContactsMan()+"','"+Finance.getFinanceDemandInfo().getFsContactsPhone()+"','"+Finance.getFinanceDemandInfo().getCsEnName()+"','"+Finance.getFinanceDemandInfo().getCsEnuu()+"',"
|
|
|
+ + "'"+Finance.getFinanceDemandInfo().getCsUserName()+"','"+Finance.getFinanceDemandInfo().getCsUseruu()+"','"+Finance.getFinanceDemandInfo().getCsContactsMan()+"',"
|
|
|
+ + "'"+Finance.getFinanceDemandInfo().getCsContactsPhone()+"','"+Finance.getFinanceDemandInfo().getPubTime()+"','"+Finance.getFinanceDemandInfo().getEndTime()+"'"
|
|
|
+ + ",'"+Finance.getFinanceDemandInfo().getDealTime()+"','"+Finance.getFinanceDemandInfo().getOfferCount()+"','"+Finance.getFinanceDemandInfo().getFsDemandAmount()+"'"
|
|
|
+ + ",'已上传')");
|
|
|
+
|
|
|
+ }
|
|
|
+ jdbcTemplate.batchExecute(sqls); //报价信息
|
|
|
+ jdbcTemplate.batchExecute(sqlsDemand); //融资信息
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 额度申请
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ @TaskMapping(title = "额度申请下载", fixedDelay = 360000, method = Method.DOWNLOAD)
|
|
|
+ public void getOfferQuotaInfoList() throws Exception {
|
|
|
+ final List<String> sqls = new ArrayList<>();
|
|
|
+ GetOfferQuotaInfoListReq.Builder req = GetOfferQuotaInfoListReq.newBuilder();
|
|
|
+ req.setCsEnuu(10042875);
|
|
|
+ req.setPageNumber(1);
|
|
|
+ req.setPageSize(100);
|
|
|
+ GetOfferQuotaInfoListResp resp = capitalSideSdk.getOfferQuotaInfoList(req);
|
|
|
+ java.util.List<OfferQuotaInfoRest> restlist = resp.getOfferQuoteInfoList();
|
|
|
+ for(OfferQuotaInfoRest rest :restlist){
|
|
|
+ sqls.add("insert into OfferQuotaInfoRest(CSENUU,CSENNAME,FSENUU,FSENNAME,QUOTAAMOUNT,CREDDAYS,FINANCERATE,OFFERRATE,REPAYMENT,APPLYTIME,"
|
|
|
+ + "APPLYUU,APPLYUSERNAME,CHECKERTIME,CHECKERUU,CHECKERUSERNAME,STATUS,CHECKERCONTENT,ID,CODE,UPLOADSTATUS) "
|
|
|
+ + "values ('"+rest.getCsEnuu()+"','"+rest.getCsEnName()+"','"+rest.getFsEnuu()+"',"
|
|
|
+ + "'"+rest.getFsEnName()+"','"+rest.getQuotaAmount()+"','"+rest.getCredDays()+"','"+rest.getFinanceRate()+"',"
|
|
|
+ + "'"+rest.getOfferRate()+"','"+rest.getRepayment()+"','"+rest.getApplyTime()+"','"+rest.getApplyUu()+"',"
|
|
|
+ + "'"+rest.getApplyUsername()+"','"+rest.getCheckerTime()+"','"+rest.getCheckerUu()+"','"+rest.getCheckerUsername()+"',"
|
|
|
+ + "'"+rest.getStatus()+"','"+rest.getCheckerContent()+"',OfferQuotaInfoRest_seq.nextval,'"+rest.getCode()+"','已上传')");
|
|
|
+ }
|
|
|
+ jdbcTemplate.batchExecute(sqls);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 下载报价详情
|
|
|
+ */
|
|
|
+ public void getFinanceOfferDetails() throws Exception {
|
|
|
+ final List<String> ordersqls = new ArrayList<>(); //订单详情
|
|
|
+ final List<String> acceptsqls = new ArrayList<>(); //验收单详情
|
|
|
+ GetFinanceOfferDetailsReq.Builder req = GetFinanceOfferDetailsReq.newBuilder();
|
|
|
+ req.setOfferCode("71191218666434955543");//financeDemandDetail
|
|
|
+ GetFinanceOfferDetailsResp resp = capitalSideSdk.getFinanceOfferDetails(req);
|
|
|
+ FinanceOfferDetails adetaillist = resp.getFinanceOfferInfo();
|
|
|
+ List<OfferDetailAndFinanceAccept> restlist = adetaillist.getOfferDetailAndFinanceAcceptInfoList();
|
|
|
+ for(OfferDetailAndFinanceAccept rest :restlist){
|
|
|
+ ordersqls.add("insert into ACCEPTFINANCEDEMANDDETAIL(ID,CODE,FINANCEDEMANDCODE,CUSTENUU,CUSTENNAME,CUSTGRADE,PAYMENTS,ORDERID,ORDERCODE,ORDERTOTAL,"
|
|
|
+ + "ACCEPTAMOUNT,UPLOADSTATUS) "
|
|
|
+ + "values (ACCEPTFINANCEDEMANDDETAIL_seq.nextval,'"+rest.getFinanceDemandDetail().getCode()+"','"+rest.getFinanceDemandDetail().getFinanceDemandCode()+"','"+rest.getFinanceDemandDetail().getCustEnuu()+"',"
|
|
|
+ + "'"+rest.getFinanceDemandDetail().getCustEnName()+"','"+rest.getFinanceDemandDetail().getCustGrade()+"','"+rest.getFinanceDemandDetail().getPayments()+"','"+rest.getFinanceDemandDetail().getOrderId()+"',"
|
|
|
+ + "'"+rest.getFinanceDemandDetail().getOrderCode()+"','"+rest.getFinanceDemandDetail().getOrderTotal()+"','"+rest.getFinanceDemandDetail().getAcceptAmount()+"','已上传'");
|
|
|
+
|
|
|
+ acceptsqls.add("insert into FINANCEDEMANDDETAILACCEPT(ID,CODE,FINANCEDEMANDCODE,FINANCEDEMANDDETAILCODE,ORDERITEMID,ACCEPTITEMID,ACCEPTID,ACCEPTAMOUNT,ACCEPTDATE,ACCEPTCODE,"
|
|
|
+ + "ACCEPTSTATUS,TITLE,SPEC,PRODUCTCODE,STATUS,UPLOADSTATUS) "
|
|
|
+ + "values (FINANCEDEMANDDETAILACCEPT_seq.nextval,'"+rest.getFinanceDemandDetailAccept().getCode()+"','"+rest.getFinanceDemandDetailAccept().getFinanceDemandCode()+"','"+rest.getFinanceDemandDetailAccept().getFinanceDemandDetailCode()+"',"
|
|
|
+ + "'"+rest.getFinanceDemandDetailAccept().getOrderItemId()+"','"+rest.getFinanceDemandDetailAccept().getAcceptId()+"','"+rest.getFinanceDemandDetailAccept().getAcceptAmount()+"','"+rest.getFinanceDemandDetailAccept().getAcceptDate()+"',"
|
|
|
+ + "'"+rest.getFinanceDemandDetailAccept().getAcceptCode()+"','"+rest.getFinanceDemandDetailAccept().getAcceptStatus()+"','"+rest.getFinanceDemandDetailAccept().getTitle()+"','"+rest.getFinanceDemandDetailAccept().getSpec()+"','"+rest.getFinanceDemandDetailAccept().getProductCode()+"','"+rest.getFinanceDemandDetailAccept().getStatus()+"','已上传'");
|
|
|
+ }
|
|
|
+ System.out.println(ordersqls);
|
|
|
+ jdbcTemplate.batchExecute(ordersqls);
|
|
|
+ jdbcTemplate.batchExecute(acceptsqls);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 上传卖方客户额度申请
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ @TaskMapping(title = "上传卖方客户额度申请", fixedDelay = 60000, method = Method.DOWNLOAD)
|
|
|
+ public void saveOfferQuotaInfoReq() throws Exception{
|
|
|
+ List<Map<String, Object>> customerQuotaUpload = getCustomerQuotaUpload();
|
|
|
+ if (!CollectionUtils.isEmpty(customerQuotaUpload)) {
|
|
|
+ List<String> sqlList = new ArrayList<>();
|
|
|
+ for (Map<String, Object> map:customerQuotaUpload) {
|
|
|
+ //资金方UU
|
|
|
+ Object cq_factoruu = map.get("CQ_FACTORUU");
|
|
|
+ Integer cqFactoruu =10046945;
|
|
|
+ if (cq_factoruu!=null) {
|
|
|
+ cqFactoruu = Integer.valueOf(cq_factoruu.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ //融资方UU
|
|
|
+ Object cq_custuu = map.get("CQ_CUSTUU");
|
|
|
+ Integer cqCustuu =0;
|
|
|
+ if (cq_custuu!=null) {
|
|
|
+ cqCustuu = Integer.valueOf(cq_custuu.toString());
|
|
|
+ }
|
|
|
+ //融资方企业名称
|
|
|
+ Object cq_custname = map.get("CQ_CUSTNAME");
|
|
|
+ String cqCustname = map.get("CQ_CUSTNAME").toString();
|
|
|
+ //授信期限(月)
|
|
|
+ Integer cqEffectdays = Integer.valueOf(map.get("CQ_EFFECTDAYS").toString());
|
|
|
+ //当前额度
|
|
|
+ Double cqQuota = Double.valueOf(map.get("CQ_QUOTA").toString())/10000;
|
|
|
+ //融资比例
|
|
|
+ Double cqLendrate = Double.valueOf(map.get("CQ_LENDRATE").toString());
|
|
|
+ //年化利率
|
|
|
+ Double cqAnnualrate = Double.valueOf(map.get("CQ_ANNUALRATE").toString());
|
|
|
+ //还款方式
|
|
|
+ String cqRepaymentmeans = map.get("CQ_REPAYMENTMEANS").toString();
|
|
|
+ //录入人UU
|
|
|
+ Object cq_recorderuu = map.get("CQ_RECORDERUU");
|
|
|
+ Integer cqRecorderuu =1000014617;
|
|
|
+ if (cq_recorderuu!=null) {
|
|
|
+ cqRecorderuu = Integer.valueOf(cq_recorderuu.toString());
|
|
|
+ }
|
|
|
+ SaveOfferQuotaInfoReq.Builder req = SaveOfferQuotaInfoReq.newBuilder();
|
|
|
+ req.setCsEnuu(cqFactoruu).setCsEnName("深圳市英唐保理有限公司").setFsEnuu(cqCustuu).setFsEnName(cqCustname).setQuotaAmount(cqQuota)
|
|
|
+ .setCredDays(cqEffectdays).setFinanceRate(cqLendrate).setOfferRate(cqAnnualrate).setRepayment(
|
|
|
+ cqRepaymentmeans).setApplyUu(cqRecorderuu);
|
|
|
+ SaveOfferQuotaInfoResp resp = capitalSideSdk.saveOfferQuotaInfo(req);
|
|
|
+ String s = ProtoBufUtil.toJSON(resp);
|
|
|
+ JSONObject jsonObject = JSONObject.parseObject(s);
|
|
|
+ Object code = JSONObject.parseObject(jsonObject.get("respHeader").toString()).get("code");
|
|
|
+ if ("0".equals(code.toString())){
|
|
|
+ sqlList.add("update customerQuota set CQ_UPLOADSTATUS = '已上传' where cq_id = " + map.get("CQ_ID"));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (!CollectionUtils.isEmpty(sqlList)) {
|
|
|
+ jdbcTemplate.batchExecute(sqlList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取需要上传的卖方客户额度申请
|
|
|
+ *
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private List<Map<String, Object>> getCustomerQuotaUpload() {
|
|
|
+ List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from (select cq_id,cq_factoruu," +
|
|
|
+ "cq_custuu,cq_custname,cq_effectdays,cq_quota,cq_lendrate,cq_annualrate," +
|
|
|
+ "cq_repaymentmeans,cq_recorderuu from " +
|
|
|
+ "customerQuota where " +
|
|
|
+ "CQ_UPLOADSTATUS='待上传' and cq_quotatype='卖方客户' order by cq_code ) where rownum < 100");
|
|
|
+ return maps;
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|