| @@ -220,44 +220,46 @@ public class JinMaoController extends BaseController { | |||||
| String paramStr = IOUtils.toString(inputStream, "utf-8"); | String paramStr = IOUtils.toString(inputStream, "utf-8"); | ||||
| logger.info("dfh heartBeat: {}",paramStr); | logger.info("dfh heartBeat: {}",paramStr); | ||||
| if (StringUtils.isBlank(paramStr)) { | if (StringUtils.isBlank(paramStr)) { | ||||
| generateResult(response,true,false, null, "参数不能为空paramStr", null, "参数非法"); | |||||
| generateHeartBeatResult(response,"unvalid param", "参数不能为空paramStr"); | |||||
| return ; | return ; | ||||
| } | } | ||||
| Map param = JSON.parseObject(paramStr, Map.class); | Map param = JSON.parseObject(paramStr, Map.class); | ||||
| String keyStr = param.get("Key")==null?"":param.get("Key").toString(); | String keyStr = param.get("Key")==null?"":param.get("Key").toString(); | ||||
| if (StringUtils.isBlank(keyStr)) { | if (StringUtils.isBlank(keyStr)) { | ||||
| generateResult(response,true,false, null, "参数非法Key"+keyStr, null, "参数非法"); | |||||
| generateHeartBeatResult(response,"unvalid param", "参数非法Key"+keyStr); | |||||
| return ; | return ; | ||||
| } | } | ||||
| PrintWriter out; | |||||
| try { | |||||
| Map retMap = new HashMap(); | |||||
| retMap.put("Key",keyStr); | |||||
| response.setContentType("application/json"); | |||||
| response.setCharacterEncoding("GB2312"); | |||||
| out = response.getWriter(); | |||||
| out.print("DATA="+JSON.toJSONString(retMap)); | |||||
| out.close(); | |||||
| } catch (IOException e) { | |||||
| logger.error(" jinmao writeResponse error.",e); | |||||
| } | |||||
| generateHeartBeatResult(response,keyStr, null); | |||||
| }catch(Exception e){ | }catch(Exception e){ | ||||
| logger.error("JinMaoController --heartBeat",e); | logger.error("JinMaoController --heartBeat",e); | ||||
| generateResult(response,true,false, null, "核销错误"+e.getMessage(), null, "核销错误"); | |||||
| generateHeartBeatResult(response,"error", "心跳错误"+e.getMessage()); | |||||
| return ; | return ; | ||||
| }finally { | }finally { | ||||
| if (null != inputStream ) { | if (null != inputStream ) { | ||||
| inputStream.close(); | inputStream.close(); | ||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| private void generateHeartBeatResult(HttpServletResponse response,String key,String msg) { | |||||
| PrintWriter out; | |||||
| try { | |||||
| Map retMap = new HashMap(); | |||||
| retMap.put("Key",key); | |||||
| if (null != msg) { | |||||
| retMap.put("Note",msg); | |||||
| } | |||||
| response.setContentType("application/json"); | |||||
| response.setCharacterEncoding("GB2312"); | |||||
| out = response.getWriter(); | |||||
| out.print("DATA="+JSON.toJSONString(retMap)); | |||||
| out.close(); | |||||
| } catch (IOException e) { | |||||
| logger.error(" jinmao writeResponse error.",e); | |||||
| } | |||||
| } | |||||
| /** | /** | ||||
| * Request: | * Request: | ||||