Explorar el Código

对象、关系发生变化后,记录变更历史-接口调整

linhuili hace 3 años
padre
commit
ae0c4ec222

+ 0 - 36
dmp-business/dmp-rwd-plus/src/main/java/com/persagy/dmp/rwd/version/handler/ObjectDigitalHistoryMessageHandler.java

@@ -33,8 +33,6 @@ import java.io.DataInput;
 @Slf4j
 @Component
 @RabbitListener
-@RestController
-@RequestMapping("object")
 public class ObjectDigitalHistoryMessageHandler extends AbstractRabbitHandlerTemplate {
 
     @Autowired
@@ -76,38 +74,4 @@ public class ObjectDigitalHistoryMessageHandler extends AbstractRabbitHandlerTem
         }
 
     }
-
-    @RequestMapping("/test")
-    public void handler2(@RequestBody String message) {
-        try {
-            log.info("对象历史记录-接收对象消息:{}", message);
-            //接收对象消息
-            DigitalManageMessage messageVO = objectMapper.readValue(message, DigitalManageMessage.class);
-            ObjectNode objectDigital = messageVO.getNewObj();
-            if(objectDigital == null || StrUtil.isEmpty(messageVO.getOperatorType()) || StrUtil.isEmpty(messageVO.getOperatorObj())){
-                log.info("对象消息格式有误:{}"+ messageVO);
-                return;
-            }
-            if(!ObjectDigital.class.getSimpleName().equals(messageVO.getOperatorObj())){
-                return;
-            }
-            ObjectDigital objectDigitalVO = objectMapper.readValue(objectDigital.toString(), ObjectDigital.class);
-            //新增对象,历史记录
-            if(DigitalMessageConstant.OPERATE_AFTER_INSERT.equals(messageVO.getOperatorType())){
-                objectDigitalHisService.insert(objectDigitalVO);
-            }
-            //修改对象,历史记录
-            if(DigitalMessageConstant.OPERATE_AFTER_UPDATE.equals(messageVO.getOperatorType())){
-                objectDigitalHisService.update(objectDigitalVO);
-            }
-            //删除对象,历史记录
-            if(DigitalMessageConstant.OPERATE_AFTER_DELETE.equals(messageVO.getOperatorType())){
-                objectDigitalHisService.delete(objectDigitalVO);
-            }
-        } catch (Exception e) {
-            log.error(e.getMessage(), e);
-            throw new BusinessException(e.getMessage(), e);
-        }
-
-    }
 }