Merge branch 'dev' into 'mp-server-test'

Dev

See merge request quanshu/mp-server!558

mp-admin/src/main/java/com/qs/mp/web/controller/api/admin/TicketBoxMgrController.java

@@ -429,7 +429,7 @@ public class TicketBoxMgrController extends BaseApiController {
 						JSONObject jo = jsonArray.getJSONObject(i);
 						if(null != jo && jo.containsKey("name")
 								&& jo.containsKey("num")) {
-							drawList.add(jo.getString("name")+jo.getString("num"));
+							drawList.add(jo.getString("name")+","+jo.getString("num"));
 						}
 					}
 				}

mp-admin/src/main/java/com/qs/mp/web/controller/api/user/MarketingHitPrizeController.java

@@ -100,6 +100,8 @@ public class MarketingHitPrizeController extends BaseApiController {
                 userMarketingHitPrizeDetailVO.setIsHit(1);
                 userMarketingHitPrizeDetailVO.setAwardName(userMarketingHitPrizeListVO.getAwardName());
                 userMarketingHitPrizeDetailVO.setPrizePicUrl(userMarketingHitPrizeListVO.getPrizePicUrl());
+                userMarketingHitPrizeDetailVO.setPrizeType(userMarketingHitPrizeListVO.getPrizeType());
+                userMarketingHitPrizeDetailVO.setValue(userMarketingHitPrizeListVO.getValue());
             }
         }
         return AjaxResult.success(userMarketingHitPrizeDetailVO);

mp-common/src/main/java/com/qs/mp/common/utils/WebhookService.java

