码迷,mamicode.com
首页 > Web开发 > 详细

.NET下的并行开发(案例代码)

时间:2014-09-26 00:36:48      阅读:275      评论:0      收藏:0      [点我收藏+]

标签:des   style   http   color   io   os   使用   ar   for   

以下主要是通过一个报表处理程序来说明并行开发的方式。对于数据冲突和共享,可以通过对象数组解决。设计到并行的核心代码已用红色标出。在并行程序的处理上,需要把原来串行的子公司变成一个一个类的对象,让所有的类对象一起并行运行就达到提高响应速率的目的了。并行设计中,主要的还是编程的思想,并行的语法,规则都是规划好的。好的工具就看你如何使用了。

using System;
using System.Data;
using System.Configuration;
using System.Collections;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
//using Excel = Microsoft.Office.Interop.Excel;
using gcdb;
using System.Data.Odbc;
using gc;
using ExcelQuicker.Framework;
using System.IO;
using System.Threading;
using System.Threading.Tasks;
using System.Data.SqlClient;

namespace scbb
{

    //企业营业额完成情况一览表
    //具体注释,请参考 建筑业总产值分类完成情况表
    // h 开头为海外项目统计参数
    //"企业营业额完成情况表.xls";//模板文件名称



    public class scbb_b7
    {
        string downExcelFile;

        string c_yhid, c_yhdw, c_xmmxf, c_sfgz, c_ddlb, c_yearmonth, c_yhjb, c_ybtime;
        int c_dlml;//是否存储到独立目录
        string yearmonth;
        string jibie;
        string year;
        string month;
        string ddlb;
      
      public   object[,] objDataExcel;
        System.Collections.Queue q = new Queue();
        System.Collections.Queue q2 = new Queue();

        protected string tbn(int n)
        {
            if (n <= 0 || n > 10)
                return "";
            string[] bigNum = new string[] { "一", "二", "三", "四", "五", "六", "七", "八", "九", "十" };
            return bigNum[n - 1];

        }
        protected string toBigNumber(int num)
        {
            string b = "";
            if (num > 100 || num <= 0)
                return "";
            if (num <= 10)
                b = tbn(num);
            else if (num < 20)
            {
                b = "十" + tbn(num % 10);
            }
            else
            {
                b = tbn(num / 10) + "十" + tbn(num % 10);
            }

            b = b + "、";
            return b;
        }

        DB db = new DB();

        public void Initialize()
        {
            if (Directory.Exists(HttpRuntime.AppDomainAppPath + "ExcelQuicker\\gf\\" + c_ybtime.Substring(0, 7)) == false)
            {
                Directory.CreateDirectory(HttpRuntime.AppDomainAppPath + "ExcelQuicker\\gf\\" + c_ybtime.Substring(0, 7));
            }
            EQConfiguration.XmlFileName = HttpRuntime.AppDomainAppPath + "ExcelQuicker\\Lib\\Message.xml";
            EQConfiguration.Language = "EN";
            if (c_dlml == 1)
            {
                EQConfiguration.TemporaryFilePath = HttpRuntime.AppDomainAppPath + "ExcelQuicker\\gf\\";
                EQConfiguration.OutputFilePath = HttpRuntime.AppDomainAppPath + "ExcelQuicker\\gf\\" + c_ybtime.Substring(0, 7) + "\\";
            }
            else
            {
                if (Directory.Exists(HttpRuntime.AppDomainAppPath + "ExcelQuicker\\TempReports\\" + c_yhdw.Substring(0, 4)) == false)
                {
                    Directory.CreateDirectory(HttpRuntime.AppDomainAppPath + "ExcelQuicker\\TempReports\\" + c_yhdw.Substring(0, 4));
                }
                EQConfiguration.TemporaryFilePath = HttpRuntime.AppDomainAppPath + "ExcelQuicker\\TempReports\\" + c_yhdw.Substring(0, 4);
                EQConfiguration.OutputFilePath = HttpRuntime.AppDomainAppPath + "ExcelQuicker\\TempReports\\" + c_yhdw.Substring(0, 4);
            }
            EQConfiguration.TemplateFilePath = HttpRuntime.AppDomainAppPath + "ExcelQuicker\\Template\\";

        }


        public void setSpeficedRange(int x0, int y0, int x1, int y1, EQWorksheet xlWorkSheet, string content)
        {
            string[,] dwfzr = new string[1, 1];  //建立二維數組對象
            dwfzr[0, 0] = content;
            EQRange range = new EQRange(dwfzr, x0, y0, x1, y1);
            range.MergeCells = true;
            xlWorkSheet.Add(range);

        }
        void set_Excel(string strFileName, string strTemplate, DwObject[] dwmobjdata)
        {

            OdbcDataReader tempOdr;
            EQApplication objApp = new EQApplication(strFileName, EQReportFormat.Excel, strTemplate, false);
            //objApp.AddOutputFile(strFileName, EQReportFormat.HTML);    //Command to output a html format report file at the same time
            EQWorksheet objWS = new EQWorksheet("报表数据");
            EQRange zrange = new EQRange(objDataExcel, 8, 1, 9, 140);
            zrange.AddStyle(EQStyleFactory.BlackAndGrayBorder);
            zrange.AddStyle(EQStyleFactory.OuterBorder);
            zrange.AddStyle(EQStyleFactory.AlignRight);
            zrange.Type = EQType.General;
            setRowColor(8, 19, 10, objWS);
            objWS.Add(zrange);
            EQRange[] range = new EQRange[dwmobjdata.Length];
            int sum = 0;
            int sun = 0;
            for (int p = 0; p < dwmobjdata.Length; p++)
            {

                sum += dwmobjdata[p].objData .GetLength(0);
                sun = sum - dwmobjdata[p].objData.GetLength(0);

                range[p] = new EQRange(dwmobjdata[p].objData, 10+ sun, 1, 10 + sum - 1, 140);
                range[p].Type = EQType.General;

                //設置單元格整體風格
                range[p].AddStyle(EQStyleFactory.BlackAndGrayBorder);
                range[p].AddStyle(EQStyleFactory.OuterBorder);
                range[p].AddStyle(EQStyleFactory.AlignRight); //設置所有單元格右對齊
                //設置第一列左對齊
                EQColumnStyle mycolumnstyle = new EQColumnStyle();
                mycolumnstyle.SetColumnStyle(1, EQStyleFactory.AlignCenter);
                mycolumnstyle.SetColumnStyle(2, EQStyleFactory.AlignLeft);
                setRowColor(10 + sun, 19, 10, objWS);

                objWS.Add(range[p]);
                objWS.Add(mycolumnstyle);
            }




            //设置特定行的格式

            //设置表头部信息
            string sql_yhdw = "select dwmc from t_dw where dwid = ‘" + c_yhdw + "‘";
            tempOdr = db.getReader(sql_yhdw);
            tempOdr.Read();
            string mydwmc = tempOdr.GetValue(0).ToString();//设置选定区域的文本,可用于设置填报公司
            mydwmc = "填报单位:" + mydwmc;
            tempOdr.Close();
            setSpeficedRange(4, 1, 4, 1, objWS, mydwmc);
            setSpeficedRange(3, 1, 3, 12, objWS, "单位建设项目主要实物工程量完成情况(" + c_ddlb + ")");
            string mytime = year + "年" + month + "月";
            setSpeficedRange(4, 6, 4, 7, objWS, mytime);
            //设置表尾信息
            FillIn(sum, objWS);
            objApp.Add(objWS);
            try
            {
                objApp.Output();
            }
            catch (Exception)
            {
                objApp.Dispose();
                zdscbb.xrbbhcwcyy("b7", c_yhdw, c_xmmxf, c_sfgz, c_ddlb, c_ybtime, "Output Error");
            }
        }




