新增任务

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/Enum/TaskTypeStationEnum.java

+package com.yeejoin.amos.boot.module.hygf.api.Enum;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+@Getter
+@AllArgsConstructor
+public enum  TaskTypeStationEnum {
+    经销商审核("经销商审核", "经销商审核"),
+    电站勘察("电站勘察", "电站勘察"),
+    电站审核("电站审核", "电站审核"),
+    合同填报("合同填报", "合同填报");
+    /**
+     * 名称，描述
+     */
+    private String name;
+    /**
+     * 编码
+     */
+    private String code;
+
+    public static TaskTypeStationEnum getNodeByCode(String code) {
+        TaskTypeStationEnum taskTypeStationEnum = null;
+        for(TaskTypeStationEnum type: TaskTypeStationEnum.values()) {
+            if (type.getCode().equals(code)) {
+                taskTypeStationEnum = type;
+                break;
+            }
+        }
+        return taskTypeStationEnum;
+    }
+}
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/PeasantHouseholdDto.java

@@ -100,6 +100,8 @@ public class PeasantHouseholdDto  extends BaseDto {
     @ApiModelProperty(value = "开发人")
     @NotBlank(message = "开发人不能为空")
     private String developer;
+    @ApiModelProperty(value = "开发人userid")
+    private String developerUserId;
 
     @ApiModelProperty(value = "常住地址")
     private String permanentAddressName;

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/PreparationMoneyDto.java

@@ -4,7 +4,6 @@ import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoneyLog;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import com.yeejoin.amos.boot.biz.common.dto.BaseDto;

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/TasksRole.java

+package com.yeejoin.amos.boot.module.hygf.api.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2023/9/11
+ */
+@Data
+public class TasksRole {
+
+    @ApiModelProperty(value = "用户id")
+    private String amosUserId;
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/ToDoTasksPageDto.java

+package com.yeejoin.amos.boot.module.hygf.api.dto;
+
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.hygf.api.entity.ToDoTasks;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2023/8/21
+ */
+@Data
+public class ToDoTasksPageDto extends Page<ToDoTasks> {
+
+
+
+    @ApiModelProperty(value = "任务类型")
+    private String type;
+
+
+    @ApiModelProperty(value = "任务状态")
+    private String state;
+
+    @ApiModelProperty(value = "用户id")
+    private String amosUserId;
+
+    @ApiModelProperty(value = "  任务创建时间")
+    private Date creationTime;
+
+    @ApiModelProperty(value = "完成时间")
+    private Date completeTime;
+
+    @ApiModelProperty(value = "任务名称")
+    private String taskName;
+
+
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/PeasantHousehold.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler;
 import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
@@ -139,6 +140,9 @@ public class PeasantHousehold extends BaseEntity {
 	* */
     @TableField("developer")
     private String developer;
+
+    @TableField("developer_user_id")
+    private String developerUserId;
     /*
      * 区域公司id
      * */

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/PersonnelBusinessMapper.xml

@@ -54,12 +54,12 @@ select  ORG_CODE orgCode from  privilege_company  where privilege_company.SEQUEN
 
     </select>
 
-    <select id="getCompanyDtoUserDtopage"  resultType="com.yeejoin.amos.boot.module.hygf.api.dto.UserUnitInformationDto">
+    <select id="getUserUnitInformationDto"  resultType="com.yeejoin.amos.boot.module.hygf.api.dto.UserUnitInformationDto">
     SELECT
 
     hygf_personnel_business.regional_companies_seq   regionalCompaniesSeq    ,
-    hygf_personnel_business.regional_companies_code   regionalCompaniesName  ,
-    hygf_personnel_business.regional_companies_name  regionalCompaniesCode   ,
+    hygf_personnel_business.regional_companies_code    regionalCompaniesCode ,
+    hygf_personnel_business.regional_companies_name  regionalCompaniesName   ,
 
     hygf_personnel_business.amos_unit_id   amosUnitId  ,
     hygf_personnel_business.amos_unit_name    amosUnitName ,
@@ -75,7 +75,8 @@ select  ORG_CODE orgCode from  privilege_company  where privilege_company.SEQUEN
 
     LEFT JOIN privilege_company on privilege_company.SEQUENCE_NBR=hygf_personnel_business.amos_dealer_id
 
-    WHERE std_user_biz.amos_user_id==#{id}
+
+    WHERE std_user_biz.amos_user_id=#{userId}
 
     </select>
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/HouseholdContractController.java

 package com.yeejoin.amos.boot.module.hygf.biz.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.HouseholdContractEnum;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.TaskTypeStationEnum;
 import com.yeejoin.amos.boot.module.hygf.api.dto.HouseholdContractPageDto;
+import com.yeejoin.amos.boot.module.hygf.api.dto.UserUnitInformationDto;
 import com.yeejoin.amos.boot.module.hygf.api.entity.HouseholdContract;
+import com.yeejoin.amos.boot.module.hygf.api.entity.PeasantHousehold;
+import com.yeejoin.amos.boot.module.hygf.api.entity.ToDoTasks;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.HouseholdContractMapper;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.PersonnelBusinessMapper;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.ToDoTasksMapper;
+import com.yeejoin.amos.boot.module.hygf.biz.service.impl.PeasantHouseholdServiceImpl;
 import com.yeejoin.amos.boot.module.hygf.biz.service.impl.QiyuesuoServiceImpl;
+import com.yeejoin.amos.boot.module.hygf.biz.service.impl.ToDoTasksServiceImpl;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
 import com.yeejoin.amos.feign.privilege.Privilege;
 import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.RequestMapping;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.Api;
@@ -51,7 +61,18 @@ public class HouseholdContractController extends BaseController {
     @Autowired
     QiyuesuoServiceImpl qiyuesuoServiceImpl;
 
+    @Autowired
+    ToDoTasksServiceImpl toDoTasksServiceImpl;
+
+    @Autowired
+    PeasantHouseholdServiceImpl peasantHouseholdServiceImpl;
 
+    @Value("${dealer.engineering}")
+    private String engineering;
+    @Autowired
+    PersonnelBusinessMapper personnelBusinessMapper;
+    @Autowired
+    ToDoTasksMapper toDoTasksMapper;
     /**
      * 新增
      *
@@ -125,7 +146,16 @@ public class HouseholdContractController extends BaseController {
 	@GetMapping(value = "/page")
 	@ApiOperation(httpMethod = "GET",value = "分页查询",  notes = "分页查询")
 	public ResponseModel<IPage< HouseholdContract > > queryForPage(HouseholdContractPageDto dto) {
-	    return ResponseHelper.buildResponse(householdContractServiceImpl.queryForPreparationMoneyPage(dto));
+
+
+        //获取用户所在经销商单位
+        UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto(getUserId());
+
+         if(userUnitInformationDto!=null&&userUnitInformationDto.getAmosDealerId()!=null){
+             dto.setDealerId(userUnitInformationDto.getAmosDealerId());
+         }
+
+        return ResponseHelper.buildResponse(householdContractServiceImpl.queryForPreparationMoneyPage(dto));
 	}
 
 	/**
@@ -159,6 +189,12 @@ public class HouseholdContractController extends BaseController {
         HouseholdContract householdContrac=  householdContractServiceImpl.getById(sequenceNbr);
         householdContrac.setSignStatus(HouseholdContractEnum.签字状态_已签字.getCode());
         householdContrac.setStatus(HouseholdContractEnum.合同状态_农户已签署.getCode());
+
+        //生成填报任务
+        ToDoTasks toDoTasks1=  new ToDoTasks (  TaskTypeStationEnum.合同填报.getCode(),  householdContrac.getSequenceNbr(),   TaskTypeStationEnum.合同填报.getCode(),householdContrac.getDealerCode());
+        toDoTasksServiceImpl.addToDoTasksByRole(engineering,toDoTasks1);
+
+
         return ResponseHelper.buildResponse(householdContractServiceImpl.updateById(householdContrac));
     }
     @TycloudOperation(ApiLevel = UserType.AGENCY)
@@ -166,28 +202,69 @@ public class HouseholdContractController extends BaseController {
     @ApiOperation(httpMethod = "Post", value = "盖章", notes = "盖章")
     public ResponseModel<Boolean> stamp(@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
 
+
+        return ResponseHelper.buildResponse(this.stampdata(sequenceNbr));
+    }
+
+    @Transactional
+    public boolean stampdata(Long sequenceNbr){
+
         HouseholdContract householdContrac=  householdContractServiceImpl.getById(sequenceNbr);
         householdContrac.setStampStatus(HouseholdContractEnum.盖章状态_已盖章.getCode());
         householdContrac.setSigningTime(new Date());
         householdContrac.setStatus(HouseholdContractEnum.合同状态_双方已签署.getCode());
         householdContrac.setSealedUser(getUserInfo().getRealName());
-        return ResponseHelper.buildResponse(householdContractServiceImpl.updateById(householdContrac));
+
+        LambdaQueryWrapper<ToDoTasks> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ToDoTasks::getType, TaskTypeStationEnum.合同填报.getCode());
+        wrapper.eq(ToDoTasks::getState, "待办");
+        wrapper.eq(ToDoTasks::getBusinessId, householdContrac.getSequenceNbr());
+        ToDoTasks doTasks= toDoTasksMapper.selectOne(wrapper);
+        if(doTasks!=null){
+            doTasks.setState("已办");
+            doTasks.setCompleteTime(new Date());
+            toDoTasksMapper.updateById(doTasks);
+        }
+
+        return householdContractServiceImpl.updateById(householdContrac);
+
+
     }
 
 
+
+
+
+
+
+
+
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping (value = "/cancel/{sequenceNbr}")
     @ApiOperation(httpMethod = "Post", value = "作废", notes = "作废")
     public ResponseModel<Boolean> cancel(@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
+        return ResponseHelper.buildResponse(this.canceldata(sequenceNbr));
+    }
+
+
 
+    @Transactional
+    public boolean canceldata(Long sequenceNbr){
         HouseholdContract householdContrac=  householdContractServiceImpl.getById(sequenceNbr);
         householdContrac.setStatus(HouseholdContractEnum.合同状态_已作废.getCode());
+        LambdaQueryWrapper<ToDoTasks> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ToDoTasks::getType, TaskTypeStationEnum.合同填报.getCode());
+        wrapper.eq(ToDoTasks::getState, "待办");
+        wrapper.eq(ToDoTasks::getBusinessId, householdContrac.getSequenceNbr());
+        ToDoTasks doTasks= toDoTasksMapper.selectOne(wrapper);
+        if(doTasks!=null){
+            doTasks.setState("作废");
+            toDoTasksMapper.updateById(doTasks);
+        }
+        return householdContractServiceImpl.updateById(householdContrac);
 
-        return ResponseHelper.buildResponse(householdContractServiceImpl.updateById(householdContrac));
     }
 
-
-
     @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
     @GetMapping(value = "/sealId/tree")
     @ApiOperation(httpMethod = "GET", value = "印章", notes = "印章")

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/PeasantHouseholdWxController.java

@@ -3,9 +3,11 @@ package com.yeejoin.amos.boot.module.hygf.biz.controller;
 import com.alibaba.fastjson.JSONArray;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.TaskTypeStationEnum;
 import com.yeejoin.amos.boot.module.hygf.api.dto.MobileLoginParamDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.PeasantHouseholdDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.PeasantHouseholdWxDto;
+import com.yeejoin.amos.boot.module.hygf.api.entity.ToDoTasks;
 import com.yeejoin.amos.boot.module.hygf.api.service.IWxService;
 import com.yeejoin.amos.boot.module.hygf.biz.service.impl.HouseholdContractServiceImpl;
 import com.yeejoin.amos.boot.module.hygf.biz.service.impl.PeasantHouseholdServiceImpl;
@@ -164,6 +166,7 @@ public class PeasantHouseholdWxController extends BaseController {
             }
         }
         PeasantHouseholdDto result = peasantHouseholdServiceImpl.savePeasantHousehold(model, userInfo);
+
         return ResponseHelper.buildResponse(result);
     }
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/PersonnelBusinessController.java

@@ -208,7 +208,7 @@ public class PersonnelBusinessController extends BaseController {
     public ResponseModel<UserDataDto> czPassword(String id) {
         PublicAgencyUser publicAgencyUser= publicAgencyUserMapper.selectById(id);
 
-        FeignClientResult<List<String>> data=Privilege.agencyUserClient.restorePassword(publicAgencyUser.getAmosUserId());
+        FeignClientResult data=Privilege.agencyUserClient.restorePassword(publicAgencyUser.getAmosUserId());
 
         if(data==null||data.getResult()==null){
             throw new BadRequest("修改状态失败！");

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/UnitInfoController.java

@@ -373,7 +373,10 @@ public class UnitInfoController extends BaseController {
 		String code = "";
 		Random random = new Random();
 		for (int i = 0; i < 6; i++) {
-			int r = random.nextInt(10)+1;
+			int r = random.nextInt(10);
+			if(r==0){
+			    r=1;
+            }
 			code = code + r;
 		}
 		return code;
@@ -562,7 +565,7 @@ public class UnitInfoController extends BaseController {
         Collection<GroupModel> chil =new ArrayList<>();
         for (GroupModel child : children) {
             if("户用光伏-经销商".equals(child.getGroupName())||"用户光伏-微信农户".equals(child.getGroupName())){
-
+            //排除其余角色
             }else{
                 chil.add(child);
             }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/DealerReviewServiceImpl.java

 package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.DealerReviewEnum;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.TaskTypeStationEnum;
 import com.yeejoin.amos.boot.module.hygf.api.dto.DealerReviewDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.ReviewDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.UnitInfoDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.WorkDto;
 import com.yeejoin.amos.boot.module.hygf.api.entity.DealerReview;
+import com.yeejoin.amos.boot.module.hygf.api.entity.ToDoTasks;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.DealerReviewMapper;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.ToDoTasksMapper;
 import com.yeejoin.amos.boot.module.hygf.api.service.IDealerReviewService;
 import com.yeejoin.amos.boot.module.hygf.biz.feign.WorkflowFeignClient;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
@@ -21,6 +26,7 @@ import org.springframework.stereotype.Service;
 import org.typroject.tyboot.core.foundation.exception.BaseException;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 
+import java.util.Date;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -34,12 +40,16 @@ import java.util.stream.Collectors;
 public class DealerReviewServiceImpl extends BaseService<DealerReviewDto, DealerReview, DealerReviewMapper> implements IDealerReviewService {
     @Autowired
     DealerReviewMapper dealerReviewMapper;
-    private static final String IDX_REQUEST_STATE="200";
+    private static final String IDX_REQUEST_STATE = "200";
     @Autowired
     WorkflowFeignClient workflowFeignClient;
 
     @Autowired
     AmosRequestContext requestContext;
+    @Autowired
+    ToDoTasksServiceImpl toDoTasksServiceImpl;
+    @Autowired
+    ToDoTasksMapper toDoTasksMapper;
 
     @Value("${amos.system.user.product}")
     private String AMOS_STUDIO_WEB;
@@ -48,10 +58,10 @@ public class DealerReviewServiceImpl extends BaseService<DealerReviewDto, Dealer
 
 
     @Override
-    public  com.baomidou.mybatisplus.extension.plugins.pagination.Page<ReviewDto> queryForDealerReviewPage(int pageNum, int pageSize,  ReviewDto reviewDto){
-        PageHelper.startPage(pageNum,  pageSize);
-        List<ReviewDto> list= dealerReviewMapper.queryForDealerReviewPage(reviewDto);
-        PageInfo<ReviewDto> page=new PageInfo(list);
+    public com.baomidou.mybatisplus.extension.plugins.pagination.Page<ReviewDto> queryForDealerReviewPage(int pageNum, int pageSize, ReviewDto reviewDto) {
+        PageHelper.startPage(pageNum, pageSize);
+        List<ReviewDto> list = dealerReviewMapper.queryForDealerReviewPage(reviewDto);
+        PageInfo<ReviewDto> page = new PageInfo(list);
         com.baomidou.mybatisplus.extension.plugins.pagination.Page<ReviewDto> pagenew = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<ReviewDto>();
         pagenew.setCurrent(pageNum);
         pagenew.setTotal(page.getTotal());
@@ -62,81 +72,99 @@ public class DealerReviewServiceImpl extends BaseService<DealerReviewDto, Dealer
 
     @Override
     public boolean saveDealerReview(DealerReview dealerReview, boolean flag, boolean token) {
-        try{
+        try {
             //流程节点code
             if (flag) {
-                String flowTaskIdnext = this.getTaskNoAuth(dealerReview.getProcessInstanceId(),token);
-                WorkDto workDto=this.getNodeInfoCode(flowTaskIdnext,token);
+                String flowTaskIdnext = this.getTaskNoAuth(dealerReview.getProcessInstanceId(), token);
+                WorkDto workDto = this.getNodeInfoCode(flowTaskIdnext, token);
                 dealerReview.setNextProcessNode(workDto.getNextProcessNode());
                 dealerReview.setNodeRole(workDto.getNodeRole());
                 dealerReview.setNodeRouting(workDto.getNodeRouting());
             }
-            return this.saveOrUpdate(dealerReview);
-        }catch (Exception e){
-            throw new BaseException("获取工作流节点失败！","400","获取工作流节点失败！");
+            boolean fl = this.saveOrUpdate(dealerReview);
+            if (flag) {
+                ToDoTasks toDoTasks = new ToDoTasks(TaskTypeStationEnum.经销商审核.getCode(), dealerReview.getSequenceNbr(), TaskTypeStationEnum.经销商审核.getCode(),null);
+                toDoTasksServiceImpl.addToDoTasksByRole(dealerReview.getNodeRole(), toDoTasks);
+            }else{
+                LambdaQueryWrapper<ToDoTasks> wrapper = new LambdaQueryWrapper<>();
+                wrapper.eq(ToDoTasks::getType, TaskTypeStationEnum.经销商审核.getCode());
+                wrapper.eq(ToDoTasks::getState, "待办");
+                wrapper.eq(ToDoTasks::getBusinessId, dealerReview.getSequenceNbr());
+                ToDoTasks doTasks= toDoTasksMapper.selectOne(wrapper);
+                if(doTasks!=null){
+                    doTasks.setState("已办");
+                    doTasks.setCompleteTime(new Date());
+                    toDoTasksMapper.updateById(doTasks);
+                }
+            }
+                return fl;
+
+
+        } catch (Exception e) {
+            throw new BaseException("获取工作流节点失败！", "400", "获取工作流节点失败！");
         }
     }
 
-    public WorkDto getNodeInfoCode(String flowTaskId,boolean token){
-        WorkDto workDto=null;
-        try{
-            FeignClientResult<JSONObject> jSONObject= null;
-            if(token){
-                jSONObject= workflowFeignClient.getNodeInfo(flowTaskId);
+    public WorkDto getNodeInfoCode(String flowTaskId, boolean token) {
+        WorkDto workDto = null;
+        try {
+            FeignClientResult<JSONObject> jSONObject = null;
+            if (token) {
+                jSONObject = workflowFeignClient.getNodeInfo(flowTaskId);
 
-            }else{
-                jSONObject= workflowFeignClient.getNodeInfotoken(AMOS_STUDIO, AMOS_STUDIO_WEB,requestContext.getToken(),flowTaskId);
+            } else {
+                jSONObject = workflowFeignClient.getNodeInfotoken(AMOS_STUDIO, AMOS_STUDIO_WEB, requestContext.getToken(), flowTaskId);
             }
 
-            if(IDX_REQUEST_STATE.equals(String.valueOf(jSONObject.getStatus()))){
-                JSONObject js=jSONObject.getResult();
-                if(js==null){
-                    throw new BaseException("获取工作流节点失败！","400","获取工作流节点失败！");
+            if (IDX_REQUEST_STATE.equals(String.valueOf(jSONObject.getStatus()))) {
+                JSONObject js = jSONObject.getResult();
+                if (js == null) {
+                    throw new BaseException("获取工作流节点失败！", "400", "获取工作流节点失败！");
                 }
-                LinkedHashMap  taskInfo= js.get("taskInfo")!=null?(LinkedHashMap)js.get("taskInfo"):null;
-                String nextProcessNode=taskInfo!=null?taskInfo.get("taskDefinitionKey").toString():null;
-                List<LinkedHashMap>  executor= js.get("executor")!=null?( List<LinkedHashMap>)js.get("executor"):null;
-                String nodeRole=null;
-                if(!executor.isEmpty()){
-                    List<String> idList = executor.stream().map(e->e.get("groupId").toString()).collect(Collectors.toList());
-                    nodeRole= StringUtils.join(idList,",");
+                LinkedHashMap taskInfo = js.get("taskInfo") != null ? (LinkedHashMap) js.get("taskInfo") : null;
+                String nextProcessNode = taskInfo != null ? taskInfo.get("taskDefinitionKey").toString() : null;
+                List<LinkedHashMap> executor = js.get("executor") != null ? (List<LinkedHashMap>) js.get("executor") : null;
+                String nodeRole = null;
+                if (!executor.isEmpty()) {
+                    List<String> idList = executor.stream().map(e -> e.get("groupId").toString()).collect(Collectors.toList());
+                    nodeRole = StringUtils.join(idList, ",");
                 }
 
-                LinkedHashMap  extensionInfo= js.get("extensionInfo")!=null?(LinkedHashMap)js.get("extensionInfo"):null;
-                String nodeRouting=extensionInfo!=null?extensionInfo.get("nodeRole").toString():null;
+                LinkedHashMap extensionInfo = js.get("extensionInfo") != null ? (LinkedHashMap) js.get("extensionInfo") : null;
+                String nodeRouting = extensionInfo != null ? extensionInfo.get("nodeRole").toString() : null;
 
-                workDto=new WorkDto(nodeRouting,  nodeRole,  nextProcessNode);
+                workDto = new WorkDto(nodeRouting, nodeRole, nextProcessNode);
             }
 
-            return  workDto;
-        }catch (Exception e){
+            return workDto;
+        } catch (Exception e) {
             e.printStackTrace();
-            throw new  BaseException("获取工作流节点失败！","400","获取工作流节点失败！");
+            throw new BaseException("获取工作流节点失败！", "400", "获取工作流节点失败！");
 
         }
     }
 
-    public String getTaskNoAuth(String processInstanceId,boolean token){
-        String flowTaskId=null;
-        try{
-            JSONObject jSONObject=null;
-            if(token){
-                jSONObject= workflowFeignClient.getTaskNoAuth(processInstanceId);
+    public String getTaskNoAuth(String processInstanceId, boolean token) {
+        String flowTaskId = null;
+        try {
+            JSONObject jSONObject = null;
+            if (token) {
+                jSONObject = workflowFeignClient.getTaskNoAuth(processInstanceId);
 
-            }else{
-                jSONObject= workflowFeignClient.getTaskNoAuthtoken(AMOS_STUDIO, AMOS_STUDIO_WEB,requestContext.getToken(),processInstanceId);
+            } else {
+                jSONObject = workflowFeignClient.getTaskNoAuthtoken(AMOS_STUDIO, AMOS_STUDIO_WEB, requestContext.getToken(), processInstanceId);
             }
-            if(IDX_REQUEST_STATE.equals(String.valueOf(jSONObject.get("code")))){
-                LinkedHashMap jsd= jSONObject.get("data")!=null?(LinkedHashMap)jSONObject.get("data"):null;
-                flowTaskId=jsd!=null?jsd.get("id").toString():null;
+            if (IDX_REQUEST_STATE.equals(String.valueOf(jSONObject.get("code")))) {
+                LinkedHashMap jsd = jSONObject.get("data") != null ? (LinkedHashMap) jSONObject.get("data") : null;
+                flowTaskId = jsd != null ? jsd.get("id").toString() : null;
             }
-            if(flowTaskId==null){
-                throw new BaseException("获取工作流节点失败！","400","获取工作流节点失败！");
+            if (flowTaskId == null) {
+                throw new BaseException("获取工作流节点失败！", "400", "获取工作流节点失败！");
             }
-            return  flowTaskId;
-        }catch (Exception e){
+            return flowTaskId;
+        } catch (Exception e) {
             e.printStackTrace();
-            throw new  BaseException("获取工作流节点失败！","400","获取工作流节点失败！");
+            throw new BaseException("获取工作流节点失败！", "400", "获取工作流节点失败！");
 
         }
     }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/HouseholdContractServiceImpl.java

@@ -3,11 +3,9 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.HouseholdContractEnum;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.TaskTypeStationEnum;
 import com.yeejoin.amos.boot.module.hygf.api.dto.*;
-import com.yeejoin.amos.boot.module.hygf.api.entity.ContractTemplate;
-import com.yeejoin.amos.boot.module.hygf.api.entity.HouseholdContract;
-import com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoney;
-import com.yeejoin.amos.boot.module.hygf.api.entity.SealDictionary;
+import com.yeejoin.amos.boot.module.hygf.api.entity.*;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.ContractTemplateMapper;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.HouseholdContractMapper;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.SealDictionaryMapper;
@@ -49,7 +47,11 @@ public class HouseholdContractServiceImpl extends BaseService<HouseholdContractD
     @Autowired
     ContractTemplateMapper contractTemplateMapper;
 
+    @Autowired
+    ToDoTasksServiceImpl toDoTasksServiceImpl;
 
+    @Autowired
+    PeasantHouseholdServiceImpl peasantHouseholdServiceImpl;
     /**
      * 列表查询 示例
      */
@@ -186,7 +188,12 @@ public class HouseholdContractServiceImpl extends BaseService<HouseholdContractD
         householdContract.setContractLockId(contractLockId);
         householdContract.setInitiateStatus(HouseholdContractEnum.发起状态_已发起.getCode());
         householdContractMapper.updateById(householdContract);
-       return householdContract;
+        //创建农户待办
+
+        ToDoTasks toDoTasks1=  new ToDoTasks (  TaskTypeStationEnum.合同填报.getCode(),  householdContract.getSequenceNbr(),   TaskTypeStationEnum.合同填报.getCode(),householdContract.getDealerCode());
+        PeasantHousehold peasantHousehold=peasantHouseholdServiceImpl.getById(householdContract.getPeasantHouseholdId());
+        toDoTasksServiceImpl.addToDoTasksByUserId(peasantHousehold.getAmosUserId(),toDoTasks1);
+        return householdContract;
 
     }
 
@@ -287,7 +294,15 @@ public class HouseholdContractServiceImpl extends BaseService<HouseholdContractD
         householdContract.setContractLockId(contractLockId);
         householdContract.setInitiateStatus(HouseholdContractEnum.发起状态_已发起.getCode());
         householdContractMapper.updateById(householdContract);
-        return householdContract;
+
+         //生成填报任务
+         ToDoTasks toDoTasks1=  new ToDoTasks (  TaskTypeStationEnum.合同填报.getCode(),  householdContract.getSequenceNbr(),   TaskTypeStationEnum.合同填报.getCode(),householdContract.getDealerCode());
+         PeasantHousehold peasan=peasantHouseholdServiceImpl.getById(householdContract.getPeasantHouseholdId());
+         toDoTasksServiceImpl.addToDoTasksByUserId(peasan.getAmosUserId(),toDoTasks1);
+
+
+
+         return householdContract;
 
     }
 

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/PeasantHouseholdServiceImpl.java

@@ -6,14 +6,9 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.PeasantHouseholdEnum;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.PhoneRegisterTypeEum;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.TaskTypeStationEnum;
 import com.yeejoin.amos.boot.module.hygf.api.dto.*;
-import com.yeejoin.amos.boot.module.hygf.api.entity.Commercial;
-import com.yeejoin.amos.boot.module.hygf.api.entity.ExtendedInformation;
-import com.yeejoin.amos.boot.module.hygf.api.entity.HouseholdContract;
-import com.yeejoin.amos.boot.module.hygf.api.entity.Information;
-import com.yeejoin.amos.boot.module.hygf.api.entity.PeasantHousehold;
-import com.yeejoin.amos.boot.module.hygf.api.entity.SurveyDetails;
-import com.yeejoin.amos.boot.module.hygf.api.entity.UnitInfo;
+import com.yeejoin.amos.boot.module.hygf.api.entity.*;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.PeasantHouseholdMapper;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.PersonnelBusinessMapper;
 import com.yeejoin.amos.boot.module.hygf.api.service.IPeasantHouseholdService;
@@ -148,6 +143,9 @@ public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto
     UnitInfoServiceImpl unitInfoServiceImpl;
     @Autowired
     AmosRequestContext requestContext;
+    @Autowired
+    ToDoTasksServiceImpl toDoTasksServiceImpl;
+
     public static final String SECRETKEY = "qaz";
 
     @Transactional (rollbackFor = Exception.class)
@@ -195,6 +193,13 @@ public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto
         householdContract.setProjectUserId(peasantHousehold.getAmosUserId());
         householdContractServiceImpl.addHouseholdContract(householdContract);
 
+        //生成待办任务
+        ToDoTasks toDoTasks=  new ToDoTasks (  TaskTypeStationEnum.电站勘察.getCode(),  peasantHousehold.getSequenceNbr(),   TaskTypeStationEnum.电站勘察.getCode(),householdContract.getDealerCode());
+        toDoTasksServiceImpl.addToDoTasksByUserId(peasantHousehold.getDeveloperUserId(),toDoTasks);
+
+        ToDoTasks toDoTasks1=  new ToDoTasks (  TaskTypeStationEnum.合同填报.getCode(),  householdContract.getSequenceNbr(),   TaskTypeStationEnum.合同填报.getCode(),householdContract.getDealerCode());
+        toDoTasksServiceImpl.addToDoTasksByUserId(peasantHousehold.getDeveloperUserId(),toDoTasks1);
+
         return model;
     }
 
@@ -319,13 +324,14 @@ public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto
                 peasantHousehold.setReview(0);
                 peasantHousehold.setTelephone(phoneNo);
                 PeasantHouseholdDto peasantHouseholdDto = buildDefaultPeasantHouseholdDto(wxDTO.getAmosUserId(), wxDTO.getQrCodeType(), phoneNo);
-                peasantHousehold.setDeveloperCode(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloperCode).orElse(""));// 开发方code
+                peasantHousehold.setDeveloperCode(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloperCode).orElse(null));// 开发方code
                 peasantHousehold.setDeveloperId(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloperId).orElse(null));// 开发方id
