package com.ld.igds.sh.service;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.log.service.InteStatusLogService;
import com.ld.igds.models.Grain;
import com.ld.igds.models.InteStatusLog;
import com.ld.igds.sh.dto.ApiResponse;
import com.ld.igds.sh.dto.Dto1401;
import com.ld.igds.sh.param.ApiRequest;
import com.ld.igds.sh.param.BaseParam;
import com.ld.igds.sh.service.impl.HApiShServiceImpl;
import com.ld.igds.sh.util.ApiShConst;
import com.ld.igds.sh.util.ApiShUtil;
import com.ld.igds.sh.util.RespCodeEnum;
import com.ld.igds.sh.util.RespUtil;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.util.RedisUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateFormatUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

/**
 * 温湿度检测接口
 *
 * @author chen
 */
@Slf4j
@Service
public class ApiShServiceImpl1401 implements ApiShService {

    @Autowired
    private HApiShServiceImpl hApiShServiceImpl;
    @Autowired
    private InteStatusLogService inteStatusLogService;
    @Autowired
    private RedisUtil redisUtil;
    @Override
    public String getInterfaceId() {
        return ApiShConst.API_SH_1401;
    }

    @SuppressWarnings("unchecked")
    @Override
    public ApiResponse<Object> execute(ApiRequest<Object> request){
        //获取参数信息
        String deptId = request.getDeptId();
        BaseParam param = JSONObject.parseObject(JSONObject.toJSONString(request.getData()), BaseParam.class);

        String companyId = ContextUtil.getDefaultCompanyId();

//        String key = RedisConst.buildKey(companyId, ApiShConst.API_SH_1112);
//        Date startTime = (Date) redisUtil.get(key);
//        if(null == startTime){
//            startTime = DateUtils.addDays(param.getEndTime(), -30);
//        }
//        redisUtil.set(key, param.getEndTime());
        if(null == param.getStartTime()){
            param.setStartTime(DateUtils.addDays(param.getEndTime(), -1));
        }

        //查询温湿度信息，即粮情信息
        List<Grain> dataList = hApiShServiceImpl.listGrain(companyId,
                param.getDepotId(), param.getStartTime(), param.getEndTime());

        //响应数据为空则直接返回响应码2000
        if (dataList == null || dataList.isEmpty()) {
            return RespUtil.error(RespCodeEnum.CODE_2000.getCode(), request);
        }

        List<Dto1401> list = new ArrayList<>();
        Dto1401 dto1401;
        InteStatusLog log;
        InteStatusLog addLog;
        Calendar c = Calendar.getInstance();
        //封装数据信息
        for (Grain grain : dataList) {
            dto1401 = new Dto1401();
            dto1401.setLqjcbm(ApiShUtil.getGbDepotId(grain.getDepotId()) + grain.getBatchId());
            dto1401.setJcsj(DateFormatUtils.format(grain.getReceiveDate(), "yyyy-MM-dd HH:mm:ss"));

            dto1401.setHwbm(ApiShUtil.getGbDepotId(grain.getDepotId()) + "01");
            dto1401.setCfww(String.valueOf(grain.getTempOut()));
            dto1401.setCfws(String.valueOf(grain.getHumidityOut()));
            dto1401.setCfnw(String.valueOf(grain.getTempIn()));
            dto1401.setCfns(String.valueOf(grain.getHumidityIn()));
            dto1401.setZgw(String.valueOf(grain.getTempMax()));
            dto1401.setZdw(String.valueOf(grain.getTempMin()));
            dto1401.setPjw(String.valueOf(grain.getTempAve()));
            if (StringUtils.isEmpty(grain.getCableCir())) {
                dto1401.setLswdzjh(getPointList1(grain.getPoints(), grain.getCable()));
            } else {
                dto1401.setLswdzjh(getPointList2(grain.getPoints(), grain.getCable(), grain.getCableCir()));
            }
            dto1401.setNm(ApiShUtil.getGbDepotId(grain.getDepotId()).substring(0, 21));
            dto1401.setZznm(ApiShUtil.getGbDepotId(grain.getDepotId()).substring(0, 21));
            dto1401.setCfnm(ApiShUtil.getGbDepotId(grain.getDepotId()).substring(0, 25));
            dto1401.setDqwd(String.valueOf(grain.getTempOut()));
            dto1401.setDqsd(String.valueOf(grain.getHumidityOut()));
            dto1401.setCnwd(String.valueOf(grain.getTempIn()));
            dto1401.setCnsd(String.valueOf(grain.getHumidityIn()));
            dto1401.setZgwd(String.valueOf(grain.getTempMax()));
            dto1401.setZdwd(String.valueOf(grain.getTempMin()));
            dto1401.setPjlw(String.valueOf(grain.getTempAve()));

            dto1401.setCpjw(String.valueOf(grain.getTempAve()));
            dto1401.setCzgw(String.valueOf(grain.getTempAve()));
            dto1401.setCzdw(String.valueOf(grain.getTempAve()));
            dto1401.setGfwjw(String.valueOf(grain.getTempAve()));
            dto1401.setLwmx(dto1401.getLswdzjh());
            dto1401.setSf(dto1401.getLswdzjh());
            dto1401.setJwrq(DateFormatUtils.format(grain.getReceiveDate(), "yyyy-MM-dd"));
            dto1401.setJwsj(DateFormatUtils.format(grain.getReceiveDate(), "HH:mm:ss"));
            c.setTime(grain.getReceiveDate());
            dto1401.setXq((c.get(Calendar.DAY_OF_WEEK) - 1) + "");
            dto1401.setPcid(grain.getBatchId());

            dto1401.setZhgxsj(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
            //查询日志状态表，设置操作标志
            log = inteStatusLogService.getLogByBizId(companyId, ApiShConst.API_SH_1401 + "_" + grain.getBatchId());
            if(null == log){
                dto1401.setTjbz("0"); //未提交
                addLog = new InteStatusLog();
                addLog.setBizId(ApiShConst.API_SH_1401 + "_" + grain.getBatchId());
                addLog.setCompanyId(companyId);
                addLog.setBizType(ApiShConst.API_SH_TYPE_TASK);
                addLog.setInterfaceId(ApiShConst.API_SH_1401);
                addLog.setInterfaceType(ApiShConst.API_SH_TYPE_TASK);
                addLog.setStatus(ApiShConst.API_SH_STATUS_SUCCESS);

                inteStatusLogService.addInteStatusLog(addLog);
            }else {
                dto1401.setTjbz("1"); //已提交
                dto1401.setCzbz(ApiShConst.API_SH_U);
            }
            list.add(dto1401);
        }

        //响应数据为空则直接返回响应码2000
        if (list.isEmpty()) {
            return RespUtil.error(RespCodeEnum.CODE_2000.getCode(), request);
        }

        return RespUtil.success(list, request);
    }

    /**
     * 获取平方仓的温度值集合，格式：温度值,层数,行数,列数|温度值,层数,行数,列数|温度值,层数,行数,列数
     *
     * @return
     */
    private String getPointList1(String point, String cable) {
        String[] cab = cable.split("-");
        int c = Integer.valueOf(cab[0]);
        int h = Integer.valueOf(cab[1]);
        int l = Integer.valueOf(cab[2]);

        String[] points = point.split(",");
        String result = "";
        for (int i = 1; i <= l; i++){
            for (int j = 1; j <= h; j++){
                for (int z = 1; z <= c; z++){
                    if((i*j-1)*c + z - 1 < points.length){
                        result += ("|" + points[(i*j-1)*c + z - 1] + "," + z + "," + j + "," + i);
                    }
                }
            }
        }
        return result.substring(1);
    }

    /**
     * 获取筒仓的温度值集合，格式：温度值,圈数,点数,层数|温度值,圈数,点数,层数|温度值,圈数,点数,层数
     *
     * @return
     */
    private String getPointList2(String point, String cable, String cableCir) {
        String[] cab = cable.split("-");
        String[] cabCir = cableCir.split("-");

        int q = cab.length;  //圈数
        int c = Integer.valueOf(cabCir[0]);  //层数
        int g = 0;  //圈根数
        int g1 = 1;  //圈起始根数
        int g2 = 0;  //圈截止根数

        String[] points = point.split(",");
        String result = "";
        for (int i = 1; i <= q; i++){
            g1 += g2;
            g = Integer.valueOf(cab[i-1]);
            g2 += g;
            for (int j = g1; j <= g2; j++){
                for (int z = 1; z <= c; z++){
                    if((j - 1) * c + z - 1 < points.length) {
                        result += ("|" + points[(j - 1) * c + z - 1] + "," + i + "," + j + "," + z);
                    }
                }
            }

        }
        return result.substring(1);
    }
}