[update] 失衡入库数据优化

wj-datacenter-service/src/main/java/net/wanji/datacenter/kafka/CrossStrategyOptConsumerHandler.java

@@ -63,6 +63,8 @@ public class CrossStrategyOptConsumerHandler implements KafkaListenerErrorHandle
         if (StringUtils.isNotBlank(message)) {
             ObjectMapper mapper = JacksonUtils.getInstance();
             ImbalanceAlgorithmDTO imbalanceAlgorithmDTO = mapper.readValue(message, ImbalanceAlgorithmDTO.class);
+            // 设置3,优化方案
+            imbalanceAlgorithmDTO.setRtnType(3);
             crossStrategyOptService.save(imbalanceAlgorithmDTO);
         }
         acknowledgment.acknowledge();

wj-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/CrossStrategyOptServiceImpl.java

@@ -68,7 +68,7 @@ public class CrossStrategyOptServiceImpl implements CrossStrategyOptService {
     public void save(ImbalanceAlgorithmDTO dto) {
         try {
             // 未操作的不存
-            if (!Objects.equals(0, dto.getRtnType())) {
+            if (0 != dto.getRtnType()) {
                 ObjectMapper mapper = JacksonUtils.getInstance();
                 CrossStrategyResultEntity crossStrategyResultEntity = new CrossStrategyResultEntity();
                 crossStrategyResultEntity.setCrossId(dto.getPlatformId());