some changes

专题/后端/2021.03.01新总部运营后台适配办公楼版.md

@@ -0,0 +1,74 @@
+> 需要解决的问题是什么？
+
+新的总部运营后台适配办公楼版。从数据库来说，老的总部运营后台用到了`authserver`和`hd`这两个数据库。而新的总部运营后台用到了`hd_new`这个数据库。
+
+
+
+从基础设施层来看，原先所有和`authserver`和`hd`相关的增删改查都要切换到`hd_new`这个数据库。
+
+
+
+> 大致步骤
+
+- 找出所有和`IHeadQuarterRepository`和`IAuthRepository`
+- 替换成`HdContext`上下文下的表
+
+
+
+> 原则
+
+- 不改变接口
+- 做基础设施层
+- 在Application层加上`TODO`或自己改
+
+
+
+> `authserver`数据库
+
+- `aspnetusers`:用户表
+
+```
+-- UserName:在办公楼版中是手机号
+-- ProjectIds:通常用来表示用户属于哪个项目，但在办公楼版的后期没有用到，用户和项目的关系放在了projectuserroles表
+-- RemarkName:被用做了办公楼版的昵称
+-- Avator：被用做了办公楼版的头像
+```
+
+- `aspnetroles`: 角色表
+
+```
+与办公楼版有关的几个角色，分别是：
+-- HdDg:表示总部电工，也叫做办公楼版的超级管理员。总部电工/超级管理员登录办公楼版APP的时候，在"我的"里面可以选择项目下的某个公司，然后向这个公司的某个人A(想成为OfficeAdmin的那个人)展示二维码，扫描二维码以后，A就成为新朋友，然后总部电工/超级管理员在新朋友列表中找到A，点击同意，把他设置成公司管理员，即OfficeAdmin。其中相关的表用到了:office_demo中的companyusers,和authserver中的projectuserroles表
+-- OfficeAdmin:表示办公楼版的管理员。在办公楼版中，一个项目下有多个公司，每个公司只能有1个管理员，但是管理员可以在多个公司。
+-- OfficeGuest:表是办公楼版的游客。当某个注册用户，即在authserver中的aspnetusers表中有记录的用户扫描二维码，他的默认角色就是OfficeGuest
+-- OfficeOperator: 表示办公楼版的操作员。操作员不仅可以查看信息，还可以修改开关名称，控制开关，延时断电。
+```
+
+- `aspnetuserroles`:用户角色中间表，后期没有用到。把用户、角色与项目和公司的关系放到了`projectuserroles`表中
+- `projectuserroles`表：用来存放用户、角色与项目和公司的关系，具体什么时候用到表，要看具体业务逻辑。
+
+
+
+> `hd`数据库
+
+
+
+- `projects`表：有关项目
+- `groups`表：集团
+- `macprojects`: 模块和项目的关系
+- `banners`表示项目的banner管理
+- `industries`表是行业
+- `warningpolicies`表示报警策略
+
+
+
+> `hd_new`数据库
+
+
+
+
+
+# 
+
+
+

专题/后端/2021.2.3好用的sql语句.md

@@ -13,5 +13,13 @@ select count(*) from breakerdatas where mac='98CC4D213003'
 delete from breakerdatas where mac='187ED53338C4' and str_to_date(CreateTime, '%Y-%m-%d %H:%i:%s') <= str_to_date('2021-02-23 18:54:00', '%Y-%m-%d %H:%i:%s')
 
 select CreateTime, mac, addr from  breakerdatas where mac='187ED53338C4' and addr='1' and str_to_date(CreateTime, '%Y-%m-%d %H:%i:%s') >= str_to_date('2021-02-23 19:30:00', '%Y-%m-%d %H:%i:%s')
