Przeglądaj źródła

feat: 提交订单消息队列

shc 3 lat temu
rodzic
commit
4f65a689df

+ 6 - 0
hnqz-upms/hnqz-upms-api/src/main/java/com/qunzhixinxi/hnqz/admin/api/constant/MqConstants.java

@@ -25,4 +25,10 @@ public interface MqConstants {
 	String DIRECT_MODE_GIG_SIGN_CERT_QUEUE = "direct_mode_gig_sign_cert_queue";
 	String DIRECT_MODE_GIG_SIGN_CERT_RES_QUEUE = "direct_mode_gig_sign_cert_res_queue";
 	String DIRECT_MODE_GIG_BANK_CARD_QUEUE = "direct_mode_gig_bank_card_queue";
+
+	/**
+	 * 订单服务队列
+	 */
+	String DIRECT_MODE_OMS_ORDER_BATCH_SUBMIT_QUEUE = "direct_mode_oms_order_batch_submit_queue";
+
 }

+ 1 - 0
hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/controller/WmPayOffController.java

@@ -154,6 +154,7 @@ public class WmPayOffController {
 	 * @Author: ryz
 	 * @Date: 2021/4/28
 	*/
+	@Deprecated
 	@ApiOperation(value = "结算", notes = "结算")
 	@SysLog("结算" )
 	@PostMapping("/settleIssue")

+ 2 - 0
hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/service/impl/WmPayOffServiceImpl.java

@@ -21,6 +21,7 @@ import com.qunzhixinxi.hnqz.common.ding.config.DingConfig;
 import com.qunzhixinxi.hnqz.common.ding.entity.*;
 import com.qunzhixinxi.hnqz.common.ding.enums.DingEnum;
 import com.qunzhixinxi.hnqz.common.ding.service.DingService;
+import com.qunzhixinxi.hnqz.common.rabbitmq.client.RabbitMqClient;
 import com.qunzhixinxi.hnqz.common.security.service.HnqzUser;
 import com.qunzhixinxi.hnqz.common.security.util.SecurityUtils;
 import com.qunzhixinxi.hnqz.common.taxhelper.config.TaxHelperConfig;
@@ -70,6 +71,7 @@ public class WmPayOffServiceImpl extends ServiceImpl<WmPayOffMapper, WmPayOff> i
 	private final WmDaDrugEntService wmDaDrugEntService;
 	private final TaxHelperService taxHelperService;
 	private final TaxNotifyConfig taxNotifyConfig;
+	private final RabbitMqClient rabbitMqClient;
 
 	@Override
 	@Transactional(rollbackFor = Exception.class)