ANTAI-WLTMS-API/src/main/java/com/steerinfo/dil/service/impl/TmsComprehensiveResultServiceImpl.java

package com.steerinfo.dil.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.steerinfo.dil.mapper.OmsTransOrderMapper;
import com.steerinfo.dil.mapper.TmsAddenergyResultMapper;
import com.steerinfo.dil.model.TmsAddenergyResult;
import com.steerinfo.dil.util.DaZongUtil;
import com.steerinfo.dil.util.DataChange;
import com.steerinfo.framework.mapper.IBaseMapper;
import com.steerinfo.framework.service.impl.BaseServiceImpl;
import com.steerinfo.dil.model.TmsComprehensiveResult;
import com.steerinfo.dil.mapper.TmsComprehensiveResultMapper;
import com.steerinfo.dil.service.ITmsComprehensiveResultService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;


/**
 * TmsComprehensiveResult服务实现：
 * @author generator
 * @version 1.0-SNAPSHORT 2023-10-28 02:59
 * 类描述
 * 修订历史：
 * 日期：2023-10-28
 * 作者：generator
 * 参考：
 * 描述：TmsComprehensiveResult服务实现
 * @see null
 * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
 */
@Service(value = "tmsComprehensiveResultService")
public class TmsComprehensiveResultServiceImpl extends BaseServiceImpl<TmsComprehensiveResult, BigDecimal> implements ITmsComprehensiveResultService {

    @Autowired
    private TmsComprehensiveResultMapper tmsComprehensiveResultMapper;
    @Autowired
    private OmsTransOrderMapper omsTransOrderMapper;
    @Autowired
    private DaZongUtil daZongUtil;

    @Autowired
    private TmsAddenergyResultMapper tmsAddenergyResultMapper;

