DemandReleaseOrderServiceImpl(update)

src/main/java/com/mmc/oms/service/demand/Impl/DemandReleaseOrderServiceImpl.java

@@ -13,6 +13,7 @@ import com.mmc.oms.dao.topup.TopUpOrderDao;
 import com.mmc.oms.entity.demand.DemandReleaseOrderDO;
 import com.mmc.oms.entity.demand.GetOrderNumberDO;
 import com.mmc.oms.entity.demand.GetOrderNumberDTO;
+import com.mmc.oms.entity.demand.ServiceRequirementsDO;
 import com.mmc.oms.entity.topup.TopUpOrderDO;
 import com.mmc.oms.model.vo.demand.CommonPaymentVO;
 import com.mmc.oms.model.vo.demand.DemandReleaseOrderVO;
@@ -58,6 +59,9 @@ public class DemandReleaseOrderServiceImpl implements DemandReleaseOrderService
     @Value("${payment.url}")
     private String paymentUrl;
 
+    @Value("${ims.url}")
+    private String imsApp;
+
     @Autowired
     private StringRedisTemplate stringRedisTemplate;
 
@@ -82,7 +86,7 @@ public class DemandReleaseOrderServiceImpl implements DemandReleaseOrderService
                 return orderPost(commonPaymentVO, token);
             case "4":
                 //发布服务需求支付
-                return publishServicePay(commonPaymentVO, token, userAccountId);
+                return publishServicePay(commonPaymentVO, token, userAccountId,request);
             case "5":
                 return topUpOrder(commonPaymentVO, token, userAccountId);
             default:
@@ -139,7 +143,7 @@ public class DemandReleaseOrderServiceImpl implements DemandReleaseOrderService
      * @param userAccountId
      * @return
      */
-    private ResultBody publishServicePay(CommonPaymentVO commonPaymentVO, String token,Integer userAccountId) {
+    private ResultBody publishServicePay(CommonPaymentVO commonPaymentVO, String token,Integer userAccountId, HttpServletRequest request) {
 
         if ("4".equals(commonPaymentVO.getOrderPort().toString())){
             String orderNumber = commonPaymentVO.getOrderNumber();
@@ -151,6 +155,11 @@ public class DemandReleaseOrderServiceImpl implements DemandReleaseOrderService
                 if (i!=0){
                     return ResultBody.error("当前需求已有人支付");
                 }
+                ServiceRequirementsDO repertory = repertory(getOrderNumberDO.getRequirementsInfoId(), request);
+                Integer repertory1 = repertory.getRepertory();
+                if (repertory1<=0){
+                    return ResultBody.error("需求已被人抢走");
+                }
             }
             releaseOrderDao.insertService(getOrderNumberDO);
             BigDecimal paramMoney = getOrderNumberDO.getWeChatPay();
@@ -239,4 +248,23 @@ public class DemandReleaseOrderServiceImpl implements DemandReleaseOrderService
         }
         return ResultBody.success(map);
     }
+
+
+    /**
+     * 查看是否支付成功
+     *
+     * @param requirementsInfoId
+     * @return
+     */
+    public ServiceRequirementsDO repertory(Integer requirementsInfoId, HttpServletRequest request) {
+        String token = request.getHeader("token");
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+        headers.add("token", token);
+        HttpEntity<String> entity = new HttpEntity<>(JSONObject.toJSONString(requirementsInfoId), headers);
+        ResponseEntity<ServiceRequirementsDO> exchange = restTemplate.exchange(imsApp + "requirements/repertory?requirementsInfoId=" + requirementsInfoId, HttpMethod.GET, entity, ServiceRequirementsDO.class);
+        ServiceRequirementsDO body = exchange.getBody();
+        return body;
+    }
+
 }