支付模块,依赖处理

happy-boot-module-flexjob/pom.xml

@@ -43,6 +43,11 @@
             <artifactId>happy-boot-module-common</artifactId>
             <version>2.1.0</version>
         </dependency>
+        <dependency>
+            <groupId>org.jeecgframework.boot</groupId>
+            <artifactId>happy-boot-module-pay</artifactId>
+            <version>2.1.0</version>
+        </dependency>
     </dependencies>
 
     <build>

happy-boot-module-pay/pom.xml

@@ -11,5 +11,11 @@
         <version>2.1.0</version>
     </parent>
 
-
+    <dependencies>
+        <dependency>
+            <groupId>org.jeecgframework.boot</groupId>
+            <artifactId>happy-boot-base-common</artifactId>
+            <version>2.1.0</version>
+        </dependency>
+    </dependencies>
 </project>

happy-boot-module-pay/src/main/java/org/jeecg/common/PayDemo.java

@@ -1,17 +1,96 @@
 package org.jeecg.common;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import org.jeecg.common.utils.PayConst;
 import org.jeecg.common.utils.PayRequest;
+import org.jeecg.modules.paymanager.service.IHwPayAccoutService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
 
+import javax.annotation.PostConstruct;
+
+@Component
 public class PayDemo {
+    @Autowired
+    public IHwPayAccoutService hwPayAccoutService;
+
+    private static IHwPayAccoutService re;
+
+    @PostConstruct
+    public void init() {
+        re = hwPayAccoutService;
+    }
 
     public static void main(String[] args) {
+        DCDACCYE();
+//        DCAGPCNV();
+    }
+
+    /**
+     * 账户信息查询
+     */
+    private static void DCDACCYE() {
         // body
         JSONObject obj_body = new JSONObject();
         //funcode接口名称
         String funcode = PayConst.DCDACCYE;
         obj_body.put("ctnkey", "");
-        PayRequest.doRequest(obj_body, funcode);
+        String result = PayRequest.doRequest(obj_body, funcode);
+        JSONObject jsonObject = JSONObject.parseObject(result);
+        JSONObject jsonObject1 = jsonObject.getJSONObject("response");
+        JSONObject jsonObjectHead = jsonObject1.getJSONObject("head");
+        String resultcode = jsonObjectHead.getString("resultcode");
+        //正常响应为SUC0000
+        if ("SUC0000".equals(resultcode)) {
+            JSONObject jsonObjectBody = jsonObject1.getJSONObject("body");
+            JSONArray jsonArray = jsonObjectBody.getJSONArray("actlis");
+            for (int i = 0; i < jsonArray.size(); i++) {
+                JSONObject jsonObject2 = jsonArray.getJSONObject(i);
+                System.out.println("户口号========" + jsonObject2.get("eacnbr"));
+                System.out.println("账号========" + jsonObject2.get("actnbr"));
+                //保存账户信息
+                re.saveAccout(jsonObject2);
+            }
+            System.out.println("head========" + jsonObjectHead.getString("resultcode"));
+            System.out.println("body========" + jsonArray);
+        } else {
+            System.out.println("resultcode========" + jsonObjectHead.getString("resultcode"));
+            System.out.println("resultmsg========" + jsonObjectHead.getString("resultmsg"));
+
+        }
     }
+
+    /**
+     * 移动代发查询协议号
+     */
+    private static void DCAGPCNV() {
+        // body
+        JSONObject obj_body = new JSONObject();
+        //funcode接口名称
+        String funcode = PayConst.DCAGPCNV;
+        obj_body.put("dbtacc", "755915675610802");
+        obj_body.put("ccynbr", "10");
+        String result = PayRequest.doRequest(obj_body, funcode);
+        JSONObject jsonObject = JSONObject.parseObject(result);
+        JSONObject jsonObject1 = jsonObject.getJSONObject("response");
+        JSONObject jsonObjectHead = jsonObject1.getJSONObject("head");
+        String resultcode = jsonObjectHead.getString("resultcode");
+        //正常响应为SUC0000
+        if ("SUC0000".equals(resultcode)) {
+            JSONObject jsonObjectBody = jsonObject1.getJSONObject("body");
+            JSONArray jsonArray = jsonObjectBody.getJSONArray("cnvlist");
+            for (int i = 0; i < jsonArray.size(); i++) {
+                JSONObject jsonObject2 = jsonArray.getJSONObject(i);
+
+            }
+            System.out.println("head========" + jsonObjectHead.getString("resultcode"));
+            System.out.println("body========" + jsonArray);
+        } else {
+            System.out.println("resultcode========" + jsonObjectHead.getString("resultcode"));
+            System.out.println("resultmsg========" + jsonObjectHead.getString("resultmsg"));
+
+        }
+    }
+
 }

