package com.shlanbao.tzsc.pms.board.board.service.impl;

import com.shlanbao.tzsc.base.dao.QmOutwardDaoI;
import com.shlanbao.tzsc.base.dao.SchStatFaultDaoI;
import com.shlanbao.tzsc.base.dao.SchWorkorderDaoI;
import com.shlanbao.tzsc.base.service.BaseService;
import com.shlanbao.tzsc.pms.board.board.service.BoardServiceI;
import com.shlanbao.tzsc.pms.qm.self.beans.QmOutWandBean;
import com.shlanbao.tzsc.utils.tools.MathUtil;
import com.shlanbao.tzsc.utils.tools.RedisUtil;
import com.shlanbao.tzsc.utils.tools.StringUtil;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;

@Service
public class BoardServiceImpl extends BaseService implements BoardServiceI {
    @Autowired
    private SchWorkorderDaoI schWorkorderDao;

    @Autowired
    private QmOutwardDaoI qmOutwardDao;

    @Autowired
    private SchStatFaultDaoI schStatFaultDao;

    /**
     * @param type 1-卷接机 2-包装机
     *             {planQtyCount=50.0, data=[{realQty=0, code=R0219123111#010, sts=4, qty=50, id=8aa737836f597cc3016f59831b3b0251}], orderCount=1, openOrder=0, qtyCount=0.0}
     * @return
     * @throws Exception
     */
    @Override
    public Map<String, Object> getRollPackWorkOrder(int type) throws Exception {
//        List<WorkOrderBean> list = new ArrayList<>();
//        String hql = "from SchWorkorder o where o.del=0 and o.isCheck=1 and (o.type = 1 or o.type =2) ";
//        List<SchWorkorder> query = schWorkorderDao.query(hql);
//        if(query==null||query.size()<1) return list;
//        for (int i = 0 ;i<query.size();i++){
//            SchWorkorder order = query.get(i);
//            WorkOrderBean bean = new WorkOrderBean();
//            bean.setId(order.getId());
//            bean.setSts(order.getSts()); //状态
//            bean.setQty(order.getQty()); //计划产量
//            bean.setCode(order.getCode()); //工单号
//            if(order.getMdMat()!=null&&order.getMdMat().getName()!=null) bean.setMat(order.getMdMat().getName());
//            else  bean.setMat("");
//            list.add(bean);
//        }
        Map<String, Object> root = new HashMap<>();
        String sql = "SELECT DISTINCT a.id,a.code,a.QTY,a.STS,b.qty as realQty FROM SCH_WORKORDER a LEFT JOIN SCH_STAT_OUTPUT b on a.id = b.OID WHERE a.IS_CHECK = 1 AND a.DEL = 0 AND  TO_CHAR(a.DATE_,'SYYYY-MM-DD') =  TO_CHAR(SYSDATE, 'SYYYY-MM-DD') AND  SYSDATE BETWEEN a.STIM AND  a.ETIM and a.type = " + type;
        List<?> list = schWorkorderDao.queryBySql(sql);
        List<Map<String, String>> listMe = new ArrayList<>();
        int orderCount = 0;
        int openOrder = 0;
        double planQtyCount = 0;
        double qtyCount = 0;
        if (list != null && list.size() > 0) {
            for (Object o : list) {
                Map<String, String> map = new HashMap<>();
                Object[] temp = (Object[]) o;
                map.put("id", StringUtil.convertObjToString(temp[0]));
                map.put("code", StringUtil.convertObjToString(temp[1]));
                map.put("qty", StringUtil.convertObjToString(temp[2]));
                map.put("sts", StringUtil.convertObjToString(temp[3]));
                map.put("realQty", StringUtil.convertObjToString(temp[4]));
                listMe.add(map);
                orderCount = listMe.size();
                //统计数据
                if (StringUtil.notEmpty(map.get("sts"))) {
                    if (Integer.parseInt(map.get("sts")) == 2) {
                        openOrder += 1;
                    }
                }
                if (StringUtil.notEmpty(map.get("qty"))) {
                    planQtyCount += Double.parseDouble(map.get("qty"));
                }
                if (StringUtil.notEmpty(map.get("realQty"))) {
                    qtyCount += Double.parseDouble(map.get("realQty"));
                }

            }
        }
        root.put("data", listMe);
        root.put("orderCount", orderCount);
        root.put("openOrder", openOrder);
        root.put("planQtyCount", planQtyCount);
        root.put("qtyCount", qtyCount);
        return root;
    }