        public void setRowColor(int rowNum, int colorIndex, int fontSize, EQWorksheet xlWorkSheet)
        {

            EQRowStyle mystyle = new EQRowStyle();
            EQRangeStyle mystyle2 = new EQRangeStyle();
            mystyle2.BackColor = colorIndex;
            mystyle2.Size = fontSize;
            //mystyle2.Bond = true;
            string endColumn1 = "e";   //结束时的列
            string endColumn2 = "j";  //结束时的列
            mystyle.SetRowStyle(rowNum, endColumn1, endColumn2, mystyle2);
            xlWorkSheet.Add(mystyle);
        }


        public int get_Count_From_Sql(string sql)
        {

            OdbcDataReader tempOdr;
            int tempNum;
            tempOdr = db.getReader(sql);
            tempOdr.Read();
            tempNum = int.Parse(tempOdr.GetValue(0).ToString());//公司数目
            tempOdr.Close();

            return tempNum;
        }






        public void xrbb(string cl_yhid, string cl_yhdw, string cl_xmmxf, string cl_sfgz, string cl_ddlb, string cl_yearmonth, string cl_yhjb, string cl_ybtime, int cl_dlml)
        {
            c_dlml = cl_dlml;
            c_yhid = cl_yhid;
            c_yhdw = cl_yhdw;
            c_xmmxf = cl_xmmxf;
            c_sfgz = cl_sfgz;
            c_ddlb = cl_ddlb;
            c_yearmonth = cl_yearmonth;
            c_yhjb = cl_yhjb;
            c_ybtime = cl_ybtime;
            string strFileName = "b7_" + c_yhdw + "_" + c_ddlb + c_xmmxf + c_ybtime + c_sfgz + ".xls";//生成的临时文件名称
            zdscbb.xrbbhc("b7", cl_yhdw, cl_xmmxf, cl_sfgz, cl_ddlb, cl_ybtime, strFileName);
            downExcelFile = "../ExcelQuicker/TempReports/" + strFileName;



            yearmonth = c_yearmonth;
            jibie = c_yhjb.ToString().Trim();
            ddlb = c_ddlb.ToString();
            year = yearmonth.Substring(0, 4);
            month = yearmonth.Substring(5, 2);

            int iMonth = Convert.ToInt32(month);

            if (iMonth < 10)
                month = month.Substring(1, 1);

            ////项目数
            //string sql_xmmc_count1 = "select count(*) from (  select id,sgdw,xmmc,sfgz" + c_yhjb + ",ddlb  from T_gcxm where  (lrrq is null or year(lrrq)<" + year + " or (YEAR(lrrq)=" + year + " and MONTH(lrrq)<=" + month + "))and (xmjd<>‘竣工‘  or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id ) or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and" +
            //                " sgdw like‘" + c_yhdw + "%‘  or (sgdw like ‘" + c_yhdw + "%‘ and fgcid is null ) "
            //    +
            //     " union (select id,sgdw,xmmc,sfgz" + c_yhjb + ",ddlb from T_gcxm where (lrrq is null or year(lrrq)<" + year + " or (YEAR(lrrq)=" + year + " and MONTH(lrrq)<=" + month + "))and  (xmjd<>‘竣工‘  or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id ) or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and fgcid in (select id from T_gcxm where (xmjd<>‘竣工‘  or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id ) or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and  xmgldw = ‘" +
            //        c_yhdw + "‘ ) and sgdw !=‘" + c_yhdw + "‘) ) as table_name  where 1=1 ";


        string sql_xmmc_count=  " select count(*) from t_gcxm where (lrrq is null or year(lrrq)<" + year + " or (YEAR(lrrq)=" + year + " and MONTH(lrrq)<=" + month + "))and (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)";
            //所有项目
            string sql_xmmc = "select * from ( select id, xmmc, sgdw,sfgz" + c_yhjb + ",ddlb from T_gcxm where  (lrrq is null or year(lrrq)<" + year + " or (YEAR(lrrq)=" + year + " and MONTH(lrrq)<=" + month + "))and (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and " +
              " sgdw like‘" + c_yhdw + "%‘ and ((sgdw <>‘" + c_yhdw
              + "‘ and fgcid is  null)or(sgdw =‘";
           
            string sql_xmmc_part2 = "‘ )) " + " union (select id,xmmc, sgdw,sfgz" + c_yhjb + ",ddlb from T_gcxm where  (lrrq is null or year(lrrq)<" + year + " or (YEAR(lrrq)=" + year + " and MONTH(lrrq)<=" + month + "))and (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and fgcid in (select id from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and  xmgldw = ‘" + c_yhdw + "‘ ) and sgdw !=‘" + c_yhdw + "‘) ) as table_name where 1=1   ";

            //        土石方    隧道  桥梁(设计折合 米)     其中:大中桥        其中:立交、高架桥        正线铺轨(公里)    其中:高速    站线铺轨(公里)  铁路制梁(片)    铁路架梁(孔)    机械化整道(公里)    无砟轨道通信线路(公里)自动闭塞(区间公里)    电气集中(联锁道岔)    供电线路(公里)变配电所(站)    接触网(正线公里)    牵引变电所(处)    房屋施工面积    房屋竣工面积    地铁成洞(折合米)        地铁车站(座)        轻轨(折合米)        公路(折合公里)        其中:高速公路        其中:路面(平方米)        



            string sql_sum_klwc = " select sum(byxmzcz),sum(sw_tsf),sum(sw_sdsjcd),sum(sw_qlsjcd),sum(sw_dzq),sum(sw_ljgs),sum(tdq),sum(sw_tlzhxpg),sum(sw_gstl),sum(sw_tlzxpg),null,sum(sw_tljl),null,null,sum(sd_gdxl),sum(sd_bpds),sum(sd_jcw),sum(sd_qybds),sum(sd_txxl),sum(sd_xlgl),sum(sd_txsb),sum(sd_zdbs),sum(sd_dqjz),sum(fj_fwjzmj),sum(fj_fjzhmj),sum(fj_fjjgmj),sum(sw_dt),sum(sw_dtcz),sum(sw_qg),sum(sw_gl),sum(sw_gl_gs),sum(sw_gl_lm) from VIEW_YB_ALL where " +
                "  (lrrq is null or year(lrrq)<" + year + " or (YEAR(lrrq)=" + year + " and MONTH(lrrq)<=" + month + "))and sgdw like‘" + c_yhdw + "%‘";

            //(a.bqswl <> 1) OR (a.bqswl IS NULL)
            //本年完成
            string sql_sum_bnwc = " select sum(byxmzcz),sum(sw_tsf),sum(sw_sdsjcd),sum(sw_qlsjcd),sum(sw_dzq),sum(sw_ljgs),sum(tdq),sum(sw_tlzhxpg),sum(sw_gstl),sum(sw_tlzxpg),null,sum(sw_tljl),null,null,sum(sd_gdxl),sum(sd_bpds),sum(sd_jcw),sum(sd_qybds),sum(sd_txxl),sum(sd_xlgl),sum(sd_txsb),sum(sd_zdbs),sum(sd_dqjz),sum(fj_fwjzmj),sum(fj_fjzhmj),sum(fj_fjjgmj),sum(sw_dt),sum(sw_dtcz),sum(sw_qg),sum(sw_gl),sum(sw_gl_gs),sum(sw_gl_lm) from VIEW_YB_XM where " +
                " sgdw like‘" + c_yhdw + "%‘ and  year(ybsj)= ‘" + year + "‘" + " and month(ybsj)<= " + month + " ";

            //string subproject_yb = " or  fgcid in ( select xmid from view_yb_xm where sgdw like ‘" +c_yhdw + "%‘  and  year(ybsj)= ‘" + year + "‘ ";

            if (c_sfgz.ToString() == "关注项目")
            {
                sql_xmmc_count = sql_xmmc_count + " and sfgz" + c_yhjb + "=1";
                sql_xmmc_part2 = sql_xmmc_part2 + " and sfgz" + c_yhjb + "=1";
                sql_sum_klwc = sql_sum_klwc + " and sfgz" + c_yhjb + "=1";
                sql_sum_bnwc = sql_sum_bnwc + " and sfgz" + c_yhjb + "=1";

            }
            if (c_sfgz.ToString() == "非关注项目")
            {
                sql_xmmc_count = sql_xmmc_count + " and sfgz" + c_yhjb + "=0";
                sql_xmmc_part2 = sql_xmmc_part2 + " and sfgz" + c_yhjb + "=0";
                sql_sum_klwc = sql_sum_klwc + " and sfgz" + c_yhjb + "=0";
                sql_sum_bnwc = sql_sum_bnwc + " and sfgz" + c_yhjb + "=0";

            }

            string sql_sum_klwc_total = sql_sum_klwc;
            string sql_sum_bnwc_total = sql_sum_bnwc;


            if (c_ddlb.ToString() == "海外")
            {
                sql_xmmc_count = sql_xmmc_count + "and ddlb = ‘海外‘";
                sql_xmmc_part2 = sql_xmmc_part2 + "and ddlb = ‘海外‘";
                sql_sum_klwc = sql_sum_klwc + "and ddlb = ‘海外‘";
                sql_sum_bnwc = sql_sum_bnwc + "and ddlb = ‘海外‘";

            }

            if (c_ddlb.ToString() == "国内")
            {
                sql_xmmc_count = sql_xmmc_count + "and (ddlb = ‘省内‘ or ddlb = ‘省外‘)";
                sql_xmmc_part2 = sql_xmmc_part2 + "and (ddlb = ‘省内‘ or ddlb = ‘省外‘)";
                sql_sum_klwc = sql_sum_klwc + "and (ddlb = ‘省内‘ or ddlb = ‘省外‘)";
                sql_sum_bnwc = sql_sum_bnwc + "and (ddlb = ‘省内‘ or ddlb = ‘省外‘)";
            }



            int cnum = 140;

            objDataExcel = new object[2, cnum];  //分配两行,一行显示总计数据,一行显示范围


            for (int i2 = 0; i2 < 2; i2++)
            {
                for (int j2 = 0; j2 < cnum; j2++)
                    objDataExcel[i2, j2] = "";
            }



            objDataExcel[0, 1] = "总计";

          if (c_ddlb.ToString() == "国内" || c_ddlb.ToString() == "海外" || c_ddlb.ToString()=="全部")
              objDataExcel[1, 1] = "  " + c_ddlb.ToString() + "项目计";

         
            //单位名称分类
            //支公司检阅信息
            string sql_dw_fid = "select id from t_dw  where dwid = ‘" + c_yhdw + "‘ ";  //查询单位的编号
            OdbcDataReader odr_dw_fid = db.getReader(sql_dw_fid);
            odr_dw_fid.Read();
          string   dw_fid = odr_dw_fid["id"].ToString ();
            odr_dw_fid.Close();



            string sql_dw = "select dwmc,dwid,dwjb,fdwid from t_dw where (dwid = ‘" + c_yhdw + "‘ or fdwid =  ‘" + dw_fid  + "‘ ) and bbxs is null order by dwxh";
        
           
            OdbcDataReader odr_dw = db.getReader(sql_dw);


        

         
            int dw_count = 0;    //记录总的单位数量
            string sql_dw_count2 = "select count(*) from t_dw where (dwid = ‘" + c_yhdw + "‘ or fdwid =  ‘" + dw_fid + "‘ ) and bbxs is null  ";
           
            OdbcDataReader odr = db.getReader(sql_dw_count2);
            odr.Read();
            dw_count = (int)odr[0];
            odr.Close();
            int dws = 0;//记录单位的数量
            string[] arry = new string[dw_count];//记录单位的编号

            while (odr_dw.Read())
            {
                arry[dws] = odr_dw.GetValue(1).ToString();
                dws++;
            }
            odr_dw.Close();
            DwObject[] dwmess = new DwObject[dw_count];

         
            Parallel.For(0, dw_count, (y) =>
            {
                dwmess[y] = new DwObject();
                dwmess[y].post( year,c_yhdw,sql_sum_bnwc, sql_xmmc_part2, sql_sum_klwc, sql_xmmc, c_xmmxf, c_yhjb,  c_ybtime, y, sql_xmmc_count);
                dwmess[y].dws(arry[y]);
              

            });


            /********************
             *
             * 统计总计数据
             * *********************/
            if (c_yhjb.ToString() == "3")
            {
                for (int z = 0; z < cnum; z++)
                { objDataExcel[0, z] = ""; }
            }
            else
            {
                double[] sum = new double[150];
                for (int z = 2; z < cnum; z++)
                {
                    for (int p = 0; p < dwmess.Length; p++)
                    {
                        if ( dwmess[p].objData[0, z].ToString() != "")
                            sum[z] += Convert.ToDouble(dwmess[p].objData[0, z]);

                    }

                    if (c_yhdw.ToString() != "gf" && dwmess[0].objData[0, z].ToString() != "")
                    {
                        sum[z] -= 2 * Convert.ToDouble(dwmess[0].objData[0, z]); /*分公司项目存在局指,项目重复显示*/
                    }
                    objDataExcel[0, z] = sum[z];


                }
            }

         
            string strTemplate = "单位实物量统计表.xls";
            Initialize();//调用excel quicker初始化函数
            set_Excel(strFileName, strTemplate,dwmess );//生成并设置此excel表
            zdscbb.xrbbhcwc("b7", cl_yhdw, cl_xmmxf, cl_sfgz, cl_ddlb, cl_ybtime, strFileName);
        }

