MedicalInsurance/NanChang/NanChangMI/Forms/ProgressBar.cs

using Newtonsoft.Json.Linq;
using PTMedicalInsurance.Business;
using PTMedicalInsurance.Helper;
using PTMedicalInsurance.Variables;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace NanChangMI.Forms
{
    public partial class ProgressBar : Form
    {
        private InvokeHelper invoker = new InvokeHelper();
        private MIIrisServices mIS = new MIIrisServices();
        private ManualResetEvent manualReset = new ManualResetEvent(true);
        private string funNO;
        private int singleCount;
        private JArray jaFeeDetail;
        public string outParam;

        public struct userState
        {
            public int childProgress;
            public string description;
            public string error;
            public string detailHisCode;
            public string detailHisName;
            public string detailInsuCode;
        }

        private userState getUserState(int progress,string desc,string err, JToken jt)
        {
            userState us = new userState();
            us.childProgress = progress;
            us.description = desc;
            us.error = err;
            JObject jo = (JObject)jt;
            us.detailHisCode = jo["medins_list_codg"].ToString();
            //us.detailHisName = jo["medins_list_desc"].ToString();
            us.detailInsuCode = jo["med_list_codg"].ToString();
            return us;
        }
        public ProgressBar(string funNO, int singleCount, JArray jaFeeDetail)
        {
            InitializeComponent();
            this.funNO = funNO;
            this.singleCount = singleCount;
            this.jaFeeDetail = jaFeeDetail;
            this.pbFee.Maximum = jaFeeDetail.Count;
            

        }

        private void btExit_Click(object sender, EventArgs e)
        {
            this.DialogResult = DialogResult.Cancel;
            Close();
        }

        public void setPos(int pos)
        {
            pbFee.Value = pos;
        }
        public void writeError(string error)
        {
            rtbRecord.AppendText(error + System.Environment.NewLine);
        }

        private void ProgressBar_Load(object sender, EventArgs e)
        {
            bgWorker1.WorkerReportsProgress = true;
            bgWorker1.WorkerSupportsCancellation = true;
            bgWorker1.RunWorkerAsync();
        }

        private void bgWorker1_DoWork(object sender, DoWorkEventArgs e)
        {
            BackgroundWorker bgWorker = sender as BackgroundWorker;
            string errMsg;
            int feeCount = jaFeeDetail.Count;
            int errorCount = 0;
            try
            {
                JArray jaTmp = new JArray();
                userState us = new userState();
                Thread.Sleep(1000);
                for (int i = 0; i < feeCount; i++)
                {
                    manualReset.WaitOne();

                    if (bgWorker.CancellationPending)
                    {
                        e.Cancel = true;
                        break;
                    }

                    jaFeeDetail[i]["chrg_bchno"] = Global.pat.adm_Dr.ToString();
                    jaFeeDetail[i]["med_type"] = Global.pat.medType;
                    if (jaFeeDetail[i]["validFlag"].ToString() == "N")
                    {
                        bgWorker.ReportProgress(i, null);
                        continue;
                    }
                    jaTmp.Add(jaFeeDetail[i]);
                    if (((i + 1) % singleCount == 0) || ((i + 1) == jaFeeDetail.Count))
                    {

                        JObject joFeeDetail = new JObject();
                        joFeeDetail.Add("feedetail", jaTmp);
                        JObject joRtn = invoker.invokeCenterService(funNO, JsonHelper.setCenterInpar(funNO, joFeeDetail.ToString()));
                        if (JsonHelper.parseCenterRtnValue(joRtn, out errMsg) != 0)
                        {
                            outParam = outParam + errMsg + System.Environment.NewLine;
                            us = getUserState(1, "解析中心返回值", "失败。原因：" + errMsg, jaFeeDetail[i]);
                            bgWorker.ReportProgress(i, us);
                            errorCount++;
                        }
                        else
                        {
                            us = getUserState(1, "解析中心返回值", "成功", jaFeeDetail[i]);
                            bgWorker.ReportProgress(i, us);
                            //成功后插入医保平台
                            if (mIS.insertFee(jaTmp, out errMsg) != 0)
                            {
                                outParam = outParam + errMsg + System.Environment.NewLine;
                                us = getUserState(2, "插入医保平台", "失败。原因：" + errMsg, jaFeeDetail[i]);
                                errorCount++;
                            }
                            else
                                us = getUserState(2, "插入医保平台", "成功", jaFeeDetail[i]);
                            bgWorker.ReportProgress(i, us);
                            //更新2301返回的数据
                            if (mIS.updateFee(JArray.Parse(JsonHelper.getDestValue(joRtn, "output.result")), out errMsg) != 0)
                            {
                                outParam = outParam + errMsg + System.Environment.NewLine;
                                us = getUserState(3, "根据中心返回数据更新费用明细", "失败。原因：" + errMsg, jaFeeDetail[i]);
                                errorCount++;
                            }
                            else
                                us = getUserState(3, "根据中心返回数据更新费用明细", "成功", jaFeeDetail[i]);
                            bgWorker.ReportProgress(i, us);
                        }
                        jaTmp = new JArray();
                    }
                    bgWorker.ReportProgress(i + 1, null);
                }
                if ((errorCount == 0) && (e.Cancel == false))
                {
                    Thread.Sleep(1000);
                    this.DialogResult = DialogResult.OK;
                }
                else
                {

                }
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }

        }

        //private void bgWorker1_DoWork(object sender, DoWorkEventArgs e)
        //{
        //    //BackgroundWorker bgWorker = sender as BackgroundWorker;
        //    MessageBox.Show("a1");
        //    string errMsg;
        //    int feeCount = jaFeeDetail.Count;
        //    int errorCount = 0;
        //    try
        //    {
        //        JArray jaTmp = new JArray();
        //        userState us = new userState();
        //        for (int i = 0; i < feeCount; i++)
        //        {

        //            manualReset.WaitOne();

        //            if (bgWorker1.CancellationPending)
        //            {
        //                e.Cancel = true;
        //                errorCount++;
        //                break;
        //            }

        //            jaFeeDetail[i]["chrg_bchno"] = Global.pat.adm_Dr.ToString();
        //            jaFeeDetail[i]["med_type"] = Global.pat.medType;
        //            if (jaFeeDetail[i]["validFlag"].ToString() == "N")
        //            {
        //                bgWorker1.ReportProgress(i, null);
        //                continue;
        //            }
        //            jaTmp.Add(jaFeeDetail[i]);
        //            if (((i + 1) % singleCount == 0) || ((i + 1) == jaFeeDetail.Count))
        //            {

        //                JObject joFeeDetail = new JObject();
        //                joFeeDetail.Add("feedetail", jaTmp);
        //                JObject joRtn = invoker.invokeCenterService(funNO, JsonHelper.setCenterInpar(funNO, joFeeDetail.ToString()));
        //                if (JsonHelper.parseCenterRtnValue(joRtn, out errMsg) != 0)
        //                {
        //                    outParam = outParam + errMsg + System.Environment.NewLine;
        //                    us = getUserState(1, "解析中心返回值", "失败。原因：" + errMsg, jaFeeDetail[i]);
        //                    errorCount++;
        //                }
        //                else
        //                {
        //                    us = getUserState(1, "解析中心返回值", "成功", jaFeeDetail[i]);
        //                    bgWorker1.ReportProgress(i, us);
        //                    //成功后插入医保平台
        //                    if (mIS.insertFee(jaTmp, out errMsg) != 0)
        //                    {
        //                        outParam = outParam + errMsg + System.Environment.NewLine;
        //                        us = getUserState(2, "插入医保平台", "失败。原因：" + errMsg, jaFeeDetail[i]);
        //                        errorCount++;
        //                    }
        //                    else
        //                        us = getUserState(2, "插入医保平台", "成功", jaFeeDetail[i]);
        //                    bgWorker1.ReportProgress(i, us);
        //                    //更新2301返回的数据
        //                    if (mIS.updateFee(JArray.Parse(JsonHelper.getDestValue(joRtn, "output.result")), out errMsg) != 0)
        //                    {
        //                        outParam = outParam + errMsg + System.Environment.NewLine;
        //                        us = getUserState(3, "根据中心返回数据更新费用明细", "失败。原因：" + errMsg, jaFeeDetail[i]);
        //                        errorCount++;
        //                    }
        //                    else
        //                        us = getUserState(3, "根据中心返回数据更新费用明细", "成功", jaFeeDetail[i]);
        //                    bgWorker1.ReportProgress(i, us);
        //                }
        //                jaTmp = new JArray();
        //            }
        //            bgWorker1.ReportProgress(i + 1, null);
        //        }
        //        if (errorCount == 0)
        //        {
        //            Thread.Sleep(1000);
        //            this.DialogResult = DialogResult.OK;
        //        }
        //        else
        //        {

        //        }
        //    }
        //    catch (Exception ex)
        //    {
        //        MessageBox.Show(ex.Message);
        //    }

        //}

        private void bgWorker1_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            if (e.ProgressPercentage < 0)
            {
                setPos(0);
            }
            else
            {
                setPos(e.ProgressPercentage);
            }

            if (e.UserState != null)
            {
                userState us = (userState)e.UserState;
                string upDetailRecord = "";
                upDetailRecord = "【His名称：" + us.detailHisName + ";";
                upDetailRecord = upDetailRecord + "His编码：" + us.detailInsuCode + "; ";
                upDetailRecord = upDetailRecord + "医保编码：" + us.detailInsuCode + ";";
                upDetailRecord = upDetailRecord + "当前节点：" + us.description + "】";
                upDetailRecord = upDetailRecord + us.error + System.Environment.NewLine;

                this.rtbRecord.AppendText(upDetailRecord);
                pbDetail.Value = us.childProgress;
            }

        }



        private void rtbRecord_TextChanged(object sender, EventArgs e)
        {
            rtbRecord.SelectionStart = rtbRecord.Text.Length;
            rtbRecord.ScrollToCaret();
        }

        private void btUpload_Click(object sender, EventArgs e)
        {
            if (!bgWorker1.IsBusy)
            {
                rtbRecord.Clear();
                bgWorker1.RunWorkerAsync();
            }
            else
            {
                MessageBox.Show("请点击停止按钮！");

            }
        }

        private void btPause_Click(object sender, EventArgs e)
        {
            if (btPause.Text == "暂停")
            {
                manualReset.Reset();//暂停当前线程的工作，发信号给waitOne方法，阻塞
                btPause.Text = "继续";
            }
            else
            {
                manualReset.Set();//继续某个线程的工作
                btPause.Text = "暂停";
            }
        }

        private void btStop_Click(object sender, EventArgs e)
        {
            if (bgWorker1.IsBusy)  bgWorker1.CancelAsync();
        }

        private void bgWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
            if (e.Cancelled)
            { }

            if (e.Error != null)
            {
                outParam = e.Error.ToString();
            }
            //e.Result  
        }
    }
}