多小程序支付开发

fs-admin/src/main/java/com/fs/store/controller/FsStorePaymentController.java

@@ -36,8 +36,17 @@ import com.fs.store.service.impl.FsCouponScheduleServiceImpl;
 import com.fs.store.service.impl.FsStoreOrderServiceImpl;
 import com.fs.store.vo.FsStorePaymentVO;
 import com.fs.pay.service.IPayService;
+import com.fs.system.domain.WxMiniProgramConfig;
+import com.fs.system.mapper.WxMiniProgramConfigMapper;
 import com.fs.tzBank.TzBankService;
 import com.fs.tzBank.utils.TzConfigUtils;
+import com.github.binarywang.wxpay.bean.request.WxPayRefundRequest;
+import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
+import com.github.binarywang.wxpay.bean.result.WxPayRefundQueryResult;
+import com.github.binarywang.wxpay.bean.result.WxPayRefundResult;
+import com.github.binarywang.wxpay.config.WxPayConfig;
+import com.github.binarywang.wxpay.exception.WxPayException;
+import com.github.binarywang.wxpay.service.WxPayService;
 import com.hc.openapi.tool.fastjson.JSON;
 import com.ijpay.alipay.AliPayApi;
 import com.ijpay.alipay.AliPayApiConfig;
@@ -69,8 +78,13 @@ import com.fs.common.core.page.TableDataInfo;
 @RequestMapping("/store/storePayment")
 public class FsStorePaymentController extends BaseController
 {
+    @Autowired
+    private WxPayService wxPayService;
     @Autowired
     private IFsStorePaymentService fsStorePaymentService;
+
+    @Autowired
+    private WxMiniProgramConfigMapper wxMiniProgramConfigMapper;
     @Autowired
     private IPayService payService;
     @Autowired
@@ -294,6 +308,41 @@ public class FsStorePaymentController extends BaseController
                     TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                     return R.error(result.getMessage());
                 }
