zhywebcore/EC.App/EC.App/AutoWeight/Truck/TruckService.cs

using Dapper;
using learun.application;
using learun.util;
using System.Collections.Generic;
using System.Data;
using System.Text;
using System.Threading.Tasks;
using Newtonsoft.Json.Linq;

namespace EC.App.AutoWeight.Truck
{
	/// <summary>
	/// 汽车衡
	/// Copyright (c) 2019-present 汽车衡
	/// 创建人：lxc
	/// 日 期： 2020-11-06 11:31:36
	/// 描 述： 运单 aw_truck
	/// </summary>
	public class TruckService : ServiceBase
	{
		private readonly string _fieldSql;

		public TruckService()
		{
			_fieldSql = @"t.Id,
					t.SupplierId, t.SupplierName,
					t.LicensePlate,
					t.IsWork, t.Remark, 
					t.CreateMan, t.CreateTime, t.UpdateMan, t.UpdateTime";
		}

		#region 获取数据

		/// <summary>
		/// 获取主表aw_truck的实体
		/// </summary>
		/// <param name="keyValue">主键</param>
		/// <returns></returns>
		public Task<TruckEntity> GetEntity(string keyValue)
		{
			return BaseRepository().FindEntityByKey<TruckEntity>(keyValue);
		}

		/// <summary>
		/// 获取主表aw_truck的实体
		/// </summary>
		/// <param name="param">参数</param>
		/// <returns></returns>
		public Task<TruckEntity> GetEntity(object param)
		{
			return BaseRepository().FindEntity<TruckEntity>(param);
		}

		public Task<IEnumerable<TruckEntity>> GetList()
		{
			var strSql = new StringBuilder();
			strSql.Append($"SELECT {_fieldSql} FROM aw_truck t WHERE 1=1");
			return BaseRepository().FindList<TruckEntity>(strSql.ToString());
		}

		public Task<IEnumerable<TruckEntity>> GetListByKey(string key, string value, int type = 0)
		{
			var strSql = new StringBuilder();
			var ver = type == 0 ? "=" : "like";
			strSql.Append($"SELECT {_fieldSql} FROM aw_truck t WHERE 1=1");
			strSql.Append($" AND {key} {ver} '{value}'");
			return BaseRepository().FindList<TruckEntity>(strSql.ToString());
		}

		/// <summary>
		/// 获取主表aw_truck的所有列表数据
		/// </summary>
		/// <param name="queryJson">查询参数,json字串</param>
		/// <returns></returns>
		public Task<IEnumerable<TruckEntity>> GetList(string queryJson)
		{
			var strSql = new StringBuilder();
			var queryParam = queryJson.ToJObject();
			var dp = new DynamicParameters(new { });

			strSql.Append($"SELECT {_fieldSql} FROM aw_truck t WHERE 1=1");
			// LicensePlate
			if (!queryParam["LicensePlate"].IsEmpty())
			{
				dp.Add("LicensePlate", $"%{queryParam["LicensePlate"]}%", DbType.String);
				strSql.Append(" AND (LicensePlate like @LicensePlate)");
			}
			// 操作时间
			if (!queryParam["StartTime"].IsEmpty() && !queryParam["EndTime"].IsEmpty())
			{
				dp.Add("startTime", queryParam["StartTime"].ToDate(), DbType.DateTime);
				dp.Add("endTime", queryParam["EndTime"].ToDate(), DbType.DateTime);
				strSql.Append(" AND (CreateTime >= @startTime AND CreateTime <= @endTime)");
			}

			return BaseRepository().FindList<TruckEntity>(strSql.ToString(), dp);
		}

		/// <summary>
		/// 获取主表aw_truck的分页列表数据
		/// </summary>
		/// <param name="pagination">分页参数</param>
		/// <param name="queryParam">查询参数,json字串</param>
		/// <returns></returns>
		public Task<IEnumerable<TruckEntity>> GetPageList(Pagination pagination, JObject queryParam)
		{
			var strSql = new StringBuilder();
			var dp = new DynamicParameters(new { });
			strSql.Append($"SELECT {_fieldSql} FROM aw_truck t WHERE 1=1");

			dp.Add("SupplierId", queryParam["SupplierId"], DbType.String);
			strSql.Append(" AND SupplierId = @SupplierId");
			// 关键字
			if (!queryParam["Keyword"].IsEmpty())
			{
				dp.Add("Keyword", $"%{queryParam["Keyword"]}%", DbType.String);
				strSql.Append(" AND (LicensePlate like @Keyword)");
			}
			// 操作时间
			if (!queryParam["StartTime"].IsEmpty() && !queryParam["EndTime"].IsEmpty())
			{
				dp.Add("startTime", queryParam["StartTime"].ToDate(), DbType.DateTime);
				dp.Add("endTime", queryParam["EndTime"].ToDate(), DbType.DateTime);
				strSql.Append(" AND (CreateTime >= @startTime AND CreateTime <= @endTime)");
			}

			return BaseRepository().FindList<TruckEntity>(strSql.ToString(), dp, pagination);
		}

		#endregion 获取数据

		#region 提交数据

		/// <summary>
		/// 删除
		/// </summary>
		/// <param name="keyValue">主表主键</param>
		public async Task<int> Delete(string keyValue)
		{
			return await BaseRepository().DeleteAny<TruckEntity>(new { Id = keyValue });
		}

		/// <summary>
		/// 新增
		/// </summary>
		/// <param name="entity">aw_truck实体数据</param>
		/// <returns></returns>
		public async Task<int> Insert(TruckEntity entity)
		{
			return await BaseRepository().Insert(entity);
		}

		/// <summary>
		/// 新增
		/// </summary>
		/// <param name="entity">aw_truck实体数据</param>
		/// <returns></returns>
		public async Task<int> Update(TruckEntity entity)
		{
			return await BaseRepository().Update(entity);
		}

		#endregion 提交数据
	}
}