clunt
/
ghy-all
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Merge branch 'master' of https://gitee.com/op-souls/ghy-all

This commit is contained in:
donqi 2022-08-25 00:06:24 +08:00
parent 685f26d8a6 190f6a58ff
commit 634c1637ec
18 changed files with 318 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
ghy-admin/src/main/java/com/ghy/web/controller/customer/CustomerPlaceController.java
View File

@ -4,8 +4,13 @@ import java.util.List;
import com.ghy.common.enums.PlaceStatus;
import com.ghy.common.utils.CacheUtils;
import com.ghy.common.utils.ExceptionUtil;
import com.ghy.common.utils.ObjectUtils;
import com.ghy.customer.domain.Customer;
import com.ghy.customer.service.CustomerService;
import com.ghy.worker.domain.Worker;
import com.ghy.worker.domain.WorkerBank;
import com.ghy.worker.domain.WorkerCertification;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
@ -170,4 +175,29 @@ public class CustomerPlaceController extends BaseController
{
return toAjax(customerPlaceService.deleteCustomerPlaceByIds(ids));
}
@PostMapping("/changeStatus")
@ResponseBody
public AjaxResult changeStatus(String ids,Integer status){
try {
int result = customerPlaceService.changeStatus(ids, status);
if(result > 0){
String [] idArray = ids.split(",");
for (String id : idArray){
CustomerPlace customerPlace = customerPlaceService.selectCustomerPlaceById(id);
Customer customer = new Customer();
customer.setCustomerId(customerPlace.getCustomerId());
customer.setPlaceStatus(status);
customerService.updateCustomer(customer);
}
return AjaxResult.success("操作成功!");
}else {
return AjaxResult.warn("操作失败!");
}
}catch (Exception e){
e.printStackTrace();
logger.error(ExceptionUtil.getExceptionMessage(e));
return AjaxResult.error("操作失败!");
}
}
}

18
ghy-admin/src/main/java/com/ghy/web/controller/order/OrderDetailController.java
View File