+
+select * from  breakerdatas where mac='187ED53338C4' and str_to_date(CreateTime, '%Y-%m-%d %H:%i:%s') >= str_to_date('2021-02-23 19:30:00', '%Y-%m-%d %H:%i:%s')
+
+select * from  breakerdatas where mac='187ED53338C4' and str_to_date(CreateTime, '%Y-%m-%d %H:%i:%s') >= date_sub(now(), interval 1 hour)
+
+select mac, addr, CreateTime from breakerdatas where mac='187ED53338C4' and addr='1' ORDER BY CreateTime desc
+
+select count(*) from breakerdatas where mac='187ED53338C4' and addr='1'
 ```
 

专题/后端/DDD/10、MedatR的两种用途.md

@@ -0,0 +1,19 @@
+如果是请求响应模式
+
+```
+IRequest
+IRequestHandler
+
+_mediator.Send(IRequest);
+```
+
+如果是事件广播模式
+
+```
+INotification
+INotificationHandler
+
+_mediator.Publish(INotification);
+```
+
+而`IMediator`可以被注入到任何类中。

专题/后端/Starbust/01AntJob的运作原理.md

@@ -0,0 +1,160 @@
+# 表结构
+
+```
+//每一个应用实例就是一个App
+public class App
+{
+	public int ID {get;set;}
+	publi string DisplayName {get;set;}
+	public string Secret {get;set;}	
+}
+
+//描述App的工作状态
+public class AppOnline
+{
+	public int ID {get;set;}
+	public string Instantce {get;set;}
+	public string Client {get;set;}
+	public string Name {get;set;}
+	public int ProcessId {get;set;}
+	public string Version {get;set;}
+	public string Server {get;set;}
+	public int Tasks {get;set;}
+	public int Total {get;set;}
+}
+
+//作业
+public class Job
+{
+	public int ID {get;set;}
+	public int AppID {get;set;}
+	public string Name {get;set;}
+	public string ClassName {get;set;}
+	public string DisplayName {get;set;}
+	public int Mode {get;set;}
+	public string Topic {get;set;}
+	public int MessageCount {get;set;}
+	public DateTime Start {get;set;}
+	public DateTime End {get;set;}
+	public int Step {get;set;}
+	public int BatchSize {get;set;}
+	public int Offset {get;set;}	
+}
+
+//作业的任务
+public class JobTask
+{
+	public int ID {get;set;}
+	public int AppID {get;set;}
+	public int JobID {get;set;}
+}
+```
+
+# 应用、调度中心、Web控制台
+
+![](F:\SourceCodes\DDWiki\专题\后端\Starbust\AntJob.svg)
+
+- 计算应用：理解成一个应用实例，可能是本地开发环境的控制台程序，可能是服务器上的一个服务
+- 调度中心：调度所有的作业，需要被持久化
+- Web控制台：展示调度中心的持久化内容
+
+# 最简单的例子
+
+应用要做的事情是把作业交给调度器开始执行。
+
+```
+            var set = AntSetting.Current;
+
+            // 实例化调度器
+            var sc = new Scheduler();
+
+            // 使用分布式调度引擎替换默认的本地文件调度
+            sc.Provider = new NetworkJobProvider
+            {
+                Server = set.Server,
+                AppID = set.AppID,
+                Secret = set.Secret,
+            };
+
+            // 添加作业处理器
+            sc.Handlers.Add(new HelloJob());
+            sc.Handlers.Add(new BuildPatient());
+            sc.Handlers.Add(new BuildWill());
+
+            // 启动调度引擎，调度器内部多线程处理
+            sc.Start();
+```
+
+所有的作业都是`Handler`类型。
+
+```
+	[DisplayName("定时欢迎")]
+    [Description("简单的定时任务")]
+    internal class HelloJob : Handler
+    {
+        public HelloJob()
+        {
+            // 今天零点开始，每10秒一次
+            var job = Job;
+            job.Start = DateTime.Today;
+            job.Step = 10;
+        }
+
+        protected override Int32 Execute(JobContext ctx)
+        {
+            // 当前任务时间
+            var time = ctx.Task.Start;
+            WriteLog("新生命蚂蚁调度系统！当前任务时间：{0}", time);
+
+            // 成功处理数据量
+            return 1;
+        }
+    }
+```
+
+![antjob1](F:\SourceCodes\DDWiki\专题\后端\Starbust\antjob1.png)
+
+# `Scheduler.Start()`做了什么？
+
+```
+public class Scheduler
+{
+	public List<Handler> Handlers { get; } = new List<Handler>();
+	public IJobProvider Provider { get; set; }//作业提供者
+	
+	public void Start()
+	{
+		var prv = Provider;
+		prv.Schedule = this;
+		prv.Start();//作业提供者开始
+		
+		var jobs = prv.GetJobs();
+		
+		var hs = Handlers;
+		foreach (var handler in hs)
+		{
+			handler.Schedule = this;
+			handler.Provider = prv;
+			
+			var job = jobs.FirstOrDefault(e => e.Name == handler.Name);
+			if(job!=null && job.Mode ==0) job.Mode = handler.Mode;
+			handler.Job = job;
+			
+			handler.Start();//作业处理器开始
+		}
+		
+		if(Period > 0) _timer = new TimeX(Loop, null, Period * 1000, "Job"){Async = true};
+	}
+}
+```
+
+`Scheduler`中维护着`Handler`的集合以及`IJobProvider`。`IJobProvider`需要知道`Scheduler`。`Handler`需要知道`Scheduler`和`IJobProvider`以及`IJob`。`Scheduler`让`IJobProvider`和每个`Handler`开始工作。更加重要的是，在实例化`TimeX`的过程中开始了任务调度，即`Scheudler`中的`Process()`。
+
+
+
+`Pr`
+
+
+
+
+

专题/后端/数据/数据问题的基本面.md

@@ -0,0 +1,337 @@
+# 存储过程的使用
+
+使用`EF`结合存储过程。用`EF`生成数据库、数据库迁移，查询用存储过程。更新、添加、删除之类的用`EF`。
+
+# 升级
+
+- 将来有一个注册中心可以进行远程发布
+
+
+
+# 实时数据
+
+
+
+> 使用场景包括：
+
+- 当对开关进行合闸分断后，需要根据实时数据来判断是否操作成功
+- 当对报警进行判断的时候，需要根据实时数据来判断报警是否解除
+
+
+
+
+
+>  实时数据从哪里来？
+
+每一个模块(通讯模块)可以指定服务器`IP`，实际上是指向到服务器上的一个`API`接口，然后在接口里对实时数据进行处理。比如说，指向到`47.103.61.198:5008/ebx-bishop/data/carry`。
+
+
+
+> 实时数据到哪里去？
+
+- 最新的实时数据进入了`Redis`缓存
+
+关于键和命名空间
+
+```
+OpenAPI_Test:187ED53159E4,macss 就是缓存的键。其中OpenAPI_Test可以理解为是命名空间，而且是可以多级的，比如：OpenAPI_Test：Test2
+```
+
+实时数据长啥样？
+
+```
+{
+  "serverinfo": {
+    "port": "12345",
+    "hardware": "T25",
+    "execleakcheck": "false",
+    "mac": "187ED53159E4", //模块号，是唯一的
+    "loginid": "187ED53159E4",
+    "gate": "",
+    "ip": "192.168.8.151",
+    "version": "2.52",
+    "loginpwd": "7a57a5a743894ae4",
+    "ssidpwd": "2803f88db851c67a",
+    "ssid": "DDINGW",
+    "timezoneId": "Asia/Shanghai",
+    "server": "http://47.103.61.198:5008/snd",
+    "datetime": "2021-02-25 02:10:00", //上传时间，会根据这个字段判断是否离线
+    "leakcheckdate": "3,13,33",
+    "lastleakcheckdate": "2017-01-01 10:00:00"
+  },
+  "distributbox": {
+    "Breakers": { //开关
+      "1": {//线路地址1
+        "version": "0.72",
+        "title": "总路",
+        "model": "JZK2L100-BL6523",
+        "Alarm": 0,
+        "EnableNetCtrl": true,//是否可以通过软件控制线路，比如线下某个电工手动把分断了，那么这里的EnableNetCtrl=false,这时候，如果软件界面上需要合闸，需要判断EnableNetCtrl这个字段值，如果是EnableNetCtrl=false情况下不运行进行合闸，避免导致电工的生命安全，需要自己写逻辑判断
+        "MXDW": 0.0,//门限低温，当温度低于这里的设置，模块会主动推送报警，服务端来接收，门限值常见会提供接口进行修改
+        "MXGG": 7040.0,//门限过功，门限值常见会提供接口进行修改
+        "MXGL": 48.00,//门限过流，门限值常见会提供接口进行修改
+        "MXGW": 90.0,//门限过温，门限值常见会提供接口进行修改
+        "MXGY": 260.0,//门限过压，门限值常见会提供接口进行修改
+        "MXLD": 30.0,//门限漏电，门限值常见会提供接口进行修改
+        "MXQY": 100.0,//门限欠压，门限值常见会提供接口进行修改
+        "OpenClose": true,//开关的合闸分断状态，true表示当前合闸状态
+        "addr": 1,//线路地址
+        "power": 51.3,//上一个小时的电量，单位是瓦W
+        "specification": "32",//线路规格
+        "control": 1,//线路是否可控，如果是0的话，线路无法合闸分断，在实践中再去体会
+        "visibility": 1,//线路是否可见
+        "totalChannelId": -1,//是否是总路，本开关线路是被接入到哪个开关线路下(-1 - 进线直连，即本开关未被接入到其它开关；其它 - 本开关线路被接入到另一个开关线路，此值为本开关所接入的开关线路的地址编号),需要实际施工的时候区分连接方式
+        "lineType": "220",//线路类型，220表示接的220V的电压；380表示接入的是380V的三相电压
+        "A_A": 0.13,//三相情况下的A相电流，在lineTYpe=220的情况下，就是线路电流
+        "A_T": 27.5,//线温
+        "A_V": 232.0,//电压
+        "A_WP": 25.0,//功率
+        "A_LD": 0.0,//漏电
+        "A_PF": 0.0,//功率因素
+        "G_A": 0.0,//平均电流
+        "G_T": 0.0,
+        "G_V": 0.0,
+        "G_WP": 0.0,
+        "G_LD": 0.0,
+        "G_PF": 0.0,
+        "B_A": 0.0,//B相
+        "B_T": 0.0,
+        "B_V": 0.0,
+        "B_WP": 0.0,
+        "B_PF": 0.0,
+        "C_A": 0.0,//相
+        "C_T": 0.0,
+        "C_V": 0.0,
+        "C_WP": 0.0,
+        "C_PF": 0.0,
+        "N_A": 0.0,//零线电流
+        "N_T": 0.0//零线线温
+      },
+      "2": {
+        "version": "0.72",
+        "title": "线路1",
+        "model": "JZK2L100-BL6523",
+        "Alarm": 0,
+        "EnableNetCtrl": true,
+        "MXDW": 0.0,
+        "MXGG": 7040.0,
+        "MXGL": 48.00,
+        "MXGW": 90.0,
+        "MXGY": 260.0,
+        "MXLD": 100.0,
+        "MXQY": 100.0,
+        "OpenClose": true,
+        "addr": 2,
+        "power": 4.7,
+        "specification": "32",
+        "control": 1,
+        "visibility": 1,
+        "totalChannelId": 1,
+        "lineType": "220",
+        "A_A": 0.00,
+        "A_T": 26.4,
+        "A_V": 234.0,
+        "A_WP": 0.0,
+        "A_LD": 0.0,
+        "A_PF": 0.0,
+        "G_A": 0.0,
+        "G_T": 0.0,
+        "G_V": 0.0,
+        "G_WP": 0.0,
+        "G_LD": 0.0,
+        "G_PF": 0.0,
+        "B_A": 0.0,
+        "B_T": 0.0,
+        "B_V": 0.0,
+        "B_WP": 0.0,
+        "B_PF": 0.0,
+        "C_A": 0.0,
+        "C_T": 0.0,
+        "C_V": 0.0,
+        "C_WP": 0.0,
+        "C_PF": 0.0,
+        "N_A": 0.0,
+        "N_T": 0.0
+      },
+      "3": {
+        "version": "0.72",
+        "title": "线路2",
+        "model": "JZK2L100-BL6523",
+        "Alarm": 0,
+        "EnableNetCtrl": true,
+        "MXDW": 0.0,
+        "MXGG": 7040.0,
+        "MXGL": 48.00,
+        "MXGW": 90.0,
+        "MXGY": 260.0,
+        "MXLD": 30.0,
+        "MXQY": 100.0,
+        "OpenClose": true,
+        "addr": 3,
+        "power": 40.6,
+        "specification": "32",
+        "control": 1,
+        "visibility": 1,
+        "totalChannelId": 1,
+        "lineType": "220",
+        "A_A": 0.11,
+        "A_T": 28.2,
+        "A_V": 235.0,
+        "A_WP": 22.0,
+        "A_LD": 0.0,
+        "A_PF": 0.0,
+        "G_A": 0.0,
+        "G_T": 0.0,
+        "G_V": 0.0,
+        "G_WP": 0.0,
+        "G_LD": 0.0,
+        "G_PF": 0.0,
+        "B_A": 0.0,
+        "B_T": 0.0,
+        "B_V": 0.0,
+        "B_WP": 0.0,
+        "B_PF": 0.0,
+        "C_A": 0.0,
+        "C_T": 0.0,
+        "C_V": 0.0,
+        "C_WP": 0.0,
+        "C_PF": 0.0,
+        "N_A": 0.0,
+        "N_T": 0.0
+      }
+    },
+    "Change": null
+  }
+}
+```
+
+总之，`Redis`中的实时数据理解为模块最近一次上传的实时数据；如果需要最实时的数据，直接调用接口获取。
+
+
+
+- 最近60分钟的数据进入`MySQL`数据库
+
+`Redis`只能记录最近的一条记录，但是，在一些场景下需要最近比如60分钟的数据。举例来说，在负荷报表中希望看到最近60分钟的负荷情况。这时，需要把最近60分钟的数据保存到`MySQL`数据库。
+
+- 每一次的上传数据进入时序数据库
+
+
+
+> 实时数据的上传频率问题
+
+默认情况下模块每10分钟上传一次数据。如果想让模块以最快的频率上传数据，需要给模块发一条指令(有时需要同时发2条指令，第一条指令让模块保持登录态，另一条指令设置实时数据的上传频率)。而这条执行的生效时长是5分钟。
+
+
+
+# 电量数据
+
+
+
+> 原理
+
+模块每小时、每天、每月的开头会向服务器发送电量数据。服务器会把电量数据保存到时序数据库。
+
+在`UDP`协议中可以查询获取过去一个月的电量历史数据。在`HTTP`中主动查模块的电量数据暂时不确定。
+
+> 目前存在的问题
+
+电量数据会重复传或者漏传。
+
+
+
+#  实时调度平台
+
+
+
+目前采用`大石头`的`AntJob`组件。
+
+- 应用程序
+- 作业
+
+# 报警机制
+
+
+
+> 报警策略
+
+```
+报警策略名称：总部默认报警策略
+
+过压报警： 是否启用，阈值=230V
+过压预警：是否启用
+		蓝色预警：阈值=222V
+		黄色预警：阈值=225V   
+		橙色预警：阈值=228V  
+手动分断报警：是否启用
+离线报警：是否启用，阈值=10分钟
+```
+
+
+
+> 报警如何产生的？
+
+- 达到模块内部的报警条件触发报警，模块向服务器发送报警
+- 达到某种报警策略的报警触发条件进而报警，也就是在应用程序层面判断并记录
+
+
+
+> 报警和项目如何关联？
+
+在总部运营后台，关联报警策略和项目。而且，一个项目可以有多个报警策略。
+
+
+
+> 报警存入哪里？
+
+报警分为实时报警和历史报警。实时报警就是当下所有开关的报警；历史报警是发生在过去，报警已经解除的哪些报警。比如，开关A，在`8：10`程序判断出现手动分断报警，那么在实时报警中添加一条记录。接着，在`9:10`程序判断开关A已经正常，就在历史报警中添加一条记录，这条记录的报警开始时间是`8:10`,结束时间是`9:10`，并且在实时报警中更新该条记录，更新为开关A属于正常状态。
+
+
+
+实时报警存入关系数据库，历史报警存入时序数据库。实时报警中可以只记录当下正在发生的报警。
+
+
+
+> 报警如何处理？
+
+- 有些项目不处理，不关心，比如商场只关心到点开或关
+- 有些项目非常关心，比如涉及到电量统计，一旦开关或模块不正常，会影响到电量的统计，或者有关安全的，这时候需要把实时报警上报。
+
+
+
+也就是，有些报警需要推送到负责人(可能是客服，也可能是电工，也可能是某个项目经理)，然后进行处理。
+
+
+
+不是所有的报警类型都需要推送到人。
+
+
+
+> 报警推送频率
+
+比如有一个开关一直报警，那是在报警发生的当下推送呢？还是说每隔一段时间推送一次呢？还是说晚上的时间不推送呢？还是说让客户自己设置推送的频率和时间段呢？
+
+
+
+> 报警如何解除
+
+
+
+有一个后台运行计算，如果没有达到报警触发的条件，就意味着解除。
+
+
+
+> 应用程序判断报警的背景计算放在项目，还是放在开放平台？
+
+
+
+判断报警的服务理解成一个作业，可以嵌入到任何的应用程序中。
+
+
+
+# 数据模拟器
+
+
+
+- 确定模拟哪些数据：实时数据、电量数据、报警数据、开关、模块
+- 模拟程序
+- 有些模拟到关系数据库，有些模拟到时序数据库