Parcourir la source

add 增加业务模块

fengxiaolei il y a 2 ans
Parent
commit
83dbc4d20c
15 fichiers modifiés avec 1194 ajouts et 0 suppressions
  1. 28 0
      product-center-manage-business/pom.xml
  2. 127 0
      product-center-manage-business/src/main/java/com/product/center/manage/controller/policysynconf/CenterPolicySynConfController.java
  3. 127 0
      product-center-manage-business/src/main/java/com/product/center/manage/controller/policysynconf/CenterPolicySynLogController.java
  4. 123 0
      product-center-manage-business/src/main/java/com/product/center/manage/domain/CenterPolicySynConf.java
  5. 122 0
      product-center-manage-business/src/main/java/com/product/center/manage/domain/CenterPolicySynLog.java
  6. 64 0
      product-center-manage-business/src/main/java/com/product/center/manage/mapper/CenterPolicySynConfMapper.java
  7. 64 0
      product-center-manage-business/src/main/java/com/product/center/manage/mapper/CenterPolicySynLogMapper.java
  8. 62 0
      product-center-manage-business/src/main/java/com/product/center/manage/service/ICenterPolicySynConfService.java
  9. 62 0
      product-center-manage-business/src/main/java/com/product/center/manage/service/ICenterPolicySynLogService.java
  10. 14 0
      product-center-manage-business/src/main/java/com/product/center/manage/service/PolicySynService.java
  11. 96 0
      product-center-manage-business/src/main/java/com/product/center/manage/service/impl/CenterPolicySynConfServiceImpl.java
  12. 96 0
      product-center-manage-business/src/main/java/com/product/center/manage/service/impl/CenterPolicySynLogServiceImpl.java
  13. 33 0
      product-center-manage-business/src/main/java/com/product/center/manage/service/impl/PolicySynServiceImpl.java
  14. 90 0
      product-center-manage-business/src/main/resources/mapper/CenterPolicySynConfMapper.xml
  15. 86 0
      product-center-manage-business/src/main/resources/mapper/CenterPolicySynLogMapper.xml

+ 28 - 0
product-center-manage-business/pom.xml

@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <parent>
+        <groupId>com.product.center.manage</groupId>
+        <artifactId>product-center-manage</artifactId>
+        <version>4.7.5</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>product-center-manage-business</artifactId>
+
+    <description>
+        业务模块
+    </description>
+
+    <dependencies>
+
+        <!-- 通用工具-->
+        <dependency>
+            <groupId>com.product.center.manage</groupId>
+            <artifactId>product-center-manage-common</artifactId>
+        </dependency>
+
+    </dependencies>
+
+</project>

+ 127 - 0
product-center-manage-business/src/main/java/com/product/center/manage/controller/policysynconf/CenterPolicySynConfController.java

