Commit 58fbe0c5 authored by hezhuozhi's avatar hezhuozhi

Merge remote-tracking branch 'origin/developer_bw' into developer_bw

parents 8d94f529 cc88742f
...@@ -27,6 +27,8 @@ public class HouseholdContractPageDto extends Page<HouseholdContract> { ...@@ -27,6 +27,8 @@ public class HouseholdContractPageDto extends Page<HouseholdContract> {
*/ */
private String status; private String status;
private String projectAddress;
/** /**
* 农户id * 农户id
*/ */
......
...@@ -101,4 +101,6 @@ public class PowerStationDto extends BaseDto { ...@@ -101,4 +101,6 @@ public class PowerStationDto extends BaseDto {
private String realScale; private String realScale;
@ApiModelProperty(value = "省份") @ApiModelProperty(value = "省份")
private String province; private String province;
@ApiModelProperty(value = "制单日期")
private String creatorTime;
} }
...@@ -2,12 +2,14 @@ package com.yeejoin.amos.boot.module.hygf.api.dto; ...@@ -2,12 +2,14 @@ package com.yeejoin.amos.boot.module.hygf.api.dto;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto; import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
import com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoneyLog;
import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModel;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* 发货单 * 发货单
......
...@@ -23,6 +23,12 @@ public class WorkOrderPage { ...@@ -23,6 +23,12 @@ public class WorkOrderPage {
@ApiModelProperty(value = "农户信息编号") @ApiModelProperty(value = "农户信息编号")
private String peasantHouseholdNo; private String peasantHouseholdNo;
@ApiModelProperty(value = "开发商")
private String developerName;
@ApiModelProperty(value = "区域公司")
private String regionalCompaniesName;
@ApiModelProperty(value = "派工单编号") @ApiModelProperty(value = "派工单编号")
private String workOrderNum; private String workOrderNum;
......
...@@ -12,6 +12,7 @@ import lombok.experimental.Accessors; ...@@ -12,6 +12,7 @@ import lombok.experimental.Accessors;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* 发货单 * 发货单
...@@ -153,11 +154,16 @@ public class PreparationMoney extends BaseEntity { ...@@ -153,11 +154,16 @@ public class PreparationMoney extends BaseEntity {
@TableField(exist = false) @TableField(exist = false)
private List<HygfReplenishment> files; private List<HygfReplenishment> files;
@TableField(exist = false)
private List<Map> replenishmentFile; //补货单
@TableField(exist = false) @TableField(exist = false)
private String instanceId; //发货单流水 private String instanceId; //发货单流水
//订单状态 //订单状态
@TableField("order_status") @TableField("order_status")
private String orderStatus; private String orderStatus;
@TableField(exist = false)
private String delFile;
@TableField(exist = false)
private String arrFile;
} }
...@@ -23,8 +23,9 @@ public interface PowerStationMapper extends BaseMapper<PowerStation> { ...@@ -23,8 +23,9 @@ public interface PowerStationMapper extends BaseMapper<PowerStation> {
@Param("regionalCompaniesName") String regionalCompaniesName, @Param("processStatus") String processStatus, @Param("regionalCompaniesName") String regionalCompaniesName, @Param("processStatus") String processStatus,
@Param("province") String province, @Param("province") String province,
@Param("projectAddress") String projectAddress, @Param("projectAddress") String projectAddress,
@Param("status") String status); @Param("status") String status,
@Param("startTime") String startTime,
@Param("endTime") String endTime);
String getInstanceIdByhouseId(String peasantHouseholdId); String getInstanceIdByhouseId(String peasantHouseholdId);
List<Map<String, Object>> getKcCreateTime(); List<Map<String, Object>> getKcCreateTime();
......
...@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage; ...@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants; import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.yeejoin.amos.boot.module.hygf.api.config.UserEmpower; import com.yeejoin.amos.boot.module.hygf.api.config.UserEmpower;
import com.yeejoin.amos.boot.module.hygf.api.dto.PreparationDto; import com.yeejoin.amos.boot.module.hygf.api.dto.PreparationDto;
import com.yeejoin.amos.boot.module.hygf.api.dto.PreparationMoneyDto;
import com.yeejoin.amos.boot.module.hygf.api.dto.PreparationPageDto; import com.yeejoin.amos.boot.module.hygf.api.dto.PreparationPageDto;
import com.yeejoin.amos.boot.module.hygf.api.entity.PeasantHousehold; import com.yeejoin.amos.boot.module.hygf.api.entity.PeasantHousehold;
import com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoney; import com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoney;
...@@ -24,18 +25,20 @@ import java.util.Map; ...@@ -24,18 +25,20 @@ import java.util.Map;
public interface PreparationMoneyMapper extends BaseMapper<PreparationMoney> { public interface PreparationMoneyMapper extends BaseMapper<PreparationMoney> {
List<PeasantHousehold> getPeasantHouseholdData(@Param("sequenceNbr") Long sequenceNbr,@Param("ownersName") String ownersName, @Param("projectAddress") String projectAddress); List<PeasantHousehold> getPeasantHouseholdData(@Param("sequenceNbr") Long sequenceNbr, @Param("ownersName") String ownersName, @Param("projectAddress") String projectAddress);
@UserEmpower(field ={"regional_companies_code"} ,dealerField={"amos_unit_org_code","regional_companies_code"} ,fieldConditions ={"eq","in"} ,relationship="and") @UserEmpower(field = {"regional_companies_code"}, dealerField = {"amos_unit_org_code", "regional_companies_code"}, fieldConditions = {"eq", "in"}, relationship = "and")
List<PreparationMoney> selectPageList(@Param(value = "dto") PreparationDto preparationDto); List<PreparationMoney> selectPageList(@Param(value = "dto") PreparationDto preparationDto);
@UserEmpower(field ={"regional_companies_code"} ,dealerField={"developer_code","regional_companies_code"} ,fieldConditions ={"eq","in"} ,relationship="and") @UserEmpower(field = {"regional_companies_code"}, dealerField = {"developer_code", "regional_companies_code"}, fieldConditions = {"eq", "in"}, relationship = "and")
List<Map<String,Object>> preparationStation (@Param(value = "preparationMoneyState") String preparationMoneyState, List<Map<String, Object>> preparationStation(@Param(value = "preparationMoneyState") String preparationMoneyState,
@Param(value = "ownersName") String ownersName, @Param(value = "ownersName") String ownersName,
@Param(value = "regionalCompaniesSeq") String regionalCompaniesSeq, @Param(value = "regionalCompaniesSeq") String regionalCompaniesSeq,
@Param(value = "developerId") String developerId, @Param(value = "developerId") String developerId,
@Param(value = "state") String state, @Param(value = "state") String state,
@Param(value = "province") String province, @Param(value = "province") String province,
@Param(value = "projectAddress") String projectAddress); @Param(value = "projectAddress") String projectAddress,
@Param(value = "startTime") String startTime,
@Param(value = "endTime") String endTime);
PreparationMoney selectPreparationMoneyInfo(@Param(value = "peasantHouseholdId") String peasantHouseholdId);
} }
...@@ -47,6 +47,12 @@ ...@@ -47,6 +47,12 @@
<if test="map.amosDealerId!=null and map.amosDealerId!=''"> <if test="map.amosDealerId!=null and map.amosDealerId!=''">
and hygf_work_order.amos_dealer_id = #{map.amosDealerId} and hygf_work_order.amos_dealer_id = #{map.amosDealerId}
</if> </if>
<if test="map.developerName!=null and map.developerName!=''">
and hph.developer_name like concat('%',#{map.developerName},'%')
</if>
<if test="map.regionalCompaniesName!=null and map.regionalCompaniesName!=''">
and hph.regional_companies_name like concat('%',#{map.regionalCompaniesName},'%')
</if>
<if test="map.regionCompanyId!=null and map.regionCompanyId!=''"> <if test="map.regionCompanyId!=null and map.regionCompanyId!=''">
and hygf_work_order.region_company_id =#{map.regionCompanyId} and hygf_work_order.region_company_id =#{map.regionCompanyId}
</if> </if>
...@@ -56,8 +62,11 @@ ...@@ -56,8 +62,11 @@
<if test="map.formType != null and map.formType!=''"> <if test="map.formType != null and map.formType!=''">
AND hbga.acceptance_check_status IN ('2', '3', '4') AND hbga.acceptance_check_status IN ('2', '3', '4')
</if> </if>
<if test="map.projectAddress != null and map.projectAddress!=''"> <if test="map.projectAddress != null and map.projectAddress != '' and map.projectAddress.contains('/'.toString())">
AND hph.project_address_name LIKE concat(concat('%', #{map.projectAddress}), '%') AND hph.project_address_name LIKE CONCAT('%', #{map.projectAddress}, '%')
</if>
<if test="map.projectAddress != null and map.projectAddress != '' and !map.projectAddress.contains('/'.toString())">
AND REPLACE(hph.project_address_name, '/', '') LIKE CONCAT('%', #{map.projectAddress}, '%')
</if> </if>
<if test="map.type != null"> <if test="map.type != null">
and ( (hbga.basic_grid_node is not null AND hbga.basic_grid_node != 'jxsAdmin') and ( (hbga.basic_grid_node is not null AND hbga.basic_grid_node != 'jxsAdmin')
......
...@@ -61,11 +61,20 @@ ...@@ -61,11 +61,20 @@
<if test="map.powerStationCode!=null and map.powerStationCode!=''"> <if test="map.powerStationCode!=null and map.powerStationCode!=''">
and hph.peasant_household_no like concat('%',#{map.powerStationCode},'%') and hph.peasant_household_no like concat('%',#{map.powerStationCode},'%')
</if> </if>
<if test="map.developerName!=null and map.developerName!=''">
and hph.developer_name like concat('%',#{map.developerName},'%')
</if>
<if test="map.regionalCompaniesName!=null and map.regionalCompaniesName!=''">
and hph.regional_companies_name like concat('%',#{map.regionalCompaniesName},'%')
</if>
<if test="map.formType != null and map.formType!=''"> <if test="map.formType != null and map.formType!=''">
AND hbga.grid_status IN ('2', '3', '4') AND hbga.grid_status IN ('2', '3', '4')
</if> </if>
<if test="map.projectAddress != null and map.projectAddress!=''"> <if test="map.projectAddress != null and map.projectAddress != '' and map.projectAddress.contains('/'.toString())">
AND hph.project_address_name LIKE concat(concat('%', #{map.projectAddress}), '%') AND hph.project_address_name LIKE CONCAT('%', #{map.projectAddress}, '%')
</if>
<if test="map.projectAddress != null and map.projectAddress != '' and !map.projectAddress.contains('/'.toString())">
AND REPLACE(hph.project_address_name, '/', '') LIKE CONCAT('%', #{map.projectAddress}, '%')
</if> </if>
<if test="map.type != null"> <if test="map.type != null">
AND ( (hbga.basic_grid_node IS NOT NULL AND hbga.basic_grid_node != 'jxsAdmin' ) AND ( (hbga.basic_grid_node IS NOT NULL AND hbga.basic_grid_node != 'jxsAdmin' )
......
...@@ -18,6 +18,7 @@ ...@@ -18,6 +18,7 @@
CONCAT(info.disbursement_money,'') as disbursementMoney, CONCAT(info.disbursement_money,'') as disbursementMoney,
hph.regional_companies_code, hph.regional_companies_code,
hph.developer_code, hph.developer_code,
hph.developer_name developerName,
hph.is_history isHistory, hph.is_history isHistory,
info.financing_companies_name financingCompaniesName info.financing_companies_name financingCompaniesName
FROM FROM
...@@ -29,6 +30,15 @@ ...@@ -29,6 +30,15 @@
<if test="params.ownersName != null and params.ownersName !=''"> <if test="params.ownersName != null and params.ownersName !=''">
and hph.owners_name like concat('%',#{params.ownersName},'%') and hph.owners_name like concat('%',#{params.ownersName},'%')
</if> </if>
<if test="params.peasantHouseholdNo != null and params.peasantHouseholdNo !=''">
and hph.peasant_household_no like concat('%',#{params.peasantHouseholdNo},'%')
</if>
<if test="params.developerName != null and params.developerName !=''">
and hph.developer_name like concat('%',#{params.developerName},'%')
</if>
<if test="params.financingCompaniesName != null and params.financingCompaniesName !=''">
and info.financing_companies_name like concat('%',#{params.financingCompaniesName},'%')
</if>
<if test="params.isHistory != null and params.isHistory !='' and params.type != 2 "> <if test="params.isHistory != null and params.isHistory !='' and params.type != 2 ">
and hph.is_history is not null and hph.is_history is not null
</if> </if>
...@@ -50,7 +60,12 @@ ...@@ -50,7 +60,12 @@
<if test="params.peasantHouseholdNo != null and params.peasantHouseholdNo !='' "> <if test="params.peasantHouseholdNo != null and params.peasantHouseholdNo !='' ">
and hph.peasant_household_no = #{params.peasantHouseholdNo} and hph.peasant_household_no = #{params.peasantHouseholdNo}
</if> </if>
<if test="params.projectAddress != null and params.projectAddress != '' and params.projectAddress.contains('/'.toString())">
AND concat(hph.project_address_name,hph.project_address_detail) LIKE CONCAT('%', #{params.projectAddress}, '%')
</if>
<if test="params.projectAddress != null and params.projectAddress != '' and !params.projectAddress.contains('/'.toString())">
AND REPLACE(concat(hph.project_address_name,hph.project_address_detail), '/', '') LIKE CONCAT('%', #{params.projectAddress}, '%')
</if>
</where> </where>
ORDER BY ORDER BY
info.rec_date DESC ,hph.sequence_nbr DESC ) as sta info.rec_date DESC ,hph.sequence_nbr DESC ) as sta
......
...@@ -18,6 +18,12 @@ ...@@ -18,6 +18,12 @@
<if test="dto.status != null and dto.status !=''"> <if test="dto.status != null and dto.status !=''">
and hygf_household_contract.status = #{dto.status} and hygf_household_contract.status = #{dto.status}
</if> </if>
<if test="dto.projectAddress != null and dto.projectAddress != '' and dto.projectAddress.contains('/'.toString())">
AND hygf_household_contract.project_address_name LIKE CONCAT('%', #{dto.projectAddress}, '%')
</if>
<if test="dto.projectAddress != null and dto.projectAddress != '' and !dto.projectAddress.contains('/'.toString())">
AND REPLACE(hygf_household_contract.project_address_name, '/', '') LIKE CONCAT('%', #{dto.projectAddress}, '%')
</if>
<if test="dto.name != null and dto.name !='' "> <if test="dto.name != null and dto.name !='' ">
and hygf_household_contract.name like concat('%',#{dto.name},'%') and hygf_household_contract.name like concat('%',#{dto.name},'%')
</if> </if>
......
...@@ -34,7 +34,8 @@ ...@@ -34,7 +34,8 @@
ph.project_address_detail, ph.project_address_detail,
SUBSTRING_INDEX(ph.project_address_name, '/', 1) AS province, SUBSTRING_INDEX(ph.project_address_name, '/', 1) AS province,
lc.stamp_status, lc.stamp_status,
lc.status lc.status,
hsi.creator_time
FROM FROM
hygf_power_station ps hygf_power_station ps
LEFT JOIN ( LEFT JOIN (
...@@ -56,6 +57,7 @@ ...@@ -56,6 +57,7 @@
ON lc.peasant_household_id = ps.peasant_household_id ON lc.peasant_household_id = ps.peasant_household_id
LEFT JOIN hygf_peasant_household ph LEFT JOIN hygf_peasant_household ph
ON ph.sequence_nbr = ps.peasant_household_id ON ph.sequence_nbr = ps.peasant_household_id
LEFT JOIN (select sequence_nbr, creator_time from hygf_survey_information ) hsi on ph.survey_information_id = hsi.sequence_nbr
WHERE WHERE
ps.is_delete = 0 ps.is_delete = 0
<if test="powerStationCode != null and powerStationCode != ''"> <if test="powerStationCode != null and powerStationCode != ''">
...@@ -80,11 +82,17 @@ ...@@ -80,11 +82,17 @@
AND ps.process_status = #{processStatus} AND ps.process_status = #{processStatus}
</if> </if>
<if test="province != null and province != ''"> <if test="province != null and province != ''">
AND ph.project_address_name LIKE CONCAT('%', #{province}, '%') AND ph.project_address LIKE CONCAT('%', #{province}, '%')
</if> </if>
<if test="status != null and status != ''"> <if test="status != null and status != ''">
AND lc.status = #{status} AND lc.status = #{status}
</if> </if>
<if test="startTime != null and startTime != ''">
AND hsi.creator_time &gt;= #{startTime}
</if>
<if test="endTime != null and endTime != ''">
AND hsi.creator_time &lt;= #{endTime}
</if>
ORDER BY ps.rec_date DESC ORDER BY ps.rec_date DESC
</select> </select>
<select id="getInstanceIdByhouseId" resultType="java.lang.String"> <select id="getInstanceIdByhouseId" resultType="java.lang.String">
......
...@@ -89,6 +89,12 @@ LEFT JOIN hygf_document_station on hygf_document_station.station_id=hygf_peasan ...@@ -89,6 +89,12 @@ LEFT JOIN hygf_document_station on hygf_document_station.station_id=hygf_peasan
<if test="province != null and province != ''"> <if test="province != null and province != ''">
and hygf_peasant_household.project_address like concat(concat('%',#{province}),'%') and hygf_peasant_household.project_address like concat(concat('%',#{province}),'%')
</if> </if>
<if test="startTime != null and startTime != ''">
and hygf_preparation_money.delivery_time &gt;= #{startTime}
</if>
<if test="endTime != null and endTime != ''">
and hygf_preparation_money.delivery_time &lt;= #{endTime}
</if>
<if test="projectAddress != null and projectAddress != '' and projectAddress.contains('/'.toString())"> <if test="projectAddress != null and projectAddress != '' and projectAddress.contains('/'.toString())">
AND concat_ws('/',hygf_peasant_household.project_address_name,hygf_peasant_household.project_address_detail) LIKE CONCAT('%', #{projectAddress}, '%') AND concat_ws('/',hygf_peasant_household.project_address_name,hygf_peasant_household.project_address_detail) LIKE CONCAT('%', #{projectAddress}, '%')
</if> </if>
...@@ -106,4 +112,16 @@ LEFT JOIN hygf_document_station on hygf_document_station.station_id=hygf_peasan ...@@ -106,4 +112,16 @@ LEFT JOIN hygf_document_station on hygf_document_station.station_id=hygf_peasan
) b ) b
</select> </select>
<select id="selectPreparationMoneyInfo" resultType="com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoney">
SELECT
*,
delivery_file as delFile,
arrival_file as arrFile
FROM
`hygf_preparation_money` pm
LEFT JOIN hygf_document_station ds ON ds.preparation_money_id = pm.sequence_nbr
WHERE
ds.station_id = #{peasantHouseholdId}
</select>
</mapper> </mapper>
...@@ -112,7 +112,7 @@ ...@@ -112,7 +112,7 @@
<select id="preparationMoneyTotal" resultType="map"> <select id="preparationMoneyTotal" resultType="map">
SELECT SELECT
SUM( CASE WHEN preparation_money_state = '待发货' or preparation_money_state = '暂存发货'or preparation_money_state = '待补货' THEN 1 ELSE 0 END ) AS '待发货', SUM( CASE WHEN preparation_money_state = '待发货' or preparation_money_state = '暂存发货'or preparation_money_state = '待补货' THEN 1 ELSE 0 END ) AS '待发货',
SUM( CASE WHEN preparation_money_state = '备货完成' THEN 1 ELSE 0 END ) AS '已收货', SUM( CASE WHEN preparation_money_state = '备货完成' or preparation_money_state = '已收货' THEN 1 ELSE 0 END ) AS '已收货',
SUM( CASE WHEN preparation_money_state = '待收货' THEN 1 ELSE 0 END ) AS '已发货' SUM( CASE WHEN preparation_money_state = '待收货' THEN 1 ELSE 0 END ) AS '已发货'
FROM FROM
hygf_peasant_household hygf_peasant_household
...@@ -138,13 +138,13 @@ ...@@ -138,13 +138,13 @@
<select id="workOrderTotal" resultType="map"> <select id="workOrderTotal" resultType="map">
SELECT SELECT
count(*) AS total, count(*) AS total,
(CASE WHEN power_station_construction_status = '待施工' THEN '派工发料' (CASE
WHEN power_station_construction_status = '未通过' THEN '未通过' WHEN power_station_construction_status = '未通过' THEN '未通过'
WHEN power_station_construction_status = '施工中' or power_station_construction_status = '待登记' THEN '施工资料已上传' WHEN power_station_construction_status = '施工中' or power_station_construction_status = '待施工' THEN '施工资料上传'
WHEN power_station_construction_status = '待审核' and work_order_power_station_node IS NULL THEN '完工登记' WHEN power_station_construction_status = '待登记' THEN '完工登记'
WHEN power_station_construction_status = '待审核' and work_order_power_station_node ='area' THEN '完工自审' WHEN power_station_construction_status = '待审核' and work_order_power_station_node is null THEN '完工自审'
WHEN power_station_construction_status = '已完工' THEN '已完成' WHEN power_station_construction_status = '已完工' THEN '已完成'
WHEN power_station_construction_status = '待审核' and work_order_power_station_node in ('engineering','design') THEN '审核中' WHEN power_station_construction_status = '待审核' and work_order_power_station_node in ('engineering','design','area') THEN '审核中'
ELSE power_station_construction_status END ) ELSE power_station_construction_status END )
AS statusText, AS statusText,
ROUND(COALESCE(SUM(ei.real_scale), 0), 2) AS realScale FROM ROUND(COALESCE(SUM(ei.real_scale), 0), 2) AS realScale FROM
...@@ -270,7 +270,7 @@ ...@@ -270,7 +270,7 @@
'待放款' '待放款'
WHEN info.`status` = '待融资审核' THEN WHEN info.`status` = '待融资审核' THEN
'待审核' '待审核'
WHEN info.`status` = '审核不通过' THEN WHEN info.`status` = '审核不通过' or info.`status` = '重新验收' THEN
'未通过' '未通过'
WHEN info.`status` = '放款完成' THEN WHEN info.`status` = '放款完成' THEN
'放款完成' ELSE '待推送' '放款完成' ELSE '待推送'
...@@ -391,8 +391,8 @@ ...@@ -391,8 +391,8 @@
'' AS kcjxzrl, '' AS kcjxzrl,
SUM(CASE WHEN ps.process_status = '完成' THEN 1 ELSE 0 END) AS kcywc, SUM(CASE WHEN ps.process_status = '完成' THEN 1 ELSE 0 END) AS kcywc,
ROUND(COALESCE(SUM(CASE WHEN ps.process_status = '完成' THEN ei.real_scale ELSE 0 END)/1000, 0), 2) AS kcywcrl, ROUND(COALESCE(SUM(CASE WHEN ps.process_status = '完成' THEN ei.real_scale ELSE 0 END)/1000, 0), 2) AS kcywcrl,
SUM(CASE WHEN ph.preparation_money_state = '备货完成' THEN 1 ELSE 0 END) AS bhywc, SUM(CASE WHEN ph.preparation_money_state = '备货完成' or ph.preparation_money_state = '已收货'THEN 1 ELSE 0 END) AS bhywc,
ROUND(COALESCE(SUM(CASE WHEN ph.preparation_money_state = '备货完成' THEN ei.real_scale ELSE 0 END)/1000, 0), 2) AS bhywcrl, ROUND(COALESCE(SUM(CASE WHEN ph.preparation_money_state = '备货完成'or ph.preparation_money_state = '已收货' THEN ei.real_scale ELSE 0 END)/1000, 0), 2) AS bhywcrl,
SUM(CASE WHEN ph.preparation_money_state = '待发货' or ph.preparation_money_state = '暂存发货'or ph.preparation_money_state = '待补货' THEN 1 ELSE 0 END ) AS bhwtg, SUM(CASE WHEN ph.preparation_money_state = '待发货' or ph.preparation_money_state = '暂存发货'or ph.preparation_money_state = '待补货' THEN 1 ELSE 0 END ) AS bhwtg,
'' AS bhjxzrl, '' AS bhjxzrl,
SUM(CASE WHEN ph.preparation_money_state = '待收货' THEN 1 ELSE 0 END) AS bhjxz, SUM(CASE WHEN ph.preparation_money_state = '待收货' THEN 1 ELSE 0 END) AS bhjxz,
...@@ -611,8 +611,8 @@ ...@@ -611,8 +611,8 @@
<select id="statisticsPreparationMoney" resultType="map"> <select id="statisticsPreparationMoney" resultType="map">
SELECT SELECT
IFNULL(SUM( CASE WHEN preparation_money_state = '待发货' or preparation_money_state = '暂存发货' or preparation_money_state = '待补货' THEN 1 ELSE 0 END ), 0 ) AS dfh, IFNULL(SUM( CASE WHEN preparation_money_state = '待发货' or preparation_money_state = '暂存发货' or preparation_money_state = '待补货' THEN 1 ELSE 0 END ), 0 ) AS dfh,
IFNULL(SUM( CASE WHEN preparation_money_state = '备货完成' THEN 1 ELSE 0 END ), 0 ) AS ysh, IFNULL(SUM( CASE WHEN preparation_money_state = '备货完成' or preparation_money_state = '已收货'THEN 1 ELSE 0 END ), 0 ) AS ysh,
IFNULL(SUM( CASE WHEN preparation_money_state = '备货完成' THEN ei.real_scale ELSE 0 END ), 0 ) AS yshrl, IFNULL(SUM( CASE WHEN preparation_money_state = '备货完成' or preparation_money_state = '已收货'THEN ei.real_scale ELSE 0 END ), 0 ) AS yshrl,
IFNULL(SUM( CASE WHEN preparation_money_state = '待收货' THEN 1 ELSE 0 END ), 0 ) AS yfh IFNULL(SUM( CASE WHEN preparation_money_state = '待收货' THEN 1 ELSE 0 END ), 0 ) AS yfh
FROM FROM
......
...@@ -73,6 +73,8 @@ ...@@ -73,6 +73,8 @@
select select
hygf_peasant_household.sequence_nbr sequenceNbr, hygf_peasant_household.sequence_nbr sequenceNbr,
hygf_peasant_household.peasant_household_no peasantHouseholdNo, hygf_peasant_household.peasant_household_no peasantHouseholdNo,
hygf_peasant_household.developer_name developerName,
hygf_peasant_household.regional_companies_name regionalCompaniesName,
substring_index ( hygf_peasant_household.project_address_name, '/', 1 ) AS province, substring_index ( hygf_peasant_household.project_address_name, '/', 1 ) AS province,
hygf_work_order.work_order_num workOrderNum, hygf_work_order.work_order_num workOrderNum,
hygf_peasant_household.owners_name ownersName, hygf_peasant_household.owners_name ownersName,
...@@ -117,12 +119,18 @@ ...@@ -117,12 +119,18 @@
or hygf_work_order_power_station.power_station_engineering_status is not null or hygf_work_order_power_station.power_station_engineering_status is not null
) )
</if> </if>
<if test="dto.projectAddressName!=null and dto.projectAddressName!=''"> <if test="dto.projectAddressName != null and dto.projectAddressName != '' and dto.projectAddressName.contains('/'.toString())">
and hygf_peasant_household.project_address_name like concat(concat('%',#{dto.projectAddressName}),'%') AND hygf_peasant_household.project_address_name LIKE CONCAT('%', #{dto.projectAddressName}, '%')
</if>
<if test="dto.projectAddressName != null and dto.projectAddressName != '' and !dto.projectAddressName.contains('/'.toString())">
AND REPLACE(hygf_peasant_household.project_address_name, '/', '') LIKE CONCAT('%', #{dto.projectAddressName}, '%')
</if> </if>
<if test="dto.peasantHouseholdNo!=null and dto.peasantHouseholdNo!=''"> <if test="dto.peasantHouseholdNo!=null and dto.peasantHouseholdNo!=''">
and hygf_peasant_household.peasant_household_no like concat(concat('%',#{dto.peasantHouseholdNo}),'%') and hygf_peasant_household.peasant_household_no like concat(concat('%',#{dto.peasantHouseholdNo}),'%')
</if> </if>
<if test="dto.constructionRegionManager!=null and dto.constructionRegionManager!=''">
and hygf_work_order.construction_region_manager like concat(concat('%',#{dto.constructionRegionManager}),'%')
</if>
<if test="dto.ownersName!=null and dto.ownersName!=''"> <if test="dto.ownersName!=null and dto.ownersName!=''">
and hygf_peasant_household.owners_name like concat(concat('%',#{dto.ownersName}),'%') and hygf_peasant_household.owners_name like concat(concat('%',#{dto.ownersName}),'%')
</if> </if>
......
...@@ -206,7 +206,9 @@ public class AcceptanceCheckController extends BaseController { ...@@ -206,7 +206,9 @@ public class AcceptanceCheckController extends BaseController {
@RequestParam(required = false,value = "acceptanceCheckStatus") String acceptanceCheckStatus, @RequestParam(required = false,value = "acceptanceCheckStatus") String acceptanceCheckStatus,
@RequestParam(required = false,value = "type") String type, @RequestParam(required = false,value = "type") String type,
@RequestParam(required = false,value = "acceptanceTime") String acceptanceTime, @RequestParam(required = false,value = "acceptanceTime") String acceptanceTime,
@RequestParam(required = false, value = "province") String province) throws Exception { @RequestParam(required = false, value = "province") String province,
@RequestParam(required = false, value = "developerName") String developerName,
@RequestParam(required = false, value = "regionalCompaniesName") String regionalCompaniesName) throws Exception {
//当前登录人所属场站 //当前登录人所属场站
// UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId()); // UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId());
...@@ -235,7 +237,7 @@ public class AcceptanceCheckController extends BaseController { ...@@ -235,7 +237,7 @@ public class AcceptanceCheckController extends BaseController {
basicGridNodes.add("ys-zichan"); basicGridNodes.add("ys-zichan");
} }
} }
Page<AcceptanceCheckDto> page = acceptanceCheckServiceImpl.selectPage(null,null,current, size, projectAddress, powerStationCode, ownersName, acceptanceCheckStatus, acceptanceTime, "",basicGridNodes,type,province); Page<AcceptanceCheckDto> page = acceptanceCheckServiceImpl.selectPage(null,null,current, size, projectAddress, powerStationCode, ownersName, acceptanceCheckStatus, acceptanceTime, "",basicGridNodes,type,province, developerName, regionalCompaniesName);
//根据角色及当前节点判断是否有操作权限 //根据角色及当前节点判断是否有操作权限
if (basicGridNodes != null){ if (basicGridNodes != null){
for (AcceptanceCheckDto e : page.getRecords()) { for (AcceptanceCheckDto e : page.getRecords()) {
......
...@@ -151,7 +151,9 @@ public class BasicGridAcceptanceController extends BaseController { ...@@ -151,7 +151,9 @@ public class BasicGridAcceptanceController extends BaseController {
@RequestParam(required = false, value = "gridStatus") String gridStatus, @RequestParam(required = false, value = "gridStatus") String gridStatus,
@RequestParam(required = false, value = "type") String type, @RequestParam(required = false, value = "type") String type,
@RequestParam(required = false, value = "gridConnectionTime") String gridConnectionTime, @RequestParam(required = false, value = "gridConnectionTime") String gridConnectionTime,
@RequestParam(required = false, value = "province") String province) throws Exception { @RequestParam(required = false, value = "province") String province,
@RequestParam(required = false, value = "developerName") String developerName,
@RequestParam(required = false, value = "regionalCompaniesName") String regionalCompaniesName) throws Exception {
// 当前登录人所属场站 // 当前登录人所属场站
// UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId()); // UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId());
...@@ -178,7 +180,7 @@ public class BasicGridAcceptanceController extends BaseController { ...@@ -178,7 +180,7 @@ public class BasicGridAcceptanceController extends BaseController {
} }
Page<BasicGridRecordDto> page = basicGridAcceptanceServiceImpl.selectPage(null, null, current, size, Page<BasicGridRecordDto> page = basicGridAcceptanceServiceImpl.selectPage(null, null, current, size,
projectAddress, powerStationCode, ownersName, gridStatus, gridConnectionTime, "", basicGridNodes, type, projectAddress, powerStationCode, ownersName, gridStatus, gridConnectionTime, "", basicGridNodes, type,
province); province, developerName, regionalCompaniesName);
// 根据角色及当前节点判断是否有操作权限 // 根据角色及当前节点判断是否有操作权限
if (basicGridNodes != null) { if (basicGridNodes != null) {
for (BasicGridRecordDto e : page.getRecords()) { for (BasicGridRecordDto e : page.getRecords()) {
...@@ -218,7 +220,7 @@ public class BasicGridAcceptanceController extends BaseController { ...@@ -218,7 +220,7 @@ public class BasicGridAcceptanceController extends BaseController {
// 当前登录人所属场站 // 当前登录人所属场站
Page<BasicGridRecordDto> page = basicGridAcceptanceServiceImpl.selectPage(null, null, current, size, Page<BasicGridRecordDto> page = basicGridAcceptanceServiceImpl.selectPage(null, null, current, size,
projectAddress, powerStationCode, ownersName, gridStatus, gridConnectionTime, "check", null, null,province); projectAddress, powerStationCode, ownersName, gridStatus, gridConnectionTime, "check", null, null,province, null, null);
return ResponseHelper.buildResponse(page); return ResponseHelper.buildResponse(page);
} }
......
...@@ -166,11 +166,15 @@ public class FinancingInfoController extends BaseController { ...@@ -166,11 +166,15 @@ public class FinancingInfoController extends BaseController {
@RequestParam(value = "region" ,required = false) String region , @RequestParam(value = "region" ,required = false) String region ,
@RequestParam(value = "batchNo" ,required = false) String batchNo , @RequestParam(value = "batchNo" ,required = false) String batchNo ,
@RequestParam(value = "isHistory" ,required = false) String isHistory , @RequestParam(value = "isHistory" ,required = false) String isHistory ,
@RequestParam(value = "ownersName",required = false) String ownersName){ @RequestParam(value = "ownersName",required = false) String ownersName,
@RequestParam(value = "projectAddress",required = false) String projectAddress,
@RequestParam(value = "peasantHouseholdNo",required = false) String peasantHouseholdNo,
@RequestParam(value = "developerName",required = false) String developerName,
@RequestParam(value = "financingCompaniesName",required = false) String financingCompaniesName){
Page<Map<String, Object>> page = new Page<Map<String, Object>>(); Page<Map<String, Object>> page = new Page<Map<String, Object>>();
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(financingInfoServiceImpl.queryForFinancingInfoPage(page,type,status,regionalCompaniesCode,ownersName, region,batchNo,isHistory)); return ResponseHelper.buildResponse(financingInfoServiceImpl.queryForFinancingInfoPage(page,type,status,regionalCompaniesCode,ownersName, region,batchNo,isHistory, projectAddress, peasantHouseholdNo, developerName, financingCompaniesName));
} }
/** /**
......
...@@ -107,12 +107,14 @@ public class PowerStationController extends BaseController { ...@@ -107,12 +107,14 @@ public class PowerStationController extends BaseController {
@RequestParam(value = "regionalCompaniesName",required = false)String regionalCompaniesName, @RequestParam(value = "regionalCompaniesName",required = false)String regionalCompaniesName,
@RequestParam(value = "province",required = false)String province, @RequestParam(value = "province",required = false)String province,
@RequestParam(value = "projectAddress",required = false)String projectAddress, @RequestParam(value = "projectAddress",required = false)String projectAddress,
@RequestParam(value = "status",required = false)String status) { @RequestParam(value = "status",required = false)String status,
@RequestParam(value = "startTime",required = false)String startTime,
@RequestParam(value = "endTime",required = false)String endTime) {
Page<PowerStationDto> page = new Page<PowerStationDto>(); Page<PowerStationDto> page = new Page<PowerStationDto>();
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
AgencyUserModel userInfo = getUserInfo(); AgencyUserModel userInfo = getUserInfo();
return ResponseHelper.buildResponse(powerStationServiceImpl.queryForPowerStationUserRoles(page,powerStationCode,ownersName,userInfo,serviceAgent,regionalCompaniesName,processStatus,province, projectAddress, status)); return ResponseHelper.buildResponse(powerStationServiceImpl.queryForPowerStationUserRoles(page,powerStationCode,ownersName,userInfo,serviceAgent,regionalCompaniesName,processStatus,province, projectAddress, status, startTime, endTime));
} }
/** /**
......
...@@ -346,9 +346,11 @@ public class PreparationMoneyController extends BaseController { ...@@ -346,9 +346,11 @@ public class PreparationMoneyController extends BaseController {
@RequestParam(value = "state",required = false) String state, @RequestParam(value = "state",required = false) String state,
@RequestParam(value = "preparationMoneyState") String preparationMoneyState, @RequestParam(value = "preparationMoneyState") String preparationMoneyState,
@RequestParam(value = "province",required = false) String province, @RequestParam(value = "province",required = false) String province,
@RequestParam(value = "projectAddress",required = false) String projectAddress){ @RequestParam(value = "projectAddress",required = false) String projectAddress,
@RequestParam(value = "startTime",required = false) String startTime,
@RequestParam(value = "endTime",required = false) String endTime){
return ResponseHelper.buildResponse(preparationMoneyServiceImpl.preparationStation(current,size,preparationMoneyState,ownersName,regionalcompaniesSeq,developerId,state,province, projectAddress)) ; return ResponseHelper.buildResponse(preparationMoneyServiceImpl.preparationStation(current,size,preparationMoneyState,ownersName,regionalcompaniesSeq,developerId,state,province, projectAddress, startTime, endTime)) ;
} }
......
...@@ -70,7 +70,7 @@ public class AcceptanceCheckServiceImpl extends BaseService<AcceptanceCheckDto,A ...@@ -70,7 +70,7 @@ public class AcceptanceCheckServiceImpl extends BaseService<AcceptanceCheckDto,A
public Page<AcceptanceCheckDto> selectPage(Long regionCompanyId, Long amosDealerId, int current, int size, public Page<AcceptanceCheckDto> selectPage(Long regionCompanyId, Long amosDealerId, int current, int size,
String projectAddress, String powerStationCode, String ownersName, String acceptanceCheckStatus, String projectAddress, String powerStationCode, String ownersName, String acceptanceCheckStatus,
String gridConnectionTime, String formType, List<String> basicGridNodes, String type,String province) throws Exception { String gridConnectionTime, String formType, List<String> basicGridNodes, String type,String province, String developerName, String regionalCompaniesName) throws Exception {
PageHelper.startPage(current, size); PageHelper.startPage(current, size);
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
Date date = null; Date date = null;
...@@ -88,6 +88,8 @@ public class AcceptanceCheckServiceImpl extends BaseService<AcceptanceCheckDto,A ...@@ -88,6 +88,8 @@ public class AcceptanceCheckServiceImpl extends BaseService<AcceptanceCheckDto,A
map.put("basicGridNodes",basicGridNodes); map.put("basicGridNodes",basicGridNodes);
map.put("type",type); map.put("type",type);
map.put("province",province); map.put("province",province);
map.put("developerName", developerName);
map.put("regionalCompaniesName", regionalCompaniesName);
List<AcceptanceCheckDto> list = acceptanceCheckMapper.selectPageList(map); List<AcceptanceCheckDto> list = acceptanceCheckMapper.selectPageList(map);
if(list != null && list.size() > 0) { if(list != null && list.size() > 0) {
......
...@@ -100,7 +100,7 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta ...@@ -100,7 +100,7 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta
public Page<BasicGridRecordDto> selectPage(Long regionCompanyId, Long amosDealerId, int current, int size, public Page<BasicGridRecordDto> selectPage(Long regionCompanyId, Long amosDealerId, int current, int size,
String projectAddress, String powerStationCode, String ownersName, String gridStatus, String projectAddress, String powerStationCode, String ownersName, String gridStatus,
String gridConnectionTime, String formType, List<String> basicGridNodes, String type, String province) String gridConnectionTime, String formType, List<String> basicGridNodes, String type, String province, String developerName, String regionalCompaniesName)
throws Exception { throws Exception {
PageHelper.startPage(current, size); PageHelper.startPage(current, size);
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
...@@ -119,6 +119,8 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta ...@@ -119,6 +119,8 @@ public class BasicGridAcceptanceServiceImpl extends BaseService<BasicGridAccepta
map.put("basicGridNodes", basicGridNodes); map.put("basicGridNodes", basicGridNodes);
map.put("type", type); map.put("type", type);
map.put("province", province); map.put("province", province);
map.put("developerName", developerName);
map.put("regionalCompaniesName", regionalCompaniesName);
List<BasicGridRecordDto> list = basicGridAcceptanceMapper.selectPageList(map); List<BasicGridRecordDto> list = basicGridAcceptanceMapper.selectPageList(map);
PageInfo<BasicGridRecordDto> page = new PageInfo(list); PageInfo<BasicGridRecordDto> page = new PageInfo(list);
Page<BasicGridRecordDto> pageNew = new Page<>(); Page<BasicGridRecordDto> pageNew = new Page<>();
......
...@@ -3,9 +3,12 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl; ...@@ -3,9 +3,12 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.map.MapBuilder; import cn.hutool.core.map.MapBuilder;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.google.common.net.HttpHeaders; import com.google.common.net.HttpHeaders;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.biz.common.utils.DateUtils; import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
import com.yeejoin.amos.boot.biz.common.utils.RedisUtils; import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
...@@ -44,6 +47,7 @@ import org.springframework.core.io.Resource; ...@@ -44,6 +47,7 @@ import org.springframework.core.io.Resource;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.typroject.tyboot.core.foundation.utils.Bean;
import javax.servlet.ServletOutputStream; import javax.servlet.ServletOutputStream;
...@@ -106,6 +110,16 @@ public class CommonServiceImpl { ...@@ -106,6 +110,16 @@ public class CommonServiceImpl {
@Autowired @Autowired
ConstructionRecordsMapper constructionRecordsMapper; ConstructionRecordsMapper constructionRecordsMapper;
@Autowired @Autowired
PreparationMoneyServiceImpl preparationMoneyService;
@Autowired
PreparationMoneyMapper preparationMoneyMapper;
@Autowired
private HygfReplenishmentMapper hygfReplenishmentMapper;
@Autowired
PreparationMoneyLogMapper preparationMoneyLogMapper;
@Autowired
HygfPreparationMoneyAuditingMapper preparationMoneyAuditingMapper;
@Autowired
ConstructionGirdRecordsMapper constructionGirdRecordsMapper; ConstructionGirdRecordsMapper constructionGirdRecordsMapper;
@Autowired @Autowired
ConstructionAcceptanceRecordsMapper constructionAcceptanceRecordsMapper; ConstructionAcceptanceRecordsMapper constructionAcceptanceRecordsMapper;
...@@ -555,6 +569,47 @@ public class CommonServiceImpl { ...@@ -555,6 +569,47 @@ public class CommonServiceImpl {
for (String peasantHouseholdId : peasantHouseholdIds) { for (String peasantHouseholdId : peasantHouseholdIds) {
SurveyInfoAllDto returnDto = surveyInformationServiceImpl.querySurveyInfo(surveyInformationId, peasantHouseholdId, processInstanceId, null); SurveyInfoAllDto returnDto = surveyInformationServiceImpl.querySurveyInfo(surveyInformationId, peasantHouseholdId, processInstanceId, null);
fileName = returnDto.getSurveyInformation().getOwnersName(); fileName = returnDto.getSurveyInformation().getOwnersName();
//客户优化项 补充发货信息
PreparationMoney preparationMoneyDto = preparationMoneyMapper.selectPreparationMoneyInfo(peasantHouseholdId);
String preparationMoneyInstanceId = null;
if (null != preparationMoneyDto){
preparationMoneyDto.setDeliveryFile(null != preparationMoneyDto.getDelFile()?JSONArray.parseArray(preparationMoneyDto.getDelFile()):null);
preparationMoneyDto.setArrivalFile(null != preparationMoneyDto.getArrFile()?JSONArray.parseArray(preparationMoneyDto.getArrFile()):null);
LambdaUpdateWrapper<PreparationMoneyLog> q1 = new LambdaUpdateWrapper<>();
q1.eq(PreparationMoneyLog::getPreparationMoneyId, preparationMoneyDto.getSequenceNbr());
q1.orderByAsc(PreparationMoneyLog::getExecutionTime);
List<PreparationMoneyLog> preparationMoneyLogs = preparationMoneyLogMapper.selectList(q1);
if (!Objects.isNull(preparationMoneyLogs)){
preparationMoneyDto.setPreparationMoneyLog(preparationMoneyLogs);
}
LambdaUpdateWrapper<HygfPreparationMoneyAuditing> q2 = new LambdaUpdateWrapper<>();
q2.eq(HygfPreparationMoneyAuditing::getPreparationMoneyId, preparationMoneyDto.getSequenceNbr());
q2.orderByAsc(HygfPreparationMoneyAuditing::getRecDate);
q2.last("limit 1");
HygfPreparationMoneyAuditing hygfPreparationMoneyAuditing = preparationMoneyAuditingMapper.selectOne(q2);
if (null != hygfPreparationMoneyAuditing){
preparationMoneyInstanceId = hygfPreparationMoneyAuditing.getInstanceId();
}
//查询补货单
LambdaQueryWrapper<HygfReplenishment> files = new LambdaQueryWrapper<>();
files.eq(HygfReplenishment::getPreparationMoneyId,preparationMoneyDto.getSequenceNbr());
files.orderByDesc(BaseEntity::getRecDate);
List<HygfReplenishment> hygfReplenishments = hygfReplenishmentMapper.selectList(files);
List<Map> hygfReplenishmentFiles = new ArrayList<>();
if (CollectionUtil.isNotEmpty(hygfReplenishments)){
for (HygfReplenishment hygfReplenishment : hygfReplenishments) {
hygfReplenishmentFiles.addAll(hygfReplenishment.getFile());
}
preparationMoneyDto.setReplenishmentFile(hygfReplenishmentFiles);
}
}
if (!redisKey.contains(",")){ if (!redisKey.contains(",")){
redisUtils.set(redisKey, MapBuilder.<String, Object>create() redisUtils.set(redisKey, MapBuilder.<String, Object>create()
.put("value", currentBili).build()); .put("value", currentBili).build());
...@@ -566,6 +621,7 @@ public class CommonServiceImpl { ...@@ -566,6 +621,7 @@ public class CommonServiceImpl {
List<ConstructionRecords> workOrderStationWorkLog = new ArrayList<>(); List<ConstructionRecords> workOrderStationWorkLog = new ArrayList<>();
List<ConstructionGirdRecords> basicGridWorkLog = new ArrayList<>(); List<ConstructionGirdRecords> basicGridWorkLog = new ArrayList<>();
List<LinkedHashMap> financingWorkLog = new ArrayList<>(); List<LinkedHashMap> financingWorkLog = new ArrayList<>();
List<LinkedHashMap> preparationMoneyLog = new ArrayList<>();
List<ConstructionAcceptanceRecords> accptWorkLog = new ArrayList<>(); List<ConstructionAcceptanceRecords> accptWorkLog = new ArrayList<>();
workOrderStationWorkLog = this.getConstructionRecords(returnDto.getPowerStationEngineeringInfo().getWorkOrderPowerStationId(),returnDto.getPowerStationEngineeringInfo().getWorkOrderId()); workOrderStationWorkLog = this.getConstructionRecords(returnDto.getPowerStationEngineeringInfo().getWorkOrderPowerStationId(),returnDto.getPowerStationEngineeringInfo().getWorkOrderId());
accptWorkLog = this.getConstructionRecordsAcc(peasantHouseholdId); accptWorkLog = this.getConstructionRecordsAcc(peasantHouseholdId);
...@@ -574,6 +630,7 @@ public class CommonServiceImpl { ...@@ -574,6 +630,7 @@ public class CommonServiceImpl {
try { try {
powerStationWorkLog = this.getWorkLog(powerStationInstanceId); powerStationWorkLog = this.getWorkLog(powerStationInstanceId);
financingWorkLog = this.getWorkLog(financingInstanceId); financingWorkLog = this.getWorkLog(financingInstanceId);
preparationMoneyLog = this.getWorkLog(preparationMoneyInstanceId);
}catch (Exception e){ }catch (Exception e){
e.printStackTrace(); e.printStackTrace();
...@@ -624,32 +681,42 @@ public class CommonServiceImpl { ...@@ -624,32 +681,42 @@ public class CommonServiceImpl {
Sheet secondSheet6 = workbook.getSheetAt(6); Sheet secondSheet6 = workbook.getSheetAt(6);
fillSheet(secondSheet6, returnDto.getPowerStationEngineeringInfo()); fillSheet(secondSheet6, returnDto.getPowerStationEngineeringInfo());
Sheet secondSheet10 = workbook.getSheetAt(7); Sheet secondSheet7 = workbook.getSheetAt(7);
fillSheet(secondSheet10, returnDto.getPowerStationConstructionData()); fillSheet(secondSheet7, preparationMoneyDto);
Sheet secondSheet7 = workbook.getSheetAt(8); Sheet secondSheet8 = workbook.getSheetAt(8);
fillSheet(secondSheet7, returnDto.getHygfOnGrid()); fillSheet(secondSheet8, returnDto.getPowerStationConstructionData());
Sheet secondSheet8 = workbook.getSheetAt(9); Sheet secondSheet9 = workbook.getSheetAt(9);
fillSheet(secondSheet8, returnDto.getWorkOrder()); fillSheet(secondSheet9, returnDto.getHygfOnGrid());
Sheet secondSheet9 = workbook.getSheetAt(10); Sheet secondSheet10 = workbook.getSheetAt(10);
fillSheet(secondSheet9, returnDto.getAcceptanceCheck()); fillSheet(secondSheet10, returnDto.getWorkOrder());
Sheet secondSheet11 = workbook.getSheetAt(11); Sheet secondSheet11 = workbook.getSheetAt(11);
fillSheet(secondSheet11, powerStationWorkLog); fillSheet(secondSheet11, returnDto.getAcceptanceCheck());
Sheet secondSheet12 = workbook.getSheetAt(12); Sheet secondSheet12 = workbook.getSheetAt(12);
fillSheet(secondSheet12, workOrderStationWorkLog); fillSheet(secondSheet12, powerStationWorkLog);
Sheet secondSheet13 = workbook.getSheetAt(13); Sheet secondSheet13 = workbook.getSheetAt(13);
fillSheet(secondSheet13, basicGridWorkLog); if (CollectionUtil.isNotEmpty(preparationMoneyLog)){
fillSheet(secondSheet13, preparationMoneyLog);
}else if (CollectionUtil.isNotEmpty(preparationMoneyLog)){
fillSheet(secondSheet13, preparationMoneyDto != null?preparationMoneyDto.getPreparationMoneyLog():null);
}
Sheet secondSheet14 = workbook.getSheetAt(14); Sheet secondSheet14 = workbook.getSheetAt(14);
fillSheet(secondSheet14, accptWorkLog); fillSheet(secondSheet14, workOrderStationWorkLog);
Sheet secondSheet15 = workbook.getSheetAt(15); Sheet secondSheet15 = workbook.getSheetAt(15);
fillSheet(secondSheet15, financingWorkLog); fillSheet(secondSheet15, basicGridWorkLog);
Sheet secondSheet16 = workbook.getSheetAt(16);
fillSheet(secondSheet16, accptWorkLog);
Sheet secondSheet17 = workbook.getSheetAt(17);
fillSheet(secondSheet17, financingWorkLog);
// 写入到新的Excel文件中 // 写入到新的Excel文件中
try (FileOutputStream fos = new FileOutputStream(outputPath)) { try (FileOutputStream fos = new FileOutputStream(outputPath)) {
workbook.write(fos); workbook.write(fos);
...@@ -718,6 +785,20 @@ public class CommonServiceImpl { ...@@ -718,6 +785,20 @@ public class CommonServiceImpl {
})); }));
futures.add(executorService.submit(() -> { futures.add(executorService.submit(() -> {
try { try {
downloadAndZipImages(preparationMoneyDto,"发货信息附件",tempDir,urlPath);
if (!finalRedisKey.contains(",")){
Map<String, Object> map = (Map<String, Object>) redisUtils.get(finalRedisKey);
Integer currentNum = (Integer) map.get("value")+7;
redisUtils.set(finalRedisKey, MapBuilder.<String, Object>create()
.put("value", currentNum).build());
}
} catch (IOException e) {
e.printStackTrace();
}
}));
futures.add(executorService.submit(() -> {
try {
downloadAndZipImages(returnDto.getDesignInformation(),"设计信息附件",tempDir,urlPath); downloadAndZipImages(returnDto.getDesignInformation(),"设计信息附件",tempDir,urlPath);
if (!finalRedisKey.contains(",")){ if (!finalRedisKey.contains(",")){
Map<String, Object> map = (Map<String, Object>) redisUtils.get(finalRedisKey); Map<String, Object> map = (Map<String, Object>) redisUtils.get(finalRedisKey);
...@@ -898,11 +979,18 @@ public class CommonServiceImpl { ...@@ -898,11 +979,18 @@ public class CommonServiceImpl {
response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName+".zip", "UTF-8")); response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName+".zip", "UTF-8"));
createZipFile(ziLiaoDir, "批量资料",response); createZipFile(ziLiaoDir, "批量资料",response);
} }
private void autoSizeColumns(Sheet sheet) {
if (null != sheet.getRow(0) ){
for (int i = 0; i < sheet.getRow(0).getLastCellNum(); i++) {
sheet.autoSizeColumn(i);
}
}
}
private void fillSheet(Sheet sheet, Object data) { private void fillSheet(Sheet sheet, Object data) {
if (Objects.isNull(data)){ if (Objects.isNull(data)){
return; return;
} }
autoSizeColumns(sheet);
int startRow = 1; int startRow = 1;
for (int i = 0; i < sheet.getLastRowNum() + 1; i++) { for (int i = 0; i < sheet.getLastRowNum() + 1; i++) {
Row row = sheet.getRow(i); Row row = sheet.getRow(i);
...@@ -1266,6 +1354,29 @@ public class CommonServiceImpl { ...@@ -1266,6 +1354,29 @@ public class CommonServiceImpl {
} }
} }
if (sheet.getSheetName().contains("发货操作流水")) {
int startRowNum = 1;
if (null !=data){
int headerRow = startRowNum + 1; // 表头所在的行
int headerOneRow = startRowNum; // 表头所在的行
int dataStartRow = startRowNum+2; // 数据开始的行
startRowNum= dataStartRow +1;
// if ((data ){
// 假设表头内容如下:
String headerOne = "发货操作流水";
String[] headersNames = {"审核节点","审核人","审核时间", "审核状态", "审核意见"};
String[] headers = {"taskName","operator", "operateDate", "approvalStatue", "approvalSuggestion"};
documentSpecialProcessing(sheet,headerRow,headerOneRow,dataStartRow,headersNames,headers,headerOne, (List<Map<String, Object>>) data);
// }else {
//
//
// }
}
}
if (sheet.getSheetName().contains("审核记录")) { if (sheet.getSheetName().contains("审核记录")) {
int startRowNum = 1; int startRowNum = 1;
if (null !=data){ if (null !=data){
......
...@@ -87,7 +87,7 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina ...@@ -87,7 +87,7 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina
private RedisLockUtil redisLockUtil; private RedisLockUtil redisLockUtil;
@UserLimits @UserLimits
public Page<Map<String, Object>> queryForFinancingInfoPage(Page<Map<String, Object>> page, String type, String status, String regionalCompaniesCode, String ownersName, String region,String batchNo,String isHistory) { public Page<Map<String, Object>> queryForFinancingInfoPage(Page<Map<String, Object>> page, String type, String status, String regionalCompaniesCode, String ownersName, String region,String batchNo,String isHistory, String projectAddress, String peasantHouseholdNo, String developerName, String financingCompaniesName) {
StdUserEmpower orgCode = (StdUserEmpower) redisUtils.get("Emp_" + RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())); StdUserEmpower orgCode = (StdUserEmpower) redisUtils.get("Emp_" + RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken()));
ReginParams reginParams = JSON.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class); ReginParams reginParams = JSON.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
List<String> amosOrgCodes = orgCode.getAmosOrgCode(); List<String> amosOrgCodes = orgCode.getAmosOrgCode();
...@@ -101,6 +101,10 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina ...@@ -101,6 +101,10 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina
params.put("batchNo", batchNo); params.put("batchNo", batchNo);
params.put("isHistory", isHistory); params.put("isHistory", isHistory);
params.put("region", region); params.put("region", region);
params.put("projectAddress", projectAddress);
params.put("peasantHouseholdNo", peasantHouseholdNo);
params.put("developerName", developerName);
params.put("financingCompaniesName", financingCompaniesName);
// 1 投融人员 2.融资 3经销商管理员 // 1 投融人员 2.融资 3经销商管理员
switch (type) { switch (type) {
case "1": case "1":
......
...@@ -98,7 +98,7 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS ...@@ -98,7 +98,7 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
private RedisLockUtil redisLockUtil; private RedisLockUtil redisLockUtil;
public Page<PowerStationDto> queryForPowerStationUserRoles(Page<PowerStationDto> page, String powerStationCode, public Page<PowerStationDto> queryForPowerStationUserRoles(Page<PowerStationDto> page, String powerStationCode,
String ownersName, AgencyUserModel userInfo, String serviceAgent, String regionalCompaniesName, String processStatus,String province, String projectAddress, String status) { String ownersName, AgencyUserModel userInfo, String serviceAgent, String regionalCompaniesName, String processStatus,String province, String projectAddress, String status, String startTime, String endTime) {
// Map<Long, List<RoleModel>> orgRoles = userInfo.getOrgRoles(); // Map<Long, List<RoleModel>> orgRoles = userInfo.getOrgRoles();
// Collection<List<RoleModel>> roleModels = orgRoles.values(); // Collection<List<RoleModel>> roleModels = orgRoles.values();
// if(roleModels !=null){ // if(roleModels !=null){
...@@ -124,7 +124,7 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS ...@@ -124,7 +124,7 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
// this.queryForPowerStationPage(page,powerStationCode,ownersName,serviceAgent); // this.queryForPowerStationPage(page,powerStationCode,ownersName,serviceAgent);
Page<PowerStationDto> powerStationDtoPage = this.queryPage((int) page.getCurrent(), (int) page.getSize(), powerStationCode, ownersName, Page<PowerStationDto> powerStationDtoPage = this.queryPage((int) page.getCurrent(), (int) page.getSize(), powerStationCode, ownersName,
serviceAgent, regionalCompaniesName, processStatus,province, projectAddress, status); serviceAgent, regionalCompaniesName, processStatus,province, projectAddress, status, startTime, endTime);
// if(powerStationDtoPage.getRecords() != null && powerStationDtoPage.getRecords().size() > 0) { // if(powerStationDtoPage.getRecords() != null && powerStationDtoPage.getRecords().size() > 0) {
// powerStationDtoPage.getRecords().forEach(e -> { // powerStationDtoPage.getRecords().forEach(e -> {
...@@ -170,10 +170,10 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS ...@@ -170,10 +170,10 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
// 查询电站审核记录 // 查询电站审核记录
public Page<PowerStationDto> queryPage(int current, int size, String powerStationCode, String ownersName, public Page<PowerStationDto> queryPage(int current, int size, String powerStationCode, String ownersName,
String serviceAgent,String regionalCompaniesName,String processStatus,String province,String projectAddress, String status) { String serviceAgent,String regionalCompaniesName,String processStatus,String province,String projectAddress, String status, String startTime, String endTime) {
PageHelper.startPage(current, size); PageHelper.startPage(current, size);
List<PowerStationDto> list = powerStationMapper.queryPage(powerStationCode, ownersName, serviceAgent,regionalCompaniesName,processStatus,province, projectAddress, status); List<PowerStationDto> list = powerStationMapper.queryPage(powerStationCode, ownersName, serviceAgent,regionalCompaniesName,processStatus,province, projectAddress, status, startTime, endTime);
PageInfo<PowerStationDto> pages = new PageInfo(list); PageInfo<PowerStationDto> pages = new PageInfo(list);
com.baomidou.mybatisplus.extension.plugins.pagination.Page<PowerStationDto> pagenew = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<PowerStationDto>(); com.baomidou.mybatisplus.extension.plugins.pagination.Page<PowerStationDto> pagenew = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<PowerStationDto>();
......
...@@ -99,8 +99,6 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto ...@@ -99,8 +99,6 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
private HygfReplenishmentMapper hygfReplenishmentMapper; private HygfReplenishmentMapper hygfReplenishmentMapper;
@Autowired @Autowired
private WorkflowFeignClient workflowFeignClient; private WorkflowFeignClient workflowFeignClient;
@Autowired
private CommonServiceImpl commonService;
private static final String regionRedis = "app_region_redis"; private static final String regionRedis = "app_region_redis";
// private static final String PROCESSKEY = "DeliveryManagement"; // private static final String PROCESSKEY = "DeliveryManagement";
...@@ -1208,11 +1206,11 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto ...@@ -1208,11 +1206,11 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
} }
public IPage<Map<String,Object>> preparationStation(Integer current, Integer size, String preparationMoneyState,String ownersName,String regionalcompaniesSeq,String developerId,String state,String province, String projectAddress){ public IPage<Map<String,Object>> preparationStation(Integer current, Integer size, String preparationMoneyState,String ownersName,String regionalcompaniesSeq,String developerId,String state,String province, String projectAddress, String startTime, String endTime){
PageHelper.startPage(current, size); PageHelper.startPage(current, size);
List<Map<String, Object>> resultPage = preparationMoneyMapper.preparationStation(preparationMoneyState,ownersName,regionalcompaniesSeq,developerId,state,province, projectAddress); List<Map<String, Object>> resultPage = preparationMoneyMapper.preparationStation(preparationMoneyState,ownersName,regionalcompaniesSeq,developerId,state,province, projectAddress, startTime, endTime);
if(resultPage != null && resultPage.size() > 0) { if(resultPage != null && resultPage.size() > 0) {
resultPage.forEach(e -> { resultPage.forEach(e -> {
......
...@@ -106,7 +106,7 @@ public class StatisticsHomepageServiceImpl { ...@@ -106,7 +106,7 @@ public class StatisticsHomepageServiceImpl {
List<String> surveKeys = new ArrayList<>(Arrays.asList("未通过","未勘察","已完成(法务审核)","进行中(审核)")); List<String> surveKeys = new ArrayList<>(Arrays.asList("未通过","未勘察","已完成(法务审核)","进行中(审核)"));
List<String> contractKeys = new ArrayList<>(Arrays.asList("双方已签署","农户已签署","未签署","已作废")); List<String> contractKeys = new ArrayList<>(Arrays.asList("双方已签署","农户已签署","未签署","已作废"));
List<String> workOrder = new ArrayList<>(Arrays.asList("派工发料","未通过","施工资料已上传","完工登记","完工自审","审核中","已完成","整改待审核" ,"待整改")); List<String> workOrder = new ArrayList<>(Arrays.asList("未通过","施工资料上传","完工登记","完工自审","审核中","已完成","整改待审核" ,"待整改"));
List<String> preparationMoneyKeys = new ArrayList<>(Arrays.asList("待发货","已收货","已发货")); List<String> preparationMoneyKeys = new ArrayList<>(Arrays.asList("待发货","已收货","已发货"));
List<String> desionKeys = new ArrayList<>(Arrays.asList("施工图已上传","典设图已上传")); List<String> desionKeys = new ArrayList<>(Arrays.asList("施工图已上传","典设图已上传"));
List<String> gridKeys = new ArrayList<>(Arrays.asList("待登记","审核中","已完成","未通过","整改待审核" ,"待整改")); List<String> gridKeys = new ArrayList<>(Arrays.asList("待登记","审核中","已完成","未通过","整改待审核" ,"待整改"));
...@@ -204,14 +204,14 @@ public class StatisticsHomepageServiceImpl { ...@@ -204,14 +204,14 @@ public class StatisticsHomepageServiceImpl {
realScale += (double) map.get("realScale"); realScale += (double) map.get("realScale");
iterator.remove(); iterator.remove();
} }
if ("施工资料上传".equals(map.get("statusText"))) { if ("施工资料上传".equals(map.get("statusText"))) {
sgtotal += (long) map.get("total"); sgtotal += (long) map.get("total");
sgrealScale += (double) map.get("realScale"); sgrealScale += (double) map.get("realScale");
iterator.remove(); iterator.remove();
} }
} }
maps.add(MapBuilder.<String, Object>create().put("statusText","审核中").put("total",total).put("realScale",new BigDecimal(realScale).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue()).build()); maps.add(MapBuilder.<String, Object>create().put("statusText","审核中").put("total",total).put("realScale",new BigDecimal(realScale).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue()).build());
maps.add(MapBuilder.<String, Object>create().put("statusText","施工资料上传").put("total",sgtotal).put("realScale",new BigDecimal(sgrealScale).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue()).build()); maps.add(MapBuilder.<String, Object>create().put("statusText","施工资料上传").put("total",sgtotal).put("realScale",new BigDecimal(sgrealScale).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue()).build());
differenceValue(maps,workOrder); differenceValue(maps,workOrder);
resultMap.put("workOrder",maps); resultMap.put("workOrder",maps);
} }
...@@ -274,13 +274,13 @@ public class StatisticsHomepageServiceImpl { ...@@ -274,13 +274,13 @@ public class StatisticsHomepageServiceImpl {
if ("放款完成".equals(map.get("statusText"))) { if ("放款完成".equals(map.get("statusText"))) {
disbursementMoney += (double)map.get("disbursementMoney"); disbursementMoney += (double)map.get("disbursementMoney");
} }
if ("待推送".equals(map.get("statusText"))) { if ("未通过".equals(map.get("statusText"))) {
trtotal += (long) map.get("total"); trtotal += (long) map.get("total");
trrealScale += (double) map.get("realScale"); trrealScale += (double) map.get("realScale");
iterator2.remove(); iterator2.remove();
} }
} }
maps.add(MapBuilder.<String, Object>create().put("statusText","待推送").put("total",trtotal).put("realScale",new BigDecimal(trrealScale).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue()).build()); maps.add(MapBuilder.<String, Object>create().put("statusText","未通过").put("total",trtotal).put("realScale",new BigDecimal(trrealScale).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue()).build());
differenceValue(maps,financingKeys); differenceValue(maps,financingKeys);
resultMap.put("financing",maps); resultMap.put("financing",maps);
} }
......
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