|
|
@@ -3,6 +3,7 @@ package com.sckw.manage.service;
|
|
|
import java.io.IOException;
|
|
|
import java.util.Date;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.github.pagehelper.PageHelper;
|
|
|
import com.github.pagehelper.PageInfo;
|
|
|
@@ -41,6 +42,8 @@ import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
+
|
|
|
+import javax.json.JsonObject;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
@@ -196,36 +199,39 @@ public class KwmCooperateManageService {
|
|
|
Long userId = LoginUserHolder.getUserId();
|
|
|
Date date = new Date();
|
|
|
//判断是否可以解除-销售订单
|
|
|
- Boolean order = tradeOrderInfoService.associateEnt(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviteeEntId());
|
|
|
+ Boolean order = tradeOrderInfoService.associateEnt(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviterEntId());
|
|
|
if (order)
|
|
|
{
|
|
|
throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_031);
|
|
|
}
|
|
|
|
|
|
//判断是否可以解除-托运和承运
|
|
|
- HttpResult response = transportDubboService.checkLogisticsOrderIsFinishByEntId(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviteeEntId());
|
|
|
- Object receivedResult = response.getData();
|
|
|
- if (receivedResult != null)
|
|
|
+ HttpResult response = transportDubboService.checkLogisticsOrderIsFinishByEntId(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviterEntId());
|
|
|
+ log.info("getInviteeEntId-{}",kwmCooperates.get(0).getInviteeEntId());
|
|
|
+ log.info("getInviterEntId-{}",kwmCooperates.get(0).getInviterEntId());
|
|
|
+ log.info("aaaaa-{}",JSONObject.toJSONString(response));
|
|
|
+ Integer receivedResult = response.getCode();
|
|
|
+ if (!receivedResult.toString().equals(String.valueOf(HttpStatus.SUCCESS_CODE)))
|
|
|
{
|
|
|
- throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_031);
|
|
|
+ throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_032);
|
|
|
}
|
|
|
- Map<OrderEnum, List<String>> ledgerMap = paymentDubboService.checkLedger(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviteeEntId());
|
|
|
+ Map<OrderEnum, List<String>> ledgerMap = paymentDubboService.checkLedger(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviterEntId());
|
|
|
if (!CollectionUtils.isEmpty(ledgerMap.get(OrderEnum.LOGISTICS)))
|
|
|
{
|
|
|
- throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_031);
|
|
|
+ throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_034);
|
|
|
}
|
|
|
if (!CollectionUtils.isEmpty(ledgerMap.get(OrderEnum.TRADE)))
|
|
|
{
|
|
|
- throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_031);
|
|
|
+ throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_034);
|
|
|
}
|
|
|
- Map<OrderEnum,List<String>> settlementMap= paymentDubboService.checkSettlement(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviteeEntId());
|
|
|
+ Map<OrderEnum,List<String>> settlementMap= paymentDubboService.checkSettlement(kwmCooperates.get(0).getInviteeEntId(),kwmCooperates.get(0).getInviterEntId());
|
|
|
if (!CollectionUtils.isEmpty(settlementMap.get(OrderEnum.LOGISTICS)))
|
|
|
{
|
|
|
- throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_031);
|
|
|
+ throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_034);
|
|
|
}
|
|
|
if (!CollectionUtils.isEmpty(settlementMap.get(OrderEnum.TRADE)))
|
|
|
{
|
|
|
- throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_031);
|
|
|
+ throw new SystemException(HttpStatus.CRUD_FAIL_CODE, HttpStatus.MSG_034);
|
|
|
}
|
|
|
kwmCooperates.forEach(item -> {
|
|
|
//运营端可以操作任意状态,企业端只能操作合作中的数据
|