+            }else if (payment.getPayMode()==null||payment.getPayMode().equals("wx")){
+                WxMiniProgramConfig wxMiniProgramConfig = new WxMiniProgramConfig();
+                wxMiniProgramConfig.setAppid(fsStorePayment.getAppId());
+                List<WxMiniProgramConfig>  wxMiniProgramConfigs = wxMiniProgramConfigMapper.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+                WxMiniProgramConfig wConfig = wxMiniProgramConfigs.get(0);
+                WxPayConfig payConfig = new WxPayConfig();
+                payConfig.setAppId(wConfig.getAppid());
+                payConfig.setMchId(wConfig.getWxMerchantNo());
+                payConfig.setMchKey(wConfig.getWxKey());
+                payConfig.setKeyPath(wConfig.getWxKeyPath());
+                payConfig.setSubAppId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+                payConfig.setSubMchId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+                wxPayService.setConfig(payConfig);
+                WxPayRefundRequest refundRequest = new WxPayRefundRequest();
+                refundRequest.setOutTradeNo("store-"+payment.getPayCode());
+                refundRequest.setOutRefundNo("store-"+payment.getPayCode());
+                refundRequest.setTotalFee(WxPayUnifiedOrderRequest.yuanToFen(payment.getPayMoney().toString()));
+                refundRequest.setRefundFee(WxPayUnifiedOrderRequest.yuanToFen(fsStorePayment.getRefundMoney().toString()));
+                try {
+                    WxPayRefundResult refundResult = wxPayService.refund(refundRequest);
+                    WxPayRefundQueryResult refundQueryResult = wxPayService.refundQuery("", refundResult.getOutTradeNo(), refundResult.getOutRefundNo(), refundResult.getRefundId());
+                    if(refundQueryResult!=null&&refundQueryResult.getResultCode().equals("SUCCESS")){
+                        FsStorePayment paymentMap=new FsStorePayment();
+                        paymentMap.setPaymentId(payment.getPaymentId());
+                        paymentMap.setStatus(-1);
+                        paymentMap.setRefundTime(DateUtils.getNowDate());
+                        paymentMap.setRefundMoney(fsStorePayment.getRefundMoney());
+                        fsStorePaymentService.updateFsStorePayment(paymentMap);
+                    }
+                    else {
+                        return R.error("退款请求失败"+refundQueryResult.getErrCodeDes());
+                    }
+                } catch (WxPayException e) {
+                    return R.error("退款请求失败"+e.getErrCodeDes());
+                }
             }else if (payment.getPayMode()!=null&&payment.getPayMode().equals("hf")){
                 V2TradePaymentScanpayRefundRequest request = new V2TradePaymentScanpayRefundRequest();
                 request.setOrdAmt(payment.getPayMoney().toString());

fs-admin/src/main/java/com/fs/web/controller/system/FsCoursePlaySourceConfigController.java

@@ -1,8 +1,10 @@
 package com.fs.web.controller.system;
 
+import cn.hutool.json.JSONUtil;
 import com.fs.common.annotation.Log;
 import com.fs.common.core.controller.BaseController;
 import com.fs.common.core.domain.AjaxResult;
+import com.fs.common.core.domain.R;
 import com.fs.common.core.page.TableDataInfo;
 import com.fs.common.enums.BusinessType;
 import com.fs.common.utils.ServletUtils;
@@ -45,8 +47,6 @@ public class FsCoursePlaySourceConfigController extends BaseController {
         FsCoursePlaySourceConfig fsCoursePlaySourceConfig = new FsCoursePlaySourceConfig();
         fsCoursePlaySourceConfig.setName(name);
         fsCoursePlaySourceConfig.setAppid(appid);
-        fsCoursePlaySourceConfig.setIsMall(isMall);
-        fsCoursePlaySourceConfig.setCompanyId(companyId);
         LoginUser loginUser = tokenService.getLoginUser(ServletUtils.getRequest());
         fsCoursePlaySourceConfig.setCreateUserId(loginUser.getUser().getUserId());
         fsCoursePlaySourceConfig.setCreateDeptId(loginUser.getUser().getDeptId());
@@ -72,17 +72,16 @@ public class FsCoursePlaySourceConfigController extends BaseController {
     public AjaxResult add(@Valid @RequestBody FsCoursePlaySourceConfigCreateParam param) {
         FsCoursePlaySourceConfig fsCoursePlaySourceConfig = new FsCoursePlaySourceConfig();
         fsCoursePlaySourceConfig.setAppid(param.getAppid());
-        fsCoursePlaySourceConfig.setIsMall(0);
+        fsCoursePlaySourceConfig.setIsDel(0);
         List<FsCoursePlaySourceConfig> list = fsCoursePlaySourceConfigService.selectFsCoursePlaySourceConfigList(fsCoursePlaySourceConfig);
         if (CollectionUtils.isNotEmpty(list) && !list.get(0).getAppid().equals(param.getAppid())) {
             return AjaxResult.error("appid已存在");
         }
         LoginUser loginUser = tokenService.getLoginUser(ServletUtils.getRequest());
         FsCoursePlaySourceConfig config = new FsCoursePlaySourceConfig();
+        BeanUtils.copyProperties(param, config);
         config.setCreateUserId(loginUser.getUser().getUserId());
         config.setCreateDeptId(loginUser.getUser().getDeptId());
-        BeanUtils.copyProperties(param, config);
-
         config.setIsDel(0);
         config.setCreateTime(new Date());
         fsCoursePlaySourceConfigService.insertFsCoursePlaySourceConfig(config);
@@ -111,5 +110,8 @@ public class FsCoursePlaySourceConfigController extends BaseController {
         return AjaxResult.success();
     }
 
-
+    @GetMapping("/listAll")
+    public R listAll() {
+        return R.ok().put("data", fsCoursePlaySourceConfigService.selectFsCoursePlaySourceConfigAll());
+    }
 }

fs-admin/src/main/java/com/fs/web/controller/system/WxMiniProgramConfigController.java

@@ -0,0 +1,103 @@
+package com.fs.web.controller.system;
+
+import java.util.List;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import com.fs.common.annotation.Log;
+import com.fs.common.core.controller.BaseController;
+import com.fs.common.core.domain.AjaxResult;
+import com.fs.common.enums.BusinessType;
+import com.fs.system.domain.WxMiniProgramConfig;
+import com.fs.system.service.IWxMiniProgramConfigService;
+import com.fs.common.utils.poi.ExcelUtil;
+import com.fs.common.core.page.TableDataInfo;
+
+/**
+ * 微信小程序支付配置Controller
+ *
+ * @author fs
+ * @date 2025-12-01
+ */
+@RestController
+@RequestMapping("/system/wxMiniProgramConfig")
+public class WxMiniProgramConfigController extends BaseController
+{
+    @Autowired
+    private IWxMiniProgramConfigService wxMiniProgramConfigService;
+
+    /**
+     * 查询微信小程序支付配置列表
+     */
+    @PreAuthorize("@ss.hasPermi('system:wxMiniProgramConfig:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(WxMiniProgramConfig wxMiniProgramConfig)
+    {
+        startPage();
+        List<WxMiniProgramConfig> list = wxMiniProgramConfigService.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出微信小程序支付配置列表
+     */
+    @PreAuthorize("@ss.hasPermi('system:wxMiniProgramConfig:export')")
+    @Log(title = "微信小程序支付配置", businessType = BusinessType.EXPORT)
+    @GetMapping("/export")
+    public AjaxResult export(WxMiniProgramConfig wxMiniProgramConfig)
+    {
+        List<WxMiniProgramConfig> list = wxMiniProgramConfigService.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+        ExcelUtil<WxMiniProgramConfig> util = new ExcelUtil<WxMiniProgramConfig>(WxMiniProgramConfig.class);
+        return util.exportExcel(list, "wxMiniProgramConfig");
+    }
+
+    /**
+     * 获取微信小程序支付配置详细信息
+     */
+    @PreAuthorize("@ss.hasPermi('system:wxMiniProgramConfig:query')")
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Long id)
+    {
+        return AjaxResult.success(wxMiniProgramConfigService.selectWxMiniProgramConfigById(id));
+    }
+
+    /**
+     * 新增微信小程序支付配置
+     */
+    @PreAuthorize("@ss.hasPermi('system:wxMiniProgramConfig:add')")
+    @Log(title = "微信小程序支付配置", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody WxMiniProgramConfig wxMiniProgramConfig)
+    {
+        return toAjax(wxMiniProgramConfigService.insertWxMiniProgramConfig(wxMiniProgramConfig));
+    }
+
+    /**
+     * 修改微信小程序支付配置
+     */
+    @PreAuthorize("@ss.hasPermi('system:wxMiniProgramConfig:edit')")
+    @Log(title = "微信小程序支付配置", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody WxMiniProgramConfig wxMiniProgramConfig)
+    {
+        return toAjax(wxMiniProgramConfigService.updateWxMiniProgramConfig(wxMiniProgramConfig));
+    }
+
+    /**
+     * 删除微信小程序支付配置
+     */
+    @PreAuthorize("@ss.hasPermi('system:wxMiniProgramConfig:remove')")
+    @Log(title = "微信小程序支付配置", businessType = BusinessType.DELETE)
+	@DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Long[] ids)
+    {
+        return toAjax(wxMiniProgramConfigService.deleteWxMiniProgramConfigByIds(ids));
+    }
+}

fs-service-system/src/main/java/com/fs/huifuPay/domain/HuiFuCreateOrder.java

@@ -19,4 +19,9 @@ public class HuiFuCreateOrder {
     String transAmt;
     String goodsDesc;
     String openid;
+
+    /**
+     * 多小程序支付
+     */
+    String appId;
 }

fs-service-system/src/main/java/com/fs/huifuPay/service/impl/HuiFuServiceImpl.java

@@ -3,6 +3,7 @@ package com.fs.huifuPay.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.fs.common.exception.CustomException;
+import com.fs.common.utils.StringUtils;
 import com.fs.common.utils.spring.SpringUtils;
 import com.fs.huifuPay.domain.*;
 import com.fs.huifuPay.sdk.opps.core.config.MerConfig;
@@ -57,10 +58,14 @@ public class HuiFuServiceImpl implements HuiFuService {
             extendInfoMap.put("pay_scene", "02");
             // 传入分帐遇到优惠的处理规则
             extendInfoMap.put("term_div_coupon_type", "0");
+            String appId = order.getAppId();
+            if (StringUtils.isBlank(appId)){
+                appId = config.getAppId();
+            }
             if (order.getTradeType().equals("T_MINIAPP")||order.getTradeType().equals("T_JSAPI")){
                 JSONObject dto = new JSONObject();
                 // 子商户公众账号id
-                dto.put("sub_appid", config.getAppId());
+                dto.put("sub_appid", appId);
                 // 用户标识
                 dto.put("openid", order.getOpenid());
                 extendInfoMap.put("wx_data", dto);

fs-service-system/src/main/java/com/fs/store/domain/FsCoursePlaySourceConfig.java

@@ -62,39 +62,15 @@ public class FsCoursePlaySourceConfig extends BaseEntity {
      */
     private String msgDataFormat;
 
-    /**
-     * 类型 1小程序 2公众号
-     */
-    private Integer type;
-
     /**
      * 是否删除 0正常 1删除
      */
     private Integer isDel;
-
-    /**
-     * 公司ID
-     */
-    private Long companyId;
-
-    /**
-     * 销售公司ids 用于判定销售公司可见编辑列表
-     */
-    private String setCompanyIds;
-    /**
-     * 销售ID
-     */
-    private Long companyUserId;
     // 创建人
     private Long createUserId;
     // 创建部门
     private Long createDeptId;
 
-    /**
-     * 是否是互医/商城小程序
-     */
-    private Integer isMall;
-
     /**
      * 小程序状态：0正常，1半封禁，2封禁
      */

fs-service-system/src/main/java/com/fs/store/domain/FsStorePayment.java

@@ -82,6 +82,21 @@ public class FsStorePayment extends BaseEntity
 
     private Integer isPayRemain;
 
+    /**
+     * 小程序appId
+     */
+    private String appId;
+
+
+    public String getAppId() {
+        return appId;
+    }
+
+    public FsStorePayment setAppId(String appId) {
+        this.appId = appId;
+        return this;
+    }
+
     public String getPayMode() {
         return payMode;
     }

fs-service-system/src/main/java/com/fs/store/domain/FsUserWx.java

@@ -0,0 +1,47 @@
+package com.fs.store.domain;
+
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class FsUserWx {
+    /**
+     * 主键ID
+     */
+    private Long id;
+    /**
+     * 用户ID
+     */
+    private Long fsUserId;
+
+    /**
+     * 公司ID
+     */
+    private Long companyId;
+    /**
+     * 小程序/公众号appId
+     */
+    private String appId;
+    /**
+     * 微信unionId
+     */
+    private String unionId;
+    /**
+     * 微信openId
+     */
+    private String openId;
+
+    /**
+     * 1:小程序 2：服务号
+     */
+    private Integer type;
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+}

fs-service-system/src/main/java/com/fs/store/mapper/FsStorePaymentMapper.java

@@ -132,7 +132,7 @@ public interface FsStorePaymentMapper
             " AND date_format(p.create_time,'%y%m%d') >= date_format(#{maps.createTimeList[0]},'%y%m%d') " +
             " AND date_format(p.create_time,'%y%m%d') <= date_format(#{maps.createTimeList[1]},'%y%m%d') " +
             "</if>" +
-
+            "            <if test=\"maps.appId != null and maps.appId != ''\">  and sp.app_id like #{maps.appId}</if>\n" +
 //            "<if test = 'maps.refundTime != null    '> " +
 //            "and DATE_FORMAT(p.refund_time,'%Y-%m-%d') = DATE_FORMAT(#{maps.refundTime},'%Y-%m-%d')  " +
 //            "</if>" +

fs-service-system/src/main/java/com/fs/store/mapper/FsUserWxMapper.java

@@ -0,0 +1,45 @@
+package com.fs.store.mapper;
+
+
+import com.fs.store.domain.FsUserWx;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+import java.util.List;
+
+public interface FsUserWxMapper{
+
+    /**
+     * 根据FsUserId和AppId唯一键保存或更新
+     * @param wx    配置信息
+     */
+    void insertOrUpdateByUniqueKey(FsUserWx wx);
+
+
+    /**
+     * 根据fs_user_id、app_id、openId进行修改
+     * @param userId
+     * @param appId
+     * @param openId
+     * @param companyId
+     * @param unionId
+     * @param updateTime
+     * @return
+     */
+    int updateFsUserWx(@Param("userId") Long userId,
+                       @Param("appId") String appId,
+                       @Param("openId") String openId,
+                       @Param("companyId") Long companyId,
+                       @Param("unionId") String unionId,
+                       @Param("updateTime") Date updateTime);
+
+    /**
+     * 查询用户小程序关联信息
+     *
+     * @param userId
+     * @param appId
+     * @return
+     */
+    FsUserWx selectListByUserIdAndAppId(@Param("userId") Long userId,
+                                              @Param("appId") String appId);
+}

fs-service-system/src/main/java/com/fs/store/param/FsStoreOrderOtherPayParam.java

@@ -18,4 +18,8 @@ public class FsStoreOrderOtherPayParam implements Serializable
     private String code;
 
 
+    /**
+     * 小程序APPID
+     */
+    private String appId;
 }

fs-service-system/src/main/java/com/fs/store/param/FsStoreOrderPayParam.java

@@ -16,4 +16,9 @@ public class FsStoreOrderPayParam implements Serializable
     @ApiModelProperty(value = "payType")
     @NotNull(message = "支付类型不能为空")
     private Integer payType;
+
+    /**
+     * appId
+     */
+    private String appId;
 }

fs-service-system/src/main/java/com/fs/store/param/FsStorePaymentParam.java

@@ -48,4 +48,9 @@ public class FsStorePaymentParam  extends BaseEntity implements Serializable
     private String createTimeRange;
     private String   payMode;
     private String[] createTimeList;
+
+    /**
+     * 小程序Id
+     */
+    private String appId;
 }

fs-service-system/src/main/java/com/fs/store/param/FsStorePaymentPayParam.java

@@ -20,4 +20,9 @@ public class FsStorePaymentPayParam implements Serializable
     private Long companyUserId;
 
     private String code;
+
+    /**
+     * appId
+     */
+    private String appId;
 }

fs-service-system/src/main/java/com/fs/store/param/LoginMaWxParam.java

@@ -0,0 +1,62 @@
+package com.fs.store.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+@Data
+public class LoginMaWxParam implements Serializable {
+
+    @NotBlank(message = "code参数缺失")
+    @ApiModelProperty(value = "小程序登陆code")
+    private String code;
+
+    @ApiModelProperty(value = "小程序完整用户信息的加密数据")
+    private String encryptedData;
+
+    @ApiModelProperty(value = "小程序加密算法的初始向量")
+    private String iv;
+
+    @NotNull(message = "公司id不能为空")
+    @ApiModelProperty(value = "公司id")
+    private Long companyId;
+
+    @NotNull(message = "销售id不能为空")
+    @ApiModelProperty(value = "销售id")
+    private Long companyUserId;
+
+    @ApiModelProperty(value = "用户昵称")
+    private String nickname;
+
+    @ApiModelProperty(value = "用户头像")
+    private String avatar;
+
+    @NotNull(message = "项目id不能为空")
+    @ApiModelProperty(value = "课程归属项目id")
+    private Long projectId;
+
+//    @ApiModelProperty(value = "公司id，如果不是第一位销售，都需要传")
+//    private Long companyId;
+
+//    @ApiModelProperty(value = "电话号码")
+//    private String phoneNumber;
+
+//    @ApiModelProperty(value = "上级销售id，如果没有则不传")
+//    private Long parentCompanyUseId;
+//
+//    @ApiModelProperty(value = "用户密码")
+//    private String password;
+
+    /**
+     * 0：静默授权  1：手机号授权
+     */
+    @NotNull(message = "授权类型缺失")
+    @ApiModelProperty(value = "小程序授权类型")
+    private Integer authType;
+
+    private String appId;
+
+}

fs-service-system/src/main/java/com/fs/store/param/LoginMpWxParam.java

@@ -24,5 +24,8 @@ public class LoginMpWxParam implements Serializable {
 
     private String userCode;
 
-
+    /**
+     * 小程序APPID
+     */
+    private String appId;
 }

fs-service-system/src/main/java/com/fs/store/service/IFsCoursePlaySourceConfigService.java

@@ -58,4 +58,10 @@ public interface IFsCoursePlaySourceConfigService {
      * @return 结果
      */
     int deleteFsCoursePlaySourceConfigById(Long id);
+
+    /**
+     * 查询小程序所有数据
+     * @return
+     */
+    List<FsCoursePlaySourceConfig> selectFsCoursePlaySourceConfigAll();
 }

fs-service-system/src/main/java/com/fs/store/service/channel/WxPaymentHandler.java

@@ -0,0 +1,115 @@
+package com.fs.store.service.channel;
+
+import com.alibaba.fastjson.JSON;
+import com.fs.common.core.domain.R;
+import com.fs.common.exception.CustomException;
+import com.fs.common.utils.DateUtils;
+import com.fs.common.utils.ServletUtils;
+import com.fs.common.utils.ip.IpUtils;
+import com.fs.huifuPay.domain.HuiFuCreateOrder;
+import com.fs.huifuPay.domain.HuiFuRefundResult;
+import com.fs.huifuPay.domain.HuifuCreateOrderResult;
+import com.fs.huifuPay.sdk.opps.core.request.V2TradePaymentScanpayRefundRequest;
+import com.fs.huifuPay.service.HuiFuService;
+import com.fs.store.domain.FsStorePayment;
+import com.fs.store.service.channel.param.PayProcessContext;
+import com.fs.system.domain.WxMiniProgramConfig;
+import com.github.binarywang.wxpay.bean.order.WxPayMpOrderResult;
+import com.github.binarywang.wxpay.bean.request.WxPayRefundRequest;
+import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
+import com.github.binarywang.wxpay.bean.result.WxPayRefundQueryResult;
+import com.github.binarywang.wxpay.bean.result.WxPayRefundResult;
+import com.github.binarywang.wxpay.config.WxPayConfig;
+import com.github.binarywang.wxpay.exception.WxPayException;
+import com.github.binarywang.wxpay.service.WxPayService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Scope;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.springframework.beans.factory.config.ConfigurableBeanFactory.SCOPE_PROTOTYPE;
+
+/**
+ * hf支付处理
+ */
+@Service
+@Scope(value = SCOPE_PROTOTYPE)
+@Slf4j
+public class WxPaymentHandler extends PaymentHandler{
+    @Autowired
+    private WxPayService wxPayService;
+
+    @Override
+    protected R doCreateOrder(PayProcessContext context) {
+        WxMiniProgramConfig wxMiniProgramConfig = context.getWxMiniProgramConfig();
+        WxPayConfig payConfig = new WxPayConfig();
+        payConfig.setAppId(wxMiniProgramConfig.getAppid());
+        payConfig.setMchId(wxMiniProgramConfig.getWxMerchantNo());
+        payConfig.setMchKey(wxMiniProgramConfig.getWxKey());
+        payConfig.setSubAppId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+        payConfig.setSubMchId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+        payConfig.setKeyPath(wxMiniProgramConfig.getWxKeyPath());
+        payConfig.setNotifyUrl(wxMiniProgramConfig.getWxNotifyUrl());
+        wxPayService.setConfig(payConfig);
+        WxPayUnifiedOrderRequest orderRequest = new WxPayUnifiedOrderRequest();
+        orderRequest.setOpenid(user.getMaOpenId());//公众号支付提供用户openid
+        orderRequest.setBody("商城订单支付");
+        orderRequest.setOutTradeNo("store-" + context.getPayCode());
+        orderRequest.setTotalFee(WxPayUnifiedOrderRequest.yuanToFen(context.getStorePayment().getPayMoney().toString()));//测试
+        orderRequest.setTradeType("JSAPI");
+        orderRequest.setSpbillCreateIp(IpUtils.getIpAddr(ServletUtils.getRequest()));
+        //调用统一下单接口，获取"预支付交易会话标识"
+        try {
+            WxPayMpOrderResult orderResult = wxPayService.createOrder(orderRequest);
+            String resultJson = JSON.toJSONString(orderResult);
+            return R.ok().put("result", orderResult).put("type", "wx").put("isPay", 0).put("payType",context.getPayType());
+        } catch (WxPayException e) {
+            e.printStackTrace();
+            throw new CustomException("支付失败" + e.getMessage());
+        }
+    }
+
+    @Override
+    protected void doRefundOrder(PayProcessContext context) {
+        WxMiniProgramConfig wxMiniProgramConfig = context.getWxMiniProgramConfig();
+        WxPayConfig payConfig = new WxPayConfig();
+        payConfig.setAppId(wxMiniProgramConfig.getAppid());
+        payConfig.setMchId(wxMiniProgramConfig.getWxMerchantNo());
+        payConfig.setMchKey(wxMiniProgramConfig.getWxKey());
+        payConfig.setKeyPath(wxMiniProgramConfig.getWxKeyPath());
+        payConfig.setSubAppId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+        payConfig.setSubMchId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+        wxPayService.setConfig(payConfig);
+        WxPayRefundRequest refundRequest = new WxPayRefundRequest();
+        refundRequest.setOutTradeNo("store-" + context.getPayCode());
+        refundRequest.setOutRefundNo("store-" + context.getPayCode());
+        refundRequest.setTotalFee(WxPayUnifiedOrderRequest.yuanToFen(context.getStorePayment().getPayMoney().toString()));
+        refundRequest.setRefundFee(WxPayUnifiedOrderRequest.yuanToFen(context.getStorePayment().getPayMoney().toString()));
+        try {
+            WxPayRefundResult refundResult = wxPayService.refund(refundRequest);
+            WxPayRefundQueryResult refundQueryResult = wxPayService.refundQuery("", refundResult.getOutTradeNo(), refundResult.getOutRefundNo(), refundResult.getRefundId());
+            if (refundQueryResult != null && refundQueryResult.getResultCode().equals("SUCCESS")) {
+                FsStorePayment paymentMap = new FsStorePayment();
+                paymentMap.setPaymentId(context.getPaymentId());
+                paymentMap.setStatus(-1);
+                paymentMap.setRefundTime(DateUtils.getNowDate());
+                paymentMap.setRefundMoney(context.getStorePayment().getPayMoney());
+                fsStorePaymentService.updateFsStorePayment(paymentMap);
+            } else {
+                log.error("退款请求失败:{}",refundQueryResult.getErrCodeDes());
+            }
+        } catch (WxPayException e) {
+           log.error("退款请求失败", e.getErrCodeDes());
+        }
+    }
+
+    @Override
+    public boolean support(String code) {
+        return "wx".equals(code);
+    }
+}

fs-service-system/src/main/java/com/fs/store/service/channel/param/PayProcessContext.java

@@ -1,6 +1,8 @@
 package com.fs.store.service.channel.param;
 
 import com.fs.store.domain.FsPayConfig;
+import com.fs.store.domain.FsStorePayment;
+import com.fs.system.domain.WxMiniProgramConfig;
 import lombok.Data;
 
 @Data
@@ -29,11 +31,21 @@ public class PayProcessContext {
      */
     private String payCode;
 
+    /**
+     * 支付详情
+     */
+    private FsStorePayment storePayment;
+
     /**
      * 支付配置信息
      */
     private FsPayConfig fsPayConfig;
 
+    /**
+     * 微信支付配置信息
+     */
+    private WxMiniProgramConfig wxMiniProgramConfig;
+
     /**
      * 订单前缀
      */

fs-service-system/src/main/java/com/fs/store/service/impl/FsCoursePlaySourceConfigServiceImpl.java

@@ -93,4 +93,9 @@ public class FsCoursePlaySourceConfigServiceImpl  implements IFsCoursePlaySource
     {
         return baseMapper.deleteFsCoursePlaySourceConfigById(id);
     }
+
+    @Override
+    public List<FsCoursePlaySourceConfig> selectFsCoursePlaySourceConfigAll() {
+        return baseMapper.selectFsCoursePlaySourceConfigAll();
+    }
 }

fs-service-system/src/main/java/com/fs/store/service/impl/FsStoreAfterSalesServiceImpl.java

@@ -37,6 +37,8 @@ import com.fs.store.cache.IFsWarehouseCacheService;
 import com.fs.store.mapper.FsStoreDeliversMapper;
 import com.fs.store.mapper.FsWarehousesMapper;
 import com.fs.system.config.SnowflakeUtils;
+import com.fs.system.domain.WxMiniProgramConfig;
+import com.fs.system.mapper.WxMiniProgramConfigMapper;
 import com.fs.tzBank.TzBankService;
 import com.fs.pay.pay.domain.RefundResult;
 import com.fs.pay.pay.service.PayService;
@@ -55,6 +57,13 @@ import com.fs.store.vo.FsStoreOrderItemVO;
 import com.fs.pay.service.IPayService;
 import com.fs.system.service.ISysConfigService;
 import com.fs.tzBank.utils.TzConfigUtils;
+import com.github.binarywang.wxpay.bean.request.WxPayRefundRequest;
+import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
+import com.github.binarywang.wxpay.bean.result.WxPayRefundQueryResult;
+import com.github.binarywang.wxpay.bean.result.WxPayRefundResult;
+import com.github.binarywang.wxpay.config.WxPayConfig;
+import com.github.binarywang.wxpay.exception.WxPayException;
+import com.github.binarywang.wxpay.service.WxPayService;
 import com.hc.openapi.tool.fastjson.JSON;
 import lombok.Synchronized;
 import org.slf4j.Logger;
@@ -79,7 +88,10 @@ import org.springframework.transaction.interceptor.TransactionAspectSupport;
 public class FsStoreAfterSalesServiceImpl implements IFsStoreAfterSalesService
 {
     Logger logger= LoggerFactory.getLogger(getClass());
-
+    @Autowired
+    private WxMiniProgramConfigMapper wxMiniProgramConfigMapper;
+    @Autowired
+    private WxPayService wxPayService;
     @Autowired
     private IFsStorePaymentService paymentService;
     @Autowired
@@ -129,6 +141,9 @@ public class FsStoreAfterSalesServiceImpl implements IFsStoreAfterSalesService
 
     @Autowired
     private IFsWarehouseCacheService fsWarehouseCacheService;
+    @Autowired
+    private IFsStorePaymentService fsStorePaymentService;
+
     /**
      * 查询售后记录
      *
@@ -693,6 +708,41 @@ public class FsStoreAfterSalesServiceImpl implements IFsStoreAfterSalesService
                             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                             return R.error(result.getMessage());
                         }
+                    }else if (payment.getPayMode()==null||payment.getPayMode().equals("wx")){
+                        WxMiniProgramConfig wxMiniProgramConfig = new WxMiniProgramConfig();
+                        wxMiniProgramConfig.setAppid(payment.getAppId());
+                        List<WxMiniProgramConfig>  wxMiniProgramConfigs = wxMiniProgramConfigMapper.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+                        WxMiniProgramConfig wConfig = wxMiniProgramConfigs.get(0);
+                        WxPayConfig payConfig = new WxPayConfig();
+                        payConfig.setAppId(wConfig.getAppid());
+                        payConfig.setMchId(wConfig.getWxMerchantNo());
+                        payConfig.setMchKey(wConfig.getWxKey());
+                        payConfig.setKeyPath(wConfig.getWxKeyPath());
+                        payConfig.setSubAppId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+                        payConfig.setSubMchId(org.apache.commons.lang3.StringUtils.trimToNull(null));
+                        wxPayService.setConfig(payConfig);
+                        WxPayRefundRequest refundRequest = new WxPayRefundRequest();
+                        refundRequest.setOutTradeNo("store-"+payment.getPayCode());
+                        refundRequest.setOutRefundNo("store-"+payment.getPayCode());
+                        refundRequest.setTotalFee(WxPayUnifiedOrderRequest.yuanToFen(payment.getPayMoney().toString()));
+                        refundRequest.setRefundFee(WxPayUnifiedOrderRequest.yuanToFen(param.getRefundAmount().toString()));
+                        try {
+                            WxPayRefundResult refundResult = wxPayService.refund(refundRequest);
+                            WxPayRefundQueryResult refundQueryResult = wxPayService.refundQuery("", refundResult.getOutTradeNo(), refundResult.getOutRefundNo(), refundResult.getRefundId());
+                            if(refundQueryResult!=null&&refundQueryResult.getResultCode().equals("SUCCESS")){
+                                FsStorePayment paymentMap=new FsStorePayment();
+                                paymentMap.setPaymentId(payment.getPaymentId());
+                                paymentMap.setStatus(-1);
+                                paymentMap.setRefundTime(DateUtils.getNowDate());
+                                paymentMap.setRefundMoney(payment.getRefundMoney());
+                                fsStorePaymentService.updateFsStorePayment(paymentMap);
+                            }
+                            else {
+                                return R.error("退款请求失败"+refundQueryResult.getErrCodeDes());
+                            }
+                        } catch (WxPayException e) {
+                            return R.error("退款请求失败"+e.getErrCodeDes());
+                        }
                     }else if (payment.getPayMode()!=null&&payment.getPayMode().equals("hf")){
                         V2TradePaymentScanpayRefundRequest request = new V2TradePaymentScanpayRefundRequest();
                         request.setOrdAmt(payment.getPayMoney().toString());

fs-service-system/src/main/java/com/fs/store/service/impl/FsStoreOrderServiceImpl.java

@@ -81,6 +81,9 @@ import com.fs.store.strategy.ShippingOrder;
 import com.fs.store.strategy.ShippingTemplateManager;
 import com.fs.store.vo.*;
 import com.fs.system.config.SnowflakeUtils;
+import com.fs.system.domain.WxMiniProgramConfig;
+import com.fs.system.mapper.FsCoursePlaySourceConfigMapper;
+import com.fs.system.mapper.WxMiniProgramConfigMapper;
 import com.fs.system.service.ISysConfigService;
 import com.fs.tzBank.TzBankService;
 import com.fs.tzBank.utils.TzConfigUtils;
@@ -126,6 +129,13 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
     @Autowired
     private CompanyMoneyLogsMapper moneyLogsMapper;
     @Autowired
+    private FsUserWxMapper fsUserWxMapper;
+    @Autowired
+    private FsCoursePlaySourceConfigMapper fsCoursePlaySourceConfigMapper;
+
+    @Autowired
+    private WxMiniProgramConfigMapper wxMiniProgramConfigMapper;
+    @Autowired
     private IFsStoreOrderStatusService orderStatusService;
     @Autowired
     private FsStoreCartMapper cartMapper;
@@ -419,7 +429,35 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
         }
 
         FsUser user=userService.selectFsUserById(order.getUserId());
-        if(user!=null&& StringUtils.isNotEmpty(user.getMaOpenId())){
+//        String json = configService.selectConfigByKey("store.pay");
+//        FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);
+        WxMiniProgramConfig wxMiniProgramConfig = new WxMiniProgramConfig();
+        wxMiniProgramConfig.setAppid(param.getAppId());
+        List<WxMiniProgramConfig>  wxMiniProgramConfigs = wxMiniProgramConfigMapper.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+        WxMiniProgramConfig wConfig = wxMiniProgramConfigs.get(0);
+        String openId = null;
+        String appId = param.getAppId();
+        if (StringUtils.isNotBlank(appId)) {
+            //查询fs_user_wx的openId
+            FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+            logger.info("用户微信信息==============={}",fsUserWx);
+            if (fsUserWx != null) {
+                openId = fsUserWx.getOpenId();
+            }
+        } else {
+            appId = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(param.getAppId()).getAppid();
+            openId = Objects.isNull(user) ? "" : user.getMaOpenId();
+            if (StringUtils.isBlank(openId)){
+                FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+                logger.info("用户微信信息==============={}",fsUserWx);
+                if (Objects.nonNull(fsUserWx)){
+                    openId = fsUserWx.getOpenId();
+                }
+            }
+        }
+
+
+        if(user!=null&& StringUtils.isNotEmpty(openId)){
             //已改价处理
             if(order.getIsEditMoney()!=null&&order.getIsEditMoney()==1){
                 //改过价不做处理
@@ -450,15 +488,14 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             String payCode = SnowflakeUtils.nextId();
 
             if(order.getPayType().equals("1")||order.getPayType().equals("2")){
-                String json = configService.selectConfigByKey("store.pay");
-                FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);
+
                 List<FsStorePayment> fsStorePayments = fsStorePaymentMapper.selectFsStorePaymentByOrderIdNew(order.getId());
                 FsStorePayment storePayment;
                 if(CollectionUtils.isEmpty(fsStorePayments)){
                     storePayment=new FsStorePayment();
                     storePayment.setCompanyId(order.getCompanyId());
                     storePayment.setCompanyUserId(order.getCompanyUserId());
-                    storePayment.setPayMode(fsPayConfig.getType());
+                    storePayment.setPayMode("wx");
                     storePayment.setStatus(0);
                     storePayment.setPayCode(payCode);
                     storePayment.setPayMoney(order.getPayMoney());
@@ -466,14 +503,15 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                     storePayment.setPayTypeCode("weixin");
                     storePayment.setBusinessType(2);
                     storePayment.setRemark("商城订单支付");
-                    storePayment.setOpenId(user.getRealName());
+                    storePayment.setOpenId(openId);
                     storePayment.setUserId(user.getUserId());
+                    storePayment.setAppId(appId);
                     storePayment.setBusinessOrderId(order.getId().toString());
                     storePayment.setOrderId(order.getId());
                     fsStorePaymentMapper.insertFsStorePayment(storePayment);
                 } else {
                     storePayment = fsStorePayments.get(0);
-                    storePayment.setPayMode(fsPayConfig.getType());
+                    storePayment.setPayMode("wx");
                     storePayment.setStatus(0);
                     storePayment.setPayMoney(order.getPayMoney());
                     storePayment.setCreateTime(new Date());
@@ -481,8 +519,9 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                     storePayment.setBusinessType(2);
                     storePayment.setRemark("商城订单支付");
                     storePayment.setPayCode(payCode);
-                    storePayment.setOpenId(user.getRealName());
+                    storePayment.setOpenId(openId);
                     storePayment.setUserId(user.getUserId());
+                    storePayment.setAppId(appId);
                     storePayment.setBusinessOrderId(order.getId().toString());
                     storePayment.setOrderId(order.getId());
                     fsStorePaymentMapper.updateFsStorePayment(storePayment);
@@ -493,11 +532,12 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                 processContext.setPayType(param.getPayType());
                 processContext.setPaymentId(storePayment.getPaymentId());
                 processContext.setPayCode(storePayment.getPayCode());
-                processContext.setFsPayConfig(fsPayConfig);
+                processContext.setWxMiniProgramConfig(wConfig);
+                processContext.setStorePayment(storePayment);
                 processContext.setUserId(order.getUserId());
                 processContext.setGoodsInfo("商城订单支付");
                 processContext.setOrderPrefix("store-");
-                PaymentHandler payment = PaymentHandlerHolder.findBest(fsPayConfig.getType());
+                PaymentHandler payment = PaymentHandlerHolder.findBest("wx");
                 if(ObjectUtil.isNull(payment)){
                     throw new CustomException("支付方式不存在");
                 }
@@ -1200,6 +1240,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             List<FsStorePayment> fsStorePayments = fsStorePaymentService.selectFsStorePaymentByOrderIdNew(order.getId());
             if(CollectionUtils.isNotEmpty(fsStorePayments)){
                 FsStorePayment fsStorePayment = fsStorePayments.get(0);
+                fsWxExpressTask.setAppid(fsStorePayment.getAppId());
                 fsWxExpressTask.setPayCode(fsStorePayment.getPayCode());
             }
             fsWxExpressTaskMapper.insert(fsWxExpressTask);
@@ -2453,6 +2494,12 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                     payProcessContext.setPayCode(payment.getPayCode());
                     payProcessContext.setUserId(order.getUserId());
                     payProcessContext.setOrderPrefix("refund-");
+                    WxMiniProgramConfig wxMiniProgramConfig = new WxMiniProgramConfig();
+                    wxMiniProgramConfig.setAppid(payment.getAppId());
+                    List<WxMiniProgramConfig>  wxMiniProgramConfigs = wxMiniProgramConfigMapper.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+                    WxMiniProgramConfig wConfig = wxMiniProgramConfigs.get(0);
+                    payProcessContext.setWxMiniProgramConfig(wConfig);
+                    payProcessContext.setStorePayment(payment);
                     best.refundOrder(payProcessContext);
                 }
             }
@@ -3153,7 +3200,25 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
     @Transactional(rollbackFor = Throwable.class,propagation = Propagation.REQUIRED)
     public R otherPayment(FsStoreOrderOtherPayParam param) {
 
-        final WxMaService wxService = WxMaConfiguration.getMaService(properties.getConfigs().get(0).getAppid());
+        String courseMa_appId;
+
+        System.out.println("appid"+param.getCode());
+        logger.info("appid"+param.getCode());
+        if(org.apache.commons.lang3.StringUtils.isNotEmpty(param.getAppId())){
+            try {
+                courseMa_appId = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(param.getAppId()).getAppid();
+            } catch (Exception e) {
+                courseMa_appId = param.getAppId();
+            }
+        }else{
+            courseMa_appId = properties.getConfigs().get(0).getAppid();
+        }
+        WxMiniProgramConfig wxMiniProgramConfig = new WxMiniProgramConfig();
+        wxMiniProgramConfig.setAppid(param.getAppId());
+        List<WxMiniProgramConfig>  wxMiniProgramConfigs = wxMiniProgramConfigMapper.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+        WxMiniProgramConfig wConfig = wxMiniProgramConfigs.get(0);
+
+        final WxMaService wxService = WxMaConfiguration.getMaService(courseMa_appId);
         try {
             String ip = IpUtil.getRequestIp();
             WxMaJscode2SessionResult session = wxService.getUserService().getSessionInfo(param.getCode());
@@ -3189,8 +3254,8 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
 
 
             String payCode = SnowflakeUtils.nextId();
-            String json = configService.selectConfigByKey("store.pay");
-            FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);
+           /* String json = configService.selectConfigByKey("store.pay");
+            FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);*/
             List<FsStorePayment> fsStorePayments = fsStorePaymentMapper.selectFsStorePaymentByOrderIdNew(order.getId());
 
             FsStorePayment storePayment;
@@ -3199,7 +3264,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                 storePayment.setCompanyId(order.getCompanyId());
                 storePayment.setCompanyUserId(order.getCompanyUserId());
                 storePayment.setStatus(0);
-                storePayment.setPayMode(fsPayConfig.getType());
+                storePayment.setPayMode("wx");
                 storePayment.setPayCode(payCode);
                 storePayment.setPayMoney(order.getPayMoney());
                 storePayment.setCreateTime(new Date());
@@ -3207,6 +3272,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                 storePayment.setBusinessType(2);
                 storePayment.setRemark("商城订单支付");
                 storePayment.setOpenId(session.getOpenid());
+                storePayment.setAppId(courseMa_appId);
                 storePayment.setUserId(user.getUserId());
                 storePayment.setBusinessOrderId(order.getId().toString());
                 storePayment.setOrderId(order.getId());
@@ -3218,6 +3284,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                 storePayment.setCreateTime(new Date());
                 storePayment.setPayTypeCode("weixin");
                 storePayment.setBusinessType(2);
+                storePayment.setAppId(courseMa_appId);
                 storePayment.setRemark("商城订单支付");
                 storePayment.setOpenId(session.getOpenid());
                 storePayment.setUserId(user.getUserId());
@@ -3226,7 +3293,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                 fsStorePaymentMapper.updateFsStorePayment(storePayment);
             }
 
-            PaymentHandler payment = PaymentHandlerHolder.findBest(fsPayConfig.getType());
+            PaymentHandler payment = PaymentHandlerHolder.findBest("wx");
             if(ObjectUtil.isNull(payment)){
                 throw new CustomException("支付方式不存在");
             }
@@ -3235,7 +3302,8 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             processContext.setPayType(null);
             processContext.setPaymentId(storePayment.getPaymentId());
             processContext.setPayCode(storePayment.getPayCode());
-            processContext.setFsPayConfig(fsPayConfig);
+            processContext.setWxMiniProgramConfig(wConfig);
+            processContext.setStorePayment(storePayment);
             processContext.setUserId(order.getUserId());
             processContext.setGoodsInfo("商城订单支付");
             processContext.setOrderPrefix("store-");
@@ -3255,7 +3323,22 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
     @Override
     @Transactional(rollbackFor = Throwable.class, propagation = Propagation.REQUIRED)
     public R otherPaymentRemain(FsStoreOrderOtherPayParam param) {
-        final WxMaService wxService = WxMaConfiguration.getMaService(properties.getConfigs().get(0).getAppid());
+        String courseMa_appId;
+
+        System.out.println("appid"+param.getCode());
+        logger.info("appid"+param.getCode());
+        if(org.apache.commons.lang3.StringUtils.isNotEmpty(param.getAppId())){
+            try {
+                courseMa_appId = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(param.getAppId()).getAppid();
+            } catch (Exception e) {
+                courseMa_appId = param.getAppId();
+            }
+        }else{
+            courseMa_appId = properties.getConfigs().get(0).getAppid();
+        }
+
+
+        final WxMaService wxService = WxMaConfiguration.getMaService(courseMa_appId);
         try {
             String ip = IpUtil.getRequestIp();
             WxMaJscode2SessionResult session = wxService.getUserService().getSessionInfo(param.getCode());
@@ -3295,6 +3378,30 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             //易宝支付
             String json = configService.selectConfigByKey("store.pay");
             FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);
+
+            String openId = null;
+            String appId = param.getAppId();
+            if (StringUtils.isNotBlank(appId)) {
+                //查询fs_user_wx的openId
+                FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+                logger.info("用户微信信息==============={}",fsUserWx);
+                if (fsUserWx != null) {
+                    openId = fsUserWx.getOpenId();
+                }
+            } else {
+                appId = fsPayConfig.getAppId();
+                openId = Objects.isNull(user) ? "" : user.getMaOpenId();
+                if (StringUtils.isBlank(openId)){
+                    FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+                    logger.info("用户微信信息==============={}",fsUserWx);
+                    if (Objects.nonNull(fsUserWx)){
+                        openId = fsUserWx.getOpenId();
+                    }
+                }
+            }
+
+
+
             FsStorePayment storePayment=new FsStorePayment();
             storePayment.setCompanyId(order.getCompanyId());
             storePayment.setCompanyUserId(order.getCompanyUserId());
@@ -3305,7 +3412,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             storePayment.setPayTypeCode("weixin");
             storePayment.setBusinessType(2);
             storePayment.setRemark("商城订单尾款支付");
-            storePayment.setOpenId(user.getRealName());
+            storePayment.setOpenId(openId);
             storePayment.setUserId(user.getUserId());
             storePayment.setBusinessOrderId(order.getId().toString());
             storePayment.setOrderId(order.getId());
@@ -3315,7 +3422,8 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             if (fsPayConfig.getType().equals("hf")){
                 HuiFuCreateOrder o = new HuiFuCreateOrder();
                 o.setTradeType("T_MINIAPP");
-                o.setOpenid(user.getMaOpenId());
+                o.setOpenid(openId);
+                o.setAppId(appId);
                 o.setReqSeqId("store_remain-"+storePayment.getPayCode());
                 o.setTransAmt(storePayment.getPayMoney().toString());
                 o.setGoodsDesc("支付订单尾款");
@@ -3324,6 +3432,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                     FsStorePayment mt=new FsStorePayment();
                     mt.setPaymentId(storePayment.getPaymentId());
                     mt.setTradeNo(result.getHf_seq_id());
+                    mt.setAppId(appId);
                     fsStorePaymentMapper.updateFsStorePayment(mt);
                     redisCache.setCacheObject("isPaying:"+order.getId(),order.getId().toString(),1, TimeUnit.MINUTES);
                     return R.ok().put("result",result.getPay_info());
@@ -3338,7 +3447,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                 p.setBody("支付订单尾款");
                 p.setIsMinipg("1");
                 p.setReturnUrl(fsPayConfig.getYbNotifyUrl());
-                p.setOpenId(user.getMaOpenId());
+                p.setOpenId(openId);
                 p.setAttach("");
                 p.setStoreid("0");
                 CreateWxOrderResult wxOrder = ybPayService.createWxOrder(p);
@@ -3695,10 +3804,32 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             return R.error("此订单已支付");
         }
         FsUser user=userService.selectFsUserById(order.getUserId());
-        if(user!=null&& StringUtils.isNotEmpty(user.getMaOpenId())){
+        String json = configService.selectConfigByKey("store.pay");
+        FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);
+        String openId = null;
+        String appId = param.getAppId();
+        if (StringUtils.isNotBlank(appId)) {
+            //查询fs_user_wx的openId
+            FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+            logger.info("用户微信信息==============={}",fsUserWx);
+            if (fsUserWx != null) {
+                openId = fsUserWx.getOpenId();
+            }
+        } else {
+            appId = fsPayConfig.getAppId();
+            openId = Objects.isNull(user) ? "" : user.getMaOpenId();
+            if (StringUtils.isBlank(openId)){
+                FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+                logger.info("用户微信信息==============={}",fsUserWx);
+                if (Objects.nonNull(fsUserWx)){
+                    openId = fsUserWx.getOpenId();
+                }
+            }
+        }
+
+        if(user!=null&& StringUtils.isNotEmpty(openId)){
             String payCode = SnowflakeUtils.nextId();
-            String json = configService.selectConfigByKey("store.pay");
-            FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);
+
 
             FsStorePayment storePayment=new FsStorePayment();
             storePayment.setCompanyId(order.getCompanyId());
@@ -3711,7 +3842,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             storePayment.setPayTypeCode("weixin");
             storePayment.setBusinessType(2);
             storePayment.setRemark("商城订单尾款支付");
-            storePayment.setOpenId(user.getRealName());
+            storePayment.setOpenId(openId);
             storePayment.setUserId(user.getUserId());
             storePayment.setBusinessOrderId(order.getId().toString());
             storePayment.setOrderId(order.getId());
@@ -3720,7 +3851,8 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
             if (fsPayConfig.getType().equals("hf")){
                 HuiFuCreateOrder o = new HuiFuCreateOrder();
                 o.setTradeType("T_MINIAPP");
-                o.setOpenid(user.getMaOpenId());
+                o.setOpenid(openId);
+                o.setAppId(appId);
                 o.setReqSeqId("store_remain-"+storePayment.getPayCode());
                 o.setTransAmt(storePayment.getPayMoney().toString());
                 o.setGoodsDesc("商城订单尾款支付");
@@ -3730,6 +3862,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                     FsStorePayment mt=new FsStorePayment();
                     mt.setPaymentId(storePayment.getPaymentId());
                     mt.setTradeNo(result.getHf_seq_id());
+                    mt.setAppId(appId);
                     fsStorePaymentMapper.updateFsStorePayment(mt);
                     redisCache.setCacheObject("isPaying:"+order.getId(),order.getId().toString(),1, TimeUnit.MINUTES);
                     return R.ok().put("result",result.getPay_info());
@@ -3745,7 +3878,7 @@ public class FsStoreOrderServiceImpl implements IFsStoreOrderService
                 p.setBody("商城订单尾款支付");
                 p.setIsMinipg("1");
                 p.setReturnUrl(fsPayConfig.getYbNotifyUrl());
-                p.setOpenId(user.getMaOpenId());
+                p.setOpenId(openId);
                 p.setAttach("");
                 p.setStoreid("0");
                 CreateWxOrderResult wxOrder = ybPayService.createWxOrder(p);

fs-service-system/src/main/java/com/fs/store/service/impl/FsStorePaymentServiceImpl.java

@@ -1,10 +1,7 @@
 package com.fs.store.service.impl;
 
 import java.math.BigDecimal;
-import java.util.Collections;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.concurrent.TimeUnit;
 
 import cn.hutool.core.util.IdUtil;
@@ -15,17 +12,22 @@ import com.fs.common.annotation.DataScope;
 import com.fs.common.core.domain.R;
 import com.fs.common.exception.CustomException;
 import com.fs.common.utils.DateUtils;
+import com.fs.common.utils.StringUtils;
 import com.fs.company.domain.CompanyUser;
 import com.fs.company.service.ICompanyService;
 import com.fs.company.service.ICompanyUserService;
 import com.fs.huifuPay.dto.*;
 import com.fs.pay.pay.util.PayUtil;
 import com.fs.store.domain.*;
+import com.fs.store.mapper.FsUserWxMapper;
 import com.fs.store.service.IFsStoreOrderService;
 import com.fs.store.service.channel.PaymentHandler;
 import com.fs.store.service.channel.PaymentHandlerHolder;
 import com.fs.store.service.channel.param.PayProcessContext;
 import com.fs.system.config.SnowflakeUtils;
+import com.fs.system.domain.WxMiniProgramConfig;
+import com.fs.system.mapper.FsCoursePlaySourceConfigMapper;
+import com.fs.system.mapper.WxMiniProgramConfigMapper;
 import com.fs.tzBank.TzBankService;
 import com.fs.store.param.FsStoreStatisticsParam;
 import com.fs.store.service.IFsCouponScheduleService;
@@ -63,6 +65,10 @@ public class FsStorePaymentServiceImpl implements IFsStorePaymentService
     @Autowired
     private FsStorePaymentMapper fsStorePaymentMapper;
     @Autowired
+    private FsCoursePlaySourceConfigMapper fsCoursePlaySourceConfigMapper;
+    @Autowired
+    private WxMiniProgramConfigMapper wxMiniProgramConfigMapper;
+    @Autowired
     private IFsUserService userService;
 
     @Autowired
@@ -84,6 +90,9 @@ public class FsStorePaymentServiceImpl implements IFsStorePaymentService
     @Autowired
     private OrderQueryService orderQueryService;
 
+    @Autowired
+    private FsUserWxMapper fsUserWxMapper;
+
     @Value("${wx.miniapp.configs[0].account}")
     private String account;
 
@@ -173,37 +182,67 @@ public class FsStorePaymentServiceImpl implements IFsStorePaymentService
         FsUser user=userService.selectFsUserById(payment.getUserId());
 
 
-        String json = configService.selectConfigByKey("store.pay");
-        FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);
+/*        String json = configService.selectConfigByKey("store.pay");
+        FsPayConfig fsPayConfig = JSON.parseObject(json, FsPayConfig.class);*/
+        WxMiniProgramConfig wxMiniProgramConfig = new WxMiniProgramConfig();
+        wxMiniProgramConfig.setAppid(payment.getAppId());
+        List<WxMiniProgramConfig>  wxMiniProgramConfigs = wxMiniProgramConfigMapper.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+        WxMiniProgramConfig wConfig = wxMiniProgramConfigs.get(0);
+        String openId = null;
+        String appId = payment.getAppId();
+        if (StringUtils.isNotBlank(appId)) {
+            //查询fs_user_wx的openId
+            FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+            logger.info("用户微信信息==============={}",fsUserWx);
+            if (fsUserWx != null) {
+                openId = fsUserWx.getOpenId();
+            }
+        } else {
+            appId = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(payment.getAppId()).getAppid();
+            openId = Objects.isNull(user) ? "" : user.getMaOpenId();
+            if (StringUtils.isBlank(openId)){
+                FsUserWx fsUserWx = fsUserWxMapper.selectListByUserIdAndAppId(user.getUserId(),appId);
+                logger.info("用户微信信息==============={}",fsUserWx);
+                if (Objects.nonNull(fsUserWx)){
+                    openId = fsUserWx.getOpenId();
+                }
+            }
+        }
+
+
+
+
         FsStorePayment storePayment=new FsStorePayment();
         storePayment.setCompanyId(payment.getCompanyId());
         storePayment.setCompanyUserId(payment.getCompanyUserId());
         storePayment.setStatus(0);
-        storePayment.setPayMode(fsPayConfig.getType());
+        storePayment.setPayMode("wx");
         storePayment.setPayCode(orderSn);
         storePayment.setPayMoney(payment.getPayMoney());
         storePayment.setCreateTime(new Date());
         storePayment.setPayTypeCode("weixin");
         storePayment.setBusinessType(1);
+        storePayment.setAppId(appId);
         storePayment.setRemark(payment.getRemark());
-        storePayment.setOpenId(user.getMaOpenId());
+        storePayment.setOpenId(openId);
         storePayment.setUserId(user.getUserId());
         if(companyUser==null){
             return R.error("销售帐号不存在");
         }
         storePayment.setDeptId(companyUser.getDeptId());
-        //易宝支付
         fsStorePaymentMapper.insertFsStorePayment(storePayment);
+        //易宝支付
         PayProcessContext processContext = new PayProcessContext();
         processContext.setOrderId(null);
         processContext.setPayType(null);
         processContext.setPaymentId(storePayment.getPaymentId());
         processContext.setPayCode(orderSn);
-        processContext.setFsPayConfig(fsPayConfig);
+        processContext.setWxMiniProgramConfig(wConfig);
         processContext.setUserId(user.getUserId());
+        processContext.setStorePayment(storePayment);
         processContext.setGoodsInfo("医学管理方案服务");
         processContext.setOrderPrefix("payment-");
-        PaymentHandler paymentHandler = PaymentHandlerHolder.findBest(fsPayConfig.getType());
+        PaymentHandler paymentHandler = PaymentHandlerHolder.findBest("wx");
         if(ObjectUtil.isNull(payment)){
             throw new CustomException("支付方式不存在");
         }

fs-service-system/src/main/java/com/fs/store/service/impl/FsUserServiceImpl.java

@@ -14,14 +14,11 @@ import cn.hutool.json.JSONUtil;
 import com.fs.common.core.domain.R;
 import com.fs.common.utils.DateUtils;
 import com.fs.common.utils.IpUtil;
-import com.fs.store.domain.FsStoreOrder;
-import com.fs.store.domain.FsStoreOrderItem;
-import com.fs.store.domain.FsUserBill;
+import com.fs.store.domain.*;
 import com.fs.store.dto.FsStoreCartDTO;
 import com.fs.store.enums.BillDetailEnum;
-import com.fs.store.mapper.FsStoreOrderMapper;
-import com.fs.store.mapper.FsStoreProductAttrValueMapper;
-import com.fs.store.mapper.FsUserTuiMoneyRankMapper;
+import com.fs.store.mapper.*;
+import com.fs.store.param.LoginMaWxParam;
 import com.fs.store.param.LoginMpWxParam;
 import com.fs.store.service.IFsUserBillService;
 import com.fs.store.utils.JwtUtils;
@@ -30,6 +27,7 @@ import com.fs.store.vo.FsUserVO;
 import com.fs.store.vo.FsCompanyUserListQueryVO;
 import com.fs.store.vo.FsUserShareVO;
 import com.fs.store.vo.FsUserTuiVO;
+import com.fs.system.mapper.FsCoursePlaySourceConfigMapper;
 import com.fs.wx.miniapp.config.WxMaConfiguration;
 import com.fs.wx.miniapp.config.WxMaProperties;
 import me.chanjar.weixin.common.error.WxErrorException;
@@ -42,8 +40,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.EnableAspectJAutoProxy;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
-import com.fs.store.mapper.FsUserMapper;
-import com.fs.store.domain.FsUser;
 import com.fs.store.service.IFsUserService;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -65,6 +61,8 @@ public class FsUserServiceImpl implements IFsUserService
     @Autowired
     private FsUserMapper fsUserMapper;
 
+    @Autowired
+    private FsUserWxMapper fsUserWxMapper;
     @Autowired
     private FsStoreProductAttrValueMapper storeProductAttrValueMapper;
 
@@ -73,6 +71,9 @@ public class FsUserServiceImpl implements IFsUserService
     @Autowired
     private FsStoreOrderMapper storeOrderMapper;
 
+    @Autowired
+    private FsCoursePlaySourceConfigMapper fsCoursePlaySourceConfigMapper;
+
     @Autowired
     private WxMaProperties maProperties;
 
@@ -387,8 +388,25 @@ public class FsUserServiceImpl implements IFsUserService
         if (StringUtils.isBlank(param.getCode())) {
             return R.error("code不存在");
         }
+
+        String courseMa_appId;
+
+        System.out.println("appid"+param.getCode());
+        logger.info("appid"+param.getCode());
+        if(StringUtils.isNotEmpty(param.getAppId())){
+            try {
+                courseMa_appId = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(param.getAppId()).getAppid();
+            } catch (Exception e) {
+                courseMa_appId = param.getAppId();
+            }
+        }else{
+            courseMa_appId = maProperties.getConfigs().get(0).getAppid();
+        }
+
+
+
         try {
-            WxMaService wxService = WxMaConfiguration.getMaService(maProperties.getConfigs().get(0).getAppid());
+            WxMaService wxService = WxMaConfiguration.getMaService(courseMa_appId);
 
             WxMaJscode2SessionResult session = wxService.getUserService().getSessionInfo(param.getCode());
             FsUser user=fsUserMapper.selectFsUserByMaOpenIdOrUnionId(session.getOpenid(),session.getUnionid());
@@ -408,13 +426,35 @@ public class FsUserServiceImpl implements IFsUserService
                     }
                 });
             }
