同步代码

陈勇

2 天以前 6b74e1dcf5642c8f56975471e27780d695953989

 ÏîÄ¿´úÂë/WMS/WMSServer/WIDESEA_StorageBasicServices/Stock/VV_MesLockInfoService.cs

@@ -7,15 +7,22 @@
using System.Linq.Expressions;
using WIDESEA_Core;
using WIDESEA_DTO.Basic;
using WIDESEA_IStoragIntegrationServices;

namespace WIDESEA_StorageBasicService;

public class VV_MesLockInfoService : ServiceBase<VV_MesLockInfo, IVV_MesLockInfoRepository>, IVV_MesLockInfoService
{
    private readonly IVV_StockInfoRepository _stockInfoRepository;
    public VV_MesLockInfoService(IVV_MesLockInfoRepository BaseDal, IVV_StockInfoRepository stockInfoRepository) : base(BaseDal)
    private readonly IDt_MESLockInfoRepository _MESLockInfoRepository;
    private readonly IDt_CarBodyInfoRepository _carBodyInfoRepository;
    private readonly IMESService _MESService;
    public VV_MesLockInfoService(IVV_MesLockInfoRepository BaseDal, IVV_StockInfoRepository stockInfoRepository, IDt_MESLockInfoRepository MESLockInfoRepository, IDt_CarBodyInfoRepository carBodyInfoRepository, IMESService MESService) : base(BaseDal)
    {
        _stockInfoRepository = stockInfoRepository;
        _MESLockInfoRepository = MESLockInfoRepository;
        _carBodyInfoRepository = carBodyInfoRepository;
        _MESService = MESService;
    }

    public WebResponseContent GetMesLockInfo()
@@ -46,7 +53,6 @@
                    carBodyCharacteristic = x.carBodyCharacteristic
                });
            });

            return content.OK(data: mesLockDTOs);
        }
        catch (Exception ex)
@@ -69,4 +75,81 @@
            return content.Error(ex.Message);
        }
    }

    public WebResponseContent MesLock(object[] keys)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            List<Dt_CarBodyInfo> bodyInfos = new List<Dt_CarBodyInfo>();
            List<Dt_MESLockInfo> lockinfo = new List<Dt_MESLockInfo>();
            foreach (var item in keys)
            {

            }

            if (!bodyInfos.Any()) throw new Exception("锁车上报失败:无锁车数据");

            var mesLock = _MESLockInfoRepository.QueryFirst(x => x.Id == Convert.ToInt32(keys));
            mesLock.LockStatue = 3; //异常锁车
            var carInfo = _carBodyInfoRepository.QueryFirst(x => x.Id == mesLock.carBodyID);
            if (carInfo != null)
            {
                bodyInfos.Add(carInfo);
                lockinfo.Add(mesLock);
            }

            WebResponseContent webResponse = _MESService.LockRequest(carInfo, 1);
            if (webResponse.Status)
            {
                _MESLockInfoRepository.UpdateData(lockinfo);
                content.OK();
            }
            else
            {
                content.Error();
            }
        }
        catch (Exception ex)
        {
            content.Error(ex.Message);
        }
        return content;
    }

    public WebResponseContent MesUnLock(object[] keys)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            List<Dt_CarBodyInfo> bodyInfos = new List<Dt_CarBodyInfo>();
            foreach (var item in keys)
            {

            }

            if (!bodyInfos.Any()) throw new Exception("锁车上报失败:无锁车数据");

            var mesLock = _MESLockInfoRepository.QueryFirst(x => x.Id == Convert.ToInt32(keys));

            var carInfo = _carBodyInfoRepository.QueryFirst(x => x.Id == mesLock.carBodyID);
            if (carInfo != null) bodyInfos.Add(carInfo);

            WebResponseContent webResponse = _MESService.LockRequest(carInfo, 1);
            if (webResponse.Status)
            {
                content.OK();
            }
            else
            {
                content.Error();
            }
        }
        catch (Exception ex)
        {
            content.Error(ex.Message);
        }
        return content;
    }

}