-                peasantHousehold.setDeveloperName(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloperName).orElse(""));// 开发方名称
-                peasantHousehold.setDeveloper(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloper).orElse(""));// 开发人
+                peasantHousehold.setDeveloperName(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloperName).orElse(null));// 开发方名称
+                peasantHousehold.setDeveloper(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloper).orElse(null));// 开发人
+                peasantHousehold.setDeveloperUserId(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getDeveloperUserId).orElse(null));
                 peasantHousehold.setRegionalCompaniesSeq(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getRegionalCompaniesSeq).orElse(null));
-                peasantHousehold.setRegionalCompaniesCode(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getRegionalCompaniesCode).orElse(""));
-                peasantHousehold.setRegionalCompaniesName(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getRegionalCompaniesName).orElse(""));
+                peasantHousehold.setRegionalCompaniesCode(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getRegionalCompaniesCode).orElse(null));
+                peasantHousehold.setRegionalCompaniesName(Optional.ofNullable(peasantHouseholdDto).map(PeasantHouseholdDto::getRegionalCompaniesName).orElse(null));
                 peasantHousehold.setIsCertified(0);
                 // 过滤传给前端的数据
                 this.save(peasantHousehold);
@@ -510,6 +516,7 @@ public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto
         dto.setDeveloperId(sequenceNbr);// 开发方id
         dto.setDeveloperName(companyName);// 开发方名称
         dto.setDeveloper(userInfo.getRealName());// 开发人
