Bplus/ApiWeb/ApiProcessToken/Process/ProcessUpdateDb.cs


using CommonObj.common;
using CommonObj.model;
using Newtonsoft.Json;
using ResfullApi.Models;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Text;

namespace ApiProcess.Process
{
    public class ProcessUpdateDb : MainThread
    {
        static readonly log4net.ILog logger = log4net.LogManager.GetLogger(typeof(ProcessUpdateDb));
        public override void Process()
        {

            Sleep(500);
            try
            {
                if (Variable.chargerObj.IsEmpty()) return;
                logger.Info("Start save charge to DB ");
                ArrayList arrCharge = new ArrayList();
                long total_row_up_toDB = 50;
                if (Variable.chargerObj.Size() < total_row_up_toDB)
                {
                    arrCharge = Variable.chargerObj.ToArrayListAndClear();
                }
                else
                {
                    for (int i = 0; i < total_row_up_toDB; i++)
                    {
                        arrCharge.Add(Variable.chargerObj.Dequeue());
                    }
                }

                List<List<string>> DataColumms = new List<List<string>>();
                var username = new List<string>();
                var password = new List<string>();
                var serviceid = new List<string>();
                var msisdn = new List<string>();
                var chargetime = new List<string>();
                var paramss = new List<string>();
                var mode = new List<string>();
                var amount = new List<string>();
                var prefix = new List<string>();
                var cmd = new List<string>();
                var transaction = new List<string>();


                string chargeLogPath= Common.GetValuesAppSetting("webConfig", "chargeLogPath");
                
                
                foreach (chargeObj obj in arrCharge)
                {
                    string _username = obj.username;
                    string _password = obj.password;
                    string _serviceid = obj.serviceid;
                    string _msisdn = obj.msisdn;
                    string _chargetime = obj.chargetime;
                    string _paramss = obj.paramss;
                    string _mode = obj.mode;
                    string _amount = obj.amount;
                    string _prefix = obj.prefix;
                    string _cmd = obj.cmd;
                    string _transaction = obj.transaction;
                    //ghi lai file text
                    Guid g = Guid.NewGuid();
                    string fileName = DateTime.Now.ToString("ddMMyyyy") + "_" + g.ToString() + ".txt";
                    string filePath = chargeLogPath  + fileName;


                    string line = _username + "\t" + _password + "\t" + _serviceid + "\t" + _msisdn
                        + "\t" + _chargetime + "\t" + _paramss + "\t" + _mode
                        + "\t" + _amount + "\t" + _prefix + "\t" + _cmd
                        + "\t" + _transaction;
                    Variable.WriteLineAppendTextFile(filePath, line);

                    /*
                    username.Add(_username);
                    password.Add(_password);
                    serviceid.Add(_serviceid);
                    msisdn.Add(_msisdn);
                    chargetime.Add(_chargetime);
                    paramss.Add(_paramss);
                    mode.Add(_mode);
                    amount.Add(_amount);
                    prefix.Add(_prefix);
                    cmd.Add(_cmd);
                    transaction.Add(_transaction);
                    */



                }
                /*
                DataColumms.Add(username);
                DataColumms.Add(password);
                DataColumms.Add(serviceid);
                DataColumms.Add(msisdn);
                DataColumms.Add(chargetime);
                DataColumms.Add(paramss);
                DataColumms.Add(mode);
                DataColumms.Add(amount);
                DataColumms.Add(prefix);
                DataColumms.Add(cmd);
                DataColumms.Add(transaction);
                DataAccess.updateCharge("MPS_PKG.PROCESS_SMS_CHARGE_BULK", DataColumms);
                */

            }
            catch (Exception ex)
            {

                logger.Info("Reload param exception: " + ex.ToString());
            }




        }


        

    }
}