Lianxun_Java.git

			@@ -15,6 +15,7 @@
			*/
			package com.java110.common.cmd.itemRelease;

			import com.alibaba.fastjson.JSONArray;
			import com.alibaba.fastjson.JSONObject;
			import com.java110.core.annotation.Java110Cmd;
			import com.java110.core.annotation.Java110Transactional;
			@@ -23,15 +24,29 @@
			import com.java110.core.event.cmd.CmdEvent;
			import com.java110.core.factory.GenerateCodeFactory;
			import com.java110.doc.annotation.*;
			import com.java110.dto.itemRelease.ItemReleaseDto;
			import com.java110.dto.itemRelease.ItemReleaseTypeDto;
			import com.java110.dto.oaWorkflow.OaWorkflowDto;
			import com.java110.dto.user.UserDto;
			import com.java110.intf.common.IItemReleaseResV1InnerServiceSMO;
			import com.java110.intf.common.IItemReleaseTypeV1InnerServiceSMO;
			import com.java110.intf.common.IItemReleaseV1InnerServiceSMO;
			import com.java110.intf.common.IOaWorkflowActivitiInnerServiceSMO;
			import com.java110.intf.oa.IOaWorkflowInnerServiceSMO;
			import com.java110.intf.user.IUserInnerServiceSMO;
			import com.java110.po.itemRelease.ItemReleasePo;
			import com.java110.po.itemRelease.ItemReleaseResPo;
			import com.java110.utils.exception.CmdException;
			import com.java110.utils.util.Assert;
			import com.java110.utils.util.BeanConvertUtil;
			import com.java110.utils.util.StringUtil;
			import com.java110.vo.ResultVo;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;

			import java.util.ArrayList;
			import java.util.List;

			@Java110CmdDoc(title = "申请物品放行",
			description = "申请物品放行",
			@@ -61,7 +76,29 @@
			)

			@Java110ExampleDoc(
			reqBody="{'typeId':'123','communityId':'123','applyCompany':'123','applyPerson':'123','idCard':'123','applyTel':'123','passTime':'123','amount':'123'}",
			reqBody="{\n" +
			"\t\"irId\": \"\",\n" +
			"\t\"typeId\": \"102023011264340006\",\n" +
			"\t\"applyCompany\": \"123123\",\n" +
			"\t\"applyPerson\": \"12312\",\n" +
			"\t\"idCard\": \"12312\",\n" +
			"\t\"applyTel\": \"18909711443\",\n" +
			"\t\"passTime\": \"2023-01-13 11:55:00\",\n" +
			"\t\"resNames\": [{\n" +
			"\t\t\"resName\": \"123\",\n" +
			"\t\t\"amount\": \"123\"\n" +
			"\t}],\n" +
			"\t\"state\": \"\",\n" +
			"\t\"carNum\": \"123123\",\n" +
			"\t\"remark\": \"123\",\n" +
			"\t\"audit\": {\n" +
			"\t\t\"assignee\": \"-2\",\n" +
			"\t\t\"staffId\": \"\",\n" +
			"\t\t\"staffName\": \"\",\n" +
			"\t\t\"taskId\": \"\"\n" +
			"\t},\n" +
			"\t\"communityId\": \"2022120695590004\"\n" +
			"}",
			resBody="{'code':0,'msg':'成功'}"
			)
			/**
			@@ -84,6 +121,22 @@
			@Autowired
			private IItemReleaseV1InnerServiceSMO itemReleaseV1InnerServiceSMOImpl;

			@Autowired
			private IItemReleaseResV1InnerServiceSMO itemReleaseResV1InnerServiceSMOImpl;

			@Autowired
			private IItemReleaseTypeV1InnerServiceSMO itemReleaseTypeV1InnerServiceSMOImpl;

			@Autowired
			private IOaWorkflowInnerServiceSMO oaWorkflowInnerServiceSMOImpl;

			@Autowired
			private IUserInnerServiceSMO userInnerServiceSMOImpl;

			@Autowired
			private IOaWorkflowActivitiInnerServiceSMO oaWorkflowActivitiInnerServiceSMOImpl;


			@Override
			public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
			Assert.hasKeyAndValue(reqJson, "typeId", "请求报文中未包含typeId");
			@@ -92,22 +145,108 @@
			Assert.hasKeyAndValue(reqJson, "idCard", "请求报文中未包含idCard");
			Assert.hasKeyAndValue(reqJson, "applyTel", "请求报文中未包含applyTel");
			Assert.hasKeyAndValue(reqJson, "passTime", "请求报文中未包含passTime");
			Assert.hasKeyAndValue(reqJson, "amount", "请求报文中未包含amount");
			Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId");

			//校验物品是否存在
			if(!reqJson.containsKey("resNames")){
			throw new CmdException("未包含物品");
			}

			JSONArray resNames = reqJson.getJSONArray("resNames");
			if(resNames == null \|\| resNames.size() < 1){
			throw new CmdException("未包含物品");
			}
			}

			@Override
			@Java110Transactional
			public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {

			String userId = cmdDataFlowContext.getReqHeaders().get("user-id");

			ItemReleaseTypeDto itemReleaseTypeDto = new ItemReleaseTypeDto();
			itemReleaseTypeDto.setTypeId(reqJson.getString("typeId"));
			itemReleaseTypeDto.setCommunityId(reqJson.getString("communityId"));
			List<ItemReleaseTypeDto> itemReleaseTypeDtos = itemReleaseTypeV1InnerServiceSMOImpl.queryItemReleaseTypes(itemReleaseTypeDto);
			Assert.listOnlyOne(itemReleaseTypeDtos,"未包含放行类型");

			OaWorkflowDto oaWorkflowDto = new OaWorkflowDto();
			oaWorkflowDto.setStoreId(itemReleaseTypeDtos.get(0).getStoreId());
			oaWorkflowDto.setFlowId(itemReleaseTypeDtos.get(0).getFlowId());
			List<OaWorkflowDto> oaWorkflowDtos = oaWorkflowInnerServiceSMOImpl.queryOaWorkflows(oaWorkflowDto);
			Assert.listOnlyOne(oaWorkflowDtos, "流程不存在");
			if (!OaWorkflowDto.STATE_COMPLAINT.equals(oaWorkflowDtos.get(0).getState())) {
			throw new IllegalArgumentException(oaWorkflowDtos.get(0).getFlowName() + "流程未部署");
			}

			if (StringUtil.isEmpty(oaWorkflowDtos.get(0).getProcessDefinitionKey())) {
			throw new IllegalArgumentException(oaWorkflowDtos.get(0).getFlowName() + "流程未部署");
			}

			//查询用户名称
			UserDto userDto = new UserDto();
			userDto.setUserId(userId);
			List<UserDto> userDtos = userInnerServiceSMOImpl.getUsers(userDto);
			Assert.listOnlyOne(userDtos, "用户不存在");


			ItemReleasePo itemReleasePo = BeanConvertUtil.covertBean(reqJson, ItemReleasePo.class);
			itemReleasePo.setIrId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
			itemReleasePo.setState(ItemReleaseDto.STATE_WAIT);
			itemReleasePo.setCreateUserId(userId);
			int flag = itemReleaseV1InnerServiceSMOImpl.saveItemRelease(itemReleasePo);

			if (flag < 1) {
			throw new CmdException("保存数据失败");
			}

			JSONArray resNames = reqJson.getJSONArray("resNames");
			JSONObject resNameObj = null;
			ItemReleaseResPo itemReleaseResPo = null;
			List<ItemReleaseResPo> itemReleaseResPos = new ArrayList<>();
			for(int resNameIndex = 0; resNameIndex< resNames.size(); resNameIndex++){
			resNameObj = resNames.getJSONObject(resNameIndex);
			itemReleaseResPo = new ItemReleaseResPo();
			itemReleaseResPo.setAmount(resNameObj.getString("amount"));
			itemReleaseResPo.setResName(resNameObj.getString("resName"));
			itemReleaseResPo.setResId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
			itemReleaseResPo.setIrId(itemReleasePo.getIrId());
			itemReleaseResPo.setCommunityId(itemReleasePo.getCommunityId());
			itemReleaseResPos.add(itemReleaseResPo);
			}

			flag = itemReleaseResV1InnerServiceSMOImpl.saveItemReleaseReses(itemReleaseResPos);

			if (flag < 1) {
			throw new CmdException("保存数据失败");
			}



			//启动任务
			JSONObject flowJson = new JSONObject();
			flowJson.put("processDefinitionKey", oaWorkflowDtos.get(0).getProcessDefinitionKey());
			flowJson.put("createUserId",userId);
			flowJson.put("flowId",oaWorkflowDtos.get(0).getFlowId());
			flowJson.put("id",itemReleasePo.getIrId());
			flowJson.put("auditMessage","提交审核");
			flowJson.put("storeId",itemReleaseTypeDtos.get(0).getStoreId());
			reqJson.put("processDefinitionKey", oaWorkflowDtos.get(0).getProcessDefinitionKey());
			JSONObject result = oaWorkflowActivitiInnerServiceSMOImpl.startProcess(flowJson);

			//提交者提交
			flowJson = new JSONObject();
			flowJson.put("processInstanceId",result.getString("processInstanceId"));
			flowJson.put("createUserId",userId);
			flowJson.put("nextUserId",reqJson.getJSONObject("audit").getString("staffId"));
			flowJson.put("storeId",itemReleaseTypeDtos.get(0).getStoreId());
			flowJson.put("id",itemReleasePo.getIrId());
			flowJson.put("flowId",oaWorkflowDtos.get(0).getFlowId());


			oaWorkflowActivitiInnerServiceSMOImpl.autoFinishFirstTask(flowJson);


			cmdDataFlowContext.setResponseEntity(ResultVo.success());
			}
			}