蓝月亮

jt

2021-06-10 5d0d028456874576560552f5a5c4e8b801786f11

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using HH.WMS.Entitys;
using HH.WMS.Common;
using System.Data.Common;
 
namespace HH.WMS.DAL.SysMgr
{
    public class TN_WM_TASKDAL : DapperBaseDAL
    {
        #region GET
 
        public DataTable GetList(int pageIndex, int pageSize, out long total, string where = "", string orderBy = "")
        {
            string sql = @" (SELECT * FROM TN_WM_TASK " + where + ") a ";
            return ExecutePagingData(sql, pageIndex, pageSize, out total, "", "");
        }
 
        #endregion
 
 
        /// <summary>
        /// 获取正在执行中或者未执行的任务
        /// </summary>
        /// <param name="trayCode"></param>
        /// <returns></returns>
        public List<TN_WM_TASKEntity> GetTaskByTray(string trayCode)
        {
            string sql = @" SELECT * FROM TN_WM_TASK where CN_S_TRAY_CODE ='" + trayCode + "' AND CN_S_STATE IN('" + Constants.TaskState_NoExecuted + "','" + Constants.TaskState_Executing + "') ";
            return ExecuteQuery<TN_WM_TASKEntity>(sql, null);
        }
        /// <summary>
        /// 获取正在执行中或者未执行的任务
        /// </summary>
        /// <param name="trayCode"></param>
        /// <returns></returns>
        public List<TN_WM_TASKEntity> GetTaskByEndLocation(string locationCode)
        {
            string sql = @" SELECT * FROM TN_WM_TASK where CN_S_END_BIT ='" + locationCode + "' AND CN_S_STATE IN('" + Constants.TaskState_NoExecuted + "','" + Constants.TaskState_Executing + "') ";
            return ExecuteQuery<TN_WM_TASKEntity>(sql, null);
        }
 
        /// <summary>
        /// 获取任务根据任务号
        /// </summary>
        /// <param name="taskNo"></param>
        /// <returns></returns>
        public List<TN_WM_TASKEntity> GetTaskByTaskNo(string taskNo)
        {
            string sql = " SELECT * FROM TN_WM_TASK WHERE CN_S_TASK_NO='" + taskNo + "' ";
            return ExecuteQuery<TN_WM_TASKEntity>(sql, null);
        }
 
        public List<TN_WM_TASKEntity> GetTask(string sqlWhere)
        {
            string sql = " SELECT * FROM TN_WM_TASK WHERE 1=1 " + sqlWhere;
            return ExecuteQuery<TN_WM_TASKEntity>(sql, null);
        }
 
        public List<TN_WM_TASKEntity> GetTaskByAreaCode(string areaCode) 
        {
            string sql = string.Format(@" SELECT * FROM TN_WM_TASK WHERE (CN_S_START_AREA='{0}' OR CN_S_END_AREA='{0}') AND CN_S_STATE IN ('未执行','执行中','开始取货','取货完成','开始卸货','卸货完成') ", areaCode);
            return ExecuteQuery<TN_WM_TASKEntity>(sql, null);
        }
        public List<TN_WM_TASKEntity> GetTaskByAreaCodeJX(string areaCode)
        {
            string sql = string.Format(@" SELECT * FROM TN_WM_TASK WHERE  CN_S_END_AREA='{0}' AND CN_S_STATE IN ('未执行','执行中','开始取货','取货完成','开始卸货','卸货完成') ", areaCode);
            return ExecuteQuery<TN_WM_TASKEntity>(sql, null);
        }
        public List<TN_WM_TASKEntity> GetTaskByAreaCodeList(string areaCode)
        {
            string sql = string.Format(@" SELECT * FROM TN_WM_TASK WHERE (CN_S_START_AREA IN '{0}' OR CN_S_END_AREA IN '{0}') AND CN_S_STATE IN ('未执行','执行中') ", areaCode);
            return ExecuteQuery<TN_WM_TASKEntity>(sql, null);
        }
        public OperateResult UpdateState(string locationCode, string afterLocationSate, string useState, string beforeLocationState, IDbTransaction trans)
        {
            string sql = string.Format(@"UPDATE tn_wm_b_location_ext SET CN_S_LOCATION_STATE='{0}',CN_S_USE_STATE='{1}' 
                WHERE CN_S_LOCATION_CODE='{2}' AND CN_S_LOCATION_STATE='{3}' ", afterLocationSate, useState, locationCode, beforeLocationState);
            return ExecuteTranSql(sql, null, trans);
        }
        #region 计算该库区中的出入任务总和
        /// <summary>
        /// 查找该库区中即将要存放该物料的货位
        /// </summary>
        /// <param name="stockCode"></param>
        /// <param name="locationCodes"></param>
        /// <param name="opType"></param>
        /// <returns></returns>
        public long CalTaskCountByAreaCode(string areaCode)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.AppendLine(" SELECT *  FROM  TN_WM_TASK  ");
            strSql.AppendLine(" WHERE  CN_S_STATE IN ('未执行','执行中')  ");
            if (!string.IsNullOrEmpty(areaCode))
            {
                strSql.AppendLine(" AND CN_S_END_AREA = '" + areaCode + "' ");
            }
            Log.AlgorInfo("CalTaskCountByAreaCode", "sql语句为：" + strSql.ToString());
            long result = ExecuteCountSql(strSql.ToString());
            return result;
        }
        #endregion
 
    }
}