@@ -0,0 +1,127 @@
+package com.product.center.manage.controller.policysynconf;
+
+import java.util.List;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.ModelMap;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import com.product.center.manage.common.annotation.Log;
+import com.product.center.manage.common.enums.BusinessType;
+import com.product.center.manage.system.domain.CenterPolicySynConf;
+import com.product.center.manage.system.service.ICenterPolicySynConfService;
+import com.product.center.manage.common.core.controller.BaseController;
+import com.product.center.manage.common.core.domain.AjaxResult;
+import com.product.center.manage.common.utils.poi.ExcelUtil;
+import com.product.center.manage.common.core.page.TableDataInfo;
+
+/**
+ * 【请填写功能名称】Controller
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+@Controller
+@RequestMapping("/system/conf")
+public class CenterPolicySynConfController extends BaseController
+{
+    private String prefix = "system/conf";
+
+    @Autowired
+    private ICenterPolicySynConfService centerPolicySynConfService;
+
+    @RequiresPermissions("system:conf:view")
+    @GetMapping()
+    public String conf()
+    {
+        return prefix + "/conf";
+    }
+
+    /**
+     * 查询【请填写功能名称】列表
+     */
+    @RequiresPermissions("system:conf:list")
+    @PostMapping("/list")
+    @ResponseBody
+    public TableDataInfo list(CenterPolicySynConf centerPolicySynConf)
+    {
+        startPage();
+        List<CenterPolicySynConf> list = centerPolicySynConfService.selectCenterPolicySynConfList(centerPolicySynConf);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出【请填写功能名称】列表
+     */
+    @RequiresPermissions("system:conf:export")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    @ResponseBody
+    public AjaxResult export(CenterPolicySynConf centerPolicySynConf)
+    {
+        List<CenterPolicySynConf> list = centerPolicySynConfService.selectCenterPolicySynConfList(centerPolicySynConf);
+        ExcelUtil<CenterPolicySynConf> util = new ExcelUtil<CenterPolicySynConf>(CenterPolicySynConf.class);
+        return util.exportExcel(list, "【请填写功能名称】数据");
+    }
+
+    /**
+     * 新增【请填写功能名称】
+     */
+    @GetMapping("/add")
+    public String add()
+    {
+        return prefix + "/add";
+    }
+
+    /**
+     * 新增保存【请填写功能名称】
+     */
+    @RequiresPermissions("system:conf:add")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.INSERT)
+    @PostMapping("/add")
+    @ResponseBody
+    public AjaxResult addSave(CenterPolicySynConf centerPolicySynConf)
+    {
+        return toAjax(centerPolicySynConfService.insertCenterPolicySynConf(centerPolicySynConf));
+    }
+
+    /**
+     * 修改【请填写功能名称】
+     */
+    @RequiresPermissions("system:conf:edit")
+    @GetMapping("/edit/{id}")
+    public String edit(@PathVariable("id") Long id, ModelMap mmap)
+    {
+        CenterPolicySynConf centerPolicySynConf = centerPolicySynConfService.selectCenterPolicySynConfById(id);
+        mmap.put("centerPolicySynConf", centerPolicySynConf);
+        return prefix + "/edit";
+    }
+
+    /**
+     * 修改保存【请填写功能名称】
+     */
+    @RequiresPermissions("system:conf:edit")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.UPDATE)
+    @PostMapping("/edit")
+    @ResponseBody
+    public AjaxResult editSave(CenterPolicySynConf centerPolicySynConf)
+    {
+        return toAjax(centerPolicySynConfService.updateCenterPolicySynConf(centerPolicySynConf));
+    }
+
+    /**
+     * 删除【请填写功能名称】
+     */
+    @RequiresPermissions("system:conf:remove")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.DELETE)
+    @PostMapping( "/remove")
+    @ResponseBody
+    public AjaxResult remove(String ids)
+    {
+        return toAjax(centerPolicySynConfService.deleteCenterPolicySynConfByIds(ids));
+    }
+}

+ 127 - 0
product-center-manage-business/src/main/java/com/product/center/manage/controller/policysynconf/CenterPolicySynLogController.java

@@ -0,0 +1,127 @@
+package com.product.center.manage.controller.policysynconf;
+
+import java.util.List;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.ModelMap;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import com.product.center.manage.common.annotation.Log;
+import com.product.center.manage.common.enums.BusinessType;
+import com.product.center.manage.system.domain.CenterPolicySynLog;
+import com.product.center.manage.system.service.ICenterPolicySynLogService;
+import com.product.center.manage.common.core.controller.BaseController;
+import com.product.center.manage.common.core.domain.AjaxResult;
+import com.product.center.manage.common.utils.poi.ExcelUtil;
+import com.product.center.manage.common.core.page.TableDataInfo;
+
+/**
+ * 【请填写功能名称】Controller
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+@Controller
+@RequestMapping("/system/log")
+public class CenterPolicySynLogController extends BaseController
+{
+    private String prefix = "system/log";
+
+    @Autowired
+    private ICenterPolicySynLogService centerPolicySynLogService;
+
+    @RequiresPermissions("system:log:view")
+    @GetMapping()
+    public String log()
+    {
+        return prefix + "/log";
+    }
+
+    /**
+     * 查询【请填写功能名称】列表
+     */
+    @RequiresPermissions("system:log:list")
+    @PostMapping("/list")
+    @ResponseBody
+    public TableDataInfo list(CenterPolicySynLog centerPolicySynLog)
+    {
+        startPage();
+        List<CenterPolicySynLog> list = centerPolicySynLogService.selectCenterPolicySynLogList(centerPolicySynLog);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出【请填写功能名称】列表
+     */
+    @RequiresPermissions("system:log:export")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    @ResponseBody
+    public AjaxResult export(CenterPolicySynLog centerPolicySynLog)
+    {
+        List<CenterPolicySynLog> list = centerPolicySynLogService.selectCenterPolicySynLogList(centerPolicySynLog);
+        ExcelUtil<CenterPolicySynLog> util = new ExcelUtil<CenterPolicySynLog>(CenterPolicySynLog.class);
+        return util.exportExcel(list, "【请填写功能名称】数据");
+    }
+
+    /**
+     * 新增【请填写功能名称】
+     */
+    @GetMapping("/add")
+    public String add()
+    {
+        return prefix + "/add";
+    }
+
+    /**
+     * 新增保存【请填写功能名称】
+     */
+    @RequiresPermissions("system:log:add")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.INSERT)
+    @PostMapping("/add")
+    @ResponseBody
+    public AjaxResult addSave(CenterPolicySynLog centerPolicySynLog)
+    {
+        return toAjax(centerPolicySynLogService.insertCenterPolicySynLog(centerPolicySynLog));
+    }
+
+    /**
+     * 修改【请填写功能名称】
+     */
+    @RequiresPermissions("system:log:edit")
+    @GetMapping("/edit/{id}")
+    public String edit(@PathVariable("id") Long id, ModelMap mmap)
+    {
+        CenterPolicySynLog centerPolicySynLog = centerPolicySynLogService.selectCenterPolicySynLogById(id);
+        mmap.put("centerPolicySynLog", centerPolicySynLog);
+        return prefix + "/edit";
+    }
+
+    /**
+     * 修改保存【请填写功能名称】
+     */
+    @RequiresPermissions("system:log:edit")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.UPDATE)
+    @PostMapping("/edit")
+    @ResponseBody
+    public AjaxResult editSave(CenterPolicySynLog centerPolicySynLog)
+    {
+        return toAjax(centerPolicySynLogService.updateCenterPolicySynLog(centerPolicySynLog));
+    }
+
+    /**
+     * 删除【请填写功能名称】
+     */
+    @RequiresPermissions("system:log:remove")
+    @Log(title = "【请填写功能名称】", businessType = BusinessType.DELETE)
+    @PostMapping( "/remove")
+    @ResponseBody
+    public AjaxResult remove(String ids)
+    {
+        return toAjax(centerPolicySynLogService.deleteCenterPolicySynLogByIds(ids));
+    }
+}

