fix;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/candy/task/CandyMgtCouponTaskController.java

 package com.liquidnet.service.platform.controller.candy.task;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import com.liquidnet.common.cache.redis.util.RedisUtil;
-import com.liquidnet.commons.lang.util.IDGenerator;
-import com.liquidnet.service.candy.constant.CandyRedisConst;
-import com.liquidnet.service.candy.dto.CandyCouponCodeDto;
-import com.liquidnet.service.candy.dto.CandyCouponInfoDto;
-import com.liquidnet.service.candy.dto.CandyCouponRuleDto;
-import com.liquidnet.service.candy.dto.CandyUserCouponBasicDto;
-import com.liquidnet.service.candy.entity.*;
-import com.liquidnet.service.platform.service.impl.adam.dm.DMRdmService;
-import com.liquidnet.service.platform.service.impl.candy.*;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.candy.entity.CandyCoupon;
+import com.liquidnet.service.candy.entity.CandyMgtCoupon;
+import com.liquidnet.service.platform.service.impl.candy.PlatformCandyCouponService;
+import com.liquidnet.service.platform.service.impl.candy.PlatformCandyMgtCouponService;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.RandomStringUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.util.CollectionUtils;
-import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.time.LocalDateTime;
-import java.util.ArrayList;
 import java.util.List;
 
 @Slf4j
@@ -36,14 +25,14 @@ public class CandyMgtCouponTaskController {
     @Autowired
     private PlatformCandyCouponService platformCandyCouponService;
 
-    @PostMapping("issue/coupons")
-    public void issueCoupons() {
+    @PutMapping("issue/coupons")
+    public ResponseDto<String> issueCoupons() {
         LambdaQueryWrapper<CandyMgtCoupon> queryWrapper = Wrappers.lambdaQuery(CandyMgtCoupon.class)
                 .eq(CandyMgtCoupon::getState, 0)
                 // TODO: 2021/8/26 时间判断
                 .orderByAsc(CandyMgtCoupon::getEventAt);
         List<CandyMgtCoupon> list = platformCandyMgtCouponService.list(queryWrapper);
-        int taskSize = CollectionUtils.isEmpty(list) ? -1 : list.size();
+        int taskSize = CollectionUtils.isEmpty(list) ? -1 : list.size(), pl = 0;
         log.info("发放券任务总数:{} >>> BEGIN BEGIN BEGIN", taskSize);
 
         for (int i = 0; i < taskSize; i++) {
@@ -82,11 +71,15 @@ public class CandyMgtCouponTaskController {
 
                     log.info("发放券任务总数:{},任务{}处理{}[mcouponId:{},couType:{},bindType:{},eventAmt:{},eventType:{}]", taskSize, i, (update ? "成功" : "失败"),
                             mgtCoupon.getMcouponId(), coupon.getCouType(), coupon.getBindType(), mgtCoupon.getEventAmt(), mgtCoupon.getEventType());
+
+                    pl++;
                 }
             } catch (Exception e) {
                 log.error("发放券任务总数:{},任务{}处理异常[mcouponId:{}]", taskSize, i, mgtCoupon.getMcouponId(), e);
             }
         }
-        log.info("发放券任务总数:{} >>> END END END", taskSize);
+        log.info("发放券任务总数:{},成功处理任务数:{} >>> END END END", taskSize, pl);
+
+        return ResponseDto.success(String.format("发放券任务总数:%s,成功处理任务数:%s", taskSize, pl));
     }
 }