alazhar/CsharpTemplate
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add project files.

Browse Source
This commit is contained in:
Al Azhar
2023-10-27 19:00:41 +07:00
parent 54a23f5c2c
commit 3949c3c62a
27 changed files with 1238 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
ConsoleTemplate/Conf.cs Normal file
View File

@ -0,0 +1,26 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using ConsoleTemplate.Repositories;
using Microsoft.Extensions.Configuration;
namespace ConsoleTemplate
{
internal static class Conf
{
public static string DB_SCHEME = "testdb";
public static string OTHER_CONF = "";
public static void Load(IRepository rorepository, IConfiguration config)
{
// Read config
if (config.GetValue<string>("Const:db_scheme") != null)
DB_SCHEME = config.GetValue<string>("Const:db_scheme");
//Read DB
// OTHER_CONF = _repo.GetConf("other");
}
}
}

16
ConsoleTemplate/ConsoleTemplate.config.json Normal file
View File

@ -0,0 +1,16 @@
{
"Logger": [
{
"Name": "Console",
"MinimumLevel": "Info"
},
{
"Name": "Text",
"MinimumLevel": "Debug"
}
],
"ConnectionStrings": {
"ReadDB": "server=localhost;port=3306;user id=root; password=root1234;Persist Security Info=True;pooling=false;connection timeout=500;allow user variables=True;Allow Zero DateTime=True;Convert Zero Datetime=True;SslMode:none",
"WriteDB": "server=localhost;port=3306;user id=root; password=root1234;Persist Security Info=True;pooling=false;connection timeout=500;allow user variables=True;Allow Zero DateTime=True;Convert Zero Datetime=True;SslMode:none"
}
}

43
ConsoleTemplate/ConsoleTemplate.csproj Normal file
View File

@ -0,0 +1,43 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>net6.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings>
<Nullable>disable</Nullable>
</PropertyGroup>
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
<DebugType>embedded</DebugType>
</PropertyGroup>
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|AnyCPU'">
<DebugType>embedded</DebugType>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="7.0.4" />
<PackageReference Include="Microsoft.Extensions.Configuration.Ini" Version="7.0.0" />
<PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="7.0.0" />
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="7.0.0" />
<PackageReference Include="MySqlConnector" Version="2.2.7" />
<PackageReference Include="System.CommandLine" Version="2.0.0-beta4.22272.1" />
<PackageReference Include="System.CommandLine.NamingConventionBinder" Version="2.0.0-beta4.22272.1" />
</ItemGroup>
<ItemGroup>
<Folder Include="Entities\" />
</ItemGroup>
<ItemGroup>
<None Update="changelog.txt">
<CopyToOutputDirectory>Always</CopyToOutputDirectory>
<ExcludeFromSingleFile>true</ExcludeFromSingleFile>
</None>
<None Update="$safeprojectname$.config.json">
<CopyToOutputDirectory>Always</CopyToOutputDirectory>
<ExcludeFromSingleFile>true</ExcludeFromSingleFile>
</None>
</ItemGroup>
</Project>

25
ConsoleTemplate/ConsoleTemplate.sln Normal file
View File

@ -0,0 +1,25 @@

Microsoft Visual Studio Solution File, Format Version 12.00
# Visual Studio Version 17
VisualStudioVersion = 17.7.34031.279
MinimumVisualStudioVersion = 10.0.40219.1
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConsoleTemplate", "ConsoleTemplate.csproj", "{FB15BFF9-C749-43D3-B571-F6A16E94E731}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
Release|Any CPU = Release|Any CPU
EndGlobalSection
GlobalSection(ProjectConfigurationPlatforms) = postSolution
{FB15BFF9-C749-43D3-B571-F6A16E94E731}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{FB15BFF9-C749-43D3-B571-F6A16E94E731}.Debug|Any CPU.Build.0 = Debug|Any CPU
{FB15BFF9-C749-43D3-B571-F6A16E94E731}.Release|Any CPU.ActiveCfg = Release|Any CPU
{FB15BFF9-C749-43D3-B571-F6A16E94E731}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {939171FE-D5DB-4034-B198-43FDDFAC2D32}
EndGlobalSection
EndGlobal

10
ConsoleTemplate/Contexts/IDBContext.cs Normal file
View File

@ -0,0 +1,10 @@
using MySqlConnector;
namespace ConsoleTemplate.Contexts
{
internal interface IDBContext
{
Object GetWriteConn();
Object GetReadConn();
}
}

38
ConsoleTemplate/Contexts/MysqlDBContext.cs Normal file
View File