+ 123 - 0
product-center-manage-business/src/main/java/com/product/center/manage/domain/CenterPolicySynConf.java

@@ -0,0 +1,123 @@
+package com.product.center.manage.domain;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import com.product.center.manage.common.annotation.Excel;
+import com.product.center.manage.common.core.domain.BaseEntity;
+
+/**
+ * 【请填写功能名称】对象 center_policy_syn_conf
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+public class CenterPolicySynConf extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** 主键 */
+    private Long id;
+
+    /** 渠道 */
+    @Excel(name = "渠道")
+    private String channel;
+
+    /** 渠道同步url */
+    @Excel(name = "渠道同步url")
+    private String uri;
+
+    /** 配置别名称 */
+    @Excel(name = "配置别名称")
+    private String aliasName;
+
+    /** 上次同步保单表时间 */
+    @Excel(name = "上次同步保单表时间")
+    private String lastUpdateDate;
+
+    /** aes加密key */
+    @Excel(name = "aes加密key")
+    private String aesKey;
+
+    /** 0 关闭 1 开启 */
+    @Excel(name = "0 关闭 1 开启")
+    private Long isOpen;
+
+    public void setId(Long id)
+    {
+        this.id = id;
+    }
+
+    public Long getId()
+    {
+        return id;
+    }
+    public void setChannel(String channel)
+    {
+        this.channel = channel;
+    }
+
+    public String getChannel()
+    {
+        return channel;
+    }
+    public void setUri(String uri)
+    {
+        this.uri = uri;
+    }
+
+    public String getUri()
+    {
+        return uri;
+    }
+    public void setAliasName(String aliasName)
+    {
+        this.aliasName = aliasName;
+    }
+
+    public String getAliasName()
+    {
+        return aliasName;
+    }
+    public void setLastUpdateDate(String lastUpdateDate)
+    {
+        this.lastUpdateDate = lastUpdateDate;
+    }
+
+    public String getLastUpdateDate()
+    {
+        return lastUpdateDate;
+    }
+    public void setAesKey(String aesKey)
+    {
+        this.aesKey = aesKey;
+    }
+
+    public String getAesKey()
+    {
+        return aesKey;
+    }
+    public void setIsOpen(Long isOpen)
+    {
+        this.isOpen = isOpen;
+    }
+
+    public Long getIsOpen()
+    {
+        return isOpen;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+            .append("id", getId())
+            .append("channel", getChannel())
+            .append("uri", getUri())
+            .append("aliasName", getAliasName())
+            .append("lastUpdateDate", getLastUpdateDate())
+            .append("aesKey", getAesKey())
+            .append("remark", getRemark())
+            .append("isOpen", getIsOpen())
+            .append("createTime", getCreateTime())
+            .toString();
+    }
+}

+ 122 - 0
product-center-manage-business/src/main/java/com/product/center/manage/domain/CenterPolicySynLog.java