@ -36,6 +36,7 @@ import com.ghy.web.pojo.vo.OrderListResponse;
import com.ghy.web.pojo.vo.OrderStandard;
import com.ghy.worker.domain.Worker;
import com.ghy.worker.service.WorkerService;
import com.huifu.adapay.core.exception.BaseAdaPayException;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.apache.shiro.util.Assert;
import org.springframework.beans.factory.annotation.Autowired;
@ -339,6 +340,23 @@ public class OrderDetailController extends BaseController {
return orderDetailService.checkOrderDetailCodeUnique(orderDetail);
}
/**
* 消费者确认完成子订单
*
* @param orderDetailId 子订单ID
*/
@PostMapping("/finish")
@ResponseBody
public AjaxResult finish(Long orderDetailId) {
try {
orderDetailService.finish(orderDetailId);
} catch (BaseAdaPayException e) {
logger.error(e.getMessage(), e);
return AjaxResult.error("操作失败，请稍后重试");
}
return AjaxResult.success();
}
/**
* 消费者申请取消子订单
*

8
ghy-admin/src/main/java/com/ghy/web/controller/payment/FinancialMasterController.java
View File

@ -46,6 +46,14 @@ public class FinancialMasterController extends BaseController {
return getDataTable(list);
}
@PostMapping("/app/list")
@ResponseBody
public TableDataInfo appList(FinancialMaster request) {
startPage();
List<FinancialMaster> list = financialMasterService.selectAppList(request);
return getDataTable(list);
}
@Log(title = "主财务单管理", businessType = BusinessType.EXPORT)
@RequiresPermissions("financial:master:export")
@PostMapping("/export")

24
ghy-admin/src/main/resources/templates/customer/place/place.html
View File

@ -36,15 +36,15 @@
</div>
<div class="btn-group-sm" id="toolbar" role="group">
<a class="btn btn-success" onclick="$.operate.add()" shiro:hasPermission="customer:place:add">
<i class="fa fa-plus"></i> 添加
<a class="btn btn-primary multiple disabled" onclick="auditStatus(2)" shiro:hasPermission="customer:place:add">
<i class="fa fa-edit"></i> 通过
</a>
<a class="btn btn-danger multiple disabled" onclick="auditStatus(0)" shiro:hasPermission="customer:place:remove">
<i class="fa fa-remove"></i> 拒绝
</a>
<a class="btn btn-primary single disabled" onclick="$.operate.edit()" shiro:hasPermission="customer:place:edit">
<i class="fa fa-edit"></i> 修改
</a>
<a class="btn btn-danger multiple disabled" onclick="$.operate.removeAll()" shiro:hasPermission="customer:place:remove">
<i class="fa fa-remove"></i> 删除
</a>
<a class="btn btn-warning" onclick="$.table.exportExcel()" shiro:hasPermission="customer:place:export">
<i class="fa fa-download"></i> 导出
</a>
@ -63,9 +63,7 @@
$(function() {
var options = {
url: prefix + "/list",
createUrl: prefix + "/add",
updateUrl: prefix + "/edit/{id}",
removeUrl: prefix + "/remove",
exportUrl: prefix + "/export",
modalName: "分销申请",
columns: [{
@ -109,6 +107,18 @@
};
$.table.init(options);
});
function auditStatus(status){
table.set();
var rows = $.common.isEmpty(table.options.uniqueId) ? $.table.selectFirstColumns() : $.table.selectColumns(table.options.uniqueId);
if (rows.length == 0) {
$.modal.alertWarning("请至少选择一条记录");
return;
}
$.modal.confirm("确认审核吗？", function() {
$.operate.post(prefix + "/changeStatus", { "ids": rows.join(), "status": status });
})
}
</script>
</body>
</html>

9
ghy-custom/src/main/java/com/ghy/customer/mapper/CustomerPlaceMapper.java
View File

@ -2,6 +2,7 @@ package com.ghy.customer.mapper;
import java.util.List;
import com.ghy.customer.domain.CustomerPlace;
import org.apache.ibatis.annotations.Param;
/**
* 分销申请Mapper接口
@ -58,4 +59,12 @@ public interface CustomerPlaceMapper
* @return 结果
*/
public int deleteCustomerPlaceByIds(String[] ids);
/**
* @param ids 需要审核的id
* @param status 审核结果
* @return 结果
*/
public int changeStatus(@Param("ids") String ids, @Param("status") Integer status);
}

8
ghy-custom/src/main/java/com/ghy/customer/service/ICustomerPlaceService.java
View File

@ -58,4 +58,12 @@ public interface ICustomerPlaceService
* @return 结果
*/
public int deleteCustomerPlaceById(String id);
/**
* @param ids 需要审核的id
* @param status 审核结果
* @return 结果
*/
public int changeStatus(String ids,Integer status);
}

5
ghy-custom/src/main/java/com/ghy/customer/service/impl/CustomerPlaceServiceImpl.java
View File

@ -93,4 +93,9 @@ public class CustomerPlaceServiceImpl implements ICustomerPlaceService
{
return customerPlaceMapper.deleteCustomerPlaceById(id);
}
@Override
public int changeStatus(String ids, Integer status) {
return customerPlaceMapper.changeStatus(ids, status);
}
}

5
ghy-custom/src/main/resources/mapper/customer/CustomerPlaceMapper.xml
View File

