update activity

src/main/java/com/example/afrishop_v3/models/ActivityVo.java

+package com.example.afrishop_v3.models;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+/**
+ * @Auther: wudepeng
+ * @Date: 2020/12/11
+ * @Description:活动模板
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class ActivityVo {
+
+    private Activity activity;
+    private String activityId;
+    private Integer itemNum;
+    private BigDecimal itemPrice;
+
+    public String getActivityId() {
+        return activity == null ? null : activity.getId();
+    }
+}

src/main/java/com/example/afrishop_v3/models/TbCfOrder.java

 package com.example.afrishop_v3.models;
 
 import com.alibaba.fastjson.JSONObject;
+import com.example.afrishop_v3.base.Result;
 import com.example.afrishop_v3.base.StateConstant;
 import com.example.afrishop_v3.enums.OrderStatusEnum;
+import com.example.afrishop_v3.enums.ResultCodeEnum;
 import com.example.afrishop_v3.repository.ActivityRepository;
 import com.example.afrishop_v3.repository.TbCfStationItemRepository;
 import com.example.afrishop_v3.util.IdUtil;
@@ -13,10 +15,13 @@ import lombok.Data;
 import net.sf.json.JSONArray;
 import org.hibernate.annotations.Where;
 import org.springframework.data.relational.core.sql.In;
+import org.springframework.web.bind.annotation.PathVariable;
 
 import javax.persistence.*;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
+import java.text.DateFormat;
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -249,7 +254,7 @@ public class TbCfOrder {
         return itemOrderList;
     }
 
-    public void getItemOrderListFromCartList(List<TbCfCartRecordR> cartList, TbCfStationItemRepository itemRepository, ActivityRepository activityRepository) {
+    public void getItemOrderListFromCartList(List<TbCfCartRecordR> cartList, TbCfStationItemRepository itemRepository, ActivityRepository activityRepository) throws ParseException {
         itemOrderList = cartList.stream().map(f -> f.getOrderItem(orderId)).collect(Collectors.toList());
         doSomeCalculations(itemRepository, activityRepository);
         setOrderTime(new Date());
@@ -262,13 +267,14 @@ public class TbCfOrder {
         this.defaultTemplate = defaultTemplate;
     }
 
-    private void doSomeCalculations(TbCfStationItemRepository itemRepository, ActivityRepository activityRepository) {
+    private void doSomeCalculations(TbCfStationItemRepository itemRepository, ActivityRepository activityRepository) throws ParseException {
         itemsPrice = itemsPrice == null ? new BigDecimal(0.0) : itemsPrice;
         expressCost = expressCost == null ? new BigDecimal(0.0) : expressCost;
         fee = fee == null ? new BigDecimal(0.0) : fee;
         tax = tax == null ? new BigDecimal(0.0) : tax;
         reduceAmount = reduceAmount == null ? new BigDecimal(0.0) : reduceAmount;
         List<TemplateVo> templateList = new ArrayList<>();
+//        List<ActivityVo> activityList = new ArrayList<>();
 
         itemOrderList.forEach(item -> {
             BigDecimal itemPrice = item.getItemPriceTotal();
@@ -281,9 +287,16 @@ public class TbCfOrder {
             Optional<TbCfStationItem> optionalTbCfStationItem = itemRepository.findById(item.getItemId());
             boolean categoriesAct = activityRepository.existsByUseType(2);
             boolean specialAct = activityRepository.existsByUseType(3);
-            if (categoriesAct || specialAct) {
-
-            }
+//            Activity activity = new Activity();
+//            if (categoriesAct || specialAct) {
+//                try {
+//                    activity = getItemActivity(activityRepository, itemRepository, item.getItemId());
+//                } catch (ParseException e) {
+//                    e.printStackTrace();
+//                }
+//
+//                activityList.add(new ActivityVo(activity, activity.getId(), item.getItemNum(), itemPrice));
+//            }
             if (optionalTbCfStationItem.isPresent()) {
                 TbCfStationItem stationItem = optionalTbCfStationItem.get();
                 if (stationItem.getExpress() != null) {
@@ -299,6 +312,8 @@ public class TbCfOrder {
                 templateList.add(new TemplateVo(template, template.getTemplateId(), item.getItemNum(), itemPrice));
         });
         Map<String, List<TemplateVo>> map = templateList.stream().collect(Collectors.groupingBy(TemplateVo::getTemplateId));
+//        Map<String, List<ActivityVo>> actMap = activityList.stream().collect(Collectors.groupingBy(ActivityVo::getActivityId));
+
         //按模板分组计算商品价格
         Integer itemSum = 0;
         List<TemplateVo> list = new ArrayList<>();
@@ -362,8 +377,48 @@ public class TbCfOrder {
                 System.out.println("折扣比例：" + rate);
                 itemsPrice = rate.multiply(itemsPrice);
             }
+        } /*else {
+            //按活动类型计算优惠价格
+            Integer sum = 0;
+            List<ActivityVo> actlist = new ArrayList<>();
+            for (String key : actMap.keySet()) {
+                Activity activity = null;
+                ActivityVo activityVo = new ActivityVo();
+                Integer count = 0;
+                BigDecimal totalPrice = BigDecimal.ZERO;
+                for (ActivityVo act : actMap.get(key)) {
+                    totalPrice = totalPrice.add(act.getItemPrice());
+                    count += act.getItemNum();
+                    sum += act.getItemNum();
+                    activity = act.getActivity();
+                }
+                activityVo.setActivity(activity);
+                activityVo.setActivityId(key);
+                activityVo.setItemNum(count);
+                activityVo.setItemPrice(totalPrice);
+                actlist.add(activityVo);
             }
 
+            actlist.forEach(act -> {
+                while (act.getActivityId() == null) {
+                    continue;
+                }
+                if ("1".equals(act.getActivity().getUseType())) {
+                    reduceAmount = caculateActFee(false, false, act.getActivity(), act.getItemPrice(), null);
+                    System.out.println("减免金额：" + reduceAmount);
+                } else if ("2".equals(act.getActivity().getUseType())) {
+                    rate = caculateActFee(false, true, act.getActivity(), act.getItemPrice(), null);
+                    System.out.println("折扣比例：" + rate);
+                    itemsPrice = rate.multiply(itemsPrice);
+                } else if ("3".equals(act.getActivity().getUseType())) {
+                    rate = caculateActFee(true, true, act.getActivity(), act.getItemPrice(), act.getItemNum());
+                    System.out.println("购买件数：" + act.getItemNum());
+                    System.out.println("折扣比例：" + rate);
+                    itemsPrice = rate.multiply(itemsPrice);
+                }
+            });
+        }*/
+
         totalPrice = itemsPrice.add(fee).add(tax).add(expressCost).subtract(reduceAmount);
 
         countRealityPay();
