潘钊 / bsth_control · Files

package com.bsth.service.directive;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.bsth.common.ResponseCode;
import com.bsth.data.BasicData;
import com.bsth.data.directive.DayOfDirectives;
import com.bsth.data.directive.DirectiveCreator;
import com.bsth.data.directive.GatewayHttpUtils;
import com.bsth.data.gpsdata_v2.GpsRealData;
import com.bsth.data.gpsdata_v2.entity.GpsEntity;
import com.bsth.data.pilot80.PilotReport;
import com.bsth.data.schedule.DayOfSchedule;
import com.bsth.data.schedule.edit_logs.service.dto.SchEditInfoDto;
import com.bsth.data.utils.ListFilterUtils;
import com.bsth.data.utils.ListPageQueryUtils;
import com.bsth.entity.directive.*;
import com.bsth.entity.realcontrol.ScheduleRealInfo;
import com.bsth.entity.realcontrol.ScheduleRealInfoTag;
import com.bsth.entity.sys.SysUser;
import com.bsth.repository.directive.D60Repository;
import com.bsth.repository.directive.D64Repository;
import com.bsth.repository.directive.D80Repository;
import com.bsth.security.util.SecurityUtils;
import com.bsth.service.directive.dto.DeviceConfigDto;
import com.bsth.service.impl.BaseServiceImpl;
import com.bsth.websocket.handler.RealControlSocketHandler;
import com.bsth.websocket.handler.SendUtils;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.base.Splitter;
import com.google.common.collect.Lists;
import org.apache.commons.lang3.StringEscapeUtils;
import org.apache.commons.lang3.StringUtils;
import org.joda.time.format.DateTimeFormat;
import org.joda.time.format.DateTimeFormatter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestParam;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;

@Service
public class DirectiveServiceImpl extends BaseServiceImpl<D60, Integer> implements DirectiveService {

    Logger logger = LoggerFactory.getLogger(this.getClass());

    @Autowired
    D60Repository d60Repository;

    @Autowired
    GpsRealData gpsRealDataBuffer;

    @Autowired
    D64Repository d64Repository;

    @Autowired
    RealControlSocketHandler socketHandler;

    @Autowired
    D80Repository d80Repository;

    @Autowired
    DayOfDirectives dayOfDirectives;

    @Autowired
    PilotReport pilotReport;

    @Autowired
    DayOfSchedule dayOfSchedule;

    @Autowired
    JdbcTemplate jdbcTemplate;

    @Autowired
    BasicData basicData;

    @Autowired
    SendUtils sendUtils;

    //static Long schDiff = 1000 * 60 * 60L;

    private static DateTimeFormatter fmtHHmm = DateTimeFormat.forPattern("HH:mm"), fmtHHmm_CN = DateTimeFormat.forPattern("HH点mm分");

    @Override
    public int send60Phrase(String nbbm, String text, String sender) {
        D60 d60 = null;
        try {
            text = StringEscapeUtils.unescapeHtml4(text);
            text = text.replaceAll("#", "");
            d60 = create60Data(nbbm, text, (short) 0x00, null);
        } catch (Exception e) {
            logger.error("发送消息短语出现异常", e);
            return -1;
        }

        if (null == d60)
            return -1;

        // 发送指令
        int code = GatewayHttpUtils.postJson(JSON.toJSONString(d60));
        if (null != sender)
            d60.setSender(sender);
        d60.setHttpCode(code);

        if (code != 0)
            d60.setErrorText("网关通讯失败, code: " + code);

        dayOfDirectives.put60(d60);
        return code;
    }

    @Override
    public int send60Dispatch(ScheduleRealInfo sch, int finish, String sender, String txtPrefix) {
        D60 d60 = null;
        try {
            if (sch.isDestroy()) {
                logger.warn("烂班不允许发送调度指令....");
                return -1;
            }

            //待发应到时间
            String dfsj = fmtHHmm.print(sch.getDfsjT() + (sch.getBcsj() * 60 * 1000));
            String text = "您已完成" + finish + "个班次，下一发车时间" + fmtHHmm_CN.print(sch.getDfsjT()) + "，由"
                    + sch.getQdzName() + "发往" + sch.getZdzName() + ";应到 " + dfsj;

            if(sch.getBcType().equals("venting")){
                text += " (直放)";
            }
            else if(sch.getBcType().equals("major")){
                text += " (放站到"+sch.getMajorStationName()+"带客)";
            } else if ("ldks".equals(sch.getBcType())) {
            	text += " (两点空驶)";
            }

            //下发0x02指令  调度指令(闹钟有效)
            long t = System.currentTimeMillis() + 1000 * 30,
                    alarmTime = sch.getDfsjT() < t?t:sch.getDfsjT();

            if(StringUtils.isNotEmpty(txtPrefix)){
                text = txtPrefix + text;
            }
            text = StringEscapeUtils.unescapeHtml4(text);
            int state = 0;//营运状态
            if(dayOfSchedule.emptyService(sch))
                state = 1;
            d60 = new DirectiveCreator().createD60_02(sch.getClZbh(), text, Integer.parseInt(sch.getXlDir())
                    , state, new Date(alarmTime));

            d60.setLineCode(sch.getXlBm());
        } catch (Exception e) {
            logger.error("生成调度指令时出现异常", e);
            return -1;
        }

        if (null == d60)
            return -1;

        d60.setSender(sender);

        JSONObject jObj = JSON.parseObject(JSON.toJSONString(d60));

        //进场或者出场班次时，附加lock 标识
        if (null != sch.getBcType()
                && (sch.getBcType().equals("out") || sch.getBcType().equals("in"))) {

            jObj.put("lock", 1);
        }

        // 发送指令
        int code = GatewayHttpUtils.postJson(jObj.toJSONString());

        d60.setDispatch(true);
        d60.setSch(sch);
        d60.setHttpCode(code);

        if (code == 0) {
            sch.setDirectiveState(60);
            // 通知页面
            sendD60ToPage(sch);
        } else {
            d60.setErrorText("网关通讯失败, code: " + code);
        }

        dayOfDirectives.put60(d60);
        return code;
    }