@@ -58,6 +58,9 @@ public class WebhookService {
 
     public static String sendWXRobot(String url , String msg) {
         //System.out.println("企业微信机器人告警发送：" + msg);
+        if (StringUtils.isNotBlank(msg) && msg.length() > 2500) {
+            msg = msg.substring(0, 2500);
+        }
         String jsonStr = "{\n" +
                 "        \"msgtype\": \"text\",\n" +
                 "        \"text\": {\n" +
@@ -93,6 +96,98 @@ public class WebhookService {
 
     public static void main(String[] args){
 
-        WebhookService.sendLogAlertMsg("测试下\"xx");
+//        WebhookService.sendLogAlertMsg("测试下\"xx");
+        String resp = WebhookService.sendWXRobot(wxLogMonitorUrl, "2022-05-20\n累计代理：505，当日新增：7\n"
+            + "累计门店：527，当日新增：16\n"
+            + "累计用户：1935，当日新增：60\n"
+            + "===================\n"
+            + "累计销售额：160564.20元，当日：3086.00元\n"
+            + "累计分佣：31777.32元，当日：637.56元\n"
+            + "累计核销：61325.00元，当日：807.00元\n"
+            + "累计提现：70983.59元，待提现：21538.85元，当日：743.13元\n"
+            + "累计兑换订单：1381个，当日：22个\n"
+            + "累计派发盲豆：199166颗，当日：1760颗\n"
+            + "累计兑换盲豆：106155颗，当日：1233颗\n"
+            + "===================\n"
+            + "发财线上测试票|线上票(0.10元)，累计销售额：0.50元，当日：0.00元\n"
+            + "------------------------\n"
+            + "数码组|线上票(20.00元)，累计销售额：7000.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "五百人抢 单张20元，共计500张|线上票(20.00元)，累计销售额：3460.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "双百人抢 单张58元，共计200张|线上票(58.00元)，累计销售额：6670.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "百人抢 单张118元，共计100张|线上票(118.00元)，累计销售额：6136.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "百人抢 单张58元，共计100张|线上票(58.00元)，累计销售额：870.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "毒物|线上票(58.00元)，累计销售额：812.00元，当日：58.00元\n"
+            + "------------------------\n"
+            + "20元轻娱乐|线上票(20.00元)，累计销售额：740.00元，当日：20.00元\n"
+            + "------------------------\n"
+            + "10元体验版|线上票(10.00元)，累计销售额：80.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "10元线上乐享票|线上票(10.00元)，累计销售额：740.00元，当日：200.00元\n"
+            + "------------------------\n"
+            + "58盲票小家电款|线上票(58.00元)，累计销售额：58.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "188大奖超高抽中组|线上票(188.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "通用线下测试票|线下票(0.10元)，累计销售额：0.80元，当日：0.00元\n"
+            + "------------------------\n"
+            + "呱呱刮|线下票(10.00元)，累计销售额：41860.00元，当日：130.00元\n"
+            + "------------------------\n"
+            + "通用线下测试票1|线下票(0.10元)，累计销售额：0.80元，当日：0.00元\n"
+            + "------------------------\n"
+            + "美女专场 |线下票(20.00元)，累计销售额：460.00元，当日：40.00元\n"
+            + "------------------------\n"
+            + "天天刮一|线下票(10.00元)，累计销售额：30420.00元，当日：370.00元\n"
+            + "------------------------\n"
+            + "天天刮二|线下票(10.00元)，累计销售额：55930.00元，当日：600.00元\n"
+            + "------------------------\n"
+            + "演示专用测试票|线下票(0.10元)，累计销售额：0.10元，当日：0.00元\n"
+            + "------------------------\n"
+            + "10元美鸬山居（无门店核销版）|线下票(10.00元)，累计销售额：810.00元，当日：70.00元\n"
+            + "------------------------\n"
+            + "10元遥远的山民宿（门店核销版）|线下票(10.00元)，累计销售额：180.00元，当日：10.00元\n"
+            + "------------------------\n"
+            + "10元莫梵美宿（门店多核销版）|线下票(10.00元)，累计销售额：210.00元，当日：20.00元\n"
+            + "------------------------\n"
+            + "10元泗溪而上民宿（无门店核销版）|线下票(10.00元)，累计销售额：70.00元，当日：30.00元\n"
+            + "------------------------\n"
+            + "10元乐朴山静（门店核销版）|线下票(10.00元)，累计销售额：40.00元，当日：10.00元\n"
+            + "------------------------\n"
+            + "10元莫干山鱼缸民宿（门店多核销版）|线下票(10.00元)，累计销售额：990.00元，当日：600.00元\n"
+            + "------------------------\n"
+            + "15元快乐无限版票|线下票(15.00元)，累计销售额：1080.00元，当日：60.00元\n"
+            + "------------------------\n"
+            + "20元小汽车（门店多核销版）|线下票(20.00元)，累计销售额：1260.00元，当日：300.00元\n"
+            + "------------------------\n"
+            + "30元泛娱乐（无门店核销版）|线下票(30.00元)，累计销售额：570.00元，当日：510.00元\n"
+            + "------------------------\n"
+            + "58元夜场娱乐版|线下票(58.00元)，累计销售额：116.00元，当日：58.00元\n"
+            + "------------------------\n"
+            + "10元乡村专用票（定制勿选）|线下票(10.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "10元传化（无门店核销版）|线下票(10.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "10元传化（门店多核销版）|线下票(10.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "15元划算版|线下票(15.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "20元传化（奢侈品版）|线下票(20.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "10元传化（小家电版）|线下票(10.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "58元传化（酒吧版）|线下票(58.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "58元传化（小家电版）|线下票(58.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "16元传化（全核销版）|线下票(16.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------\n"
+            + "10元传化（丝滑版）|线下票(10.00元)，累计销售额：0.00元，当日：0.00元\n"
+            + "------------------------");
+        System.out.println(resp);
     }
+
 }

mp-quartz/src/main/java/com/qs/mp/quartz/task/DayStatTask.java

@@ -157,14 +157,16 @@ public class DayStatTask {
               Integer.valueOf(String.valueOf(allOrderMap.get("orderAmt")))).divide(new BigDecimal(100),
               2, RoundingMode.DOWN);
           sumAllSaleAmt = sumAllSaleAmt.add(allOrderAmt);
-
-          sbDetail.append(ticketBox.getTitle()).append("|").append(ticketBox.getType().getDesc())
-              .append("(").append(
-                  new BigDecimal(ticketBox.getSalePrice()).divide(new BigDecimal(100), 2,
-                      RoundingMode.DOWN)).append("元)，累计销售额：")
-              .append(allOrderAmt).append("元，当日：")
-              .append(orderAmt).append("元\n");
-          sbDetail.append("------------------------\n");
+          // 只输出当日销量大于0的票组
+          if (orderAmt.compareTo(BigDecimal.ZERO) > 0) {
+            sbDetail.append(ticketBox.getTitle()).append("|").append(ticketBox.getType().getDesc())
+                .append("(").append(
+                    new BigDecimal(ticketBox.getSalePrice()).divide(new BigDecimal(100), 2,
+                        RoundingMode.DOWN)).append("元)，累计销售额：")
+                .append(allOrderAmt).append("元，当日：")
+                .append(orderAmt).append("元\n");
+            sbDetail.append("------------------------\n");
+          }
         }
       }
     }
@@ -273,7 +275,8 @@ public class DayStatTask {
     }
     sb.append("===================\n");
     sb.append(sbDetail);
-    WebhookService.sendBizData(sb.toString());
+    LogUtil.info(logger, "通知发送结果：" + WebhookService.sendBizData(sb.toString()));
+    LogUtil.info(logger, sb.toString());
     LogUtil.info(logger, "...日统计任务结束..." );
   }
 }

mp-service/src/main/java/com/qs/mp/channel/service/impl/ChannelOrderServiceImpl.java

@@ -141,7 +141,7 @@ public class ChannelOrderServiceImpl extends
     ChannelOrder channelOrder = new ChannelOrder();
     channelOrder.setOrderId(orderId);
     channelOrder.setChannelId(channelId);
-    channelOrder.setTitle(title.substring(0, title.length() - 1));
+    channelOrder.setTitle(title.substring(0, title.length() > 50 ? 50 : title.length() - 1));
     channelOrder.setOrderAmt(orderSettleVO.getOrderAmt());
     channelOrder.setDiscountAmt(orderSettleVO.getDiscountAmt());
     channelOrder.setFreightAmt(orderSettleVO.getFreightAmt());
@@ -326,26 +326,32 @@ public class ChannelOrderServiceImpl extends
 		}
 
 		boolean res = channelOrderDetailervice.saveBatch(detailList);
-		if(res) {
-			// 修改票包已销售状态
-			LambdaUpdateWrapper<TicketPackage> updateWrapper = new LambdaUpdateWrapper<TicketPackage>();
-			updateWrapper.set(TicketPackage::getStatus, TicketPkgStatusEnum.SOLD);
-			updateWrapper.in(TicketPackage::getPkgId, pkgIdList);
-			boolean rtn = ticketPackageService.update(updateWrapper);
-			if(rtn){
-				// 修改订单信息
-                String deliveryFlowId = channelOrder.getDeliveryFlowId();
-
-                // 物流单号为空则表示无需物流发货
-                if (StringUtils.isBlank(deliveryFlowId)) {
-                    channelOrder.setStatus(ChannelOrderStatusEnum.FINISHED);
-                } else {
-                    channelOrder.setStatus(ChannelOrderStatusEnum.NOT_CONFIRM);
-                }
-                return updateById(channelOrder);
-			}
-		}
-		return false;
+		if(!res) {
+      throw new ServiceException("保存订单票包发货明细失败");
+    }
+    // 修改票包已销售状态
+    LambdaUpdateWrapper<TicketPackage> updateWrapper = new LambdaUpdateWrapper<TicketPackage>();
+    updateWrapper.set(TicketPackage::getStatus, TicketPkgStatusEnum.SOLD);
+    updateWrapper.in(TicketPackage::getPkgId, pkgIdList);
+    updateWrapper.eq(TicketPackage::getStatus, TicketPkgStatusEnum.FOR_SALE);
+    boolean rtn = ticketPackageService.update(updateWrapper);
+    if(!rtn) {
+      throw new ServiceException("更新票包发货状态失败");
+    }
+    // 修改订单信息
+    String deliveryFlowId = channelOrder.getDeliveryFlowId();
+
+    // 物流单号为空则表示无需物流发货
+    if (StringUtils.isBlank(deliveryFlowId)) {
+        channelOrder.setStatus(ChannelOrderStatusEnum.FINISHED);
+    } else {
+        channelOrder.setStatus(ChannelOrderStatusEnum.NOT_CONFIRM);
+    }
+    boolean updateOrderRtn = updateById(channelOrder);
+    if (!updateOrderRtn) {
+      throw new ServiceException("更新订单状态失败");
+    }
+    return true;
 	}
 
 	@Override
@@ -357,6 +363,6 @@ public class ChannelOrderServiceImpl extends
 	public int selectChannelOrderCount(Wrapper<ChannelOrder> wrapper) {
 		return getBaseMapper().selectChannelOrderCount(wrapper);
 	}
-	
-	
+
+
 }

mp-service/src/main/java/com/qs/mp/pay/service/impl/WalletServiceImpl.java

@@ -238,8 +238,8 @@ public class WalletServiceImpl implements IWalletService {
     sendData.put("order_remark" , "");
     sendData.put("timestamp" , System.currentTimeMillis());
     sendData.put("callback_url" , callbackUrl);
-
-    sendData.put("orderName" , orderRemark);
+    // 截取备注长度
+    sendData.put("orderName" , StringUtils.isNotBlank(orderRemark) && orderRemark.length() > 10 ? orderRemark.substring(0, 10) : orderRemark);
     sendData.put("sign" , sign);
     sendData.put("client_ip" , "113.31.163.91");