ljw 2025-12-17 17:20:27 +08:00
parent 2875291282
commit 08cfaa9665
35 changed files with 160 additions and 9 deletions

View File

@ -67,3 +67,4 @@ public class OrderController {
} }
} }

View File

@ -12,3 +12,4 @@ import org.apache.ibatis.annotations.Mapper;
public interface OrderMapper extends BaseMapper<OrderEntity> { public interface OrderMapper extends BaseMapper<OrderEntity> {
} }

View File

@ -132,3 +132,4 @@ public class OrderEntity extends BaseEntity {
private String customerMemo; private String customerMemo;
} }

View File

@ -24,3 +24,4 @@ public interface OrderService extends IService<OrderEntity> {
PageResult<OrderEntity> paging(PageParam pageParam, OrderEntity orderEntity); PageResult<OrderEntity> paging(PageParam pageParam, OrderEntity orderEntity);
} }

View File

@ -52,3 +52,4 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderEntity> impl
} }
} }

View File

@ -67,3 +67,4 @@ public class OrderCargoPlaceController {
} }
} }

View File

@ -12,3 +12,4 @@ import org.apache.ibatis.annotations.Mapper;
public interface OrderCargoPlaceMapper extends BaseMapper<OrderCargoPlaceEntity> { public interface OrderCargoPlaceMapper extends BaseMapper<OrderCargoPlaceEntity> {
} }

View File

@ -84,3 +84,4 @@ public class OrderCargoPlaceEntity extends BaseEntity {
private Double lat; private Double lat;
} }

View File

@ -24,3 +24,4 @@ public interface OrderCargoPlaceService extends IService<OrderCargoPlaceEntity>
PageResult<OrderCargoPlaceEntity> paging(PageParam pageParam, OrderCargoPlaceEntity orderCargoPlaceEntity); PageResult<OrderCargoPlaceEntity> paging(PageParam pageParam, OrderCargoPlaceEntity orderCargoPlaceEntity);
} }

View File

@ -52,3 +52,4 @@ public class OrderCargoPlaceServiceImpl extends ServiceImpl<OrderCargoPlaceMappe
} }
} }

View File

@ -67,3 +67,4 @@ public class OrderExpenseDetailController {
} }
} }

View File

@ -12,3 +12,4 @@ import org.apache.ibatis.annotations.Mapper;
public interface OrderExpenseDetailMapper extends BaseMapper<OrderExpenseDetailEntity> { public interface OrderExpenseDetailMapper extends BaseMapper<OrderExpenseDetailEntity> {
} }

View File

@ -96,3 +96,4 @@ public class OrderExpenseDetailEntity extends BaseEntity {
private Long payerMoneyAccount; private Long payerMoneyAccount;
} }

View File

@ -24,3 +24,4 @@ public interface OrderExpenseDetailService extends IService<OrderExpenseDetailEn
PageResult<OrderExpenseDetailEntity> paging(PageParam pageParam, OrderExpenseDetailEntity orderExpenseDetailEntity); PageResult<OrderExpenseDetailEntity> paging(PageParam pageParam, OrderExpenseDetailEntity orderExpenseDetailEntity);
} }

View File

@ -52,3 +52,4 @@ public class OrderExpenseDetailServiceImpl extends ServiceImpl<OrderExpenseDetai
} }
} }

View File

@ -67,3 +67,4 @@ public class OrderExpenseItemsController {
} }
} }

View File

@ -12,3 +12,4 @@ import org.apache.ibatis.annotations.Mapper;
public interface OrderExpenseItemsMapper extends BaseMapper<OrderExpenseItemsEntity> { public interface OrderExpenseItemsMapper extends BaseMapper<OrderExpenseItemsEntity> {
} }

View File

@ -100,3 +100,4 @@ public class OrderExpenseItemsEntity extends BaseEntity {
private String goodsScope; private String goodsScope;
} }

View File

@ -24,3 +24,4 @@ public interface OrderExpenseItemsService extends IService<OrderExpenseItemsEnti
PageResult<OrderExpenseItemsEntity> paging(PageParam pageParam, OrderExpenseItemsEntity orderExpenseItemsEntity); PageResult<OrderExpenseItemsEntity> paging(PageParam pageParam, OrderExpenseItemsEntity orderExpenseItemsEntity);
} }

View File

@ -52,3 +52,4 @@ public class OrderExpenseItemsServiceImpl extends ServiceImpl<OrderExpenseItemsM
} }
} }

View File

@ -67,3 +67,4 @@ public class OrderTransController {
} }
} }

View File

@ -12,3 +12,4 @@ import org.apache.ibatis.annotations.Mapper;
public interface OrderTransMapper extends BaseMapper<OrderTransEntity> { public interface OrderTransMapper extends BaseMapper<OrderTransEntity> {
} }

View File

@ -181,3 +181,4 @@ public class OrderTransEntity extends BaseEntity {
private LocalDateTime outTime; private LocalDateTime outTime;
} }

View File

