如何监控1小时内EDI系统传输的文件数量？

发表于 2023年4月4日作者知行软件

在知行之桥EDI系统中，我们可以设置周报和日报，从而来清楚知道EDI系统上每天或者每周的文件收发数量的情况。对于每天传输文件数量较多的客户，或者传输的业务数据比较重要的客户，若想每小时都收到来自EDI系统文件收发数量的汇总，了解是否有传输失败的文件，以便及时处理以避免或者减少损失，我们该如何实现？

首先我们需要建立一个script端口。在script端口配置如下代码。

<arc:call op="portStatisticsTransactionLogs?type=day" out="output">
  <!-- Only check transactions on the last hour (e.g. 02:00 to 03:00) -->
  <arc:if exp="[_index] == 2">
      
<!-- Send Email -->
           <arc:set attr="Subject"  value="Transaction Log Notify-2020"></arc:set>
          <arc:set attr="Message"   value="The transaction log is Received:[output.Received] + Sent:[output.Sent] + Error:[output.Error] within the last hour, please check."></arc:set>
          <arc:set attr="To"    value="michaelw@kasoftware.cn"></arc:set>
          <arc:call op="appSendEmail" ></arc:call>
  </arc:if>
</arc:call>

<arc:call op="portStatisticsTransactionLogs?type=day" out="output">

<arc:if exp="[_index] == 2">

<arc:set attr="Subject" value="Transaction Log Notify-2020"></arc:set>

<arc:set attr="Message" value="The transaction log is Received:[output.Received] + Sent:[output.Sent] + Error:[output.Error] within the last hour, please check."></arc:set>

<arc:set attr="To" value="michaelw@kasoftware.cn"></arc:set>

<arc:call op="appSendEmail" ></arc:call>

</arc:if>

</arc:call>

注：

关于此段代码中涉及的参数说明如下：

（1）arc:call op=”portStatisticsTransactionLogs? 是我们需要调用StatisticsTransactionLogs里的记录，该记录中包含了EDI系统中每小时发送和接收文件的数量以及error的数量。

（2）Subject是邮件通知的主题，可以在value里面自定义，这里邮件的标题是Transaction Log Notify-2020.

（3）Message是邮件内容，可自定义，这里邮件内容是：The transaction log is Received:[output.Received] + Sent:[output.Sent] + Error:[output.Error] within the last hour, please check.。其中[output.Received]为一小时中接收到的文件数量,[output.Sent]是一小时中发送文件的数量,[output.Error]是失败文件的数量。

（4）To是收件人邮箱，可以配置多个收件人，多个邮箱间以英文逗号间隔。

代码逻辑：首先我们通过获取StatisticsTransactionLogs中的记录，在记录里获取到近一小时内Sent和Received以及Error对应的数值，将获取到的值写在我们邮件通知的内容中。

在Script端口写好代码后，我们需要打开自动接收并且选择每小时自动接收一次。

此时我们每小时就会收到EDI系统的邮件通知，汇总近一小时内收到的文件收发数量以及报错数量。

知识拓展：

除了上述的代码部署方式，我们也可以根据用户不同的需求来自定义部署。例如有的客户只想当系统近一小时传输文件数量少于某值时再进行邮件通知，而不是每小时都会接收到通知。我们就可以在上面的代码基础上进行修改来满足客户的需求。比如我们只想当遇到近一小时内EDI系统中发送接收以及报错的文件总数量少于100时再进行邮件通知的情况，我们可以这样修改代码:

<arc:call op="portStatisticsTransactionLogs?type=day" out="output">
  <!-- Only check transactions on the last hour (e.g. 02:00 to 03:00) -->
  <arc:if exp="[_index] == 2">
    <arc:if exp="([output.Received] + [output.Sent] + [output.Error]) < 100">
      

<!-- Send Email -->
          <arc:set attr="Subject"    value="Transaction Log Notify-2020"></arc:set>
          <arc:set attr="Message"  value="The transaction log is Received:[output.Received] + Sent:[output.Sent] + Error:[output.Error] within the last hour, please check."></arc:set>
          <arc:set attr="To"    value="michaelw@kasoftware.cn"></arc:set>
          <arc:call op="appSendEmail" ></arc:call>
    </arc:if>
  </arc:if>
</arc:call>

<arc:call op="portStatisticsTransactionLogs?type=day" out="output">

<arc:if exp="[_index] == 2">

<arc:if exp="([output.Received] + [output.Sent] + [output.Error]) < 100">

<arc:set attr="Subject" value="Transaction Log Notify-2020"></arc:set>

<arc:set attr="Message" value="The transaction log is Received:[output.Received] + Sent:[output.Sent] + Error:[output.Error] within the last hour, please check."></arc:set>

<arc:set attr="To" value="michaelw@kasoftware.cn"></arc:set>

<arc:call op="appSendEmail" ></arc:call>

</arc:if>

</arc:call>

修改的地方就是在配置邮件发送前添加了一个判断条件，判断Received和Sent以及Error三者加起来的数量是否少于100。

有的客户如果有每天收到邮件太多或者不经常看邮箱的情况时，我们配置邮件通知的方案可能就起不到很好的效果，那为了解决这样的问题我们同样可以用钉钉通知的方案替换邮件通知。修改后的代码如下:

<arc:call op="portStatisticsTransactionLogs?type=day" out="output">
  <!-- Only check transactions on the last hour (e.g. 02:00 to 03:00) -->
  <arc:if exp="[_index] == 2">
          <rsb:set attr="check.sslcert" value="*"/>
          <rsb:call op="httpGet" in="check">
          <rsb:catch code="*">
          <rsb:setattr="notify.url" value="https://oapi.dingtalk.com/robot/send?access_token=986e48ae3595afc58363adcf7da08a61549c6e66554fd77e84e6947e1dafe6d9"/>
          <rsb:setm item="notify">
           url= https://oapi.dingtalk.com/robot/send?access_token=986e48ae3595afc58363adcf7da08a61549c6e66554fd77e84e6947e1dafe6d9           
postdata = 
{"at": {"atMobiles":\["18991281155"\],"isAtAll":true},"text": {"content":"收到:[output.Received] + Sent:[output.Sent] + Error:[output.Error] within the last hour, please check."},"msgtype":"text"}
           contenttype = application/json
    </rsb:setm>
    <rsb:call op="httpPost" in="notify" />
  </rsb:catch>
</rsb:call>
  </arc:if>
</arc:call>

<arc:call op="portStatisticsTransactionLogs?type=day" out="output">

<arc:if exp="[_index] == 2">

<rsb:set attr="check.sslcert" value="*"/>

<rsb:call op="httpGet" in="check">

<rsb:catch code="*">

<rsb:setattr="notify.url" value="https://oapi.dingtalk.com/robot/send?access_token=986e48ae3595afc58363adcf7da08a61549c6e66554fd77e84e6947e1dafe6d9"/>

<rsb:setm item="notify">

url= https://oapi.dingtalk.com/robot/send?access_token=986e48ae3595afc58363adcf7da08a61549c6e66554fd77e84e6947e1dafe6d9

postdata =

{"at": {"atMobiles":\["18991281155"\],"isAtAll":true},"text": {"content":"收到:[output.Received] + Sent:[output.Sent] + Error:[output.Error] within the last hour, please check."},"msgtype":"text"}

contenttype = application/json

</rsb:setm>

<rsb:call op="httpPost" in="notify" />

</rsb:catch>

</rsb:call>

</arc:if>

</arc:call>