zjh 本地 2024/01/30 -1

zjh

2024-01-30 83fbc58aa801c13224dca4cd628d93e4cc5f656e

zjh 本地 2024/01/30 -1

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

@@ -75,6 +75,8 @@
    private ITjOrderService orderService;
    @Resource
    private ISysDeptService deptService;
    @Resource
    private LtkjHisUserService hisUserService;

    @GetMapping("/getTjHyBgList")
    @ApiOperation(value = "查询lis数据库项目信息接口")
@@ -333,5 +335,20 @@
    }



    @GetMapping("/getLtkjHisUser")
    @ApiOperation(value = "同步his用户")
    public AjaxResult getLtkjHisUser() {
        List<LtkjHisUser> list = testMapper.getLtkjHisUser();
        if(null !=list && list.size()>0){
            DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
            for (LtkjHisUser user : list) {
                LtkjHisUser hisUser= hisUserService.getHisUserByHisGh(user.getHisgh());
                if(null == hisUser){
                    hisUserService.save(user);
                }
            }
            DynamicDataSourceContextHolder.clearDataSourceType();
        }
        return AjaxResult.success();
    }
}

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

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

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ltkj.hosp.sqlDomain.LtkjHisUser;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;


@Mapper
public interface LtkjHisUserMapper extends BaseMapper<LtkjHisUser> {

    @Select("SELECT * FROM ltkj_his_user a WHERE a.hisgh=#{hisgh}")
    LtkjHisUser getHisUserByHisGh(String hisgh);
}

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

@@ -184,4 +184,7 @@
                                                  @Param("pacName")String pacName,
                                                  @Param("pacRemark")String pacRemark);

    @Select("SELECT * FROM histjv_ltkj_userinfo")
    @DataSource(value = DataSourceType.SLAVE_HIS)
    public List<LtkjHisUser> getLtkjHisUser();
}

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

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

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

public interface LtkjHisUserService extends IService<LtkjHisUser> {
    LtkjHisUser getHisUserByHisGh(String hisgh);
}

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

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

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ltkj.common.annotation.RepeatSubmit;
import com.ltkj.hosp.mapper.LtkjHisUserMapper;
import com.ltkj.hosp.service.LtkjHisUserService;
import com.ltkj.hosp.sqlDomain.LtkjHisUser;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class LtkjHisUserServiceImpl extends ServiceImpl<LtkjHisUserMapper, LtkjHisUser> implements LtkjHisUserService {

    @Resource
    private LtkjHisUserMapper mapper;

    @Override
    public LtkjHisUser getHisUserByHisGh(String hisgh) {
        return mapper.getHisUserByHisGh(hisgh);
    }
}

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

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

import com.ltkj.common.annotation.DataSource;
import lombok.Data;

@Data
public class LtkjHisUser {

    private String id;
    private String hisgh;
    private String xb;
    private String sfzh;
    private String dh;
    private String ybbm;
    private String zgzh;
    private String zc;
    private String ksdm;
    private String ksmc;
    private String qmtp;
    private String rylx;
    private String ryzt;
    private String csrq;
    private String ghzlbm;
    private String ghzlmc;
    private String czykl;
    private String czyjj;
    private String zsmc;

}