package com.deloitte.system.service;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.alibaba.fastjson.JSONArray;
|
import com.common.core.constant.GlobalConst;
|
import com.common.core.enums.ResultCodeEnum;
|
import com.common.core.exception.BizException;
|
import com.common.core.service.CryptoService;
|
import com.common.core.utils.BeanHelper;
|
import com.common.core.utils.DesensitiveUtils;
|
import com.common.core.utils.IdUtils;
|
import com.common.redis.util.RedisUtil;
|
import com.deloitte.system.model.CacheList;
|
import com.deloitte.system.model.Opportunity;
|
import com.deloitte.system.model.Order;
|
import com.deloitte.system.request.OpportunityDto;
|
import com.deloitte.system.request.OrderDto;
|
import com.jfinal.plugin.activerecord.Db;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import static com.common.core.constant.GlobalConst.PIPL_UNCONFIRM_INSERT;
|
import static com.common.core.constant.GlobalConst.PIPL_UNCONFIRM_UPDATE;
|
|
@Service
|
public class OrderService {
|
private String tableName = "order";
|
|
@Autowired
|
private CryptoService cryptoService;
|
|
@Autowired
|
private IdUtils idWorker;
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
public OrderDto queryForOne(String dataId) {
|
Order order = Order.dao.findById(dataId);
|
if (!ObjectUtil.isEmpty(order)) {
|
return BeanHelper.copyAs(order,OrderDto.class);
|
}
|
return null;
|
}
|
|
public List<OrderDto> insertList(List<OrderDto> orderList, String txId) {
|
List<OrderDto> respList = new ArrayList<>();
|
CacheList<OrderDto> dtoCacheList = new CacheList<>();
|
dtoCacheList.setTableName(tableName);
|
List<OrderDto> dtoItemList = new ArrayList<>();
|
orderList.forEach(e -> {
|
String dataId = idWorker.nextId();
|
OrderDto cacheItem = BeanHelper.copyAs(e, OrderDto.class);
|
cacheItem.setDataId(dataId);
|
dtoItemList.add(cacheItem);
|
|
OrderDto target = BeanHelper.copyAs(e, OrderDto.class);
|
target.setDataId(dataId);
|
OrderDto dto = cryptoService.encryptModelColumns(e);
|
dto.setDataId(dataId);
|
cryptoService.convertor(dto,target);
|
DesensitiveUtils.format(target);
|
respList.add(target);
|
});
|
dtoCacheList.setData(dtoItemList);
|
String insertJsonString = JSONArray.toJSONString(dtoCacheList);
|
String insertKey = PIPL_UNCONFIRM_INSERT + txId;
|
boolean redisFlag = redisUtil.set(insertKey, insertJsonString, GlobalConst.DATA_EXPIRE);
|
if (!redisFlag) {
|
throw new BizException("缓存写入失败");
|
}
|
return respList;
|
}
|
|
public List<OrderDto> updateList(List<OrderDto> orderList, String txId) {
|
List<OrderDto> respList = new ArrayList<>();
|
CacheList<OrderDto> dtoCacheList = new CacheList<>();
|
dtoCacheList.setTableName(tableName);
|
List<OrderDto> dtoItemList = new ArrayList<>();
|
orderList.forEach(e -> {
|
Order order = Order.dao.findById(e.getDataId());
|
OrderDto cacheItem = BeanHelper.copyAs(e, OrderDto.class);
|
dtoItemList.add(cacheItem);
|
OrderDto dto = BeanHelper.copyAs(BeanHelper.copy(cacheItem,order),OrderDto.class);
|
OrderDto target = BeanHelper.copyAs(dto, OrderDto.class);
|
dto = cryptoService.encryptModelColumns(dto);
|
target.setSpecialDeliveryPhoneEncrypt(dto.getSpecialDeliveryPhone());
|
target.setSpecialDeliveryPhoneDEncrypt(dto.getSpecialDeliveryPhoneD());
|
target.setShippingRecieverEmailAdrEncrypt(dto.getShippingRecieverEmailAdr());
|
target.setShipToContactIdEncrypt(dto.getShipToContactId());
|
target.setCustomerAuthorizedByIdEncrypt(dto.getCustomerAuthorizedById());
|
target.setBillToContactIdEncrypt(dto.getBillToContactId());
|
target.setSpecialDeliveryContact2Encrypt(dto.getSpecialDeliveryContact2());
|
target.setSpecialDeliveryContactTextEncrypt(dto.getSpecialDeliveryContact());
|
target.setShippingAddressTextEncrypt(dto.getShippingAddressText());
|
target.setSpecialDeliveryContact2DEncrypt(dto.getSpecialDeliveryContact2D());
|
target.setEndUserEncrypt(dto.getEndUser());
|
target.setEndUserDEncrypt(dto.getEndUserD());
|
target.setSpecialDeliveryContactEncrypt(dto.getSpecialDeliveryContact());
|
target.setSpecialDeliveryContactDEncrypt(dto.getSpecialDeliveryContactD());
|
target.setPdfNNotifyPartyEncrypt(dto.getPdfNNotifyParty());
|
target.setPdfNFaxEncrypt(dto.getPdfNFax());
|
target.setPdfNContactEncrypt(dto.getPdfNContact());
|
target.setPdfSTelEncrypt(dto.getPdfSTel());
|
target.setPdfSPhoneEncrypt(dto.getPdfSPhone());
|
target.setPdfSNameEncrypt(dto.getPdfSName());
|
target.setPdfSFaxEncrypt(dto.getPdfSFax());
|
target.setPdfFTelEncrypt(dto.getPdfFTel());
|
target.setPdfFFaxEncrypt(dto.getPdfFFax());
|
target.setPdfFContactPersonEncrypt(dto.getPdfFContactPerson());
|
target.setPdfSAddsEncrypt(dto.getPdfSAdds());
|
target.setPdfSAddressEncrypt(dto.getPdfSAddress());
|
target.setPdfSellerEncrypt(dto.getPdfSeller());
|
target.setPdfCTheconsigneEncrypt(dto.getPdfCTheconsigne());
|
target.setPdfCTelEncrypt(dto.getPdfCTel());
|
target.setPdfCFaxEncrypt(dto.getPdfCFax());
|
target.setPdfCConsigneeEncrypt(dto.getPdfCConsignee());
|
target.setPdfCContactEncrypt(dto.getPdfCContact());
|
target.setPdfCAddrEncrypt(dto.getPdfCAddr());
|
target.setSpecialDeliveryAddressEncrypt(dto.getSpecialDeliveryAddress());
|
target.setSpecialDeliveryAddressDEncrypt(dto.getSpecialDeliveryAddressD());
|
target.setDealerSalesStaffNameAEncrypt(dto.getDealerSalesStaffNameA());
|
target.setPdfSignTitleEncrypt(dto.getPdfSignTitle());
|
target.setPdfSignNameEncrypt(dto.getPdfSignName());
|
target.setPdfSignaturePlacesEncrypt(dto.getPdfSignaturePlaces());
|
target.setPdfByTelEncrypt(dto.getPdfByTel());
|
target.setPdfByAddEncrypt(dto.getPdfByAdd());
|
DesensitiveUtils.format(target);
|
respList.add(target);
|
});
|
dtoCacheList.setData(dtoItemList);
|
String updateJsonString = JSONArray.toJSONString(dtoCacheList);
|
String updateKey = PIPL_UNCONFIRM_UPDATE + txId;
|
boolean redisFlag = redisUtil.set(updateKey, updateJsonString,GlobalConst.DATA_EXPIRE);
|
if (!redisFlag) {
|
throw new BizException("缓存写入失败");
|
}
|
return respList;
|
}
|
|
public Boolean deleteOne(String dataId) {
|
Order order = Order.dao.findById(dataId);
|
order.setIsDelete(1);
|
return order.saveOrUpdate();
|
}
|
|
public Boolean undeleteOne(String dataId) {
|
Order order = Order.dao.findById(dataId);
|
order.setIsDelete(0);
|
return order.saveOrUpdate();
|
}
|
|
public List<OrderDto> search(List<String> idList){
|
if (CollUtil.isEmpty(idList)) {
|
return null;
|
}
|
StringBuilder queryParam = new StringBuilder();
|
queryParam.append("and id in ").append(idList.stream().collect(Collectors.joining(", ", "(", ")")));
|
List<Order> quotesList = Order.dao.findList(queryParam.toString());
|
return quotesList.stream()
|
.map(quotes -> BeanHelper.copyAs(quotes, OrderDto.class)).collect(Collectors.toList());
|
|
}
|
|
public List<OrderDto> decryptUpdate(List<OrderDto> orderList) {
|
List<OrderDto> respList =new ArrayList<>();
|
String[] decryptColumn =new String[]{"expected_delivery_date","sales_account_code","special_delivery_address","dealer_service_d","dealer_service","dealer_sales_staff_name_d","dealer_sales_staff_name"};
|
Db.tx(() -> {
|
for (OrderDto e : orderList) {
|
Order order =Order.dao.findById(e.getDataId());
|
if (order == null) {
|
throw new BizException("无效的DataId");
|
}
|
Order item=new Order();
|
BeanHelper.copyEncrypt(e, item);
|
cryptoService.decryptoColumnModel(item,decryptColumn);
|
BeanHelper.copyEncrypt(item, order);
|
order.setSfRecordId(e.getSfRecordId());
|
if (!order.saveOrUpdate()) {
|
throw new BizException(ResultCodeEnum.RT_ERROR);
|
}
|
|
respList.add(e);
|
}
|
return true;
|
});
|
return respList;
|
}
|
|
|
public List<OrderDto> decryptInsert(List<OrderDto> orderList) {
|
List<OrderDto> respList =new ArrayList<>();
|
Db.tx(() -> {
|
for (OrderDto e : orderList) {
|
Order order = new Order();
|
String dataId =idWorker.nextId();
|
BeanHelper.copyEncrypt(e, order);
|
cryptoService.decryptoModel(order);
|
order.setSfRecordId(e.getSfRecordId());
|
order.setDataId(Long.valueOf(dataId));
|
if(!order.save()) {
|
throw new BizException(ResultCodeEnum.RT_ERROR);
|
}
|
e.setDataId(dataId);
|
respList.add(e);
|
}
|
return true;
|
});
|
return respList;
|
}
|
|
}
|
