JobServiceSMOImpl.java
4.92 KB
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);
}
}
}