        private void FillIn(int num, EQWorksheet xlWorkSheet)
        {
            string sql_user = "select  dwfzr,tjfzr,yhmc,lxfs from t_user where yhid = ‘" + c_yhid + "‘";

            OdbcDataReader odr_user = db.getReader(sql_user);
            odr_user.Read();

            int Allnum = num + 11;
            string[,] dwfzr = new string[1, 1];
            dwfzr[0, 0] = "单位负责人:" + odr_user.GetValue(0).ToString() + "          统计负责人:" + odr_user.GetValue(1).ToString() + "           填报人:" + odr_user.GetValue(2).ToString() + "          联系电话:" + odr_user.GetValue(3).ToString() + "          上报日期:" + DateTime.Today.ToShortDateString();
            EQRange range = new EQRange(dwfzr, Allnum, 1, Allnum, 10);

            range.MergeCells = true;
            range.AddStyle(EQStyleFactory.AlignCenter);






            xlWorkSheet.Add(range);

            odr_user.Close();
            //完成填报
        }


     
    }

  public class DwObject
    {
          int xmxh = 0;
          Hashtable ht;
        int row_position = 0;
        int control_col = 139;
        int gclb_row = 0;
        int zj_row = 0;
        int gnxm_row = 0;
        public int rnum = 0;
        public int cnum = 140;  // 列
        public object[,] objData;
        DB db = new DB();
        int flxh=0;   //工程项目序号
    
      
        //由scbb_b7中赋值后传过来的变量
        string sql_sum_bnwc = "";
       string sql_xmmc_part2 ="";
        string sql_sum_klwc = "";
        string sql_xmmc = "";
        string sql_xmmc_count;
        string c_xmmxf, c_yhjb, c_ybtime,c_yhdw,year;
        //在调用函数时要先赋值给他们
        public void post(string year1,string c_yhdw1,string sql_sum_bnwc1, string sql_xmmc_part21, string sql_sum_klwc1, string sql_xmmc1, string c_xmmxf1, string c_yhjb1, string c_ybtime1, int flxh1,string  sql_xmmc_count1)
        {
            c_yhdw=c_yhdw1;
            sql_sum_bnwc = sql_sum_bnwc1;
           sql_xmmc_part2 =sql_xmmc_part21;
            sql_sum_klwc = sql_sum_klwc1;
            sql_xmmc = sql_xmmc1;
            c_xmmxf = c_xmmxf1;
            c_yhjb = c_yhjb1;
            c_ybtime = c_ybtime1;
            flxh = flxh1;
            sql_xmmc_count= sql_xmmc_count1;
              year=year1;

        }

