消息队列通知

## 消息队列通知
### 消息队列发送有2种情况：
1.系统默认发送MQTT消息队列
2.用户自定义

------------

系统默认：
首先需要初始化MQTT配置信息，参考：
MQTT项目配置
Groovy模板
若后续改动Groovy模板内容需要实时生效，请参考：
须知
配置流程通知规则，全局或是局部亦可，如图：

![](/media/202405/2024-05-07_163111_347657.png)

红框中的内容按需配置即可，其中需要特殊说明的有2项：《主题》 和 《内容》

------------

主题：若用户不配置主题，那么会使用系统默认产生的主题，默认格式：
项目名/账号/工号/task，例如：eap5csxm/admin/00001/task
若不为空，则根据用户配置产生。主题一般是双方约定产生，并非随意指定，该内容需配置人员自行与对接方约定

------------

内容：根据用户配置产生，若没有配置，那么内容为空

### 注意：
主题和内容均为表达式，因此用户可以按需配置生成主题和内容，但其中部分属性是流程产生才具有的属性，该属性并不存在数据集中。且该属性只在通知规则才具备，属性如图：

![](/media/202405/2024-05-07_163215_555413.png)

具体每个属性说明参考： <a href="https://doc.eap.kunluiot.com/project-2/doc-216/">属性说明</a>

其中：subject 和 content 分别对应主题和内容，若要生成类似默认的系统主题，可以参考如下表达式

> return record.get('projectName')+'/'+record.get('group')+'/'+record.get('fuserid')+'/task'
基本语法为：record.get('字段名')，上图的属性说明中的字段，均可以这种方式获取

最终会往mqtt发送消息，主题是系统默认或用户自定义，发往mqtt的内容是一个json包如下，至于json包字段参考上面的《属性说明》：
```json
{
  "subject": "eap5csxm/admin/249/task",
  "type": "",
  "content": "测试消息内容",
  "flowstate": "tsProcessing",
  "ftaskurgentlevel": "紧急",
  "fbzid": "BZ0000243",
  "fcreatorid": "admin",
  "mainParams": [
    {
      "modelFilePath": "eap5csxm.pro/LiuChengCeShi.dir/PuTongLiuCheng.moduledir/dataset.datadir/LiuChengShuJuJi.bizstore|usWsXwen.BizEntity~_extFile",
      "keys": {
        "queryCdions": {
          "join": "and",
          "items": [
            {
              "sign": "eq",
              "name": "FNUMBER",
              "value": "PTLC-231103-0004",
              "enabled": true
            }
          ]
        },
        "FNUMBER": "PTLC-231103-0004"
      }
    }
  ],
  "fversion": "1.0.0",
  "fmodelpath": "eap5csxm/LiuChengCeShi/PuTongLiuCheng/flow/LiuChengCeShi.flow",
  "group": "admin",
  "hasBack": true,
  "fcreatorname": "管理员",
  "fpdisplayname": "流程测试2",
  "sendusername": "管理员",
  "fdisplayname": "环节3",
  "fcreatetime": "2023-12-01 14:44:50",
  "fordernumber": "PTLC-231103-0004",
  "fuserid": "249",
  "fcreatorbz": "admin",
  "isEnd": false,
  "ftaskguid": "4f3b8e7790a842618c23ad5cdb411d29",
  "fstate": "tsTask",
  "fbatch": true,
  "senduserid": "admin",
  "projectName": "eap5csxm",
  "oneKey": false
}
```

------------

**用户自定义：**
配置流程通知规则，全局或是局部亦可，如图：

![](/media/202405/2024-05-07_163543_928292.png)

重点看红色方块内的四项：主题/队列，内容表达式，groovy路径，groovy方法

> 如果选择了自定义，那么 主题/队列，内容表达式 这2项可以不配置
主题不配置会产生系统默认主题：项目名/账号/工号/task，例如：eap5csxm/admin/00001/task
内容表达式不配置，则为空
如果配置了，也会执行产生结果，最终也会将这2项的结果设置到上下文环境中，后续可以在groovy中获取

如果是自定义，那么 groovy路径，groovy方法 这2项一定要配置，否则不会发送通知
1.新建消息队列groovy业务逻辑，如图：

![](/media/202405/2024-05-07_163758_759145.png)

2.编写groovy逻辑
```groovy

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject
import com.zhc.eap.service.Impl.FlowDataHandle;
import com.zhc.eap.utils.MqttUtil;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.zhc.eap.util.ExceptionUtil;
import org.slf4j.Logger
import org.slf4j.LoggerFactory

class ZiDingYimqtt {

private Logger logger = LoggerFactory.getLogger("ZiDingYimqtt.groovy");

//logger.info("日志信息"); 输日志
    //com.zhc.eap.util.ExceptionUtil.throwMessage(entityCo.get("controlDesc")); 抛异常
    //event-placeholder
    public void sendMsg(Map<String, Object> map) {
        //获取数据包
        JSONArray datas = map.get("data");

//自定义发送第三方消息队列或是第三方接口
        for (JSONObject item : datas) {
            //每一项即代表发送一条通知，例如：任务流转至下环节为：张三，李四
            //那么此处会循环2次，分别是张三的数据和李四的数据

//获取主题，如果通知规则有配置主题，那么此处返回用户配置的内容。
            //若没有配置，依旧会给与默认主题，默认格式：项目名/账号/工号/task，例如：eap5csxm/admin/00001/task
            String subject = item.getString("subject");

//获取通知内容，如果有配置这里即存在值，若没有配置，这里获取值为null
            String content = item.getString("content");

//如果需要获取流程制单数据，根据制单数据生成主题或是内容等，可以执行如下2行代码获取数据
            JSONArray array = (JSONArray) item.get("mainParams");
            List<Map<String, Object>> list = FlowDataHandle.getInstance().query(array);

//注意：由于自定义发送mqtt，用户可以不需要配置主题和内容，因此用户可以在groovy代码里面自行定义所需内容

//如果还要使用系统工具类发送mqtt消息，那么需要初始化MQTT配置，至于如何初始化，参考文档 系统默认 下的步骤
            //注意：这里是将整个item内容发送，若不需要可以自行定义
            //MqttUtil.publish(subject, item.toJSONString());

//通过以上步骤基本上已经可以获取到通知的所有数据，如果要调用第三方接口或自定义mqtt发送，请自行实现代码
        }
    }
}

```

------------
**注意：此处拷贝《方法》和《导入包》即可，类名之类的每个groovy不同，因此不要一股脑全部拷贝**

------------
具体注意细节在groovy代码里面都有注释了，认真查阅即可，其中map的参数可以参考下图：

![](/media/202405/2024-05-07_163929_531960.png)

其中，如果配置了 主题/队列，内容表达式 这2项的执行结果也可以在上下文中获取

分别对应字段：subject->主题/队列，content-内容表达式
具体每项属性说明参考： <a href="https://doc.eap.kunluiot.com/project-2/doc-216/">属性说明</a>