happy-boot-module-pay/src/main/java/org/jeecg/modules/paymanager/controller/HwPayAccoutController.java

@@ -0,0 +1,221 @@
+package org.jeecg.modules.paymanager.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.system.query.QueryGenerator;
+import org.jeecg.common.util.oConvertUtils;
+import org.jeecg.modules.paymanager.entity.HwPayAccout;
+import org.jeecg.modules.paymanager.service.IHwPayAccoutService;
+import org.jeecgframework.poi.excel.ExcelImportUtil;
+import org.jeecgframework.poi.excel.def.NormalExcelConstants;
+import org.jeecgframework.poi.excel.entity.ExportParams;
+import org.jeecgframework.poi.excel.entity.ImportParams;
+import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+import org.springframework.web.multipart.MultipartHttpServletRequest;
+import org.springframework.web.servlet.ModelAndView;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+ /**
+ * @Description: hw_pay_accout
+ * @Author: jeecg-boot
+ * @Date:   2019-10-08
+ * @Version: V1.0
+ */
+@RestController
+@RequestMapping("/paymanager/hwPayAccout")
+@Slf4j
+public class HwPayAccoutController {
+	@Autowired
+	private IHwPayAccoutService hwPayAccoutService;
+	
+	/**
+	  * 分页列表查询
+	 * @param hwPayAccout
+	 * @param pageNo
+	 * @param pageSize
+	 * @param req
+	 * @return
+	 */
+	@GetMapping(value = "/list")
+	public Result<IPage<HwPayAccout>> queryPageList(HwPayAccout hwPayAccout,
+									  @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
+									  @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
+									  HttpServletRequest req) {
+		Result<IPage<HwPayAccout>> result = new Result<IPage<HwPayAccout>>();
+		QueryWrapper<HwPayAccout> queryWrapper = QueryGenerator.initQueryWrapper(hwPayAccout, req.getParameterMap());
+		Page<HwPayAccout> page = new Page<HwPayAccout>(pageNo, pageSize);
+		IPage<HwPayAccout> pageList = hwPayAccoutService.page(page, queryWrapper);
+		result.setSuccess(true);
+		result.setResult(pageList);
+		return result;
+	}
+	
+	/**
+	  *   添加
+	 * @param hwPayAccout
+	 * @return
+	 */
+	@PostMapping(value = "/add")
+	public Result<HwPayAccout> add(@RequestBody HwPayAccout hwPayAccout) {
+		Result<HwPayAccout> result = new Result<HwPayAccout>();
+		try {
+			hwPayAccoutService.save(hwPayAccout);
+			result.success("添加成功！");
+		} catch (Exception e) {
+			log.error(e.getMessage(),e);
+			result.error500("操作失败");
+		}
+		return result;
+	}
+	
+	/**
+	  *  编辑
+	 * @param hwPayAccout
+	 * @return
+	 */
+	@PutMapping(value = "/edit")
+	public Result<HwPayAccout> edit(@RequestBody HwPayAccout hwPayAccout) {
+		Result<HwPayAccout> result = new Result<HwPayAccout>();
+		HwPayAccout hwPayAccoutEntity = hwPayAccoutService.getById(hwPayAccout.getId());
+		if(hwPayAccoutEntity==null) {
+			result.error500("未找到对应实体");
+		}else {
+			boolean ok = hwPayAccoutService.updateById(hwPayAccout);
+			//TODO 返回false说明什么？
+			if(ok) {
+				result.success("修改成功!");
+			}
+		}
+		
+		return result;
+	}
+	
+	/**
+	  *   通过id删除
+	 * @param id
+	 * @return
+	 */
+	@DeleteMapping(value = "/delete")
+	public Result<?> delete(@RequestParam(name="id",required=true) String id) {
+		try {
+			hwPayAccoutService.removeById(id);
+		} catch (Exception e) {
+			log.error("删除失败",e.getMessage());
+			return Result.error("删除失败!");
+		}
+		return Result.ok("删除成功!");
+	}
+	
+	/**
+	  *  批量删除
+	 * @param ids
+	 * @return
+	 */
+	@DeleteMapping(value = "/deleteBatch")
+	public Result<HwPayAccout> deleteBatch(@RequestParam(name="ids",required=true) String ids) {
+		Result<HwPayAccout> result = new Result<HwPayAccout>();
+		if(ids==null || "".equals(ids.trim())) {
+			result.error500("参数不识别！");
+		}else {
+			this.hwPayAccoutService.removeByIds(Arrays.asList(ids.split(",")));
+			result.success("删除成功!");
+		}
+		return result;
+	}
+	
+	/**
+	  * 通过id查询
+	 * @param id
+	 * @return
+	 */
+	@GetMapping(value = "/queryById")
+	public Result<HwPayAccout> queryById(@RequestParam(name="id",required=true) String id) {
+		Result<HwPayAccout> result = new Result<HwPayAccout>();
+		HwPayAccout hwPayAccout = hwPayAccoutService.getById(id);
+		if(hwPayAccout==null) {
+			result.error500("未找到对应实体");
+		}else {
+			result.setResult(hwPayAccout);
+			result.setSuccess(true);
+		}
+		return result;
+	}
+
+  /**
+      * 导出excel
+   *
+   * @param request
+   * @param response
+   */
+  @RequestMapping(value = "/exportXls")
+  public ModelAndView exportXls(HttpServletRequest request, HwPayAccout hwPayAccout) {
+      // Step.1 组装查询条件查询数据
+      QueryWrapper<HwPayAccout> queryWrapper = QueryGenerator.initQueryWrapper(hwPayAccout, request.getParameterMap());
+      List<HwPayAccout> pageList = hwPayAccoutService.list(queryWrapper);
+      // Step.2 AutoPoi 导出Excel
+      ModelAndView mv = new ModelAndView(new JeecgEntityExcelView());
+      // 过滤选中数据
+      String selections = request.getParameter("selections");
+      if(oConvertUtils.isEmpty(selections)) {
+    	  mv.addObject(NormalExcelConstants.DATA_LIST, pageList);
+      }else {
+    	  List<String> selectionList = Arrays.asList(selections.split(","));
+    	  List<HwPayAccout> exportList = pageList.stream().filter(item -> selectionList.contains(item.getId())).collect(Collectors.toList());
+    	  mv.addObject(NormalExcelConstants.DATA_LIST, exportList);
+      }
+      //导出文件名称
+      mv.addObject(NormalExcelConstants.FILE_NAME, "hw_pay_accout列表");
+      mv.addObject(NormalExcelConstants.CLASS, HwPayAccout.class);
+      mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("hw_pay_accout列表数据", "导出人:Jeecg", "导出信息"));
+      return mv;
+  }
+
+  /**
+      * 通过excel导入数据
+   *
+   * @param request
+   * @param response
+   * @return
+   */
+  @RequestMapping(value = "/importExcel", method = RequestMethod.POST)
+  public Result<?> importExcel(HttpServletRequest request, HttpServletResponse response) {
+      MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
+      Map<String, MultipartFile> fileMap = multipartRequest.getFileMap();
+      for (Map.Entry<String, MultipartFile> entity : fileMap.entrySet()) {
+          MultipartFile file = entity.getValue();// 获取上传文件对象
+          ImportParams params = new ImportParams();
+          params.setTitleRows(2);
+          params.setHeadRows(1);
+          params.setNeedSave(true);
+          try {
+              List<HwPayAccout> listHwPayAccouts = ExcelImportUtil.importExcel(file.getInputStream(), HwPayAccout.class, params);
+              hwPayAccoutService.saveBatch(listHwPayAccouts);
+              return Result.ok("文件导入成功！数据行数:" + listHwPayAccouts.size());
+          } catch (Exception e) {
+              log.error(e.getMessage(),e);
+              return Result.error("文件导入失败:"+e.getMessage());
+          } finally {
+              try {
+                  file.getInputStream().close();
+              } catch (IOException e) {
+                  e.printStackTrace();
+              }
+          }
+      }
+      return Result.ok("文件导入失败！");
+  }
+
+}

