Commit 424aa764 by gechengyang

提交多数据源切换版本,可以正常返回收报查询列表

parent 4b28fb4b
......@@ -5,11 +5,17 @@ import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
@SpringBootApplication(scanBasePackages = {"com.brilliance.mda", "com.ceb.gjjs.mda"},exclude={DataSourceAutoConfiguration.class})
@SpringBootApplication(exclude={DataSourceAutoConfiguration.class},scanBasePackages = {"com.brilliance.mda", "com.ceb.gjjs.mda"})
@MapperScan({"com.ceb.gjjs.mda.dao","com.brilliance.mda.support.mybatis.dync.mapper"})
public class Bd2poinnewApplication {
public static void main(String[] args) {
SpringApplication.run(Bd2poinnewApplication.class, args);
// TestConfig bean = MdaEnv.getBean(TestConfig.class);
// System.out.println(bean);
// System.out.println(bean.getProperty());
}
}
package com.ceb.gjjs.mda.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import java.util.List;
import java.util.Map;
/**
* 测试使用
*/
@Configuration
@ConfigurationProperties(prefix = "spring")
@Data
public class TestConfig {
@Autowired
private Environment environment;
//@Value("${spring.datasource.swd.password}")
private String swdpassword;
private List list;
private Map dataSourceMap;
private Map duridMap;
public String getSwdpassword() {
return swdpassword;
}
public void setSwdpassword(String swdpassword) {
this.swdpassword = swdpassword;
}
public Map<String, String> getDataSourceMap() {
return dataSourceMap;
}
public void setDataSourceMap(Map<String, String> dataSourceMap) {
this.dataSourceMap = dataSourceMap;
}
public Map<String, List<String>> getDuridMap() {
return duridMap;
}
public void setDuridMap(Map<String, List<String>> duridMap) {
this.duridMap = duridMap;
}
public String getProperty()
{
return environment.getProperty("spring.datasource");
}
}
......@@ -17,6 +17,7 @@ import lombok.Setter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.util.*;
import java.util.regex.Matcher;
......@@ -866,6 +867,8 @@ public class Rcvp extends AbstractModule{
{
this.getMsggrp().getMpss().getElement(i).setSweflg(NULLSTR);
}
Field[] ff= this.getMsggrp().getMpis().getElement(i).getClass().getDeclaredFields();
System.out.println(ff[0].getName());
this.getMsggrp().getRcvlst().add(new Argument("inr",this.getMsggrp().getMpss().getElement(i).getInr()),new Argument("dir",this.getMsggrp().getMpss().getElement(i).getDir()),new Argument("srcchncod",this.getMsggrp().getMpss().getElement(i).getSrcchncod()),new Argument("chncod",this.getMsggrp().getMpss().getElement(i).getChncod()),new Argument("nxtchncod",this.getMsggrp().getMpss().getElement(i).getNxtchncod()),new Argument("tgtchncod",this.getMsggrp().getMpss().getElement(i).getTgtchncod()),new Argument("smhinr",this.getMsggrp().getMpss().getElement(i).getSmhinr()),new Argument("sta",this.getMsggrp().getMpss().getElement(i).getSta()),new Argument("rspsta",this.getMsggrp().getMpss().getElement(i).getRspsta()),new Argument("rcvdattim",this.getMsggrp().getMpss().getElement(i).getRcvdattim()),new Argument("lstdattim",this.getMsggrp().getMpss().getElement(i).getLstdattim()),new Argument("sttdattim",this.getMsggrp().getMpss().getElement(i).getSttdattim()),new Argument("tgtdattime",this.getMsggrp().getMpss().getElement(i).getTgtdattime()),new Argument("snddattim",this.getMsggrp().getMpss().getElement(i).getSnddattim()),new Argument("rspdattim",this.getMsggrp().getMpss().getElement(i).getRspdattim()),new Argument("ownref",this.getMsggrp().getMpis().getElement(i).getOwnref()),new Argument("othref",this.getMsggrp().getMpis().getElement(i).getOthref()),new Argument("sndbic",this.getMsggrp().getMpis().getElement(i).getSndbic()),new Argument("rcvbic",this.getMsggrp().getMpis().getElement(i).getRcvbic()),new Argument("act",this.getMsggrp().getMpis().getElement(i).getAct()),new Argument("dtlchg",this.getMsggrp().getMpis().getElement(i).getDtlchg()),new Argument("cur",this.getMsggrp().getMpis().getElement(i).getCur()),new Argument("amt",this.getMsggrp().getMpis().getElement(i).getAmt()),new Argument("valdat",this.getMsggrp().getMpis().getElement(i).getValdat()),new Argument("msgtyp",this.getMsggrp().getMpis().getElement(i).getMsgtyp()),new Argument("subtyp",this.getMsggrp().getMpis().getElement(i).getSubtyp()),new Argument("actbic",this.getMsggrp().getMpis().getElement(i).getActbic()),new Argument("t53bic",this.getMsggrp().getMpis().getElement(i).getT53bic()),new Argument("gpi",this.getMsggrp().getMpis().getElement(i).getGpi()),new Argument("uetr",this.getMsggrp().getMpis().getElement(i).getUetr()),new Argument("lstdattim",this.getMsggrp().getMpss().getElement(i).getLstdattim()),new Argument("lcnb",this.getMsggrp().getMpis().getElement(i).getLcnb()),new Argument("sweflg",this.getMsggrp().getMpss().getElement(i).getSweflg()));
//this.getMsggrp().getRcvlst().add(this.getMsggrp().getMpss().getElement(i).getInr(),this.getMsggrp().getMpss().getElement(i).getDir(),this.getMsggrp().getMpss().getElement(i).getSrcchncod(),this.getMsggrp().getMpss().getElement(i).getChncod(),this.getMsggrp().getMpss().getElement(i).getNxtchncod(),this.getMsggrp().getMpss().getElement(i).getTgtchncod(),this.getMsggrp().getMpss().getElement(i).getSmhinr(),this.getMsggrp().getMpss().getElement(i).getSta(),this.getMsggrp().getMpss().getElement(i).getRspsta(),this.getMsggrp().getMpss().getElement(i).getRcvdattim(),this.getMsggrp().getMpss().getElement(i).getLstdattim(),this.getMsggrp().getMpss().getElement(i).getSttdattim(),this.getMsggrp().getMpss().getElement(i).getTgtdattime(),this.getMsggrp().getMpss().getElement(i).getSnddattim(),this.getMsggrp().getMpss().getElement(i).getRspdattim(),this.getMsggrp().getMpis().getElement(i).getOwnref(),this.getMsggrp().getMpis().getElement(i).getOthref(),this.getMsggrp().getMpis().getElement(i).getSndbic(),this.getMsggrp().getMpis().getElement(i).getRcvbic(),this.getMsggrp().getMpis().getElement(i).getAct(),this.getMsggrp().getMpis().getElement(i).getDtlchg(),this.getMsggrp().getMpis().getElement(i).getCur(),this.getMsggrp().getMpis().getElement(i).getAmt(),this.getMsggrp().getMpis().getElement(i).getValdat(),this.getMsggrp().getMpis().getElement(i).getMsgtyp(),this.getMsggrp().getMpis().getElement(i).getSubtyp(),this.getMsggrp().getMpis().getElement(i).getActbic(),this.getMsggrp().getMpis().getElement(i).getT53bic(),this.getMsggrp().getMpis().getElement(i).getGpi(),this.getMsggrp().getMpis().getElement(i).getUetr(),this.getMsggrp().getMpss().getElement(i).getLstdattim(),this.getMsggrp().getMpis().getElement(i).getLcnb(), this.getMsggrp().getMpss().getElement(i).getSweflg());
......
......@@ -5,21 +5,20 @@ server:
spring:
datasource:
swd:
jdbc-url: jdbc:postgresql://114.115.138.98:9622/swd?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&allowMultiQueries=true
eibs:
jdbc-url: jdbc:postgresql://114.115.138.98:9622/eibs?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&allowMultiQueries=true
driver-class-name: org.postgresql.Driver
username: postgres
password: postgres
fxd:
jdbc-url: jdbc:postgresql://114.115.138.98:9622/fxd?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&allowMultiQueries=true
swd:
jdbc-url: jdbc:postgresql://114.115.138.98:9622/swd?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&allowMultiQueries=true
driver-class-name: org.postgresql.Driver
username: postgres
password: postgres
eibs:
jdbc-url: jdbc:postgresql://114.115.138.98:9622/eibs?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&allowMultiQueries=true
fxd:
jdbc-url: jdbc:postgresql://114.115.138.98:9622/fxd?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&allowMultiQueries=true
driver-class-name: org.postgresql.Driver
username: postgres
password: postgres
......
spring:
profiles:
active: pg
active: db
logging:
config: classpath:logback.xml
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment