package com.dy.pipIrrIrrigate.project;


import com.dy.common.webUtil.QueryResultVo;
import com.dy.pipIrrGlobal.daoIr.IrProjectGroupMapper;
import com.dy.pipIrrGlobal.daoIr.IrProjectMapper;
import com.dy.pipIrrGlobal.pojoIr.IrProject;
import com.dy.pipIrrGlobal.pojoIr.IrProjectGroup;
import com.dy.pipIrrGlobal.voIr.VoProject;
import com.dy.pipIrrGlobal.voIr.VoProjectDetail;
import com.dy.pipIrrGlobal.voIr.VoProjectOne;
import com.dy.pipIrrGlobal.voIr.VoProjectSimple;
import com.dy.pipIrrIrrigate.project.dto.IrrigateProject;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.common.utils.PojoUtils;
import org.springframework.aop.framework.AopContext;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author :WuZeYu
 * @Date :2024/5/14  13:56
 * @LastEditTime :2024/5/14  13:56
 * @Description
 */
@Slf4j
@Service
public class ProjectSv {
    @Autowired
    private IrProjectMapper irProjectMapper;

    @Autowired
    private IrProjectGroupMapper irProjectGroupMapper;

    /**
     * 添加项目，旧版本，原则上废弃
     * @param po
     * @return
     */
    public Integer addProject(IrProject po) {
        po.setOperateTime(new Date());
        po.setDeleted((byte) 0);
        if (po.getVillageId() != null) {
            po.setTownId(irProjectMapper.getSupperByVillageId(po.getVillageId()));
            po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId()));
            po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId()));
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        if (po.getTownId() != null) {
            po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId()));
            po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId()));
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        if (po.getCountyId() != null) {
            po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId()));
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        if (po.getCityId() != null) {
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        int rows = irProjectMapper.insertSelective(po);
        if (rows == 0) {
            return 0;
        }
        return 1;
    }

    /**
     * 添加项目，目前使用
     * @param po
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    public Map addIrrigateProject(IrrigateProject po) {
        String projectName = po.getProjectName();
        String irrigateGroups = po.getIrrigateGroups();
        Long operatorId = po.getOperatorId();

        IrProject irProject = new IrProject();
        irProject.setProjectName(projectName);
        irProject.setProjectState((byte)1);
        irProject.setOperator(operatorId);
        irProject.setOperateTime(new Date());
        irProject.setDeleted((byte)0);
        irProjectMapper.insert(irProject);
        Long projectId = irProject.getId();
        if(projectId == null) {
            Map map = new HashMap<>();
            map.put("success", false);
            map.put("msg", "创建灌溉项目失败");
            map.put("content", null);
            return map;
        }

        String[] irrigateGroupArr = irrigateGroups.split(",");
        Integer sort = 1;
        for(String irrigateGroupId : irrigateGroupArr) {
            String trimmed = irrigateGroupId.trim();
            if(trimmed.isEmpty()) {
                continue;
            }
            try {
                Long irrigateGroupIdLong = Long.parseLong(trimmed);
                IrProjectGroup irProjectGroup = new IrProjectGroup();
                irProjectGroup.setProjectId(projectId);
                irProjectGroup.setGroupId(irrigateGroupIdLong);
                irProjectGroup.setSort(sort++);
                irProjectGroupMapper.insert(irProjectGroup);
            } catch (NumberFormatException  e) {
                Map map = new HashMap<>();
                map.put("success", false);
                map.put("msg", "灌溉组ID格式错误");
                map.put("content", null);
                return map;
            }
        }
        Map map = new HashMap<>();
        map.put("success", true);
        map.put("msg", "添加灌溉项目成功");
        map.put("content", null);
        return map;
    }

    /**
     * 删除灌溉项目，目前使用
     * @param projectId
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    public Map deleteIrrigateProject(Long projectId) {
        try {
            irProjectGroupMapper.unbindGroup(projectId);
            irProjectMapper.deleteByPrimaryKey(projectId);

            Map map = new HashMap<>();
            map.put("success", true);
            map.put("msg", "灌溉项目删除成功");
            map.put("content", null);
            return map;
        } catch (Exception e) {
            Map map = new HashMap<>();
            map.put("success", false);
            map.put("msg", "灌溉项目删除失败");
            map.put("content", null);
            return map;
        }
    }

    /**
     * 修改灌溉项目，目前使用
     * @param po
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    public Map updateIrrigateProject(IrrigateProject po) {
        Long projectId = po.getProjectId();
        Map map_deleteProject = ((ProjectSv) AopContext.currentProxy()).deleteIrrigateProject(projectId);
        if(map_deleteProject.get("success").equals(false)) {
            Map map = new HashMap<>();
            map.put("success", false);
            map.put("msg", map_deleteProject.get("msg").toString());
            map.put("content", null);
            return map;
        }

        Map map_addProject = ((ProjectSv) AopContext.currentProxy()).addIrrigateProject(po);
        if(map_addProject.get("success").equals(false)) {
            Map map = new HashMap<>();
            map.put("success", false);
            map.put("msg", map_addProject.get("msg").toString());
            map.put("content", null);
            return map;
        }

        Map map = new HashMap<>();
        map.put("success", true);
        map.put("msg", "修改灌溉项目成功");
        map.put("content", null);
        return map;
    }

    /**
     * 删除项目，旧版本，原则上废弃
     * @param id
     */
    public Integer deleteProject(Long id) {
        int rows = irProjectMapper.deleteLogicById(id);
        if (rows == 0) {
            return 0;
        }
            return 1;
    }

    /**
     * 修改项目信息
     * @param po
     * @return
     */
    public Integer updateProject(IrProject po){
        po.setOperateTime(new Date());
        if (po.getVillageId() != null) {
            po.setTownId(irProjectMapper.getSupperByVillageId(po.getVillageId()));
            po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId()));
            po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId()));
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        if (po.getTownId() != null) {
            po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId()));
            po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId()));
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        if (po.getCountyId() != null) {
            po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId()));
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        if (po.getCityId() != null) {
            po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId()));
        }
        int rows = irProjectMapper.updateByPrimaryKeySelective(po);
        if (rows == 0){
            return 0;
        }
        return 1;
    }

    /**
     * 修改项目状态
     * @param po
     * @return
     */
    public Integer updateProjectState(IrProject po){
        po.setOperateTime(new Date());
        int rows = irProjectMapper.updateProjectState(po);
        if (rows == 0){
            return 0;
        }
        return 1;
    }

    /**
     * 获取一个项目数据
     * @param id
     * @return
     */
    public VoProjectOne selectById(Long id){
        VoProjectOne irProject = irProjectMapper.selectById(id);
        return irProject;
    }

    /**
     * 分页查询项目，旧版本，原则上废弃
     * @param queryVo
     * @return
     */
    public QueryResultVo<List<VoProject>> getProjects(QueryVo queryVo){
        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
        Long itemTotal = irProjectMapper.getRecordCount(params);

        QueryResultVo<List<VoProject>> rsVo = new QueryResultVo<>();
        rsVo.pageSize = queryVo.pageSize;
        rsVo.pageCurr = queryVo.pageCurr;
        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = irProjectMapper.getProjects(params);
        return rsVo;
    }

    /**
     * 分页查询项目，新版本，目前使用
     * @param queryVo
     * @return
     */
    public QueryResultVo<List<VoProjectSimple>> getSimpleProjects(QueryVo queryVo) {
        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
        Long itemTotal = irProjectMapper.getSimpleProjectsCount(params);

        QueryResultVo<List<VoProjectSimple>> rsVo = new QueryResultVo<>();
        rsVo.pageSize = queryVo.pageSize;
        rsVo.pageCurr = queryVo.pageCurr;
        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = irProjectMapper.getSimpleProjects(params);
        return rsVo;
    }

    /**
     * 根据项目Id获取项目详情，编辑项目信息使用
     * @param projectId
     * @return
     */
    public Map getProjectDetail(Long projectId) {
        try {
            VoProjectDetail voProjectDetail = irProjectMapper.getProjectDetail(projectId);
            Map map = new HashMap<>();
            map.put("success", true);
            map.put("msg", "获取项目详情成功");
            map.put("content", voProjectDetail);
            return map;
        } catch (Exception e) {
            Map map = new HashMap<>();
            map.put("success", false);
            map.put("msg", "获取项目详情失败");
            map.put("content", null);
            return map;
        }
    }
}