@@ -0,0 +1,122 @@
+package com.product.center.manage.domain;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import com.product.center.manage.common.annotation.Excel;
+import com.product.center.manage.common.core.domain.BaseEntity;
+
+/**
+ * 【请填写功能名称】对象 center_policy_syn_log
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+public class CenterPolicySynLog extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** 主键 */
+    private Long id;
+
+    /** 保单同步配置表主键 */
+    @Excel(name = "保单同步配置表主键")
+    private Long confId;
+
+    /** 保单订单号 */
+    @Excel(name = "保单订单号")
+    private String orderNo;
+
+    /** 渠道 */
+    @Excel(name = "渠道")
+    private String channel;
+
+    /** 同步状态 0 成功 1 失败 */
+    @Excel(name = "同步状态 0 成功 1 失败")
+    private Long synState;
+
+    /** 同步失败处理状态 */
+    @Excel(name = "同步失败处理状态")
+    private Long synFailHanState;
+
+    /** 接口返回报文 */
+    @Excel(name = "接口返回报文")
+    private String resMsg;
+
+    public void setId(Long id)
+    {
+        this.id = id;
+    }
+
+    public Long getId()
+    {
+        return id;
+    }
+    public void setConfId(Long confId)
+    {
+        this.confId = confId;
+    }
+
+    public Long getConfId()
+    {
+        return confId;
+    }
+    public void setOrderNo(String orderNo)
+    {
+        this.orderNo = orderNo;
+    }
+
+    public String getOrderNo()
+    {
+        return orderNo;
+    }
+    public void setChannel(String channel)
+    {
+        this.channel = channel;
+    }
+
+    public String getChannel()
+    {
+        return channel;
+    }
+    public void setSynState(Long synState)
+    {
+        this.synState = synState;
+    }
+
+    public Long getSynState()
+    {
+        return synState;
+    }
+    public void setSynFailHanState(Long synFailHanState)
+    {
+        this.synFailHanState = synFailHanState;
+    }
+
+    public Long getSynFailHanState()
+    {
+        return synFailHanState;
+    }
+    public void setResMsg(String resMsg)
+    {
+        this.resMsg = resMsg;
+    }
+
+    public String getResMsg()
+    {
+        return resMsg;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+            .append("id", getId())
+            .append("confId", getConfId())
+            .append("orderNo", getOrderNo())
+            .append("channel", getChannel())
+            .append("synState", getSynState())
+            .append("synFailHanState", getSynFailHanState())
+            .append("resMsg", getResMsg())
+            .append("createTime", getCreateTime())
+            .toString();
+    }
+}

+ 64 - 0
product-center-manage-business/src/main/java/com/product/center/manage/mapper/CenterPolicySynConfMapper.java