        public int rnumber(string dwid, string sql_xmmc_count)
        {



            int gclb_count = 1;

            int gcxm_count = 0;  //记录具体的项目数量
            if (c_xmmxf == "True")    //是否显示明细
            {
                // 统计行数
                OdbcDataReader odr;
                 string sql_xmmc_count_dw = sql_xmmc_count + "and sgdw = ‘" + dwid + "‘";
                  if (dwid == c_yhdw.ToString())

               sql_xmmc_count_dw = sql_xmmc_count + "and sgdw = ‘" + dwid + "‘";
                  else  
                  
                      sql_xmmc_count_dw = sql_xmmc_count + "and sgdw like ‘" + dwid + "%‘";


                  odr = db.getReader(sql_xmmc_count_dw);       //工程项目行数
                  odr.Read();
                  gcxm_count = (int)odr[0];
                  odr.Close();

                  int zgc_count = 0;
                /***********************************
                 * 对于股份公司,在求它空间的时候,应该去掉相应重复的跨单位工程
                 *
                 * *************************************/
                  if (c_yhdw.ToString() == "gf" && dwid != c_yhdw.ToString())   
                  {
                      //跨单位管理的工程将显示两遍,
                     
                      string sql_zgcxm = "select count(*) from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and fgcid is not null and sgdw like‘" + dwid + "%‘";
                      odr = db.getReader(sql_zgcxm);
                      odr.Read();
                      zgc_count = (int)odr[0];
                      odr.Close();
                     

                  }

                  gcxm_count -= zgc_count;

                //====================================================================统计子项目个数       
                    string odr_gcxm_gclb = "";
                    if (dwid == c_yhdw.ToString())
                        odr_gcxm_gclb = sql_xmmc + dwid + sql_xmmc_part2 + " and sgdw =‘" + dwid + "‘ order by id desc";

                    else
                        odr_gcxm_gclb = sql_xmmc + dwid + sql_xmmc_part2 + " and sgdw like‘" + dwid + "%‘ order by id desc";

                    OdbcDataReader odr_gcxm_count = db.getReader(odr_gcxm_gclb);



                    while (odr_gcxm_count.Read())
                    {
                        string s_sql_sfyzxm = "select isnull(fgcid,0) from t_gcxm where id=" + odr_gcxm_count.GetValue(0).ToString() + " ";
                        OdbcDataReader odr_zxm = db.getReader(s_sql_sfyzxm);
                        if (odr_zxm.Read())
                        {
                            if (odr_zxm[0].ToString() != "0" && dwid != c_yhdw)
                            {
                                string sql1 = "select xmgldw,xmmc,id from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and  id=(select fgcid from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and id=‘" + odr_gcxm_count.GetValue(0).ToString() + "‘)";
                                OdbcDataReader reader = db.getReader(sql1);
                                while (reader.Read())
                                {
                                    if (reader.GetValue(0).ToString() == dwid)
                                    {
                                        //表明当前项目的父项目的项目管理单位是用户单位
                                        string sql_zxm_count = "select count(*) from T_gcxm where (xmjd<>‘竣工‘  or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id ) or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and fgcid=(select fgcid from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and id=‘" + odr_gcxm_count.GetValue(0).ToString() + "‘) ";
                                        OdbcDataReader odr_zxm_count = db.getReader(sql_zxm_count);
                                        odr_zxm_count.Read();
                                        gcxm_count += (int)odr_zxm_count[0];
                                        odr_zxm_count.Close();
                                    }

                                }
                                reader.Close();
                            }
                        }
                    }
                    odr_gcxm_count.Close();
                }

            
            int total = gcxm_count  + gclb_count;
            return total;

        }




        
        protected string toBigNumber(int num)
        {
            string[] bigNum = new string[] { "", "一", "二", "三", "四", "五", "六", "七", "八", "九", "十", "十一", "十二", "十三", "十四", "十五", "十六", "十七", "十八", "十九", "二十" };
            if (num > 0 && num <= 20)
                return bigNum[num] + "、";
            else
                if (num < 100)
                {
                    return bigNum[num / 10] + bigNum[num % 10 + 10] + "、";
                }
                else
                    return "";
        }

      
      public object[,] dws(string dwid)
        {