+            LoginMaWxParam loginMaWxParam = new LoginMaWxParam();
+            loginMaWxParam.setAppId(param.getAppId());
+            loginMaWxParam.setCompanyId(user.getCompanyId());
+
+            handleFsUserWx(user,loginMaWxParam,session);
             String token = jwtUtils.generateToken(user.getUserId());
             return R.ok("登录成功").put("token",token).put("user", user);
         } catch (WxErrorException e) {
             return R.error("授权失败,"+e.getMessage());
         }
     }
-
+    public void handleFsUserWx(FsUser user, LoginMaWxParam param, WxMaJscode2SessionResult session) {
+        if (user == null) return;
+        // 尝试更新
+        boolean updated = fsUserWxMapper.updateFsUserWx(user.getUserId(),param.getAppId(),session.getOpenid(),param.getCompanyId(),session.getUnionid() == null ? "" : session.getUnionid(),new Date())> 0;
+        // 如果更新失败（记录不存在），则插入
+        if (!updated) {
+            FsUserWx fsUserWx = new FsUserWx();
+            fsUserWx.setType(1);
+            fsUserWx.setFsUserId(user.getUserId());
+            fsUserWx.setCompanyId(param.getCompanyId());
+            fsUserWx.setAppId(param.getAppId());
+            fsUserWx.setOpenId(session.getOpenid());
+            fsUserWx.setUnionId(session.getUnionid() == null ? "" : session.getUnionid());
+            fsUserWx.setCreateTime(new Date());
+            fsUserWx.setUpdateTime(new Date());
+            fsUserWxMapper.insertOrUpdateByUniqueKey(fsUserWx);
+        }
+    }
     private FsUser saveUser(LoginMpWxParam param, WxMaService wxService, WxMaJscode2SessionResult session, String ip) {
         FsUser user;
         // 解密

fs-service-system/src/main/java/com/fs/system/domain/WxMiniProgramConfig.java

@@ -0,0 +1,69 @@
+package com.fs.system.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fs.common.annotation.Excel;
+import com.fs.common.core.domain.BaseEntity;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+import java.util.Date;
+
+/**
+ * 微信小程序支付配置对象 wx_mini_program_config
+ *
+ * @author fs
+ * @date 2025-12-01
+ */
+@Data
+public class WxMiniProgramConfig extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    private Long id;
+
+    /** 小程序名称 */
+    @Excel(name = "小程序名称")
+    private String appName;
+
+    /** 小程序appid */
+    @Excel(name = "小程序appid")
+    private String appid;
+
+    /** 小程序密钥 */
+    @Excel(name = "小程序密钥")
+    private String appSecret;
+
+    /** 微信商户号 */
+    @Excel(name = "微信商户号")
+    private String wxMerchantNo;
+
+    /** 微信API密钥 */
+    @Excel(name = "微信API密钥")
+    private String wxKey;
+
+    @Excel(name = "微信V3 API密钥")
+    private String wxV3Key;
+
+    /** 微信证书路径 */
+    @Excel(name = "微信证书路径")
+    private String wxKeyPath;
+
+    /** 微信支付回调地址 */
+    @Excel(name = "微信支付回调地址")
+    private String wxNotifyUrl;
+
+    /** 状态 */
+    @Excel(name = "状态")
+    private Long status;
+
+    @Excel(name = "商户简称")
+    private String merchantShortName;
+
+    @Excel(name = "管理员")
+    private String adminName;
+
+    @Excel(name = "签约时间")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date signingTime;
+}

