package com.product.data.center.service;
|
|
import java.util.Date;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.websocket.service.WebsocketMesssageServiceThread;
|
import com.product.data.center.config.CmnConst;
|
import com.product.util.BaseUtil;
|
|
import cn.hutool.core.date.DateField;
|
import cn.hutool.core.date.DateUtil;
|
|
@Service("autoSendErrorLogMassage")
|
public class SendMessageTaskService extends AbstractBaseService{
|
|
@Autowired
|
BaseDao baseDao;
|
|
/**
|
* 获取周期内产生错误的日志信息（日志uuid，操作类型，操作表，操作时间区间）
|
* 同操作、同表、同期内只取一次记录
|
* @param period 周期（分钟）
|
*/
|
public void getAllErrorLog(Integer period) {
|
Date currentDate=new Date();
|
|
StringBuilder sb = new StringBuilder(256);
|
sb.append(" SELECT ")
|
.append(" B.config_uuid,B.type,B.uuid,B.end_time,B.start_time,A.source_table ")
|
.append(" FROM( ")
|
.append(" SELECT ")
|
.append(" config_uuid,type,uuid, ")
|
.append(" DATE_FORMAT(Max(statistics_final_time),'%Y-%m-%d %H:%i:%s') end_time, ")
|
.append(" DATE_FORMAT(Max(statistics_start_time),'%Y-%m-%d %H:%i:%s') start_time ")
|
.append(" FROM product_sys_data_center_log ")
|
.append(" WHERE result=0 AND (deal_flag=0 OR deal_flag IS NULL) ")
|
.append(" AND created_utc_datetime>date_add(now(),interval -").append(period).append(" minute) AND created_utc_datetime<=now() ")
|
.append(" GROUP BY config_uuid ")
|
.append(" )B ")
|
.append(" LEFT JOIN product_sys_data_center_config_view A ON a.uuid = B.config_uuid");
|
|
DataTableEntity dtErrorLog = baseDao.listTable(sb.toString(), new Object[] {});
|
if(!BaseUtil.dataTableIsEmpty(dtErrorLog)) {
|
|
JSONObject allType = getAllOpreaType();
|
|
// 发送给所有的管理员
|
DataTableEntity managerDte = baseDao.listTable("product_sys_org_manager", "is_used=1");
|
StringBuilder receiver = new StringBuilder(32);
|
FieldSetEntity managerFse;
|
for (int i = 0; i < managerDte.getRows(); i++) {
|
managerFse = managerDte.getFieldSetEntity(i);
|
if (receiver.length() > 0) {
|
receiver.append(",");
|
}
|
receiver.append(managerFse.getString("user_id"));
|
}
|
|
for (int i = 0; i < dtErrorLog.getRows(); i++) {
|
createdAndSendMassage(dtErrorLog.getFieldSetEntity(i), allType, receiver.toString());
|
}
|
|
}
|
}
|
|
/**
|
* 通过错误日志信息，生成消息
|
* @param fseErrorLog
|
* @param allType
|
* @param receiver
|
*/
|
public void createdAndSendMassage(FieldSetEntity fseErrorLog, JSONObject allType, String receiver) {
|
//生成标题和内容
|
StringBuilder massageTitle = new StringBuilder(64);
|
StringBuilder massageContent = new StringBuilder(64);
|
|
String sourceTable=fseErrorLog.getString(CmnConst.SOURCE_TABLE);
|
if (!BaseUtil.strIsNull(sourceTable)) {
|
massageTitle.append("《").append(sourceTable).append("表");
|
massageContent.append(sourceTable).append("表");
|
}
|
|
String type = fseErrorLog.getString(CmnConst.TYPE);
|
if (!BaseUtil.strIsNull(type)) {
|
massageTitle.append(allType.get(type)).append("出错").append("》");
|
massageContent.append(allType.get(type)).append("出错");
|
}
|
|
|
String startTime = fseErrorLog.getString(CmnConst.START_TIME);
|
String endTime = fseErrorLog.getString(CmnConst.END_TIME);
|
if (!BaseUtil.strIsNull(startTime) && !BaseUtil.strIsNull(endTime)) {
|
massageContent.append("任务于")
|
.append(startTime)
|
.append("~")
|
.append(endTime)
|
.append("期间出现报错，请及时查看并处理！");
|
}else {
|
massageContent.append("任务出现报错，请及时查看并处理！");
|
}
|
|
String uuid = fseErrorLog.getString(CmnConst.UUID);
|
if(!BaseUtil.strIsNull(uuid)) {
|
WebsocketMesssageServiceThread.getInstance().appendMessage(receiver, massageContent.toString(), massageTitle.toString(), 1, "1",
|
"166269029153939a5ln9629?uuid="+uuid+"&config_uuid="+fseErrorLog.getString(CmnConst.CONFIG_UUID)+"&type="+type , CmnConst.PRODUCT_SYS_DATA_CENTER_LOG, uuid, 1, 0, 0);
|
}
|
}
|
|
/**
|
* 获取所有操作类型
|
* @return
|
*/
|
public JSONObject getAllOpreaType() {
|
DataTableEntity dtAllType = baseDao.listTable(CmnConst.PRODUCT_SYS_DICT, " dict_name='journal_type' ");
|
if (!BaseUtil.dataTableIsEmpty(dtAllType)) {
|
JSONObject json = new JSONObject();
|
for (int i = 0; i < dtAllType.getRows(); i++) {
|
FieldSetEntity fseType = dtAllType.getFieldSetEntity(i);
|
json.put(fseType.getString(CmnConst.DICT_VALUE), fseType.getString(CmnConst.DICT_LABEL));
|
}
|
return json;
|
}
|
return null;
|
}
|
}
|
