sqlserver拿视图数据存储mysql表

lige

2023-12-11 926dc4daf0ea8be960647ecaeec389e866037ef9

sqlserver拿视图数据存储mysql表

 ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java

New file
@@ -0,0 +1,102 @@
package com.ltkj.web.controller.sqlserver;

import com.ltkj.common.core.controller.BaseController;
import com.ltkj.common.core.domain.AjaxResult;
import com.ltkj.common.enums.DataSourceType;
import com.ltkj.framework.datasource.DynamicDataSourceContextHolder;
import com.ltkj.hosp.service.LtkjMiddleDetailService;
import com.ltkj.hosp.service.LtkjMiddleHeadService;
import com.ltkj.hosp.service.TjvLtkjvtjpatService;
import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail;
import com.ltkj.hosp.sqlDomain.LtkjMiddleHead;
import com.ltkj.hosp.sqlDomain.LtkjTjPat;
import com.ltkj.hosp.mapper.TestMapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.List;


@RestController
@RequestMapping("/sqlserver/getdata")
@Api(tags = "获取从库数据")
public class TjSqlController extends BaseController {
    @Resource
    private TestMapper testMapper;

    @Resource
    private TjvLtkjvtjpatService tjvLtkjvtjpatService;

    @Resource
    private LtkjMiddleDetailService middleDetailService;

    @Resource
    private LtkjMiddleHeadService headService;


    @GetMapping("/getMiddleDetail")
    @ApiOperation(value = "查看列表")
    public AjaxResult getMiddleDetail() {
        List<LtkjMiddleDetail> list = testMapper.getMiddleDetail();
        return AjaxResult.success(list);
    }


    @GetMapping("/getMiddleHead")
    @ApiOperation(value = "查看列表")
    public AjaxResult getMiddleHead() {
        List<LtkjMiddleHead> list = testMapper.getMiddleHead();
        return AjaxResult.success(list);
    }

//    @GetMapping("/getVbjitem")
//    @ApiOperation(value = "查看列表")
//    public AjaxResult getVbjitem() {
//        List<LtkjVbjitem> list = testMapper.getVbjitem();
//        return AjaxResult.success(list);
//    }


    @GetMapping("/getTjPat")
    @ApiOperation(value = "查看列表")
    public AjaxResult getTjPat() {
        List<LtkjTjPat> list = testMapper.getTjPat();
        return AjaxResult.success(list);
    }


    @GetMapping("/getLtkjTjPatById")
    @ApiOperation(value = "根据id查,存进mysql")
    public AjaxResult getLtkjTjPatById(String id) {
        LtkjTjPat one = testMapper.getTjPatById(id);
        DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
        final boolean save = tjvLtkjvtjpatService.save(one);
        DynamicDataSourceContextHolder.clearDataSourceType();
        return AjaxResult.success(save);
    }


    @GetMapping("/getMiddleDetailById")
    @ApiOperation(value = "根据id查,存进mysql")
    public AjaxResult getMiddleDetailById(String id) {
        LtkjMiddleDetail one = testMapper.getMiddleDetailById(id);
        DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
        final boolean save = middleDetailService.save(one);
        DynamicDataSourceContextHolder.clearDataSourceType();
        return AjaxResult.success(save);
    }


    @GetMapping("/getMiddleHeadById")
    @ApiOperation(value = "根据id查,存进mysql")
    public AjaxResult getMiddleHeadById(String id) {
        LtkjMiddleHead one = testMapper.getMiddleHeadById(id);
        DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
        final boolean save = headService.save(one);
        DynamicDataSourceContextHolder.clearDataSourceType();
        return AjaxResult.success(save);
    }

}

 ltkj-admin/src/test/java/lgTest.java

@@ -1,5 +1,4 @@
import com.ltkj.LtkjApplication;
import com.ltkj.hosp.domain.SqlTest;
import com.ltkj.hosp.mapper.TestMapper;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
@@ -10,8 +9,6 @@
import org.springframework.test.context.junit4.SpringRunner;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;

/**
 * @Company: 西安路泰科技有限公司
@@ -28,8 +25,7 @@
    private TestMapper testMapper;
    @Test
    public void lige() {
        final SqlTest list = testMapper.getList();
        System.out.println(list);

    }

    public static void main(String[] args) {

 ltkj-framework/src/main/java/com/ltkj/framework/config/SecurityConfig.java

@@ -108,7 +108,7 @@
                // 过滤请求
                .authorizeRequests()
                // 对于登录login 注册register 验证码captchaImage 允许匿名访问
                .antMatchers("/login", "/register", "/captchaImage","/cus/**","/getCaptchaConfigKey","/report/jmreport/**").permitAll()
                .antMatchers("/login", "/register", "/captchaImage","/cus/**","/getCaptchaConfigKey","/report/jmreport/**","/sqlserver/getdata/**").permitAll()
                // 静态资源，可匿名访问
                .antMatchers(HttpMethod.GET, "/", "/*.html", "/**/*.html", "/**/*.css", "/**/*.js", "/profile/**").permitAll()
                .antMatchers("/swagger-ui.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**").permitAll()

 ltkj-hosp/src/main/java/com/ltkj/hosp/domain/SqlTest.java

File was deleted

 ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/LtkjMiddleDetailMapper.java

New file
@@ -0,0 +1,18 @@
package com.ltkj.hosp.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ltkj.common.annotation.DataSource;
import com.ltkj.common.enums.DataSourceType;
import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail;
import com.ltkj.hosp.sqlDomain.LtkjTjPat;
import org.apache.ibatis.annotations.Mapper;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:56
 */
