Browse Source

Merge remote-tracking branch 'origin/develop' into develop

develop
zhao-meiyu 11 months ago
parent
commit
10a7062957
  1. 12
      ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/SysUser.java
  2. 12
      ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml
  3. 53
      zc-business/src/main/java/com/zc/business/controller/DcBoardController.java
  4. 104
      zc-business/src/main/java/com/zc/business/controller/DcBoardReleaseLogController.java
  5. 116
      zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java
  6. 13
      zc-business/src/main/java/com/zc/business/controller/DcEventProcessController.java
  7. 4
      zc-business/src/main/java/com/zc/business/controller/DcEventTypeController.java
  8. 115
      zc-business/src/main/java/com/zc/business/controller/DcFacilityController.java
  9. 5
      zc-business/src/main/java/com/zc/business/controller/DcInfoBoardTemplateController.java
  10. 124
      zc-business/src/main/java/com/zc/business/controller/DcInfoBoardVocabularyController.java
  11. 16
      zc-business/src/main/java/com/zc/business/controller/DcProcessConfigController.java
  12. 115
      zc-business/src/main/java/com/zc/business/controller/DcProductController.java
  13. 115
      zc-business/src/main/java/com/zc/business/controller/DcRoadController.java
  14. 115
      zc-business/src/main/java/com/zc/business/controller/DcStakeMarkController.java
  15. 47
      zc-business/src/main/java/com/zc/business/domain/DcBoardPublish.java
  16. 208
      zc-business/src/main/java/com/zc/business/domain/DcBoardReleaseLog.java
  17. 50
      zc-business/src/main/java/com/zc/business/domain/DcDevice.java
  18. 12
      zc-business/src/main/java/com/zc/business/domain/DcEventProcess.java
  19. 40
      zc-business/src/main/java/com/zc/business/domain/DcFacility.java
  20. 70
      zc-business/src/main/java/com/zc/business/domain/DcInfoBoardVocabulary.java
  21. 34
      zc-business/src/main/java/com/zc/business/domain/DcProduct.java
  22. 8
      zc-business/src/main/java/com/zc/business/domain/DcPublishInfo.java
  23. 28
      zc-business/src/main/java/com/zc/business/domain/DcRoad.java
  24. 31
      zc-business/src/main/java/com/zc/business/domain/DcStakeMark.java
  25. 61
      zc-business/src/main/java/com/zc/business/mapper/DcBoardReleaseLogMapper.java
  26. 14
      zc-business/src/main/java/com/zc/business/mapper/DcDeviceMapper.java
  27. 14
      zc-business/src/main/java/com/zc/business/mapper/DcFacilityMapper.java
  28. 61
      zc-business/src/main/java/com/zc/business/mapper/DcInfoBoardVocabularyMapper.java
  29. 14
      zc-business/src/main/java/com/zc/business/mapper/DcProductMapper.java
  30. 14
      zc-business/src/main/java/com/zc/business/mapper/DcRoadMapper.java
  31. 14
      zc-business/src/main/java/com/zc/business/mapper/DcStakeMarkMapper.java
  32. 61
      zc-business/src/main/java/com/zc/business/service/IDcBoardReleaseLogService.java
  33. 27
      zc-business/src/main/java/com/zc/business/service/IDcBoardService.java
  34. 64
      zc-business/src/main/java/com/zc/business/service/IDcDeviceService.java
  35. 63
      zc-business/src/main/java/com/zc/business/service/IDcFacilityService.java
  36. 71
      zc-business/src/main/java/com/zc/business/service/IDcInfoBoardVocabularyService.java
  37. 63
      zc-business/src/main/java/com/zc/business/service/IDcProductService.java
  38. 63
      zc-business/src/main/java/com/zc/business/service/IDcRoadService.java
  39. 63
      zc-business/src/main/java/com/zc/business/service/IDcStakeMarkService.java
  40. 93
      zc-business/src/main/java/com/zc/business/service/impl/DcBoardReleaseLogServiceImpl.java
  41. 104
      zc-business/src/main/java/com/zc/business/service/impl/DcBoardServiceImpl.java
  42. 258
      zc-business/src/main/java/com/zc/business/service/impl/DcDeviceServiceImpl.java
  43. 144
      zc-business/src/main/java/com/zc/business/service/impl/DcFacilityServiceImpl.java
  44. 127
      zc-business/src/main/java/com/zc/business/service/impl/DcInfoBoardVocabularyServiceImpl.java
  45. 144
      zc-business/src/main/java/com/zc/business/service/impl/DcProductServiceImpl.java
  46. 129
      zc-business/src/main/java/com/zc/business/service/impl/DcRoadServiceImpl.java
  47. 129
      zc-business/src/main/java/com/zc/business/service/impl/DcStakeMarkServiceImpl.java
  48. 105
      zc-business/src/main/resources/mapper/business/DcBoardReleaseLogMapper.xml
  49. 60
      zc-business/src/main/resources/mapper/business/DcInfoBoardVocabularyMapper.xml

12
ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/SysUser.java

@ -39,6 +39,9 @@ public class SysUser extends BaseEntity
@Excel(name = "用户名称")
private String nickName;
/** 用户类型(00系统用户) */
private String userType;
/** 用户邮箱 */
@Excel(name = "用户邮箱")
private String email;
@ -146,6 +149,14 @@ public class SysUser extends BaseEntity
this.nickName = nickName;
}
public String getUserType() {
return userType;
}
public void setUserType(String userType) {
this.userType = userType;
}
@Xss(message = "用户账号不能包含脚本字符")
@NotBlank(message = "用户账号不能为空")
@Size(min = 0, max = 30, message = "用户账号长度不能超过30个字符")
@ -321,6 +332,7 @@ public class SysUser extends BaseEntity
.append("deptId", getDeptId())
.append("userName", getUserName())
.append("nickName", getNickName())
.append("userType", getUserType())
.append("email", getEmail())
.append("phonenumber", getPhonenumber())
.append("sex", getSex())

12
ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml

@ -9,6 +9,7 @@
<result property="deptId" column="dept_id" />
<result property="userName" column="user_name" />
<result property="nickName" column="nick_name" />
<result property="userType" column="user_type" />
<result property="email" column="email" />
<result property="phonenumber" column="phonenumber" />
<result property="sex" column="sex" />
@ -47,7 +48,7 @@
</resultMap>
<sql id="selectUserVo">
select u.user_id, u.dept_id, u.user_name, u.nick_name, u.email, u.avatar, u.phonenumber, u.password, u.sex, u.status, u.del_flag, u.login_ip, u.login_date, u.create_by, u.create_time, u.remark,
select u.user_id, u.dept_id, u.user_name, u.nick_name, u.user_type, u.email, u.avatar, u.phonenumber, u.password, u.sex, u.status, u.del_flag, u.login_ip, u.login_date, u.create_by, u.create_time, u.remark,
d.dept_id, d.parent_id, d.ancestors, d.dept_name, d.order_num, d.leader, d.status as dept_status,
r.role_id, r.role_name, r.role_key, r.role_sort, r.data_scope, r.status as role_status
from sys_user u
@ -57,7 +58,7 @@
</sql>
<select id="selectUserList" parameterType="SysUser" resultMap="SysUserResult">
select u.user_id, u.dept_id, u.nick_name, u.user_name, u.email, u.avatar, u.phonenumber, u.password, u.sex, u.status, u.del_flag, u.login_ip, u.login_date, u.create_by, u.create_time, u.remark, d.dept_name, d.leader from sys_user u
select u.user_id, u.dept_id, u.nick_name, u.user_name, u.user_type, u.email, u.avatar, u.phonenumber, u.password, u.sex, u.status, u.del_flag, u.login_ip, u.login_date, u.create_by, u.create_time, u.remark, d.dept_name, d.leader from sys_user u
left join sys_dept d on u.dept_id = d.dept_id
where u.del_flag = '0'
<if test="userId != null and userId != 0">
@ -86,7 +87,7 @@
</select>
<select id="selectAllocatedList" parameterType="SysUser" resultMap="SysUserResult">
select distinct u.user_id, u.dept_id, u.user_name, u.nick_name, u.email, u.phonenumber, u.status, u.create_time
select distinct u.user_id, u.dept_id, u.user_name, u.nick_name,u.user_type, u.email, u.phonenumber, u.status, u.create_time
from sys_user u
left join sys_dept d on u.dept_id = d.dept_id
left join sys_user_role ur on u.user_id = ur.user_id
@ -103,7 +104,7 @@
</select>
<select id="selectUnallocatedList" parameterType="SysUser" resultMap="SysUserResult">
select distinct u.user_id, u.dept_id, u.user_name, u.nick_name, u.email, u.phonenumber, u.status, u.create_time
select distinct u.user_id, u.dept_id, u.user_name, u.nick_name, u.user_type, u.email, u.phonenumber, u.status, u.create_time
from sys_user u
left join sys_dept d on u.dept_id = d.dept_id
left join sys_user_role ur on u.user_id = ur.user_id
@ -148,6 +149,7 @@
<if test="deptId != null and deptId != 0">dept_id,</if>
<if test="userName != null and userName != ''">user_name,</if>
<if test="nickName != null and nickName != ''">nick_name,</if>
<if test="userType != null and userType != ''">user_type,</if>
<if test="email != null and email != ''">email,</if>
<if test="avatar != null and avatar != ''">avatar,</if>
<if test="phonenumber != null and phonenumber != ''">phonenumber,</if>
@ -162,6 +164,7 @@
<if test="deptId != null and deptId != ''">#{deptId},</if>
<if test="userName != null and userName != ''">#{userName},</if>
<if test="nickName != null and nickName != ''">#{nickName},</if>
<if test="userType != null and userType != ''">#{userType},</if>
<if test="email != null and email != ''">#{email},</if>
<if test="avatar != null and avatar != ''">#{avatar},</if>
<if test="phonenumber != null and phonenumber != ''">#{phonenumber},</if>
@ -180,6 +183,7 @@
<if test="deptId != null and deptId != 0">dept_id = #{deptId},</if>
<if test="userName != null and userName != ''">user_name = #{userName},</if>
<if test="nickName != null and nickName != ''">nick_name = #{nickName},</if>
<if test="userType != null and userType != ''">user_type = #{userType},</if>
<if test="email != null ">email = #{email},</if>
<if test="phonenumber != null ">phonenumber = #{phonenumber},</if>
<if test="sex != null and sex != ''">sex = #{sex},</if>

53
zc-business/src/main/java/com/zc/business/controller/DcBoardController.java

@ -0,0 +1,53 @@
package com.zc.business.controller;
import com.ruoyi.common.core.domain.AjaxResult;
import com.zc.business.domain.DcBoardPublish;
import com.zc.business.service.IDcBoardService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import java.util.List;
import java.util.Map;
/**
* @Description 情报板Controller
*
* @author liuwenge
* @date 2024/1/5 11:38
*/
@Api(tags = "情报板")
@RestController
@RequestMapping("/business/board")
public class DcBoardController {
@Autowired
private IDcBoardService dcBoardService;
/**
* 情报板发布
*/
@ApiOperation("情报板发布")
@PreAuthorize("@ss.hasPermi('business:board:publish')")
@PostMapping("/publish")
public AjaxResult publish(@RequestBody DcBoardPublish dcBoardPublish){
return dcBoardService.publish(dcBoardPublish);
}
/**
* 情报板回读
*/
@ApiOperation("情报板回读")
@PreAuthorize("@ss.hasPermi('business:board:realtimeProperty')")
@GetMapping("/realtimeProperty/{deviceId}")
public AjaxResult realtimeProperty(@ApiParam(name = "deviceId", value = "设备id", required = true) @PathVariable("deviceId") String deviceId){
return dcBoardService.realtimeProperty(deviceId);
}
}

104
zc-business/src/main/java/com/zc/business/controller/DcBoardReleaseLogController.java