fs-service-system/src/main/java/com/fs/system/mapper/FsCoursePlaySourceConfigMapper.java

@@ -18,6 +18,7 @@ public interface FsCoursePlaySourceConfigMapper {
      * @return 点播播放源配置
      */
     FsCoursePlaySourceConfig selectFsCoursePlaySourceConfigById(Long id);
+    FsCoursePlaySourceConfig selectFsCoursePlaySourceConfigByAppId(String appId);
 
     /**
      * 查询点播播放源配置列表
@@ -58,4 +59,11 @@ public interface FsCoursePlaySourceConfigMapper {
      * @return 结果
      */
     int deleteFsCoursePlaySourceConfigByIds(Long[] ids);
+
+    /**
+     * 查询所有小程序数据
+     *
+     * @return
+     */
+    List<FsCoursePlaySourceConfig> selectFsCoursePlaySourceConfigAll();
 }

fs-service-system/src/main/java/com/fs/system/mapper/WxMiniProgramConfigMapper.java

@@ -0,0 +1,61 @@
+package com.fs.system.mapper;
+
+import java.util.List;
+import com.fs.system.domain.WxMiniProgramConfig;
+
+/**
+ * 微信小程序支付配置Mapper接口
+ * 
+ * @author fs
+ * @date 2025-12-01
+ */
+public interface WxMiniProgramConfigMapper 
+{
+    /**
+     * 查询微信小程序支付配置
+     * 
+     * @param id 微信小程序支付配置ID
+     * @return 微信小程序支付配置
+     */
+    public WxMiniProgramConfig selectWxMiniProgramConfigById(Long id);
+
+    /**
+     * 查询微信小程序支付配置列表
+     * 
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 微信小程序支付配置集合
+     */
+    public List<WxMiniProgramConfig> selectWxMiniProgramConfigList(WxMiniProgramConfig wxMiniProgramConfig);
+
+    /**
+     * 新增微信小程序支付配置
+     * 
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 结果
+     */
+    public int insertWxMiniProgramConfig(WxMiniProgramConfig wxMiniProgramConfig);
+
+    /**
+     * 修改微信小程序支付配置
+     * 
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 结果
+     */
+    public int updateWxMiniProgramConfig(WxMiniProgramConfig wxMiniProgramConfig);
+
+    /**
+     * 删除微信小程序支付配置
+     * 
+     * @param id 微信小程序支付配置ID
+     * @return 结果
+     */
+    public int deleteWxMiniProgramConfigById(Long id);
+
+    /**
+     * 批量删除微信小程序支付配置
+     * 
+     * @param ids 需要删除的数据ID
+     * @return 结果
+     */
+    public int deleteWxMiniProgramConfigByIds(Long[] ids);
+}

