Blame view

service-job/src/main/java/com/java110/job/smo/impl/JobServiceSMOImpl.java 4.92 KB
88e030b7   王彪总   init project
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
  package com.java110.job.smo.impl;
  
  import com.alibaba.fastjson.JSONArray;
  import com.alibaba.fastjson.JSONObject;
  import com.java110.core.base.smo.BaseServiceSMO;
  import com.java110.core.context.BusinessServiceDataFlow;
  import com.java110.core.event.service.BusinessServiceDataFlowEventPublishing;
  import com.java110.core.factory.DataFlowFactory;
  import com.java110.dto.system.DataFlowLinksCost;
  import com.java110.dto.system.DataFlowLog;
  import com.java110.job.smo.IJobServiceSMO;
  import com.java110.utils.cache.MappingCache;
  import com.java110.utils.constant.KafkaConstant;
  import com.java110.utils.constant.MappingConstant;
  import com.java110.utils.constant.ResponseConstant;
  import com.java110.utils.exception.SMOException;
  import com.java110.utils.kafka.KafkaFactory;
  import com.java110.utils.util.Assert;
  import com.java110.utils.util.DateUtil;
  import org.slf4j.Logger;
  import com.java110.core.log.LoggerFactory;
  import org.springframework.stereotype.Service;
  import org.springframework.transaction.annotation.Transactional;
  
  import java.util.Date;
  import java.util.List;
  
  /**
   * 用户服务信息管理业务信息实现
   * Created by wuxw on 2017/4/5.
   */
  @Service("jobServiceSMOImpl")
  @Transactional
  public class JobServiceSMOImpl extends BaseServiceSMO implements IJobServiceSMO {
  
      private static Logger logger = LoggerFactory.getLogger(JobServiceSMOImpl.class);
  
  
      //新增用户
      private static final String USER_ACTION_ADD = "ADD";
  
      //新增用户
      private static final String USER_ACTION_KIP = "KIP";
  
      //新增用户
      private static final String USER_ACTION_DEL = "DEL";
  
  
      @Override
      public JSONObject service(BusinessServiceDataFlow businessServiceDataFlow) throws SMOException {
          try {
              Assert.hasLength(businessServiceDataFlow.getbId(), "bId 不能为空");
  
              BusinessServiceDataFlowEventPublishing.multicastEvent(businessServiceDataFlow);
              Assert.notEmpty(businessServiceDataFlow.getResJson(), "定时任务服务[" + businessServiceDataFlow.getCurrentBusiness().getServiceCode() + "]没有返回内容");
          } catch (Exception e) {
              logger.error("定时任务处理异常", e);
              throw new SMOException(ResponseConstant.RESULT_PARAM_ERROR, "定时任务处理异常" + e.getMessage());
          } finally {
              if (businessServiceDataFlow == null) {
                  return null;
              }
  
              //这里记录日志
              Date endDate = DateUtil.getCurrentDate();
  
              businessServiceDataFlow.setEndDate(endDate);
              //添加耗时
              DataFlowFactory.addCostTime(businessServiceDataFlow, "service", "业务处理总耗时",
                      businessServiceDataFlow.getStartDate(), businessServiceDataFlow.getEndDate());
              //保存耗时
              saveCostTimeLogMessage(businessServiceDataFlow);
              //保存日志
              saveLogMessage(businessServiceDataFlow);
          }
          return businessServiceDataFlow.getResJson();
      }
  
  
      /**
       * 保存日志信息
       *
       * @param businessServiceDataFlow 业务日志对象
       */
      private void saveLogMessage(BusinessServiceDataFlow businessServiceDataFlow) {
  
          try {
              if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.DOMAIN_SYSTEM_SWITCH,MappingConstant.KEY_LOG_ON_OFF))) {
                  for (DataFlowLog dataFlowLog : businessServiceDataFlow.getLogDatas()) {
                      KafkaFactory.sendKafkaMessage(KafkaConstant.TOPIC_LOG_NAME, "", JSONObject.toJSONString(dataFlowLog));
                  }
              }
          } catch (Exception e) {
              logger.error("报错日志出错了,", e);
          }
      }
  
      /**
       * 保存耗时信息
       *
       * @param businessServiceDataFlow
       */
      private void saveCostTimeLogMessage(BusinessServiceDataFlow businessServiceDataFlow) {
          try {
              if (MappingConstant.VALUE_ON.equals(MappingCache.getValue(MappingConstant.DOMAIN_SYSTEM_SWITCH,MappingConstant.KEY_COST_TIME_ON_OFF))) {
                  List<DataFlowLinksCost> dataFlowLinksCosts = businessServiceDataFlow.getLinksCostDates();
                  JSONObject costDate = new JSONObject();
                  JSONArray costDates = new JSONArray();
                  JSONObject newObj = null;
                  for (DataFlowLinksCost dataFlowLinksCost : dataFlowLinksCosts) {
                      newObj = JSONObject.parseObject(JSONObject.toJSONString(dataFlowLinksCost));
                      newObj.put("dataFlowId", businessServiceDataFlow.getDataFlowId());
                      newObj.put("transactionId", businessServiceDataFlow.getTransactionId());
                      costDates.add(newObj);
                  }
                  costDate.put("costDates", costDates);
  
                  KafkaFactory.sendKafkaMessage(KafkaConstant.TOPIC_COST_TIME_LOG_NAME, "", costDate.toJSONString());
              }
          } catch (Exception e) {
              logger.error("报错日志出错了,", e);
          }
      }
  
  
  
  }