xinshenger

boman-web-core/src/main/java/com/boman/web/core/controller/TaskController.java

@@ -45,6 +45,11 @@ public class TaskController {
         taskService.getNewborn();
     }
 
+    @GetMapping("/getNewbornS")
+    private void getNewbornS(String startTime,String endTime) {
+        taskService.getNewbornS(startTime,endTime);
+    }
+
     @GetMapping("/insertAccountingData")
     private void insertAccountingData() {
         taskService.insertAccountingData();

boman-web-core/src/main/java/com/boman/web/core/mapper/BirthRecordsMapper.java

@@ -14,4 +14,8 @@ public interface BirthRecordsMapper {
     BirthRecords getBirthRecordsInfo(String id);
 
     void updataBirthRecordsInfo(String idCard);
+
+    int selectBirthRecordsByCsyxzmbh(String csyxzmbh);
+
+    void insertBirthRecords(BirthRecords birthRecords);
 }

boman-web-core/src/main/java/com/boman/web/core/service/TaskService.java

@@ -609,8 +609,14 @@ public class TaskService {
                     birthRecords.setUpdateBy("系统");
                     birthRecords.setStatus(1);
                 }
-                //批量保存
-                birthRecordsService.insertListBirthRecords(birthRecordsList);
+                //保存
+                for (BirthRecords birthRecords : birthRecordsList) {
+                    //判断数据库是否存在数据
+                    int num =  birthRecordsService.selectBirthRecordsByCsyxzmbh(birthRecords.getCsyxzmbh());
+                    if(num<1){
+                        birthRecordsService.insertBirthRecords(birthRecords);
+                    }
+                }
                 System.out.println(data);
             } catch (IOException e) {
                 e.printStackTrace();
@@ -618,6 +624,53 @@ public class TaskService {
         }
     }
 
