提交全图监控

sckw-modules-api/sckw-system-api/src/main/java/com/sckw/system/api/RemoteSystemService.java

@@ -5,6 +5,7 @@ import com.sckw.system.api.model.dto.res.*;
 
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 
 /**
  * @desc: 基础信息远程接口
@@ -289,4 +290,6 @@ public interface RemoteSystemService {
 
 
     KwsRoleDto queryByRoleIdAndEntId(Long currentRoleId);
+
+    List<EntTypeResDto> queryEntTypeByIds(Set<Long> entIds);
 }

sckw-modules/sckw-contract/src/main/java/com/sckw/contract/repository/KwcContractLogisticsRepository.java

@@ -24,11 +24,9 @@ import java.util.Set;
 @Repository
 public class KwcContractLogisticsRepository extends ServiceImpl<KwcContractLogisticsMapper, KwcContractLogistics> {
     public IPage<KwcContractLogistics> queryByPage(int pageNum, int pageSize, String contractNo, String contractName,
-                                                   String status,
-                                                   Long entId,Set<Long> contractIds ) {
+                                                   String status,Set<Long> contractIds ) {
         return page(new Page<>(pageNum, pageSize), Wrappers.<KwcContractLogistics>lambdaQuery()
                 .eq(KwcContractLogistics::getDelFlag, 0)
-                .eq(Objects.nonNull(entId), KwcContractLogistics::getEntId, entId)
                 .like(StringUtils.isNotBlank(contractNo), KwcContractLogistics::getContractNo, contractNo)
                 .like(StringUtils.isNotBlank(contractName), KwcContractLogistics::getName, contractName)
                 .eq(StringUtils.isNotBlank(status), KwcContractLogistics::getStatus, status)
@@ -72,12 +70,11 @@ public class KwcContractLogisticsRepository extends ServiceImpl<KwcContractLogis
                 .eq(KwcContractLogistics::getDelFlag, 0));
     }
 
-    public List<KwcContractLogistics> queryList(Long entId, Set<Long> contractIdList, String contractNo, String contractName, String status) {
+    public List<KwcContractLogistics> queryList(Set<Long> contractIdList, String contractNo, String contractName, String status) {
         return list(Wrappers.<KwcContractLogistics>lambdaQuery()
                 .eq(KwcContractLogistics::getDelFlag, 0)
                 .eq(Objects.nonNull(status),KwcContractLogistics::getStatus, status)
                 .in(CollectionUtils.isNotEmpty(contractIdList),KwcContractLogistics::getId, contractIdList)
-                .eq(Objects.nonNull(entId),KwcContractLogistics::getEntId, entId)
                 .like(org.apache.commons.lang3.StringUtils.isNotBlank(contractNo),KwcContractLogistics::getContractNo, contractNo)
                 .like(org.apache.commons.lang3.StringUtils.isNotBlank(contractName),KwcContractLogistics::getName, contractName));
     }

sckw-modules/sckw-contract/src/main/java/com/sckw/contract/repository/KwcContractTradeRepository.java

@@ -61,7 +61,7 @@ public class KwcContractTradeRepository extends ServiceImpl<KwcContractTradeMapp
 
     }
 
-    public List<KwcContractTrade> queryTradeListByPageList( List<Long> authEntIdList,String contractCode,
+    public List<KwcContractTrade> queryTradeListByPageList(String contractCode,
                                                          String contractName, String supplementCode,
                                                             Set<Long> contractIds, Integer status, int pageNum, int pageSize) {
         return list( Wrappers.<KwcContractTrade>lambdaQuery()
@@ -71,7 +71,6 @@ public class KwcContractTradeRepository extends ServiceImpl<KwcContractTradeMapp
                 .eq(Objects.nonNull(status),KwcContractTrade::getStatus, status)
                 .like(StringUtils.isNotBlank(supplementCode),KwcContractTrade::getContractPid, supplementCode)
                 .in(CollectionUtils.isNotEmpty(contractIds),KwcContractTrade::getId, contractIds)
-                .in(CollectionUtils.isNotEmpty(authEntIdList),KwcContractTrade::getEntId, authEntIdList)
                 .orderByDesc(KwcContractTrade::getUpdateTime)
                 .orderByDesc(KwcContractTrade::getId));
 

sckw-modules/sckw-contract/src/main/java/com/sckw/contract/service/operateService/KwcContractLogisticsService.java

@@ -1064,6 +1064,7 @@ public class KwcContractLogisticsService {
         }
 
         List<Long> entIdList = Lists.newArrayList();
+        entIdList.add(entId);
         if (org.apache.commons.lang3.StringUtils.isNotBlank(req.getConsignCompanyId())){
             entIdList.add(Long.valueOf(req.getConsignCompanyId()));
         }
@@ -1081,7 +1082,7 @@ public class KwcContractLogisticsService {
 
         IPage<KwcContractLogistics> page =kwcContractLogisticsRepository.queryByPage(req.getPageNum(),req.getPageSize(),
                 req.getContractNo(),
-                req.getContractName(),req.getStatus(),entId,contractIdList);
+                req.getContractName(),req.getStatus(),contractIdList);
         List<KwcContractLogistics> records = page.getRecords();
         if (CollectionUtils.isEmpty(records)) {
             return PageDataResult.empty(req.getPageNum(),req.getPageSize());
@@ -1522,9 +1523,14 @@ public class KwcContractLogisticsService {
                 .sorted(Comparator.comparing(ContractStatusEnum::getCode))
                 .collect(Collectors.toList());
 
-        Long entId = org.apache.commons.lang3.StringUtils.isNotBlank(req.getEntId()) ?  Long.valueOf(req.getEntId()) :
-                null;
+        Long entId;
+        if (org.apache.commons.lang3.StringUtils.isNotBlank(req.getEntId())){
+            entId = Long.valueOf(req.getEntId());
+        }else {
+            entId = LoginUserHolder.getEntId();
+        }
         List<Long> entIdList = Lists.newArrayList();
+        entIdList.add(entId);
         if (org.apache.commons.lang3.StringUtils.isNotBlank(req.getConsignCompanyId())){
             entIdList.add(Long.valueOf(req.getConsignCompanyId()));
         }
@@ -1551,7 +1557,7 @@ public class KwcContractLogisticsService {
         }
 
 
-        List<KwcContractLogistics> contractLogistics = kwcContractLogisticsRepository.queryList(entId,contractIdList,req.getContractNo(),req.getContractName(),req.getStatus());
+        List<KwcContractLogistics> contractLogistics = kwcContractLogisticsRepository.queryList(contractIdList,req.getContractNo(),req.getContractName(),req.getStatus());
 
         if (CollectionUtils.isEmpty(contractLogistics)){
             Map<Integer, List<KwcContractLogistics>> statusAndLogOrdersMap = new HashMap<>();

sckw-modules/sckw-contract/src/main/java/com/sckw/contract/service/operateService/KwcContractTradeService.java

@@ -1495,8 +1495,14 @@ public class KwcContractTradeService {
 
     public  List<QueryListResVo> queryTradeListByPage(QueryTradeReq req) {
 
-        Long entId = StringUtils.isNotBlank(req.getEntId()) ? Long.valueOf(req.getEntId()) : null;
+        Long entId;
+        if (org.apache.commons.lang3.StringUtils.isNotBlank(req.getEntId())){
+            entId =Long.valueOf(req.getEntId());
+        }else {
+            entId = LoginUserHolder.getEntId();
+        }
         Set<Long> entIds = Sets.newHashSet();
+        entIds.add(entId);
         if (org.apache.commons.lang3.StringUtils.isNotBlank(req.getPurchaseEntId())) {
             //查询企业 信息
             entIds.add(Long.valueOf(req.getPurchaseEntId()));
@@ -1508,29 +1514,17 @@ public class KwcContractTradeService {
         if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(entIds)){
            List<KwcContractTradeUnit> units = kwcContractTradeUnitRepository.queryByEntIds(entIds);
            if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(units)){
-              contractIds = units.stream().map(KwcContractTradeUnit::getContractId).collect(Collectors.toSet());
+              contractIds = units.stream()
+                      .map(KwcContractTradeUnit::getContractId)
+                      .collect(Collectors.toSet());
            }
         }
-        List<Long> allEnt = Lists.newArrayList();
-        if (StringUtils.isBlank(req.getEntId())) {
-            req.setEntId(String.valueOf(LoginUserHolder.getEntId()));
-            allEnt.add(LoginUserHolder.getEntId());
-        }
-
-        if (Objects.nonNull(entId)) {
-         allEnt.add(entId);
-         EntCacheResDto entCacheResDto = remoteSystemService.queryEntTreeById(entId);
-            if (Objects.nonNull(entCacheResDto)) {
-                EntCacheResDto entCacheResDto1 = remoteSystemService.queryEntTreeById(entCacheResDto.getId());
-                List<EntCacheResDto> child = entCacheResDto1.getChild();
-                if (CollectionUtils.isNotEmpty(child)) {
-                    allEnt.addAll(child.stream().map(EntCacheResDto::getId).toList());
-                }
-            }
+        if (org.apache.commons.collections4.CollectionUtils.isEmpty(contractIds)){
+            return Collections.emptyList();
         }
         PageHelper.startPage(req.getPageNum(), req.getPageSize());
         //分页查询合同信息
-        List<KwcContractTrade> records = kwcContractTradeRepository.queryTradeListByPageList(allEnt,
+        List<KwcContractTrade> records = kwcContractTradeRepository.queryTradeListByPageList(
                 req.getContractCode(),
                 req.getContractName(),
                 req.getSupplementCode(),
@@ -1539,6 +1533,49 @@ public class KwcContractTradeService {
         if (org.apache.commons.collections4.CollectionUtils.isEmpty(records)){
             return Collections.emptyList();
         }
+        entIds.addAll(records.stream().map(KwcContractTrade::getEntId).collect(Collectors.toSet()));
+        List<EntTypeResDto> ents = remoteSystemService.queryEntTypeByIds(entIds);
+        Map<Long, EntTypeResDto> entIdAndEntMap = Maps.newHashMap() ;
+        if (CollectionUtils.isNotEmpty(ents)){
+            entIdAndEntMap =
+                    ents.stream().collect(Collectors.toMap(EntTypeResDto::getEntId, Function.identity(), (v1, v2) -> v1));
+        }
+        //如果登录方是采购方，创建方是提供方，那么采购方只能看到已经签约的合同
+        EntTypeResDto entTypeResDto = entIdAndEntMap.getOrDefault(entId, new EntTypeResDto());
+        //如果登录方是采购商，创建方是供应方，那么采购商只能看到已经签约的合同
+        List<KwcContractTrade> contractTrades  = Lists.newArrayList();
+        List<KwcContractTrade> contractTrades1  = Lists.newArrayList();
+        if (entTypeResDto.getType().equals(EntTypeEnum.PURCHASER.getCode())){
+            List<Integer> statusList = Arrays.asList(ContractStatusEnum.SIGNED.getCode(), ContractStatusEnum.COMPLETE.getCode());
+            Map<Long, EntTypeResDto> finalEntIdAndEntMap1 = entIdAndEntMap;
+
+            records.forEach(record -> {
+                EntTypeResDto orDefault = finalEntIdAndEntMap1.getOrDefault(record.getEntId(), new EntTypeResDto());
+                if (Objects.equals(orDefault.getType(),EntTypeEnum.SUPPLIER.getCode()) && statusList.contains(record.getStatus())){
+                    contractTrades.add(record);
+                }else if (Objects.equals(orDefault.getType(),EntTypeEnum.PURCHASER.getCode())) {
+                    contractTrades1.add(record);
+                }
+            });
+        }
+        //如果登录方是供应方，创建方是采购方，那么供应方不能看到已作废的 合同
+        if (entTypeResDto.getType().equals(EntTypeEnum.SUPPLIER.getCode())){
+            Map<Long, EntTypeResDto> finalEntIdAndEntMap = entIdAndEntMap;
+            records.forEach(record -> {
+                        EntTypeResDto orDefault = finalEntIdAndEntMap.getOrDefault(record.getEntId(), new EntTypeResDto());
+                        if (Objects.equals(orDefault.getType(),EntTypeEnum.PURCHASER.getCode()) && !Objects.equals(record.getStatus(),ContractStatusEnum.CANNEL.getCode())){
+                            contractTrades.add(record);
+                        }else if (Objects.equals(orDefault.getType(),EntTypeEnum.SUPPLIER.getCode())){
+                            contractTrades1.add(record);
+                        }
+            });
+        }
+        contractTrades.addAll(contractTrades1);
+        records = contractTrades;
+        if (org.apache.commons.collections4.CollectionUtils.isEmpty(records)){
+            return Collections.emptyList();
+        }
+
         Set<Long> tradeContractIds = records.stream().map(KwcContractTrade::getId).collect(Collectors.toSet());
         //获取父id
         Set<Long> contractPids = records.stream().map(KwcContractTrade::getContractPid).collect(Collectors.toSet());
@@ -1887,8 +1924,14 @@ public class KwcContractTradeService {
                 .collect(Collectors.toList());
         ContractStatusCountResp contractStatusCountResp = new ContractStatusCountResp();
         contractStatusCountResp.setTotalNum("0");
-        Long entId = StringUtils.isNotBlank(req.getEntId()) ? Long.valueOf(req.getEntId()) : null;
+        Long entId;
+        if (Objects.nonNull(req.getEntId())){
+            entId =req.getEntId();
+        }else {
+            entId = LoginUserHolder.getEntId();
+        }
         Set<Long> entIds = Sets.newHashSet();
+        entIds.add(entId);
         if (org.apache.commons.lang3.StringUtils.isNotBlank(req.getPurchaseEntId())) {
             //查询企业 信息
             entIds.add(Long.valueOf(req.getPurchaseEntId()));
@@ -1913,24 +1956,7 @@ public class KwcContractTradeService {
             return contractStatusCountResp;
         }
 
-        List<Long> allEnt = Lists.newArrayList();
-        if (StringUtils.isBlank(req.getEntId())) {
-            req.setEntId(LoginUserHolder.getEntId());
-            allEnt.add(LoginUserHolder.getEntId());
-        }
-
-        if (Objects.nonNull(entId)) {
-            allEnt.add(entId);
-            EntCacheResDto entCacheResDto = remoteSystemService.queryEntTreeById(entId);
-            if (Objects.nonNull(entCacheResDto)) {
-                EntCacheResDto entCacheResDto1 = remoteSystemService.queryEntTreeById(entCacheResDto.getId());
-                List<EntCacheResDto> child = entCacheResDto1.getChild();
-                if (CollectionUtils.isNotEmpty(child)) {
-                    allEnt.addAll(child.stream().map(EntCacheResDto::getId).toList());
-                }
-            }
-        }
-        List<KwcContractTrade> kwcContractTrades = kwcContractTradeRepository.queryTradeListByPageList(allEnt,
+        List<KwcContractTrade> kwcContractTrades = kwcContractTradeRepository.queryTradeListByPageList(
                 req.getContractCode(),
                 req.getContractName(),
                 req.getSupplementCode(),
@@ -1946,6 +1972,54 @@ public class KwcContractTradeService {
             contractStatusCountResp.setContractStatusInfo(statusCounts);
             return contractStatusCountResp;
         }
+        entIds.addAll(kwcContractTrades.stream().map(KwcContractTrade::getEntId).collect(Collectors.toSet()));
+        List<EntTypeResDto> ents = remoteSystemService.queryEntTypeByIds(entIds);
+        Map<Long, EntTypeResDto> entIdAndEntMap = Maps.newHashMap() ;
+        if (CollectionUtils.isNotEmpty(ents)){
+            entIdAndEntMap =
+                    ents.stream().collect(Collectors.toMap(EntTypeResDto::getEntId, Function.identity(), (v1, v2) -> v1));
+        }
+        //如果登录方是采购方，创建方是提供方，那么采购方只能看到已经签约的合同
+        EntTypeResDto entTypeResDto = entIdAndEntMap.getOrDefault(entId, new EntTypeResDto());
+        //如果登录方是采购商，创建方是供应方，那么采购商只能看到已经签约的合同
+        List<KwcContractTrade> contractTrades  = Lists.newArrayList();
+        List<KwcContractTrade> contractTrades1  = Lists.newArrayList();
+        if (entTypeResDto.getType().equals(EntTypeEnum.PURCHASER.getCode())){
+
+            List<Integer> statusList = Arrays.asList(ContractStatusEnum.SIGNED.getCode(), ContractStatusEnum.COMPLETE.getCode());
+            Map<Long, EntTypeResDto> finalEntIdAndEntMap1 = entIdAndEntMap;
+
+            kwcContractTrades.forEach(record -> {
+                EntTypeResDto orDefault = finalEntIdAndEntMap1.getOrDefault(record.getEntId(), new EntTypeResDto());
+                if (Objects.equals(orDefault.getType(),EntTypeEnum.SUPPLIER.getCode()) && statusList.contains(record.getStatus())){
+                    contractTrades.add(record);
+                }else if (Objects.equals(orDefault.getType(),EntTypeEnum.PURCHASER.getCode())){
+                    contractTrades1.add(record);
+                }
+            });
+            kwcContractTrades = contractTrades;
+        }
+        //如果登录方是供应方，创建方是采购方，那么供应方不能看到已作废的 合同
+        if (entTypeResDto.getType().equals(EntTypeEnum.SUPPLIER.getCode())){
+            Map<Long, EntTypeResDto> finalEntIdAndEntMap = entIdAndEntMap;
+            kwcContractTrades.forEach(record -> {
+                EntTypeResDto orDefault = finalEntIdAndEntMap.getOrDefault(record.getEntId(), new EntTypeResDto());
+                if (Objects.equals(orDefault.getType(),EntTypeEnum.PURCHASER.getCode()) && !Objects.equals(record.getStatus(),ContractStatusEnum.CANNEL.getCode())){
+                    contractTrades.add(record);
+                }else if (Objects.equals(orDefault.getType(),EntTypeEnum.SUPPLIER.getCode())){
+                    contractTrades1.add(record);
+                }
+            });
+            kwcContractTrades = contractTrades;
+        }
+        if (org.apache.commons.collections4.CollectionUtils.isEmpty(kwcContractTrades)){
+            Map<Integer, List<KwcContractTrade>> statusAndLogOrdersMap = new HashMap<>();
+            List<ContractStatusCountResp.ContractStatusCount> statusCounts = statusEnums.stream()
+                    .map(x -> getContractStatusCount(x, statusAndLogOrdersMap))
+                    .collect(Collectors.toList());
+            contractStatusCountResp.setContractStatusInfo(statusCounts);
+            return contractStatusCountResp;
+        }
         Map<Integer, List<KwcContractTrade>> statusAndLogOrdersMap = kwcContractTrades.stream().collect(Collectors.groupingBy(KwcContractTrade::getStatus));
         return getContractStatusCountResp(statusEnums, statusAndLogOrdersMap, contractStatusCountResp, kwcContractTrades);
     }

sckw-modules/sckw-fleet/src/main/resources/bootstrap.yml

@@ -10,29 +10,6 @@ spring:
   main:
     allow-bean-definition-overriding: true
     allow-circular-references: true
-
-# 车辆轨迹服务配置
-vehicle:
-  trace:
-    api:
-      base-url: ${VEHICLE_TRACE_API_URL:http://localhost:8080}
-
-# Feign 配置
-feign:
-  client:
-    config:
-      default:
-        connect-timeout: 5000
-        read-timeout: 10000
-      vehicle-trace-service:
-        connect-timeout: 5000
-        read-timeout: 10000
-        logger-level: full
-  httpclient:
-    enabled: true
-    max-connections: 200
-    max-connections-per-route: 50
-
   cloud:
     nacos:
       discovery:

sckw-modules/sckw-system/src/main/java/com/sckw/system/dubbo/RemoteSystemServiceImpl.java

@@ -20,11 +20,14 @@ import com.sckw.system.dao.SysDictDao;
 import com.sckw.system.model.*;
 import com.sckw.system.model.vo.res.FindAreaTreeResVo;
 import com.sckw.system.model.vo.res.KwsUserResVo;
+import com.sckw.system.repository.KwsEntTypeRepository;
+import com.sckw.system.repository.KwsEnterpriseRepository;
 import com.sckw.system.service.KwsUserService;
 import com.sckw.system.service.SysAreaService;
 import jakarta.annotation.Resource;
 import lombok.RequiredArgsConstructor;
 import org.apache.dubbo.config.annotation.DubboService;
+import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 import org.springframework.beans.factory.annotation.Autowired;
 
@@ -53,6 +56,7 @@ public class RemoteSystemServiceImpl implements RemoteSystemService {
     private SysAreaService sysAreaService;
 
     private final KwsRoleDao kwsRoleDao;
+    private final KwsEntTypeRepository kwsEntTypeRepository;
 
     /**
      * @param keys type#value,type#value
@@ -936,4 +940,32 @@ public class RemoteSystemServiceImpl implements RemoteSystemService {
         return kwsRoleDto;
     }
 
+    @Override
+    public List<EntTypeResDto> queryEntTypeByIds(Set<Long> entIds) {
+        List<KwsEntType> kwsEnterprises = kwsEntTypeRepository.queryByEntIds(entIds);
+        if (org.apache.commons.collections4.CollectionUtils.isEmpty(kwsEnterprises)){
+            return List.of();
+        }
+        return kwsEnterprises.stream()
+                .map(RemoteSystemServiceImpl::getEntTypeResDto)
+                .collect(Collectors.toList());
+
+    }
+
+    @NotNull
+    private static EntTypeResDto getEntTypeResDto(KwsEntType item) {
+        EntTypeResDto entTypeResDto = new EntTypeResDto();
+        entTypeResDto.setEntId(item.getEntId());
+        entTypeResDto.setType(item.getType());
+        entTypeResDto.setId(item.getId());
+        entTypeResDto.setRemark(item.getRemark());
+        entTypeResDto.setStatus(item.getStatus());
+        entTypeResDto.setCreateBy(item.getCreateBy());
+        entTypeResDto.setCreateTime(item.getCreateTime());
+        entTypeResDto.setUpdateBy(item.getUpdateBy());
+        entTypeResDto.setUpdateTime(item.getUpdateTime());
+        entTypeResDto.setDelFlag(item.getDelFlag());
+        return entTypeResDto;
+    }
+
 }

sckw-modules/sckw-system/src/main/java/com/sckw/system/repository/KwsEntTypeRepository.java

@@ -36,4 +36,10 @@ public class KwsEntTypeRepository extends ServiceImpl<KwsEntTypeDao, KwsEntType>
                 .eq(KwsEntType::getEntId, entId)
                 .last("limit 1"));
     }
+
+    public List<KwsEntType> queryByEntIds(Set<Long> entIds) {
+        return list(Wrappers.<KwsEntType>lambdaQuery()
+                .eq(BaseModel::getDelFlag,0)
+                .in(KwsEntType::getEntId, entIds));
+    }
 }

sckw-modules/sckw-transport/src/main/resources/bootstrap.yml

@@ -11,27 +11,6 @@ spring:
     allow-bean-definition-overriding: true
     allow-circular-references: true
 
-# 车辆轨迹服务配置
-vehicle:
-  trace:
-    api:
-      base-url: ${VEHICLE_TRACE_API_URL:http://localhost:8080}
-
-# Feign 配置
-feign:
-  client:
-    config:
-      default:
-        connect-timeout: 5000
-        read-timeout: 10000
-      vehicle-trace-service:
-        connect-timeout: 5000
-        read-timeout: 10000
-        logger-level: full
-  httpclient:
-    enabled: true
-    max-connections: 200
-    max-connections-per-route: 50
 
 mybatis-plus:
   configuration: