From b80f019dea691c33610d30bcf272f318e87a5a92 Mon Sep 17 00:00:00 2001 From: wangfs <15029758498@163.com> Date: Tue, 22 Aug 2017 17:07:33 +0800 Subject: [PATCH] 提交 --- src/main/java/com/zteits/irain/portal/web/fangle/FangleEqpController.java | 156 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 156 insertions(+), 0 deletions(-) create mode 100644 src/main/java/com/zteits/irain/portal/web/fangle/FangleEqpController.java diff --git a/src/main/java/com/zteits/irain/portal/web/fangle/FangleEqpController.java b/src/main/java/com/zteits/irain/portal/web/fangle/FangleEqpController.java new file mode 100644 index 0000000..235a050 --- /dev/null +++ b/src/main/java/com/zteits/irain/portal/web/fangle/FangleEqpController.java @@ -0,0 +1,156 @@ +package com.zteits.irain.portal.web.fangle; + +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.HashMap; +import java.util.Map; +import java.util.Map.Entry; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; + +import com.alibaba.dubbo.common.utils.StringUtils; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.clouds.common.utils.ExceptionUtil; +import com.clouds.common.web.BizController; +import com.zteits.clouds.api.apibase.bean.BaseInfo; +import com.zteits.clouds.api.apibase.bean.BizResult; +import com.zteits.clouds.api.apibase.constants.ErrorType; +import com.zteits.clouds.api.apibase.exception.BizException; +import com.zteits.clouds.api.dto.park.param.BerthStateRequest; +import com.zteits.clouds.api.dto.park.param.EqpHeartBeatRequest; +import com.zteits.clouds.api.dto.park.param.EqpLogRequest; +import com.zteits.clouds.api.dto.park.param.InParkingRequest; +import com.zteits.clouds.api.dto.park.param.OutParkingRequest; +import com.zteits.clouds.api.dto.park.param.InterfaceLogSaveRequest; +import com.zteits.clouds.api.service.park.EqpBerthsService; +import com.zteits.clouds.api.service.park.InterfaceLogService; +import com.zteits.irain.portal.common.AESPlus; +import com.zteits.irain.portal.common.HttpClientTutorial; +import com.zteits.irain.portal.constant.IRainResultEnum; +import com.zteits.irain.portal.constant.ParkConstant.InterfaceLog; +import com.zteits.irain.portal.service.interfaces.inoutparklot.InOutParkLotReportService; +import com.zteits.irain.portal.service.interfaces.inoutparklot.param.RecordInParkLotRequest; +import com.zteits.irain.portal.service.interfaces.inoutparklot.param.RecordOutParkLotRequest; +import com.zteits.irain.portal.vo.irain.IRainResponseVO; + +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; + +/** + * Copyright: Copyright (c) 2017 ZTE-ITS + * + * @ClassName: FangleEqpController.java + * @Description:方格尔设备同步 + * @version: v1.0.0 + * @author: wangfei + * @date: 2017年4月20日 下午17:51:45 + * Modification History: + * Date Author Version Description + *---------------------------------------------------------* + * 2017年8月21日 wangfei v1.0.0 创建 + */ +@Api(value="方格尔设备同步",description="方格尔设备同步") +@RestController +@RequestMapping("/fangle") +public class FangleEqpController extends BizController{ + + + private static final Logger logger = LoggerFactory.getLogger(FangleEqpController.class); + @Value("${project.syscode}") + private String sysCode; + @Autowired + private EqpBerthsService eqpBerthsService; + + @ApiOperation("泊位信息同步") + @RequestMapping(value = "/synBerthInfo",method = RequestMethod.POST) + public BizResult> synBerthInfo(@RequestBody String param){ + logger.info("同步入参：" + param); + + JSONObject jsonObject = JSONObject.parseObject(param); + String reqList = jsonObject.getString("pushdata"); + JSONArray jsonArray = JSON.parseArray(reqList); + BerthStateRequest request = JSON.parseObject(jsonArray.getString(0),BerthStateRequest.class); + BaseInfo info = new BaseInfo(); + request.setBaseRequest(info); + request.setSysCode(sysCode); + //数据转换 + EqpLogRequest eqpLogRequest = new EqpLogRequest(); + BeanUtils.copyProperties(request, eqpLogRequest); + eqpLogRequest.setBerthOutNo(request.getBerthcode()); + eqpLogRequest.setEqpType(1);//地磁 + if(request.getBerthstatus().equals("1") || request.getBerthstatus().equals("2")){ + eqpLogRequest.setEqpStatus("1");//设备状态 1-正常 + } + if(request.getBerthstatus().equals("3")){ + eqpLogRequest.setEqpStatus("0");//设备状态 0-故障 + } + if(request.getBerthstatus().equals("2")){ + eqpLogRequest.setBerthState("0");//泊位状态 0-空闲 + } + if(request.getBerthstatus().equals("1")){ + eqpLogRequest.setBerthState("1");//泊位状态 1- 占用 + } + eqpLogRequest.setElectricity(request.getElectricity()); + eqpLogRequest.setVoltag(request.getVoltage()); + + BizResult> result = eqpBerthsService.synBerthState(eqpLogRequest); + return result; + } + + @ApiOperation("设备心跳信息同步") + @RequestMapping(value = "/synEqpHeartBeatInfo",method = RequestMethod.POST) + public BizResult> synEqpHeartBeatInfo(@RequestBody String param){ + logger.info("同步入参：" + param); + + JSONObject jsonObject = JSONObject.parseObject(param); + String reqList = jsonObject.getString("pushdata"); + JSONArray jsonArray = JSON.parseArray(reqList); + EqpHeartBeatRequest request = JSON.parseObject(jsonArray.getString(0),EqpHeartBeatRequest.class); + BaseInfo info = new BaseInfo(); + request.setBaseRequest(info); + request.setSysCode(sysCode); + + //数据转换 + EqpLogRequest eqpLogRequest = new EqpLogRequest(); + BeanUtils.copyProperties(request, eqpLogRequest); + eqpLogRequest.setEqpNo(request.getEquipmentCode()); + if(request.getEquipmentType().equals("1")){ + eqpLogRequest.setEqpType(4);//设备类型 4-车检器 + } + if(request.getEquipmentType().equals("2")){ + eqpLogRequest.setEqpType(5);//设备类型 5-网关 + } + if(request.getEquipmentType().equals("3")){ + eqpLogRequest.setEqpType(6);//设备类型 6-中继器 + } + if(request.getEquipmentStatus().equals("1")){ + eqpLogRequest.setEqpStatus("1");//设备状态 1-正常 + } + if(request.getEquipmentStatus().equals("2")){ + eqpLogRequest.setEqpStatus("0");//设备状态 0-故障 + } + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); + Date date; + try { + date = sdf.parse(request.getPushTime()); + eqpLogRequest.setHeartbeatTime(date); + } catch (ParseException e) { + e.printStackTrace(); + } + BizResult> result = eqpBerthsService.synBerthState(eqpLogRequest); + return result; + } + +} -- libgit2 0.21.4