OTS/OTSIncAMeasureApp/0-OTSModel/Measure/DBDataTransition/PosXrayDBMgr.cs

using OTSDataType;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Threading.Tasks;
using OTSModelSharp.DTLBase;
using OTSModelSharp.ServiceInterface;
using OTSCLRINTERFACE;
using System.Data.SQLite;

namespace OTSModelSharp
{
    public class CPosXrayDBMgr 
    {
        protected static NLog.Logger logger = null;

        bool m_bHasElement;

        //List<CPosXrayClr> m_listPosXray;
        //database
        CXRayDataDB m_pXrayDataDB;
        CElementChemistryDB m_pElementChemistryDB;
        CPosXrayInfoDB m_pXrayInfoDB;

 
        const long GENERALXRAYCHANNELS = 2000;


     
        private CSQLiteDBStore m_dbStore;

       
        public CPosXrayDBMgr(CSQLiteDBStore a_dbStore)
        {
     
            m_dbStore = a_dbStore;
            //m_listPosXray = new List<CPosXrayClr>();
            logger = NLog.LogManager.GetCurrentClassLogger();
        }
        public void InitDataTable()
        {
            m_pXrayDataDB = new CXRayDataDB(m_dbStore, new CXRayDataTable());
            m_pXrayDataDB.Init();
            m_pElementChemistryDB = new CElementChemistryDB(m_dbStore, new CElementChemistryTable());
            m_pElementChemistryDB.Init();
            m_pXrayInfoDB = new CPosXrayInfoDB(m_dbStore, new CPosXrayInfoTable());
            m_pXrayInfoDB.Init();
        
        
        }

    


        public void SetHasElement(bool a_bHasElement) { m_bHasElement = a_bHasElement; }


        public CElementChemistryDB GetElementChemistryDB()
        {
            if (m_pElementChemistryDB == null)
            {


                m_pElementChemistryDB = new CElementChemistryDB(m_dbStore, new CElementChemistryTable());
            }
            return m_pElementChemistryDB;
        }

        //protected

        
        public bool SaveXray(List<CPosXrayClr> a_listPosXray,bool m_bHasElement)
        {
            if (a_listPosXray != null)          
            {
              
                CElementChemistryDB XElementChemistryDB = GetElementChemistryDB();


                m_dbStore.CloseSynchronous();
                m_dbStore.BeginTransaction();
            
                SaveXrayInfoList(a_listPosXray);

                foreach (CPosXrayClr pPosXray in a_listPosXray)
                {
                    if (!SavePosXrayPtr(pPosXray))
                    {
                        logger.Error("Failed to save x-ray data.");
                
                        return false;
                    }
                    //save element
                    if (m_bHasElement)
                    {
                        if (!XElementChemistryDB.SaveElementChemistriesList(pPosXray))
                        {
                            logger.Error("Failed to save element chemistry list data.");
                            return false;
                        }

                    }
                }
                
                m_dbStore.CommitTransaction();
            }
            return true;
        }
        public List<KeyValuePair<string, SQLiteParameter[]>> GetSavingXrayCmds(List<CPosXrayClr> a_listPosXray, bool m_bHasElement)
        {
            List<KeyValuePair<string, SQLiteParameter[]>> cmds = new List<KeyValuePair<string, SQLiteParameter[]>>();
            if (a_listPosXray != null)
            {

                CElementChemistryDB XElementChemistryDB = GetElementChemistryDB();

               var xrayInfoDB = GetXrayInfoDB();

                var xrayinfocmds  =xrayInfoDB.GetSavingXrayInfoCmds (a_listPosXray);
                foreach (var s in xrayinfocmds)
                {
                    var cmd = new KeyValuePair<string, SQLiteParameter[]>(s, null);
                    cmds.Add(cmd);
                
                }
                foreach (CPosXrayClr pPosXray in a_listPosXray)
                {
                 
                   var cmd= GetSavingPosXrayDataCmds(pPosXray);
                    cmds.Add(cmd);
                   
                    if (m_bHasElement)
                    {
                      
                        var cmdlist = XElementChemistryDB.GetSavingElementChemistriesCmds(pPosXray);
                        foreach (var s in cmdlist)
                        {
                            var cmd1 = new KeyValuePair<string, SQLiteParameter[]>(s, null);
                            cmds.Add(cmd1);
                        }

                    }
                }

               
            }
            return cmds;
        }

