package common.service.impl;
import adi.dic.PackageEnum;
import adi.model.ADIUser;
import adi.service.ADIAccountService;
import common.model.*;
import common.repository.*;
import common.service.ContractService;
import common.service.UserService;
import dic.ContractStatusEnum;
import dic.ContractTypeEnum;
import dic.RoleEnum;
import org.joda.time.DateTime;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import tkio.model.Account;
import tkio.model.IncrementFlow;
import tkio.model.PackageType;
import tkio.repository.AccountRepository;
import tkio.repository.IncrementFlowRepository;
import tkio.repository.PackageTypeRepository;
import tkio.service.AccountService;
import tkio.service.TkioAccountService;
import userio.service.AccountIOService;
import userio.service.IOAccountService;
import util.*;
import java.beans.BeanInfo;
import java.beans.IntrospectionException;
import java.beans.Introspector;
import java.beans.PropertyDescriptor;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.util.*;
/**
* Created by mxq on 2018/1/16.
*/
@Service
public class ContractServiceImpl implements ContractService {
private static final Map<String, String> CONTRACT_TYPE = new HashMap() {{
put("0", "首次签约");
put("1", "续约");
put("2", "合同变更");
}};
public static final Map<String,String> FUNCTION_TYPE = new HashMap(){{
put("1","流量赠送");
put("2","合同变更记录");
put("3","收款/开票记录");
put("4","合同管理");
}};
@Autowired
ContractRepository contractRepository;
@Autowired
ContractBodyRepository contractBodyRepository;
@Autowired
Account4WebRepository account4WebRepository;
@Autowired
PackageTypeRepository packageTypeRepository;
@Autowired
PriceLevelMoneyRepository priceLevelMoneyRepository;
@Autowired
UserRepository userRepository;
@Autowired
ContractChangeRepository contractChangeRepository;
@Autowired
ContractMoneyRepository contractMoneyRepository;
@Autowired
AccountService accountService;
@Autowired
AccountIOService accountIOService;
@Autowired
IOAccount4WebRepository ioAccount4WebRepository;
@Autowired
ContractIncrementRepository contractIncrementRepository;
@Autowired
TkioAccountService tkioAccountService;
@Autowired
IOAccountService ioAccountService;
@Autowired
AccountRepository accountRepository;
@Autowired
UserService userService;
@Autowired
IncrementFlowRepository incrementFlowRepository;
@Autowired
BPUContractRepository bpuContractRepository;
@Autowired
ADIAccountService adiAccountService;
@Autowired
TradeTypeRepsitory tradeTypeRepsitory;
@Autowired
ContractRelationRepository contractRelationRepository;
@Autowired
FlowChangeRepository flowChangeRepository;
@Autowired
ChangeDelDetailRepository changeDelDetailRepository;
@Autowired
ChangeDelInfoRepository changeDelInfoRepository;
@Autowired
SalesRepository salesRepository;
@Override
public Map<String, Object> checkAccount(String email, String platfrom) {
Map<String, Object> map = new HashMap<>();
Account4Web account4Web = null;
IOAccount4Web ioAccount4Web = null;
ADIUser adiUser = null;
platfrom = "tkio";
if ("tkio".equals(platfrom)) {
account4Web = account4WebRepository.findByEmail(email);
} else if ("io".equals(platfrom)) {
ioAccount4Web = ioAccount4WebRepository.findByEmail(email);
} else if ("adi".equals(platfrom)) {
adiUser = adiAccountService.findOne(email);
}
if (null == account4Web && null == ioAccount4Web && null == adiUser) {
map.put("result", 0);
} else {
BigInteger integer = contractRepository.countNumByEmail(email, platfrom);
map.put("result", 1);
if (platfrom.equals("adi")) {
map.put("company", adiUser.getCompany());
} else {
map.put("company", null == account4Web ? ioAccount4Web.getCompany() : account4Web.getCompany());
}
map.put("num", integer.intValue());
Contract contract = contractRepository.findByPlatformAndEmailLimitVaild(platfrom, email);
if (null == contract) {
map.put("status", false);
} else {
map.put("status", true);
}
}
return map;
}
@Override
public Boolean checkTime(String email, String platfrom, String type, String product) {
Boolean flag = false;
if (ContractTypeEnum.MAIN.getKey().equals(type)) {
Contract contract = contractRepository.findByPlatformAndEmailLimit1(platfrom, email, type);
if (null == contract) {
flag = true;
} else {
String beforeDay = DateUtil.getBeforeDays(180);
if (beforeDay.compareTo(contract.getEndDate()) > 0) {
flag = true;
}
}
} else {
ContractIncrement increment = contractIncrementRepository.findByCode(product);
Contract contract = contractRepository.findByPlatformAndEmailAndPricelevelLimit1(platfrom, email, type, increment.getId());
if (null == contract) {
flag = true;
} else {
String beforeDay = DateUtil.getBeforeDays(180);
String endDate = contract.getEndDate() == null ? contract.getDs() : contract.getEndDate();
if (beforeDay.compareTo(endDate) > 0) {
flag = true;
}
}
}
return flag;
}
@Override
public List<ContractBody> findBody() {
return contractBodyRepository.findAll();
}
@Override
public String getContractCode(String code) {
BigInteger integer = contractRepository.countNumByDs(DateUtil.getBeforeDays(0));
String lastCode = "";
if (integer.intValue() < 9) {
lastCode = "0" + (integer.intValue() + 1);
} else {
lastCode = "" + (integer.intValue() + 1);
}
String re = code + "-" + DateUtil.getDays2(0) + lastCode;
return re;
}
@Override
public String getContractCode(String code, String platform, String company) {
// BigInteger countContract = contractRepository.findcountContract(code);
//
// String lastCode;
//
// if("fake".equals(platform)){
// platform = "FZBWS";
// }
//
// int codeInt = countContract.intValue();
//
// if (codeInt < 9) {
// lastCode = "0" + (codeInt + 1);
// } else {
// lastCode = "" + (codeInt + 1);
// }
// return code + "-" + platform.toUpperCase() + "-" + DateUtil.getDays2(0) + "-" + lastCode;
String codeName = contractRepository.findLastCode(code);
if("fake".equals(platform)){
platform = "FZBWS";
}
int codeInt = 0;
if (!StringUtils.isEmpty(codeName)) {
String[] codeformat = codeName.split("-");
if (codeformat.length == 4) {
codeInt = Integer.parseInt(codeformat[3]);
}
}
String lastCode;
if (codeInt < 9) {
lastCode = "0" + (codeInt + 1);
} else {
lastCode = "" + (codeInt + 1);
}
return code + "-" + platform.toUpperCase() + "-" + DateUtil.getDays2(0) + "-" + lastCode;
}
@Override
public List findSetmeal(String platform) {
platform = "tkio";
List list = new ArrayList();
if ("adi".equals(platform)) {
for (int i = 1; i < 3; i++) {
Map<String, String> packageMap = new HashMap<>();
packageMap.put("id", i + "");
if (i == 1) {
packageMap.put("packageName", PackageEnum.PROBATION.getValue());
} else {
packageMap.put("packageName", PackageEnum.FORMAL.getValue());
}
list.add(packageMap);
}
} else {
if ("tkio".equals(platform) || "io".equals(platform)) {
// List<PackageType> packageTypeList = packageTypeRepository.findAll();
List<PackageType> packageTypeList = packageTypeRepository.findIsNewAll();
for (PackageType p : packageTypeList) {
p.setType("main");
list.add(p);
}
// 增值套餐
// List<ContractIncrement> increments = contractIncrementRepository.findAll();
// list.addAll(increments);
} else if ("userdesk".equals(platform) || "dmp".equals(platform) || "fake".equals(platform)) {
list = bpuContractRepository.findByProduct(platform);
}
}
return list;
}
@Override
public List<ContractIncrement> findIncrement() {
return null;
}
@Override
public Double getRebat(String product, Integer level, Long money) {
Double rebat = 1d;
try {
PriceLevelMoney levelMoney = priceLevelMoneyRepository.getOne(product, level);
rebat = money * 1.0 / levelMoney.getMoney();
} catch (Exception e) {
e.printStackTrace();
}
return rebat;
}
@Override
public List<Sales> getSales() {
return salesRepository.findAllByStatusOn();
}
@Override
public Contract build(Contract contract) {
User user = userRepository.findByEmail(contract.getSaleName());
if (null != user) {
contract.setSale(user.getId());
}
contract.setVirtual(true);
Account account = accountRepository.findByEmail(contract.getEmail());
contract.setCustomerBody(account.getCompany());
contract.setType("increment");
contract.setPlatform("tkio");
contract.setStartDate(DateUtil.getBeforeDays(0));
ContractIncrement contractIncrement = contractIncrementRepository.findByCode(contract.getPriceLevelName());
contract.setPriceLevel(contractIncrement.getId());
Contract contract1 = create(null, contract);
return contract1;
}
@Override
public Contract create(User loginUser, Contract resource) {
if (resource == null) {
return null;
}
Contract contractExist = contractRepository.findByCode(resource.getContractCode());
if (contractExist != null) {
contractExist = new Contract();
// 合同编号已存在
contractExist.setId(-100L);
contractExist.setErroMessage("合同编号已存在");
return contractExist;
}
resource.setInvoice(0L);
Long extraFlow = resource.getExtraFlow();
if(extraFlow==null){
extraFlow = 0L;
}
if(resource.getPayMoney()==null){
resource.setPayMoney(0L);
}
resource.setDs(DateUtil.getBeforeDays(0));
this.saveIncrementFlow(resource,extraFlow);
this.dealContractStatus(resource,loginUser,"save");
if (resource.getRelationContract() == null) {
resource.setRelationContract(-1L);
}
if (null != loginUser) {
resource.setCreateAccount(loginUser.getId());
resource.setCreateName(loginUser.getName());
}
resource.setCreateTime(new Date());
//同步修改trackingio的数据
// if (resource.getPlatform().equals("tkio") && resource.getType().equals("main")) {
// accountService.update(resource);
// }
// if (resource.getPlatform().equals("io") && resource.getType().equals("main")) {
// accountIOService.update(resource);
// }
// if (resource.getPlatform().equals("adi")) {
// adiAccountService.updateAccount(resource);
// }
resource = contractRepository.save(resource);
this.saveContractRelations(resource,resource.getId());
return resource;
}
private void saveIncrementFlow( Contract resource, Long extraFlow){
if (resource.getType().equals("main")) {
if (resource.getPlatform().equals("tkio")) {
if (!(extraFlow.longValue() == 0)) {
if (resource.getPlatform().equals("tkio")) {
IncrementFlow flow = new IncrementFlow();
Account account = accountRepository.findByEmail(resource.getEmail());
flow.setAccount(account.getId());
flow.setFlow(extraFlow);
flow.setEndDate(resource.getEndDate());
flow.setStartDate(resource.getStartDate());
flow.setContractCode(resource.getContractCode());
incrementFlowRepository.save(flow);
}
}
}
}
}
private void saveContractRelations(Contract resource,Long contractId){
if (resource.getRelationContract() != null && resource.getRelationContract() > 0) {
//保存关联合同信息
ContractRelation relation = new ContractRelation();
relation.setCreateTime(new Date());
relation.setMainContract(contractId);
relation.setRelationId(resource.getRelationContract());
relation.setPlatform(resource.getPlatform());
ContractRelation relationOrig = contractRelationRepository.findByRelationData(relation.getMainContract(),relation.getRelationId(),resource.getPlatform());
if(relationOrig==null){
contractRelationRepository.save(relation);
}
//处理被关联 合同
Contract contract = contractRepository.findOne(resource.getRelationContract());
if (contract.getRelationContract() == null || contract.getRelationContract() == -1) {
contract.setRelationContract(contractId);
contract.setRelationCode(resource.getContractCode());
contractRepository.save(contract);
}
//设置关联编号
resource.setRelationCode(contract.getContractCode());
}
}
public Contract create_bak(User loginUser, Contract resource) {
if (resource == null) {
return null;
}
Contract contractExist = contractRepository.findByCodePlatform(resource.getContractCode(), resource.getPlatform());
if (contractExist != null) {
// 合同编号已存在
return null;
}
// 老的逻辑
String contractCode = getContractCode(resource.getMyBodyCode());
if (!contractCode.equals(resource.getContractCode())) {
resource.setContractCode(contractCode);
}
resource.setPayMoney(0L);
resource.setInvoice(0L);
Long extraFlow = resource.getExtraFlow();
resource.setDs(DateUtil.getBeforeDays(0));
if (resource.getType().equals("main")) {
if (resource.getPlatform().equals("tkio")) {
if (!(extraFlow.longValue() == 0)) {
if (resource.getPlatform().equals("tkio")) {
IncrementFlow flow = new IncrementFlow();
Account account = accountRepository.findByEmail(resource.getEmail());
flow.setAccount(account.getId());
flow.setFlow(extraFlow);
flow.setEndDate(resource.getEndDate());
flow.setStartDate(resource.getStartDate());
flow.setContractCode(resource.getContractCode());
incrementFlowRepository.save(flow);
}
}
}
if (DateUtil.getBeforeDays(0).compareTo(resource.getStartDate()) < 0) {
resource.setDs(DateUtil.getBeforeDays(0));
resource.setStatus("wait");
} else {
resource.setDs(DateUtil.getBeforeDays(0));
resource.setStatus("executing");
}
} else {
// resource.setDs(DateUtil.getBeforeDays(0));
// resource.setStatus("wait");
}
// if (resource.getRebateMoney() != null) {
// if (resource.getMoney() == null) {
// resource.setMoney(0L);
// }
//
// if (resource.getRebateMoney().compareTo(BigDecimal.ZERO) < 0) {
// //未回款
// resource.setStatus(ContractStatusEnum.MONEY_BACK_NONE.getKey());
//
// }else if(resource.getRebateMoney().compareTo(new BigDecimal(resource.getMoney()+""))< 0){
// // 部分回款
// resource.setStatus(ContractStatusEnum.MONEY_BACK_PART.getKey());
// }else{
// // 已回款
// resource.setStatus(ContractStatusEnum.MONEY_BACK_ALL.getKey());
// }
//
// } else {
// //未回款
// resource.setStatus(ContractStatusEnum.MONEY_BACK_NONE.getKey());
// }
Double rebat = null;
if (null != resource.getPriceLevel()) {
rebat = getRebat(resource.getProduct(), resource.getPriceLevel().intValue(), resource.getMoney());
} else {
rebat = getRebat(resource.getProduct(), 0, resource.getMoney());
}
BigDecimal bg = new BigDecimal(rebat);
double f1 = bg.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
resource.setRebate(f1);
if (null != loginUser) {
resource.setCreateAccount(loginUser.getId());
resource.setCreateName(loginUser.getName());
}
resource.setCreateTime(new Date());
//同步修改trackingio的数据
if (resource.getPlatform().equals("tkio") && resource.getType().equals("main")) {
accountService.update(resource);
}
if (resource.getPlatform().equals("io") && resource.getType().equals("main")) {
accountIOService.update(resource);
}
if (resource.getPlatform().equals("adi")) {
adiAccountService.updateAccount(resource);
}
if (resource.getType().equals(ContractTypeEnum.MAIN.getKey())
|| (resource.getType().equals(ContractTypeEnum.INCREMENT.getKey()) && resource.getPriceLevel().equals(1L))) {
List<Contract> contractList = contractRepository.findByPlatformAndEmail(resource.getPlatform(), resource.getEmail(), resource.getType());
if (ValidateUtil.isValid(contractList)) {
List<Contract> list = new ArrayList<>();
for (Contract contract : contractList) {
if (contract.getType().equals(ContractTypeEnum.MAIN.getKey())
|| (contract.getType().equals(ContractTypeEnum.INCREMENT.getKey()) && contract.getPriceLevel().equals(1L))) {
if (contract.getStatus().equals(ContractStatusEnum.EXECUTING.getKey())
|| contract.getStatus().equals(ContractStatusEnum.WAIT.getKey())) {
contract.setStatus(ContractStatusEnum.CANCEL.getKey());
}
list.add(contract);
}
}
contractRepository.save(contractList);
}
}
resource = contractRepository.save(resource);
if (resource.getRelationContract() != null && resource.getRelationContract() > 0) {
//保存关联合同信息
ContractRelation relation = new ContractRelation();
relation.setCreateTime(new Date());
relation.setMainContract(resource.getId());
relation.setRelationId(resource.getRelationContract());
relation.setPlatform(resource.getPlatform());
contractRelationRepository.save(relation);
}
return resource;
}
@Override
public Contract update(User loginUser, Contract resource, String ip) {
Contract contract = contractRepository.findOne(resource.getId());
if(!contract.getContractCode().equals(resource.getContractCode())){
Contract contractExist = contractRepository.findByCode(resource.getContractCode());
if (contractExist != null) {
// 合同编号已存在
contractExist = new Contract();
contractExist.setId(-100L);
contractExist.setErroMessage("合同编号已存在");
return contractExist;
}
}
this.dealContractStatus(resource,loginUser,"update");
this.saveContractRelations(resource,contract.getId());
ChangeDelInfo delInfo = new ChangeDelInfo();
delInfo.setModifyId(loginUser.getId());
delInfo.setModifyAccount(loginUser.getName());
delInfo.setEmail(contract.getEmail());
delInfo.setDs(new DateTime().toString("yyyy-MM-dd"));
delInfo.setModifyType(2);
delInfo.setContractCode(contract.getContractCode());
delInfo.setCreatTime(new Date());
delInfo.setFunction(4);
delInfo.setDetail("修改详情");
delInfo.setIp(ip);
List<ChangeDelDetail> updateFields = this.changeDelInfoForContract(contract,resource,delInfo.getId(),"");
if (updateFields != null && updateFields.size() > 0) {
changeDelInfoRepository.save(delInfo);
for (ChangeDelDetail delDetail : updateFields) {
delDetail.setParentId(delInfo.getId());
}
changeDelDetailRepository.save(updateFields);
}
resource.setCreateName(contract.getCreateName());
resource.setCreateAccount(contract.getCreateAccount());
resource.setCreateTime(contract.getCreateTime());
resource.setDs(contract.getDs());
resource.setProduct(contract.getProduct());
resource.setModifyTime(new Date());
if (null != loginUser) {
resource.setModifyAccount(loginUser.getId());
}
resource.setId(contract.getId());
return contractRepository.save(resource);
}
private List<ChangeDelDetail> changeDelInfoForContract(Contract byfind, Contract resource, Long pid, String ip){
List<ChangeDelDetail> delDetailsList = new ArrayList<>();
String contractCode = byfind.getContractCode();
this.dealChangeInfoDetail(byfind.getCustomerBody(),resource.getCustomerBody(),
"客户签约主体","customerBody",pid,delDetailsList,byfind);
this.dealChangeInfoDetail(byfind.getCustomerShort(),resource.getCustomerShort(),
"客户简称","customerShort",pid,delDetailsList,byfind);
this.dealChangeInfoDetail(byfind.getCustomerThird(),resource.getCustomerThird(),
"第三方签约主体","customerThird",pid,delDetailsList,byfind);
if (byfind.getTradeType() != resource.getTradeType()) {
List<TradeType> types = tradeTypeRepsitory.findByTwoId(byfind.getTradeType(), resource.getTradeType());
this.dealChangeInfoDetail(types.get(0).getName(), types.get(1).getName(),
"行业分类", "tradeType", pid, delDetailsList,byfind);
}
this.dealChangeInfoDetail(byfind.getStartDate(),resource.getStartDate(),
"合同开始日期","startDate",pid,delDetailsList,byfind);
this.dealChangeInfoDetail(byfind.getEndDate(),resource.getEndDate(),
"合同结束日期","startDate",pid,delDetailsList,byfind);
if (byfind.getSale() != resource.getSale()) {
List<Sales> sales = salesRepository.findByTwoId(byfind.getSale(),resource.getSale());
this.dealChangeInfoDetail(sales.get(0).getName(),sales.get(1).getName(),
"签约销售","sale",pid,delDetailsList,byfind);
}
this.dealChangeInfoDetail(byfind.getExtraFlow()==null?"":byfind.getExtraFlow().toString(),
resource.getExtraFlow()==null?"":resource.getExtraFlow().toString(),
"赠送流量","extraFlow",pid,delDetailsList,byfind);
this.dealChangeInfoDetail(byfind.getEmail(),resource.getEmail(),
"客户主账号","startDate",pid,delDetailsList,byfind);
this.dealChangeInfoDetail(CONTRACT_TYPE.get(byfind.getContractType()),
CONTRACT_TYPE.get(resource.getContractType()),
"签约类型","startDate",pid,delDetailsList,byfind);
// if(byfind.getPriceLevel()!=null && !byfind.getPriceLevel().equals(resource.getPriceLevel())){
// List<PackageType> packageTypes = packageTypeRepository.findByTwoId(byfind.getPriceLevel(),resource.getPriceLevel());
// this.dealChangeInfoDetail(packageTypes.get(0).getPackageName(),packageTypes.get(1).getPackageName(),
// "套餐","priceLevel",pid,delDetailsList,byfind);
// }
// this.dealChangeInfoDetail(byfind.getMoney()==null?"":byfind.getMoney().toString(),
// resource.getMoney()==null?"":resource.getMoney().toString(),
// "合同金额","money",pid,delDetailsList,contractCode);
//
// this.dealChangeInfoDetail(byfind.getPayMoney()==null?"":byfind.getPayMoney().toString(),
// resource.getPayMoney()==null?"":resource.getPayMoney().toString(),
// "回款金额","payMoney",pid,delDetailsList,contractCode);
//
// this.dealChangeInfoDetail(byfind.getInvoiceMoney()==null?"":byfind.getInvoiceMoney().toString(),
// resource.getInvoiceMoney()==null?"":resource.getInvoiceMoney().toString(),
// "发票金额","invoiceMoney",pid,delDetailsList,contractCode);
this.dealChangeInfoDetail(byfind.getDiscountTimeLong()==null?"":byfind.getDiscountTimeLong().toString(),
resource.getDiscountTimeLong()==null?"":resource.getDiscountTimeLong().toString(),
"赠送时长","discountTimeLong",pid,delDetailsList,byfind);
return delDetailsList;
}
private void dealChangeInfoDetail(String before, String now,String delDetailinfo,String fildeName,
Long pid,List<ChangeDelDetail> delDetails,Contract contract) {
ChangeDelDetail delDetail = new ChangeDelDetail();
delDetail.setFiledName(fildeName);
delDetail.setDetail(delDetailinfo);
delDetail.setCreatTime(new Date());
delDetail.setItem("合同修改");
delDetail.setParentId(pid);
delDetail.setContractCode(contract.getContractCode());
delDetail.setEmail(contract.getEmail());
if (before != null && !before.equals(now)) {
delDetail.setBeforeValue(before);
delDetail.setAfterValue(now == null ? "" : now);
delDetails.add(delDetail);
} else {
if (now != null && !now.equals(before)) {
delDetail.setBeforeValue(before == null ? "" : before);
delDetail.setAfterValue(now);
delDetails.add(delDetail);
}
}
}
public Contract update_bak(User loginUser, Contract resource) {
// Map<Long, String> packageMap = getPackageMap();
// Map<Long, String> saleMap = getSaleMap();
// Contract contract = contractRepository.findOne(resource.getId());
//
// ContractChange cc = new ContractChange();
// cc.setType("update");
// cc.setUser(loginUser.getId());
// cc.setDs(DateUtil.getBeforeDays(0));
// cc.setContent("");
// cc.setEmail(contract.getEmail());
// cc.setCompany(contract.getCustomerBody());
// cc.setContractCode(contract.getContractCode());
// this.dealContractStatus(resource,loginUser,"update");
// if (!resource.getStartDate().equals(contract.getStartDate())) {
// cc.setContent(cc.getContent() + "开始时间变更 : " + contract.getStartDate() + "-->" + resource.getStartDate());
// contract.setStartDate(resource.getStartDate());
//// if(DateUtil.getBeforeDays(0).compareTo(resource.getStartDate()) < 0){
//// contract.setStatus("wait");
//// }else{
//// contract.setStatus("executing");
//// }
// }
// if (!resource.getEndDate().equals(contract.getEndDate())) {
// cc.setContent(cc.getContent() + " 结束时间变更 : " + contract.getEndDate() + "-->" + resource.getEndDate());
// contract.setEndDate(resource.getEndDate());
// }
//
// boolean newRebat = false;
// if (contract.getType().equals(ContractTypeEnum.MAIN.getKey()) && null != resource.getPriceLevel()) {
// if (!resource.getPriceLevel().equals(contract.getPriceLevel())) {
// cc.setContent(cc.getContent() + " 套餐变更：" + packageMap.get(contract.getPriceLevel()) + "-->" + packageMap.get(resource.getPriceLevel()));
// newRebat = true;
// contract.setPriceLevel(resource.getPriceLevel());
// }
// }
//
// if (!resource.getMoney().equals(contract.getMoney())) {
// cc.setContent(cc.getContent() + " 金额变更： " + contract.getMoney() + "-->" + resource.getMoney());
// newRebat = true;
// contract.setMoney(resource.getMoney());
// }
//
// if (!resource.getRebateMoney().equals(contract.getRebateMoney())) {
// cc.setContent(cc.getContent() + " 回款金额变更： " + contract.getMoney() + "-->" + resource.getMoney());
// newRebat = true;
// contract.setMoney(resource.getMoney());
// }
//
// if (!resource.getSale().equals(contract.getSale())) {
// cc.setContent(cc.getContent() + "销售变更：" + saleMap.get(contract.getSale()) + "-->" + saleMap.get(resource.getSale()));
// contract.setSale(resource.getSale());
// }
//
//// if (newRebat && !"adi".equals(contract.getPlatform())) {
//// Double rebat = getRebat(contract.getProduct(), contract.getPriceLevel().intValue(), contract.getMoney());
//// BigDecimal bg = new BigDecimal(rebat);
//// double f1 = bg.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
////// contract.setRebate(f1);
//// }
//
// if (!resource.getSale().equals(contract.getSale())) {
// cc.setContent(cc.getContent() + "销售变更：" + saleMap.get(contract.getSale()) + "-->" + saleMap.get(resource.getSale()));
// contract.setSale(resource.getSale());
// }
// cc.setPlatform(contract.getPlatform());
// contractChangeRepository.save(cc);
//同步修改trackingio的数据
// if (contract.getPlatform().equals("tkio") && resource.getType().equals("main")) {
// accountService.update(contract);
// }
// if (contract.getPlatform().equals("io") && resource.getType().equals("main")) {
// accountIOService.update(contract);
// }
// if (contract.getPlatform().equals("adi")) {
// adiAccountService.updateAccount(contract);
// }
// if (contract.getPlatform().equals("tkio")) {
// if (contract.getType().equals("main")) {
// IncrementFlow flow = incrementFlowRepository.findOne(resource.getContractCode());
// if (null != flow) {
// flow.setEndDate(resource.getEndDate());
// flow.setStartDate(resource.getStartDate());
// if (contract.getExtraFlow() != resource.getExtraFlow()) {
// flow.setFlow(resource.getExtraFlow());
// incrementFlowRepository.save(flow);
// }
// } else if (resource.getExtraFlow().longValue() > 0) {
// IncrementFlow flow1 = new IncrementFlow();
// Account account = accountRepository.findByEmail(contract.getEmail());
// flow1.setAccount(account.getId());
// flow1.setFlow(resource.getExtraFlow());
// flow1.setEndDate(resource.getEndDate());
// flow1.setStartDate(resource.getStartDate());
// flow1.setContractCode(resource.getContractCode());
// incrementFlowRepository.save(flow1);
// }
// }
//
// }
// contract.setStatus(resource.getStatus());
// contract.setExtraFlow(resource.getExtraFlow());
// contract.setTradeType(resource.getTradeType());
// contract.setInvoiceMoney(resource.getInvoiceMoney());
// contract.setRelationContract(resource.getRelationContract());
// contract.setRebateMoney(resource.getRebateMoney());
// contract.setDiscountTimeLong(resource.getDiscountTimeLong());
//
// contract.setModifyTime(new Date());
// if (null != loginUser) {
// resource.setModifyAccount(loginUser.getId());
// }
//
//
// this.saveContractRelations(resource,contract.getId());
//
// return contractRepository.save(contract);
return null;
}
private void dealContractStatus(Contract resource,User loginUser,String type){
if (resource.getPayMoney() != null) {
if (resource.getMoney() == null) {
resource.setMoney(0L);
}
if (resource.getPayMoney().longValue() <= 0) {
//未回款
resource.setStatus(ContractStatusEnum.MONEY_BACK_NONE.getKey());
}else if(resource.getPayMoney().longValue() < resource.getMoney().longValue()){
// 部分回款
resource.setStatus(ContractStatusEnum.MONEY_BACK_PART.getKey());
//记录收款记录
ContractMoney money = new ContractMoney();
money.setType("pay");
saveContractMoney(money,loginUser,resource,type);
}else{
// 已回款
resource.setStatus(ContractStatusEnum.MONEY_BACK_ALL.getKey());
ContractMoney money = new ContractMoney();
money.setType("pay");
saveContractMoney(money,loginUser,resource,type);
}
} else {
//未回款
resource.setStatus(ContractStatusEnum.MONEY_BACK_NONE.getKey());
}
if (resource.getPayMoney() == null) {
resource.setPayMoney(0L);
}
if (resource.getInvoiceMoney() == null) {
resource.setInvoiceMoney(new BigDecimal(0));
}else{
// 记录发票记录
ContractMoney money = new ContractMoney();
money.setType("invoice");
saveContractMoney(money,loginUser,resource,type);
}
if (resource.getDiscountTimeLong() == null) {
resource.setDiscountTimeLong(0L);
}
if (resource.getExtraFlow() == null) {
resource.setExtraFlow(0L);
}
if(resource.getDiscountTimeLong()> 0 || resource.getExtraFlow()> 0){
//记录优惠信息
saveFlowChange(resource,loginUser,type, resource.getDiscountTimeLong(), resource.getExtraFlow());
}
//处理合同编号
resource.setCodeNum(Integer.parseInt(resource.getContractCode().split("-")[3]));
}
//保存开票收款记录
private void saveContractMoney(ContractMoney money,User loginUser,Contract contract,String type){
if(!"save".equals(type)){
return;
}
if (money.getType().equals("pay")) {
money.setMoney(contract.getMoney());
} else {
money.setMoney(contract.getInvoiceMoney().longValue());
}
money.setCompany(contract.getMyBodyName());
money.setContractCode(contract.getContractCode());
money.setPlatform(contract.getPlatform());
money.setEmail(contract.getEmail());
money.setPlatform(contract.getPlatform());
money.setCreateAccount(loginUser.getId());
money.setCreateTime(new Date());
money.setUser(loginUser.getId());
money.setCreateName(loginUser.getName());
money.setDs(new DateTime().toString("yyyy-MM-dd"));
contractMoneyRepository.save(money);
}
// 保存优惠流量 优惠时长 记录
private void saveFlowChange(Contract contract, User loginUser, String type, Long discountTimeLong, Long extraFlow){
if(!"save".equals(type)){
return;
}
FlowChange change = new FlowChange();
change.setDiscountFlow(extraFlow);
change.setDiscountTimeLong(discountTimeLong);
change.setAddDate(new DateTime().toString("yyyy-MM-dd"));
change.setAddTime(new Date());
change.setCompany(contract.getMyBodyName());
change.setContractCode(contract.getContractCode());
change.setDelFlag(0);
change.setEmail(contract.getEmail());
change.setModifyUname(loginUser.getName());
change.setModifyUser(loginUser.getId());
flowChangeRepository.save(change);
}
/**
*
* @param loginAccount
* @param startDate
* @param endDate
* @param platform
* @param contractId 用于 获取关联合同列表
* @return
*/
@Override
public List<Contract> findAll(User loginAccount, String startDate, String endDate, String platform, String contractId) {
List<Contract> result = new ArrayList<>();
List<User> sales = userRepository.findAll();
Map<Long, String> saleMap = new HashMap<>();
if (ValidateUtil.isValid(sales)) {
for (User s : sales) {
saleMap.put(s.getId(), s.getName());
}
}
List<PackageType> typeList = packageTypeRepository.findAll();
Map<Long, String> typeMap = new HashMap<>();
if (ValidateUtil.isValid(typeList)) {
for (PackageType s : typeList) {
typeMap.put(s.getId(), s.getPackageName());
}
}
List<ContractIncrement> incrementList = contractIncrementRepository.findAll();
Map<Long, String> incremenMap = new HashMap<>();
if (ValidateUtil.isValid(incrementList)) {
for (ContractIncrement s : incrementList) {
incremenMap.put(s.getId(), s.getPackageName());
}
}
List<BPUContract> bpuContractList = bpuContractRepository.findAll();
Map<Long, String> bpuMap = new HashMap<>();
if (ValidateUtil.isValid(bpuContractList)) {
for (BPUContract s : bpuContractList) {
bpuMap.put(s.getId(), s.getPackageName());
}
}
List<String> platforms = new ArrayList<>();
Map<String,String> idsDic = new HashMap<>();
platforms.add(platform);
if (!StringUtils.isEmpty(contractId)) {
//获取 关联合同列表
List<String> conIds = new ArrayList<>();
conIds.add(contractId);
this.getContractRelationIds(conIds,idsDic);
idsDic.remove(contractId);
if("fake".equals(platform)){
platforms.add("tkio");
}
}
List<Contract> contractList = new ArrayList<>();
List<String> ids = new ArrayList<>(idsDic.keySet());
if (loginAccount.getRole().equals(RoleEnum.SOUTH_BUSSINUSS.getKey()) || loginAccount.getRole().equals(RoleEnum.NORTH_BUSSINUSS.getKey())) {
List<User> userList = userService.findAllSons(loginAccount.getId());
List<Long> idList = new ArrayList<>();
idList.add(loginAccount.getId());
for (User u : userList) {
idList.add(u.getId());
}
// contractList = contractRepository.findByDsAndRoile(startDate, endDate, platfrom, idList);
if(!StringUtils.isEmpty(contractId)){
//查看关联合同
if (ids != null && ids.size() > 0) {
contractList = contractRepository.findByDsAndRoileRelation(startDate, endDate, platforms, idList, ids);
}
}else{
contractList = contractRepository.findByDsAndRoile(startDate, endDate, platform, idList);
}
} else {
// contractList = contractRepository.findByDs(startDate, endDate, platform);
if(!StringUtils.isEmpty(contractId)){
if (ids != null && ids.size() > 0) {
contractList = contractRepository.findByDsRelation(startDate, endDate, platforms, ids);
}
}else{
contractList = contractRepository.findByDs(startDate, endDate, platform);
}
}
if (ValidateUtil.isValid(contractList)) {
for (Contract c : contractList) {
if ((c.getExtraFlow() != null && c.getExtraFlow() > 0) ||
(c.getDiscountTimeLong() != null && c.getDiscountTimeLong() > 0)) {
c.setHasDiscount("有");
} else {
c.setHasDiscount("无");
}
if(c.getRelationContract()==null){
c.setRelationContract(-1L);
}
c.setSaleName(saleMap.containsKey(c.getSale()) ? saleMap.get(c.getSale()) : "");
c.setPriceLevelName(typeMap.containsKey(c.getPriceLevel()) ? typeMap.get(c.getPriceLevel()) : "");
// if (c.getType().equals(ContractTypeEnum.MAIN.getKey()) && platform.contains("io")) {
//
// } else if (c.getType().equals(ContractTypeEnum.MAIN.getKey())) {
// c.setPriceLevelName(bpuMap.containsKey(c.getPriceLevel()) ? bpuMap.get(c.getPriceLevel()) : "");
// } else {
// c.setPriceLevelName(incremenMap.containsKey(c.getPriceLevel()) ? incremenMap.get(c.getPriceLevel()) : "");
// }
c.setCreateName(saleMap.containsKey(c.getCreateAccount()) ? saleMap.get(c.getCreateAccount()) : "");
result.add(c);
}
}
return result;
}
private void getContractRelationIds (List<String> contractId,Map<String,String> idsDic){
//获取 关联合同 id
List<String> contractIds = new ArrayList<>();
List<BigInteger> ids = contractRelationRepository.findRelationIds(contractId);
if (ids != null && ids.size() > 0) {
for(BigInteger id : ids){
String idss = id.toString();
if (idsDic.get(idss) == null) {
contractIds.add(idss);
idsDic.put(idss,"0");
}
}
if(contractIds.size()>0){
//递归 查询 id 查询所有相关联的合同
this.getContractRelationIds(contractIds,idsDic);
}
}
}
@Override
public Contract contractStatusUpdate(String platform, String contractId, String status, String ip, User loginUser) {
if (StringUtils.isEmpty(contractId)) {
return null;
}
Contract contract = contractRepository.findOne(Long.parseLong(contractId));
ChangeDelInfo changeDelInfo = new ChangeDelInfo();
changeDelInfo.setContractCode(contract.getContractCode());
changeDelInfo.setEmail(contract.getEmail());
changeDelInfo.setEmail(contract.getEmail());
if (ContractStatusEnum.CANCEL.getKey().equals(status)) {
contract.setStatus(status);
changeDelInfo.setDetail("废弃合同");
this.saveChangeDelInfo(changeDelInfo,4,2,ip,loginUser); // type 2 修改
} else {
contract.setStatus(ContractStatusEnum.DELETE.getKey());
changeDelInfo.setDetail("删除合同");
this.saveChangeDelInfo(changeDelInfo,4,1,ip,loginUser);
}
return contractRepository.save(contract);
}
@Override
public Contract findOne(String code) {
List<Contract> result = new ArrayList<>();
List<User> sales = userRepository.findAll();
Map<Long, String> saleMap = new HashMap<>();
if (ValidateUtil.isValid(sales)) {
for (User s : sales) {
saleMap.put(s.getId(), s.getName());
}
}
List<PackageType> typeList = packageTypeRepository.findAll();
Map<Long, String> typeMap = new HashMap<>();
if (ValidateUtil.isValid(typeList)) {
for (PackageType s : typeList) {
typeMap.put(s.getId(), s.getPackageName());
}
}
List<ContractIncrement> incrementList = contractIncrementRepository.findAll();
Map<Long, String> incremenMap = new HashMap<>();
if (ValidateUtil.isValid(incrementList)) {
for (ContractIncrement s : incrementList) {
incremenMap.put(s.getId(), s.getPackageName());
}
}
Contract contract = contractRepository.findByCode(code);
contract.setSaleName(saleMap.containsKey(contract.getSale()) ? saleMap.get(contract.getSale()) : "");
if (contract.getType().equals(ContractTypeEnum.MAIN.getKey())) {
contract.setPriceLevelName(typeMap.containsKey(contract.getPriceLevel()) ? typeMap.get(contract.getPriceLevel()) : "");
} else {
contract.setPriceLevelName(incremenMap.containsKey(contract.getPriceLevel()) ? incremenMap.get(contract.getPriceLevel()) : "");
}
contract.setCreateName(saleMap.containsKey(contract.getCreateAccount()) ? saleMap.get(contract.getCreateAccount()) : "");
Boolean flag = null;
if (!contract.getType().equals(ContractTypeEnum.MAIN.getKey())) {
//人群分析
if (null == contract.getEndDate()) {
flag = checkTime(contract.getEmail(), contract.getPlatform(), contract.getType(), "black");
} else {
flag = checkTime(contract.getEmail(), contract.getPlatform(), contract.getType(), "analysis");
}
if (flag) {
contract.setContractType("0");
} else {
contract.setContractType("1");
}
}
return contract;
}
@Override
public ContractMoney pay(User loginUser, ContractMoney resource) {
Contract contract = contractRepository.findByCode(resource.getContractCode());
if (resource.getType().equals("pay")) {
contract.setPayMoney(contract.getPayMoney()+resource.getMoney());
//判断回款状态
this.dealContractStatus(contract,loginUser,"update");
} else {
contract.setInvoiceMoney(contract.getInvoiceMoney().add(new BigDecimal(resource.getMoney().toString())) );
}
if (contract.getType().equals(ContractTypeEnum.INCREMENT.getKey())) {
contract.setStatus("end");
}
contractRepository.save(contract);
resource.setPlatform(contract.getPlatform());
resource.setCreateAccount(loginUser.getId());
resource.setCreateTime(new Date());
resource.setUser(loginUser.getId());
// if (resource.getType().equals("pay") && contract.getPlatform().equals("tkio")) {
// tkioAccountService.contractPay(loginUser, resource);
// } else if (resource.getType().equals("pay") && contract.getPlatform().equals("io")) {
// ioAccountService.contractPay(loginUser, resource);
// }
return contractMoneyRepository.save(resource);
}
@Override
public Contract change(User loginUser, ContractChange resource, FlowChange flowChange) {
Map<Long, String> packageMap = getPackageMap();
Map<Long, String> saleMap = getSaleMap();
Contract contract = contractRepository.findByCode(resource.getContractCode());
// ChangeDelInfo changeDelInfo = new ChangeDelInfo();
// changeDelInfo.setContractCode(contract.getContractCode());
// changeDelInfo.setEmail(contract.getEmail());
if (resource.getType().equals("price")) {
resource.setContent(packageMap.get(contract.getPriceLevel())+"改为"+packageMap.get(resource.getLevel()));
resource.setMarke(contract.getMoney()+"元改为"+resource.getMoney()+"元");
contract.setMoney(resource.getMoney());
contract.setPriceLevel(resource.getLevel());
// 处理回款状态
this.dealContractStatus(contract,loginUser,"update");
}else if("give".equals(resource.getType())){
//变更优惠记录
this.saveFlowChange(contract,loginUser,"save",resource.getDiscountTimeLong(),resource.getExtraFlow());
// 累加 合同表中数据
if(resource.getExtraFlow()!=null){
contract.setExtraFlow(contract.getExtraFlow()+resource.getExtraFlow());
}
if(resource.getDiscountTimeLong()!=null){
contract.setDiscountTimeLong(contract.getDiscountTimeLong()+resource.getDiscountTimeLong());
}
} else {
// //同步修改trackingio的数据
// if (contract.getPlatform().equals("tkio") && contract.getType().equals("main")) {
// accountService.forbiden(contract);
// } else if (contract.getPlatform().equals("io") && contract.getType().equals("main")) {
// accountIOService.update(contract);
// }
//状态变更
resource.setContent("作废");
contract.setStatus("cancel");
}
resource.setPlatform(contract.getPlatform());
resource.setCreateAccount(loginUser.getId());
resource.setCreateTime(new Date());
resource.setDs(DateUtil.getBeforeDays(0));
resource.setUser(loginUser.getId());
if(!"give".equals(resource.getType())){
contractChangeRepository.save(resource);
}
return contractRepository.save(contract);
}
@Override
public Object changesDel(String platform, String id, String type, String ip, User loginUser) {
if("give".equals(type)){
// 优惠流量
FlowChange change = flowChangeRepository.findOne(Long.parseLong(id));
change.setDelFlag(1);
flowChangeRepository.save(change);
ChangeDelInfo changeDelInfo = new ChangeDelInfo();
changeDelInfo.setContractCode(change.getContractCode());
changeDelInfo.setEmail(change.getEmail());
changeDelInfo.setDetail("赠送时长:"+change.getDiscountTimeLong()+"天 — 赠送流量"+ change.getDiscountFlow());
this.saveChangeDelInfo(changeDelInfo,1,1,ip,loginUser);
return change;
}else if("change".equals(type)){
//套餐变更
ContractChange contractChange = contractChangeRepository.findOne(Long.parseLong(id));
contractChange.setDelFlag(1);
contractChangeRepository.save(contractChange);
ChangeDelInfo changeDelInfo = new ChangeDelInfo();
changeDelInfo.setContractCode(contractChange.getContractCode());
changeDelInfo.setDetail("套餐变更");
changeDelInfo.setEmail(contractChange.getEmail());
this.saveChangeDelInfo(changeDelInfo,2,1,ip,loginUser);
return contractChange;
}else{
ContractMoney contractMoney = contractMoneyRepository.findOne(Long.parseLong(id));
contractMoney.setDelFlag(1);
contractMoneyRepository.save(contractMoney);
ChangeDelInfo changeDelInfo = new ChangeDelInfo();
changeDelInfo.setContractCode(contractMoney.getContractCode());
changeDelInfo.setEmail(contractMoney.getEmail());
if("pay".equals(contractMoney.getType())){
// 删除收款记录 修改相应收款金额
Contract contract = contractRepository.findByCode(contractMoney.getContractCode());
contract.setPayMoney(contract.getPayMoney()-contractMoney.getMoney());
contractRepository.save(contract);
changeDelInfo.setDetail("收款记录-金额:"+contractMoney.getMoney());
}else{
changeDelInfo.setDetail("开票记录-金额:"+contractMoney.getMoney());
}
this.saveChangeDelInfo(changeDelInfo,3,1,ip,loginUser);
return contractMoney;
}
}
@Override
public List<ChangeDelInfo> getChangeDelData(User loginAccount, String contranctCode, String startDate, String endDate) {
List<ChangeDelInfo> datas = changeDelInfoRepository.findOnStartDate(startDate,endDate);
return datas;
}
@Override
public List<ChangeDelDetail> getChangeDelDetailData(User loginAccount, String pid) {
List<ChangeDelDetail> datas = changeDelDetailRepository.findByPid(pid);
return datas;
}
public void saveChangeDelInfo(ChangeDelInfo changeDelInfo, int function, int type, String ip, User loginUser){
changeDelInfo.setCreatTime(new Date());
changeDelInfo.setFunction(function);// 1 赠送记录
changeDelInfo.setModifyType(type);// 1 删除
changeDelInfo.setIp(ip);
changeDelInfo.setDs(new DateTime().toString("yyyy-MM-dd"));
changeDelInfo.setModifyAccount(loginUser.getName());
changeDelInfo.setModifyId(loginUser.getId());
changeDelInfoRepository.save(changeDelInfo);
}
@Override
public List<ContractMoney> findPay(String startDate, String endDate, String code) {
List<User> sales = userRepository.findAll();
Map<Long, String> saleMap = new HashMap<>();
if (ValidateUtil.isValid(sales)) {
for (User s : sales) {
saleMap.put(s.getId(), s.getName());
}
}
List<ContractMoney> result = new ArrayList<>();
List<ContractMoney> list = contractMoneyRepository.findByDs(startDate, endDate, code);
if (ValidateUtil.isValid(list)) {
for (ContractMoney cm : list) {
cm.setCreateName(saleMap.containsKey(cm.getUser()) ? saleMap.get(cm.getUser()) : "");
result.add(cm);
}
}
return result;
}
@Override
public List<ContractChange> findChange(String startDate, String endDate, String code) {
List<User> sales = userRepository.findAll();
Map<Long, String> saleMap = new HashMap<>();
if (ValidateUtil.isValid(sales)) {
for (User s : sales) {
saleMap.put(s.getId(), s.getName());
}
}
List<ContractChange> result = new ArrayList<>();
List<ContractChange> list = contractChangeRepository.findByDs(startDate, endDate, code);
if (ValidateUtil.isValid(list)) {
for (ContractChange cm : list) {
cm.setCreateName(saleMap.containsKey(cm.getUser()) ? saleMap.get(cm.getUser()) : "");
result.add(cm);
}
}
return result;
}
@Override
public List<FlowChange> findflowChange(String startDate, String endDate, String code) {
return flowChangeRepository.findByAddDate(startDate, endDate, code);
}
@Override
public Contract updatePay(User loginUser, ContractMoney resource, String ip) {
ContractMoney contractMoney = contractMoneyRepository.findOne(resource.getId());
Contract contract = contractRepository.findByCode(resource.getContractCode());
ChangeDelInfo changeDelInfo = new ChangeDelInfo();
ChangeDelDetail delDetail = new ChangeDelDetail();
delDetail.setBeforeValue(contractMoney.getMoney().toString());
delDetail.setAfterValue(resource.getMoney().toString());
if (contractMoney.getType().equals("pay")) {
contract.setPayMoney(contract.getPayMoney() + resource.getMoney() - contractMoney.getMoney());
delDetail.setItem("收款");
delDetail.setDetail("收款金额");
} else {
// contract.setInvoice(contract.getInvoice() + resource.getMoney() - contractMoney.getMoney());
contract.setInvoiceMoney(contract.getInvoiceMoney().add(new BigDecimal(resource.getMoney())).subtract(new BigDecimal(contractMoney.getMoney())));
delDetail.setItem("开票");
delDetail.setDetail("开票金额");
}
changeDelInfo.setDetail("修改详情");//
changeDelInfo.setContractCode(contractMoney.getContractCode());
changeDelInfo.setEmail(contractMoney.getEmail());
this.saveChangeDelInfo(changeDelInfo,3,2,ip,loginUser);
delDetail.setCreatTime(new Date());
delDetail.setContractCode(contractMoney.getContractCode());
delDetail.setEmail(contractMoney.getEmail());
delDetail.setParentId(changeDelInfo.getId());
changeDelDetailRepository.save(delDetail);
Contract save = contractRepository.save(contract);
contractMoney.setModifyAccount(loginUser.getId());
contractMoney.setModifyTime(new Date());
contractMoney.setMoney(resource.getMoney());
// contractMoney.setDs(resource.getDs());
contractMoneyRepository.save(contractMoney);
List<User> sales = userRepository.findAll();
Map<Long, String> saleMap = new HashMap<>();
if (ValidateUtil.isValid(sales)) {
for (User s : sales) {
saleMap.put(s.getId(), s.getName());
}
}
List<PackageType> typeList = packageTypeRepository.findAll();
Map<Long, String> typeMap = new HashMap<>();
if (ValidateUtil.isValid(typeList)) {
for (PackageType s : typeList) {
typeMap.put(s.getId(), s.getPackageName());
}
}
save.setSaleName(saleMap.containsKey(save.getSale()) ? saleMap.get(save.getSale()) : "");
save.setPriceLevelName(typeMap.containsKey(save.getPriceLevel()) ? typeMap.get(save.getPriceLevel()) : "");
save.setCreateName(saleMap.containsKey(save.getSale()) ? saleMap.get(save.getSale()) : "");
return save;
}
@Override
public List<ContractMoney> findPayAll(String startDate, String endDate, String platfrom) {
List<User> sales = userRepository.findAll();
Map<Long, String> saleMap = new HashMap<>();
if (ValidateUtil.isValid(sales)) {
for (User s : sales) {
saleMap.put(s.getId(), s.getName());
}
}
List<ContractMoney> result = new ArrayList<>();
List<ContractMoney> list = contractMoneyRepository.findByDsAll(startDate, endDate, platfrom);
if (ValidateUtil.isValid(list)) {
for (ContractMoney cm : list) {
cm.setCreateName(saleMap.containsKey(cm.getUser()) ? saleMap.get(cm.getUser()) : "");
result.add(cm);
}
}
return result;
}
@Override
public List<TradeType> getTradeData(String platform) {
return tradeTypeRepsitory.findAll();
}
@Override
public List<Map> contractCodeAll(String platform, String contractId) {
Map<String,String> data = new HashMap<>();
data.put("id","-1");
data.put("contractCode","无");
List result = new ArrayList();
result.add(data);
List<String> plats = new ArrayList<>();
plats.add(platform);
if("fake".equals(platform)){
plats.add("tkio");
}
List<ContractRelation> ids = null;
Contract contract = null;
if(!StringUtils.isEmpty(contractId) && !contractId.equals("null")){
ids = contractRelationRepository.findRelationIdsMain(contractId);
contract = contractRepository.findOne(Long.parseLong(contractId));
}
if (ids != null) {
// 已关联合同 字典
Map<String,String> filterMap = new HashMap();
for(ContractRelation relation : ids){
if(contract!=null && !relation.getRelationId().equals(contract.getRelationContract())){
filterMap.put(relation.getRelationId()+"_","");
}
}
// 所有可关联合同
List<Map> resultBefore = contractRepository.contractCodePlatform(plats);
for (Map m : resultBefore) {
String m_id = m.get("id").toString() + "_";
if (filterMap.get(m_id) == null && !m_id.equals(contractId+"_")) {
result.add(m);
}
}
} else {
result.addAll(contractRepository.contractCodePlatform(plats));
}
return result;
}
@Override
public Map contractCodeCheck(String platform, String contractCode) {
Contract contractExist = contractRepository.findByCodePlatform(contractCode, platform);
Map<String,String> data = new HashMap<>();
if(contractExist!=null){
data.put("exist","true");
}else{
data.put("exist","false");
}
return data;
}
public Map<Long, String> getPackageMap() {
// List<PackageType> typeList = packageTypeRepository.findAll();
List<PackageType> typeList = packageTypeRepository.findIsNewAll();
Map<Long, String> typeMap = new HashMap<>();
if (ValidateUtil.isValid(typeList)) {
for (PackageType s : typeList) {
typeMap.put(s.getId(), s.getPackageName());
}
}
return typeMap;
}
public Map<Long, String> getSaleMap() {
List<User> sales = userRepository.findAll();
Map<Long, String> saleMap = new HashMap<>();
if (ValidateUtil.isValid(sales)) {
for (User s : sales) {
saleMap.put(s.getId(), s.getName());
}
}
return saleMap;
}
public static Map<String, String> convertBean(Object bean) throws IntrospectionException, IllegalArgumentException, IllegalAccessException, InvocationTargetException {
Class type = bean.getClass();
Map<String, String> returnMap = new HashMap<String, String>();
BeanInfo beanInfo = Introspector.getBeanInfo(type);
PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
for (int i = 0; i < propertyDescriptors.length; i++) {
PropertyDescriptor descriptor = propertyDescriptors[i];
String propertyName = descriptor.getName();
if (!propertyName.equals("class")) {
Method readMethod = descriptor.getReadMethod();
Object invoke = readMethod.invoke(bean, new Object[0]);
String result = (null == invoke ? null : invoke.toString());
if (result != null) {
returnMap.put(propertyName, result);
} else {
returnMap.put(propertyName, null);
}
}
}
return returnMap;
}
}