    /**
     * @return {data=[{name=1月, value=0.0}, {name=2月, value=0.0}, {name=3月, value=0.0}, {name=4月, value=0.0}, {name=5月, value=0.0}, {name=6月, value=7.0}, {name=7月, value=944.8}, {name=8月, value=0.0}, {name=9月, value=0.0}, {name=10月, value=0.0}, {name=11月, value=0.0}, {name=12月, value=0.0}]}
     * @throws Exception
     */
    @Override
    public Map<String, Object> getYearMonthQty() throws Exception {
        Map<String, Object> root = new HashMap<>();
        List<Map<String, Object>> data = new ArrayList<>();
        String sql = "select DISTINCT" +
                "       sum(decode(to_char(a.DATE_,'MM'),'01',b.QTY,0)) month1,sum(decode(to_char(a.DATE_,'MM'),'02',b.QTY,0)) month2," +
                "       sum(decode(to_char(a.DATE_,'MM'),'03',b.QTY,0)) month3,sum(decode(to_char(a.DATE_,'MM'),'04',b.QTY,0)) month4," +
                "       sum(decode(to_char(a.DATE_,'MM'),'05',b.QTY,0)) month5,sum(decode(to_char(a.DATE_,'MM'),'06',b.QTY,0)) month6," +
                "       sum(decode(to_char(a.DATE_,'MM'),'07',b.QTY,0)) month7,sum(decode(to_char(a.DATE_,'MM'),'08',b.QTY,0)) month8," +
                "       sum(decode(to_char(a.DATE_,'MM'),'09',b.QTY,0)) month9,sum(decode(to_char(a.DATE_,'MM'),'10',b.QTY,0)) month10," +
                "       sum(decode(to_char(a.DATE_,'MM'),'11',b.QTY,0)) month11,sum(decode(to_char(a.DATE_,'MM'),'12',b.QTY,0)) month12" +
                "       FROM SCH_WORKORDER a LEFT JOIN SCH_STAT_OUTPUT b on a.id = b.oid WHERE a.IS_CHECK = 1 AND a.DEL = 0  AND a.TYPE = 3 AND STS = 4  AND TO_CHAR(a.DATE_,'SYYYY') =  TO_CHAR(SYSDATE, 'SYYYY')";
        List<?> list = schWorkorderDao.queryBySql(sql);
        Object[] temp = (Object[]) list.get(0);
        for (int i = 0; i < temp.length; i++) {
            Map<String, Object> map = new HashMap<>();
            map.put("value", StringUtil.convertObjToDouble(temp[i]));
            map.put("name", i + 1 + "月");
            data.add(map);
        }
        root.put("data", data);

        return root;
    }

    /**
     * @return {xaxis=[07-27, 07-28, 07-29, 07-30, 07-31, 08-01, 08-02], dime=[product, 卷接机, 包装机, 封箱机, 成型机], data=[{product=07-27, 包装机=0.0, 封箱机=0.0, 成型机=0.0, 卷接机=0.0}, {product=07-28, 包装机=0.0, 封箱机=0.0, 成型机=0.0, 卷接机=0.0}, {product=07-29, 包装机=0.0, 封箱机=0.0, 成型机=0.0, 卷接机=0.0}, {product=07-30, 包装机=3.2, 封箱机=0.0, 成型机=0.0, 卷接机=0.0}, {product=07-31, 包装机=0.0, 封箱机=0.0, 成型机=0.0, 卷接机=0.0}, {product=08-01, 包装机=0.0, 封箱机=0.0, 成型机=0.0, 卷接机=0.0}, {product=08-02, 包装机=0.0, 封箱机=0.0, 成型机=0.0, 卷接机=71.72}]}
     * @throws Exception
     */
    @Override
    public Map<String, Object> getSevenDayQty() throws Exception {
        //所有数据
        Map<String, Object> root = new HashMap<>();
        //组装后四种设备七天数据
        List<Map<String, Object>> data = new ArrayList<>();
        //四种设备七天原始数据
        List<Map<String, Object>> res = new ArrayList<>();
        List<String> dimensions = new ArrayList<>();
        //获取四个类型设备近七天数据
        for (int i = 1; i <= 4; i++) {
            Map<String, Object> equData = getEquData(i);
            res.add(equData);
        }
        //echart的dimensions
        dimensions.add("product");
        dimensions.add("卷接机");
        dimensions.add("包装机");
        dimensions.add("封箱机");
        dimensions.add("成型机");


//        List<String> week = Arrays.asList("周一", "周二", "周三", "周四", "周五", "周六", "周日");
        List<String> week = getDay();
        //将四个设备七天数据组合为 echart需要格式 product:日期  卷接机:'value'  包装机:'value'  封箱机:'value'  成型机:'value'
        for (int i = 0; i < 7; i++) {
            //一天的数据容器
            Map<String, Object> item = new HashMap<>();

            item.put("product", "" + (week.get(i)));
            for (int j = 0; j < res.size(); j++) {
                Map<String, Object> map = res.get(j);
                item.put(dimensions.get(j + 1), map.get("day" + i));
            }
            data.add(item);
        }

        root.put("data", data);
        root.put("dime", dimensions);
        root.put("xaxis", week);

        return root;
    }