            rnum = rnumber(dwid,sql_xmmc_count );
            objData = new object[rnum, cnum];
            for (int i2 = 0; i2 < rnum; i2++)
            {
                for (int j2 = 0; j2 < cnum; j2++)
                    objData[i2, j2] = "";
            }
            
            gclb_row = row_position;
           
          string sql_dw = "select dwmc from t_dw where dwid = ‘" + dwid + "‘";
            OdbcDataReader odr_dw = db.getReader(sql_dw);
            string dwmc = "";
            odr_dw.Read();
            dwmc = odr_dw.GetValue(0).ToString();
            odr_dw.Close();
            objData[row_position, 0] = toBigNumber(flxh + 1);   //计量单位的编号,序号为生成的对象
            objData[row_position, 1] = dwmc;
                //记录分类位置

             //   q.Enqueue(row_position);

                string sql_sum_bnwc_gclb = "";
                if (dwid == c_yhdw.ToString())
                    sql_sum_bnwc_gclb = sql_sum_bnwc + "and sgdw = ‘" + dwid + "‘";  // //工程分类
                else
                    sql_sum_bnwc_gclb = sql_sum_bnwc + "and sgdw like ‘" + dwid + "%‘";  // //工程分类
             
                OdbcDataReader odr_sum_gclb_bnwc;//= db.getReader(sql_sum_bnwc_gclb);

                //同一类别项目总计行本年完成
                // odr_sum_gclb_bnwc.Read();

              int   n = 1;
              int   k = 1;

                while (n < control_col)
                {

                    objData[row_position, n + 1] = "";// odr_sum_gclb_bnwc.GetValue(k).ToString(); //在range中的位置 (1,1)
                    n += 3;
                    k++;
                }
                string sql_sum_klwc_gclb = "";
                if (dwid == c_yhdw.ToString())
                    sql_sum_klwc_gclb = sql_sum_klwc + "and sgdw = ‘" + dwid + "‘";  //
                else
                    sql_sum_klwc_gclb = sql_sum_klwc + "and sgdw like ‘" + dwid + "%‘";  //
                OdbcDataReader odr_sum_gclb_klwc;// = db.getReader(sql_sum_klwc_gclb);

                //同一类别项目总计行开累完成
                // odr_sum_gclb_klwc.Read();
            int   m = 3;
            int   i = 1;
                while (m < control_col + 1)
                {
                    objData[row_position, m] = "";// odr_sum_gclb_klwc.GetValue(i).ToString(); //在range中的位置 (1,1)
                    m += 2;
                    i++;
                }


                row_position++;

                //不同项目 列循环

                string odr_gcxm_gclb = "";
                //if(Session["yhjb"].ToString()=="3")
                //    odr_gcxm_gclb = sql_xmmc;
                //  else
                if (dwid == c_yhdw.ToString())
                    odr_gcxm_gclb = sql_xmmc + dwid + sql_xmmc_part2 + " and sgdw =‘" + dwid + "‘ order by id desc";

                else
                    odr_gcxm_gclb = sql_xmmc + dwid + sql_xmmc_part2 + " and sgdw like‘" + dwid + "%‘ order by id desc";

                //odr_gcxm_gclb = sql_xmmc + dwid + sql_xmmc_part2 + " and sgdw =‘" + dwid + "‘ order by id desc";
                OdbcDataReader odr_gcxm = db.getReader(odr_gcxm_gclb);



