新增同步工程

yangys

2025-07-31 2e0a915c24c115caff97f68ec073f7a4ae9fa474

新增同步工程

 blade-service/blade-mdm/pom.xml

@@ -104,7 +104,24 @@
            <artifactId>blade-starter-transaction</artifactId>
        </dependency>-->
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <mainClass>org.springblade.mdm.MdmApplication</mainClass>
                    <layout>ZIP</layout>
                    <includes>

                        <include>
                            <groupId>nothing</groupId>
                            <artifactId>nothing</artifactId>
                        </include>


                    </includes>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

 blade-service/blade-qinzhesync/src/main/java/org/springblade/qinzhesync/config/DataSourceConfig.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package org.springblade.qinzhesync.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import javax.sql.DataSource;

@Configuration
public class DataSourceConfig {

    @Primary
    @ConfigurationProperties(prefix="spring.datasource")
    public DataSource dataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean("mdmDdataSource")
    @ConfigurationProperties(prefix="spring.datasource.mdm")
    public DataSource preDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean("qinzheDataSource")
    @ConfigurationProperties(prefix="spring.datasource.qinzhe")
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create().build();
    }
}

 blade-service/blade-qinzhesync/src/main/java/org/springblade/qinzhesync/config/JdbcTemplateConfig.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,35 @@
package org.springblade.qinzhesync.config;

import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.core.JdbcTemplate;

import javax.sql.DataSource;

@Configuration
public class JdbcTemplateConfig {
    private String mapper = "classpath:org/springblade/qinzhesync/mapper/*Mapper.xml";   //xml扫描路径
    @Primary
    @Bean
    public JdbcTemplate primaryJdbcTemplate(@Qualifier("mdmDdataSource") DataSource dataSource) {//
        return new JdbcTemplate(dataSource);
    }

    @Bean
    public JdbcTemplate qingzheJdbcTemplate(@Qualifier("qinzheDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }

    @Bean
    public SqlSessionFactory sqlSessionFactory(@Qualifier("mdmDdataSource") DataSource dataSource) throws Exception {
        final SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        //sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapper));
        return sqlSessionFactoryBean.getObject();
    }
}

 blade-service/blade-qinzhesync/src/main/java/org/springblade/qinzhesync/controller/SyncController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,35 @@
package org.springblade.qinzhesync.controller;

import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tool.api.R;
import org.springblade.qinzhesync.service.QinzheSyncService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@Slf4j
@RestController
@RequestMapping("/test/qinzhe")
@Tag(name = "主制分工表", description = "主制分工表")
public class SyncController {

    @Autowired
    private QinzheSyncService service;

    /**
     * æ–°å¢ž
     */
    @GetMapping("/sync")
    @Operation(summary = "同步", description = "同步分工表")
    public R<Boolean> sync() {
        try {
            service.syncData();
        }catch (Exception e) {
            log.error("同步失败", e);;
            return R.fail(e.getMessage());
        }
        return R.<Boolean>status(true);
    }

}

 blade-service/blade-qinzhesync/src/main/java/org/springblade/qinzhesync/service/QinzheSyncService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,31 @@
package org.springblade.qinzhesync.service;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;

import java.util.Map;

/**
 * å‹¤å“²ä¸»åˆ¶åˆ†å·¥è¡¨æ•°æ®åŒæ­¥çš„服务
 */
@Service
@Slf4j
public class QinzheSyncService {
    @Qualifier("primaryJdbcTemplate")
    @Autowired
    private  JdbcTemplate mdmJdbcTemplate;

    @Qualifier("qingzheJdbcTemplate")
    @Autowired
    private JdbcTemplate qingzheJdbcTemplate;

    public void syncData(){
        Map mmdData = mdmJdbcTemplate.queryForMap("select count(*) n from mdm_machine");
        log.info("mdm:{}",mmdData);
        Map qinzheData = qingzheJdbcTemplate.queryForMap("select count(*) n from mdm_machine");
        log.info("qingzhe:{}",qinzheData);
    }
}

 blade-service/pom.xml

@@ -20,6 +20,8 @@
        <module>blade-desk</module>
        <module>blade-system</module>
        <module>blade-mdm</module>
        <module>blade-qinzhesync</module>

    </modules>

    <dependencies>