server/aspnetapp/Controllers/WebApi/BrokerController.cs

微信扫码关注公众号，代码整理好后第一时间通知你。

using aspnetapp.Models;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;

// For more information on enabling Web API for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860

namespace aspnetapp.Controllers.WebApi
{
    [Route("api/[controller]")]
    [ApiController]
    public class BrokerController : ControllerBase
    {
        private readonly CounterContext _context;

        public BrokerController(CounterContext context)
        {
            _context = context;
        }
        public class BrokerResponse
        {
            public List<string>? wxids { get; set; }
            public List<string>? names { get; set; }
        }


        private async Task<BrokerResponse> getBroker(string wxid)
        {
            BuyrUserEntity? thisu = await _context.BuyrUsers.FirstOrDefaultAsync(s => s.WeChatOpenid == wxid).ConfigureAwait(false);
            if (thisu == null)
            {
                return new BrokerResponse();
            }
            List<BuyrUserEntity>? allagent = new List<BuyrUserEntity>() { new BuyrUserEntity() { Name = thisu.Name, WeChatOpenid = thisu.WeChatOpenid } };
            allagent.AddRange(await (from r in _context.RU2Users.AsNoTracking()
                                     join u in _context.BuyrUsers.AsNoTracking() on r.U2UserId equals u.Id
                                     where r.UserId == thisu.Id
                                     select u).ToListAsync().ConfigureAwait(false));

            return new BrokerResponse() { names = allagent.Select(s => s.Name).ToList(), wxids = allagent.Select(s => s.WeChatOpenid).ToList() };
        }


        // GET: api/<BrokerController>
        [HttpGet]
        public async Task<ActionResult<BrokerResponse>> Get(string wxid)
        {
            var analyse = await getBroker(wxid);
            return analyse;
        }
    }
}