优化

yanjinhui

10 天以前 b330b8ff1b5315684b25afb534f74044dea1654b

 н¨Îļþ¼Ð/WIDESEA_WMSServer/ClassLibrary2/EquipmentAlarmInforService.cs

@@ -4,8 +4,10 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Security.Policy;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEA_Core;
using WIDESEA_Core.BaseRepository;
using WIDESEA_Core.BaseServices;
@@ -19,8 +21,11 @@
{
    public class EquipmentAlarmInforService : ServiceBase<Dt_EquipmentAlarmInfor, IRepository<Dt_EquipmentAlarmInfor>>, IEquipmentAlarmInforService
    {
        public EquipmentAlarmInforService(IRepository<Dt_EquipmentAlarmInfor> BaseDal) : base(BaseDal)
        private readonly IMessageInfoService _messageInfoService;

        public EquipmentAlarmInforService(IRepository<Dt_EquipmentAlarmInfor> BaseDal, IMessageInfoService messageInfoService) : base(BaseDal)
        {
            _messageInfoService = messageInfoService;
        }


@@ -33,11 +38,12 @@
        {
            try
            {
                var url = "http://172.16.1.2:8080/PORT/cube/taskInfo/getDeviceStatus";

                // è°ƒç”¨WCS接口获取设备状态
                var url = "http://172.16.1.2:8080/cube/taskInfo/getDeviceStatus?token=wH5zdAUCv2BEHJIinmowyki8cdc5ge8fAwFDcYZs0bVldNgmORt0O0l4GJTDv1dglRdMxb9xDK5Qb3NJAqL1Li2GkfdVa3KnIkfrQZtsP7UXhMmUz6xEuztG6d5svAJO9HENLb8JWVqCfpO2EWV6ebo/g5tJ9x7kbwwAxvCBrWdiEJv09FvaRQ==  ";
                var result = HttpHelper.Get(url);

                var response = JsonConvert.DeserializeObject<AGVResponse<DeviceStatusData>>(result);



                // æ£€æŸ¥æŽ¥å£å“åº”是否成功
                if (response == null || response.code != "0")
@@ -69,6 +75,10 @@
                                Creater = "System"
                            };
                            BaseDal.AddData(newRecord);
                            if(robot.status== "error")
                            {
                                _messageInfoService.AddMessageInfo(MessageGroupByEnum.EquipmentAlarm, robot.robotName,$"{ robot.robotName}发生错误", MessageStatusEnum.Emergency);
                            }
                        }
                        else
                        {
@@ -79,6 +89,10 @@
                            existingRecord.ModifyDate = syncTime;
                            existingRecord.Modifier = "System";
                            BaseDal.UpdateData(existingRecord);
                            if (robot.status == "error")
                            {
                                _messageInfoService.AddMessageInfo(MessageGroupByEnum.EquipmentAlarm, robot.robotName, $"{robot.robotName}发生错误", MessageStatusEnum.Emergency);
                            }
                        }
                        saveCount++;
                    }
@@ -105,6 +119,10 @@
                                Creater = "System"
                            };
                            BaseDal.AddData(newRecord);
                            if (sorter.status == "error")
                            {
                                _messageInfoService.AddMessageInfo(MessageGroupByEnum.EquipmentAlarm, sorter.sorterName, $"{sorter.sorterName}发生错误", MessageStatusEnum.Emergency);
                            }
                        }
                        else
                        {
@@ -115,6 +133,10 @@
                            existingRecord.ModifyDate = syncTime;
                            existingRecord.Modifier = "System";
                            BaseDal.UpdateData(existingRecord);
                            if (sorter.status == "error")
                            {
                                _messageInfoService.AddMessageInfo(MessageGroupByEnum.EquipmentAlarm, sorter.sorterName, $"{sorter.sorterName}发生错误", MessageStatusEnum.Emergency);
                            }
                        }
                        saveCount++;
                    }