+        dto.setDeveloperUserId(userInfo.getUserId());
 //        UnitInfo unitInfo;
 //        if (!CollectionUtils.isEmpty(unitInfos)) {
 //            log.warn("userId:{} 查询不到经销商信息", userInfo.getUserId());

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/PowerStationServiceImpl.java

@@ -7,18 +7,13 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.HouseholdContractEnum;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.PowerStationNodeEnum;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.PowerStationProcessStateEnum;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.TaskTypeStationEnum;
 import com.yeejoin.amos.boot.module.hygf.api.dto.PowerStationDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.UserUnitInformationDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.WorkDto;
-import com.yeejoin.amos.boot.module.hygf.api.entity.DesignInformation;
-import com.yeejoin.amos.boot.module.hygf.api.entity.HouseholdContract;
-import com.yeejoin.amos.boot.module.hygf.api.entity.PeasantHousehold;
-import com.yeejoin.amos.boot.module.hygf.api.entity.PowerStation;
+import com.yeejoin.amos.boot.module.hygf.api.entity.*;
 import com.yeejoin.amos.boot.module.hygf.api.fegin.IdxFeginService;
-import com.yeejoin.amos.boot.module.hygf.api.mapper.DesignInformationMapper;
-import com.yeejoin.amos.boot.module.hygf.api.mapper.HouseholdContractMapper;
-import com.yeejoin.amos.boot.module.hygf.api.mapper.PersonnelBusinessMapper;
-import com.yeejoin.amos.boot.module.hygf.api.mapper.PowerStationMapper;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.*;
 import com.yeejoin.amos.boot.module.hygf.api.service.IPowerStationService;
 import com.yeejoin.amos.boot.module.hygf.biz.feign.WorkflowFeignClient;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