@@ -0,0 +1,64 @@
+package com.product.center.manage.mapper;
+
+import java.util.List;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.product.center.manage.domain.CenterPolicySynConf;
+import org.springframework.stereotype.Repository;
+
+/**
+ * 【请填写功能名称】Mapper接口
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+@Repository
+public interface CenterPolicySynConfMapper extends BaseMapper<CenterPolicySynConf> {
+    /**
+     * 查询【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 【请填写功能名称】
+     */
+    public CenterPolicySynConf selectCenterPolicySynConfById(Long id);
+
+    /**
+     * 查询【请填写功能名称】列表
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 【请填写功能名称】集合
+     */
+    public List<CenterPolicySynConf> selectCenterPolicySynConfList(CenterPolicySynConf centerPolicySynConf);
+
+    /**
+     * 新增【请填写功能名称】
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 结果
+     */
+    public int insertCenterPolicySynConf(CenterPolicySynConf centerPolicySynConf);
+
+    /**
+     * 修改【请填写功能名称】
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 结果
+     */
+    public int updateCenterPolicySynConf(CenterPolicySynConf centerPolicySynConf);
+
+    /**
+     * 删除【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 结果
+     */
+    public int deleteCenterPolicySynConfById(Long id);
+
+    /**
+     * 批量删除【请填写功能名称】
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteCenterPolicySynConfByIds(String[] ids);
+}

+ 64 - 0
product-center-manage-business/src/main/java/com/product/center/manage/mapper/CenterPolicySynLogMapper.java

@@ -0,0 +1,64 @@
+package com.product.center.manage.mapper;
+
+import java.util.List;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.product.center.manage.domain.CenterPolicySynLog;
+import org.springframework.stereotype.Repository;
+
+/**
+ * 【请填写功能名称】Mapper接口
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+@Repository
+public interface CenterPolicySynLogMapper extends BaseMapper<CenterPolicySynLog> {
+    /**
+     * 查询【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 【请填写功能名称】
+     */
+    public CenterPolicySynLog selectCenterPolicySynLogById(Long id);
+
+    /**
+     * 查询【请填写功能名称】列表
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 【请填写功能名称】集合
+     */
+    public List<CenterPolicySynLog> selectCenterPolicySynLogList(CenterPolicySynLog centerPolicySynLog);
+
+    /**
+     * 新增【请填写功能名称】
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 结果
+     */
+    public int insertCenterPolicySynLog(CenterPolicySynLog centerPolicySynLog);
+
+    /**
+     * 修改【请填写功能名称】
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 结果
+     */
+    public int updateCenterPolicySynLog(CenterPolicySynLog centerPolicySynLog);
+
+    /**
+     * 删除【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 结果
+     */
+    public int deleteCenterPolicySynLogById(Long id);
+
+    /**
+     * 批量删除【请填写功能名称】
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteCenterPolicySynLogByIds(String[] ids);
+}

+ 62 - 0
product-center-manage-business/src/main/java/com/product/center/manage/service/ICenterPolicySynConfService.java

@@ -0,0 +1,62 @@
+package com.product.center.manage.service;
+
+import com.product.center.manage.domain.CenterPolicySynConf;
+
+import java.util.List;
+
+/**
+ * 【请填写功能名称】Service接口
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+public interface ICenterPolicySynConfService
+{
+    /**
+     * 查询【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 【请填写功能名称】
+     */
+    public CenterPolicySynConf selectCenterPolicySynConfById(Long id);
+
+    /**
+     * 查询【请填写功能名称】列表
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 【请填写功能名称】集合
+     */
+    public List<CenterPolicySynConf> selectCenterPolicySynConfList(CenterPolicySynConf centerPolicySynConf);
+
+    /**
+     * 新增【请填写功能名称】
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 结果
+     */
+    public int insertCenterPolicySynConf(CenterPolicySynConf centerPolicySynConf);
+
+    /**
+     * 修改【请填写功能名称】
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 结果
+     */
+    public int updateCenterPolicySynConf(CenterPolicySynConf centerPolicySynConf);
+
+    /**
+     * 批量删除【请填写功能名称】
+     *
+     * @param ids 需要删除的【请填写功能名称】主键集合
+     * @return 结果
+     */
+    public int deleteCenterPolicySynConfByIds(String ids);
+
+    /**
+     * 删除【请填写功能名称】信息
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 结果
+     */
+    public int deleteCenterPolicySynConfById(Long id);
+}

+ 62 - 0
product-center-manage-business/src/main/java/com/product/center/manage/service/ICenterPolicySynLogService.java

@@ -0,0 +1,62 @@
+package com.product.center.manage.service;
+
+import com.product.center.manage.domain.CenterPolicySynLog;
+
+import java.util.List;
+
+/**
+ * 【请填写功能名称】Service接口
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+public interface ICenterPolicySynLogService
+{
+    /**
+     * 查询【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 【请填写功能名称】
+     */
+    public CenterPolicySynLog selectCenterPolicySynLogById(Long id);
+
+    /**
+     * 查询【请填写功能名称】列表
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 【请填写功能名称】集合
+     */
+    public List<CenterPolicySynLog> selectCenterPolicySynLogList(CenterPolicySynLog centerPolicySynLog);
+
+    /**
+     * 新增【请填写功能名称】
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 结果
+     */
+    public int insertCenterPolicySynLog(CenterPolicySynLog centerPolicySynLog);
+
+    /**
+     * 修改【请填写功能名称】
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 结果
+     */
+    public int updateCenterPolicySynLog(CenterPolicySynLog centerPolicySynLog);
+
+    /**
+     * 批量删除【请填写功能名称】
+     *
+     * @param ids 需要删除的【请填写功能名称】主键集合
+     * @return 结果
+     */
+    public int deleteCenterPolicySynLogByIds(String ids);
+
+    /**
+     * 删除【请填写功能名称】信息
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 结果
+     */
+    public int deleteCenterPolicySynLogById(Long id);
+}

+ 14 - 0
product-center-manage-business/src/main/java/com/product/center/manage/service/PolicySynService.java

@@ -0,0 +1,14 @@
+package com.product.center.manage.service;
+
+/**
+ * @author :fxl
+ * @date :Created in 2022/9/22 10:45
+ * @description:
+ */
+public interface PolicySynService {
+
+    /**
+     * 开始同步保单数据
+     */
+    void startPolicySyn();
+}

+ 96 - 0
product-center-manage-business/src/main/java/com/product/center/manage/service/impl/CenterPolicySynConfServiceImpl.java

