|
|
@@ -32,6 +32,8 @@ import org.springblade.purchase.sales.entity.BidingAgent;
|
|
|
import org.springblade.purchase.sales.entity.BidingItems;
|
|
|
import org.springblade.purchase.sales.mapper.BidingMapper;
|
|
|
import org.springblade.purchase.sales.service.IBidingService;
|
|
|
+import org.springblade.system.feign.IDictBizClient;
|
|
|
+import org.springblade.system.feign.ISysClient;
|
|
|
import org.springblade.system.user.entity.User;
|
|
|
import org.springblade.system.user.feign.IUserClient;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
@@ -61,6 +63,8 @@ public class BidingServiceImpl extends ServiceImpl<BidingMapper, Biding> impleme
|
|
|
private final IUserClient userClient;//获得用户信息
|
|
|
private ICorpsAttnClient corpsAttnClient;//客户联系人
|
|
|
private final IWechatClient wechatClient;//微信
|
|
|
+ private final IDictBizClient dictBizClient;//业务字典
|
|
|
+ private final ISysClient sysClient;//获得岗位信息
|
|
|
|
|
|
/**
|
|
|
* 获得标书详情
|
|
|
@@ -218,6 +222,7 @@ public class BidingServiceImpl extends ServiceImpl<BidingMapper, Biding> impleme
|
|
|
biding.setTenantId(SecureUtil.getTenantId());
|
|
|
biding.setCreateUser(AuthUtil.getUserId());
|
|
|
biding.setCreateTime(new Date());
|
|
|
+ biding.setCreateDept(Long.valueOf(AuthUtil.getDeptId()));
|
|
|
baseMapper.insert(biding);
|
|
|
}else {//id不为空修改单据
|
|
|
biding.setTenantId(SecureUtil.getTenantId());
|
|
|
@@ -341,6 +346,31 @@ public class BidingServiceImpl extends ServiceImpl<BidingMapper, Biding> impleme
|
|
|
if (com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(auditPathsLevels)) {
|
|
|
throw new SecurityException("开启审批失败:未查询到审批信息");
|
|
|
}
|
|
|
+
|
|
|
+ if (ObjectUtil.isNotEmpty(salesBiding.getLine())){
|
|
|
+ //根据航线编号获得航线名称
|
|
|
+ R<String> lineName = dictBizClient.getValue("dominant_route", salesBiding.getLine());
|
|
|
+ if (lineName.isSuccess() && lineName.getData() != null){
|
|
|
+ //根据航线名称获得岗位
|
|
|
+ R<String> postIds = sysClient.getPostIds(AuthUtil.getTenantId(), lineName.getData());
|
|
|
+ if (postIds.isSuccess() && postIds.getData() != null){
|
|
|
+ //获得当前请核人的岗位
|
|
|
+ R<User> user = userClient.userInfoById(AuthUtil.getUserId());
|
|
|
+ if (user.isSuccess() && user.getData() != null){
|
|
|
+ if (!user.getData().getPostId().contains(postIds.getData())){
|
|
|
+ throw new SecurityException("当前请核人岗位没有该航线,无法请核");
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ throw new SecurityException("用户信息异常,请联系管理员");
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ throw new SecurityException("岗位信息异常,请联系管理员");
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ throw new SecurityException("航线异常,请维护航线");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
//修改订单信息
|
|
|
AuditProecessDTO auditProecessDTO = new AuditProecessDTO();
|
|
|
// 绑定审核类型
|