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 | 961 ++++++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 866 insertions(+), 95 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 1271147..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;
@@ -30,7 +31,6 @@
import com.java110.job.adapt.hcIot.asyn.IIotSendAsyn;
import com.java110.po.machineTranslateError.MachineTranslateErrorPo;
import com.java110.utils.util.DateUtil;
-import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -51,6 +51,9 @@
@Service
public class IotSendAsynImpl implements IIotSendAsyn {
private static final Logger logger = LoggerFactory.getLogger(IotSendAsynImpl.class);
+
+ private static final String DEFAULT_MACHINE_CODE = "-";
+ private static final String DEFAULT_MACHINE_ID = "-";
@Autowired
@@ -100,19 +103,14 @@
@Override
@Async
public void addCommunity(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_ADD_COMMUNITY);
- machineTranslateDto.setMachineCode("-");
- machineTranslateDto.setMachineId("-");
- machineTranslateDto.setObjId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setObjName(postParameters.getString("name"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_COMMUNITY);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_ADD_COMMUNITY,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID, "extCommunityId", "name", MachineTranslateDto.TYPE_COMMUNITY);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.ADD_COMMUNITY_URL);
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);
@@ -137,19 +135,13 @@
@Override
@Async
public void editCommunity(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_UPDATE_COMMUNITY);
- machineTranslateDto.setMachineCode("-");
- machineTranslateDto.setMachineId("-");
- machineTranslateDto.setObjId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setObjName(postParameters.getString("name"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_COMMUNITY);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_UPDATE_COMMUNITY,
+ DEFAULT_MACHINE_CODE, DEFAULT_MACHINE_ID, "extCommunityId", "name", MachineTranslateDto.TYPE_COMMUNITY);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.UPDATE_COMMUNITY_URL);
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);
@@ -176,19 +168,14 @@
@Override
@Async
public void deleteCommunity(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_DELETE_COMMUNITY);
- machineTranslateDto.setMachineCode("-");
- machineTranslateDto.setMachineId("-");
- machineTranslateDto.setObjId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setObjName(postParameters.getString("name"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_COMMUNITY);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_DELETE_COMMUNITY,
+ DEFAULT_MACHINE_CODE, DEFAULT_MACHINE_ID,
+ "extCommunityId", "name", MachineTranslateDto.TYPE_COMMUNITY);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.DELETE_COMMUNITY_URL);
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);
@@ -220,19 +207,13 @@
@Override
@Async
public void addMachine(JSONObject postParameters, List<JSONObject> ownerDtos) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_ADD_MACHINE);
- machineTranslateDto.setMachineCode(postParameters.getString("machineCode"));
- machineTranslateDto.setMachineId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjName(postParameters.getString("machineName"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_MACHINE);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_ADD_MACHINE,
+ postParameters.getString("machineCode"), postParameters.getString("extMachineId"),
+ "extMachineId", "machineName", MachineTranslateDto.TYPE_MACHINE);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.ADD_MACHINE_URL);
try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
responseEntity = outRestTemplate.exchange(IotConstant.getUrl(IotConstant.ADD_MACHINE_URL), HttpMethod.POST, httpEntity, String.class);
@@ -280,19 +261,14 @@
@Override
@Async
public void updateMachine(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_UPDATE_MACHINE);
- machineTranslateDto.setMachineCode(postParameters.getString("machineCode"));
- machineTranslateDto.setMachineId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjName(postParameters.getString("machineName"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_MACHINE);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_UPDATE_MACHINE,
+ postParameters.getString("machineCode"),
+ postParameters.getString("extMachineId"),
+ "extMachineId", "machineName", MachineTranslateDto.TYPE_MACHINE);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.UPDATE_MACHINE_URL);
try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
@@ -332,20 +308,18 @@
}
@Override
+ @Async
public void deleteMachine(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_DELETE_MACHINE);
- machineTranslateDto.setMachineCode(postParameters.getString("machineCode"));
- machineTranslateDto.setMachineId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjName(postParameters.getString("machineName"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_MACHINE);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_DELETE_MACHINE,
+ postParameters.getString("machineCode"),
+ postParameters.getString("extMachineId"),
+ "extMachineId",
+ "machineName",
+ MachineTranslateDto.TYPE_MACHINE);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.DELETE_MACHINE_URL);
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);
@@ -363,7 +337,6 @@
machineTranslateDto.setRemark(tokenObj.getString("msg"));
//淇濆瓨 澶辫触鎶ユ枃
saveTranslateError(machineTranslateDto, postParameters.toJSONString(), responseEntity != null ? responseEntity.getBody() : "", url);
-
}
} catch (Exception e) {
machineTranslateDto.setState(MachineTranslateDto.STATE_ERROR);
@@ -377,21 +350,19 @@
}
@Override
+ @Async
public void addOwner(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_ADD_OWNER_FACE);
- machineTranslateDto.setMachineCode(postParameters.getString("machineCode"));
- machineTranslateDto.setMachineId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjId(postParameters.getString("userId"));
- machineTranslateDto.setObjName(postParameters.getString("name"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_OWNER);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_ADD_OWNER_FACE,
+ postParameters.getString("machineCode"),
+ postParameters.getString("extMachineId"),
+ "userId",
+ "name",
+ MachineTranslateDto.TYPE_OWNER);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.ADD_OWNER);
try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
@@ -425,20 +396,17 @@
}
@Override
+ @Async
public void sendUpdateOwner(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_UPDATE_OWNER_FACE);
- machineTranslateDto.setMachineCode(postParameters.getString("machineCode"));
- machineTranslateDto.setMachineId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjId(postParameters.getString("userId"));
- machineTranslateDto.setObjName(postParameters.getString("name"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_OWNER);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_UPDATE_OWNER_FACE,
+ postParameters.getString("machineCode"),
+ postParameters.getString("extMachineId"),
+ "userId", "name",
+ MachineTranslateDto.TYPE_OWNER);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.EDIT_OWNER);
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);
@@ -471,21 +439,20 @@
}
@Override
+ @Async
public void sendDeleteOwner(JSONObject postParameters) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
- machineTranslateDto.setMachineCmd(MachineTranslateDto.CMD_DELETE_OWNER_FACE);
- machineTranslateDto.setMachineCode(postParameters.getString("machineCode"));
- machineTranslateDto.setMachineId(postParameters.getString("extMachineId"));
- machineTranslateDto.setObjId(postParameters.getString("userId"));
- machineTranslateDto.setObjName(postParameters.getString("name"));
- machineTranslateDto.setTypeCd(MachineTranslateDto.TYPE_OWNER);
- machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
- machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_DELETE_OWNER_FACE,
+ postParameters.getString("machineCode"),
+ postParameters.getString("extMachineId"),
+ "userId",
+ "name",
+ MachineTranslateDto.TYPE_OWNER);
ResponseEntity<String> responseEntity = null;
String url = IotConstant.getUrl(IotConstant.DELETE_OWNER);
try {
+ postParameters.put("taskId", machineTranslateDto.getMachineTranslateId());
HttpEntity httpEntity = new HttpEntity(postParameters.toJSONString(), getHeaders());
responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
@@ -525,6 +492,7 @@
* @param reqJson
*/
@Override
+ @Async
public void reSendIot(JSONObject reqJson) {
MachineTranslateErrorDto machineTranslateErrorDto = new MachineTranslateErrorDto();
machineTranslateErrorDto.setCommunityId(reqJson.getString("communityId"));
@@ -555,6 +523,812 @@
machineTranslateInnerServiceSMOImpl.updateMachineTranslateState(machineTranslateDto);
}
+ @Override
+ @Async
+ public void addParkingArea(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_ADD_PARKING_AREA,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extPaId",
+ "num",
+ MachineTranslateDto.TYPE_PARKING_AREA);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.ADD_PARKING_AREA_URL);
+ 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 updateParkingArea(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_UPDATE_PARKING_AREA,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extPaId",
+ "num",
+ MachineTranslateDto.TYPE_PARKING_AREA);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.UPDATE_PARKING_AREA_URL);
+ 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 deleteParkingArea(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_DELETE_PARKING_AREA,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extPaId",
+ "num",
+ MachineTranslateDto.TYPE_PARKING_AREA);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.DELETE_PARKING_AREA_URL);
+ 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 addOwnerCar(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_ADD_OWNER_CAR,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extCarId",
+ "carNum",
+ MachineTranslateDto.TYPE_OWNER_CAR);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.ADD_OWNER_CAR_URL);
+ 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 updateOwnerCar(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_UPDATE_OWNER_CAR,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extCarId",
+ "carNum",
+ MachineTranslateDto.TYPE_OWNER_CAR);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.UPDATE_OWNER_CAR_URL);
+ 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 deleteOwnerCar(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters, MachineTranslateDto.CMD_DELETE_OWNER_CAR,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extCarId",
+ "carNum",
+ MachineTranslateDto.TYPE_OWNER_CAR);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.DELETE_OWNER_CAR_URL);
+ 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 addCarBlackWhite(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_ADD_CAR_BLACK_WHITE,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extBwId",
+ "carNum",
+ MachineTranslateDto.TYPE_OWNER_CAR);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.ADD_CAR_BLACK_WHITE_URL);
+ 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 deleteCarBlackWhite(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_DELETE_CAR_BLACK_WHITE,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extBwId",
+ "carNum",
+ MachineTranslateDto.TYPE_OWNER_CAR);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.DELETE_CAR_BLACK_WHITE_URL);
+ 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 addTempCarFeeConfig(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_ADD_TEAM_CAR_FEE_CONFIG,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extConfigId",
+ "feeName",
+ MachineTranslateDto.TYPE_TEAM_CAR_FEE_CONFIG);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.ADD_TEAM_CAR_FEE_CONFIG);
+ 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 updateTempCarFeeConfig(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_UPDATE_TEAM_CAR_FEE_CONFIG,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extConfigId",
+ "feeName",
+ MachineTranslateDto.TYPE_TEAM_CAR_FEE_CONFIG);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.UPDATE_TEAM_CAR_FEE_CONFIG);
+ 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 deleteTempCarFeeConfig(JSONObject postParameters) {
+ MachineTranslateDto machineTranslateDto = getMachineTranslateDto(postParameters,
+ MachineTranslateDto.CMD_DELETE_TEAM_CAR_FEE_CONFIG,
+ DEFAULT_MACHINE_CODE,
+ DEFAULT_MACHINE_ID,
+ "extBwId",
+ "carNum",
+ MachineTranslateDto.TYPE_TEAM_CAR_FEE_CONFIG);
+ ResponseEntity<String> responseEntity = null;
+ String url = IotConstant.getUrl(IotConstant.DELETE_TEAM_CAR_FEE_CONFIG);
+ 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 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,
+ String objId,
+ String objName,
+ String typeCd) {
+ MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
+ machineTranslateDto.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
+ machineTranslateDto.setCommunityId(postParameters.getString("extCommunityId"));
+ machineTranslateDto.setMachineCmd(cmd);
+ machineTranslateDto.setMachineCode(machineCode);
+ machineTranslateDto.setMachineId(machineId);
+ machineTranslateDto.setObjId(postParameters.getString(objId));
+ machineTranslateDto.setObjName(postParameters.getString(objName));
+ machineTranslateDto.setTypeCd(typeCd);
+ machineTranslateDto.setState(MachineTranslateDto.STATE_SUCCESS);
+ machineTranslateDto.setRemark("鍚屾鐗╄仈缃戠郴缁熸垚鍔�");
+ return machineTranslateDto;
+ }
+
+
/**
* 瀛樺偍浜や簰 璁板綍
*
@@ -562,9 +1336,6 @@
*/
public void saveTranslateLog(MachineTranslateDto machineTranslateDto) {
machineTranslateDto.setbId("-1");
- if (StringUtil.isEmpty(machineTranslateDto.getMachineTranslateId())) {
- machineTranslateDto.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
- }
machineTranslateDto.setObjBId("-1");
machineTranslateDto.setUpdateTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
machineTranslateInnerServiceSMOImpl.saveMachineTranslate(machineTranslateDto);
--
Gitblit v1.8.0