需求

mall-server-api/src/main/java/com/gree/mall/manager/controller/policy/PolicyOrderController.java

@@ -91,6 +91,17 @@ public class PolicyOrderController {
         FieldUtils.exportData(policyOrderVOIPage.getRecords(), zfireParam.getExportFields(), request, response);
     }
 
+
+    @PostMapping("/importEm")
+    @ApiOperation(value = "雇主险导入")
+    public ResponseHelper importEm(
+            @RequestParam MultipartFile file
+    ) throws RemoteServiceException, IOException {
+        List<Object> objects = ExcelUtils.importExcel(file);
+        policyOrderLogic.importEm(objects);
+        return ResponseHelper.success();
+    }
+
     @PostMapping("/detail")
     @ApiOperation("保险险订单详情")
     public ResponseHelper<PolicyOrder> detail(
@@ -141,7 +152,7 @@ public class PolicyOrderController {
 
 
     @PostMapping("/import")
-    @ApiOperation(value = "工伤保险导入购买")
+    @ApiOperation(value = "工伤保险导入")
     public ResponseHelper wait2Del(
             @RequestParam MultipartFile file
     ) throws RemoteServiceException, IOException {

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

@@ -2,6 +2,7 @@ package com.gree.mall.manager.logic.policy;
 
 import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.gree.mall.manager.bean.admin.AdminUserCom;
 import com.gree.mall.manager.bean.policy.PolicyOrderEmVO;
@@ -9,15 +10,21 @@ import com.gree.mall.manager.bean.policy.PolicyOrderInVO;
 import com.gree.mall.manager.bean.policy.PolicyOrderVO;
 import com.gree.mall.manager.bean.policy.PolicyVo;
 import com.gree.mall.manager.commonmapper.PolicyCMapper;
+import com.gree.mall.manager.enums.IsYesNoEnum;
 import com.gree.mall.manager.logic.common.CommonLogic;
+import com.gree.mall.manager.plus.entity.AdminWebsit;
 import com.gree.mall.manager.plus.entity.PolicyOrder;
+import com.gree.mall.manager.plus.entity.WebsitUser;
 import com.gree.mall.manager.plus.entity.WorkerPolicy;
+import com.gree.mall.manager.plus.service.AdminWebsitService;
 import com.gree.mall.manager.plus.service.PolicyOrderService;
+import com.gree.mall.manager.plus.service.WebsitUserService;
 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.math.BigDecimal;
 import java.util.Date;
 import java.util.List;
 
@@ -34,15 +41,21 @@ public class PolicyOrderLogic {
     @Autowired
     PolicyOrderService policyOrderService;
 
+    @Autowired
+    AdminWebsitService adminWebsitService;
+
+    @Autowired
+    WebsitUserService websitUserService;
+
     public IPage<PolicyOrderVO> listPolicyOrder(Page page, ZfireParamBean zfireParam) {
         //获取当前登录企业id
         AdminUserCom adminUser = commonLogic.getAdminUser();
 
         List<String> adminCompanyIds = adminUser.getCompanyWechatIds();
         //1.组装查询条件
-        zfireParam = FieldUtils.supplyParam(zfireParam, PolicyOrderVO.class,adminUser);
+        zfireParam = FieldUtils.supplyParam(zfireParam, PolicyOrderVO.class, adminUser);
 
-        IPage<PolicyOrderVO> policyOrderVOIPage = policyCMapper.listPolicyOrder(page, zfireParam,adminCompanyIds);
+        IPage<PolicyOrderVO> policyOrderVOIPage = policyCMapper.listPolicyOrder(page, zfireParam, adminCompanyIds);
         return policyOrderVOIPage;
     }
 
@@ -53,9 +66,9 @@ public class PolicyOrderLogic {
 
         List<String> adminCompanyIds = adminUser.getCompanyWechatIds();
         //1.组装查询条件
-        zfireParam = FieldUtils.supplyParam(zfireParam, PolicyOrderEmVO.class,adminUser);
+        zfireParam = FieldUtils.supplyParam(zfireParam, PolicyOrderEmVO.class, adminUser);
 
-        IPage<PolicyOrderEmVO> policyOrderVOIPage = policyCMapper.listEm(page, zfireParam,adminCompanyIds);
+        IPage<PolicyOrderEmVO> policyOrderVOIPage = policyCMapper.listEm(page, zfireParam, adminCompanyIds);
 
         return policyOrderVOIPage;
     }
@@ -68,9 +81,9 @@ public class PolicyOrderLogic {
 
         List<String> adminCompanyIds = adminUser.getCompanyWechatIds();
         //1.组装查询条件
-        zfireParam = FieldUtils.supplyParam(zfireParam, PolicyOrderInVO.class,adminUser);
+        zfireParam = FieldUtils.supplyParam(zfireParam, PolicyOrderInVO.class, adminUser);
 
-        IPage<PolicyOrderInVO> policyOrderVOIPage = policyCMapper.listIn(page, zfireParam,adminCompanyIds);
+        IPage<PolicyOrderInVO> policyOrderVOIPage = policyCMapper.listIn(page, zfireParam, adminCompanyIds);
 
         return policyOrderVOIPage;
     }
@@ -97,7 +110,7 @@ public class PolicyOrderLogic {
                     .eq(PolicyOrder::getPolicyOrderStatus, "DGM").one();
 
 
-            if (policyOrder != null){
+            if (policyOrder != null) {
                 WorkerPolicy workerPolicy = new WorkerPolicy();
                 workerPolicy.setWorkerId(policyOrder.getWorkerNumber());
                 workerPolicy.setType("IN");
@@ -106,8 +119,8 @@ public class PolicyOrderLogic {
                 workerPolicy.setCompany(policyOrder.getBelongCompany());
                 workerPolicy.setPolicyOrder(policyOrder.getPolicyNumber());
                 workerPolicy.setPolicyType("IN");
-                workerPolicy.setStartTime(DateUtil.parse((String) row.get(9),"yyyy-MM-dd"));
-                workerPolicy.setEndTime(DateUtil.endOfDay(DateUtil.parse((String) row.get(10),"yyyy-MM-dd")));
+                workerPolicy.setStartTime(DateUtil.parse((String) row.get(9), "yyyy-MM-dd"));
+                workerPolicy.setEndTime(DateUtil.endOfDay(DateUtil.parse((String) row.get(10), "yyyy-MM-dd")));
                 workerPolicy.setWebsitUserId(policyOrder.getId());
                 workerPolicy.setWebsitId(policyOrder.getWebsitId());
                 workerPolicy.setWebsitName(policyOrder.getWebsitName());
@@ -123,8 +136,8 @@ public class PolicyOrderLogic {
                 workerPolicy.insert();
             }
 
-            policyOrder.setStartTime(DateUtil.parse((String) row.get(9),"yyyy-MM-dd"));
-            policyOrder.setEndTime(DateUtil.endOfDay(DateUtil.parse((String) row.get(10),"yyyy-MM-dd")));
+            policyOrder.setStartTime(DateUtil.parse((String) row.get(9), "yyyy-MM-dd"));
+            policyOrder.setEndTime(DateUtil.endOfDay(DateUtil.parse((String) row.get(10), "yyyy-MM-dd")));
             policyOrder.setClassWebsitId((String) row.get(11));
             policyOrder.setClassWebsitId((String) row.get(12));
 
@@ -140,6 +153,91 @@ public class PolicyOrderLogic {
             policyOrder.updateById();
 
 
+        }
+    }
+
+    public void importEm(List<Object> objects) {
+
+        for (Object o : objects) {
+            List<Object> row = (List<Object>) o;
+
+            AdminWebsit adminWebsit = adminWebsitService.lambdaQuery().eq(AdminWebsit::getWebsitNumber, (String) row.get(1)).one();
+
+            WebsitUser websitUser = websitUserService.lambdaQuery().eq(WebsitUser::getWebsitId, (String) row.get(1))
+                    .eq(WebsitUser::getWorkerNumber, (String) row.get(3)).one();
+
+            PolicyOrder policyOrder = new PolicyOrder();
+            policyOrder.setId("PW"+ IdWorker.getIdStr());
+
+            policyOrder.setPolicyName("雇主险");
+            policyOrder.setPolicyId(policyOrder.getId());
+            policyOrder.setPolicyNumber(policyOrder.getId());
+
+            policyOrder.setWebsitUserId(websitUser.getId());
+
+            policyOrder.setStartTime(DateUtil.parse((String) row.get(6), "yyyy-MM-dd"));
+            policyOrder.setEndTime(DateUtil.parse((String) row.get(7), "yyyy-MM-dd"));
+
+            policyOrder.setIsSend(IsYesNoEnum.NO.getKey());
+            policyOrder.setIsReceipt(IsYesNoEnum.NO.getKey());
+
+
+            policyOrder.setBelongCompany(adminWebsit.getBelongCompany());
+            policyOrder.setBelongCompanyCode(adminWebsit.getBelongCompanyCode());
+
+            policyOrder.setCompanyWechatId(adminWebsit.getCompanyWechatId());
+            policyOrder.setCompanyWechatName(adminWebsit.getCompanyWechatName());
+
+            policyOrder.setWebsitId(adminWebsit.getWebsitId());
+            policyOrder.setWebsitName(adminWebsit.getName());
+
+            policyOrder.setWorkerIdcard((String) row.get(4));
+            policyOrder.setWorkerMobile((String) row.get(5));
+            policyOrder.setWorkerName((String) row.get(2));
+            policyOrder.setWorkerNumber((String) row.get(3));
+
+            policyOrder.setType("EM");
+
+
+
+            if (new Date().after(policyOrder.getStartTime()) && new Date().before(policyOrder.getEndTime()))
+                policyOrder.setPolicyOrderStatus("BZZ");
+            else if (new Date().after(policyOrder.getEndTime()))
+                policyOrder.setPolicyOrderStatus("YSX");
+            else {
+                policyOrder.setPolicyOrderStatus("DSX");
+            }
+
+            policyOrder.insert();
+
+
+            WorkerPolicy workerPolicy = new WorkerPolicy();
+            workerPolicy.setWorkerId(websitUser.getWorkerNumber());
+            workerPolicy.setType("EM");
+            workerPolicy.setOrderId(policyOrder.getId());
+            workerPolicy.setPolicyName(policyOrder.getPolicyName());
+            workerPolicy.setCompany(policyOrder.getBelongCompany());
+            workerPolicy.setPolicyOrder(policyOrder.getPolicyNumber());
+            workerPolicy.setPolicyType("LINE");
+            workerPolicy.setStartTime(DateUtil.parse((String) row.get(9), "yyyy-MM-dd"));
+            workerPolicy.setEndTime(DateUtil.endOfDay(DateUtil.parse((String) row.get(10), "yyyy-MM-dd")));
+            workerPolicy.setWebsitUserId(policyOrder.getId());
+            workerPolicy.setWebsitId(policyOrder.getWebsitId());
+            workerPolicy.setWebsitName(policyOrder.getWebsitName());
+            workerPolicy.setWorkerName(policyOrder.getWorkerName());
+
+            if (new Date().after(workerPolicy.getStartTime()) && new Date().before(workerPolicy.getEndTime()))
+                workerPolicy.setStatus("BZZ");
+            else if (new Date().after(policyOrder.getEndTime()))
+                workerPolicy.setStatus("YSX");
+            else {
+                workerPolicy.setStatus("DSX");
+            }
+            workerPolicy.insert();
+
+
+
+
 
         }
     }