src/main/java/com/fgkj/controller/Ld9/BadLd9_monController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fgkj/controller/ram/Fbs9100_setparamController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fgkj/controller/ram/Fbs9100_stateController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fgkj/mapper/impl/Ld9/BadLd9_monMapper.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fgkj/mapper/impl/ram/Fbs9100_stateMapper.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fgkj/services/Ld9/BadLd9_monService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/fgkj/services/ram/Fbs9100_stateService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/resources/mapper/ld9/BadLd9MonMapper.xml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/resources/mapper/ram/Fbs9100StateMapper.xml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/fgkj/controller/Ld9/BadLd9_monController.java
@@ -2,6 +2,7 @@ import com.fgkj.dto.Batt_Maint_Dealarm; import com.fgkj.dto.ServiceModel; import com.fgkj.dto.ServiceModelOnce; import com.fgkj.dto.User_inf; import com.fgkj.services.Ld9.BadLd9_monService; import com.fgkj.util.ActionUtil; @@ -26,16 +27,16 @@ //查询落后单体总数 @GetMapping("num") @ApiOperation(notes = "",value="查询落后单体总数") public ServiceModel searchNums() { @ApiOperation(notes = "TODO Table 'web_site.tb_badld9_mon' doesn't exist",value="查询落后单体总数") public ServiceModelOnce searchNums() { User_inf uinf=(User_inf) ActionUtil.getUser(); ServiceModel model = service.searchNums(uinf); ServiceModelOnce model = service.searchNums(uinf); return model; } //落后单体查询:根据条件查询落后单体 @GetMapping("byInfo") @ApiOperation(notes = "",value="落后单体查询:根据条件查询落后单体") @ApiOperation(notes = "TODO Table 'web_site.tb_badld9_mon' doesn't exist",value="落后单体查询:根据条件查询落后单体") public ServiceModel serchByInfo(@RequestBody Batt_Maint_Dealarm bmd) { // Batt_Maint_Dealarm bmd = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Batt_Maint_Dealarm.class); User_inf uinf=(User_inf) ActionUtil.getUser(); src/main/java/com/fgkj/controller/ram/Fbs9100_setparamController.java
@@ -42,7 +42,7 @@ //根据设备id查询设备的放电参数 @PostMapping("devParamById") @ApiOperation(notes = "",value="设备id查询设备的放电参数") @ApiOperation(notes = "TODO 待测",value="设备id查询设备的放电参数") public ServiceModel serchdevParam(@RequestParam Integer fbsDeviceId) { BattInf binf = new BattInf(); binf.setFbsDeviceId(fbsDeviceId); src/main/java/com/fgkj/controller/ram/Fbs9100_stateController.java
@@ -1,6 +1,7 @@ package com.fgkj.controller.ram; import com.fgkj.dto.BattInf; import com.fgkj.dto.PageBean; import com.fgkj.dto.ServiceModel; import com.fgkj.dto.User_inf; import com.fgkj.dto.ram.Fbs9100_state; @@ -23,7 +24,27 @@ private Fbs9100_stateService service; @PostMapping("/") @ApiOperation(notes = "",value="添加") @ApiOperation(notes = "dev_id 唯一 {\n" + " \"dev_ip\": \"\",\n" + " \"dev_id\": 618500009,\n" + " \"op_cmd\": 0,\n" + " \"dev_datetime\": \"\",\n" + " \"dev_testtype\": 0,\n" + " \"dev_testgroupnum\": 0,\n" + " \"dev_workstate\": 0,\n" + " \"dev_alarmstate\": 0,\n" + " \"dev_onlinevollow\": 0,\n" + " \"dev_eachgroup_battsum\": 0,\n" + " \"dev_captest_onlinevol\": 0.0,\n" + " \"dev_captest_groupvol\": 0.0,\n" + " \"dev_captest_curr\": 0.0,\n" + " \"dev_captest_cap\": 0.0,\n" + " \"dev_captest_timelong\": 0,\n" + " \"dev_restest_moncount\": 0,\n" + " \"dev_restest_monindex\": 0,\n" + " \"dev_commcount\": 0,\n" + " \"dev_errcommcount\": 0\n" + "}",value="添加") public ServiceModel add(@RequestBody Fbs9100_state state) { // Fbs9100_state state = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Fbs9100_state.class); ServiceModel model = service.add(state); @@ -32,7 +53,28 @@ } @PutMapping("/") @ApiOperation(notes = "",value="修改") @ApiOperation(notes = "{\n" + "\t\"dev_ip\":\"\",\n" + " \"dev_id\":\"-\",\n" + " \"op_cmd\":\"-\",\n" + " \"dev_datetime\":\"-\",\n" + " \"dev_testtype\":\"-\",\n" + " \"dev_testgroupnum\":\"-\",\n" + " \"dev_workstate\":\"-\",\n" + " \"dev_alarmstate\":\"-\",\n" + " \"dev_onlinevollow\":\"-\",\n" + " \"dev_eachgroup_battsum\":\"-\",\n" + " \"dev_captest_onlinevol\":\"-\",\n" + " \"dev_captest_groupvol\":\"-\",\n" + " \"dev_captest_curr\":\"-\",\n" + " \"dev_captest_cap\":\"-\",\n" + " \"dev_captest_timelong\":\"-\",\n" + " \"dev_restest_moncount\":\"-\",\n" + " \"dev_restest_monindex\":\"-\",\n" + " \"dev_commcount\":\"-\",\n" + " \"dev_errcommcount\":\"-\",\n" + " \"num\":\"-\"\n" + "}",value="修改") public ServiceModel update(@RequestBody Fbs9100_state state) { // Fbs9100_state state = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Fbs9100_state.class); ServiceModel model = service.update(state); @@ -41,7 +83,12 @@ //fbs9600设备内阻测试 @PutMapping("/updatePro") @ApiOperation(notes = "",value="fbs9600设备内阻测试") @ApiOperation(notes = "[\n" + " {\n" + " \"op_cmd\": \"1\",\n" + " \"dev_id\": \"-\"\n" + " }\n" + "]",value="fbs9600设备内阻测试") public ServiceModel updatePro(@RequestBody List<Fbs9100_state> list) { // List<Fbs9100_state> list =getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, new TypeToken<List<Fbs9100_state>>(){}.getType()); ServiceModel model = service.updatePro(list); @@ -50,7 +97,9 @@ @DeleteMapping("/") @ApiOperation(notes = "",value="删除") public ServiceModel delete(@RequestBody Fbs9100_state state) { public ServiceModel delete(@RequestParam Integer num) { Fbs9100_state state = new Fbs9100_state(); state.setNum(num); // Fbs9100_state state = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Fbs9100_state.class); ServiceModel model = service.delete(state); return model; @@ -66,10 +115,15 @@ } //11.1FBS9100设备通信状态查询 @GetMapping("byCondition") @PostMapping("byCondition") @ApiOperation(notes = "",value="FBS9100设备通信状态查询") public ServiceModel serchByCondition(@RequestBody Fbs9100_state state){ // Fbs9100_state state = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Fbs9100_state.class); public ServiceModel serchByCondition(@RequestParam Integer dev_errcommcount,@RequestParam Integer pageNum,@RequestParam Integer pageSize) { Fbs9100_state state = new Fbs9100_state(); state.setDev_errcommcount(dev_errcommcount); PageBean pageBean = new PageBean(); pageBean.setPageNum(pageNum); pageBean.setPageSize(pageSize); state.setPageBean(pageBean); User_inf uinf=(User_inf) ActionUtil.getUser(); state.setNum(uinf.getuId());//将用户id存放在Fbs9100_state的num中用于处理用户管理的机房问题 ServiceModel model = service.serchByCondition(state); @@ -78,20 +132,22 @@ } //实时监测界面根据dev_alarmstate状态判断接触器状态 @GetMapping("contactorState") @PostMapping("contactorState") @ApiOperation(notes = "",value="实时监测界面根据dev_alarmstate状态判断接触器状态") public ServiceModel serchContactorState(@RequestBody Fbs9100_state state) { // Fbs9100_state state = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Fbs9100_state.class); public ServiceModel serchContactorState(@RequestParam Integer dev_id) { Fbs9100_state state = new Fbs9100_state(); state.setDev_id(dev_id); ServiceModel model = service.serchContactorState(state); return model; } //放电测试界面根据设备id查询网络拓扑图 @GetMapping("byInfo") @PostMapping("byInfo") @ApiOperation(notes = "",value="放电测试界面根据设备id查询网络拓扑图") public ServiceModel serchByInfo(@RequestBody BattInf binf) { // BattInf binf = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, BattInf.class); public ServiceModel serchByInfo(@RequestParam Integer battGroupId) { BattInf binf = new BattInf(); binf.setBattGroupId(battGroupId); ServiceModel model = service.serchByInfo(binf); return model; @@ -115,10 +171,12 @@ } //查询61850设备的6种工作状态 @GetMapping("devWorkState") @PostMapping("devWorkState") @ApiOperation(notes = "",value="查询61850设备的6种工作状态") public ServiceModel searchDevWorkstate(@RequestBody Fbs9100_state state){ // Fbs9100_state state = getGson("yyyy-MM-dd HH:mm:ss").fromJson(json, Fbs9100_state.class); public ServiceModel searchDevWorkstate(@RequestParam Integer dev_id,@RequestParam Integer dev_workstate){ Fbs9100_state state = new Fbs9100_state(); state.setDev_id(dev_id); state.setDev_workstate(dev_workstate); User_inf uinf=(User_inf) ActionUtil.getUser(); //用户id暂存在num中 state.setNum(uinf.getuId()); @@ -139,7 +197,7 @@ //11.1FBS9100设备通信状态查询 <-- 跨域 --> @GetMapping("byConditionKy") @ApiOperation(tags = "跨域", notes = "",value="FBS9100设备通信状态查询") @ApiOperation(tags = "跨域", notes = "",value="FBS9100设备通信状态查询 跨域") public ServiceModel serchByCondition_ky(){ //isAllowHeaders(); //允许跨域访问 ServiceModel model = service.serchByCondition_ky(); src/main/java/com/fgkj/mapper/impl/Ld9/BadLd9_monMapper.java
@@ -1,5 +1,8 @@ package com.fgkj.mapper.impl.Ld9; import com.fgkj.dto.User_inf; import org.apache.ibatis.annotations.Select; import java.util.List; public interface BadLd9_monMapper{ @@ -11,7 +14,16 @@ public String serchMonBad(Object obj); //查询落后单体总数 public int searchNums(Object obj); @Select("select count(num) as nums " + " from web_site.tb_badld9_mon " + " where web_site.tb_badld9_mon.battgroupid in(select distinct db_battinf.tb_battinf.battgroupid " + " from db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf " + " where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " + " and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + " and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + " and db_user.tb_user_inf.uid=#{uId} )" + " limit 1 ") public int searchNums(User_inf obj); //落后单体查询:根据条件查询落后单体(用户管理的电池组) public List serchByInfo(Object obj); src/main/java/com/fgkj/mapper/impl/ram/Fbs9100_stateMapper.java
@@ -56,7 +56,7 @@ " where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " + " and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " + " and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " + " and db_user.tb_user_inf.uid=#{UId} )"+ " and db_user.tb_user_inf.uid=#{uId} )"+ " and tb_Fbs9100_state.dev_id like '%96%'") public List<Fbs9100_state> searchByUid(User_inf uinf); src/main/java/com/fgkj/services/Ld9/BadLd9_monService.java
@@ -1,7 +1,6 @@ package com.fgkj.services.Ld9; import com.fgkj.dto.Batt_Maint_Dealarm; import com.fgkj.dto.ServiceModel; import com.fgkj.dto.*; import com.fgkj.mapper.impl.Ld9.BadLd9_monMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -19,10 +18,10 @@ ServiceModel model = new ServiceModel(); //查询落后单体总数 public ServiceModel searchNums(Object obj) { int nums= mapper.searchNums(obj); //TODO perry // model.setSum(nums); public ServiceModelOnce searchNums(User_inf obj) { ServiceModelOnce model = new ServiceModelOnce(); Integer nums = mapper.searchNums(obj); model.setSum(nums); return model; } //落后单体查询:根据条件查询落后单体 src/main/java/com/fgkj/services/ram/Fbs9100_stateService.java
@@ -32,7 +32,14 @@ public ServiceModel add(Fbs9100_state state) { ServiceModel model = new ServiceModel(); Boolean bl=mapper.add(state)>0; Boolean bl= null; try { bl = mapper.add(state)>0; } catch (Exception e) { e.printStackTrace(); model.setMsg("添加失败!"); return model; } if(bl){ model.setCode(1); model.setMsg("添加成功!"); src/main/resources/mapper/ld9/BadLd9MonMapper.xml
@@ -197,6 +197,6 @@ <select id="serchByStationId" resultType="java.lang.Integer"></select> <select id="serchMonBad" resultType="java.lang.String"></select> <select id="searchNums" resultType="java.lang.Integer"></select> <!-- <select id="searchNums" resultType="java.lang.Integer"></select>--> <select id="serchByInfo" resultType="java.util.List"></select> </mapper> src/main/resources/mapper/ram/Fbs9100StateMapper.xml
@@ -274,7 +274,7 @@ where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid and db_user.tb_user_inf.uid=#{uinf.UId} ) and db_user.tb_user_inf.uid=#{uinf.uId} ) </select> <select id="serchByCondition_ky" resultMap="Map_Fbs9100State"> select