Procházet zdrojové kódy

下载u智融数据

tanmh před 5 roky
rodič
revize
d38df7ed6d

+ 25 - 0
.classpath

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="bin/main" path="src/main/java">
+		<attributes>
+			<attribute name="gradle_scope" value="main"/>
+			<attribute name="gradle_used_by_scope" value="main,test"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="bin/test" path="src/test/java">
+		<attributes>
+			<attribute name="gradle_scope" value="test"/>
+			<attribute name="gradle_used_by_scope" value="test"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="bin/main" path="src/main/resources">
+		<attributes>
+			<attribute name="gradle_scope" value="main"/>
+			<attribute name="gradle_used_by_scope" value="main,test"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7/"/>
+	<classpathentry kind="con" path="org.eclipse.buildship.core.gradleclasspathcontainer"/>
+	<classpathentry kind="output" path="bin/default"/>
+</classpath>

+ 1 - 0
.gitignore

@@ -42,3 +42,4 @@ gradle-app.setting
 *.zip
 *.tar.gz
 *.rar
+/bin/

+ 42 - 0
.project

@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>uas-schedular</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.buildship.core.gradleprojectbuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.wst.jsdt.core.javascriptValidator</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.wst.common.project.facet.core.builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.wst.validation.validationbuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jem.workbench.JavaEMFNature</nature>
+		<nature>org.eclipse.wst.common.modulecore.ModuleCoreNature</nature>
+		<nature>org.eclipse.wst.common.project.facet.core.nature</nature>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.wst.jsdt.core.jsNature</nature>
+		<nature>org.eclipse.buildship.core.gradleprojectnature</nature>
+	</natures>
+</projectDescription>

+ 12 - 0
.settings/.jsdtscope

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="WebContent"/>
+	<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.JRE_CONTAINER"/>
+	<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.WebProject">
+		<attributes>
+			<attribute name="hide" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.baseBrowserLibrary"/>
+	<classpathentry kind="output" path=""/>
+</classpath>

+ 13 - 0
.settings/org.eclipse.buildship.core.prefs

@@ -0,0 +1,13 @@
+arguments=
+auto.sync=false
+build.scans.enabled=false
+connection.gradle.distribution=GRADLE_DISTRIBUTION(LOCAL_INSTALLATION(D\:\\gradle\\gradle-6.0.1))
+connection.project.dir=
+eclipse.preferences.version=1
+gradle.user.home=D\:/gradle/gradle-6.0.1
+java.home=
+jvm.arguments=
+offline.mode=false
+override.workspace.settings=true
+show.console.view=true
+show.executions.view=true

+ 7 - 0
.settings/org.eclipse.jdt.core.prefs

@@ -0,0 +1,7 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7
+org.eclipse.jdt.core.compiler.compliance=1.7
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.source=1.7

+ 9 - 0
.settings/org.eclipse.wst.common.component

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?><project-modules id="moduleCoreId" project-version="1.5.0">
+    <wb-module deploy-name="uas-schedular">
+        <wb-resource deploy-path="/" source-path="/WebContent" tag="defaultRootSource"/>
+        <wb-resource deploy-path="/WEB-INF/classes" source-path="/src/main/java"/>
+        <wb-resource deploy-path="/WEB-INF/classes" source-path="/src/test/java"/>
+        <property name="java-output-path" value="/uas-schedular/bin"/>
+        <property name="context-root" value="uas-schedular"/>
+    </wb-module>
+</project-modules>

+ 7 - 0
.settings/org.eclipse.wst.common.project.facet.core.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<faceted-project>
+  <fixed facet="wst.jsdt.web"/>
+  <installed facet="java" version="1.8"/>
+  <installed facet="jst.web" version="3.0"/>
+  <installed facet="wst.jsdt.web" version="1.0"/>
+</faceted-project>

+ 1 - 0
.settings/org.eclipse.wst.jsdt.ui.superType.container

@@ -0,0 +1 @@
+org.eclipse.wst.jsdt.launching.baseBrowserLibrary

+ 1 - 0
.settings/org.eclipse.wst.jsdt.ui.superType.name

@@ -0,0 +1 @@
+Window

+ 3 - 0
WebContent/META-INF/MANIFEST.MF

@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Class-Path: 
+

+ 3 - 0
build.gradle

@@ -41,6 +41,8 @@ repositories {
 	maven { url "http://10.10.100.21:8081/artifactory/ext-release-local" }
     maven { url "http://10.10.100.21:8081/artifactory/libs-snapshot-local" }
     maven { url "http://maven.aliyun.com/nexus/content/groups/public/" }
+    maven { url "https://artifactory.uuzcc.cn/artifactory/libs-snapshot" }
+    maven { url "https://artifactory.uuzcc.cn/artifactory/libs-release" }
     mavenCentral()
 }
 
