diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataClientServiceImpl.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataClientServiceImpl.java index 3ca0cc29f..7a7148d77 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataClientServiceImpl.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataClientServiceImpl.java @@ -33,6 +33,8 @@ import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.DictBizConstant; import org.springblade.core.log.exception.ServiceException; import org.springblade.core.mp.base.BaseServiceImpl; +import org.springblade.core.secure.BladeUser; +import org.springblade.core.secure.utils.AuthUtil; import org.springblade.core.tool.utils.BeanUtil; import org.springblade.system.cache.DictBizCache; import org.springblade.system.entity.DictBiz; @@ -333,7 +335,9 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl basicdataClientEntities = baseMapper.selectList(Wrappers.query().lambda().eq(BasicdataClientEntity::getClientCode, i.getClientCode())); if(basicdataClientEntities.isEmpty()){ + BladeUser user = AuthUtil.getUser(); basicdataClient.setPid(0L); + basicdataClient.setCreateUser(user.getUserId()); basicdataClient.setCargoControl(false); basicdataClient.setStatus(0); basicdataClient.setIsDeleted(0); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml index 36f4f4aa2..b8d2e7238 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml @@ -458,7 +458,6 @@ from logpm_trunkline_cars_load_scan where load_id = #{loadId} and scan_status != '1' - and and is_data = 1 order by create_time asc diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.java index 26995bda2..fce9831b9 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.java @@ -11,7 +11,7 @@ import java.util.List; public interface TrunklineCostShareRecordMapper extends BaseMapper { - TrunklineCostShareRecordEntity findPackageDataByLoadIdAndCode(@Param("scanCode") String scanCode, @Param("loadId") Long loadId); + TrunklineCostShareRecordEntity findPackageDataByLoadIdAndCode(@Param("scanCode") String scanCode, @Param("loadId") Long loadId,@Param("tenantId") String tenantId); Integer findTotalUnloadNumByLoad(@Param("loadId") Long loadId); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.xml b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.xml index b1232da92..96bafef02 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.xml +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCostShareRecordMapper.xml @@ -7,6 +7,7 @@ from logpm_trunkline_cost_share_record where load_id = #{loadId} and product_code = #{scanCode} + and tenant_id = #{tenantId} and product_type = 1 diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ICarsLoadAsyncService.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ICarsLoadAsyncService.java index ebfdde9ae..6ed538acf 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ICarsLoadAsyncService.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ICarsLoadAsyncService.java @@ -7,7 +7,7 @@ public interface ICarsLoadAsyncService { void saveLog(TrunklineCarsLoadEntity carsLoadEntity, TrunklineCarsLoadLineEntity carsLoadLineEntity, int cardLoadType,String nickName,Long userId); - void saveCostShareRecord(Long loadId,TrunklineCarsLoadEntity carsLoadEntity); + void saveCostShareRecord(Long loadId, TrunklineCarsLoadEntity carsLoadEntity, Long userId, String tenantId, String deptId); void costShareByLoadId(Long loadId,TrunklineCarsLoadEntity carsLoadEntity); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCostShareRecordService.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCostShareRecordService.java index 02b30d574..5ad4aa87b 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCostShareRecordService.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCostShareRecordService.java @@ -6,7 +6,7 @@ import org.springblade.core.mp.base.BaseService; import java.util.List; public interface ITrunklineCostShareRecordService extends BaseService { - TrunklineCostShareRecordEntity findPackageDataByLoadIdAndCode(String scanCode, Long loadId); + TrunklineCostShareRecordEntity findPackageDataByLoadIdAndCode(String scanCode, Long loadId,String tenantId); Integer findTotalUnloadNumByLoad(Long loadId); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/CarsLoadAsyncServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/CarsLoadAsyncServiceImpl.java index d4f9334a3..89a444536 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/CarsLoadAsyncServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/CarsLoadAsyncServiceImpl.java @@ -154,7 +154,13 @@ public class CarsLoadAsyncServiceImpl implements ICarsLoadAsyncService { @Async @Override - public void saveCostShareRecord(Long loadId,TrunklineCarsLoadEntity carsLoadEntity) { + public void saveCostShareRecord(Long loadId, TrunklineCarsLoadEntity carsLoadEntity, Long userId, String tenantId, String deptIds) { + Long deptId = null; + if(deptIds.contains(",")){ + String[] split = deptIds.split(","); + deptId = Long.parseLong(split[split.length-1]); + } + List scanEntities = trunklineCarsLoadScanService.findListByLoadIdOrderByCreateTimeAsc(loadId); @@ -186,11 +192,15 @@ public class CarsLoadAsyncServiceImpl implements ICarsLoadAsyncService { TrunklineCostShareRecordEntity trunklineCostShareRecordEntity = null; if(type.equals(1)){ - trunklineCostShareRecordEntity = trunklineCostShareRecordService.findPackageDataByLoadIdAndCode(scanCode,loadId); + trunklineCostShareRecordEntity = trunklineCostShareRecordService.findPackageDataByLoadIdAndCode(scanCode,loadId,tenantId); } if(Objects.isNull(trunklineCostShareRecordEntity)){ trunklineCostShareRecordEntity = new TrunklineCostShareRecordEntity(); + trunklineCostShareRecordEntity.setTenantId(tenantId); + trunklineCostShareRecordEntity.setCreateUser(userId); + trunklineCostShareRecordEntity.setUpdateUser(userId); + trunklineCostShareRecordEntity.setCreateDept(deptId); trunklineCostShareRecordEntity.setLoadId(loadId); trunklineCostShareRecordEntity.setCarsNo(carsLoadEntity.getCarsNo()); trunklineCostShareRecordEntity.setWaybillId(waybillId); @@ -289,7 +299,7 @@ public class CarsLoadAsyncServiceImpl implements ICarsLoadAsyncService { for (TrunklineCostShareRecordEntity trunklineCostShareRecordEntity : list) { BigDecimal income = trunklineCostShareRecordEntity.getIncome(); - trunklineCostShareRecordEntity.setCostZhang(countTransportCost.multiply(income.divide(totalIncome))); + trunklineCostShareRecordEntity.setCostZhang(countTransportCost.multiply(income.divide(totalIncome,8,RoundingMode.HALF_UP))); } trunklineCostShareRecordService.updateBatchById(list); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java index 30a604911..bb2890647 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java @@ -774,7 +774,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl unloadPackageList = batchUnloadDTO.getUnloadPackageList(); List unloadZeroList = batchUnloadDTO.getUnloadZeroList(); @@ -3920,7 +3933,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl implements ITrunklineCostShareRecordService { @Override - public TrunklineCostShareRecordEntity findPackageDataByLoadIdAndCode(String scanCode, Long loadId) { - return baseMapper.findPackageDataByLoadIdAndCode(scanCode,loadId); + public TrunklineCostShareRecordEntity findPackageDataByLoadIdAndCode(String scanCode, Long loadId,String tenantId) { + return baseMapper.findPackageDataByLoadIdAndCode(scanCode,loadId,tenantId); } @Override