happy-boot-module-pay/src/main/java/org/jeecg/modules/paymanager/entity/HwPayAccout.java

@@ -0,0 +1,100 @@
+package org.jeecg.modules.paymanager.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import org.jeecgframework.poi.excel.annotation.Excel;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+
+/**
+ * @Description: hw_pay_accout
+ * @Author: jeecg-boot
+ * @Date:   2019-10-08
+ * @Version: V1.0
+ */
+@Data
+@TableName("hw_pay_accout")
+public class HwPayAccout implements Serializable {
+    private static final long serialVersionUID = 1L;
+    
+	/**id*/
+	@TableId(type = IdType.ID_WORKER_STR)
+	private java.lang.Integer id;
+	/**户口代码*/
+	@Excel(name = "户口代码", width = 15)
+	private java.lang.String eaccod;
+	/**户口代码名称*/
+	@Excel(name = "户口代码名称", width = 15)
+	private java.lang.String eccnam;
+	/**账户代码*/
+	@Excel(name = "账户代码", width = 15)
+	private java.lang.String actcod;
+	/**账户代码名称*/
+	@Excel(name = "账户代码名称", width = 15)
+	private java.lang.String actnam;
+	/**账号*/
+	@Excel(name = "账号", width = 15)
+	private java.lang.String actnbr;
+	/**账户名称*/
+	@Excel(name = "账户名称", width = 15)
+	private java.lang.String eacnam;
+	/**账户币种*/
+	@Excel(name = "账户币种", width = 15)
+	private java.lang.String ccynbr;
+	/**账户可用余额*/
+	@Excel(name = "账户可用余额", width = 15)
+	private java.math.BigDecimal avlbal;
+	/**账户冻结余额*/
+	@Excel(name = "账户冻结余额", width = 15)
+	private java.math.BigDecimal hldbal;
+	/**存款类型*/
+	@Excel(name = "存款类型", width = 15)
+	private java.lang.String eactyp;
+	/**存款期限*/
+	@Excel(name = "存款期限", width = 15)
+	private java.lang.String mthnbr;
+	/**存款年利率*/
+	@Excel(name = "存款年利率", width = 15)
+	private java.math.BigDecimal inrval;
+	/**开户分行*/
+	@Excel(name = "开户分行", width = 15)
+	private java.lang.String bbknbr;
+	/**开户网点*/
+	@Excel(name = "开户网点", width = 15)
+	private java.lang.String brnnbr;
+	/**状态*/
+	@Excel(name = "状态", width = 15)
+	private java.lang.String actsts;
+	/**地区*/
+	@Excel(name = "地区", width = 15)
+	private java.lang.String ctycod;
+	/**开户日*/
+	@Excel(name = "开户日", width = 15, format = "yyyy-MM-dd")
+	private java.lang.String opndat;
+	/**户口号*/
+	@Excel(name = "户口号", width = 15)
+	private java.lang.String eacnbr;
+	/**创建时间*/
+	@Excel(name = "创建时间", width = 15, format = "yyyy-MM-dd")
+	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd")
+    @DateTimeFormat(pattern="yyyy-MM-dd")
+	private java.util.Date createTime;
+	/**创建者*/
+	@Excel(name = "创建者", width = 15)
+	private java.lang.String createBy;
+	/**更新时间*/
+	@Excel(name = "更新时间", width = 15, format = "yyyy-MM-dd")
+	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd")
+    @DateTimeFormat(pattern="yyyy-MM-dd")
+	private java.util.Date updateTime;
+	/**更新者*/
+	@Excel(name = "更新者", width = 15)
+	private java.lang.String updateBy;
+	/**删除状态(0-正常,1-已删除)*/
+	@Excel(name = "删除状态(0-正常,1-已删除)", width = 15)
+	private java.lang.String delFlag;
+}