+    /***
+     * 新生儿（手动跑数据，时间间隔一个月）
+     *
+     */
+    public void getNewbornS(String startTime,String endTime) {
+
+        String token = getToken();
+
+        if (StringUtils.isNotBlank(token)) {
+
+            endTime = endTime.replace(" ", "%20");
+            startTime = startTime.replace(" ", "%20");
+
+            Map<String, String> paramMap = new HashMap<>();
+            paramMap.put("client_id", "acdf50bd13be4901b64c62b1fee862c0");
+            paramMap.put("access_token", token);
+            paramMap.put("xzqh", "潜山市");
+            paramMap.put("start_time", startTime);
+            paramMap.put("end_time", endTime);
+            String http = "http://60.171.171.235:9090/service/api/rkk/qxcsyxzmcx";
+            try {
+                String data = HttpClientUtils.doGet(http, paramMap);
+
+                List<BirthRecords> birthRecordsList = JSONObject.parseArray(data, BirthRecords.class);
+                for (BirthRecords birthRecords : birthRecordsList) {
+                    birthRecords.setIsDel("N");
+                    birthRecords.setCreateBy("系统");
+                    birthRecords.setUpdateBy("系统");
+                    birthRecords.setStatus(1);
+                }
+                //保存
+                for (BirthRecords birthRecords : birthRecordsList) {
+                    //判断数据库是否存在数据
+                    int num =  birthRecordsService.selectBirthRecordsByCsyxzmbh(birthRecords.getCsyxzmbh());
+                    if(num<1){
+                        birthRecordsService.insertBirthRecords(birthRecords);
+                    }
+                }
+                System.out.println(data);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+
+
 
     /**
      * 获取政务网token

boman-web-core/src/main/java/com/boman/web/core/service/birth/BirthRecordsService.java

@@ -9,4 +9,8 @@ public interface BirthRecordsService {
     void insertListBirthRecords(List<BirthRecords> birthRecordsList);
 
     List<BirthRecords> listDie(BirthRecords birthRecords);
+
+    int selectBirthRecordsByCsyxzmbh(String csyxzmbh);
+
+    void insertBirthRecords(BirthRecords birthRecords);
 }

boman-web-core/src/main/java/com/boman/web/core/service/birth/BirthRecordsServiceImpl.java

@@ -50,6 +50,16 @@ public class BirthRecordsServiceImpl implements BirthRecordsService {
         return birthRecordsList;
     }
 
+    @Override
+    public int selectBirthRecordsByCsyxzmbh(String csyxzmbh) {
+        return birthRecordsMapper.selectBirthRecordsByCsyxzmbh(csyxzmbh);
+    }
+
+    @Override
+    public void insertBirthRecords(BirthRecords birthRecords) {
+        birthRecordsMapper.insertBirthRecords(birthRecords);
+    }
+
     private void startPage() {
         PageDomain pageDomain = TableSupport.buildPageRequest();
         Integer pageNum = pageDomain.getPageNum();

boman-web-core/src/main/resources/mapper/BirthRecordsMapper.xml

@@ -124,6 +124,81 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             sysdate(),sysdate())
         </foreach>
     </insert>
+    <insert id="insertBirthRecords">
+        insert into birth_records(create_by,
+        update_by,
+        is_del,
+        remark,
+        csrq,
+        csyxzmbh,
+        fqmz,
+        csyxzmbb,
+        xsexbdm,
+        sfgwrs,
+        sfycsqx,
+        csjkzk,
+        cstz,
+        sfzjhm,
+        sfzjlx,
+        fqgj,
+        csdxz,
+        ycfjkzk,
+        mqmz,
+        xsexb,
+        fmfs,
+        mqsfzjlx,
+        mqxm,
+        mz,
+        cssc,
+        xsexm,
+        fqxm,
+        fqsfzjlx,
+        cstc,
+        csdxzqh,
+        mqgj,
+        csyxzmqfrq,
+        csyxzmqfjg,fqsfzjhm,csyljg,mqsfzjhm,csyz,status,create_time,update_time)
+        values
+            (#{birthRecords.createBy},
+            #{birthRecords.updateBy},
+            #{birthRecords.isDel},
+            #{birthRecords.remark},
+            #{birthRecords.csrq},
+            #{birthRecords.csyxzmbh},
+            #{birthRecords.fqmz},
+            #{birthRecords.csyxzmbb},
+            #{birthRecords.xsexbdm},
+            #{birthRecords.sfgwrs},
+            #{birthRecords.sfycsqx},
+            #{birthRecords.csjkzk},
+            #{birthRecords.cstz},
+            #{birthRecords.sfzjhm},
+            #{birthRecords.sfzjlx},
+            #{birthRecords.fqgj},
+            #{birthRecords.csdxz},
+            #{birthRecords.ycfjkzk},
+            #{birthRecords.mqmz},
+            #{birthRecords.xsexb},
+            #{birthRecords.fmfs},
+            #{birthRecords.mqsfzjlx},
+            #{birthRecords.mqxm},
+            #{birthRecords.mz},
+            #{birthRecords.cssc},
+            #{birthRecords.xsexm},
+            #{birthRecords.fqxm},
+            #{birthRecords.fqsfzjlx},
+            #{birthRecords.cstc},
+            #{birthRecords.csdxzqh},
+            #{birthRecords.mqgj},
+            #{birthRecords.csyxzmqfrq},
+            #{birthRecords.csyxzmqfjg},
+            #{birthRecords.fqsfzjhm},
+            #{birthRecords.csyljg},
+            #{birthRecords.mqsfzjhm},
+            #{birthRecords.csyz},
+            #{birthRecords.status},
+            sysdate(),sysdate())
+    </insert>
     <update id="updataBirthRecordsInfo">
         update birth_records set status='2' where sfzjhm = #{idCard}
     </update>
@@ -169,7 +244,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="mqsfzjhm != null  and mqsfzjhm != ''">and mqsfzjhm = #{mqsfzjhm}</if>
             <if test="status != null  and status != ''">and status = #{status}</if>
         </where>
-        order by status, create_time DESC
+        order by status, csrq DESC
 
 
     </select>
@@ -182,4 +257,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         where id = #{id}
     </select>
 
+    <select id="selectBirthRecordsByCsyxzmbh" resultType="java.lang.Integer">
+        select id, create_by,update_by,is_del,remark,csrq,
+               csyxzmbh,fqmz,csyxzmbb,xsexbdm,sfgwrs,sfycsqx,csjkzk,cstz,sfzjhm,sfzjlx,
+               fqgj,csdxz,ycfjkzk,mqmz,xsexb,fmfs,mqsfzjlx,mqxm,mz,cssc,xsexm,fqxm,fqsfzjlx,cstc,csdxzqh,mqgj,
+               csyxzmqfrq,csyxzmqfjg,fqsfzjhm,csyljg,mqsfzjhm,csyz,status,create_time,update_time
+        from birth_records
+        where csyxzmbh = #{csyxzmbh}
+    </select>
+
 </mapper>