@ -0,0 +1,38 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Extensions.Configuration;
using MySqlConnector;
namespace ConsoleTemplate.Contexts
{
internal class MysqlDBContext : IDBContext
{
private IConfiguration _config;
private MySqlConnection _connection;
private MySqlCommand _cmd;
private string _connectionStringRead;
private string _connectionStringWrite;
public MysqlDBContext(IConfiguration configuration)
{
_config = configuration;
_connectionStringRead = _config.GetConnectionString("ReadDB").ToString();
_connectionStringWrite = _config.GetConnectionString("WriteDB").ToString();
}
public Object GetReadConn()
{
_connection = new MySqlConnection(_connectionStringWrite);
return _connection;
}
public Object GetWriteConn()
{
_connection = new MySqlConnection(_connectionStringRead);
return _connection;
}
}
}

95
ConsoleTemplate/Program.cs Normal file
View File

@ -0,0 +1,95 @@
using ConsoleTemplate.Contexts;
using ConsoleTemplate.Repositories;
using ConsoleTemplate.Services;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using System.CommandLine;
using System.Globalization;
namespace ConsoleTemplate
{
internal class Program
{
static int Main(string[] args)
{
Thread.CurrentThread.CurrentCulture = new CultureInfo("en-US");
var serviceCollection = new ServiceCollection();
ConfigureServices(serviceCollection);
var serviceProvider = serviceCollection.BuildServiceProvider();
var timerSvc = serviceProvider.GetRequiredService<TimerService>();
// Option
var dateOption = new Option<DateTime>
(
name: "--date",
description: "Tangal Proses",
isDefault: true,
parseArgument: result =>
{
if (result.Tokens.Count == 0)
{
return DateTime.Now;
}
string strtgl = result.Tokens.Single().Value;
if (DateTime.TryParseExact(strtgl, "yyMMdd", null, DateTimeStyles.None, out DateTime tgl))
{
return tgl;
}
else
{
result.ErrorMessage = "Format tanggal salah";
return DateTime.Now;
}
}
);
dateOption.AddAlias("-d");
var threadOption = new Option<int>
(
name: "--thread",
description: "Jumlah Thread",
getDefaultValue: () => 8
);
threadOption.AddAlias("-t");
// Command
// == Timer
var rootCommand = new RootCommand("Proses RO PB");
rootCommand.AddOption(dateOption);
rootCommand.AddOption(threadOption);
rootCommand.SetHandler
(
(ctx) =>
{
timerSvc.Start(
ctx.ParseResult.GetValueForOption<DateTime>(dateOption),
ctx.ParseResult.GetValueForOption<int>(threadOption)
);
}
);
return rootCommand.Invoke(args);
}
private static void ConfigureServices(ServiceCollection service)
{
// Build Configuration
IConfiguration configuration = new ConfigurationBuilder()
.SetBasePath(Directory.GetCurrentDirectory())
//.SetBasePath(Environment.CurrentDirectory)
.AddJsonFile("$safeprojectname$.config.json")
.Build();
service.AddSingleton(configuration);
service.AddSingleton<IDBContext, MysqlDBContext>();
service.AddSingleton<LogService>();
service.AddSingleton<TimerService>();
service.AddScoped<IRepository, MysqlRepository>();
}
}
}

13
ConsoleTemplate/Repositories/IRepository.cs Normal file
View File

@ -0,0 +1,13 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConsoleTemplate.Repositories
{
internal interface IRepository
{
bool InitDB();
}
}

33
ConsoleTemplate/Repositories/MysqlRepository.cs Normal file
View File

@ -0,0 +1,33 @@
using ConsoleTemplate.Contexts;
using ConsoleTemplate.Services;
using MySqlConnector;
namespace ConsoleTemplate.Repositories
{
internal class MysqlRepository : IRepository
{
private IDBContext _dbContext;
private LogService _log;
public MysqlRepository(IDBContext dbContext, LogService logger)
{
_dbContext = dbContext;
_log = logger;
}
public bool InitDB()
{
using (MySqlConnection con = (MySqlConnection)_dbContext.GetWriteConn())
{
_log.Info("Init DB");
con.Open();
MySqlCommand cmd = con.CreateCommand();
cmd.CommandText = $"CREATE DATABASE IF NOT EXISTS `{Conf.DB_SCHEME}`";
cmd.ExecuteNonQuery();
return true;
}
}
}
}

266
ConsoleTemplate/Services/LogService.cs Normal file
View File

