侦查指令回报添加新增积分功能

src/main/java/com/founder/model/TbYwJfls.java

+package com.founder.model;
+
+import java.io.Serializable;
+
+/**
+ * <p>
+ * 积分详情流水表
+ * </p>
+ *
+ * @author wangyang
+ * @since 2020-08-27
+ */
+public class TbYwJfls implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+   //信息主键编号
+    private String xxzjbh;
+
+    //用户名称
+    private String xm;
+
+    //积分来源相关编号
+    private String xgbh;
+
+    //用户身份证号
+    private String sfzh;
+
+    //用户警号
+    private String yhjh;
+
+    //用户单位
+    private String gajgjgdm;
+
+    //用户单位名称
+    private String gajgjgdmmc;
+
+
+   //分数
+    private String fs;
+
+    //登记人身份证号
+    private String djrsfzh;
+
+
+    //信息详情
+    private String xxqk;
+
+    public static long getSerialVersionUID() {
+        return serialVersionUID;
+    }
+
+    public String getXxzjbh() {
+        return xxzjbh;
+    }
+
+    public void setXxzjbh(String xxzjbh) {
+        this.xxzjbh = xxzjbh;
+    }
+
+    public String getXm() {
+        return xm;
+    }
+
+    public void setXm(String xm) {
+        this.xm = xm;
+    }
+
+    public String getXgbh() {
+        return xgbh;
+    }
+
+    public void setXgbh(String xgbh) {
+        this.xgbh = xgbh;
+    }
+
+    public String getSfzh() {
+        return sfzh;
+    }
+
+    public void setSfzh(String sfzh) {
+        this.sfzh = sfzh;
+    }
+
+    public String getYhjh() {
+        return yhjh;
+    }
+
+    public void setYhjh(String yhjh) {
+        this.yhjh = yhjh;
+    }
+
+    public String getGajgjgdm() {
+        return gajgjgdm;
+    }
+
+    public void setGajgjgdm(String gajgjgdm) {
+        this.gajgjgdm = gajgjgdm;
+    }
+
+    public String getGajgjgdmmc() {
+        return gajgjgdmmc;
+    }
+
+    public void setGajgjgdmmc(String gajgjgdmmc) {
+        this.gajgjgdmmc = gajgjgdmmc;
+    }
+
+
+    public String getFs() {
+        return fs;
+    }
+
+    public void setFs(String fs) {
+        this.fs = fs;
+    }
+
+    public String getDjrsfzh() {
+        return djrsfzh;
+    }
+
+    public void setDjrsfzh(String djrsfzh) {
+        this.djrsfzh = djrsfzh;
+    }
+
+    public String getXxqk() {
+        return xxqk;
+    }
+
+    public void setXxqk(String xxqk) {
+        this.xxqk = xxqk;
+    }
+}

src/main/java/com/founder/zczl/controller/ZczlController.java

@@ -2065,6 +2065,26 @@ public class ZczlController {
                 usersIdentitycard.add(fprgmsfhm);
             }
             messageService.sendMessage(usersIdentitycard,user.getIdentitycard(),xxnr,zczlxx.getZczlbh(),"020500");
+            //2021.01.29 新增回报新增积分功能
+            if("0".equals(sfxb)){
+                //首次回报新增积分
+                String grade = zczlService.getJfGzByType();
+                //信息主键编号
+                TbYwJfls tbYwJfls = new TbYwJfls();
+                tbYwJfls.setXxzjbh(UUID.randomUUID()
+                        .toString().replace("-", ""));
+                tbYwJfls.setXxqk("回报指令编号为：" + tbYwZczlHb.getZczlbh() +
+                        " 的侦查指令，获取积分，分数为：" + grade+"。");
+                tbYwJfls.setDjrsfzh(user.getIdentitycard());
+                tbYwJfls.setFs(grade);
+                tbYwJfls.setXm(user.getTrueName());
+                tbYwJfls.setXgbh(tbYwZczlHb.getZczlbh());
+                tbYwJfls.setSfzh(user.getIdentitycard());
+                tbYwJfls.setYhjh(user.getPolicemanid());
+                tbYwJfls.setGajgjgdm(user.getUnitcode());
+                tbYwJfls.setGajgjgdmmc(user.getUnitname());
+                zczlService.insertUserGrade(tbYwJfls);
+            }
         }else{
             flag = "0";
         }

