From 42f9c8cf31cc8a694c6478b12c832c1991bf35b7 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Mon, 21 Aug 2023 15:58:10 +0800 Subject: [PATCH] chore:测试提交 --- screen-manage/src/main/java/com/moral/api/service/impl/SpecialDeviceHistoryServiceImpl.java | 174 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 172 insertions(+), 2 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/SpecialDeviceHistoryServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/SpecialDeviceHistoryServiceImpl.java index cd44849..1959592 100644 --- a/screen-manage/src/main/java/com/moral/api/service/impl/SpecialDeviceHistoryServiceImpl.java +++ b/screen-manage/src/main/java/com/moral/api/service/impl/SpecialDeviceHistoryServiceImpl.java @@ -1,10 +1,25 @@ package com.moral.api.service.impl; -import com.moral.api.entity.SpecialDeviceHistory; -import com.moral.api.mapper.SpecialDeviceHistoryMapper; +import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.moral.api.entity.*; +import com.moral.api.mapper.*; import com.moral.api.service.SpecialDeviceHistoryService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.moral.api.util.LogUtils; +import com.moral.constant.Constants; +import com.moral.constant.ResponseCodeEnum; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.web.context.request.RequestContextHolder; +import org.springframework.web.context.request.ServletRequestAttributes; + +import javax.servlet.http.HttpServletRequest; +import java.text.SimpleDateFormat; +import java.util.*; /** * <p> @@ -17,4 +32,159 @@ @Service public class SpecialDeviceHistoryServiceImpl extends ServiceImpl<SpecialDeviceHistoryMapper, SpecialDeviceHistory> implements SpecialDeviceHistoryService { + @Autowired(required = false) + private SpecialDeviceHistoryMapper specialDeviceHistoryMapper; + + @Autowired(required = false) + private ManageAccountMapper manageAccountMapper; + + @Autowired(required = false) + private VersionMapper versionMapper; + + @Autowired(required = false) + private SysDictDataMapper sysDictDataMapper; + + @Autowired(required = false) + private OrganizationMapper organizationMapper; + + @Autowired(required = false) + private GovMonitorPointMapper govMonitorPointMapper; + + + @Override + public Map<String, Object> getDataByCondition(Map map) { + Map<String,Object> resultMap = new HashMap<>(); + if (!map.containsKey("current")||!map.containsKey("size")){ + resultMap.put("code",ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode()); + resultMap.put("msg",ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg()); + return resultMap; + } + int current = Integer.parseInt(map.get("current").toString()); + int size = Integer.parseInt(map.get("size").toString()); + Page<SpecialDeviceHistory> page = new Page<>(current,size); + QueryWrapper<SpecialDeviceHistory> wrapper_Condition = new QueryWrapper<>(); + wrapper_Condition.eq("is_delete",Constants.NOT_DELETE); + if (!ObjectUtils.isEmpty(map.get("organization_id"))){ + wrapper_Condition.eq("organization_id",map.get("organization_id").toString()); + } + if (!ObjectUtils.isEmpty(map.get("keyword"))){ + wrapper_Condition.and(wc -> wc.like("name",map.get("keyword").toString()).or().like("mac",map.get("keyword").toString())); + //wrapper_Condition.like("name",map.get("keyword").toString()).or().like("mac",map.get("keyword").toString()); + } + wrapper_Condition.orderByDesc("create_time"); + Page resultPage = specialDeviceHistoryMapper.selectPage(page,wrapper_Condition); + int totalNumber = specialDeviceHistoryMapper.selectCount(wrapper_Condition); + List<SpecialDeviceHistory> specialDeviceHistories = resultPage.getRecords(); + SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + List<Map<String,Object>> specialDeviceList = new ArrayList<>(); + for (SpecialDeviceHistory specialDeviceHistory:specialDeviceHistories) { + Map specialDeviceHistoryMap = JSON.parseObject(JSON.toJSONString(specialDeviceHistory),Map.class); + String createTime = SDF.format(specialDeviceHistory.getCreateTime()); + String updateTime = SDF.format(specialDeviceHistory.getUpdateTime()); + specialDeviceHistoryMap.put("createTime",createTime); + specialDeviceHistoryMap.put("updateTime",updateTime); + Map<String,Object> govMonitorPointMap = new HashMap<>(); + if (!ObjectUtils.isEmpty(specialDeviceHistory.getGuid()) && specialDeviceHistory.getGuid()!=null && !"".equals(specialDeviceHistory.getGuid())){ + String guid = specialDeviceHistory.getGuid().toString(); + QueryWrapper<GovMonitorPoint> wapper_govMonitorPoint = new QueryWrapper<>(); + wapper_govMonitorPoint.eq("is_delete",Constants.NOT_DELETE); + wapper_govMonitorPoint.eq("guid",guid); + GovMonitorPoint govMonitorPoint = govMonitorPointMapper.selectOne(wapper_govMonitorPoint); + if (!ObjectUtils.isEmpty(govMonitorPoint)){ + govMonitorPointMap.put("id",govMonitorPoint.getId()); + govMonitorPointMap.put("guid",govMonitorPoint.getGuid()); + govMonitorPointMap.put("name",govMonitorPoint.getName()); + } + } + specialDeviceHistoryMap.put("govMonitorPoint",govMonitorPointMap); + List<Map<String,Object>> operateList = new ArrayList<>(); + if (!ObjectUtils.isEmpty(specialDeviceHistory.getOperateIds()) && specialDeviceHistory.getOperateIds()!=null){ + String operateIds = specialDeviceHistory.getOperateIds(); + String[] operateIdArr = operateIds.split(","); + if (operateIdArr.length>0){ + List<Integer> operateIdList = new ArrayList<>(); + for (int i = 0; i < operateIdArr.length; i++){ + operateIdList.add(Integer.parseInt(operateIdArr[i])); + } + QueryWrapper<ManageAccount> wapper_manageAccount = new QueryWrapper<>(); + wapper_manageAccount.eq("is_delete",Constants.NOT_DELETE); + wapper_manageAccount.in("id",operateIdList); + wapper_manageAccount.select("id", "user_name"); + List<ManageAccount> manageAccounts = manageAccountMapper.selectList(wapper_manageAccount); + for (ManageAccount manageAccount:manageAccounts) { + Map<String,Object> operateMap = new HashMap<>(); + operateMap.put("id",manageAccount.getId()); + operateMap.put("name",manageAccount.getUserName()); + operateList.add(operateMap); + } + } + } + specialDeviceHistoryMap.put("operates",operateList); + Map<String,Object> deviceVersionMap = new HashMap<>(); + if (!ObjectUtils.isEmpty(specialDeviceHistory.getDeviceVersionId()) && specialDeviceHistory.getDeviceVersionId()!=null && !"".equals(specialDeviceHistory.getDeviceVersionId())){ + int versionId = Integer.parseInt(specialDeviceHistory.getDeviceVersionId().toString()); + QueryWrapper<Version> wapper_version = new QueryWrapper<>(); + wapper_version.eq("is_delete",Constants.NOT_DELETE); + wapper_version.eq("id",versionId); + Version version = versionMapper.selectOne(wapper_version); + if (!ObjectUtils.isEmpty(version)){ + deviceVersionMap.put("id",version.getId()); + deviceVersionMap.put("name",version.getName()); + } + } + specialDeviceHistoryMap.put("version",deviceVersionMap); + Map<String,Object> specialTypeMap = new HashMap<>(); + if (!ObjectUtils.isEmpty(specialDeviceHistory.getSpecialType()) && specialDeviceHistory.getSpecialType()!=null && !"".equals(specialDeviceHistory.getSpecialType())){ + int specialTypeId = Integer.parseInt(specialDeviceHistory.getSpecialType().toString()); + QueryWrapper<SysDictData> wapper_sysDictData = new QueryWrapper<>(); + wapper_sysDictData.eq("is_delete",Constants.NOT_DELETE); + wapper_sysDictData.eq("dict_type_id",27); + wapper_sysDictData.eq("dataKey",specialTypeId); + SysDictData sysDictData = sysDictDataMapper.selectOne(wapper_sysDictData); + if (!ObjectUtils.isEmpty(sysDictData)){ + specialTypeMap.put("id",sysDictData.getId()); + specialTypeMap.put("dataKey",sysDictData.getDataKey()); + specialTypeMap.put("name",sysDictData.getDataValue()); + } + } + specialDeviceHistoryMap.put("specialType",specialTypeMap); + Map<String,Object> organizationMap = new HashMap<>(); + if (!ObjectUtils.isEmpty(specialDeviceHistory.getOrganizationId()) && specialDeviceHistory.getOrganizationId()!=null && !"".equals(specialDeviceHistory.getOrganizationId())){ + int organizationId = Integer.parseInt(specialDeviceHistory.getOrganizationId().toString()); + QueryWrapper<Organization> wapper_organization = new QueryWrapper<>(); + wapper_organization.eq("is_delete",Constants.NOT_DELETE); + wapper_organization.eq("id",organizationId); + Organization organization = organizationMapper.selectOne(wapper_organization); + if (!ObjectUtils.isEmpty(organization)){ + organizationMap.put("id",organization.getId()); + organizationMap.put("name",organization.getName()); + } + } + specialDeviceHistoryMap.put("organization",organizationMap); + specialDeviceList.add(specialDeviceHistoryMap); + } + resultMap.put("specialDevices",specialDeviceList); + resultMap.put("totalNumber",totalNumber); + resultMap.put("current",current); + int totalPageNumber = totalNumber/size; + if(totalNumber%size != 0){ + totalPageNumber += 1; + } + resultMap.put("totalPageNumber",totalPageNumber); + return resultMap; + } + + @Override + public void delete(Integer specialDeviceHistoryId) { + SpecialDeviceHistory specialDeviceHistory = specialDeviceHistoryMapper.selectById(specialDeviceHistoryId); + UpdateWrapper<SpecialDeviceHistory> updateWrapper = new UpdateWrapper<>(); + updateWrapper.eq("id",specialDeviceHistoryId).set("is_delete",Constants.DELETE); + specialDeviceHistoryMapper.update(null,updateWrapper); + String mac = specialDeviceHistory.getMac(); + //������������������ + HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest(); + StringBuilder content = new StringBuilder(); + content.append("������������������������������").append(specialDeviceHistory.getName()).append(";").append("mac���").append(mac); + LogUtils.saveOperationForManage(request, content.toString(), Constants.DELETE_OPERATE_TYPE); + } } -- Gitblit v1.8.0