|
|
@@ -0,0 +1,101 @@
|
|
|
+package com.zhongshu.card.server.core.dao.school.impl;
|
|
|
+
|
|
|
+import com.github.microservice.components.data.mongo.mongo.helper.DBHelper;
|
|
|
+import com.zhongshu.card.client.model.school.DeviceBindSearch;
|
|
|
+import com.zhongshu.card.client.model.school.DeviceInfoSearch;
|
|
|
+import com.zhongshu.card.server.core.dao.BaseImpl;
|
|
|
+import com.zhongshu.card.server.core.dao.school.extend.DeviceBindDaoExtend;
|
|
|
+import com.zhongshu.card.server.core.dao.school.extend.DeviceInfoDaoExtend;
|
|
|
+import com.zhongshu.card.server.core.domain.org.DeviceInfo;
|
|
|
+import com.zhongshu.card.server.core.domain.school.Area;
|
|
|
+import com.zhongshu.card.server.core.domain.school.DeviceBind;
|
|
|
+import com.zhongshu.card.server.core.util.CommonUtil;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.data.domain.Page;
|
|
|
+import org.springframework.data.domain.Pageable;
|
|
|
+import org.springframework.data.domain.Sort;
|
|
|
+import org.springframework.data.mongodb.core.MongoTemplate;
|
|
|
+import org.springframework.data.mongodb.core.query.Criteria;
|
|
|
+import org.springframework.data.mongodb.core.query.Query;
|
|
|
+import org.springframework.util.CollectionUtils;
|
|
|
+
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.List;
|
|
|
+import java.util.regex.Pattern;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @Author TRX
|
|
|
+ * @CreateDate: 2023/4/12
|
|
|
+ * @Version: 1.0
|
|
|
+ */
|
|
|
+public class DeviceBindDaoImpl extends BaseImpl implements DeviceBindDaoExtend {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private MongoTemplate mongoTemplate;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DBHelper dbHelper;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Page<DeviceBind> page(Pageable pageable, DeviceBindSearch param) {
|
|
|
+ Criteria criteria = buildCriteria(param);
|
|
|
+
|
|
|
+ if (param.getDeviceType() != null) {
|
|
|
+ criteria.and("deviceType").is(param.getDeviceType());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (param.getOnLineState() != null) {
|
|
|
+ criteria.and("onLineState").is(param.getOnLineState());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (StringUtils.isNotEmpty(param.getAreaId())) {
|
|
|
+ criteria.and("area").is(Area.build(param.getAreaId()));
|
|
|
+ }
|
|
|
+
|
|
|
+ if (StringUtils.isNotEmpty(param.getProjectInfoCode())) {
|
|
|
+ criteria.and("projectInfoCode").is(param.getProjectInfoCode());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (StringUtils.isNotEmpty(param.getSchoolInfoOid())) {
|
|
|
+ criteria.and("schoolInfoOid").is(param.getSchoolInfoOid());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (StringUtils.isNotEmpty(param.getShopInfoOid())) {
|
|
|
+ criteria.and("shopInfoOid").is(param.getShopInfoOid());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!CommonUtil.longIsEmpty(param.getStartTime()) && !CommonUtil.longIsEmpty(param.getEndTime())) {
|
|
|
+ criteria.and("createTime").gte(param.getStartTime()).and("createTime").lte(param.getEndTime());
|
|
|
+ }
|
|
|
+
|
|
|
+ // 模糊搜索
|
|
|
+ List<Criteria> criterias = new ArrayList<>();
|
|
|
+ if (StringUtils.isNotEmpty(param.getDeviceId())) {
|
|
|
+ Pattern pattern = Pattern.compile("^.*" + param.getDeviceId() + ".*$");
|
|
|
+ criterias.add(Criteria.where("deviceId").is(pattern));
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotEmpty(param.getDeviceName())) {
|
|
|
+ Pattern pattern = Pattern.compile("^.*" + param.getDeviceName() + ".*$");
|
|
|
+ criterias.add(Criteria.where("deviceName").is(pattern));
|
|
|
+ }
|
|
|
+ if (!CollectionUtils.isEmpty(criterias)) {
|
|
|
+ criteria.andOperator(criterias.toArray(new Criteria[]{}));
|
|
|
+ }
|
|
|
+
|
|
|
+ if (StringUtils.isNotEmpty(param.getKeyWord())) {
|
|
|
+ Pattern pattern = Pattern.compile("^.*" + param.getKeyWord() + ".*$");
|
|
|
+ criteria.orOperator(
|
|
|
+ Criteria.where("deviceId").regex(pattern),
|
|
|
+ Criteria.where("deviceName").regex(pattern),
|
|
|
+ Criteria.where("gateWayId").regex(pattern)
|
|
|
+ );
|
|
|
+ }
|
|
|
+
|
|
|
+ Sort sort = buildSort(param);
|
|
|
+ Query query = Query.query(criteria);
|
|
|
+ query.with(sort);
|
|
|
+ return dbHelper.pages(query, pageable, DeviceBind.class);
|
|
|
+ }
|
|
|
+
|
|
|
+}
|