                //gclb = 3;
                ht = new Hashtable();
                while (odr_gcxm.Read())    //同一单位,不同项目循环
                {
                    int i_sfjs;//标志是改项目数据是否参与总计行的合计。
                    i_sfjs = 0;


                    string s_xmid;
                    s_xmid = odr_gcxm.GetValue(0).ToString();
                    string s_sql_sfyzxm = "select isnull(fgcid,0) from t_gcxm where id=" + s_xmid + " ";
                    OdbcDataReader odr_zxm = db.getReader(s_sql_sfyzxm);
                    if (odr_zxm.Read())
                    {
                        if (odr_zxm[0].ToString() == "0" || dwid == c_yhdw)
                            i_sfjs = 1;

                    }
                    odr_zxm.Close();


                    if (check_is_xmgldw(odr_gcxm.GetValue(0).ToString(), dwid))//检查当前项目是不是项目管理单位,传递项目id和单位id
                    {
                        continue;
                    }
                    //填写项目序号
                    xmxh++;
                    if (c_xmmxf.ToString() == "True")
                    {
                        objData[row_position, 0] = xmxh;


                        objData[row_position, 1] = "" + odr_gcxm.GetValue(1).ToString();   //项目名称
                    }
                    //同一项目列循环的本年完成

                    //存储过程返回的是---年累产值  type=2
                    //
                    string sql_sum_bnwc_gclbtemp = "p_sum_yb_cz_swl_dw  " + odr_gcxm.GetValue(0).ToString() + " , ‘"
                                + c_ybtime.ToString().Trim() + "‘," + c_yhjb
                                + ", 2";          //

                    odr_sum_gclb_bnwc = db.getReader(sql_sum_bnwc_gclbtemp);

                    odr_sum_gclb_bnwc.Read();

                    n = 2;
                    k = 1;

                    while (n < control_col)  //同一项目列循环的本年完成
                    {
                        if (c_xmmxf.ToString() == "True")
                        {
                            objData[row_position, n + 1] = odr_sum_gclb_bnwc.GetValue(k).ToString(); //在range中的位置 (1,1)
                        }
                        decimal d_gclb = 0, d_gcxm = 0, d_zj = 0;
                        if (objData[gclb_row, n + 1].ToString() != "")
                            d_gclb = Convert.ToDecimal((objData[gclb_row, n + 1]));
                        if (objData[zj_row, n + 1].ToString() != "")
                            d_zj = Convert.ToDecimal((objData[zj_row, n + 1]));
                        //if (objData[gnxm_row, n + 1].ToString() != "")
                        //    d_gnxm = Convert.ToDecimal((objData[gnxm_row, n + 1]));
                        if (odr_sum_gclb_bnwc.GetValue(k).ToString() != "")
                            d_gcxm = Convert.ToDecimal(odr_sum_gclb_bnwc.GetValue(k));



                        if (d_gcxm + d_gclb != 0 || d_gcxm != 0)
                            objData[gclb_row, n + 1] = (d_gcxm + d_gclb).ToString();
                        if (d_gcxm + d_zj != 0 && i_sfjs == 1)
                            objData[zj_row, n + 1] = (d_gcxm + d_zj).ToString();
                        // if (d_gcxm + d_gnxm != 0)
                        //     objData[gnxm_row, n + 1] = (d_gcxm + d_gnxm).ToString();
                        n += 3;
                        k++;
                    }
                    odr_sum_gclb_bnwc.Close();
                    //同一项目列循环的   开累完成
                    //存储过程返回的是---开累产值  type=3
                    //
                    string sql_sum_klwc_gclbtemp = "p_sum_yb_cz_swl_dw  " + odr_gcxm.GetValue(0).ToString() + " , ‘"
                                + c_ybtime.ToString().Trim() + "‘," + c_yhjb
                                + ", 3";          //

                    odr_sum_gclb_klwc = db.getReader(sql_sum_klwc_gclbtemp);

                    odr_sum_gclb_klwc.Read();

                    m = 4;
                    i = 1;
                    while (m < control_col + 1)//同一项目列循环的开累完成
                    {
                        if (c_xmmxf.ToString() == "True")
                        {
                            objData[row_position, m] = odr_sum_gclb_klwc.GetValue(i).ToString(); //在range中的位置 (1,1)
                        }
                        /*  d_zj     总计行
                         *  d_gnxm   国内项目或海外项目行 总计值
                         *  d_gclb   工程类别行
                         */

                        decimal d_gclb = 0, d_gcxm = 0, d_zj = 0;

                        if (objData[gclb_row, m].ToString() != "")
                            d_gclb = Convert.ToDecimal((objData[gclb_row, m]));
                        if (objData[zj_row, m].ToString() != "")
                            d_zj = Convert.ToDecimal((objData[zj_row, m]));
                        //if (objData[gnxm_row, m].ToString() != "")
                        //    d_gnxm = Convert.ToDecimal((objData[gnxm_row, m]));
                        if (odr_sum_gclb_klwc.GetValue(i).ToString() != "")
                            d_gcxm = Convert.ToDecimal(odr_sum_gclb_klwc.GetValue(i).ToString());

                        if (d_gcxm + d_gclb != 0 || d_gcxm != 0)
                            objData[gclb_row, m] = (d_gcxm + d_gclb).ToString();
                        if (d_gcxm + d_zj != 0 && i_sfjs == 1)
                            objData[zj_row, m] = (d_gcxm + d_zj).ToString();
                        // if (d_gcxm + d_gnxm != 0)
                        //     objData[gnxm_row, m] = (d_gcxm + d_gnxm).ToString();

                        m += 3;
                        i++;
                    }
                    odr_sum_gclb_klwc.Close();

                    //同一项目列循环的本月完成
                    string sql_sum_bywc_gclbtemp = "p_sum_yb_cz_swl_dw  " + odr_gcxm.GetValue(0).ToString() + " , ‘"
                              + c_ybtime.ToString().Trim() + "‘," + c_yhjb
                              + ", 1";          //

                    OdbcDataReader odr_sum_gclb_bywc = db.getReader(sql_sum_bywc_gclbtemp);

                    odr_sum_gclb_bywc.Read();

                    m = 2;
                    i = 1;
                    while (m < control_col + 1)//同一项目列循环的开累完成
                    {
                        if (c_xmmxf.ToString() == "True")
                        {
                            objData[row_position, m] = odr_sum_gclb_bywc.GetValue(i).ToString(); //在range中的位置 (1,1)
                        }
                        /*  d_zj     总计行
                         *  d_gnxm   国内项目或海外项目行 总计值
                         *  d_gclb   工程类别行
                         */

                        decimal d_gclb = 0, d_gcxm = 0, d_zj = 0;

                        if (objData[gclb_row, m].ToString() != "")
                            d_gclb = Convert.ToDecimal((objData[gclb_row, m]));
                        if (objData[zj_row, m].ToString() != "")
                            d_zj = Convert.ToDecimal((objData[zj_row, m]));
                        // if (objData[gnxm_row, m].ToString() != "")
                        //    d_gnxm = Convert.ToDecimal((objData[gnxm_row, m]));
                        if (odr_sum_gclb_bywc.GetValue(i).ToString() != "")
                            d_gcxm = Convert.ToDecimal(odr_sum_gclb_bywc.GetValue(i).ToString());

                        if (d_gcxm + d_gclb != 0 || d_gcxm != 0)
                            objData[gclb_row, m] = (d_gcxm + d_gclb).ToString();
                        if (d_gcxm + d_zj != 0 && i_sfjs == 1)
                            objData[zj_row, m] = (d_gcxm + d_zj).ToString();
                        // if (d_gcxm + d_gnxm != 0)
                        //     objData[gnxm_row, m] = (d_gcxm + d_gnxm).ToString();

                        m += 3;
                        i++;
                    }
                    odr_sum_gclb_bywc.Close();
                    if (c_xmmxf.ToString() == "True")
                    {
                        row_position = row_position + 1;
                    }




                }  //while (odr_gcxm.Read())    //同一类别,不同项目循环     
                odr_gcxm.Close();
               // rnum = row_position;
                return objData;
               
            }   
          
          
            //设置队列中单元格字体