@ -24,3 +24,4 @@ public interface OrderTransService extends IService<OrderTransEntity> {
PageResult<OrderTransEntity> paging(PageParam pageParam, OrderTransEntity orderTransEntity); PageResult<OrderTransEntity> paging(PageParam pageParam, OrderTransEntity orderTransEntity);
} }

View File

@ -52,3 +52,4 @@ public class OrderTransServiceImpl extends ServiceImpl<OrderTransMapper, OrderTr
} }
} }

View File

@ -13,6 +13,7 @@ import java.util.List;
/** /**
* *
*
* @author ljw * @author ljw
*/ */
@Slf4j @Slf4j

View File

@ -1,15 +1,21 @@
package com.njzscloud.dispose.cst.project.mapper; package com.njzscloud.dispose.cst.project.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.njzscloud.dispose.cst.project.pojo.entity.ProjectEntity; import com.njzscloud.dispose.cst.project.pojo.entity.ProjectEntity;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
/** /**
* *
*
* @author ljw * @author ljw
*/ */
@Mapper @Mapper
public interface ProjectMapper extends BaseMapper<ProjectEntity> { public interface ProjectMapper extends BaseMapper<ProjectEntity> {
Page<ProjectEntity> paging(Page<ProjectEntity> page, @Param("ew") QueryWrapper<ProjectEntity> ew);
} }

View File

