Browse Source

优化功能调用记录

develop
zhaoxianglong 9 months ago
parent
commit
c297fa4bb3
  1. 17
      zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java
  2. 73
      zc-business/src/main/java/com/zc/business/interfaces/OperationLogAspect.java

17
zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java

@ -517,7 +517,11 @@ public class DcDeviceController extends BaseController {
resultArray.add(result); resultArray.add(result);
AjaxResult ajaxResult = (AjaxResult) result.get("result"); AjaxResult ajaxResult = (AjaxResult) result.get("result");
if (!Objects.equals(String.valueOf(ajaxResult.get("code")), "200")) { if (!Objects.equals(String.valueOf(ajaxResult.get("code")), "200")) {
return AjaxResult.error(200,"500"); if (Objects.equals(device.getString("deviceType"), "15")) {
return AjaxResult.error(200, "500");
} else {
return AjaxResult.error();
}
} }
} }
} }
@ -529,9 +533,16 @@ public class DcDeviceController extends BaseController {
}); });
JSONObject result = new JSONObject(); JSONObject result = new JSONObject();
result.put("device", device.getString("id")); result.put("device", device.getString("id"));
result.put("functionId",functionId); result.put("functionId", functionId);
if (device.getInteger("deviceType").equals(DeviceTypeConstants.ROAD_SECTION_VOICE_BROADCASTING)) { if (device.getInteger("deviceType").equals(DeviceTypeConstants.ROAD_SECTION_VOICE_BROADCASTING)) {
result.put("result", broadcastController.nearCamListDistance(jsonObject)); JSONObject value = broadcastController.nearCamListDistance(jsonObject);
AjaxResult ajaxResult = new AjaxResult();
value.keySet().forEach(item -> {
ajaxResult.put(item, value.getString(item));
});
ajaxResult.put("code", 200);
result.put("result", ajaxResult);
} else { } else {
result.put("result", getAjaxResult(iotDeviceId, functionId, params)); result.put("result", getAjaxResult(iotDeviceId, functionId, params));
} }

73
zc-business/src/main/java/com/zc/business/interfaces/OperationLogAspect.java

@ -17,7 +17,6 @@ import com.zc.business.domain.DcOperLog;
import com.zc.business.domain.DcPublishManage; import com.zc.business.domain.DcPublishManage;
import com.zc.business.service.IDcDeviceService; import com.zc.business.service.IDcDeviceService;
import com.zc.business.service.IDcOperLogService; import com.zc.business.service.IDcOperLogService;
import com.zc.business.service.IDcPublishInfoService;
import com.zc.business.service.IDcPublishManageService; import com.zc.business.service.IDcPublishManageService;
import org.aspectj.lang.JoinPoint; import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.ProceedingJoinPoint;
@ -27,6 +26,7 @@ import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
@Aspect @Aspect
@Component @Component
@ -162,7 +162,7 @@ public class OperationLogAspect {
} else { } else {
pointArg = (JSONObject) JSON.toJSON(pointArgs[0]); pointArg = (JSONObject) JSON.toJSON(pointArgs[0]);
} }
String contentDetails = "";
JSONArray devices = pointArg.getJSONArray("devices"); JSONArray devices = pointArg.getJSONArray("devices");
JSONArray functions = pointArg.getJSONArray("functions"); JSONArray functions = pointArg.getJSONArray("functions");
@ -205,6 +205,19 @@ public class OperationLogAspect {
if (i1 < functions.size() - 1) { if (i1 < functions.size() - 1) {
remark.append("、"); remark.append("、");
} }
if (Objects.equals(function.getString("functionId"), "13")&&Objects.equals(deviceType,"2")){
JSONArray parameters = function.getJSONObject("params").getJSONArray("parameters");
List<String> content = parameters.stream().map(item->((JSONObject)item).getString("CONTENT")).collect(Collectors.toList());
contentDetails = content.toString().replace("[", "").replace("]", "");
}
if (Objects.equals(deviceType,"5")){
contentDetails = function.getJSONObject("params").getString("text");
}
} }
if (i < (devices.size() - 1)) { if (i < (devices.size() - 1)) {
@ -262,7 +275,7 @@ public class OperationLogAspect {
dcPublishManage.setPublishChannels(7); dcPublishManage.setPublishChannels(7);
} }
dcPublishManage.setContentDetails(remark.toString()); dcPublishManage.setContentDetails(contentDetails);
dcPublishManageService.insertDcPublishManage(dcPublishManage); dcPublishManageService.insertDcPublishManage(dcPublishManage);
} }
@ -312,33 +325,33 @@ public class OperationLogAspect {
dcOperLogService.save(operLog); dcOperLogService.save(operLog);
if ((Objects.equals(deviceType, "2") || Objects.equals(deviceType, "5")) && Objects.nonNull(operLog.getId())) { //if ((Objects.equals(deviceType, "2") || Objects.equals(deviceType, "5")) && Objects.nonNull(operLog.getId())) {
DcPublishManage dcPublishManage = new DcPublishManage(); // DcPublishManage dcPublishManage = new DcPublishManage();
//
if (Objects.equals(state, "0") && Objects.equals(String.valueOf(((AjaxResult) jsonResult).get("code")), "200")) { // if (Objects.equals(state, "0") && Objects.equals(String.valueOf(((AjaxResult) jsonResult).get("code")), "200")) {
dcPublishManage.setPublishStatus(1);//发布状态1-成功2-失败 // dcPublishManage.setPublishStatus(1);//发布状态1-成功2-失败
} else { // } else {
dcPublishManage.setPublishStatus(2);//发布状态1-成功2-失败 // dcPublishManage.setPublishStatus(2);//发布状态1-成功2-失败
} // }
//
if (loginUser != null) { // if (loginUser != null) {
dcPublishManage.setPublisher(loginUser.getUsername());//发布人 // dcPublishManage.setPublisher(loginUser.getUsername());//发布人
} else { // } else {
dcPublishManage.setPublisher("系统定时调用");//发布人 // dcPublishManage.setPublisher("系统定时调用");//发布人
} // }
dcPublishManage.setPublishTime(new Date());//发布时间 // dcPublishManage.setPublishTime(new Date());//发布时间
dcPublishManage.setCreateTime(new Date());//创建时间 // dcPublishManage.setCreateTime(new Date());//创建时间
//
dcPublishManage.setLogId(Long.valueOf(operLog.getId()));//发布的如果的情报板传对应id // dcPublishManage.setLogId(Long.valueOf(operLog.getId()));//发布的如果的情报板传对应id
if (Objects.equals(deviceType, "2")) { // if (Objects.equals(deviceType, "2")) {
dcPublishManage.setPublishChannels(4); // dcPublishManage.setPublishChannels(4);
} else { // } else {
dcPublishManage.setPublishChannels(7); // dcPublishManage.setPublishChannels(7);
} // }
//
dcPublishManage.setContentDetails(remark.toString()); // dcPublishManage.setContentDetails(remark.toString());
dcPublishManageService.insertDcPublishManage(dcPublishManage); // dcPublishManageService.insertDcPublishManage(dcPublishManage);
} //}
} }
} }

Loading…
Cancel
Save