Commit bc98f5e8106d692df09707f638928779b581240d

Authored by lijianfa_14810364212
1 parent d796edbc

fix:解决场景联动与规则链的关联关系BUG

... ... @@ -224,7 +224,7 @@ public class TkConvertDataToController extends BaseController {
224 224 Integer sceneStatus = convertReqDTO.getStatus();
225 225 JsonNode configuration =
226 226 sceneLinkageService.getRuleNodeConfig(
227   - sceneId,
  227 + sceneId, querySceneLink.getRuleChainId(),
228 228 currentTenant,
229 229 getCurrentUser().getCustomerId().getId().toString(),
230 230 sceneStatus);
... ...
... ... @@ -602,6 +602,7 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
602 602 if (partitionService.resolve(ServiceType.TB_CORE, stateData.getTenantId(), deviceId).isMyPartition()) {
603 603
604 604 } else {
  605 + log.error("updateInactivityStateIfExpired isMyPartition=false , serverType={},tenantId={},deviceId={}",ServiceType.TB_CORE,stateData.getTenantId(),deviceId);
605 606 cleanupEntity(deviceId);
606 607 }
607 608 }
... ... @@ -617,7 +618,6 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
617 618 state.setLastInactivityAlarmTime(ts);
618 619 save(deviceId, INACTIVITY_ALARM_TIME, ts);
619 620 onDeviceActivityStatusChange(deviceId, false, stateData);
620   - System.err.println("Inactivity Device : "+deviceId);
621 621 }
622 622
623 623 boolean isActive(long ts, DeviceState state) {
... ...
... ... @@ -41,7 +41,7 @@ public class UserDTO extends BaseDTO {
41 41 private String[] roleIds;
42 42
43 43 @ApiModelProperty(value = "电话号码")
44   -// @NotEmpty(message = "电话号码不能为空或字符串", groups = AddGroup.class)
  44 + @NotEmpty(message = "电话号码不能为空或字符串", groups = AddGroup.class)
45 45 private String phoneNumber;
46 46
47 47 @ApiModelProperty(value = "邮箱")
... ...
... ... @@ -473,11 +473,12 @@ public class TkSceneLinkageServiceImpl
473 473 */
474 474 @Override
475 475 public JsonNode getRuleNodeConfig(
476   - String currentSceneId, String tenantId, String customerId, Integer state) {
  476 + String currentSceneId, String ruleChainId,String tenantId, String customerId, Integer state) {
477 477 List<TkSceneLinkageEntity> runningScenes =
478 478 baseMapper.selectList(
479 479 new LambdaQueryWrapper<TkSceneLinkageEntity>()
480 480 .eq(TkSceneLinkageEntity::getTenantId, tenantId)
  481 + .eq(TkSceneLinkageEntity::getRuleChainId,ruleChainId)
481 482 .eq(TkSceneLinkageEntity::getStatus, FastIotConstants.StateValue.ENABLE));
482 483 Set<String> enableIds = new HashSet<>();
483 484 Map<String, String> sceneInform = new HashMap<>();
... ...
... ... @@ -87,7 +87,7 @@ public interface SceneLinkageService extends BaseService<TkSceneLinkageEntity>{
87 87 * @param state 是否启动
88 88 * @return
89 89 */
90   - JsonNode getRuleNodeConfig(String sceneId,String tenantId,String customerId,Integer state);
  90 + JsonNode getRuleNodeConfig(String sceneId,String ruleChainId,String tenantId,String customerId,Integer state);
91 91
92 92 /**
93 93 * 详情
... ...