| | |
| | | @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("用户信息同步任务已提交,后台执行中,请通过日志查看进度"); |
| | | } |
| | | |
| | | /** |