@@ -60,6 +62,7 @@ dependencies {
     compile "org.projectlombok:lombok:1.18.4"
     compile "commons-io:commons-io:2.6"
     compile "com.usoft.framework:usoft-security-utils:dev-1.0-SNAPSHOT"
+    compile "com.usoft.sdk:usoft-sdk-fin:1.0-SNAPSHOT"
 }
 
 bootRun {

+ 136 - 0
src/main/java/com/uas/erp/schedular/finance/task/B2BInformation.java

@@ -0,0 +1,136 @@
+package com.uas.erp.schedular.finance.task;
+
+
+import java.util.ArrayList;
+import java.util.List;
+
+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.AcceptFinanceDemand;
+import com.usoft.fin.external.open.api.entity.AcceptOffer;
+import com.usoft.fin.external.open.api.entity.CapitalSideLoan;
+import com.usoft.fin.external.open.api.entity.FinanceOfferList;
+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.GetCapitalSideLoanReq;
+import com.usoft.fin.external.open.api.protobuf.GetCapitalSideLoanResp;
+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;
+import com.usoft.sdk.fin.client.CapitalSideSdk;
+import com.usoft.sdk.fin.utils.ProtoBufUtil;
+@Component
+@TaskMapping(title = "金融服务", role = Role.SELLER)
+public class B2BInformation  extends AbstractTask{
+	
+	private CapitalSideSdk capitalSideSdk = new CapitalSideSdk("https://finrest.uuzcc.cn", "10050877", "b78d577449b64f56a8a6cf1feeb3fbf5");
+	
+	/**
+	 * 下载放款记录列表
+	 * @throws Exception
+	 */
+    public void getCapitalSideLoan() throws Exception {
+    	final List<String> sqls = new ArrayList<>();
+        GetCapitalSideLoanReq.Builder req = GetCapitalSideLoanReq.newBuilder();
+        req.setPageSize(100);
+        req.setPageNumber(1);
+        //Object venduu = baseDao.getFieldDataByCondition("Enterprise", "en_uu", "1=1");
+        //req.setCsEnuu(10050877);  //保理企业UU
+        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()+"','已上传')");
+        }
+        System.out.println(sqls);
+        jdbcTemplate.batchExecute(sqls);
+       
+    }
+    
+    /**
+     * 报价记录下载
+     * @throws Exception
+     */
+    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();
+		
+		//List<FinanceOfferList> flist = resp.getFinanceOfferInfoList();
+		for(FinanceOfferListOrBuilder Finance :flist){  
+		//FinanceOfferList Finance = flist.get(0);
+			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()+"'"
+        				    + ",'"+Finance.getFinanceDemandInfo()+"','已上传')");
+		}
+        System.out.println(sqlsDemand);
+        jdbcTemplate.batchExecute(sqls);  //报价信息
+        jdbcTemplate.batchExecute(sqlsDemand);   //融资信息
+        
+        
+        
+	}
+    
+    /**
+     * 额度申请
+     * @throws Exception
+     */
+    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()+"','已上传')");
+        }
+		System.out.println(sqls);
+		jdbcTemplate.batchExecute(sqls);
+    }
+
+}

+ 50 - 0
src/test/java/com/uas/erp/test/SdkTest.java

@@ -0,0 +1,50 @@
+package com.uas.erp.test;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import com.uas.erp.schedular.UasSchedulingApplication;
+import com.uas.erp.schedular.entity.Master;
+import com.uas.erp.schedular.finance.task.AbstractTask;
+import com.uas.erp.schedular.finance.task.B2BInformation;
+import com.uas.erp.schedular.util.ContextHolder;
+
+
+/**
+ * Created by Pro1 on 2020/1/13.
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE, classes = UasSchedulingApplication.class)
+public class SdkTest extends AbstractTask {
+	
+	 @Autowired
+	B2BInformation b2BInformation;
+	 
+	 @Test
+	 public void downCapitalSideLoan() throws Exception{
+		 Master master = new Master();
+         master.setMa_user("YITOA_BL");
+         ContextHolder.setMaster(master);
+		 b2BInformation.getCapitalSideLoan();
+	 }
+	 
+	 @Test
+	 public void downOfferQuotaInfoList() throws Exception{
+		 Master master = new Master();
+         master.setMa_user("YITOA_BL");
+         ContextHolder.setMaster(master);
+		 b2BInformation.getOfferQuotaInfoList();
+	 }
+	 @Test
+	 public void getFinanceOfferList() throws Exception{
+		 Master master = new Master();
+         master.setMa_user("YITOA_BL");
+         ContextHolder.setMaster(master);
+		 b2BInformation.getFinanceOfferList();
+	 }
+	 
+	
+}