Lianxun_Java.git

New file
			@@ -0,0 +1,231 @@
			package com.java110.job.adapt.car;

			import com.alibaba.fastjson.JSONObject;
			import com.java110.core.client.OutRestTemplate;
			import com.java110.core.client.RestTemplate;
			import com.java110.core.log.LoggerFactory;
			import com.java110.dto.machine.CarInoutDetailDto;
			import com.java110.dto.parking.ParkingAreaDto;
			import com.java110.dto.system.Business;
			import com.java110.intf.community.IParkingAreaV1InnerServiceSMO;
			import com.java110.job.adapt.DatabusAdaptImpl;
			import com.java110.po.car.CarInoutDetailPo;
			import com.java110.utils.cache.CommonCache;
			import com.java110.utils.cache.MappingCache;
			import com.java110.utils.constant.MappingConstant;
			import com.java110.utils.factory.ApplicationContextFactory;
			import com.java110.utils.util.BeanConvertUtil;
			import com.java110.utils.util.DateUtil;
			import com.java110.utils.util.ImageUtils;
			import com.java110.utils.util.StringUtil;
			import org.slf4j.Logger;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.http.HttpEntity;
			import org.springframework.http.HttpHeaders;
			import org.springframework.http.HttpMethod;
			import org.springframework.http.ResponseEntity;
			import org.springframework.stereotype.Component;
			import org.springframework.util.MultiValueMap;
			import org.springframework.web.client.HttpStatusCodeException;

			import java.util.List;

			/**
			* 停车进出数据向东莞市公安局社会停车场（道闸卡口）平台同步数据
			* <p>
			* databus 配置
			* <p>
			* 名称车辆进出databus
			* 业务类型 saveCarInoutDetail
			* 适配器 sendInoutCarToDGGAJParkingAdapt
			* 顺序 80
			* 状态在用
			*
			*
			* mapping 中配置 DOGUAN_PAKRING_KEY 平台提供的key
			*/
			@Component(value = "sendInoutCarToDGGAJParkingAdapt")
			public class SendInoutCarToDGGAJParkingAdapt extends DatabusAdaptImpl {

			private static Logger logger = LoggerFactory.getLogger(SendInoutCarToDGGAJParkingAdapt.class);

			@Autowired
			private IParkingAreaV1InnerServiceSMO parkingAreaV1InnerServiceSMOImpl;

			@Autowired
			private RestTemplate outRestTemplate;

			private static final String url = "http://59.39.179.74:9070/services/hole";

			@Override
			public void execute(Business business, List<Business> businesses) {
			JSONObject data = business.getData();

			//todo 获取到参数信息
			CarInoutDetailPo carInoutDetailPo = BeanConvertUtil.covertBean(data, CarInoutDetailPo.class);

			//todo 获取到token
			String token = initTrans(carInoutDetailPo);

			//todo 上传进出场车辆信息
			parkWriteInfoV2(carInoutDetailPo,token);


			}

			/**
			* 写停车场车辆信息
			* @param carInoutDetailPo
			* @param token
			*/
			private void parkWriteInfoV2(CarInoutDetailPo carInoutDetailPo, String token) {

			ParkingAreaDto parkingAreaDto = new ParkingAreaDto();
			parkingAreaDto.setPaId(carInoutDetailPo.getPaId());
			parkingAreaDto.setCommunityId(carInoutDetailPo.getCommunityId());
			List<ParkingAreaDto> parkingAreaDtos = parkingAreaV1InnerServiceSMOImpl.queryParkingAreas(parkingAreaDto);

			if (parkingAreaDtos == null \|\| parkingAreaDtos.size() < 1) {
			throw new IllegalArgumentException("停车场未找到");
			}

			//进
			String directType = "1";

			if (CarInoutDetailDto.CAR_INOUT_OUT.equals(carInoutDetailPo.getCarInout())) {
			directType = "2"; // todo 出
			}
			String photo = ImageUtils.getBase64ByImgUrl(carInoutDetailPo.getPhotoJpg());
			JSONObject picBase64 = JSONObject.parseObject("{\"SubImageInfo\": [{\"FileFormat\":\"Jpeg\",\"Data\":\"无图片\"}]}");

			if(!StringUtil.isEmpty(photo)){
			picBase64.getJSONArray("SubImageInfo").getJSONObject(0).put("Data","data:image/jpeg;base64,"+photo);
			}

			String reqParam = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ws=\"http://ws.conflux.sunshine.com\">\n" +
			" <soapenv:Header/>\n" +
			" <soapenv:Body>\n" +
			" <ws:parkWriteInfoV2>\n" +
			" <!--Optional:-->\n" +
			" <gateId>"+parkingAreaDtos.get(0).getNum()+"</gateId>\n" +
			" <!--Optional:-->\n" +
			" <directType>"+directType+"</directType>\n" +
			" <driverWayNo>"+carInoutDetailPo.getMachineId()+"</driverWayNo>\n" +
			" <!--Optional:-->\n" +
			" <driverWayType>00</driverWayType>\n" +
			" <!--Optional:-->\n" +
			" <licenseType>02</licenseType>\n" +
			" <!--Optional:-->\n" +
			" <passTime>"+ DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A) +"</passTime>\n" +
			" <!--Optional:-->\n" +
			" <licenseColor>9</licenseColor>\n" +
			" <!--Optional:-->\n" +
			" <carType>K33</carType>\n" +
			" <!--Optional:-->\n" +
			" <license>"+carInoutDetailPo.getCarNum()+"</license>\n" +
			" <!--Optional:-->\n" +
			" <backLicense></backLicense>\n" +
			" <!--Optional:-->\n" +
			" <backLicenseColor></backLicenseColor>\n" +
			" <!--Optional:-->\n" +
			" <identical>1</identical>\n" +
			" <!--Optional:-->\n" +
			" <carColor>99</carColor>\n" +
			" <!--Optional:-->\n" +
			" <carBrand>0</carBrand>\n" +
			" <!--Optional:-->\n" +
			" <carShape>8</carShape>\n" +
			" <!--Optional:-->\n" +
			" <picBase64>"+picBase64.toJSONString()+"</picBase64>\n" +
			" <freeParkingNums>-1</freeParkingNums>\n" +
			" <!--Optional:-->\n" +
			" <sendFlag>0</sendFlag>\n" +
			" <!--Optional:-->\n" +
			" <inputTime>"+ DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A) +"</inputTime>\n" +
			" <!--Optional:-->\n" +
			" <token>"+token+"</token>\n" +
			" </ws:parkWriteInfoV2>\n" +
			" </soapenv:Body>\n" +
			"</soapenv:Envelope>";
			logger.debug("请求报文：{}",reqParam);
			HttpHeaders httpHeaders = new HttpHeaders();
			httpHeaders.add("Content-Type","text/xml;charset=UTF-8");
			HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity(reqParam, httpHeaders);
			try {
			ResponseEntity<String> responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
			logger.debug("返回报文,{}",responseEntity);
			}catch (HttpStatusCodeException e){
			logger.error("调用异常",e);
			}catch (Exception e){
			logger.error("调用异常",e);
			}
			}

			/**
			* 初始化连接
			* @param carInoutDetailPo
			* @return
			*/
			public String initTrans(CarInoutDetailPo carInoutDetailPo) {

			String token = CommonCache.getValue("DGGAJ_Parking_token");

			if(!StringUtil.isEmpty(token)){
			return token;
			}

			ParkingAreaDto parkingAreaDto = new ParkingAreaDto();
			parkingAreaDto.setPaId(carInoutDetailPo.getPaId());
			parkingAreaDto.setCommunityId(carInoutDetailPo.getCommunityId());
			List<ParkingAreaDto> parkingAreaDtos = parkingAreaV1InnerServiceSMOImpl.queryParkingAreas(parkingAreaDto);

			if (parkingAreaDtos == null \|\| parkingAreaDtos.size() < 1) {
			throw new IllegalArgumentException("停车场未找到");
			}

			String key = MappingCache.getValue("DOGUAN_PAKRING_KEY");

			//进
			String directType = "1";

			if (CarInoutDetailDto.CAR_INOUT_OUT.equals(carInoutDetailPo.getCarInout())) {
			directType = "2"; // todo 出
			}

			String paramIn = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ws=\"http://ws.conflux.sunshine.com\">\n" +
			" <soapenv:Header/>\n" +
			" <soapenv:Body>\n" +
			" <ws:initTrans>\n" +
			" <!--Optional:-->\n" +
			" <gateId>" + parkingAreaDtos.get(0).getNum() + "</gateId>\n" +
			" <!--Optional:-->\n" +
			" <directType>" + directType + "</directType>\n" +
			" <driverWayNo>" + carInoutDetailPo.getMachineId() + "</driverWayNo>\n" +
			" <!--Optional:-->\n" +
			" <initKey>"+key+"</initKey>\n" +
			" </ws:initTrans>\n" +
			" </soapenv:Body>\n" +
			"</soapenv:Envelope>";

			logger.debug("请求报文：{}",paramIn);
			HttpHeaders httpHeaders = new HttpHeaders();
			httpHeaders.add("Content-Type","text/xml;charset=UTF-8");
			HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity(paramIn, httpHeaders);
			try {
			ResponseEntity<String> responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
			logger.debug("返回报文,{}",responseEntity);
			String body = responseEntity.getBody();
			if(!body.contains("token")){
			return token;
			}
			token = body.substring(body.indexOf("<token>")+7,body.indexOf("</token>"));
			CommonCache.setValue("DGGAJ_Parking_token",token,CommonCache.TOKEN_EXPIRE_TIME);
			}catch (HttpStatusCodeException e){
			logger.error("调用异常",e);
			}catch (Exception e){
			logger.error("调用异常",e);
			}

			return token;
			}
			}

	java110-bean/src/main/java/com/java110/dto/data/DatabusDataDto.java	3 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	service-common/src/main/java/com/java110/common/smo/impl/CarInoutDetailV1InnerServiceSMOImpl.java	9 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	service-job/src/main/java/com/java110/job/adapt/car/SendInoutCarToDGGAJParkingAdapt.java	231 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

			@@ -15,6 +15,9 @@
			**/
			public class DatabusDataDto extends PageDto implements Serializable {

			// 车辆进出手动触发
			public static final String BUSINESS_TYPE_SAVE_CAR_INOUT_DETAIL = "saveCarInoutDetail";

			private String businessTypeCd;

			private JSONObject data;

			@@ -17,8 +17,10 @@


			import com.java110.common.dao.ICarInoutDetailV1ServiceDao;
			import com.java110.dto.data.DatabusDataDto;
			import com.java110.dto.machine.CarInoutDetailDto;
			import com.java110.intf.common.ICarInoutDetailV1InnerServiceSMO;
			import com.java110.intf.job.IDataBusInnerServiceSMO;
			import com.java110.po.car.CarInoutDetailPo;
			import com.java110.utils.util.BeanConvertUtil;
			import com.java110.core.base.smo.BaseServiceSMO;
			@@ -45,10 +47,17 @@
			@Autowired
			private ICarInoutDetailV1ServiceDao carInoutDetailV1ServiceDaoImpl;

			@Autowired
			private IDataBusInnerServiceSMO dataBusInnerServiceSMOImpl;


			@Override
			public int saveCarInoutDetail(@RequestBody CarInoutDetailPo carInoutDetailPo) {
			int saveFlag = carInoutDetailV1ServiceDaoImpl.saveCarInoutDetailInfo(BeanConvertUtil.beanCovertMap(carInoutDetailPo));

			//todo 手工触发databus
			dataBusInnerServiceSMOImpl.databusData(new DatabusDataDto(DatabusDataDto.BUSINESS_TYPE_SAVE_CAR_INOUT_DETAIL,BeanConvertUtil.beanCovertJson(carInoutDetailPo)));

			return saveFlag;
			}