fs-service-system/src/main/java/com/fs/system/service/IWxMiniProgramConfigService.java

@@ -0,0 +1,61 @@
+package com.fs.system.service;
+
+import java.util.List;
+import com.fs.system.domain.WxMiniProgramConfig;
+
+/**
+ * 微信小程序支付配置Service接口
+ * 
+ * @author fs
+ * @date 2025-12-01
+ */
+public interface IWxMiniProgramConfigService 
+{
+    /**
+     * 查询微信小程序支付配置
+     * 
+     * @param id 微信小程序支付配置ID
+     * @return 微信小程序支付配置
+     */
+    public WxMiniProgramConfig selectWxMiniProgramConfigById(Long id);
+
+    /**
+     * 查询微信小程序支付配置列表
+     * 
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 微信小程序支付配置集合
+     */
+    public List<WxMiniProgramConfig> selectWxMiniProgramConfigList(WxMiniProgramConfig wxMiniProgramConfig);
+
+    /**
+     * 新增微信小程序支付配置
+     * 
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 结果
+     */
+    public int insertWxMiniProgramConfig(WxMiniProgramConfig wxMiniProgramConfig);
+
+    /**
+     * 修改微信小程序支付配置
+     * 
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 结果
+     */
+    public int updateWxMiniProgramConfig(WxMiniProgramConfig wxMiniProgramConfig);
+
+    /**
+     * 批量删除微信小程序支付配置
+     * 
+     * @param ids 需要删除的微信小程序支付配置ID
+     * @return 结果
+     */
+    public int deleteWxMiniProgramConfigByIds(Long[] ids);
+
+    /**
+     * 删除微信小程序支付配置信息
+     * 
+     * @param id 微信小程序支付配置ID
+     * @return 结果
+     */
+    public int deleteWxMiniProgramConfigById(Long id);
+}

