From 1488a0ef2d2f523f5aeac8c439ed9ba3ae2ee1d0 Mon Sep 17 00:00:00 2001 From: ky_yusj <2655568377@qq.com> Date: Wed, 2 Jun 2021 09:28:09 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E4=BB=BB=E5=8A=A1=E5=88=97=E8=A1=A8?= =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=BA=BA=E5=91=98=E4=BA=BA=E5=85=83userid?= =?UTF-8?q?=E8=BF=87=E6=BB=A4=E6=9D=A1=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../HouseSafety/HouseTask/HouseTaskService.cs | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/Api/Ewide.Application/Service/HouseSafety/HouseTask/HouseTaskService.cs b/Api/Ewide.Application/Service/HouseSafety/HouseTask/HouseTaskService.cs index 3dd4d7c..2d5058e 100644 --- a/Api/Ewide.Application/Service/HouseSafety/HouseTask/HouseTaskService.cs +++ b/Api/Ewide.Application/Service/HouseSafety/HouseTask/HouseTaskService.cs @@ -1,8 +1,10 @@ using Dapper; +using Ewide.Core; using Ewide.Core.Extension; using Furion.DatabaseAccessor; using Furion.DependencyInjection; using Furion.DynamicApiController; +using Furion.FriendlyException; using Microsoft.AspNetCore.Mvc; using System; using System.Collections.Generic; @@ -21,11 +23,13 @@ namespace Ewide.Application.Service { private readonly IRepository _houseTaskRep; private readonly IDapperRepository _dapperRepository; + private readonly IUserManager _userManager; - public HouseTaskService(IRepository HouseTaskRep, IDapperRepository dapperRepository) + public HouseTaskService(IRepository HouseTaskRep, IDapperRepository dapperRepository, IUserManager userManager) { _houseTaskRep = HouseTaskRep; _dapperRepository = dapperRepository; + _userManager = userManager; } [HttpPost("/houseTask/page")] @@ -37,10 +41,14 @@ LEFT JOIN bs_house_info HI ON HI.HouseCodeId = T.HouseCodeId LEFT JOIN bs_house_projectinfo Proj ON Proj.Id=HC.ProjectId LEFT JOIN sys_area_code CA ON CA.Code = Proj.AreaCode LEFT JOIN sys_area_code RA ON RA.AdCode = SUBSTR(CA.AdCode,1,9) -LEFT JOIN sys_area_code AA ON AA.AdCode = SUBSTR(CA.AdCode,1,6)"; - return await _dapperRepository.QueryPageDataDynamic(sql, input, filterFields: new string[] { "Type", "Address", "HouseCode" }); +LEFT JOIN sys_area_code AA ON AA.AdCode = SUBSTR(CA.AdCode,1,6) +WHERE T.UserID=@UserID"; + var user = await _userManager.CheckUserAsync(); + if (user == null) throw Oops.Oh("登录信息丢失"); + var param = new DynamicParameters(); + param.Add("UserID", user.Id); + return await _dapperRepository.QueryPageDataDynamic(sql, input, param, filterFields: new string[] { "Type", "Address", "HouseCode" }); } - } }