DataV/服务API/Controllers/LogController.cs

using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using 服务API.Model;
using 服务API.ServerDB.MongoDB;
using 服务API.Tool.IOT;

namespace 服务API.Controllers
{
    /// <summary>
    /// MG数据库:日志表 LogTable
    /// </summary>
    public class LogController :BaseController
    {

        MongoDbHelper<LogTable> mg = new MongoDbHelper<LogTable>(DataBus.DataBus.connStr,DataBus.DataBus.dbName);
        MongoDbHelper<DeviceTable> mgsb = new MongoDbHelper<DeviceTable>(DataBus.DataBus.connStr,DataBus.DataBus.dbName);

        string st = System.Reflection.MethodBase.GetCurrentMethod().Name;

        /// <summary>
        /// 新增一条数据
        /// </summary>
        [HttpPost]
        public JsonMsg<LogTable> Create(LogTable auth)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                if (string.IsNullOrEmpty(auth.ClientId))
                {
                    return JsonMsg<LogTable>.Error(null,st,"设备ID不能为空"); ;
                }
                mg.Insert(auth);
                return JsonMsg<LogTable>.OK(auth,st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<LogTable>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 批量新增一条数据
        /// </summary>
        /// <param name="auth">日志消息</param>
        [HttpPost]
        public JsonMsg<List<LogTable>> Creates(List<LogTable> auth)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                mg.Inserts(auth);
                return JsonMsg<List<LogTable>>.OK(auth,st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<List<LogTable>>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 修改数据
        /// </summary>
        /// <param name="auth"></param>
        /// <returns></returns>
        [HttpPost]
        public JsonMsg<LogTable> Modify(LogTable auth)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                mg.Update(auth);
                return JsonMsg<LogTable>.OK(auth,st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<LogTable>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 根据唯一ID查询数据
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet]
        public JsonMsg<LogTable> QueryOne(string id)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                return JsonMsg<LogTable>.OK(mg.QueryOne(id),st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<LogTable>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 根据客户端ID查询当日未处理信息
        /// </summary>
        /// <param name="clientId"></param>
        /// <returns></returns>
        [HttpGet]
        public JsonMsg<List<LogTable>> QueryClientId(string clientId)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                return JsonMsg<List<LogTable>>.OK(mg.QueryClientId(clientId),st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<List<LogTable>>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 根据设备名称查询当日未处理信息
        /// </summary>
        /// <param name="DeviceName"></param>
        /// <returns></returns>
        [HttpGet]
        public JsonMsg<List<LogTable>> QueryDeviceName(string DeviceName,string StartTime,string StopTime)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                DeviceTable device = mgsb.QueryDeviceName(DeviceName);
                if (device != null)
                {
                    if (!string.IsNullOrEmpty(StartTime) && !string.IsNullOrEmpty(StopTime))
                    {
                        DateTime starttime, stoptime;
                        starttime = Tools.ConvertLongToDateTime(long.Parse(StartTime));
                        stoptime = Tools.ConvertLongToDateTime(long.Parse(StopTime));
                        return JsonMsg<List<LogTable>>.OK(mg.QueryAllTime(device.ClientId,starttime,stoptime),st);
                    }
                    else return JsonMsg<List<LogTable>>.OK(mg.QueryClientId(device.ClientId),st);
                }
                return JsonMsg<List<LogTable>>.OK(null,st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<List<LogTable>>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 根据客户端ID 时间查询设备日志信息
        /// </summary>
        /// <param name="clientId"></param>
        /// <param name="datesta"></param>
        /// <param name="datastop"></param>
        /// <returns></returns>
        [HttpGet]
        public JsonMsg<List<LogTable>> Query(string clientId,DateTime datesta,DateTime datastop)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                return JsonMsg<List<LogTable>>.OK(mg.QueryAllTime(clientId,datesta,datastop),st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<List<LogTable>>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 分页查询 
        /// </summary>
        /// <param name="chid"></param>
        /// <param name="datesta"></param>
        /// <param name="datastop"></param>
        /// <param name="PageNumber"></param>
        /// <param name="PageSize"></param>
        /// <returns></returns>
        [HttpGet]
        public JsonMsg<PaginationListModel<LogTable>> BasePagQuery(string clientId,DateTime datesta,DateTime datastop,int PageNumber = 1,int PageSize = 100)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                return JsonMsg<PaginationListModel<LogTable>>.OK(mg.BasePagQuery(clientId,datesta,datastop,PageNumber,PageSize),st);
            }
            catch (System.Exception ex)
            {
                return JsonMsg<PaginationListModel<LogTable>>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 删除数据(假删除-只做标记)
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet]
        public JsonMsg<string> Delete(string id)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                if (string.IsNullOrEmpty(id))
                {
                    return JsonMsg<string>.Error(null,st,"设备ID不能为空"); ;
                }
                else
                {
                    mg.Modify(id,"State","n");
                    return JsonMsg<string>.OK("success!",st);
                }
            }
            catch (System.Exception ex)
            {
                return JsonMsg<string>.Error(null,st,ex.Message);
            }
        }
        /// <summary>
        /// 删除数据
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet]
        public JsonMsg<string> DeleteDate(string id)
        {
            st = System.Reflection.MethodBase.GetCurrentMethod().Name;
            try
            {
                if (string.IsNullOrEmpty(id))
                {
                    return JsonMsg<string>.Error(null,st,"设备ID不能为空"); ;
                }
                else
                {
                    mg.Delete(id);
                    return JsonMsg<string>.OK("success!",st);
                }
            }
            catch (System.Exception ex)
            {
                return JsonMsg<string>.Error(null,st,ex.Message);
            }
        }
    }
}