using System;
using System.Collections.Generic;
using Dapper;
using MySql.Data.MySqlClient;
using log4net;
using CncModels.Entity;

namespace CncCollector.Core
{
    /// <summary>
    /// 采集数据批量写入：cnc_collect_record 与 log_collect_raw，以及更新 CNC 机床状态。
    /// </summary>
    public static class CollectRecordWriter
    {
        private static readonly ILog Log = LogManager.GetLogger(typeof(CollectRecordWriter));

        /// <summary>
        /// 将批量结构化记录写入 cnc_collect_record，并记录原始 JSON 到 log_collect_raw，同时更新机床实时状态。
        /// </summary>
        /// <param name="connectionString">数据库连接字符串</param>
        /// <param name="records">结构化记录集合</param>
        /// <param name="rawJson">原始 JSON 日志</param>
        /// <param name="collectAddressId">采集地址标识</param>
        public static void WriteBatch(string connectionString, IEnumerable<CollectRecord> records, string rawJson, int collectAddressId)
        {
            if (records == null) return;
            using (var conn = new MySqlConnection(connectionString))
            {
                conn.Open();
                using (var tran = conn.BeginTransaction())
                {
                    try
                    {
                        // 插入原始日志
                        const string sqlLog = @"INSERT INTO log_collect_raw
                            (collect_address_id, request_time, response_time, response_duration, is_success, status_code, raw_json, error_message, created_at)
                          VALUES
                            (@CollectAddressId, @RequestTime, @ResponseTime, @ResponseDuration, @IsSuccess, @StatusCode, @RawJson, @ErrorMessage, NOW())";
                        conn.Execute(sqlLog, new
                        {
                            CollectAddressId = collectAddressId,
                            RequestTime = DateTime.Now,
                            ResponseTime = DateTime.Now,
                            ResponseDuration = 0,
                            IsSuccess = 1,
                            StatusCode = 200,
                            RawJson = rawJson,
                            ErrorMessage = (string)null
                        }, tran);

                        // 插入结构化记录（逐条，保持简单且具备可编译性）
                        const string sqlRec = @"INSERT INTO cnc_collect_record
                            (machine_id, collect_time, device_time, program_name, part_count, device_status, run_status, operate_mode, spindle_speed_set, feed_speed_set, spindle_speed_actual, feed_speed_actual, spindle_load, spindle_override, power_on_time, run_time, cutting_time, cycle_time, machining_status, extra_data, created_at)
                          VALUES
                            (@MachineId, @CollectTime, @DeviceTime, @ProgramName, @PartCount, @DeviceStatus, @RunStatus, @OperateMode, @SpindleSpeedSet, @FeedSpeedSet, @SpindleSpeedActual, @FeedSpeedActual, @SpindleLoad, @SpindleOverride, @PowerOnTime, @RunTime, @CuttingTime, @CycleTime, @MachiningStatus, @ExtraData, NOW())";
                        foreach (var r in records)
                        {
                            r.CreatedAt = DateTime.Now;
                            conn.Execute(sqlRec, r, tran);
                        }

                        // 简单的机床状态更新（按单条记录的最后一条）
                        foreach (var r in records)
                        {
                            const string sqlMach = @"UPDATE cnc_machine
                                SET last_collect_time = @CollectTime, last_device_status = @DeviceStatus, last_run_status = @RunStatus, last_program_name = @ProgramName, last_part_count = @PartCount, last_operate_mode = @OperateMode, last_machining_status = @MachiningStatus
                                WHERE machine_id = @MachineId";
                            conn.Execute(sqlMach, new
                            {
                                MachineId = r.MachineId,
                                CollectTime = r.CollectTime,
                                DeviceStatus = r.DeviceStatus,
                                RunStatus = r.RunStatus,
                                ProgramName = r.ProgramName,
                                PartCount = r.PartCount,
                                OperateMode = r.OperateMode,
                                MachiningStatus = r.MachiningStatus
                            }, tran);
                        }
                        tran.Commit();
                    }
                    catch (Exception ex)
                    {
                        tran.Rollback();
                        Log.Error("批量写入采集记录失败", ex);
                        throw;
                    }
                }
            }
        }
    }
}