@@ -0,0 +1,96 @@
+package com.product.center.manage.service.impl;
+
+import java.util.List;
+import com.product.center.manage.common.utils.DateUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.product.center.manage.system.mapper.CenterPolicySynConfMapper;
+import com.product.center.manage.system.domain.CenterPolicySynConf;
+import com.product.center.manage.system.service.ICenterPolicySynConfService;
+import com.product.center.manage.common.core.text.Convert;
+
+/**
+ * 【请填写功能名称】Service业务层处理
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+@Service
+public class CenterPolicySynConfServiceImpl implements ICenterPolicySynConfService
+{
+    @Autowired
+    private CenterPolicySynConfMapper centerPolicySynConfMapper;
+
+    /**
+     * 查询【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 【请填写功能名称】
+     */
+    @Override
+    public CenterPolicySynConf selectCenterPolicySynConfById(Long id)
+    {
+        return centerPolicySynConfMapper.selectCenterPolicySynConfById(id);
+    }
+
+    /**
+     * 查询【请填写功能名称】列表
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 【请填写功能名称】
+     */
+    @Override
+    public List<CenterPolicySynConf> selectCenterPolicySynConfList(CenterPolicySynConf centerPolicySynConf)
+    {
+        return centerPolicySynConfMapper.selectCenterPolicySynConfList(centerPolicySynConf);
+    }
+
+    /**
+     * 新增【请填写功能名称】
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 结果
+     */
+    @Override
+    public int insertCenterPolicySynConf(CenterPolicySynConf centerPolicySynConf)
+    {
+        centerPolicySynConf.setCreateTime(DateUtils.getNowDate());
+        return centerPolicySynConfMapper.insertCenterPolicySynConf(centerPolicySynConf);
+    }
+
+    /**
+     * 修改【请填写功能名称】
+     *
+     * @param centerPolicySynConf 【请填写功能名称】
+     * @return 结果
+     */
+    @Override
+    public int updateCenterPolicySynConf(CenterPolicySynConf centerPolicySynConf)
+    {
+        return centerPolicySynConfMapper.updateCenterPolicySynConf(centerPolicySynConf);
+    }
+
+    /**
+     * 批量删除【请填写功能名称】
+     *
+     * @param ids 需要删除的【请填写功能名称】主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCenterPolicySynConfByIds(String ids)
+    {
+        return centerPolicySynConfMapper.deleteCenterPolicySynConfByIds(Convert.toStrArray(ids));
+    }
+
+    /**
+     * 删除【请填写功能名称】信息
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCenterPolicySynConfById(Long id)
+    {
+        return centerPolicySynConfMapper.deleteCenterPolicySynConfById(id);
+    }
+}

+ 96 - 0
product-center-manage-business/src/main/java/com/product/center/manage/service/impl/CenterPolicySynLogServiceImpl.java

@@ -0,0 +1,96 @@
+package com.product.center.manage.service.impl;
+
+import java.util.List;
+import com.product.center.manage.common.utils.DateUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.product.center.manage.system.mapper.CenterPolicySynLogMapper;
+import com.product.center.manage.system.domain.CenterPolicySynLog;
+import com.product.center.manage.system.service.ICenterPolicySynLogService;
+import com.product.center.manage.common.core.text.Convert;
+
+/**
+ * 【请填写功能名称】Service业务层处理
+ *
+ * @author ruoyi
+ * @date 2022-09-22
+ */
+@Service
+public class CenterPolicySynLogServiceImpl implements ICenterPolicySynLogService
+{
+    @Autowired
+    private CenterPolicySynLogMapper centerPolicySynLogMapper;
+
+    /**
+     * 查询【请填写功能名称】
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 【请填写功能名称】
+     */
+    @Override
+    public CenterPolicySynLog selectCenterPolicySynLogById(Long id)
+    {
+        return centerPolicySynLogMapper.selectCenterPolicySynLogById(id);
+    }
+
+    /**
+     * 查询【请填写功能名称】列表
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 【请填写功能名称】
+     */
+    @Override
+    public List<CenterPolicySynLog> selectCenterPolicySynLogList(CenterPolicySynLog centerPolicySynLog)
+    {
+        return centerPolicySynLogMapper.selectCenterPolicySynLogList(centerPolicySynLog);
+    }
+
+    /**
+     * 新增【请填写功能名称】
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 结果
+     */
+    @Override
+    public int insertCenterPolicySynLog(CenterPolicySynLog centerPolicySynLog)
+    {
+        centerPolicySynLog.setCreateTime(DateUtils.getNowDate());
+        return centerPolicySynLogMapper.insertCenterPolicySynLog(centerPolicySynLog);
+    }
+
+    /**
+     * 修改【请填写功能名称】
+     *
+     * @param centerPolicySynLog 【请填写功能名称】
+     * @return 结果
+     */
+    @Override
+    public int updateCenterPolicySynLog(CenterPolicySynLog centerPolicySynLog)
+    {
+        return centerPolicySynLogMapper.updateCenterPolicySynLog(centerPolicySynLog);
+    }
+
+    /**
+     * 批量删除【请填写功能名称】
+     *
+     * @param ids 需要删除的【请填写功能名称】主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCenterPolicySynLogByIds(String ids)
+    {
+        return centerPolicySynLogMapper.deleteCenterPolicySynLogByIds(Convert.toStrArray(ids));
+    }
+
+    /**
+     * 删除【请填写功能名称】信息
+     *
+     * @param id 【请填写功能名称】主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCenterPolicySynLogById(Long id)
+    {
+        return centerPolicySynLogMapper.deleteCenterPolicySynLogById(id);
+    }
+}

+ 33 - 0
product-center-manage-business/src/main/java/com/product/center/manage/service/impl/PolicySynServiceImpl.java

@@ -0,0 +1,33 @@
+package com.product.center.manage.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+
+import com.product.center.manage.domain.CenterPolicySynConf;
+import com.product.center.manage.mapper.CenterPolicySynConfMapper;
+import com.product.center.manage.service.PolicySynService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author :fxl
+ * @date :Created in 2022/9/22 10:45
+ * @description:
+ */
+@Repository
+public class PolicySynServiceImpl implements PolicySynService {
+
+    @Autowired
+    private CenterPolicySynConfMapper centerPolicySynConfMapper;
+
+    /**
+     * 开始同步保单数据
+     */
+    @Override
+    public void startPolicySyn() {
+        LambdaQueryWrapper<CenterPolicySynConf> lqw = Wrappers.lambdaQuery();
+        lqw.eq(true,CenterPolicySynConf::getIsOpen,1);
+    }
+
+
+}

+ 90 - 0
product-center-manage-business/src/main/resources/mapper/CenterPolicySynConfMapper.xml

@@ -0,0 +1,90 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.product.center.manage.mapper.CenterPolicySynConfMapper">
+
+    <resultMap type="com.product.center.manage.domain.CenterPolicySynConf" id="CenterPolicySynConfResult">
+        <result property="id"    column="id"    />
+        <result property="channel"    column="channel"    />
+        <result property="uri"    column="uri"    />
+        <result property="aliasName"    column="alias_name"    />
+        <result property="lastUpdateDate"    column="last_update_date"    />
+        <result property="aesKey"    column="aes_key"    />
+        <result property="remark"    column="remark"    />
+        <result property="isOpen"    column="is_open"    />
+        <result property="createTime"    column="create_time"    />
+    </resultMap>
+
+    <sql id="selectCenterPolicySynConfVo">
+        select id, channel, uri, alias_name, last_update_date, aes_key, remark, is_open, create_time from center_policy_syn_conf
+    </sql>
+
+    <select id="selectCenterPolicySynConfList" parameterType="CenterPolicySynConf" resultMap="CenterPolicySynConfResult">
+        <include refid="selectCenterPolicySynConfVo"/>
+        <where>
+            <if test="channel != null  and channel != ''"> and channel = #{channel}</if>
+            <if test="uri != null  and uri != ''"> and uri = #{uri}</if>
+            <if test="aliasName != null  and aliasName != ''"> and alias_name like concat('%', #{aliasName}, '%')</if>
+            <if test="lastUpdateDate != null  and lastUpdateDate != ''"> and last_update_date = #{lastUpdateDate}</if>
+            <if test="aesKey != null  and aesKey != ''"> and aes_key = #{aesKey}</if>
+            <if test="isOpen != null "> and is_open = #{isOpen}</if>
+        </where>
+    </select>
+
+    <select id="selectCenterPolicySynConfById" parameterType="Long" resultMap="CenterPolicySynConfResult">
+        <include refid="selectCenterPolicySynConfVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertCenterPolicySynConf" parameterType="CenterPolicySynConf" useGeneratedKeys="true" keyProperty="id">
+        insert into center_policy_syn_conf
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="channel != null">channel,</if>
+            <if test="uri != null">uri,</if>
+            <if test="aliasName != null">alias_name,</if>
+            <if test="lastUpdateDate != null">last_update_date,</if>
+            <if test="aesKey != null">aes_key,</if>
+            <if test="remark != null">remark,</if>
+            <if test="isOpen != null">is_open,</if>
+            <if test="createTime != null">create_time,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="channel != null">#{channel},</if>
+            <if test="uri != null">#{uri},</if>
+            <if test="aliasName != null">#{aliasName},</if>
+            <if test="lastUpdateDate != null">#{lastUpdateDate},</if>
+            <if test="aesKey != null">#{aesKey},</if>
+            <if test="remark != null">#{remark},</if>
+            <if test="isOpen != null">#{isOpen},</if>
+            <if test="createTime != null">#{createTime},</if>
+         </trim>
+    </insert>
+
+    <update id="updateCenterPolicySynConf" parameterType="CenterPolicySynConf">
+        update center_policy_syn_conf
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="channel != null">channel = #{channel},</if>
+            <if test="uri != null">uri = #{uri},</if>
+            <if test="aliasName != null">alias_name = #{aliasName},</if>
+            <if test="lastUpdateDate != null">last_update_date = #{lastUpdateDate},</if>
+            <if test="aesKey != null">aes_key = #{aesKey},</if>
+            <if test="remark != null">remark = #{remark},</if>
+            <if test="isOpen != null">is_open = #{isOpen},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteCenterPolicySynConfById" parameterType="Long">
+        delete from center_policy_syn_conf where id = #{id}
+    </delete>
+
+    <delete id="deleteCenterPolicySynConfByIds" parameterType="String">
+        delete from center_policy_syn_conf where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+</mapper>

+ 86 - 0
product-center-manage-business/src/main/resources/mapper/CenterPolicySynLogMapper.xml

@@ -0,0 +1,86 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.product.center.manage.mapper.CenterPolicySynLogMapper">
+
+    <resultMap type="com.product.center.manage.domain.CenterPolicySynLog" id="CenterPolicySynLogResult">
+        <result property="id"    column="id"    />
+        <result property="confId"    column="conf_id"    />
+        <result property="orderNo"    column="order_no"    />
+        <result property="channel"    column="channel"    />
+        <result property="synState"    column="syn_state"    />
+        <result property="synFailHanState"    column="syn_fail_han_state"    />
+        <result property="resMsg"    column="res_msg"    />
+        <result property="createTime"    column="create_time"    />
+    </resultMap>
+
+    <sql id="selectCenterPolicySynLogVo">
+        select id, conf_id, order_no, channel, syn_state, syn_fail_han_state, res_msg, create_time from center_policy_syn_log
+    </sql>
+
+    <select id="selectCenterPolicySynLogList" parameterType="CenterPolicySynLog" resultMap="CenterPolicySynLogResult">
+        <include refid="selectCenterPolicySynLogVo"/>
+        <where>
+            <if test="confId != null "> and conf_id = #{confId}</if>
+            <if test="orderNo != null  and orderNo != ''"> and order_no = #{orderNo}</if>
+            <if test="channel != null  and channel != ''"> and channel = #{channel}</if>
+            <if test="synState != null "> and syn_state = #{synState}</if>
+            <if test="synFailHanState != null "> and syn_fail_han_state = #{synFailHanState}</if>
+            <if test="resMsg != null  and resMsg != ''"> and res_msg = #{resMsg}</if>
+        </where>
+    </select>
+
+    <select id="selectCenterPolicySynLogById" parameterType="Long" resultMap="CenterPolicySynLogResult">
+        <include refid="selectCenterPolicySynLogVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertCenterPolicySynLog" parameterType="CenterPolicySynLog" useGeneratedKeys="true" keyProperty="id">
+        insert into center_policy_syn_log
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="confId != null">conf_id,</if>
+            <if test="orderNo != null">order_no,</if>
+            <if test="channel != null">channel,</if>
+            <if test="synState != null">syn_state,</if>
+            <if test="synFailHanState != null">syn_fail_han_state,</if>
+            <if test="resMsg != null">res_msg,</if>
+            <if test="createTime != null">create_time,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="confId != null">#{confId},</if>
+            <if test="orderNo != null">#{orderNo},</if>
+            <if test="channel != null">#{channel},</if>
+            <if test="synState != null">#{synState},</if>
+            <if test="synFailHanState != null">#{synFailHanState},</if>
+            <if test="resMsg != null">#{resMsg},</if>
+            <if test="createTime != null">#{createTime},</if>
+         </trim>
+    </insert>
+
+    <update id="updateCenterPolicySynLog" parameterType="CenterPolicySynLog">
+        update center_policy_syn_log
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="confId != null">conf_id = #{confId},</if>
+            <if test="orderNo != null">order_no = #{orderNo},</if>
+            <if test="channel != null">channel = #{channel},</if>
+            <if test="synState != null">syn_state = #{synState},</if>
+            <if test="synFailHanState != null">syn_fail_han_state = #{synFailHanState},</if>
+            <if test="resMsg != null">res_msg = #{resMsg},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteCenterPolicySynLogById" parameterType="Long">
+        delete from center_policy_syn_log where id = #{id}
+    </delete>
+
+    <delete id="deleteCenterPolicySynLogByIds" parameterType="String">
+        delete from center_policy_syn_log where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+</mapper>