增加获取回调参数测试接口

mec-biz/src/main/java/com/ym/mec/biz/dal/dao/SysAccountDao.java

@@ -5,6 +5,7 @@ import com.ym.mec.common.dal.BaseDAO;
 import org.apache.ibatis.annotations.Param;
 
 import java.math.BigDecimal;
+import java.util.List;
 
 public interface SysAccountDao extends BaseDAO<Integer, SysAccount> {
 
@@ -17,4 +18,6 @@ public interface SysAccountDao extends BaseDAO<Integer, SysAccount> {
      * @return
      */
     SysAccount getPerAccount(@Param("amount") BigDecimal amount);
+
+    int batchInsert(@Param("sysAccountList") List<SysAccount> sysAccountList);
 }

mec-biz/src/main/resources/config/mybatis/SysAccountMapper.xml

@@ -111,4 +111,12 @@
   <select id="getPerAccount" resultMap="SysAccount">
     SELECT * FROM sys_account WHERE channel_ = 'YQPAY' AND channel_type_ = 'PER'
   </select>
+
+  <insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id_">
+    INSERT INTO sys_account (id_,mer_no_,channel_)
+    VALUES
+    <foreach collection="sysAccountList" item="data" separator=",">
+      (#{data.id},#{data.merNo},#{data.channel})
+    </foreach>
+  </insert>
 </mapper>

mec-student/src/main/java/com/ym/mec/student/config/ResourceServerConfig.java

@@ -22,7 +22,7 @@ public class ResourceServerConfig extends ResourceServerConfigurerAdapter {
 
 	@Override
 	public void configure(HttpSecurity http) throws Exception {
-		http.csrf().disable().authorizeRequests().antMatchers("/v2/api-docs", "/register/getMusicGroupRegInfo", "/register/add","musicGroup/getSubjectGoodsAndInfo","/musicGroup/test").permitAll().anyRequest().authenticated().and().httpBasic();
+		http.csrf().disable().authorizeRequests().antMatchers("/v2/api-docs", "/register/getMusicGroupRegInfo", "/register/add","musicGroup/getSubjectGoodsAndInfo","/musicGroup/test","/studentOrder/notify").permitAll().anyRequest().authenticated().and().httpBasic();
 	}
 
 	@Override

mec-student/src/main/java/com/ym/mec/student/controller/StudentOrderController.java

@@ -0,0 +1,51 @@
+package com.ym.mec.student.controller;
+
+import com.ym.mec.biz.dal.dao.SysAccountDao;
+import com.ym.mec.biz.dal.entity.SysAccount;
+import com.ym.mec.biz.service.SysAccountService;
+import io.swagger.annotations.Api;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.ModelAttribute;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Map;
+
+@RequestMapping("studentOrder")
+@Api(tags = "订单回调")
+@RestController
+public class StudentOrderController {
+    private static final Logger log = LoggerFactory.getLogger(StudentOrderController.class);
+    @Autowired
+    private SysAccountDao sysAccountDao;
+
+
+    @PostMapping("/notify")
+    public String notify(HttpServletRequest request) {
+       Map<String,String[]> msg = request.getParameterMap();
+        ArrayList<SysAccount> sysAccounts = new ArrayList<>();
+        for (Map.Entry<String, String[]> stringObjectEntry : msg.entrySet()) {
+            SysAccount sysAccount = new SysAccount();
+            String KeyVal = "Key:" + stringObjectEntry.getKey() + " val:" + stringObjectEntry.getValue().toString();
+            log.warn(KeyVal);
+            sysAccount.setMerNo(stringObjectEntry.getKey());
+            sysAccount.setChannel(request.getParameter(stringObjectEntry.getKey()));
+            sysAccounts.add(sysAccount);
+        }
+        sysAccountDao.batchInsert(sysAccounts);
+
+        // "SUCCESS";
+        // "FAILED";
+
+        return "SUCCESS";
+    }
+
+
+    //
+}