|
@@ -1,10 +1,12 @@
|
|
|
package com.kxs.product.biz.service.impl;
|
|
package com.kxs.product.biz.service.impl;
|
|
|
|
|
|
|
|
|
|
+import cn.hutool.core.collection.CollectionUtil;
|
|
|
import cn.hutool.core.date.DatePattern;
|
|
import cn.hutool.core.date.DatePattern;
|
|
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
|
|
import cn.hutool.crypto.symmetric.AES;
|
|
import cn.hutool.crypto.symmetric.AES;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
@@ -15,11 +17,13 @@ import com.kxs.common.core.exception.GlobalCustomerException;
|
|
|
import com.kxs.common.core.util.R;
|
|
import com.kxs.common.core.util.R;
|
|
|
import com.kxs.common.core.util.RetOps;
|
|
import com.kxs.common.core.util.RetOps;
|
|
|
import com.kxs.common.security.util.SecurityUtils;
|
|
import com.kxs.common.security.util.SecurityUtils;
|
|
|
|
|
+import com.kxs.product.api.dto.admin.machine.SysMachinePageDTO;
|
|
|
import com.kxs.product.api.dto.kxsapp.GetActivityMachineByIdAndTimeDTO;
|
|
import com.kxs.product.api.dto.kxsapp.GetActivityMachineByIdAndTimeDTO;
|
|
|
import com.kxs.product.api.dto.kxsapp.machine.*;
|
|
import com.kxs.product.api.dto.kxsapp.machine.*;
|
|
|
import com.kxs.product.api.dto.kxsapp.merchant.MachineRatioDTO;
|
|
import com.kxs.product.api.dto.kxsapp.merchant.MachineRatioDTO;
|
|
|
import com.kxs.product.api.model.*;
|
|
import com.kxs.product.api.model.*;
|
|
|
import com.kxs.product.api.req.kxs.DepositSetReq;
|
|
import com.kxs.product.api.req.kxs.DepositSetReq;
|
|
|
|
|
+import com.kxs.product.api.vo.admin.machine.SysMachinePageVO;
|
|
|
import com.kxs.product.api.vo.kxsapp.machine.*;
|
|
import com.kxs.product.api.vo.kxsapp.machine.*;
|
|
|
import com.kxs.common.core.constant.enums.MachineTypeEnum;
|
|
import com.kxs.common.core.constant.enums.MachineTypeEnum;
|
|
|
import com.kxs.product.biz.constant.enums.ProductErrorTypeEnum;
|
|
import com.kxs.product.biz.constant.enums.ProductErrorTypeEnum;
|
|
@@ -27,9 +31,12 @@ import com.kxs.product.biz.mapper.*;
|
|
|
import com.kxs.product.biz.service.KxsMachineService;
|
|
import com.kxs.product.biz.service.KxsMachineService;
|
|
|
import com.kxs.stat.api.dto.statUser.GetActivityStatByIdAndTimeDTO;
|
|
import com.kxs.stat.api.dto.statUser.GetActivityStatByIdAndTimeDTO;
|
|
|
import com.kxs.stat.api.vo.GetActivityStatByIdAndTimeVO;
|
|
import com.kxs.stat.api.vo.GetActivityStatByIdAndTimeVO;
|
|
|
|
|
+import com.kxs.store.api.dto.admin.machine.WarehouseSearchDTO;
|
|
|
import com.kxs.store.api.feign.RemoteKxsStoreService;
|
|
import com.kxs.store.api.feign.RemoteKxsStoreService;
|
|
|
|
|
+import com.kxs.store.api.feign.RemoteKxsWarehouseService;
|
|
|
import com.kxs.system.api.feign.RemoteOldService;
|
|
import com.kxs.system.api.feign.RemoteOldService;
|
|
|
import com.kxs.system.api.vo.kxsapp.RecycleBrandListVO;
|
|
import com.kxs.system.api.vo.kxsapp.RecycleBrandListVO;
|
|
|
|
|
+import com.kxs.user.api.dto.admin.user.UserSearchDTO;
|
|
|
import com.kxs.user.api.feign.RemoteKxsUserService;
|
|
import com.kxs.user.api.feign.RemoteKxsUserService;
|
|
|
import com.kxs.user.api.model.KxsUser;
|
|
import com.kxs.user.api.model.KxsUser;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.RequiredArgsConstructor;
|
|
@@ -74,6 +81,8 @@ public class KxsMachineServiceImpl extends ServiceImpl<KxsMachineMapper, KxsMach
|
|
|
|
|
|
|
|
private final AES cryptoOldAes;
|
|
private final AES cryptoOldAes;
|
|
|
|
|
|
|
|
|
|
+ private final RemoteKxsWarehouseService remoteKxsWarehouseService;
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
public IPage<MachineStoreListVO> machineStoreList(Page<MachineStoreListVO> page, MachineStoreListDTO param) {
|
|
public IPage<MachineStoreListVO> machineStoreList(Page<MachineStoreListVO> page, MachineStoreListDTO param) {
|
|
|
|
|
|
|
@@ -385,6 +394,84 @@ public class KxsMachineServiceImpl extends ServiceImpl<KxsMachineMapper, KxsMach
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public List<SysMachinePageVO> machinePage(Page page, SysMachinePageDTO param) {
|
|
|
|
|
+ //如果有用户名称或用户编号的搜索条件,先去查用户,再根据用户id搜索机具
|
|
|
|
|
+ String userCode = param.getUserCode();
|
|
|
|
|
+ String username = param.getUsername();
|
|
|
|
|
+ List<Integer> searchUserIds = param.getUserIds();
|
|
|
|
|
+ if(StringUtils.isNotBlank(userCode) || StringUtils.isNotBlank(username)){
|
|
|
|
|
+ UserSearchDTO userSearchDTO = new UserSearchDTO();
|
|
|
|
|
+ userSearchDTO.setUsername(username);
|
|
|
|
|
+ userSearchDTO.setUserCode(userCode);
|
|
|
|
|
+ List<Integer> userIds = getUserIdsSearch(userSearchDTO);
|
|
|
|
|
+ if(CollectionUtil.isNotEmpty(userIds)){
|
|
|
|
|
+ if(searchUserIds == null){
|
|
|
|
|
+ searchUserIds = new ArrayList<>();
|
|
|
|
|
+ }
|
|
|
|
|
+ searchUserIds.addAll(userIds);
|
|
|
|
|
+ }else{
|
|
|
|
|
+ return new ArrayList<>();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ //设置用户userIds
|
|
|
|
|
+ param.setUserIds(searchUserIds);
|
|
|
|
|
+
|
|
|
|
|
+ //如果有仓库编号或仓库所属人创客编号的搜索条件,先去查仓库信息,再根据仓库id搜索机具
|
|
|
|
|
+ String warehouseNo = param.getWarehouseNo();
|
|
|
|
|
+ String warehouseUserCode = param.getWarehouseUserCode();
|
|
|
|
|
+ List<Integer> searchWarehouseIds = param.getWarehouseIds();
|
|
|
|
|
+ if(StringUtils.isNotBlank(warehouseNo) || StringUtils.isNotBlank(warehouseUserCode)){
|
|
|
|
|
+ WarehouseSearchDTO warehouseSearchDTO = new WarehouseSearchDTO();
|
|
|
|
|
+ warehouseSearchDTO.setWarehouseNo(warehouseNo);
|
|
|
|
|
+ warehouseSearchDTO.setWarehouseUserCode(warehouseUserCode);
|
|
|
|
|
+ List<Integer> warehouseIds = getWarehouseIdsSearch(warehouseSearchDTO);
|
|
|
|
|
+ if(CollectionUtil.isNotEmpty(warehouseIds)){
|
|
|
|
|
+ if(searchWarehouseIds == null){
|
|
|
|
|
+ searchWarehouseIds = new ArrayList<>();
|
|
|
|
|
+ }
|
|
|
|
|
+ searchWarehouseIds.addAll(warehouseIds);
|
|
|
|
|
+ }else{
|
|
|
|
|
+ return new ArrayList<>();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ //设置仓库warehouseIds
|
|
|
|
|
+ param.setWarehouseIds(searchWarehouseIds);
|
|
|
|
|
+
|
|
|
|
|
+ List<SysMachinePageVO> list = baseMapper.machinePage(page, param);
|
|
|
|
|
+
|
|
|
|
|
+ if(page != null){
|
|
|
|
|
+ page.setRecords(list);
|
|
|
|
|
+ }
|
|
|
|
|
+ return list;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 通过条件获取用户id数据
|
|
|
|
|
+ * @return
|
|
|
|
|
+ */
|
|
|
|
|
+ private List<Integer> getUserIdsSearch(UserSearchDTO userSearchDTO){
|
|
|
|
|
+ R<List<Integer>> rList = remoteKxsUserService.searchUserList(userSearchDTO, SecurityConstants.FROM_IN);
|
|
|
|
|
+ if (rList.getStatus() != 1) {
|
|
|
|
|
+ throw new GlobalCustomerException("用户服务请求异常");
|
|
|
|
|
+ }else{
|
|
|
|
|
+ return rList.getData();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 通过条件获取用户id数据
|
|
|
|
|
+ * @return
|
|
|
|
|
+ */
|
|
|
|
|
+ private List<Integer> getWarehouseIdsSearch(WarehouseSearchDTO warehouseSearchDTO){
|
|
|
|
|
+ R<List<Integer>> rList = remoteKxsWarehouseService.searchWarehouseList(warehouseSearchDTO, SecurityConstants.FROM_IN);
|
|
|
|
|
+ if (rList.getStatus() != 1) {
|
|
|
|
|
+ throw new GlobalCustomerException("用户服务请求异常");
|
|
|
|
|
+ }else{
|
|
|
|
|
+ return rList.getData();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|