JLH/JLHHJSvr/Excutor/UpdateL1BasicinfoExcutor.cs

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using JLHHJSvr.BLL;
using JLHHJSvr.Com;
using JLHHJSvr.Com.Model;
using JLHHJSvr.Helper;
using LJLib.DAL.SQL;
using LJLib.Net.SPI.Server;
using Newtonsoft.Json.Linq;

namespace JLHHJSvr.Excutor
{
    internal sealed class UpdateL1BasicinfoExcutor : ExcutorBase<UpdateL1BasicinfoRequest, UpdateL1BasicinfoResponse>
    {
        Dictionary<string, object> replacements = new Dictionary<string, object>();

        protected override void ExcuteInternal(UpdateL1BasicinfoRequest request, object state, UpdateL1BasicinfoResponse rslt)
        {
            var tokendata = BllHelper.GetToken(request.token);
            if (tokendata == null)
            {
                rslt.ErrMsg = "会话已经中断，请重新登录";
                return;
            }

            using (var con = new SqlConnection(GlobalVar.ConnectionString))
            using (var cmd = con.CreateCommand())
            {
                con.Open();


                var maxMtrlModdate = (DateTime?)null;

                cmd.CommandText = @"
                    SELECT MAX(MaxAmount) AS moddate
                    FROM (
                        SELECT MAX(moddate) AS MaxAmount
                        FROM u_mtrldef
                        UNION ALL
                        SELECT MAX(opdate)
                        FROM u_mtrldef
                    ) AS SubQuery;
                ";
                cmd.Parameters.Clear();
                using (var reader = cmd.ExecuteReader())
                {
                    if (reader.Read())
                    {
                        maxMtrlModdate = Convert.ToDateTime(reader["moddate"]);
                    }
                }

                var mtrldefList = new List<erp_mtrldef>();

                var erpHelper = HelperBase.GetHelper<ERPHelper>(null);

                var parameters = new JObject();
                parameters.Add("moddate", JToken.FromObject(maxMtrlModdate));
                parameters.Add("pageindex", JToken.FromObject(0));
                parameters.Add("pagesize", JToken.FromObject(0));

                mtrldefList = erpHelper.GetERPList<erp_mtrldef>("GetL1Mtrldef", parameters);


            }
        }

    }
}