| | |
|---|
| | | import com.genersoft.iot.vmp.storager.dao.GbStreamMapper; |
|---|
| | | import com.genersoft.iot.vmp.storager.dao.PlatformGbStreamMapper; |
|---|
| | | import com.genersoft.iot.vmp.storager.dao.StreamPushMapper; |
|---|
| | | import com.genersoft.iot.vmp.utils.DateUtil; |
|---|
| | | import org.checkerframework.checker.units.qual.C; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | |
|---|
| | | gbStreamMapper.update(transform); |
|---|
| | | streamPushMapper.del(gbStreamList.get(0).getApp(), gbStreamList.get(0).getStream()); |
|---|
| | | }else { |
|---|
| | | transform.setCreateStamp(System.currentTimeMillis()); |
|---|
| | | transform.setCreateTime(DateUtil.getNow()); |
|---|
| | | transform.setUpdateTime(DateUtil.getNow()); |
|---|
| | | gbStreamMapper.add(transform); |
|---|
| | | } |
|---|
| | | if (transform != null) { |
|---|