    /**
     * @Title: sendDirectiveState @Description: TODO(向页面推送班次指令状态) @throws
     */
    @Override
    public void sendD60ToPage(ScheduleRealInfo sch) {
        Map<String, Object> map = new HashMap<>();
        map.put("fn", "directive");
        map.put("t", sch);

        ObjectMapper mapper = new ObjectMapper();

        try {
            socketHandler.sendMessageToLine(sch.getXlBm(), mapper.writeValueAsString(map));
        } catch (JsonProcessingException e) {
            logger.error("", e);
        }
    }

    @Override
    public int send60Dispatch(Long id, String sender) {
        ScheduleRealInfo sch = dayOfSchedule.get(id);
        // 车辆已完成班次
        int finish = dayOfSchedule.doneSum(sch.getClZbh());
        return send60Dispatch(sch, finish, sender, "");
    }

    @Override
    public int send60Operation(String nbbm, int state, int upDown, String sender) {
        logger.info("切换运营状态, nbbm: " + nbbm + " ,state: " + state + " ,upDown:" + upDown);

        String text = "切换为 " + (upDown == 0 ? "上行" : "下行") + (state == 0 ? "营运" : "未营运");
        D60 d60 = new DirectiveCreator().createD60(nbbm, text, (short) 0x03, upDown, state, null);

        if (null == d60)
            return -1;
        if (null != sender)
            d60.setSender(sender);
        else
            d60.setSender("系统");
        // 发送指令
        int code = GatewayHttpUtils.postJson(JSON.toJSONString(d60));
        // 添加到缓存，等待入库
        d60.setHttpCode(code);

        GpsEntity gps = gpsRealDataBuffer.getByNbbm(nbbm);
        if(null != gps)
            d60.setLineCode(gps.getLineId());

        if (code != 0)
            d60.setErrorText("网关通讯失败, code: " + code);

        dayOfDirectives.put60(d60);
        return code;
    }

    /**
     * 线路切换
     */
    @Override
    public int lineChange(String nbbm, String lineCode, String sender) {
        return lineChangeByDeviceId(BasicData.deviceId2NbbmMap.inverse().get(nbbm), lineCode, sender);
    }


    @Override
    public int lineChangeByDeviceId(String deviceId, String lineCode, String sender) {
        DirectiveCreator crt = new DirectiveCreator();
        Long t = System.currentTimeMillis();
        //生成64数据包
        D64 d64 = crt.create64(deviceId, lineCode, t);

        if (null != sender)
            d64.setSender(sender);
        else
            d64.setSender("系统");

        //String deviceId = d64.getDeviceId();
        int code = GatewayHttpUtils.postJson(JSON.toJSONString(d64));
        // 入库
        d64.setHttpCode(code);
        d64.getData().setTxtContent("切换线路[" + BasicData.lineCode2NameMap.get(lineCode) + "]");
        // 通知设备刷新线路文件，忽略结果
        if (code == 0)
            GatewayHttpUtils.postJson(crt.createDeviceRefreshData(deviceId, lineCode));
        else
            d64.setErrorText(" 网关通讯失败, code: " + code);

        dayOfDirectives.put64(d64);
        return code;
    }

