|
|
@@ -30,10 +30,12 @@ import org.springblade.core.tool.utils.ObjectUtil;
|
|
|
import org.springblade.core.tool.utils.StringUtil;
|
|
|
import org.springblade.finance.feign.IFinanceClient;
|
|
|
import org.springblade.finance.vojo.Acc;
|
|
|
+import org.springblade.purchase.sales.entity.IntegralDetail;
|
|
|
import org.springblade.purchase.sales.entity.Order;
|
|
|
import org.springblade.purchase.sales.entity.OrderItems;
|
|
|
import org.springblade.purchase.sales.excel.AnalysisDetailsExcel;
|
|
|
import org.springblade.purchase.sales.excel.PjStockDetails;
|
|
|
+import org.springblade.purchase.sales.service.IIntegralDetailService;
|
|
|
import org.springblade.purchase.sales.service.IOrderItemsService;
|
|
|
import org.springblade.purchase.sales.service.IOrderService;
|
|
|
import org.springblade.purchase.sales.vo.OrderVO;
|
|
|
@@ -71,6 +73,7 @@ public class AppPartsController extends BladeController {
|
|
|
private final IStorageClient iStorageClient;//库区信息
|
|
|
private final IFinanceClient financeClient;
|
|
|
private final ISysClient sysClient;
|
|
|
+ private final IIntegralDetailService integralDetailService;
|
|
|
/**
|
|
|
* 库区信息
|
|
|
*/
|
|
|
@@ -81,8 +84,8 @@ public class AppPartsController extends BladeController {
|
|
|
*/
|
|
|
@GetMapping("/revenueExpenditure")
|
|
|
@ApiOperation(value = "营业收入和采购支出", notes = "传入order")
|
|
|
- public R revenueExpenditure(@RequestParam(value = "tenantId" ,required = false) String tenantId, HttpServletRequest request) {
|
|
|
- if (ObjectUtils.isNull(request.getHeader("Blade-Auth"))){
|
|
|
+ public R revenueExpenditure(@RequestParam(value = "tenantId", required = false) String tenantId, HttpServletRequest request) {
|
|
|
+ if (ObjectUtils.isNull(request.getHeader("Blade-Auth"))) {
|
|
|
// 获取租户信息
|
|
|
R<Tenant> tenant = sysClient.getTenantByAppId(request.getHeader("appId"));
|
|
|
if (tenant.isSuccess() && ObjectUtils.isNotNull(tenant.getData())) {
|
|
|
@@ -176,7 +179,7 @@ public class AppPartsController extends BladeController {
|
|
|
lambdaQueryWrapper.orderByAsc(Order::getBusinesDate);
|
|
|
} else if ("5".equals(order.getTypeSort())) {
|
|
|
lambdaQueryWrapper.orderByAsc(Order::getConfirmStatus);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
lambdaQueryWrapper.orderByDesc(Order::getBusinesDate);
|
|
|
}
|
|
|
} else if ("1".equals(order.getSort())) {
|
|
|
@@ -190,7 +193,7 @@ public class AppPartsController extends BladeController {
|
|
|
lambdaQueryWrapper.orderByDesc(Order::getBusinesDate);
|
|
|
} else if ("5".equals(order.getTypeSort())) {
|
|
|
lambdaQueryWrapper.orderByDesc(Order::getConfirmStatus);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
lambdaQueryWrapper.orderByDesc(Order::getBusinesDate);
|
|
|
}
|
|
|
} else {
|
|
|
@@ -345,16 +348,16 @@ public class AppPartsController extends BladeController {
|
|
|
LambdaQueryWrapper<Order> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
lambdaQueryWrapper.eq(Order::getTenantId, SecureUtil.getTenantId());//租户id
|
|
|
lambdaQueryWrapper.eq(Order::getIsDeleted, 0);//订单是否有效
|
|
|
- if (ObjectUtils.isNotNull(order.getType()) && "1".equals(order.getType())){
|
|
|
+ if (ObjectUtils.isNotNull(order.getType()) && "1".equals(order.getType())) {
|
|
|
CorpsAttn corpsAttn = corpsAttnClient.getUser(AuthUtil.getUserId());
|
|
|
if (ObjectUtils.isNotNull(corpsAttn)) {
|
|
|
CorpsDesc corpsDesc = corpsDescClient.getCorpId(corpsAttn.getPid());
|
|
|
if (ObjectUtils.isNotNull(corpsDesc)) {
|
|
|
- lambdaQueryWrapper.eq( Order::getCorpId, corpsDesc.getId());//客户id
|
|
|
+ lambdaQueryWrapper.eq(Order::getCorpId, corpsDesc.getId());//客户id
|
|
|
order.setCorpId(corpsDesc.getId());
|
|
|
}
|
|
|
}
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
lambdaQueryWrapper.like(Func.isNotEmpty(order.getCorpId()), Order::getCorpId, order.getCorpId());//客户id
|
|
|
lambdaQueryWrapper.eq(ObjectUtils.isNotNull(order.getSalesName()), Order::getSalesName, order.getSalesName());//业务员
|
|
|
if (AuthUtil.getUserRole().contains("销售") || AuthUtil.getUserRole().contains("业务员")) {
|
|
|
@@ -656,7 +659,8 @@ public class AppPartsController extends BladeController {
|
|
|
@RepeatSubmit
|
|
|
public R quickBillingWX(@Valid @RequestBody Order order) {
|
|
|
order.setTradeType(OrderTypeEnum.PARTS.getType());
|
|
|
- return orderService.quickBillingWX(order);}
|
|
|
+ return orderService.quickBillingWX(order);
|
|
|
+ }
|
|
|
|
|
|
/**
|
|
|
* 新增或修改 经销商销售或采购订单表(微信小程序)
|
|
|
@@ -667,7 +671,8 @@ public class AppPartsController extends BladeController {
|
|
|
@RepeatSubmit
|
|
|
public R quickBillingWXv2(@Valid @RequestBody Order order) {
|
|
|
order.setTradeType(OrderTypeEnum.PARTS.getType());
|
|
|
- return orderService.quickBillingWXv2(order);}
|
|
|
+ return orderService.quickBillingWXv2(order);
|
|
|
+ }
|
|
|
|
|
|
/**
|
|
|
* 新增或修改 经销商销售或采购订单表(微信小程序积分兑换)
|
|
|
@@ -678,7 +683,8 @@ public class AppPartsController extends BladeController {
|
|
|
@RepeatSubmit
|
|
|
public R quickBillingWXIntegral(@Valid @RequestBody Order order) {
|
|
|
order.setTradeType(OrderTypeEnum.PARTS.getType());
|
|
|
- return orderService.quickBillingWXIntegral(order);}
|
|
|
+ return orderService.quickBillingWXIntegral(order);
|
|
|
+ }
|
|
|
|
|
|
/**
|
|
|
* 收付款(单)
|
|
|
@@ -720,20 +726,19 @@ public class AppPartsController extends BladeController {
|
|
|
* 积分兑换记录
|
|
|
*/
|
|
|
@GetMapping("/integralExchangeRecord")
|
|
|
- public R<IPage<Map<String,Object>>> integralExchangeRecord(HttpServletRequest request, Query query,@RequestParam(value = "corpId",required = false) Long corpId) {
|
|
|
- Order order = new Order();
|
|
|
- order.setTradeType(OrderTypeEnum.PARTS.getType());
|
|
|
- if (corpId == null){
|
|
|
+ public R<IPage<IntegralDetail>> integralExchangeRecord(HttpServletRequest request, Query query, @RequestParam(value = "corpId", required = false) Long corpId) {
|
|
|
+ LambdaQueryWrapper<IntegralDetail> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ if (corpId == null) {
|
|
|
if (ObjectUtils.isNull(request.getHeader("Blade-Auth"))) {
|
|
|
// 获取租户信息
|
|
|
R<Tenant> tenant = sysClient.getTenantByAppId(request.getHeader("appId"));
|
|
|
if (tenant.isSuccess() && ObjectUtils.isNotNull(tenant.getData())) {
|
|
|
- order.setTenantId(tenant.getData().getTenantId());
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getTenantId, tenant.getData().getTenantId());
|
|
|
} else {
|
|
|
throw new RuntimeException("获取数据失败");
|
|
|
}
|
|
|
} else {
|
|
|
- order.setTenantId(AuthUtil.getTenantId());
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getTenantId, AuthUtil.getTenantId());
|
|
|
}
|
|
|
if (AuthUtil.getUserRole().equals("客户")) {
|
|
|
CorpsAttn corpsAttn = corpsAttnClient.getUser(AuthUtil.getUserId());
|
|
|
@@ -748,32 +753,32 @@ public class AppPartsController extends BladeController {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- }else{
|
|
|
- order.setTenantId(AuthUtil.getTenantId());
|
|
|
+ } else {
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getTenantId, AuthUtil.getTenantId());
|
|
|
}
|
|
|
- order.setCorpId(corpId);
|
|
|
- order.setWhetherIntegral("1");
|
|
|
- return R.data(orderService.integralRecord(Condition.getPage(query),order));
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getCorpId, corpId)
|
|
|
+ .eq(IntegralDetail::getType, "积分兑换")
|
|
|
+ .ne(IntegralDetail::getIntegral,0);
|
|
|
+ return R.data(integralDetailService.page(Condition.getPage(query), lambdaQueryWrapper));
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 积分获取记录
|
|
|
*/
|
|
|
@GetMapping("/integralRecord")
|
|
|
- public R<IPage<Map<String,Object>>> integralRecord(HttpServletRequest request, Query query,@RequestParam(value = "corpId",required = false) Long corpId) {
|
|
|
- Order order = new Order();
|
|
|
- order.setTradeType(OrderTypeEnum.PARTS.getType());
|
|
|
- if (corpId == null){
|
|
|
+ public R<IPage<IntegralDetail>> integralRecord(HttpServletRequest request, Query query, @RequestParam(value = "corpId", required = false) Long corpId) {
|
|
|
+ LambdaQueryWrapper<IntegralDetail> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ if (corpId == null) {
|
|
|
if (ObjectUtils.isNull(request.getHeader("Blade-Auth"))) {
|
|
|
// 获取租户信息
|
|
|
R<Tenant> tenant = sysClient.getTenantByAppId(request.getHeader("appId"));
|
|
|
if (tenant.isSuccess() && ObjectUtils.isNotNull(tenant.getData())) {
|
|
|
- order.setTenantId(tenant.getData().getTenantId());
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getTenantId, tenant.getData().getTenantId());
|
|
|
} else {
|
|
|
throw new RuntimeException("获取数据失败");
|
|
|
}
|
|
|
} else {
|
|
|
- order.setTenantId(AuthUtil.getTenantId());
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getTenantId, AuthUtil.getTenantId());
|
|
|
}
|
|
|
if (AuthUtil.getUserRole().equals("客户")) {
|
|
|
CorpsAttn corpsAttn = corpsAttnClient.getUser(AuthUtil.getUserId());
|
|
|
@@ -788,12 +793,13 @@ public class AppPartsController extends BladeController {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- }else{
|
|
|
- order.setTenantId(AuthUtil.getTenantId());
|
|
|
+ } else {
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getTenantId, AuthUtil.getTenantId());
|
|
|
}
|
|
|
- order.setCorpId(corpId);
|
|
|
- order.setWhetherIntegral("0");
|
|
|
- return R.data(orderService.integralRecord(Condition.getPage(query),order));
|
|
|
+ lambdaQueryWrapper.eq(IntegralDetail::getCorpId, corpId)
|
|
|
+ .apply("find_in_set(type,'购买获取,退款退货')")
|
|
|
+ .ne(IntegralDetail::getIntegral,0);
|
|
|
+ return R.data(integralDetailService.page(Condition.getPage(query), lambdaQueryWrapper));
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -802,11 +808,12 @@ public class AppPartsController extends BladeController {
|
|
|
@GetMapping("/consumptionRecords")
|
|
|
public R<IPage<Order>> consumptionRecords(Order order, Query query) {
|
|
|
LambdaQueryWrapper<Order> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
- lambdaQueryWrapper.eq(Order::getTenantId,AuthUtil.getTenantId())
|
|
|
- .eq(Order::getIsDeleted,0)
|
|
|
- .eq(Order::getTradeType,OrderTypeEnum.PARTS.getType())
|
|
|
- .eq(Order::getWhetherIntegral,"0")
|
|
|
- .eq(Order::getCorpId,order.getCorpId());
|
|
|
+ lambdaQueryWrapper.eq(Order::getTenantId, AuthUtil.getTenantId())
|
|
|
+ .eq(Order::getIsDeleted, 0)
|
|
|
+ .eq(Order::getTradeType, OrderTypeEnum.PARTS.getType())
|
|
|
+ .eq(Order::getWhetherIntegral, "0")
|
|
|
+ .ne(Order::getMemberBalance,0)
|
|
|
+ .eq(Order::getCorpId, order.getCorpId());
|
|
|
return R.data(orderService.page(Condition.getPage(query), lambdaQueryWrapper));
|
|
|
}
|
|
|
|