需求

mall-server-api/src/main/java/com/gree/mall/manager/logic/policy/PolicyOrderLogic.java

@@ -1,5 +1,6 @@
 package com.gree.mall.manager.logic.policy;
 
+import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.gree.mall.manager.bean.admin.AdminUserCom;
@@ -10,12 +11,14 @@ import com.gree.mall.manager.bean.policy.PolicyVo;
 import com.gree.mall.manager.commonmapper.PolicyCMapper;
 import com.gree.mall.manager.logic.common.CommonLogic;
 import com.gree.mall.manager.plus.entity.PolicyOrder;
+import com.gree.mall.manager.plus.entity.WorkerPolicy;
 import com.gree.mall.manager.plus.service.PolicyOrderService;
 import com.gree.mall.manager.zfire.bean.ZfireParamBean;
 import com.gree.mall.manager.zfire.util.FieldUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
 import java.util.List;
 
 @Service
@@ -84,7 +87,54 @@ public class PolicyOrderLogic {
     public void importData(List<Object> objects) {
 
         for (Object o : objects) {
-            String websitNumber = (String) row.get(0);
+            List<Object> row = (List<Object>) o;
+
+
+            PolicyOrder policyOrder = policyOrderService.lambdaQuery()
+                    .eq(PolicyOrder::getWebsitId, (String) row.get(1))
+                    .eq(PolicyOrder::getWorkerNumber, (String) row.get(3))
+                    .eq(PolicyOrder::getType, "IN")
+                    .eq(PolicyOrder::getPolicyOrderStatus, "DSX").one();
+
+
+            if (policyOrder != null){
+                WorkerPolicy workerPolicy = new WorkerPolicy();
+                workerPolicy.setWorkerId(policyOrder.getWorkerNumber());
+                workerPolicy.setType("IN");
+                workerPolicy.setOrderId(policyOrder.getId());
+                workerPolicy.setPolicyName(policyOrder.getPolicyName());
+                workerPolicy.setCompany(policyOrder.getBelongCompany());
+                workerPolicy.setPolicyOrder(policyOrder.getPolicyNumber());
+                workerPolicy.setPolicyType("IN");
+                workerPolicy.setStartTime(policyOrder.getStartTime());
+                workerPolicy.setEndTime(policyOrder.getEndTime());
+                workerPolicy.setWebsitUserId(policyOrder.getId());
+                workerPolicy.setWebsitId(policyOrder.getWebsitId());
+                workerPolicy.setWebsitName(policyOrder.getWebsitName());
+                workerPolicy.setWorkerName(policyOrder.getWorkerName());
+
+                if (new Date().after(policyOrder.getStartTime()) && new Date().before(policyOrder.getEndTime()))
+                    workerPolicy.setStatus("BZZ");
+                else if (new Date().after(policyOrder.getEndTime()))
+                    workerPolicy.setStatus("YSX");
+                else {
+                    workerPolicy.setStatus("DSX");
+                }
+                workerPolicy.insert();
+            }
+
+            policyOrderService.lambdaUpdate()
+                    .eq(PolicyOrder::getWebsitId,(String) row.get(1))
+                    .eq(PolicyOrder::getWorkerNumber,(String) row.get(3))
+                    .eq(PolicyOrder::getType,"IN")
+                    .eq(PolicyOrder::getPolicyOrderStatus,"DSX")
+                    .set(PolicyOrder::getStartTime, DateUtil.parse((String) row.get(9),"yyyy-MM-dd"))
+                    .set(PolicyOrder::getEndTime,DateUtil.endOfDay(DateUtil.parse((String) row.get(10),"yyyy-MM-dd")))
+                    .set(PolicyOrder::getClassWebsitId,(String) row.get(11))
+                    .set(PolicyOrder::getClassWebsitName,(String) row.get(12))
+                    .set(DateUtil.parse((String) row.get(9),"yyyy-MM-dd").after(new Date()),PolicyOrder::getPolicyOrderStatus,"BZZ")
+                    .update();
+
         }
     }
 }