package cn.huge.module.syncbydyh.service;

import cn.huge.base.common.exception.ServiceException;
import cn.huge.module.ctuser.domain.po.*;
import cn.huge.module.ctuser.service.*;
import cn.huge.module.cust.constant.RoleBaseEnum;
import cn.huge.module.cust.constant.UserBaseConsts;
import cn.huge.module.syncbydyh.client.api.impl.SyncBydyhClientImpl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * @title: 白云数据割接为广州数据的业务逻辑处理
 * @Description 白云数据割接为广州数据的业务逻辑处理
 * @company hugeinfo
 * @author liyj
 * @Time 2024-08-19 20:04:19
 * @version 1.0.0
 */
@Slf4j
@Service
@Transactional(rollbackFor = Exception.class)
public class ByToGzService{

    @Autowired
    private SyncBydyhClientImpl syncBydyhClient;
    @Autowired
    private CtUnitService ctUnitService;
    @Autowired
    private CtDeptService ctDeptService;
    @Autowired
    private CtUserService ctUserService;
    @Autowired
    private CtAccountService ctAccountService;
    @Autowired
    private CtUseroleService ctUseroleService;

    /**
     * 白云区矛盾纠纷多元化解平台数据割接-组织信息
     */
    public void byToGzCtUnit(){
        try{
            List<CtUnit> byToGzDTOList = syncBydyhClient.byToGzCtUnit();
            for (CtUnit byToGzDTO: byToGzDTOList){
                ctUnitService.saveOrUpdate(byToGzDTO);
            }
        }catch (Exception e){
            log.error("[ByToGzService.byToGzCtUnit]调用失败，异常信息："+e, e);
            throw new ServiceException("ByToGzService.byToGzCtUnit", e);
        }
    }

    /**
     * 白云区矛盾纠纷多元化解平台数据割接-部门信息
     */
    public void byToGzCtDept(){
        try{
            List<CtDept> byToGzDTOList = syncBydyhClient.byToGzCtDept();
            for (CtDept byToGzDTO: byToGzDTOList){
                ctDeptService.saveOrUpdate(byToGzDTO);
            }
        }catch (Exception e){
            log.error("[ByToGzService.byToGzCtDept]调用失败，异常信息："+e, e);
            throw new ServiceException("ByToGzService.byToGzCtDept", e);
        }
    }

    /**
     * 白云区矛盾纠纷多元化解平台数据割接-用户信息
     */
    public void byToGzCtUser(){
        try{
            List<CtUser> byToGzDTOList = syncBydyhClient.byToGzCtUser();
            for (CtUser byToGzDTO: byToGzDTOList){
                ctUserService.saveOrUpdate(byToGzDTO);
            }
        }catch (Exception e){
            log.error("[ByToGzService.byToGzCtUser]调用失败，异常信息："+e, e);
            throw new ServiceException("ByToGzService.byToGzCtUser", e);
        }
    }

    /**
     * 白云区矛盾纠纷多元化解平台数据割接-账号信息
     */
    public void byToGzCtAccount(){
        try{
            List<CtAccount> byToGzDTOList = syncBydyhClient.byToGzCtAccount();
            for (CtAccount byToGzDTO: byToGzDTOList){
                ctAccountService.saveOrUpdate(byToGzDTO);
            }
        }catch (Exception e){
            log.error("[ByToGzService.byToGzCtAccount]调用失败，异常信息："+e, e);
            throw new ServiceException("ByToGzService.byToGzCtAccount", e);
        }
    }

    /**
     * 白云区矛盾纠纷多元化解平台数据割接-用户角色关系信息
     */
    public void byToGzCtUserole(){
        try{
            List<CtUserole> byToGzDTOList = syncBydyhClient.byToGzCtUserole();
            for (CtUserole byToGzDTO: byToGzDTOList){
                ctUseroleService.saveOrUpdate(byToGzDTO);
            }
        }catch (Exception e){
            log.error("[ByToGzService.byToGzCtUserole]调用失败，异常信息："+e, e);
            throw new ServiceException("ByToGzService.byToGzCtUserole", e);
        }
    }





    /**
     * 单位名称更新-白云单位名称街道办->综治中心
     */
    public void upUnitNameZzzx(){
        try{
            QueryWrapper<CtUnit> ctUnitQueryWrapper = new QueryWrapper<>();
            ctUnitQueryWrapper.eq("unit_grade", UserBaseConsts.UNIT_GRADE_3);
            List<CtUnit> ctUnitList = ctUnitService.list(ctUnitQueryWrapper);
            for (CtUnit ctUnit: ctUnitList){
                ctUnit.setUnitName(ctUnit.getUnitName().replace("街道办", "街综治中心"));
                ctUnitService.updateById(ctUnit);
                // 更新人员单位名称
                UpdateWrapper<CtUser> ctUserUpdateWrapper = new UpdateWrapper<>();
                ctUserUpdateWrapper.eq("unit_id", ctUnit.getId()).set("unit_name", ctUnit.getUnitName());
                ctUserService.update(ctUserUpdateWrapper);
            }
        }catch (Exception e){
            log.error("[ByToGzService.upUnitNameZzzx]调用失败，异常信息："+e, e);
            throw new ServiceException("ByToGzService.upUnitNameZzzx", e);
        }
    }
}