    /**
     * @return {xaxis=[07-27, 07-28, 07-29, 07-30, 07-31, 08-01, 08-02], data4=[0.0, 0.0, 0.0, 0.0, 0.0, 0.0, 0.0], data3=[0.0, 0.0, 0.0, 0.0, 0.0, 0.0, 0.0], data2=[0.0, 0.0, 0.0, 4.0, 0.0, 0.0, 0.0], data1=[0.0, 0.0, 0.0, 0.0, 0.0, 0.0, 39.0]}
     * @throws Exception
     */
    @Override
    public Map<String, Object> getEquEffe() throws Exception {
        Map<String, Object> root = new HashMap<>();
        for (int i = 1; i <= 4; i++) {
            List<Double> effe = getEffe(i);
            root.put("data" + i, effe);
        }
        List<String> week = getDay();
        root.put("xaxis", week);
        return root;
    }


    /**
     * 获取一个设备类型近七天有效作用率
     * sql说明：
     * 有效作业率的公式=产量/（生产时间*8.4）*100%
     * 生产时间=工单时间-a-b-c-d
     * 变量a=吃饭时间（可设置，默认0.5）
     * 变量b=保养时间（可设置，默认0.5）
     * 变量c=换牌时间（如果有换牌， 默认0.7）
     * 变量d=非正常停机时间（可设置，默认0）
     * <p>
     * sql解释
     * 由于统计出'工单时间' 可能为 0，会导致除数不能为 '0' 的错误，所有使用decode函数
     * decode(工单时间，0，0，(产量/工单时间))   TODO 优化sql过长
     * 含义解释：
     * decode(条件,值1,返回值1,缺省值) tip：当工单时间为0，直接返回0，不去计算
     * <p>
     * 数据日期(SYSDATE- 6)与 getDay()方法关联 TODO
     *
     * @param type 设备类型
     * @return
     */
    public List<Double> getEffe(int type) {
        String sql = "select  DISTINCT" +
                "    DECODE( (sum(decode(FLOOR(SYSDATE-a.DATE_),7,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4), 0,0 , ( sum(decode(FLOOR(SYSDATE-a.DATE_),7,b.QTY,0)) / (sum(decode(FLOOR(SYSDATE-a.DATE_),7,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4))) day1," +
                "    DECODE( (sum(decode(FLOOR(SYSDATE-a.DATE_),6,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4), 0,0 , ( sum(decode(FLOOR(SYSDATE-a.DATE_),6,b.QTY,0)) / (sum(decode(FLOOR(SYSDATE-a.DATE_),6,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4))) day2," +
                "    DECODE( (sum(decode(FLOOR(SYSDATE-a.DATE_),5,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4), 0,0 , ( sum(decode(FLOOR(SYSDATE-a.DATE_),5,b.QTY,0)) / (sum(decode(FLOOR(SYSDATE-a.DATE_),5,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4))) day3," +
                "    DECODE( (sum(decode(FLOOR(SYSDATE-a.DATE_),4,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4), 0,0 , ( sum(decode(FLOOR(SYSDATE-a.DATE_),4,b.QTY,0)) / (sum(decode(FLOOR(SYSDATE-a.DATE_),4,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4))) day4," +
                "    DECODE( (sum(decode(FLOOR(SYSDATE-a.DATE_),3,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4), 0,0 , ( sum(decode(FLOOR(SYSDATE-a.DATE_),3,b.QTY,0)) / (sum(decode(FLOOR(SYSDATE-a.DATE_),3,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4))) day5," +
                "    DECODE( (sum(decode(FLOOR(SYSDATE-a.DATE_),2,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4), 0,0 , ( sum(decode(FLOOR(SYSDATE-a.DATE_),2,b.QTY,0)) / (sum(decode(FLOOR(SYSDATE-a.DATE_),2,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4))) day6," +
                "    DECODE( (sum(decode(FLOOR(SYSDATE-a.DATE_),1,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4), 0,0 , ( sum(decode(FLOOR(SYSDATE-a.DATE_),1,b.QTY,0)) / (sum(decode(FLOOR(SYSDATE-a.DATE_),1,TO_NUMBER((a.ETIM- a.STIM)*24)-0.7*(SELECT COUNT(*) FROM SCH_SHIFT_EXCHG WHERE HO_ORDER = a.id AND ROWNUM = 1) - 0.5   - 0.5 - 0,0)) * 8.4))) day7" +
                "    FROM SCH_WORKORDER a LEFT JOIN SCH_STAT_OUTPUT b on a.id = b.oid WHERE a.IS_CHECK = 1 AND a.DEL = 0 AND STS = 4  AND a.TYPE = " + type +
                "    AND  a.DATE_  > (SYSDATE- 7)";
        List<?> list = schWorkorderDao.queryBySql(sql);
        Object[] temp = (Object[]) list.get(0);
        List<Double> data = new ArrayList<>();
        for (int i = 0; i < temp.length; i++) {
            data.add(StringUtil.convertObjTox100Double(temp[i])>90?90:StringUtil.convertObjTox100Double(temp[i]));
        }
        return data;
    }