fs-service-system/src/main/java/com/fs/system/service/impl/WxMiniProgramConfigServiceImpl.java

@@ -0,0 +1,112 @@
+package com.fs.system.service.impl;
+
+import java.util.List;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.fs.common.utils.DateUtils;
+import com.fs.store.domain.FsCoursePlaySourceConfig;
+import com.fs.system.mapper.FsCoursePlaySourceConfigMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.fs.system.mapper.WxMiniProgramConfigMapper;
+import com.fs.system.domain.WxMiniProgramConfig;
+import com.fs.system.service.IWxMiniProgramConfigService;
+
+/**
+ * 微信小程序支付配置Service业务层处理
+ *
+ * @author fs
+ * @date 2025-12-01
+ */
+@Service
+public class WxMiniProgramConfigServiceImpl implements IWxMiniProgramConfigService
+{
+    @Autowired
+    private WxMiniProgramConfigMapper wxMiniProgramConfigMapper;
+    @Autowired
+    private FsCoursePlaySourceConfigMapper fsCoursePlaySourceConfigMapper;
+
+    /**
+     * 查询微信小程序支付配置
+     *
+     * @param id 微信小程序支付配置ID
+     * @return 微信小程序支付配置
+     */
+    @Override
+    public WxMiniProgramConfig selectWxMiniProgramConfigById(Long id)
+    {
+        return wxMiniProgramConfigMapper.selectWxMiniProgramConfigById(id);
+    }
+
+    /**
+     * 查询微信小程序支付配置列表
+     *
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 微信小程序支付配置
+     */
+    @Override
+    public List<WxMiniProgramConfig> selectWxMiniProgramConfigList(WxMiniProgramConfig wxMiniProgramConfig)
+    {
+        return wxMiniProgramConfigMapper.selectWxMiniProgramConfigList(wxMiniProgramConfig);
+    }
+
+    /**
+     * 新增微信小程序支付配置
+     *
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 结果
+     */
+    @Override
+    public int insertWxMiniProgramConfig(WxMiniProgramConfig wxMiniProgramConfig)
+    {
+        FsCoursePlaySourceConfig fsCoursePlaySourceConfig = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(wxMiniProgramConfig.getAppid());
+        if (ObjectUtil.isNotEmpty(fsCoursePlaySourceConfig)){
+            wxMiniProgramConfig.setAppName(fsCoursePlaySourceConfig.getName());
+            wxMiniProgramConfig.setAppSecret(fsCoursePlaySourceConfig.getSecret());
+        }
+        wxMiniProgramConfig.setCreateTime(DateUtils.getNowDate());
+        return wxMiniProgramConfigMapper.insertWxMiniProgramConfig(wxMiniProgramConfig);
+    }
+
+    /**
+     * 修改微信小程序支付配置
+     *
+     * @param wxMiniProgramConfig 微信小程序支付配置
+     * @return 结果
+     */
+    @Override
+    public int updateWxMiniProgramConfig(WxMiniProgramConfig wxMiniProgramConfig)
+    {
+        FsCoursePlaySourceConfig fsCoursePlaySourceConfig = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(wxMiniProgramConfig.getAppid());
+        if (ObjectUtil.isNotEmpty(fsCoursePlaySourceConfig)){
+            wxMiniProgramConfig.setAppName(fsCoursePlaySourceConfig.getName());
+            wxMiniProgramConfig.setAppSecret(fsCoursePlaySourceConfig.getSecret());
+        }
+        wxMiniProgramConfig.setUpdateTime(DateUtils.getNowDate());
+        return wxMiniProgramConfigMapper.updateWxMiniProgramConfig(wxMiniProgramConfig);
+    }
+
+    /**
+     * 批量删除微信小程序支付配置
+     *
+     * @param ids 需要删除的微信小程序支付配置ID
+     * @return 结果
+     */
+    @Override
+    public int deleteWxMiniProgramConfigByIds(Long[] ids)
+    {
+        return wxMiniProgramConfigMapper.deleteWxMiniProgramConfigByIds(ids);
+    }
+
+    /**
+     * 删除微信小程序支付配置信息
+     *
+     * @param id 微信小程序支付配置ID
+     * @return 结果
+     */
+    @Override
+    public int deleteWxMiniProgramConfigById(Long id)
+    {
+        return wxMiniProgramConfigMapper.deleteWxMiniProgramConfigById(id);
+    }
+}

fs-service-system/src/main/java/com/fs/wx/domain/FsWxExpressTask.java

@@ -93,4 +93,9 @@ public class FsWxExpressTask {
      * 快递编号
      */
     private String expressNo;
+
+    /**
+     * 小程序ID
+     */
+    private String appid;
 }

fs-service-system/src/main/java/com/fs/wx/mapper/FsWxExpressTaskMapper.java