    public D60 create60Data(String nbbm, String text, Short dispatchInstruct, ScheduleRealInfo sch) {

        String deviceId = BasicData.deviceId2NbbmMap.inverse().get(nbbm);
        String lineCode = null;
        if (null == deviceId) {
            logger.error("没有设备号对照的车辆：" + nbbm);
            return null;
        }
        // 根据当前GPS确定 上下行和营运状态
        Byte upDown = null;
        Integer state = null;
        if (null == sch) {
            GpsEntity gpsData = gpsRealDataBuffer.get(deviceId);
            if (null == gpsData) {
                /*
				 * 短语指令不会变更设备状态，所以在没有gps状态对照的情况下可以下发
				 * 其他指令在不确定状态的情况下，一律不允许
				 */
                if (dispatchInstruct == 0) {
                    upDown = 0;
                    state = 0;
                } else {
                    logger.error("没有找到gps对照，无法确认营运状态和上下行：" + nbbm);
                    return null;
                }
            } else {
                upDown = gpsData.getUpDown();
                state = gpsData.getState();
                lineCode = gpsData.getLineId();
            }
        } else {
            upDown = Byte.parseByte(sch.getXlDir());
            state = 0;
        }

        return new DirectiveCreator().createD60(nbbm, text, dispatchInstruct, upDown, state, lineCode);
    }

/*    @Override
    public int upDownChange(String nbbm, Integer upDown, String sender) {
        return send60Operation(nbbm, 0, upDown, sender);
    }*/


    @Override
    public Map<String, List<D80>> findNoCofm80(String lineCodes) {
        List<String> lineList = Splitter.on(",").trimResults().splitToList(lineCodes);

        Map<String, List<D80>> rs = new HashMap<>();
        for (String code : lineList)
            rs.put(code, pilotReport.unconfirmed80(code));

        return rs;
    }

    @Override
    public Map<String, Object> reply80(int id, int reply) {
        Map<String, Object> rs = new HashMap<>();
        D80 d80 = pilotReport.findById(id);
        try {
            if (null == d80) {
                rs.put("status", ResponseCode.ERROR);
                rs.put("msg", "服务器没有找到对应数据！");
            } else if (d80.isConfirm()) {
                rs.put("status", ResponseCode.ERROR);
                rs.put("msg", "该数据已经被处理了！");
            } else {
                SysUser user = SecurityUtils.getCurrentUser();
                d80.setC0(reply, user.getUserName());
                // 入库
                d80Repository.save(d80);
                //回复网关
                int code = GatewayHttpUtils.postJson(JSON.toJSONString(d80.getC0()));

                rs.put("status", ResponseCode.SUCCESS);
                if (code != 0)
                    rs.put("msg", "发送C0响应指令到车载设备失败，但该操作已经被系统记录！");

                pilotReport.reply(d80);

                // 通知页面
                Map<String, Object> sockMap = new HashMap<>();
                sockMap.put("fn", "d80Confirm");
                sockMap.put("id", d80.getId());
                sockMap.put("lineId", d80.getData().getLineId());
                socketHandler.sendMessageToLine(d80.getData().getLineId().toString(), JSON.toJSONString(sockMap));
            }
        } catch (Exception e) {
            logger.error("80响应出现异常...", e);
            rs.put("status", ResponseCode.SUCCESS);
        }

        return rs;
    }

    @Override
    public Map<String, Object> findDirective(String nbbms, int dType, int page, int size) {
        Map<String, Object> rsMap = new HashMap<>();
        try{

            List<String> carArray = new ArrayList<>(), deviceArray=new ArrayList<>();
            if(StringUtils.isNotEmpty(nbbms)){
                carArray = Splitter.on(",").splitToList(nbbms);
                //转换成设备号
                Map<String, String> nbbm2deviceMap = BasicData.deviceId2NbbmMap.inverse();
                for(int i = 0, len=carArray.size(); i < len; i++){
                    deviceArray.add(nbbm2deviceMap.get(carArray.get(i)));
                }
            }

            List<Directive> list = new ArrayList<>();
            switch (dType) {
                case -1:
                    //所有指令
                    list = new ArrayList<>(dayOfDirectives.all());
                    break;
                case 0:
                    //调度指令
                    Collection<D60> dptArray = dayOfDirectives.all60();
                    for (D60 d60 : dptArray) {
                        if (d60.isDispatch())
                            list.add(d60);
                    }
                    break;
                case 1:
                    //运营指令
                    Collection<D60> yyArray = dayOfDirectives.all60();
                    for (D60 d60 : yyArray) {
                        if (d60 != null && d60.getData().getDispatchInstruct() == (short) 0x03
                                && !d60.isDispatch())
                            list.add(d60);
                    }
                    break;
                case 2:
                    //线路切换指令
                    list.addAll(dayOfDirectives.all64());
                    break;
                case 3:
                    //消息短语
                    Collection<D60> dyArray = dayOfDirectives.all60();
                    for (D60 d60 : dyArray) {
                        if (d60 != null && d60.getData().getDispatchInstruct() == (short) 0x00
                                && !d60.isDispatch())
                            list.add(d60);
                    }
                    break;
            }

            // 时间倒序
            Collections.sort(list, new DayOfDirectives.DComparator());
            if(deviceArray.size() > 0){
                //按设备号过滤
                List<Directive> subList = new ArrayList<>();
                for (Directive d : list) {
                    if (deviceArray.contains(d.getDeviceId())) {
                        subList.add(d);
                    }
                }
                list = subList;
            }

            for(Directive d : list){
                d.setTimeHHmm(fmtHHmm.print(d.getTimestamp()));
                d.setNbbm(BasicData.deviceId2NbbmMap.get(d.getDeviceId()));
            }

            int count = list.size();
            // 分页
            int s = page * size, e = s + size;

            if (e > count)
                e = count;

            List<Directive> rs = list.subList(s, e);
            rsMap.put("list", rs);
            rsMap.put("totalPages", count % size == 0 ? (count / size - 1) : count / size);
            rsMap.put("page", page);
        }catch (Exception e){
            logger.error("", e);
            throw e;
        }
        return rsMap;
    }

