测试批量插入

ebc-sea-platform/src/main/java/com/ai/ipu/server/controller/TestController.java

@@ -0,0 +1,51 @@
package com.ai.ipu.server.controller;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.server.dao.interfaces.AreaInOutRecordDao;
import com.ai.ipu.server.service.interfaces.AreaInOutRecordService;
import com.github.pagehelper.PageInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.ArrayList;
import java.util.HashMap;
@Controller
@RequestMapping("/areaInOutRecord")
public class TestController {
	Logger logger = LoggerFactory.getLogger(TestController.class);
	@Autowired
	AreaInOutRecordDao areaInOutRecordDao;
	/**
	 * 分页查询作业考勤信息
	 */
	@ResponseBody
	@RequestMapping("/testInsert")
	public JMap testInsert() throws Exception {
		HashMap<String, Object> dataMap = new HashMap<>();
		ArrayList<Object> dataList = new ArrayList<>();
		for(int j = 0; j<10 ; j++){
			HashMap<String, Object> paramsMap = new HashMap<>();
			paramsMap.put("mapTagId",j);
			paramsMap.put("employeeId",j);
			paramsMap.put("deviceId",j);
			dataList.add(paramsMap);
		}
		dataMap.put("dataList",dataList );
		int i = areaInOutRecordDao.testInsert(dataMap);
		JMap result = new JsonMap();
		result.put("result", i);
		return result;
	}
}

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/impl/AreaInOutRecordDaoImpl.java

@@ -64,23 +64,29 @@ public class AreaInOutRecordDaoImpl extends AbstractBizDao implements AreaInOutR
	@Override
	public boolean addSameInTimeAreaInRecord(JMap params,List<Map<String, String>> mapTagInfoList) throws Exception {
		Map<String, Object> dataMap = new HashMap<String, Object>();
		
		dataMap.put("dataList", mapTagInfoList);
		dataMap.put("employeeId", 0);// TODO 人员ID
		dataMap.put("deviceId", params.get("deviceId"));
		dataMap.put("longitude", params.get("longitude"));
		dataMap.put("latitude", params.get("latitude"));
		dataMap.put("inDate", params.get("newDate"));
		dataMap.put("remarks", params.get("remarks"));
		
		dataMap.put("dataStatus", "1");
		//TODO 创建人和操作人的编号和部门
		dataMap.put("createDate", TimeUtil.getSysTime());
		dataMap.put("createOpId", "");
		dataMap.put("createOrgId", "");
		dataMap.put("doneDate", TimeUtil.getSysTime());
		dataMap.put("opId", "");
		dataMap.put("orgId", "");
		ArrayList<Object> dataList = new ArrayList<>();
		for(Map mapTagInfo: mapTagInfoList ){
			HashMap<String, Object> paramsMap = new HashMap<>();
			paramsMap.put("mapTagId",mapTagInfo.get("mapTagId"));
			paramsMap.put("recordLocation",mapTagInfo.get("recordLocation"));
			paramsMap.put("employeeId", 0);// TODO 人员ID
			paramsMap.put("deviceId", params.get("deviceId"));
			paramsMap.put("longitude", params.get("longitude"));
			paramsMap.put("latitude", params.get("latitude"));
			paramsMap.put("inDate", params.get("newDate"));
			paramsMap.put("remarks", params.get("remarks"));
			paramsMap.put("dataStatus", "1");
			//TODO 创建人和操作人的编号和部门
			paramsMap.put("createDate", TimeUtil.getSysTime());
			paramsMap.put("createOpId", "");
			paramsMap.put("createOrgId", "");
			paramsMap.put("doneDate", TimeUtil.getSysTime());
			paramsMap.put("opId", "");
			paramsMap.put("orgId", "");
			dataList.add(paramsMap);
		}
		dataMap.put("dataList",dataList );
		
		ISqlMgmtDao mgmtDao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
		int num = mgmtDao.executeInsert("ipu.AreaInOutRecordDao", "addSameInTimeRecordDao", dataMap);
@@ -109,6 +115,13 @@ public class AreaInOutRecordDaoImpl extends AbstractBizDao implements AreaInOutR
	}
	@Override
	public int testInsert(Map params)  throws Exception{
		ISqlMgmtDao mgmtDao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
		int num = mgmtDao.executeInsert("ipu.AreaInOutRecordDao", "testInsert", params);
		return num;
	}
	@Override
	public PageInfo queryPageAreaInOutRecordInfo(JMap params, int pageNum, int pageSize) throws Exception {
		return null;

ebc-sea-platform/src/main/java/com/ai/ipu/server/dao/interfaces/AreaInOutRecordDao.java

@@ -71,4 +71,6 @@ public interface AreaInOutRecordDao {
	PageInfo queryPageAreaInOutRecordInfoDetaile(JMap params, int pageNum, int pageSize) throws Exception;
	boolean updateSameOutTimeAreaOutRecord(String outDate,List<String> recordIdList) throws Exception;
	int testInsert(Map params)  throws Exception;
}

ebc-sea-platform/src/main/resources/sql/ipu/AreaInOutRecordDao.xml

@@ -12,21 +12,21 @@
	      	<foreach collection="dataList" item="item" separator=",">
	          (
	          	#{item.mapTagId},
	          	#{employeeId},
	          	#{deviceId},
	          	#{longitude},
	          	#{latitude},
	          	#{item.employeeId},
	          	#{item.deviceId},
	          	#{item.longitude},
	          	#{item.latitude},
	          	#{item.recordLocation},
	          	#{inDate},
	          	#{remarks},
				
				#{dataStatus},
				#{createDate},
				#{createOpId},
				#{createOrgId},
				#{doneDate},
				#{opId},
				#{orgId}
	          	#{item.inDate},
	          	#{item.remarks},
				#{item.dataStatus},
				#{item.createDate},
				#{item.createOpId},
				#{item.createOrgId},
				#{item.doneDate},
				#{item.opId},
				#{item.orgId}
	          )
	      	</foreach>
	      	
@@ -53,5 +53,24 @@
		</update>
		]]>
	</sql>
	
	<sql name="testInsert">
		<![CDATA[
			<insert id="testInsert" parameterType="java.util.Map" useGeneratedKeys="true" keyProperty="RECORD_ID">
	      	INSERT INTO LR_AREA_IN_OUT_RECORD (
			MAP_TAG_ID,EMPLOYEE_ID,DEVICE_ID
			) VALUES
	      	<foreach collection="dataList" item="item" separator=",">
	          (
	          	#{item.mapTagId},
	          	#{item.employeeId},
	          	#{item.deviceId}
	          )
	      	</foreach>
	    	</insert>
		]]>
	</sql>
</sqls>