@ -0,0 +1,266 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using ConsoleTemplate.Contexts;
using Microsoft.Extensions.Configuration;
namespace ConsoleTemplate.Services
{
internal class LogService
{
private LogType[] _logtype;
private IDBContext _db;
public LogService(IConfiguration config, IDBContext dbcontext)
{
_db = dbcontext;
_logtype = config.GetSection("Logger").Get<LogType[]>();
}
public LogService(LogType[] logtype)
{
_logtype = logtype;
}
public void Debug(string s, string trace = "", string cmd = "")
{
WriteLog("Debug", s, "", trace, cmd);
}
public void Debug(string s, string toko, string trace = "", string cmd = "")
{
WriteLog("Debug", s, toko, trace, cmd);
}
public void Info(string s, string trace = "", string cmd = "")
{
WriteLog("Info", s, "", trace, cmd);
}
public void Info(string s, string toko, string trace = "", string cmd = "")
{
WriteLog("Info", s, toko, trace, cmd);
}
public void Warning(string s, string trace = "", string cmd = "")
{
WriteLog("Warn", s, "", trace, cmd);
}
public void Warning(string s, string toko, string trace = "", string cmd = "")
{
WriteLog("Warn", s, toko, trace, cmd);
}
public void Error(string s, string trace = "", string cmd = "")
{
WriteLog("Error", s, "", trace, cmd);
}
public void Error(string s, string toko, string trace = "", string cmd = "")
{
WriteLog("Error", s, toko, trace, cmd);
}
private void WriteLog(string tipe, string s, string toko, string trace = "", string cmd = "")
{
foreach (LogType l in _logtype)
{
if (
(l.MinimumLevel.ToLower() == "error" && tipe.ToLower() == "error") ||
(l.MinimumLevel.ToLower() == "warn" && (tipe.ToLower() == "warn" || tipe.ToLower() == "warn")) ||
(l.MinimumLevel.ToLower() == "info" && tipe.ToLower() != "debug") ||
(l.MinimumLevel.ToLower() == "debug")
)
{
switch (l.Name.ToLower())
{
case "console":
ConsoleLog(s, toko, tipe, trace);
break;
case "text":
TextLog(l.Path, s, toko, tipe, trace, cmd);
break;
case "json":
JsonLog(l.Path, s, toko, tipe, trace, cmd);
break;
default:
break;
}
}
}
}
private static void ConsoleLog(string s, string toko, string tipe, string trace = "")
{
Console.Write($"{DateTime.Now:yyyy-MM-dd HH:mm:ss} ");
if (tipe.ToLower() == "info")
{
Console.BackgroundColor = ConsoleColor.Green;
Console.ForegroundColor = ConsoleColor.White;
Console.Write($"[INFO ]");
Console.ResetColor();
if (toko == "")
Console.WriteLine($" {s}");
else
Console.WriteLine($" ({toko}) {s}");
}
else if (tipe.ToLower() == "warn")
{
Console.BackgroundColor = ConsoleColor.Yellow;
Console.ForegroundColor = ConsoleColor.Black;
Console.Write($"[WARN ]");
Console.ResetColor();
if (toko == "")
Console.WriteLine($" {s}");
else
Console.WriteLine($" ({toko}) {s}");
}
else if (tipe.ToLower() == "error")
{
Console.BackgroundColor = ConsoleColor.Red;
Console.ForegroundColor = ConsoleColor.White;
Console.Write($"[ERROR]");
Console.ResetColor();
if (toko == "")
Console.WriteLine($" {s}");
else
Console.WriteLine($" ({toko}) {s}");
if (trace != "")
Console.WriteLine(Environment.NewLine + trace);
}
else
{
Console.WriteLine($"[DEBUG] {s}");
}
}
private static void TextLog(string path, string s, string toko, string level, string trace = "", string cmd = "")
{
if (path is null)
{
path = Environment.CurrentDirectory + "\\logs";
}
string filename;
if (toko == "")
{
filename = @$"{path}\log-{DateTime.Now:MMM-yyyy}.log";
}
else
{
filename = @$"{path}\toko\{toko} log-{DateTime.Now:MMM-yyyy}.log";
}
bool written = false;
Directory.CreateDirectory(path);
Directory.CreateDirectory(path + "\\toko");
s = System.Text.RegularExpressions.Regex.Replace(s, @"\p{C}+", ">").Replace(Environment.NewLine, ">");
trace = System.Text.RegularExpressions.Regex.Replace(trace, @"\p{C}+", ">").Replace(Environment.NewLine, ">");
cmd = System.Text.RegularExpressions.Regex.Replace(cmd, @"\p{C}+", ">").Replace(Environment.NewLine, ">");
level = level.PadRight(5).ToUpper();
while (!written)
{
try
{
using (StreamWriter sw = System.IO.File.AppendText(filename))
{
sw.WriteLine(@$"{DateTime.Now:dd-MM-yy HH:mm:ss}|[{level}]|{s}|{trace}|{cmd}");
}
written = true;
}
catch (Exception)
{
}
}
}
private static void DBLog(string s, string toko, string level, string trace = "", string cmd = "")
{
}
private static void JsonLog(string path, string s, string toko, string level, string trace = "", string cmd = "")
{
if (path is null)
{
path = Environment.CurrentDirectory + "\\logs";
}
string filename;
if (toko == "")
{
filename = @$"{path}\log-{DateTime.Now:MMM-yyyy}.json";
}
else
{
filename = @$"{path}\toko\{toko} log-{DateTime.Now:MMM-yyyy}.json";
}
bool written = false;
Directory.CreateDirectory(path);
Directory.CreateDirectory(path + "\\toko");
while (!written)
{
try
{
List<JsonLog> loglist;
if (File.Exists(filename))
{
string jsondata = System.IO.File.ReadAllText(filename);
loglist = JsonSerializer.Deserialize<List<JsonLog>>(jsondata);
}
else
{
loglist = new List<JsonLog>();
}
loglist.Add(new JsonLog()
{
Time = DateTime.Now,
Mesage = s,
Toko = toko,
Level = level,
Trace = trace,
Cmd = cmd,
});
File.WriteAllText(filename, JsonSerializer.Serialize(loglist));
written = true;
}
catch (Exception)
{
}
}
}
}
class LogType
{
public string Name { get; set; }
public string MinimumLevel { get; set; }
public string Path { get; set; }
}
class JsonLog
{
public DateTime Time { get; set; }
public string Toko { get; set; }
public string Level { get; set; }
public string Mesage { get; set; }
public string Trace { get; set; }
public string Cmd { get; set; }
}
}