    @Override
    public Map<String, Object> findAll80(Map<String, Object> map, int page, int size) {

        List all = ListFilterUtils.filter(pilotReport.findAll(), map, D80.class);
        //排序
        Collections.sort(all, new Comparator<D80>() {
            @Override
            public int compare(D80 o1, D80 o2) {
                return (int) (o2.getTimestamp() - o1.getTimestamp());
            }
        });
        List<D80> d80s = ListPageQueryUtils.paging(all, page, size);
        //时间格式化
        for (D80 d80 : d80s) {
            d80.setTimeStr(fmtHHmm.print(d80.getTimestamp()));
        }
        Map<String, Object> rsMap = new HashMap<>();
        rsMap.put("list", d80s);
        rsMap.put("totalPages", all.size() % size == 0 ? all.size() / size - 1: all.size() / size);
        rsMap.put("page", page);
        return rsMap;
    }

    @Override
    public D64 save64(D64 d64) {
        return d64Repository.save(d64);
    }

    @Override
    public Map<String, Object> sendC0A4(String nbbm) {
        Map<String, Object> rs = new HashMap<>();

        String deviceId = BasicData.deviceId2NbbmMap.inverse().get(nbbm);

        GpsEntity gps = gpsRealDataBuffer.get(deviceId);
        if(gps == null || gps.isOffline()){
            rs.put("status", ResponseCode.ERROR);
            rs.put("msg", "下发指令失败，设备离线");
            return rs;
        }

        Map<String, Object> c0a4 = new HashMap<>();
        c0a4.put("deviceId", deviceId);
        c0a4.put("timestamp", System.currentTimeMillis());
        c0a4.put("operCode", (short) 0xC0);

        Map<String, Object> data = new HashMap<>();
        data.put("deviceId", deviceId);
        data.put("operCode2", (short) 0xA4);
        c0a4.put("data", data);

        int code = GatewayHttpUtils.postJson(JSON.toJSONString(c0a4));
        if(code != 0){
            rs.put("status", ResponseCode.ERROR);
            rs.put("msg", "和网关通讯失败， code " + code);
        }
        else{
            rs.put("status", ResponseCode.SUCCESS);
        }
        return rs;
    }

    @Override
    public int sendC0A3(DC0_A3 c0a3) {
        GatewayHttpUtils.postJson(JSON.toJSONString(c0a3));
        return 0;
    }

    @Override
    public int sendC0A5(String json) {
        return GatewayHttpUtils.postJson(json);
    }

    @Override
    public int refreshLineFile(String deviceId) {
        GpsEntity gps = gpsRealDataBuffer.get(deviceId);
        if (gps == null)
            return -1;

        return GatewayHttpUtils.postJson(new DirectiveCreator().createDeviceRefreshData(deviceId, gps.getLineId()));
    }

/*    @Override
    public int stateChange(String nbbm, Integer upDown, Integer state, String userName) {
        return send60Operation(nbbm, state, upDown, userName);
    }*/

    @Override
    public Map<String, Object> deviceCofigList(Map<String, String> map, int page, int size) {
        Map<String, Object> rs = new HashMap<>();
        try {
            String conts="";
            if(StringUtils.isNotBlank(map.get("lineId"))){
                conts+=" AND xl='" + map.get("lineId")+"'";
            }
            if(StringUtils.isNotBlank(map.get("nbbm"))){
                conts+=" AND inside_code like '%" + map.get("nbbm")+"%'";
            }
            if(StringUtils.isNotBlank(map.get("deviceId"))){
                conts+=" AND equipment_code like '%" + map.get("deviceId")+"%'";
            }

            String sql = "select * from (SELECT * FROM (SELECT id AS cl_id,inside_code,equipment_code FROM bsth_c_cars ) t1 LEFT JOIN bsth_v_c0_a4 t2 ON t1.equipment_code = t2.id LEFT JOIN (SELECT xl,cl FROM bsth_c_s_ccinfo WHERE id IN (SELECT max(id) FROM bsth_c_s_ccinfo GROUP BY cl)) t3 ON t1.cl_id = t3.cl ORDER BY t2.`timestamp` DESC) t4 where 1=1 "+conts;

            int count = jdbcTemplate.queryForObject("select count(*) from ("+sql+") c1", Integer.class);
            int totalPages = count % size == 0 ? count / size : count / size + 1;
            int s = page * size;
            List<DeviceConfigDto> list = jdbcTemplate.query(sql + " LIMIT " + s + "," + size, new BeanPropertyRowMapper<>(DeviceConfigDto.class));

            rs.put("status", ResponseCode.SUCCESS);
            rs.put("list", list);
            rs.put("totalPages", totalPages);
            rs.put("page", page);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("", e);
            rs.put("status", ResponseCode.ERROR);
        }
        return rs;
    }