@Mapper
@DataSource(value = DataSourceType.MASTER)
public interface LtkjMiddleDetailMapper extends BaseMapper<LtkjMiddleDetail> {
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/LtkjMiddleHeadMapper.java

New file
@@ -0,0 +1,17 @@
package com.ltkj.hosp.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ltkj.common.annotation.DataSource;
import com.ltkj.common.enums.DataSourceType;
import com.ltkj.hosp.sqlDomain.LtkjMiddleHead;
import org.apache.ibatis.annotations.Mapper;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:56
 */
@Mapper
@DataSource(value = DataSourceType.MASTER)
public interface LtkjMiddleHeadMapper extends BaseMapper<LtkjMiddleHead> {
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TestMapper.java

@@ -3,10 +3,14 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ltkj.common.annotation.DataSource;
import com.ltkj.common.enums.DataSourceType;
import com.ltkj.hosp.domain.SqlTest;
import com.ltkj.hosp.domain.TjAdvice;
import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail;
import com.ltkj.hosp.sqlDomain.LtkjMiddleHead;
import com.ltkj.hosp.sqlDomain.LtkjTjPat;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;

import java.util.List;

/**
 * @Company: 西安路泰科技有限公司
@@ -14,8 +18,28 @@
 * @Date: 2023/12/11 14:51
 */
@Mapper
public interface TestMapper extends BaseMapper<SqlTest> {
    @DataSource(value = DataSourceType.SLAVE)
    @Select("select * from City where id=1")
    public SqlTest getList();
@DataSource(value = DataSourceType.SLAVE)
public interface TestMapper{

    @Select("SELECT * FROM tjv_Ltkj_middle_detail")
    public List<LtkjMiddleDetail> getMiddleDetail();

    @Select("SELECT * FROM tjv_Ltkj_middle_head")
    public List<LtkjMiddleHead> getMiddleHead();

//    @Select("SELECT * FROM tjv_LTKJVBJITEM")
//    public List<LtkjVbjitem> getVbjitem();

    @Select("SELECT * FROM tjv_LTKJVTJPAT")
    public List<LtkjTjPat> getTjPat();


    @Select("SELECT * FROM tjv_LTKJVTJPAT where pat_id=#{id}")
    public LtkjTjPat getTjPatById(String id);

    @Select("SELECT * FROM tjv_Ltkj_middle_detail where fdetall_id=#{id}")
    public LtkjMiddleDetail getMiddleDetailById(String id);

