From 576c52d8d8e6fb1e738380cc5fc101a6a2b0b3a8 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期六, 04 九月 2021 16:00:57 +0800
Subject: [PATCH] Merge branch 'master' of http://git.homecommunity.cn/supervip/MicroCommunity
---
service-job/src/main/java/com/java110/job/adapt/hcIot/asyn/impl/IotSendAsynImpl.java | 278 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 278 insertions(+), 0 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcIot/asyn/impl/IotSendAsynImpl.java b/service-job/src/main/java/com/java110/job/adapt/hcIot/asyn/impl/IotSendAsynImpl.java
old mode 100644
new mode 100755
index 02d7c59..f523206
--- a/service-job/src/main/java/com/java110/job/adapt/hcIot/asyn/impl/IotSendAsynImpl.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcIot/asyn/impl/IotSendAsynImpl.java
@@ -15,6 +15,7 @@
*/
package com.java110.job.adapt.hcIot.asyn.impl;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.client.RestTemplate;
import com.java110.core.factory.GenerateCodeFactory;
@@ -307,6 +308,7 @@
}
@Override
+ @Async
public void deleteMachine(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_DELETE_MACHINE,
postParameters.getString("machineCode"),
@@ -348,6 +350,7 @@
}
@Override
+ @Async
public void addOwner(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_ADD_OWNER_FACE,
@@ -393,6 +396,7 @@
}
@Override
+ @Async
public void sendUpdateOwner(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_UPDATE_OWNER_FACE,
postParameters.getString("machineCode"),
@@ -435,6 +439,7 @@
}
@Override
+ @Async
public void sendDeleteOwner(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
@@ -487,6 +492,7 @@
* @param reqJson
*/
@Override
+ @Async
public void reSendIot(JSONObject reqJson) {
MachineTranslateErrorDto machineTranslateErrorDto = new MachineTranslateErrorDto();
machineTranslateErrorDto.setCommunityId(reqJson.getString("communityId"));
@@ -518,6 +524,7 @@
}
@Override
+ @Async
public void addParkingArea(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_ADD_PARKING_AREA,
DEFAULT_MACHINE_CODE,
@@ -564,6 +571,7 @@
}
@Override
+ @Async
public void updateParkingArea(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_UPDATE_PARKING_AREA,
DEFAULT_MACHINE_CODE,
@@ -610,6 +618,7 @@
}
@Override
+ @Async
public void deleteParkingArea(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_DELETE_PARKING_AREA,
DEFAULT_MACHINE_CODE,
@@ -656,6 +665,7 @@
}
@Override
+ @Async
public void addOwnerCar(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
MachineTranslateDto.CMD_ADD_OWNER_CAR,
@@ -703,6 +713,7 @@
}
@Override
+ @Async
public void updateOwnerCar(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_UPDATE_OWNER_CAR,
DEFAULT_MACHINE_CODE,
@@ -749,6 +760,7 @@
}
@Override
+ @Async
public void deleteOwnerCar(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_DELETE_OWNER_CAR,
DEFAULT_MACHINE_CODE,
@@ -795,6 +807,7 @@
}
@Override
+ @Async
public void addCarBlackWhite(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
MachineTranslateDto.CMD_ADD_CAR_BLACK_WHITE,
@@ -842,6 +855,7 @@
}
@Override
+ @Async
public void deleteCarBlackWhite(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
MachineTranslateDto.CMD_DELETE_CAR_BLACK_WHITE,
@@ -890,6 +904,7 @@
@Override
+ @Async
public void addTempCarFeeConfig(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
MachineTranslateDto.CMD_ADD_TEAM_CAR_FEE_CONFIG,
@@ -937,6 +952,7 @@
}
@Override
+ @Async
public void updateTempCarFeeConfig(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
MachineTranslateDto.CMD_UPDATE_TEAM_CAR_FEE_CONFIG,
@@ -984,6 +1000,7 @@
}
@Override
+ @Async
public void deleteTempCarFeeConfig(JSONObject postParameters) {
MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
MachineTranslateDto.CMD_DELETE_TEAM_CAR_FEE_CONFIG,
@@ -1030,6 +1047,267 @@
}
}
+ @Override
+ @Async
+ public void addAttendance(JSONObject postParameters, List<JSONObject> staffs) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_ADD_ATTENDANCE_CLASSES,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extClassesId",
+ "classesName",
+ MachineTranslateDto.TYPE_ATTENDANCE);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.ADD_ATTENDANCE_CLASSES);
+ try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
+ HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
+ responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ logger.debug("璋冪敤HC IOT淇℃伅锛�" + responseEntity);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(responseEntity.getBody());
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+ return;
+ }
+ JSONObject tokenObj = JSONObject.parseObject(responseEntity.getBody());
+
+ if (!tokenObj.containsKey("code") || ResultVo.CODE_OK != tokenObj.getInteger("code")) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(tokenObj.getString("msg"));
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ }
+
+ if (staffs == null || staffs.size() < 1) {
+ return;
+ }
+
+ url = IotConstant.getUrl(IotConstant.ADD_ATTENDANCE_CLASSES_STAFFS);
+ for (JSONObject staff : staffs) {
+ staff.put("taskId", machineTranslateDto.getMachineTranslateId());
+ }
+
+ httpEntity = new HttpEntity(JSONArray.toJSONString(staffs), getHeaders());
+ responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+
+ } catch (Exception e) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(e.getLocalizedMessage());
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ } finally {
+ saveTranslateLog(machineTranslateDto);
+ refreshAccessToken(responseEntity);
+ }
+ }
+
+ @Override
+ @Async
+ public void addAttendanceStaff(JSONObject postParameters, List<JSONObject> staffs) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_ADD_ATTENDANCE_CLASSES,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extClassesId",
+ "classesName",
+ MachineTranslateDto.TYPE_ATTENDANCE);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.ADD_ATTENDANCE_CLASSES_STAFFS);
+ try {
+ for (JSONObject staff : staffs) {
+ staff.put("taskId", machineTranslateDto.getMachineTranslateId());
+ }
+ HttpEntity httpEntity = new HttpEntity(JSONArray.toJSONString(staffs), getHeaders());
+ responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ logger.debug("璋冪敤HC IOT淇℃伅锛�" + responseEntity);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(responseEntity.getBody());
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+ return;
+ }
+ JSONObject tokenObj = JSONObject.parseObject(responseEntity.getBody());
+
+ if (!tokenObj.containsKey("code") || ResultVo.CODE_OK != tokenObj.getInteger("code")) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(tokenObj.getString("msg"));
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ }
+
+ } catch (Exception e) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(e.getLocalizedMessage());
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ } finally {
+ saveTranslateLog(machineTranslateDto);
+ refreshAccessToken(responseEntity);
+ }
+ }
+
+
+ @Override
+ @Async
+ public void deleteAttendanceStaff(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_DELETE_ATTENDANCE_CLASSES,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extClassesId",
+ "classesName",
+ MachineTranslateDto.TYPE_ATTENDANCE);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.DELETE_ATTENDANCE_CLASSES_STAFFS);
+ try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
+ HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
+ responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ logger.debug("璋冪敤HC IOT淇℃伅锛�" + responseEntity);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(responseEntity.getBody());
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+ return;
+ }
+ JSONObject tokenObj = JSONObject.parseObject(responseEntity.getBody());
+
+ if (!tokenObj.containsKey("code") || ResultVo.CODE_OK != tokenObj.getInteger("code")) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(tokenObj.getString("msg"));
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ }
+
+ } catch (Exception e) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(e.getLocalizedMessage());
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ } finally {
+ saveTranslateLog(machineTranslateDto);
+ refreshAccessToken(responseEntity);
+ }
+ }
+
+ @Override
+ @Async
+ public void updateAttendance(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_UPDATE_ATTENDANCE_CLASSES,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extClassesId",
+ "classesName",
+ MachineTranslateDto.TYPE_ATTENDANCE);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.UPDATE_ATTENDANCE_CLASSES);
+ try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
+ HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
+ responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ logger.debug("璋冪敤HC IOT淇℃伅锛�" + responseEntity);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(responseEntity.getBody());
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+ return;
+ }
+ JSONObject tokenObj = JSONObject.parseObject(responseEntity.getBody());
+
+ if (!tokenObj.containsKey("code") || ResultVo.CODE_OK != tokenObj.getInteger("code")) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(tokenObj.getString("msg"));
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ }
+
+ } catch (Exception e) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(e.getLocalizedMessage());
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ } finally {
+ saveTranslateLog(machineTranslateDto);
+ refreshAccessToken(responseEntity);
+ }
+ }
+
+ @Override
+ @Async
+ public void deleteAttendance(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_DELETE_ATTENDANCE_CLASSES,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extClassesId",
+ "classesName",
+ MachineTranslateDto.TYPE_ATTENDANCE);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.DELETE_ATTENDANCE_CLASSES);
+ try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
+ HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
+ responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ logger.debug("璋冪敤HC IOT淇℃伅锛�" + responseEntity);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(responseEntity.getBody());
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+ return;
+ }
+ JSONObject tokenObj = JSONObject.parseObject(responseEntity.getBody());
+
+ if (!tokenObj.containsKey("code") || ResultVo.CODE_OK != tokenObj.getInteger("code")) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(tokenObj.getString("msg"));
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ }
+
+ } catch (Exception e) {
+ machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
+ machineTranslateDto.setRemark(e.getLocalizedMessage());
+ //淇濆瓨 澶辫触鎶ユ枃
+ saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
+
+ return;
+ } finally {
+ saveTranslateLog(machineTranslateDto);
+ refreshAccessToken(responseEntity);
+ }
+ }
+
private MachineTranslateDto getMachineTranslateDto(JSONObject postParameters, String cmd,
String machineCode,
String machineId,
--
Gitblit v1.8.0