    @Transactional
    @Override
    public Map<String,Object> stationSigno(Map<String, Object> map) {
        Map<String, Object> rs = new HashMap<>();
        try {

            String fPlateCode = map.get("fPlateCode")==null?"":map.get("fPlateCode").toString();
            String fBusID = map.get("fBusID")==null?"":map.get("fBusID").toString();
            String fInParkName = map.get("fInParkName")==null?"":map.get("fInParkName").toString().trim();
            Long fOutTime = map.get("fOutTime")==null?0:(Long.parseLong(map.get("fOutTime").toString())*1000);
            int fIsOut = map.get("fIsOut")==null?0:Integer.parseInt(map.get("fIsOut").toString());
            Long fInTime = map.get("fInTime")==null?0:(Long.parseLong(map.get("fInTime").toString())*1000);
            int fInStatus = map.get("fInStatus")==null?0:Integer.parseInt(map.get("fInStatus").toString());
            String fOutParkName = map.get("fOutParkName")==null?"":map.get("fOutParkName").toString().trim();

//            String fInPlate = map.get("fInPlate")==null?"":map.get("fInPlate").toString();
//            String fInStatus = map.get("fInStatus")==null?"":map.get("fInStatus").toString();
//            String fOutStatus = map.get("fOutStatus")==null?"":map.get("fOutStatus").toString();
//            String fOutPlate = map.get("fOutPlate")==null?"":map.get("fOutPlate").toString();
            if(fPlateCode.equals("")){
                rs.put("code",-1);
                rs.put("message","失败");
                rs.put("info","车牌号为空");
                return rs;
            }
            if(fPlateCode.indexOf("沪") != -1){
                String cps1[] = fPlateCode.split("沪");
                fPlateCode = "";
                for (int i=0;i<cps1.length;i++){
                    fPlateCode += cps1[i];
                }
            }
            if(fPlateCode.indexOf("-") != -1){
                String cps1[] = fPlateCode.split("-");
                fPlateCode = "";
                for (int i=0;i<cps1.length;i++){
                    fPlateCode += cps1[i];
                }
            }

            String carPlate  = basicData.plateCompanyNbbmMap.get(fPlateCode);
            if(StringUtils.isEmpty(carPlate)){
                rs.put("code",-1);
                rs.put("message","失败");
                rs.put("info","车牌号不在调度系统中");
                return rs;
            }
            // 是否为补传数据
            boolean isbc = false;
            Long date = new Date().getTime();
            Long timeT = 0l;
            if (fIsOut == 1 && fInStatus != 0 && fInTime != 0) {
                timeT = fInTime;
            } else if (fIsOut == 2 && fOutTime != 0) {
                timeT = fOutTime;
            }
            ScheduleRealInfo sr = null;
            List<ScheduleRealInfo> list = dayOfSchedule.findByNbbm(carPlate);
            int size = list.size();

            // bcwcTime 补传误差允许时间，zcwcTime 正常误差允许时间
            Long bcwcTime = 5*60*1000l;
            Long zcwcTime = 3*60*1000l;
            List<Map<String,Object>> timeL = jdbcTemplate.queryForList("select bcwc_time,zcwc_time from bsth_tag_time");
            if(timeL.size() > 0){
                bcwcTime = Long.parseLong(timeL.get(0).get("bcwc_time").toString());
                zcwcTime = Long.parseLong(timeL.get(0).get("zcwc_time").toString());
            }
            // 大于当前时间5分钟为补传数据
            if(Math.abs(date-timeT) >= bcwcTime){
                for (int i = 0; i < size; i++) {
                    ScheduleRealInfo isr = list.get(i);
                    if (list.get(i).isDestroy())
                        continue;
                    if(fIsOut == 2 && (isr.getQdzName().trim().indexOf(fOutParkName) != -1) && (Math.abs(isr.getDfsjT()-fOutTime)<bcwcTime || (isr.getFcsjActualTime() != null && Math.abs(isr.getFcsjActualTime()-fOutTime)<bcwcTime))){
                        sr = isr;
                        break;
                    }
                    if(fIsOut == 1 && fInStatus != 0 && (isr.getZdzName().trim().indexOf(fInParkName) != -1) && (Math.abs(isr.getZdsjT()-fInTime)<bcwcTime || (isr.getZdsjActualTime() != null && Math.abs(isr.getZdsjActualTime()-fInTime)<bcwcTime))){
                        sr = isr;
                        break;
                    }
                }
                if(sr==null){
                    rs.put("code",0);
                    rs.put("message","成功");
                    rs.put("info","补传成功，但未找到车辆对应班次");
                    return rs;
                }
            } else {
                if(sr==null){
                    // 班次完成3分钟内上传道闸消息，可以标记
                    for (int i = 0; i < size; i++) {
                        ScheduleRealInfo isr = list.get(i);
                        if (list.get(i).isDestroy())
                            continue;
                        if(fIsOut == 2 && (isr.getQdzName().trim().indexOf(fOutParkName) != -1) && (Math.abs(isr.getDfsjT()-fOutTime)<zcwcTime || (isr.getFcsjActualTime() != null && Math.abs(isr.getFcsjActualTime()-fOutTime)<zcwcTime))){
                            sr = isr;
                            break;
                        }
                        if(fIsOut == 1 && fInStatus != 0 && (isr.getZdzName().trim().indexOf(fInParkName) != -1) && (Math.abs(isr.getZdsjT()-fInTime)<zcwcTime || (isr.getZdsjActualTime() != null && Math.abs(isr.getZdsjActualTime()-fInTime)<zcwcTime))){
                            sr = isr;
                            break;
                        }
                    }
                    if(sr==null){
                        rs.put("code",-1);
                        rs.put("message","失败");
                        rs.put("info","未找到车辆对应班次");
                        return rs;
                    }
                }
            }
            //ScheduleRealInfo prevSr = dayOfSchedule.prev(sr);
            //ScheduleRealInfo nextSr = dayOfSchedule.next(sr);

            boolean isMatch = sr == null ? false : true;
            ScheduleRealInfo matchSr = sr;
            String inTimeStr = fmtHHmm.print(fInTime),outTimeStr = fmtHHmm.print(fOutTime);
            /**
               fIsOut 1：进场 2：出场
             * 进场 如果道闸信息先发，则为当前班次， 道闸信息后发，则为上一个班次信息
             *
             * 出场 如果道闸信息先发，则为下一个班次信息， 道闸信息后发，则为当前班次
             *
             * 到达时间接近那个班次的进场/出场判定为这个班次
             */
            /*if (fIsOut == 1 && fInStatus != 0 && fInTime != 0) {
                if(prevSr == null && (sr.getZdzName().trim().indexOf(fInParkName) != -1) && (Math.abs((sr.getZdsjT()- fInTime)) < Math.abs((prevSr.getZdsjT()- fInTime)))){
                    isMatch = true;
                    matchSr = sr;
                } else if(prevSr.getZdzName().trim().indexOf(fInParkName) != -1){//if(Math.abs((prevSr.getDfsjT())- fInTime) < 120)
                    isMatch = true;
                    matchSr = prevSr;
                }
                inTimeStr = fmtHHmm.print(fInTime);
            } else if (fIsOut == 2 && fOutTime != 0) {
                if(nextSr == null && (sr.getQdzName().trim().indexOf(fOutParkName) != -1) && (Math.abs((sr.getDfsjT()- fOutTime)) < Math.abs((nextSr.getDfsjT()- fOutTime)))){
                    isMatch = true;
                    matchSr = sr;
                } else if(nextSr.getQdzName().trim().indexOf(fOutParkName) != -1){ // if(Math.abs((nextSr.getDfsjT())- fInTime) < 120)
                    isMatch = true;
                    matchSr = nextSr;
                }
                outTimeStr = fmtHHmm.print(fOutTime);
            }*/
            if(isMatch){
                ScheduleRealInfoTag tag = new ScheduleRealInfoTag();
                Long real_id = matchSr.getId();
                String lineCode = matchSr.getXlBm();
                String dateStr = matchSr.getScheduleDateStr();
                List<ScheduleRealInfoTag> tagList = jdbcTemplate.query("select * from bsth_c_s_sp_info_real_tag where real_id = "+real_id, new RowMapper<ScheduleRealInfoTag>() {
                    @Override
                    public ScheduleRealInfoTag mapRow(ResultSet resultSet, int i) throws SQLException {
                        ScheduleRealInfoTag srt = new ScheduleRealInfoTag();
                        srt.setRealId(resultSet.getLong("real_id"));
                        srt.setfBusIdIn(resultSet.getString("f_bus_id_in"));
                        srt.setfBusIdOut(resultSet.getString("f_bus_id_out"));
                        srt.setfBusIdSd(resultSet.getString("f_bus_id_sd"));
                        srt.setIn(resultSet.getInt("in"));
                        srt.setInTime(resultSet.getLong("in_time"));
                        srt.setInTimeStr(resultSet.getString("in_time_str"));
                        srt.setOut(resultSet.getInt("out"));
                        srt.setOutTime(resultSet.getLong("out_time"));
                        srt.setOutTimeStr(resultSet.getString("out_time_str"));
                        srt.setSdTag(resultSet.getInt("sd_tag"));
                        srt.setSdTime(resultSet.getString("sd_time"));
                        srt.setClZbh(resultSet.getString("cl_zbh"));
                        srt.setCarPlate(resultSet.getString("car_plate"));
                        srt.setXlBm(resultSet.getString("xl_bm"));
                        srt.setScheduleDateStr(resultSet.getString("schedule_date_str"));
                        return srt;
                    }
                });
                String sql;
                if(tagList.size() > 0){
                    tag = tagList.get(0);
                    tag.setfBusIdIn(fBusID);
                    if(fIsOut==1 && fInStatus != 0){
                        sql = "UPDATE bsth_c_s_sp_info_real_tag set `in` = ? ,in_time=?,in_time_str=?,f_bus_id_in=?,in_name=? WHERE real_id=?";
                        jdbcTemplate.update(sql,1,fInTime,inTimeStr,fBusID,fInParkName,real_id);
                        tag.setIn(1);
                        tag.setfBusIdIn(fInTime.toString());
                        tag.setInTimeStr(inTimeStr);
                    } else if(fIsOut==2){
                        sql = "UPDATE bsth_c_s_sp_info_real_tag set `out` =?,out_time=?,out_time_str=?,f_bus_id_out=?,out_name=? WHERE real_id=?";
                        jdbcTemplate.update(sql,1,fOutTime,outTimeStr,fBusID,fOutParkName,real_id);
                        tag.setOut(1);
                        tag.setOutTime(fOutTime);
                        tag.setOutTimeStr(outTimeStr);
                    }
                } else{
                    tag.setRealId(real_id);
                    tag.setfBusIdIn(fBusID);
                    tag.setClZbh(matchSr.getClZbh());
                    tag.setCarPlate(fPlateCode);
                    tag.setXlBm(lineCode);
                    tag.setScheduleDateStr(dateStr);
                    if(fIsOut==1 && fInStatus != 0){
                        sql = "INSERT INTO bsth_c_s_sp_info_real_tag (real_id,`in`,in_time,in_time_str,cl_zbh,car_plate,f_bus_id_in,xl_bm,schedule_date_str,qdz_name,zdz_name,in_name)VALUES (?,?,?,?,?,?,?,?,?,?,?,?)";
                        jdbcTemplate.update(sql,real_id,1,fInTime,inTimeStr,matchSr.getClZbh(),fPlateCode,fBusID,lineCode,dateStr,matchSr.getQdzName(),matchSr.getZdzName(),fInParkName);
                        tag.setIn(1);
                        tag.setfBusIdIn(fInTime.toString());
                        tag.setInTimeStr(inTimeStr);
                    } else if(fIsOut==2){
                        sql = "INSERT INTO bsth_c_s_sp_info_real_tag (real_id,`out`,out_time,out_time_str,cl_zbh,car_plate,f_bus_id_out,xl_bm,schedule_date_str,qdz_name,zdz_name,out_name)VALUES (?,?,?,?,?,?,?,?,?,?,?,?)";
                        jdbcTemplate.update(sql,real_id,1,fOutTime,outTimeStr,matchSr.getClZbh(),fPlateCode,fBusID,lineCode,dateStr,matchSr.getQdzName(),matchSr.getZdzName(),fOutParkName);
                        tag.setOut(1);
                        tag.setOutTime(fOutTime);
                        tag.setOutTimeStr(outTimeStr);
                    }
                }
                sendUtils.stationSigno(tag);

                // 进场班次，匹配的下一个班次中放实到字段内容
                ScheduleRealInfo mNextSr = dayOfSchedule.next(matchSr);
                if(fIsOut==1 && fInStatus != 0 && mNextSr != null){
                    ScheduleRealInfoTag tagNext = new ScheduleRealInfoTag();
                    Long nextId = mNextSr.getId();
//                    int haveNext = jdbcTemplate.queryForObject("select count(*) from bsth_c_s_sp_info_real_tag where real_id = "+nextId,Integer.class);
                    List<ScheduleRealInfoTag> tagNextList = jdbcTemplate.query("select * from bsth_c_s_sp_info_real_tag where real_id = "+nextId, new RowMapper<ScheduleRealInfoTag>() {
                        @Override
                        public ScheduleRealInfoTag mapRow(ResultSet resultSet, int i) throws SQLException {
                            ScheduleRealInfoTag srt = new ScheduleRealInfoTag();
                            srt.setRealId(resultSet.getLong("real_id"));
                            srt.setfBusIdIn(resultSet.getString("f_bus_id_in"));
                            srt.setfBusIdOut(resultSet.getString("f_bus_id_out"));
                            srt.setfBusIdSd(resultSet.getString("f_bus_id_sd"));
                            srt.setIn(resultSet.getInt("in"));
                            srt.setInTime(resultSet.getLong("in_time"));
                            srt.setInTimeStr(resultSet.getString("in_time_str"));
                            srt.setOut(resultSet.getInt("out"));
                            srt.setOutTime(resultSet.getLong("out_time"));
                            srt.setOutTimeStr(resultSet.getString("out_time_str"));
                            srt.setSdTag(resultSet.getInt("sd_tag"));
                            srt.setSdTime(resultSet.getString("sd_time"));
                            srt.setClZbh(resultSet.getString("cl_zbh"));
                            srt.setCarPlate(resultSet.getString("car_plate"));
                            srt.setXlBm(resultSet.getString("xl_bm"));
                            srt.setScheduleDateStr(resultSet.getString("schedule_date_str"));
                            return srt;
                        }
                    });

                    if (tagNextList.size() < 1) {
                        sql = "INSERT INTO bsth_c_s_sp_info_real_tag (real_id,sd_tag,sd_time,cl_zbh,car_plate,f_bus_id_sd,xl_bm,schedule_date_str,qdz_name,zdz_name)VALUES (?,?,?,?,?,?,?,?,?,?)";
                        jdbcTemplate.update(sql,nextId,1,inTimeStr,matchSr.getClZbh(),fPlateCode,fBusID,lineCode,dateStr,mNextSr.getQdzName(),mNextSr.getZdzName());
                        tagNext.setClZbh(matchSr.getClZbh());
                        tagNext.setCarPlate(fPlateCode);
                        tagNext.setXlBm(lineCode);
                        tagNext.setScheduleDateStr(dateStr);
                    } else{
                        sql = "UPDATE bsth_c_s_sp_info_real_tag set sd_tag = ? ,sd_time=?,f_bus_id_sd=? WHERE real_id=?";
                        jdbcTemplate.update(sql,1,inTimeStr,fBusID,nextId);
                        tagNext = tagNextList.get(0);
                    }
                    tagNext.setRealId(nextId);
                    tagNext.setfBusIdIn(fBusID);
                    tagNext.setSdTag(1);
                    tagNext.setSdTime(inTimeStr);

                    sendUtils.stationSigno(tagNext);
                }

//                System.out.println("stationSigno----"+map);
                System.out.println("stationSigno-info---:fPlateCode"+fPlateCode+",fBusID"+fBusID+",fOutTime"+fOutTime+",fIsOut"+fIsOut+",fInTime"+fInTime);
                rs.put("code",0);
                rs.put("message","成功");
                return rs;
            } else {
                rs.put("code",-1);
                rs.put("message","失败");
                rs.put("info","未找到车辆对应班次");
                return rs;
            }
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("", e);
            rs.put("code",-1);
            rs.put("message","失败");
            return rs;
        }
    }

