package com.ruoyi.quartz.controller; 
 | 
  
 | 
import com.ruoyi.common.core.controller.BaseController; 
 | 
import com.ruoyi.common.core.domain.AjaxResult; 
 | 
import com.ruoyi.common.core.domain.entity.SysDept; 
 | 
import com.ruoyi.common.core.domain.entity.SysUser; 
 | 
import com.ruoyi.quartz.service.ICollectHISService; 
 | 
import com.smartor.domain.HnDataGatherVO; 
 | 
import com.smartor.domain.Icd10; 
 | 
import com.smartor.service.IHNGatherPatArchiveService; 
 | 
import io.swagger.annotations.Api; 
 | 
import io.swagger.annotations.ApiOperation; 
 | 
import lombok.extern.slf4j.Slf4j; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.web.bind.annotation.PostMapping; 
 | 
import org.springframework.web.bind.annotation.RequestBody; 
 | 
import org.springframework.web.bind.annotation.RequestMapping; 
 | 
import org.springframework.web.bind.annotation.RestController; 
 | 
  
 | 
@Slf4j 
 | 
@RestController 
 | 
@RequestMapping("/monitor/his") 
 | 
@Api(description = "采集患者信息接口") 
 | 
public class CollectHISController extends BaseController { 
 | 
    @Autowired 
 | 
    private ICollectHISService ichService; 
 | 
  
 | 
    /** 
 | 
     * 河南数据采集 
 | 
     */ 
 | 
    @PostMapping("/collect") 
 | 
    @ApiOperation("同步病人相关数据") 
 | 
    public AjaxResult hnDataGather(@RequestBody HnDataGatherVO hnDataGatherVO) { 
 | 
        try { 
 | 
            Integer count =ichService.sync(); 
 | 
            return AjaxResult.success(count); 
 | 
        } catch (Exception ex) { 
 | 
            return AjaxResult.error(ex.getMessage()); 
 | 
        } 
 | 
  
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 查询疾病列表数据采集 
 | 
     */ 
 | 
    @PostMapping("/collectIcd10") 
 | 
    @ApiOperation("同步标准诊断") 
 | 
    public AjaxResult selectIcd10List(@RequestBody Icd10 icd10) { 
 | 
        Integer integer = ichService.selectIcd10List(icd10); 
 | 
        return AjaxResult.success(integer); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 用户信息集合信息数据采集 
 | 
     */ 
 | 
    @PostMapping("/collectUser") 
 | 
    @ApiOperation("同步用户信息") 
 | 
    public AjaxResult selectUserList(@RequestBody SysUser sysUser) { 
 | 
        Integer integer = ichService.selectUserList(sysUser); 
 | 
        return AjaxResult.success(integer); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 部门信息集合信息数据采集 
 | 
     */ 
 | 
    @PostMapping("/collectDept") 
 | 
    @ApiOperation("同步科室信息") 
 | 
    public AjaxResult selectDeptList(@RequestBody SysDept sysDept) { 
 | 
        Integer integer = ichService.selectDeptList(sysDept); 
 | 
        return AjaxResult.success(integer); 
 | 
    } 
 | 
  
 | 
} 
 |