public void UploadInsurHistory()

        {

            using (IDbConnection connection = ConnConfig.DmsConnection)

            {

                IDbTransaction trans = connection.BeginTransaction();

                try

                {

                    InsuranceBuyAccess gateway = new InsuranceBuyAccess(trans);

                    CommonDataGateway commonDataGateway = new CommonDataGateway(trans);

                    //1、检测系统参数UploadFlag != '0',就不上传

                    string uploadFlag = commonDataGateway.GetSettingValue("Repair", "UploadFlag");

                    if (uploadFlag != "")

                    {

                        return;

                    }

                    //2、修正数据，将交强险、商业险到期日为 "0001-01-01"的数据到期日置为 NULL

                    gateway.ModifyDueDate();

                    //3、保险历史数据上传，每500条作为一个Json

                    DataSet dcsDS = gateway.GetAllInsuranceData();

                    JsonDCS mainJson = new JsonDCS();

                    mainJson.ver = ;

                    mainJson.bl = "S.I.INSURANCEBUY";

                    mainJson.sbl = new ArrayList();

                    DCSHeader dcsHeader = new DCSHeader();

                    dcsHeader.bl = "S.I.INSURANCEBUY";

                    dcsHeader.ver = ;

                    //一次性将历史数据写入一个Json之中

                    if (dcsDS.Tables[].Rows.Count > )

                    {

                        JsonDCS insuranceBuyJson = new JsonDCS();

                        insuranceBuyJson.ver = ;

                        insuranceBuyJson.bl = "S.I.INSURANCEBUY.INSURANCEBUY_I0";

                        insuranceBuyJson.cols = new string[]{"FrameNo","BuyDate","InsurerCode","InsuranceType","InsuranceBuyDate","InsuranceMaturityDate","SalesType","Remark","BizNo","TrafficNo",

                 "CommercialNo","CustomerNo","CoverageType","SaleChannel","IsChange","HandlePerson","NextPerson","CustOrigin","CommercialStartDate","CommercialEndDate",

                 "Insured","Tel","TrafficFee","TrafficDiscount","CommercialFee","CommercialDiscount","TotalFee","Deleted","InputPerson","InputTime","OpFlag"};

                        insuranceBuyJson.data = new object[dcsDS.Tables[].Rows.Count][];

                        for (int i = ; i < dcsDS.Tables[].Rows.Count; i++)

                        {

                            insuranceBuyJson.data[i] = new object[] { dcsDS.Tables[].Rows[i]["FRAMENO"], CanHelper.ToDate(dcsDS.Tables[].Rows[i]["BUYDATE"]), dcsDS.Tables[].Rows[i]["INSURERCODE"],

                                dcsDS.Tables[].Rows[i]["INSURANCETYPE"], CanHelper.ToDate(dcsDS.Tables[].Rows[i]["INSURANCEBUYDATE"]), CanHelper.ToDate(dcsDS.Tables[].Rows[i]["INSURANCEMATURITYDATE"]),

                                dcsDS.Tables[].Rows[i]["SALESTYPE"], dcsDS.Tables[].Rows[i]["REMARK"], dcsDS.Tables[].Rows[i]["BIZNO"],

                                dcsDS.Tables[].Rows[i]["TRAFFICNO"], dcsDS.Tables[].Rows[i]["COMMERCIALNO"], dcsDS.Tables[].Rows[i]["CUSTOMERNO"],

                                dcsDS.Tables[].Rows[i]["COVERAGETYPE"], dcsDS.Tables[].Rows[i]["SALECHANNEL"], dcsDS.Tables[].Rows[i]["ISCHANGE"],

                                dcsDS.Tables[].Rows[i]["HANDLEPERSON"], dcsDS.Tables[].Rows[i]["NEXTPERSON"], dcsDS.Tables[].Rows[i]["CUSTORIGIN"],

                                CanHelper.ToDate(dcsDS.Tables[].Rows[i]["COMMERCIALSTARTDATE"]), CanHelper.ToDate(dcsDS.Tables[].Rows[i]["COMMERCIALENDDATE"]), dcsDS.Tables[].Rows[i]["INSURED"],

                                dcsDS.Tables[].Rows[i]["TEL"], dcsDS.Tables[].Rows[i]["TRAFFICFEE"], dcsDS.Tables[].Rows[i]["TRAFFICDISCOUNT"],

                                dcsDS.Tables[].Rows[i]["COMMERCIALFEE"], dcsDS.Tables[].Rows[i]["COMMERCIALDISCOUNT"], dcsDS.Tables[].Rows[i]["TOTALFEE"],

                                dcsDS.Tables[].Rows[i]["DELETED"], dcsDS.Tables[].Rows[i]["INPUTPERSON"], dcsDS.Tables[].Rows[i]["INPUTTIME"],"U"};

                        }

                        mainJson.sbl.Add(insuranceBuyJson);

                    }

                    //分解Json传送数据

                    if (mainJson.sbl.Count > )

                    {

                        int rowCount = ((JsonDCS) mainJson.sbl[]).data.Length;

                        if (mainJson.sbl != null && mainJson.sbl[] != null && rowCount > ) //大于500行的分包发送

                        {

                            //childCount 分解的后需要传送的Json数目

                            int childCount = rowCount / ;

                            if (rowCount %  != )

                            {

                                childCount++;

                            }

                            JsonDCS subJson = (JsonDCS) mainJson.sbl[];

                            for (int i = ; i < childCount + ; i++)

                            {

                                JsonDCS childMainJson = new JsonDCS();

                                childMainJson.bl = "S.I.INSURANCEBUY";

                                childMainJson.ver = ;

                                childMainJson.sbl = new ArrayList();

                                JsonDCS childJson = new JsonDCS();

                                childJson.bl = "S.I.INSURANCEBUY.INSURANCEBUY_I0";

                                childJson.ver = ;

                                childJson.cols = new string[]{"FrameNo","BuyDate","InsurerCode","InsuranceType","InsuranceBuyDate","InsuranceMaturityDate","SalesType","Remark","BizNo","TrafficNo",

                 "CommercialNo","CustomerNo","CoverageType","SaleChannel","IsChange","HandlePerson","NextPerson","CustOrigin","CommercialStartDate","CommercialEndDate",

                 "Insured","Tel","TrafficFee","TrafficDiscount","CommercialFee","CommercialDiscount","TotalFee","Deleted","InputPerson","InputTime","OpFlag"};

                                childJson.data = new object[][];

                                if (i == childCount)

                                {

                                    childJson.data = new object[rowCount - ((i - ) * )][];

                                }

                                for (int j = ; j < ; j++)

                                {

                                    if (j + (i - ) *  == rowCount)

                                    {

                                        break;

                                    }

                                    else

                                    {

                                        childJson.data[j] = subJson.data[j + (i - ) * ];

                                    }

                                }

                                childMainJson.sbl.Add(childJson);

                                gateway.CacheData(mainJson, dcsHeader);

                            }

                        }

                        else

                        {

                            gateway.CacheData(mainJson, dcsHeader);

                        }

                        //4、设置系统参数UploadFlag = '1'

                        commonDataGateway.UpdateStringValue("", "Repair", "UploadFlag");

                        trans.Commit();

                    }

                }

                catch (Exception ex)

                {

                    trans.Rollback();

                    throw ex;

                }

            }

        }