    @Override
    public List<ScheduleRealInfoTag> tagByLines(String lines) {
        List<ScheduleRealInfoTag> list  = new ArrayList<>();
        List<String> lineList = Lists.newArrayList(Splitter.on(',').trimResults().omitEmptyStrings().split(lines));
        String line = "";
        for (String l:lineList) {
            line += "'"+l+"',";
        }
        line = line.substring(0,line.length()-1);
        String day = DayOfSchedule.currSchDateMap.get(lineList.get(0));
        try{
            list = jdbcTemplate.query("select * from bsth_c_s_sp_info_real_tag where xl_bm in ("+line+") and schedule_date_str = '"+day+"'", new RowMapper<ScheduleRealInfoTag>() {
                @Override
                public ScheduleRealInfoTag mapRow(ResultSet resultSet, int i) throws SQLException {
                    ScheduleRealInfoTag srt = new ScheduleRealInfoTag();
                    srt.setRealId(resultSet.getLong("real_id"));
                    srt.setfBusIdIn(resultSet.getString("f_bus_id_in"));
                    srt.setfBusIdOut(resultSet.getString("f_bus_id_out"));
                    srt.setfBusIdSd(resultSet.getString("f_bus_id_sd"));
                    srt.setIn(resultSet.getInt("in"));
                    srt.setInTime(resultSet.getLong("in_time"));
                    srt.setInTimeStr(resultSet.getString("in_time_str"));
                    srt.setOut(resultSet.getInt("out"));
                    srt.setOutTime(resultSet.getLong("out_time"));
                    srt.setOutTimeStr(resultSet.getString("out_time_str"));
                    srt.setSdTag(resultSet.getInt("sd_tag"));
                    srt.setSdTime(resultSet.getString("sd_time"));
                    srt.setClZbh(resultSet.getString("cl_zbh"));
                    srt.setCarPlate(resultSet.getString("car_plate"));
                    srt.setXlBm(resultSet.getString("xl_bm"));
                    srt.setScheduleDateStr(resultSet.getString("schedule_date_str"));
                    return srt;
                }
            });
        }catch (Exception e){
            logger.error(e.toString(),e);
            return null;
        }
        return list;
    }
}