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) { 
 | 
        log.info("开始按天同步用户数据,时间范围: {} 到 {}", hnDataGatherVO.getStartTime(), hnDataGatherVO.getEndTime()); 
 | 
        Boolean aBoolean = ichService.hnDataGather(hnDataGatherVO); 
 | 
        return AjaxResult.success(aBoolean); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 查询疾病列表数据采集 
 | 
     */ 
 | 
    @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); 
 | 
    } 
 | 
  
 | 
} 
 |