    /**
     * 获取设备一周数据
     * 数据日期(SYSDATE- 6)与 getDay()方法关联 TODO
     *
     * @param type
     * @return
     */
    public Map<String, Object> getEquData(int type) {
        String sql = "select DISTINCT" +
                " sum(decode(FLOOR (SYSDATE-a.DATE_),7,b.QTY,0)) day1, " +
                " sum(decode(FLOOR (SYSDATE-a.DATE_),6,b.QTY,0)) day2, " +
                " sum(decode(FLOOR (SYSDATE-a.DATE_),5,b.QTY,0)) day3, " +
                " sum(decode(FLOOR (SYSDATE-a.DATE_),4,b.QTY,0)) day4, " +
                " sum(decode(FLOOR (SYSDATE-a.DATE_),3,b.QTY,0)) day5, " +
                " sum(decode(FLOOR (SYSDATE-a.DATE_),2,b.QTY,0)) day6, " +
                " sum(decode(FLOOR (SYSDATE-a.DATE_),1,b.QTY,0)) day7  " +
                " FROM SCH_WORKORDER a LEFT JOIN SCH_STAT_OUTPUT b on a.id = b.oid WHERE a.IS_CHECK = 1 AND a.DEL = 0  AND a.TYPE = " + type +
                " AND STS = 4  AND   a.DATE_  > (SYSDATE- 7) ";
        Map<String, Object> map = new HashMap<>();
        List<?> list = schWorkorderDao.queryBySql(sql);
        Object[] temp = (Object[]) list.get(0);
        for (int i = 0; i < temp.length; i++) {
            map.put("day" + i, StringUtil.convertObjToDouble(temp[i]));
        }
        return map;
    }

    /**
     * 根据当前获取前六天日期
     * 重要：方法为图表x轴取日期，需要和数据库限制日期一致
     *
     * @return
     */

    private List<String> getDay() {
        List<String> list = new ArrayList<>();
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        Calendar c = Calendar.getInstance();
        for (int i = 7; i > 0; i--) {
            c.add(Calendar.DATE, -1);
            String temp = format.format(c.getTime());
            list.add(temp);
        }
        Collections.sort(list, new Comparator<String>() {
            @Override
            public int compare(String o1, String o2) {
                return o1.compareTo(o2);
            }
        });
        for (int i = 0; i < list.size(); i++) {
            list.set(i, list.get(i).substring(5));
        }

        return list;
    }

