JLH/JLHHJSvr/Excutor/SetSysUserFileStringExcutor.cs

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Diagnostics;
using System.IO;
using System.IO.Compression;
using System.Linq;
using System.Text;
using JLHHJSvr;
using JLHHJSvr.BLL;
using JLHHJSvr.Com;
using JLHHJSvr.DBA.DBModle;
using JLHHJSvr.Helper;
using LJLib.Net.SPI.Server;
using LJLib.SQLEX;
using PhoneUI.BLL.L1BLL;

namespace JLHHJSvr.Excutor
{
    internal sealed class SetSysUserFileStringExcutor : ExcutorBase<SetSysUserFileStringRequest, SetSysUserFileStringResponse>
    {
        protected override void ExcuteInternal(SetSysUserFileStringRequest request, object state, SetSysUserFileStringResponse rslt)
        {
            if (request.empid == null)
            {
                rslt.ErrMsg = "参数错误,empid不能为null";
                return;
            }

            if (request.dwname == null)
            {
                rslt.ErrMsg = "参数错误,dwname不能为null";
                return;
            }

            if (request.itemname == null)
            {
                rslt.ErrMsg = "参数错误,itemname不能为null";
                return;
            }

            if (request.itemvalue == null)
            {
                rslt.ErrMsg = "参数错误,itemvalue不能为null";
                return;
            }


            var tokendata = BllHelper.GetToken(request.token);
            if (tokendata == null)
            {
                rslt.ErrMsg = "会话已经中断";
                return;
            }
            //if (string.IsNullOrEmpty(tokendata.ConStr))
            //{
            //    rslt.ErrMsg = "当前账套未设置数据库";
            //    return;
            //}

            using (var con = GlobalVar.ConnectionString.NewSqlConnection())
            using (var cmd = con.CreateCommand())
            {
                con.Open();
                using (cmd.Transaction = con.BeginTransaction())
                {
                    try
                    {
                        //var ufs = HelperBase.GetHelper<SysUserFileString>(cmd);

                        //var ifok = BllHelper.SetValue(cmd, request.empid.Value, request.dwname, request.itemname, request.itemvalue, request.ifcompress == 1 ? true : false);
                        //if (!ifok)
                        //{
                        //    rslt.ErrMsg = "自定义值保存失败,可能数据库字段长度不足";
                        //}
                        //if (request.empid == -1)
                        //{
                        //    BllHelper.delOtherLayout(cmd, request.dwname, request.itemname);
                        //}

                        var ufs = HelperBase.GetHelper<SysUserFileString>(cmd);

                        var ifok = ufs.SetValue(request.empid.Value, request.dwname, request.itemname, request.itemvalue, request.ifcompress == 1 ? true : false);
                        if (!ifok)
                        {
                            rslt.ErrMsg = "自定义值保存失败,可能数据库字段长度不足";
                            return;
                        }
                        if (request.ifdelother == 1)
                        {
                            ufs.delOtherLayout(request.dwname, request.itemname);
                        }
                        if (request.iffilesave != null && request.iffilesave.Value == 1)
                        {
                            ufs.saveSystemLayout(request.itemname, request.itemvalue);

                            // 记录操作日志
                            LogHelper logHelper = HelperBase.GetHelper<LogHelper>(cmd);
                            var logType = "L1WEB操作日志";
                            var logDscrp = "设置默认布局:ifdelother:" + request.ifdelother + ",itemname:" + request.itemname + ",itemvalue:" + request.itemvalue;
                            var opEmp = tokendata.username;
                            logHelper.SetSysoplog(logType, logDscrp, opEmp);
                        }

                        if (request.empid != null && request.empid.Value != -1)
                        {
                            // 记录操作日志
                            LogHelper logHelper = HelperBase.GetHelper<LogHelper>(cmd);
                            var logType = "个性布局操作日志";
                            var logDscrp = "empid:" + request.empid + ",dwname:" + request.dwname + ",itemname:" + request.itemname + ",itemvalue:" + request.itemvalue + " >>>>> UPDATE sys_user_filestring SET itemvalue = '" + request.itemvalue + "' WHERE empid = " + request.empid + " AND dwname = '" + request.dwname + "' AND itemname = '" + request.itemname + "'";
                            var opEmp = tokendata.username;
                            logHelper.SetSysoplog(logType, logDscrp, opEmp);
                        }

                        cmd.Transaction.Commit();
                    }
                    catch (Exception e)
                    {
                        cmd.Transaction.Rollback();
                        rslt.ErrMsg = e.ToString();
                    }
                }

            }
        }
    }
}