tnb.server/ProductionMgr/Tnb.ProductionMgr/PrdInstockService.cs

using JNPF;
using JNPF.Common.Core.Manager;
using JNPF.Common.Enums;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.Extras.CollectiveOAuth.Utils;
using JNPF.FriendlyException;
using JNPF.RemoteRequest;
using JNPF.Systems.Interfaces.System;
using Mapster;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using SqlSugar;
using Tnb.BasicData.Entities;
using Tnb.ProductionMgr.Entities;
using Tnb.ProductionMgr.Entities.Dto;
using Tnb.ProductionMgr.Interfaces;
using Tnb.WarehouseMgr;
using Tnb.WarehouseMgr.Entities.Dto.Inputs;
using Tnb.BasicData;

namespace Tnb.ProductionMgr
{
    /// <summary>
    /// mes生产入库申请
    /// </summary>
    [ApiDescriptionSettings(Tag = ModuleConst.Tag, Area = ModuleConst.Area, Order = 700)]
    [Route("api/[area]/[controller]/[action]")]
    public class PrdInstockService  : IPrdInstockService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<PrdInstockH> _repository;
        private readonly IUserManager _userManager;


        public PrdInstockService(
            ISqlSugarRepository<PrdInstockH> repository,
            IUserManager userManager
        )
        {
            _repository = repository;
            _userManager = userManager;
        }

        [HttpPost]
        public async Task<dynamic> SaveData(PrdInstockInput input)
        {
            var db = _repository.AsSugarClient();
            var location = await db.Queryable<BasLocation>().FirstAsync(x => x.location_code == input.location_code);
            PrdInstockH prdInstockH = null;
            DbResult<bool> result = await db.Ado.UseTranAsync(async () =>
            {
                prdInstockH = new PrdInstockH()
                {
                    bill_type = input.bill_type,
                    bill_date = DateTime.Now,
                    create_id = _userManager.UserId,
                    location_code = input.location_code,
                    carry_code = input.carry_code,
                    is_check = input.is_check,
                    org_id = _userManager.GetUserInfo().Result.organizeId,
                    warehouse_id = location?.wh_id,
                    status = 0,
                };

                List<PrdInstockD> prdInstockDs = new List<PrdInstockD>() { };
                foreach (var item in input.details)
                {
                    prdInstockDs.Add(new PrdInstockD()
                    {
                        instock_id = prdInstockH.id,
                        report_id = item.ContainsKey("report_id") ? item["report_id"] : "",
                        material_id = item.ContainsKey("material_id") ? item["material_id"] : "",
                        material_code = item.ContainsKey("material_code") ? item["material_code"] : "",
                        unit_id = item.ContainsKey("unit_id") ? item["unit_id"] : "",
                        code_batch = item.ContainsKey("batch") ? item["batch"] : "",
                        barcode = item.ContainsKey("batch") ? item["batch"]+"0001" : "",
                        quantity = Convert.ToInt32(item.ContainsKey("quantity") ? item["quantity"] : "0"),
                    });
                }

                await _repository.InsertAsync(prdInstockH);

                if (prdInstockDs.Count > 0)
                {
                    await db.Insertable<PrdInstockD>(prdInstockDs).ExecuteCommandAsync();
                }

            });

            if (result.IsSuccess)
            {
                MESCreateInstockInput mesCreateInstockInput = new MESCreateInstockInput();
                mesCreateInstockInput.instock = new MESWmsInstockHInput()
                {
                    org_id = _userManager.GetUserInfo().Result.organizeId,
                    bill_date = DateTime.Now,
                    bill_type = input.bill_type,
                    warehouse_id = location?.wh_id,
                    source_id = prdInstockH.id,
                    create_id = _userManager.UserId,
                    carry_code = input.carry_code,
                    location_code = input.location_code,
                    is_check = input.is_check,
                };
                mesCreateInstockInput.instockds = new List<MESWmsInstockDInput>();
                mesCreateInstockInput.instockcodes = new List<MESWmsInstockCodeInput>();
                foreach (var item in input.details)
                {
                    mesCreateInstockInput.instockds.Add(new MESWmsInstockDInput()
                    {
                        material_id = item.ContainsKey("material_id") ? item["material_id"] : "",
                        material_code = item.ContainsKey("material_code") ? item["material_code"] : "",
                        unit_id = item.ContainsKey("unit_id") ? item["unit_id"] : "",
                        code_batch = item.ContainsKey("batch") ? item["batch"] : "",
                        pr_qty = Convert.ToInt32(item.ContainsKey("quantity") ? item["quantity"] : "0"),
                    });
                    
                    mesCreateInstockInput.instockcodes.Add(new MESWmsInstockCodeInput()
                    {
                        material_id = item.ContainsKey("material_id") ? item["material_id"] : "",
                        material_code = item.ContainsKey("material_code") ? item["material_code"] : "",
                        unit_id = item.ContainsKey("unit_id") ? item["unit_id"] : "",
                        code_batch = item.ContainsKey("batch") ? item["batch"] : "",
                        barcode = item.ContainsKey("batch") ? item["batch"]+"0001" : "",
                        codeqty = Convert.ToInt32(item.ContainsKey("quantity") ? item["quantity"] : "0"),
                    });
                }
                string domain = (App.HttpContext.Request.IsHttps ? "https://" : "http://") + App.HttpContext.Request.Host;
                Dictionary<string, object> header = new Dictionary<string, object>()
                {
                    ["Authorization"] = App.HttpContext.Request.Headers["Authorization"]
                };
                var sendResult = HttpUtils.RequestPost(domain + WebApiConst.MES_CREATE_INSTOCK,JsonConvert.SerializeObject(mesCreateInstockInput),header);
                Console.WriteLine(sendResult);
            }
            
            if(!result.IsSuccess) throw Oops.Oh(ErrorCode.COM1008);
            return result.IsSuccess ? "保存成功" : result.ErrorMessage;
        }

        /// <summary>
        /// 入库申请同步
        /// </summary>
        /// <param name="dic">source_id</param>
        /// <returns></returns>
        public async Task<dynamic> SyncInstock(Dictionary<string, string> dic)
        {
            string sourceId = dic.ContainsKey("source_id") ? dic["source_id"] : "";
            if (!string.IsNullOrEmpty(sourceId))
            {
                return await _repository.UpdateAsync(x => new PrdInstockH()
                {
                    status = 1
                }, x => x.id == sourceId);
            }

            return false;
        }
    }
}