@@ -893,4 +948,63 @@ public class TbCfOrder {
     public String getRemarkInfo() {
         return remarkInfo;
     }
+
+    public Activity getItemActivity(ActivityRepository activityRepository, TbCfStationItemRepository itemRepository, String itemId) throws ParseException {
+        Activity activity = null;
+//
+        //全场活动
+        if (activityRepository.existsByUseType(1)) {
+            List<Activity> fullList = activityRepository.findAllByUseType(1);
+            activity = fullList.get(0);
+        }
+
+        //商品分类活动
+        if (activityRepository.existsByUseType(2)) {
+            Optional<TbCfStationItem> byId = itemRepository.findById(itemId);
+            if (byId.isPresent()) {
+                TbCfStationItem item = byId.get();
+                String category1 = item.getItemCategory();
+                String category2 = item.getItemCategorytwo();
+                String category3 = item.getItemDescritionId();
+                String con2 = category1 + "," + category2;
+                String con3 = category1 + "," + category2 + "," + category3;
+
+                List<Activity> activityList = activityRepository.findAllByUseType(2);
+                List<Activity> actList = new ArrayList<>();
+                for (Activity act2 : activityList) {
+                    if (category1.equals(act2.getCategoryId())) {
+                        act2.setOrder(3);
+                        actList.add(act2);
+                    }
+                    if (con2.equals(act2.getCategoryId())) {
+                        act2.setOrder(2);
+                        actList.add(act2);
+                    }
+                    if (con3.equals(act2.getCategoryId())) {
+                        act2.setOrder(1);
+                        actList.add(act2);
+                    }
+                }
+                Collections.sort(actList, Comparator.comparing(Activity::getOrder));
+                if (actList.size() > 0 && actList != null)
+                    activity = actList.get(0);
+            }
+
+        }
+
+        //特定商品
+        if (activityRepository.existsByUseType(3)) {
+            List<Activity> list = activityRepository.findAllByUseType(3);
+            for (Activity act3 : list) {
+                String[] itemIdArr = act3.getItemIds().split(",");
+                List<String> idList = Arrays.asList(itemIdArr);
+                if (idList.contains(itemId))
+                    activity = act3;
+                break;
+            }
+
+        }
+
+        return activity;
+    }
 }