using System;

 using System.Linq;

 using System.Threading.Tasks;

 using Senparc.WebSocket;

 using Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage;

 using Senparc.Weixin.WxOpen.Containers;

 namespace Senparc.Weixin.MP.Sample.CommonService.MessageHandlers.WebSocket

 {

     /// <summary>

     /// .NET Core 自定义 WebSocket 处理类

     /// </summary>

     public class CustomNetCoreWebSocketMessageHandler : WebSocketMessageHandler

     {

         public override Task OnConnecting(WebSocketHelper webSocketHandler)

         {

             //TODO:处理连接时的逻辑

             return base.OnConnecting(webSocketHandler);

         }

         public override Task OnDisConnected(WebSocketHelper webSocketHandler)

         {

             //TODO:处理断开连接时的逻辑

             return base.OnDisConnected(webSocketHandler);

         }

         public override async Task OnMessageReceiced(WebSocketHelper webSocketHandler, ReceivedMessage receivedMessage, string originalData)

         {

             if (receivedMessage == null || string.IsNullOrEmpty(receivedMessage.Message))

             {

                 return;

             }

             var message = receivedMessage.Message;

             await webSocketHandler.SendMessage("originalData：" + originalData, webSocketHandler.WebSocket.Clients.Caller);

             await webSocketHandler.SendMessage("您发送了文字：" + message, webSocketHandler.WebSocket.Clients.Caller);

             await webSocketHandler.SendMessage("正在处理中（反转文字）...", webSocketHandler.WebSocket.Clients.Caller);

             await Task.Delay();

             //处理文字

             var result = string.Concat(message.Reverse());

             await webSocketHandler.SendMessage(result, webSocketHandler.WebSocket.Clients.Caller);

             var appId = Config.SenparcWeixinSetting.WxOpenAppId;//与微信小程序账号后台的AppId设置保持一致，区分大小写。

             try

             {

                 var sessionBag = SessionContainer.GetSession(receivedMessage.SessionId);

                 //临时演示使用固定openId

                 var openId = sessionBag != null ? sessionBag.OpenId : "onh7q0DGM1dctSDbdByIHvX4imxA";// "用户未正确登陆";

                 //await webSocketHandler.SendMessage("OpenId：" + openId, webSocketHandler.WebSocket.Clients.Caller);

                 //await webSocketHandler.SendMessage("FormId：" + formId);

                 //群发

                 await webSocketHandler.SendMessage($"[群发消息] [来自 OpenId：***{openId.Substring(openId.Length - 10, 10)}，昵称：{sessionBag.DecodedUserInfo?.nickName}]：{message}", webSocketHandler.WebSocket.Clients.All);

                 //发送模板消息

                 //var data = new WxOpenTemplateMessage_PaySuccessNotice(

                 //    "在线购买", SystemTime.Now, "图书众筹", "1234567890",

                 //    100, "400-9939-858", "http://sdk.senparc.weixin.com");

                 var formId = receivedMessage.FormId;//发送模板消息使用，需要在wxml中设置<form report-submit="true">

                 var data = new

                 {

                     keyword1 = new TemplateDataItem("来自小程序WebSocket的模板消息（测试数据）"),

                     keyword2 = new TemplateDataItem(SystemTime.Now.LocalDateTime.ToString()),

                     keyword3 = new TemplateDataItem($"来自 Senparc.Weixin SDK 小程序 .Net Core WebSocket 触发\r\n您刚才发送了文字：{message}"),

                     keyword4 = new TemplateDataItem(SystemTime.NowTicks.ToString()),

                     keyword5 = new TemplateDataItem(.ToString("C")),

                     keyword6 = new TemplateDataItem("400-031-8816"),

                 };

                 var tmResult = Senparc.Weixin.WxOpen.AdvancedAPIs.Template.TemplateApi.SendTemplateMessage(appId, openId, "Ap1S3tRvsB8BXsWkiILLz93nhe7S8IgAipZDfygy9Bg", data, receivedMessage.FormId, "pages/websocket/websocket", "websocket",

                          null);

             }

             catch (Exception ex)

             {

                 var msg = ex.Message + "\r\n\r\n" + originalData + "\r\n\r\nAPPID:" + appId;

                 await webSocketHandler.SendMessage(msg, webSocketHandler.WebSocket.Clients.Caller); //VS2017以下如果编译不通过，可以注释掉这一行

                 WeixinTrace.SendCustomLog("WebSocket OnMessageReceiced()过程出错", msg);

             }

         }

     }

 }

 var signalR = require("../../utils/signalr.1.0.js")

 var senparcWebsocket = require("../../utils/senparc.websocket.js")

 var connection;// Signalr 连接

 var app = getApp()

 var socketOpen = false;//WebSocket 打开状态

 Page({

   data: {

     messageTip: '正在连接中，请等待...',

     messageTextArr: [],

     messageContent: 'TEST',

     userinfo: {}

   },

   //sendMessage

   formSubmit: function (e) {

     var that = this;

     console.log('formSubmit', e);

     if (socketOpen) {

       var text = e.detail.value.messageContent;//必填，获得输入文字

       var sessionId = wx.getStorageSync("sessionId");//选填，不需要可输入''

       var formId = e.detail.formId//选填formId用于发送模板消息，不需要可输入''

       senparcWebsocket.sendMessage(text,sessionId,formId);//发送 websocket 请求

       that.setData({

         messageContent: ''

       })

     } else {

       that.setData({

         messageTip: 'WebSocket 链接失败，请重新连接！'

       })

     }

   },

   onLoad: function () {

     console.log('onLoad')

   },

   onShow:function(){

     console.log('onShow');

     var that = this;

     var hubUrl = wx.getStorageSync('wssDomainName') + "/SenparcHub";//Hub Url

     var onStart = function () {

       console.log('ws started');

       socketOpen = true;

       that.setData({

         messageTip: 'WebSocket 连接成功！'

       })

     };

     connection = senparcWebsocket.buildConnectionAndStart(hubUrl, signalR, onStart);

     //定义收到消息后触发的事件

     var onReceive = function (res) {

       console.log('收到服务器内容：' + res)

       var jsonResult = JSON.parse(res);

       var currentIndex = that.data.messageTextArr.length + ;

       var newArr = that.data.messageTextArr;

       newArr.unshift(

         {

           index: currentIndex,

           content: jsonResult.content,

           time: jsonResult.time

         });

       console.log(that);

       that.setData({

         messageTextArr: newArr

       });

     };

     senparcWebsocket.onReceiveMessage(onReceive);

     //WebSocket 连接成功

     wx.onSocketOpen(function (res) {

       console.log('WebSocket 连接成功！')

     })

     //WebSocket 已关闭

     wx.onSocketClose(function (res) {

       console.log('WebSocket 已关闭！')

       socketOpen = false;

     })

     //WebSocket 打开失败

     wx.onSocketError(function (res) {

       console.log('WebSocket连接打开失败，请检查！')

     })

   }

 })