    @Select("SELECT * FROM tjv_Ltkj_middle_head where fead_id=#{id}")
    public LtkjMiddleHead getMiddleHeadById(String id);
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TjvLtkjvtjpatMapper.java

New file
@@ -0,0 +1,18 @@
package com.ltkj.hosp.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ltkj.common.annotation.DataSource;
import com.ltkj.common.enums.DataSourceType;
import com.ltkj.hosp.domain.TjTollCollector;
import com.ltkj.hosp.sqlDomain.LtkjTjPat;
import org.apache.ibatis.annotations.Mapper;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:56
 */
@Mapper
@DataSource(value = DataSourceType.MASTER)
public interface TjvLtkjvtjpatMapper extends BaseMapper<LtkjTjPat> {
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/service/LtkjMiddleDetailService.java

New file
@@ -0,0 +1,12 @@
package com.ltkj.hosp.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:57
 */
public interface LtkjMiddleDetailService extends IService<LtkjMiddleDetail> {
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/service/LtkjMiddleHeadService.java

New file
@@ -0,0 +1,12 @@
package com.ltkj.hosp.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.ltkj.hosp.sqlDomain.LtkjMiddleHead;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:57
 */
public interface LtkjMiddleHeadService extends IService<LtkjMiddleHead> {
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/service/TjvLtkjvtjpatService.java

New file
@@ -0,0 +1,13 @@
package com.ltkj.hosp.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.ltkj.hosp.domain.TjReport;
import com.ltkj.hosp.sqlDomain.LtkjTjPat;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:57
 */
public interface TjvLtkjvtjpatService  extends IService<LtkjTjPat> {
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/LtkjMiddleDetailImpl.java

New file
@@ -0,0 +1,18 @@
package com.ltkj.hosp.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ltkj.hosp.mapper.LtkjMiddleDetailMapper;
import com.ltkj.hosp.service.LtkjMiddleDetailService;
import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail;
import org.springframework.stereotype.Service;

/**
 * 病种+意见Service业务层处理
 *
 * @author ltkj_赵佳豪&李格
 * @date 2023-08-30
 */
@Service
public class LtkjMiddleDetailImpl extends ServiceImpl<LtkjMiddleDetailMapper, LtkjMiddleDetail> implements LtkjMiddleDetailService {

}

 ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/LtkjMiddleHeadImpl.java

New file
@@ -0,0 +1,20 @@
package com.ltkj.hosp.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ltkj.hosp.mapper.LtkjMiddleDetailMapper;
import com.ltkj.hosp.mapper.LtkjMiddleHeadMapper;
import com.ltkj.hosp.service.LtkjMiddleDetailService;
import com.ltkj.hosp.service.LtkjMiddleHeadService;
import com.ltkj.hosp.sqlDomain.LtkjMiddleHead;
import org.springframework.stereotype.Service;

/**
 * 病种+意见Service业务层处理
 *
 * @author ltkj_赵佳豪&李格
 * @date 2023-08-30
 */
@Service
public class LtkjMiddleHeadImpl extends ServiceImpl<LtkjMiddleHeadMapper, LtkjMiddleHead>  implements LtkjMiddleHeadService {

}

 ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjvLtkjvtjpatServiceImpl.java

New file
@@ -0,0 +1,21 @@
package com.ltkj.hosp.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ltkj.hosp.domain.TjRuleAdvice;
import com.ltkj.hosp.mapper.TjRuleAdviceMapper;
import com.ltkj.hosp.mapper.TjvLtkjvtjpatMapper;
import com.ltkj.hosp.service.ITjRuleAdviceService;
import com.ltkj.hosp.service.TjvLtkjvtjpatService;
import com.ltkj.hosp.sqlDomain.LtkjTjPat;
import org.springframework.stereotype.Service;

/**
 * 病种+意见Service业务层处理
 *
 * @author ltkj_赵佳豪&李格
 * @date 2023-08-30
 */
@Service
public class TjvLtkjvtjpatServiceImpl extends ServiceImpl<TjvLtkjvtjpatMapper, LtkjTjPat>  implements TjvLtkjvtjpatService {

}

 ltkj-hosp/src/main/java/com/ltkj/hosp/sqlDomain/LtkjMiddleDetail.java

New file
@@ -0,0 +1,22 @@
package com.ltkj.hosp.sqlDomain;

import lombok.Data;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 16:37
 */
@Data
public class LtkjMiddleDetail {
    private String fdetallId;
    private String fheadId;
    private String chgItemid;
    private String chgItemname;
    private String itemId;
    private String rprice;
    private String quantity;
    private String sumTotal;
    private String discount;
    private String checkexamId;
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/sqlDomain/LtkjMiddleHead.java

New file
@@ -0,0 +1,25 @@
package com.ltkj.hosp.sqlDomain;

import lombok.Data;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:13
 */
@Data
public class LtkjMiddleHead {
    private String feadId;
    private String patBarCode;
    private String patId;
    private String isChg;
    private String chgnoteId;
    private String invoiceId;
    private String chgDate;
    private String cancelApp;
    private String cancelAppDate;
    private String isCanceled;
    private String canceledDate;
    private String insertTime;

}

 ltkj-hosp/src/main/java/com/ltkj/hosp/sqlDomain/LtkjTjPat.java

New file
@@ -0,0 +1,28 @@
package com.ltkj.hosp.sqlDomain;

import lombok.Data;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:20
 */
@Data
public class LtkjTjPat {
    private String patId;
    private String patName;
    private String patsexId;
    private String patbDate;
    private String addressHeng;
    private String addressHi;
    private String addresXianq;
    private String addresXiangz;
    private String addressHeqc;
    private String addresXiangx;
    private String fullAddress;
    private String fixPhone;
    private String mobile;
    private String postBox;
    private String fcardId;
    private String fcardNo;
}

 ltkj-hosp/src/main/java/com/ltkj/hosp/sqlDomain/LtkjVbjitem.java

New file
@@ -0,0 +1,20 @@
package com.ltkj.hosp.sqlDomain;

import lombok.Data;

/**
 * @Company: 西安路泰科技有限公司
 * @Author: lige
 * @Date: 2023/12/11 17:18
 */
@Data
public class LtkjVbjitem {
    private String itemId;
    private String itemCnname;
    private String rprice;
    private String pkgUnit;
    private String pkgName;
    private String pkgId;
    private String pkgDept;
    private String pkgDeptid;
}