@@ -35,12 +30,7 @@ import org.typroject.tyboot.core.rdbms.service.BaseService;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -75,6 +65,10 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
     HouseholdContractServiceImpl householdContractServiceImpl;
     @Autowired
     PersonnelBusinessMapper personnelBusinessMapper;
+    @Autowired
+    ToDoTasksMapper toDoTasksMapper;
+    @Autowired
+    ToDoTasksServiceImpl toDoTasksServiceImpl;
 
     public Page<PowerStationDto> queryForPowerStationUserRoles(Page<PowerStationDto> page, String powerStationCode, String ownersName, AgencyUserModel userInfo){
         String serviceAgent =null;
@@ -128,7 +122,30 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
                 powerStation.setNodeRole(workDto.getNodeRole());
                 powerStation.setNodeRouting(workDto.getNodeRouting());
             }
-            return this.saveOrUpdate(powerStation);
+            Boolean fl= this.saveOrUpdate(powerStation);
+            if (flag){
+
+                //获取经销商orgcode
+                PeasantHousehold peasantHouseholdd=   peasantHouseholdService.getById(powerStation.getPeasantHouseholdId());
+
+                ToDoTasks toDoTasks=  new ToDoTasks (  TaskTypeStationEnum.电站审核.getCode(),  powerStation.getSequenceNbr(),   TaskTypeStationEnum.电站审核.getCode(),peasantHouseholdd.getDeveloperCode());
+                toDoTasksServiceImpl.addToDoTasksByRole(powerStation.getNodeRole(),toDoTasks);
+
+            }else{
+                LambdaQueryWrapper<ToDoTasks> wrapper = new LambdaQueryWrapper<>();
+                wrapper.eq(ToDoTasks::getType, TaskTypeStationEnum.电站审核.getCode());
+                wrapper.eq(ToDoTasks::getState, "待办");
+                wrapper.eq(ToDoTasks::getBusinessId, powerStation.getSequenceNbr());
+                ToDoTasks doTasks= toDoTasksMapper.selectOne(wrapper);
+                if(doTasks!=null){
+                    doTasks.setState("已办");
+                    doTasks.setCompleteTime(new Date());
+
+                    toDoTasksMapper.updateById(doTasks);
+                }
+            }
+
+            return fl;
         }catch (Exception e){
             throw new  BaseException("获取工作流节点失败！","400","获取工作流节点失败！");
         }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/SurveyInformationServiceImpl.java