@ -1,7 +1,10 @@
package com.njzscloud.dispose.cst.project.pojo.entity; package com.njzscloud.dispose.cst.project.pojo.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.njzscloud.dispose.common.pojo.entity.BaseEntity; import com.njzscloud.dispose.common.pojo.entity.BaseEntity;
import com.njzscloud.dispose.cst.customer.pojo.entity.CustomerEntity;
import com.njzscloud.dispose.cst.org.pojo.entity.OrgEntity;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.ToString; import lombok.ToString;
@ -35,21 +38,48 @@ public class ProjectEntity extends BaseEntity {
*/ */
private Long transCustomerId; private Long transCustomerId;
/**
*
*/
@TableField(exist = false)
private CustomerEntity transCustomerInfo;
/** /**
* Id * Id
*/ */
private Long transOrgId; private Long transOrgId;
@TableField(exist = false)
private String transOrgName;
/**
*
*/
@TableField(exist = false)
private OrgEntity transOrgInfo;
/** /**
* / Id * / Id
*/ */
private Long fringeCustomerId; private Long fringeCustomerId;
/**
* /
*/
@TableField(exist = false)
private CustomerEntity fringeCustomerInfo;
/** /**
* / Id * / Id
*/ */
private Long fringeOrgId; private Long fringeOrgId;
/**
* /
*/
@TableField(exist = false)
private OrgEntity fringeOrgInfo;
/** /**
* *
*/ */

View File

@ -1,9 +1,17 @@
package com.njzscloud.dispose.cst.project.service.impl; package com.njzscloud.dispose.cst.project.service.impl;
import cn.hutool.core.collection.CollUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.OrderItem;
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.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njzscloud.common.mp.support.PageParam; import com.njzscloud.common.mp.support.PageParam;
import com.njzscloud.common.mp.support.PageResult; import com.njzscloud.common.mp.support.PageResult;
import com.njzscloud.dispose.cst.customer.pojo.entity.CustomerEntity;
import com.njzscloud.dispose.cst.customer.service.CustomerService;
import com.njzscloud.dispose.cst.org.pojo.entity.OrgEntity;
import com.njzscloud.dispose.cst.org.service.OrgService;
import com.njzscloud.dispose.cst.project.mapper.ProjectMapper; import com.njzscloud.dispose.cst.project.mapper.ProjectMapper;
import com.njzscloud.dispose.cst.project.pojo.entity.ProjectEntity; import com.njzscloud.dispose.cst.project.pojo.entity.ProjectEntity;
import com.njzscloud.dispose.cst.project.service.ProjectService; import com.njzscloud.dispose.cst.project.service.ProjectService;
@ -12,10 +20,12 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.List; import java.util.*;
import java.util.stream.Collectors;
/** /**
* *
*
* @author ljw * @author ljw
*/ */
@Slf4j @Slf4j
@ -23,6 +33,9 @@ import java.util.List;
@RequiredArgsConstructor @RequiredArgsConstructor
public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, ProjectEntity> implements ProjectService { public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, ProjectEntity> implements ProjectService {
private final CustomerService customerService;
private final OrgService orgService;
@Override @Override
public void add(ProjectEntity projectEntity) { public void add(ProjectEntity projectEntity) {
this.save(projectEntity); this.save(projectEntity);
@ -41,12 +54,73 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, ProjectEntity
@Override @Override
public ProjectEntity detail(Long id) { public ProjectEntity detail(Long id) {
return this.getById(id); ProjectEntity detail = this.getById(id);
if (detail != null) {
fillCustomerAndOrgInfo(Collections.singletonList(detail));
}
return detail;
} }
@Override @Override
public PageResult<ProjectEntity> paging(PageParam pageParam, ProjectEntity projectEntity) { public PageResult<ProjectEntity> paging(PageParam pageParam, ProjectEntity projectEntity) {
return PageResult.of(this.page(pageParam.toPage(), Wrappers.<ProjectEntity>query(projectEntity))); QueryWrapper<ProjectEntity> ew = Wrappers.<ProjectEntity>query().eq("p.deleted", 0);
if (projectEntity != null) {
String projectName = projectEntity.getProjectName();
String transOrgName = projectEntity.getTransOrgName();
ew.like(projectName != null, "p.project_name", projectName).like(transOrgName != null, "o.org_name", transOrgName);
}
// 直接调用自定义分页 SQL项目名称 & 运输公司名称均为模糊查询)
Page<ProjectEntity> page = pageParam.toPage();
page.addOrder(OrderItem.desc("p.create_time"), OrderItem.desc("p.id"));
Page<ProjectEntity> paging = baseMapper.paging(page, ew);
if (CollUtil.isNotEmpty(paging.getRecords())) {
fillCustomerAndOrgInfo(paging.getRecords());
}
return PageResult.of(paging);
}
/**
* /
*/
private void fillCustomerAndOrgInfo(List<ProjectEntity> records) {
// 收集所有需要的 ID
Set<Long> transCustomerIds = records.stream().map(ProjectEntity::getTransCustomerId).filter(Objects::nonNull).collect(Collectors.toSet());
Set<Long> fringeCustomerIds = records.stream().map(ProjectEntity::getFringeCustomerId).filter(Objects::nonNull).collect(Collectors.toSet());
Set<Long> transOrgIds = records.stream().map(ProjectEntity::getTransOrgId).filter(Objects::nonNull).collect(Collectors.toSet());
Set<Long> fringeOrgIds = records.stream().map(ProjectEntity::getFringeOrgId).filter(Objects::nonNull).collect(Collectors.toSet());
Set<Long> allCustomerIds = new HashSet<>(transCustomerIds);
allCustomerIds.addAll(fringeCustomerIds);
Set<Long> allOrgIds = new HashSet<>(transOrgIds);
allOrgIds.addAll(fringeOrgIds);
Map<Long, CustomerEntity> customerMap = Collections.emptyMap();
Map<Long, OrgEntity> orgMap = Collections.emptyMap();
if (!allCustomerIds.isEmpty()) {
customerMap = customerService.listByIds(allCustomerIds).stream().collect(Collectors.toMap(CustomerEntity::getId, it -> it));
}
if (!allOrgIds.isEmpty()) {
orgMap = orgService.listByIds(allOrgIds).stream().collect(Collectors.toMap(OrgEntity::getId, it -> it));
}
for (ProjectEntity item : records) {
if (item.getTransCustomerId() != null) {
item.setTransCustomerInfo(customerMap.get(item.getTransCustomerId()));
}
if (item.getFringeCustomerId() != null) {
item.setFringeCustomerInfo(customerMap.get(item.getFringeCustomerId()));
}
if (item.getTransOrgId() != null) {
item.setTransOrgInfo(orgMap.get(item.getTransOrgId()));
}
if (item.getFringeOrgId() != null) {
item.setFringeOrgInfo(orgMap.get(item.getFringeOrgId()));
}
}
} }
} }

View File

@ -70,3 +70,4 @@
</mapper> </mapper>

View File

@ -56,3 +56,4 @@
</mapper> </mapper>

View File

@ -31,16 +31,26 @@
</resultMap> </resultMap>
<sql id="Base_Column_List"> <sql id="Base_Column_List">
id, project_name, contract_picture, trans_customer_id, trans_org_id, p.id, p.project_name, p.contract_picture, p.trans_customer_id, p.trans_org_id,
fringe_customer_id, fringe_org_id, province, city, area, town, p.fringe_customer_id, p.fringe_org_id, p.province, p.city, p.area, p.town,
province_name, city_name, area_name, town_name, address, lng, lat, p.province_name, p.city_name, p.area_name, p.town_name, p.address, p.lng, p.lat,
contract_start_date, contract_end_date, creator_id, modifier_id, create_time, modify_time, deleted p.contract_start_date, p.contract_end_date, p.creator_id, p.modifier_id, p.create_time, p.modify_time, p.deleted
</sql> </sql>
<select id="getById" resultMap="ProjectResultMap"> <select id="getById" resultMap="ProjectResultMap">
SELECT <include refid="Base_Column_List"/> SELECT <include refid="Base_Column_List"/>
FROM cst_project FROM cst_project p
WHERE id = #{id} WHERE p.id = #{id}
</select>
<!-- 分页查询,支持项目名称模糊查询与运输公司名称模糊查询(直接表关联写法) -->
<select id="paging" resultMap="ProjectResultMap">
SELECT <include refid="Base_Column_List"/>
FROM cst_project p
LEFT JOIN cst_org o ON o.id = p.trans_org_id AND o.deleted = 0
<if test="ew.customSqlSegment != null and ew.customSqlSegment != ''">
${ew.customSqlSegment}
</if>
</select> </select>
</mapper> </mapper>