JLH/JLHHJSvr/Excutor/RefreshMattressInterfaceExcutor.cs

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

namespace JLHHJSvr.Excutor
{
    internal sealed class RefreshMattressInterfaceExcutor : ExcutorBase<RefreshMattressInterfaceRequest, RefreshMattressInterfaceResponse>
    {
        protected override void ExcuteInternal(RefreshMattressInterfaceRequest request, object state, RefreshMattressInterfaceResponse rslt)
        {
            var tokendata = BllHelper.GetToken(request.token);
            if (tokendata == null)
            {
                rslt.ErrMsg = "会话已经中断，请重新登录";
                return;
            }
            if (request.mattressid == null || request.mattressid <= 0)
            {
                rslt.ErrMsg = "床垫id有误,请检查!";
                return;
            }

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

                var copy_list = new List<u_mattress_interface>();

                var selectStr = @"SELECT mattressid
	                            ,printid
	                            ,itemname
	                            ,bj_pzname
	                            ,bj_namemx
	                            ,actual_size
	                            ,sb_craft
	                            ,actual_size_sb
	                            ,erp_pzid
	                            ,ss_rate
	                            ,ls_rate
	                            ,bj_inputtype
                            FROM u_mattress_interface";
                DbSqlHelper.SelectJoin(cmd, selectStr, "mattressid = @mattressid", new Dictionary<string, object>() { { "@mattressid", request.mattressid } }, "printid", "mattressid,printid,itemname,bj_pzname,bj_namemx,actual_size,sb_craft,actual_size_sb,erp_pzid,ss_rate,ls_rate,bj_inputtype", 0, 0, copy_list);

                using (var erp_con = new SqlConnection(BllHelper.GetERPConnectString(cmd)))
                using (var erp_cmd = erp_con.CreateCommand())
                {
                    erp_con.Open();

                    var interfaceHelper = HelperBase.GetHelper<InterfaceHelper>(cmd,erp_cmd, new HelperBase.Context() { tokendata = tokendata });

                    var interfaceList = interfaceHelper.RefreshMattressInterfaceList(request.mattressid.Value);

                    if(request.isPz != null && request.isPz == 1)
                    {
                        var copyDict = copy_list.Where(mx2 => mx2.erp_pzid > 0)
                                    .ToDictionary(mx2 => mx2.erp_pzid, mx2 => mx2);

                        foreach (var mx in interfaceList)
                        {
                            if (mx.erp_pzid > 0 && copyDict.TryGetValue(mx.erp_pzid, out var mx2))
                            {
                                if (mx.bj_inputtype != 2 || (mx.bj_inputtype == 2 && mx2.bj_inputtype == 1))
                                {
                                    mx.bj_namemx = mx2.bj_namemx;
                                    mx.actual_size = mx2.actual_size;
                                    mx.sb_craft = mx2.sb_craft;
                                    mx.actual_size_sb = mx2.actual_size_sb;
                                    mx.ss_rate = mx2.ss_rate;
                                    mx.ls_rate = mx2.ls_rate;

                                    if (mx.bj_inputtype == 2 && mx2.bj_inputtype == 1)
                                    {
                                        mx.bj_inputtype = 1;
                                    }
                                }
                                else
                                {
                                    mx.actual_size = mx2.actual_size;
                                    mx.sb_craft = mx2.sb_craft;
                                    mx.actual_size_sb = mx2.actual_size_sb;
                                    mx.ss_rate = mx2.ss_rate;
                                    mx.ls_rate = mx2.ls_rate;
                                }
                            }
                        }
                    }

                    rslt.mxList = interfaceList;
                }
            }
        }
    }
}