HC小区物业管理系统

package com.java110.order.smo.impl; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.order.dao.ICenterServiceDAO; import com.java110.order.smo.ICenterServiceSMO; import com.java110.utils.cache.AppRouteCache; import com.java110.utils.cache.MappingCache; import com.java110.utils.constant.*; import com.java110.utils.exception.*; import com.java110.utils.factory.ApplicationContextFactory; import com.java110.utils.kafka.KafkaFactory; import com.java110.utils.log.LoggerEngine; import com.java110.utils.util.*; import com.java110.core.client.RestTemplate; import com.java110.core.context.DataFlow; import com.java110.core.factory.AuthenticationFactory; import com.java110.core.factory.DataFlowFactory; import com.java110.core.factory.DataTransactionFactory; import com.java110.core.factory.GenerateCodeFactory; import com.java110.entity.center.AppRoute; import com.java110.entity.center.AppService; import com.java110.entity.center.Business; import com.java110.entity.center.DataFlowLinksCost; import com.java110.core.event.center.DataFlowEventPublishing; import com.java110.core.log.LogAgent; import com.java110.service.init.ServiceInfoListener; import com.java110.service.smo.IQueryServiceSMO; import org.apache.commons.lang3.math.NumberUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.*; import org.springframework.stereotype.Service; import java.util.*; /** * 中心服务处理类 * Created by wuxw on 2018/4/13. */ @Service("centerServiceSMOImpl") //@Transactional public class CenterServiceSMOImpl extends LoggerEngine implements ICenterServiceSMO { @Autowired ICenterServiceDAO centerServiceDaoImpl; @Autowired private RestTemplate restTemplate; @Autowired private RestTemplate outRestTemplate; @Autowired private IQueryServiceSMO queryServiceSMOImpl; @Override @Deprecated public String service(String reqJson, Map<String, String> headers) throws SMOException{ DataFlow dataFlow = null; JSONObject responseJson = null; String resJson = ""; try { reqJson = decrypt(reqJson,headers); DataFlowEventPublishing.preValidateData(reqJson,headers); //1.0 创建数据流 dataFlow = DataFlowFactory.newInstance(DataFlow.class).builder(reqJson, headers); //DataFlowEventPublishing.initDataFlowComplete(dataFlow); //2.0 加载配置信息 initConfigData(dataFlow); //DataFlowEventPublishing.loadConfigDataComplete(dataFlow); //3.0 校验 APPID是否有权限操作serviceCode judgeAuthority(dataFlow); //4.0 调用规则校验 ruleValidate(dataFlow); //DataFlowEventPublishing.ruleValidateComplete(dataFlow); //5.0 保存订单和业务项 c_orders c_order_attrs c_business c_business_attrs saveOrdersAndBusiness(dataFlow); //6.0 调用下游系统 //DataFlowEventPublishing.invokeBusinessSystem(dataFlow); invokeBusinessSystem(dataFlow); responseJson = DataTransactionFactory.createCommonResponseJson(dataFlow); } catch (DecryptException e){ //解密异常 responseJson = DataTransactionFactory.createOrderResponseJson(ResponseConstant.NO_TRANSACTION_ID, e.getResult().getCode(), e.getMessage()); }catch (BusinessException e) { try { //7.0 作废订单和业务项 invalidOrderAndBusiness(dataFlow); //8.0 广播作废业务系统订单信息 //想法:这里可以直接不广播，只有在业务返回时才广播, // 疑问：在这里部分消息发出去了，如果在receiveBusinessSystemNotifyMessage这个方法中依然没有收到，我们认为是下游系统也是失败了不用处理， //目前看逻辑也是对的 //invalidBusinessSystem(dataFlow); } catch (Exception e1) { LoggerEngine.error("作废订单失败", e); //9.0 将订单状态改为失败，人工处理。 updateOrderAndBusinessError(dataFlow); } finally { responseJson = DataTransactionFactory.createOrderResponseJson(dataFlow.getTransactionId(), e.getResult().getCode(), e.getMessage()); } } catch (OrdersException e) { responseJson = DataTransactionFactory.createOrderResponseJson(dataFlow.getTransactionId(), e.getResult().getCode(), e.getMessage()); } catch (RuleException e) { responseJson = DataTransactionFactory.createOrderResponseJson(dataFlow.getTransactionId(), e.getResult().getCode(), e.getMessage()); } catch (NoAuthorityException e) { responseJson = DataTransactionFactory.createOrderResponseJson(dataFlow.getTransactionId(), e.getResult().getCode(), e.getMessage()); } catch (InitConfigDataException e){ responseJson = DataTransactionFactory.createOrderResponseJson(dataFlow.getTransactionId(), e.getResult().getCode(), e.getMessage()); }catch (Exception e) { logger.error("内部异常了：",e); responseJson = DataTransactionFactory.createOrderResponseJson(dataFlow == null ? ResponseConstant.NO_TRANSACTION_ID : dataFlow.getTransactionId(), ResponseConstant.RESULT_CODE_INNER_ERROR, "内部异常了：" + e.getMessage() + e.getLocalizedMessage()); } finally { if(dataFlow != null) { //这里记录日志 Date endDate = DateUtil.getCurrentDate(); dataFlow.setEndDate(endDate); dataFlow.setResJson(responseJson); //添加耗时 //DataFlowFactory.addCostTime(dataFlow, "service", "业务处理总耗时", dataFlow.getStartDate(), dataFlow.getEndDate()); //保存耗时 //saveCostTimeLogMessage(dataFlow); //处理返回报文鉴权 AuthenticationFactory.putSign(dataFlow, responseJson); saveLogMessage(dataFlow,LogAgent.createLogMessage(dataFlow.getRequestHeaders(),dataFlow.getReqJson().toJSONString()), LogAgent.createLogMessage(dataFlow.getResponseHeaders(),dataFlow.getResJson().toJSONString()),endDate.getTime()-dataFlow.getStartDate().getTime()); // DataFlowEventPublishing.dataResponse(dataFlow,reqJson,headers); } resJson = encrypt(responseJson.toJSONString(),headers); //这里保存耗时，以及日志 return resJson; } } /** * 业务统一处理服务方法 * @param reqJson 请求报文json * @return */ public ResponseEntity<String> serviceApi(String reqJson, Map<String,String> headers) throws SMOException{ DataFlow dataFlow = null; JSONObject responseJson = null; ResponseEntity<String> responseEntity = null; try { DataFlowEventPublishing.preValidateData(reqJson,headers); //1.0 创建数据流 dataFlow = DataFlowFactory.newInstance(DataFlow.class).builder(reqJson, headers); //DataFlowEventPublishing.initDataFlowComplete(dataFlow); //2.0 加载配置信息 initConfigData(dataFlow); //DataFlowEventPublishing.loadConfigDataComplete(dataFlow); //3.0 校验 APPID是否有权限操作serviceCode judgeAuthority(dataFlow); //4.0 调用规则校验 ruleValidate(dataFlow); //DataFlowEventPublishing.ruleValidateComplete(dataFlow); //5.0 保存订单和业