package com.gk.firework.Service.ServiceImpl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gk.firework.Domain.*;
|
import com.gk.firework.Domain.BO.SaleOrderDetailInfoBO;
|
import com.gk.firework.Domain.Enum.ErrorCode;
|
import com.gk.firework.Domain.Exception.BusinessException;
|
import com.gk.firework.Domain.Utils.Msg;
|
import com.gk.firework.Domain.Utils.PageInfo;
|
import com.gk.firework.Domain.Utils.StringUtils;
|
import com.gk.firework.Domain.Vo.*;
|
import com.gk.firework.Mapper.SaleOrderDetailInfoMapper;
|
import com.gk.firework.Mapper.SaleOrderInfoMapper;
|
import com.gk.firework.Mapper.UserInfoMapper;
|
import com.gk.firework.Service.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.text.DateFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.time.Instant;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
import static com.gk.firework.Domain.Vo.EntryUtils.RK_ENTRY;
|
import static com.gk.firework.Domain.Vo.EntryUtils.TH_ENTRY;
|
|
/**
|
* @author : jingjy
|
* @date : 2021/3/30 17:30
|
*/
|
@Service("SaleOrderService")
|
public class SaleOrderServiceImpl extends ServiceImpl<SaleOrderInfoMapper, SaleOrderInfo> implements SaleOrderService {
|
@Autowired
|
private UserInfoMapper userInfoMapper;
|
@Autowired
|
private SaleOrderInfoMapper saleOrderInfoMapper;
|
@Autowired
|
private SaleOrderService saleOrderService;
|
@Autowired
|
private SaleOrderDetailService saleOrderDetailService;
|
@Autowired
|
private CustomerService customerService;
|
@Autowired
|
private StockService stockService;
|
@Autowired
|
private SaleOrderDetailInfoMapper saleOrderDetailInfoMapper;
|
@Autowired
|
private ProductService productService;
|
@Autowired
|
private UserService userService;
|
@Autowired
|
private EnterpriseService enterpriseService;
|
@Autowired
|
private EntryService entryService;
|
@Autowired
|
private DistrictService districtService;
|
@Autowired
|
private DeliveryDetailService deliveryDetailService;
|
|
@Value("${hostId}")
|
private String hostId;
|
|
private static final String RETAIL_ORDER = "1";
|
private static final String GROUP_ORDER = "2";
|
private static final String NORMAL_DELIVERY = "1";
|
public static final String OTHER_DELIVERY = "2";
|
static final String MODULE_ENTRY = "入库";
|
public static final String MODULE_DELIVERY = "出库";
|
private static final String MODULE_SALE = "销售";
|
|
@Override
|
public SaleOrderInfo createOrder(UserInfo userInfo, List<SaleOrderDetailInfoBO> detailInfoList, String type, Integer num,
|
Date salesTime, Long customerId, String pay, String total, String change, String auth) {
|
//TODO:添加订单信息及订单详情信息
|
SaleOrderInfo orderInfo = new SaleOrderInfo();
|
orderInfo.setCode(generateOrderCode(MODULE_SALE,type,new Date(),userInfo.getId()));
|
orderInfo.setType(Byte.parseByte(type));
|
orderInfo.setCreatedat(salesTime);
|
orderInfo.setCreatedby(userInfo.getUsername());
|
orderInfo.setBoxnum(new BigDecimal(num));
|
orderInfo.setPay(new BigDecimal(pay));
|
orderInfo.setChange(new BigDecimal(change));
|
orderInfo.setSalesperson(userInfo.getUsername());
|
orderInfo.setTotalprice(new BigDecimal(total));
|
orderInfo.setShop(userInfo.getCompany());
|
orderInfo.setCompanynumber(userInfo.getCompanynumber());
|
orderInfo.setCustomer(customerId);
|
for (SaleOrderDetailInfo detailInfo : detailInfoList){
|
detailInfo.setOrdercode(orderInfo.getCode());
|
detailInfo.setCreatedat(salesTime);
|
detailInfo.setCreatedby(userInfo.getUsername());
|
}
|
saleOrderService.save(orderInfo);
|
saleOrderDetailService.saveBatchOrderDetailInfo(detailInfoList.stream().map(item -> (SaleOrderDetailInfo) item).collect(Collectors.toList()));
|
|
return orderInfo;
|
}
|
|
@Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
|
@Override
|
public Msg doSalesProcess(JSONObject customer, Integer num, String idCardNum, UserInfo userInfo,
|
List<SaleOrderDetailInfoBO> detailInfoList, String type, Date salesTime,
|
String pay, String total, String change, String auth) {
|
|
Msg msg = new Msg();
|
msg.setCode("200");
|
CustomerInfo customerInfo;
|
// 身份证表 存入和更新
|
try {
|
customerInfo = customerService.createOrUpdate(customer, num, salesTime);
|
} catch (ParseException e) {
|
throw new BusinessException("时间解析错误");
|
}
|
|
// CustomerInfo customerInfo = customerService.getCustomerByIdCardNum(idCardNum);
|
|
//扣库存
|
Msg result = stockService.changeStockBySale(customerInfo,detailInfoList,userInfo,salesTime);
|
if (!result.getCode().equals(ErrorCode.SUCCESS.getCode())){
|
msg = result;
|
}else {
|
//订单及详情生成
|
SaleOrderInfo saleOrderInfo = saleOrderService.createOrder(userInfo,detailInfoList,type,num,salesTime,customerInfo.getId(),pay,total,change, auth);
|
msg.setResult(saleOrderInfo);
|
}
|
return msg;
|
}
|
|
@Override
|
public List<SaleOrderDetailInfo> selectDetailByIdCardNum(String idCardNum, String directionCode) {
|
return saleOrderDetailInfoMapper.selectDetailByIdCardNumAndDire(idCardNum,directionCode);
|
}
|
|
@Override
|
public SaleOrderDetailInfo selectOrderByDirectionAndCustomer(String directionCode, CustomerInfo customerInfo) {
|
return saleOrderDetailInfoMapper.selectOrderByDirectionAndCustomer(directionCode, customerInfo.getId());
|
}
|
|
@Override
|
public void selectReturnDataGrid(PageInfo pageInfo) {
|
Page<SaleOrderDetailInfo> page = new Page<>(pageInfo.getPageIndex(), pageInfo.getPageSize());
|
|
List<OrderItem> orderItems = new ArrayList<>();
|
OrderItem orderItem = new OrderItem();
|
if (StringUtils.isNotBlank(pageInfo.getSort()) && StringUtils.isNotBlank(pageInfo.getOrder())) {
|
orderItem.setAsc(pageInfo.getOrder().equalsIgnoreCase("ascending"));
|
orderItem.setColumn(pageInfo.getSort());
|
}else {
|
orderItem.setAsc(false);
|
orderItem.setColumn("createdat");
|
}
|
orderItems.add(orderItem);
|
page.setOrders(orderItems);
|
if (StringUtils.isBlank(pageInfo.getSort())){
|
pageInfo.setSort("createdat");
|
}
|
if (StringUtils.isBlank(pageInfo.getOrder())){
|
pageInfo.setOrder("desc");
|
}
|
List<SaleOrderDetailInfo> detailInfos = saleOrderDetailInfoMapper.selectDetailDataGridByIdCardNum(pageInfo.getCondition(),page);
|
pageInfo.setResult(detailInfos);
|
pageInfo.setTotalCount(page.getTotal());
|
}
|
|
/**
|
* @Description: 按零售单位查询
|
* @date 2021/4/12 16:35
|
*/
|
@Override
|
public IPage selectSaleRecord2(Page<Map> page, Map filter, UserInfo user) {
|
Map<String, Object> params = new HashMap<>();
|
UserInfo userInfo = userService.getById(user.getId());
|
//过滤条件
|
//权限
|
{
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
}
|
//基本
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
|
List<Map> list = saleOrderInfoMapper.selectSaleRecord2(page, params);
|
return page.setRecords(list);
|
}
|
|
/**
|
* @Description: 按产品查询，没有权限，显示所有产品
|
* @date 2021/4/13 8:54
|
*/
|
@Override
|
public PageInfoExtension<Map> selectSaleRecord3(Page<Map> page, Map filter, UserInfo user) {
|
|
Map<String, Object> params = new HashMap<>();
|
UserInfo userInfo = userService.getById(user.getId());
|
//权限
|
{
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
}
|
//过滤条件
|
//产品流向码，产品名称
|
params.put("itemcode", filter.get("itemcode"));
|
params.put("itemname", filter.get("itemname"));
|
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
|
List<Map> list = saleOrderInfoMapper.selectSaleRecord3(page, params);
|
//统计该查询条件下所有产品销售的总箱数
|
Map sales = saleOrderInfoMapper.selectProductSales(params);
|
PageInfoExtension<Map> extension = new PageInfoExtension<>();
|
extension.setExtension(sales);
|
extension.setPageSize((int) page.getSize());
|
extension.setPageIndex((int) page.getCurrent());
|
extension.setResult(list);
|
extension.setTotalCount(page.getTotal());
|
return extension;
|
}
|
|
/**
|
* @Description: 按购买人查询
|
* @date 2021/4/13 9:07
|
*/
|
@Override
|
public IPage selectSaleRecord4(Page<Map> page, Map filter, UserInfo user) {
|
|
Map<String, Object> params = new HashMap<>();
|
UserInfo userInfo = userService.getById(user.getId());
|
//过滤条件
|
//权限
|
{
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
if (StringUtils.isNotBlank(userInfo.getCompanynumber())) {
|
List<Enterprise> subs = enterpriseService.selectSubEnterprise(userInfo.getCompanyid());
|
List<String> subList = subs.stream().map(Enterprise::getEnterprisenumber).collect(Collectors.toList());
|
if (subList.size() > 0)
|
params.put("subList", subList);
|
}
|
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
}
|
//基本
|
params.put("directioncode", filter.get("directioncode"));
|
params.put("identify", filter.get("identify"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
params.put("isNeedUploadPhoto", filter.get("isNeedUploadPhoto"));
|
params.put("nation", filter.get("nation"));
|
//省市区
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
List<Map> list = saleOrderInfoMapper.selectSaleRecord4(page, params);
|
|
Map<String, Object> totalRow = new HashMap<>();
|
//购买总人数
|
totalRow.put("city", "合计");
|
totalRow.put("enterprisename", "购买总人数");
|
Integer i = saleOrderInfoMapper.selectSaleAllPerson(params);
|
totalRow.put("name", i);
|
//购买总数
|
totalRow.put("identify", "购买总挂数");
|
Integer j = saleOrderInfoMapper.selectAllSaleNum(params);
|
totalRow.put("num", j);
|
//退货数量
|
Integer m = saleOrderInfoMapper.selectAllReturnNum(params);
|
totalRow.put("returnnum", m);
|
ArrayList<Map> res = new ArrayList<>(list);
|
res.add(totalRow);
|
return page.setRecords(res);
|
}
|
|
/**
|
* @Description: 根据销售企业的单位编号和人员的身份证获取购买明细
|
* @date 2021/4/14 12:43
|
*/
|
@Override
|
public IPage getPurchaseDetailInUnit(Page<SaleOrderDetailInfo> page, Map filter, UserInfo user) {
|
|
String enterprisenumber = (String) filter.get("enterprisenumber");
|
String identify = (String) filter.get("identify");
|
if (StringUtils.isBlank(enterprisenumber) || StringUtils.isBlank(identify)) {
|
throw new BusinessException("企业单位编号和身份证不能为空");
|
}
|
Map<String, Object> params = new HashMap<>();
|
params.put("enterprisenumber", enterprisenumber);
|
params.put("identify", identify);
|
params.put("directioncode", filter.get("directioncode"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
List<SaleOrderDetailInfo> list = saleOrderInfoMapper.getPurchaseDetailInUnit(page, params);
|
return page.setRecords(list);
|
}
|
|
@Override
|
public List<SaleOrderInfo> selectEarlyWarn(String starttime, String endttime, Integer min, Integer max) {
|
return saleOrderInfoMapper.selectEarlyWarn(starttime, endttime, min, max);
|
}
|
|
@Override
|
public List<SaleOrderInfo> selectAlarm(String starttime, String endttime, Integer max) {
|
return saleOrderInfoMapper.selectAlarm(starttime, endttime, max);
|
}
|
|
@Override
|
public Long selectByCustomer(Long customid) {
|
return saleOrderInfoMapper.selectByCustomer(customid);
|
}
|
|
@Override
|
public BigDecimal getSaleNumByCondition(Map<String, Object> condition) {
|
return saleOrderDetailInfoMapper.getSaleNumByCondition(condition);
|
}
|
|
/**
|
* @Description: 销售汇总导出
|
* @date 2021/4/19 17:33
|
*/
|
@Override
|
public List<Map> selectExportSaleRecord3(Map filter, UserInfo user) {
|
|
Map<String, Object> params = new HashMap<>();
|
UserInfo userInfo = userService.getById(user);
|
//权限
|
{
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
}
|
//过滤条件
|
//产品流向码，产品名称
|
params.put("itemcode", filter.get("itemcode"));
|
params.put("itemname", filter.get("itemname"));
|
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
|
return saleOrderInfoMapper.selectSaleRecord3(params);
|
}
|
|
/**
|
* @Description: 实名销售导出
|
* @date 2021/4/19 17:40
|
*/
|
@Override
|
public List<Map> selectExportSaleRecord4(Map filter, UserInfo user) {
|
|
Map<String, Object> params = new HashMap<>();
|
UserInfo userInfo = userService.getById(user.getId());
|
//过滤条件
|
//权限
|
{
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
if (StringUtils.isNotBlank(userInfo.getCompanynumber())) {
|
List<Enterprise> subs = enterpriseService.selectSubEnterprise(userInfo.getCompanyid());
|
List<String> subList = subs.stream().map(Enterprise::getEnterprisenumber).collect(Collectors.toList());
|
if (subList.size() > 0)
|
params.put("subList", subList);
|
}
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
}
|
//基本
|
params.put("directioncode", filter.get("directioncode"));
|
params.put("identify", filter.get("identify"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
params.put("nation", filter.get("nation"));
|
//省市区
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
|
List<Map> list = saleOrderInfoMapper.selectSaleRecord4(params);
|
Map<String, Object> totalRow = new HashMap<>();
|
//购买总人数
|
totalRow.put("city", "合计");
|
totalRow.put("enterprisename", "购买总人数");
|
Integer i = saleOrderInfoMapper.selectSaleAllPerson(params);
|
totalRow.put("name", i);
|
//购买总数
|
totalRow.put("identify", "购买总挂数");
|
Integer j = saleOrderInfoMapper.selectAllSaleNum(params);
|
totalRow.put("num", j);
|
//退货数量
|
Integer m = saleOrderInfoMapper.selectAllReturnNum(params);
|
totalRow.put("returnnum", m);
|
ArrayList<Map> res = new ArrayList<>(list);
|
res.add(totalRow);
|
return res;
|
|
|
}
|
|
@Override
|
public PageInfoExtension<List> selectDailySaleReport(PageInfo pageInfo) {
|
Page<DailySaleReport> page = new Page<>(pageInfo.getPageIndex(), pageInfo.getPageSize());
|
|
List<OrderItem> orderItems = new ArrayList<>();
|
OrderItem orderItem = new OrderItem();
|
if (StringUtils.isNotBlank(pageInfo.getSort()) && StringUtils.isNotBlank(pageInfo.getOrder())) {
|
orderItem.setAsc(pageInfo.getOrder().equalsIgnoreCase("ascending"));
|
orderItem.setColumn(pageInfo.getSort());
|
}else {
|
orderItem.setAsc(false);
|
orderItem.setColumn("createdat");
|
}
|
orderItems.add(orderItem);
|
page.setOrders(orderItems);
|
if (StringUtils.isBlank(pageInfo.getSort())){
|
pageInfo.setSort("createdat");
|
}
|
if (StringUtils.isBlank(pageInfo.getOrder())){
|
pageInfo.setOrder("desc");
|
}
|
List<DailySaleReport> reports = saleOrderInfoMapper.selectDailySaleReport(pageInfo.getCondition(),page);
|
pageInfo.setResult(reports);
|
pageInfo.setTotalCount(page.getTotal());
|
List<Map> list = saleOrderInfoMapper.selectAllDailySaleReport(pageInfo.getCondition());
|
PageInfoExtension<List> extension = new PageInfoExtension<>(pageInfo);
|
extension.setExtension(list);
|
return extension;
|
}
|
|
@Override
|
public void selectOrderDataGrid(PageInfo pageInfo) {
|
Page<SaleOrderInfo> page = new Page<>(pageInfo.getPageIndex(), pageInfo.getPageSize());
|
|
List<OrderItem> orderItems = new ArrayList<>();
|
OrderItem orderItem = new OrderItem();
|
if (StringUtils.isNotBlank(pageInfo.getSort()) && StringUtils.isNotBlank(pageInfo.getOrder())) {
|
orderItem.setAsc(pageInfo.getOrder().equalsIgnoreCase("ascending"));
|
orderItem.setColumn(pageInfo.getSort());
|
}else {
|
orderItem.setAsc(false);
|
orderItem.setColumn("createdat");
|
}
|
orderItems.add(orderItem);
|
page.setOrders(orderItems);
|
if (StringUtils.isBlank(pageInfo.getSort())){
|
pageInfo.setSort("createdat");
|
}
|
if (StringUtils.isBlank(pageInfo.getOrder())){
|
pageInfo.setOrder("desc");
|
}
|
List<SaleOrderInfo> orderInfos = saleOrderInfoMapper.selectDataGrid(pageInfo.getCondition(),page);
|
if (orderInfos.size() > 0) {
|
for (SaleOrderInfo info : orderInfos) {
|
info.setDetails(saleOrderInfoMapper.selectDetails(info.getCode()));
|
}
|
}
|
pageInfo.setResult(orderInfos);
|
pageInfo.setTotalCount(page.getTotal());
|
}
|
|
@Override
|
public int getDailySaleCount(UserInfo userInfo) {
|
LambdaQueryWrapper<SaleOrderInfo>wrapper = new LambdaQueryWrapper<>();
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.HOUR_OF_DAY, 0);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.SECOND, 0);
|
Date start = calendar.getTime();
|
calendar.set(Calendar.HOUR_OF_DAY, 23);
|
calendar.set(Calendar.MINUTE, 59);
|
calendar.set(Calendar.SECOND, 59);
|
Date end = calendar.getTime();
|
wrapper.ge(SaleOrderInfo::getCreatedat,start);
|
wrapper.le(SaleOrderInfo::getCreatedat,end);
|
wrapper.eq(SaleOrderInfo::getCompanynumber,userInfo.getCompanynumber());
|
return saleOrderInfoMapper.selectCount(wrapper);
|
}
|
|
@Override
|
public void selectEnterpriseEnterSellStoreDataGrid(PageInfo pageInfo, Map<String, Object> filter, UserInfo userInfo) {
|
Page<Enterprise> page = new Page<>(pageInfo.getPageIndex(), pageInfo.getPageSize());
|
|
Map<String, Object> params = new HashMap<>();
|
//过滤条件
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
|
if (userInfo != null && userInfo.getCompanynumber() != null){
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
List<Enterprise> subs = enterpriseService.selectSubEnterprise(userInfo.getCompanyid());
|
List<String> subList = subs.stream().map(Enterprise::getEnterprisenumber).collect(Collectors.toList());
|
if (subList.size() > 0)
|
params.put("subList", subList);
|
}
|
|
List<OrderItem> orderItems = new ArrayList<>();
|
OrderItem orderItem = new OrderItem();
|
if (StringUtils.isNotBlank(pageInfo.getSort()) && StringUtils.isNotBlank(pageInfo.getOrder())) {
|
orderItem.setAsc(pageInfo.getOrder().equalsIgnoreCase("ascending"));
|
orderItem.setColumn(pageInfo.getSort());
|
}else {
|
orderItem.setAsc(false);
|
orderItem.setColumn("id");
|
}
|
orderItems.add(orderItem);
|
page.setOrders(orderItems);
|
if (StringUtils.isBlank(pageInfo.getSort())){
|
pageInfo.setSort("id");
|
}
|
if (StringUtils.isBlank(pageInfo.getOrder())){
|
pageInfo.setOrder("asc");
|
}
|
List<Enterprise> enterprises = enterpriseService.selectSaleEnterprise(params,page);
|
List<EnterpriseDataVo> enterpriseDataVos = new ArrayList<>();
|
for (Enterprise enterprise : enterprises){
|
BigDecimal saleNumber = saleOrderInfoMapper.selectEnterpriseSaleNumber(enterprise.getEnterprisenumber(),filter.get("starttime"),filter.get("endtime"));
|
BigDecimal entryNumber = entryService.selectEnterpriseEntryNumber(enterprise.getEnterprisenumber(),filter.get("starttime"),filter.get("endtime"));
|
BigDecimal deliveryNumber = deliveryDetailService.selectEnterpriseDeliveryNumber(enterprise.getEnterprisenumber(), filter.get("starttime"), filter.get("endtime"));
|
EnterpriseDataVo enterpriseDataVo = new EnterpriseDataVo(enterprise.getEnterprisename(),saleNumber,entryNumber);
|
enterpriseDataVo.setDeliveryNumber(deliveryNumber);
|
enterpriseDataVos.add(enterpriseDataVo);
|
}
|
pageInfo.setResult(enterpriseDataVos);
|
pageInfo.setTotalCount(page.getTotal());
|
}
|
|
@Override
|
public List<EnterpriseDataVo> selectEnterpriseEnterSellStoreData(Map<String, Object> filter,UserInfo userInfo) {
|
Map<String, Object> params = new HashMap<>();
|
//过滤条件
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
|
if (userInfo != null && userInfo.getCompanynumber() != null){
|
params.put("enterprisename", userInfo.getCompany());
|
}
|
|
List<Enterprise> enterprises = enterpriseService.selectSaleEnterprise(params);
|
List<EnterpriseDataVo> enterpriseDataVos = new ArrayList<>();
|
for (Enterprise enterprise : enterprises){
|
BigDecimal saleNumber = saleOrderInfoMapper.selectEnterpriseSaleNumber(enterprise.getEnterprisenumber(),filter.get("starttime"),filter.get("endtime"));
|
BigDecimal entryNumber = entryService.selectEnterpriseEntryNumber(enterprise.getEnterprisenumber(),filter.get("starttime"),filter.get("endtime"));
|
BigDecimal deliveryNumber = deliveryDetailService.selectEnterpriseDeliveryNumber(enterprise.getEnterprisenumber(), filter.get("starttime"), filter.get("endtime"));
|
EnterpriseDataVo enterpriseDataVo = new EnterpriseDataVo(enterprise.getEnterprisename(),saleNumber,entryNumber);
|
enterpriseDataVo.setDeliveryNumber(deliveryNumber);
|
enterpriseDataVos.add(enterpriseDataVo);
|
}
|
return enterpriseDataVos;
|
}
|
|
@Override
|
public SaleOrderDetailInfo selectOrderByDirectionReturnflag(String directionCode, byte returnflag, String datetime) {
|
return saleOrderDetailInfoMapper.selectOrderByDirectionReturnflag(directionCode,returnflag,datetime);
|
}
|
|
@Override
|
public void selectCityEnterSellStoreDataGrid(PageInfo pageInfo, Map<String, Object> filter) {
|
Page<Enterprise> page = new Page<>(pageInfo.getPageIndex(), pageInfo.getPageSize());
|
|
Map<String, Object> params = new HashMap<>();
|
//过滤条件
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("safetysupervision", filter.get("safetysupervision"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
|
List<OrderItem> orderItems = new ArrayList<>();
|
OrderItem orderItem = new OrderItem();
|
if (StringUtils.isNotBlank(pageInfo.getSort()) && StringUtils.isNotBlank(pageInfo.getOrder())) {
|
orderItem.setAsc(pageInfo.getOrder().equalsIgnoreCase("ascending"));
|
orderItem.setColumn(pageInfo.getSort());
|
}else {
|
orderItem.setAsc(false);
|
orderItem.setColumn("id");
|
}
|
orderItems.add(orderItem);
|
page.setOrders(orderItems);
|
if (StringUtils.isBlank(pageInfo.getSort())){
|
pageInfo.setSort("id");
|
}
|
if (StringUtils.isBlank(pageInfo.getOrder())){
|
pageInfo.setOrder("asc");
|
}
|
|
List<DistrictInfo> districtInfos = districtService.selectInfoByParentCodeAndCity("65",filter.get("city"));
|
List<CityDataVo> cityDataVos = new ArrayList<>();
|
for (DistrictInfo districtInfo : districtInfos){
|
BigDecimal saleNumber = saleOrderInfoMapper.selectCitySaleNumber(districtInfo.getName(),filter.get("starttime"),filter.get("endtime"));
|
BigDecimal entryNumber = entryService.selectCityEntryNumber(districtInfo.getName(),filter.get("starttime"),filter.get("endtime"));
|
//销售金额
|
BigDecimal sales = saleOrderInfoMapper.selectCitySales(districtInfo.getName(),filter.get("starttime"),filter.get("endtime"));
|
BigDecimal saleNumber2 = saleOrderInfoMapper.selectCitySaleNumber(districtInfo.getName(),filter.get("starttime2"),filter.get("endtime2"));
|
BigDecimal entryNumber2 = entryService.selectCityEntryNumber(districtInfo.getName(),filter.get("starttime2"),filter.get("endtime2"));
|
////销售金额
|
BigDecimal sales2 = saleOrderInfoMapper.selectCitySales(districtInfo.getName(),filter.get("starttime2"),filter.get("endtime2"));
|
String dataRange = filter.get("starttime")+" - "+filter.get("endtime");
|
String dataRange2 = filter.get("starttime2")+" - "+filter.get("endtime2");
|
CityDataVo cityDataVo = new CityDataVo(districtInfo.getName(),dataRange,saleNumber,entryNumber,dataRange2,saleNumber2,entryNumber2);
|
cityDataVo.setSales(sales);
|
cityDataVo.setSales2(sales2);
|
cityDataVos.add(cityDataVo);
|
}
|
pageInfo.setResult(cityDataVos);
|
pageInfo.setTotalCount(page.getTotal());
|
}
|
|
/**
|
* @Description: 按流向码查询
|
* @date 2021/4/12 16:35
|
*/
|
@Override
|
public IPage selectSaleRecord1(Page<Map> page,Map filter, UserInfo user) {
|
|
Map<String, Object> params = new HashMap<>();
|
UserInfo userInfo = userService.getById(user.getId());
|
//过滤条件
|
//权限
|
{
|
params.put("enterprisenumber", userInfo.getCompanynumber());
|
params.put("province", user.getProvince());
|
params.put("city", user.getCity());
|
params.put("district", user.getArea());
|
params.put("street", user.getTown());
|
params.put("committee", user.getCommunity());
|
}
|
//基本
|
params.put("filterProvince", filter.get("province"));
|
params.put("filterCity", filter.get("city"));
|
params.put("filterDistrict", filter.get("district"));
|
params.put("filterStreet", filter.get("street"));
|
params.put("filterCommittee", filter.get("committee"));
|
params.put("starttime", filter.get("starttime"));
|
params.put("endtime", filter.get("endtime"));
|
params.put("identify", filter.get("identify"));
|
params.put("directioncode", filter.get("directioncode"));
|
params.put("safetySupervision", filter.get("safetySupervision"));
|
params.put("enterprisename", filter.get("enterprisename"));
|
params.put("parententerprisename", filter.get("parententerprisename"));
|
List<Map> list = saleOrderInfoMapper.selectSaleRecord1(page, params);
|
return page.setRecords(list);
|
}
|
|
|
|
public SaleOrderInfo generateSaleOrderInfo(String type, UserInfo userInfo, Integer num, Date salesTime,
|
Long customerId, String pay, String total, String change, String userId){
|
SaleOrderInfo orderInfo = new SaleOrderInfo();
|
orderInfo.setCode(generateOrderCode(MODULE_SALE,type,new Date(),userInfo.getId()));
|
orderInfo.setType(Byte.parseByte(type));
|
orderInfo.setCreatedat(salesTime);
|
orderInfo.setCreatedby(userInfo.getUsername());
|
orderInfo.setBoxnum(new BigDecimal(num));
|
orderInfo.setPay(new BigDecimal(pay));
|
orderInfo.setChange(new BigDecimal(change));
|
orderInfo.setSalesperson(userInfo.getUsername());
|
orderInfo.setTotalprice(new BigDecimal(total));
|
orderInfo.setShop(userInfo.getCompany());
|
orderInfo.setCompanynumber(userInfo.getCompanynumber());
|
orderInfo.setCustomer(customerId);
|
|
return orderInfo;
|
}
|
|
@Override
|
public String generateOrderCode(String module, String type, Date date, Long userId){
|
//DateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
//创建Instant对象
|
Instant instant = Instant.now();
|
//获取毫秒数
|
long currentMilli = instant.toEpochMilli();
|
String orderCode = String.valueOf(currentMilli);
|
String extend = String.format("%06d",userId);
|
switch (module) {
|
case MODULE_ENTRY:
|
if (type.equals(RK_ENTRY)) {
|
orderCode = "RK-" + orderCode;
|
} else if (type.equals(TH_ENTRY)) {
|
orderCode = "TH-" + orderCode;
|
}
|
break;
|
case MODULE_DELIVERY:
|
if (type.equals(NORMAL_DELIVERY)) {
|
orderCode = "ND-" + orderCode;
|
} else {
|
orderCode = "OD-" + orderCode;
|
}
|
break;
|
case MODULE_SALE:
|
if (type.equals(RETAIL_ORDER)) {
|
orderCode = "RO-" + orderCode;
|
} else if (type.equals(GROUP_ORDER)) {
|
orderCode = "GO-" + orderCode;
|
}
|
break;
|
default:
|
}
|
|
return orderCode+extend+hostId+Thread.currentThread().getId();
|
}
|
|
@Override
|
public SaleOrderInfo isExist(Long id, String companynumber, Date salesTime) {
|
LambdaQueryWrapper<SaleOrderInfo>wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(SaleOrderInfo::getCreatedat,salesTime);
|
wrapper.eq(SaleOrderInfo::getCustomer,id);
|
wrapper.eq(SaleOrderInfo::getCompanynumber,companynumber);
|
return baseMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<SaleOrderInfo> getWaitUploadOrderByEnterprise(Enterprise enterprise) {
|
LambdaQueryWrapper<SaleOrderInfo> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(SaleOrderInfo::getIsupload,0);
|
wrapper.ge(SaleOrderInfo::getCreatedat,"2022-01-21");
|
wrapper.eq(SaleOrderInfo::getCompanynumber,enterprise.getEnterprisenumber());
|
return baseMapper.selectList(wrapper);
|
}
|
|
}
|
