|  |  |  | 
|---|
|  |  |  | import com.dy.common.webUtil.BaseResponse; | 
|---|
|  |  |  | import com.dy.common.webUtil.BaseResponseUtils; | 
|---|
|  |  |  | import com.dy.common.webUtil.QueryResultVo; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voPr.VoAllIntake; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voPr.VoOnLineIntake; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voRm.VoOpenClostWechat; | 
|---|
|  |  |  | import com.dy.pipIrrWechat.intake.qo.OnLineIntakesQO; | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param qo | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | //@GetMapping(path = "one_intake") | 
|---|
|  |  |  | @GetMapping(path = "all_intakes") | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoOnLineIntake>>> getSomeIntakes(OnLineIntakesQO qo) { | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(intakeSv.selectSomeIntakes(qo)); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("查询取水口异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据取水口编号获取取水口对象 | 
|---|
|  |  |  | * @param qo | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @GetMapping(path = "all_intakes1") | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<VoOnLineIntake>> getOneIntake(OnLineIntakesQO qo) { | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(intakeSv.selectOneIntake(qo)); | 
|---|
|  |  |  | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 获得全部取水口 | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @GetMapping(path = "all") | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoAllIntake>>> all() { | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoAllIntake>> res = this.intakeSv.selectAll(); | 
|---|
|  |  |  | if (res == null) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg("没有符合条件的取水口数据"); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("查询取水口异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|