| | |
| | | import com.whyc.dto.FBS9100_ComBase; |
| | | import com.whyc.mapper.FGCDFileDownloadMapper; |
| | | import com.whyc.pojo.FGCDFileDownload; |
| | | import com.whyc.util.ActionUtil; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | |
| | | return mapper.selectList(wrapper); |
| | | } |
| | | |
| | | /**不会进行op_cmd的返回码校验*/ |
| | | /**追加op_cmd的返回码校验*/ |
| | | public boolean sendCmdToA059(Integer deviceId) { |
| | | boolean exeRes = false; |
| | | UpdateWrapper<FGCDFileDownload> wrapper = Wrappers.update(); |
| | | wrapper.set("op_cmd", FBS9100_ComBase.CMD_StopFile).eq("dev_id",deviceId); |
| | | mapper.update(null,wrapper); |
| | | return true; |
| | | mapper.update((FGCDFileDownload) ActionUtil.objeNull,wrapper); |
| | | |
| | | QueryWrapper<FGCDFileDownload> queryWrapper = Wrappers.query(); |
| | | for (int i = 0; i < SuperConstant.CMD_SEND_TIME; i++) { |
| | | queryWrapper.eq("dev_id",deviceId).last(" limit 1"); |
| | | FGCDFileDownload download = mapper.selectOne(queryWrapper); |
| | | if(FBS9100_ComBase.CMD_StopFile_ACK == download.getOpCmd()){ |
| | | exeRes = true; |
| | | } |
| | | try { |
| | | sleep(SuperConstant.CMD_SEND_INTERVAL_TIME); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | return exeRes; |
| | | } |
| | | |
| | | public List sendCmdToA059ReadFile(Integer deviceId, Integer fileIndex) { |
| | | List<Object> resList = new LinkedList<>(); |
| | | UpdateWrapper<FGCDFileDownload> wrapper = Wrappers.update(); |
| | | wrapper.set("op_cmd", FBS9100_ComBase.CMD_ReadFBDFile).set("file_index",fileIndex).eq("dev_id",deviceId); |
| | | mapper.update(null,wrapper); |
| | | mapper.update((FGCDFileDownload) ActionUtil.objeNull,wrapper); |
| | | |
| | | QueryWrapper<FGCDFileDownload> queryWrapper = Wrappers.query(); |
| | | for (int i = 0; i < SuperConstant.CMD_SEND_TIME; i++) { |
| | |
| | | .set("download_flag7",download.getDownloadFlag7()) |
| | | .set("download_flag8",download.getDownloadFlag8()) |
| | | .eq("dev_id",download.getDevId()); |
| | | mapper.update(null,wrapper); |
| | | mapper.update((FGCDFileDownload) ActionUtil.objeNull,wrapper); |
| | | |
| | | QueryWrapper<FGCDFileDownload> queryWrapper = Wrappers.query(); |
| | | for (int i = 0; i < SuperConstant.CMD_SEND_TIME*2; i++) { |