| | |
|---|
| | | case MqttConstant.TENANT_UP_PREFIX_EQU: |
|---|
| | | ThreadUtil.execute(() -> { |
|---|
| | | try { |
|---|
| | | DryEquipment equipment = (DryEquipment) messageJson.get("equipment"); |
|---|
| | | |
|---|
| | | Object equObj = messageJson.get("equipment"); |
|---|
| | | DryEquipment equipment = JSON.parseObject(equObj.toString(), DryEquipment.class); |
|---|
| | | TenantContext.setTenant(equipment.getTenantId()+""); |
|---|
| | | DryEquipment dryEquipment = equipmentService.selectByTenantIdEquipmentId(equipment.getTenantId() + "", equipment.getCode()); |
|---|
| | | if (dryEquipment == null) { |
|---|
| | | equipmentService.save(equipment); |
|---|
| | | } |
|---|
| | | |
|---|
| | | Object typeObj = messageJson.get("eqpType"); |
|---|
| | | DryEqpType eqpType = JSON.parseObject(typeObj.toString(), DryEqpType.class); |
|---|
| | | DryEqpType dryEqpType = eqpTypeService.getById(eqpType.getId()); |
|---|
| | | if (dryEqpType == null) { |
|---|
| | | eqpTypeService.save(eqpType); |
|---|
| | | } |
|---|
| | | // 获取设备所属车间 |
|---|
| | | DryShop shop = (DryShop) messageJson.get("shop"); |
|---|
| | | shop.setTenantId(equipment.getTenantId()); |
|---|
| | | dryShopService.save(shop); |
|---|
| | | |
|---|
| | | Object shopObj = messageJson.get("shop"); |
|---|
| | | DryShop shop = JSON.parseObject(shopObj.toString(), DryShop.class); |
|---|
| | | DryShop dryShop = dryShopService.getById(shop.getId()); |
|---|
| | | if (dryShop == null) { |
|---|
| | | dryShopService.save(shop); |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