@@ -23,8 +23,8 @@ public interface FsWxExpressTaskMapper {
      * @param task 任务实体
      * @return 影响行数
      */
-    @Insert("INSERT INTO fs_wx_express_task (order_code, user_id, data, status, retry_count, max_retries, request_params, request_body, response_body, error_message, create_time, update_time,express_company,express_no) " +
-            "VALUES (#{orderCode}, #{userId}, #{data}, #{status}, #{retryCount}, #{maxRetries}, #{requestParams}, #{requestBody}, #{responseBody}, #{errorMessage}, #{createTime}, #{updateTime},#{expressCompany},#{expressNo})")
+    @Insert("INSERT INTO fs_wx_express_task (order_code, user_id, data, status, retry_count, max_retries, request_params, request_body, response_body, error_message, create_time, update_time,express_company,express_no,type,appid) " +
+            "VALUES (#{orderCode}, #{userId}, #{data}, #{status}, #{retryCount}, #{maxRetries}, #{requestParams}, #{requestBody}, #{responseBody}, #{errorMessage}, #{createTime}, #{updateTime},#{expressCompany},#{expressNo},#{type},#{appid})")
     @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
     int insert(FsWxExpressTask task);
 

fs-service-system/src/main/java/com/fs/wx/miniapp/config/WxMaConfiguration.java

@@ -7,6 +7,9 @@ import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;
 import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
 import cn.binarywang.wx.miniapp.message.WxMaMessageHandler;
 import cn.binarywang.wx.miniapp.message.WxMaMessageRouter;
+import com.fs.common.utils.spring.SpringUtils;
+import com.fs.store.domain.FsCoursePlaySourceConfig;
+import com.fs.system.mapper.FsCoursePlaySourceConfigMapper;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import me.chanjar.weixin.common.bean.result.WxMediaUploadResult;
@@ -37,14 +40,33 @@ public class WxMaConfiguration {
     }
 
     public static WxMaService getMaService(String appid) {
-        WxMaService wxService = maServices.get(appid);
-        if (wxService == null) {
-            throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", appid));
-        }
+        return maServices.computeIfAbsent(appid,e->{
+            // 查询数据库
+            FsCoursePlaySourceConfigMapper configMapper = SpringUtils.getBean(FsCoursePlaySourceConfigMapper.class);
 
-        return wxService;
-    }
+            FsCoursePlaySourceConfig config = configMapper.selectFsCoursePlaySourceConfigByAppId(appid);
+            if (config == null) {
+                throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", appid));
+            }
 
+            return getWxMaService(config.getAppid(), config.getSecret(), config.getToken(), config.getAesKey(), config.getMsgDataFormat());
+        });
+    }
+    /**
+     * 初始化WxMaService
+     */
+    private static WxMaService getWxMaService(String appid, String secret, String token, String aesKey, String msgDataFormat) {
+        WxMaDefaultConfigImpl maConfig = new WxMaDefaultConfigImpl();
+        maConfig.setAppid(appid);
+        maConfig.setSecret(secret);
+        maConfig.setToken(token);
+        maConfig.setAesKey(aesKey);
+        maConfig.setMsgDataFormat(msgDataFormat);
+
+        WxMaService service = new WxMaServiceImpl();
+        service.setWxMaConfig(maConfig);
+        return service;
+    }
     public static WxMaMessageRouter getRouter(String appid) {
         return routers.get(appid);
     }

fs-service-system/src/main/resources/mapper/store/FsStorePaymentMapper.xml

@@ -28,10 +28,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <result property="orderId"    column="order_id"    />
         <result property="isPayRemain"    column="is_pay_remain"    />
         <result property="payMode"    column="pay_mode"    />
+        <result property="appId"    column="app_id"    />
     </resultMap>
 
     <sql id="selectFsStorePaymentVo">
-        select payment_id,pay_mode, pay_code, pay_type_code, pay_money, pay_time, create_time, trade_no, user_id, open_id, business_type, business_order_id, status,remark,company_id,company_user_id,dept_id,bank_transaction_id,bank_serial_no,refund_money,refund_time,order_id,is_pay_remain from fs_store_payment
+        select payment_id,pay_mode,app_id, pay_code, pay_type_code, pay_money, pay_time, create_time, trade_no, user_id, open_id, business_type, business_order_id, status,remark,company_id,company_user_id,dept_id,bank_transaction_id,bank_serial_no,refund_money,refund_time,order_id,is_pay_remain from fs_store_payment
 
     </sql>
 
@@ -55,6 +56,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="bankTransactionId != null "> and bank_transaction_id = #{bankTransactionId}</if>
             <if test="bankSerialNo != null "> and bank_serial_no = #{bankSerialNo}</if>
             <if test="orderId != null "> and order_id = #{orderId}</if>
+            <if test="appId != null and appId !=''"> and app_id = #{appId}</if>
         </where>
     </select>
 
@@ -88,6 +90,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="orderId != null">order_id,</if>
             <if test="isPayRemain != null">is_pay_remain,</if>
             <if test="payMode != null">pay_mode,</if>
+            <if test="appId != null">app_id,</if>
          </trim>
         <trim prefix="values (" suffix=")" suffixOverrides=",">
             <if test="payCode != null">#{payCode},</if>
@@ -112,6 +115,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="orderId != null">#{orderId},</if>
             <if test="isPayRemain != null">#{isPayRemain},</if>
             <if test="payMode != null">#{payMode},</if>
+            <if test="appId != null">#{appId},</if>
          </trim>
     </insert>
 
@@ -140,6 +144,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="orderId != null">order_id = #{orderId},</if>
             <if test="isPayRemain != null">is_pay_remain = #{isPayRemain},</if>
             <if test="payMode != null">pay_mode = #{payMode},</if>
+            <if test="appId != null">app_id = #{appId},</if>
         </trim>
         where payment_id = #{paymentId}
     </update>

fs-service-system/src/main/resources/mapper/store/FsUserWxMapper.xml

