|
|
@@ -1,64 +1,46 @@
|
|
|
package com.ydtech.modules.esm.controller;
|
|
|
|
|
|
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
-import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
-import com.ydtech.constants.RedisConstant;
|
|
|
import com.ydtech.core.page.BaseController;
|
|
|
import com.ydtech.core.page.HttpResult;
|
|
|
import com.ydtech.core.page.PageRequest;
|
|
|
import com.ydtech.core.page.PageResult;
|
|
|
-import com.ydtech.exception.SystemException;
|
|
|
-import com.ydtech.modules.admin.model.SysUser;
|
|
|
-import com.ydtech.modules.admin.service.SysDeptService;
|
|
|
import com.ydtech.modules.esm.model.*;
|
|
|
import com.ydtech.modules.esm.service.*;
|
|
|
-import com.ydtech.modules.esm.vo.EsmInsAttributionTemplateVo;
|
|
|
-import com.ydtech.modules.esm.vo.EsmInsAttributionVo;
|
|
|
-import com.ydtech.modules.esm.vo.req.EsmInsAttributionAuthorizeReq;
|
|
|
+import com.ydtech.modules.esm.model.vo.EsmInsAttributionVo;
|
|
|
+import com.ydtech.modules.esm.model.vo.req.EsmInsAttributionAuthorizeReq;
|
|
|
import com.ydtech.modules.order.entity.vo.zm.ZmAscriptionResponse;
|
|
|
import com.ydtech.modules.order.entity.vo.zm.ZmAscriptionVo;
|
|
|
import com.ydtech.modules.order.service.ZhongMeiOrderService;
|
|
|
-import com.ydtech.security.JwtUserDetails;
|
|
|
-import com.ydtech.security.utils.SecurityUtils;
|
|
|
-import com.ydtech.utils.JsonUtils;
|
|
|
-import com.ydtech.utils.RedisUtils;
|
|
|
import com.ydtech.utils.StringUtils;
|
|
|
import io.swagger.annotations.Api;
|
|
|
import io.swagger.annotations.ApiImplicitParam;
|
|
|
import io.swagger.annotations.ApiImplicitParams;
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
-import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.security.core.Authentication;
|
|
|
-import org.springframework.security.core.context.SecurityContext;
|
|
|
-import org.springframework.security.core.context.SecurityContextHolder;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
-import java.sql.SQLException;
|
|
|
-import java.sql.SQLIntegrityConstraintViolationException;
|
|
|
import java.util.ArrayList;
|
|
|
-import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
|
|
|
@Api(tags = "归属信息")
|
|
|
@RestController
|
|
|
-@RequestMapping("esm/attribution")
|
|
|
+@RequestMapping("/esm/attribution")
|
|
|
public class EsmInsAttributionController extends BaseController {
|
|
|
|
|
|
@Autowired
|
|
|
EsmInsAttributionService esmInsAttributionService;
|
|
|
+
|
|
|
@Autowired
|
|
|
EsmInsAttributionDeptService esmInsAttributionDeptService;
|
|
|
+
|
|
|
@Autowired
|
|
|
EsmInsAttributionTemplateService esmInsAttributionTemplateService;
|
|
|
|
|
|
@@ -81,7 +63,7 @@ public class EsmInsAttributionController extends BaseController {
|
|
|
queryWrapper.eq(EsmInsAttributionTemplate::getInsCompanyId, insCompanyId);
|
|
|
EsmInsAttributionTemplate template = esmInsAttributionTemplateService.getOne(queryWrapper);
|
|
|
|
|
|
- if (null == template) return HttpResult.ok("模板不存在,请联系管理员初始化模板");
|
|
|
+// if (null == template) return HttpResult.ok("模板不存在,请联系管理员初始化模板");
|
|
|
|
|
|
return HttpResult.ok(template);
|
|
|
|
|
|
@@ -93,28 +75,22 @@ public class EsmInsAttributionController extends BaseController {
|
|
|
// public HttpResult gainAllowQuoteList() {
|
|
|
//
|
|
|
// String str = RedisUtils.get(RedisConstant.INS_COMPANY_ALLOW_QUOTE);
|
|
|
-// if(StringUtils.isNotEmpty(str)){
|
|
|
+// if (StringUtils.isNotEmpty(str)) {
|
|
|
// LambdaQueryWrapper<EsmInsAttribution> lqw = new LambdaQueryWrapper();
|
|
|
-// lqw.eq(EsmInsAttribution::getOpenQuote,1);
|
|
|
+// lqw.eq(EsmInsAttribution::getOpenQuote, 1);
|
|
|
// List<EsmInsAttribution> openQuoteList = esmInsAttributionService.list(lqw);
|
|
|
-// RedisUtils.set(RedisConstant.INS_COMPANY_ALLOW_QUOTE , JsonUtils.toJson(openQuoteList));
|
|
|
+// RedisUtils.set(RedisConstant.INS_COMPANY_ALLOW_QUOTE, JsonUtils.toJson(openQuoteList));
|
|
|
// }
|
|
|
-//
|
|
|
-// List<EsmInsAttribution> attrList = JsonUtils.toObjectList(str,EsmInsAttribution.class);
|
|
|
-//
|
|
|
-//
|
|
|
-//
|
|
|
+// List<EsmInsAttribution> attrList = JsonUtils.toObjectList(str, EsmInsAttribution.class);
|
|
|
//
|
|
|
//// LambdaQueryWrapper<EsmInsAttribution> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
//// queryWrapper.eq(EsmInsAttribution::getOpenQuote, "1");
|
|
|
//// List<EsmInsAttribution> attrList = esmInsAttributionService.list(queryWrapper);
|
|
|
//
|
|
|
// return HttpResult.ok(attrList);
|
|
|
-//
|
|
|
// }
|
|
|
|
|
|
|
|
|
-
|
|
|
/**
|
|
|
* @author: lig
|
|
|
* @date: 2022年10月26日 0026
|
|
|
@@ -124,7 +100,8 @@ public class EsmInsAttributionController extends BaseController {
|
|
|
@Transactional
|
|
|
public HttpResult save(@RequestBody EsmInsAttribution eia, HttpServletRequest request) {
|
|
|
|
|
|
- long i = esmInsAttributionService.count(new LambdaQueryWrapper<EsmInsAttribution>().eq(EsmInsAttribution::getUsername, eia.getUsername()));
|
|
|
+ long i = esmInsAttributionService.count(new LambdaQueryWrapper<EsmInsAttribution>()
|
|
|
+ .eq(EsmInsAttribution::getUsername, eia.getUsername()));
|
|
|
if (StringUtils.isEmpty(eia.getId()) && i > 0) return HttpResult.ok("保险公司账号不可重复!");
|
|
|
if (StringUtils.isNotEmpty(eia.getId()) && i > 1) return HttpResult.ok("保险公司账号不可重复!");
|
|
|
|
|
|
@@ -135,17 +112,15 @@ public class EsmInsAttributionController extends BaseController {
|
|
|
String aValue = "{}";
|
|
|
|
|
|
//中煤
|
|
|
- if(StringUtils.isNotEmpty(eia.getInsCompanyId()) && eia.getInsCompanyId().equals("000019")){
|
|
|
+ if (StringUtils.isNotEmpty(eia.getInsCompanyId()) && eia.getInsCompanyId().equals("000019")) {
|
|
|
ZmAscriptionVo zmVo = EsmInsAttribution.gainZmAscriptionVo(eia);
|
|
|
ZmAscriptionResponse zmResponse = zhongMeiOrderService.ascription(zmVo);
|
|
|
- if(null == zmResponse)return HttpResult.ok("归属保存失败,请检查参数是否正确!");
|
|
|
+ if (null == zmResponse) return HttpResult.ok("归属保存失败,请检查参数是否正确!");
|
|
|
aValue = JSONObject.toJSONString(zmResponse);
|
|
|
- }else{
|
|
|
- return HttpResult.ok("未开通配置此保险公司保险代理信息!");
|
|
|
}
|
|
|
|
|
|
eia.setValue(aValue);
|
|
|
- if(StringUtils.isNullOrEmpty(eia.getInsCompanyName())){
|
|
|
+ if (StringUtils.isNullOrEmpty(eia.getInsCompanyName())) {
|
|
|
//保险公司
|
|
|
EsmInsCompany insCompany = esmInsCompanyService.getById(eia.getInsCompanyId());
|
|
|
eia.setInsCompanyName(insCompany.getName());
|
|
|
@@ -167,7 +142,7 @@ public class EsmInsAttributionController extends BaseController {
|
|
|
|
|
|
@ApiOperation(value = "获取用户归属 分页")
|
|
|
@GetMapping(value = "/findPage")
|
|
|
- public HttpResult findPage(PageRequest pageRequest,HttpServletRequest request) {
|
|
|
+ public HttpResult findPage(PageRequest pageRequest, HttpServletRequest request) {
|
|
|
|
|
|
String userId = getUserId(request);
|
|
|
// int pageNum = pageRequest.getPageNum();
|
|
|
@@ -175,11 +150,11 @@ public class EsmInsAttributionController extends BaseController {
|
|
|
String insCompanyId = pageRequest.getColumnFilterValue(pageRequest, "ins_company_id"); // 保险公司ID
|
|
|
|
|
|
LambdaQueryWrapper<EsmInsAttribution> lqw = new LambdaQueryWrapper<>();
|
|
|
- lqw.eq(StringUtils.isNotEmpty(insCompanyId),EsmInsAttribution::getInsCompanyId, insCompanyId);
|
|
|
- lqw.eq(EsmInsAttribution::getUserId,userId);
|
|
|
+ lqw.eq(StringUtils.isNotEmpty(insCompanyId), EsmInsAttribution::getInsCompanyId, insCompanyId);
|
|
|
+ lqw.eq(EsmInsAttribution::getUserId, userId);
|
|
|
Page p = PageRequest.buildPageRequest(pageRequest);
|
|
|
|
|
|
- IPage<EsmInsAttribution> pResult = esmInsAttributionService.page(p,lqw);
|
|
|
+ IPage<EsmInsAttribution> pResult = esmInsAttributionService.page(p, lqw);
|
|
|
|
|
|
return HttpResult.ok(PageResult.buildPageResult(pResult));
|
|
|
|
|
|
@@ -207,19 +182,20 @@ public class EsmInsAttributionController extends BaseController {
|
|
|
return HttpResult.ok(esmInsAttributionService.removeById(id));
|
|
|
|
|
|
}
|
|
|
+
|
|
|
@ApiOperation(value = "归属授权")
|
|
|
@PostMapping(value = "/authorize")
|
|
|
// @ApiImplicitParam(name = "deptIds", value = "部门ID集", required = true, paramType = "query", dataType = "String")
|
|
|
public HttpResult authorize(@RequestBody EsmInsAttributionAuthorizeReq req) {
|
|
|
|
|
|
- LambdaUpdateWrapper<EsmInsAttributionDept> luw = new LambdaUpdateWrapper();
|
|
|
- luw.eq(EsmInsAttributionDept::getAttributionId,req.getAttributionId());
|
|
|
+ LambdaUpdateWrapper<EsmInsAttributionDept> luw = new LambdaUpdateWrapper<>();
|
|
|
+ luw.eq(EsmInsAttributionDept::getAttributionId, req.getAttributionId());
|
|
|
esmInsAttributionDeptService.remove(luw);
|
|
|
|
|
|
|
|
|
- if(null != req.getDeptIds() && req.getDeptIds().size() > 0){
|
|
|
+ if (null != req.getDeptIds() && !req.getDeptIds().isEmpty()) {
|
|
|
List<EsmInsAttributionDept> eiadList = new ArrayList<>();
|
|
|
- req.getDeptIds().stream().forEach(a ->{
|
|
|
+ req.getDeptIds().stream().forEach(a -> {
|
|
|
EsmInsAttributionDept eiad = new EsmInsAttributionDept();
|
|
|
eiad.setAttributionId(Long.valueOf(req.getAttributionId()));
|
|
|
eiad.setInsCompanyId(req.getInsCompanyId());
|