            //for (int i2 = 0; i2 < rnum; i2++)
            //    for (int j = 0; j < cnum; j++)
            //    {
            //        if (j == 1 || j == 0)
            //            continue;
            //        if (objData[i2, j] != null && objData[i2, j].ToString() != "")
            //            objData[i2, j] = decimal.Parse(objData[i2, j].ToString());
            //    }

            //以下处理房屋施工面积,房屋竣工面积
            //  for (int i2 = 0; i2 < rnum; i2++)
            // {
            //     objData[i2, 75] = objData[i2, 74];
            //     objData[i2, 74] = "";
            //objData[i2, 82] = objData[i2, 80];
            //objData[i2, 81] = objData[i2, 80];
            //objData[i2, 39] = objData[i2, 38];
            // objData[i2, 40] = objData[i2, 38];
            // objData[i2, 39] = Convert.ToDouble(objData[i2, 38].ToString() != "" ? objData[i2, 38].ToString() : "0") - Convert.ToDouble(objData[i2, 43].ToString() != "" ? objData[i2, 43].ToString() : "0") + Convert.ToDouble(objData[i2, 42].ToString() != "" ? objData[i2, 42].ToString() : "0");//房屋设计面积 - 开累竣工面积+本年竣工面积;
            //  if (objData[i2, 39].ToString() == "0")
            //      objData[i2, 39] = "";
            //  objData[i2, 40] = objData[i2, 38];
            //  objData[i2, 38] = "";
            //  }
            //清除3级单位的总计行,三级单位总计计算有误,而且也不需要总计
         