        public bool SavePosXrayPtr(CPosXrayClr a_pXray)
        {

            var tableInfoPtr =m_pXrayDataDB. GetTableInfo();

            var datastorePtr = m_pXrayDataDB.GetDatastore();


            String sInsertFormat = tableInfoPtr.GetInsertCommandFormatString(true);
           
            UInt32[] xrayData = a_pXray.GetXrayData();
            String sSQLCommand = string.Format(sInsertFormat,
            a_pXray.GetIndex(),
            a_pXray.GetScanFieldId()
                    );
            byte[] bytedata = new byte[GENERALXRAYCHANNELS * 4];
            
            for (int j = 0; j < GENERALXRAYCHANNELS; j++)
            {

                uint m = xrayData[j];
                byte[] dwordData = BitConverter.GetBytes(m);
                bytedata[j * 4] = dwordData[0];
                bytedata[j * 4 + 1] = dwordData[1];
                bytedata[j * 4 + 2] = dwordData[2];
                bytedata[j * 4 + 3] = dwordData[3];

            }



            if (!datastorePtr.InsertBlobData(sSQLCommand, bytedata, Convert.ToInt32(otsdataconst.GENERALXRAYCHANNELS) * 4))
            {

          


                return false;
            }
            return true;
        }

        private KeyValuePair<string,SQLiteParameter[]> GetSavingPosXrayDataCmds(CPosXrayClr a_pXray)
        {
            KeyValuePair<string, SQLiteParameter[]> cmd;
            List<SQLiteParameter> ps = new List<SQLiteParameter>();
            var tableInfoPtr = m_pXrayDataDB.GetTableInfo();

            var datastorePtr = m_pXrayDataDB.GetDatastore();


            String sInsertFormat = tableInfoPtr.GetInsertCommandFormatString(true);

            UInt32[] xrayData = a_pXray.GetXrayData();
            String sSQLCommand = string.Format(sInsertFormat,
            a_pXray.GetIndex(),
            a_pXray.GetScanFieldId()
                    );
            byte[] bytedata = new byte[GENERALXRAYCHANNELS * 4];

            for (int j = 0; j < GENERALXRAYCHANNELS; j++)
            {

                uint m = xrayData[j];
                byte[] dwordData = BitConverter.GetBytes(m);
                bytedata[j * 4] = dwordData[0];
                bytedata[j * 4 + 1] = dwordData[1];
                bytedata[j * 4 + 2] = dwordData[2];
                bytedata[j * 4 + 3] = dwordData[3];

            }
            ps.Add(new SQLiteParameter(@"blob", bytedata));
           

            cmd = new KeyValuePair<string, SQLiteParameter[]>(sSQLCommand, ps.ToArray());
           
            return cmd;
        }





        protected bool SaveXrayInfoList(List<CPosXrayClr>  a_listPosXray)
        {
            var XrayInfoDB = GetXrayInfoDB();
        

            if (!XrayInfoDB.SaveXrayInfoList(a_listPosXray))
            {
                logger.Error("Failed to save xray info list.");
              
                return false;
            }
            return true;
        }
     
        protected bool GetXrayInfoList(ref List<CPosXrayClr> a_listXra, int fldId)
        {
            var XrayInfoDB = GetXrayInfoDB();
            if (XrayInfoDB==null)
            {
                logger.Error("Failed to open result setting table");
           
                return false;
            }
            a_listXra = XrayInfoDB.GetXrayInfoListByFieldId(fldId);
            return true;
        }
        
        //Get DB
        public CXRayDataDB GetXrayDataDB()
        {
            if (m_pXrayDataDB==null)
            {
         
                m_pXrayDataDB = new CXRayDataDB(m_dbStore, new CXRayDataTable());
              
            }
            return m_pXrayDataDB;
        }

        public CPosXrayInfoDB GetXrayInfoDB()
        {
            if (m_pXrayInfoDB==null)
            {

                m_pXrayInfoDB = new CPosXrayInfoDB(m_dbStore,new CPosXrayInfoTable());
            }
            return m_pXrayInfoDB;
        }
        // cleanup 
        protected void Cleanup()
        {
            // need to do nothing at the moment
            //m_listPosXray.Clear();
        }

   
        // duplication
        protected void Duplicate( CPosXrayDBMgr a_oSource)
        {
            // initialization
            //m_listPosXray.Clear();


            // copy data over
            //foreach(CPosXrayClr pPosXray in a_oSource.m_listPosXray)
            ////for (auto pPosXray : a_oSource.m_listPosXray)
            //{
            //    CPosXrayClr pPosXrayNew = new CPosXrayClr(pPosXray);
            //    m_listPosXray.Add(pPosXrayNew);
            //}
        }
    }

    
}