    /**
     * 获取设备最高运行效率
     * ID                         	TYPE	STIM         	  ETIM	          EQUIPMENT_CODE	MINUTE
     * 4028ab09740e83c401740eb97d1a0007	2	2020-08-21 07:30:00	 2020-08-21 17:30:00	201	       153.36
     * 运行效率=运行时间/（当前服务器时间-计划班次开始时间）×100%
     */
    @Override
    public Map<String, Object> getEquMax() throws Exception {
        String sql = "SELECT a.id,a.type,a.STIM,a.ETIM,b.EQUIPMENT_CODE,(SYSDATE - a.STIM)*60*24 as minute,a.shift  FROM SCH_WORKORDER a " +
                " LEFT JOIN MD_EQUIPMENT b on a.EQP = b.id" +
                " WHERE   TO_CHAR(a.DATE_,'SYYYY-MM-DD') =  TO_CHAR(SYSDATE, 'SYYYY-MM-DD') " +
                " AND  SYSDATE BETWEEN  a.STIM AND  a.ETIM  ";
        Map<String, Object> root = new HashMap<>();
        List<Map<String, String>> resitem = new ArrayList<>();
        //1.数据分类
        List<?> list = schWorkorderDao.queryBySql(sql);
        //卷接机
        List<Map<String, String>> list1 = new ArrayList<>();
        //包装机
        List<Map<String, String>> list2 = new ArrayList<>();
        //封箱机
        List<Map<String, String>> list3 = new ArrayList<>();
        //成型机
        List<Map<String, String>> list4 = new ArrayList<>();
        if (list != null && list.size() > 0) {
            for (Object o : list) {
                Map<String, String> map = new HashMap<>();
                Object[] temp = (Object[]) o;
                String id = StringUtil.convertObjToString(temp[0]);
                String type = StringUtil.convertObjToString(temp[1]);
                String stim = StringUtil.convertObjToString(temp[2]);
                String etim = StringUtil.convertObjToString(temp[3]);
                String equCode = StringUtil.convertObjToString(temp[4]);
                String minute = StringUtil.convertObjToString(temp[5]);
                String shift = StringUtil.convertObjToString(temp[6]);
                map.put("id", id);
                map.put("type", type);
                map.put("stim", stim);
                map.put("etim", etim);
                map.put("equCode", equCode);
                map.put("minute", minute);
                map.put("shift", shift);
                getRedisRunTime(map);
                if (StringUtil.notEmpty(type)) {
                    switch (type) {
                        case "1":
                            list1.add(map);
                            break;
                        case "2":
                            list2.add(map);
                            break;
                        case "3":
                            list3.add(map);
                            break;
                        case "4":
                            list4.add(map);
                            break;
                    }
                }
            }
        }

        //2.每种设备到redis获取数据并比较大小
        Map<String, String> res1 = listMax(list1);
        Map<String, String> res2 = listMax(list2);
        Map<String, String> res3 = listMax(list3);
        Map<String, String> res4 = listMax(list4);
        root.put("data1",res1);
        root.put("data2",res2);
        root.put("data3",res3);
        root.put("data4",res4);
        return root;
    }
    /**
    * 获取效率最高机台
    * */
    private  Map<String, String> listMax( List<Map<String, String>> list){
        //没有数据返回空数据
        if(list.size()<1) return  new HashMap<>();
        return Collections.max(list, new Comparator<Map<String, String>>() {
            @Override
            public int compare(Map<String, String> o1, Map<String, String> o2) {
                return o1.get("runeffe").compareTo(o2.get("runeffe"));
            }
        });
    }