@ -0,0 +1,104 @@
package com.zc.business.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.enums.BusinessType;
import com.zc.business.domain.DcBoardReleaseLog;
import com.zc.business.service.IDcBoardReleaseLogService;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.core.page.TableDataInfo;
/**
* 情报板内容发布日志Controller
*
* @author ruoyi
* @date 2024-01-05
*/
@RestController
@RequestMapping("/business/boardReleaseLog")
public class DcBoardReleaseLogController extends BaseController
{
@Autowired
private IDcBoardReleaseLogService dcBoardReleaseLogService;
/**
* 查询情报板内容发布日志列表
*/
@PreAuthorize("@ss.hasPermi('business:boardReleaseLog:list')")
@GetMapping("/list")
public TableDataInfo list(DcBoardReleaseLog dcBoardReleaseLog)
{
startPage();
List<DcBoardReleaseLog> list = dcBoardReleaseLogService.selectDcBoardReleaseLogList(dcBoardReleaseLog);
return getDataTable(list);
}
/**
* 导出情报板内容发布日志列表
*/
@PreAuthorize("@ss.hasPermi('business:boardReleaseLog:export')")
@Log(title = "情报板内容发布日志", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, DcBoardReleaseLog dcBoardReleaseLog)
{
List<DcBoardReleaseLog> list = dcBoardReleaseLogService.selectDcBoardReleaseLogList(dcBoardReleaseLog);
ExcelUtil<DcBoardReleaseLog> util = new ExcelUtil<>(DcBoardReleaseLog.class);
util.exportExcel(response, list, "情报板内容发布日志数据");
}
/**
* 获取情报板内容发布日志详细信息
*/
@PreAuthorize("@ss.hasPermi('business:boardReleaseLog:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
return AjaxResult.success(dcBoardReleaseLogService.selectDcBoardReleaseLogById(id));
}
/**
* 新增情报板内容发布日志
*/
@PreAuthorize("@ss.hasPermi('business:boardReleaseLog:add')")
@Log(title = "情报板内容发布日志", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody DcBoardReleaseLog dcBoardReleaseLog)
{
return toAjax(dcBoardReleaseLogService.insertDcBoardReleaseLog(dcBoardReleaseLog));
}
/**
* 修改情报板内容发布日志
*/
@PreAuthorize("@ss.hasPermi('business:boardReleaseLog:edit')")
@Log(title = "情报板内容发布日志", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody DcBoardReleaseLog dcBoardReleaseLog)
{
return toAjax(dcBoardReleaseLogService.updateDcBoardReleaseLog(dcBoardReleaseLog));
}
/**
* 删除情报板内容发布日志
*/
@PreAuthorize("@ss.hasPermi('business:boardReleaseLog:remove')")
@Log(title = "情报板内容发布日志", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
{
return toAjax(dcBoardReleaseLogService.deleteDcBoardReleaseLogByIds(ids));
}
}

116
zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java

@ -0,0 +1,116 @@
package com.zc.business.controller;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.enums.BusinessType;
import com.zc.business.domain.DcDevice;
import com.zc.business.service.IDcDeviceService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.List;
/**
* 设备Controller
*
* @author zhaoxianglong
*/
@Api("设备")
@RestController
@RequestMapping("/iot/device")
public class DcDeviceController extends BaseController {
//
@Resource
private IDcDeviceService dcDeviceService;
//*********************************设备增删改查******************************************
/**
* 分页查询设备列表
*
* @param dcDevice 请求参数
* @return 分页查询结果
*/
@ApiOperation("分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:device:list')")
@GetMapping("list")
public TableDataInfo listDevice(DcDevice dcDevice) {
return getDataTable(dcDeviceService.pageDevice(dcDevice));
}
/**
* 无分页查询设备列表
*
* @param dcDevice 请求参数
* @return 查询结果
*/
@ApiOperation("无分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:device:query')")
@GetMapping("query")
public AjaxResult queryDevice(DcDevice dcDevice) {
return AjaxResult.success(dcDeviceService.listDevice(dcDevice));
}
/**
* 根据id查询设备信息
*
* @param id id
* @return 查询结果
*/
@ApiOperation("根据id查询设备信息")
@PreAuthorize("@ss.hasPermi('iot:device:query')")
@GetMapping("{id}")
public AjaxResult getDevice(@PathVariable String id) {
return AjaxResult.success(dcDeviceService.getDevice(id));
}
/**
* 新增
*
* @param dcDevice 新增参数
* @return 新增操作结果
*/
@ApiOperation("新增")
@PreAuthorize("@ss.hasPermi('iot:device:add')")
@Log(title = "新增设备", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult addDevice(@Valid @RequestBody DcDevice dcDevice) {
return toAjax(dcDeviceService.addDevice(dcDevice));
}
/**
* 修改
*
* @param dcDevice 修改参数
* @return 修改操作结果
*/
@ApiOperation("修改")
@PreAuthorize("@ss.hasPermi('iot:device:edit')")
@Log(title = "修改设备", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult editDevice(@Valid @RequestBody DcDevice dcDevice) {
return toAjax(dcDeviceService.editDevice(dcDevice));
}
/**
* 删除
*
* @param ids id集
* @return 删除操作结果
*/
@ApiOperation("删除")
@PreAuthorize("@ss.hasPermi('iot:device:remove')")
@Log(title = "删除", businessType = BusinessType.DELETE)
@DeleteMapping("{ids}")
public AjaxResult removeDevice(@PathVariable List<String> ids) {
return toAjax(dcDeviceService.removeDevice(ids));
}
}

13
zc-business/src/main/java/com/zc/business/controller/DcEventProcessController.java

@ -1,8 +1,13 @@
package com.zc.business.controller;
import java.io.IOException;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import com.ruoyi.common.config.RuoYiConfig;
import com.ruoyi.common.exception.file.InvalidExtensionException;
import com.ruoyi.common.utils.file.FileUploadUtils;
import com.ruoyi.common.utils.file.MimeTypeUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
@ -85,8 +90,12 @@ public class DcEventProcessController extends BaseController
@PreAuthorize("@ss.hasPermi('system:process:add')")
@Log(title = "事件处理流程", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody DcEventProcess dcEventProcess)
{
public AjaxResult add(@RequestBody DcEventProcess dcEventProcess) throws IOException, InvalidExtensionException {
//如果有文件传入
if(!dcEventProcess.getFile().isEmpty()){
String address =FileUploadUtils.upload(RuoYiConfig.getAvatarPath(), dcEventProcess.getFile(), MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
dcEventProcess.setContext(address);
}
return toAjax(dcEventProcessService.insertDcEventProcess(dcEventProcess));
}

4
zc-business/src/main/java/com/zc/business/controller/DcEventTypeController.java

@ -31,7 +31,7 @@ import com.ruoyi.common.core.page.TableDataInfo;
* @author ruoyi
* @date 2024-01-03
*/
@Api(value = "事件类型")
@Api(value = "事件类型",tags = {"事件类型"})
@RestController
@RequestMapping("/business/dcEventType")
public class DcEventTypeController extends BaseController
@ -45,7 +45,7 @@ public class DcEventTypeController extends BaseController
@ApiOperation("查询事件类型列表")
@PreAuthorize("@ss.hasPermi('business:dcEventType:list')")
@GetMapping("/list")
public TableDataInfo list(@RequestBody DcEventType dcEventType)
public TableDataInfo list(DcEventType dcEventType)
{
startPage();
List<DcEventType> list = dcEventTypeService.selectDcEventTypeList(dcEventType);

115
zc-business/src/main/java/com/zc/business/controller/DcFacilityController.java

@ -0,0 +1,115 @@
package com.zc.business.controller;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.enums.BusinessType;
import com.zc.business.domain.DcFacility;
import com.zc.business.service.IDcFacilityService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.List;
/**
* 路网设施Controller
*
* @author zhaoxianglong
*/
@Api("路网设施")
@RestController
@RequestMapping("/iot/facility")
public class DcFacilityController extends BaseController {
@Resource
private IDcFacilityService dcFacilityService;
//*********************************设备增删改查******************************************
/**
* 分页查询设备列表
*
* @param dcFacility 请求参数
* @return 分页查询结果
*/
@ApiOperation("分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:facility:list')")
@GetMapping("list")
public TableDataInfo listFacility(DcFacility dcFacility) {
return getDataTable(dcFacilityService.pageFacility(dcFacility));
}
/**
* 无分页查询设备列表
*
* @param dcFacility 请求参数
* @return 查询结果
*/
@ApiOperation("无分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:facility:query')")
@GetMapping("query")
public AjaxResult queryFacility(DcFacility dcFacility) {
return AjaxResult.success(dcFacilityService.listFacility(dcFacility));
}
/**
* 根据id查询设备信息
*
* @param id id
* @return 查询结果
*/
@ApiOperation("根据id查询设备信息")
@PreAuthorize("@ss.hasPermi('iot:facility:query')")
@GetMapping("{id}")
public AjaxResult getFacility(@PathVariable String id) {
return AjaxResult.success(dcFacilityService.getFacility(id));
}
/**
* 新增
*
* @param dcFacility 新增参数
* @return 新增操作结果
*/
@ApiOperation("新增")
@PreAuthorize("@ss.hasPermi('iot:facility:add')")
@Log(title = "新增设备", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult addFacility(@Valid @RequestBody DcFacility dcFacility) {
return toAjax(dcFacilityService.addFacility(dcFacility));
}
/**
* 修改
*
* @param dcFacility 修改参数
* @return 修改操作结果
*/
@ApiOperation("修改")
@PreAuthorize("@ss.hasPermi('iot:facility:edit')")
@Log(title = "修改设备", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult editFacility(@Valid @RequestBody DcFacility dcFacility) {
return toAjax(dcFacilityService.editFacility(dcFacility));
}
/**
* 删除
*
* @param ids id集
* @return 删除操作结果
*/
@ApiOperation("删除")
@PreAuthorize("@ss.hasPermi('iot:facility:remove')")
@Log(title = "删除", businessType = BusinessType.DELETE)
@DeleteMapping("{ids}")
public AjaxResult removeFacility(@PathVariable List<String> ids) {
return toAjax(dcFacilityService.removeFacility(ids));
}
}

5
zc-business/src/main/java/com/zc/business/controller/DcInfoBoardTemplateController.java

@ -19,7 +19,7 @@ import org.springframework.web.bind.annotation.*;
* 情报板模板Controller
*
*/
@Api("情报板模板")
@Api(tags = {"情报板模板"})
@RestController
@RequestMapping("/business/boardTemplate")
public class DcInfoBoardTemplateController extends BaseController
@ -29,7 +29,8 @@ public class DcInfoBoardTemplateController extends BaseController
@ApiOperation("获取情报板模板")
@GetMapping("/getAllVmsTemplate")
public AjaxResult getAllVmsTemplate(String category, String devicePixel) {
public AjaxResult getAllVmsTemplate(@ApiParam(value="情报板分组", name="category", required=true) String category,
@ApiParam(value="分辨率", name="devicePixel", required=true) String devicePixel) {
return AjaxResult.success(dcInfoBoardTemplateService.getAllVmsTemplate(category, devicePixel));
}

124
zc-business/src/main/java/com/zc/business/controller/DcInfoBoardVocabularyController.java

@ -0,0 +1,124 @@
package com.zc.business.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.enums.BusinessType;
import com.zc.business.domain.DcInfoBoardVocabulary;
import com.zc.business.service.IDcInfoBoardVocabularyService;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.core.page.TableDataInfo;
/**
* 情报板敏感字管理Controller
*
* @author ruoyi
* @date 2024-01-05
*/
@Api(tags = {"情报板敏感字管理"})
@RestController
@RequestMapping("/business/dcInfoBoardVocabulary")
public class DcInfoBoardVocabularyController extends BaseController
{
@Autowired
private IDcInfoBoardVocabularyService dcInfoBoardVocabularyService;
/**
* 查询情报板敏感字管理列表
*/
@ApiOperation("查询情报板敏感字管理列表")
@PreAuthorize("@ss.hasPermi('business:dcInfoBoardVocabulary:list')")
@GetMapping("/list")
public TableDataInfo list(DcInfoBoardVocabulary dcInfoBoardVocabulary)
{
startPage();
List<DcInfoBoardVocabulary> list = dcInfoBoardVocabularyService.selectDcInfoBoardVocabularyList(dcInfoBoardVocabulary);
return getDataTable(list);
}
/**
* 导出情报板敏感字管理列表
*/
@ApiOperation("导出情报板敏感字管理列表")
@PreAuthorize("@ss.hasPermi('business:dcInfoBoardVocabulary:export')")
@Log(title = "情报板敏感字管理", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, DcInfoBoardVocabulary dcInfoBoardVocabulary)
{
List<DcInfoBoardVocabulary> list = dcInfoBoardVocabularyService.selectDcInfoBoardVocabularyList(dcInfoBoardVocabulary);
ExcelUtil<DcInfoBoardVocabulary> util = new ExcelUtil<>(DcInfoBoardVocabulary.class);
util.exportExcel(response, list, "情报板敏感字管理数据");
}
/**
* 获取情报板敏感字管理详细信息
*/
@ApiOperation("获取情报板敏感字管理详细信息")
@PreAuthorize("@ss.hasPermi('business:dcInfoBoardVocabulary:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") @ApiParam(value="id", name="id", required=true) Long id)
{
return AjaxResult.success(dcInfoBoardVocabularyService.selectDcInfoBoardVocabularyById(id));
}
/**
* 新增情报板敏感字管理
*/
@ApiOperation("新增情报板敏感字管理")
@PreAuthorize("@ss.hasPermi('business:dcInfoBoardVocabulary:add')")
@Log(title = "情报板敏感字管理", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody DcInfoBoardVocabulary dcInfoBoardVocabulary)
{
return toAjax(dcInfoBoardVocabularyService.insertDcInfoBoardVocabulary(dcInfoBoardVocabulary));
}
/**
* 修改情报板敏感字管理
*/
@ApiOperation("修改情报板敏感字管理")
@PreAuthorize("@ss.hasPermi('business:dcInfoBoardVocabulary:edit')")
@Log(title = "情报板敏感字管理", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody DcInfoBoardVocabulary dcInfoBoardVocabulary)
{
return toAjax(dcInfoBoardVocabularyService.updateDcInfoBoardVocabulary(dcInfoBoardVocabulary));
}
/**
* 删除情报板敏感字管理
*/
@ApiOperation("删除情报板敏感字管理")
@PreAuthorize("@ss.hasPermi('business:dcInfoBoardVocabulary:remove')")
@Log(title = "情报板敏感字管理", businessType = BusinessType.DELETE)
@DeleteMapping("/{id}")
public AjaxResult remove(@PathVariable @ApiParam(value="id", name="id", required=true) Long id)
{
return toAjax(dcInfoBoardVocabularyService.deleteDcInfoBoardVocabularyById(id));
}
/**
* 检查情报板是否含有敏感字
*/
@ApiOperation("检查情报板是否含有敏感字")
@GetMapping("/checkBoardContent")
public AjaxResult checkBoardContent(String content) {
return dcInfoBoardVocabularyService.checkBoardContent(content);
}
}

16
zc-business/src/main/java/com/zc/business/controller/DcProcessConfigController.java

@ -30,9 +30,8 @@ import com.ruoyi.common.core.page.TableDataInfo;
* @author ruoyi
* @date 2024-01-03
*/
@Api("事件流程配置")
@RestController
@RequestMapping("/system/dcProcessConfig")
@RequestMapping("/business/dcProcessConfig")
public class DcProcessConfigController extends BaseController
{
@Autowired
@ -41,8 +40,7 @@ public class DcProcessConfigController extends BaseController
/**
* 查询事件流程配置列表
*/
@ApiOperation("查询事件流程配置列表")
@PreAuthorize("@ss.hasPermi('system:dcProcessConfig:list')")
@PreAuthorize("@ss.hasPermi('business:dcProcessConfig:list')")
@GetMapping("/list")
public TableDataInfo list(DcProcessConfig dcProcessConfig)
{
@ -54,7 +52,7 @@ public class DcProcessConfigController extends BaseController
/**
* 导出事件流程配置列表
*/
@PreAuthorize("@ss.hasPermi('system:dcProcessConfig:export')")
@PreAuthorize("@ss.hasPermi('business:dcProcessConfig:export')")
@Log(title = "事件流程配置", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, DcProcessConfig dcProcessConfig)
@ -67,7 +65,7 @@ public class DcProcessConfigController extends BaseController
/**
* 获取事件流程配置详细信息
*/
@PreAuthorize("@ss.hasPermi('system:dcProcessConfig:query')")
@PreAuthorize("@ss.hasPermi('business:dcProcessConfig:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@ -77,7 +75,7 @@ public class DcProcessConfigController extends BaseController
/**
* 新增事件流程配置
*/
@PreAuthorize("@ss.hasPermi('system:dcProcessConfig:add')")
@PreAuthorize("@ss.hasPermi('business:dcProcessConfig:add')")
@Log(title = "事件流程配置", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody DcProcessConfig dcProcessConfig)
@ -88,7 +86,7 @@ public class DcProcessConfigController extends BaseController
/**
* 修改事件流程配置
*/
@PreAuthorize("@ss.hasPermi('system:dcProcessConfig:edit')")
@PreAuthorize("@ss.hasPermi('business:dcProcessConfig:edit')")
@Log(title = "事件流程配置", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody DcProcessConfig dcProcessConfig)
@ -99,7 +97,7 @@ public class DcProcessConfigController extends BaseController
/**
* 删除事件流程配置
*/
@PreAuthorize("@ss.hasPermi('system:dcProcessConfig:remove')")
@PreAuthorize("@ss.hasPermi('business:dcProcessConfig:remove')")
@Log(title = "事件流程配置", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)

115
zc-business/src/main/java/com/zc/business/controller/DcProductController.java

@ -0,0 +1,115 @@
package com.zc.business.controller;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.enums.BusinessType;
import com.zc.business.domain.DcProduct;
import com.zc.business.service.IDcProductService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.List;
/**
* 产品Controller
*
* @author zhaoxianglong
*/
@Api("产品")
@RestController
@RequestMapping("/iot/product")
public class DcProductController extends BaseController {
@Resource
private IDcProductService dcProdurtService;
//*********************************设备增删改查******************************************
/**
* 分页查询设备列表
*
* @param dcProduct 请求参数
* @return 分页查询结果
*/
@ApiOperation("分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:product:list')")
@GetMapping("list")
public TableDataInfo listProduct(DcProduct dcProduct) {
return getDataTable(dcProdurtService.pageProduct(dcProduct));
}
/**
* 无分页查询设备列表
*
* @param dcProduct 请求参数
* @return 查询结果
*/
@ApiOperation("无分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:product:query')")
@GetMapping("query")
public AjaxResult queryProduct(DcProduct dcProduct) {
return AjaxResult.success(dcProdurtService.listProduct(dcProduct));
}
/**
* 根据id查询设备信息
*
* @param id id
* @return 查询结果
*/
@ApiOperation("根据id查询设备信息")
@PreAuthorize("@ss.hasPermi('iot:product:query')")
@GetMapping("{id}")
public AjaxResult getProduct(@PathVariable String id) {
return AjaxResult.success(dcProdurtService.getProduct(id));
}
/**
* 新增
*
* @param dcProduct 新增参数
* @return 新增操作结果
*/
@ApiOperation("新增")
@PreAuthorize("@ss.hasPermi('iot:product:add')")
@Log(title = "新增设备", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult addProduct(@Valid @RequestBody DcProduct dcProduct) {
return toAjax(dcProdurtService.addProduct(dcProduct));
}
/**
* 修改
*
* @param dcProduct 修改参数
* @return 修改操作结果
*/
@ApiOperation("修改")
@PreAuthorize("@ss.hasPermi('iot:product:edit')")
@Log(title = "修改设备", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult editProduct(@Valid @RequestBody DcProduct dcProduct) {
return toAjax(dcProdurtService.editProduct(dcProduct));
}
/**
* 删除
*
* @param ids id集
* @return 删除操作结果
*/
@ApiOperation("删除")
@PreAuthorize("@ss.hasPermi('iot:product:remove')")
@Log(title = "删除", businessType = BusinessType.DELETE)
@DeleteMapping("{ids}")
public AjaxResult removeProduct(@PathVariable List<String> ids) {
return toAjax(dcProdurtService.removeProduct(ids));
}
}

115
zc-business/src/main/java/com/zc/business/controller/DcRoadController.java

@ -0,0 +1,115 @@
package com.zc.business.controller;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.enums.BusinessType;
import com.zc.business.domain.DcRoad;
import com.zc.business.service.IDcRoadService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.List;
/**
* 道路信息Controller
*
* @author zhaoxianglong
*/
@Api("道路信息")
@RestController
@RequestMapping("/iot/road")
public class DcRoadController extends BaseController {
@Resource
private IDcRoadService dcRoadService;
//*********************************设备增删改查******************************************
/**
* 分页查询设备列表
*
* @param dcRoad 请求参数
* @return 分页查询结果
*/
@ApiOperation("分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:road:list')")
@GetMapping("list")
public TableDataInfo listRoad(DcRoad dcRoad) {
return getDataTable(dcRoadService.pageRoad(dcRoad));
}
/**
* 无分页查询设备列表
*
* @param dcRoad 请求参数
* @return 查询结果
*/
@ApiOperation("无分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:road:query')")
@GetMapping("query")
public AjaxResult queryRoad(DcRoad dcRoad) {
return AjaxResult.success(dcRoadService.listRoad(dcRoad));
}
/**
* 根据id查询设备信息
*
* @param id id
* @return 查询结果
*/
@ApiOperation("根据id查询设备信息")
@PreAuthorize("@ss.hasPermi('iot:road:query')")
@GetMapping("{id}")
public AjaxResult getRoad(@PathVariable String id) {
return AjaxResult.success(dcRoadService.getRoad(id));
}
/**
* 新增
*
* @param dcRoad 新增参数
* @return 新增操作结果
*/
@ApiOperation("新增")
@PreAuthorize("@ss.hasPermi('iot:road:add')")
@Log(title = "新增设备", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult addRoad(@Valid @RequestBody DcRoad dcRoad) {
return toAjax(dcRoadService.addRoad(dcRoad));
}
/**
* 修改
*
* @param dcRoad 修改参数
* @return 修改操作结果
*/
@ApiOperation("修改")
@PreAuthorize("@ss.hasPermi('iot:road:edit')")
@Log(title = "修改设备", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult editRoad(@Valid @RequestBody DcRoad dcRoad) {
return toAjax(dcRoadService.editRoad(dcRoad));
}
/**
* 删除
*
* @param ids id集
* @return 删除操作结果
*/
@ApiOperation("删除")
@PreAuthorize("@ss.hasPermi('iot:road:remove')")
@Log(title = "删除", businessType = BusinessType.DELETE)
@DeleteMapping("{ids}")
public AjaxResult removeRoad(@PathVariable List<String> ids) {
return toAjax(dcRoadService.removeRoad(ids));
}
}

115
zc-business/src/main/java/com/zc/business/controller/DcStakeMarkController.java

@ -0,0 +1,115 @@
package com.zc.business.controller;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.enums.BusinessType;
import com.zc.business.domain.DcStakeMark;
import com.zc.business.service.IDcStakeMarkService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.List;
/**
* 桩号Controller
*
* @author zhaoxianglong
*/
@Api("桩号")
@RestController
@RequestMapping("/iot/stakeMark")
public class DcStakeMarkController extends BaseController {
@Resource
private IDcStakeMarkService dcStakeMarkService;
//*********************************设备增删改查******************************************
/**
* 分页查询设备列表
*
* @param dcStakeMark 请求参数
* @return 分页查询结果
*/
@ApiOperation("分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:stakeMark:list')")
@GetMapping("list")
public TableDataInfo listStakeMark(DcStakeMark dcStakeMark) {
return getDataTable(dcStakeMarkService.pageStakeMark(dcStakeMark));
}
/**
* 无分页查询设备列表
*
* @param dcStakeMark 请求参数
* @return 查询结果
*/
@ApiOperation("无分页查询设备列表")
@PreAuthorize("@ss.hasPermi('iot:stakeMark:query')")
@GetMapping("query")
public AjaxResult queryStakeMark(DcStakeMark dcStakeMark) {
return AjaxResult.success(dcStakeMarkService.listStakeMark(dcStakeMark));
}
/**
* 根据id查询设备信息
*
* @param id id
* @return 查询结果
*/
@ApiOperation("根据id查询设备信息")
@PreAuthorize("@ss.hasPermi('iot:stakeMark:query')")
@GetMapping("{id}")
public AjaxResult getStakeMark(@PathVariable String id) {
return AjaxResult.success(dcStakeMarkService.getStakeMark(id));
}
/**
* 新增
*
* @param dcStakeMark 新增参数
* @return 新增操作结果
*/
@ApiOperation("新增")
@PreAuthorize("@ss.hasPermi('iot:stakeMark:add')")
@Log(title = "新增设备", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult addStakeMark(@Valid @RequestBody DcStakeMark dcStakeMark) {
return toAjax(dcStakeMarkService.addStakeMark(dcStakeMark));
}
/**
* 修改
*
* @param dcStakeMark 修改参数
* @return 修改操作结果
*/
@ApiOperation("修改")
@PreAuthorize("@ss.hasPermi('iot:stakeMark:edit')")
@Log(title = "修改设备", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult editStakeMark(@Valid @RequestBody DcStakeMark dcStakeMark) {
return toAjax(dcStakeMarkService.editStakeMark(dcStakeMark));
}
/**
* 删除
*
* @param ids id集
* @return 删除操作结果
*/
@ApiOperation("删除")
@PreAuthorize("@ss.hasPermi('iot:stakeMark:remove')")
@Log(title = "删除", businessType = BusinessType.DELETE)
@DeleteMapping("{ids}")
public AjaxResult removeStakeMark(@PathVariable List<String> ids) {
return toAjax(dcStakeMarkService.removeStakeMark(ids));
}
}

47
zc-business/src/main/java/com/zc/business/domain/DcBoardPublish.java

@ -0,0 +1,47 @@
package com.zc.business.domain;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.ruoyi.common.annotation.Excel;
import com.ruoyi.common.core.domain.BaseEntity;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import java.util.Date;
import java.util.List;
import java.util.Map;
/**
* 情报板发布对象
*
* @author ruoyi
* @date 2024-01-05
*/
@ApiModel("情报板发布对象")
public class DcBoardPublish
{
@ApiModelProperty(value = "设备id", required = true)
private String deviceId;
@ApiModelProperty(value = "内容列表", required = true)
private List<Map<String,Object>> content;
public String getDeviceId() {
return deviceId;
}
public void setDeviceId(String deviceId) {
this.deviceId = deviceId;
}
public List<Map<String, Object>> getContent() {
return content;
}
public void setContent(List<Map<String, Object>> content) {
this.content = content;
}
}

208
zc-business/src/main/java/com/zc/business/domain/DcBoardReleaseLog.java

@ -0,0 +1,208 @@
package com.zc.business.domain;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.ruoyi.common.annotation.Excel;
import com.ruoyi.common.core.domain.BaseEntity;
/**
* 情报板内容发布日志对象 dc_board_release_log
*
* @author ruoyi
* @date 2024-01-05
*/
@ApiModel("情报板内容发布日志对象")
public class DcBoardReleaseLog extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** $column.columnComment */
@ApiModelProperty(value="id")
private Long id;
/** 设备编号 */
@Excel(name = "设备编号")
@ApiModelProperty(value="设备编号")
private String deviceId;
/** 设备名称 */
@Excel(name = "设备名称")
@ApiModelProperty(value="设备名称")
private String deviceName;
/** 发布内容 */
@Excel(name = "发布内容")
@ApiModelProperty(value="发布内容")
private String releaseContent;
/** 发布状态(0:成功;1:失败) */
@Excel(name = "发布状态", readConverterExp = "0=:成功;1:失败")
@ApiModelProperty(value="发布状态0=:成功;1:失败")
private String releaseStatus;
/** 发布时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value="发布时间")
@Excel(name = "发布时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss")
private Date releaseTime;
/** 发布机构 */
@Excel(name = "发布机构")
@ApiModelProperty(value="发布机构")
private String releaseDeptName;
/** 发布机构 */
@Excel(name = "发布机构")
@ApiModelProperty(value="发布机构id")
private String releaseDeptId;
/** 发布用户 */
@Excel(name = "发布用户")
@ApiModelProperty(value="发布用户")
private String releaseUserName;
/** 发布用户 */
@Excel(name = "发布用户")
@ApiModelProperty(value="发布用户")
private String releaseUserId;
/** 发布端 */
@Excel(name = "发布端")
@ApiModelProperty(value="发布端(00=系统用户,01=智慧大脑,02=GIS+BIM")
private String platform;
/** ip地址 */
@Excel(name = "ip地址")
@ApiModelProperty(value="ip地址")
private String releaseIp;
public void setId(Long id)
{
this.id = id;
}
public Long getId()
{
return id;
}
public void setDeviceId(String deviceId)
{
this.deviceId = deviceId;
}
public String getDeviceId()
{
return deviceId;
}
public void setDeviceName(String deviceName)
{
this.deviceName = deviceName;
}
public String getDeviceName()
{
return deviceName;
}
public void setReleaseContent(String releaseContent)
{
this.releaseContent = releaseContent;
}
public String getReleaseContent()
{
return releaseContent;
}
public void setReleaseStatus(String releaseStatus)
{
this.releaseStatus = releaseStatus;
}
public String getReleaseStatus()
{
return releaseStatus;
}
public void setReleaseTime(Date releaseTime)
{
this.releaseTime = releaseTime;
}
public Date getReleaseTime()
{
return releaseTime;
}
public void setReleaseDeptName(String releaseDeptName)
{
this.releaseDeptName = releaseDeptName;
}
public String getReleaseDeptName()
{
return releaseDeptName;
}
public void setReleaseDeptId(String releaseDeptId)
{
this.releaseDeptId = releaseDeptId;
}
public String getReleaseDeptId()
{
return releaseDeptId;
}
public void setReleaseUserName(String releaseUserName)
{
this.releaseUserName = releaseUserName;
}
public String getReleaseUserName()
{
return releaseUserName;
}
public void setReleaseUserId(String releaseUserId)
{
this.releaseUserId = releaseUserId;
}
public String getReleaseUserId()
{
return releaseUserId;
}
public String getPlatform() {
return platform;
}
public void setPlatform(String platform) {
this.platform = platform;
}
public void setReleaseIp(String releaseIp)
{
this.releaseIp = releaseIp;
}
public String getReleaseIp()
{
return releaseIp;
}
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("id", getId())
.append("deviceId", getDeviceId())
.append("deviceName", getDeviceName())
.append("releaseContent", getReleaseContent())
.append("releaseStatus", getReleaseStatus())
.append("releaseTime", getReleaseTime())
.append("releaseDeptName", getReleaseDeptName())
.append("releaseDeptId", getReleaseDeptId())
.append("releaseUserName", getReleaseUserName())
.append("releaseUserId", getReleaseUserId())
.append("releaseIp", getReleaseIp())
.toString();
}
}

50
zc-business/src/main/java/com/zc/business/domain/DcDevice.java

@ -0,0 +1,50 @@
package com.zc.business.domain;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
@Data
@ApiModel(value = "DcDevice", description = "设备实体")
public class DcDevice {
public static final Integer UNUSEDSTATE = 0;
public static final Integer USEOFSTATE = 1;
@ApiModelProperty("ID")
private Long id;
@ApiModelProperty("物联设备ID")
private String iotDeviceId;
@ApiModelProperty("组ID")
private Long groupId;
@ApiModelProperty("产品ID")
private Long productId;
@ApiModelProperty("桩号")
private String stakeMarkId;
@ApiModelProperty("道路标识")
private Long roadId;
@ApiModelProperty("设备名称")
private String deviceName;
@ApiModelProperty("设备类型")
private Integer deviceType;
@ApiModelProperty("安装日期")
private Date installationDate;
@ApiModelProperty("生产日期")
private Date productionDate;
@ApiModelProperty("使用年限")
private String durableYears;
@ApiModelProperty("安装位置")
private String installationSite;
@ApiModelProperty("使用状态")
private Integer useState;
@ApiModelProperty("其他配置")
private String otherConfig;
@ApiModelProperty("备注")
private String remark;
@ApiModelProperty("创建时间")
private Date createTime;
@ApiModelProperty("修改时间")
private Date updateTime;
}

12
zc-business/src/main/java/com/zc/business/domain/DcEventProcess.java

@ -7,6 +7,7 @@ import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.ruoyi.common.annotation.Excel;
import com.ruoyi.common.core.domain.BaseEntity;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.constraints.NotBlank;
@ -73,6 +74,17 @@ public class DcEventProcess
@Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()")
private String processName;
public MultipartFile getFile() {
return file;
}
public void setFile(MultipartFile file) {
this.file = file;
}
@ApiModelProperty("上传文件")
private MultipartFile file;
public void setId(Long id)
{
this.id = id;

40
zc-business/src/main/java/com/zc/business/domain/DcFacility.java

@ -0,0 +1,40 @@
package com.zc.business.domain;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
@Data
@ApiModel(value = "DcFacility", description = "路网设施实体")
public class DcFacility {
public static final String UP = "1";
public static final String CENTRE = "2";
public static final String DOWN = "3";
public static final String TOLLSTATION = "1";
public static final String BRIDGE = "2";
public static final String INTERCHANGE = "3";
@ApiModelProperty("ID")
private Long id;
@ApiModelProperty("桩号")
private String stakeMarkId;
@ApiModelProperty("方向")
private String direction;
@ApiModelProperty("道路标识")
private String roadId;
@ApiModelProperty("设备类型")
private Integer facilityType;
@ApiModelProperty("设备名称")
private String facilityName;
@ApiModelProperty("备注")
private String remark;
@ApiModelProperty("其他配置")
private String otherConfig;
@ApiModelProperty("创建时间")
private Date createTime;
@ApiModelProperty("修改时间")
private Date updateTime;
}

70
zc-business/src/main/java/com/zc/business/domain/DcInfoBoardVocabulary.java

@ -0,0 +1,70 @@
package com.zc.business.domain;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.ruoyi.common.annotation.Excel;
import com.ruoyi.common.core.domain.BaseEntity;
import java.util.Date;
/**
* 情报板敏感字管理对象 dc_info_board_vocabulary
*
* @author ruoyi
* @date 2024-01-05
*/
@ApiModel("情报板敏感字管理对象")
public class DcInfoBoardVocabulary
{
private static final long serialVersionUID = 1L;
/** id */
private Long id;
/** 文本 */
@Excel(name = "文本")
private String word;
/** 创建时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8")
@Excel(name = "创建时间")
private Date createTime;
public void setId(Long id)
{
this.id = id;
}
public Long getId()
{
return id;
}
public void setWord(String word)
{
this.word = word;
}
public String getWord()
{
return word;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("id", getId())
.append("word", getWord())
.append("createTime", getCreateTime())
.toString();
}
}

34
zc-business/src/main/java/com/zc/business/domain/DcProduct.java

@ -0,0 +1,34 @@
package com.zc.business.domain;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
@Data
@ApiModel(value = "DcProduct", description = "产品实体")
public class DcProduct {
@ApiModelProperty("ID")
private Long id;
@ApiModelProperty("产品名称")
private String productName;
@ApiModelProperty("制造商")
private String manufacturer;
@ApiModelProperty("品牌")
private String brand;
@ApiModelProperty("模型")
private String model;
@ApiModelProperty("生产地")
private String productionPlace;
@ApiModelProperty("备注")
private String remark;
@ApiModelProperty("其他配置")
private String otherConfig;
@ApiModelProperty("创建时间")
private Date createTime;
@ApiModelProperty("修改时间")
private Date updateTime;
}

8
zc-business/src/main/java/com/zc/business/domain/DcPublishInfo.java

@ -61,14 +61,14 @@ public class DcPublishInfo extends BaseEntity
/** 发布时间 */
@ApiModelProperty(value = "发布时间")
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "发布时间", width = 30, dateFormat = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Excel(name = "发布时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss")
private Date publishTime;
/** 审核时间 */
@ApiModelProperty(value = "审核时间")
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "审核时间", width = 30, dateFormat = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@Excel(name = "审核时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss")
private Date auditTime;
/** 发布状态0失败, 1成功, 2草稿 */

28
zc-business/src/main/java/com/zc/business/domain/DcRoad.java

@ -0,0 +1,28 @@
package com.zc.business.domain;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
@Data
@ApiModel(value = "DcRoad", description = "道路信息实体")
public class DcRoad {
@ApiModelProperty("ID")
private Long id;
@ApiModelProperty("道路名称")
private String roadName;
@ApiModelProperty("道路方向")
private String roadDirection;
@ApiModelProperty("道路编号")
private String roadCode;
@ApiModelProperty("单位")
private String organization;
@ApiModelProperty("创建时间")
private Date createTime;
@ApiModelProperty("修改时间")
private Date updateTime;
}

31
zc-business/src/main/java/com/zc/business/domain/DcStakeMark.java

@ -0,0 +1,31 @@
package com.zc.business.domain;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
@Data
@ApiModel(value = "DcStakeMark", description = "桩号实体")
public class DcStakeMark {
public static final String UP = "1";
public static final String CENTRE = "2";
public static final String DOWN = "3";
@ApiModelProperty("ID")
private String id;
@ApiModelProperty("经度")
private String longitude;
@ApiModelProperty("纬度")
private String latitude;
@ApiModelProperty("方向")
private String direction;
@ApiModelProperty("位置")
private String location;
@ApiModelProperty("创建时间")
private Date createTime;
@ApiModelProperty("修改时间")
private Date updateTime;
}

61
zc-business/src/main/java/com/zc/business/mapper/DcBoardReleaseLogMapper.java

@ -0,0 +1,61 @@
package com.zc.business.mapper;
import java.util.List;
import com.zc.business.domain.DcBoardReleaseLog;
/**
* 情报板内容发布日志Mapper接口
*
* @author ruoyi
* @date 2024-01-05
*/
public interface DcBoardReleaseLogMapper
{
/**
* 查询情报板内容发布日志
*
* @param id 情报板内容发布日志主键
* @return 情报板内容发布日志
*/
public DcBoardReleaseLog selectDcBoardReleaseLogById(Long id);
/**
* 查询情报板内容发布日志列表
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 情报板内容发布日志集合
*/
List<DcBoardReleaseLog> selectDcBoardReleaseLogList(DcBoardReleaseLog dcBoardReleaseLog);
/**
* 新增情报板内容发布日志
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 结果
*/
int insertDcBoardReleaseLog(DcBoardReleaseLog dcBoardReleaseLog);
/**
* 修改情报板内容发布日志
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 结果
*/
int updateDcBoardReleaseLog(DcBoardReleaseLog dcBoardReleaseLog);
/**
* 删除情报板内容发布日志
*
* @param id 情报板内容发布日志主键
* @return 结果
*/
int deleteDcBoardReleaseLogById(Long id);
/**
* 批量删除情报板内容发布日志
*
* @param ids 需要删除的数据主键集合
* @return 结果
*/
int deleteDcBoardReleaseLogByIds(Long[] ids);
}

14
zc-business/src/main/java/com/zc/business/mapper/DcDeviceMapper.java

@ -0,0 +1,14 @@
package com.zc.business.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zc.business.domain.DcDevice;
import org.apache.ibatis.annotations.Mapper;
/**
* 设备Mapper接口
*
* @author zhaoxianglong
*/
@Mapper
public interface DcDeviceMapper extends BaseMapper<DcDevice> {
}

14
zc-business/src/main/java/com/zc/business/mapper/DcFacilityMapper.java

@ -0,0 +1,14 @@
package com.zc.business.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zc.business.domain.DcFacility;
import org.apache.ibatis.annotations.Mapper;
/**
* 路网设施Mapper接口
*
* @author zhaoxianglong
*/
@Mapper
public interface DcFacilityMapper extends BaseMapper<DcFacility> {
}

61
zc-business/src/main/java/com/zc/business/mapper/DcInfoBoardVocabularyMapper.java

@ -0,0 +1,61 @@
package com.zc.business.mapper;
import java.util.List;
import com.zc.business.domain.DcInfoBoardVocabulary;
/**
* 情报板敏感字管理Mapper接口
*
* @author ruoyi
* @date 2024-01-05
*/
public interface DcInfoBoardVocabularyMapper
{
/**
* 查询情报板敏感字管理
*
* @param id 情报板敏感字管理主键
* @return 情报板敏感字管理
*/
public DcInfoBoardVocabulary selectDcInfoBoardVocabularyById(Long id);
/**
* 查询情报板敏感字管理列表
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 情报板敏感字管理集合
*/
List<DcInfoBoardVocabulary> selectDcInfoBoardVocabularyList(DcInfoBoardVocabulary dcInfoBoardVocabulary);
/**
* 新增情报板敏感字管理
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 结果
*/
int insertDcInfoBoardVocabulary(DcInfoBoardVocabulary dcInfoBoardVocabulary);
/**
* 修改情报板敏感字管理
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 结果
*/
int updateDcInfoBoardVocabulary(DcInfoBoardVocabulary dcInfoBoardVocabulary);
/**
* 删除情报板敏感字管理
*
* @param id 情报板敏感字管理主键
* @return 结果
*/
int deleteDcInfoBoardVocabularyById(Long id);
/**
* 批量删除情报板敏感字管理
*
* @param ids 需要删除的数据主键集合
* @return 结果
*/
int deleteDcInfoBoardVocabularyByIds(Long[] ids);
}

14
zc-business/src/main/java/com/zc/business/mapper/DcProductMapper.java

@ -0,0 +1,14 @@
package com.zc.business.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zc.business.domain.DcProduct;
import org.apache.ibatis.annotations.Mapper;
/**
* 产品Mapper接口
*
* @author zhaoxianglong
*/
@Mapper
public interface DcProductMapper extends BaseMapper<DcProduct> {
}

14
zc-business/src/main/java/com/zc/business/mapper/DcRoadMapper.java

@ -0,0 +1,14 @@
package com.zc.business.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zc.business.domain.DcRoad;
import org.apache.ibatis.annotations.Mapper;
/**
* 道路信息Mapper接口
*
* @author zhaoxianglong
*/
@Mapper
public interface DcRoadMapper extends BaseMapper<DcRoad> {
}

14
zc-business/src/main/java/com/zc/business/mapper/DcStakeMarkMapper.java

@ -0,0 +1,14 @@
package com.zc.business.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.zc.business.domain.DcStakeMark;
import org.apache.ibatis.annotations.Mapper;
/**
* 桩号Mapper接口
*
* @author zhaoxianglong
*/
@Mapper
public interface DcStakeMarkMapper extends BaseMapper<DcStakeMark> {
}

61
zc-business/src/main/java/com/zc/business/service/IDcBoardReleaseLogService.java

@ -0,0 +1,61 @@
package com.zc.business.service;
import java.util.List;
import com.zc.business.domain.DcBoardReleaseLog;
/**
* 情报板内容发布日志Service接口
*
* @author ruoyi
* @date 2024-01-05
*/
public interface IDcBoardReleaseLogService
{
/**
* 查询情报板内容发布日志
*
* @param id 情报板内容发布日志主键
* @return 情报板内容发布日志
*/
public DcBoardReleaseLog selectDcBoardReleaseLogById(Long id);
/**
* 查询情报板内容发布日志列表
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 情报板内容发布日志集合
*/
List<DcBoardReleaseLog> selectDcBoardReleaseLogList(DcBoardReleaseLog dcBoardReleaseLog);
/**
* 新增情报板内容发布日志
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 结果
*/
int insertDcBoardReleaseLog(DcBoardReleaseLog dcBoardReleaseLog);
/**
* 修改情报板内容发布日志
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 结果
*/
int updateDcBoardReleaseLog(DcBoardReleaseLog dcBoardReleaseLog);
/**
* 批量删除情报板内容发布日志
*
* @param ids 需要删除的情报板内容发布日志主键集合
* @return 结果
*/
int deleteDcBoardReleaseLogByIds(Long[] ids);
/**
* 删除情报板内容发布日志信息
*
* @param id 情报板内容发布日志主键
* @return 结果
*/
int deleteDcBoardReleaseLogById(Long id);
}

27
zc-business/src/main/java/com/zc/business/service/IDcBoardService.java

@ -0,0 +1,27 @@
package com.zc.business.service;
import com.ruoyi.common.core.domain.AjaxResult;
import com.zc.business.domain.DcBoardPublish;
import java.util.List;
import java.util.Map;
/**
* 情报板Service接口
*
* @author ruoyi
* @date 2024-01-03
*/
public interface IDcBoardService
{
/**
* 情报板发布
*/
AjaxResult publish(DcBoardPublish dcBoardPublish);
/**
* 情报板回读
*/
AjaxResult realtimeProperty(String deviceId);
}

64
zc-business/src/main/java/com/zc/business/service/IDcDeviceService.java

@ -0,0 +1,64 @@
package com.zc.business.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zc.business.domain.DcDevice;
import java.util.List;
/**
* 设备Service接口
*
* @author zhaoxianglong
*/
public interface IDcDeviceService extends IService<DcDevice> {
/**
* 添加设备信息
*
* @param dcDevice 设备信息
* @return 操作结果
*/
boolean addDevice(DcDevice dcDevice);
/**
* 修改设备信息
*
* @param dcDevice 设备信息
* @return 操作结果
*/
boolean editDevice(DcDevice dcDevice);
/**
* 删除设备
*
* @param ids 设备ID
* @return 操作结果
*/
boolean removeDevice(List<String> ids);
/**
* 获取设备列表
*
* @param dcDevice 参数
* @return 结果
*/
List<DcDevice> pageDevice(DcDevice dcDevice);
/**
* 获取设备列表
*
* @param dcDevice 参数
* @return 结果
*/
List<DcDevice> listDevice(DcDevice dcDevice);
/**
* 根据id查询设备信息
*
* @param id 设备ID
* @return 设备信息
*/
DcDevice getDevice(String id);
}

63
zc-business/src/main/java/com/zc/business/service/IDcFacilityService.java

@ -0,0 +1,63 @@
package com.zc.business.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zc.business.domain.DcFacility;
import java.util.List;
/**
* 路网设施Service接口
*
* @author zhaoxianglong
*/
public interface IDcFacilityService extends IService<DcFacility> {
/**
* 添加设备信息
*
* @param dcFacility 设备信息
* @return 操作结果
*/
boolean addFacility(DcFacility dcFacility);
/**
* 修改设备信息
*
* @param dcFacility 设备信息
* @return 操作结果
*/
boolean editFacility(DcFacility dcFacility);
/**
* 删除设备
*
* @param ids 设备ID
* @return 操作结果
*/
boolean removeFacility(List<String> ids);
/**
* 获取设备列表
*
* @param dcFacility 参数
* @return 结果
*/
List<DcFacility> pageFacility(DcFacility dcFacility);
/**
* 获取设备列表
*
* @param dcFacility 参数
* @return 结果
*/
List<DcFacility> listFacility(DcFacility dcFacility);
/**
* 根据id查询设备信息
*
* @param id 设备ID
* @return 设备信息
*/
DcFacility getFacility(String id);
}

71
zc-business/src/main/java/com/zc/business/service/IDcInfoBoardVocabularyService.java

@ -0,0 +1,71 @@
package com.zc.business.service;
import java.util.List;
import com.ruoyi.common.core.domain.AjaxResult;
import com.zc.business.domain.DcInfoBoardVocabulary;
/**
* 情报板敏感字管理Service接口
*
* @author ruoyi
* @date 2024-01-05
*/
public interface IDcInfoBoardVocabularyService
{
/**
* 查询情报板敏感字管理
*
* @param id 情报板敏感字管理主键
* @return 情报板敏感字管理
*/
public DcInfoBoardVocabulary selectDcInfoBoardVocabularyById(Long id);
/**
* 查询情报板敏感字管理列表
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 情报板敏感字管理集合
*/
List<DcInfoBoardVocabulary> selectDcInfoBoardVocabularyList(DcInfoBoardVocabulary dcInfoBoardVocabulary);
/**
* 新增情报板敏感字管理
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 结果
*/
int insertDcInfoBoardVocabulary(DcInfoBoardVocabulary dcInfoBoardVocabulary);
/**
* 修改情报板敏感字管理
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 结果
*/
int updateDcInfoBoardVocabulary(DcInfoBoardVocabulary dcInfoBoardVocabulary);
/**
* 批量删除情报板敏感字管理
*
* @param ids 需要删除的情报板敏感字管理主键集合
* @return 结果
*/
int deleteDcInfoBoardVocabularyByIds(Long[] ids);
/**
* 删除情报板敏感字管理信息
*
* @param id 情报板敏感字管理主键
* @return 结果
*/
int deleteDcInfoBoardVocabularyById(Long id);
/**
* 检查情报板是否含有敏感字
*
* @param content 情报板内容
* @return 结果
*/
AjaxResult checkBoardContent(String content);
}

63
zc-business/src/main/java/com/zc/business/service/IDcProductService.java

@ -0,0 +1,63 @@
package com.zc.business.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zc.business.domain.DcProduct;
import java.util.List;
/**
* 产品Service接口
*
* @author zhaoxianglong
*/
public interface IDcProductService extends IService<DcProduct> {
/**
* 添加设备信息
*
* @param dcProduct 设备信息
* @return 操作结果
*/
boolean addProduct(DcProduct dcProduct);
/**
* 修改设备信息
*
* @param dcProduct 设备信息
* @return 操作结果
*/
boolean editProduct(DcProduct dcProduct);
/**
* 删除设备
*
* @param ids 设备ID
* @return 操作结果
*/
boolean removeProduct(List<String> ids);
/**
* 获取设备列表
*
* @param dcProduct 参数
* @return 结果
*/
List<DcProduct> pageProduct(DcProduct dcProduct);
/**
* 获取设备列表
*
* @param dcProduct 参数
* @return 结果
*/
List<DcProduct> listProduct(DcProduct dcProduct);
/**
* 根据id查询设备信息
*
* @param id 设备ID
* @return 设备信息
*/
DcProduct getProduct(String id);
}

63
zc-business/src/main/java/com/zc/business/service/IDcRoadService.java

@ -0,0 +1,63 @@
package com.zc.business.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zc.business.domain.DcRoad;
import java.util.List;
/**
* 道路信息Service接口
*
* @author zhaoxianglong
*/
public interface IDcRoadService extends IService<DcRoad> {
/**
* 添加设备信息
*
* @param dcRoad 设备信息
* @return 操作结果
*/
boolean addRoad(DcRoad dcRoad);
/**
* 修改设备信息
*
* @param dcRoad 设备信息
* @return 操作结果
*/
boolean editRoad(DcRoad dcRoad);
/**
* 删除设备
*
* @param ids 设备ID
* @return 操作结果
*/
boolean removeRoad(List<String> ids);
/**
* 获取设备列表
*
* @param dcRoad 参数
* @return 结果
*/
List<DcRoad> pageRoad(DcRoad dcRoad);
/**
* 获取设备列表
*
* @param dcRoad 参数
* @return 结果
*/
List<DcRoad> listRoad(DcRoad dcRoad);
/**
* 根据id查询设备信息
*
* @param id 设备ID
* @return 设备信息
*/
DcRoad getRoad(String id);
}

63
zc-business/src/main/java/com/zc/business/service/IDcStakeMarkService.java

@ -0,0 +1,63 @@
package com.zc.business.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zc.business.domain.DcStakeMark;
import java.util.List;
/**
* 桩号Service接口
*
* @author zhaoxianglong
*/
public interface IDcStakeMarkService extends IService<DcStakeMark> {
/**
* 添加设备信息
*
* @param dcStakeMark 设备信息
* @return 操作结果
*/
boolean addStakeMark(DcStakeMark dcStakeMark);
/**
* 修改设备信息
*
* @param dcStakeMark 设备信息
* @return 操作结果
*/
boolean editStakeMark(DcStakeMark dcStakeMark);
/**
* 删除设备
*
* @param ids 设备ID
* @return 操作结果
*/
boolean removeStakeMark(List<String> ids);
/**
* 获取设备列表
*
* @param dcStakeMark 参数
* @return 结果
*/
List<DcStakeMark> pageStakeMark(DcStakeMark dcStakeMark);
/**
* 获取设备列表
*
* @param dcStakeMark 参数
* @return 结果
*/
List<DcStakeMark> listStakeMark(DcStakeMark dcStakeMark);
/**
* 根据id查询设备信息
*
* @param id 设备ID
* @return 设备信息
*/
DcStakeMark getStakeMark(String id);
}

93
zc-business/src/main/java/com/zc/business/service/impl/DcBoardReleaseLogServiceImpl.java

@ -0,0 +1,93 @@
package com.zc.business.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.zc.business.mapper.DcBoardReleaseLogMapper;
import com.zc.business.domain.DcBoardReleaseLog;
import com.zc.business.service.IDcBoardReleaseLogService;
/**
* 情报板内容发布日志Service业务层处理
*
* @author ruoyi
* @date 2024-01-05
*/
@Service
public class DcBoardReleaseLogServiceImpl implements IDcBoardReleaseLogService
{
@Autowired
private DcBoardReleaseLogMapper dcBoardReleaseLogMapper;
/**
* 查询情报板内容发布日志
*
* @param id 情报板内容发布日志主键
* @return 情报板内容发布日志
*/
@Override
public DcBoardReleaseLog selectDcBoardReleaseLogById(Long id)
{
return dcBoardReleaseLogMapper.selectDcBoardReleaseLogById(id);
}
/**
* 查询情报板内容发布日志列表
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 情报板内容发布日志
*/
@Override
public List<DcBoardReleaseLog> selectDcBoardReleaseLogList(DcBoardReleaseLog dcBoardReleaseLog)
{
return dcBoardReleaseLogMapper.selectDcBoardReleaseLogList(dcBoardReleaseLog);
}
/**
* 新增情报板内容发布日志
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 结果
*/
@Override
public int insertDcBoardReleaseLog(DcBoardReleaseLog dcBoardReleaseLog)
{
return dcBoardReleaseLogMapper.insertDcBoardReleaseLog(dcBoardReleaseLog);
}
/**
* 修改情报板内容发布日志
*
* @param dcBoardReleaseLog 情报板内容发布日志
* @return 结果
*/
@Override
public int updateDcBoardReleaseLog(DcBoardReleaseLog dcBoardReleaseLog)
{
return dcBoardReleaseLogMapper.updateDcBoardReleaseLog(dcBoardReleaseLog);
}
/**
* 批量删除情报板内容发布日志
*
* @param ids 需要删除的情报板内容发布日志主键
* @return 结果
*/
@Override
public int deleteDcBoardReleaseLogByIds(Long[] ids)
{
return dcBoardReleaseLogMapper.deleteDcBoardReleaseLogByIds(ids);
}
/**
* 删除情报板内容发布日志信息
*
* @param id 情报板内容发布日志主键
* @return 结果
*/
@Override
public int deleteDcBoardReleaseLogById(Long id)
{
return dcBoardReleaseLogMapper.deleteDcBoardReleaseLogById(id);
}
}

104
zc-business/src/main/java/com/zc/business/service/impl/DcBoardServiceImpl.java

@ -0,0 +1,104 @@
package com.zc.business.service.impl;
import com.alibaba.fastjson.JSON;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.model.LoginUser;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.zc.business.domain.DcBoardPublish;
import com.zc.business.domain.DcBoardReleaseLog;
import com.zc.business.mapper.DcBoardReleaseLogMapper;
import com.zc.business.service.IDcBoardService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 情报板Service业务层处理
*
* @author ruoyi
* @date 2024-01-03
*/
@Service
public class DcBoardServiceImpl implements IDcBoardService {
@Autowired
private DcBoardReleaseLogMapper dcBoardReleaseLogMapper;
/**
* @Description 情报板发布
*
* @author liuwenge
* @date 2024/1/5 14:30
* @return com.ruoyi.common.core.domain.AjaxResult
*/
public AjaxResult publish(DcBoardPublish dcBoardPublish){
if (StringUtils.isEmpty(dcBoardPublish.getDeviceId())){
return AjaxResult.error("设备id为空");
}
if (dcBoardPublish.getContent() == null || dcBoardPublish.getContent().size() == 0){
return AjaxResult.error("下发内容为空");
}
String deviceId = dcBoardPublish.getDeviceId();
List<Map<String,Object>> contentList = dcBoardPublish.getContent();
//TODO 调用控制设备接口
/* //下发文件名
Map<String,Object> param = new HashMap<>();
param.put("size","65535");
param.put("fileName","play010.lst");
invokeFunction(deviceId,"11",param);
//功能码13 下发内容
param = new HashMap<>();
param.put("parameters",contentList);
invokeFunction(deviceId,"1B",param);
//功能码1B 播放
param = new HashMap<>();
param.put("fileId","10");
invokeFunction(deviceId,"13",param);*/
String status = "1";
//发布记录
LoginUser loginUser = SecurityUtils.getLoginUser();
for (Map<String, Object> content : contentList) {
DcBoardReleaseLog releaseLog = new DcBoardReleaseLog();
releaseLog.setDeviceId(deviceId);
releaseLog.setReleaseContent(JSON.toJSONString(content));
releaseLog.setReleaseIp(loginUser.getIpaddr());
releaseLog.setReleaseStatus(status);
releaseLog.setReleaseUserId(loginUser.getUsername());
releaseLog.setReleaseUserName(loginUser.getUser().getNickName());
releaseLog.setReleaseDeptId(loginUser.getDeptId().toString());
dcBoardReleaseLogMapper.insertDcBoardReleaseLog(releaseLog);
}
return AjaxResult.success();
}
/**
* @Description 情报板回读
*
* @author liuwenge
* @date 2024/1/5 15:58
* @param deviceId 设备id
*/
public AjaxResult realtimeProperty(String deviceId){
/*Map<String,Object> param = new HashMap<>();
param.put("async",false);
invokeFunction(deviceId,"3A",param);*/
return AjaxResult.success();
}
}

258
zc-business/src/main/java/com/zc/business/service/impl/DcDeviceServiceImpl.java

@ -0,0 +1,258 @@
package com.zc.business.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.constant.HttpStatus;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.PageUtils;
import com.zc.business.domain.DcDevice;
import com.zc.business.domain.DcProduct;
import com.zc.business.mapper.DcDeviceMapper;
import com.zc.business.service.IDcDeviceService;
import com.zc.business.service.IDcProductService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
import java.util.Objects;
/**
* 设备Service业务层处理
*
* @author zhaoxianglong
*/
@Service
public class DcDeviceServiceImpl extends ServiceImpl<DcDeviceMapper, DcDevice> implements IDcDeviceService {
@Resource
private IDcProductService dcProdurtService;
public LambdaQueryWrapper<DcDevice> deviceQueryWrapper(DcDevice dcDevice) {
LambdaQueryWrapper<DcDevice> queryWrapper = new LambdaQueryWrapper<>();
// 设备ID
if (Objects.nonNull(dcDevice.getId())) {
queryWrapper.eq(DcDevice::getId, dcDevice.getId());
}
// 物联设备ID
if (StringUtils.hasText(dcDevice.getIotDeviceId())) {
queryWrapper.eq(DcDevice::getIotDeviceId, dcDevice.getIotDeviceId());
}
// 组ID
if (Objects.nonNull(dcDevice.getGroupId())) {
queryWrapper.eq(DcDevice::getGroupId, dcDevice.getGroupId());
}
// 设备ID
if (Objects.nonNull(dcDevice.getProductId())) {
queryWrapper.eq(DcDevice::getProductId, dcDevice.getProductId());
}
// 木桩
if (StringUtils.hasText(dcDevice.getStakeMarkId())) {
queryWrapper.eq(DcDevice::getStakeMarkId, dcDevice.getStakeMarkId());
}
// 道路标识
if (Objects.nonNull(dcDevice.getRoadId())) {
queryWrapper.eq(DcDevice::getRoadId, dcDevice.getRoadId());
}
// 设备名称
if (StringUtils.hasText(dcDevice.getDeviceName())) {
queryWrapper.like(DcDevice::getDeviceName, dcDevice.getDeviceName());
}
// 设备类型
if (Objects.nonNull(dcDevice.getDeviceType())) {
queryWrapper.eq(DcDevice::getDeviceType, dcDevice.getDeviceType());
}
// 安装日期
if (Objects.nonNull(dcDevice.getInstallationDate())) {
queryWrapper.eq(DcDevice::getInstallationDate, dcDevice.getInstallationDate());
}
// 生产日期
if (Objects.nonNull(dcDevice.getProductionDate())) {
queryWrapper.eq(DcDevice::getProductionDate, dcDevice.getProductionDate());
}
// 使用年限
if (StringUtils.hasText(dcDevice.getDurableYears())) {
queryWrapper.eq(DcDevice::getDurableYears, dcDevice.getDurableYears());
}
// 安装位置
if (StringUtils.hasText(dcDevice.getInstallationSite())) {
queryWrapper.like(DcDevice::getInstallationSite, dcDevice.getInstallationSite());
}
// 使用状态
if (Objects.nonNull(dcDevice.getUseState())) {
queryWrapper.eq(DcDevice::getUseState, dcDevice.getUseState());
}
// 备注
if (StringUtils.hasText(dcDevice.getRemark())) {
queryWrapper.like(DcDevice::getRemark, dcDevice.getRemark());
}
// 创建时间
if (Objects.nonNull(dcDevice.getCreateTime())) {
queryWrapper.eq(DcDevice::getCreateTime, dcDevice.getCreateTime());
}
// 更新时间
if (Objects.nonNull(dcDevice.getUpdateTime())) {
queryWrapper.eq(DcDevice::getUpdateTime, dcDevice.getUpdateTime());
}
return queryWrapper;
}
/**
* 新增
*
* @param dcDevice 新整参数
* @return 新增操作结果
*/
@Override
public boolean addDevice(DcDevice dcDevice) {
Long id = dcDevice.getId();
if (Objects.nonNull(id)) {
// 检查设备id是否重复
DcDevice device = getById(id);
if (Objects.nonNull(device)) {
throw new ServiceException("设备ID[" + id + "]已存在", HttpStatus.BAD_REQUEST);
}
}
String iotDeviceId = dcDevice.getIotDeviceId();
if (Objects.nonNull(iotDeviceId)) {
LambdaQueryWrapper<DcDevice> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(DcDevice::getIotDeviceId, iotDeviceId);
// 检查设备id是否重复
DcDevice device = getOne(lambdaQueryWrapper);
if (Objects.nonNull(device)) {
throw new ServiceException("物联设备ID[" + id + "]已存在", HttpStatus.BAD_REQUEST);
}
}
Long productId = dcDevice.getProductId();
if (Objects.nonNull(productId)) {
DcProduct dcProduct = dcProdurtService.getById(productId);
// 产品不存在
if (Objects.isNull(dcProduct)) {
throw new ServiceException("所属产品[" + productId + "]不存在", HttpStatus.BAD_REQUEST);
}
}
dcDevice.setCreateTime(new Date());
dcDevice.setUseState(DcDevice.UNUSEDSTATE);
return save(dcDevice);
}
/**
* 修改
*
* @param dcDevice 修改参数
* @return 修改操作结果
*/
@Override
public boolean editDevice(DcDevice dcDevice) {
Long id = dcDevice.getId();
// 检查设备id是否重复
DcDevice device = getById(id);
if (Objects.isNull(device)) {
throw new ServiceException("设备ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
dcDevice.setUpdateTime(new Date());
return updateById(dcDevice);
}
/**
* 删除
*
* @param ids 设备id集
* @return 删除操作结果
*/
@Override
public boolean removeDevice(List<String> ids) {
// 根据 ids 批量查询设备信息
LambdaQueryWrapper<DcDevice> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.in(DcDevice::getId, ids);
List<DcDevice> list = list(queryWrapper);
list.forEach(item -> {
if (Objects.equals(item.getUseState(), DcDevice.USEOFSTATE)) {
throw new ServiceException("设备正在使用", HttpStatus.MOVED_PERM);
}
});
return removeByIds(ids);
}
/**
* 分页查询设备列表
*
* @param dcDevice 请求参数
* @return 分页查询结果
*/
@Override
public List<DcDevice> pageDevice(DcDevice dcDevice) {
// 分页
PageUtils.startPage();
return list(deviceQueryWrapper(dcDevice));
}
/**
* 无分页查询设备列表
*
* @param dcDevice 请求参数
* @return 查询结果
*/
@Override
public List<DcDevice> listDevice(DcDevice dcDevice) {
return list(deviceQueryWrapper(dcDevice));
}
/**
* 根据id查询设备信息
*
* @param id 设备id
* @return 查询结果
*/
@Override
public DcDevice getDevice(String id) {
// 检查设备id是否重复
DcDevice device = getById(id);
if (Objects.isNull(device)) {
throw new ServiceException("设备ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
return getById(id);
}
}

144
zc-business/src/main/java/com/zc/business/service/impl/DcFacilityServiceImpl.java

@ -0,0 +1,144 @@
package com.zc.business.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.constant.HttpStatus;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.PageUtils;
import com.zc.business.domain.DcFacility;
import com.zc.business.mapper.DcFacilityMapper;
import com.zc.business.service.IDcFacilityService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.Date;
import java.util.List;
import java.util.Objects;
/**
* 路网设施Service业务层处理
*
* @author zhaoxianglong
*/
@Service
public class DcFacilityServiceImpl extends ServiceImpl<DcFacilityMapper, DcFacility> implements IDcFacilityService {
public LambdaQueryWrapper<DcFacility> facilityQueryWrapper(DcFacility dcFacility) {
LambdaQueryWrapper<DcFacility> queryWrapper = new LambdaQueryWrapper<>();
// 设备ID
if (Objects.nonNull(dcFacility.getId())) {
queryWrapper.eq(DcFacility::getId, dcFacility.getId());
}
// 木桩
if (StringUtils.hasText(dcFacility.getStakeMarkId())) {
queryWrapper.eq(DcFacility::getStakeMarkId, dcFacility.getStakeMarkId());
}
// 方向
if (StringUtils.hasText(dcFacility.getDirection())) {
queryWrapper.eq(DcFacility::getDirection, dcFacility.getDirection());
}
// 道路标识
if (StringUtils.hasText(dcFacility.getRoadId())) {
queryWrapper.like(DcFacility::getRoadId, dcFacility.getRoadId());
}
// 设备类型
if (Objects.nonNull(dcFacility.getFacilityType())) {
queryWrapper.like(DcFacility::getFacilityType, dcFacility.getFacilityType());
}
// 名称
if (StringUtils.hasText(dcFacility.getFacilityName())) {
queryWrapper.like(DcFacility::getFacilityName, dcFacility.getFacilityName());
}
// 备注
if (StringUtils.hasText(dcFacility.getRemark())) {
queryWrapper.like(DcFacility::getRemark, dcFacility.getRemark());
}
// 其他配置
if (StringUtils.hasText(dcFacility.getOtherConfig())) {
queryWrapper.like(DcFacility::getOtherConfig, dcFacility.getOtherConfig());
}
// 创建时间
if (Objects.nonNull(dcFacility.getCreateTime())) {
queryWrapper.eq(DcFacility::getCreateTime, dcFacility.getCreateTime());
}
// 更新时间
if (Objects.nonNull(dcFacility.getUpdateTime())) {
queryWrapper.eq(DcFacility::getUpdateTime, dcFacility.getUpdateTime());
}
return queryWrapper;
}
@Override
public boolean addFacility(DcFacility dcFacility) {
Long id = dcFacility.getId();
if (Objects.nonNull(id)) {
DcFacility device = getById(id);
if (device != null) {
throw new ServiceException("路网设施ID[" + id + "]已存在", HttpStatus.BAD_REQUEST);
}
}
dcFacility.setCreateTime(new Date());
return save(dcFacility);
}
@Override
public boolean editFacility(DcFacility dcFacility) {
Long id = dcFacility.getId();
// 检查设备id是否重复
DcFacility facility = getById(id);
if (Objects.isNull(facility)) {
throw new ServiceException("路网设施ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
dcFacility.setUpdateTime(new Date());
return updateById(dcFacility);
}
@Override
public boolean removeFacility(List<String> ids) {
return removeByIds(ids);
}
@Override
public List<DcFacility> pageFacility(DcFacility dcFacility) {
// 分页
PageUtils.startPage();
return list(facilityQueryWrapper(dcFacility));
}
@Override
public List<DcFacility> listFacility(DcFacility dcFacility) {
return list(facilityQueryWrapper(dcFacility));
}
@Override
public DcFacility getFacility(String id) {
// 检查设备id是否重复
DcFacility facility = getById(id);
if (Objects.isNull(facility)) {
throw new ServiceException("路网设施ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
return getById(id);
}
}

127
zc-business/src/main/java/com/zc/business/service/impl/DcInfoBoardVocabularyServiceImpl.java

@ -0,0 +1,127 @@
package com.zc.business.service.impl;
import java.net.URLDecoder;
import java.util.List;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.zc.business.mapper.DcInfoBoardVocabularyMapper;
import com.zc.business.domain.DcInfoBoardVocabulary;
import com.zc.business.service.IDcInfoBoardVocabularyService;
/**
* 情报板敏感字管理Service业务层处理
*
* @author ruoyi
* @date 2024-01-05
*/
@Service
public class DcInfoBoardVocabularyServiceImpl implements IDcInfoBoardVocabularyService
{
@Autowired
private DcInfoBoardVocabularyMapper dcInfoBoardVocabularyMapper;
/**
* 查询情报板敏感字管理
*
* @param id 情报板敏感字管理主键
* @return 情报板敏感字管理
*/
@Override
public DcInfoBoardVocabulary selectDcInfoBoardVocabularyById(Long id)
{
return dcInfoBoardVocabularyMapper.selectDcInfoBoardVocabularyById(id);
}
/**
* 查询情报板敏感字管理列表
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 情报板敏感字管理
*/
@Override
public List<DcInfoBoardVocabulary> selectDcInfoBoardVocabularyList(DcInfoBoardVocabulary dcInfoBoardVocabulary)
{
return dcInfoBoardVocabularyMapper.selectDcInfoBoardVocabularyList(dcInfoBoardVocabulary);
}
/**
* 新增情报板敏感字管理
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 结果
*/
@Override
public int insertDcInfoBoardVocabulary(DcInfoBoardVocabulary dcInfoBoardVocabulary)
{
dcInfoBoardVocabulary.setCreateTime(DateUtils.getNowDate());
return dcInfoBoardVocabularyMapper.insertDcInfoBoardVocabulary(dcInfoBoardVocabulary);
}
/**
* 修改情报板敏感字管理
*
* @param dcInfoBoardVocabulary 情报板敏感字管理
* @return 结果
*/
@Override
public int updateDcInfoBoardVocabulary(DcInfoBoardVocabulary dcInfoBoardVocabulary)
{
return dcInfoBoardVocabularyMapper.updateDcInfoBoardVocabulary(dcInfoBoardVocabulary);
}
/**
* 批量删除情报板敏感字管理
*
* @param ids 需要删除的情报板敏感字管理主键
* @return 结果
*/
@Override
public int deleteDcInfoBoardVocabularyByIds(Long[] ids)
{
return dcInfoBoardVocabularyMapper.deleteDcInfoBoardVocabularyByIds(ids);
}
/**
* 删除情报板敏感字管理信息
*
* @param id 情报板敏感字管理主键
* @return 结果
*/
@Override
public int deleteDcInfoBoardVocabularyById(Long id)
{
return dcInfoBoardVocabularyMapper.deleteDcInfoBoardVocabularyById(id);
}
/**
* 检查情报板是否含有敏感字
*
* @param content 情报板内容
* @return 结果
*/
@Override
public AjaxResult checkBoardContent(String content){
if (content == null || content.equals("")) {
return AjaxResult.error("情报板内容为空");
} else {
Boolean flag = false;
List<DcInfoBoardVocabulary> boardVocabularies = dcInfoBoardVocabularyMapper.selectDcInfoBoardVocabularyList(null);
try {
content = URLDecoder.decode(content, "UTF-8");
} catch (Exception e) {
e.printStackTrace();
return AjaxResult.error();
}
for (int i = 0;i < boardVocabularies.size();i++) {
String word = boardVocabularies.get(i).getWord();
if (content.contains(word)) {
return AjaxResult.error("当前发布内容包含敏感字段'" + word + "',请修改");
}
}
}
return AjaxResult.success("验证通过");
}
}

144
zc-business/src/main/java/com/zc/business/service/impl/DcProductServiceImpl.java

@ -0,0 +1,144 @@
package com.zc.business.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.constant.HttpStatus;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.PageUtils;
import com.zc.business.domain.DcProduct;
import com.zc.business.mapper.DcProductMapper;
import com.zc.business.service.IDcProductService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.Date;
import java.util.List;
import java.util.Objects;
/**
* 产品Service业务层处理
*
* @author zhaoxianglong
*/
@Service
public class DcProductServiceImpl extends ServiceImpl<DcProductMapper, DcProduct> implements IDcProductService {
public LambdaQueryWrapper<DcProduct> productQueryWrapper(DcProduct dcProduct) {
LambdaQueryWrapper<DcProduct> queryWrapper = new LambdaQueryWrapper<>();
// 设备ID
if (Objects.nonNull(dcProduct.getId())) {
queryWrapper.eq(DcProduct::getId, dcProduct.getId());
}
// 名称
if (StringUtils.hasText(dcProduct.getProductName())) {
queryWrapper.like(DcProduct::getProductName, dcProduct.getProductName());
}
// 生产商
if (StringUtils.hasText(dcProduct.getManufacturer())) {
queryWrapper.eq(DcProduct::getManufacturer, dcProduct.getManufacturer());
}
// 品牌
if (StringUtils.hasText(dcProduct.getBrand())) {
queryWrapper.like(DcProduct::getBrand, dcProduct.getBrand());
}
// 模型
if (StringUtils.hasText(dcProduct.getModel())) {
queryWrapper.like(DcProduct::getModel, dcProduct.getModel());
}
// 生产地
if (StringUtils.hasText(dcProduct.getProductionPlace())) {
queryWrapper.like(DcProduct::getProductionPlace, dcProduct.getProductionPlace());
}
// 备注
if (StringUtils.hasText(dcProduct.getRemark())) {
queryWrapper.like(DcProduct::getRemark, dcProduct.getRemark());
}
// 其他配置
if (StringUtils.hasText(dcProduct.getOtherConfig())) {
queryWrapper.like(DcProduct::getOtherConfig, dcProduct.getOtherConfig());
}
// 创建时间
if (Objects.nonNull(dcProduct.getCreateTime())) {
queryWrapper.eq(DcProduct::getCreateTime, dcProduct.getCreateTime());
}
// 更新时间
if (Objects.nonNull(dcProduct.getUpdateTime())) {
queryWrapper.eq(DcProduct::getUpdateTime, dcProduct.getUpdateTime());
}
return queryWrapper;
}
@Override
public boolean addProduct(DcProduct dcProduct) {
Long id = dcProduct.getId();
if (Objects.nonNull(id)) {
DcProduct device = getById(id);
if (Objects.nonNull(device)) {
throw new ServiceException("产品ID[" + id + "]已存在", HttpStatus.BAD_REQUEST);
}
}
dcProduct.setCreateTime(new Date());
return save(dcProduct);
}
@Override
public boolean editProduct(DcProduct dcProduct) {
Long id = dcProduct.getId();
// 检查设备id是否重复
DcProduct product = getById(id);
if (Objects.isNull(product)) {
throw new ServiceException("产品ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
dcProduct.setUpdateTime(new Date());
return updateById(dcProduct);
}
@Override
public boolean removeProduct(List<String> ids) {
return removeByIds(ids);
}
@Override
public List<DcProduct> pageProduct(DcProduct dcProduct) {
// 分页
PageUtils.startPage();
return list(productQueryWrapper(dcProduct));
}
@Override
public List<DcProduct> listProduct(DcProduct dcProduct) {
return list(productQueryWrapper(dcProduct));
}
@Override
public DcProduct getProduct(String id) {
// 检查设备id是否重复
DcProduct product = getById(id);
if (Objects.isNull(product)) {
throw new ServiceException("产品ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
return getById(id);
}
}

129
zc-business/src/main/java/com/zc/business/service/impl/DcRoadServiceImpl.java

@ -0,0 +1,129 @@
package com.zc.business.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.constant.HttpStatus;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.PageUtils;
import com.zc.business.domain.DcRoad;
import com.zc.business.mapper.DcRoadMapper;
import com.zc.business.service.IDcRoadService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.Date;
import java.util.List;
import java.util.Objects;
/**
* 道路信息Service业务层处理
*
* @author zhaoxianglong
*/
@Service
public class DcRoadServiceImpl extends ServiceImpl<DcRoadMapper, DcRoad> implements IDcRoadService {
public LambdaQueryWrapper<DcRoad> roadQueryWrapper(DcRoad dcRoad) {
LambdaQueryWrapper<DcRoad> queryWrapper = new LambdaQueryWrapper<>();
// 设备ID
if (Objects.nonNull(dcRoad.getId())) {
queryWrapper.eq(DcRoad::getId, dcRoad.getId());
}
// 名称
if (StringUtils.hasText(dcRoad.getRoadName())) {
queryWrapper.like(DcRoad::getRoadName, dcRoad.getRoadName());
}
// 路的方向
if (StringUtils.hasText(dcRoad.getRoadDirection())) {
queryWrapper.eq(DcRoad::getRoadDirection, dcRoad.getRoadDirection());
}
// 道路代码
if (StringUtils.hasText(dcRoad.getRoadCode())) {
queryWrapper.like(DcRoad::getRoadCode, dcRoad.getRoadCode());
}
// 配置
if (StringUtils.hasText(dcRoad.getOrganization())) {
queryWrapper.like(DcRoad::getOrganization, dcRoad.getOrganization());
}
// 创建时间
if (Objects.nonNull(dcRoad.getCreateTime())) {
queryWrapper.eq(DcRoad::getCreateTime, dcRoad.getCreateTime());
}
// 更新时间
if (Objects.nonNull(dcRoad.getUpdateTime())) {
queryWrapper.eq(DcRoad::getUpdateTime, dcRoad.getUpdateTime());
}
return queryWrapper;
}
@Override
public boolean addRoad(DcRoad dcRoad) {
Long id = dcRoad.getId();
if (Objects.nonNull(id)) {
DcRoad device = getById(id);
if (Objects.nonNull(device)) {
throw new ServiceException("道路信息ID[" + id + "]已存在", HttpStatus.BAD_REQUEST);
}
}
dcRoad.setCreateTime(new Date());
return save(dcRoad);
}
@Override
public boolean editRoad(DcRoad dcRoad) {
Long id = dcRoad.getId();
// 检查设备id是否重复
DcRoad road = getById(id);
if (Objects.isNull(road)) {
throw new ServiceException("道路信息ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
dcRoad.setUpdateTime(new Date());
return updateById(dcRoad);
}
@Override
public boolean removeRoad(List<String> ids) {
return removeByIds(ids);
}
@Override
public List<DcRoad> pageRoad(DcRoad dcRoad) {
// 分页
PageUtils.startPage();
return list(roadQueryWrapper(dcRoad));
}
@Override
public List<DcRoad> listRoad(DcRoad dcRoad) {
return list(roadQueryWrapper(dcRoad));
}
@Override
public DcRoad getRoad(String id) {
// 检查设备id是否重复
DcRoad road = getById(id);
if (Objects.isNull(road)) {
throw new ServiceException("道路信息ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
return getById(id);
}
}

129
zc-business/src/main/java/com/zc/business/service/impl/DcStakeMarkServiceImpl.java

@ -0,0 +1,129 @@
package com.zc.business.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.constant.HttpStatus;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.PageUtils;
import com.zc.business.domain.DcStakeMark;
import com.zc.business.mapper.DcStakeMarkMapper;
import com.zc.business.service.IDcStakeMarkService;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.Date;
import java.util.List;
import java.util.Objects;
/**
* 桩号Service业务层处理
*
* @author zhaoxianglong
*/
@Service
public class DcStakeMarkServiceImpl extends ServiceImpl<DcStakeMarkMapper, DcStakeMark> implements IDcStakeMarkService {
public LambdaQueryWrapper<DcStakeMark> stakeMarkQueryWrapper(DcStakeMark dcStakeMark) {
LambdaQueryWrapper<DcStakeMark> queryWrapper = new LambdaQueryWrapper<>();
// 设备ID
if (StringUtils.hasText(dcStakeMark.getId())) {
queryWrapper.eq(DcStakeMark::getId, dcStakeMark.getId());
}
// 经度
if (StringUtils.hasText(dcStakeMark.getLongitude())) {
queryWrapper.like(DcStakeMark::getLongitude, dcStakeMark.getLongitude());
}
// 纬度
if (StringUtils.hasText(dcStakeMark.getLatitude())) {
queryWrapper.eq(DcStakeMark::getLatitude, dcStakeMark.getLatitude());
}
// 方向
if (StringUtils.hasText(dcStakeMark.getDirection())) {
queryWrapper.like(DcStakeMark::getDirection, dcStakeMark.getDirection());
}
// 地点
if (StringUtils.hasText(dcStakeMark.getLocation())) {
queryWrapper.like(DcStakeMark::getLocation, dcStakeMark.getLocation());
}
// 创建时间
if (Objects.nonNull(dcStakeMark.getCreateTime())) {
queryWrapper.eq(DcStakeMark::getCreateTime, dcStakeMark.getCreateTime());
}
// 更新时间
if (Objects.nonNull(dcStakeMark.getUpdateTime())) {
queryWrapper.eq(DcStakeMark::getUpdateTime, dcStakeMark.getUpdateTime());
}
return queryWrapper;
}
@Override
public boolean addStakeMark(DcStakeMark dcStakeMark) {
String id = dcStakeMark.getId();
if (Objects.nonNull(id)) {
DcStakeMark device = getById(id);
if (Objects.nonNull(device)) {
throw new ServiceException("桩号ID[" + id + "]已存在", HttpStatus.BAD_REQUEST);
}
}
dcStakeMark.setCreateTime(new Date());
return save(dcStakeMark);
}
@Override
public boolean editStakeMark(DcStakeMark dcStakeMark) {
String id = dcStakeMark.getId();
// 检查设备id是否重复
DcStakeMark product = getById(id);
if (Objects.isNull(product)) {
throw new ServiceException("桩号ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
dcStakeMark.setUpdateTime(new Date());
return updateById(dcStakeMark);
}
@Override
public boolean removeStakeMark(List<String> ids) {
return removeByIds(ids);
}
@Override
public List<DcStakeMark> pageStakeMark(DcStakeMark dcStakeMark) {
// 分页
PageUtils.startPage();
return list(stakeMarkQueryWrapper(dcStakeMark));
}
@Override
public List<DcStakeMark> listStakeMark(DcStakeMark dcStakeMark) {
return list(stakeMarkQueryWrapper(dcStakeMark));
}
@Override
public DcStakeMark getStakeMark(String id) {
// 检查设备id是否重复
DcStakeMark product = getById(id);
if (Objects.isNull(product)) {
throw new ServiceException("桩号ID[" + id + "]不存在", HttpStatus.BAD_REQUEST);
}
return getById(id);
}
}

105
zc-business/src/main/resources/mapper/business/DcBoardReleaseLogMapper.xml

@ -0,0 +1,105 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zc.business.mapper.DcBoardReleaseLogMapper">
<resultMap type="DcBoardReleaseLog" id="DcBoardReleaseLogResult">
<result property="id" column="id" />
<result property="deviceId" column="device_id" />
<result property="deviceName" column="device_name" />
<result property="releaseContent" column="release_content" />
<result property="releaseStatus" column="release_status" />
<result property="releaseTime" column="release_time" />
<result property="releaseDeptName" column="release_dept_name" />
<result property="releaseDeptId" column="release_dept_id" />
<result property="releaseUserName" column="release_user_name" />
<result property="releaseUserId" column="release_user_id" />
<result property="platform" column="platform" />
<result property="releaseIp" column="release_ip" />
</resultMap>
<sql id="selectDcBoardReleaseLogVo">
select id, device_id, device_name, release_content, release_status, release_time, release_dept_name, release_dept_id, release_user_name, release_user_id, platform,release_ip from dc_board_release_log
</sql>
<select id="selectDcBoardReleaseLogList" parameterType="DcBoardReleaseLog" resultMap="DcBoardReleaseLogResult">
<include refid="selectDcBoardReleaseLogVo"/>
<where>
<if test="deviceId != null and deviceId != ''"> and device_id = #{deviceId}</if>
<if test="deviceName != null and deviceName != ''"> and device_name like concat('%', #{deviceName}, '%')</if>
<if test="releaseContent != null and releaseContent != ''"> and release_content = #{releaseContent}</if>
<if test="releaseStatus != null and releaseStatus != ''"> and release_status = #{releaseStatus}</if>
<if test="releaseTime != null "> and release_time = #{releaseTime}</if>
<if test="releaseDeptName != null and releaseDeptName != ''"> and release_dept_name like concat('%', #{releaseDeptName}, '%')</if>
<if test="releaseDeptId != null and releaseDeptId != ''"> and release_dept_id = #{releaseDeptId}</if>
<if test="releaseUserName != null and releaseUserName != ''"> and release_user_name like concat('%', #{releaseUserName}, '%')</if>
<if test="releaseUserId != null and releaseUserId != ''"> and release_user_id = #{releaseUserId}</if>
<if test="releaseIp != null and releaseIp != ''"> and release_ip = #{releaseIp}</if>
<if test="platform != null and platform != ''"> and platform = #{platform}</if>
</where>
</select>
<select id="selectDcBoardReleaseLogById" parameterType="Long" resultMap="DcBoardReleaseLogResult">
<include refid="selectDcBoardReleaseLogVo"/>
where id = #{id}
</select>
<insert id="insertDcBoardReleaseLog" parameterType="DcBoardReleaseLog" useGeneratedKeys="true" keyProperty="id">
insert into dc_board_release_log
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="deviceId != null">device_id,</if>
<if test="deviceName != null">device_name,</if>
<if test="releaseContent != null">release_content,</if>
<if test="releaseStatus != null">release_status,</if>
<if test="releaseDeptName != null">release_dept_name,</if>
<if test="releaseDeptId != null">release_dept_id,</if>
<if test="releaseUserName != null">release_user_name,</if>
<if test="releaseUserId != null">release_user_id,</if>
<if test="releaseIp != null">release_ip,</if>
<if test="platform != null">platform,</if>
release_time
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="deviceId != null">#{deviceId},</if>
<if test="deviceName != null">#{deviceName},</if>
<if test="releaseContent != null">#{releaseContent},</if>
<if test="releaseStatus != null">#{releaseStatus},</if>
<if test="releaseDeptName != null">#{releaseDeptName},</if>
<if test="releaseDeptId != null">#{releaseDeptId},</if>
<if test="releaseUserName != null">#{releaseUserName},</if>
<if test="releaseUserId != null">#{releaseUserId},</if>
<if test="releaseIp != null">#{releaseIp},</if>
<if test="platform != null">#{platform},</if>
now()
</trim>
</insert>
<update id="updateDcBoardReleaseLog" parameterType="DcBoardReleaseLog">
update dc_board_release_log
<trim prefix="SET" suffixOverrides=",">
<if test="deviceId != null">device_id = #{deviceId},</if>
<if test="deviceName != null">device_name = #{deviceName},</if>
<if test="releaseContent != null">release_content = #{releaseContent},</if>
<if test="releaseStatus != null">release_status = #{releaseStatus},</if>
<if test="releaseDeptName != null">release_dept_name = #{releaseDeptName},</if>
<if test="releaseDeptId != null">release_dept_id = #{releaseDeptId},</if>
<if test="releaseUserName != null">release_user_name = #{releaseUserName},</if>
<if test="releaseUserId != null">release_user_id = #{releaseUserId},</if>
<if test="releaseIp != null">release_ip = #{releaseIp},</if>
<if test="platform != null">platform = #{platform},</if>
</trim>
where id = #{id}
</update>
<delete id="deleteDcBoardReleaseLogById" parameterType="Long">
delete from dc_board_release_log where id = #{id}
</delete>
<delete id="deleteDcBoardReleaseLogByIds" parameterType="String">
delete from dc_board_release_log where id in
<foreach item="id" collection="array" open="(" separator="," close=")">
#{id}
</foreach>
</delete>
</mapper>

60
zc-business/src/main/resources/mapper/business/DcInfoBoardVocabularyMapper.xml

@ -0,0 +1,60 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zc.business.mapper.DcInfoBoardVocabularyMapper">
<resultMap type="DcInfoBoardVocabulary" id="DcInfoBoardVocabularyResult">
<result property="id" column="id" />
<result property="word" column="word" />
<result property="createTime" column="create_time" />
</resultMap>
<sql id="selectDcInfoBoardVocabularyVo">
select id, word, create_time from dc_info_board_vocabulary
</sql>
<select id="selectDcInfoBoardVocabularyList" parameterType="DcInfoBoardVocabulary" resultMap="DcInfoBoardVocabularyResult">
<include refid="selectDcInfoBoardVocabularyVo"/>
<where>
<if test="word != null and word != ''"> and word = #{word}</if>
</where>
</select>
<select id="selectDcInfoBoardVocabularyById" parameterType="Long" resultMap="DcInfoBoardVocabularyResult">
<include refid="selectDcInfoBoardVocabularyVo"/>
where id = #{id}
</select>
<insert id="insertDcInfoBoardVocabulary" parameterType="DcInfoBoardVocabulary" useGeneratedKeys="true" keyProperty="id">
insert into dc_info_board_vocabulary
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="word != null">word,</if>
<if test="createTime != null">create_time,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="word != null">#{word},</if>
<if test="createTime != null">#{createTime},</if>
</trim>
</insert>
<update id="updateDcInfoBoardVocabulary" parameterType="DcInfoBoardVocabulary">
update dc_info_board_vocabulary
<trim prefix="SET" suffixOverrides=",">
<if test="word != null">word = #{word},</if>
<if test="createTime != null">create_time = #{createTime},</if>
</trim>
where id = #{id}
</update>
<delete id="deleteDcInfoBoardVocabularyById" parameterType="Long">
delete from dc_info_board_vocabulary where id = #{id}
</delete>
<delete id="deleteDcInfoBoardVocabularyByIds" parameterType="String">
delete from dc_info_board_vocabulary where id in
<foreach item="id" collection="array" open="(" separator="," close=")">
#{id}
</foreach>
</delete>
</mapper>
Loading…
Cancel
Save