Skip to content

C
civil-bigdata
Commit 5995a212 by 袁伟铭
Options

Merge remote-tracking branch 'origin/master'

parents a8cdb3b0 42ed7bff
Showing with 493 additions and 15 deletions
portal-server/src/main/java/com/zq/portal/dao/CjStatsDao.java
......@@ -39,7 +39,7 @@ public interface CjStatsDao {
List<StatsVo> getYearSevereDisabledStats(StatsReqVo vo);
/**
* 获取区域下的残疾人统计
* 获取区域下的重度残疾人统计
*
* @param vo
* @return
......@@ -47,6 +47,14 @@ public interface CjStatsDao {
StatsVo getSeverePeopleNumStats(StatsReqVo vo);
/**
* 获取区域下的困难残疾人统计
*
* @param vo
* @return
*/
StatsVo getDifficultPeopleNumStats(StatsReqVo vo);
/**
* 获取区域发放统计
*
* @return
......
portal-server/src/main/java/com/zq/portal/service/CjStatsService.java
......@@ -236,6 +236,7 @@ public class CjStatsService {
data.put("areaName", area.getName());
data.put("areaCode",severeAreaIssueStat.getCode());
data.put("severePeopleNum", cjStatsDao.getSeverePeopleNumStats(vo).getNum());
data.put("difficultPeopleNum",cjStatsDao.getDifficultPeopleNumStats(vo).getNum());
data.put("issueNum", severeAreaIssueStat.getNum());
data.put("issueAmount", severeAreaIssueStat.getAmount());
areaPeopleNumList.add(data);
......
portal-server/src/main/resources/mapper/CjStatsMapper.xml
......@@ -65,6 +65,22 @@
</if>
</select>
<select id="getDifficultPeopleNumStats" resultType="com.zq.portal.vo.StatsVo">
SELECT
COUNT( 1 ) 'num'
FROM
`cjrjz_proposer`
WHERE
ENSURE_LEVEL_ID IS NOT NULL
AND ENSURE_LEVEL_ID IN (3,4)
<if test="subAreaCode != null and subAreaCode != ''">
AND CARD_CODE LIKE CONCAT(#{subAreaCode}, '%')
</if>
<if test="year != null">
AND LEFT(CREATE_DATE, 4) = #{year}
</if>
</select>
<select id="getAreaIssueStats" resultType="com.zq.portal.vo.StatsVo">
SELECT LEFT(UNIT_ID, #{size}) 'code', APPLY_TYPE_ID 'type', GRANT_YEAR 'year', COUNT_PEOPLE 'num', SUM_MONEY
'amount'
......
portal-server/src/main/resources/mapper/ShzzStatsMapper.xml
......@@ -11,8 +11,8 @@
<if test="subAreaCode != null and subAreaCode != ''">
AND p.DEPTCODE LIKE CONCAT(#{subAreaCode},'%')
</if>
<if test="year != null">
AND DATE_FORMAT(s.issueTime, "%Y") = #{year}
<if test="type != null">
AND s.ORGTYPE = #{type}
</if>
</select>
......@@ -22,13 +22,10 @@
s.orgType 'type'
FROM
soorgan s LEFT JOIN pfdept P ON s.DEPTID = p.DEPTID
WHERE LEFT ( p.DEPTCODE, 4 ) != '4500'
WHERE 1=1
<if test="subAreaCode != null and subAreaCode != ''">
AND p.DEPTCODE LIKE CONCAT(#{subAreaCode},'%')
</if>
<if test="year != null">
AND DATE_FORMAT(s.issueTime, "%Y") = #{year}
</if>
GROUP BY s.orgType
</select>
......
sync-server/src/main/java/com/zq/sync/entity/Fdx01.java
......@@ -282,5 +282,28 @@ public class Fdx01 {
*/
@ApiModelProperty("修改时间")
private Date afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/entity/Fdx02.java
......@@ -282,5 +282,28 @@ public class Fdx02 {
*/
@ApiModelProperty("修改时间")
private Date afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/entity/Fdx03.java
......@@ -120,5 +120,28 @@ public class Fdx03 {
*/
@ApiModelProperty("乡镇")
private String afdx0802;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/entity/Fdx04.java
......@@ -144,5 +144,28 @@ public class Fdx04 {
*/
@ApiModelProperty("乡镇")
private String afdx0802;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/entity/Fdx05.java
......@@ -144,5 +144,28 @@ public class Fdx05 {
*/
@ApiModelProperty("乡镇")
private String afdx0802;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/entity/Fdx06.java
......@@ -288,5 +288,28 @@ public class Fdx06 {
*/
@ApiModelProperty("修改时间")
private Date afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/entity/Fdx07.java
......@@ -171,5 +171,27 @@ public class Fdx07 {
@ApiModelProperty("护理补发人次")
private Integer agax0922;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/entity/Fdx88.java
......@@ -123,5 +123,28 @@ public class Fdx88 {
*/
@ApiModelProperty("修改时间")
private Date afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
\ No newline at end of file
sync-server/src/main/java/com/zq/sync/service/DisabledService.java
......@@ -59,6 +59,10 @@ public class DisabledService {
.afdx0816(fdx88.getAfdx0816())
.afdx0817(fdx88.getAfdx0817()!=null? DateUtil.format(fdx88.getAfdx0817(), DatePattern.NORM_DATETIME_PATTERN):"")
.afdx0818(fdx88.getAfdx0818()!=null? DateUtil.format(fdx88.getAfdx0818(), DatePattern.NORM_DATETIME_PATTERN):"")
.serialNumner(fdx88.getSerialNumner())
.dataStatus(fdx88.getDataStatus())
.dataTime(fdx88.getDataTime())
.areaCode(fdx88.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_btdxlxxx")
......@@ -123,6 +127,10 @@ public class DisabledService {
.agax0920(fdx07.getAgax0920())
.agax0921(fdx07.getAgax0921())
.agax0922(fdx07.getAgax0922())
.serialNumner(fdx07.getSerialNumner())
.dataStatus(fdx07.getDataStatus())
.dataTime(fdx07.getDataTime())
.areaCode(fdx07.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_ffhzxx")
......@@ -205,6 +213,10 @@ public class DisabledService {
.afdx0870(fdx06.getAfdx0870()!=null? DateUtil.format(fdx06.getAfdx0870(), DatePattern.NORM_MONTH_PATTERN):"")
.afdx0817(fdx06.getAfdx0817()!=null? DateUtil.format(fdx06.getAfdx0817(), DatePattern.NORM_MONTH_PATTERN):"")
.afdx0818(fdx06.getAfdx0818()!=null? DateUtil.format(fdx06.getAfdx0818(), DatePattern.NORM_MONTH_PATTERN):"")
.serialNumner(fdx06.getSerialNumner())
.dataStatus(fdx06.getDataStatus())
.dataTime(fdx06.getDataTime())
.areaCode(fdx06.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_lsxx")
.form("access_key", "mzb_gx_450000")
......@@ -262,6 +274,10 @@ public class DisabledService {
.afdx0807(fdx05.getAfdx0807())
.afdx0808(fdx05.getAfdx0808())
.afdx0802(fdx05.getAfdx0802())
.serialNumner(fdx05.getSerialNumner())
.dataStatus(fdx05.getDataStatus())
.dataTime(fdx05.getDataTime())
.areaCode(fdx05.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_zjryxx")
......@@ -321,6 +337,10 @@ public class DisabledService {
.afdx0807(fdx04.getAfdx0807())
.afdx0808(fdx04.getAfdx0808())
.afdx0802(fdx04.getAfdx0802())
.serialNumner(fdx04.getSerialNumner())
.dataStatus(fdx04.getDataStatus())
.dataTime(fdx04.getDataTime())
.areaCode(fdx04.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_bfryxx")
.form("access_key", "mzb_gx_450000")
......@@ -374,6 +394,10 @@ public class DisabledService {
.afdx0807(fdx03.getAfdx0807())
.afdx0808(fdx03.getAfdx0808())
.afdx0802(fdx03.getAfdx0802())
.serialNumner(fdx03.getSerialNumner())
.dataStatus(fdx03.getDataStatus())
.dataTime(fdx03.getDataTime())
.areaCode(fdx03.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_tfryxx")
......@@ -455,6 +479,10 @@ public class DisabledService {
.afdx0870(fdx02.getAfdx0870()!=null? DateUtil.format(fdx02.getAfdx0870(), DatePattern.NORM_MONTH_PATTERN):"")
.afdx0817(fdx02.getAfdx0817()!=null? DateUtil.format(fdx02.getAfdx0817(), DatePattern.NORM_MONTH_PATTERN):"")
.afdx0818(fdx02.getAfdx0818()!=null? DateUtil.format(fdx02.getAfdx0818(), DatePattern.NORM_MONTH_PATTERN):"")
.serialNumner(fdx02.getSerialNumner())
.dataStatus(fdx02.getDataStatus())
.dataTime(fdx02.getDataTime())
.areaCode(fdx02.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_xzryxx")
......@@ -537,6 +565,10 @@ public class DisabledService {
.afdx0870(fdx01.getAfdx0870()!=null? DateUtil.format(fdx01.getAfdx0870(), DatePattern.NORM_MONTH_PATTERN):"")
.afdx0817(fdx01.getAfdx0817()!=null? DateUtil.format(fdx01.getAfdx0817(), DatePattern.NORM_MONTH_PATTERN):"")
.afdx0818(fdx01.getAfdx0818()!=null? DateUtil.format(fdx01.getAfdx0818(), DatePattern.NORM_MONTH_PATTERN):"")
.serialNumner(fdx01.getSerialNumner())
.dataStatus(fdx01.getDataStatus())
.dataTime(fdx01.getDataTime())
.areaCode(fdx01.getAreaCode())
.build();
HttpRequest request = HttpRequest.post("https://59.255.186.1/yhbcp-engine_gov/rest/cjrfl_report_zcryxx")
......
sync-server/src/main/java/com/zq/sync/task/ReportTask.java
......@@ -18,7 +18,42 @@ public class ReportTask {
* 每月16日执行上报
*/
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx88(){
public void fdx88() {
disabledService.fdx88();
}
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx07(){
disabledService.fdx07();
}
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx06(){
disabledService.fdx06();
}
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx05(){
disabledService.fdx05();
}
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx04(){
disabledService.fdx04();
}
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx03(){
disabledService.fdx03();
}
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx02(){
disabledService.fdx02();
}
@Scheduled(cron = "0 0 0 16 * ?")
public void fdx01(){
disabledService.fdx01();
}
}
sync-server/src/main/java/com/zq/sync/vo/Fdx01Vo.java
......@@ -278,4 +278,28 @@ public class Fdx01Vo {
*/
@ApiModelProperty("修改时间")
private String afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
sync-server/src/main/java/com/zq/sync/vo/Fdx02Vo.java
......@@ -7,6 +7,8 @@ import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
@Data
@AllArgsConstructor
......@@ -277,4 +279,28 @@ public class Fdx02Vo {
*/
@ApiModelProperty("修改时间")
private String afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
sync-server/src/main/java/com/zq/sync/vo/Fdx03Vo.java
......@@ -7,6 +7,7 @@ import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
@Data
......@@ -116,4 +117,28 @@ public class Fdx03Vo {
*/
@ApiModelProperty("乡镇")
private String afdx0802;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
sync-server/src/main/java/com/zq/sync/vo/Fdx04Vo.java
......@@ -140,4 +140,28 @@ public class Fdx04Vo {
*/
@ApiModelProperty("乡镇")
private String afdx0802;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
sync-server/src/main/java/com/zq/sync/vo/Fdx05Vo.java
......@@ -7,6 +7,8 @@ import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
@Data
@AllArgsConstructor
......@@ -140,4 +142,28 @@ public class Fdx05Vo {
*/
@ApiModelProperty("乡镇")
private String afdx0802;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
sync-server/src/main/java/com/zq/sync/vo/Fdx06Vo.java
......@@ -283,4 +283,28 @@ public class Fdx06Vo {
*/
@ApiModelProperty("修改时间")
private String afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
sync-server/src/main/java/com/zq/sync/vo/Fdx07Vo.java
......@@ -7,6 +7,8 @@ import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
@Data
@AllArgsConstructor
......@@ -165,4 +167,27 @@ public class Fdx07Vo {
@ApiModelProperty("护理补发人次")
private Integer agax0922;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
sync-server/src/main/java/com/zq/sync/vo/Fdx88Vo.java
......@@ -116,4 +116,28 @@ public class Fdx88Vo {
*/
@ApiModelProperty("修改时间")
private String afdx0818;
/**
* 数据唯一流水号
*/
@ApiModelProperty("数据唯一流水号")
private String serialNumner;
/**
* 数据状态
*/
@ApiModelProperty("数据状态")
private String dataStatus;
/**
* 数据上报时间
*/
@ApiModelProperty("数据上报时间")
private Date dataTime;
/**
* 区划代码
*/
@ApiModelProperty("区划代码")
private String areaCode;
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment