|  |  | 
 |  |  | import com.dy.pipIrrGlobal.pojoUg.UgRtuProgram; | 
 |  |  | import com.dy.pipIrrGlobal.pojoUg.UgRtuTask; | 
 |  |  | import com.dy.pipIrrGlobal.rtuMw.Web2RtuMw; | 
 |  |  | import com.dy.pipIrrGlobal.voUg.VoUgRtuResult; | 
 |  |  | import com.dy.pipIrrGlobal.voUg.VoUgRtuResult4Failure; | 
 |  |  | import com.dy.pipIrrGlobal.voUg.VoUgRtuResult4Success; | 
 |  |  | import com.dy.pipIrrGlobal.voUg.VoWatch; | 
 |  |  | import io.swagger.v3.oas.annotations.Operation; | 
 |  |  | import io.swagger.v3.oas.annotations.media.Content; | 
 |  |  | 
 |  |  |         vo.callbackWebUrl = ugCallbackUrl_rm ; | 
 |  |  |  | 
 |  |  |         String rqUrl = this.get2MwRequestUrl(this.env, ContextUgTaskSend) ; | 
 |  |  |         BaseResponse res = sendRequest2Mw(restTemplate, rqUrl, vo) ; | 
 |  |  |         BaseResponse res = sendPostRequest2Mw(restTemplate, rqUrl, vo) ; | 
 |  |  |         if(res != null){ | 
 |  |  |             if(res.isSuccess()){ | 
 |  |  |                 this.sv.setUpgradeTaskExecuted(id); | 
 |  |  | 
 |  |  |                 if(msg == null){ | 
 |  |  |                     msg = res.getMsg() ; | 
 |  |  |                 } | 
 |  |  |                 log.error("通信中间件执行下发升级任务失败" + msg) ; | 
 |  |  |                 return BaseResponseUtils.buildErrorMsg("通信中间件执行失败" + msg) ; | 
 |  |  |                 log.error("通信中间件执行下发升级任务失败," + msg) ; | 
 |  |  |                 return BaseResponseUtils.buildErrorMsg("通信中间件执行失败," + msg) ; | 
 |  |  |             } | 
 |  |  |         }else{ | 
 |  |  |             log.error("通信中间件返回结果为null") ; | 
 |  |  | 
 |  |  |     @SsoAop() | 
 |  |  |     public BaseResponse<String> forceOver() { | 
 |  |  |         String rqUrl = this.get2MwRequestUrl(this.env, ContextUgForceOver) ; | 
 |  |  |         BaseResponse res = sendRequest2Mw(restTemplate, rqUrl, null) ; | 
 |  |  |         BaseResponse res = sendGetRequest2Mw(restTemplate, rqUrl) ; | 
 |  |  |         if(res != null){ | 
 |  |  |             if(res.isSuccess()){ | 
 |  |  |                 return BaseResponseUtils.buildSuccess(true) ; | 
 |  |  |                 RtuUpgradeStateReceiverCtrl.afterMwForceOverCurUgTask(); | 
 |  |  |                 String msg = res.getContent()==null?null:(String)res.getContent() ; | 
 |  |  |                 if(msg == null){ | 
 |  |  |                     msg = res.getMsg() ; | 
 |  |  |                 } | 
 |  |  |                 return BaseResponseUtils.buildResult(ResultCodeMsg.RsCode.SUCCESS_CODE, msg, msg) ; | 
 |  |  |             }else{ | 
 |  |  |                 String msg = res.getContent()==null?null:(String)res.getContent() ; | 
 |  |  |                 if(msg == null){ | 
 |  |  | 
 |  |  |     @RequestMapping(value = "/exportUgFail", method = RequestMethod.GET) | 
 |  |  |     public void exportUgFail(HttpServletResponse response) throws Exception { | 
 |  |  |         setExcelRespProp(response, "升级失败RTU列表"); | 
 |  |  |         List<VoUgRtuResult> rsList = resSv.exportUgFail(); | 
 |  |  |         List<VoUgRtuResult4Failure> rsList = resSv.exportUgFail(); | 
 |  |  |         EasyExcel.write(response.getOutputStream()) | 
 |  |  |                 .head(VoUgRtuResult.class) | 
 |  |  |                 .head(VoUgRtuResult4Failure.class) | 
 |  |  |                 .excelType(ExcelTypeEnum.XLSX) | 
 |  |  |                 .sheet("升级失败RTU列表") | 
 |  |  |                 .doWrite(rsList); | 
 |  |  | 
 |  |  |     @RequestMapping(value = "/exportUgSuccess", method = RequestMethod.GET) | 
 |  |  |     public void exportUgSuccess(HttpServletResponse response) throws Exception { | 
 |  |  |         setExcelRespProp(response, "升级成功RTU列表"); | 
 |  |  |         List<VoUgRtuResult> rsList = resSv.exportUgSuccess(); | 
 |  |  |         List<VoUgRtuResult4Success> rsList = resSv.exportUgSuccess(); | 
 |  |  |         EasyExcel.write(response.getOutputStream()) | 
 |  |  |                 .head(VoUgRtuResult.class) | 
 |  |  |                 .head(VoUgRtuResult4Success.class) | 
 |  |  |                 .excelType(ExcelTypeEnum.XLSX) | 
 |  |  |                 .sheet("升级成功RTU列表") | 
 |  |  |                 .doWrite(rsList); |