3cx Tapi Server

server/src/CPATapi.Server/Controllers/AvailabilityController.cs

@@ -0,0 +1,47 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Dapper;
+using Microsoft.Data.SqlClient;
+using Microsoft.Extensions.Configuration;
+
+namespace CPATapi.Server.Controllers
+{
+    [Route("[controller]")]
+    [ApiController]
+    public class AvailabilityController : ControllerBase
+    {
+        private readonly IConfiguration _config;
+        public AvailabilityController(IConfiguration config) => _config = config;
+
+        [HttpGet, Route("users")]
+        public async Task<IEnumerable<string>> GetUsers()
+        {
+            await using var con = new SqlConnection(_config["Db:ConnectionStringZc"]);
+            await con.OpenAsync();
+            return await con.QueryAsync<string>(@"
+SELECT DISTINCT MA_USER_NAME
+FROM dbo.MA_DATEN
+WHERE MA_USER_NAME IS NOT NULL AND MA_USER_AKTIV = 1
+ORDER BY MA_USER_NAME");
+        }
+
+        [HttpGet, Route("{user}")]
+        public async Task<object> GetAvailability(string user)
+        {
+            await using var con = new SqlConnection(_config["Db:ConnectionStringZc"]);
+            await con.OpenAsync();
+            var stampCount = (await con.QueryAsync(@"
+SELECT *
+FROM dbo.BU
+INNER JOIN dbo.MA_DATEN on MA_NR = BU_MA_NR
+WHERE
+  MA_USER_NAME = @user AND
+  BU_BU >= @date AND BU_BU < @tomorrow", new { user, date = DateTime.Now.Date, tomorrow = DateTime.Now.AddDays(1).Date })).Count();
+            return new { user, loggedIn = stampCount % 2 != 0 };
+        }
+    }
+}

server/src/CPATapi.Server/Controllers/CallerIdController.cs

@@ -0,0 +1,42 @@
+using System.Threading.Tasks;
+using CPATapi.Server.Models;
+using Dapper;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Data.SqlClient;
+using Microsoft.Extensions.Configuration;
+
+namespace CPATapi.Server.Controllers
+{
+    [Route("[controller]")]
+    [ApiController]
+    public class CallerIdController : ControllerBase
+    {
+        private readonly IConfiguration _config;
+        public CallerIdController(IConfiguration config) => _config = config;
+
+
+        [HttpGet, Route("{number}")]
+        public async Task<TapiContact> CallerIdAsync([FromRoute] string number)
+        {
+            if (number.Length >= 5)
+            {
+                var minMatch = number[^5..];
+                number = "%" + minMatch;
+            }
+
+            await using var con = new SqlConnection(_config["Db:ConnectionString"]);
+            await con.OpenAsync();
+
+            var result = await con.QueryFirstOrDefaultAsync<TapiContact>(@"
+SELECT 
+TD_ID,
+TD_NAME,
+TD_NUMBER,
+TD_NUMBER_TAPI,
+TD_MEDIUM
+FROM dbo.CP_TAPI_DIRECTORY
+WHERE TD_NUMBER_TAPI LIKE @number", new {number});
+            return result;
+        }
+    }
+}

server/src/CPATapi.Server/Controllers/ContactController.cs

@@ -0,0 +1,43 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using CPATapi.Server.Models;
+using Dapper;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Data.SqlClient;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+
+namespace CPATapi.Server.Controllers
+{
+    [ApiController]
+    [Route("[controller]")]
+    public class ContactController : ControllerBase
+    {
+
+        private readonly ILogger<ContactController> _logger;
+        private readonly IConfiguration _config;
+
+        public ContactController(ILogger<ContactController> logger, IConfiguration config)
+        {
+            _logger = logger;
+            _config = config;
+        }
+
+        [HttpGet]
+        public async Task<IEnumerable<TapiContact>> GetAsync()
+        {
+            await using var con = new SqlConnection(_config["Db:ConnectionString"]);
+            await con.OpenAsync();
+
+            var contacts = await con.QueryAsync<TapiContact>(@"
+SELECT 
+TD_ID,
+TD_NAME,
+TD_NUMBER,
+TD_NUMBER_TAPI,
+TD_MEDIUM
+FROM dbo.CP_TAPI_DIRECTORY");
+            return contacts;
+        }
+    }
+}

server/src/CPATapi.Server/Controllers/SearchController.cs

@@ -0,0 +1,64 @@
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Text.RegularExpressions;
+using System.Threading.Tasks;
+using CPATapi.Server.Models;
+using Dapper;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Data.SqlClient;
+using Microsoft.Extensions.Configuration;
+
+namespace CPATapi.Server.Controllers
+{
+    [Route("[controller]")]
+    [ApiController]
+    public class SearchController : ControllerBase
+    {
+        private readonly IConfiguration _config;
+        public SearchController(IConfiguration config) => _config = config;
+
+        [HttpGet]
+        public async Task<IEnumerable<TapiContact>> SearchAsync([FromQuery] string query)
+        {
+            if (query == null)
+            {
+                return new List<TapiContact>();
+            }
+
+            var args = Regex.Split(query, "\\s").Where(s => !string.IsNullOrWhiteSpace(s)).Select(s => s.Trim()).ToArray();
+
+            if (args.Length == 0)
+            {
+                return new List<TapiContact>();
+            }
+
+            await using var con = new SqlConnection(_config["Db:ConnectionString"]);
+            await con.OpenAsync();
+            var sql = new StringBuilder(@"
+SELECT TOP 10
+TD_ID,
+TD_NAME,
+TD_NUMBER,
+TD_NUMBER_TAPI,
+TD_MEDIUM
+FROM dbo.CP_TAPI_DIRECTORY
+WHERE ");
+            var first = true;
+            var dp = new DynamicParameters();
+            for (var i = 1; i <= args.Length; i++)
+            {
+                if (!first)
+                {
+                    sql.AppendLine("AND");
+                }
+                first = false;
+                sql.AppendLine($"(TD_NAME LIKE @s{i} OR");
+                sql.AppendLine($" TD_NUMBER_TAPI LIKE @s{i})");
+                dp.Add($"s{i}", $"%{args[i-1]}%");
+            }
+
+            return await con.QueryAsync<TapiContact>(sql.ToString(), dp);
+        }
+    }
+}