happy-boot-module-pay/src/main/java/org/jeecg/modules/paymanager/mapper/HwPayAccoutMapper.java

@@ -0,0 +1,20 @@
+package org.jeecg.modules.paymanager.mapper;
+
+import java.util.List;
+
+import org.apache.ibatis.annotations.Param;
+import org.jeecg.modules.paymanager.entity.HwPayAccout;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * @Description: hw_pay_accout
+ * @Author: jeecg-boot
+ * @Date: 2019-10-08
+ * @Version: V1.0
+ */
+public interface HwPayAccoutMapper extends BaseMapper<HwPayAccout> {
+
+    int getCount(@Param("hwPayAccout") HwPayAccout hwPayAccout);
+
+    void saveAccout(@Param("hwPayAccout") HwPayAccout hwPayAccout);
+}

happy-boot-module-pay/src/main/java/org/jeecg/modules/paymanager/mapper/xml/HwPayAccoutMapper.xml

@@ -0,0 +1,162 @@
+<?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="org.jeecg.modules.paymanager.mapper.HwPayAccoutMapper">
+
+    <sql id="hwPayAccoutColumns">
+		a.id AS "id",
+		a.eaccod AS "eaccod",
+		a.eccnam AS "eccnam",
+		a.actcod AS "actcod",
+		a.actnam AS "actnam",
+		a.actnbr AS "actnbr",
+		a.eacnam AS "eacnam",
+		a.ccynbr AS "ccynbr",
+		a.avlbal AS "avlbal",
+		a.hldbal AS "hldbal",
+		a.eactyp AS "eactyp",
+		a.mthnbr AS "mthnbr",
+		a.inrval AS "inrval",
+		a.bbknbr AS "bbknbr",
+		a.brnnbr AS "brnnbr",
+		a.actsts AS "actsts",
+		a.ctycod AS "ctycod",
+		a.opndat AS "opndat",
+		a.eacnbr AS "eacnbr",
+		a.create_time AS "createTime",
+		a.create_by AS "createBy",
+		a.update_time AS "updateTime",
+		a.update_by AS "updateBy",
+		a.del_flag AS "delFlag"
+	</sql>
+
+    <sql id="hwPayAccoutJoins">
+
+    </sql>
+
+
+    <select id="get" resultType="org.jeecg.modules.paymanager.entity.HwPayAccout">
+        SELECT
+        <include refid="hwPayAccoutColumns"/>
+        FROM hw_pay_accout a
+        <include refid="hwPayAccoutJoins"/>
+        WHERE a.id = #{id}
+    </select>
+
+    <select id="findList" resultType="org.jeecg.modules.paymanager.entity.HwPayAccout">
+        SELECT
+        <include refid="hwPayAccoutColumns"/>
+        FROM hw_pay_accout a
+        <include refid="hwPayAccoutJoins"/>
+        <where>
+
+        </where>
+    </select>
+
+    <select id="findAllList" resultType="org.jeecg.modules.paymanager.entity.HwPayAccout">
+        SELECT
+        <include refid="hwPayAccoutColumns"/>
+        FROM hw_pay_accout a
+        <include refid="hwPayAccoutJoins"/>
+        <where>
+
+        </where>
+    </select>
+
+    <insert id="saveAccout" keyProperty="id" useGeneratedKeys="true" parameterType="org.jeecg.modules.paymanager.entity.HwPayAccout">
+		INSERT INTO hw_pay_accout(
+			eaccod,
+			eccnam,
+			actcod,
+			actnam,
+			actnbr,
+			eacnam,
+			ccynbr,
+			avlbal,
+			hldbal,
+			eactyp,
+			mthnbr,
+			inrval,
+			bbknbr,
+			brnnbr,
+			actsts,
+			ctycod,
+			opndat,
+			eacnbr,
+			create_time,
+			create_by,
+			update_time,
+			update_by,
+			del_flag
+		) VALUES (
+			#{hwPayAccout.eaccod},
+			#{hwPayAccout.eccnam},
+			#{hwPayAccout.actcod},
+			#{hwPayAccout.actnam},
+			#{hwPayAccout.actnbr},
+			#{hwPayAccout.eacnam},
+			#{hwPayAccout.ccynbr},
+			#{hwPayAccout.avlbal},
+			#{hwPayAccout.hldbal},
+			#{hwPayAccout.eactyp},
+			#{hwPayAccout.mthnbr},
+			#{hwPayAccout.inrval},
+			#{hwPayAccout.bbknbr},
+			#{hwPayAccout.brnnbr},
+			#{hwPayAccout.actsts},
+			#{hwPayAccout.ctycod},
+			#{hwPayAccout.opndat},
+			#{hwPayAccout.eacnbr},
+			#{hwPayAccout.createTime},
+			#{hwPayAccout.createBy},
+			#{hwPayAccout.updateTime},
+			#{hwPayAccout.updateBy},
+			#{hwPayAccout.delFlag}
+		)
+	</insert>
+
+    <update id="update">
+		UPDATE hw_pay_accout SET
+			eaccod = #{hwPayAccout.eaccod},
+			eccnam = #{hwPayAccout.eccnam},
+			actcod = #{hwPayAccout.actcod},
+			actnam = #{hwPayAccout.actnam},
+			actnbr = #{hwPayAccout.actnbr},
+			eacnam = #{hwPayAccout.eacnam},
+			ccynbr = #{hwPayAccout.ccynbr},
+			avlbal = #{hwPayAccout.avlbal},
+			hldbal = #{hwPayAccout.hldbal},
+			eactyp = #{hwPayAccout.eactyp},
+			mthnbr = #{hwPayAccout.mthnbr},
+			inrval = #{hwPayAccout.inrval},
+			bbknbr = #{hwPayAccout.bbknbr},
+			brnnbr = #{hwPayAccout.brnnbr},
+			actsts = #{hwPayAccout.actsts},
+			ctycod = #{hwPayAccout.ctycod},
+			opndat = #{hwPayAccout.opndat},
+			eacnbr = #{hwPayAccout.eacnbr},
+			create_time = #{hwPayAccout.createTime},
+			update_time = #{hwPayAccout.updateTime},
+			update_by = #{hwPayAccout.updateBy}
+		WHERE id = #{hwPayAccout.id}
+	</update>
+
+
+    <!--物理删除-->
+    <update id="delete">
+		DELETE FROM hw_pay_accout
+		WHERE id = #{id}
+	</update>
+
+    <!--逻辑删除-->
+    <update id="deleteByLogic">
+		UPDATE hw_pay_accout SET
+			del_flag = #{DEL_FLAG_DELETE}
+		WHERE id = #{id}
+	</update>
+
+    <select id="getCount" resultType="int">
+        select count(a.id)
+        from hw_pay_accout a
+        where a.eacnbr = #{hwPayAccout.eacnbr}
+    </select>
+</mapper>

