Browse Source

Merge branch 'dev' into pre-production

master
pref_mail@163.com 11 months ago
parent
commit
16cc8dca5c
  1. 2
      blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataStoreBrandEntity.java
  2. 19
      blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/excel/BasicdataClientExcel.java
  3. 342
      blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataClientServiceImpl.java
  4. 2
      blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java
  5. 8
      blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml
  6. 4
      blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineLoadSignOrderMapper.xml
  7. 1
      blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadScanService.java
  8. 5
      blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadScanServiceImpl.java
  9. 7
      blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java

2
blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataStoreBrandEntity.java

@ -68,7 +68,7 @@ public class BasicdataStoreBrandEntity extends TenantEntity {
* 品牌编码 * 品牌编码
*/ */
@ApiModelProperty(value = "品牌ID") @ApiModelProperty(value = "品牌ID")
private String brandId; private Long brandId;
/** /**
* 品牌名称 * 品牌名称
*/ */

19
blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/excel/BasicdataClientExcel.java

@ -134,6 +134,14 @@ public class BasicdataClientExcel implements Serializable {
@ColumnWidth(20) @ColumnWidth(20)
@ExcelProperty("三方商场编码") @ExcelProperty("三方商场编码")
private String tripartiteCoding; private String tripartiteCoding;
/**
* 三方商场品牌
*/
@ColumnWidth(20)
@ExcelProperty("三方商场品牌")
private String tripartiteMallBrand;
/** /**
* 三方商场 * 三方商场
*/ */
@ -167,4 +175,15 @@ public class BasicdataClientExcel implements Serializable {
@ExcelProperty("合同结束时间") @ExcelProperty("合同结束时间")
private Date contractEntTime; private Date contractEntTime;
/**
* 默认付款方式
*/
@ColumnWidth(20)
@ExcelProperty("默认付款方式")
private String defaultPaymentMethods;
} }

342
blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataClientServiceImpl.java

@ -18,6 +18,7 @@ package com.logpm.basicdata.service.impl;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
@ -31,11 +32,13 @@ import com.logpm.basicdata.vo.BasicdataClientVO;
import com.logpm.basicdata.vo.ClientInfoVO; import com.logpm.basicdata.vo.ClientInfoVO;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springblade.common.constant.DictBizConstant; import org.springblade.common.constant.DictBizConstant;
import org.springblade.core.cache.utils.CacheUtil;
import org.springblade.core.log.exception.ServiceException; import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.base.BaseServiceImpl; import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.secure.BladeUser; import org.springblade.core.secure.BladeUser;
import org.springblade.core.secure.utils.AuthUtil; import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.BeanUtil; import org.springblade.core.tool.utils.BeanUtil;
import org.springblade.core.tool.utils.ObjectUtil;
import org.springblade.system.cache.DictBizCache; import org.springblade.system.cache.DictBizCache;
import org.springblade.system.entity.DictBiz; import org.springblade.system.entity.DictBiz;
import org.springblade.system.feign.IUserClient; import org.springblade.system.feign.IUserClient;
@ -47,6 +50,8 @@ import java.security.NoSuchAlgorithmException;
import java.util.*; import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import static org.springblade.common.constant.DictBizConstant.OPEN_ORDER_PAY_WAY;
/** /**
* 基础客户表 服务实现类 * 基础客户表 服务实现类
* *
@ -59,25 +64,25 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
@Autowired @Autowired
private IBasicdataHistoricalContractService basicdataHistoricalContractService; private IBasicdataHistoricalContractService basicdataHistoricalContractService;
@Autowired @Autowired
private IBasicdataStoreContactService basicdataStoreContactService; //联系人 private IBasicdataStoreContactService basicdataStoreContactService; //联系人
@Autowired @Autowired
private IBasicdataStoreBusinessService basicdataStoreBusinessService; private IBasicdataStoreBusinessService basicdataStoreBusinessService;
@Autowired @Autowired
private IBasicdataTripartiteMallService basicdataTripartiteMallService; //三方商场 private IBasicdataTripartiteMallService basicdataTripartiteMallService; //三方商场
@Autowired @Autowired
private IBasicdataStorageServicesService basicdataStorageServicesService; //服务仓 private IBasicdataStorageServicesService basicdataStorageServicesService; //服务仓
@Autowired @Autowired
private IBasicdataBrandService basicdataBrandService; //品牌 private IBasicdataBrandService basicdataBrandService; //品牌
@Autowired @Autowired
private IBasicdataStoreBrandService basicdataStoreBrandService; //品牌 private IBasicdataStoreBrandService basicdataStoreBrandService; //品牌
@Autowired @Autowired
private IBasicdataWarehouseService warehouseService; private IBasicdataWarehouseService warehouseService;
// private final IBasicdataClientUserService basicdataClientUserService; // private final IBasicdataClientUserService basicdataClientUserService;
@Autowired @Autowired
private IUserClient userClient; private IUserClient userClient;
@Override @Override
public IPage<BasicdataClientVO> selectBasicdataClientPage(IPage<BasicdataClientVO> page, BasicdataClientVO basicdataClient) { public IPage<BasicdataClientVO> selectBasicdataClientPage(IPage<BasicdataClientVO> page, BasicdataClientVO basicdataClient) {
@ -105,7 +110,7 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
List<BasicdataStoreBusinessEntity> list = basicdataStoreBusinessService.list(Wrappers.<BasicdataStoreBusinessEntity>query().lambda() List<BasicdataStoreBusinessEntity> list = basicdataStoreBusinessService.list(Wrappers.<BasicdataStoreBusinessEntity>query().lambda()
.eq(BasicdataStoreBusinessEntity::getClientId, basicdataClient.getId()) .eq(BasicdataStoreBusinessEntity::getClientId, basicdataClient.getId())
); );
if (list.size() > 0) { if (!list.isEmpty()) {
//有数据 //有数据
List<Long> stringList = new ArrayList<>(); List<Long> stringList = new ArrayList<>();
list.forEach(i -> { list.forEach(i -> {
@ -158,18 +163,16 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
//查询客户编码和客户名称是否存在 //查询客户编码和客户名称是否存在
BasicdataClientEntity basicdataClient1 = baseMapper.selectOne(Wrappers.<BasicdataClientEntity>query().lambda() BasicdataClientEntity basicdataClient1 = baseMapper.selectOne(Wrappers.<BasicdataClientEntity>query().lambda()
.eq(BasicdataClientEntity::getClientCode, basicdataClient.getClientCode()) .eq(BasicdataClientEntity::getClientCode, basicdataClient.getClientCode())
.or() .or()
.eq(BasicdataClientEntity::getClientName, basicdataClient.getClientName()) .eq(BasicdataClientEntity::getClientName, basicdataClient.getClientName())
); );
if(ObjectUtils.isNotNull(basicdataClient1)){ if (ObjectUtils.isNotNull(basicdataClient1)) {
throw new ServiceException("客户编码或客户名称已存在"); throw new ServiceException("客户编码或客户名称已存在");
} }
//添加 //添加
this.save(basicdataClient); this.save(basicdataClient);
// //绑定客户账号和客户关系 // //绑定客户账号和客户关系
// this.saveCustomerAndAddAcount(phone,linkman,basicdataClient.getId());
//添加联系人 //添加联系人
BasicdataStoreContactEntity basicdataStoreContactEntity = new BasicdataStoreContactEntity(); BasicdataStoreContactEntity basicdataStoreContactEntity = new BasicdataStoreContactEntity();
@ -181,9 +184,8 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
basicdataStoreContactService.save(basicdataStoreContactEntity); basicdataStoreContactService.save(basicdataStoreContactEntity);
//添加客户类型 //添加客户类型
if (basicdataClient.getTypeServiceList().size() > 0) { if (!basicdataClient.getTypeServiceList().isEmpty()) {
for (String s : basicdataClient.getTypeServiceList()) { for (String s : basicdataClient.getTypeServiceList()) {
//添加服务类型 //添加服务类型
BasicdataStoreBusinessEntity basicdataStoreBusinessEntity = new BasicdataStoreBusinessEntity(); BasicdataStoreBusinessEntity basicdataStoreBusinessEntity = new BasicdataStoreBusinessEntity();
@ -195,7 +197,6 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
basicdataStoreBusinessService.save(basicdataStoreBusinessEntity); basicdataStoreBusinessService.save(basicdataStoreBusinessEntity);
} }
} else { } else {
log.info("服务类型没有!!!"); log.info("服务类型没有!!!");
@ -214,7 +215,7 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
log.info("没有必要的ID了!!!"); log.info("没有必要的ID了!!!");
return false; return false;
} }
if(ObjectUtils.isNotNull(basicdataClient.getLeaseAccessories())){ if (ObjectUtils.isNotNull(basicdataClient.getLeaseAccessories())) {
//添加历史合同 //添加历史合同
BasicdataHistoricalContractEntity basicdataHistoricalContract = new BasicdataHistoricalContractEntity(); BasicdataHistoricalContractEntity basicdataHistoricalContract = new BasicdataHistoricalContractEntity();
basicdataHistoricalContract.setClientId(basicdataClient.getId().toString()); basicdataHistoricalContract.setClientId(basicdataClient.getId().toString());
@ -259,31 +260,32 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
} }
/** /**
* 查询客户编码 * 查询客户编码
*
* @param code * @param code
* @return * @return
*/ */
@Override @Override
public List<BasicdataClientEntity> listCode(String code) { public List<BasicdataClientEntity> listCode(String code) {
return baseMapper.selectList(Wrappers.<BasicdataClientEntity>query().lambda() return baseMapper.selectList(Wrappers.<BasicdataClientEntity>query().lambda()
.eq(BasicdataClientEntity::getClientCode,code) .eq(BasicdataClientEntity::getClientCode, code)
); );
} }
@Override @Override
public List<BasicdataClientVO> dictList() { public List<BasicdataClientVO> dictList() {
BasicdataWarehouseEntity myCurrentWarehouse = warehouseService.getMyCurrentWarehouse(); BasicdataWarehouseEntity myCurrentWarehouse = warehouseService.getMyCurrentWarehouse();
if (null == myCurrentWarehouse){ if (null == myCurrentWarehouse) {
return new ArrayList<BasicdataClientVO>(); return new ArrayList<BasicdataClientVO>();
} }
List<BasicdataClientVO> list = baseMapper.selectListDict(myCurrentWarehouse.getId()); List<BasicdataClientVO> list = baseMapper.selectListDict(myCurrentWarehouse.getId());
return list; return list;
} }
/** /**
* 导入数据 * 导入数据
*
* @param data * @param data
* @param isCovered * @param isCovered
*/ */
@ -301,153 +303,165 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
List<DictBiz> dictBizs = DictBizCache.getList(DictBizConstant.DISTRIBUTION_TYPE);//商 市 自 List<DictBiz> dictBizs = DictBizCache.getList(DictBizConstant.DISTRIBUTION_TYPE);//商 市 自
List<DictBiz> clientBiz = DictBizCache.getList(DictBizConstant.CLIENT_TYPE); //客 工 List<DictBiz> clientBiz = DictBizCache.getList(DictBizConstant.CLIENT_TYPE); //客 工
List<DictBiz> freightBiz = DictBizCache.getList(DictBizConstant.BASIC_FREIGHT_TYPE); //客 工 List<DictBiz> freightBiz = DictBizCache.getList(DictBizConstant.BASIC_FREIGHT_TYPE); //客 工
Set<String> set =new HashSet<>(); Set<String> set = new HashSet<>();
QueryWrapper<BasicdataClientEntity> queryWrapper = new QueryWrapper<>(); QueryWrapper<BasicdataClientEntity> queryWrapper = new QueryWrapper<>();
List<BasicdataClientEntity> basicdataClients = baseMapper.selectList(queryWrapper); List<BasicdataClientEntity> basicdataClients = baseMapper.selectList(queryWrapper);
LambdaQueryWrapper<BasicdataBrandEntity> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(BasicdataBrandEntity::getIsDeleted, 0);
List<BasicdataBrandEntity> basicdataBrandEntityList = basicdataBrandService.list(lambdaQueryWrapper);
for (BasicdataClientExcel i : data) { for (BasicdataClientExcel i : data) {
log.info("导入数据《》《》{}",i);
if(set.isEmpty()){ // 处理下空格 换行
set.add(i.getClientCode()); i.setClientName(i.getClientName().trim());
}else{ i.setClientCode(i.getClientCode().trim());
boolean b = set.stream().anyMatch(a -> a.equals(i.getClientCode()));
if(b){ log.info("导入数据《》《》{}", i);
continue; if (set.isEmpty()) {
} set.add(i.getClientCode());
} else {
boolean b = set.stream().anyMatch(a -> a.equals(i.getClientCode()));
if (b) {
continue;
} }
if(ObjectUtils.isNull(i.getClientCode()) || ObjectUtils.isNull(i.getClientName())){ }
if (ObjectUtils.isNull(i.getClientCode()) || ObjectUtils.isNull(i.getClientName())) {
throw new ServiceException("客户编码或客户名称不能为空!"); throw new ServiceException("客户编码或客户名称不能为空!");
} }
BasicdataClientEntity basicdataClient = new BasicdataClientEntity(); BasicdataClientEntity basicdataClient = new BasicdataClientEntity();
BeanUtil.copyProperties(i,basicdataClient); BeanUtil.copyProperties(i, basicdataClient);
log.info("比对对象>>>:{}",basicdataClient);
log.info("查询客户信息>>>:{}",basicdataClients);
log.info(">>>>>> basicdataClient.getClientCode() {}",basicdataClient.getClientCode());
//查询客户编码和客户名称是否存在 //查询客户编码和客户名称是否存在
boolean b = basicdataClients.stream().anyMatch(ii -> ii.getClientCode().equals(basicdataClient.getClientCode()) boolean b = basicdataClients.stream().anyMatch(ii -> ii.getClientCode().equals(basicdataClient.getClientCode())
|| ii.getClientName().equals(basicdataClient.getClientName())); || ii.getClientName().equals(basicdataClient.getClientName().trim()));
if(b){ if (b) {
List<BasicdataClientEntity> basicdataClientEntities = basicdataClients.stream().filter(ii -> ii.getClientCode().equals(basicdataClient.getClientCode()) List<BasicdataClientEntity> basicdataClientEntities = basicdataClients.stream().filter(ii -> ii.getClientCode().equals(basicdataClient.getClientCode())
|| ii.getClientName().equals(basicdataClient.getClientName())).collect(Collectors.toList()); || ii.getClientName().equals(basicdataClient.getClientName())).collect(Collectors.toList());
log.info("###############basicdataClientEntities重复客户:{}",basicdataClientEntities); log.info("###############basicdataClientEntities重复客户:{}", basicdataClientEntities);
throw new ServiceException("客户编码或客户名称已存在"); throw new ServiceException("客户编码或客户名称已存在");
} }
// Optional<DictBiz> first = dictBizs.stream().filter(ii -> ii.getDictValue().equals(i.getTypeService())).findFirst(); // Optional<DictBiz> first = dictBizs.stream().filter(ii -> ii.getDictValue().equals(i.getTypeService())).findFirst();
Optional<DictBiz> clientFirst = clientBiz.stream().filter(ii -> ii.getDictValue().equals(i.getClientType())).findFirst(); Optional<DictBiz> clientFirst = clientBiz.stream().filter(ii -> ii.getDictValue().equals(i.getClientType())).findFirst();
// i.setTypeService(first.get().getDictValue()); // i.setTypeService(first.get().getDictValue());
basicdataClient.setClientType(clientFirst.get().getDictKey()); basicdataClient.setClientType(clientFirst.get().getDictKey());
//查询是不是重复 //查询是不是重复
List<BasicdataClientEntity> basicdataClientEntities = baseMapper.selectList(Wrappers.<BasicdataClientEntity>query().lambda().eq(BasicdataClientEntity::getClientCode, i.getClientCode())); List<BasicdataClientEntity> basicdataClientEntities = baseMapper.selectList(Wrappers.<BasicdataClientEntity>query().lambda().eq(BasicdataClientEntity::getClientCode, i.getClientCode()));
if(basicdataClientEntities.isEmpty()){ if (basicdataClientEntities.isEmpty()) {
BladeUser user = AuthUtil.getUser(); BladeUser user = AuthUtil.getUser();
basicdataClient.setPid(0L); basicdataClient.setPid(0L);
basicdataClient.setCreateUser(user.getUserId()); basicdataClient.setCreateUser(user.getUserId());
basicdataClient.setCargoControl(false); basicdataClient.setCargoControl(false);
basicdataClient.setStatus(0); basicdataClient.setStatus(0);
basicdataClient.setIsDeleted(0); basicdataClient.setIsDeleted(0);
basicdataClient.setCreateTime(new Date()); basicdataClient.setCreateTime(new Date());
baseMapper.insert(basicdataClient);
if(ObjectUtils.isNull(basicdataClient.getId())){ // 默认付款方式
throw new ServiceException("客户ID不存在"); String keyValue = matchDictValue(DictBizCache.getList(OPEN_ORDER_PAY_WAY), i.getDefaultPaymentMethods().trim());
}
//添加服务类型 basicdataClient.setDefaultPaymentMethods(keyValue);
if(ObjectUtils.isNotNull(i.getTypeService())){
BasicdataStoreBusinessEntity storeBusinessEntity = new BasicdataStoreBusinessEntity();
storeBusinessEntity.setClientId(basicdataClient.getId().toString());
storeBusinessEntity.setTypeService(i.getTypeService());
storeBusinessEntity.setMold(i.getMold());
storeBusinessEntities.add(storeBusinessEntity);
}
//添加服务仓
if(ObjectUtils.isNotNull(i.getServeWarehouseName())){ baseMapper.insert(basicdataClient);
BasicdataStorageServicesEntity servicesEntity = new BasicdataStorageServicesEntity(); if (ObjectUtils.isNull(basicdataClient.getId())) {
servicesEntity.setClientId(basicdataClient.getId()); throw new ServiceException("客户ID不存在");
servicesEntity.setDistinguish(2); }
if(ObjectUtils.isNotNull(i.getSendWarehouseName())){
//添加服务类型
if (ObjectUtils.isNotNull(i.getTypeService())) {
BasicdataStoreBusinessEntity storeBusinessEntity = new BasicdataStoreBusinessEntity();
storeBusinessEntity.setClientId(basicdataClient.getId().toString());
storeBusinessEntity.setTypeService(i.getTypeService());
storeBusinessEntity.setMold(i.getMold());
storeBusinessEntities.add(storeBusinessEntity);
}
//添加服务仓
if (ObjectUtils.isNotNull(i.getServeWarehouseName())) {
BasicdataStorageServicesEntity servicesEntity = new BasicdataStorageServicesEntity();
servicesEntity.setClientId(basicdataClient.getId());
servicesEntity.setDistinguish(2);
if (ObjectUtils.isNotNull(i.getSendWarehouseName())) {
// Long id = list1.stream().filter(q -> q.getName().equals(i.getSendWarehouseName())).findFirst().get().getId(); // Long id = list1.stream().filter(q -> q.getName().equals(i.getSendWarehouseName())).findFirst().get().getId();
// servicesEntity.setSendWarehouseId(String.valueOf(id)); // servicesEntity.setSendWarehouseId(String.valueOf(id));
servicesEntity.setSendWarehouseName(i.getSendWarehouseName()); servicesEntity.setSendWarehouseName(i.getSendWarehouseName());
}
Long id = list1.stream().filter(q -> q.getName().equals(i.getServeWarehouseName())).findFirst().get().getId();
servicesEntity.setServeWarehouseId(id);
servicesEntity.setServeWarehouseName(i.getServeWarehouseName());
storageServicesEntities.add(servicesEntity);
} }
//添加品牌 Long id = list1.stream().filter(q -> q.getName().equals(i.getServeWarehouseName())).findFirst().get().getId();
if(ObjectUtils.isNotNull(i.getBrandName())){ servicesEntity.setServeWarehouseId(id);
BasicdataStoreBrandEntity storeBrandEntity= new BasicdataStoreBrandEntity(); servicesEntity.setServeWarehouseName(i.getServeWarehouseName());
storageServicesEntities.add(servicesEntity);
}
//添加品牌
if (ObjectUtils.isNotNull(i.getBrandName())) {
String [] ars = i.getBrandName().split(",");
for (String ar : ars) {
BasicdataStoreBrandEntity storeBrandEntity = new BasicdataStoreBrandEntity();
storeBrandEntity.setClientId(basicdataClient.getId()); storeBrandEntity.setClientId(basicdataClient.getId());
storeBrandEntity.setShopId(basicdataClient.getId().toString()); storeBrandEntity.setShopId(basicdataClient.getId().toString());
BasicdataBrandEntity one = basicdataBrandService.getOne(Wrappers.<BasicdataBrandEntity>query().lambda().eq(BasicdataBrandEntity::getBrandName, i.getBrandName())); BasicdataBrandEntity one = matchBasicdataBrandEntityListValue(basicdataBrandEntityList, ar);
if(ObjectUtils.isNull(one)){
if (ObjectUtils.isNull(one)) {
throw new ServiceException("品牌不存在"); throw new ServiceException("品牌不存在");
} }
storeBrandEntity.setBrandId(String.valueOf(one.getId())); assert one != null;
storeBrandEntity.setBrandName(i.getBrandName()); storeBrandEntity.setBrandId(one.getId());
storeBrandEntity.setBrandName(one.getBrandName());
storeBrandEntities.add(storeBrandEntity); storeBrandEntities.add(storeBrandEntity);
} }
//添加联系人
if(ObjectUtils.isNotNull(i.getLinkman())){
BasicdataStoreContactEntity storeContactEntity = new BasicdataStoreContactEntity();
storeContactEntity.setShopId(basicdataClient.getId());
storeContactEntity.setPhone(i.getPhone());
storeContactEntity.setLinkman(i.getLinkman());
storeContactEntities.add(storeContactEntity);
}
//添加三方商场
if(ObjectUtils.isNotNull(i.getTripartiteMall())){
BasicdataTripartiteMallEntity tripartiteMallEntity = new BasicdataTripartiteMallEntity();
tripartiteMallEntity.setClientId(basicdataClient.getId());
tripartiteMallEntity.setTripartiteMall(i.getTripartiteMall());
tripartiteMallEntity.setTripartiteCoding(i.getTripartiteCoding());
tripartiteMallEntities.add(tripartiteMallEntity);
}
} }
} //添加联系人
if (ObjectUtils.isNotNull(i.getLinkman())) {
BasicdataStoreContactEntity storeContactEntity = new BasicdataStoreContactEntity();
storeContactEntity.setShopId(basicdataClient.getId());
storeContactEntity.setPhone(i.getPhone());
storeContactEntity.setLinkman(i.getLinkman());
storeContactEntities.add(storeContactEntity);
//品牌 }
if(!storeBrandEntities.isEmpty()){ //添加三方商场
List<BasicdataStoreBrandEntity> list = new ArrayList<>(); if (ObjectUtils.isNotNull(i.getTripartiteMall())) {
storeBrandEntities.stream().forEach(i ->{ BasicdataTripartiteMallEntity tripartiteMallEntity = new BasicdataTripartiteMallEntity();
if(i.getBrandName().contains(",")){ tripartiteMallEntity.setClientId(basicdataClient.getId());
String[] split = i.getBrandName().split(","); tripartiteMallEntity.setTripartiteMall(i.getTripartiteMall());
for (int j = 0; j < split.length; j++) { tripartiteMallEntity.setTripartiteCoding(i.getTripartiteCoding());
BasicdataStoreBrandEntity business = new BasicdataStoreBrandEntity();
BeanUtil.copyProperties(i,business); BasicdataBrandEntity one = matchBasicdataBrandEntityListValue(basicdataBrandEntityList, i.getTripartiteMallBrand());
List<BasicdataBrandEntity> list2 = basicdataBrandService.list(Wrappers.<BasicdataBrandEntity>query().lambda()
.eq(BasicdataBrandEntity::getBrandName, i.getBrandName()) if (ObjectUtil.isNotEmpty(one)) {
); //三方名称
business.setBrandName(split[j]); assert one != null;
business.setBrandId(list2.get(0).getId().toString()); tripartiteMallEntity.setBrandId(one.getId());
list.add(business); tripartiteMallEntity.setBrandName(one.getBrandName());
} }
}else{ tripartiteMallEntities.add(tripartiteMallEntity);
List<BasicdataBrandEntity> list2 = basicdataBrandService.list(Wrappers.<BasicdataBrandEntity>query().lambda()
.eq(BasicdataBrandEntity::getBrandName, i.getBrandName())
);
i.setBrandName(i.getBrandName());
i.setBrandId(list2.get(0).getId().toString());
list.add(i);
} }
});
basicdataStoreBrandService.saveBatch(list); }
}
//品牌
if (!storeBrandEntities.isEmpty()) {
basicdataStoreBrandService.saveBatch(storeBrandEntities);
} }
//服务类型 //服务类型
if(!storeBusinessEntities.isEmpty()){ if (!storeBusinessEntities.isEmpty()) {
List<BasicdataStoreBusinessEntity> list = new ArrayList<>(); List<BasicdataStoreBusinessEntity> list = new ArrayList<>();
storeBusinessEntities.stream().forEach(i ->{ storeBusinessEntities.stream().forEach(i -> {
// List<DictBiz> dictBizs = DictBizCache.getList(DictBizConstant.DISTRIBUTION_TYPE); if (i.getTypeService().contains(",")) {
if(i.getTypeService().contains(",")){
String[] split = i.getTypeService().split(","); String[] split = i.getTypeService().split(",");
for (int j = 0; j < split.length; j++) { for (int j = 0; j < split.length; j++) {
BasicdataStoreBusinessEntity business = new BasicdataStoreBusinessEntity(); BasicdataStoreBusinessEntity business = new BasicdataStoreBusinessEntity();
BeanUtil.copyProperties(i,business); BeanUtil.copyProperties(i, business);
int finalJ = j; int finalJ = j;
if(split[j].equals("配送")){ if (split[j].equals("配送")) {
switch ( business.getMold()){ switch (business.getMold()) {
case "商配": case "商配":
business.setMold("1"); business.setMold("1");
break; break;
@ -462,20 +476,20 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
break; break;
} }
}else{ } else {
business.setMold(null); business.setMold(null);
} }
log.info("#################split[finalJ]>>>>>>>>>>>>>>:{}",split[finalJ]); log.info("#################split[finalJ]>>>>>>>>>>>>>>:{}", split[finalJ]);
String dictValue = freightBiz.stream().filter(q -> q.getDictValue().equals(split[finalJ])).findFirst().get().getDictKey(); String dictValue = freightBiz.stream().filter(q -> q.getDictValue().equals(split[finalJ])).findFirst().get().getDictKey();
business.setTypeService(dictValue); business.setTypeService(dictValue);
list.add(business); list.add(business);
} }
}else{ } else {
String dictValue = freightBiz.stream().filter(q -> q.getDictValue().equals(i.getTypeService())).findFirst().get().getDictKey(); String dictValue = freightBiz.stream().filter(q -> q.getDictValue().equals(i.getTypeService())).findFirst().get().getDictKey();
i.setTypeService(dictValue); i.setTypeService(dictValue);
if(i.getTypeService().equals("配送")){ if (i.getTypeService().equals("配送")) {
String mold = i.getMold(); String mold = i.getMold();
switch (mold){ switch (mold) {
case "商配": case "商配":
i.setMold("1"); i.setMold("1");
break; break;
@ -490,7 +504,7 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
break; break;
} }
}else{ } else {
i.setMold(null); i.setMold(null);
} }
list.add(i); list.add(i);
@ -499,28 +513,28 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
basicdataStoreBusinessService.saveBatch(list); basicdataStoreBusinessService.saveBatch(list);
} }
//服务仓 //服务仓
if(!storageServicesEntities.isEmpty()){ if (!storageServicesEntities.isEmpty()) {
List<BasicdataStorageServicesEntity> servicesEntityList = new ArrayList<>(); List<BasicdataStorageServicesEntity> servicesEntityList = new ArrayList<>();
storageServicesEntities.stream().forEach(i ->{ storageServicesEntities.forEach(i -> {
if(ObjectUtils.isNotNull(i.getSendWarehouseName())){ if (ObjectUtils.isNotNull(i.getSendWarehouseName())) {
if( i.getSendWarehouseName().contains(",")){ if (i.getSendWarehouseName().contains(",")) {
String[] split = i.getSendWarehouseName().split(","); String[] split = i.getSendWarehouseName().split(",");
for (int j = 0; j < split.length; j++) { for (int j = 0; j < split.length; j++) {
BasicdataStorageServicesEntity servicesEntity = new BasicdataStorageServicesEntity(); BasicdataStorageServicesEntity servicesEntity = new BasicdataStorageServicesEntity();
Long id = list1.stream().filter(q -> q.getName().equals(i.getSendWarehouseName())).findFirst().get().getId(); Long id = list1.stream().filter(q -> q.getName().equals(i.getSendWarehouseName())).findFirst().get().getId();
BeanUtil.copyProperties(i,servicesEntity); BeanUtil.copyProperties(i, servicesEntity);
servicesEntity.setSendWarehouseId(id.toString()); servicesEntity.setSendWarehouseId(id.toString());
servicesEntity.setSendWarehouseName(split[j]); servicesEntity.setSendWarehouseName(split[j]);
servicesEntityList.add(servicesEntity); servicesEntityList.add(servicesEntity);
} }
}else{ } else {
Long id = list1.stream().filter(q -> q.getName().equals(i.getSendWarehouseName()) ).findFirst().get().getId(); Long id = list1.stream().filter(q -> q.getName().equals(i.getSendWarehouseName())).findFirst().get().getId();
i.setSendWarehouseId(id.toString()); i.setSendWarehouseId(id.toString());
servicesEntityList.add(i); servicesEntityList.add(i);
} }
}else{ } else {
BasicdataStorageServicesEntity servicesEntity = new BasicdataStorageServicesEntity(); BasicdataStorageServicesEntity servicesEntity = new BasicdataStorageServicesEntity();
BeanUtil.copyProperties(i,servicesEntity); BeanUtil.copyProperties(i, servicesEntity);
servicesEntityList.add(servicesEntity); servicesEntityList.add(servicesEntity);
} }
@ -528,19 +542,49 @@ public class BasicdataClientServiceImpl extends BaseServiceImpl<BasicdataClientM
basicdataStorageServicesService.saveBatch(servicesEntityList); basicdataStorageServicesService.saveBatch(servicesEntityList);
} }
//联系人 //联系人
if(!storeContactEntities.isEmpty()){ if (!storeContactEntities.isEmpty()) {
basicdataStoreContactService.saveBatch(storeContactEntities); basicdataStoreContactService.saveBatch(storeContactEntities);
} }
//三方 //三方
if(!tripartiteMallEntities.isEmpty()){ if (!tripartiteMallEntities.isEmpty()) {
basicdataTripartiteMallService.saveBatch(tripartiteMallEntities); basicdataTripartiteMallService.saveBatch(tripartiteMallEntities);
} }
} }
/**
* 匹配品牌
*
* @param basicdataBrandEntityList
* @param brandName
* @return
*/
private BasicdataBrandEntity matchBasicdataBrandEntityListValue(List<BasicdataBrandEntity> basicdataBrandEntityList, String brandName) {
for (BasicdataBrandEntity basicdataBrandEntity : basicdataBrandEntityList) {
if (basicdataBrandEntity.getBrandName().equals(brandName.trim())) {
return basicdataBrandEntity;
}
}
return null;
}
private String matchDictValue(List<DictBiz> list, String defaultPaymentMethods) {
for (DictBiz dictBiz : list) {
if (defaultPaymentMethods.equals(dictBiz.getDictValue())) {
return dictBiz.getDictKey();
}
}
return null;
}
@Override @Override
public List<JSONObject> findListByClientName(String clientName,String linkMan,String linkPhone) { public List<JSONObject> findListByClientName(String clientName, String linkMan, String linkPhone) {
List<ClientInfoVO> ls = baseMapper.findListByClientName(clientName,linkMan,linkPhone); List<ClientInfoVO> ls = baseMapper.findListByClientName(clientName, linkMan, linkPhone);
List<JSONObject> list = new ArrayList<>(); List<JSONObject> list = new ArrayList<>();
for (ClientInfoVO clientInfoVO : ls) { for (ClientInfoVO clientInfoVO : ls) {
list.add(JSONObject.parseObject(JSONObject.toJSONString(clientInfoVO))); list.add(JSONObject.parseObject(JSONObject.toJSONString(clientInfoVO)));

2
blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java

@ -118,4 +118,6 @@ public interface TrunklineCarsLoadScanMapper extends BaseMapper<TrunklineCarsLoa
List<String> findSignListOrderPackageCodes(@Param("loadId") Long loadId); List<String> findSignListOrderPackageCodes(@Param("loadId") Long loadId);
List<String> findSignListOrderPackageCodesByIds(@Param("list") List<Long> loadScanIds); List<String> findSignListOrderPackageCodesByIds(@Param("list") List<Long> loadScanIds);
List<Long> findAllIdListByLoadId(@Param("loadId") Long loadId);
} }

8
blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml

@ -537,4 +537,12 @@
</if> </if>
</select> </select>
<select id="findAllIdListByLoadId" resultType="Long">
select id
from logpm_trunkline_cars_load_scan
where 1=1
and load_id = #{loadId}
and scan_status = '1'
</select>
</mapper> </mapper>

4
blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineLoadSignOrderMapper.xml

@ -18,7 +18,8 @@
<select id="finaSignOrderList" resultType="com.logpm.trunkline.vo.TrunklineLoadSignOrderVO"> <select id="finaSignOrderList" resultType="com.logpm.trunkline.vo.TrunklineLoadSignOrderVO">
select ltlso.*, select ltlso.*,
ltcl.driver_name driverName ltcl.driver_name driverName,
ltcl.cars_no carsNo
from logpm_trunkline_load_sign_order ltlso from logpm_trunkline_load_sign_order ltlso
left join logpm_trunkline_cars_load ltcl on ltcl.id = ltlso.load_id left join logpm_trunkline_cars_load ltcl on ltcl.id = ltlso.load_id
<where> <where>
@ -61,6 +62,7 @@
ltcls.num num, ltcls.num num,
ltcls.unload_num unloadNum, ltcls.unload_num unloadNum,
ltcls.remark remak, ltcls.remark remak,
ltcls.load_code carsNo,
ltco.sign_order_id signOrderId ltco.sign_order_id signOrderId
from logpm_trunkline_cars_order ltco from logpm_trunkline_cars_order ltco
left join logpm_trunkline_cars_load_scan ltcls on ltco.load_id = ltcls.load_id and ltco.node_id = ltcls.warehouse_id and ltcls.order_code = ltco.order_code and ltcls.waybill_no = ltco.waybill_no left join logpm_trunkline_cars_load_scan ltcls on ltco.load_id = ltcls.load_id and ltco.node_id = ltcls.warehouse_id and ltcls.order_code = ltco.order_code and ltcls.waybill_no = ltco.waybill_no

1
blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadScanService.java

@ -114,4 +114,5 @@ public interface ITrunklineCarsLoadScanService extends BaseService<TrunklineCars
List<String> findSignListOrderPackageCodesByIds(List<Long> loadScanIds); List<String> findSignListOrderPackageCodesByIds(List<Long> loadScanIds);
List<Long> findAllIdListByLoadId(Long loadId);
} }

5
blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadScanServiceImpl.java

@ -278,4 +278,9 @@ public class TrunklineCarsLoadScanServiceImpl extends BaseServiceImpl<TrunklineC
return baseMapper.findSignListOrderPackageCodesByIds(loadScanIds); return baseMapper.findSignListOrderPackageCodesByIds(loadScanIds);
} }
@Override
public List<Long> findAllIdListByLoadId(Long loadId) {
return baseMapper.findAllIdListByLoadId(loadId);
}
} }

7
blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java

@ -664,8 +664,10 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
carsLoadEntity.setCancleUserName(AuthUtil.getUserName()); carsLoadEntity.setCancleUserName(AuthUtil.getUserName());
updateById(carsLoadEntity); updateById(carsLoadEntity);
//TODO 逻辑删除装车扫描表的数据 //逻辑删除装车扫描表的数据
List<Long> carsLoadScanIdList = trunklineCarsLoadScanService.findAllIdListByLoadId(loadId);
removeCarsLoadScan(StringUtil.join(carsLoadScanIdList, ","),warehouseId);
try { try {
trunklineCarsLoadLogService.saveLog(carsLoadEntity, currentCarsLoadLineEntity, CarsLoadLogTypeConstant.CANCEL_CARS_LOAD.getValue()); trunklineCarsLoadLogService.saveLog(carsLoadEntity, currentCarsLoadLineEntity, CarsLoadLogTypeConstant.CANCEL_CARS_LOAD.getValue());
@ -896,6 +898,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
currentCarsLoadLineEntity.setUnloadUserName(AuthUtil.getUserName()); currentCarsLoadLineEntity.setUnloadUserName(AuthUtil.getUserName());
currentCarsLoadLineEntity.setUnloadDate(new Date()); currentCarsLoadLineEntity.setUnloadDate(new Date());
trunklineCarsLoadLineService.updateById(currentCarsLoadLineEntity); trunklineCarsLoadLineService.updateById(currentCarsLoadLineEntity);
carsLoadEntity.setLoadStatus("80");
updateById(carsLoadEntity);
try { try {
carsLoadAsyncService.saveLog(carsLoadEntity, currentCarsLoadLineEntity, CarsLoadLogTypeConstant.END_UNLOAD_CARS_LOAD.getValue(), AuthUtil.getNickName(), AuthUtil.getUserId()); carsLoadAsyncService.saveLog(carsLoadEntity, currentCarsLoadLineEntity, CarsLoadLogTypeConstant.END_UNLOAD_CARS_LOAD.getValue(), AuthUtil.getNickName(), AuthUtil.getUserId());
openOrderAsyncService.saveUnloadStartCarLog(currentCarsLoadLineEntity, AuthUtil.getNickName(), AuthUtil.getUserId()); openOrderAsyncService.saveUnloadStartCarLog(currentCarsLoadLineEntity, AuthUtil.getNickName(), AuthUtil.getUserId());

Loading…
Cancel
Save