| | |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.whyc.constant.CMD_Constant; |
| | | import com.whyc.constant.LogOpEnum; |
| | | import com.whyc.constant.OperationLogEnum; |
| | | import com.whyc.dto.Response; |
| | | import com.whyc.mapper.CKPowerDevBattSetLogMapper; |
| | | import com.whyc.mapper.CKPowerDevHrTestParamMapper; |
| | | import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtStateSet; |
| | | import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattSetLog; |
| | | import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevHrTestParam; |
| | | import com.whyc.util.OpCmdUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | @Service |
| | | public class CKPowerDevHrTestParamService { |
| | |
| | | @Resource |
| | | private CKPowerDevHrTestParamMapper mapper; |
| | | |
| | | @Resource |
| | | private CKPowerDevBattSetLogMapper setLogMapper; |
| | | |
| | | @Resource |
| | | private CKPowerDevBattSetLogService setLogService; |
| | | |
| | | public Response getBattDisParam() { |
| | | UpdateWrapper<CKPowerDevHrTestParam> update = Wrappers.update(); |
| | | update.set("op_cmd",CMD_Constant.CMD_GetBattDisParam); |
| | | mapper.update(null,update); |
| | | QueryWrapper<CKPowerDevHrTestParam> query = Wrappers.query(); |
| | | return OpCmdUtil.readByUpdateOpCmd(mapper, query, CMD_Constant.CMD_GetBattDisParam, 20, null); |
| | | Response opStatus= OpCmdUtil.readByUpdateOpCmd(mapper, query, CMD_Constant.CMD_GetBattDisParam, 20, null); |
| | | if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功 |
| | | //记录日志 |
| | | Date now = new Date(); |
| | | CKPowerDevBattSetLog log=new CKPowerDevBattSetLog(); |
| | | //查询最大的操作编号 |
| | | String opNum=setLogMapper.getOpNum()!=null?setLogMapper.getOpNum():"0"; |
| | | log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1)); |
| | | log.setCreateTime(now); |
| | | log.setCreateDay(now); |
| | | log.setCmdType(LogOpEnum.TYPE_CMD_RED.getType()); |
| | | log.setDevType(0); |
| | | log.setBattIndex(0); |
| | | setLogService.add(log); |
| | | } |
| | | return opStatus; |
| | | } |
| | | |
| | | public Response getDevIp() { |
| | |
| | | update.set("op_cmd",CMD_Constant.CMD_GetDevIP); |
| | | mapper.update(null,update); |
| | | QueryWrapper<CKPowerDevHrTestParam> query = Wrappers.query(); |
| | | return OpCmdUtil.readByUpdateOpCmd(mapper, query, CMD_Constant.CMD_GetDevIP, 20, null); |
| | | Response opStatus= OpCmdUtil.readByUpdateOpCmd(mapper, query, CMD_Constant.CMD_GetDevIP, 20, null); |
| | | if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功 |
| | | //记录日志 |
| | | Date now = new Date(); |
| | | CKPowerDevBattSetLog log=new CKPowerDevBattSetLog(); |
| | | //查询最大的操作编号 |
| | | String opNum=setLogMapper.getOpNum()!=null?setLogMapper.getOpNum():"0"; |
| | | log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1)); |
| | | log.setCreateTime(now); |
| | | log.setCreateDay(now); |
| | | log.setCmdType(LogOpEnum.TYPE_CMD_RED.getType()); |
| | | log.setDevType(0); |
| | | log.setBattIndex(0); |
| | | setLogService.add(log); |
| | | } |
| | | return opStatus; |
| | | } |
| | | |
| | | public Response update(CKPowerDevHrTestParam set) { |
| | | set.setOpCmd(CMD_Constant.CMD_SetBattDisParam); |
| | | mapper.update(set,null); |
| | | QueryWrapper<CKPowerDevHrTestParam> query = Wrappers.query(); |
| | | return OpCmdUtil.getOpStatus(mapper, query, CMD_Constant.CMD_SetBattDisParam,20,null); |
| | | Response opStatus=OpCmdUtil.getOpStatus(mapper, query, CMD_Constant.CMD_SetBattDisParam,20,null); |
| | | if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功 |
| | | //记录日志 |
| | | Date now = new Date(); |
| | | List<CKPowerDevBattSetLog> logList = set.getLogList(); |
| | | //查询最大的操作编号 |
| | | String opNum=setLogMapper.getOpNum()!=null?setLogMapper.getOpNum():"0"; |
| | | logList.forEach(log->{ |
| | | log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1)); |
| | | log.setCmdType(LogOpEnum.TYPE_CMD_UPDATE.getType()); |
| | | log.setCreateTime(now); |
| | | log.setCreateDay(now); |
| | | }); |
| | | setLogService.addBatch(logList); |
| | | } |
| | | return opStatus; |
| | | } |
| | | |
| | | public Response updateStartOrStop(Integer opCmd) { |
| | |
| | | param.setOpCmd(opCmd); |
| | | mapper.update(param,null); |
| | | QueryWrapper<CKPowerDevHrTestParam> query = Wrappers.query(); |
| | | return OpCmdUtil.getOpStatus(mapper, query, opCmd,20,null); |
| | | Response opStatus=OpCmdUtil.getOpStatus(mapper, query, opCmd,20,null); |
| | | if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功 |
| | | //记录日志 |
| | | Date now = new Date(); |
| | | CKPowerDevBattSetLog log=new CKPowerDevBattSetLog(); |
| | | //查询最大的操作编号 |
| | | String opNum=setLogMapper.getOpNum()!=null?setLogMapper.getOpNum():"0"; |
| | | log.setOpNum(String.valueOf(Integer.valueOf(opNum)+1)); |
| | | log.setCreateTime(now); |
| | | log.setCreateDay(now); |
| | | log.setCmdType(LogOpEnum.TYPE_CMD_START.getType()); |
| | | log.setDevType(0); |
| | | log.setBattIndex(0); |
| | | setLogService.add(log); |
| | | } |
| | | return opStatus; |
| | | } |
| | | } |