package com.panzhihua.service_community.service.impl;

import static java.util.Objects.nonNull;
import static org.apache.commons.lang3.StringUtils.isNotBlank;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import javax.annotation.Resource;

import com.panzhihua.service_community.dao.ComActDAO;
import com.panzhihua.service_community.model.dos.ComActDO;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.property.CommonPage;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActColumnVO;
import com.panzhihua.service_community.dao.ComActAnnouncementDao;
import com.panzhihua.service_community.dao.ComActColumnDao;
import com.panzhihua.service_community.dao.ComActSocialWorkerDao;
import com.panzhihua.service_community.entity.ComActAnnouncement;
import com.panzhihua.service_community.entity.ComActColumn;
import com.panzhihua.service_community.entity.ComActSocialWorker;
import com.panzhihua.service_community.service.ComActColumnService;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * 分类列表(ComActColumn)表服务实现类
 *
 * @author makejava
 * @since 2021-11-01 14:38:25
 */
@Slf4j
@Service
public class ComActColumnServiceImpl extends ServiceImpl<ComActColumnDao, ComActColumn> implements ComActColumnService {
    @Resource
    private ComActColumnDao comActColumnDao;
    @Resource
    private ComActAnnouncementDao comActAnnouncementDao;
    @Resource
    private ComActSocialWorkerDao comActSocialWorkerDao;
    @Resource
    private ComActDAO comActDAO;
    @Override
    public R pageList(CommonPage commonPage) {
        return R.ok(this.comActColumnDao.pageList(new Page(commonPage.getPage(),commonPage.getSize()),commonPage));
    }

    @Override
    public R delete(Long id) {
        if(!comActAnnouncementDao.selectList(new QueryWrapper<ComActAnnouncement>().lambda().eq(ComActAnnouncement::getColumnId,id)).isEmpty()){
            return R.fail("当前类型无法删除，请先处理绑定数据");
        }
        ComActColumn comActColumn = comActColumnDao.selectById(id);
        if (nonNull(comActColumn) && comActColumn.getType().equals(2)) {
            //社工技能
            updateWorkerSkill(id);
        }
        return R.ok(comActColumnDao.deleteById(id));
    }

    @Override
    public R queryLevel(ComActColumnVO comActColumnVO) {
        Integer type = comActColumnVO.getType();
        Long communityId = comActColumnVO.getCommunityId();
        if (nonNull(type) && type.equals(4) && nonNull(communityId)) {
            ComActDO comActDO = comActDAO.selectById(communityId);
            if (nonNull(comActDO)) {
                comActColumnVO.setStreetId(comActDO.getStreetId());
            }
        }
        return R.ok(this.comActColumnDao.queryLevel(comActColumnVO));
    }

    /**
     * 修改数据
     *
     * @param comActColumnVO 实体对象
     * @return 修改结果
     */
    @Override
    public R updateColumn(ComActColumnVO comActColumnVO) {
        ComActColumn comActColumn = this.baseMapper.selectById(comActColumnVO.getId());
        BeanUtils.copyProperties(comActColumnVO, comActColumn);
        int result = this.baseMapper.updateById(comActColumn);
        if (result > 0) {
            if (comActColumn.getType().equals(2)) {
                //社工技能
                updateWorkerSkill(comActColumn.getId());
            }
            return R.ok();
        }
        return R.fail("操作失败，请重新尝试");
    }

    /**
     * 新增数据
     *
     * @param comActColumnVO 实体对象
     * @return 新增结果
     */
    @Override
    public R addColumn(ComActColumnVO comActColumnVO) {
        ComActColumn comActColumn = new ComActColumn();
        BeanUtils.copyProperties(comActColumnVO, comActColumn);
        Long communityId = comActColumnVO.getCommunityId();
        if (nonNull(communityId)) {
            ComActDO comActDO = comActDAO.selectById(communityId);
            if (nonNull(comActDO)) {
                comActColumn.setStreetId(comActDO.getStreetId());
            }
        }
        int result = this.baseMapper.insert(comActColumn);
        if (result > 0) {
            return R.ok();
        }
        return R.fail("操作失败，请重新尝试");
    }

    private void updateWorkerSkill(Long id) {
        List<ComActSocialWorker> workerList = comActSocialWorkerDao.selectIncludeSkillWorkerList(id);
        if (!workerList.isEmpty()) {
            workerList.forEach(e -> {
                String skillType = e.getSkillType();
                if (isNotBlank(skillType)) {
                    List<String> skillList = Arrays.asList(skillType.split(","));
                    List<String> list = new ArrayList<String>(skillList);
                    list.remove(id.toString());
                    StringBuilder sb = new StringBuilder();
                    StringBuilder sb1 = new StringBuilder();
                    for (int i = 0; i < list.size(); i++) {
                        String skillId = list.get(i);
                        ComActColumn skillColumn = comActColumnDao.selectById(skillId);
                        if (i < list.size() - 1) {
                            sb.append(skillId);
                            sb.append(",");
                            sb1.append(skillColumn.getName());
                            sb1.append(",");
                        } else {
                            sb.append(skillId);
                            sb1.append(skillColumn.getName());
                        }
                    }
                    e.setSkillType(sb.toString());
                    e.setSkillTypeName(sb1.toString());
                    comActSocialWorkerDao.updateById(e);
                }
            });
        }
    }

}