【正文】 實現(xiàn)：/** * 意見反饋 * @param params * @param pageInfo * @param conn * @return * @throws ComponentException * @throws EMPRestrictException */ public EcfFeedBackReturnBO queryFeeBackList(FeedBackConBO req,Connection conn)throws ComponentException, EMPRestrictException { try { //EcfFeedBackReturnBO resp = new EcfFeedBackReturnBO()。 //返回報文 EcfFeedBackService service = (EcfFeedBackService)().getBean(ecfFeedBackService)。//調(diào)用意見反饋接口 EcfFeedBackReturnBO ecfFeedBackReturnBO = (req)。 if(ecfFeedBackReturnBO !=null){ return ecfFeedBackReturnBO。 } } catch (Exception e) { ()。 } return null。 } cims調(diào)用核算接口：分期試算接口：!分期試算接口 ! 生成遠程服務(wù)代理，可以像使用本地bean一樣使用demoService dubbo:reference id=ecfYcloansDubboService timeout=30000 interface= /服務(wù)接口類：package 。import 。public interface EcfYcloansDubboService { /** * 通過map參數(shù)請求，返回map形式的接口調(diào)用 * @param map * @return * @throws Exception */ public MapObject, Object execute(MapString, Object map) throws Exception。 /** * 通過json參數(shù)請求，返回json形式的接口調(diào)用 * @param jsonStr * @return * @throws Exception */ public String execute(String jsonStr) throws Exception。}服務(wù)接口實現(xiàn)類：package 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。/** * * p * 對于實時類交易,不走報文的形式,而是采用dubbo的形式進行 * p * 使用dubbo交易，可以比較方便靈活的進行內(nèi)部系統(tǒng)中的交互 * p * 在遠程交互過程中的對象必須是實現(xiàn)了序列化接口的對象 * */public class ServDubboBeanAction implements EcfYcloansDubboService{ private static Log log = ()。 /** * 通過map參數(shù)請求，返回map形式的接口調(diào)用 * @param map * @return * @throws Exception */ @SuppressWarnings(unchecked) public MapObject, Object execute(MapString, Object serData) throws Exception { Ser1buzInterface ser = null。 String servicesId = null。 Context rtXContext = null。 Context context = null。 MapObject, Object rsData = null。 try { rsData = new HashMapObject, Object()。 // 構(gòu)造 EMP Context 對象 rtXContext = ((EMPFlowComponentFactory) ComponentFactory .getComponentFactory()) .getContext(null,rootCtx)。 //創(chuàng)建context，裝載到rootContext context = new Context()。 (new KeyedCollection())。 (rtXContext)。 // 交易碼 servicesId = (String) (serData, )。 if ((servicesId)) throw new Cmis2YcloansException(, 交易碼為空)。 // 服務(wù)接口 ser = (Ser1buzInterface) (servicesId)。 if (ser == null){ throw new Cmis2YcloansException()。 } /*map轉(zhuǎn)換為keyedcollection形式*/ KeyedCollection kColl = (serData)。 // 設(shè)置業(yè)務(wù)請求到Context 中// (kColl)。 //直接putall icoll格式不對// (kColl)。 //直接addDataElement 多了一層serData /*將kcoll數(shù)據(jù)放入context中，用于后續(xù)接口取數(shù)*/ for(Iterator iterator = ().iterator()。 ()。 ){ ((DataElement)())。 } (核算系統(tǒng)接收數(shù)據(jù) + serData)。 // 執(zhí)行業(yè)務(wù)處理 (context)。 // 設(shè)置返回數(shù)據(jù) Object rsObject = ()。 if(rsObject != null){ rsData = ((KeyedCollection)rsObject)。 } (核算系統(tǒng)響應(yīng)數(shù)據(jù) + rsData)。 (errorCode,)。 (errorMsg, )。 } catch (Cmis2YcloansException e) { ()。 (errorCode, ())。 (errorMsg, ())。 } catch (Exception e) { ()。 (errorCode,)。 (errorMsg, ())。 //關(guān)閉釋放context } finally { ()。 } return rsData。 } /** * 通過json參數(shù)請求，返回json形式的接口調(diào)用 * @param jsonStr * @return * @throws Exception */ public String execute(String jsonStr) throws Exception { Map reqMap = (jsonStr)。 Map retMap = (reqMap)。 String retJsonStr = (retMap)。 return retJsonStr。 }}cmis調(diào)用核算配制：!分期試算接口 !分期試算接口 dubbo:reference id=lmLimitAgreementDubboService interface= version= /渠道調(diào)用接口實現(xiàn)：/** * 調(diào)用核算接口的通用方法。 * 傳入接口請求requestMessage對象, 轉(zhuǎn)換為json格式, 請求核算dubbo服務(wù)器, 返回json格式, 轉(zhuǎn)換為responseMessage對象 * @param reqMessage * @return */ private Object callYcloansDubboMethod(Object requestMsg, Class responseMessageClass) { EcfYcloansDubboService service = (EcfYcloansDubboService) ().getBean(ecfYcloansDubboService)。 if(service == null){ (AccountDubboServiceImple, , 0, ecfYcloansDubboService 消費端對象為null.)。 return null。 } /* 第1步 將對象轉(zhuǎn)為json格式 */ String resJsonStr = (requestMsg)。 (核算請求報文：+resJsonStr)。 /* 第2步 調(diào)用dubbo接口傳入json對象 */ String reqJsonStr = (resJsonStr)。 (核算返回報文：+reqJsonStr)。 /* 第3步 將返回的json轉(zhuǎn)為對象 */ Object reponseObj = (reqJsonStr, responseMessageClass)。 return reponseObj。 } /** * 調(diào)用核算統(tǒng)一操作dubbo接口 * @param map * @return */ public MapString, String execute(MapString, Object map) { MapString, String resultMap = new HashMapString, String()。 EcfYcloansDubboService service = (EcfYcloansDubboService) ().getBean(ecfYcloansDubboService)。 if(service == null){ (AccountDubboServiceImple, , 0, ecfYcloansDubboService 消費端對象為null.)。 return null。 } MapString, Object pMap = new HashMapString, Object()。 for(String key : ()){ Object value = (key)。 ( ((_) 0) ? key : (), value)。 } String pMapJson = (pMap)。 MapObject, Object responseMap = (pMap)。 StringBuffer sbf = new StringBuffer()。 for(Object key : ()){ Object value = (key)。 ((), (value == null) ? : ())。 (key + : + ( ( value != null ) ? value : ) )。 (,)。 } String serviceId = (serviceId) ? (((serviceId) != null) ? (serviceId).toString() : ) : 。 String optTyp = (OPT_TYP) ? (((OPT_TYP) != null) ? (OPT_TYP).toString() : ) : 。 (AccountDubboServiceImple, , 0, execute,serviceId: + serviceId + ,opt_typ: + optTyp + , 核算請求報文： + pMapJson)。 (AccountDubboServiceImple, , 0, execute,serviceId: + serviceId + ,opt_typ: + optTyp + , response: + ())。 return resultMap。