/*** 〈一句话功能简述〉<br>* 〈功能详细描述〉 http 接收接口基类实现  父类实现为prototype  不是单例的* * 基于策略模式  后面增加子类接收实现的方法 请参照：CrmReceiveHttpIntfAction的实现* * @author lilin* @see [相关类/方法]（可选）* @since [产品/模块版本] （可选）*/
@Controller
@Scope(value = "prototype")
public abstract class BaseReceiveHttpIntfAction extends BasicAction {/***/private static final long serialVersionUID = -4667071743433536439L;private IHttpMessageHandle httpMessageHandle;/*** * 功能描述: <br>* 〈功能详细描述〉用于 子类 注入父类属性* * @param httpMessageHandle* @see [相关类/方法](可选)* @since [产品/模块版本](可选)*/public void setHttpMessageHandle(IHttpMessageHandle httpMessageHandle) {this.httpMessageHandle = httpMessageHandle;}public String doBusiness() {InputStream inputStream = null;try {inputStream = request.getInputStream();} catch (IOException e1) {logger.error("IOException: ", e1);}logger.info("@@HttpClient 解析接收报文:");SAXReader sb = new SAXReader();String returnStr = null;try {Document document = sb.read(inputStream);logger.info(document.asXML());// 保存报文信息Map<String, Object> map = httpMessageHandle.handleMessage(document);// 拼接返回报文returnStr = httpMessageHandle.getResponseMsg(map, document);logger.info("@@ 报文解析成功!");} catch (DocumentException e) {logger.info("@@HttpClient 解析报文出错!", e);}logger.info("@@ 返回报文 : " + returnStr);writeResponse(returnStr, response);return null;}/*** * 功能描述: <br>* 〈功能详细描述〉* * @param respXML* @param response* @throws IOException* @see [相关类/方法](可选)* @since [产品/模块版本](可选)*/private void writeResponse(String respXML, HttpServletResponse response) {OutputStream out = null;try {byte[] data = respXML.getBytes("UTF-8");out = response.getOutputStream();out.write(data);} catch (IOException e) {logger.error("Write response error: ", e);} finally {if (out != null) {try {out.flush();out.close();} catch (IOException e) {logger.error("IOException: ", e);}}}}}

/*** 〈一句话功能简述〉<br>* 〈功能详细描述〉* * @author lilin* @see [相关类/方法]（可选）* @since [产品/模块版本] （可选）*/
public interface IHttpMessageHandle {/*** * 功能描述: <br>* 〈功能详细描述〉处理接收到的报文信息* * @param document* @return* @see [相关类/方法](可选)* @since [产品/模块版本](可选)*/Map<String, Object> handleMessage(Document document);/*** * 功能描述: <br>* 〈功能详细描述〉获取需要返回的报文信息* * @param map* @param document* @return* @see [相关类/方法](可选)* @since [产品/模块版本](可选)*/String getResponseMsg(Map<String, Object> map, Document document);}

/*** 〈一句话功能简述〉<br>* 〈功能详细描述〉* * @author lilin* @see [相关类/方法]（可选）* @since [产品/模块版本] （可选）*/
@Service
public class CrmHttpMessageHandle implements IHttpMessageHandle {private Logger logger = Logger.getLogger(CrmHttpMessageHandle.class);@Resourceprivate LowPriceTaskService lowPriceTaskService;@Overridepublic String getResponseMsg(Map<String, Object> map, Document document) {logger.info("CrmHttp Get ResponseMsg:");printLogByEntry(map);Document doc = DocumentHelper.createDocument();// MbfService 拼接Element mbfService = DocumentHelper.createElement("MbfService");doc.add(mbfService);Element output1 = DocumentHelper.createElement("output1");mbfService.add(output1);// MbfHeader 拼接Element mbfHeader = DocumentHelper.createElement("MbfHeader");output1.add(mbfHeader);PriceCommonService.addElement(mbfHeader, "ServiceCode", (String) map.get("ServiceCode"));PriceCommonService.addElement(mbfHeader, "Operation", (String) map.get("Operation"));PriceCommonService.addElement(mbfHeader, "AppCode", (String) map.get("AppCode"));PriceCommonService.addElement(mbfHeader, "UId", (String) map.get("UId"));// ServiceResponse 拼接Element serviceResponse = DocumentHelper.createElement("ServiceResponse");mbfHeader.add(serviceResponse);PriceCommonService.addElement(serviceResponse, "Status", null);PriceCommonService.addElement(serviceResponse, "Code", null);PriceCommonService.addElement(serviceResponse, "Desc", null);// MbfBody 拼接Element mbfBody = DocumentHelper.createElement("MbfBody");output1.add(mbfBody);PriceCommonService.addElement(mbfBody, "reFlag", (String) map.get("reFlag"));PriceCommonService.addElement(mbfBody, "errorMessage", (String) map.get("errorMessage"));logger.info("CrmHttp Final ResponseMsg:" + doc.asXML());return doc.asXML();}@Overridepublic Map<String, Object> handleMessage(Document document) {logger.info("CrmHttp Start HandleMessage:");Map<String, Object> res = new HashMap<String, Object>();LowPriceTask task = new LowPriceTask();Element root = document.getRootElement();Element outElement = root.element("input1");Element mbfHeader = outElement.element("MbfHeader");String serviceCode = mbfHeader.elementTextTrim("ServiceCode");res.put("ServiceCode", serviceCode);logger.info("## ServiceCode : " + serviceCode);String operation = mbfHeader.elementTextTrim("Operation");res.put("Operation", operation);logger.info("## operation : " + operation);String appCode = mbfHeader.elementTextTrim("AppCode");res.put("AppCode", appCode);logger.info("##  appCode : " + appCode);String uId = mbfHeader.elementTextTrim("UId");res.put("UId", uId);logger.info("##  uId : " + uId);// 设置返回值if (!StringUtils.isEmpty(serviceCode) && !StringUtils.isEmpty(operation)) {task.setMsg(document.asXML());task.setScanNum(0);task.setScanResult("F");task.setStoreTime(DateUtils.getDate2());lowPriceTaskService.saveTask(task);res.put("reFlag", "S");res.put("errorMessage", "S");logger.info("@@HttpClient 保存报文信息成功!");} else {res.put("reFlag", "E");res.put("errorMessage", "报文头有问题");}return res;}

/*** 〈一句话功能简述〉<br>* 〈功能详细描述〉* * @author lilin* @see [相关类/方法]（可选）* @since [产品/模块版本] （可选）*/
@Controller
public class CrmReceiveHttpIntfAction extends BaseReceiveHttpIntfAction {/***/private static final long serialVersionUID = -104341558961432099L;@Resourceprivate IHttpMessageHandle crmHttpMessageHandle;@PostConstructpublic void injectHttpMessageHandle() {super.setHttpMessageHandle(crmHttpMessageHandle);}
}