customer / shanghai-railway-web

/*
 * @(#)ApiLogManagerImpl.java
 *
 * Copyright (c) 2014-2017  xiniunet 版权所有
 * xiniunet. All rights reserved.
 *
 * This software is the confidential and proprietary
 * information of  xiniunet.
 * ("Confidential Information"). You shall not disclose
 * such Confidential Information and shall use it only
 * in accordance with the terms of the contract agreement
 * you entered into with xiniunet.
 */
package com.xiniunet.service.railway.biz;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.xiniunet.framework.base.BaseManagerImpl;
import com.xiniunet.framework.base.BaseResponse;
import com.xiniunet.framework.exception.ErrorType;
import com.xiniunet.framework.log.LogUtil;
import com.xiniunet.framework.security.Passport;
import com.xiniunet.railway.domain.TrainsDetail;
import com.xiniunet.railway.domain.TransPositionData;
import com.xiniunet.railway.request.*;
import com.xiniunet.railway.response.*;
import com.xiniunet.service.railway.Constant;
import com.xiniunet.service.railway.po.ApiLogPO;
import com.xiniunet.service.railway.util.RailwayThirdTools;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 远程调用日志的管理方法实现.
 *
 * @author xiniunet
 */
@Transactional
public class RailwayThirdManagerImpl extends BaseManagerImpl implements RailwayThirdManager {


