| | |
|---|
| | | import com.ruoyi.common.core.redis.RedisCache; |
|---|
| | | import com.ruoyi.common.utils.spring.SpringUtils; |
|---|
| | | import com.ruoyi.task.CameraAssembleUtil; |
|---|
| | | import com.ruoyi.task.DataAssembleUtil; |
|---|
| | | import com.ruoyi.utils.FtpUtils; |
|---|
| | | |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | FtpUtils ftpUtil = new FtpUtils(RuoYiConfig.getFtpHost(),RuoYiConfig.getFtpUserName(),RuoYiConfig.getFtpPassWord()); |
|---|
| | | while (true){ |
|---|
| | | Date date=new Date(); |
|---|
| | | String nowTime=format.format(date); |
|---|
| | |
|---|
| | | //获取队列中的第一个(防止发送频繁，一次只处理一个) |
|---|
| | | JSONObject obj= (JSONObject) redisCache.lGetLpopIndex(Thread.currentThread().getName()); |
|---|
| | | |
|---|
| | | if(Thread.currentThread().getName().equals("DataAssemble")){ |
|---|
| | | DataAssembleUtil.DataTransmission(ftpUtil,obj); |
|---|
| | | }else if(Thread.currentThread().getName().equals("CameraAssemble")){ |
|---|
| | | if(Thread.currentThread().getName().equals("CameraAssemble")){ |
|---|
| | | CameraAssembleUtil.DataTransmission(obj); |
|---|
| | | } |
|---|
| | | }else{ |
|---|
