U8API/UFIDA.U8.Framework.Api.ControlObject/ST/USERPCO.cs

using log4net;
using MSXML2;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using UFIDA.U8.Framework.Api.ControlObject.Common;
using UFIDA.U8.Framework.Api.ControlObject.Entity;
using UFIDA.U8.Framework.Api.ControlObject.Json;
using UFIDA.U8.Framework.Api.ControlObject.U8M;

namespace UFIDA.U8.Framework.Api.ControlObject.ST
{
    /// <summary>
    /// 库存管理
    /// </summary>
    public class USERPCO
    {
        protected readonly ILog logInfo = LogManager.GetLogger("logInfo");


        public async Task<BaseResult<string>> Insert(BaseLogin baseLogin, Dictionary<string, object> dictionary,string sVouchType,bool bGetCode=false,string codeKey="",bool bCheck=true,bool bBeforCheckStock=true,bool bIsRedVouch=false,string sAddedState="", bool bReMote=false)
        {
            try
            {
                var co = "USERPCO.VoucherCO".GetComObject();

                var errorMsg = "";

                if (!co.IniLogin(baseLogin._vbLogin, ref errorMsg))
                {
                    await Task.Delay(1);
                    throw new Exception(errorMsg);
                }

                var domHead = dictionary.ToDocument2();

                if (!dictionary.TryGetValue("body", out var bodys))
                {
                    await Task.Delay(1);
                    throw new Exception("无法获取表体数据");
                }

                if (!(bodys is List<Dictionary<string, object>> dictionarys) || dictionarys.Count <= 0)
                {
                    await Task.Delay(1);
                    throw new Exception("无法获取表体数据");
                }

                if (bGetCode && !string.IsNullOrWhiteSpace(codeKey))
                {
                    errorMsg = "";
                    var newCode = co.GetNewVouchCode(sVouchType, domHead, ref errorMsg);

                    logInfo.Debug($"获取新单号:{newCode}");

                    if (!string.IsNullOrWhiteSpace(newCode))
                    {
                        object value = CommonHelper.SetDomKeyValue(domHead, codeKey, newCode);
                    }
                }


                var domBody = dictionarys.ToDocument2();
                IXMLDOMDocument2 domPosition = new DOMDocument();
                IXMLDOMDocument2 domMsg = new DOMDocument();
                errorMsg = "";
                baseLogin.Connection.BeginTrans();
                var vouchId = "";

                var res = new BaseResult<string>();
                try
                {
                    res.bSuccess = co.Insert(sVouchType, domHead, domBody, domPosition, ref errorMsg, baseLogin.Connection, ref vouchId, ref domMsg, bCheck, bBeforCheckStock, bIsRedVouch, sAddedState, bReMote);
                }
                catch (Exception ex)
                {
                    await Task.Delay(1);
                    baseLogin.Connection.RollbackTrans();
                    throw ex;
                }

                baseLogin.Connection.CommitTrans();

                if (!res.bSuccess)
                {
                    res.message = "新增失败";
                    res.result = errorMsg;
                }
                else
                {
                    res.message = "新增成功";
                    res.result = vouchId;
                }

                return res;

                //var bodys = dictionary.TryGetValue() dictionary["body"];


            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<string> { bSuccess = false, message = "新增失败", result = ex.Message };
            }
            
        }

        public async Task<BaseResult<string>> Update(BaseLogin baseLogin, Dictionary<string, object> dictionary, string sCardNum , string sVouchType,
            bool bCheck = true, bool bBeforCheckStock = true, bool bIsRedVouch = false, string sAddedState = "",
            bool bUpdateNeedEas = true)
        {
            try
            {
                var co = "USERPCO.VoucherCO".GetComObject();

                var errorMsg = "";

                if (!co.IniLogin(baseLogin._vbLogin, ref errorMsg))
                {
                    await Task.Delay(1);
                    throw new Exception(errorMsg);
                }

                IXMLDOMDocument2 domHead = new DOMDocument();
                IXMLDOMDocument2 domBody = new DOMDocument();
                IXMLDOMDocument2 domPosition = new DOMDocument();
                errorMsg = "";
                if (!co.GetDefaultVoucherDom(sVouchType, sCardNum, ref domHead, ref domBody, ref domPosition, ref errorMsg))
                {
                    throw new Exception(errorMsg);
                }

                domHead = dictionary.ToDocument2(domHead);

                var bodys = dictionary["body"] as List<Dictionary<string, object>> ?? $"{dictionary["body"]}".ToObject<List<Dictionary<string, object>>>();

                if (bodys==null || bodys.Count<=0)
                {
                    await Task.Delay(1);
                    throw new Exception("无法获取表体数据");
                }
                
                //if (!(bodys is List<Dictionary<string, object>> dictionarys) || dictionarys.Count <= 0)
                //{

                //    await Task.Delay(1);
                //    throw new Exception("无法获取表体数据");
                //}


                domBody = bodys.ToDocument2(domBody);
               
                IXMLDOMDocument2 domMsg = new DOMDocument();

                errorMsg = "";
                baseLogin.Connection.BeginTrans();
                var vouchId = "";

                var res = new BaseResult<string>();
                try
                {
                    res.bSuccess = co.Update(sVouchType, domHead, domBody, domPosition);
                }
                catch (Exception ex)
                {
                    baseLogin.Connection.RollbackTrans();
                    throw ex;
                }

                if (!res.bSuccess)
                {
                    baseLogin.Connection.RollbackTrans();
                    res.message = "新增失败";
                    res.result = errorMsg;
                }
                else
                {
                    baseLogin.Connection.CommitTrans();
                    res.message = "新增成功";
                    res.result = vouchId;
                }

                return res;

                //var bodys = dictionary.TryGetValue() dictionary["body"];


            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<string> { bSuccess = false, message = "新增失败", result = ex.Message };
            }
        }
    }
}