添加积分消息队列接口

xx-activity/xx-activity-api/src/main/java/com/xxfc/platform/activity/entity/IntegralUserRecord.java

@@ -58,7 +58,7 @@ public class IntegralUserRecord {
      * 获取积分的途径id:如订单id,评论id，签到记录id
      */
     @Column(name = "channel_id")
-    private Integer channelId;
+    private String channelId;
 
 
 }
\ No newline at end of file

xx-activity/xx-activity-api/src/main/java/com/xxfc/platform/activity/vo/IntegralUserRecordDto.java

@@ -23,7 +23,7 @@ public class IntegralUserRecordDto extends PageParam {
     /**
      * 获取积分的途径id:如订单id,评论id，签到记录id
      */
-    private Integer channelId;
+    private String channelId;
 
     public IntegralUserRecord getIntegralUserRecord() {
         IntegralUserRecord integralUserRecord = new IntegralUserRecord();

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/IntegralSignRecordBiz.java

@@ -138,7 +138,7 @@ public class IntegralSignRecordBiz extends BaseBiz<IntegralSignRecordMapper, Int
         IntegralUserRecordDto integralUserRecord = new IntegralUserRecordDto();
         integralUserRecord.setUserId(appUserDTO.getUserid());
         integralUserRecord.setType(0);
-        integralUserRecord.setChannelId(integralSignRecords.get(0).getId());
+        integralUserRecord.setChannelId(integralSignRecords.get(0).getId().toString());
         integralUserRecord.setIntegralRuleCode(integralRule.getCode());
         integralUserRecord.setPoint(point);
         integralUserRecordBiz.add(integralUserRecord);

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/biz/OrderPayBiz.java

@@ -148,7 +148,7 @@ public class OrderPayBiz extends BaseBiz<OrderPayMapper,OrderPay> {
                 JSONObject jsonObject = new JSONObject();
                 jsonObject.put("userId", newValue.getUserId());
                 jsonObject.put("amount", newValue.getAmount());
-                jsonObject.put("channelId", newValue.getId());
+                jsonObject.put("channelId", newValue.getOrderNo());
                 if(newValue.getChannel() == 1) {//租车
                     jsonObject.put("integralRuleCode", "RENTRV");
                 } else if(newValue.getChannel() == 2) { //旅游