    /**
     * 根据班次何设备code 获取redis  数据
     */
    public Map<String, String> getRedisRunTime(Map<String, String> map) {
        if (map.get("shift").isEmpty() || map.get("equCode").isEmpty()) {
            map.put("runtime", "0");   //运行时间
            map.put("runeffe", "0");   //运行效率
            map.put("stopTime", "0"); //停机时间
            map.put("stopTimes", "0");//停机次数
        } else {
            String runkey = "runTime";
            String stopkey = "stopTime";
            String timesKey = "stopTimes";
            int xs = 1;
            if("2".equals(map.get("type"))){
                runkey = "chcRunTime";
                stopkey = "chcStopTime";
                timesKey = "chcStopTimes";
                xs = 60;
            } else if("4".equals(map.get("type"))){
                xs = 60;
            }
            Map redis = RedisUtil.getMap(map.get("shift") + map.get("equCode"));

            double runTime = 0;
            if (!redis.isEmpty() && redis.get(runkey) != null && !"".equals(redis.get(runkey).toString().trim())) {
                try {
                    runTime = StringUtil.converObj2Double(redis.get(runkey).toString())/xs;
                } catch (Exception e) {
                    System.out.println(map.get("equCode"));
                    e.printStackTrace();
                }
            }
            double minute = 0;
            if (map.get("minute") != null) {
                try {
                    minute = Double.parseDouble(map.get("minute"));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            double stopTime = 0;
            if (redis.get(stopkey) != null) {
                stopTime = MathUtil.roundHalfUp(StringUtil.converObj2Double(redis.get(stopkey).toString())/xs,2);

            }

            String stopTimes = "0";
            if (redis.get(timesKey) != null) {
                stopTimes =  redis.get(timesKey).toString();
            }
            map.put("runtime", runTime + "");
            map.put("runeffe", "0");
            map.put("stopTime",stopTime + "");
            map.put("stopTimes", stopTimes);
            if (runTime > 0 && minute > 0) {
                double time = runTime / minute * 100;
                //TODO 避免redis
                if(time>100) time = 100;
                DecimalFormat df = new DecimalFormat("#.00");
                String format = df.format(time);
                map.put("runeffe", format);
            }
        }

        return map;
    }


    @Override
    public List<QmOutWandBean> queryLastMonthWgqx() {
        String sql = "SELECT c.code,c.name,c.type,c.pos,c.des,c.lvl,c.minusscore,b.val FROM QM_OUTWARD a JOIN  QM_OUTWARD_DET b on a.id = b.QO_ID  " +
                "JOIN QM_OUTWARD_DEFECT_ITEM c on b.item=c.id  " +
                "WHERE time >=   SYSDATE - 30 " ;

        List<?> datas = qmOutwardDao.queryBySql(sql);
        List<QmOutWandBean> beans=new ArrayList<>();
        Object[] obj=null;
        QmOutWandBean bean=null;
        for (Object object : datas) {
            obj=(Object[]) object;
            bean=new QmOutWandBean();
            bean.setCode(StringUtil.convertObjToString(obj[0]));
            bean.setName(StringUtil.convertObjToString(obj[1]));
            bean.setType(StringUtil.convertObjToString(obj[2]));
            bean.setPos(StringUtil.convertObjToString(obj[3]));
            bean.setDes(StringUtil.convertObjToString(obj[4]));
            bean.setLvl(StringUtil.convertObjToString(obj[5]));
            bean.setMinusScore(StringUtil.convertObjToString(obj[6]));
            String val = StringUtil.convertObjToString(obj[7]);
            if(!StringUtils.isEmpty(val)){
                bean.setValue(Integer.parseInt(val));
                beans.add(bean);
            }


        }
        return beans;
    }

    @Override
    public List<Map<String, Object>> queryLastMonthTc() {
        String sql = "SELECT a.TYPE tctype, a.id tcid, to_char( b.date_, 'yyyy-MM-dd' ) AS date_, a.name AS faultName, a.time AS faultTime, a.times AS faultTimes, nvl( c.MAIN_BAD_QTY, 0 ) AS badQty " +
                "FROM SCH_STAT_FAULT a, SCH_WORKORDER b, SCH_STAT_OUTPUT c " +
                "WHERE a.status = 1  AND a.TYPE = '卷接剔除'  AND b.del = 0  AND b.sts IN ( 2, 4 )  AND a.oid = c.id  AND c.oid = b.id AND b.date_ >= SYSDATE - 30 " ;
        List<?> datas = schWorkorderDao.queryBySql(sql);
        List<Map<String,Object>> beans=new ArrayList<>();
        Object[] obj=null;
        Map<String,Object> bean=null;
        for (Object object : datas) {
            obj=(Object[]) object;
            bean=new HashMap<>();
            bean.put("name",StringUtil.convertObjToString(obj[3]));
            bean.put("value",StringUtil.convertObjToString(obj[4]));
            beans.add(bean);
        }
        return beans;
    }

}