    @Autowired
    private ApiLogManager apiLogManager;
    @Autowired
    private EventManager eventManager;
    /**
     * 调用第三方接口
     * @param request
     * @return
     */
    @Override
    public RailwayGetPositionResponse getPosition(RailwayGetPositionRequest request,Passport passport){
        RailwayGetPositionResponse response = new RailwayGetPositionResponse();
        String url = Constant.RALWAY_THIRD_SAFETY_ESCORT_POSITION_URL;
        Date now=new Date();
        try
        {
            long start =System.currentTimeMillis();
            response = JSON.toJavaObject(RailwayThirdTools.railwayThird(url, request), response.getClass());
            long end = System.currentTimeMillis();
            long count = end-start;
            LogUtil.warnLog("调用 getPosition.action 耗时："+count/1000 +"秒");
            String lineId ="未知";
            if(response.getTrainCarriageId() != null && !"".equals(response.getTrainCarriageId()) && response.getTrainCarriageId().length()>5){
                lineId = response.getTrainCarriageId().substring(0,2);
                response.setTrainNo(response.getTrainCarriageId().substring(0,5));
            }
            response.setTrainLineId(lineId);
        }
        catch(Exception e)
        {
            response.addError(ErrorType.SYSTEM_ERROR, e.getMessage());
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("getPosition");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) +com.alibaba.fastjson.JSON.toJSONString(request));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date()) +com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，获取行车位置");
        apiLogManager.create(apiLogCreateRequest,passport);
        return  response;
    }

    /**
     * 调用第三方接口（获取当前时间列车信息）
     * @param request
     * @param passport
     * @return
     */
    @Override
    public RailwayTransDetailCountGetResponse getTransCountDetail(RailwayTransDetailGetRequest request, Passport passport){
        RailwayTransDetailCountGetResponse railwayTransDetailCountGetResponse = new RailwayTransDetailCountGetResponse();
        RailwayTransDetailGetResponse response = new RailwayTransDetailGetResponse();
        List<TrainsDetail> trainsDetails = new ArrayList<>();
        String url = Constant.RALWAY_THIRD_ALL_TRAIN_INFO_URL;
        Date now=new Date();
        try
        {
            long start =System.currentTimeMillis();
            response = JSON.toJavaObject(RailwayThirdTools.railwayThird(url, request), response.getClass());
            long end = System.currentTimeMillis();
            long count = end-start;
            LogUtil.warnLog("调用 getAllTrainPosition.action 耗时："+count/1000 +"秒");
            List<TransPositionData> positionDataList = response.getTrainData();
            //去重TransPositionData信息
            //lineId,trainId 和 TransPositionData关系
            Map<String,TransPositionData> lineTrainIdMap = new HashMap<>();
            List<TransPositionData> newPositionDataList = new ArrayList<>();
            for(TransPositionData transPositionData:positionDataList){
                if(!lineTrainIdMap.containsKey(transPositionData.getLineId()+transPositionData.getTrainId())){
                    lineTrainIdMap.put(transPositionData.getLineId()+transPositionData.getTrainId(),transPositionData);
                    newPositionDataList.add(transPositionData);
                }
            }
            response.setTrainData(newPositionDataList);
        }
        catch(Exception e)
        {
            response.addError(ErrorType.SYSTEM_ERROR, e.getMessage());
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("getTransDetail");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        Date now1=new Date();
        String invokeTime=myFmt1.format(now1);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) +com.alibaba.fastjson.JSON.toJSONString(request));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date()) +com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，获取当前时间列车信息");
        ApiLogCreateResponse apiLogCreateResponse =apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return railwayTransDetailCountGetResponse;
        }
        List<TransPositionData> list = response.getTrainData();
        Integer totalTrainCount = 0;
        Integer totalCarriageCount = 0;
        Map<String, List<TransPositionData>> resultMap= new HashMap<>(); // 最终要的结果
        if (list != null && list.size() > 0){
            List<TransPositionData> transPositionDataList = null;
            for (TransPositionData transPositionData : list){
                if(resultMap.containsKey(transPositionData.getLineId())){
                    transPositionDataList = resultMap.get(transPositionData.getLineId());
                }else{
                    transPositionDataList = new ArrayList<>();
                }
                transPositionDataList.add(transPositionData);
                resultMap.put(transPositionData.getLineId(),transPositionDataList);
            }
            //遍历map中的键
            if(resultMap != null && resultMap.size() > 0){
                for (String key : resultMap.keySet()) {
                    TrainsDetail trainsDetail = new TrainsDetail();
                    trainsDetail.setTrainLineId(key);
                    int trainCount = resultMap.get(key).size();
                    int carriageCount = 0;
                    List<String > lineCarriageIds = new ArrayList<>();
                    //车厢数
                    List<TransPositionData> transPositionDatas = resultMap.get(key);
                    for (TransPositionData entity : transPositionDatas){
                        carriageCount += entity.getTrainCarriageIds().size();
                        lineCarriageIds.addAll(entity.getTrainCarriageIds());
                    }
                    trainsDetail.setTrainCarriageIds(lineCarriageIds);
                    trainsDetail.setTrainCarriageCount(carriageCount);
                    trainsDetail.setTrainCount(trainCount);
                    trainsDetails.add(trainsDetail);
                    totalCarriageCount += carriageCount;
                }

            }
            totalTrainCount = list.size();
        }
        railwayTransDetailCountGetResponse.setTrainCarriageCount(totalCarriageCount);
        railwayTransDetailCountGetResponse.setTrainCount(totalTrainCount);
        railwayTransDetailCountGetResponse.setTrainsDetails(trainsDetails);
        return  railwayTransDetailCountGetResponse;
    }
    /**
     * 调用第三方接口（获取当前时间列车信息）
     * @param request
     * @return
     */
    @Override
    public RailwayTransDetailGetResponse getTransDetail(RailwayTransDetailGetRequest request, Passport passport){
        RailwayTransDetailGetResponse response = new RailwayTransDetailGetResponse();
        String url = Constant.RALWAY_THIRD_ALL_TRAIN_INFO_URL;
        //当前日期（yyyy-MM-dd  hh:mm:ss）
       /* SimpleDateFormat myFmt=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");*/
        Date now=new Date();
         /*String dateId=myFmt.format(now);
        request.setRequestTime(dateId);*/
        try
        {
            long start =System.currentTimeMillis();
            response = JSON.toJavaObject(RailwayThirdTools.railwayThird(url, request), response.getClass());
            long end = System.currentTimeMillis();
            long count = end-start;
            LogUtil.warnLog("调用 getAllTrainPosition.action 耗时："+count/1000 +"秒");
            List<TransPositionData> positionDataList = response.getTrainData();
            //去重TransPositionData信息
            //lineId,trainId 和 TransPositionData关系
            Map<String,TransPositionData> lineTrainIdMap = new HashMap<>();
            List<TransPositionData> newPositionDataList = new ArrayList<>();
            for(TransPositionData transPositionData:positionDataList){
                if(!lineTrainIdMap.containsKey(transPositionData.getLineId()+transPositionData.getTrainId())){
                    lineTrainIdMap.put(transPositionData.getLineId()+transPositionData.getTrainId(),transPositionData);
                    newPositionDataList.add(transPositionData);
                }
            }
            response.setTrainData(newPositionDataList);
        }
        catch(Exception e)
        {
            response.addError(ErrorType.SYSTEM_ERROR, e.getMessage());
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("getTransDetail");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，获取当前时间列车信息");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        List<TransPositionData> list = response.getTrainData();
        if(list != null && list.size()>0){
            response.setTrainData(list);
        }
        return response;
    }
    /**
     * 验证对象
     *
     * @param apiLog   远程调用日志
     * @param passport 用户护照
     */
    private void checkValidate(ApiLogPO apiLog, Passport passport, BaseResponse response) {
        // TODO
    }

    /**
     * 调用第三方接口（获取布岗查询信息）
     * @param request
     * @return
     */
    @Override
    public RailwayPostPositionResponse getRailwayPostPosition(RailwayPostPositionGetRequest request, Passport passport){
        RailwayPostPositionResponse response = new RailwayPostPositionResponse();
        RailwayPostPositionRequest request1 = new RailwayPostPositionRequest();
        request1.setUserName("pingan");
        request1.setPassWord("e10adc3949ba59abbe56e057f20f883e");
        request1.setIdentify("PA11");
        String[] strArray = new String[3];
        if (request.getLineId() != null) {
            strArray[0] = request.getLineId();
        }else {
            strArray[0] = "";
        }
        if (request.getStationeId() != null) {
            strArray[1] = request.getStationeId();
        }else {
            strArray[1] = "";
        }
        if (request.getPublishDate() != null) {
            strArray[2] = request.getPublishDate();
        }else {
            strArray[2] = "";
        }
        request1.setParams(strArray);
        Date now=new Date();
        String url = Constant.RALWAY_THIRD_WEB_SERVICE_URL;
        String operationName = Constant.RALWAY_THIRD_WEB_SERVICE_OPERATIONNAME;
        String paramName = Constant.RALWAY_THIRD_WEB_SERVICE_PARAMNAME;
        try {
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWebService(url, request1,operationName, paramName), response.getClass());
        } catch (IOException e) {
            e.printStackTrace();
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("getRailwayPostPosition");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request1));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，获取布岗查询信息");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 调用第三方接口（选岗添加）
     * @param request
     * @return
     */
    @Override
    public  RailwayPostPositionCreateResponse createRailwayPostPosition(RailwayPostPositionCreateRequest request, Passport passport){
        RailwayPostPositionCreateResponse response = new RailwayPostPositionCreateResponse();
        RailwayPostPositionRequest request1 = new RailwayPostPositionRequest();
        request1.setUserName("pingan");
        request1.setPassWord("e10adc3949ba59abbe56e057f20f883e");
        request1.setIdentify("PA12");
        String requestStr = JSON.toJSONString(request);
        String[] strArray = new String[1];
        strArray[0] = requestStr;
        request1.setParams(strArray);
        Date now=new Date();
        String url = Constant.RALWAY_THIRD_WEB_SERVICE_URL;
        String operationName = Constant.RALWAY_THIRD_WEB_SERVICE_OPERATIONNAME;
        String paramName = Constant.RALWAY_THIRD_WEB_SERVICE_PARAMNAME;
        try {
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWebService(url, request1,operationName, paramName), response.getClass());
        } catch (IOException e) {
            e.printStackTrace();
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("createRailwayPostPosition");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request1));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，选岗添加");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 调用第三方接口（签到新增）
     * @param request
     * @return
     */
    @Override
    public  RailwayPostPositionCreateResponse createRailwayArrival(RailwayArrivalCreateRequest request, Passport passport){
        RailwayPostPositionCreateResponse response = new RailwayPostPositionCreateResponse();
        RailwayPostPositionRequest request1 = new RailwayPostPositionRequest();
        request1.setUserName("pingan");
        request1.setPassWord("e10adc3949ba59abbe56e057f20f883e");
        request1.setIdentify("PA03");
        String requestStr = JSON.toJSONString(request);
        String[] strArray = new String[1];
        strArray[0] = requestStr;
        request1.setParams(strArray);
        Date now=new Date();
        String url = Constant.RALWAY_THIRD_WEB_SERVICE_URL;
        String operationName = Constant.RALWAY_THIRD_WEB_SERVICE_OPERATIONNAME;
        String paramName = Constant.RALWAY_THIRD_WEB_SERVICE_PARAMNAME;
        try {
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWebService(url, request1,operationName, paramName), response.getClass());
        } catch (IOException e) {
            e.printStackTrace();
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("createRailwayArrival");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request1));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，签到新增");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 调用第三方接口（签退修改）
     * @param request
     * @return
     */
    @Override
    public RailwayPostPositionCreateResponse createRailwayLeave(RailwayLeaveCreateRequest request, Passport passport){
        RailwayPostPositionCreateResponse response = new RailwayPostPositionCreateResponse();
        RailwayPostPositionRequest request1 = new RailwayPostPositionRequest();
        request1.setUserName("pingan");
        request1.setPassWord("e10adc3949ba59abbe56e057f20f883e");
        request1.setIdentify("PA04");
        String requestStr = JSON.toJSONString(request);
        String[] strArray = new String[1];
        strArray[0] = requestStr;
        request1.setParams(strArray);
        Date now=new Date();
        String url = Constant.RALWAY_THIRD_WEB_SERVICE_URL;
        String operationName = Constant.RALWAY_THIRD_WEB_SERVICE_OPERATIONNAME;
        String paramName = Constant.RALWAY_THIRD_WEB_SERVICE_PARAMNAME;
        try {
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWebService(url, request1,operationName, paramName), response.getClass());
        } catch (IOException e) {
            e.printStackTrace();
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("createRailwayLeave");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request1));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，签退修改");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 调用第三方接口（志愿者考勤信息）
     * @param request
     * @return
     */
    @Override
    public RailwayPostPositionDetailResponse getRailwayPostPositionDetail(RailwayPostPositionDetailRequest request, Passport passport){
        RailwayPostPositionDetailResponse response = new RailwayPostPositionDetailResponse();
        RailwayPostPositionRequest request1 = new RailwayPostPositionRequest();
        request1.setUserName("pingan");
        request1.setPassWord("e10adc3949ba59abbe56e057f20f883e");
        request1.setIdentify("PA05");
        String[] strArray = new String[5];
        strArray[0] = request.getLineId() == null ? "":request.getLineId();
        strArray[1] = request.getStationId() == null ? "":request.getStationId();
        strArray[2] = request.getStartDate() == null ? "":request.getStartDate();
        strArray[3] = request.getEndDate() == null ? "":request.getEndDate();
        strArray[4] = request.getUserId() == null ? "":request.getUserId();
        request1.setParams(strArray);
        Date now=new Date();
        String url = Constant.RALWAY_THIRD_WEB_SERVICE_URL;
        String operationName = Constant.RALWAY_THIRD_WEB_SERVICE_OPERATIONNAME;
        String paramName = Constant.RALWAY_THIRD_WEB_SERVICE_PARAMNAME;
        try {
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWebService(url, request1,operationName, paramName), response.getClass());
        } catch (IOException e) {
            e.printStackTrace();
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("getRailwayPostPositionDetail");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request1));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，志愿者考勤信息");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 调用第三方接口（志愿者选岗撤销）
     * @param request
     * @return
     */
    @Override
    public RailwayPostPositionCreateResponse cancelRailwayPostPosition(RailwayPostPositionCancelRequest request, Passport passport){
        RailwayPostPositionCreateResponse response = new RailwayPostPositionCreateResponse();
        RailwayPostPositionRequest request1 = new RailwayPostPositionRequest();
        request1.setUserName("pingan");
        request1.setPassWord("e10adc3949ba59abbe56e057f20f883e");
        request1.setIdentify("PA06");
        String[] strArray = new String[2];
        if (request.getUserId() != null) {
            strArray[0] = request.getUserId();
        }else {
            strArray[0] = "";
        }
        if (request.getXgId() != null) {
            strArray[1] = request.getXgId();
        }else {
            strArray[1] = "";
        }
        request1.setParams(strArray);
        Date now=new Date();
        String url = Constant.RALWAY_THIRD_WEB_SERVICE_URL;
        String operationName = Constant.RALWAY_THIRD_WEB_SERVICE_OPERATIONNAME;
        String paramName = Constant.RALWAY_THIRD_WEB_SERVICE_PARAMNAME;
        try {
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWebService(url, request1,operationName, paramName), response.getClass());
        } catch (IOException e) {
            e.printStackTrace();
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("cancelRailwayPostPosition");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request1));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，志愿者选岗撤销");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 调用第三方接口（根据车厢号查询位置）
     * @param request
     * @return
     */
    @Override
    public RailwayCarriagePositionFindResponse findRailwayCarriagePosition(RailwayCarriagePositionFindRequest request, Passport passport){
        RailwayCarriagePositionFindResponse response = new RailwayCarriagePositionFindResponse();
        String url = Constant.RALWAY_THIRD_CARRIAGE_POSITION_URL;
        Date now=new Date();
        request.setRequestTime(now.toString());
        try
        {
            long start =System.currentTimeMillis();
            response = JSON.toJavaObject(RailwayThirdTools.railwayThird(url, request), response.getClass());
            long end = System.currentTimeMillis();
            long count = end-start;
            LogUtil.warnLog("调用 getPositionByTrainCarriageId.action 耗时："+count/1000 +"秒");
        }
        catch(Exception e)
        {
            response.addError(ErrorType.SYSTEM_ERROR, e.getMessage());
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("findRailwayCarriagePosition");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，根据车厢号查询位置");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 调用第三方接口（事件上报）
     * @param request
     * @return
     */
    @Override
    public RailwayReportEventResponse createRailwayReportEvent(RailwayReportEventCreateRequest request, Passport passport){
        RailwayReportEventResponse response = new RailwayReportEventResponse();
        Date now=new Date();
        SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmssSSS");
        SimpleDateFormat format1 = new SimpleDateFormat("yyyyMMdd");
        String appEventId = format.format(now.getTime());
        String dateId = format1.format(now.getTime());
        request.setAppEventId(appEventId);
        String url = Constant.RALWAY_THIRD_REPORT_EVENT_URL;
        String operationName = Constant.RALWAY_THIRD_REPORT_EVENT_OPERATIONNAME;
        String paramName = Constant.RALWAY_THIRD_REPORT_EVENT_PARAMNAME;
        try {
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWebService(url, request,operationName, paramName), response.getClass());
        } catch (IOException e) {
            e.printStackTrace();
        }
        EventCreateRequest request1 = new EventCreateRequest();
        request1 = this.getMapper().map(request,request1.getClass());
        request1.setStation(request.getStationName());
        request1.setNextStation(request.getNextStationName());
        request1.setDescription(request.getContent());
        request1.setUserId(Long.valueOf(request.getVolunteerId()));
        request1.setIsHandled(false);
        request1.setDateId(dateId);
        request1.setEventTime(now);
        for(int i = 0; i < request.getAppAttachementAddress().length; i++){
            if ( i == 0){
                request1.setAppAttachementAddress1(request.getAppAttachementAddress()[i]);
            }else if( i == 1){
                request1.setAppAttachementAddress2(request.getAppAttachementAddress()[i]);
            }else {
                request1.setAppAttachementAddress3(request.getAppAttachementAddress()[i]);
            }
        }
        EventCreateResponse response1 = eventManager.create(request1,passport);
        if(response1.hasError()){
            response.addErrors(response1.getErrors());
            return response;
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("createRailwayReportEvent");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，事件上报");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * wifi获取定位信息
     */
    @Override
    public WifiPositionResponse findRailwayWifiPosition(WifiPositionRequest request, Passport passport){
        WifiPositionResponse response = new WifiPositionResponse();
        String url = Constant.RALWAY_THIRD_WIFI_POSITION_URL;
        Date now=new Date();
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String invokeTime=myFmt1.format(now);
        request.setRequestTime(invokeTime);
        try
        {
            long start =System.currentTimeMillis();
            response = JSON.toJavaObject(RailwayThirdTools.railwayThirdWifi(url, request), response.getClass());
            long end = System.currentTimeMillis();
            long count = end-start;
            LogUtil.warnLog("调用 findRailwayWifiPosition.action 耗时："+count/1000 +"秒");
        }
        catch(Exception e)
        {
            response.addError(ErrorType.SYSTEM_ERROR, e.getMessage());
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("findRailwayWifiPosition");
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("调用第三方接口，根据wifi获取定位信息");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            return response;
        }
        return response;
    }

    /**
     * 第三方回调（事件处理结果）
     *
     * @param request  更新事件请求
     * @param passport 用户护照
     * @return 更新事件应答
     */
    @Override
    public String updateEvent(EventUpdateRequest request, Passport passport){
        String result;
        EventUpdateResponse response = new EventUpdateResponse();
        RailwayThirdEventResponse railwayThirdEventResponse = new RailwayThirdEventResponse();
        Date now=new Date();
        response = eventManager.updateEvent(request,passport);
        if(response.hasError()){
            response.addErrors(response.getErrors());
            railwayThirdEventResponse.setResultCode("002");
            railwayThirdEventResponse.setResultChineseDesc("未找到事件");
            result = JSON.toJSONString(railwayThirdEventResponse);
            return result;
        }
        //插入日志信息
        ApiLogCreateRequest apiLogCreateRequest = new ApiLogCreateRequest();
        apiLogCreateRequest.setApiMethod("updateEvent");
        SimpleDateFormat myFmt1=new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss");
        String invokeTime=myFmt1.format(now);
        apiLogCreateRequest.setInvokeTime(invokeTime);
        apiLogCreateRequest.setRequestParam(myFmt1.format(now) + com.alibaba.fastjson.JSON.toJSONString(request));
        apiLogCreateRequest.setResponse(myFmt1.format(new Date())+com.alibaba.fastjson.JSON.toJSONString(response));
        apiLogCreateRequest.setDescription("第三方回调（事件处理结果）");
        ApiLogCreateResponse apiLogCreateResponse = apiLogManager.create(apiLogCreateRequest,passport);
        if(apiLogCreateResponse.hasError()){
            response.addErrors(apiLogCreateResponse.getErrors());
            railwayThirdEventResponse.setResultCode("002");
            railwayThirdEventResponse.setResultChineseDesc("失败");
            result = JSON.toJSONString(railwayThirdEventResponse);
            return result;
        }
        if (response.getResult() > 0){
            railwayThirdEventResponse.setResultCode("001");
            railwayThirdEventResponse.setResultChineseDesc("成功");
        }else{
            railwayThirdEventResponse.setResultCode("002");
            railwayThirdEventResponse.setResultChineseDesc("未查询到上报事件");
        }
        result = JSON.toJSONString(railwayThirdEventResponse);
        return result;
    }
}