| | |
| | | return res; |
| | | }*/ |
| | | |
| | | internal static bool AddCntr(string cntrCode ,int detallCount = 1) |
| | | internal static bool AddCntr(string cntrCode ,int detallCount = 0) |
| | | { |
| | | var res = false; |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | var TN_Container = new Container { S_CODE = cntrCode ,N_DETAIL_COUNT = detallCount }; |
| | | try |
| | | { |
| | | db.BeginTran(); |
| | | var container = db.Queryable<Container>().Where(a => a.S_CODE.Trim() == cntrCode).First(); |
| | | if (container == null) |
| | | { |
| | | db.Insertable<Container>(TN_Container).ExecuteCommand(); |
| | | res = db.Insertable<Container>(TN_Container).ExecuteCommand() > 0; |
| | | } |
| | | else |
| | | { |
| | | container.N_DETAIL_COUNT = detallCount; |
| | | container.N_E_STATE = 0; |
| | | db.Updateable(container).ExecuteCommand(); |
| | | } |
| | | db.CommitTran(); |
| | | res = true; |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | db.RollbackTran(); |
| | | WMSHelper.addAlarmRecord("系统错误", "高", $"添加容器错误,错误原因:{ex.Message}"); |
| | | throw new BusinessException($"添加容器错误,错误原因:{ex.Message}"); |
| | | } |
| | |
| | | /// |
| | | /// </summary> |
| | | /// <param name="cntrCode"></param> |
| | | /// <param name="state">托盘异常状态 0.默认 1.WCS读码异常 2.AGV读码器读码异常</param> |
| | | /// <param name="errMsg">异常信息</param> |
| | | /// <param name="state">托盘异常状态 0.正常 1.异常</param> |
| | | /// <returns></returns> |
| | | internal static bool UpdateCntrState(string cntrCode, int state ,string errMsg) { |
| | | internal static bool UpdateCntrState(string cntrCode, int state) { |
| | | var res = false; |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | var models = db.Queryable<Container>().Where(a => a.S_CODE.Trim() == cntrCode).ToList(); |
| | | if (models.Count > 0) { |
| | | models.ForEach(a => { |
| | | a.N_E_STATE = state; |
| | | a.S_ERR_DESC = errMsg; |
| | | db.Updateable(a).UpdateColumns(it => new { it.N_E_STATE,it.S_ERR_DESC }).ExecuteCommand(); |
| | | }); |
| | | res = true; |