维护管理之CRUD

newnms/src/main/java/com/hongxinhui/enums/CommonEnums.java

+package com.hongxinhui.enums;
+
+public enum CommonEnums {
+
+    DELETED0(0, "未删除"),
+    DELETED1(1, "已删除"),
+    ;
+    public final Integer code;
+    public final String desc;
+
+    CommonEnums(Integer code, String desc) {
+        this.code = code;
+        this.desc = desc;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+}

newnms/src/main/java/com/hongxinhui/service/impl/MmsAlarmServiceImpl.java

 package com.hongxinhui.service.impl;
 
 import com.hongxinhui.entity.MmsAlarm;
+import com.hongxinhui.entity.MmsDevice;
+import com.hongxinhui.enums.CommonEnums;
 import com.hongxinhui.mapper.MmsAlarmMapper;
 import com.hongxinhui.service.MmsAlarmService;
 import com.hongxinhui.param.MmsAlarmPageParam;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.hongxinhui.utils.CommonAttributeSet;
 import io.geekidea.springbootplus.framework.common.service.impl.BaseServiceImpl;
 import io.geekidea.springbootplus.framework.core.pagination.Paging;
 import io.geekidea.springbootplus.framework.core.pagination.PageInfo;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.springframework.beans.BeanUtils;
 import org.springframework.transaction.annotation.Transactional;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -32,25 +36,37 @@ public class MmsAlarmServiceImpl extends BaseServiceImpl<MmsAlarmMapper, MmsAlar
     @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean saveMmsAlarm(MmsAlarm mmsAlarm) throws Exception {
+        //前端传或者应该获取漏缆型号(如果获取的对象信息较多的话需要建立表,否则在字典表中加数据)
+
+        CommonAttributeSet commonAttributeSet = new CommonAttributeSet().builderInsert();
+        BeanUtils.copyProperties(commonAttributeSet,mmsAlarm);
         return super.save(mmsAlarm);
     }
 
     @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean updateMmsAlarm(MmsAlarm mmsAlarm) throws Exception {
+        //一些公用的属性赋值(修改人,修改时间)
+        BeanUtils.copyProperties(new CommonAttributeSet().builderUpdate(),mmsAlarm);
         return super.updateById(mmsAlarm);
     }
 
     @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean deleteMmsAlarm(Long id) throws Exception {
-        return super.removeById(id);
+
+        //删除设备告警参数限制时是否同步删除包含使用到它的地方信息
+        MmsAlarm mmsAlarm = mmsAlarmMapper.selectById(id);
+        //一些公用的属性赋值(删除标识,删除人,删除时间)
+        BeanUtils.copyProperties(new CommonAttributeSet().builderDeleted(),mmsAlarm);
+        return super.updateById(mmsAlarm);
     }
 
     @Override
     public Paging<MmsAlarm> getMmsAlarmPageList(MmsAlarmPageParam mmsAlarmPageParam) throws Exception {
-        Page<MmsAlarm> page = new PageInfo<>(mmsAlarmPageParam, OrderItem.desc(getLambdaColumn(MmsAlarm::getId)));
+        Page<MmsAlarm> page = new PageInfo<>(mmsAlarmPageParam, OrderItem.desc(getLambdaColumn(MmsAlarm::getCreateTime)));
         LambdaQueryWrapper<MmsAlarm> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(MmsAlarm::getDeleted, CommonEnums.DELETED0.getCode());
         IPage<MmsAlarm> iPage = mmsAlarmMapper.selectPage(page, wrapper);
         return new Paging<MmsAlarm>(iPage);
     }

newnms/src/main/java/com/hongxinhui/service/impl/MmsDeviceServiceImpl.java

 package com.hongxinhui.service.impl;
 
+import com.hongxinhui.entity.AlarmConnection;
 import com.hongxinhui.entity.MmsDevice;
+import com.hongxinhui.enums.CommonEnums;
 import com.hongxinhui.mapper.MmsDeviceMapper;
 import com.hongxinhui.service.MmsDeviceService;
 import com.hongxinhui.param.MmsDevicePageParam;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.hongxinhui.utils.CommonAttributeSet;
 import io.geekidea.springbootplus.framework.common.service.impl.BaseServiceImpl;
 import io.geekidea.springbootplus.framework.core.pagination.Paging;
 import io.geekidea.springbootplus.framework.core.pagination.PageInfo;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.springframework.beans.BeanUtils;
 import org.springframework.transaction.annotation.Transactional;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -32,25 +36,40 @@ public class MmsDeviceServiceImpl extends BaseServiceImpl<MmsDeviceMapper, MmsDe
     @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean saveMmsDevice(MmsDevice mmsDevice) throws Exception {
+        //前端传或者应该获取基站名称信息,FSU信息,设备类型配置信息,设备配置下发信息,设备运行参数配置下发(如果获取的对象信息较多的话需要建立表,否则在字典表中加数据)
+
+        //一些公用的属性赋值(删除状态,创建人,创建时间)
+        CommonAttributeSet commonAttributeSet = new CommonAttributeSet().builderInsert();
+        BeanUtils.copyProperties(commonAttributeSet,mmsDevice);
         return super.save(mmsDevice);
     }
 
     @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean updateMmsDevice(MmsDevice mmsDevice) throws Exception {
+        //前端传或者应该获取基站名称信息,FSU信息,设备类型配置信息,设备配置下发信息,设备运行参数配置下发(如果获取的对象信息较多的话需要建立表,否则在字典表中加数据)
+
+        //一些公用的属性赋值(修改人,修改时间)
+        BeanUtils.copyProperties(new CommonAttributeSet().builderUpdate(),mmsDevice);
         return super.updateById(mmsDevice);
     }
 
     @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean deleteMmsDevice(Long id) throws Exception {
-        return super.removeById(id);
+
+        //删除设备本身维护数据时是否同步删除包含使用到它的地方信息
+        MmsDevice mmsDevice = mmsDeviceMapper.selectById(id);
+        //一些公用的属性赋值(删除标识,删除人,删除时间)
+        BeanUtils.copyProperties(new CommonAttributeSet().builderDeleted(),mmsDevice);
+        return super.updateById(mmsDevice);
     }
 
     @Override
     public Paging<MmsDevice> getMmsDevicePageList(MmsDevicePageParam mmsDevicePageParam) throws Exception {
-        Page<MmsDevice> page = new PageInfo<>(mmsDevicePageParam, OrderItem.desc(getLambdaColumn(MmsDevice::getId)));
+        Page<MmsDevice> page = new PageInfo<>(mmsDevicePageParam, OrderItem.desc(getLambdaColumn(MmsDevice::getCreateTime)));
         LambdaQueryWrapper<MmsDevice> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(MmsDevice::getDeleted, CommonEnums.DELETED0.getCode());
         IPage<MmsDevice> iPage = mmsDeviceMapper.selectPage(page, wrapper);
         return new Paging<MmsDevice>(iPage);
     }

newnms/src/main/java/com/hongxinhui/utils/CommonAttributeSet.java

+package com.hongxinhui.utils;
+
+import com.hongxinhui.entity.User;
+import com.hongxinhui.enums.CommonEnums;
+import io.geekidea.springbootplus.framework.common.entity.BaseEntity;
+import io.geekidea.springbootplus.framework.util.LoginUtil;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @ClassName CommonAttributeSet: 公用属性赋值
+ * @Description TODO
+ * @Author lhb
+ * @Date 2022/2/14 15:59
+ * @Version 1.0
+ **/
+@Data
+public class CommonAttributeSet extends BaseEntity {
+
+    private Integer deleted;
+    private String deletedBy;
+    private Date deletedTime;
+    private String createBy;
+    private Date createTime;
+    private String updateBy;
+    private Date updateTime;
+
+    /**
+     * 当前登陆用户
+     * @return
+     */
+    public User getUser(){
+        Object sysUser = LoginUtil.getSysUser();
+        if (null != sysUser) {
+            User user = (User) sysUser;
+            return user;
+        }
+        return null;
+    }
+
+    /**
+     * 新增公共参数赋值
+     * @return
+     */
+    public  CommonAttributeSet builderInsert() {
+        CommonAttributeSet commonAttributeSet = new CommonAttributeSet();
+        commonAttributeSet.setDeleted(CommonEnums.DELETED0.getCode());
+        commonAttributeSet.setCreateTime(DateUtils.getNowDate());
+
+        User user = getUser();
+        if (null != user) {
+            commonAttributeSet.setCreateBy(user.getId().toString());
+        }
+        return commonAttributeSet;
+    }
+
+    /**
+     * 修改公共参数赋值
+     * @return
+     */
+    public  CommonAttributeSet builderUpdate() {
+        CommonAttributeSet commonAttributeSet = new CommonAttributeSet();
+        commonAttributeSet.setUpdateTime(DateUtils.getNowDate());
+
+        User user = getUser();
+        if (null != user) {
+            commonAttributeSet.setUpdateBy(user.getId().toString());
+        }
+        return commonAttributeSet;
+    }
+
+    /**
+     * 删除公共参数赋值
+     * @return
+     */
+    public  CommonAttributeSet builderDeleted() {
+        CommonAttributeSet commonAttributeSet = new CommonAttributeSet();
+        commonAttributeSet.setDeleted(CommonEnums.DELETED1.getCode());
+        commonAttributeSet.setDeletedTime(DateUtils.getNowDate());
+
+        User user = getUser();
+        if (null != user) {
+            commonAttributeSet.setDeletedBy(user.getId().toString());
+        }
+        return commonAttributeSet;
+    }
+
+}

newnms/src/main/java/com/hongxinhui/utils/DateUtils.java

@@ -55,6 +55,16 @@ public final class DateUtils {
         return new SimpleDateFormat("yyyyMMddHHmm").format(new Date());
     }
 
+    /**
+     * 获取当前Date型日期
+     *
+     * @return Date() 当前日期
+     */
+    public static Date getNowDate()
+    {
+        return new Date();
+    }
+
     /**
      * {@link Date}转为指定格式字符串
      * @param date {@link Date}