|
@@ -44,8 +44,9 @@ import redis.clients.jedis.JedisCluster;
|
|
import javax.annotation.Resource;
|
|
import javax.annotation.Resource;
|
|
|
|
|
|
import static com.fire.common.constants.RocketTopic.ORDER_TOPIC;
|
|
import static com.fire.common.constants.RocketTopic.ORDER_TOPIC;
|
|
|
|
+import static com.fire.dto.enums.OrderStatus.ORDER_FAIL;
|
|
import static com.fire.dto.enums.RedisKey.ORDER_INFO;
|
|
import static com.fire.dto.enums.RedisKey.ORDER_INFO;
|
|
-
|
|
|
|
|
|
+import static com.fire.dto.enums.OrderStatus.ORDER_SUCCESS;
|
|
@Service
|
|
@Service
|
|
@Slf4j
|
|
@Slf4j
|
|
public class OrderManagementService {
|
|
public class OrderManagementService {
|
|
@@ -733,6 +734,8 @@ public class OrderManagementService {
|
|
try {
|
|
try {
|
|
//状态改为成功或失败
|
|
//状态改为成功或失败
|
|
flowOrderInfo.setStatus(orderSetPram.getStatus());
|
|
flowOrderInfo.setStatus(orderSetPram.getStatus());
|
|
|
|
+ flowOrderInfo.setNote(orderSetPram.getStatus()==ORDER_SUCCESS.status() ? ORDER_SUCCESS.message(): ORDER_FAIL.message());
|
|
|
|
+ flowOrderInfo.setGwStatus(flowOrderInfo.getNote());
|
|
String orderString = om.writeValueAsString(flowOrderInfo);
|
|
String orderString = om.writeValueAsString(flowOrderInfo);
|
|
//redis改状态
|
|
//redis改状态
|
|
long hKey = flowOrderInfo.getOrderId() / 10000000;
|
|
long hKey = flowOrderInfo.getOrderId() / 10000000;
|