wcs/WCS.BLL/Services/Service/SingleLightService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using TouchSocket.Core;
using WCS.BLL.Manager;
using WCS.BLL.Services.IService;
using WCS.BLL.Tool;
using WCS.DAL;
using WCS.DAL.Db;
using WCS.DAL.Db.AuthDb;
using WCS.DAL.DbModels;
using WCS.Model;
using WCS.Model.ApiModel;
using WCS.Model.ApiModel.SingleLight;
using WCS.Model.ApiModel.User;
using WCS.Model.WebSocketModel;
using static System.Formats.Asn1.AsnWriter;
using static WCS.BLL.Tool.Helper;

namespace WCS.BLL.Services.Service
{
    public class SingleLightService : ISingleLightService
    {
        /// <summary>
        /// 单灯 一个库位对应一个硬件
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public async Task<ResponseCommon<object>> SingleLightControl(SingleLightControlRequest request)
        {
            try
            {
                //传入数据校验
                if (request.StoreCodes == null || request.StoreCodes.Count == 0)
                {
                    return new ResponseCommon<object>()
                    {
                        Code = 201,
                        Message = "操作失败：没有需要控制的库位",
                    };
                }


                //库位编码去重
                var storeCodes = request.StoreCodes.Distinct()
                                                  .ToList();
                //For联调
                if (storeCodes.Contains("A01-R1C1"))
                {
                    //返回成功
                    return new ResponseCommon<object>()
                    {
                        Code = 200,
                        Message = "success",
                    };
                }


                var stores = DbHelp.db.Queryable<StoreInfo>()
                                      .Where(t => storeCodes.Contains(t.StoreCode))
                                      .ToList();
                if (stores == null || stores.Count == 0)
                {
                    return new ResponseCommon<object>
                    {
                        Code = 201,
                        Message = $"操作失败：所有库位不存在！"
                    };
                }

                //对应货架（获取TCP和报警灯ID）
                var shelfIds = stores.Select(t => t.ShelfId).Distinct().ToList();
                var shelfs = DbHelp.db.Queryable<ShelfInfo>().Where(t => shelfIds.Contains(t.Id))
                                                             .ToList();

                //对应模组信息
                var moduleIds = stores.Select(t => t.ModuleId).Distinct().ToList();
                var modules = DbHelp.db.Queryable<ModuleInfo>().Where(t => moduleIds.Contains(t.Id))
                                                               .ToList();

                //加载请求参数中的库位灯 板子ID和货架ID
                //foreach (var store in request.StoreList)
                //{
                //    var storeInDb = stores.Where(t => t.StoreCode == store.StoreCode).FirstOrDefault();
                //    if (storeInDb == null)
                //    {
                //        return new ResponseCommon<object>
                //        {
                //            Code = 201,
                //            Message = $"操作失败：库位{store.StoreCode}不存在(store)！"
                //        };
                //    }
                //    else
                //        store.ShelfId = storeInDb.ShelfId;

                //    var moduleInDb = modules.Where(t => t.Id == storeInDb.ModuleId).FirstOrDefault();
                //    if (moduleInDb == null)
                //    {
                //        return new ResponseCommon<object>
                //        {
                //            Code = 201,
                //            Message = $"操作失败：库位{store.StoreCode}不存在(module)！"
                //        };
                //    }
                //    else
                //        store.BoardId = moduleInDb.BoardId;
                //}

                //合并：同一个货架的库位合并
                var shelfModels = new List<SingleLightShelfModel>();
                foreach (var shelf in shelfs)
                {
                    var shelfModel = new SingleLightShelfModel();
                    //报警灯
                    shelfModel.WarningLightMode = request.LightMode;
                    //shelfModel.WarningBuzzerMode = request.WarningBuzzerMode;
                    shelfModel.WarningLightColor = request.ColorMode;
                    shelfModel.WarningBoardId = shelf.LightId;
                    shelfModel.ClientIp = shelf.ClientIp;
                    //库位
                    //var storesThisShelf = request;
                    //foreach (var storeThisShelf in storesThisShelf)
                    //{
                    //    shelfModel.StoreList.Add(new SingleLightStoreModel()
                    //    {
                    //        BoardId = storeThisShelf.BoardId,
                    //        LightColor = storeThisShelf.LightColor,
                    //        LightMode = storeThisShelf.LightMode,
                    //    });
                    //}
                    //shelfModels.Add(shelfModel);
                }

                //合并：同一个TCP的货架合并 报警灯和库位灯统一只发送一条指令
                var clientIpList = shelfs.Select(t => t.ClientIp)
                                         .Distinct()
                                         .ToList();
                foreach (var clientIp in clientIpList)
                {
                    var shelfModelsInOneIp = shelfModels.Where(t => t.ClientIp == clientIp).ToList();
                    var sendData = Helper.SingleLightControl(shelfModelsInOneIp);

                    TCPClient tCPClient = TCPClientManager.GetTCPClientByIPHost(clientIp);
                    tCPClient.Send(sendData);
                    Logs.Write("【单灯单独控制】发送指令" + BitConverter.ToString(sendData));
                }

                //返回成功
                return new ResponseCommon<object>()
                {
                    Code = 200,
                    Message = "success",
                };
            }
            catch (Exception ex)
            {

                //操作失败
                return new ResponseCommon<object>()
                {
                    Code = 300,
                    Message = $"操作失败：{ex.Message}",
                };
            }
        }

        public async Task<ResponseCommon<object>> TurnoffLightByArea(TurnoffLightByAreaRequest request)
        {
            try
            {
                //传入数据校验
                if (string.IsNullOrEmpty(request.Area))
                {
                    return new ResponseCommon<object>()
                    {
                        Code = 201,
                        Message = "操作失败：参数传入错误！Area为空！",
                    };
                }
                //库位
                var stores = DbHelp.db.Queryable<StoreInfo>()
                                      .Where(t => t.Area == request.Area)
                                      .ToList();
                if (stores == null || stores.Count == 0)
                {
                    return new ResponseCommon<object>
                    {
                        Code = 201,
                        Message = $"操作失败：所选区域不存在库位！"
                    };
                }

                //对应货架（获取TCP和报警灯ID）
                var shelfIds = stores.Select(t => t.ShelfId).Distinct().ToList();
                var shelfs = DbHelp.db.Queryable<ShelfInfo>().Where(t => shelfIds.Contains(t.Id))
                                                             .ToList();
                //获取对应货架所有IP
                var clientIPs = shelfs.Select(t => t.ClientIp)
                                    .Distinct()
                                    .ToList();

                //挨个发关灯指令
                foreach (var clientIP in clientIPs) 
                { 
                
                }

                //返回成功
                return new ResponseCommon<object>()
                {
                    Code = 200,
                    Message = "success",
                };
            }
            catch (Exception ex)
            {

                //操作失败
                return new ResponseCommon<object>()
                {
                    Code = 300,
                    Message = $"操作失败：{ex.Message}",
                };
            }
        }
    }
}