src/main/java/com/founder/zczl/dao/ZczlDao.java

@@ -160,4 +160,10 @@ public interface ZczlDao {
     int updateQxfp(TbYwZczlSpqx tbYwZczlSpqx);
 
     List<String> queryAllUserIdByYwlx(String startId);
+
+    String getJfGzByType();
+
+    void insertJfls(TbYwJfls tbYwJfls);
+
+    void addUserGrade(Map<String, Object> map);
 }

src/main/java/com/founder/zczl/service/IZczlService.java

@@ -147,4 +147,8 @@ public interface IZczlService {
     Map getFpqxxxByUserId(String userId);
 
     String doQxfp(TbYwZczlSpqx tbYwZczlSpqx);
+
+    String getJfGzByType();
+
+    void insertUserGrade(TbYwJfls tbYwJfls);
 }

src/main/java/com/founder/zczl/service/impl/ZczlService.java

@@ -1914,5 +1914,25 @@ public class ZczlService implements IZczlService {
         return flag;
     }
 
+    @Override
+    public String getJfGzByType() {
+        String grade = zczlDao.getJfGzByType();
+        if (StringUtils.isEmpty(grade)) {
+            grade = "0";
+        }
+        return grade;
+    }
+
+    @Override
+    public void insertUserGrade(TbYwJfls tbYwJfls) {
+        //插入积分流水
+        zczlDao.insertJfls(tbYwJfls);
+        Map<String, Object> map = new HashMap<>();
+        map.put("zjhm", tbYwJfls.getSfzh());
+        //获取分数
+        map.put("totalScore", tbYwJfls.getFs());
+        zczlDao.addUserGrade(map);
+    }
+
     //审批权限查询与设置--end
 }

src/main/resources/mapper/ZczlMapper.xml

@@ -1848,8 +1848,47 @@
         from TB_YW_ZCZL_SPQX spqx ,SYS_USER u where spqx.xxsc_pdbz=0 and spqx.ywlx like '%'||#{startId, jdbcType=VARCHAR}||'%'
         and u.scbz=0 and u.open_flag='1' and spqx.USERID = u.id
     </select>
+    <!--  审批权限查询与设置end  -->
 
+    <insert id="insertJfls" parameterType="com.founder.model.TbYwJfls">
+        INSERT INTO TB_YW_JFLS ( XXZJBH
+                               , XM
+                               , XGBH
+                               , SFZH
+                               , YHJH
+                               , GAJGJGDM
+                               , GAJGJGDMMC
+                               , JFLY
+                               , FS
+                               , XXQK
+                               , DJRSFZH
+                               , DJSJ)
+        VALUES ( #{ xxzjbh , jdbcType=VARCHAR }
+               , #{ xm , jdbcType=VARCHAR }
+               , #{ xgbh , jdbcType=VARCHAR }
+               , #{ sfzh , jdbcType=VARCHAR }
+               , #{ yhjh , jdbcType=VARCHAR }
+               , #{ gajgjgdm , jdbcType=VARCHAR }
+               , #{ gajgjgdmmc , jdbcType=VARCHAR }
+               , #{ jfly , jdbcType=VARCHAR }
+               , #{ fs , jdbcType=VARCHAR }
+               , #{ xxqk , jdbcType=VARCHAR }
+               , #{ djrsfzh , jdbcType=VARCHAR }
+               , sysdate)
+    </insert>
+    <!--添加用户积分-->
+    <update id="addUserGrade" parameterType="java.util.Map">
+        UPDATE sys_user
+        SET GRDF = to_number(NVL(grdf, 0)) + #{totalScore}
+        where IDENTITYCARD = #{zjhm}
+          AND SCBZ = '0'
+    </update>
 
+    <select id="getJfGzByType" resultType="java.lang.String">
+        select GRADE
+        from TB_YW_AJJFGZ
+        where SFSC_PDBZ = '0'
+          AND CODE = 'qt_zlfk'
+    </select>
 
-    <!--  审批权限查询与设置end  -->
 </mapper>
\ No newline at end of file