@@ -265,14 +265,13 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
 
 
         //获取用户所在经销商单位
-        UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto(userInfo.getUserId());
-
-
+        UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto(peasantHousehold.getDeveloperUserId());
 
         BeanUtils.copyProperties(peasantHousehold, surveyInfoAllDto.getSurveyInformation());
         surveyInfoAllDto.getSurveyInformation().setDeveloperName(userUnitInformationDto.getAmosDealerName());
         surveyInfoAllDto.getSurveyInformation().setDeveloperCode(userUnitInformationDto.getAmosDealerOrgCode());
         surveyInfoAllDto.getSurveyInformation().setDeveloperId(userUnitInformationDto.getAmosDealerId());
+
         surveyInfoAllDto.getSurveyInformation().setSalesmanId(userInfo.getUserId());
         surveyInfoAllDto.getSurveyInformation().setSalesman(userInfo.getRealName());
         surveyInfoAllDto.getSurveyInformation().setCreator(userInfo.getRealName());

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/UnitInfoServiceImpl.java

@@ -506,8 +506,8 @@ public class UnitInfoServiceImpl extends BaseService<UnitInfoDto,UnitInfo,UnitIn
         BeanUtils.copyProperties(unitInfo,unitInformation);
         unitInformation.setHeadCardPhotoBack(unitInformation.getHeadCardPhotoBack());
         unitInformation.setHeadCardPhotoFront(unitInformation.getHeadCardPhotoFront());