    @Override
    protected IBaseMapper<TmsComprehensiveResult, BigDecimal> getMapper() {
        return tmsComprehensiveResultMapper;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String upload(List<TmsComprehensiveResult> model) throws Exception {
        String msg = null;
        if (model==null){
            return "修改信息不能为空！";
        }
        for (TmsComprehensiveResult tmsComprehensiveResult : model) {
            Calendar calendar = Calendar.getInstance();
            tmsComprehensiveResult.setUpdateUsername("admin");
            tmsComprehensiveResult.setUpdateTime(DataChange.dataToDate(calendar.getTime()));
            if ("请假".equals(tmsComprehensiveResult.getResultType()) && tmsComprehensiveResult.getAlternateFields7() != null) {
                tmsComprehensiveResultMapper.updatePersonnelStatus(tmsComprehensiveResult.getPersonnelId(),new BigDecimal(3));
            }
            if ("请假".equals(tmsComprehensiveResult.getResultType()) && tmsComprehensiveResult.getAlternateFields9() != null) {
                tmsComprehensiveResultMapper.updatePersonnelStatus(tmsComprehensiveResult.getPersonnelId(),new BigDecimal(0));
            }
            msg = tmsComprehensiveResultMapper.updateByPrimaryKeySelective(tmsComprehensiveResult) > 0? "操作成功" : "操作失败";
            //if ("借车".equals(tmsComprehensiveResult.getResultType())) {
            //    //推送大宗
            //    Map<String,Object> params = new HashMap<>();
            //    Map<String, Object> capacity = new HashMap<>();
            //    Map<String, Object>  driver = new HashMap<>();
            //    //推送车辆档案
            //    capacity=omsTransOrderMapper.findCapacityMes(tmsComprehensiveResult.getCapacityId());
            //    capacity.put("clbh",tmsComprehensiveResult.getAlternateFields12());
            //    driver = omsTransOrderMapper.findDriverMes(tmsComprehensiveResult.getPersonnelId());
            //    params = new HashMap<>();
            //    params.putAll(capacity);
            //    params.putAll(driver);
            //    daZongUtil.execute("30010000002", new Map[]{params});
            //}
        }
        return msg;
    }

    @Override
    public String importComprehensiveResult(Map<String, Object> mapValue) throws Exception {
        String resultType = mapValue.get("resultType").toString();
        if ("加油-加油站系统数据".equals(resultType)) {
            return importAddOilResult(mapValue);
        }
        if ("加油-其他系统数据".equals(resultType)) {
            return importAddOilResultOther(mapValue);
        }
        if ("加油-电量数据".equals(resultType)) {
            return importAddEnergyResult(mapValue);
        }
        if ("维保".equals(resultType)) {
            return importRepairResult(mapValue);
        }
        return "导入成功";
    }



    @Transactional(rollbackFor = Exception.class)
    public String importRepairResult(Map<String, Object> mapValue) throws Exception {
        String userName = mapValue.get("userName").toString();
        String filePath = mapValue.get("filePath").toString();
        List<Map<String,Object>> list =  (ArrayList) mapValue.get("list");
        List<TmsComprehensiveResult> tmsComprehensiveResultInsertList = new ArrayList<>();
        List<TmsComprehensiveResult> tmsComprehensiveResultUpdateList = new ArrayList<>();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
        for(Map<String,Object> item : list) {
            if(item.get("车号") == null) {
                throw new Exception("车号不能为空");
            }
            //根据车号查询运力ID
            String capacityNumber = item.get("大号").toString();
            BigDecimal capacityId = tmsComprehensiveResultMapper.selectCapacityId(capacityNumber);
            if(capacityId == null) {
                throw new Exception(capacityNumber + "车号不存在系统,请联系物流调度录入");
            }
            String date = item.get("维修时间").toString();
            TmsComprehensiveResult tmsComprehensiveResult = new TmsComprehensiveResult();
            tmsComprehensiveResult.setResultId(tmsComprehensiveResultMapper.nextId());
            tmsComprehensiveResult.setResultTime(simpleDateFormat.parse(date));
            tmsComprehensiveResult.setResultType("维保");

            tmsComprehensiveResult.setAlternateFields3(item.get("维修内容").toString());
            tmsComprehensiveResult.setAlternateFields13(item.get("工时费").toString());
            tmsComprehensiveResult.setAlternateFields14(item.get("维保人").toString());
            tmsComprehensiveResult.setAlternateFields15(item.get("配件费").toString());
            tmsComprehensiveResult.setAlternateFields20(item.get("车属单位").toString());
            tmsComprehensiveResult.setCapacityId(capacityId);
            tmsComprehensiveResult.setAlternateFields11(capacityId.toString());
            tmsComprehensiveResult.setInsertTime(new Date());
            tmsComprehensiveResult.setInsertUsername(userName);
            tmsComprehensiveResult.setDeleted(BigDecimal.ZERO);
            tmsComprehensiveResult.setAlternateFields18(filePath);
            tmsComprehensiveResultInsertList.add(tmsComprehensiveResult);
        }
        tmsComprehensiveResultMapper.batchInsert(tmsComprehensiveResultInsertList);
        return "操作成功!";
    }

    @Transactional(rollbackFor = Exception.class)
    public synchronized String importAddOilResult(Map<String,Object> mapValue) throws Exception{
        System.out.println(new JSONObject(mapValue));
        String userName = mapValue.get("userName").toString();
        String filePath = mapValue.get("filePath").toString();
        List<Map<String,Object>> list =  (ArrayList) mapValue.get("list");
        List<TmsAddenergyResult> tmsAddEnergyResultList = new ArrayList<>();
        List<TmsAddenergyResult> tmsUpdateEnergyResultList = new ArrayList<>();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        for(Map<String,Object> item : list) {
            if(item.get("卡账号") == null || "".equals(item.get("卡账号").toString().trim())) {
                continue;
            }
            //获取车牌号
            String capacityNo = null;
            if(item.get("车牌号") == null || "".equals(item.get("车牌号").toString().trim())) {
                capacityNo = item.get("持卡人").toString().trim();
            }else{
                capacityNo = item.get("车牌号").toString().trim();
            }
            //根据车号获取ID,
            BigDecimal capacityId = tmsComprehensiveResultMapper.selectCapacityId(capacityNo);
            //获取卡号
            String cardNo = item.get("卡账号") == null ? "" : item.get("卡账号").toString();
            //获取油品名
            if(item.get("油品名") == null) {
                continue;
            }
            String oilName = item.get("油品名").toString();
            //获取油量升
            String oilNumber = item.get("油量升").toString();
            //获取金额
            String amount = item.get("金额").toString();
            //单价
            String price = item.get("单价").toString();
            String companyName = item.get("单位名").toString();
            if("".equals(companyName)) {
                companyName = "宏瑞物流";
            }
            //获取加油时间
            String addOilTimeStr = item.get("加油时间").toString();
            Date addOilTime = simpleDateFormat.parse(addOilTimeStr);
            Map<String, Object> searchMap  = new HashMap<>();
            searchMap.put("energyAddTime",addOilTime);
            searchMap.put("capacityNumber",capacityNo);
            searchMap.put("deleted",0);
            List<TmsAddenergyResult> addenergyResults = tmsAddenergyResultMapper.selectByParametersSt(searchMap);
            if(addenergyResults != null && addenergyResults.size() > 0) {
                addenergyResults.get(0).setEnergyName(oilName);
                addenergyResults.get(0).setCompanyName(companyName);
                addenergyResults.get(0).setCapacityId(capacityId == null ? null : capacityId.toString());
                addenergyResults.get(0).setEnergyJyPrice(DataChange.dataToBigDecimal(price));
                addenergyResults.get(0).setEnergyJyAmount(DataChange.dataToBigDecimal(amount));
                addenergyResults.get(0).setEnergyNumber(DataChange.dataToBigDecimal(oilNumber));
                addenergyResults.get(0).setCardNo(cardNo);
                addenergyResults.get(0).setUpdateTime(new Date());
                addenergyResults.get(0).setUpdateUsername(userName);
                addenergyResults.get(0).setAlternateFields2(filePath);
                tmsUpdateEnergyResultList.add(addenergyResults.get(0));
            }else{
                TmsAddenergyResult tmsAddenergyResult = new TmsAddenergyResult();
                tmsAddenergyResult.setResultId(tmsAddenergyResultMapper.nextId());
                tmsAddenergyResult.setCapacityId(capacityId == null ? null : capacityId.toString());
                tmsAddenergyResult.setCardNo(cardNo);
                tmsAddenergyResult.setEnergyName(oilName);
                tmsAddenergyResult.setCompanyName(companyName);
                tmsAddenergyResult.setEnergyJyPrice(DataChange.dataToBigDecimal(price));
                tmsAddenergyResult.setEnergyJyAmount(DataChange.dataToBigDecimal(amount));
                tmsAddenergyResult.setEnergyNumber(DataChange.dataToBigDecimal(oilNumber));
                tmsAddenergyResult.setEnergyAddTime(addOilTime);
                tmsAddenergyResult.setCapacityNumber(capacityNo);
                tmsAddenergyResult.setCardNo(cardNo);
                tmsAddenergyResult.setDeleted(0);
                tmsAddenergyResult.setInsertTime(new Date());
                tmsAddenergyResult.setInsertUsername(userName);
                tmsAddenergyResult.setAlternateFields1(filePath);
                tmsAddEnergyResultList.add(tmsAddenergyResult);
            }
        }
        if(tmsAddEnergyResultList.size() > 0) {
            tmsAddenergyResultMapper.batchInsert(tmsAddEnergyResultList);
        }
        if(tmsUpdateEnergyResultList.size() > 0) {
            tmsAddenergyResultMapper.batchUpdate(tmsUpdateEnergyResultList);
        }
        return "导入成功";
    }


    @Transactional(rollbackFor = Exception.class)
    public String importAddOilResultOther(Map<String, Object> mapValue) throws Exception{
        String userName = mapValue.get("userName").toString();
        String filePath = mapValue.get("filePath").toString();
        List<Map<String,Object>> list =  (ArrayList) mapValue.get("list");
        List<TmsAddenergyResult> tmsAddEnergyResultList = new ArrayList<>();
        List<TmsAddenergyResult> tmsUpdateEnergyResultList = new ArrayList<>();
        String note = "其他系统数据";
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
        for(Map<String,Object> item : list) {
            String cardNo = item.get("卡号") == null ? "" : item.get("卡号").toString().trim();
            String capacityNumber = item.get("车号") == null ? "" : item.get("车号").toString().trim();
            if("".equals(cardNo) && "".equals(capacityNumber)) {
                continue;
            }
            if("".equals(cardNo) && !"".equals(capacityNumber)) {
                cardNo = capacityNumber;
            }
            if("".equals(capacityNumber) && !"".equals(cardNo)) {
                capacityNumber = cardNo;
            }
            //获取车牌号
            String capacityNo = capacityNumber;
            //根据车号获取ID,
            BigDecimal capacityId = tmsComprehensiveResultMapper.selectCapacityId(capacityNo);
            //获取卡号
            String oilName = null;
            //获取油品名
            if(item.get("油品名") == null) {
                throw new Exception("请标记油品名");
            }else{
                oilName = item.get("油品名").toString();
            }
            String month = item.get("月份").toString();
            //获取金额
            String amount = "1";
            //单价
            String price = "1";
            String companyName = item.get("单位") == null ? "宏瑞物流" : item.get("单位").toString();
            Set<String> strings = item.keySet();
            for(String key : strings) {
                if(key.contains("日")){
                    String day = key.split("日")[0];
                    String date = month + "-" + day;
                    Date addTime = simpleDateFormat.parse(date);
                    Map<String, Object> searchMap  = new HashMap<>();
                    searchMap.put("energyAddTime",addTime);
                    searchMap.put("capacityNumber",capacityNo);
                    searchMap.put("deleted",0);
                    searchMap.put("energyName",oilName);
                    List<TmsAddenergyResult> addenergyResults = tmsAddenergyResultMapper.selectByParametersSt(searchMap);
                    if(addenergyResults != null && addenergyResults.size() > 0) {
                            addenergyResults.get(0).setEnergyName(oilName);
                            addenergyResults.get(0).setCompanyName(companyName);
                            addenergyResults.get(0).setCapacityId(capacityId == null ? null : capacityId.toString());
                            addenergyResults.get(0).setEnergyJyPrice(DataChange.dataToBigDecimal(price));
                            addenergyResults.get(0).setEnergyJyAmount(DataChange.dataToBigDecimal(amount));
                            addenergyResults.get(0).setEnergyNumber(DataChange.dataToBigDecimal(item.get(key)));
                            addenergyResults.get(0).setCardNo(cardNo);
                            addenergyResults.get(0).setUpdateTime(new Date());
                            addenergyResults.get(0).setUpdateUsername(userName);
                            addenergyResults.get(0).setAlternateFields2(filePath);
                            addenergyResults.get(0).setAlternateFields2(note);
                            tmsUpdateEnergyResultList.add(addenergyResults.get(0));
                    }else{
                            TmsAddenergyResult tmsAddenergyResult = new TmsAddenergyResult();
                            tmsAddenergyResult.setResultId(tmsAddenergyResultMapper.nextId());
                            tmsAddenergyResult.setCapacityId(capacityId == null ? null : capacityId.toString());
                            tmsAddenergyResult.setCardNo(cardNo);
                            tmsAddenergyResult.setEnergyName(oilName);
                            tmsAddenergyResult.setCompanyName(companyName);
                            tmsAddenergyResult.setEnergyJyPrice(DataChange.dataToBigDecimal(price));
                            tmsAddenergyResult.setEnergyJyAmount(DataChange.dataToBigDecimal(amount));
                            tmsAddenergyResult.setEnergyNumber(DataChange.dataToBigDecimal(item.get(key)));
                            tmsAddenergyResult.setEnergyAddTime(addTime);
                            tmsAddenergyResult.setCapacityNumber(capacityNo);
                            tmsAddenergyResult.setCardNo(cardNo);
                            tmsAddenergyResult.setDeleted(0);
                            tmsAddenergyResult.setInsertTime(new Date());
                            tmsAddenergyResult.setInsertUsername(userName);
                            tmsAddenergyResult.setAlternateFields1(filePath);
                            tmsAddenergyResult.setAlternateFields2(note);
                            tmsAddEnergyResultList.add(tmsAddenergyResult);
                    }
                }
             }
        }
        //    //获取加油时间
        if(tmsAddEnergyResultList.size() > 0) {
            tmsAddenergyResultMapper.batchInsert(tmsAddEnergyResultList);
        }
        if(tmsUpdateEnergyResultList.size() > 0) {
            tmsAddenergyResultMapper.batchUpdate(tmsUpdateEnergyResultList);
        }
        return "导入成功";
    }


    @Transactional(rollbackFor = Exception.class)
    public String importAddEnergyResult(Map<String, Object> mapValue) throws Exception {
        String userName = mapValue.get("userName").toString();
        String filePath = mapValue.get("filePath").toString();
        List<Map<String, Object>> list = (ArrayList) mapValue.get("list");
        List<TmsAddenergyResult> tmsAddEnergyResultList = new ArrayList<>();
        List<TmsAddenergyResult> tmsUpdateEnergyResultList = new ArrayList<>();
        String note = "电系统数据";
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        for (Map<String, Object> item : list) {
            if (item.get("车号") == null || "".equals(item.get("车号").toString().trim())) {
                continue;
            }
            //获取油量升
            if (item.get("度数") == null) {
                continue;
            }
            if (item.get("充电时间") == null || "".equals(item.get("充电时间").toString().trim())) {
                continue;
            }
            String oilNumber = item.get("度数").toString();
            if (DataChange.dataToBigDecimal(oilNumber).compareTo(BigDecimal.ZERO) == 0) {
                continue;
            }
            //获取车牌号
            String capacityNo = item.get("车号").toString().trim();
            //根据车号获取ID
            Map<String, Object> capacityMesInfo = tmsAddenergyResultMapper.selectCapacityMes(capacityNo);
            BigDecimal capacityId = null;
            String capacityNumber = null;
            String capacityInnerNumber = null;
            String cardNo = null;
            if (capacityMesInfo != null) {
                capacityId = DataChange.dataToBigDecimal(capacityMesInfo.get("capacityId"));
                capacityNumber = capacityMesInfo.get("capacityNumber").toString();
                capacityInnerNumber = capacityMesInfo.get("capacityInnerNumber") == null ? capacityNo : capacityMesInfo.get("capacityInnerNumber").toString();
                cardNo = capacityNumber;
            } else {
                capacityNumber = capacityNo;
                capacityInnerNumber = capacityNo;
                cardNo = capacityNo;
            }
            String oilName = "电";

            String companyName = "宏瑞物流";
            //获取加油时间
            String addOilTimeStr = item.get("充电时间").toString().replace(".", "-");
            Date addOilTime = simpleDateFormat.parse(addOilTimeStr);
            Map<String, Object> searchMap = new HashMap<>();
            searchMap.put("energyAddTime", addOilTime);
            searchMap.put("capacityNumber", capacityNo);
            searchMap.put("deleted", 0);
            searchMap.put("energyName", "电");
            List<TmsAddenergyResult> addenergyResults = tmsAddenergyResultMapper.selectByParametersSt(searchMap);
            if (addenergyResults != null && addenergyResults.size() > 0) {
                addenergyResults.get(0).setEnergyName(oilName);
                addenergyResults.get(0).setCompanyName(companyName);
                addenergyResults.get(0).setCapacityId(capacityId == null ? null : capacityId.toString());
                addenergyResults.get(0).setCardNo(cardNo);
                addenergyResults.get(0).setCapacityInnerNumber(capacityInnerNumber);
                addenergyResults.get(0).setCapacityNumber(capacityNumber);
                addenergyResults.get(0).setEnergyNumber(DataChange.dataToBigDecimal(oilNumber));
                addenergyResults.get(0).setUpdateTime(new Date());
                addenergyResults.get(0).setUpdateUsername(userName);
                addenergyResults.get(0).setAlternateFields2(filePath);
                tmsUpdateEnergyResultList.add(addenergyResults.get(0));
            } else {
                TmsAddenergyResult tmsAddenergyResult = new TmsAddenergyResult();
                tmsAddenergyResult.setResultId(tmsAddenergyResultMapper.nextId());
                tmsAddenergyResult.setCapacityId(capacityId == null ? null : capacityId.toString());
                tmsAddenergyResult.setEnergyName(oilName);
                tmsAddenergyResult.setCompanyName(companyName);
                tmsAddenergyResult.setEnergyNumber(DataChange.dataToBigDecimal(oilNumber));
                tmsAddenergyResult.setEnergyAddTime(addOilTime);
                tmsAddenergyResult.setCapacityNumber(capacityNumber);
                tmsAddenergyResult.setCapacityInnerNumber(capacityInnerNumber);
                tmsAddenergyResult.setCardNo(cardNo);
                tmsAddenergyResult.setDeleted(0);
                tmsAddenergyResult.setInsertTime(new Date());
                tmsAddenergyResult.setInsertUsername(userName);
                tmsAddenergyResult.setAlternateFields1(filePath);
                tmsAddEnergyResultList.add(tmsAddenergyResult);
            }
        }
        int section = 100;
        if (tmsAddEnergyResultList.size() > 0) {
            for (int i = 1; (i - 1) * section < tmsAddEnergyResultList.size(); i++) {
                List<TmsAddenergyResult> tempList = null;
                if (i * section < tmsAddEnergyResultList.size()) {
                    tempList = tmsAddEnergyResultList.subList((i - 1) * section, i * section);
                } else {
                    tempList = tmsAddEnergyResultList.subList((i - 1) * section, tmsAddEnergyResultList.size());
                }
                if (tempList.size() > 0) {
                    tmsAddenergyResultMapper.batchInsert(tempList);
                }
            }
        }
        if (tmsUpdateEnergyResultList.size() > 0) {
            for (int i = 1; (i - 1) * section < tmsUpdateEnergyResultList.size(); i++) {
                List<TmsAddenergyResult> tempList = null;
                if (i * section < tmsUpdateEnergyResultList.size()) {
                    tempList = tmsUpdateEnergyResultList.subList((i - 1) * section, i * section);
                } else {
                    tempList = tmsUpdateEnergyResultList.subList((i - 1) * section, tmsUpdateEnergyResultList.size());
                }
                if (tempList.size() > 0) {
                    tmsAddenergyResultMapper.batchUpdate(tempList);
                }
            }
        }
        return "导入成功";
    }

//借车添加排班
    @Override
    public String insertCapacityDriver(BigDecimal personnelId,Map<String, Object> mapValue,TmsComprehensiveResult model) {
        Map<String,Object>  searchMap = new HashMap<>();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        BigDecimal capacityDriverId = tmsComprehensiveResultMapper.rcdNextId();
        model.setAlternateFields19(capacityDriverId.toString());
        model.setAlternateFields20("借车申请：我于"+simpleDateFormat.format(new Date())+"申请了借车，原因是"+model.getAlternateFields3());
        model.setAlternateFields21("0");
        model.setAlternateFields6("系统自动批准");
        model.setAlternateFields7("系统自动批准");
        //修改借车实绩状态
        tmsComprehensiveResultMapper.updateByPrimaryKeySelective(model);
        tmsComprehensiveResultMapper.updateCapacityStatus(DataChange.dataToBigDecimal(mapValue.get("oldCapacityId")),new BigDecimal(3));
        //新增排班信息
        searchMap.put("capacityDriverId",capacityDriverId);
        searchMap.put("capacityId", mapValue.get("capacityId"));
        searchMap.put("personnelId", mapValue.get("personnelId"));
        searchMap.put("deleted",0);
        //新增排班d
        searchMap.put("insertTime",new Date());
        searchMap.put("insertUsername",mapValue.get("userName"));
        searchMap.put("alternateFields1","借车");
        Integer count = tmsComprehensiveResultMapper.insertCapacityDriver(searchMap);
        if(count > 0){
            return "新增成功";
        }else {
            return "新增失败";
        }
    }
}