| | |
|---|
| | | @PostMapping("/collect") |
|---|
| | | @ApiOperation("同步病人相关数据") |
|---|
| | | public AjaxResult hnDataGather(@RequestBody HnDataGatherVO hnDataGatherVO) { |
|---|
| | | log.info("开始按天同步用户数据，时间范围: {} 到 {}", hnDataGatherVO.getStartTime(), hnDataGatherVO.getEndTime()); |
|---|
| | | Boolean aBoolean = ichService.hnDataGather(hnDataGatherVO); |
|---|
| | | return AjaxResult.success(aBoolean); |
|---|
| | | try { |
|---|
| | | Integer count =ichService.sync(); |
|---|
| | | return AjaxResult.success(count); |
|---|
| | | } catch (Exception ex) { |
|---|
| | | return AjaxResult.error(ex.getMessage()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 用户信息集合信息数据采集 |
|---|
| | | * 用户信息集合信息数据采集（异步执行，接口立即返回） |
|---|
| | | */ |
|---|
| | | @PostMapping("/collectUser") |
|---|
| | | @ApiOperation("同步用户信息") |
|---|
| | | public AjaxResult selectUserList(@RequestBody SysUser sysUser) { |
|---|
| | | Integer integer = ichService.selectUserList(sysUser); |
|---|
| | | return AjaxResult.success(integer); |
|---|
| | | boolean submitted = ichService.selectUserListAsync(sysUser); |
|---|
| | | if (!submitted) { |
|---|
| | | return AjaxResult.warn("用户信息同步任务正在执行中，请勿重复提交"); |
|---|
| | | } |
|---|
| | | return AjaxResult.success("用户信息同步任务已提交，后台执行中，请通过日志查看进度"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