-        unitInformation.setRegisterPcdCode(unitInformation.getRegisterPcdCode());
-        unitInformation.setWorkPcdCode(unitInformation.getWorkPcdCode());
+        unitInformation.setRegisterPcdCode((unitInformation.getRegisterPcdCode()!=null&&!"".equals(unitInformation.getRegisterPcdCode()))?unitInformation.getRegisterPcdCode():null);
+        unitInformation.setWorkPcdCode((unitInformation.getWorkPcdCode()!=null&&!"".equals(unitInformation.getWorkPcdCode()))?unitInformation.getWorkPcdCode():null);
         BeanUtils.copyProperties(commerceInfo,commerceDto);
         commerceDto.setBusinessLicensePhoto(commerceDto.getBusinessLicensePhoto());
         commerceDto.setLegalPersonCardPhotoBack(commerceDto.getLegalPersonCardPhotoBack());
@@ -545,7 +545,7 @@ public class UnitInfoServiceImpl extends BaseService<UnitInfoDto,UnitInfo,UnitIn
                        }
                    }
                }
-               unitInformation.setRegisterPcd(codenameRegi!=null?codenameRegi.toString():null);
+               unitInformation.setRegisterPcd(codenameRegi!=null&&!"".equals(codenameRegi.toString())?codenameRegi.toString():null);
            }
 
            //办公地址