@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fs.store.mapper.FsUserWxMapper">
+
+    <insert id="insertOrUpdateByUniqueKey">
+        insert into fs_user_wx
+            (fs_user_id, app_id, union_id, open_id, create_time, update_time)
+        values
+            (#{fsUserId}, #{appId}, #{unionId}, #{openId}, #{createTime, jdbcType=TIMESTAMP}, #{updateTime, jdbcType=TIMESTAMP})
+        ON DUPLICATE KEY UPDATE
+        <if test="unionId != null">
+            union_id = VALUES(union_id),
+        </if>
+            open_id     = VALUES(open_id),
+            update_time = VALUES(update_time)
+    </insert>
+
+
+    <update id="updateFsUserWx">
+        UPDATE fs_user_wx
+        <set>
+            <if test="companyId != null and companyId != ''">
+                company_id = #{companyId},
+            </if>
+            <if test="unionId != null">
+                union_id = #{unionId},
+            </if>
+            update_time = #{updateTime}
+        </set>
+        WHERE
+        fs_user_id = #{userId}
+        AND app_id = #{appId}
+        AND open_id = #{openId}
+    </update>
+
+    <select id="selectListByUserIdAndAppId" resultType="com.fs.store.domain.FsUserWx">
+        SELECT * FROM fs_user_wx
+        WHERE fs_user_id = #{userId}
+          AND app_id = #{appId} limit 1
+    </select>
+
+</mapper>

fs-service-system/src/main/resources/mapper/system/FsCoursePlaySourceConfigMapper.xml

@@ -14,25 +14,22 @@
         <result property="token"    column="token"    />
         <result property="aesKey"    column="aes_key"    />
         <result property="msgDataFormat"    column="msg_data_format"    />
-        <result property="type"    column="type"    />
         <result property="isDel"    column="is_del"    />
         <result property="createTime"    column="create_time"    />
         <result property="updateTime"    column="update_time"    />
-        <result property="companyId"    column="company_id"    />
-        <result property="companyUserId"    column="company_user_id"    />
         <result property="createUserId"    column="create_user_id"    />
         <result property="createDeptId"    column="create_dept_id"    />
-        <result property="isMall"    column="is_mall"    />
-        <result property="setCompanyIds"    column="set_company_ids"    />
+        <result property="status"    column="status"    />
     </resultMap>
 
     <sql id="selectFsCoursePlaySourceConfigVo">
-        select id, name, appid, secret, img, original_id, token, aes_key, msg_data_format, type, is_del, create_time, update_time, company_id, company_user_id, create_user_id, create_dept_id, is_mall, set_company_ids from fs_course_play_source_config
+        select id, name, appid,status, secret, img, original_id, token, aes_key, msg_data_format,is_del, create_time, update_time, create_user_id, create_dept_id from fs_course_play_source_config
     </sql>
 
     <select id="selectFsCoursePlaySourceConfigList" parameterType="FsCoursePlaySourceConfig" resultMap="FsCoursePlaySourceConfigResult">
         <include refid="selectFsCoursePlaySourceConfigVo"/>
         <where>
+            is_del = 0
             <if test="name != null  and name != ''"> and name like concat('%', #{name}, '%')</if>
             <if test="appid != null  and appid != ''"> and appid = #{appid}</if>
             <if test="secret != null  and secret != ''"> and secret = #{secret}</if>
@@ -41,14 +38,9 @@
             <if test="token != null  and token != ''"> and token = #{token}</if>
             <if test="aesKey != null  and aesKey != ''"> and aes_key = #{aesKey}</if>
             <if test="msgDataFormat != null  and msgDataFormat != ''"> and msg_data_format = #{msgDataFormat}</if>
-            <if test="type != null "> and type = #{type}</if>
             <if test="isDel != null "> and is_del = #{isDel}</if>
-            <if test="companyId != null "> and company_id = #{companyId}</if>
-            <if test="companyUserId != null "> and company_user_id = #{companyUserId}</if>
             <if test="createUserId != null "> and create_user_id = #{createUserId}</if>
             <if test="createDeptId != null "> and create_dept_id = #{createDeptId}</if>
-            <if test="isMall != null "> and is_mall = #{isMall}</if>
-            <if test="setCompanyIds != null  and setCompanyIds != ''"> and set_company_ids = #{setCompanyIds}</if>
         </where>
     </select>
 
@@ -56,7 +48,10 @@
         <include refid="selectFsCoursePlaySourceConfigVo"/>
         where id = #{id}
     </select>
-
+    <select id="selectFsCoursePlaySourceConfigByAppId" parameterType="String" resultMap="FsCoursePlaySourceConfigResult">
+        <include refid="selectFsCoursePlaySourceConfigVo"/>
+        where appid = #{appid} and is_del = 0 limit 1
+    </select>
     <insert id="insertFsCoursePlaySourceConfig" parameterType="FsCoursePlaySourceConfig" useGeneratedKeys="true" keyProperty="id">
         insert into fs_course_play_source_config
         <trim prefix="(" suffix=")" suffixOverrides=",">
@@ -68,16 +63,12 @@
             <if test="token != null and token != ''">token,</if>
             <if test="aesKey != null and aesKey != ''">aes_key,</if>
             <if test="msgDataFormat != null and msgDataFormat != ''">msg_data_format,</if>
-            <if test="type != null">type,</if>
             <if test="isDel != null">is_del,</if>
             <if test="createTime != null">create_time,</if>
             <if test="updateTime != null">update_time,</if>
-            <if test="companyId != null">company_id,</if>
-            <if test="companyUserId != null">company_user_id,</if>
             <if test="createUserId != null">create_user_id,</if>
             <if test="createDeptId != null">create_dept_id,</if>
-            <if test="isMall != null">is_mall,</if>
-            <if test="setCompanyIds != null">set_company_ids,</if>
+            <if test="status != null">`status`,</if>
         </trim>
         <trim prefix="values (" suffix=")" suffixOverrides=",">
             <if test="name != null and name != ''">#{name},</if>
@@ -88,16 +79,12 @@
             <if test="token != null and token != ''">#{token},</if>
             <if test="aesKey != null and aesKey != ''">#{aesKey},</if>
             <if test="msgDataFormat != null and msgDataFormat != ''">#{msgDataFormat},</if>
-            <if test="type != null">#{type},</if>
             <if test="isDel != null">#{isDel},</if>
             <if test="createTime != null">#{createTime},</if>
             <if test="updateTime != null">#{updateTime},</if>
-            <if test="companyId != null">#{companyId},</if>
-            <if test="companyUserId != null">#{companyUserId},</if>
             <if test="createUserId != null">#{createUserId},</if>
             <if test="createDeptId != null">#{createDeptId},</if>
-            <if test="isMall != null">#{isMall},</if>
-            <if test="setCompanyIds != null">#{setCompanyIds},</if>
+            <if test="status != null">#{status},</if>
         </trim>
     </insert>
 
@@ -112,16 +99,12 @@
             <if test="token != null and token != ''">token = #{token},</if>
             <if test="aesKey != null and aesKey != ''">aes_key = #{aesKey},</if>
             <if test="msgDataFormat != null and msgDataFormat != ''">msg_data_format = #{msgDataFormat},</if>
-            <if test="type != null">type = #{type},</if>
             <if test="isDel != null">is_del = #{isDel},</if>
             <if test="createTime != null">create_time = #{createTime},</if>
             <if test="updateTime != null">update_time = #{updateTime},</if>
-            <if test="companyId != null">company_id = #{companyId},</if>
-            <if test="companyUserId != null">company_user_id = #{companyUserId},</if>
             <if test="createUserId != null">create_user_id = #{createUserId},</if>
             <if test="createDeptId != null">create_dept_id = #{createDeptId},</if>
-            <if test="isMall != null">is_mall = #{isMall},</if>
-            <if test="setCompanyIds != null">set_company_ids = #{setCompanyIds},</if>
+            <if test="status != null">`status` = #{status},</if>
         </trim>
         where id = #{id}
     </update>
@@ -130,10 +113,18 @@
         delete from fs_course_play_source_config where id = #{id}
     </delete>
 
-    <delete id="deleteFsCoursePlaySourceConfigByIds" parameterType="String">
-        update from fs_course_play_source_config set is_mall=1 where id in
+    <update id="deleteFsCoursePlaySourceConfigByIds" parameterType="String">
+        update fs_course_play_source_config
+        set is_del = 1
+        where id in
         <foreach item="id" collection="array" open="(" separator="," close=")">
             #{id}
         </foreach>
-    </delete>
+    </update>
+
+
+    <select id="selectFsCoursePlaySourceConfigAll"  resultMap="FsCoursePlaySourceConfigResult">
+        <include refid="selectFsCoursePlaySourceConfigVo"/>
+        where is_del = 0 and `status` = 0
+    </select>
 </mapper>

fs-service-system/src/main/resources/mapper/system/WxMiniProgramConfigMapper.xml

@@ -0,0 +1,122 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fs.system.mapper.WxMiniProgramConfigMapper">
+
+    <resultMap type="WxMiniProgramConfig" id="WxMiniProgramConfigResult">
+        <result property="id"    column="id"    />
+        <result property="appName"    column="app_name"    />
+        <result property="appid"    column="appid"    />
+        <result property="appSecret"    column="app_secret"    />
+        <result property="wxMerchantNo"    column="wx_merchant_no"    />
+        <result property="wxKey"    column="wx_key"    />
+        <result property="wxV3Key"    column="wx_v3_key"    />
+        <result property="wxKeyPath"    column="wx_key_path"    />
+        <result property="wxNotifyUrl"    column="wx_notify_url"    />
+        <result property="status"    column="status"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateTime"    column="update_time"    />
+        <result property="createBy"    column="create_by"    />
+        <result property="updateBy"    column="update_by"    />
+        <result property="remark"    column="remark"    />
+        <result property="merchantShortName"    column="merchant_short_name"    />
+        <result property="adminName"    column="admin_name"    />
+        <result property="signingTime"    column="signing_time"    />
+    </resultMap>
+
+    <sql id="selectWxMiniProgramConfigVo">
+        select id, app_name,wx_v3_key,merchant_short_name,admin_name,signing_time, appid, app_secret, wx_merchant_no, wx_key, wx_key_path, wx_notify_url, status, create_time, update_time, create_by, update_by, remark from wx_mini_program_config
+    </sql>
+
+    <select id="selectWxMiniProgramConfigList" parameterType="WxMiniProgramConfig" resultMap="WxMiniProgramConfigResult">
+        <include refid="selectWxMiniProgramConfigVo"/>
+        <where>
+            <if test="appName != null  and appName != ''"> and app_name like concat('%', #{appName}, '%')</if>
+            <if test="appid != null  and appid != ''"> and appid = #{appid}</if>
+        </where>
+    </select>
+
+    <select id="selectWxMiniProgramConfigById" parameterType="Long" resultMap="WxMiniProgramConfigResult">
+        <include refid="selectWxMiniProgramConfigVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertWxMiniProgramConfig" parameterType="WxMiniProgramConfig" useGeneratedKeys="true" keyProperty="id">
+        insert into wx_mini_program_config
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="appName != null">app_name,</if>
+            <if test="appid != null and appid != ''">appid,</if>
+            <if test="appSecret != null and appSecret != ''">app_secret,</if>
+            <if test="wxMerchantNo != null and wxMerchantNo != ''">wx_merchant_no,</if>
+            <if test="wxKey != null and wxKey != ''">wx_key,</if>
+            <if test="wxV3Key != null and wxV3Key != ''">wx_v3_key,</if>
+            <if test="wxKeyPath != null">wx_key_path,</if>
+            <if test="wxNotifyUrl != null and wxNotifyUrl != ''">wx_notify_url,</if>
+            <if test="status != null">status,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateTime != null">update_time,</if>
+            <if test="createBy != null">create_by,</if>
+            <if test="updateBy != null">update_by,</if>
+            <if test="remark != null">remark,</if>
+            <if test="merchantShortName != null">merchant_short_name,</if>
+            <if test="adminName != null">admin_name,</if>
+            <if test="signingTime != null">signing_time,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="appName != null">#{appName},</if>
+            <if test="appid != null and appid != ''">#{appid},</if>
+            <if test="appSecret != null and appSecret != ''">#{appSecret},</if>
+            <if test="wxMerchantNo != null and wxMerchantNo != ''">#{wxMerchantNo},</if>
+            <if test="wxKey != null and wxKey != ''">#{wxKey},</if>
+            <if test="wxV3Key != null and wxV3Key != ''">#{wxV3Key},</if>
+            <if test="wxKeyPath != null">#{wxKeyPath},</if>
+            <if test="wxNotifyUrl != null and wxNotifyUrl != ''">#{wxNotifyUrl},</if>
+            <if test="status != null">#{status},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+            <if test="createBy != null">#{createBy},</if>
+            <if test="updateBy != null">#{updateBy},</if>
+            <if test="remark != null">#{remark},</if>
+            <if test="merchantShortName != null">#{merchantShortName},</if>
+            <if test="adminName != null">#{adminName},</if>
+            <if test="signingTime != null">#{signingTime},</if>
+         </trim>
+    </insert>
+
+    <update id="updateWxMiniProgramConfig" parameterType="WxMiniProgramConfig">
+        update wx_mini_program_config
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="appName != null">app_name = #{appName},</if>
+            <if test="appid != null and appid != ''">appid = #{appid},</if>
+            <if test="appSecret != null and appSecret != ''">app_secret = #{appSecret},</if>
+            <if test="wxMerchantNo != null and wxMerchantNo != ''">wx_merchant_no = #{wxMerchantNo},</if>
+            <if test="wxKey != null and wxKey != ''">wx_key = #{wxKey},</if>
+            <if test="wxV3Key != null and wxV3Key != ''">wx_v3_key = #{wxV3Key},</if>
+            <if test="wxKeyPath != null">wx_key_path = #{wxKeyPath},</if>
+            <if test="wxNotifyUrl != null and wxNotifyUrl != ''">wx_notify_url = #{wxNotifyUrl},</if>
+            <if test="status != null">status = #{status},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+            <if test="createBy != null">create_by = #{createBy},</if>
+            <if test="updateBy != null">update_by = #{updateBy},</if>
+            <if test="remark != null">remark = #{remark},</if>
+            <if test="merchantShortName != null">merchant_short_name = #{merchantShortName},</if>
+            <if test="adminName != null">admin_name = #{adminName},</if>
+            <if test="signingTime != null">signing_time = #{signingTime},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteWxMiniProgramConfigById" parameterType="Long">
+        delete from wx_mini_program_config where id = #{id}
+    </delete>
+
+    <delete id="deleteWxMiniProgramConfigByIds" parameterType="String">
+        delete from wx_mini_program_config where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+</mapper>

fs-user-app/src/main/java/com/fs/app/controller/PaymentController.java

@@ -9,6 +9,7 @@ import com.fs.common.core.domain.R;
 import com.fs.common.utils.IpUtil;
 import com.fs.huifuPay.dto.TzMiniProgramCodeRespDTO;
 import com.fs.store.domain.FsStorePayment;
+import com.fs.system.mapper.FsCoursePlaySourceConfigMapper;
 import com.fs.wx.miniapp.config.WxMaConfiguration;
 import com.fs.wx.miniapp.config.WxMaProperties;
 import com.fs.store.domain.FsUser;
@@ -17,6 +18,7 @@ import com.fs.store.service.*;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import me.chanjar.weixin.common.error.WxErrorException;
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -37,7 +39,8 @@ public class PaymentController extends AppBaseController {
     @Autowired
     private WxMaProperties properties;
     protected final Logger logger = LoggerFactory.getLogger(PaymentController.class);
-
+    @Autowired
+    private FsCoursePlaySourceConfigMapper fsCoursePlaySourceConfigMapper;
     @Autowired
     private IFsStorePaymentService paymentService;
     @Autowired
@@ -47,7 +50,21 @@ public class PaymentController extends AppBaseController {
     @PostMapping("/payment")
     @RepeatSubmit
     public R payment(@Validated @RequestBody FsStorePaymentPayParam payment, HttpServletRequest request){
-        final WxMaService wxService = WxMaConfiguration.getMaService(properties.getConfigs().get(0).getAppid());
+        String courseMa_appId;
+
+        System.out.println("appid"+payment.getCode());
+        logger.info("appid"+payment.getCode());
+        if(StringUtils.isNotEmpty(payment.getAppId())){
+            try {
+                courseMa_appId = fsCoursePlaySourceConfigMapper.selectFsCoursePlaySourceConfigByAppId(payment.getAppId()).getAppid();
+            } catch (Exception e) {
+                courseMa_appId = payment.getAppId();
+            }
+        }else{
+            courseMa_appId = properties.getConfigs().get(0).getAppid();
+        }
+
+        final WxMaService wxService = WxMaConfiguration.getMaService(courseMa_appId);
         try {
             String ip = IpUtil.getRequestIp();
             WxMaJscode2SessionResult session = wxService.getUserService().getSessionInfo(payment.getCode());

fs-user-app/src/main/java/com/fs/app/controller/WxPayController.java

@@ -39,6 +39,9 @@ public class WxPayController {
     private IFsStoreOrderService orderService;
     @Autowired
     private IFsStoreOrderStatusService orderStatusService;
+
+    @Autowired
+    private IFsStorePaymentService storePaymentService;
     @Autowired
     private IFsUserService userService;
     /**
@@ -81,7 +84,43 @@ public class WxPayController {
     }
 
 
+    @ApiOperation("微信回调")
+    @PostMapping("/wxPayNotifyNew")
+    @Transactional
+    public String wxPayNotifyNew(HttpServletRequest request) throws Exception {
+        logger.info("====================进入微信回调接口===================");
+        try {
+            String xmlResult = IOUtils.toString(request.getInputStream(), request.getCharacterEncoding());
+            WxPayOrderNotifyResult result = wxPayService.parseOrderNotifyResult(xmlResult,"MD5");
+            System.out.println(result.getReturnCode());
+            if("SUCCESS".equals(result.getReturnCode())){
+                //订单号
+                String outtradeno = result.getOutTradeNo();
+                String tradeNo = result.getTransactionId();
+                System.out.println(outtradeno);
+                System.out.println(tradeNo);
+                String[] orderId=outtradeno.split("-");
+                switch (orderId[0]){
+                    case "store":
+                        orderService.payConfirm(1,null,orderId[1], outtradeno,tradeNo,null);
+                        break;
+                    case "store_remain":
+                        orderService.payRemainConfirm( orderId[1], outtradeno,tradeNo,null);
+                        break;
+                    case "payment":
+                        storePaymentService.payConfirm(orderId[1], outtradeno,tradeNo,null);
+                        break;
+                }
+                return WxPayNotifyResponse.success("");
+            }else{
+                return WxPayNotifyResponse.fail("");
+            }
 
+        } catch (Exception e) {
+            logger.error("微信回调结果异常,异常原因{}", e.getMessage());
+            return WxPayNotifyResponse.fail(e.getMessage());
+        }
+    }
 
     //处理订单
     @Synchronized