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.SysUserLinkZgdUserIdMapper;
import com.ydtech.modules.admin.dao.SysUserLinkZzbUserIdMapper;
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.SysUserLinkZzbUserId;
import com.ydtech.modules.admin.model.po.SysUserZzbOrZgd;
import com.ydtech.modules.admin.model.vo.SysUserLinkZzbUserIdVo;
import com.ydtech.modules.admin.service.SysUserLinkZzbUserIdService;
import com.ydtech.modules.admin.service.SysUserZgdService;
import com.ydtech.modules.admin.service.SysUserZzbService;
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 SysUserLinkZzbUserIdServiceImpl extends ServiceImpl<SysUserLinkZzbUserIdMapper, SysUserLinkZzbUserId>
        implements SysUserLinkZzbUserIdService {


    @Autowired
    private SysUserZzbService sysUserZzbService;

    @Autowired
    private SysUserLinkZzbUserIdMapper sysUserLinkZzbUserIdMapper;

    @Autowired
    private SysUserZzbMapper sysUserZzbMapper;


    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/6 19:47
     *  @Description: 绑定掌中保用户id
     */
    @Override
    public void addOrUpdate(SysUserLinkZzbUserIdVo sysUserLinkZzbUserIdVo) {
        LambdaQueryWrapper<SysUserLinkZzbUserId> lqw = new LambdaQueryWrapper<>();
        lqw.eq( SysUserLinkZzbUserId::getUserId, sysUserLinkZzbUserIdVo.getUserId());
        SysUserLinkZzbUserId one = this.getOne(lqw);
        if(one!=null){
            one.setZzbUserId(sysUserLinkZzbUserIdVo.getLinkUserId());
            one.setCreateTime(new Date());
            one.setCreateUserId(new BaseController().getUserId());
            this.updateById(one);
        }else{
            SysUserLinkZzbUserId sysUserLinkZzbUserId =new SysUserLinkZzbUserId(null,sysUserLinkZzbUserIdVo.getUserId(), sysUserLinkZzbUserIdVo.getLinkUserId(), new Date(), new BaseController().getUserId());
            this.save(sysUserLinkZzbUserId);
        }

    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/6 19:48
     *  @Description: 清空掌柜宝的关联用户id
     */
    @Override
    public void deleteByUserId(SysUserLinkZzbUserIdVo sysUserLinkZzbUserIdVo) {
        LambdaQueryWrapper<SysUserLinkZzbUserId> lqw = new LambdaQueryWrapper<>();
        lqw.eq( SysUserLinkZzbUserId::getUserId, sysUserLinkZzbUserIdVo.getUserId());
        int rows = this.baseMapper.delete(lqw);
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/9 10:00
     *  @Description:  通过用户id查询用户相关数据
     */
    @Override
    public SysUserLinkZzbUserIdDto queryData(String userId) {
        LambdaQueryWrapper<SysUserLinkZzbUserId> lqw = new LambdaQueryWrapper<>();
        lqw.eq( SysUserLinkZzbUserId::getUserId, userId);
        SysUserLinkZzbUserId one = this.getOne(lqw);
        //通过用户id查询用户数据
        SysUserZzbOrZgd sysUserZzbOrZgd =  sysUserZzbService.queryDataByUserId(one.getZzbUserId());
        SysUserLinkZzbUserIdDto   dto  = new SysUserLinkZzbUserIdDto(one.getUserId(),one.getZzbUserId(),sysUserZzbOrZgd.getUserName());
        return dto;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/9 10:00
     *  @Description:  通过用户参数查询用户数据
     */
    @Override
    public BasePageResult<SysUserLinkUserDto> queryUserPage(SysUserLinkQueryUserDto sysUserLinkQueryUserDto) {
        Page<SysUserLinkUserDto> page = new Page<>(sysUserLinkQueryUserDto.getPageNum(), sysUserLinkQueryUserDto.getPageSize());
        Page<SysUserLinkUserDto> sysUserLinkUserDtoBasePageResult = sysUserLinkZzbUserIdMapper.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 =  sysUserZzbService.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> queryUserZzbPage(SysUserLinkQueryUserDto sysUserLinkQueryUserDto) {
        Page<SysUserZzbOrZgd> page = new Page<>(sysUserLinkQueryUserDto.getPageNum(), sysUserLinkQueryUserDto.getPageSize());
        Page<SysUserZzbOrZgd> sysUserLinkUserDtoBasePageResult = sysUserZzbMapper.queryPage(page, sysUserLinkQueryUserDto);
        return  new BasePageResult<>(sysUserLinkQueryUserDto.getPageNum(), page.getSize(), sysUserLinkUserDtoBasePageResult.getTotal(), page.getPages(),
                sysUserLinkUserDtoBasePageResult.getRecords());
    }
}