@@ -561,7 +561,7 @@ public class UnitInfoServiceImpl extends BaseService<UnitInfoDto,UnitInfo,UnitIn
                        }
                    }
                }
-               unitInformation.setWorkPcd(codenamework!=null?codenamework.toString():null);
+               unitInformation.setWorkPcd(codenamework!=null&&!"".equals(codenamework.toString())?codenamework.toString():null);
            }
        unitInformation.setHeadCardPhotoBackUrl(unitInformation.getHeadCardPhotoBackUrl());
        unitInformation.setHeadCardPhotoFrontUrl(unitInformation.getHeadCardPhotoFrontUrl());
@@ -587,10 +587,10 @@ public class UnitInfoServiceImpl extends BaseService<UnitInfoDto,UnitInfo,UnitIn
        List<CompanyModel>  companyModel = (List<CompanyModel>)feignClientResult.getResult();
        List<String>  lisd=unitInfo.getRegionalCompaniesSeq();
        if(companyModel!=null&&!companyModel.isEmpty()&&lisd!=null&&!lisd.isEmpty()){
-           for (String aLong : lisd) {
+           for (Object aLong : lisd) {
                for (CompanyModel compan : companyModel) {
-                   if(compan.getSequenceNbr().longValue()==Long.valueOf(aLong).longValue()){
-                       RegionalCompanies re=  new RegionalCompanies(Long.valueOf(aLong), compan.getCompanyName(), compan.getOrgCode(), unitInfo.getSequenceNbr());
+                   if(compan.getSequenceNbr().longValue()==Long.valueOf(aLong.toString()).longValue()){
+                       RegionalCompanies re=  new RegionalCompanies(Long.valueOf(aLong.toString()), compan.getCompanyName(), compan.getOrgCode(), unitInfo.getSequenceNbr());
                        regionalComp.add(re);
                        continue;
                    }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/resources/application-dev.properties

@@ -43,9 +43,9 @@ lettuce.timeout=10000
 
 emqx.clean-session=true
 emqx.client-id=${spring.application.name}-${random.int[1024,65536]}
-emqx.broker=tcp://172.16.3.18:2883
-emqx.user-name=super
-emqx.password=a123456
+emqx.broker=tcp://172.16.10.220:1883
+emqx.user-name=admin
+emqx.password=public
 emqx.max-inflight=1000
 
 
@@ -133,6 +133,7 @@ hygfProgram.secret=3bfd098cfdac002126e728d2dbf83c0d
 farmer.orgCode=86
 farmer.sequenceNbr=1620981815542046722
 farmer.orgNamesWithoutRole=
+#农户角色
 farmer.roleId=1693501363645845505
 # 配置接口授权用户
 platform.access.loginId=hygf_platform
@@ -148,4 +149,8 @@ dealer.managementUnitId=1678209772383399937
 dealer.roleId=1678211468450885633
 
 #查询经销商用户组
-dealer.group=1681241774938419202
+dealer.group=1681241774938419202
\ No newline at end of file
+
+#户用光伏工程角色
+
+dealer.engineering=1679674919488614401
\ No newline at end of file