package com.ydtech.modules.admin.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ydtech.modules.admin.dao.SysUserZgdMapper;
import com.ydtech.modules.admin.dao.SysUserZzbMapper;
import com.ydtech.modules.admin.model.dto.SysUserLinkQueryUserDto;
import com.ydtech.modules.admin.model.dto.SysUserLinkUserDto;
import com.ydtech.modules.admin.model.dto.SysUserLinkZzbUserIdDto;
import com.ydtech.modules.admin.model.po.SysUserLinkZgdUserId;
import com.ydtech.modules.admin.model.po.SysUserZzbOrZgd;
import com.ydtech.modules.admin.model.vo.SysUserLinkZzbUserIdVo;
import com.ydtech.modules.admin.service.SysUserLinkZgdUserIdService;
import com.ydtech.modules.admin.dao.SysUserLinkZgdUserIdMapper;
import com.ydtech.modules.admin.service.SysUserZgdService;
import com.ydtech.modules.base.controller.BaseController;
import com.ydtech.modules.order.entity.BasePageResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
* @author Administrator
* @description 针对表【sys_user(用户信息表)】的数据库操作Service实现
* @createDate 2024-09-06 18:13:19
*/
@Service
public class SysUserLinkZgdUserIdServiceImpl   extends ServiceImpl<SysUserLinkZgdUserIdMapper, SysUserLinkZgdUserId>
        implements SysUserLinkZgdUserIdService {


    @Autowired
    private SysUserZgdService sysUserZgdService;

    @Autowired
    private  SysUserLinkZgdUserIdMapper  sysUserLinkZgdUserIdMapper;

    @Autowired
    private SysUserZgdMapper sysUserZgdMapper;

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/6 19:47
     *  @Description:  添加掌柜鼎的绑定的用户id
     */
    @Override
    public void addOrUpdate(SysUserLinkZzbUserIdVo sysUserLinkZzbUserIdVo) {
        LambdaQueryWrapper<SysUserLinkZgdUserId> lqw = new LambdaQueryWrapper<>();
        lqw.eq( SysUserLinkZgdUserId::getUserId, sysUserLinkZzbUserIdVo.getUserId());
        SysUserLinkZgdUserId one = this.getOne(lqw);
        if(one!=null){
            one.setZgdUserId(sysUserLinkZzbUserIdVo.getLinkUserId());
            one.setCreateTime(new Date());
            one.setCreateUserId(new BaseController().getUserId());
            this.updateById(one);
        }else{
            SysUserLinkZgdUserId sysUserLinkZgdUserId =new SysUserLinkZgdUserId(null,sysUserLinkZzbUserIdVo.getUserId(), sysUserLinkZzbUserIdVo.getLinkUserId(), new Date(), new BaseController().getUserId());
            this.save(sysUserLinkZgdUserId);
        }
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/6 19:46
     *  @Description: 通过用户id删除数据
     */
    @Override
    public void deleteByUserId(SysUserLinkZzbUserIdVo sysUserLinkZzbUserIdVo) {
        LambdaQueryWrapper<SysUserLinkZgdUserId> lqw = new LambdaQueryWrapper<>();
        lqw.eq( SysUserLinkZgdUserId::getUserId, sysUserLinkZzbUserIdVo.getUserId());
        int rows = this.baseMapper.delete(lqw);
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/9 8:53
     *  @Description:  通过用户id查询用户数据
     */
    @Override
    public SysUserLinkZzbUserIdDto queryData(String userId) {

        LambdaQueryWrapper<SysUserLinkZgdUserId> lqw = new LambdaQueryWrapper<>();
        lqw.eq( SysUserLinkZgdUserId::getUserId, userId);
        SysUserLinkZgdUserId one = this.getOne(lqw);
        //通过用户id查询用户数据
        SysUserZzbOrZgd sysUserZzbOrZgd =  sysUserZgdService.queryDataByUserId(one.getZgdUserId());
        SysUserLinkZzbUserIdDto   dto  = new SysUserLinkZzbUserIdDto(one.getUserId(),one.getZgdUserId(),sysUserZzbOrZgd.getUserName());
        return dto;
    }


    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/9 8:54
     *  @Description:  通过用户关联数据查询返回用户集合
     */
    @Override
    public BasePageResult<SysUserLinkUserDto> queryUserPage(SysUserLinkQueryUserDto sysUserLinkQueryUserDto) {
        Page<SysUserLinkUserDto> page = new Page<>(sysUserLinkQueryUserDto.getPageNum(), sysUserLinkQueryUserDto.getPageSize());
        Page<SysUserLinkUserDto> sysUserLinkUserDtoBasePageResult = sysUserLinkZgdUserIdMapper.queryPage(page, sysUserLinkQueryUserDto);
        List<SysUserLinkUserDto> records = sysUserLinkUserDtoBasePageResult.getRecords();
        List<SysUserLinkUserDto> newRecords =  new ArrayList<>();
        if(records!=null && records.size()>0){
            for(SysUserLinkUserDto  sysUserLinkUserDto : records){
               //查询外部用户id
                SysUserZzbOrZgd sysUserZzbOrZgd =  sysUserZgdService.queryDataByUserId(sysUserLinkUserDto.getLinkUserId());
                sysUserLinkUserDto.setLinkUserName(sysUserZzbOrZgd ==null? "":sysUserZzbOrZgd.getUserName());
                newRecords.add(sysUserLinkUserDto);
            }
        }
        sysUserLinkUserDtoBasePageResult.setRecords(newRecords);
        return  new BasePageResult<>(sysUserLinkQueryUserDto.getPageNum(), page.getSize(), sysUserLinkUserDtoBasePageResult.getTotal(), page.getPages(),
                sysUserLinkUserDtoBasePageResult.getRecords());
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/10 14:53
     *  @Description: 查询掌柜鼎数据
     */
    @Override
    public BasePageResult<SysUserZzbOrZgd> queryUserZgdPage(SysUserLinkQueryUserDto sysUserLinkQueryUserDto) {
        Page<SysUserZzbOrZgd> page = new Page<>(sysUserLinkQueryUserDto.getPageNum(), sysUserLinkQueryUserDto.getPageSize());
        Page<SysUserZzbOrZgd> sysUserLinkUserDtoBasePageResult = sysUserZgdMapper.queryPage(page, sysUserLinkQueryUserDto);
        return  new BasePageResult<>(sysUserLinkQueryUserDto.getPageNum(), page.getSize(), sysUserLinkUserDtoBasePageResult.getTotal(), page.getPages(),
                sysUserLinkUserDtoBasePageResult.getRecords());
    }
}