|
@@ -68,6 +68,11 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
MtStarUtil mtStarUtil;
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
+ * 添加设备
|
|
|
+ * @param equipmentVo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public Integer addEquipment(EquipmentVo equipmentVo) {
|
|
|
//判断是否已经存在设备Code
|
|
@@ -78,7 +83,8 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
if (aLong == 0){
|
|
|
Equipment equipment = new Equipment(equipmentVo);
|
|
|
//1.新增地区码映射
|
|
|
- equipment.setAddrCodeInfo(initMapUtil.getInitAddrCodeMap(equipment.getAddrCode()));
|
|
|
+ //equipment.setAddrCodeInfo(initMapUtil.getInitAddrCodeMap(equipment.getAddrCode()));
|
|
|
+
|
|
|
//2.新增创建时间
|
|
|
equipment.setEnterTime(LocalDateTime.now(ZoneId.of("Asia/Shanghai")));
|
|
|
|
|
@@ -94,8 +100,14 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 修改设备信息
|
|
|
+ * @param equipmentVo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public R updateEquipment(EquipmentVo equipmentVo) {
|
|
|
+ //查找是否存在该设备
|
|
|
QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.select("equipment_name","equipment_code","addr_info","addr_code","addr_code_info");
|
|
|
queryWrapper.eq("equipment_id",equipmentVo.getEquipmentId());
|
|
@@ -121,6 +133,7 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
.set("maintain_telephone",equipmentVo.getMaintainTelephone())
|
|
|
.set("update_time",equipmentVo.getUpdateTime());
|
|
|
equipmentMapper.update(null,updateWrapper);
|
|
|
+
|
|
|
//修改冗余字段
|
|
|
if (!equipment.getEquipmentName().equals(equipmentVo.getEquipmentName()) || !equipment.getEquipmentCode().equals(equipmentVo.getEquipmentCode()) || !equipment.getAddrCode().equals(equipmentVo.getAddrCode())){
|
|
|
UpdateWrapper<PlanItem> updateWrapper1 = new UpdateWrapper<>();
|
|
@@ -168,6 +181,11 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 获取设备详细信息
|
|
|
+ * @param equipmentId
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public EquipmentBo getEquipment(String equipmentId) {
|
|
|
Equipment equipment = equipmentMapper.selectById(equipmentId);
|
|
@@ -175,9 +193,11 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
return equipmentBo;
|
|
|
}
|
|
|
|
|
|
- /*
|
|
|
- * TODO 需要考虑上面有没有广告
|
|
|
- * */
|
|
|
+ /**
|
|
|
+ * 删除设备(需要考虑设备下有没有广告计划存在)
|
|
|
+ * @param equipmentIds
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public String deleteEquipment(String[] equipmentIds) {
|
|
|
//1.查询设备下身份有广告
|
|
@@ -197,7 +217,11 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
+ /**
|
|
|
+ * 获取没有绑定店铺的设备
|
|
|
+ * @param equipmentVo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public Page<Equipment> getEquipmentBySelect(EquipmentVo equipmentVo) {
|
|
|
QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
|
|
@@ -217,6 +241,10 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
return pageInfo;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 绑定设备
|
|
|
+ * @param equipmentVo
|
|
|
+ */
|
|
|
@Override
|
|
|
public void addStoreEquipment(EquipmentVo equipmentVo) {
|
|
|
UpdateWrapper<Equipment> updateWrapper = new UpdateWrapper<>();
|
|
@@ -225,6 +253,11 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
equipmentMapper.update(null,updateWrapper);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 获取店铺下的设备列表
|
|
|
+ * @param equipmentVo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public Page<Equipment> getEquipmentByStoreId(EquipmentVo equipmentVo) {
|
|
|
QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
|
|
@@ -237,7 +270,7 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * TODO 待测试
|
|
|
+ * 获取设备下的计划列表
|
|
|
* @param equipmentVo
|
|
|
* @return
|
|
|
*/
|
|
@@ -250,16 +283,16 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
QueryWrapper<PlanItemBo> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq("equipment_id",equipmentVo.getEquipmentId());
|
|
|
queryWrapper.and(planItemBoQueryWrapper -> {
|
|
|
- planItemBoQueryWrapper.eq("dl_plan_item.deleted",0);
|
|
|
+ planItemBoQueryWrapper.eq("dl_plan_item.deleted",0); //没有删除
|
|
|
});
|
|
|
queryWrapper.and(planItemBoQueryWrapper -> {
|
|
|
- planItemBoQueryWrapper.eq("dl_plan.state",1);
|
|
|
+ planItemBoQueryWrapper.eq("dl_plan.state",1); //审核通过
|
|
|
});
|
|
|
queryWrapper.and(planItemBoQueryWrapper -> {
|
|
|
- planItemBoQueryWrapper.eq("dl_plan.on_state",1);
|
|
|
+ planItemBoQueryWrapper.eq("dl_plan.on_state",1); //上架
|
|
|
});
|
|
|
queryWrapper.and(planItemBoQueryWrapper -> {
|
|
|
- planItemBoQueryWrapper.gt("plan_end_time",LocalDateTime.now(ZoneId.of("Asia/Shanghai")));
|
|
|
+ planItemBoQueryWrapper.gt("plan_end_time",LocalDateTime.now(ZoneId.of("Asia/Shanghai"))); //结束时间大于当前时间
|
|
|
});
|
|
|
|
|
|
queryWrapper.apply("dl_plan.`plan_id` = dl_plan_item.`plan_id`");
|
|
@@ -275,6 +308,10 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
return euipmentPlanList;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 修改设备下的计划排序
|
|
|
+ * @param planItemVo
|
|
|
+ */
|
|
|
@Override
|
|
|
public void updateEquipmentPlan(PlanItemVo planItemVo) {
|
|
|
UpdateWrapper<PlanItem> updateWrapper = new UpdateWrapper<>();
|
|
@@ -283,6 +320,10 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
planItemMapper.update(null,updateWrapper);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 获取设备数量
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public HashMap getEquipmentCount() {
|
|
|
QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
|
|
@@ -299,6 +340,11 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
return objectObjectHashMap;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 获取设备列表
|
|
|
+ * @param equipmentVo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public HashMap getEquipmentList(EquipmentVo equipmentVo) {
|
|
|
QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
|
|
@@ -366,6 +412,10 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
return objectObjectHashMap;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 解除店铺绑定的设备
|
|
|
+ * @param equipmentIds
|
|
|
+ */
|
|
|
@Override
|
|
|
public void deleteStoreEquipment(String[] equipmentIds) {
|
|
|
UpdateWrapper<Equipment> updateWrapper = new UpdateWrapper<>();
|
|
@@ -374,6 +424,10 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
equipmentMapper.update(null,updateWrapper);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 删除设备下的广告推广
|
|
|
+ * @param planItemIds
|
|
|
+ */
|
|
|
@Override
|
|
|
public void deleteEquipmentPlan(String[] planItemIds) {
|
|
|
//删除设备
|
|
@@ -387,12 +441,22 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 休眠设备
|
|
|
+ * @param equipmentCode
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public String equipmentOnStatedormancy(String equipmentCode) {
|
|
|
//调用接口
|
|
|
return mtStarUtil.dormancy(equipmentCode);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 唤醒设备
|
|
|
+ * @param equipmentCode
|
|
|
+ * @return
|
|
|
+ */
|
|
|
@Override
|
|
|
public String equipmentOnStateWakeup(String equipmentCode) {
|
|
|
return mtStarUtil.wakeup(equipmentCode);
|