MedicalInsurance/Forms/FeeUpload.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 PTMedicalInsurance.Forms
{
    public partial class FeeUpload : Form
    {
        private InvokeHelper invoker = new InvokeHelper();
        private MIIrisServices mIS = new MIIrisServices();
        private ManualResetEvent manualReset = new ManualResetEvent(true);
        private HisIrisServices hIS = new HisIrisServices();
        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;
            if (jt != null)
            {
                us.detailHisCode = jo["medins_list_codg"].ToString();
                //us.detailHisName = jo["medins_list_desc"].ToString();
                us.detailInsuCode = jo["med_list_codg"].ToString();
            }
            
            return us;
        }
        public FeeUpload(string funNO, int singleCount, JArray jaFeeDetail)
        {
            InitializeComponent();
            this.funNO = funNO;
            this.singleCount = singleCount;
            this.jaFeeDetail = jaFeeDetail;
            this.pbFee.Maximum = jaFeeDetail.Count;
            

        }

        public FeeUpload(string funNO, int singleCount)
        {
            InitializeComponent();
            this.funNO = funNO;
            this.singleCount = singleCount;
        }

        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 errorCount = 0;
            userState us = new userState();
            try
            {
                us = getUserState(0, "获取HIS费用", "......", null);
                bgWorker.ReportProgress(0, us);
                //获取IS费用
                if (hIS.getHisFee(Global.pat, out errMsg) != 0)
                {
                    us = getUserState(0, "获取HIS费用", "失败", null);
                    bgWorker.ReportProgress(0, us);
                    outParam = errMsg;
                    return;
                }
                else
                {
                    us = getUserState(0, "获取HIS费用", "成功", null);
                    bgWorker.ReportProgress(0, us);
                }
                //调用医保平台转换HIS费用（转换医保编码等）
                JObject joHisFee = JObject.Parse(errMsg);
                us = getUserState(0, "转换HIS费用", "......", null);
                bgWorker.ReportProgress(0, us);
                if (mIS.convertHisFeeWithInsuCode(joHisFee, out errMsg) != 0)
                {
                    us = getUserState(0, "转换HIS费用", "失败", null);
                    bgWorker.ReportProgress(0, us);
                    outParam = errMsg;
                    return;
                }
                else
                {
                    us = getUserState(0, "转换HIS费用", "成功", null);
                    bgWorker.ReportProgress(0, us);
                }

                JArray jaFeeDetail = JArray.Parse(JsonHelper.getDestValue(JObject.Parse(errMsg), "data"));
                int feeCount = jaFeeDetail.Count();
                this.pbFee.Maximum = jaFeeDetail.Count;
                JArray jaTmp = new JArray();
                for (int i = 0; i < feeCount; i++)
                {
                    manualReset.WaitOne();

                    if (bgWorker.CancellationPending)
                    {
                        e.Cancel = true;
                        break;
                    }
                    decimal cnt = decimal.Parse(jaFeeDetail[i]["cnt"].ToString());
                    decimal pric = decimal.Parse(jaFeeDetail[i]["pric"].ToString());
                    //decimal sumamt = decimal.Parse(jaFeeDetail[i]["det_item_fee_sumamt"].ToString());
                    jaFeeDetail[i]["cnt"] = cnt.ToString("#0.0000");
                    jaFeeDetail[i]["pric"] = pric.ToString("#0.000000");
                    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));
                        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);
                            //广州需要检查每条MEMO是否为空
                            JArray jaRtnDetail = new JArray();
                            jaRtnDetail = JArray.Parse(JsonHelper.getDestValue(joRtn, "output.result"));
                            //foreach (JToken jt in jaRtnDetail)
                            //{
                            //    if (jt["memo"].ToString() != "")
                            //    {
                            //        outParam = outParam + errMsg + System.Environment.NewLine;
                            //        us = getUserState(2, "中心返回明细报错", jt["memo"].ToString(), jt);
                            //        errorCount++;
                            //    }
                            //}

                            //for (int j = 0; j < jaRtnDetail.Count; j++)
                            //{
                            //    if (jaRtnDetail[j]["memo"] != null)
                            //    {
                            //        var memo = jaRtnDetail[j]["memo"];

                            //        if (memo.ToString() != "")
                            //        {
                            //            outParam = outParam + memo + System.Environment.NewLine;
                            //            us = getUserState(2, "中心返回明细报错", memo.ToString(), null);
                            //            bgWorker.ReportProgress(i, us);
                            //            errorCount++;
                            //        }
                            //    }
                                
                            //}
                            //成功后插入医保平台
                            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
                {
                    Global.writeLog("outParam:" +outParam);
                }
            }
            catch (Exception ex)
            {
                outParam = "费用上传异常:" + 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  
        }
    }
}