• 表設(shè)計(jì)
  

  1. solid_notify_def(通知定義表）

  Field	Type	Comment
  id	bigint(20) NOT NULL	自增主鍵
  name	varchar(40) NOT NULL	通知名稱
  impl_class	varchar(400) NOT NULL	通知的實(shí)現(xiàn)類
  method	varchar(20) NOT NULL	通知的方法名稱
  max_retry_times	int(11) NOT NULL	最大重試次數(shù)，-1表示unlimited
  max_retry_interval	int(11) NOT NULL	最大重試間隔，以分鐘為單位
  alert_trigger_type	tinyint(4) NOT NULL	報(bào)警觸發(fā)類型，0 - 最終失敗， 1 - 失敗, 2 - NEVER，3 - 失敗若干次后報(bào)警
  email	varchar(400) NOT NULL	調(diào)用失敗后通知人郵件，注意調(diào)用失敗是指經(jīng)過(guò)若干次重試后超過(guò)最大重試次數(shù)后失敗，逗號(hào)分隔
  description	varchar(400) NULL	對(duì)該通知定義的描述
  retry_interval	varchar(400) NOT NULL	重試間隔，可為固定長(zhǎng)度或列表或策略類或表達(dá)式，s - 秒，m - 分鐘，h - 小時(shí), d - 天
  alert_trigger_fail_times	int(11) NULL	失敗多少次后觸發(fā)報(bào)警
  need_confirm	tinyint(4) NOT NULL	是否需要確認(rèn)，0 - 不需要， 1 - 需要
  max_confirm_delay	int(11) NOT NULL	在需要確認(rèn)時(shí)經(jīng)過(guò)多少時(shí)間后認(rèn)為調(diào)用失敗，以秒為單位，0表示無(wú)限制等下去

   

  2. solid_notify_msg(通知消息表)

  Field	Type	Comment
  id	bigint(20) NOT NULL	自增主鍵
  def_id	bigint(20) NOT NULL	通知定義id
  param	text NULL	通知參數(shù)
  description	text NULL	描述信息，如該通知的一些上下文信息
  errors	text NULL	調(diào)用失敗記錄的錯(cuò)誤信息
  status	tinyint(4) NOT NULL	該通知的狀態(tài)，0 - 未發(fā)送， 1 - 發(fā)送成功， 2 - 發(fā)送失敗， 3 - 發(fā)送最終失敗，4 - 待確認(rèn)
  retry_times	int(11) NOT NULL	重試次數(shù)
  last_call_time	datetime NULL	最后調(diào)用時(shí)間
  nex_call_time	datetime NULL	下次執(zhí)行時(shí)間
  create_time	datetime NOT NULL	該通知最初創(chuàng)建時(shí)間

  3. solid_notify_msg_history(通知消息歷史表）

  和通知消息表表結(jié)構(gòu)完全一樣，歷史表主要用來(lái)將已經(jīng)是成功狀態(tài)或者最終失敗狀態(tài)的消息從通知消息表中移除，以免通知消息表中積攢太多消息影響性能。

   

@Override
@Transactional
public SolidNotifyMsgWithBLOBs addNotice(String defName, String param, String description) {
    final SolidNotifyMsgWithBLOBs solidNotifyMsgWithBLOBs = new SolidNotifyMsgWithBLOBs();
    SolidNotifyDef solidNotifyDef = getDefByName(defName);
    solidNotifyMsgWithBLOBs.setDefId(solidNotifyDef.getId());
    solidNotifyMsgWithBLOBs.setParam(param);
    solidNotifyMsgWithBLOBs.setDescription(description);
    solidNotifyMsgWithBLOBs.setCreateTime(new Date());
    solidNotifyMsgWithBLOBs.setStatus(SolidNotifyMsgStatus.NOT_SEND.getValue());
    solidNotifyMsgWithBLOBs.setRetryTimes(0);
    solidNotifyMsgWithBLOBs.setNexCallTime(Calendar.getInstance().getTime());
    solidNotifyMsgMapper.insert(solidNotifyMsgWithBLOBs);
    TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
        @Override
        public void afterCommit() {
            SolidNotifyDef solidNotifyDef = solidNotifyDefMapper.selectByPrimaryKey(solidNotifyMsgWithBLOBs.getDefId());
            sendNotice(solidNotifyMsgWithBLOBs, solidNotifyDef);
        }
    });
    return solidNotifyMsgWithBLOBs;

}