        bool check_is_xmgldw(string xmid, string dwid)
        {
            //if (Session["yhdw"].ToString() != dwid)
            //     return;
            bool flag = false;
            string xmmc = "";
            string fxmid = "";
            string sql1 = "select xmgldw,xmmc,id from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and  id=(select fgcid from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and id=‘" + xmid + "‘)";
            OdbcDataReader reader = db.getReader(sql1);
            while (reader.Read())
            {
                if (reader.GetValue(0).ToString() == dwid)
                    flag = true;//表明当前项目的父项目的项目管理单位是用户单位
                xmmc = reader.GetValue(1).ToString();
                fxmid = reader.GetValue(2).ToString();
            }

            reader.Close();

            if (flag)
            {
                if (!ht.Contains(fxmid))
                {
                    ht.Add(fxmid, "");
                }
                else
                {
                    return flag;
                }
                if (c_xmmxf.ToString() == "True")
                {
                   // q2.Enqueue(row_position);
                    objData[row_position, 1] = "" + xmmc;
                    gnxm_row = row_position;
                    row_position++;
                }
                string sql = "select id,xmmc from T_gcxm where (xmjd<>‘竣工‘  or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id ) or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and fgcid=(select fgcid from T_gcxm where (xmjd<>‘竣工‘ or exists(select t_xmyb.id from t_xmyb,t_fgcid_xmid where year(ybsj)=" + year + " and t_fgcid_xmid.id=  xmid  and t_fgcid_xmid.fgcid= t_gcxm.id )  or year(jgrq)>=" + c_ybtime.Substring(0, 4) + " and xmjd=‘竣工‘)and id=‘" + xmid + "‘) ";
                reader = db.getReader(sql);
                while (reader.Read())
                {
                    int i_hj;
                    i_hj = 0;
                    if (xmid == reader.GetValue(0).ToString() && dwid == c_yhdw)
                        i_hj = 1;//项目管理单位参与合计
                    fill_zxm(reader.GetValue(0).ToString(), reader.GetValue(1).ToString(), i_hj);
                }
                reader.Close();
            }


            return flag;

        }
        //填充子项目
        void fill_zxm(string xmid, string xmmc, int sfhj)
        {




            //填写项目序号
            xmxh++;
            if (c_xmmxf.ToString() == "True")
            {
                objData[row_position, 0] = xmxh;


                objData[row_position, 1] = "" + xmmc;   //项目名称
            }
            //同一项目列循环的本年完成
            //   string sql_sum_bnwc_gclbtemp = " select sum(byxmzcz),sum(sw_tsf),sum(sw_sdsjcd),sum(sw_qlsjcd),sum(sw_dzq),sum(sw_ljgs),sum(sw_tlzhxpg),sum(sw_gstl),sum(sw_tlzxpg),sum(sw_tlzl),sum(sw_tljl),sum(sw_jxhzd),sum(sw_wzgd),sum(sd_txxl) ,sum(sd_zdbs),sum(sd_dqjz),sum(sd_gdxl),sum(sd_bpds),sum(sd_jcw),sum(sd_qybds),sum(fj_fwjzmj),sum(fj_fjjgmj),sum(sw_dt),sum(sw_dtcz),sum(sw_qg),sum(sw_gl),sum(sw_gl_gs),sum(sw_gl_lm),sum(sw_gljl) " +

            //存储过程返回的是---年累产值  type=2
            //
            string sql_sum_bnwc_gclbtemp = "p_sum_yb_cz_swl_dw  " + xmid + " , ‘"
                        + c_ybtime.ToString().Trim() + "‘," + c_yhjb
                        + ", 2";          //

            OdbcDataReader odr_sum_gclb_bnwc = db.getReader(sql_sum_bnwc_gclbtemp);

            odr_sum_gclb_bnwc.Read();

            int n = 2;
            int k = 1;

            while (n < control_col)  //同一项目列循环的本年完成
            {
                if (c_xmmxf.ToString() == "True")
                {
                    objData[row_position, n + 1] = odr_sum_gclb_bnwc.GetValue(k).ToString(); //在range中的位置 (1,1)
                }
                decimal d_gclb = 0, d_gcxm = 0, d_gnxm = 0, d_zj = 0;
                if (objData[gclb_row, n + 1].ToString() != "")
                    d_gclb = Convert.ToDecimal((objData[gclb_row, n + 1]));
                if (objData[zj_row, n + 1].ToString() != "")
                    d_zj = Convert.ToDecimal((objData[zj_row, n + 1]));
                if (objData[gnxm_row, n + 1].ToString() != "")
                    d_gnxm = Convert.ToDecimal((objData[gnxm_row, n + 1]));
                if (odr_sum_gclb_bnwc.GetValue(k).ToString() != "")
                    d_gcxm = Convert.ToDecimal(odr_sum_gclb_bnwc.GetValue(k).ToString());



                if (d_gcxm + d_gclb != 0 || d_gcxm != 0)
                    objData[gclb_row, n + 1] = (d_gcxm + d_gclb).ToString();
                if ((d_gcxm + d_zj != 0 || d_gcxm != 0) && sfhj == 1)
                    objData[zj_row, n + 1] = (d_gcxm + d_zj).ToString();
                if (d_gcxm + d_gnxm != 0 || d_gcxm != 0)
                    objData[gnxm_row, n + 1] = (d_gcxm + d_gnxm).ToString();
                n += 3;
                k++;
            }
            odr_sum_gclb_bnwc.Close();
            //同一项目列循环的   开累完成
            //存储过程返回的是---开累产值  type=3
            //
            string sql_sum_klwc_gclbtemp = "p_sum_yb_cz_swl_dw  " + xmid + " , ‘"
                        + c_ybtime.ToString().Trim() + "‘," + c_yhjb
                        + ", 3";          //

            OdbcDataReader odr_sum_gclb_klwc = db.getReader(sql_sum_klwc_gclbtemp);

            odr_sum_gclb_klwc.Read();

            int m = 4;
            int i = 1;
            while (m < control_col + 1)//同一项目列循环的开累完成
            {
                if (c_xmmxf.ToString() == "True")
                {
                    objData[row_position, m] = odr_sum_gclb_klwc.GetValue(i).ToString(); //在range中的位置 (1,1)
                }
                /*  d_zj     总计行
                 *
                 */

                decimal d_gclb = 0, d_gcxm = 0, d_gnxm = 0, d_zj = 0;

                if (objData[gclb_row, m].ToString() != "")
                    d_gclb = Convert.ToDecimal((objData[gclb_row, m]));
                if (objData[zj_row, m].ToString() != "")
                    d_zj = Convert.ToDecimal((objData[zj_row, m]));
                if (objData[gnxm_row, m].ToString() != "")
                    d_gnxm = Convert.ToDecimal((objData[gnxm_row, m]));
                if (odr_sum_gclb_klwc.GetValue(i).ToString() != "")
                    d_gcxm = Convert.ToDecimal(odr_sum_gclb_klwc.GetValue(i).ToString());

                if (d_gcxm + d_gclb != 0 || d_gcxm != 0)
                    objData[gclb_row, m] = (d_gcxm + d_gclb).ToString();
                if ((d_gcxm + d_zj != 0 || d_gcxm != 0) && sfhj == 1)
                    objData[zj_row, m] = (d_gcxm + d_zj).ToString();
                if (d_gcxm + d_gnxm != 0 || d_gcxm != 0)
                    objData[gnxm_row, m] = (d_gcxm + d_gnxm).ToString();

                m += 3;
                i++;
            }
            odr_sum_gclb_klwc.Close();


            //同一项目列循环的本月完成
            string sql_sum_bywc_gclbtemp = "p_sum_yb_cz_swl_dw  " + xmid + " , ‘"
                      + c_ybtime.ToString().Trim() + "‘," + c_yhjb
                      + ", 1";          //

            OdbcDataReader odr_sum_gclb_bywc = db.getReader(sql_sum_bywc_gclbtemp);

            odr_sum_gclb_bywc.Read();

            m = 2;
            i = 1;
            while (m < control_col + 1)//同一项目列循环的开累完成
            {
                if (c_xmmxf.ToString() == "True")
                {
                    objData[row_position, m] = odr_sum_gclb_bywc.GetValue(i).ToString(); //在range中的位置 (1,1)
                }
                /*  d_zj     总计行
                 *
                 */

                decimal d_gclb = 0, d_gcxm = 0, d_gnxm = 0, d_zj = 0;

                if (objData[gclb_row, m].ToString() != "")
                    d_gclb = Convert.ToDecimal((objData[gclb_row, m]));
                if (objData[zj_row, m].ToString() != "")
                    d_zj = Convert.ToDecimal((objData[zj_row, m]));
                if (objData[gnxm_row, m].ToString() != "")
                    d_gnxm = Convert.ToDecimal((objData[gnxm_row, m]));
                if (odr_sum_gclb_bywc.GetValue(i).ToString() != "")
                    d_gcxm = Convert.ToDecimal(odr_sum_gclb_bywc.GetValue(i).ToString());

                if (d_gcxm + d_gclb != 0 || d_gcxm != 0)
                    objData[gclb_row, m] = (d_gcxm + d_gclb).ToString();
                if ((d_gcxm + d_zj != 0 || d_gcxm != 0) && sfhj == 1)
                    objData[zj_row, m] = (d_gcxm + d_zj).ToString();
                if (d_gcxm + d_gnxm != 0 || d_gcxm != 0)
                    objData[gnxm_row, m] = (d_gcxm + d_gnxm).ToString();

                m += 3;
                i++;
            }
            odr_sum_gclb_bywc.Close();
            if (c_xmmxf.ToString() == "True")
            {
                row_position = row_position + 1;
            }




        }
      
    }
    }

.NET下的并行开发(案例代码)

标签:des   style   http   color   io   os   使用   ar   for   

原文地址:http://www.cnblogs.com/wlandwl/p/3993832.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!