接口示例总结

一、http

1.查询

@RequestMapping( // value="/list", method=RequestMethod.GET, produces="application/json;charset=UTF-8" ) public @ResponseBody ReturnInfo getProductList(HttpServletRequest request, HttpServletResponse response,EntityCriteria criteria){ logger.debug("| start !"); //结果集 ReturnInfo returnInfo= new ReturnInfo (); //验证key String key = request.getParameter("api_key"); String productId = null; try { productId = keyBiz.keyValidate(key); } catch (FrameworkException e1) { String rcCode = e1.getRcElementObj().getHexRcCode(); String rcMsg = e1.getRcElementObj().getRcMsg(); returnInfo.setRcode(rcCode); returnInfo.setRmessage(rcMsg); logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); return returnInfo; } try { criteria.setProductId(productId); returnInfo = entityBiz.queryEntityList(criteria, null); returnInfo.setRcode(CommonRcTable.RcOk.getHexRcCode()); returnInfo.setRmessage(CommonRcTable.RcOk.getRcMsg()); } catch (FrameworkException fex) { String rcCode = fex.getRcElementObj().getHexRcCode(); String rcMsg = fex.getRcElementObj().getRcMsg(); returnInfo.setRcode(rcCode); returnInfo.setRmessage(rcMsg); logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); } catch (Exception e) { returnInfo.setRcode(SCMPRcTable.WebServiceQueryEntityListError.getHexRcCode()); returnInfo.setRmessage(SCMPRcTable.WebServiceQueryEntityListError.getRcMsg()); return returnInfo; } logger.debug("| End !"); return returnInfo; }

2.新增

@RequestMapping( // value="/list", method=RequestMethod.POST, produces="application/json;charset=UTF-8" ) public @ResponseBody Map createEntity(HttpServletRequest request, HttpServletResponse response,Entity entity){ logger.debug("| start !"); //结果集 // ReturnInfo returnInfo= new ReturnInfo (); Map map = new HashMap(); String productId = null; String apiKey=null; Enumeration enu = request.getHeaderNames();// 取得全部头信息 while (enu.hasMoreElements()) {// 以此取出头信息 String headerName = (String) enu.nextElement(); if(headerName.equals("apikey")){ apiKey = request.getHeader(headerName); } } try { productId = keyBiz.keyValidate(apiKey); } catch (FrameworkException e1) { String rcCode = e1.getRcElementObj().getHexRcCode(); String rcMsg = e1.getRcElementObj().getRcMsg(); map.put("rcCode", rcCode); map.put("rcMsg", rcMsg); // returnInfo.setRcode(rcCode); // returnInfo.setRmessage(rcMsg); logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); // return returnInfo; return map; } try { //如果是批量新增的，name自动设定 /* String batchFlag = entity.getBatchFlag(); if(StringUtils.isNotEmpty(batchFlag)){ int entityCount = CommonUtil.stringToInt(batchFlag); String entityName = null; if(entityCount<10){ entityName = "T000"+entityCount; }else if(entityCount>9 && entityCount<100){ entityName = "T00"+entityCount; } entity.setEntityName(entityName); entity.setEntityNo(entityName); }*/ Product product = productBiz.queryProductById(productId); if(product !=null){ entity.setProductType(product.getProductType()); } entity.setProductId(productId); String entityId=entityBiz.createEntity(entity); map.put("entityId", entityId); // Entity entit=new Entity(); // entit.setEntityId(entityId); // List list=new ArrayList (); // list.add(entit); // returnInfo.setRows(list); // returnInfo.setTotal(list.size()); //发送消息到中间件 String logId = seqBiz.getSeqLogId(SCMPConstants.SEQ_LOG_ID); entity.setReferLogId(logId); queueSender.send("entity.queue", entity); //日志记录 String strEntity = JsonUtil.JavaBeanToJson(entity); InterfaceLog interfaceLog = new InterfaceLog(); interfaceLog.setLogId(logId); interfaceLog.setInterfaceName("实体接入"); interfaceLog.setInterfaceCode("100002"); interfaceLog.setInterfaceType("0"); interfaceLog.setInterfaceChannel("平台"); interfaceLog.setState(SCMPRcTable.RcOk.getHexRcCode()); interfaceLog.setStateMsg(SCMPRcTable.RcOk.getReturnMsg()); interfaceLog.setRemark("接口消息接入并发送消息中间件:"+strEntity); interfaceLog.setStep("1"); interfaceLog.setReferLogId(logId); interfaceLogBiz.createInterfaceLog(interfaceLog); map.put("rcCode", CommonRcTable.RcOk.getHexRcCode()); map.put("rcMsg", CommonRcTable.RcOk.getRcMsg()); // returnInfo.setRcode(CommonRcTable.RcOk.getHexRcCode()); // returnInfo.setRmessage(CommonRcTable.RcOk.getRcMsg()); } catch (FrameworkException fex) { String rcCode = fex.getRcElementObj().getHexRcCode(); String rcMsg = fex.getRcElementObj().getRcMsg(); map.put("rcCode", rcCode); map.put("rcMsg", rcMsg); // // returnInfo.setRcode(rcCode); // returnInfo.setRmessage(rcMsg); logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); } catch (Exception e) { map.put("rcCode", SCMPRcTable.WebServiceCreateEntityError.getHexRcCode()); map.put("rcMsg", SCMPRcTable.WebServiceCreateEntityError.getRcMsg()); // returnInfo.setRcode(SCMPRcTable.WebServiceCreateEntityError.getHexRcCode()); // returnInfo.setRmessage(SCMPRcTable.WebServiceCreateEntityError.getRcMsg()); return map; } logger.debug("| End !"); return map; }

3.更新

@RequestMapping( // value="/list", method=RequestMethod.PUT, produces="application/json;charset=UTF-8" ) public @ResponseBody ReturnInfo updateEntity(HttpServletRequest request, HttpServletResponse response,Entity entity){ logger.debug("| start !"); //结果集 ReturnInfo returnInfo= new ReturnInfo (); //验证key String apiKey=null; Enumeration enu = request.getHeaderNames();// 取得全部头信息 while (enu.hasMoreElements()) {// 以此取出头信息 String headerName = (String) enu.nextElement(); if(headerName.equals("apikey")){ apiKey = request.getHeader(headerName); } } String productId = null; try { productId = keyBiz.keyValidate(apiKey); } catch (FrameworkException e1) { String rcCode = e1.getRcElementObj().getHexRcCode(); String rcMsg = e1.getRcElementObj().getRcMsg(); returnInfo.setRcode(rcCode); returnInfo.setRmessage(rcMsg); logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); return returnInfo; } try { entity.setProductId(productId); entityBiz.updateEntity(entity); returnInfo.setRcode(CommonRcTable.RcOk.getHexRcCode()); returnInfo.setRmessage(CommonRcTable.RcOk.getRcMsg()); } catch (FrameworkException fex) { String rcCode = fex.getRcElementObj().getHexRcCode(); String rcMsg = fex.getRcElementObj().getRcMsg(); returnInfo.setRcode(rcCode); returnInfo.setRmessage(rcMsg); logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); } catch (Exception e) { returnInfo.setRcode(SCMPRcTable.WebServiceUpdateEntityError.getHexRcCode()); returnInfo.setRmessage(SCMPRcTable.WebServiceUpdateEntityError.getRcMsg()); return returnInfo; } logger.debug("| End !"); return returnInfo; }

4.删除

@RequestMapping( value="/{entityId}", // value="/list/{entityId}", method=RequestMethod.DELETE, produces="application/json;charset=UTF-8" ) public @ResponseBody ReturnInfo deleteEntity(HttpServletRequest request, HttpServletResponse response,@PathVariable("entityId") String entityId){ logger.debug("| start !"); //结果集 ReturnInfo returnInfo= new ReturnInfo (); //验证key // String key = request.getParameter("api_key"); // try { // keyBiz.keyValidate(key); // } catch (FrameworkException e1) { // String rcCode = e1.getRcElementObj().getHexRcCode(); // String rcMsg = e1.getRcElementObj().getRcMsg(); // returnInfo.setRcode(rcCode); // returnInfo.setRmessage(rcMsg); // logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); // return returnInfo; // } try { entityBiz.deleteEntityByIds(entityId); returnInfo.setRcode(CommonRcTable.RcOk.getHexRcCode()); returnInfo.setRmessage(CommonRcTable.RcOk.getRcMsg()); } catch (FrameworkException fex) { String rcCode = fex.getRcElementObj().getHexRcCode(); String rcMsg = fex.getRcElementObj().getRcMsg(); returnInfo.setRcode(rcCode); returnInfo.setRmessage(rcMsg); logger.error(" | ReturnCode:"+rcCode+",ReturnMsg:"+rcMsg); } catch (Exception e) { returnInfo.setRcode(SCMPRcTable.WebServiceDeleteEntityError.getHexRcCode()); returnInfo.setRmessage(SCMPRcTable.WebServiceDeleteEntityError.getRcMsg()); return returnInfo; } logger.debug("| End !"); return returnInfo; }