TPipeOldPlanProcessServiceImpl.java 6.3 KB
Newer Older
耿迪迪's avatar
耿迪迪 committed
1 2 3
package com.zehong.system.service.impl;

import com.alibaba.fastjson.JSONObject;
4
import com.zehong.common.core.domain.model.LoginUser;
耿迪迪's avatar
耿迪迪 committed
5
import com.zehong.common.exception.CustomException;
6
import com.zehong.common.utils.*;
wanghao's avatar
wanghao committed
7
import com.zehong.common.utils.poi.ExcelUtil;
耿迪迪's avatar
耿迪迪 committed
8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
import com.zehong.common.utils.uuid.IdUtils;
import com.zehong.system.domain.TPipeOldPlanProcess;
import com.zehong.system.domain.vo.TPipeOldPlanProcessVo;
import com.zehong.system.mapper.TPipeOldPlanProcessMapper;
import com.zehong.system.service.ITPipeOldPlanProcessService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
23
import java.util.stream.Collectors;
耿迪迪's avatar
耿迪迪 committed
24 25 26 27 28 29 30 31 32 33 34 35

/**
 * 老旧管网-改造计划和进度Service业务层处理
 * 
 * @author zehong
 * @date 2024-06-15
 */
@Service
public class TPipeOldPlanProcessServiceImpl implements ITPipeOldPlanProcessService 
{
    private static final Logger log = LoggerFactory.getLogger(TPipeOldPlanProcessServiceImpl.class);

36
    @Resource
耿迪迪's avatar
耿迪迪 committed
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65
    private TPipeOldPlanProcessMapper tPipeOldPlanProcessMapper;

    @Resource
    private GovernmentDataUtil governmentDataUtil;

    /**
     * 查询老旧管网-改造计划和进度
     * 
     * @param fOldPlanProcessId 老旧管网-改造计划和进度ID
     * @return 老旧管网-改造计划和进度
     */
    @Override
    public TPipeOldPlanProcess selectTPipeOldPlanProcessById(Long fOldPlanProcessId)
    {
        return tPipeOldPlanProcessMapper.selectTPipeOldPlanProcessById(fOldPlanProcessId);
    }

    /**
     * 查询老旧管网-改造计划和进度列表
     * 
     * @param tPipeOldPlanProcess 老旧管网-改造计划和进度
     * @return 老旧管网-改造计划和进度
     */
    @Override
    public List<TPipeOldPlanProcess> selectTPipeOldPlanProcessList(TPipeOldPlanProcess tPipeOldPlanProcess)
    {
        return tPipeOldPlanProcessMapper.selectTPipeOldPlanProcessList(tPipeOldPlanProcess);
    }

66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83
    /**
     * 查询老旧管网-改造计划和进度列表 - 导出时使用
     *
     * @param tPipeOldPlanProcess 老旧管网-改造计划和进度
     * @return 老旧管网-改造计划和进度
     */
    @Override
    public List<TPipeOldPlanProcess> exportTPipeOldPlanProcessList(TPipeOldPlanProcess tPipeOldPlanProcess) {

        LoginUser loginUser = SecurityUtils.getLoginUser();

        // 如果是 政府端 则 把 govUploadState 赋值给 fUploadType, 把 govUploadTime 赋值给 fUploadTime
        if(loginUser.getUser().getRoles().get(0).getRoleId()==3){
            tPipeOldPlanProcess.setfUploadType("1");
        }
        List<TPipeOldPlanProcess> tPipeOldPlanProcesses = tPipeOldPlanProcessMapper.exportPipeOldPlanProcessList(tPipeOldPlanProcess);

        if(loginUser.getUser().getRoles().get(0).getRoleId()==3){
wanghao's avatar
wanghao committed
84 85 86 87 88 89 90
            ExcelUtil.hiddencolumns.add(13);
            ExcelUtil.hiddencolumns.add(14);
        }

        if (loginUser.getUser().getRoles().get(0).getRoleId()==5) {
            ExcelUtil.hiddencolumns.add(15);
            ExcelUtil.hiddencolumns.add(16);
91 92 93 94 95
        }

        return tPipeOldPlanProcesses;
    }

耿迪迪's avatar
耿迪迪 committed
96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155
    /**
     * 新增老旧管网-改造计划和进度
     * 
     * @param tPipeOldPlanProcess 老旧管网-改造计划和进度
     * @return 结果
     */
    @Override
    public int insertTPipeOldPlanProcess(TPipeOldPlanProcess tPipeOldPlanProcess)
    {
        tPipeOldPlanProcess.setfUuid(IdUtils.fastSimpleUUID());
        tPipeOldPlanProcess.setfCreateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        return tPipeOldPlanProcessMapper.insertTPipeOldPlanProcess(tPipeOldPlanProcess);
    }

