双数据源

ZY

19 小时以前 a04129405c79496236fff3b1fd8de5b70c5b3fda

双数据源

 src/main/java/com/zy/Boot.java

@@ -1,6 +1,7 @@
package com.zy;

import com.zy.common.utils.RandomValidateCodeUtil;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;

 src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java

@@ -13,7 +13,7 @@
import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = {"com.zy.asrs.*.*", "com.zy.system.*.*"}, sqlSessionFactoryRef = "primarySqlSessionFactory")
@MapperScan(basePackages = {"com.zy.asrs.mapper", "com.zy.system.mapper"}, sqlSessionFactoryRef = "primarySqlSessionFactory")
public class PrimaryDataSourceConfig {

    @Bean(name = "primarySqlSessionFactory")

 src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java

@@ -12,7 +12,7 @@
import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.zy.nc", sqlSessionFactoryRef = "secondarySqlSessionFactory")
@MapperScan(basePackages = "com.zy.nc.mapper", sqlSessionFactoryRef = "secondarySqlSessionFactory")
public class SecondaryDataSourceConfig {

    @Bean(name = "secondarySqlSessionFactory")
@@ -21,7 +21,7 @@
        sessionFactory.setDataSource(dataSource);
        // 设置MyBatis的Mapper XML文件路径
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper2/*.xml"));
                .getResources("classpath:mapper/**/*.xml"));
        return sessionFactory.getObject();
    }


 src/main/java/com/zy/nc/entity/NccSaleXsckmx.java

New file
@@ -0,0 +1,134 @@
package com.zy.nc.entity;

import com.baomidou.mybatisplus.annotations.TableId;
import com.baomidou.mybatisplus.annotations.TableName;
import lombok.Data;

import java.io.Serializable;
import java.math.BigDecimal;

@Data
@TableName("ncc_sale_xsckmx")
public class NccSaleXsckmx implements Serializable {

    @TableId
    private String cgeneralbid;

    private String cszzbm;

    private String xxzzmc;

    private String xsbmbm;

    private String xsbmmc;

    private String billcode;

    private String hts;

    private String billdate;

    private BigDecimal hdr;

    private String approdate;

    private String saler;

    private String djlx;

    private String storname;

    private String storcode;

    private String sssyb;

    private String custcode;

    private String custname;

    private String maker;

    private String approver;

    private String taudittime;

    private String status;

    private String crowno;

    private BigDecimal bdr;

    private String bts;

    private String mlbm;

    private String mlmc;

    private String wlu8Name;

    private String mlgg;

    private String mlxh;

    private String mlflbm;

    private String mlflmc;

    private String zsjflbm;

    private String zsjflmc;

    private String mlzdw;

    private String mlfdw;

    private BigDecimal sffsl;

    private BigDecimal sfzsl;

    private BigDecimal norigtaxnetprice;

    private BigDecimal ntaxprice;

    private BigDecimal norigprice;

    private BigDecimal nprice;

    private BigDecimal ntaxmny;

    private BigDecimal nmny;

    private BigDecimal ntax;

    private String vbatchcode;

    private String jt1;

    private String jt2;

    private String jt3;

    private String gx;

    private String clcj;

    private String ytdjh;

    private String lydjh;

    private String xsqy;

    private String xsflbm;

    private String xsflmc;

    private String ckbm;

    private String ckmc;

    private String sjflbm;

    private String sjflmc;


}

 src/main/java/com/zy/nc/mapper/NccSaleXsckmxMapper.java

New file
@@ -0,0 +1,12 @@
package com.zy.nc.mapper;

import com.baomidou.mybatisplus.mapper.BaseMapper;
import com.zy.nc.entity.NccSaleXsckmx;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;

@Mapper
@Repository
public interface NccSaleXsckmxMapper extends BaseMapper<NccSaleXsckmx> {

}

 src/main/java/com/zy/nc/task/PlanOrderTask.java

New file
@@ -0,0 +1,25 @@
package com.zy.nc.task;

import com.zy.asrs.task.core.ReturnT;
import com.zy.nc.task.handler.PlanOrderHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class PlanOrderTask {

    @Autowired
    private PlanOrderHandler planOrderHandler;

    @Scheduled(cron = "0/3 * * * * ? ")
    public void execute() {
        ReturnT<String> returnT = planOrderHandler.start();
        if (!returnT.isSuccess()) {
            log.error(returnT.getMsg());
        }
    }

}

 src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java

New file
@@ -0,0 +1,25 @@
package com.zy.nc.task.handler;

import com.alibaba.fastjson.JSONObject;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.nc.entity.NccSaleXsckmx;
import com.zy.nc.mapper.NccSaleXsckmxMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
@Slf4j
public class PlanOrderHandler extends AbstractHandler<String> {

    @Autowired
    private NccSaleXsckmxMapper nccSaleXsckmxMapper;

    public ReturnT<String> start() {
        NccSaleXsckmx nccSaleXsckmx = nccSaleXsckmxMapper.selectById("1001A1100000000H9KKJ");
        log.info("shuju:{}", JSONObject.toJSON(nccSaleXsckmx));
        return SUCCESS;
    }

}

 src/main/resources/application.yml

@@ -34,7 +34,10 @@
    driver-class-name: com.mysql.cj.jdbc.Driver

mybatis-plus:
  mapper-locations: classpath:mapper/*.xml
  mapper-locations:
    - classpath:mapper/*.xml
    - classpath*:mapper2/*.xml
  type-aliases-package: com.zy.**

logging:
  path: /stock/out/@pom.build.finalName@/logs

 src/main/resources/mapper/nc/NccSaleXsckmxMapper.xml

New file
@@ -0,0 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zy.nc.mapper.NccSaleXsckmxMapper">



</mapper>

 src/main/resources/mapper2/test