115
ConsoleTemplate/Services/TimerService.cs Normal file
View File

@ -0,0 +1,115 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using System.Timers;
using ConsoleTemplate.Repositories;
using Microsoft.Extensions.Configuration;
namespace ConsoleTemplate.Services
{
internal class TimerService
{
private LogService _log;
private IRepository _repo;
private IConfiguration _config;
private System.Timers.Timer _tmr;
private DateTime _tglRequest;
private int _jumlahTread;
public TimerService(LogService logger, IRepository rorepository, IConfiguration config)
{
_log = logger;
_repo = rorepository;
_config = config;
}
public void Start(DateTime tanggalProses, int jmlthread)
{
_repo.InitDB();
_tglRequest = tanggalProses;
_jumlahTread = jmlthread;
Conf.Load(_repo, _config);
_log.Info("Timer Start");
_tmr = new System.Timers.Timer(5000);
_tmr.Elapsed += CekRequest;
_tmr.Start();
Console.ReadLine();
}
private void CekRequest(object sender, ElapsedEventArgs e)
{
_tmr.Stop();
try
{
long totalRequest = 0; // _repo.GetTotalRequest(_tglRequest);
if (totalRequest > 0)
{
//List<Request> _requestList = _repo.GetRequests(_tglRequest);
ProceedRequest();
}
else if (true)
{
}
}
catch (Exception ex)
{
_log.Error("Error CekRequest : " + ex.Message);
}
_tmr.Start();
}
private void ProceedRequest()
{
try
{
List<Thread> ThreadList = new List<Thread>();
for (int i = 0; i < _jumlahTread; i++)
{
ThreadList.Add(new Thread(DummyProcess));
ThreadList[i].Name = "Thread" + i;
}
for (int i = 0; i < 10; i++)
{
int k = Array.FindIndex(ThreadList.ToArray(), IsThreadAvailable);
if (k >= 0)
{
ThreadList[k] = new Thread(() => DummyProcess());
ThreadList[k].Start();
}
while (Array.FindAll(ThreadList.ToArray(), IsThreadAvailable).Length == 0 ||
(i == 10 & Array.FindAll(ThreadList.ToArray(), IsThreadRunning).Length > 0))
Thread.Sleep(5000);
}
}
catch (Exception ex)
{
_log.Error("Error ProceedRequest : " + ex.Message);
}
}
private void DummyProcess() { }
private bool IsThreadAvailable(Thread t)
{
return t.ThreadState != ThreadState.Running && t.ThreadState != ThreadState.WaitSleepJoin;
}
private bool IsThreadRunning(Thread t)
{
return t.ThreadState == ThreadState.Running || t.ThreadState == ThreadState.WaitSleepJoin;
}
}
}

8
ConsoleTemplate/changelog.txt Normal file
View File

@ -0,0 +1,8 @@
#emailby alazhar@indomaret.co.id
#emailto alazhar@indomaret.co.id
#emailcc alazhar@indomaret.co.id
#location http://localhost:21/
#line 8
v 1.0.0.0
- Test