    /**
     * 修改老旧管网-改造计划和进度
     * 
     * @param tPipeOldPlanProcess 老旧管网-改造计划和进度
     * @return 结果
     */
    @Override
    public int updateTPipeOldPlanProcess(TPipeOldPlanProcess tPipeOldPlanProcess)
    {
        tPipeOldPlanProcess.setfUpdateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        return tPipeOldPlanProcessMapper.updateTPipeOldPlanProcess(tPipeOldPlanProcess);
    }

    /**
     * 批量删除老旧管网-改造计划和进度
     * 
     * @param fOldPlanProcessIds 需要删除的老旧管网-改造计划和进度ID
     * @return 结果
     */
    @Override
    public int deleteTPipeOldPlanProcessByIds(Long[] fOldPlanProcessIds)
    {
        return tPipeOldPlanProcessMapper.deleteTPipeOldPlanProcessByIds(fOldPlanProcessIds);
    }

    /**
     * 删除老旧管网-改造计划和进度信息
     * 
     * @param fOldPlanProcessId 老旧管网-改造计划和进度ID
     * @return 结果
     */
    @Override
    public int deleteTPipeOldPlanProcessById(Long fOldPlanProcessId)
    {
        return tPipeOldPlanProcessMapper.deleteTPipeOldPlanProcessById(fOldPlanProcessId);
    }

    @Override
    public int reportPipeOldPlanProcess(Long fOldPlanProcessId) throws Exception {
        TPipeOldPlanProcess tPipeOldPlanProcess = tPipeOldPlanProcessMapper.selectTPipeOldPlanProcessById(fOldPlanProcessId);
        TPipeOldPlanProcessVo pipeOldPlanProcessVo = new TPipeOldPlanProcessVo();
        GovernmentDataCopyUtil.copyToGovernData(tPipeOldPlanProcess,pipeOldPlanProcessVo);
        List<TPipeOldPlanProcessVo> data = new ArrayList<>();
        JSONObject reportResult = governmentDataUtil.setInfo("pipeline/old/plan/process","WRITE",data);
        log.info("上传计划和进度结果===================" + reportResult.toJSONString());
        if(!"0".equals(reportResult.getString("resultCode"))) throw new CustomException("上传计划和进度接口失败");
156 157 158 159 160 161 162 163 164 165 166 167 168
        tPipeOldPlanProcess.setGovUploadState("1");
        tPipeOldPlanProcess.setGovUploadTime(new Date());
        tPipeOldPlanProcessMapper.updateTPipeOldPlanProcess(tPipeOldPlanProcess);
        return 1;
    }

    /**
     * 企业端上传数据
     * @param fOldPlanProcessId f
     * @return r
     */
    @Override
    public int entReportPipeOldPlanProcess(Long fOldPlanProcessId) {
169 170
        String s = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, new Date());
        tPipeOldPlanProcessMapper.entReportPipeOldPlanProcess("1",s,fOldPlanProcessId);
耿迪迪's avatar
耿迪迪 committed
171 172 173
        return 1;
    }
}