@ -88,5 +88,10 @@
#{id}
</foreach>
</delete>
<update id="changeStatus">
UPDATE customer_place set status = #{status}
WHERE id in ( #{ids} )
</update>
</mapper>

8
ghy-order/src/main/java/com/ghy/order/mapper/OrderMasterMapper.java
View File

@ -77,4 +77,12 @@ public interface OrderMasterMapper {
* 查询指定状态的订单
*/
List<OrderMaster> selectByStatus(List<Integer> status);
/**
* 查询出未完成(orderStatus < 5)的主订单
*
* @return 主订单
*/
List<OrderMaster> selectUnfinished();
}

12
ghy-order/src/main/java/com/ghy/order/service/OrderDetailService.java
View File

@ -1,7 +1,7 @@
package com.ghy.order.service;
import com.ghy.order.domain.OrderDetail;
import com.ghy.order.domain.OrderMaster;
import com.huifu.adapay.core.exception.BaseAdaPayException;
import java.util.List;
import java.util.Map;
@ -98,4 +98,14 @@ public interface OrderDetailService {
* 查询指定状态的订单
*/
List<OrderDetail> selectByStatus(List<Integer> status);
/**
* 子订单确认完成
* 1.修改子订单状态为 OrderStatus.FINISH.code
* 2.将子订单对应的子财务单确认分账
* 3.异步提现至银行卡
*
* @param orderDetailId 子订单ID
*/
void finish(Long orderDetailId) throws BaseAdaPayException;
}

13
ghy-order/src/main/java/com/ghy/order/service/OrderMasterService.java
View File

@ -79,7 +79,11 @@ public interface OrderMasterService {
int updateStatus(Long orderMasterId, int status);
/**
* 确认支付订单
* 主订单完成
* 由定时器触发 而不是由用户触发（用户只能对子订单操作完成）
* 当所有的子订单完成后 定时器进入此方法
* 1.修改主订单状态
* 2.对提成、分销、罚款、手续费等类型的财务单分销和提现
*
* @param orderMasterId 主订单ID
*/
@ -104,4 +108,11 @@ public interface OrderMasterService {
* 查询指定状态的订单
*/
List<OrderMaster> selectByStatus(List<Integer> status);
/**
* 查询出未完成(orderStatus < 5)的主订单
*
* @return 主订单
*/
List<OrderMaster> selectUnfinished();
}

100
ghy-order/src/main/java/com/ghy/order/service/impl/OrderDetailServiceImpl.java
View File

@ -1,9 +1,13 @@
package com.ghy.order.service.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.ghy.common.adapay.model.AdapayStatusEnum;
import com.ghy.common.adapay.model.DivMember;
import com.ghy.common.adapay.model.PaymentDTO;
import com.ghy.common.constant.UserConstants;
import com.ghy.common.core.text.Convert;
import com.ghy.common.enums.AdapayOrderType;
import com.ghy.common.enums.OrderStatus;
import com.ghy.common.enums.PayStatus;
import com.ghy.common.utils.AdapayUtils;
@ -21,6 +25,7 @@ import com.ghy.payment.service.FinancialMasterService;
import com.huifu.adapay.core.exception.BaseAdaPayException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.Assert;
@ -51,6 +56,8 @@ public class OrderDetailServiceImpl implements OrderDetailService {
.appendValue(DAY_OF_MONTH, 2).appendValue(HOUR_OF_DAY, 2)
.appendValue(MINUTE_OF_HOUR, 2).appendValue(SECOND_OF_MINUTE, 2).toFormatter();
@Resource
private ThreadPoolTaskExecutor executor;
@Resource
private OrderDetailMapper orderDetailMapper;
@Resource
@ -182,7 +189,7 @@ public class OrderDetailServiceImpl implements OrderDetailService {
switch (orderDetail.getOrderStatus()) {
case 0:
case 1: // 待接单和待排期状态可直接取消
updateStatus(orderDetailId, OrderStatus.CANCEL.code());
orderDetailMapper.updateStatus(orderDetailId, OrderStatus.CANCEL.code());
// 发起退款
try {
refund(orderDetail);
@ -191,13 +198,13 @@ public class OrderDetailServiceImpl implements OrderDetailService {
}
break;
case 2: // 待上门状态需要师傅同意才能取消
updateStatus(orderDetailId, OrderStatus.GOING_CANCEL.code());
orderDetailMapper.updateStatus(orderDetailId, OrderStatus.GOING_CANCEL.code());
break;
case 3: // 服务中状态需要师傅同意才能取消
updateStatus(orderDetailId, OrderStatus.SERVER_CANCEL.code());
orderDetailMapper.updateStatus(orderDetailId, OrderStatus.SERVER_CANCEL.code());
break;
case 4: // 待确认状态需要师傅同意才能取消
updateStatus(orderDetailId, OrderStatus.FINISH_CHECK_CANCEL.code());
orderDetailMapper.updateStatus(orderDetailId, OrderStatus.FINISH_CHECK_CANCEL.code());
break;
default: // 其他状态不可取消
throw new IllegalArgumentException("这个子订单不能取消了");
@ -232,10 +239,6 @@ public class OrderDetailServiceImpl implements OrderDetailService {
logger.info("子订单[code={}]退款成功", orderDetail.getCode());
}
private void updateStatus(Long orderDetailId, int orderStatus) {
orderDetailMapper.updateStatus(orderDetailId, orderStatus);
}
@Override
@Transactional(rollbackFor = Exception.class)
public void cancelAgree(Long orderDetailId, Integer agree) {
@ -244,7 +247,7 @@ public class OrderDetailServiceImpl implements OrderDetailService {
if (Integer.valueOf(1).equals(agree)) {
// 师傅同意取消订单
// 修改主订单状态为已取消
updateStatus(orderDetailId, OrderStatus.CANCEL.code());
orderDetailMapper.updateStatus(orderDetailId, OrderStatus.CANCEL.code());
// 发起退款
try {
refund(orderDetail);
@ -255,7 +258,7 @@ public class OrderDetailServiceImpl implements OrderDetailService {
// 师傅不同意取消订单
Integer orderStatus = orderDetail.getOrderStatus();
// 修改主订单状态为原来的状态
updateStatus(orderDetailId, Math.abs(orderStatus));
orderDetailMapper.updateStatus(orderDetailId, Math.abs(orderStatus));
}
}
@ -269,4 +272,81 @@ public class OrderDetailServiceImpl implements OrderDetailService {
Assert.isTrue(!CollectionUtils.isEmpty(status), "订单状态为空");
return orderDetailMapper.selectByStatus(status);
}
/**
* 子订单确认完成
* 1.修改子订单状态为 OrderStatus.FINISH.code
* 2.将子订单对应的子财务单确认分账
* 3.异步提现至银行卡
*
* @param orderDetailId 子订单ID
*/
@Override
@Transactional(rollbackFor = Exception.class)
// 暂时先用 synchronized 来避免重复提交
public synchronized void finish(Long orderDetailId) throws BaseAdaPayException {
// 更新订单状态
orderDetailMapper.updateStatus(orderDetailId, OrderStatus.FINISH.code());
// 校验订单
OrderDetail orderDetail = selectById(orderDetailId);
Assert.notNull(orderDetail, "找不到对应的子订单");
Assert.isTrue(orderDetail.getOrderStatus().equals(OrderStatus.FINISH.code()), "找不到对应的子订单");
FinancialMaster financialMaster = financialMasterService.selectByOrderMasterId(orderDetail.getOrderMasterId());
Assert.notNull(financialMaster, "找不到主财务单");
PaymentDTO payment = financialMasterService.selectPaymentById(financialMaster.getPaymentId());
Assert.notNull(payment, "找不到支付记录");
FinancialDetail financialDetail = financialDetailService.selectByOrderDetailId(orderDetailId);
Assert.notNull(financialDetail, "找不到子财务单");
Assert.isTrue(financialDetail.getPayStatus() == 1, "订单不是“已支付”状态");
if (BigDecimal.ZERO.compareTo(financialDetail.getPayMoney()) > -1) {
logger.info("子财务单[code={}]支付金额<=0，不需要分账", financialDetail.getCode());
// 支付金额<=0的话 不需要走下面的流程了
return;
}
// 上门师傅结单 要判断一下这个单是否已退款
if (financialDetail.getPayStatus() > 1) {
return;
}
// 分账账户ID
String memberId;
// 分账账户信息
ArrayList<DivMember> divMembers = new ArrayList<>();
String amount = AdapayUtils.bigDecimalToString(financialDetail.getPayMoney());
memberId = AdapayUtils.getWorkerMemberId(financialDetail.getPayeeId(), orderDetail.getDeptId());
DivMember divMember = new DivMember(memberId, amount, false);
divMembers.add(divMember);
logger.info("子订单[code={}]分账信息: {}", orderDetail.getCode(), JSON.toJSONString(divMembers));
JSONObject response = adapayService.paymentConfirm(orderDetail.getDeptId(), payment.getId(), payment.getOrderNo(),
amount, divMembers, null, null);
logger.info("子订单[code={}]分账结果: {}", orderDetail.getCode(), response.toJSONString());
boolean status = AdapayStatusEnum.pending.code.equals(response.getString("status")) ||
AdapayStatusEnum.succeeded.code.equals(response.getString("status"));
// 如果确认支付失败 这里抛出异常 回滚订单状态
Assert.isTrue(status, response.getString("error_msg"));
// 走到这里确认分账成功了 异步进入自动提现流程
logger.info("子订单[code={}]开始自动提现", orderDetail.getCode());
divMembers.forEach(member -> executor.execute(() -> {
try {
String orderNo = AdapayUtils.createOrderNo(AdapayOrderType.DRAW_CASH);
JSONObject drawCashResponse = adapayService.drawCash(orderDetail.getDeptId(), orderNo, "T1",
amount, memberId, "订单结算", null);
boolean drawCashStatus = AdapayStatusEnum.pending.code.equals(drawCashResponse.getString("status")) ||
AdapayStatusEnum.succeeded.code.equals(drawCashResponse.getString("status"));
if (!drawCashStatus) {
//如果提现失败 把信息记录到error日志里
logger.error("自动发起提现失败: deptId={}, memberId={}, amount={}, 失败原因:{}", orderDetail.getDeptId(),
memberId, amount, drawCashResponse.getString("error_msg"));
}
} catch (BaseAdaPayException e) {
logger.error("自动发起提现失败: orderDetailId={}, memberId={}, cashAmt={}", orderDetailId, memberId, amount, e);
}
}));
}
}

55
ghy-order/src/main/java/com/ghy/order/service/impl/OrderMasterServiceImpl.java
View File

@ -83,10 +83,6 @@ public class OrderMasterServiceImpl implements OrderMasterService {
@Override
public int updateOrderMaster(OrderMaster orderMaster) throws BaseAdaPayException {
if (orderMaster.getOrderStatus().equals(OrderStatus.FINISH.code())) {
logger.info("订单[ID={}]完成，进入确认分账", orderMaster.getId());
finish(orderMaster.getId());
}
return orderMasterMapper.updateOrderMaster(orderMaster);
}
@ -131,17 +127,39 @@ public class OrderMasterServiceImpl implements OrderMasterService {
return orderMasterMapper.updateStatus(orderMasterId, orderStatus);
}
/**
* 主订单完成
* 由定时器触发 而不是由用户触发（用户只能对子订单操作完成）
* 当所有的子订单完成后 定时器进入此方法
* 1.修改主订单状态
* 2.对提成、分销、罚款、手续费等类型的财务单分销和提现
*
* @param orderMasterId 主订单ID
*/
@Override
@Transactional(rollbackFor = Exception.class)
public void finish(Long orderMasterId) throws BaseAdaPayException {
// 暂时先用 synchronized 来避免重复提交
public synchronized void finish(Long orderMasterId) throws BaseAdaPayException {
// 校验订单
OrderMaster orderMaster = selectById(orderMasterId);
Assert.notNull(orderMaster, "找不到对应的订单");
Assert.notNull(orderMaster, "订单不存在");
List<OrderDetail> orderDetails = orderDetailService.selectByOrderMasterId(orderMasterId);
for (OrderDetail orderDetail : orderDetails) {
logger.info("主订单[id={}]存在未完成的子订单", orderMasterId);
if (orderDetail.getOrderStatus() < 5) {
return;
}
}
FinancialMaster financialMaster = financialMasterService.selectByOrderMasterId(orderMasterId);
Assert.notNull(financialMaster, "找不到订单");
Assert.isTrue(financialMaster.getPayStatus() == 1, "订单未支付");
Assert.notNull(financialMaster, String.format("主订单[id=%d]找不到对应的主财务单", orderMasterId));
if (financialMaster.getPayStatus() != 1) {
logger.info("主订单[id={}]未支付", orderMasterId);
return;
}
PaymentDTO payment = financialMasterService.selectPaymentById(financialMaster.getPaymentId());
Assert.notNull(payment, "找不到支付记录");
Assert.notNull(payment, String.format("主订单[id=%d]找不到支付记录", orderMasterId));
updateStatus(orderMasterId, OrderStatus.FINISH_CHECK.code());
if (BigDecimal.ZERO.compareTo(financialMaster.getPayMoney()) > -1) {
logger.info("订单[code={}]支付金额<=0，不需要分账", orderMaster.getCode());
@ -153,7 +171,7 @@ public class OrderMasterServiceImpl implements OrderMasterService {
List<FinancialDetail> financialDetails = financialDetailService.selectByFinancialMasterId(financialMaster.getId());
// 校验金额 主财务单的金额减去所有子财务单的金额是否=0
BigDecimal checkMoney = financialMaster.getPayMoney();
// 确认支付金额 = 主财务单付款金额 - 退款金额
// 确认支付金额 = 主财务单付款金额 - 退款金额 - 已确认金额
BigDecimal confirmAmt = financialMaster.getPayMoney();
// key:memberId(分账账户ID) value:分账金额
@ -164,11 +182,9 @@ public class OrderMasterServiceImpl implements OrderMasterService {
String memberId;
switch (financialDetail.getFinancialDetailType()) {
case 0:
// 上门师傅结单 要判断一下这个单是否已退款
if (financialDetail.getPayStatus() < 2) {
memberId = AdapayUtils.getWorkerMemberId(financialDetail.getPayeeId(), orderMaster.getDeptId());
memberMap.merge(memberId, financialDetail.getPayMoney(), BigDecimal::add);
}
// 上门师傅的财务单单独确认分账了 不在这里分
// 减掉已确认金额
confirmAmt = confirmAmt.subtract(financialDetail.getPayMoney());
break;
case 1:
// 大师傅/店铺提成
@ -192,7 +208,7 @@ public class OrderMasterServiceImpl implements OrderMasterService {
}
break;
case 4:
// 退款
// 减掉退款金额
confirmAmt = confirmAmt.subtract(financialDetail.getPayMoney());
case 5:
// 订单超时罚金 归平台所有
@ -204,7 +220,7 @@ public class OrderMasterServiceImpl implements OrderMasterService {
}
// 这里校验一次主财务单的金额减去所有子财务单的金额是否=0
Assert.isTrue(BigDecimal.ZERO.compareTo(checkMoney) == 0, "订单异常，请稍后再试");
Assert.isTrue(BigDecimal.ZERO.compareTo(checkMoney) == 0, "订单金额异常，请稍后再试");
// 分账账户
ArrayList<DivMember> divMembers = new ArrayList<>();
@ -384,4 +400,9 @@ public class OrderMasterServiceImpl implements OrderMasterService {
Assert.isTrue(status, response.getString("error_msg"));
logger.info("订单[code={}]退款成功", orderMaster.getCode());
}
@Override
public List<OrderMaster> selectUnfinished() {
return orderMasterMapper.selectUnfinished();
}
}

9
ghy-order/src/main/resources/mapper/order/OrderMasterMapper.xml
View File

@ -254,7 +254,7 @@
<select id="checkOrderMasterCodeUnique" parameterType="String" resultMap="OrderMasterResult">
<include refid="selectOrderMaster"/>
WHERE `code` =#{orderMasterCode} LIMIT 1
WHERE `code` = #{orderMasterCode} LIMIT 1
</select>
<select id="selectByCode" parameterType="String" resultMap="OrderMasterResult">
@ -262,7 +262,7 @@
WHERE `code` = #{orderMasterCode}
</select>
<select id="selectByStatus" resultType="com.ghy.order.domain.OrderMaster">
<select id="selectByStatus" resultMap="OrderMasterResult">
<include refid="selectOrderMaster"/>
WHERE `order_status` IN
<foreach collection="list" item="orderStatus" open="(" separator="," close=")">
@ -270,4 +270,9 @@
</foreach>
</select>
<select id="selectUnfinished" resultMap="OrderMasterResult">
<include refid="selectOrderMaster"/>
WHERE `order_status` &lt; 5
</select>
</mapper>

8
ghy-payment/src/main/java/com/ghy/payment/domain/FinancialMaster.java
View File

@ -57,6 +57,14 @@ public class FinancialMaster extends BaseEntity {
private List<Long> ids;
private Integer type;
private Long userId;
private String orderCode;
private List<FinancialDetail> details;
public FinancialMaster() {
}

5
ghy-payment/src/main/java/com/ghy/payment/service/FinancialMasterService.java
View File

@ -30,6 +30,11 @@ public interface FinancialMasterService {
*/
List<FinancialMaster> selectFinancialMasterList(FinancialMaster financialMaster);
/**
* @param request 主财务单入参
* @return 主财务单集合
* */
List<FinancialMaster> selectAppList(FinancialMaster request);
/**
* @param financialMasterId 主财务单id

19
ghy-payment/src/main/java/com/ghy/payment/service/impl/FinancialMasterServiceImpl.java
View File

@ -4,9 +4,11 @@ import com.ghy.common.adapay.model.PaymentDTO;
import com.ghy.common.core.text.Convert;
import com.ghy.common.enums.PayStatus;
import com.ghy.common.enums.PayTypeEnum;
import com.ghy.payment.domain.FinancialDetail;
import com.ghy.payment.domain.FinancialMaster;
import com.ghy.payment.mapper.FinancialMasterMapper;
import com.ghy.payment.mapper.PaymentMapper;
import com.ghy.payment.service.FinancialDetailService;
import com.ghy.payment.service.FinancialMasterService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -42,6 +44,8 @@ public class FinancialMasterServiceImpl implements FinancialMasterService {
private PaymentMapper paymentMapper;
@Resource
private FinancialMasterMapper financialMasterMapper;
@Resource
private FinancialDetailService financialDetailService;
@Override
public int insertFinancialMaster(FinancialMaster financialMaster) {
@ -58,6 +62,21 @@ public class FinancialMasterServiceImpl implements FinancialMasterService {
return financialMasterMapper.selectFinancialMasterList(financialMaster);
}
@Override
public List<FinancialMaster> selectAppList(FinancialMaster request) {
List<FinancialMaster> masterList =this.selectFinancialMasterList(request);
masterList.forEach(master->{
FinancialDetail param = new FinancialDetail();
param.setFinancialMasterId(master.getId());
param.setPayeeId(request.getUserId());
List<FinancialDetail> details = financialDetailService.selectFinancialDetailList(param);
details.forEach(detail->{
});
});
return null;
}
@Override
public FinancialMaster selectById(Long financialMasterId) {
return financialMasterMapper.selectById(financialMasterId);

30
ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java
View File

@ -24,6 +24,7 @@ import javax.annotation.Resource;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.Calendar;
import java.util.Collections;
import java.util.Date;
import java.util.List;
@ -121,24 +122,33 @@ public class OrderServiceImpl implements OrderService {
@Override
public void finishOrder() {
OrderMaster orderMaster = new OrderMaster();
orderMaster.setOrderStatus(OrderStatus.FINISH_CHECK.code());
List<OrderMaster> orders = orderMasterService.selectOrderMasterList(orderMaster);
// 查询出"待确认"状态的子订单
List<OrderDetail> orderDetails = orderDetailService.selectByStatus(Collections.singletonList(OrderStatus.FINISH_CHECK.code()));
long now = System.currentTimeMillis();
long day14ago = now - (14 * 24 * 60 * 60 * 1000L);
for (OrderMaster order : orders) {
for (OrderDetail orderDetail : orderDetails) {
// 查询符合自动确认的订单
if (day14ago > order.getUpdateTime().getTime()) {
logger.info("订单自动完成[id={}, code={}]", order.getId(), order.getCode());
if (day14ago > orderDetail.getUpdateTime().getTime()) {
logger.info("订单自动完成[id={}, code={}]", orderDetail.getId(), orderDetail.getCode());
try {
// 完单流程(分账与提现)
orderMasterService.finish(order.getId());
// 修改订单状态
orderMasterService.updateStatus(order.getId(), OrderStatus.FINISH.code());
orderDetailService.finish(orderDetail.getId());
} catch (BaseAdaPayException e) {
logger.error("订单自动完成[id={}, code={}]出错", order.getId(), order.getCode(), e);
logger.error("订单自动完成[id={}, code={}]出错", orderDetail.getId(), orderDetail.getCode(), e);
}
}
}
// 当所有的子订单完成后 自动把主订单完成
List<OrderMaster> orderMasters = orderMasterService.selectUnfinished();
for (OrderMaster orderMaster : orderMasters) {
executor.execute(() -> {
try {
orderMasterService.finish(orderMaster.getId());
}catch (Exception e){
logger.error("主订单 Finish 失败", e);
}
});
}
}
}