提交 f6b5cb4a authored 作者: zhoushaopan's avatar zhoushaopan

[配发]加taskId

上级 f3078bdf
...@@ -146,5 +146,16 @@ public interface DeviceLibraryDao extends JpaRepository<DeviceLibrary, Integer>, ...@@ -146,5 +146,16 @@ public interface DeviceLibraryDao extends JpaRepository<DeviceLibrary, Integer>,
@Modifying @Modifying
@Query("update DeviceLibrary o set o.matchingRange = :matchingRange ,o.updateTime=current_timestamp where o.packingId = :packingId") @Query("update DeviceLibrary o set o.matchingRange = :matchingRange ,o.updateTime=current_timestamp where o.packingId = :packingId")
int upDateMatchingRange(Integer matchingRange,Integer packingId); int upDateMatchingRange(Integer matchingRange,Integer packingId);
@Transactional
@Modifying
@Query("update DeviceLibrary o set o.lifeStatus = :lifeStatus where o.id = :id")
int batchUpdate(Integer lifeStatus,Integer id);
@Transactional
@Modifying
@Query("update DeviceLibrary o set o.lifeStatus = :lifeStatus where o.id in :ids")
int batchUpdate2(Integer lifeStatus,List<Integer> ids);
} }
...@@ -181,4 +181,16 @@ public interface DeviceLibraryService { ...@@ -181,4 +181,16 @@ public interface DeviceLibraryService {
*/ */
List<DeviceLibrary> getAllDevByDevIds(List<Integer> ids); List<DeviceLibrary> getAllDevByDevIds(List<Integer> ids);
/**
* @param lifeStatus 更新装备生命信息
*/
void updateLifeStatus(Integer lifeStatus,Integer id);
/**
* @param lifeStatus 更新装备生命信息
*/
void updateLifeStatus2(Integer lifeStatus,List<Integer> ids);
List<DeviceLibrary> findByIds(List<Integer> ids);
} }
...@@ -9,6 +9,7 @@ import com.tykj.dev.config.base.DeviceLifeStatus; ...@@ -9,6 +9,7 @@ import com.tykj.dev.config.base.DeviceLifeStatus;
import com.tykj.dev.device.library.repository.DeviceLibraryDao; import com.tykj.dev.device.library.repository.DeviceLibraryDao;
import com.tykj.dev.device.library.service.DeviceLibraryService; import com.tykj.dev.device.library.service.DeviceLibraryService;
import com.tykj.dev.device.library.subject.domin.DeviceLibrary; import com.tykj.dev.device.library.subject.domin.DeviceLibrary;
import com.tykj.dev.device.library.subject.domin.DeviceLog;
import com.tykj.dev.device.library.subject.vo.DeviceLibrarySelectVo; import com.tykj.dev.device.library.subject.vo.DeviceLibrarySelectVo;
import com.tykj.dev.device.library.subject.vo.DeviceStatisticsVo; import com.tykj.dev.device.library.subject.vo.DeviceStatisticsVo;
import com.tykj.dev.device.user.subject.entity.Units; import com.tykj.dev.device.user.subject.entity.Units;
...@@ -570,6 +571,23 @@ public class DeviceLibraryServiceImpl implements DeviceLibraryService { ...@@ -570,6 +571,23 @@ public class DeviceLibraryServiceImpl implements DeviceLibraryService {
return allByIdIn; return allByIdIn;
} }
@Override
public void updateLifeStatus(Integer lifeStatus,Integer id) {
deviceLibraryDao.batchUpdate(lifeStatus,id);
}
@Override
public void updateLifeStatus2(Integer lifeStatus, List<Integer> ids) {
deviceLibraryDao.batchUpdate2(lifeStatus,ids);
}
@Override
public List<DeviceLibrary> findByIds(List<Integer> ids) {
return deviceLibraryDao.findAllByIdIn(ids);
}
@Override @Override
public void isNotLoss(List<Integer> ids) { public void isNotLoss(List<Integer> ids) {
ids.forEach(integer -> { ids.forEach(integer -> {
......
...@@ -24,6 +24,12 @@ public interface PackingLibraryDao extends JpaRepository<PackingLibrary, Integer ...@@ -24,6 +24,12 @@ public interface PackingLibraryDao extends JpaRepository<PackingLibrary, Integer
List<PackingLibrary> findAllByIsRootAndPackingStatus(Integer isRoot,Integer packingStatus); List<PackingLibrary> findAllByIsRootAndPackingStatus(Integer isRoot,Integer packingStatus);
List<PackingLibrary> findAllByPartParentIdAndMatchingRangeAndPackingStatusAndName(Integer partParentId,Integer matchingRange,Integer packingStatus,String name); List<PackingLibrary> findAllByPartParentIdAndMatchingRangeAndPackingStatusAndName(Integer partParentId,Integer matchingRange,Integer packingStatus,String name);
List<PackingLibrary> findAllByPartParentIdAndMatchingRangeAndPackingStatusInAndName(Integer partParentId,Integer matchingRange,List<Integer> packingStatus,String name);
/**
* zsp
*/
List<PackingLibrary> findAllByPartParentIdAndMatchingRangeAndPackingStatusAndNameAndDeleteTag(Integer partParentId,Integer matchingRange,Integer packingStatus,String name,Integer del);
List<PackingLibrary> findAllByDeleteTag(Integer deleteTag); List<PackingLibrary> findAllByDeleteTag(Integer deleteTag);
......
...@@ -160,6 +160,30 @@ public interface PackingLibraryService{ ...@@ -160,6 +160,30 @@ public interface PackingLibraryService{
*/ */
PackingLibrary findSamePacking(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange); PackingLibrary findSamePacking(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange);
/**
* 列装状态2 和4
* @param parentId 父列装id
* @param matchingRange 配用范围
*
* 查询对应横向或纵向列装
*/
PackingLibrary findSamePackingInPackingStatus(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange);
/**
*
* @param parentId 父列装id
* @param matchingRange 配用范围
* @param type
* @param style
* @param name
* @param secretLevel
* @param invisibleRange
// * @param del 删除标志
* @return
*/
// PackingLibrary findSamePackingByDel(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange,Integer del,Integer status);
List<PackingLibrary> findSamePacking1(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange); List<PackingLibrary> findSamePacking1(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange);
/** /**
* @param packingLibraries 父子结构列装 * @param packingLibraries 父子结构列装
......
...@@ -607,6 +607,7 @@ public class PackingLibraryServiceImpl implements PackingLibraryService { ...@@ -607,6 +607,7 @@ public class PackingLibraryServiceImpl implements PackingLibraryService {
*/ */
@Override @Override
public PackingLibrary findSamePacking(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange) { public PackingLibrary findSamePacking(Integer parentId,Integer matchingRange,Integer type,Integer style,String name,Integer secretLevel,Integer invisibleRange) {
List<PackingLibrary> packingLibraries = packingLibraryDao.findAllByPartParentIdAndMatchingRangeAndPackingStatusAndName(parentId,matchingRange,2,name); List<PackingLibrary> packingLibraries = packingLibraryDao.findAllByPartParentIdAndMatchingRangeAndPackingStatusAndName(parentId,matchingRange,2,name);
if (packingLibraries.isEmpty()){ if (packingLibraries.isEmpty()){
return null; return null;
...@@ -616,6 +617,29 @@ public class PackingLibraryServiceImpl implements PackingLibraryService { ...@@ -616,6 +617,29 @@ public class PackingLibraryServiceImpl implements PackingLibraryService {
} }
} }
@Override
public PackingLibrary findSamePackingInPackingStatus(Integer parentId, Integer matchingRange, Integer type, Integer style, String name, Integer secretLevel, Integer invisibleRange) {
List<Integer> list = new ArrayList<>(Arrays.asList(2, 4));
List<PackingLibrary> packingLibraries = packingLibraryDao.findAllByPartParentIdAndMatchingRangeAndPackingStatusInAndName(parentId,matchingRange,list,name);
if (packingLibraries.isEmpty()){
return null;
}
else {
return packingLibraries.get(0);
}
}
//
// @Override
// public PackingLibrary findSamePackingByDel(Integer parentId, Integer matchingRange, Integer type, Integer style, String name, Integer secretLevel, Integer invisibleRange, Integer del) {
// List<PackingLibrary> allByPartParentIdAndMatchingRangeAndPackingStatusAndNameAndDeleteTag = packingLibraryDao.findAllByPartParentIdAndMatchingRangeAndPackingStatusAndNameAndDeleteTag(parentId, matchingRange, 4, name, 1);
// if (allByPartParentIdAndMatchingRangeAndPackingStatusAndNameAndDeleteTag.isEmpty()){
// return null;
// }else {
// return allByPartParentIdAndMatchingRangeAndPackingStatusAndNameAndDeleteTag.get(0);
// }
// }
@Override @Override
public List<PackingLibrary> findSamePacking1(Integer parentId, Integer matchingRange, Integer type, Integer style, String name, Integer secretLevel, Integer invisibleRange) { public List<PackingLibrary> findSamePacking1(Integer parentId, Integer matchingRange, Integer type, Integer style, String name, Integer secretLevel, Integer invisibleRange) {
List<PackingLibrary> packingLibraries = packingLibraryDao.findAllByPartParentIdAndMatchingRangeAndPackingStatusAndName(parentId,matchingRange,2,name); List<PackingLibrary> packingLibraries = packingLibraryDao.findAllByPartParentIdAndMatchingRangeAndPackingStatusAndName(parentId,matchingRange,2,name);
......
...@@ -10,4 +10,5 @@ import org.springframework.stereotype.Repository; ...@@ -10,4 +10,5 @@ import org.springframework.stereotype.Repository;
*/ */
@Repository @Repository
public interface MessageDao extends JpaRepository<Message,Integer>, JpaSpecificationExecutor<Message> { public interface MessageDao extends JpaRepository<Message,Integer>, JpaSpecificationExecutor<Message> {
Message findByTaskId(Integer taskId);
} }
...@@ -30,6 +30,8 @@ public interface MessageService { ...@@ -30,6 +30,8 @@ public interface MessageService {
List<MessageBto> getBtoList(); List<MessageBto> getBtoList();
/** /**
* @param messageId 阅知信息id * @param messageId 阅知信息id
* 阅读该信息 * 阅读该信息
...@@ -46,4 +48,6 @@ public interface MessageService { ...@@ -46,4 +48,6 @@ public interface MessageService {
* 根据用户id查询阅知信息 * 根据用户id查询阅知信息
*/ */
boolean isNotExistMessage(Integer userId); boolean isNotExistMessage(Integer userId);
Message findByTaskId(Integer taskId);
} }
...@@ -216,4 +216,9 @@ public class MessageServiceImpl implements MessageService { ...@@ -216,4 +216,9 @@ public class MessageServiceImpl implements MessageService {
.map(Message::parse2Bto) .map(Message::parse2Bto)
.allMatch(messageBto -> messageBto.getInvolveUserIdList().contains(userId)&&messageBto.getCompleteUserIdList().contains(userId)); .allMatch(messageBto -> messageBto.getInvolveUserIdList().contains(userId)&&messageBto.getCompleteUserIdList().contains(userId));
} }
@Override
public Message findByTaskId(Integer taskId) {
return messageDao.findByTaskId(taskId);
}
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论