happy-boot-module-pay/src/main/java/org/jeecg/modules/paymanager/service/IHwPayAccoutService.java

@@ -0,0 +1,16 @@
+package org.jeecg.modules.paymanager.service;
+
+import com.alibaba.fastjson.JSONObject;
+import org.jeecg.modules.paymanager.entity.HwPayAccout;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * @Description: hw_pay_accout
+ * @Author: jeecg-boot
+ * @Date:   2019-10-08
+ * @Version: V1.0
+ */
+public interface IHwPayAccoutService extends IService<HwPayAccout> {
+
+    void saveAccout(JSONObject jsonObject);
+}

happy-boot-module-pay/src/main/java/org/jeecg/modules/paymanager/service/impl/HwPayAccoutServiceImpl.java

@@ -0,0 +1,69 @@
+package org.jeecg.modules.paymanager.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.apache.shiro.SecurityUtils;
+import org.jeecg.common.system.vo.LoginUser;
+import org.jeecg.modules.paymanager.entity.HwPayAccout;
+import org.jeecg.modules.paymanager.mapper.HwPayAccoutMapper;
+import org.jeecg.modules.paymanager.service.IHwPayAccoutService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @Description: hw_pay_accout
+ * @Author: jeecg-boot
+ * @Date: 2019-10-08
+ * @Version: V1.0
+ */
+@Service
+public class HwPayAccoutServiceImpl extends ServiceImpl<HwPayAccoutMapper, HwPayAccout> implements IHwPayAccoutService {
+
+    /**
+     * @param jsonObject
+     */
+    @Override
+    @Transactional
+    public void saveAccout(JSONObject jsonObject) {
+        HwPayAccout hwPayAccout = new HwPayAccout();
+        hwPayAccout.setEaccod(jsonObject.getString("eaccod"));
+        hwPayAccout.setEccnam(jsonObject.getString("eccnam"));
+        hwPayAccout.setActcod(jsonObject.getString("actcod"));
+        hwPayAccout.setActnam(jsonObject.getString("actnam"));
+        hwPayAccout.setActnbr(jsonObject.getString("actnbr"));
+        hwPayAccout.setEacnam(jsonObject.getString("eacnam"));
+        hwPayAccout.setCcynbr(jsonObject.getString("ccynbr"));
+        if (jsonObject.getString("avlbal") != null) {
+            hwPayAccout.setAvlbal(new BigDecimal(jsonObject.getString("avlbal")));
+        }
+        if (jsonObject.getString("hldbal") != null) {
+            hwPayAccout.setHldbal(new BigDecimal(jsonObject.getString("hldbal")));
+        }
+        hwPayAccout.setEactyp(jsonObject.getString("eactyp"));
+        hwPayAccout.setMthnbr(jsonObject.getString("mthnbr"));
+        if (jsonObject.getString("inrval") != null) {
+            hwPayAccout.setInrval(new BigDecimal(jsonObject.getString("inrval")));
+        }
+        hwPayAccout.setBbknbr(jsonObject.getString("bbknbr"));
+        hwPayAccout.setBrnnbr(jsonObject.getString("brnnbr"));
+        hwPayAccout.setActsts(jsonObject.getString("actsts"));
+        hwPayAccout.setCtycod(jsonObject.getString("ctycod"));
+        hwPayAccout.setOpndat(jsonObject.getString("opndat"));
+        hwPayAccout.setEacnbr(jsonObject.getString("eacnbr"));
+        hwPayAccout.setCreateTime(new Date());
+        //获取当前登录用户
+        LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
+        hwPayAccout.setCreateBy(sysUser.getUsername());
+        hwPayAccout.setDelFlag("0");
+        //查询当前账号是否存在
+        int count = baseMapper.getCount(hwPayAccout);
+        if (count > 0) {
+
+        } else {
+            baseMapper.saveAccout(hwPayAccout);
+        }
+    }
+}